市场管理：添加专业处室发起的日常评价工作流

src/main/java/com/common/workflow/service/activiti/contractDailyByBusinessListener/EvaApprovalByBusinessRefuseService.java

@@ -0,0 +1,52 @@
+package com.common.workflow.service.activiti.contractDailyByBusinessListener;
+
+import com.common.workflow.service.util.HttpRequest;
+import org.activiti.engine.ActivitiException;
+import org.activiti.engine.delegate.DelegateExecution;
+import org.activiti.engine.delegate.ExecutionListener;
+import org.activiti.engine.delegate.Expression;
+import org.springframework.stereotype.Component;
+
+@Component("evaApprovalByBusinessRefuseService")
+public class EvaApprovalByBusinessRefuseService implements ExecutionListener {
+
+    private Expression stepCode;
+    // 审批驳回
+    @Override
+    public void notify(DelegateExecution delegateExecution) {
+        String callbackUrl = delegateExecution.getVariable("callbackUrl").toString();
+        // String processKey = delegateExecution.getVariable("processKey").toString();
+        String businessKey = delegateExecution.getVariable("businessKey").toString();
+        Object nowStepCode = stepCode.getValue(delegateExecution).toString();
+        String approveUrl = callbackUrl + "/contract-daily-listener/approval-refuse";
+
+        String createUserId = "";
+        if (callbackUrl.length() > 0) {
+            // TODO 哪个环节被驳回的, 方便短信通知使用
+            String taskName = delegateExecution.getEventName();
+            createUserId = HttpRequest.sendGet(approveUrl, "businessKey=" + businessKey + "&stepCode=" + nowStepCode);
+        } else {
+            throw new ActivitiException("无回调地址，请联系管理员！");
+        }
+        if (createUserId.length() <= 0) {
+            throw new ActivitiException("驳回审批失败！请联系管理员！");
+        }
+
+        if (nowStepCode.equals("-1")) {
+            delegateExecution.setVariableLocal("refuseName", "初审未通过");
+        } else if (nowStepCode.equals("-2")) {
+            delegateExecution.setVariableLocal("refuseName", "复审未通过");
+        } else if (nowStepCode.equals("-3")) {
+            delegateExecution.setVariableLocal("refuseName", "专业处接收未通过");
+        } else if (nowStepCode.equals("-4")) {
+            delegateExecution.setVariableLocal("refuseName", "专业处室未通过");
+        } else if (nowStepCode.equals("-9")) {
+            delegateExecution.setVariableLocal("refuseName", "企管法规处未通过");
+        } else if (nowStepCode.equals("-10")) {
+            delegateExecution.setVariableLocal("refuseName", "二级单位分办未通过");
+        }
+        System.out.println("合同日常评审 线 驳回: " + nowStepCode);
+        delegateExecution.setVariable("backUsers", createUserId);
+        delegateExecution.setVariableLocal("backUsers", createUserId);
+    }
+}

src/main/java/com/common/workflow/service/activiti/contractDailyByBusinessListener/EvaApprovalByBusinessRefuseTaskService.java

@@ -0,0 +1,22 @@
+package com.common.workflow.service.activiti.contractDailyByBusinessListener;
+
+import org.activiti.engine.delegate.DelegateTask;
+import org.activiti.engine.delegate.TaskListener;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+
+@Component("evaApprovalByBusinessRefuseTaskService")
+public class EvaApprovalByBusinessRefuseTaskService implements TaskListener {
+    // 二级单位初审
+    @Override
+    public void notify(DelegateTask delegateTask) {
+        if (delegateTask.getVariable("backUsers") != null) {
+            String backUsers = delegateTask.getVariable("backUsers").toString();
+            delegateTask.setVariable("users", backUsers);
+            delegateTask.setVariableLocal("users", backUsers);
+            delegateTask.addCandidateUsers(Arrays.asList(backUsers.split(",")));
+            System.out.println("合同日常评审 节点 驳回: " + delegateTask.getVariable("backUsers").toString());
+        }
+    }
+}

src/main/java/com/common/workflow/service/activiti/contractDailyByBusinessListener/EvaByBusinessLawOfficeAuditService.java

