| | |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.time.LocalDateTime; |
|---|
| | | import java.time.format.DateTimeFormatter; |
|---|
| | | import java.util.Date; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * <p> |
|---|
| | | * 调度处理 服务实现类 |
|---|
| | | * 调度处理 服务实现类 |
|---|
| | | * </p> |
|---|
| | | * |
|---|
| | | * @author mg |
|---|
| | |
|---|
| | | DisposeRecordMapper disposeRecordMapper; |
|---|
| | | @Resource |
|---|
| | | WorkflowConfigStepMapper workflowConfigStepMapper; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public DispatchInfo dispatch(DispatchInfoParam dispatchInfoParam) { |
|---|
| | | //新增调度信息 |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | UpdateWrapper<DisposeRecord> updateWrapper = new UpdateWrapper<>(); |
|---|
| | | updateWrapper.eq("base_case_id", baseCase.getId()).eq("workflow_config_step_id",workflowConfigStep.getId()); |
|---|
| | | updateWrapper.eq("base_case_id", baseCase.getId()).eq("workflow_config_step_id", workflowConfigStep.getId()); |
|---|
| | | |
|---|
| | | //修改调度记录 |
|---|
| | | DisposeRecord disposeRecord = new DisposeRecord(); |
|---|
| | |
|---|
| | | stepNextRecord.setWorkflowConfigStepId(stepNext.getId()); |
|---|
| | | stepNextRecord.setStepName(stepNext.getName()); |
|---|
| | | stepNextRecord.setHandlerRoleId(stepNext.getRoleId()); |
|---|
| | | stepNextRecord.setLimitTime(LocalDateTime.parse(dispatchInfoParam.getDisposeDate(), DateTimeFormatter.ofPattern("yyyy-MM-dd hh:mm:ss"))); |
|---|
| | | //上传处置未结束 |
|---|
| | | stepNextRecord.setState(0); |
|---|
| | | stepNextRecord.setStartTime(LocalDateTime.now()); |
|---|
