|
@@ -118,12 +118,12 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
if (isEmpty(param.getProjectName())) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "工作名称不能为空。");
|
|
|
}
|
|
|
- SimulationManualProjectPo po = convertParamToPo(param);
|
|
|
+ SimulationManualProjectPO po = convertParamToPo(param);
|
|
|
|
|
|
if (isEmpty(param.getId())) {
|
|
|
// 工作名称一样的的不能创建
|
|
|
- List<SimulationManualProjectPo> simulationManualProjectPos = simulationProjectMapper.selectProjectByName(param);
|
|
|
- if (!isEmpty(simulationManualProjectPos)) {
|
|
|
+ List<SimulationManualProjectPO> simulationManualProjectPOS = simulationProjectMapper.selectProjectByName(param);
|
|
|
+ if (!isEmpty(simulationManualProjectPOS)) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "工作名称已经存在,请修改后再保存。");
|
|
|
}
|
|
|
po.createPo(AuthUtil.getCurrentUserId());
|
|
@@ -136,7 +136,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "添加失败");
|
|
|
} else {
|
|
|
// 取工作状态,仅未开始的才可以修改信息
|
|
|
- SimulationManualProjectPo simulationManualProjectPo = simulationProjectMapper.selectProjectById(param);
|
|
|
+ SimulationManualProjectPO simulationManualProjectPo = simulationProjectMapper.selectProjectById(param);
|
|
|
if (!ProjectRunStateEnum.NOT_START.getCode().equals(simulationManualProjectPo.getNowRunState())) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "当前状态不支持修改。");
|
|
|
}
|
|
@@ -209,7 +209,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
if (isEmpty(param.getId())) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE);
|
|
|
}
|
|
|
- SimulationManualProjectPo po = simulationProjectMapper.selectProjectById(param);
|
|
|
+ SimulationManualProjectPO po = simulationProjectMapper.selectProjectById(param);
|
|
|
if (po == null) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "没有获取到数据。");
|
|
|
}
|
|
@@ -240,8 +240,8 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
String[] idArr = ids.split(",");
|
|
|
|
|
|
// 仅有执行中的不能删除
|
|
|
- List<SimulationManualProjectPo> pos = simulationProjectMapper.selectProjectNowRunState(idArr);
|
|
|
- for (SimulationManualProjectPo p : pos) {
|
|
|
+ List<SimulationManualProjectPO> pos = simulationProjectMapper.selectProjectNowRunState(idArr);
|
|
|
+ for (SimulationManualProjectPO p : pos) {
|
|
|
if (ProjectRunStateEnum.EXECUTION.getCode().equals(p.getNowRunState())) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "数据不支持删除。");
|
|
|
}
|
|
@@ -255,14 +255,16 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * 修改手动运行项目状态
|
|
|
+ * 1. 手动项目:第一次运行项目 10 -> 20
|
|
|
+ * 2. 手动项目:终止项目 20 -> 40
|
|
|
+ * 3. 手动项目:重新运行项目 40 -> 20
|
|
|
*/
|
|
|
@SneakyThrows
|
|
|
@Override
|
|
|
public ResponseBodyVO<String> updateProjectNowRunState(SimulationManualProjectParam param) {
|
|
|
|
|
|
// 1 查询项目详细信息
|
|
|
- SimulationManualProjectPo po = projectUtil.getProjectInfo(param);
|
|
|
+ SimulationManualProjectPO po = projectUtil.getProjectInfo(param);
|
|
|
// 2 项目终止信息直接推送
|
|
|
if (DictConstants.PROJECT_TERMINATED.equals(param.getNowRunState())) {
|
|
|
projectStopToKafka(po);
|
|
@@ -300,15 +302,21 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
log.info("项目 " + projectId + " 的详情信息为:" + infoJson);
|
|
|
// 保存项目详情信息
|
|
|
simulationProjectMapper.updateDetailsById(projectId, infoJson);
|
|
|
-// if (DictConstants.PROJECT_TERMINATED.equals(info.getNowRunState())) {
|
|
|
-//
|
|
|
-// }
|
|
|
- if ("20".equals(param.getNowRunState())) {
|
|
|
+ if (DictConstants.PROJECT_RUNNING.equals(param.getNowRunState())) {
|
|
|
+ if (DictConstants.PROJECT_TERMINATED.equals(info.getNowRunState())) {
|
|
|
+ // 如果是重新运行的项目,修改项目ID
|
|
|
+ SimulationManualProjectPO simulationManualProjectPO = new SimulationManualProjectPO();
|
|
|
+ simulationManualProjectPO.setId(projectId);
|
|
|
+ final String newId = StringUtil.getRandomUUID();
|
|
|
+ simulationManualProjectPO.setNewId(newId);
|
|
|
+ po.setId(newId);
|
|
|
+ simulationProjectMapper.updateIdById(simulationManualProjectPO); //此处注意事务
|
|
|
+ }
|
|
|
// 设置开始时间
|
|
|
param.setStartTime(new Date());
|
|
|
// Kafka推送消息
|
|
|
projectRunToKafka(po);
|
|
|
- } else if ("30".equals(param.getNowRunState())) {
|
|
|
+ } else if (DictConstants.PROJECT_COMPLETED.equals(param.getNowRunState())) {
|
|
|
// 设置完成时间
|
|
|
param.setFinishTime(new Date());
|
|
|
}
|
|
@@ -318,7 +326,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS);
|
|
|
}
|
|
|
|
|
|
- private void projectRunToKafka(SimulationManualProjectPo po) {
|
|
|
+ private void projectRunToKafka(SimulationManualProjectPO po) {
|
|
|
try {
|
|
|
log.info("准备发送项目消息:" + po);
|
|
|
SimulationManualProjectKafkaParam kafkaParam = new SimulationManualProjectKafkaParam();
|
|
@@ -349,7 +357,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private void projectStopToKafka(SimulationManualProjectPo po) {
|
|
|
+ private void projectStopToKafka(SimulationManualProjectPO po) {
|
|
|
SimulationManualProjectKafkaParam kafkaParam = new SimulationManualProjectKafkaParam();
|
|
|
kafkaParam.setProjectId(po.getId());
|
|
|
kafkaParam.setType(DictConstants.PROJECT_TYPE_MANUAL);
|
|
@@ -369,7 +377,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}, failure -> log.error("发送消息失败:" + failure.getMessage()));
|
|
|
}
|
|
|
|
|
|
- private void autoProjectStopToKafka(SimulationAutomaticSubProjectPo po) {
|
|
|
+ private void autoProjectStopToKafka(SimulationAutomaticSubProjectPO po) {
|
|
|
SimulationManualProjectKafkaParam kafkaParam = new SimulationManualProjectKafkaParam();
|
|
|
kafkaParam.setProjectId(po.getId());
|
|
|
kafkaParam.setType(DictConstants.PROJECT_TYPE_AUTO_SUB);
|
|
@@ -396,7 +404,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
|
|
|
ProjectDetailsVo projectDetailsVo = null;
|
|
|
if (DictConstants.PROJECT_TYPE_MANUAL.equals(param.getProjectType())) { // 手动运行任务
|
|
|
- SimulationManualProjectPo po = simulationProjectMapper.selectProjectById(param);
|
|
|
+ SimulationManualProjectPO po = simulationProjectMapper.selectProjectById(param);
|
|
|
projectDetailsVo = JsonUtil.jsonToBean(po.getDetails(), ProjectDetailsVo.class);
|
|
|
projectDetailsVo.setEvaluationLevel(getDictName(DictConstants.EVALUATION_LEVEL, po.getEvaluationLevel()));
|
|
|
projectDetailsVo.setStartTime(getRqStr(po.getStartTime(), 1));
|
|
@@ -491,11 +499,11 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
ProjectDetailsVo projectDetailsVo = new ProjectDetailsVo();
|
|
|
|
|
|
// 封装要使用到的数据
|
|
|
- SimulationManualProjectPo poParam = new SimulationManualProjectPo();
|
|
|
+ SimulationManualProjectPO poParam = new SimulationManualProjectPO();
|
|
|
|
|
|
if (DictConstants.PROJECT_TYPE_MANUAL.equals(param.getProjectType())) { // 手动运行任务
|
|
|
// 项目基本信息
|
|
|
- SimulationManualProjectPo po = simulationProjectMapper.selectProjectById(param);
|
|
|
+ SimulationManualProjectPO po = simulationProjectMapper.selectProjectById(param);
|
|
|
if (po == null) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "没有获取到数据");
|
|
|
}
|
|
@@ -793,7 +801,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
public ResponseBodyVO<ProjectReportVo> selectProjectReportById(SimulationManualProjectParam param) {
|
|
|
String projectType = param.getProjectType();
|
|
|
// 封装要使用到的数据
|
|
|
- SimulationManualProjectPo poParam = new SimulationManualProjectPo();
|
|
|
+ SimulationManualProjectPO poParam = new SimulationManualProjectPO();
|
|
|
|
|
|
if (DictConstants.PROJECT_TYPE_MANUAL.equals(projectType)) {
|
|
|
// 项目基本信息
|
|
@@ -827,9 +835,9 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
*/
|
|
|
|
|
|
// 获取得分表一级指标信息
|
|
|
- SimulationMptFirstTargetScorePo par = new SimulationMptFirstTargetScorePo();
|
|
|
+ SimulationMptFirstTargetScorePO par = new SimulationMptFirstTargetScorePO();
|
|
|
par.setPId(poParam.getId());
|
|
|
- List<SimulationMptFirstTargetScorePo> pos = simulationMptFirstTargetScoreMapper.selectFirstTargetByPid(par);
|
|
|
+ List<SimulationMptFirstTargetScorePO> pos = simulationMptFirstTargetScoreMapper.selectFirstTargetByPid(par);
|
|
|
|
|
|
List<AlgorithmScoreVo> algorithmScoreVoList = new ArrayList<>();
|
|
|
String evaluationLevelReport;
|
|
@@ -843,7 +851,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
int totalSceneScoreNum = 0;
|
|
|
|
|
|
// 根据一级指标表结果获取平分细则
|
|
|
- for (SimulationMptFirstTargetScorePo firstTargetScorePo : pos) {
|
|
|
+ for (SimulationMptFirstTargetScorePO firstTargetScorePo : pos) {
|
|
|
// 获取指标信息
|
|
|
int sceneNum = firstTargetScorePo.getSceneNum(); // 一级指标包含场景数量
|
|
|
String weight = firstTargetScorePo.getWeight(); // 一级指标权重
|
|
@@ -916,7 +924,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS, projectReportVo);
|
|
|
}
|
|
|
|
|
|
- private AlgorithmPO getAlgorithmInfo(SimulationManualProjectPo po) {
|
|
|
+ private AlgorithmPO getAlgorithmInfo(SimulationManualProjectPO po) {
|
|
|
AlgorithmPO algorithmBaseInfoVo = null;
|
|
|
String algorithmId = po.getAlgorithm();
|
|
|
String algorithmType = po.getAlgorithmType();
|
|
@@ -1004,11 +1012,11 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
ProjectTaskParam projectTaskParam = new ProjectTaskParam();
|
|
|
projectTaskParam.setPId(id);
|
|
|
projectTaskParam.setId(taskId);
|
|
|
- List<ManualProjectTaskPo> pos = simulationProjectTaskMapper.selectProjectTask(projectTaskParam);
|
|
|
+ List<ManualProjectTaskPO> pos = simulationProjectTaskMapper.selectProjectTask(projectTaskParam);
|
|
|
if (CollectionUtil.isEmpty(pos)) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "没有获取到任务信息。");
|
|
|
}
|
|
|
- ManualProjectTaskPo po = pos.get(0);
|
|
|
+ ManualProjectTaskPO po = pos.get(0);
|
|
|
resultVo.setTaskId(po.getId());
|
|
|
String sceneId = po.getSceneId();
|
|
|
String sceneType = po.getSceneType(); // 4
|
|
@@ -1020,9 +1028,9 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
resultVo.setFinishState(po.getRunResult()); // Completed
|
|
|
resultVo.setSceneDescribe(""); // 场景描述设置为空
|
|
|
// -------------------------------- 获取任务得分详情 --------------------------------
|
|
|
- SimulationManualProjectPo poParam = new SimulationManualProjectPo();
|
|
|
+ SimulationManualProjectPO poParam = new SimulationManualProjectPO();
|
|
|
if (DictConstants.PROJECT_TYPE_MANUAL.equals(projectType)) {
|
|
|
- SimulationManualProjectPo spo = simulationProjectMapper.selectProjectBaseById(param);
|
|
|
+ SimulationManualProjectPO spo = simulationProjectMapper.selectProjectBaseById(param);
|
|
|
Optional.ofNullable(spo).orElseThrow(() -> new RuntimeException("没有获取到数据。"));
|
|
|
poParam = spo;
|
|
|
} else if (DictConstants.PROJECT_TYPE_AUTO_SUB.equals(projectType)) {
|
|
@@ -1570,8 +1578,8 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
result.add(scenePackageDropDown);
|
|
|
}
|
|
|
|
|
|
- private SimulationManualProjectPo convertParamToPo(SimulationManualProjectParam param) {
|
|
|
- SimulationManualProjectPo po = new SimulationManualProjectPo();
|
|
|
+ private SimulationManualProjectPO convertParamToPo(SimulationManualProjectParam param) {
|
|
|
+ SimulationManualProjectPO po = new SimulationManualProjectPO();
|
|
|
po.setId(param.getId());
|
|
|
po.setProjectName(param.getProjectName());
|
|
|
po.setProjectDescribe(param.getProjectDescribe());
|
|
@@ -1631,7 +1639,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
simulationManualProjectVo.setCreateTimeFmt(getRqStr(simulationManualProjectVo.getCreateTime(), 1));
|
|
|
}
|
|
|
|
|
|
- private void convertPoToVo(SimulationManualProjectPo po, SimulationManualProjectSingleVo vo) {
|
|
|
+ private void convertPoToVo(SimulationManualProjectPO po, SimulationManualProjectSingleVo vo) {
|
|
|
vo.setId(po.getId());
|
|
|
vo.setProjectName(po.getProjectName());
|
|
|
vo.setProjectDescribe(po.getProjectDescribe());
|
|
@@ -1645,10 +1653,10 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
|
|
|
}
|
|
|
|
|
|
- private void createProjectId(SimulationManualProjectPo po) {
|
|
|
+ private void createProjectId(SimulationManualProjectPO po) {
|
|
|
Integer nowRq = getRq(null, 0);
|
|
|
po.setProjectDate(nowRq);
|
|
|
- SimulationManualProjectPo po1 = simulationProjectMapper.selectLastProjectId(nowRq);
|
|
|
+ SimulationManualProjectPO po1 = simulationProjectMapper.selectLastProjectId(nowRq);
|
|
|
if (po1 == null) {
|
|
|
// 生成新id
|
|
|
po.setProjectNum(1);
|
|
@@ -1659,10 +1667,10 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
|
|
|
}
|
|
|
|
|
|
- private void createProjectId(SimulationAutomaticProjectPo po) {
|
|
|
+ private void createProjectId(SimulationAutomaticProjectPO po) {
|
|
|
Integer nowRq = getRq(null, 0);
|
|
|
po.setProjectDate(nowRq);
|
|
|
- SimulationAutomaticProjectPo po1 = simulationAutomaticProjectMapper.selectLastProjectId(nowRq);
|
|
|
+ SimulationAutomaticProjectPO po1 = simulationAutomaticProjectMapper.selectLastProjectId(nowRq);
|
|
|
if (po1 == null) {
|
|
|
// 生成新id
|
|
|
po.setProjectNum(1);
|
|
@@ -1769,7 +1777,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private ManualProjectTaskVo convertManualProjectTaskPoToVo(ManualProjectTaskPo po) {
|
|
|
+ private ManualProjectTaskVo convertManualProjectTaskPoToVo(ManualProjectTaskPO po) {
|
|
|
ManualProjectTaskVo manualProjectTaskVo = new ManualProjectTaskVo();
|
|
|
manualProjectTaskVo.setId(po.getId());
|
|
|
manualProjectTaskVo.setPId(po.getPId());
|
|
@@ -2459,10 +2467,10 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
|
|
|
private void setLastTargetScore(ScenePackageSubListVO vo, String pId) {
|
|
|
- SimulationMptLastTargetScorePo poParam = new SimulationMptLastTargetScorePo();
|
|
|
+ SimulationMptLastTargetScorePO poParam = new SimulationMptLastTargetScorePO();
|
|
|
poParam.setPId(pId);
|
|
|
poParam.setTarget(vo.getSublistId());
|
|
|
- SimulationMptLastTargetScorePo po = simulationMptLastTargetScoreMapper.selectLastTargetScore(poParam);
|
|
|
+ SimulationMptLastTargetScorePO po = simulationMptLastTargetScoreMapper.selectLastTargetScore(poParam);
|
|
|
if (po != null) {
|
|
|
vo.setNotStandardSceneNum(po.getNotStandardSceneNum());
|
|
|
vo.setScore(po.getScore());
|
|
@@ -2472,10 +2480,10 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
|
|
|
private void setFirstTargetScore(ScenePackageSubListVO vo, String pId) {
|
|
|
- SimulationMptFirstTargetScorePo poParam = new SimulationMptFirstTargetScorePo();
|
|
|
+ SimulationMptFirstTargetScorePO poParam = new SimulationMptFirstTargetScorePO();
|
|
|
poParam.setPId(pId);
|
|
|
poParam.setTarget(vo.getSublistId());
|
|
|
- SimulationMptFirstTargetScorePo po = simulationMptFirstTargetScoreMapper.selectFirstTargetScore(poParam);
|
|
|
+ SimulationMptFirstTargetScorePO po = simulationMptFirstTargetScoreMapper.selectFirstTargetScore(poParam);
|
|
|
if (po != null) {
|
|
|
vo.setScore(po.getScore());
|
|
|
}
|
|
@@ -2587,7 +2595,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
|
|
|
private void setScoreNum(String sublistId, String pId, SceneScoreVo resultVo) {
|
|
|
- SimulationMptSceneScorePo po = new SimulationMptSceneScorePo();
|
|
|
+ SimulationMptSceneScorePO po = new SimulationMptSceneScorePO();
|
|
|
po.setPId(pId);
|
|
|
po.setLastTargerId(sublistId);
|
|
|
SceneScoreVo sceneScoreVo = simulationProjectTaskMapper.selectSceneScoreNumQuery(po);
|
|
@@ -2599,7 +2607,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
*
|
|
|
* @return
|
|
|
*/
|
|
|
- private String getEvaluationLevel(SimulationManualProjectPo po) {
|
|
|
+ private String getEvaluationLevel(SimulationManualProjectPO po) {
|
|
|
/*
|
|
|
* 汇总测试得分(计算评级)计算方法:(每一项一级指标的测试得分*测试权重)累加
|
|
|
*/
|
|
@@ -2611,11 +2619,11 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
double totalScore = 0.0;
|
|
|
for (ScenePackageSubListVO scenePackageSubListVO : scenePackageSubListVOS) {
|
|
|
double weightDouble = Double.parseDouble(scenePackageSubListVO.getWeight());
|
|
|
- SimulationMptFirstTargetScorePo simulationMptFirstTargetScorePo = new SimulationMptFirstTargetScorePo();
|
|
|
+ SimulationMptFirstTargetScorePO simulationMptFirstTargetScorePo = new SimulationMptFirstTargetScorePO();
|
|
|
simulationMptFirstTargetScorePo.setPId(po.getId());
|
|
|
simulationMptFirstTargetScorePo.setTarget(scenePackageSubListVO.getSublistId());
|
|
|
// 单个二级指标得分
|
|
|
- SimulationMptFirstTargetScorePo simulationMptFirstTargetScorePo1 = simulationMptFirstTargetScoreMapper.selectFirstTargetScore(simulationMptFirstTargetScorePo);
|
|
|
+ SimulationMptFirstTargetScorePO simulationMptFirstTargetScorePo1 = simulationMptFirstTargetScoreMapper.selectFirstTargetScore(simulationMptFirstTargetScorePo);
|
|
|
if (simulationMptFirstTargetScorePo1 == null) {
|
|
|
return evaluationLevelReport;
|
|
|
}
|
|
@@ -3944,7 +3952,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
|
|
|
@Override
|
|
|
public String selectProjectReportIdByAlgorithmId(String algorithmId) {
|
|
|
- SimulationManualProjectPo po = simulationProjectMapper.selectProjectReportIdByAlgorithmId(algorithmId);
|
|
|
+ SimulationManualProjectPO po = simulationProjectMapper.selectProjectReportIdByAlgorithmId(algorithmId);
|
|
|
if (StringUtil.isNotEmpty(po)) {
|
|
|
return po.getId();
|
|
|
}
|
|
@@ -4253,7 +4261,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
|
|
|
// 将数据保存到库
|
|
|
- ManualProjectTaskPo manualProjectTaskPo = new ManualProjectTaskPo();
|
|
|
+ ManualProjectTaskPO manualProjectTaskPo = new ManualProjectTaskPO();
|
|
|
manualProjectTaskPo.setId(taskId);
|
|
|
manualProjectTaskPo.setPId(projectId);
|
|
|
manualProjectTaskPo.setMileage(lc.toString());
|
|
@@ -4335,7 +4343,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
// 压缩包根路径
|
|
|
SimulationManualProjectParam sp = new SimulationManualProjectParam();
|
|
|
sp.setId(id);
|
|
|
- SimulationManualProjectPo spo = simulationProjectMapper.selectProjectBaseById(sp);
|
|
|
+ SimulationManualProjectPO spo = simulationProjectMapper.selectProjectBaseById(sp);
|
|
|
String rootPath = spo.getProjectName();
|
|
|
// FileUtil.createDirectory(rootPath);
|
|
|
|
|
@@ -4427,7 +4435,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
// 打包pdf
|
|
|
if (param.getIsPagePdf() != null && param.getIsPagePdf()) {
|
|
|
// 获取工作信息
|
|
|
- SimulationManualProjectPo p = simulationProjectMapper.selectProjectBaseById(param);
|
|
|
+ SimulationManualProjectPO p = simulationProjectMapper.selectProjectBaseById(param);
|
|
|
final String algorithmName = algorithmMapper.selectAlgorithmNameByAlgorithmId(param.getAlgorithm());
|
|
|
|
|
|
pdfFile = new File(param.getLocalPdfFilePath());
|
|
@@ -4490,11 +4498,11 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
// 创建自动运行任务时自动运行状态默认为关闭(1)
|
|
|
param.setAutomaticRunState("1");
|
|
|
|
|
|
- SimulationAutomaticProjectPo po = convertToSimulationAutomaticProjectPo(param);
|
|
|
+ SimulationAutomaticProjectPO po = convertToSimulationAutomaticProjectPo(param);
|
|
|
|
|
|
if (isEmpty(param.getId())) {
|
|
|
// 工作名称一样的的不能创建
|
|
|
- List<SimulationAutomaticProjectPo> simulationManualProjectPos = simulationAutomaticProjectMapper.selectAutomaticProjectByQuery(param);
|
|
|
+ List<SimulationAutomaticProjectPO> simulationManualProjectPos = simulationAutomaticProjectMapper.selectAutomaticProjectByQuery(param);
|
|
|
if (!isEmpty(simulationManualProjectPos)) {
|
|
|
return new ResponseBodyVO(ResponseBodyVO.Response.CLIENT_FAILURE, "工作名称已经存在,请修改后再保存");
|
|
|
}
|
|
@@ -4508,7 +4516,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
return new ResponseBodyVO(ResponseBodyVO.Response.SERVER_FAILURE, "添加失败");
|
|
|
} else {
|
|
|
|
|
|
- SimulationAutomaticProjectPo saPo = simulationAutomaticProjectMapper.selectById(param.getId());
|
|
|
+ SimulationAutomaticProjectPO saPo = simulationAutomaticProjectMapper.selectById(param.getId());
|
|
|
|
|
|
// 自动运行状态为关闭的才可以修改
|
|
|
if ("0".equals(saPo.getAutomaticRunState())) {
|
|
@@ -4531,10 +4539,10 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
String ids = param.getIds();
|
|
|
String[] idArr = ids.split(",");
|
|
|
|
|
|
- List<SimulationAutomaticProjectPo> pos = simulationAutomaticProjectMapper.selectProjectNowRunState(idArr);
|
|
|
+ List<SimulationAutomaticProjectPO> pos = simulationAutomaticProjectMapper.selectProjectNowRunState(idArr);
|
|
|
|
|
|
// 已经启动定时任务的项目不可以删除
|
|
|
- for (SimulationAutomaticProjectPo p : pos) {
|
|
|
+ for (SimulationAutomaticProjectPO p : pos) {
|
|
|
if ("0".equals(p.getAutomaticRunState())) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "自动任务开启状态不支持删除");
|
|
|
}
|
|
@@ -4556,7 +4564,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
Optional.ofNullable(automaticRunState).orElseThrow(() -> new RuntimeException("自动运行状态不能为空。"));
|
|
|
|
|
|
// 1 修改父项目停用状态
|
|
|
- SimulationAutomaticProjectPo po = simulationAutomaticProjectMapper.selectById(id); // 查询父项目信息
|
|
|
+ SimulationAutomaticProjectPO po = simulationAutomaticProjectMapper.selectById(id); // 查询父项目信息
|
|
|
if ("0".equals(param.getAutomaticRunState())) { // 启动
|
|
|
// 1 判断算法是否已经被删除
|
|
|
projectUtil.checkProject(po.getAlgorithm(), po.getVehicle(), po.getScene());
|
|
@@ -4574,7 +4582,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS);
|
|
|
}
|
|
|
|
|
|
- private void runProject(AlgorithmParameter algorithmParam, SimulationManualProjectParam simulationManualProjectParam, SimulationAutomaticProjectPo simulationAutomaticProjectPo) {
|
|
|
+ private void runProject(AlgorithmParameter algorithmParam, SimulationManualProjectParam simulationManualProjectParam, SimulationAutomaticProjectPO simulationAutomaticProjectPo) {
|
|
|
|
|
|
// 更新算法版本
|
|
|
simulationAutomaticProjectMapper.updateAlgorithmGitVersion(algorithmParam);
|
|
@@ -4629,19 +4637,19 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
if (StringUtil.isEmpty(param.getId())) {
|
|
|
throw new RuntimeException("id 不能为空。");
|
|
|
}
|
|
|
- SimulationAutomaticProjectPo po = simulationAutomaticProjectMapper.selectById(param.getId());
|
|
|
+ SimulationAutomaticProjectPO po = simulationAutomaticProjectMapper.selectById(param.getId());
|
|
|
// 校验项目信息
|
|
|
projectUtil.checkProject(po.getAlgorithm(), po.getVehicle(), po.getScene());
|
|
|
// 组装数据
|
|
|
String projectName = po.getProjectName();
|
|
|
- SimulationAutomaticSubProjectPo subprojectPo = new SimulationAutomaticSubProjectPo();
|
|
|
+ SimulationAutomaticSubProjectPO subprojectPo = new SimulationAutomaticSubProjectPO();
|
|
|
subprojectPo.createPo(po.getCreateUserId());
|
|
|
subprojectPo.setParentId(po.getId());
|
|
|
subprojectPo.setParentProjectId(po.getProjectId());
|
|
|
subprojectPo.setProjectName(projectName);
|
|
|
subprojectPo.setStartTime(new Date());
|
|
|
subprojectPo.setNowRunState(ProjectRunStateEnum.EXECUTION.getCode());// 执行中
|
|
|
- SimulationAutomaticSubProjectPo sPo = simulationAutomaticSubProjectMapper.selectLastProjectId(param.getId());
|
|
|
+ SimulationAutomaticSubProjectPO sPo = simulationAutomaticSubProjectMapper.selectLastProjectId(param.getId());
|
|
|
if (StringUtil.isEmpty(sPo)) {
|
|
|
subprojectPo.setProjectNum(1);
|
|
|
subprojectPo.setProjectId(po.getProjectId() + "-1");
|
|
@@ -4673,7 +4681,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS, null);
|
|
|
}
|
|
|
|
|
|
- private void autoProjectRunToKafka(SimulationAutomaticProjectPo po, String subId) {
|
|
|
+ private void autoProjectRunToKafka(SimulationAutomaticProjectPO po, String subId) {
|
|
|
SimulationManualProjectKafkaParam kafkaParam = new SimulationManualProjectKafkaParam();
|
|
|
kafkaParam.setProjectId(subId); // 子任务id
|
|
|
kafkaParam.setAlgorithmId(po.getAlgorithm());
|
|
@@ -4710,8 +4718,8 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
String[] idArr = ids.split(",");
|
|
|
// 仅有执行中的不能删除
|
|
|
- List<SimulationAutomaticSubProjectPo> pos = simulationAutomaticSubProjectMapper.selectProjectNowRunState(idArr);
|
|
|
- for (SimulationAutomaticSubProjectPo p : pos) {
|
|
|
+ List<SimulationAutomaticSubProjectPO> pos = simulationAutomaticSubProjectMapper.selectProjectNowRunState(idArr);
|
|
|
+ for (SimulationAutomaticSubProjectPO p : pos) {
|
|
|
if (ProjectRunStateEnum.EXECUTION.getCode().equals(p.getNowRunState())) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "数据不支持删除");
|
|
|
}
|
|
@@ -4795,7 +4803,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
if (isEmpty(param.getId())) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "id不能为空");
|
|
|
}
|
|
|
- SimulationAutomaticProjectPo po = simulationAutomaticProjectMapper.selectById(param.getId());
|
|
|
+ SimulationAutomaticProjectPO po = simulationAutomaticProjectMapper.selectById(param.getId());
|
|
|
if (po == null) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "没有获取到数据");
|
|
|
}
|
|
@@ -4828,7 +4836,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "id或状态值不能为空");
|
|
|
}
|
|
|
|
|
|
- SimulationAutomaticSubProjectPo po = simulationAutomaticSubProjectMapper.selectById(param);
|
|
|
+ SimulationAutomaticSubProjectPO po = simulationAutomaticSubProjectMapper.selectById(param);
|
|
|
|
|
|
if (po == null) {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "数据没有找到");
|
|
@@ -4848,7 +4856,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE, "操作失败");
|
|
|
}
|
|
|
|
|
|
- private void convertPoToVo(SimulationAutomaticProjectPo po, SimulationManualProjectSingleVo vo) {
|
|
|
+ private void convertPoToVo(SimulationAutomaticProjectPO po, SimulationManualProjectSingleVo vo) {
|
|
|
vo.setId(po.getId());
|
|
|
vo.setProjectName(po.getProjectName());
|
|
|
vo.setProjectDescribe(po.getProjectDescribe());
|
|
@@ -4863,8 +4871,8 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
vo.setMaxSimulationTime(po.getMaxSimulationTime());
|
|
|
}
|
|
|
|
|
|
- private SimulationAutomaticProjectPo convertToSimulationAutomaticProjectPo(SimulationManualProjectParam param) {
|
|
|
- SimulationAutomaticProjectPo po = new SimulationAutomaticProjectPo();
|
|
|
+ private SimulationAutomaticProjectPO convertToSimulationAutomaticProjectPo(SimulationManualProjectParam param) {
|
|
|
+ SimulationAutomaticProjectPO po = new SimulationAutomaticProjectPO();
|
|
|
po.setId(param.getId());
|
|
|
po.setProjectName(param.getProjectName());
|
|
|
po.setProjectDescribe(param.getProjectDescribe());
|
|
@@ -5047,7 +5055,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
po.setAlgorithmName(param.getAlgorithmName());
|
|
|
po.setUploadMode(DictConstants.PLATFORM);
|
|
|
po.setIsDeleted("0");
|
|
|
- AlgorithmPO po1 = simulationProjectMapper.selectalgorithmByQuery(po);
|
|
|
+ AlgorithmPO po1 = simulationProjectMapper.selectAlgorithmByQuery(po);
|
|
|
if (po1 == null) {
|
|
|
simulationProjectMapper.insertOtherAlgorithm(po);
|
|
|
} else {
|
|
@@ -5060,7 +5068,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
|
|
|
}
|
|
|
|
|
|
- private void projectTaskStart(SimulationAutomaticProjectPo po) {
|
|
|
+ private void projectTaskStart(SimulationAutomaticProjectPO po) {
|
|
|
SimulationManualProjectParam p = new SimulationManualProjectParam();
|
|
|
p.setProjectId(po.getId());
|
|
|
p.setCron(po.getOperationCycle());
|
|
@@ -5073,7 +5081,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private void projectTaskStop(SimulationAutomaticProjectPo po) {
|
|
|
+ private void projectTaskStop(SimulationAutomaticProjectPO po) {
|
|
|
|
|
|
SimulationManualProjectParam p = new SimulationManualProjectParam();
|
|
|
p.setProjectId(po.getId());
|
|
@@ -5100,9 +5108,9 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
* 汇总得分率计算方法:(每一项一级指标的所有场景得分不为0的数量_累加/每一项一级指标的场景数量_累加)换成(得分累加取平均值)
|
|
|
*/
|
|
|
// 获取得分表一级指标信息
|
|
|
- SimulationMptFirstTargetScorePo simulationMptFirstTargetScorePo = new SimulationMptFirstTargetScorePo();
|
|
|
+ SimulationMptFirstTargetScorePO simulationMptFirstTargetScorePo = new SimulationMptFirstTargetScorePO();
|
|
|
simulationMptFirstTargetScorePo.setPId(id);
|
|
|
- List<SimulationMptFirstTargetScorePo> pos = simulationMptFirstTargetScoreMapper.selectFirstTargetByPid(simulationMptFirstTargetScorePo);
|
|
|
+ List<SimulationMptFirstTargetScorePO> pos = simulationMptFirstTargetScoreMapper.selectFirstTargetByPid(simulationMptFirstTargetScorePo);
|
|
|
List<AlgorithmScoreVo> algorithmScoreVoList = new ArrayList<>();
|
|
|
if (!isEmpty(pos)) {
|
|
|
// StringBuilder stringBuilder = new StringBuilder();
|
|
@@ -5111,7 +5119,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
|
|
|
double totalScore = 0D;
|
|
|
double totalScoreRatio = 0D;
|
|
|
Integer totalSceneScoreNum = 0;
|
|
|
- for (SimulationMptFirstTargetScorePo v : pos) {
|
|
|
+ for (SimulationMptFirstTargetScorePO v : pos) {
|
|
|
// stringBuilder.append(v.getSublistName()).append("、");
|
|
|
AlgorithmScoreVo algorithmScoreVo = new AlgorithmScoreVo();
|
|
|
algorithmScoreVo.setProjectName(v.getSublistName());
|