@@ -0,0 +1,44 @@
+package com.common.workflow.service.activiti.contractDailyByBusinessListener;
+
+import com.common.workflow.service.client.FeignClient;
+import com.common.workflow.service.dto.ApproveInfoDTO;
+import com.common.workflow.service.dto.ApproveParamsDTO;
+import feign.Feign;
+import feign.jackson.JacksonDecoder;
+import feign.jackson.JacksonEncoder;
+import org.activiti.engine.ActivitiException;
+import org.activiti.engine.delegate.DelegateTask;
+import org.activiti.engine.delegate.TaskListener;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+
+@Component("evaByBusinessLawOfficeAuditService")
+public class EvaByBusinessLawOfficeAuditService implements TaskListener {
+    // 企业法规处审核, 非入库
+    @Override
+    public void notify(DelegateTask delegateTask) {
+        String callbackUrl = delegateTask.getVariable("callbackUrl").toString();
+        String businessKey = delegateTask.getVariable("businessKey").toString();
+        ApproveParamsDTO approveParams = new ApproveParamsDTO();
+        approveParams.setBusinessKey(businessKey);
+        ApproveInfoDTO approveInfo = null;
+        String approveInfoJson = "";
+        if (callbackUrl.length() > 0) {
+            FeignClient client = Feign.builder()
+                .decoder(new JacksonDecoder())
+                .encoder(new JacksonEncoder())
+                .target(FeignClient.class, callbackUrl);
+            approveInfo = client.getEvaluateLawOfficeAuditors(approveParams);
+        } else {
+            throw new ActivitiException("无回调地址，请联系管理员！");
+        }
+        if (approveInfo.getUsers().length() <= 0) {
+            throw new ActivitiException("未找到审核用户，请联系管理员！");
+        }
+        System.out.println("合同日常评审 获取企业法规处审核审核人: " + approveInfo.getUsers());
+        delegateTask.setVariable("users", approveInfo.getUsers());
+        delegateTask.setVariableLocal("users", approveInfo.getUsers());
+        delegateTask.addCandidateUsers(Arrays.asList(approveInfo.getUsers().split(",")));
+    }
+}

src/main/java/com/common/workflow/service/activiti/contractDailyByBusinessListener/EvaByBusinessPreProfAuditService.java

@@ -0,0 +1,31 @@
+package com.common.workflow.service.activiti.contractDailyByBusinessListener;
+
+import com.common.workflow.service.util.HttpRequest;
+import org.activiti.engine.ActivitiException;
+import org.activiti.engine.delegate.DelegateTask;
+import org.activiti.engine.delegate.TaskListener;
+import org.springframework.stereotype.Component;
+
+@Component("evaByBusinessPreProfAuditService")
+public class EvaByBusinessPreProfAuditService implements TaskListener {
+    // 业务处室专业审批 仅用于回调更新状态
+    @Override
+    public void notify(DelegateTask delegateTask) {
+        String callbackUrl = delegateTask.getVariable("callbackUrl").toString();
+        // String processKey = delegateTask.getVariable("processKey").toString();
+        String businessKey = delegateTask.getVariable("businessKey").toString();
+
+        String approveUrl = callbackUrl + "/contract-daily-listener/pre-prof-audit";
+
+        String res = "";
+        if (callbackUrl.length() > 0) {
+            res = HttpRequest.sendGet(approveUrl, "businessKey=" + businessKey);
+        } else {
+            throw new ActivitiException("无回调地址，请联系管理员！");
+        }
+        if (!res.equals("1")) {
+            throw new ActivitiException("工作流异常，请联系管理员！");
+        }
+        System.out.println("合同日常评审 业务处室专业审批");
+    }
+}

src/main/java/com/common/workflow/service/activiti/contractDailyByBusinessListener/EvaByBusinessWorkflowEndService.java

@@ -0,0 +1,31 @@
+package com.common.workflow.service.activiti.contractDailyByBusinessListener;
+
+import com.common.workflow.service.util.HttpRequest;
+import org.activiti.engine.ActivitiException;
+import org.activiti.engine.delegate.DelegateExecution;
+import org.activiti.engine.delegate.ExecutionListener;
+import org.springframework.stereotype.Component;
+
+@Component("evaByBusinessWorkflowEndService")
+public class EvaByBusinessWorkflowEndService implements ExecutionListener {
+    // 企业法规处审批入库完成
+    @Override
+    public void notify(DelegateExecution delegateExecution) {
+        String callbackUrl = delegateExecution.getVariable("callbackUrl").toString();
+        // String processKey = delegateTask.getVariable("processKey").toString();
+        String businessKey = delegateExecution.getVariable("businessKey").toString();
+
+        String approveUrl = callbackUrl + "/contract-daily-listener/workflow-end";
+
+        String res = "0";
+        if (callbackUrl.length() > 0) {
+            res = HttpRequest.sendGet(approveUrl, "businessKey=" + businessKey);
+        } else {
+            throw new ActivitiException("无回调地址，请联系管理员！");
+        }
+        if (res.equals("0")) {
+            throw new ActivitiException("审核入库失败！请联系管理员！");
+        }
+        System.out.println("合同日常评审工作流 结束 ");
+    }
+}

