From 87a3956718767eb62e82817465ce5a4812740334 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Wed, 17 Jul 2024 19:22:15 +0800 Subject: [PATCH 01/15] =?UTF-8?q?feat:=20=E6=B1=87=E6=80=BB=E8=8A=82?= =?UTF-8?q?=E7=82=B9=E8=AE=BE=E7=BD=AE=E6=B5=81=E7=A8=8B=E5=8F=98=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/ProcessSCCEndListener.java | 4 +++- .../ProcessStandardComplianceCheckServiceImpl.java | 12 ++++++++++++ 2 files changed, 15 insertions(+), 1 deletion(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/listener/ProcessSCCEndListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/listener/ProcessSCCEndListener.java index 9e54de20..2f48773f 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/listener/ProcessSCCEndListener.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/listener/ProcessSCCEndListener.java @@ -15,6 +15,8 @@ public class ProcessSCCEndListener implements ExecutionListener { @Override public void notify(DelegateExecution delegateExecution) { - log.info("流程结束"); + log.info("法规符合性排查流程结束监听器开始执行"); + + log.info("法规符合性排查流程结束监听器结束执行"); } } diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java index b1dcd914..d341e1c0 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java @@ -355,6 +355,18 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl counterSignUserList = Arrays.asList(standardInfo.getCountersignUser().split(",")); + List managerList = Arrays.asList(standardInfo.getManager().split(",")); + List seniorMangagerList = Arrays.asList(standardInfo.getSeniorManager().split(",")); + runtimeService.setVariable(processInstanceId, COUNTERSIGN_USER_LIST, counterSignUserList); + runtimeService.setVariable(processInstanceId, MANAGER_LIST, managerList); + runtimeService.setVariable(processInstanceId, SENIOR_MANAGER_LIST, seniorMangagerList); + // 保存选人信息 + userMap.put(COUNTERSIGN_USER_LIST, standardInfo.getCountersignUser()); + userMap.put(MANAGER_LIST, standardInfo.getManager()); + userMap.put(SENIOR_MANAGER_LIST, standardInfo.getSeniorManager()); + processNodeLinkService.saveNodeUserLink(processDefinitionId, processInstanceId, userMap); break; } runtimeService.setVariable(processInstanceId, PASS, true); From 9364401c1d1915d43ad38022ac17fba2355d55e1 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Wed, 17 Jul 2024 19:38:04 +0800 Subject: [PATCH 02/15] =?UTF-8?q?feat:=20=E9=80=9A=E7=94=A8=E4=BF=9D?= =?UTF-8?q?=E5=AD=98=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../activiti/controller/WorkCenterController.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java b/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java index 344b937a..e8e6b3eb 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java @@ -21,11 +21,13 @@ import com.jero.modules.activiti.process.common.entity.ProcessSnapshot; import com.jero.modules.activiti.process.common.service.ActFlowCommonService; import com.jero.modules.activiti.process.common.service.ProcessDraftService; import com.jero.modules.activiti.process.fb.service.IProcessHandleService; +import com.jero.modules.activiti.process.fb.vo.ProcessInfoVO; import com.jero.modules.activiti.service.ProcessAllService; import com.jero.modules.activiti.service.ProcessApprovalRecordService; import com.jero.modules.activiti.vo.DelegateTaskParam; import com.jero.modules.activiti.vo.ResolveTaskParam; import com.jero.modules.laws.common.util.CurrentUserUtil; +import com.jero.modules.sys.utils.UserUtils; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; @@ -33,6 +35,7 @@ import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.jetbrains.annotations.NotNull; +import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; @@ -271,4 +274,16 @@ public class WorkCenterController { return Result.OK(actFlowCommonService.getExistSnapshot(snapshotId)); } + /** + * 保存到草稿 + * @param + */ + @AutoLog(value = "保存") + @ApiOperation(value="保存", notes="保存") + @PostMapping("/save") + public Result save(@Validated @RequestBody ProcessInfoVO processInfoVO) { + processHandleService.saveToDraft(processInfoVO, UserUtils.getUserId()); + return Result.OK(); + } + } From be809bc752ab6d1d2984f6dd4c30a71eef58c53f Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 08:27:02 +0800 Subject: [PATCH 03/15] =?UTF-8?q?feat:=20scc=E6=B5=81=E7=A8=8B=E7=BB=93?= =?UTF-8?q?=E6=9D=9F=E5=85=A5=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...ocessStandardComplianceCheckConstants.java | 6 ++ .../listener/ProcessSCCEndListener.java | 59 ++++++++++++++++++- 2 files changed, 64 insertions(+), 1 deletion(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/common/ProcessStandardComplianceCheckConstants.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/common/ProcessStandardComplianceCheckConstants.java index a252e2bc..60f9705a 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/common/ProcessStandardComplianceCheckConstants.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/common/ProcessStandardComplianceCheckConstants.java @@ -73,4 +73,10 @@ public class ProcessStandardComplianceCheckConstants { public static final String AUTO_TASK_1 = "sid-95E41F78-FE01-4FEC-BF8B-EC11DFBA8824"; public static final String AUTO_TASK_2 = "autoTask_2"; public static final String AUTO_TASK_3 = "autoTask_3"; + + public static final String CONFORM_TO = "1"; + public static final String DISCREPANCY = "2"; + public static final String NOT_INVOLVE = "3"; + public static final String TO_BE_VERIFIED = "4"; + } diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/listener/ProcessSCCEndListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/listener/ProcessSCCEndListener.java index 2f48773f..5f24c284 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/listener/ProcessSCCEndListener.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/listener/ProcessSCCEndListener.java @@ -1,10 +1,28 @@ package com.jero.modules.activiti.process.standardComplianceCheck.listener; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.jero.modules.activiti.process.standardComplianceCheck.entity.ProcessStandardComplianceCheck; +import com.jero.modules.activiti.process.standardComplianceCheck.entity.ProcessStandardComplianceCheckDetail; +import com.jero.modules.activiti.process.standardComplianceCheck.service.IProcessStandardComplianceCheckDetailService; +import com.jero.modules.activiti.process.standardComplianceCheck.service.IProcessStandardComplianceCheckService; +import com.jero.modules.assessmentLibrary.entity.LawsConformityAssessmentLibrary; +import com.jero.modules.assessmentLibrary.entity.LawsConformityAssessmentLibraryDetail; +import com.jero.modules.assessmentLibrary.entity.LawsEvaluationNotMetLibrary; +import com.jero.modules.assessmentLibrary.service.ILawsConformityAssessmentLibraryDetailService; +import com.jero.modules.assessmentLibrary.service.ILawsConformityAssessmentLibraryService; +import com.jero.modules.assessmentLibrary.service.ILawsEvaluationNotMetLibraryService; +import com.jero.modules.laws.enterprise.util.BeanCopyUtils; import lombok.extern.slf4j.Slf4j; import org.activiti.engine.delegate.DelegateExecution; import org.activiti.engine.delegate.ExecutionListener; import org.springframework.stereotype.Component; +import javax.annotation.Resource; +import java.util.List; +import java.util.stream.Collectors; + +import static com.jero.modules.activiti.process.standardComplianceCheck.common.ProcessStandardComplianceCheckConstants.*; + /** * @author liJiaRao * @date 2023-06-18 15:43 @@ -13,10 +31,49 @@ import org.springframework.stereotype.Component; @Component public class ProcessSCCEndListener implements ExecutionListener { + @Resource + private IProcessStandardComplianceCheckService sccService; + + @Resource + private IProcessStandardComplianceCheckDetailService sccDetailService; + + @Resource + private ILawsConformityAssessmentLibraryService calService; + + @Resource + private ILawsConformityAssessmentLibraryDetailService calDetailService; + + @Resource + private ILawsEvaluationNotMetLibraryService notMetService; + @Override public void notify(DelegateExecution delegateExecution) { log.info("法规符合性排查流程结束监听器开始执行"); - + LambdaQueryWrapper sccWrapper = new LambdaQueryWrapper<>(); + LambdaQueryWrapper sccDetailWrapper = new LambdaQueryWrapper<>(); + // 找到流程数据 + String processInstanceId = delegateExecution.getProcessInstanceId(); + sccWrapper.eq(ProcessStandardComplianceCheck::getProcessInstanceId, processInstanceId); + ProcessStandardComplianceCheck scc = sccService.getOne(sccWrapper); + // 找到条款数据 + sccDetailWrapper.eq(ProcessStandardComplianceCheckDetail::getCheckId, scc.getId()); + List list = sccDetailService.list(sccDetailWrapper); + // 入库保存 + LawsConformityAssessmentLibrary lawsConformityAssessmentLibrary = BeanCopyUtils.copyBean(scc, LawsConformityAssessmentLibrary.class); + lawsConformityAssessmentLibrary.setId(null); + calService.save(lawsConformityAssessmentLibrary); + List lawsConformityAssessmentLibraryDetails = BeanCopyUtils.copyBeanList(list, LawsConformityAssessmentLibraryDetail.class); + lawsConformityAssessmentLibraryDetails.forEach(detail -> { + detail.setBindId(lawsConformityAssessmentLibrary.getId()); + }); + calDetailService.saveBatch(lawsConformityAssessmentLibraryDetails); + // 找出不符合和待验证的存入不符合项库 + List notList = lawsConformityAssessmentLibraryDetails + .stream().filter(detail -> detail.getResult().equals(DISCREPANCY) || + detail.getResult().equals(NOT_INVOLVE)).collect(Collectors.toList()); + List lawsEvaluationNotMetLibraries = BeanCopyUtils.copyBeanList(notList, LawsEvaluationNotMetLibrary.class); + lawsEvaluationNotMetLibraries.forEach(detail -> detail.setId(null)); + notMetService.saveBatch(lawsEvaluationNotMetLibraries); log.info("法规符合性排查流程结束监听器结束执行"); } } From e3def8d17e82cd93d90d21dacf1fdaa20d762058 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 09:00:08 +0800 Subject: [PATCH 04/15] =?UTF-8?q?feat:=20=E8=8D=89=E7=A8=BF=E5=88=A0?= =?UTF-8?q?=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../activiti/controller/WorkCenterController.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java b/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java index e8e6b3eb..8900ba49 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java @@ -286,4 +286,18 @@ public class WorkCenterController { return Result.OK(); } + @AutoLog(value = "删除草稿") + @ApiOperation(value = "删除草稿") + @PostMapping("/deleteDraft") + public Result deleteDraft(@RequestBody Map map) { + String id = map.get("id"); + // 判断当前登录人是否属于草稿的所有人 + ProcessDraft processDraft = processDraftService.getById(id); + if (!CurrentUserUtil.getId().equals(processDraft.getUserId())) { + return Result.error(MessageUtils.getMessage(ResultCommon.NO_PERMISSION)); + } + processDraftService.removeById(id); + return Result.OK(); + } + } From fc17ce088b3c34da9f3d7bfc4e6e610c17cb4b48 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 09:09:31 +0800 Subject: [PATCH 05/15] =?UTF-8?q?fix:=20=E5=BC=BA=E5=88=B6=E6=92=A4?= =?UTF-8?q?=E5=9B=9E=E6=B2=A1=E6=9C=89=E8=8D=89=E7=A8=BF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/jero/modules/activiti/service/ProcessAllService.java | 1 + 1 file changed, 1 insertion(+) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessAllService.java b/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessAllService.java index c064d775..f637a93e 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessAllService.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessAllService.java @@ -228,6 +228,7 @@ public class ProcessAllService extends ServiceImpl processDraftUpdateWrapper.eq(ProcessDraft::getId, processDraft.getId()); processDraftUpdateWrapper.set(ProcessDraft::getSaveSource, null); processDraftUpdateWrapper.set(ProcessDraft::getProcessInstanceId, null); + processDraftUpdateWrapper.set(ProcessDraft::getTaskId, null); processDraftService.update(processDraftUpdateWrapper); } //activiti撤销 From 108a6b97835245b5e53ba92be855a83c2a13bbad Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 09:42:06 +0800 Subject: [PATCH 06/15] =?UTF-8?q?feat:=20=E5=B7=B2=E5=8F=91=E5=B7=B2?= =?UTF-8?q?=E5=8A=9E=E6=9F=A5=E7=9C=8B=E5=8F=AA=E8=83=BD=E6=9F=A5=E7=9C=8B?= =?UTF-8?q?=E8=87=AA=E5=B7=B1=E7=9A=84=E8=8A=82=E7=82=B9=20=E6=B5=81?= =?UTF-8?q?=E7=A8=8B=E7=9B=91=E6=8E=A7=E5=8F=AF=E4=BB=A5=E6=9F=A5=E7=9C=8B?= =?UTF-8?q?=E6=89=80=E6=9C=89=E7=9A=84=E8=8A=82=E7=82=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WorkCenterController.java | 3 ++- .../service/ProcessApprovalRecordService.java | 27 ++++++++++++++----- 2 files changed, 23 insertions(+), 7 deletions(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java b/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java index 8900ba49..ef90294a 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/controller/WorkCenterController.java @@ -134,11 +134,12 @@ public class WorkCenterController { public Result getApprovalRecordList(ProcessApprovalRecord processApprovalRecord, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, + @RequestParam(name = "type") String type, HttpServletRequest req) { Page page = new Page<>(pageNo, pageSize); Page pageList; try { - pageList = processApprovalRecordService.pageList(page, processApprovalRecord, req); + pageList = processApprovalRecordService.pageList(page, processApprovalRecord, type, req); }catch (Exception e){ return Result.error(MessageUtils.getMessage(ResultCommon.ERROR)); } diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessApprovalRecordService.java b/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessApprovalRecordService.java index 6b9c7396..09bd763b 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessApprovalRecordService.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessApprovalRecordService.java @@ -1,6 +1,7 @@ package com.jero.modules.activiti.service; import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; @@ -13,6 +14,7 @@ import com.jero.modules.activiti.mapper.ProcessApprovalRecordMapper; import com.jero.modules.activiti.process.common.entity.ProcessSnapshot; import com.jero.modules.activiti.process.common.service.ProcessSnapshotService; import com.jero.modules.laws.common.util.CurrentUserUtil; +import com.jero.modules.sys.utils.UserUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; @@ -31,6 +33,14 @@ import java.util.stream.Collectors; */ @Service public class ProcessApprovalRecordService extends ServiceImpl { + + // 已办 + public static final String COMPLETED_RECORD_LIST = "1"; + // 已发 + public static final String SENT_RECORD_LIST = "2"; + // 流程监控 + public static final String ALL_RECORD_LIST = "3"; + @Resource private ISysBaseAPI sysBaseAPI; @@ -50,7 +60,9 @@ public class ProcessApprovalRecordService extends ServiceImpl pageList(Page page, ProcessApprovalRecord processApprovalRecord, HttpServletRequest req) { + public Page pageList(Page page, ProcessApprovalRecord processApprovalRecord, String type, HttpServletRequest req) { + boolean allSnapshotFlag = !type.equals(COMPLETED_RECORD_LIST); + String curUserId = UserUtils.getUserId(); QueryWrapper wrapper = new QueryWrapper<>(); if (StringUtils.isNotBlank(processApprovalRecord.getFinishFlagSearch())){ wrapper.in("finish_flag", Arrays.asList(processApprovalRecord.getFinishFlagSearch().split(","))); @@ -66,12 +78,15 @@ public class ProcessApprovalRecordService extends ServiceImpl snapshotList = processSnapshotService.list(processSnapshotWrapper); Map> snapshotMap = snapshotList.stream().collect(Collectors.groupingBy(ProcessSnapshot::getTaskId)); for (ProcessApprovalRecord record : records) { - List processSnapshots = snapshotMap.get(record.getTaskId()); - if (CollUtil.isNotEmpty(processSnapshots)) { - ProcessSnapshot snapshot = processSnapshots.get(0); - record.setSnapshotId(snapshot.getId()); - } String userId = record.getUserId(); + if (StrUtil.isNotBlank(userId) && (allSnapshotFlag || curUserId.equals(userId))) { + List processSnapshots = snapshotMap.get(record.getTaskId()); + if (CollUtil.isNotEmpty(processSnapshots)) { + ProcessSnapshot snapshot = processSnapshots.get(0); + record.setSnapshotId(snapshot.getId()); + } + } + String taskAcceptor = sysBaseAPI.translateUserRealNameFromTable(userId); String delegateBy = record.getDelegateBy(); if (StringUtils.isNotBlank(delegateBy)){ From d55ddecc67c390292f5a7832909b09fc9b768f2c Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 09:47:54 +0800 Subject: [PATCH 07/15] =?UTF-8?q?style:=20=E5=88=A0=E9=99=A4=E6=97=A0?= =?UTF-8?q?=E7=94=A8=E7=9B=91=E5=90=AC=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../activiti/listener/CompleteListener.java | 39 ------------- .../activiti/listener/CreateListener.java | 51 ----------------- .../activiti/listener/EndListener.java | 43 -------------- .../activiti/listener/SignListener.java | 56 ------------------- .../activiti/listener/StartListener.java | 44 --------------- 5 files changed, 233 deletions(-) delete mode 100644 laws-modules/src/main/java/com/jero/modules/activiti/listener/CompleteListener.java delete mode 100644 laws-modules/src/main/java/com/jero/modules/activiti/listener/CreateListener.java delete mode 100644 laws-modules/src/main/java/com/jero/modules/activiti/listener/EndListener.java delete mode 100644 laws-modules/src/main/java/com/jero/modules/activiti/listener/SignListener.java delete mode 100644 laws-modules/src/main/java/com/jero/modules/activiti/listener/StartListener.java diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/listener/CompleteListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/listener/CompleteListener.java deleted file mode 100644 index 5c5bfce9..00000000 --- a/laws-modules/src/main/java/com/jero/modules/activiti/listener/CompleteListener.java +++ /dev/null @@ -1,39 +0,0 @@ -package com.jero.modules.activiti.listener; - -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -import com.jero.common.constant.enums.YesOrNoEnum; -import com.jero.modules.activiti.entity.ProcessApprovalRecord; -import com.jero.modules.activiti.enums.FinishFlagEnum; -import com.jero.modules.activiti.service.ProcessApprovalRecordService; -import com.jero.modules.activiti.util.SpringContextUtil; -import org.activiti.engine.delegate.DelegateTask; -import org.activiti.engine.delegate.TaskListener; - -/** - * @author liJiaRao - * @date 2023-10-15 17:02 - */ -public class CompleteListener implements TaskListener { - @Override - public void notify(DelegateTask delegateTask) { - //流程审批信息转办 - ProcessApprovalRecordService recordService = SpringContextUtil.getBean(ProcessApprovalRecordService.class); - - String taskId = delegateTask.getId(); - String assignee = delegateTask.getAssignee(); - //更新审批信息为完成 - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.eq(ProcessApprovalRecord::getTaskId,taskId); - wrapper.eq(ProcessApprovalRecord::getUserId,assignee); - ProcessApprovalRecord approvalRecord = recordService.getOne(wrapper); - approvalRecord.setFinishFlag(FinishFlagEnum.COMPLETE.getValue()); - recordService.updateById(approvalRecord); - - System.out.println(taskId); - System.out.println(delegateTask.getName()); - System.out.println(delegateTask.getEventName()); - System.out.println(assignee); - - - } -} diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/listener/CreateListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/listener/CreateListener.java deleted file mode 100644 index d9dd1e31..00000000 --- a/laws-modules/src/main/java/com/jero/modules/activiti/listener/CreateListener.java +++ /dev/null @@ -1,51 +0,0 @@ -package com.jero.modules.activiti.listener; - -import com.jero.modules.activiti.entity.ProcessApprovalRecord; -import com.jero.modules.activiti.enums.FinishFlagEnum; -import com.jero.modules.activiti.service.ProcessAllService; -import com.jero.modules.activiti.service.ProcessApprovalRecordService; -import com.jero.modules.activiti.util.SpringContextUtil; -import org.activiti.bpmn.model.ActivitiListener; - -import java.util.Date; - -import org.activiti.engine.delegate.DelegateExecution; - -import java.util.Set; - -import org.activiti.engine.delegate.DelegateTask; -import org.activiti.engine.delegate.TaskListener; -import org.activiti.engine.task.DelegationState; -import org.activiti.engine.task.IdentityLink; - -/** - * @author liJiaRao - * @date 2023-10-13 16:43 - */ -public class CreateListener implements TaskListener { - @Override - public void notify(DelegateTask delegateTask) { - //流程信息 - ProcessAllService processAllService = SpringContextUtil.getBean(ProcessAllService.class); - //流程审批信息 - ProcessApprovalRecordService recordService = SpringContextUtil.getBean(ProcessApprovalRecordService.class); - - String id = delegateTask.getId(); - String name = delegateTask.getName(); - String processInstanceId = delegateTask.getProcessInstanceId(); - Date createTime = delegateTask.getCreateTime(); - String assignee = delegateTask.getAssignee(); - String taskDefinitionKey = delegateTask.getTaskDefinitionKey(); - //新增待审批记录 - ProcessApprovalRecord approvalRecord = new ProcessApprovalRecord(); - approvalRecord.setTaskId(id); - approvalRecord.setTaskName(name); - approvalRecord.setProcessInstanceId(processInstanceId); - approvalRecord.setUserId(assignee); - approvalRecord.setFinishFlag(FinishFlagEnum.INCOMPLETE.getValue()); - approvalRecord.setCreateTime(createTime); - approvalRecord.setNodeId(taskDefinitionKey); - recordService.save(approvalRecord); - - } -} diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/listener/EndListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/listener/EndListener.java deleted file mode 100644 index f1035727..00000000 --- a/laws-modules/src/main/java/com/jero/modules/activiti/listener/EndListener.java +++ /dev/null @@ -1,43 +0,0 @@ -package com.jero.modules.activiti.listener; - -import cn.hutool.core.date.DateBetween; -import cn.hutool.core.date.DateTime; -import cn.hutool.core.date.DateUtil; -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; -import com.jero.modules.activiti.entity.ProcessAll; -import com.jero.modules.activiti.enums.ProcessStatusEnum; -import com.jero.modules.activiti.service.ProcessAllService; -import com.jero.modules.activiti.util.SpringContextUtil; -import org.activiti.engine.delegate.DelegateExecution; -import org.activiti.engine.delegate.DelegateTask; -import org.activiti.engine.delegate.ExecutionListener; -import org.activiti.engine.delegate.TaskListener; - -import java.util.Date; - -/** - * @author liJiaRao - * @date 2023-10-13 16:43 - */ -public class EndListener implements ExecutionListener { - @Override - public void notify(DelegateExecution execution) { - //流程信息 - ProcessAllService processAllService = SpringContextUtil.getBean(ProcessAllService.class); - - String processInstanceId = execution.getProcessInstanceId(); - ProcessAll processAll = processAllService.getByProcessInstanceId(processInstanceId); - Date createTime = processAll.getCreateTime(); - DateTime date = DateUtil.date(); - DateBetween between = date.between(createTime); - - //更新流程总表信息为已完成 - LambdaUpdateWrapper wrapper = new LambdaUpdateWrapper<>(); - wrapper.eq(ProcessAll::getProcessInstanceId,processInstanceId); - wrapper.set(ProcessAll::getPrcStatus, ProcessStatusEnum.COMPLETED.getValue()); - wrapper.set(ProcessAll::getEndTime,date); - wrapper.set(ProcessAll::getOverTime,between.toString()); - processAllService.update(wrapper); - } -} diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/listener/SignListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/listener/SignListener.java deleted file mode 100644 index 6c152e52..00000000 --- a/laws-modules/src/main/java/com/jero/modules/activiti/listener/SignListener.java +++ /dev/null @@ -1,56 +0,0 @@ -package com.jero.modules.activiti.listener; - -import lombok.extern.slf4j.Slf4j; -import org.activiti.engine.ProcessEngine; -import org.activiti.engine.ProcessEngines; -import org.activiti.engine.RuntimeService; -import org.activiti.engine.delegate.DelegateTask; -import org.activiti.engine.delegate.TaskListener; - -/** - * @author liJiaRao - * @date 2023-08-04 10:53 - */ -@Slf4j -public class SignListener implements TaskListener { - @Override - public void notify(DelegateTask delegateTask) { - /** - * - */ - //获取流程id - String taskId = delegateTask.getExecutionId(); - //获取流程参数pass，会签人员完成自己的审批任务时会添加流程参数pass，false为拒绝，true为同意 - // 1、创建ProcessEngine - ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); -// 2、获取RunTimeService - RuntimeService runtimeService = processEngine.getRuntimeService(); - boolean pass = (Boolean) runtimeService.getVariable(taskId, "pass"); - - /* ${nrOfCompletedInstances/nrOfInstances==1} - * false：有一个人拒绝，整个流程就结束了， - * 因为Complete condition的值为pass == false，即，当流程参数为pass时会签就结束开始下一个任务 - * 所以，当pass == false时，直接设置下一个流程跳转需要的参数 - * true：审批人同意，同时要判断是不是所有的人都已经完成了，而不是由一个人同意该会签就结束 - * 值得注意的是如果一个审批人完成了审批进入到该监听时nrOfCompletedInstances的值还没有更新，因此需要+1 - */ - Integer complete = (Integer) runtimeService.getVariable(taskId, "nrOfCompletedInstances"); - Integer all = (Integer) runtimeService.getVariable(taskId, "nrOfInstances"); - // 这里的test对应的是第一个节点中的对应的参数 - String username= (String) runtimeService.getVariable(delegateTask.getExecutionId(), "test"); - if(!pass){ - //会签结束，返回发起人节点 - runtimeService.setVariable(taskId, "countersignState", 0); - runtimeService.setVariable(taskId, "test", username); - }else{ - - //说明都完成了并且没有人拒绝 - if((complete + 1) / all == 1){ - // 流程流向下个节点 test2为下个节点人的参数 - runtimeService.setVariable(taskId, "countersignState", 1); - runtimeService.setVariable(taskId, "test2", "xiaowang"); - - } - } - } -} diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/listener/StartListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/listener/StartListener.java deleted file mode 100644 index 10b2f9bd..00000000 --- a/laws-modules/src/main/java/com/jero/modules/activiti/listener/StartListener.java +++ /dev/null @@ -1,44 +0,0 @@ -package com.jero.modules.activiti.listener; - -import com.jero.modules.activiti.entity.ProcessAll; -import com.jero.modules.activiti.enums.ProcessStatusEnum; -import com.jero.modules.activiti.enums.ProcessTypeEnum; -import com.jero.modules.activiti.service.ProcessAllService; -import com.jero.modules.activiti.service.ProcessApprovalRecordService; -import com.jero.modules.activiti.util.SpringContextUtil; - -import org.activiti.engine.*; -import org.activiti.engine.delegate.DelegateExecution; -import org.activiti.engine.delegate.ExecutionListener; -import org.activiti.engine.repository.ProcessDefinition; - -/** - * @author liJiaRao - * @date 2023-10-13 16:43 - */ -public class StartListener implements ExecutionListener { - - @Override - public void notify(DelegateExecution execution) { - //流程信息 - ProcessAllService processAllService = SpringContextUtil.getBean(ProcessAllService.class); - //流程审批信息 - ProcessApprovalRecordService recordService = SpringContextUtil.getBean(ProcessApprovalRecordService.class); - String id = execution.getId(); - String processInstanceId = execution.getProcessInstanceId(); - String processDefinitionId = execution.getProcessDefinitionId(); - - ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); - RepositoryService repositoryService = processEngine.getRepositoryService(); - ProcessDefinition processDefinition = repositoryService.getProcessDefinition(processDefinitionId); - - String name = processDefinition.getName(); - String key = processDefinition.getKey(); - //新增流程总表信息（剩余的内容在启动流程时填充） - ProcessAll processAll = new ProcessAll(); - processAll.setProcessInstanceId(processInstanceId); - processAll.setPrcType(ProcessTypeEnum.getValueByName(name, processDefinitionId)); - processAll.setPrcStatus(ProcessStatusEnum.INCOMPLETE.getValue()); - processAllService.save(processAll); - } -} From b7e9f7d3635cd5bb6ac5955346f9051467022cb4 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 10:04:13 +0800 Subject: [PATCH 08/15] =?UTF-8?q?fix:=20scc=E6=B5=81=E7=A8=8B=E4=BA=BA?= =?UTF-8?q?=E5=91=98=E4=BF=A1=E6=81=AF=E5=B7=A6=E4=BE=A7=E8=8A=82=E7=82=B9?= =?UTF-8?q?=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/ModelerController.java | 7 --- .../activiti/service/ProcessNodeService.java | 48 +++++++++++-------- 2 files changed, 27 insertions(+), 28 deletions(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/controller/ModelerController.java b/laws-modules/src/main/java/com/jero/modules/activiti/controller/ModelerController.java index 44f0956f..7d38586d 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/controller/ModelerController.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/controller/ModelerController.java @@ -8,13 +8,8 @@ import com.fasterxml.jackson.databind.node.ObjectNode; import com.jero.common.api.vo.Result; import com.jero.common.util.MessageUtils; import com.jero.modules.activiti.entity.ProcessModelNode; -import com.jero.modules.activiti.listener.CompleteListener; -import com.jero.modules.activiti.listener.CreateListener; -import com.jero.modules.activiti.listener.EndListener; -import com.jero.modules.activiti.listener.StartListener; import com.jero.modules.activiti.service.ProcessNodeService; import com.jero.modules.activiti.service.ProcessModelNodeService; -import com.jero.modules.activiti.util.CreatedTools; import com.jero.modules.activiti.vo.AddTaskVO; import com.jero.common.api.vo.ResultCommon; import io.swagger.annotations.Api; @@ -28,8 +23,6 @@ import org.activiti.bpmn.model.Process; import org.activiti.editor.constants.ModelDataJsonConstants; import org.activiti.editor.language.json.converter.BpmnJsonConverter; import org.activiti.engine.*; -import org.activiti.engine.delegate.BaseExecutionListener; -import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.repository.*; import org.activiti.engine.runtime.ProcessInstance; import org.apache.commons.lang3.StringUtils; diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java b/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java index 7471cfda..8609fc58 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java @@ -1,15 +1,17 @@ package com.jero.modules.activiti.service; import cn.hutool.core.collection.CollStreamUtil; -import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.jero.common.constant.enums.YesOrNoEnum; +import com.jero.modules.activiti.common.ActivitiCommon; +import com.jero.modules.activiti.entity.ProcessApprovalRecord; import com.jero.modules.activiti.entity.ProcessModelNode; import com.jero.modules.activiti.entity.ProcessNode; import com.jero.modules.activiti.mapper.ProcessModelNodeMapper; import com.jero.modules.activiti.mapper.ProcessNodeMapper; import lombok.extern.slf4j.Slf4j; +import org.activiti.engine.RuntimeService; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; @@ -21,6 +23,9 @@ import java.util.List; import java.util.Map; import java.util.stream.Collectors; +import static com.jero.modules.activiti.common.ActivitiCommon.*; +import static com.jero.modules.activiti.process.standardComplianceCheck.common.ProcessStandardComplianceCheckConstants.*; + /** * @author liJiaRao * @date 2023-09-26 15:12 @@ -34,6 +39,12 @@ public class ProcessNodeService extends ServiceImpl wrapper = new LambdaQueryWrapper<>(); wrapper.eq(ProcessModelNode::getNodeType, "userTask"); @@ -114,30 +125,25 @@ public class ProcessNodeService extends ServiceImpl !"123".equals(v.getVariableName())) .collect(Collectors.toList()); + specialProcessScc(processNodeList, processInstanceId); return processNodeList; } - private void specialProcessEsRecheck(List processNodeList, String processInstanceId) { - // 如果有标准化发起节点，但是没有人员，则删除标准化发起节点 - ProcessNode firstNode = processNodeList.get(0); - ProcessNode secondNode = processNodeList.get(1); - if (StrUtil.isNotBlank(secondNode.getLinkUserIds())) { - if (StrUtil.isBlank(firstNode.getLinkUserIds())) { - processNodeList.remove(0); - } + private void specialProcessScc(List processNodeList, String processInstanceId) { + // 如果没分发 则不显示 主排查人单线审核 主排查人汇总节点 + String mainInstanceId = (String) runtimeService.getVariable(processInstanceId, ActivitiCommon.MAIN_INSTANCE_ID); + boolean distribute = (boolean) runtimeService.getVariable(mainInstanceId, DISTRIBUTE); + if (!distribute) { + processNodeList.removeIf( v -> v.getXmlNodeId().equals(MAIN_CHECK_USER_APPROVAL) + || v.getXmlNodeId().equals(MAIN_CHECK_USER_COLLECT)); } - } - - private void specialProcessEsMiniProcessEnd(List processNodeList) { - // 如果第三个节点有选人信息，则判断相关人员会签节点是否有人，如果没人，则删除相关人员会签节点 - if (processNodeList.size() >= 3) { - ProcessNode processNode = processNodeList.get(2); - if (StrUtil.isNotBlank(processNode.getLinkUserIds())) { - ProcessNode processNode1 = processNodeList.get(1); - if (StrUtil.isBlank(processNode1.getLinkUserIds())) { - processNodeList.remove(1); - } - } + // 判断有没有 主排查人重新分批下发 节点 + LambdaQueryWrapper parWrapper = new LambdaQueryWrapper<>(); + parWrapper.eq(ProcessApprovalRecord::getProcessInstanceId, processInstanceId); + parWrapper.eq(ProcessApprovalRecord::getNodeId, MAIN_CHECK_USER_REDISTRIBUTE); + List list = parService.list(parWrapper); + if (CollectionUtils.isEmpty(list)) { + processNodeList.removeIf( v -> v.getXmlNodeId().equals(MAIN_CHECK_USER_REDISTRIBUTE)); } } } From 7337f33b393c3206448e586f978c54e58d971a57 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 10:23:44 +0800 Subject: [PATCH 09/15] =?UTF-8?q?fix:=20scc=E6=B5=81=E7=A8=8B=E4=BA=BA?= =?UTF-8?q?=E5=91=98=E4=BF=A1=E6=81=AF=E9=A1=B5=E9=9D=A2=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ProcessStandardComplianceCheckServiceImpl.java | 7 +++++++ .../activiti/service/ProcessApprovalRecordService.java | 2 +- .../modules/activiti/service/ProcessNodeService.java | 10 ++++++++-- 3 files changed, 16 insertions(+), 3 deletions(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java index d341e1c0..6b91b827 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java @@ -251,6 +251,11 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl pageList(Page page, ProcessApprovalRecord processApprovalRecord, String type, HttpServletRequest req) { - boolean allSnapshotFlag = !type.equals(COMPLETED_RECORD_LIST); + boolean allSnapshotFlag = type.equals(ALL_RECORD_LIST); String curUserId = UserUtils.getUserId(); QueryWrapper wrapper = new QueryWrapper<>(); if (StringUtils.isNotBlank(processApprovalRecord.getFinishFlagSearch())){ diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java b/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java index 8609fc58..c1a89cf3 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java @@ -1,6 +1,8 @@ package com.jero.modules.activiti.service; import cn.hutool.core.collection.CollStreamUtil; +import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.jero.common.constant.enums.YesOrNoEnum; @@ -23,7 +25,7 @@ import java.util.List; import java.util.Map; import java.util.stream.Collectors; -import static com.jero.modules.activiti.common.ActivitiCommon.*; +import static com.jero.modules.activiti.common.ActivitiCommon.DISTRIBUTE; import static com.jero.modules.activiti.process.standardComplianceCheck.common.ProcessStandardComplianceCheckConstants.*; /** @@ -130,9 +132,13 @@ public class ProcessNodeService extends ServiceImpl processNodeList, String processInstanceId) { + if (StrUtil.isBlank(processInstanceId)) { + return; + } // 如果没分发 则不显示 主排查人单线审核 主排查人汇总节点 String mainInstanceId = (String) runtimeService.getVariable(processInstanceId, ActivitiCommon.MAIN_INSTANCE_ID); - boolean distribute = (boolean) runtimeService.getVariable(mainInstanceId, DISTRIBUTE); + Object variable = runtimeService.getVariable(mainInstanceId, DISTRIBUTE); + boolean distribute = ObjectUtil.isNotNull(variable) && YesOrNoEnum.YES.getValue().equals(variable.toString()); if (!distribute) { processNodeList.removeIf( v -> v.getXmlNodeId().equals(MAIN_CHECK_USER_APPROVAL) || v.getXmlNodeId().equals(MAIN_CHECK_USER_COLLECT)); From 0c344672f37e54d6e9402ec3c47ef2e5a6f6195d Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 11:04:10 +0800 Subject: [PATCH 10/15] =?UTF-8?q?feat:=20scc=E6=B5=81=E7=A8=8B=E4=BC=9A?= =?UTF-8?q?=E7=AD=BE=E8=8A=82=E7=82=B9=E9=A9=B3=E5=9B=9E=E5=90=8E=E4=BA=BA?= =?UTF-8?q?=E5=91=98=E5=9B=9E=E6=98=BE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/service/ActFlowCommonService.java | 23 ++++++++++++ ...essStandardComplianceCheckServiceImpl.java | 36 ++++--------------- 2 files changed, 29 insertions(+), 30 deletions(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/common/service/ActFlowCommonService.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/common/service/ActFlowCommonService.java index 0cc405a7..462eab8f 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/common/service/ActFlowCommonService.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/common/service/ActFlowCommonService.java @@ -36,6 +36,8 @@ import org.springframework.util.CollectionUtils; import javax.annotation.Resource; import java.util.*; +import java.util.function.Consumer; +import java.util.function.Function; @Slf4j @Service @@ -152,6 +154,27 @@ public class ActFlowCommonService { return processApprovalRecordService.getByTaskId(taskId); } + public void setListAttribute(String instanceId, String variableName, Consumer> setter, Function> converter) { + Object value = runtimeService.getVariable(instanceId, variableName); + if (value != null) { + setter.accept(converter.apply(value)); + } + } + + public void setStringAttribute(String instanceId, String variableName, Consumer setter, Function converter) { + Object value = runtimeService.getVariable(instanceId, variableName); + if (value != null) { + setter.accept(converter.apply(value)); + } + } + + public void setStringBooleanAttribute(String instanceId, String variableName, Consumer setter, Function converter) { + Object value = runtimeService.getVariable(instanceId, variableName); + if (value != null) { + setter.accept(converter.apply(value)); + } + } + /** * 完成提交任务 */ diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java index 6b91b827..a3eb88dd 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java @@ -52,8 +52,6 @@ import javax.annotation.Resource; import java.io.IOException; import java.io.InputStream; import java.util.*; -import java.util.function.Consumer; -import java.util.function.Function; import java.util.stream.Collectors; import static com.jero.modules.activiti.common.ActivitiCommon.*; @@ -223,11 +221,6 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl scc.setCountersignUser(String.join(",", (List) v)), v -> (List) v); -// setListAttribute(mainInstanceId, MANAGER, scc::setManager, Object::toString); -// setListAttribute(mainInstanceId, SENIOR_MANAGER, scc::setSeniorManager, Object::toString); - } - - private void setListAttribute(String instanceId, String variableName, Consumer> setter, Function> converter) { - Object value = runtimeService.getVariable(instanceId, variableName); - if (value != null) { - setter.accept(converter.apply(value)); - } - } - - private void setStringAttribute(String instanceId, String variableName, Consumer setter, Function converter) { - Object value = runtimeService.getVariable(instanceId, variableName); - if (value != null) { - setter.accept(converter.apply(value)); - } + actFlowCommonService.setStringBooleanAttribute(mainInstanceId, DISTRIBUTE, scc::setDistributeFlag, value -> (boolean) value ? YesOrNoEnum.YES.getValue() : YesOrNoEnum.NO.getValue()); + actFlowCommonService.setStringAttribute(mainInstanceId, DEPT_USER, scc::setDeptUser, Object::toString); + actFlowCommonService.setStringAttribute(mainInstanceId, MAIN_CHECK_USER, scc::setMainCheckUser, Object::toString); + actFlowCommonService.setListAttribute(mainInstanceId, COUNTERSIGN_USER_LIST, v -> scc.setCountersignUser(String.join(",", v)), v -> (List) v); + actFlowCommonService.setListAttribute(mainInstanceId, MANAGER_LIST, v -> scc.setManager(String.join(",", v)), v -> (List) v); + actFlowCommonService.setListAttribute(mainInstanceId, SENIOR_MANAGER_LIST, v -> scc.setSeniorManager(String.join(",", v)), v -> (List) v); } private void setDesignerEngineerEvaluationHandleData(ProcessSccVO processSccVO, String mainInstanceId, String processInstanceId) { From fd5cdba866601d040769a45f32e97c92eb40a39e Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 11:19:04 +0800 Subject: [PATCH 11/15] =?UTF-8?q?feat:=20scc=E6=B5=81=E7=A8=8B=E6=8E=A7?= =?UTF-8?q?=E5=88=B6=E5=88=86=E5=8F=91=E8=8A=82=E7=82=B9=E6=98=AF=E5=90=A6?= =?UTF-8?q?=E8=83=BD=E5=A4=9F=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../entity/ProcessStandardComplianceCheck.java | 4 ++++ .../impl/ProcessStandardComplianceCheckServiceImpl.java | 3 +++ 2 files changed, 7 insertions(+) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/entity/ProcessStandardComplianceCheck.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/entity/ProcessStandardComplianceCheck.java index cf595abe..a0909ff9 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/entity/ProcessStandardComplianceCheck.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/entity/ProcessStandardComplianceCheck.java @@ -195,6 +195,10 @@ public class ProcessStandardComplianceCheck implements Serializable { @TableField(exist = false) private String seniorManager; + @ApiModelProperty(value = "是否锁定下发下拉选项") + @TableField(exist = false) + private boolean lockDistributeFlag; + @TableField(exist = false) private static final long serialVersionUID = 1L; } \ No newline at end of file diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java index a3eb88dd..fcbe1072 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java @@ -451,6 +451,9 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl (boolean) value ? YesOrNoEnum.YES.getValue() : YesOrNoEnum.NO.getValue()); + // 如果没有下发过 + String distributeFlag = scc.getDistributeFlag(); + scc.setLockDistributeFlag(YesOrNoEnum.YES.getValue().equals(distributeFlag)); actFlowCommonService.setStringAttribute(mainInstanceId, DEPT_USER, scc::setDeptUser, Object::toString); actFlowCommonService.setStringAttribute(mainInstanceId, MAIN_CHECK_USER, scc::setMainCheckUser, Object::toString); actFlowCommonService.setListAttribute(mainInstanceId, COUNTERSIGN_USER_LIST, v -> scc.setCountersignUser(String.join(",", v)), v -> (List) v); From 7d04c215c60a32c19abab23176e9a761f8a299ed Mon Sep 17 00:00:00 2001 From: yjz <3131811435@qq.com> Date: Thu, 18 Jul 2024 11:45:47 +0800 Subject: [PATCH 12/15] =?UTF-8?q?fix(=E6=96=87=E6=A1=A3=E6=8B=86=E5=88=86)?= =?UTF-8?q?:=20MinioUtil=20->=20ObsBootUtil?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../oss/controller/SplitFileController.java | 9 ++- .../split/service/impl/FileSpiltService.java | 80 ++++++++++--------- 2 files changed, 49 insertions(+), 40 deletions(-) diff --git a/laws-module-system/src/main/java/com/jero/modules/oss/controller/SplitFileController.java b/laws-module-system/src/main/java/com/jero/modules/oss/controller/SplitFileController.java index 80d9f7c4..28b77b10 100644 --- a/laws-module-system/src/main/java/com/jero/modules/oss/controller/SplitFileController.java +++ b/laws-module-system/src/main/java/com/jero/modules/oss/controller/SplitFileController.java @@ -1,7 +1,7 @@ package com.jero.modules.oss.controller; import com.jero.common.exception.JeroBootException; -import com.jero.common.util.MinioUtil; +import com.jero.common.util.obs.ObsBootUtil; import com.jero.modules.oss.service.IOSSFileService; import com.jero.modules.oss.util.SplitFileUtils; import lombok.extern.slf4j.Slf4j; @@ -36,9 +36,10 @@ public class SplitFileController { response.setHeader("Content-Disposition", "attachment; filename=\"" + SplitFileUtils.encodeFileName(fileName, request) + "\""); response.setContentType("application/force-download"); - if (MinioUtil.doesObjectExist(fileUrl)) { +// if (MinioUtil.doesObjectExist(fileUrl)) { try (OutputStream os = response.getOutputStream(); - InputStream fis = MinioUtil.download(fileUrl)) { +// InputStream fis = MinioUtil.download(fileUrl)) { + InputStream fis = ObsBootUtil.getOssFile(fileUrl)) { int len = 0; while ((len = fis.read()) != -1) { os.write(len); @@ -49,7 +50,7 @@ public class SplitFileController { } catch (IOException e) { throw new JeroBootException("文件不存在"); } - } +// } } diff --git a/laws-modules/src/main/java/com/jero/modules/split/service/impl/FileSpiltService.java b/laws-modules/src/main/java/com/jero/modules/split/service/impl/FileSpiltService.java index c77cb5e4..182a8b4c 100644 --- a/laws-modules/src/main/java/com/jero/modules/split/service/impl/FileSpiltService.java +++ b/laws-modules/src/main/java/com/jero/modules/split/service/impl/FileSpiltService.java @@ -2,12 +2,14 @@ package com.jero.modules.split.service.impl; import cn.hutool.core.lang.RegexPool; import cn.hutool.core.util.ReUtil; +import cn.hutool.http.Header; +import cn.hutool.http.HttpRequest; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.jero.common.exception.JeroBootException; import com.jero.common.system.vo.LoginUser; import com.jero.common.util.IntekeyUtils; -import com.jero.common.util.MinioUtil; import com.jero.common.util.UUIDUtils; +import com.jero.common.util.obs.ObsBootUtil; import com.jero.modules.laws.documenttool.mapper.DocumentSplitMapper; import com.jero.modules.laws.standard.entity.LawsDomesticStandard; import com.jero.modules.laws.standard.entity.LawsEnterpriseStandard; @@ -40,6 +42,8 @@ import org.openxmlformats.schemas.drawingml.x2006.main.CTGraphicalObject; import org.openxmlformats.schemas.drawingml.x2006.picture.CTPicture; import org.openxmlformats.schemas.drawingml.x2006.wordprocessingDrawing.CTAnchor; import org.openxmlformats.schemas.drawingml.x2006.wordprocessingDrawing.CTInline; +import org.openxmlformats.schemas.officeDocument.x2006.math.CTOMath; +import org.openxmlformats.schemas.officeDocument.x2006.math.CTOMathPara; import org.openxmlformats.schemas.wordprocessingml.x2006.main.CTDrawing; import org.openxmlformats.schemas.wordprocessingml.x2006.main.CTLevelText; import org.openxmlformats.schemas.wordprocessingml.x2006.main.CTR; @@ -55,6 +59,7 @@ import org.w3c.dom.NamedNodeMap; import org.w3c.dom.Node; import org.w3c.dom.NodeList; +import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; import java.util.*; @@ -173,10 +178,11 @@ public class FileSpiltService { } OSSFile ossFile = ossFileList.get(0); String readFilePath = ossFile.getUrl(); - if (StringUtils.isEmpty(readFilePath) || !MinioUtil.doesObjectExist(readFilePath)) { + if (StringUtils.isEmpty(readFilePath)) { throw new JeroBootException("当前文件未找到，请重新选择！"); } - try (InputStream is = MinioUtil.download(readFilePath);InputStream is1 = MinioUtil.download(readFilePath)) { +// try (InputStream is = MinioUtil.download(readFilePath);InputStream is1 = MinioUtil.download(readFilePath)) { + try (InputStream is = ObsBootUtil.getOssFile(readFilePath);InputStream is1 = ObsBootUtil.getOssFile(readFilePath)) { String fileName = readFilePath.substring((readFilePath.lastIndexOf("/") + 1)); MultipartFile mFile = new MockMultipartFile(fileName, fileName, ContentType.APPLICATION_OCTET_STREAM.toString(), is); MultipartFile mFile1 = new MockMultipartFile(fileName, fileName, ContentType.APPLICATION_OCTET_STREAM.toString(), is1); @@ -217,34 +223,34 @@ public class FileSpiltService { // //处理段落中的文本以及图片 // handleParagraphRun(content, (XWPFRun) child, imageParser); //} else -// if (child instanceof CTOMath) { -// CTOMath ctoMath = (CTOMath) child; -// String xmlText = ctoMath.xmlText().replaceAll("xml-fragment","m:oMath"); -// Map map = new HashMap<>(); -// map.put("encode", xmlText); -// String post = HttpRequest.post(mathToImgUrl) -// .header(Header.CONTENT_TYPE, "application/json") -// .body(xmlText) -// .execute().body(); -// //String post = HttpUtil.post(mathToImgUrl, map); -// if (messageList.size() > 0) { -// addItermsMathImage(messageList.get(messageList.size() - 1), itemValList, post); -// } -// } -// else if (child instanceof CTOMathPara) { -// CTOMathPara ctoMathPara = (CTOMathPara) child; -// String xmlText = ctoMathPara.xmlText().replaceAll("xml-fragment","m:oMath");; -// Map map = new HashMap<>(); -// map.put("encode",xmlText); -// String post = HttpRequest.post(mathToImgUrl) -// .header(Header.CONTENT_TYPE, "application/json") -// .body(xmlText) -// .execute().body(); -// //String post = HttpUtil.post(mathToImgUrl, map); -// if (messageList.size() > 0) { -// addItermsMathImage(messageList.get(messageList.size() - 1), itemValList, post); -// } -// } + if (child instanceof CTOMath) { + CTOMath ctoMath = (CTOMath) child; + String xmlText = ctoMath.xmlText().replaceAll("xml-fragment","m:oMath"); + Map map = new HashMap<>(); + map.put("encode", xmlText); + String post = HttpRequest.post(mathToImgUrl) + .header(Header.CONTENT_TYPE, "application/json") + .body(xmlText) + .execute().body(); + //String post = HttpUtil.post(mathToImgUrl, map); + if (messageList.size() > 0) { + addItermsMathImage(messageList.get(messageList.size() - 1), itemValList, post); + } + } + else if (child instanceof CTOMathPara) { + CTOMathPara ctoMathPara = (CTOMathPara) child; + String xmlText = ctoMathPara.xmlText().replaceAll("xml-fragment","m:oMath");; + Map map = new HashMap<>(); + map.put("encode",xmlText); + String post = HttpRequest.post(mathToImgUrl) + .header(Header.CONTENT_TYPE, "application/json") + .body(xmlText) + .execute().body(); + //String post = HttpUtil.post(mathToImgUrl, map); + if (messageList.size() > 0) { + addItermsMathImage(messageList.get(messageList.size() - 1), itemValList, post); + } + } } for (XWPFRun xwrun : p.getRuns()) { @@ -940,7 +946,8 @@ public class FileSpiltService { String filepathandname = filePathCos + "/" + imageName; try { String path = splitUrl+imageName; - MinioUtil.uploadByte(bytev, filepathandname); +// MinioUtil.uploadByte(bytev, filepathandname); + ObsBootUtil.upload(new ByteArrayInputStream(bytev), filepathandname); String imgCon = path; String imgConVal = ""; message.getItemsCondi().add(imgConVal); @@ -961,7 +968,8 @@ public class FileSpiltService { String filepathandname = filePathCos + "/" + imageName; try { String path = splitUrl+imageName; - MinioUtil.uploadByte(bytev, filepathandname); +// MinioUtil.uploadByte(bytev, filepathandname); + ObsBootUtil.upload(new ByteArrayInputStream(bytev), filepathandname); String imgCon = path; String imgConVal = ""; stringBuilder.append(imgConVal); @@ -1118,11 +1126,11 @@ public class FileSpiltService { } OSSFile ossFile = ossFileList.get(0); String readFilePath = ossFile.getUrl(); - if (org.apache.commons.lang.StringUtils.isEmpty(readFilePath) || !MinioUtil.doesObjectExist(readFilePath)) { + if (org.apache.commons.lang.StringUtils.isEmpty(readFilePath)) { throw new JeroBootException("当前文件未找到，请重新选择！"); } - try (InputStream is = MinioUtil.download(readFilePath)) { - +// try (InputStream is = MinioUtil.download(readFilePath)) { + try (InputStream is = ObsBootUtil.getOssFile(readFilePath)) { // InputStream is = new FileInputStream(readFilePath); //需要将文件路更改为word文档所在路径。 XWPFDocument doc = new XWPFDocument(is); From 860ce533defaf097324306468007f44b58d58df8 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 12:02:59 +0800 Subject: [PATCH 13/15] =?UTF-8?q?feat:=20scc=E5=AD=90=E6=B5=81=E7=A8=8B?= =?UTF-8?q?=E8=BD=AC=E5=8A=9E=E4=B8=BB=E6=8E=92=E6=9F=A5=E4=BA=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/StandardComplianceCheckFlow.java | 96 +++++++++++++++++++ 1 file changed, 96 insertions(+) create mode 100644 laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/StandardComplianceCheckFlow.java diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/StandardComplianceCheckFlow.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/StandardComplianceCheckFlow.java new file mode 100644 index 00000000..4160c6f0 --- /dev/null +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/StandardComplianceCheckFlow.java @@ -0,0 +1,96 @@ +package com.jero.modules.activiti.process.standardComplianceCheck.service; + +import cn.hutool.core.collection.CollUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.jero.common.exception.JeroBootException; +import com.jero.modules.activiti.entity.ProcessAll; +import com.jero.modules.activiti.entity.ProcessApprovalRecord; +import com.jero.modules.activiti.process.standardComplianceCheck.entity.ProcessStandardComplianceCheck; +import com.jero.modules.activiti.process.standardComplianceCheck.entity.ProcessStandardComplianceCheckDetail; +import com.jero.modules.activiti.service.ProcessAllService; +import com.jero.modules.activiti.service.WorkCenterService; +import com.jero.modules.activiti.util.SpringContextUtil; +import com.jero.modules.activiti.vo.DelegateTaskParam; +import lombok.extern.slf4j.Slf4j; +import org.activiti.engine.RuntimeService; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; + +import java.util.List; +import java.util.stream.Collectors; + +import static com.jero.modules.activiti.common.ActivitiCommon.MAIN_INSTANCE_ID; +import static com.jero.modules.activiti.process.standardComplianceCheck.common.ProcessStandardComplianceCheckConstants.MAIN_CHECK_USER; +import static com.jero.modules.activiti.process.standardComplianceCheck.common.ProcessStandardComplianceCheckConstants.MAIN_CHECK_USER_APPROVAL; + +/** + * @ClassName: EsInspectPlanFlowService + * @Description: + * @Author: yjz + * @Date: 2024-01-11 21:19 + * @Version: 1.0 + **/ +@Slf4j +@Transactional(rollbackFor = {Exception.class, JeroBootException.class}) +@Service +public class StandardComplianceCheckFlow implements WorkCenterService { + + @Resource + private IProcessStandardComplianceCheckService sccService; + + @Resource + private IProcessStandardComplianceCheckDetailService sccDetailService; + + @Resource + private RuntimeService runtimeService; + + /** + * 强制撤回 + * @param processAll 流程总表 + */ + @Override + public void changeToDraft(ProcessAll processAll) { + + } + + /** + * 转办 + * @param processAll + * @param processApprovalRecord + * @param toUserId + * @param userId + */ + @Override + public void handleTransfer(ProcessAll processAll, ProcessApprovalRecord processApprovalRecord, String toUserId, String userId) { + ProcessAllService processAllService = SpringContextUtil.getBean(ProcessAllService.class); + processAllService.specialTransfer(processAll, processApprovalRecord, toUserId, userId); + // 子流程中的主排查人的转办需要修改其余所有子流程及主流程中的数据 + String nodeId = processApprovalRecord.getNodeId(); + if (nodeId.equals(MAIN_CHECK_USER_APPROVAL)) { + String processInstanceId = processApprovalRecord.getProcessInstanceId(); + String mainInstanceId = (String) runtimeService.getVariable(processInstanceId, MAIN_INSTANCE_ID); + LambdaQueryWrapper sccWrapper = new LambdaQueryWrapper<>(); + sccWrapper.eq(ProcessStandardComplianceCheck::getProcessInstanceId, mainInstanceId); + ProcessStandardComplianceCheck scc = sccService.getOne(sccWrapper); + LambdaQueryWrapper sccDetailWrapper = new LambdaQueryWrapper<>(); + sccDetailWrapper.eq(ProcessStandardComplianceCheckDetail::getCheckId, scc.getId()); + sccDetailWrapper.isNotNull(ProcessStandardComplianceCheckDetail::getProcessInstanceId); + List sccDetailList = sccDetailService.list(sccDetailWrapper); + if (CollUtil.isEmpty(sccDetailList)) { + return; + } + List allChildProcessInstanceId = sccDetailList.stream() + .map(ProcessStandardComplianceCheckDetail::getProcessInstanceId).distinct().collect(Collectors.toList()); + allChildProcessInstanceId.forEach(childProcessInstanceId -> { + runtimeService.setVariable(childProcessInstanceId, MAIN_CHECK_USER, toUserId); + }); + } + } + + @Override + public void flowCountersign(DelegateTaskParam param) { + + } +} From dac4d86ea6689a00a3bd8065832340510132bcfa Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 13:34:17 +0800 Subject: [PATCH 14/15] =?UTF-8?q?feat:=20scc=E6=B5=81=E7=A8=8B=E6=8F=90?= =?UTF-8?q?=E4=BA=A4=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=8F=A3=E6=94=B9=E4=B8=BA?= =?UTF-8?q?=E5=85=88=E5=88=A0=E5=90=8E=E5=A2=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ProcessStandardComplianceCheckServiceImpl.java | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java index fcbe1072..485b0b25 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java @@ -258,6 +258,8 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl detailInfoList = businessInfoDTO.getDetailInfoList(); + List detailInfoListIds = detailInfoList.stream() + .map(ProcessStandardComplianceCheckDetail::getId).collect(Collectors.toList()); // 根据流程实例Id获取流程定义ID ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult(); // 获取流程实例ID @@ -336,7 +338,9 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl counterSignUserList = Arrays.asList(standardInfo.getCountersignUser().split(",")); List managerList = Arrays.asList(standardInfo.getManager().split(",")); From 5503b05232092738c4580ee39d732439783af360 Mon Sep 17 00:00:00 2001 From: caihaohan Date: Thu, 18 Jul 2024 13:48:31 +0800 Subject: [PATCH 15/15] =?UTF-8?q?fix:=20=E6=B5=81=E7=A8=8B=E7=BB=93?= =?UTF-8?q?=E6=9D=9F=E5=85=A5=E5=BA=93=E4=B8=A2=E5=A4=B1=E5=AD=97=E6=AE=B5?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ProcessStandardComplianceCheckDetail.java | 4 +-- ...essStandardComplianceCheckServiceImpl.java | 4 ++- .../LawsConformityAssessmentLibrary.java | 33 +++++++++---------- .../entity/LawsEvaluationNotMetLibrary.java | 2 -- 4 files changed, 21 insertions(+), 22 deletions(-) diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/entity/ProcessStandardComplianceCheckDetail.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/entity/ProcessStandardComplianceCheckDetail.java index 2119fa06..9b200b39 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/entity/ProcessStandardComplianceCheckDetail.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/entity/ProcessStandardComplianceCheckDetail.java @@ -93,7 +93,7 @@ public class ProcessStandardComplianceCheckDetail implements Serializable { */ @ApiModelProperty(value = "车型状态") @Dict(dicCode = "model_status") - private String modelState; + private String modelStatus; /** * 评估人 @@ -145,7 +145,7 @@ public class ProcessStandardComplianceCheckDetail implements Serializable { */ @ApiModelProperty(value = "整改周期") @Dict(dicCode = "correction_period") - private String correctionCycle; + private String correctionPeriod; /** * 整改费用 diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java index 485b0b25..a096ad1d 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java @@ -340,6 +340,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl detail.setValuationTime(new Date())); sccDetailService.saveBatch(detailInfoList); } runtimeService.setVariable(processInstanceId, DISTRIBUTE, distributeFlag); @@ -351,6 +352,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl { detail.setAssessor(curUserId); detail.setAuthDept(curUserDepartIds); + detail.setValuationTime(new Date()); }); // 先删后增 removeByIds(detailInfoListIds); @@ -580,7 +582,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl