|
@@ -137,8 +137,8 @@ public class CrowdTestProjectRepo implements ICrowdTestProjectRepo {
|
|
public void saveCrowdTestProject(CrowdTestProject crowdTestProject) {
|
|
public void saveCrowdTestProject(CrowdTestProject crowdTestProject) {
|
|
CrowdTestProjectPO crowdTestProjectPO = Converter.convert(CrowdTestProjectPO.class, crowdTestProject);
|
|
CrowdTestProjectPO crowdTestProjectPO = Converter.convert(CrowdTestProjectPO.class, crowdTestProject);
|
|
crowdTestProjectDao.save(crowdTestProjectPO);
|
|
crowdTestProjectDao.save(crowdTestProjectPO);
|
|
-
|
|
|
|
List<CrowdTestTask> crowdTestTaskList = crowdTestProject.getCrowdTestTaskList();
|
|
List<CrowdTestTask> crowdTestTaskList = crowdTestProject.getCrowdTestTaskList();
|
|
|
|
+ EndPoint endPoint= crowdTestProject.getEndPoint();
|
|
if (crowdTestTaskList != null) {
|
|
if (crowdTestTaskList != null) {
|
|
for (CrowdTestTask crowdTestTask : crowdTestTaskList) {
|
|
for (CrowdTestTask crowdTestTask : crowdTestTaskList) {
|
|
CrowdTestTaskPO crowdTestTaskPO = Converter.convert(CrowdTestTaskPO.class, crowdTestTask);
|
|
CrowdTestTaskPO crowdTestTaskPO = Converter.convert(CrowdTestTaskPO.class, crowdTestTask);
|
|
@@ -156,6 +156,16 @@ public class CrowdTestProjectRepo implements ICrowdTestProjectRepo {
|
|
// Set<Long> collect = taskToUserPOS.stream().map(TaskToUserPO::getUserId).collect(Collectors.toSet());
|
|
// Set<Long> collect = taskToUserPOS.stream().map(TaskToUserPO::getUserId).collect(Collectors.toSet());
|
|
// crowdTestTaskPO.setParticipantHasReportCount(collect.size());
|
|
// crowdTestTaskPO.setParticipantHasReportCount(collect.size());
|
|
crowdTestTaskDao.save(crowdTestTaskPO);
|
|
crowdTestTaskDao.save(crowdTestTaskPO);
|
|
|
|
+ if(crowdTestTask.getCaseId()!=null&&crowdTestTask.getCaseId().length()>0&&crowdTestTask.getExamId()!=null&crowdTestTask.getExamId().length()>0){
|
|
|
|
+ Optional<EndPointPO> endPointPO=endPointDao.findByTaskCode(crowdTestTask.getCode());
|
|
|
|
+ if(!endPointPO.isPresent()){
|
|
|
|
+ EndPointPO addEndPointPO = Converter.convert(EndPointPO.class, endPoint);
|
|
|
|
+ endPointDao.save(addEndPointPO);
|
|
|
|
+ }else {
|
|
|
|
+ throw new HttpBadRequestException("任务已存在");
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
}
|
|
}
|
|
}
|
|
}
|
|
// 保存项目报告
|
|
// 保存项目报告
|
|
@@ -223,10 +233,10 @@ public class CrowdTestProjectRepo implements ICrowdTestProjectRepo {
|
|
endPointPO.get().setCaseId(endPoint.getCaseId());
|
|
endPointPO.get().setCaseId(endPoint.getCaseId());
|
|
endPointPO.get().setExamId(endPoint.getExamId());
|
|
endPointPO.get().setExamId(endPoint.getExamId());
|
|
endPointDao.save(endPointPO.get());
|
|
endPointDao.save(endPointPO.get());
|
|
|
|
+ return this.getEndPoint(endPoint.getTaskCode());
|
|
}else {
|
|
}else {
|
|
throw new HttpBadRequestException("任务不存在");
|
|
throw new HttpBadRequestException("任务不存在");
|
|
}
|
|
}
|
|
- return this.getEndPoint(endPoint.getTaskCode());
|
|
|
|
}
|
|
}
|
|
|
|
|
|
// @Override
|
|
// @Override
|