mianbin/ops-pro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
HopeLi 2025-07-04 10:10:00 +08:00
parent 4b9cebb1bd
commit fedcb039db
3 changed files with 19 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/aflManager/impl/AflCrashesInfoServiceImpl.java
View File

@ -7,6 +7,7 @@ import cd.casic.ci.process.process.service.aflManager.AflCrashesInfoService;
import cd.casic.ci.process.util.SftpUploadUtil; import cd.casic.ci.process.util.SftpUploadUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
@ -48,8 +49,12 @@ public class AflCrashesInfoServiceImpl extends ServiceImpl<AflCrashesInfoDao, Af
AflCrashesInfo aflCrashesInfo = new AflCrashesInfo(); AflCrashesInfo aflCrashesInfo = new AflCrashesInfo();
aflCrashesInfo.setFilePath(o); aflCrashesInfo.setFilePath(o);
aflCrashesInfo.setPipelineId(req.getPipelineId()); aflCrashesInfo.setPipelineId(req.getPipelineId());
aflCrashesInfo.setTaskId(req.getTaskId()); if (!StringUtils.isEmpty(req.getTaskId())){
aflCrashesInfo.setPipelineHistoryId(req.getPipelineHistoryId()); aflCrashesInfo.setTaskId(req.getTaskId());
}
if (!StringUtils.isEmpty(req.getPipelineHistoryId())){
aflCrashesInfo.setPipelineHistoryId(req.getPipelineHistoryId());
}
aflCrashesInfos.add(aflCrashesInfo); aflCrashesInfos.add(aflCrashesInfo);
}); });
baseMapper.insertBatch(aflCrashesInfos); baseMapper.insertBatch(aflCrashesInfos);

8
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/aflManager/impl/AflInfoServiceImpl.java
View File

@ -48,8 +48,12 @@ public class AflInfoServiceImpl extends ServiceImpl<AflInfoDao, AflInfo> impleme
aflInfo.setFilePath(strings.get(0)); aflInfo.setFilePath(strings.get(0));
aflInfo.setPipelineId(req.getPipelineId()); aflInfo.setPipelineId(req.getPipelineId());
aflInfo.setTaskId(req.getTaskId()); if (!StringUtils.isEmpty(req.getTaskId())){
aflInfo.setPipelineHistoryId(req.getPipelineHistoryId()); aflInfo.setTaskId(req.getTaskId());
}
if (!StringUtils.isEmpty(req.getPipelineHistoryId())){
aflInfo.setPipelineHistoryId(req.getPipelineHistoryId());
}
baseMapper.insert(aflInfo); baseMapper.insert(aflInfo);
return aflInfo.getId(); return aflInfo.getId();

8
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/aflManager/impl/AflSeedInfoServiceImpl.java
View File

@ -172,9 +172,13 @@ public class AflSeedInfoServiceImpl extends ServiceImpl<AflSeedInfoDao, AflSeedI
} }
aflSeedInfo.setFilePath(o); aflSeedInfo.setFilePath(o);
aflSeedInfo.setTaskId(req.getTaskId()); if (!StringUtils.isEmpty(req.getTaskId())){
aflSeedInfo.setTaskId(req.getTaskId());
}
if (!StringUtils.isEmpty(req.getPipelineHistoryId())){
aflSeedInfo.setPipelineHistoryId(req.getPipelineHistoryId());
}
aflSeedInfo.setPipelineId(req.getPipelineId()); aflSeedInfo.setPipelineId(req.getPipelineId());
aflSeedInfo.setPipelineHistoryId(req.getPipelineHistoryId());
aflSeedInfos.add(aflSeedInfo); aflSeedInfos.add(aflSeedInfo);
}); });