|
@@ -50,6 +50,9 @@ public class WebMediatorImpl implements ViewMediator {
|
|
private CrowdTestProjectRepo projectRepo;
|
|
private CrowdTestProjectRepo projectRepo;
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
|
|
+ private CrowdTestTaskRepo taskRepo;
|
|
|
|
+
|
|
|
|
+ @Autowired
|
|
private UserRepo userRepo;
|
|
private UserRepo userRepo;
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
@@ -138,24 +141,13 @@ public class WebMediatorImpl implements ViewMediator {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public List<CrowdTestProjectVO> crowdTestProjects() {
|
|
public List<CrowdTestProjectVO> crowdTestProjects() {
|
|
- List<CrowdTestProjectVO> authingList = new ArrayList<>();
|
|
|
|
- authingList.addAll(projectDao.findAll().stream().map(crowdTestProjectPO -> {
|
|
|
|
|
|
+ List<CrowdTestProjectVO> resultList = new ArrayList<>();
|
|
|
|
+ resultList.addAll(projectDao.findAll().stream().map(crowdTestProjectPO -> {
|
|
CrowdTestProject crowdTestProject = new CrowdTestProject();
|
|
CrowdTestProject crowdTestProject = new CrowdTestProject();
|
|
BeanUtils.copyProperties(crowdTestProjectPO, crowdTestProject);
|
|
BeanUtils.copyProperties(crowdTestProjectPO, crowdTestProject);
|
|
return new CrowdTestProjectVO(crowdTestProject);
|
|
return new CrowdTestProjectVO(crowdTestProject);
|
|
}).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()));
|
|
- return authingList;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- @Override
|
|
|
|
- public List<CrowdTaskVO> findIndexTask() {
|
|
|
|
- List<CrowdTaskVO> authingList = new ArrayList<>();
|
|
|
|
- authingList.addAll(taskDao.findindexTask().stream().map(crowdTestProjectPO -> {
|
|
|
|
- CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
|
|
- BeanUtils.copyProperties(crowdTestProjectPO, crowdTestTask);
|
|
|
|
- return new CrowdTaskVO(crowdTestTask);
|
|
|
|
- }).collect(Collectors.toList()));
|
|
|
|
- return authingList;
|
|
|
|
|
|
+ return resultList;
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -372,7 +364,6 @@ public class WebMediatorImpl implements ViewMediator {
|
|
}
|
|
}
|
|
|
|
|
|
// 获取热门任务
|
|
// 获取热门任务
|
|
-
|
|
|
|
List<CrowdTaskVO> taskVOList = taskDao.findMoreHotTasks().stream().map(crowdTestTaskPO -> {
|
|
List<CrowdTaskVO> taskVOList = taskDao.findMoreHotTasks().stream().map(crowdTestTaskPO -> {
|
|
CrowdTestTask task = new CrowdTestTask();
|
|
CrowdTestTask task = new CrowdTestTask();
|
|
BeanUtils.copyProperties(crowdTestTaskPO, task);
|
|
BeanUtils.copyProperties(crowdTestTaskPO, task);
|
|
@@ -613,9 +604,10 @@ public class WebMediatorImpl implements ViewMediator {
|
|
User user = userRepo.getByID(userId);
|
|
User user = userRepo.getByID(userId);
|
|
//我的众测 - 项目相关信息
|
|
//我的众测 - 项目相关信息
|
|
|
|
|
|
- // 获取应用、测试类型code 和 name 的map
|
|
|
|
|
|
+ // 获取领域、应用、测试类型code 和 name 的map
|
|
|
|
+ Map<String, String> fieldMap = commonRepo.getFieldCodeNameMap();
|
|
Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
- Map<String, String> typeMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
|
|
+ Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
|
|
//获取我创建的项目列表
|
|
//获取我创建的项目列表
|
|
List<CrowdProjectVO> myProjects = projectDao.findByUserIdAndIsDeleted(userId, DeletedStatus.isNotDeleted)
|
|
List<CrowdProjectVO> myProjects = projectDao.findByUserIdAndIsDeleted(userId, DeletedStatus.isNotDeleted)
|
|
@@ -626,8 +618,8 @@ public class WebMediatorImpl implements ViewMediator {
|
|
// themeStatusService.updateStatus(project);
|
|
// themeStatusService.updateStatus(project);
|
|
if (project.getStatus() == CrowdTestProjectStatus.HAS_COMMITED)
|
|
if (project.getStatus() == CrowdTestProjectStatus.HAS_COMMITED)
|
|
projectVO.setNeedHandle(true);
|
|
projectVO.setNeedHandle(true);
|
|
- // 应用类型值的转换
|
|
|
|
- projectVO = changeApplicationType(projectVO, applicationMap);
|
|
|
|
|
|
+ // 领域类型、应用类型值的转换
|
|
|
|
+ projectVO = changeFieldAndApplicationAndTestType(projectVO, applicationMap, fieldMap, testMap);
|
|
|
|
|
|
// 判断项目是否截止
|
|
// 判断项目是否截止
|
|
if (projectVO.getDatetime().getTime() <= System.currentTimeMillis() && project.getStatus() < CrowdTestProjectStatus.HAS_FINISHED) {
|
|
if (projectVO.getDatetime().getTime() <= System.currentTimeMillis() && project.getStatus() < CrowdTestProjectStatus.HAS_FINISHED) {
|
|
@@ -655,7 +647,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
BeanUtils.copyProperties(crowdTestProjectPO, project);
|
|
BeanUtils.copyProperties(crowdTestProjectPO, project);
|
|
CrowdProjectVO projectVO = new CrowdProjectVO(project);
|
|
CrowdProjectVO projectVO = new CrowdProjectVO(project);
|
|
// 应用类型值的转换
|
|
// 应用类型值的转换
|
|
- projectVO = changeApplicationType(projectVO, applicationMap);
|
|
|
|
|
|
+ projectVO = changeFieldAndApplicationAndTestType(projectVO, applicationMap, fieldMap, testMap);
|
|
|
|
|
|
// List<CrowdTestTaskPO> tasksOfProject = taskDao.findByCrowdTestProjectCodeAndIsDeleted(project.getCode(), DeletedStatus.isNotDeleted);
|
|
// List<CrowdTestTaskPO> tasksOfProject = taskDao.findByCrowdTestProjectCodeAndIsDeleted(project.getCode(), DeletedStatus.isNotDeleted);
|
|
// if (tasksOfProject != null && tasksOfProject.stream().anyMatch(task -> task.getStatus() == CrowdTestTaskStatus.HAS_COMMITED)) {
|
|
// if (tasksOfProject != null && tasksOfProject.stream().anyMatch(task -> task.getStatus() == CrowdTestTaskStatus.HAS_COMMITED)) {
|
|
@@ -678,7 +670,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
CrowdTestProject project = new CrowdTestProject();
|
|
CrowdTestProject project = new CrowdTestProject();
|
|
BeanUtils.copyProperties(crowdTestProjectPO, project);
|
|
BeanUtils.copyProperties(crowdTestProjectPO, project);
|
|
CrowdProjectVO projectVO = new CrowdProjectVO(project);
|
|
CrowdProjectVO projectVO = new CrowdProjectVO(project);
|
|
- projectVO = changeApplicationType(projectVO, applicationMap);
|
|
|
|
|
|
+ projectVO = changeFieldAndApplicationAndTestType(projectVO, applicationMap, fieldMap, testMap);
|
|
return projectVO;
|
|
return projectVO;
|
|
}).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()));
|
|
myCrowdDTO.setAcceptableProjectNoticeCount(Long.parseLong("" + acceptableProject.size()));
|
|
myCrowdDTO.setAcceptableProjectNoticeCount(Long.parseLong("" + acceptableProject.size()));
|
|
@@ -707,7 +699,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
CrowdTestTask task = new CrowdTestTask();
|
|
CrowdTestTask task = new CrowdTestTask();
|
|
BeanUtils.copyProperties(crowdTestTaskPO, task);
|
|
BeanUtils.copyProperties(crowdTestTaskPO, task);
|
|
// 测试类型的转换
|
|
// 测试类型的转换
|
|
- task.setType(typeMap.get(task.getType()));
|
|
|
|
|
|
+ task.setType(testMap.get(task.getType()));
|
|
// 判断任务是否截止
|
|
// 判断任务是否截止
|
|
if (task.getDeadTime().getTime() <= System.currentTimeMillis() && task.getStatus() < CrowdTestTaskStatus.HAS_FINISHED) {
|
|
if (task.getDeadTime().getTime() <= System.currentTimeMillis() && task.getStatus() < CrowdTestTaskStatus.HAS_FINISHED) {
|
|
task.setStatus(CrowdTestTaskStatus.HAS_TIME_OUT);
|
|
task.setStatus(CrowdTestTaskStatus.HAS_TIME_OUT);
|
|
@@ -788,23 +780,99 @@ public class WebMediatorImpl implements ViewMediator {
|
|
return userDataDTO;
|
|
return userDataDTO;
|
|
}
|
|
}
|
|
|
|
|
|
- public CrowdProjectVO changeApplicationType(CrowdProjectVO projectVO, Map<String, String> applicationMap) {
|
|
|
|
|
|
+ /**
|
|
|
|
+ * 项目领域、应用、测试类型的转换
|
|
|
|
+ * @param projectVO
|
|
|
|
+ * @param applicationMap
|
|
|
|
+ * @param fieldMap
|
|
|
|
+ * @param testMap
|
|
|
|
+ * @return
|
|
|
|
+ */
|
|
|
|
+ @Override
|
|
|
|
+ public CrowdProjectVO changeFieldAndApplicationAndTestType(CrowdProjectVO projectVO, Map<String, String> applicationMap
|
|
|
|
+ , Map<String, String> fieldMap, Map<String, String> testMap) {
|
|
|
|
+ // 领域类型值的转换
|
|
|
|
+ projectVO.setField(fieldMap.get(projectVO.getField()));
|
|
// 应用类型值的转换
|
|
// 应用类型值的转换
|
|
- String applicationName = applicationMap.get(projectVO.getPlatform());
|
|
|
|
- projectVO.setPlatform(applicationName);
|
|
|
|
|
|
+ projectVO.setPlatform(applicationMap.get(projectVO.getPlatform()));
|
|
|
|
+ // 测试类型值的转换
|
|
|
|
+ projectVO.setType(projectVO.getType().stream().map(testType -> testMap.get(testType)).collect(Collectors.toList()));
|
|
return projectVO;
|
|
return projectVO;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public CrowdTestProject changeFieldAndApplicationAndTestType(CrowdTestProject project, Map<String, String> applicationMap
|
|
|
|
+ , Map<String, String> fieldMap, Map<String, String> testMap) {
|
|
|
|
+ // 领域类型值的转换
|
|
|
|
+ project.setFieldType(fieldMap.get(project.getFieldType()));
|
|
|
|
+ // 应用类型值的转换
|
|
|
|
+ project.setApplicationType(applicationMap.get(project.getApplicationType()));
|
|
|
|
+ // 测试类型值的转换
|
|
|
|
+ if(project.getType().contains("[")){
|
|
|
|
+ List<String> testTypeCodeList = (List<String>)JSONArray.parse(project.getType());
|
|
|
|
+ project.setType(testTypeCodeList.stream().map(testType -> '"'+ testMap.get(testType) + '"').collect(Collectors.toList()).toString());
|
|
|
|
+ }else{
|
|
|
|
+ project.setType(testMap.get(project.getType()));
|
|
|
|
+ }
|
|
|
|
+ return project;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public CrowdTestTask changeFieldAndApplicationAndTestTypeByTask(CrowdTestTask task, Map<String, String> applicationMap
|
|
|
|
+ , Map<String, String> fieldMap, Map<String, String> testMap) {
|
|
|
|
+ // 领域类型值的转换
|
|
|
|
+ task.setFieldType(fieldMap.get(task.getFieldType()));
|
|
|
|
+ // 应用类型值的转换
|
|
|
|
+ task.setApplicationType(applicationMap.get(task.getApplicationType()));
|
|
|
|
+ // 测试类型值的转换
|
|
|
|
+ task.setType(testMap.get(task.getType()));
|
|
|
|
+ return task;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public CrowdTestTask changeTypeByProjectAndTask(CrowdTestProject project, CrowdTestTask task, Map<String, String> applicationMap
|
|
|
|
+ , Map<String, String> fieldMap, Map<String, String> testMap) {
|
|
|
|
+ // 获取项目的领域、应用类型赋值给任务
|
|
|
|
+ task.setFieldType(project.getFieldType());
|
|
|
|
+ task.setApplicationType(project.getApplicationType());
|
|
|
|
+ // 领域类型值的转换
|
|
|
|
+ task.setFieldType(fieldMap.get(task.getFieldType()));
|
|
|
|
+ // 应用类型值的转换
|
|
|
|
+ task.setApplicationType(applicationMap.get(task.getApplicationType()));
|
|
|
|
+ // 测试类型值的转换
|
|
|
|
+ task.setType(testMap.get(task.getType()));
|
|
|
|
+ return task;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public CrowdTestTask changeTypeByProjectAndTask(CrowdTestProject project, CrowdTestTask task) {
|
|
|
|
+ // 获取领域、应用、测试类型code 和 name 的map
|
|
|
|
+ Map<String, String> fieldMap = commonRepo.getFieldCodeNameMap();
|
|
|
|
+ Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
|
|
+ Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
+
|
|
|
|
+ // 获取项目的领域、应用类型赋值给任务
|
|
|
|
+ task.setFieldType(project.getFieldType());
|
|
|
|
+ task.setApplicationType(project.getApplicationType());
|
|
|
|
+ // 领域类型值的转换
|
|
|
|
+ task.setFieldType(fieldMap.get(task.getFieldType()));
|
|
|
|
+ // 应用类型值的转换
|
|
|
|
+ task.setApplicationType(applicationMap.get(task.getApplicationType()));
|
|
|
|
+ // 测试类型值的转换
|
|
|
|
+ task.setType(testMap.get(task.getType()));
|
|
|
|
+ return task;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public TaskSquareDTO renderTaskSquare() {
|
|
public TaskSquareDTO renderTaskSquare() {
|
|
- Map<String, String> typeMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
|
|
+ Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
|
|
List<CrowdTaskVO> taskVOList = taskDao.findAllByIsDeleted(0).stream().map(crowdTestTaskPO -> {
|
|
List<CrowdTaskVO> taskVOList = taskDao.findAllByIsDeleted(0).stream().map(crowdTestTaskPO -> {
|
|
CrowdTestTask task = CrowdTestProjectFactory.defaultTask();
|
|
CrowdTestTask task = CrowdTestProjectFactory.defaultTask();
|
|
BeanUtils.copyProperties(crowdTestTaskPO, task);
|
|
BeanUtils.copyProperties(crowdTestTaskPO, task);
|
|
// 测试类型的转换
|
|
// 测试类型的转换
|
|
- task.setType(typeMap.get(task.getType()));
|
|
|
|
|
|
+ task.setType(testMap.get(task.getType()));
|
|
return task;
|
|
return task;
|
|
}).collect(Collectors.toList()).stream().filter(crowdTestTask -> crowdTestTask.getStatus() == CrowdTestTaskStatus.HAS_RELEASED ||
|
|
}).collect(Collectors.toList()).stream().filter(crowdTestTask -> crowdTestTask.getStatus() == CrowdTestTaskStatus.HAS_RELEASED ||
|
|
(crowdTestTask.getStatus() == CrowdTestTaskStatus.HAS_RECEIVED && crowdTestTask.getFullStatus() == CrowdTestTaskAcceptStatus.NOT_FULL))
|
|
(crowdTestTask.getStatus() == CrowdTestTaskStatus.HAS_RECEIVED && crowdTestTask.getFullStatus() == CrowdTestTaskAcceptStatus.NOT_FULL))
|
|
@@ -818,8 +886,10 @@ public class WebMediatorImpl implements ViewMediator {
|
|
@Override
|
|
@Override
|
|
public ProjectDetailsDTO renderProjectDetails(CrowdTestProject project, User user) {
|
|
public ProjectDetailsDTO renderProjectDetails(CrowdTestProject project, User user) {
|
|
|
|
|
|
|
|
+ Map<String, String> fieldMap = commonRepo.getFieldCodeNameMap();
|
|
Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
- Map<String, String> typeMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
|
|
+ Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
+
|
|
boolean saveFlag = false;
|
|
boolean saveFlag = false;
|
|
// 判断项目是否截止
|
|
// 判断项目是否截止
|
|
if (project.getDeadTime().getTime() <= System.currentTimeMillis() && project.getStatus() < CrowdTestProjectStatus.HAS_FINISHED) {
|
|
if (project.getDeadTime().getTime() <= System.currentTimeMillis() && project.getStatus() < CrowdTestProjectStatus.HAS_FINISHED) {
|
|
@@ -837,15 +907,13 @@ public class WebMediatorImpl implements ViewMediator {
|
|
saveFlag = true;
|
|
saveFlag = true;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ // 类型的转换
|
|
|
|
+ this.changeTypeByProjectAndTask(project, crowdTestTask, applicationMap, fieldMap, testMap);
|
|
CrowdTaskVO crowdTaskVO = new CrowdTaskVO(crowdTestTask);
|
|
CrowdTaskVO crowdTaskVO = new CrowdTaskVO(crowdTestTask);
|
|
if (crowdTestTask.getDistributionType() == 0) {
|
|
if (crowdTestTask.getDistributionType() == 0) {
|
|
EvaluationAgencyPO agencyPO = agencyDao.findByUserId(crowdTestTask.getEvaluationAgencyId());
|
|
EvaluationAgencyPO agencyPO = agencyDao.findByUserId(crowdTestTask.getEvaluationAgencyId());
|
|
crowdTaskVO.setInstitution(agencyPO == null ? "该机构已注销" : agencyPO.getEvaluationAgencyName());
|
|
crowdTaskVO.setInstitution(agencyPO == null ? "该机构已注销" : agencyPO.getEvaluationAgencyName());
|
|
}
|
|
}
|
|
- // 测试类型的转换
|
|
|
|
- crowdTaskVO.setServiceType(typeMap.get(crowdTaskVO.getServiceType()));
|
|
|
|
-// String typeName = commonRepo.getTypeNameByCode(crowdTaskVO.getServiceType());
|
|
|
|
-// crowdTaskVO.setServiceType(typeName);
|
|
|
|
taskVOList.add(crowdTaskVO);
|
|
taskVOList.add(crowdTaskVO);
|
|
}
|
|
}
|
|
|
|
|
|
@@ -865,22 +933,8 @@ public class WebMediatorImpl implements ViewMediator {
|
|
progress.add(new PieChartDataVO("进行中", crowdTestTaskList
|
|
progress.add(new PieChartDataVO("进行中", crowdTestTaskList
|
|
.stream().filter(task -> task.getStatus() > CrowdTestTaskStatus.HAS_CREATED && task.getStatus() < CrowdTestTaskStatus.HAS_FINISHED).count()));
|
|
.stream().filter(task -> task.getStatus() > CrowdTestTaskStatus.HAS_CREATED && task.getStatus() < CrowdTestTaskStatus.HAS_FINISHED).count()));
|
|
|
|
|
|
- // 应用类型值的转换
|
|
|
|
- projectVO = changeApplicationType(projectVO, applicationMap);
|
|
|
|
-
|
|
|
|
- // 领域类型值的转换
|
|
|
|
-
|
|
|
|
- Optional<FieldPO> fieldPO = fieldDao.findByCode(projectVO.getField());
|
|
|
|
- if (fieldPO.isPresent()) {
|
|
|
|
- projectVO.setField(fieldPO.get().getName());
|
|
|
|
- } else {
|
|
|
|
- throw new HttpBadRequestException("领域类型有误");
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- // 测试类型的转换
|
|
|
|
- List<String> testStringList = projectVO.getType().stream().map(testType -> typeMap.get(testType)).collect(Collectors.toList());
|
|
|
|
-
|
|
|
|
- projectVO.setType(testStringList);
|
|
|
|
|
|
+ // 项目类型值的转换
|
|
|
|
+ projectVO = changeFieldAndApplicationAndTestType(projectVO, applicationMap, fieldMap, testMap);
|
|
|
|
|
|
projectDetailsDTO.setProjectDetails(projectVO);
|
|
projectDetailsDTO.setProjectDetails(projectVO);
|
|
projectDetailsDTO.setTaskList(taskVOList);
|
|
projectDetailsDTO.setTaskList(taskVOList);
|
|
@@ -900,7 +954,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
.stream().filter(crowdTestTask -> crowdTestTask.getCode().equals(taskCode)).findFirst();
|
|
.stream().filter(crowdTestTask -> crowdTestTask.getCode().equals(taskCode)).findFirst();
|
|
if (!task.isPresent())
|
|
if (!task.isPresent())
|
|
throw new CrowdTestTaskNotExistException();
|
|
throw new CrowdTestTaskNotExistException();
|
|
- System.out.println("renderTaskReportDetails userID: " + userId);
|
|
|
|
|
|
+ log.info("renderTaskReportDetails userID: " + userId);
|
|
User user = userRepo.getByID(userId);
|
|
User user = userRepo.getByID(userId);
|
|
ReportDetailsDTO reportDetailsDTO = new ReportDetailsDTO();
|
|
ReportDetailsDTO reportDetailsDTO = new ReportDetailsDTO();
|
|
if (userId.equals(projectRepo.getByProjectCode(projectCode).getRegionalManagerId())) {
|
|
if (userId.equals(projectRepo.getByProjectCode(projectCode).getRegionalManagerId())) {
|
|
@@ -949,6 +1003,10 @@ public class WebMediatorImpl implements ViewMediator {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public TaskDetailsDTO renderTaskDetails(String projectCode, String taskCode, Long userId) {
|
|
public TaskDetailsDTO renderTaskDetails(String projectCode, String taskCode, Long userId) {
|
|
|
|
+// Map<String, String> fieldMap = commonRepo.getFieldCodeNameMap();
|
|
|
|
+// Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
|
|
+// Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
+
|
|
TaskDetailsDTO taskDetailsDTO = new TaskDetailsDTO();
|
|
TaskDetailsDTO taskDetailsDTO = new TaskDetailsDTO();
|
|
CrowdTestProject project = projectRepo.getByProjectCode(projectCode);
|
|
CrowdTestProject project = projectRepo.getByProjectCode(projectCode);
|
|
|
|
|
|
@@ -963,23 +1021,27 @@ public class WebMediatorImpl implements ViewMediator {
|
|
if (!task.isPresent())
|
|
if (!task.isPresent())
|
|
throw new CrowdTestTaskNotExistException();
|
|
throw new CrowdTestTaskNotExistException();
|
|
|
|
|
|
|
|
+ CrowdTestTask crowdTestTask = task.get();
|
|
|
|
+
|
|
// 判断任务是否截止
|
|
// 判断任务是否截止
|
|
- if (task.get().getDeadTime().getTime() <= System.currentTimeMillis() && task.get().getStatus() < CrowdTestTaskStatus.HAS_FINISHED) {
|
|
|
|
- task.get().setStatus(CrowdTestTaskStatus.HAS_TIME_OUT);
|
|
|
|
|
|
+ if (crowdTestTask.getDeadTime().getTime() <= System.currentTimeMillis() && crowdTestTask.getStatus() < CrowdTestTaskStatus.HAS_FINISHED) {
|
|
|
|
+ crowdTestTask.setStatus(CrowdTestTaskStatus.HAS_TIME_OUT);
|
|
saveFlag = true;
|
|
saveFlag = true;
|
|
}
|
|
}
|
|
|
|
|
|
- CrowdTaskVO taskVO = new CrowdTaskVO(task.get());
|
|
|
|
- // 测试类型的转换
|
|
|
|
-// String typeName = commonRepo.getTypeNameByCode(taskVO.getServiceType());
|
|
|
|
-// taskVO.setServiceType(typeName);
|
|
|
|
|
|
+ // 获取项目的领域、应用类型赋值给任务
|
|
|
|
+ crowdTestTask.setFieldType(project.getFieldType());
|
|
|
|
+ crowdTestTask.setApplicationType(project.getApplicationType());
|
|
|
|
+
|
|
|
|
+// this.changeTypeByProjectAndTask(project, crowdTestTask, applicationMap, fieldMap, testMap);
|
|
|
|
+ CrowdTaskVO taskVO = new CrowdTaskVO(crowdTestTask);
|
|
|
|
|
|
log.info("renderTaskDetails userId:" + userId);
|
|
log.info("renderTaskDetails userId:" + userId);
|
|
if (userId == null) {
|
|
if (userId == null) {
|
|
- taskDetailsDTO.setTaskOperationControl(this.initTaskPermission(project, task.get(), null));
|
|
|
|
|
|
+ taskDetailsDTO.setTaskOperationControl(this.initTaskPermission(project, crowdTestTask, null));
|
|
} else {
|
|
} else {
|
|
User user = userRepo.getByID(userId);
|
|
User user = userRepo.getByID(userId);
|
|
- taskDetailsDTO.setTaskOperationControl(this.initTaskPermission(project, task.get(), user));
|
|
|
|
|
|
+ taskDetailsDTO.setTaskOperationControl(this.initTaskPermission(project, crowdTestTask, user));
|
|
// 区域管理员视图
|
|
// 区域管理员视图
|
|
List<TaskToUserVO> taskToUserVOS = new ArrayList<>();
|
|
List<TaskToUserVO> taskToUserVOS = new ArrayList<>();
|
|
if (userId.equals(project.getRegionalManagerId())) {
|
|
if (userId.equals(project.getRegionalManagerId())) {
|
|
@@ -989,7 +1051,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
taskVO.setEndPointVO(new EndPointVO(Converter.convert(EndPoint.class, endPointPO.get())));
|
|
taskVO.setEndPointVO(new EndPointVO(Converter.convert(EndPoint.class, endPointPO.get())));
|
|
}
|
|
}
|
|
|
|
|
|
- taskToUserVOS = task.get().getAcceptedUserList().stream().map(taskToUser -> {
|
|
|
|
|
|
+ taskToUserVOS = crowdTestTask.getAcceptedUserList().stream().map(taskToUser -> {
|
|
TaskToUserVO taskToUserVO = new TaskToUserVO(taskToUser);
|
|
TaskToUserVO taskToUserVO = new TaskToUserVO(taskToUser);
|
|
taskToUserVO.setUserVO(Converter.convert(UserVO.class, taskToUser.getUser()));
|
|
taskToUserVO.setUserVO(Converter.convert(UserVO.class, taskToUser.getUser()));
|
|
// 获取每个人员的报告信息
|
|
// 获取每个人员的报告信息
|
|
@@ -1007,7 +1069,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
// if(!taskToUserOptional.isPresent())
|
|
// if(!taskToUserOptional.isPresent())
|
|
// throw new HttpBadRequestException("当前用户没有接收此任务!");
|
|
// throw new HttpBadRequestException("当前用户没有接收此任务!");
|
|
|
|
|
|
- taskToUserVOS = task.get().getAcceptedUserList().stream()
|
|
|
|
|
|
+ taskToUserVOS = crowdTestTask.getAcceptedUserList().stream()
|
|
.filter(taskToUser -> taskToUser.getUserId().equals(userId)).map(taskToUser -> {
|
|
.filter(taskToUser -> taskToUser.getUserId().equals(userId)).map(taskToUser -> {
|
|
TaskToUserVO taskToUserVO = new TaskToUserVO(taskToUser);
|
|
TaskToUserVO taskToUserVO = new TaskToUserVO(taskToUser);
|
|
taskToUserVO.setUserVO(Converter.convert(UserVO.class, taskToUser.getUser()));
|
|
taskToUserVO.setUserVO(Converter.convert(UserVO.class, taskToUser.getUser()));
|
|
@@ -1028,7 +1090,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
}
|
|
}
|
|
taskDetailsDTO.setAcceptedUserList(taskToUserVOS);
|
|
taskDetailsDTO.setAcceptedUserList(taskToUserVOS);
|
|
|
|
|
|
- Optional<EndPointPO> endPointPOOptional = endPointDao.findByTaskCode(task.get().getCode());
|
|
|
|
|
|
+ Optional<EndPointPO> endPointPOOptional = endPointDao.findByTaskCode(crowdTestTask.getCode());
|
|
// 判断是否具有配置项,提供跳转url
|
|
// 判断是否具有配置项,提供跳转url
|
|
if(endPointPOOptional.isPresent()){
|
|
if(endPointPOOptional.isPresent()){
|
|
// 获取测试类型对应的跳转url
|
|
// 获取测试类型对应的跳转url
|
|
@@ -1110,91 +1172,90 @@ public class WebMediatorImpl implements ViewMediator {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public List<BaseAuthVO> renderAuthingList() {
|
|
public List<BaseAuthVO> renderAuthingList() {
|
|
- List<BaseAuthVO> authingList = new ArrayList<>();
|
|
|
|
- authingList.addAll(personalAuthenticationDao.findByIsAuthentication(AuthenticationStatus.isAuthenIng).stream().map(personalAuthenticationPO -> {
|
|
|
|
|
|
+ List<BaseAuthVO> resultList = new ArrayList<>();
|
|
|
|
+ resultList.addAll(personalAuthenticationDao.findByIsAuthentication(AuthenticationStatus.isAuthenIng).stream().map(personalAuthenticationPO -> {
|
|
PersonalAuthentication personalAuthentication = new PersonalAuthentication();
|
|
PersonalAuthentication personalAuthentication = new PersonalAuthentication();
|
|
BeanUtils.copyProperties(personalAuthenticationPO, personalAuthentication);
|
|
BeanUtils.copyProperties(personalAuthenticationPO, personalAuthentication);
|
|
return new BaseAuthVO(personalAuthentication);
|
|
return new BaseAuthVO(personalAuthentication);
|
|
}).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()));
|
|
|
|
|
|
-// authingList.addAll(enterpriseAuthenticationDao.findByIsAuthentication(AuthenticationStatus.isAuthenIng).stream().map(enterpriseAuthenticationPO -> {
|
|
|
|
|
|
+// resultList.addAll(enterpriseAuthenticationDao.findByIsAuthentication(AuthenticationStatus.isAuthenIng).stream().map(enterpriseAuthenticationPO -> {
|
|
// EnterpriseAuthentication enterpriseAuthentication = new EnterpriseAuthentication();
|
|
// EnterpriseAuthentication enterpriseAuthentication = new EnterpriseAuthentication();
|
|
// BeanUtils.copyProperties(enterpriseAuthenticationPO, enterpriseAuthentication);
|
|
// BeanUtils.copyProperties(enterpriseAuthenticationPO, enterpriseAuthentication);
|
|
// return new BaseAuthVO(enterpriseAuthentication);
|
|
// return new BaseAuthVO(enterpriseAuthentication);
|
|
// }).collect(Collectors.toList()));
|
|
// }).collect(Collectors.toList()));
|
|
|
|
|
|
- authingList.addAll(agencyDao.findByIsAuthentication(AuthenticationStatus.isAuthenIng).stream().map(evaluationAgencyPO -> {
|
|
|
|
|
|
+ resultList.addAll(agencyDao.findByIsAuthentication(AuthenticationStatus.isAuthenIng).stream().map(evaluationAgencyPO -> {
|
|
EvaluationAgency agency = new EvaluationAgency();
|
|
EvaluationAgency agency = new EvaluationAgency();
|
|
BeanUtils.copyProperties(evaluationAgencyPO, agency);
|
|
BeanUtils.copyProperties(evaluationAgencyPO, agency);
|
|
return new BaseAuthVO(agency);
|
|
return new BaseAuthVO(agency);
|
|
}).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()));
|
|
- if(authingList.size() > 0 && authingList != null) {
|
|
|
|
- authingList.sort(Comparator.comparing(BaseAuthVO::getApplytime).reversed());
|
|
|
|
|
|
+ if(resultList.size() > 0 && resultList != null) {
|
|
|
|
+ resultList.sort(Comparator.comparing(BaseAuthVO::getApplytime).reversed());
|
|
}
|
|
}
|
|
- return authingList;
|
|
|
|
|
|
+ return resultList;
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public List<BaseAuthVO> renderAuthedList() {
|
|
public List<BaseAuthVO> renderAuthedList() {
|
|
- List<BaseAuthVO> authingList = new ArrayList<>();
|
|
|
|
- authingList.addAll(personalAuthenticationDao.findByIsAuthenticationIsNot(AuthenticationStatus.isAuthenIng).stream().map(personalAuthenticationPO -> {
|
|
|
|
|
|
+ List<BaseAuthVO> resultList = new ArrayList<>();
|
|
|
|
+ resultList.addAll(personalAuthenticationDao.findByIsAuthenticationIsNot(AuthenticationStatus.isAuthenIng).stream().map(personalAuthenticationPO -> {
|
|
PersonalAuthentication personalAuthentication = new PersonalAuthentication();
|
|
PersonalAuthentication personalAuthentication = new PersonalAuthentication();
|
|
BeanUtils.copyProperties(personalAuthenticationPO, personalAuthentication);
|
|
BeanUtils.copyProperties(personalAuthenticationPO, personalAuthentication);
|
|
return new BaseAuthVO(personalAuthentication);
|
|
return new BaseAuthVO(personalAuthentication);
|
|
}).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()));
|
|
|
|
|
|
-// authingList.addAll(enterpriseAuthenticationDao.findByIsAuthenticationIsNot(AuthenticationStatus.isAuthenIng).stream().map(enterpriseAuthenticationPO -> {
|
|
|
|
|
|
+// resultList.addAll(enterpriseAuthenticationDao.findByIsAuthenticationIsNot(AuthenticationStatus.isAuthenIng).stream().map(enterpriseAuthenticationPO -> {
|
|
// EnterpriseAuthentication enterpriseAuthentication = new EnterpriseAuthentication();
|
|
// EnterpriseAuthentication enterpriseAuthentication = new EnterpriseAuthentication();
|
|
// BeanUtils.copyProperties(enterpriseAuthenticationPO, enterpriseAuthentication);
|
|
// BeanUtils.copyProperties(enterpriseAuthenticationPO, enterpriseAuthentication);
|
|
// return new BaseAuthVO(enterpriseAuthentication);
|
|
// return new BaseAuthVO(enterpriseAuthentication);
|
|
// }).collect(Collectors.toList()));
|
|
// }).collect(Collectors.toList()));
|
|
|
|
|
|
- authingList.addAll(agencyDao.findByIsAuthenticationIsNot(AuthenticationStatus.isAuthenIng).stream().map(evaluationAgencyPO -> {
|
|
|
|
|
|
+ resultList.addAll(agencyDao.findByIsAuthenticationIsNot(AuthenticationStatus.isAuthenIng).stream().map(evaluationAgencyPO -> {
|
|
EvaluationAgency agency = new EvaluationAgency();
|
|
EvaluationAgency agency = new EvaluationAgency();
|
|
BeanUtils.copyProperties(evaluationAgencyPO, agency);
|
|
BeanUtils.copyProperties(evaluationAgencyPO, agency);
|
|
return new BaseAuthVO(agency);
|
|
return new BaseAuthVO(agency);
|
|
}).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()));
|
|
- if(authingList.size() > 0 && authingList != null){
|
|
|
|
- authingList.sort(Comparator.comparing(BaseAuthVO::getApplytime).reversed());
|
|
|
|
|
|
+ if(resultList.size() > 0 && resultList != null){
|
|
|
|
+ resultList.sort(Comparator.comparing(BaseAuthVO::getApplytime).reversed());
|
|
}
|
|
}
|
|
- return authingList;
|
|
|
|
|
|
+ return resultList;
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public List<CrowdTestProjectVO> findByNameLike(String name) {
|
|
public List<CrowdTestProjectVO> findByNameLike(String name) {
|
|
Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
- List<CrowdTestProjectVO> authingList = new ArrayList<>();
|
|
|
|
- authingList.addAll(projectDao.findByNameLikeAndIsDeleted("%" + name + "%", DeletedStatus.isNotDeleted).stream().map(crowdTestProjectPO -> {
|
|
|
|
- CrowdTestProject crowdTestProject = new CrowdTestProject();
|
|
|
|
- BeanUtils.copyProperties(crowdTestProjectPO, crowdTestProject);
|
|
|
|
|
|
+ List<CrowdTestProjectVO> resultList = new ArrayList<>();
|
|
|
|
+ resultList.addAll(projectRepo.findByNameLike("%" + name + "%").stream().map(crowdTestProject -> {
|
|
// 项目测试类型转换
|
|
// 项目测试类型转换
|
|
CrowdTestProjectVO crowdTestProjectVO = new CrowdTestProjectVO(crowdTestProject);
|
|
CrowdTestProjectVO crowdTestProjectVO = new CrowdTestProjectVO(crowdTestProject);
|
|
- crowdTestProjectVO.setApplicationType(applicationMap.get(crowdTestProjectPO.getApplicationType()));
|
|
|
|
|
|
+ crowdTestProjectVO.setApplicationType(applicationMap.get(crowdTestProject.getApplicationType()));
|
|
return crowdTestProjectVO;
|
|
return crowdTestProjectVO;
|
|
}).collect(Collectors.toList()).stream().sorted(Comparator.comparing(CrowdTestProjectVO::getCreateTime).reversed()).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()).stream().sorted(Comparator.comparing(CrowdTestProjectVO::getCreateTime).reversed()).collect(Collectors.toList()));
|
|
- return authingList;
|
|
|
|
|
|
+ return resultList;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
+ * 查看所有测试任务相关
|
|
|
|
+ * @param name
|
|
|
|
+ * @return
|
|
|
|
+ */
|
|
@Override
|
|
@Override
|
|
public List<CrowdTaskVO> findTaskByNameLike(String name) {
|
|
public List<CrowdTaskVO> findTaskByNameLike(String name) {
|
|
- List<CrowdTaskVO> authingList = new ArrayList<>();
|
|
|
|
- authingList.addAll(taskDao.findByNameLike("%" + name + "%").stream().map(crowdTestTaskPO -> {
|
|
|
|
|
|
+ Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
+ return taskRepo.findByNameLikeAndIsDeleted("%" + name +"%", DeletedStatus.isNotDeleted).stream().map(crowdTestTask -> {
|
|
//根据code值查询出来该任务的type
|
|
//根据code值查询出来该任务的type
|
|
- Optional<TestTypePO> serviceType = testTypeDao.findByCode(crowdTestTaskPO.getType());
|
|
|
|
- CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
|
|
- BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
|
|
- crowdTestTask.setType(serviceType.get().getName());
|
|
|
|
|
|
+ crowdTestTask.setType(testMap.get(crowdTestTask.getType()));
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
- }).collect(Collectors.toList()).stream().sorted(Comparator.comparing(CrowdTaskVO::getCreateTime).reversed()).collect(Collectors.toList()));
|
|
|
|
- return authingList;
|
|
|
|
|
|
+ }).sorted(Comparator.comparing(CrowdTaskVO::getStatus).thenComparing(CrowdTaskVO::getCreateTime)).collect(Collectors.toList());
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public List<CrowdTestProjectVO> AllByPage(){
|
|
public List<CrowdTestProjectVO> AllByPage(){
|
|
- List<CrowdTestProjectVO> authingList = new ArrayList<>();
|
|
|
|
|
|
+ List<CrowdTestProjectVO> resultList = new ArrayList<>();
|
|
Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
Map<String, String> applicationMap = commonRepo.getApplicationCodeNameMap();
|
|
- authingList.addAll(projectDao.findAll().stream().map(crowdTestProjectPO ->{
|
|
|
|
|
|
+ resultList.addAll(projectDao.findAll().stream().map(crowdTestProjectPO ->{
|
|
CrowdTestProject crowdTestProject = new CrowdTestProject();
|
|
CrowdTestProject crowdTestProject = new CrowdTestProject();
|
|
BeanUtils.copyProperties(crowdTestProjectPO, crowdTestProject);
|
|
BeanUtils.copyProperties(crowdTestProjectPO, crowdTestProject);
|
|
themeStatusService.updateStatus(crowdTestProject);
|
|
themeStatusService.updateStatus(crowdTestProject);
|
|
@@ -1203,7 +1264,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
crowdTestProjectVO.setApplicationType(applicationMap.get(crowdTestProjectPO.getApplicationType()));
|
|
crowdTestProjectVO.setApplicationType(applicationMap.get(crowdTestProjectPO.getApplicationType()));
|
|
return crowdTestProjectVO;
|
|
return crowdTestProjectVO;
|
|
}).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()));
|
|
- return authingList;
|
|
|
|
|
|
+ return resultList;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -1211,37 +1272,12 @@ public class WebMediatorImpl implements ViewMediator {
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- public List<CrowdTestProjectVO> hotCrowdTestProjects() {
|
|
|
|
- List<CrowdTestProjectVO> authingList = new ArrayList<>();
|
|
|
|
- authingList.addAll(projectDao.findall().stream().map(crowdTestProjectPO -> {
|
|
|
|
- CrowdTestProject crowdTestProject = new CrowdTestProject();
|
|
|
|
- BeanUtils.copyProperties(crowdTestProjectPO, crowdTestProject);
|
|
|
|
- return new CrowdTestProjectVO(crowdTestProject);
|
|
|
|
- }).collect(Collectors.toList()));
|
|
|
|
- return authingList;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- @Override
|
|
|
|
- //众测广场首页6条项目
|
|
|
|
- public List<CrowdTestProjectVO> indexCrowdTestProjects() {
|
|
|
|
- List<CrowdTestProjectVO> authingList = new ArrayList<>();
|
|
|
|
- authingList.addAll(projectDao.findindexProject().stream().map(crowdTestProjectPO -> {
|
|
|
|
- CrowdTestProject crowdTestProject = new CrowdTestProject();
|
|
|
|
- BeanUtils.copyProperties(crowdTestProjectPO, crowdTestProject);
|
|
|
|
- // 应用类型值的转换
|
|
|
|
- Optional<ApplicationTypePO> applicationTypePO = applicationTypeDao.findByCode(crowdTestProject.getApplicationType());
|
|
|
|
- if (applicationTypePO.isPresent()) {
|
|
|
|
- crowdTestProject.setApplicationType(applicationTypePO.get().getName());
|
|
|
|
- } else {
|
|
|
|
- throw new HttpBadRequestException("应用类型有误");
|
|
|
|
- }
|
|
|
|
- return new CrowdTestProjectVO(crowdTestProject);
|
|
|
|
-
|
|
|
|
- }).collect(Collectors.toList()));
|
|
|
|
- return authingList;
|
|
|
|
|
|
+ public List<CrowdTestProjectVO> hotProjectCardLimitCount(int projectCount) {
|
|
|
|
+ List<CrowdTestProjectVO> resultList = new ArrayList<>();
|
|
|
|
+ resultList.addAll(projectRepo.findHotProjectCardLimitCount(projectCount).stream().map(CrowdTestProjectVO::new).collect(Collectors.toList()));
|
|
|
|
+ return resultList;
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public List<CrowdTestProjectVO> crowdTestProjectsWaitingAccept() {
|
|
public List<CrowdTestProjectVO> crowdTestProjectsWaitingAccept() {
|
|
return projectDao.findAll().stream().filter(crowdTestProjectPO -> crowdTestProjectPO.getStatus() == CrowdTestProjectStatus.HAS_RELEASED
|
|
return projectDao.findAll().stream().filter(crowdTestProjectPO -> crowdTestProjectPO.getStatus() == CrowdTestProjectStatus.HAS_RELEASED
|
|
@@ -1284,42 +1320,44 @@ public class WebMediatorImpl implements ViewMediator {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 众测广场首页展示的众测任务
|
|
|
|
|
|
+ * 众测广场首页展示的6个众测任务
|
|
* @return
|
|
* @return
|
|
|
|
+ * @param indexCount
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- public List<CrowdTaskVO> crowdTaskVos(){
|
|
|
|
- List<CrowdTaskVO> authingList = new ArrayList<>();
|
|
|
|
- Map<String, String> typeMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
- authingList.addAll(taskDao.findindexTask().stream().filter(crowdTestTaskPO -> crowdTestTaskPO.getDeadTime().getTime() > System.currentTimeMillis()).map(crowdTestTaskPO -> {
|
|
|
|
|
|
+ public List<CrowdTaskVO> findIndexTaskLimitCount(int indexCount){
|
|
|
|
+ List<CrowdTaskVO> resultList = new ArrayList<>();
|
|
|
|
+ Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
+
|
|
|
|
+ resultList.addAll(taskDao.findIndexTaskLimitCount(indexCount).stream().filter(crowdTestTaskPO -> crowdTestTaskPO.getDeadTime().getTime() > System.currentTimeMillis()).map(crowdTestTaskPO -> {
|
|
CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
- crowdTestTask.setType(typeMap.get(crowdTestTaskPO.getType()));
|
|
|
|
|
|
+ crowdTestTask.setType(testMap.get(crowdTestTaskPO.getType()));
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
}).collect(Collectors.toList()));
|
|
}).collect(Collectors.toList()));
|
|
- return authingList;
|
|
|
|
|
|
+ return resultList;
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public List<CrowdTaskVO> crowdTaskVOSByTestTypeCode(String testTypeCode) {
|
|
public List<CrowdTaskVO> crowdTaskVOSByTestTypeCode(String testTypeCode) {
|
|
- Map<String, String> typeMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
|
|
+ Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
return taskDao.findByType(testTypeCode).stream().map(crowdTestTaskPO -> {
|
|
return taskDao.findByType(testTypeCode).stream().map(crowdTestTaskPO -> {
|
|
CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
- crowdTestTask.setType(typeMap.get(crowdTestTaskPO.getType()));
|
|
|
|
|
|
+ crowdTestTask.setType(testMap.get(crowdTestTaskPO.getType()));
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ // ???
|
|
@Override
|
|
@Override
|
|
public List<CrowdTaskVO> crowdTaskVosWaitingAccept() {
|
|
public List<CrowdTaskVO> crowdTaskVosWaitingAccept() {
|
|
- List<CrowdTestTaskPO> canAcceptTask = taskDao.findCanAcceptTask();
|
|
|
|
- List<CrowdTaskVO> taskVOList = canAcceptTask.stream().filter(crowdTestTaskPO -> crowdTestTaskPO.getDeadTime().getTime() > System.currentTimeMillis()).map(crowdTestTaskPO -> {
|
|
|
|
|
|
+ Map<String, String> testMap = commonRepo.getTypeCodeNameMap();
|
|
|
|
+ List<CrowdTaskVO> taskVOList = taskDao.findCanAcceptTask().stream().filter(crowdTestTaskPO -> crowdTestTaskPO.getDeadTime().getTime() > System.currentTimeMillis()).map(crowdTestTaskPO -> {
|
|
//根据code值查询出来该任务的type
|
|
//根据code值查询出来该任务的type
|
|
- Optional<TestTypePO> serviceType = testTypeDao.findByCode(crowdTestTaskPO.getType());
|
|
|
|
CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
- crowdTestTask.setType(serviceType.get().getName());
|
|
|
|
|
|
+ crowdTestTask.setType(testMap.get(crowdTestTaskPO.getType()));
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
return taskVOList;
|
|
return taskVOList;
|