Commit 02615b58 authored by 韩桐桐's avatar 韩桐桐

fix(注销报废):添加代办任务model字段传参dto

parent a14f4046
...@@ -12,6 +12,7 @@ import com.yeejoin.amos.boot.biz.common.bo.ReginParams; ...@@ -12,6 +12,7 @@ import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
import com.yeejoin.amos.boot.biz.common.utils.RedisKey; import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
import com.yeejoin.amos.boot.biz.common.utils.RedisUtils; import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
import com.yeejoin.amos.boot.module.jg.api.dto.JgScrapCancelDto; import com.yeejoin.amos.boot.module.jg.api.dto.JgScrapCancelDto;
import com.yeejoin.amos.boot.module.jg.api.dto.TaskMessageDto;
import com.yeejoin.amos.boot.module.jg.api.dto.TaskModelDto; import com.yeejoin.amos.boot.module.jg.api.dto.TaskModelDto;
import com.yeejoin.amos.boot.module.jg.api.dto.WorkflowResultDto; import com.yeejoin.amos.boot.module.jg.api.dto.WorkflowResultDto;
import com.yeejoin.amos.boot.module.jg.api.entity.JgScrapCancel; import com.yeejoin.amos.boot.module.jg.api.entity.JgScrapCancel;
...@@ -67,7 +68,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -67,7 +68,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
private static final String SUBMIT_TYPE_FLOW = "1"; private static final String SUBMIT_TYPE_FLOW = "1";
private static final String PAGE_KEY = "jgScrapCancelAdd"; private static final String PAGE_KEY = "jgScrapCancelAdd";
private static String template = "来自电梯【%s】【%s】的业务办理,【申请单号:%s】"; private static final String template = "来自电梯【%s】【%s】的业务办理,【申请单号:%s】";
@Autowired @Autowired
WorkFlowFeignService workFlowFeginService; WorkFlowFeignService workFlowFeginService;
@Autowired @Autowired
...@@ -98,7 +99,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -98,7 +99,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
/** /**
* 移装移装报废/注销报废判断 * 移装移装报废/注销报废判断
* *
* @return * @return BusinessTypeEnum 业务对应枚举
*/ */
public static BusinessTypeEnum businessTypeJudgment(String type) { public static BusinessTypeEnum businessTypeJudgment(String type) {
return "1".equals(type) ? BusinessTypeEnum.JG_EQUIPMENT_CANCEL : BusinessTypeEnum.JG_EQUIPMENT_MOVE; return "1".equals(type) ? BusinessTypeEnum.JG_EQUIPMENT_CANCEL : BusinessTypeEnum.JG_EQUIPMENT_MOVE;
...@@ -185,7 +186,6 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -185,7 +186,6 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
return; return;
} }
// 判断当前是否为提交 // 判断当前是否为提交
List<String> instanceIdList = new ArrayList<>();
List<WorkflowResultDto> workflowResultDtos = null; List<WorkflowResultDto> workflowResultDtos = null;
if (SUBMIT_TYPE_FLOW.equals(submitType)) { if (SUBMIT_TYPE_FLOW.equals(submitType)) {
// 发起流程 // 发起流程
...@@ -252,8 +252,8 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -252,8 +252,8 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
this.saveBatch(list); this.saveBatch(list);
if (SUBMIT_TYPE_FLOW.equals(submitType)) { if (SUBMIT_TYPE_FLOW.equals(submitType)) {
// 新增代办 // 新增代办
for (int i = 0; i < list.size(); i++) { for (JgScrapCancel jgScrapCancel : list) {
this.createTaskModel(list.get(i), taskName[0], submitType, nextUserIds); this.createTaskModel(jgScrapCancel, taskName[0], submitType, nextUserIds);
} }
} }
List<JgScrapCancelEq> jgScrapCancelEqList = equipList.stream().map(t -> { List<JgScrapCancelEq> jgScrapCancelEqList = equipList.stream().map(t -> {
...@@ -264,31 +264,35 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -264,31 +264,35 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
jgScrapCancelEqService.saveBatch(jgScrapCancelEqList); jgScrapCancelEqService.saveBatch(jgScrapCancelEqList);
} }
private void createTaskModel(JgScrapCancel dto, String taskName, String submitType, String nextUserIds) { private void createTaskModel(JgScrapCancel scrapCancel, String taskName, String submitType, String nextUserIds) {
ReginParams reginParams = JSON.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class); ReginParams reginParams = JSON.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
if ("1".equals(submitType)) { if ("1".equals(submitType)) {
TaskModelDto taskModelDto = new TaskModelDto(); TaskModelDto taskModelDto = new TaskModelDto();
taskModelDto.setFlowCreateDate(dto.getCreateDate()); taskModelDto.setFlowCreateDate(scrapCancel.getCreateDate());
taskModelDto.setTaskName(taskName); taskModelDto.setTaskName(taskName);
taskModelDto.setTaskCode(dto.getApplyNo()); taskModelDto.setTaskCode(scrapCancel.getApplyNo());
taskModelDto.setTaskContent(this.buildTaskContent(dto.getSupervisoryCode(), dto.getCancelType(), dto.getApplyNo())); taskModelDto.setTaskContent(this.buildTaskContent(scrapCancel.getSupervisoryCode(),
scrapCancel.getCancelType(), scrapCancel.getApplyNo()));
taskModelDto.setTaskDesc(""); taskModelDto.setTaskDesc("");
taskModelDto.setTaskType(businessTypeJudgment(dto.getCancelType()).getCode()); taskModelDto.setTaskType(businessTypeJudgment(scrapCancel.getCancelType()).getCode());
taskModelDto.setTaskTypeLabel(businessTypeJudgment(dto.getCancelType()).getName()); taskModelDto.setTaskTypeLabel(businessTypeJudgment(scrapCancel.getCancelType()).getName());
taskModelDto.setRelationId(dto.getInstanceId()); taskModelDto.setRelationId(scrapCancel.getInstanceId());
taskModelDto.setExecuteUserIds(nextUserIds); taskModelDto.setExecuteUserIds(nextUserIds);
FlowStatusEnum flowStatusEnum = this.getTaskStatus(submitType); FlowStatusEnum flowStatusEnum = this.getTaskStatus(submitType);
taskModelDto.setTaskStatus(flowStatusEnum.getCode()); taskModelDto.setTaskStatus(flowStatusEnum.getCode());
taskModelDto.setTaskStatusLabel(flowStatusEnum.getName()); taskModelDto.setTaskStatusLabel(flowStatusEnum.getName());
taskModelDto.setFlowStatus(this.getTaskStatusByName(dto.getAuditStatus())); taskModelDto.setFlowStatus(this.getTaskStatusByName(scrapCancel.getAuditStatus()));
taskModelDto.setFlowStatusLabel(dto.getAuditStatus()); taskModelDto.setFlowStatusLabel(scrapCancel.getAuditStatus());
taskModelDto.setStartUserId(dto.getCreateUserId()); taskModelDto.setStartUserId(scrapCancel.getCreateUserId());
taskModelDto.setFlowCode(dto.getNextTaskId()); taskModelDto.setFlowCode(scrapCancel.getNextTaskId());
taskModelDto.setStartUser(reginParams.getUserModel().getRealName()); taskModelDto.setStartUser(reginParams.getUserModel().getRealName());
taskModelDto.setStartUserCompanyName(dto.getUseUnitName()); taskModelDto.setStartUserCompanyName(scrapCancel.getUseUnitName());
taskModelDto.setNextExecuteUser(dto.getNextExecuteIds()); taskModelDto.setNextExecuteUser(scrapCancel.getNextExecuteIds());
taskModelDto.setStartDate(dto.getCreateDate()); taskModelDto.setStartDate(scrapCancel.getCreateDate());
taskModelDto.setModel(dto); TaskMessageDto taskMessageDto = new TaskMessageDto();
BeanUtils.copyProperties(scrapCancel, taskMessageDto);
taskMessageDto.setStatus(scrapCancel.getAuditStatus());
taskModelDto.setModel(taskMessageDto);
commonService.buildTaskModel(Collections.singletonList(taskModelDto)); commonService.buildTaskModel(Collections.singletonList(taskModelDto));
} }
} }
...@@ -444,7 +448,10 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -444,7 +448,10 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
TaskModelDto modelDto = new TaskModelDto(); TaskModelDto modelDto = new TaskModelDto();
BeanUtil.copyProperties(taskV2Model, modelDto); BeanUtil.copyProperties(taskV2Model, modelDto);
modelDto.setNextExecuteUser(jgScrapCancelDto.getNextExecuteIds()); modelDto.setNextExecuteUser(jgScrapCancelDto.getNextExecuteIds());
modelDto.setModel(jgScrapCancelDto); TaskMessageDto taskMessageDto = new TaskMessageDto();
BeanUtils.copyProperties(jgScrapCancelDto, taskMessageDto);
taskMessageDto.setStatus(jgScrapCancelDto.getAuditStatus());
modelDto.setModel(taskMessageDto);
commonService.buildTaskModel(Collections.singletonList(modelDto)); commonService.buildTaskModel(Collections.singletonList(modelDto));
} }
...@@ -521,7 +528,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -521,7 +528,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
ProcessTaskDTO processTaskDTO = cmWorkflowService.rollBack(instanceId); ProcessTaskDTO processTaskDTO = cmWorkflowService.rollBack(instanceId);
WorkflowResultDto workflowResultDto = commonService.buildWorkFlowInfo(Collections.singletonList(processTaskDTO)).get(0); WorkflowResultDto workflowResultDto = commonService.buildWorkFlowInfo(Collections.singletonList(processTaskDTO)).get(0);
if (!FlowStatusEnum.TO_BE_FINISHED.getName().equals(workflowResultDto.getNextTaskName())) { if (!FlowStatusEnum.TO_BE_FINISHED.getName().equals(workflowResultDto.getNextTaskName())) {
jgScrapCancel.setAuditStatus(WorkFlowStatusEnum.getMessage(workflowResultDto.getNextTaskCode()).getRollBack()); jgScrapCancel.setAuditStatus(Objects.requireNonNull(WorkFlowStatusEnum.getMessage(workflowResultDto.getNextTaskCode())).getRollBack());
} }
jgScrapCancel.setNextTaskId(workflowResultDto.getNextTaskId()); jgScrapCancel.setNextTaskId(workflowResultDto.getNextTaskId());
List<WorkflowResultDto> workflowResultDtos = commonService.buildWorkFlowInfo(Collections.singletonList(processTaskDTO)); List<WorkflowResultDto> workflowResultDtos = commonService.buildWorkFlowInfo(Collections.singletonList(processTaskDTO));
...@@ -579,7 +586,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -579,7 +586,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
String taskName = ""; String taskName = "";
String nextTaskId = ""; String nextTaskId = "";
JgScrapCancel jgScrapCancel = this.getBaseMapper().selectById(sequenceNbr); JgScrapCancel jgScrapCancel = this.getBaseMapper().selectById(sequenceNbr);
if (processTaskDTO != null && processTaskDTO.getNextTask() != null && processTaskDTO.getNextTask().size() > 0) { if (processTaskDTO != null && processTaskDTO.getNextTask() != null && !processTaskDTO.getNextTask().isEmpty()) {
taskCode = processTaskDTO.getNextTask().get(0).getKey(); taskCode = processTaskDTO.getNextTask().get(0).getKey();
taskName = processTaskDTO.getNextTask().get(0).getName(); taskName = processTaskDTO.getNextTask().get(0).getName();
nextTaskId = processTaskDTO.getNextTask().get(0).getId(); nextTaskId = processTaskDTO.getNextTask().get(0).getId();
...@@ -601,10 +608,10 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -601,10 +608,10 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
} }
if ("0".equals(operate)) { if ("0".equals(operate)) {
// 通过操作 // 通过操作
jgScrapCancel.setAuditStatus(WorkFlowStatusEnum.getMessage(taskCode).getPass()); jgScrapCancel.setAuditStatus(Objects.requireNonNull(WorkFlowStatusEnum.getMessage(taskCode)).getPass());
} else { } else {
// 驳回操作 // 驳回操作
jgScrapCancel.setAuditStatus(WorkFlowStatusEnum.getMessage(taskCode).getReject()); jgScrapCancel.setAuditStatus(Objects.requireNonNull(WorkFlowStatusEnum.getMessage(taskCode)).getReject());
jgScrapCancel.setPromoter(null); jgScrapCancel.setPromoter(null);
} }
JgScrapCancelDto scrapCancelDto = new JgScrapCancelDto(); JgScrapCancelDto scrapCancelDto = new JgScrapCancelDto();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment