|
@@ -1,12 +1,14 @@
|
|
|
package com.mooctest.crowd.site.service.impl;
|
|
package com.mooctest.crowd.site.service.impl;
|
|
|
|
|
|
|
|
import com.mooctest.crowd.domain.dao.CrowdTestTaskDao;
|
|
import com.mooctest.crowd.domain.dao.CrowdTestTaskDao;
|
|
|
|
|
+import com.mooctest.crowd.domain.dao.EvaluationAgencyDao;
|
|
|
import com.mooctest.crowd.domain.domainobject.CrowdTestProject;
|
|
import com.mooctest.crowd.domain.domainobject.CrowdTestProject;
|
|
|
import com.mooctest.crowd.domain.domainobject.CrowdTestTask;
|
|
import com.mooctest.crowd.domain.domainobject.CrowdTestTask;
|
|
|
import com.mooctest.crowd.domain.domainobject.CrowdTestTaskStatus;
|
|
import com.mooctest.crowd.domain.domainobject.CrowdTestTaskStatus;
|
|
|
import com.mooctest.crowd.domain.exception.BaseException;
|
|
import com.mooctest.crowd.domain.exception.BaseException;
|
|
|
import com.mooctest.crowd.domain.exception.CrowdTestTaskNotExistException;
|
|
import com.mooctest.crowd.domain.exception.CrowdTestTaskNotExistException;
|
|
|
import com.mooctest.crowd.domain.factory.CrowdTestProjectFactory;
|
|
import com.mooctest.crowd.domain.factory.CrowdTestProjectFactory;
|
|
|
|
|
+import com.mooctest.crowd.domain.model.EvaluationAgencyPO;
|
|
|
import com.mooctest.crowd.domain.repository.CrowdTestProjectRepo;
|
|
import com.mooctest.crowd.domain.repository.CrowdTestProjectRepo;
|
|
|
import com.mooctest.crowd.site.command.CrowdTestTaskCommand;
|
|
import com.mooctest.crowd.site.command.CrowdTestTaskCommand;
|
|
|
import com.mooctest.crowd.site.data.dto.TaskDetailsDTO;
|
|
import com.mooctest.crowd.site.data.dto.TaskDetailsDTO;
|
|
@@ -44,6 +46,9 @@ public class CrowdTaskServiceImpl implements CrowdTaskService {
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private ViewMediator viewMediator;
|
|
private ViewMediator viewMediator;
|
|
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private EvaluationAgencyDao agencyDao;
|
|
|
|
|
+
|
|
|
// @Autowired
|
|
// @Autowired
|
|
|
// GenerateFlowCodeUtil codeUtil;
|
|
// GenerateFlowCodeUtil codeUtil;
|
|
|
|
|
|
|
@@ -54,7 +59,10 @@ public class CrowdTaskServiceImpl implements CrowdTaskService {
|
|
|
Optional<CrowdTestTask> task = project.getCrowdTestTaskList().stream().filter(crowdTestTask -> crowdTestTask.getCode().equals(taskCode)).findFirst();
|
|
Optional<CrowdTestTask> task = project.getCrowdTestTaskList().stream().filter(crowdTestTask -> crowdTestTask.getCode().equals(taskCode)).findFirst();
|
|
|
if (!task.isPresent())
|
|
if (!task.isPresent())
|
|
|
throw new CrowdTestTaskNotExistException();
|
|
throw new CrowdTestTaskNotExistException();
|
|
|
- taskDetailsDTO.setCrowdTaskVO(new CrowdTaskVO(task.get()));
|
|
|
|
|
|
|
+ CrowdTaskVO taskVO = new CrowdTaskVO(task.get());
|
|
|
|
|
+ EvaluationAgencyPO agencyPO = agencyDao.findByUserId(task.get().getEvaluationAgencyId());
|
|
|
|
|
+ taskVO.setInstitution(agencyPO==null?"该机构已注销":agencyPO.getEvaluationAgencyName());
|
|
|
|
|
+ taskDetailsDTO.setCrowdTaskVO(taskVO);
|
|
|
List<CrowdReportVO> reportVOList = task.get().getCrowdTestReportList()
|
|
List<CrowdReportVO> reportVOList = task.get().getCrowdTestReportList()
|
|
|
.stream().map(crowdTestReport -> {
|
|
.stream().map(crowdTestReport -> {
|
|
|
return new CrowdReportVO(crowdTestReport);
|
|
return new CrowdReportVO(crowdTestReport);
|
|
@@ -67,7 +75,7 @@ public class CrowdTaskServiceImpl implements CrowdTaskService {
|
|
|
public TaskDetailsDTO createTask(String projectCode, CrowdTestTaskCommand command) {
|
|
public TaskDetailsDTO createTask(String projectCode, CrowdTestTaskCommand command) {
|
|
|
CrowdTestTask task = command.toCrowdTask(projectCode);
|
|
CrowdTestTask task = command.toCrowdTask(projectCode);
|
|
|
CrowdTestProject project = projectRepo.getByProjectCode(projectCode);
|
|
CrowdTestProject project = projectRepo.getByProjectCode(projectCode);
|
|
|
- String taskCode = GenerateFlowCodeUtil.generateFlowCode("TASK-"+ command.getType());
|
|
|
|
|
|
|
+ String taskCode = GenerateFlowCodeUtil.generateFlowCode("TASK-"+ ProjectType.getCode(command.getType()));
|
|
|
task.setCode(taskCode);
|
|
task.setCode(taskCode);
|
|
|
task.setStatus(CrowdTestTaskStatus.HAS_CREATED);
|
|
task.setStatus(CrowdTestTaskStatus.HAS_CREATED);
|
|
|
project.addTask(task);
|
|
project.addTask(task);
|