0714 ljc afl模块文件操作以及入库操作以及时序表操作等接口开发,包含分片代码以及文件工具类代码

This commit is contained in:
HopeLi 2025-07-14 09:45:15 +08:00
parent 560cebd6cf
commit 61733566d8
3 changed files with 10 additions and 10 deletions

View File

@ -131,19 +131,19 @@ public class AflManagerController {
} }
@PostMapping(path="/findAflPlotInfo") @PostMapping(path="/findAflPlotInfoNow")
public CommonResult<AflPlotInfoResp> findAflPlotInfo(@RequestBody @Valid AflManagerReq req) throws SftpUploadUtil.SftpUploadException { public CommonResult<AflPlotInfoResp> findAflPlotInfoNow(@RequestBody @Valid AflManagerReq req) throws SftpUploadUtil.SftpUploadException {
AflPlotInfoResp resp = aflPlotInfoService.findAflPlotInfo(req); AflPlotInfoResp resp = aflPlotInfoService.findAflPlotInfoNow(req);
return CommonResult.success(resp); return CommonResult.success(resp);
} }
@PostMapping(path="/findAflPlotInfoList") @PostMapping(path="/findAflPlotInfoListByHistory")
public CommonResult<List<AflPlotInfoResp>> findAflPlotInfoList(@RequestBody @Valid AflManagerReq req){ public CommonResult<List<AflPlotInfoResp>> findAflPlotInfoListByHistory(@RequestBody @Valid AflManagerReq req){
List<AflPlotInfoResp> respList = aflPlotInfoService.findAflPlotInfoList(req); List<AflPlotInfoResp> respList = aflPlotInfoService.findAflPlotInfoListByHistory(req);
return CommonResult.success(respList); return CommonResult.success(respList);
} }

View File

@ -20,9 +20,9 @@ public interface AflPlotInfoService extends IService<AflPlotInfo> {
String saveAflPlotInfo(@Valid AflManagerReq req) throws SftpUploadUtil.SftpUploadException; String saveAflPlotInfo(@Valid AflManagerReq req) throws SftpUploadUtil.SftpUploadException;
AflPlotInfoResp findAflPlotInfo(@Valid AflManagerReq req) throws SftpUploadUtil.SftpUploadException; AflPlotInfoResp findAflPlotInfoNow(@Valid AflManagerReq req) throws SftpUploadUtil.SftpUploadException;
List<AflPlotInfoResp> findAflPlotInfoList(@Valid AflManagerReq req); List<AflPlotInfoResp> findAflPlotInfoListByHistory(@Valid AflManagerReq req);
void updateHistoryPipelineIdByAflPlotInfo(@Valid AflManagerReq req); void updateHistoryPipelineIdByAflPlotInfo(@Valid AflManagerReq req);
} }

View File

@ -110,7 +110,7 @@ public class AflPlotInfoServiceImpl extends ServiceImpl<AflPlotInfoDao, AflPlotI
} }
@Override @Override
public AflPlotInfoResp findAflPlotInfo(AflManagerReq req) throws SftpUploadUtil.SftpUploadException { public AflPlotInfoResp findAflPlotInfoNow(AflManagerReq req) throws SftpUploadUtil.SftpUploadException {
if (StringUtils.isEmpty(req.getPipelineId()) || StringUtils.isEmpty(req.getTaskId())){ if (StringUtils.isEmpty(req.getPipelineId()) || StringUtils.isEmpty(req.getTaskId())){
throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(),"pipelineId或者taskId不能为空"); throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(),"pipelineId或者taskId不能为空");
} }
@ -139,7 +139,7 @@ public class AflPlotInfoServiceImpl extends ServiceImpl<AflPlotInfoDao, AflPlotI
} }
@Override @Override
public List<AflPlotInfoResp> findAflPlotInfoList(AflManagerReq req) { public List<AflPlotInfoResp> findAflPlotInfoListByHistory(AflManagerReq req) {
QueryWrapper<AflPlotInfo> wrapper = new QueryWrapper<>(); QueryWrapper<AflPlotInfo> wrapper = new QueryWrapper<>();
if (!ObjectUtils.isEmpty(req.getId())){ if (!ObjectUtils.isEmpty(req.getId())){
wrapper.eq("id",req.getId()); wrapper.eq("id",req.getId());