src/main/resources/processes/oil_daily_contract_eva_by_business.bpmn20.xml

@@ -0,0 +1,139 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/processdef">
+    <process id="oil_daily_contract_eva_by_business" name="oil_daily_contract_eva_by_business" isExecutable="true">
+        <documentation>日常合同评价（专业处室）</documentation>
+        <startEvent id="startEvent1"></startEvent>
+        <exclusiveGateway id="sid-C538D2C1-20B5-4A37-9315-4F2144AA4947"></exclusiveGateway>
+        <userTask id="sid-9A2D0670-8225-4F2B-9FB3-2B87DD502A43" name="专业审批" activiti:candidateUsers="${users}">
+            <extensionElements>
+                <activiti:taskListener event="create" delegateExpression="${evaByBusinessPreProfAuditService}"></activiti:taskListener>
+            </extensionElements>
+        </userTask>
+        <exclusiveGateway id="sid-8E07F48B-65B2-4541-A150-230589C7F95C"></exclusiveGateway>
+        <userTask id="sid-E04E3408-E2BB-4EC6-B98E-F80BE1108543" name="企管法规处审批">
+            <extensionElements>
+                <activiti:taskListener event="create" delegateExpression="${evaByBusinessLawOfficeAuditService}"></activiti:taskListener>
+            </extensionElements>
+        </userTask>
+        <userTask id="sid-9EF255A9-52B1-4287-8B53-0FB1D4A7C440" name="日常评价" activiti:assignee="${recorder}">
+            <extensionElements>
+                <modeler:initiator-can-complete xmlns:modeler="http://activiti.com/modeler"><![CDATA[false]]></modeler:initiator-can-complete>
+            </extensionElements>
+        </userTask>
+        <sequenceFlow id="sid-DE0F7BD6-366E-4F25-BC55-32E20E0E87B2" sourceRef="startEvent1" targetRef="sid-9EF255A9-52B1-4287-8B53-0FB1D4A7C440"></sequenceFlow>
+        <userTask id="sid-DACC03AA-AFA8-4413-B45D-C091829081F3" name="审批未通过" activiti:candidateUsers="${users}">
+            <extensionElements>
+                <activiti:taskListener event="create" delegateExpression="${evaluateApprovalRefuseTaskService}"></activiti:taskListener>
+            </extensionElements>
+        </userTask>
+        <exclusiveGateway id="sid-BEFC66DD-132F-4177-A66B-63D5CED8E569"></exclusiveGateway>
+        <endEvent id="sid-B04F4DC7-A903-4B14-9A50-2DF73371D021"></endEvent>
+        <sequenceFlow id="sid-936CB097-C571-4CCC-A87A-2BA9E81A3D21" sourceRef="sid-9EF255A9-52B1-4287-8B53-0FB1D4A7C440" targetRef="sid-C538D2C1-20B5-4A37-9315-4F2144AA4947"></sequenceFlow>
+        <sequenceFlow id="sid-D6C4C528-F1E9-44DD-9571-AA9A4F62295B" sourceRef="sid-8E07F48B-65B2-4541-A150-230589C7F95C" targetRef="sid-E04E3408-E2BB-4EC6-B98E-F80BE1108543">
+            <conditionExpression xsi:type="tFormalExpression"><![CDATA[${result==1}]]></conditionExpression>
+        </sequenceFlow>
+        <sequenceFlow id="sid-1BB01316-967A-4EE7-BCCB-C228297E1C3A" sourceRef="sid-BEFC66DD-132F-4177-A66B-63D5CED8E569" targetRef="sid-DACC03AA-AFA8-4413-B45D-C091829081F3">
+            <extensionElements>
+                <activiti:executionListener event="start" delegateExpression="${evaApprovalByBusRefuseService}">
+                    <activiti:field name="stepCode">
+                        <activiti:string><![CDATA[-9]]></activiti:string>
+                    </activiti:field>
+                </activiti:executionListener>
+            </extensionElements>
+            <conditionExpression xsi:type="tFormalExpression"><![CDATA[${result==0}]]></conditionExpression>
+        </sequenceFlow>
+        <sequenceFlow id="sid-D7E91776-67E4-4AEB-9A94-6BCC3940579F" sourceRef="sid-E04E3408-E2BB-4EC6-B98E-F80BE1108543" targetRef="sid-BEFC66DD-132F-4177-A66B-63D5CED8E569"></sequenceFlow>
+        <sequenceFlow id="sid-3EA50621-CC29-4D35-9034-97814B400470" sourceRef="sid-C538D2C1-20B5-4A37-9315-4F2144AA4947" targetRef="sid-9A2D0670-8225-4F2B-9FB3-2B87DD502A43"></sequenceFlow>
+        <sequenceFlow id="sid-5F2A768D-E979-4EA6-967D-3096F4E47819" sourceRef="sid-9A2D0670-8225-4F2B-9FB3-2B87DD502A43" targetRef="sid-8E07F48B-65B2-4541-A150-230589C7F95C"></sequenceFlow>
+        <sequenceFlow id="sid-3CA7D770-9CB1-4506-B7E6-CD9B2793A192" sourceRef="sid-BEFC66DD-132F-4177-A66B-63D5CED8E569" targetRef="sid-B04F4DC7-A903-4B14-9A50-2DF73371D021">
+            <extensionElements>
+                <activiti:executionListener event="start" delegateExpression="${evaByBusinessWorkflowEndService}"></activiti:executionListener>
+            </extensionElements>
+            <conditionExpression xsi:type="tFormalExpression"><![CDATA[${result==1}]]></conditionExpression>
+        </sequenceFlow>
+        <sequenceFlow id="sid-9CFA6746-2F45-4937-819D-3C3812A73CBA" sourceRef="sid-DACC03AA-AFA8-4413-B45D-C091829081F3" targetRef="sid-C538D2C1-20B5-4A37-9315-4F2144AA4947"></sequenceFlow>
+        <sequenceFlow id="sid-7C2671DD-3ED3-4954-9624-8CAB37D93B9F" sourceRef="sid-8E07F48B-65B2-4541-A150-230589C7F95C" targetRef="sid-DACC03AA-AFA8-4413-B45D-C091829081F3">
+            <extensionElements>
+                <activiti:executionListener event="start" delegateExpression="${evaApprovalByBusRefuseService}">
+                    <activiti:field name="stepCode">
+                        <activiti:string><![CDATA[-4]]></activiti:string>
+                    </activiti:field>
+                </activiti:executionListener>
+            </extensionElements>
+            <conditionExpression xsi:type="tFormalExpression"><![CDATA[${result==0}]]></conditionExpression>
+        </sequenceFlow>
+    </process>
+    <bpmndi:BPMNDiagram id="BPMNDiagram_oil_daily_contract_eva_by_business">
+        <bpmndi:BPMNPlane bpmnElement="oil_daily_contract_eva_by_business" id="BPMNPlane_oil_daily_contract_eva_by_business">
+            <bpmndi:BPMNShape bpmnElement="startEvent1" id="BPMNShape_startEvent1">
+                <omgdc:Bounds height="30.0" width="30.0" x="80.0" y="163.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNShape bpmnElement="sid-C538D2C1-20B5-4A37-9315-4F2144AA4947" id="BPMNShape_sid-C538D2C1-20B5-4A37-9315-4F2144AA4947">
+                <omgdc:Bounds height="40.0" width="40.0" x="295.0" y="158.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNShape bpmnElement="sid-9A2D0670-8225-4F2B-9FB3-2B87DD502A43" id="BPMNShape_sid-9A2D0670-8225-4F2B-9FB3-2B87DD502A43">
+                <omgdc:Bounds height="80.0" width="100.0" x="385.0" y="138.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNShape bpmnElement="sid-8E07F48B-65B2-4541-A150-230589C7F95C" id="BPMNShape_sid-8E07F48B-65B2-4541-A150-230589C7F95C">
+                <omgdc:Bounds height="40.0" width="40.0" x="530.0" y="158.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNShape bpmnElement="sid-E04E3408-E2BB-4EC6-B98E-F80BE1108543" id="BPMNShape_sid-E04E3408-E2BB-4EC6-B98E-F80BE1108543">
+                <omgdc:Bounds height="80.0" width="100.0" x="615.0" y="138.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNShape bpmnElement="sid-9EF255A9-52B1-4287-8B53-0FB1D4A7C440" id="BPMNShape_sid-9EF255A9-52B1-4287-8B53-0FB1D4A7C440">
+                <omgdc:Bounds height="80.0" width="100.0" x="155.0" y="138.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNShape bpmnElement="sid-DACC03AA-AFA8-4413-B45D-C091829081F3" id="BPMNShape_sid-DACC03AA-AFA8-4413-B45D-C091829081F3">
+                <omgdc:Bounds height="80.0" width="100.0" x="265.0" y="255.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNShape bpmnElement="sid-BEFC66DD-132F-4177-A66B-63D5CED8E569" id="BPMNShape_sid-BEFC66DD-132F-4177-A66B-63D5CED8E569">
+                <omgdc:Bounds height="40.0" width="40.0" x="760.0" y="158.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNShape bpmnElement="sid-B04F4DC7-A903-4B14-9A50-2DF73371D021" id="BPMNShape_sid-B04F4DC7-A903-4B14-9A50-2DF73371D021">
+                <omgdc:Bounds height="28.0" width="28.0" x="845.0" y="164.0"></omgdc:Bounds>
+            </bpmndi:BPMNShape>
+            <bpmndi:BPMNEdge bpmnElement="sid-DE0F7BD6-366E-4F25-BC55-32E20E0E87B2" id="BPMNEdge_sid-DE0F7BD6-366E-4F25-BC55-32E20E0E87B2">
+                <omgdi:waypoint x="110.0" y="178.0"></omgdi:waypoint>
+                <omgdi:waypoint x="155.0" y="178.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-D6C4C528-F1E9-44DD-9571-AA9A4F62295B" id="BPMNEdge_sid-D6C4C528-F1E9-44DD-9571-AA9A4F62295B">
+                <omgdi:waypoint x="570.0" y="178.0"></omgdi:waypoint>
+                <omgdi:waypoint x="615.0" y="178.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-3CA7D770-9CB1-4506-B7E6-CD9B2793A192" id="BPMNEdge_sid-3CA7D770-9CB1-4506-B7E6-CD9B2793A192">
+                <omgdi:waypoint x="800.0" y="178.0"></omgdi:waypoint>
+                <omgdi:waypoint x="845.0" y="178.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-9CFA6746-2F45-4937-819D-3C3812A73CBA" id="BPMNEdge_sid-9CFA6746-2F45-4937-819D-3C3812A73CBA">
+                <omgdi:waypoint x="315.0" y="255.0"></omgdi:waypoint>
+                <omgdi:waypoint x="315.0" y="198.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-936CB097-C571-4CCC-A87A-2BA9E81A3D21" id="BPMNEdge_sid-936CB097-C571-4CCC-A87A-2BA9E81A3D21">
+                <omgdi:waypoint x="255.0" y="178.0"></omgdi:waypoint>
+                <omgdi:waypoint x="295.0" y="178.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-3EA50621-CC29-4D35-9034-97814B400470" id="BPMNEdge_sid-3EA50621-CC29-4D35-9034-97814B400470">
+                <omgdi:waypoint x="334.5798319327731" y="178.42016806722688"></omgdi:waypoint>
+                <omgdi:waypoint x="385.0" y="178.2092050209205"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-7C2671DD-3ED3-4954-9624-8CAB37D93B9F" id="BPMNEdge_sid-7C2671DD-3ED3-4954-9624-8CAB37D93B9F">
+                <omgdi:waypoint x="550.0" y="198.0"></omgdi:waypoint>
+                <omgdi:waypoint x="550.0" y="295.0"></omgdi:waypoint>
+                <omgdi:waypoint x="365.0" y="295.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-D7E91776-67E4-4AEB-9A94-6BCC3940579F" id="BPMNEdge_sid-D7E91776-67E4-4AEB-9A94-6BCC3940579F">
+                <omgdi:waypoint x="715.0" y="178.0"></omgdi:waypoint>
+                <omgdi:waypoint x="760.0" y="178.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-5F2A768D-E979-4EA6-967D-3096F4E47819" id="BPMNEdge_sid-5F2A768D-E979-4EA6-967D-3096F4E47819">
+                <omgdi:waypoint x="485.0" y="178.0"></omgdi:waypoint>
+                <omgdi:waypoint x="530.0" y="178.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+            <bpmndi:BPMNEdge bpmnElement="sid-1BB01316-967A-4EE7-BCCB-C228297E1C3A" id="BPMNEdge_sid-1BB01316-967A-4EE7-BCCB-C228297E1C3A">
+                <omgdi:waypoint x="780.0" y="198.0"></omgdi:waypoint>
+                <omgdi:waypoint x="780.0" y="295.0"></omgdi:waypoint>
+                <omgdi:waypoint x="365.0" y="295.0"></omgdi:waypoint>
+            </bpmndi:BPMNEdge>
+        </bpmndi:BPMNPlane>
+    </bpmndi:BPMNDiagram>
+</definitions>