结算申请事件类

src/main/java/com/horizon/wf/core/rule/purPayReqRule.java

@@ -0,0 +1,103 @@
+package com.horizon.wf.core.rule;
+
+import cn.hutool.http.HttpUtil;
+import com.horizon.common.constant.Constants;
+import com.horizon.wf.bean.WorkParaBean;
+import com.horizon.wf.core.runtime.RunningData;
+import com.horizon.wf.definition.pub.IFlowNode;
+import com.horizon.wf.entity.db.DBTrack;
+import com.horizon.wf.entity.db.DBWork;
+import com.horizon.wf.entity.user.IRunUser;
+import com.horizon.wf.global.StaticVarExtend;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 合同业务相关的事件触发器
+ * 用于更新合同状态
+ */
+public class purPayReqRule extends BaseRuleImpl implements IBaseRule {
+
+    /**
+     * 具体的实现,参考下面方法中的说明,所有的实现都差不多结构,
+     * 只有自定义的异常处理接口实现中是没有传入 runningdata的.
+     * 不同的接口 仅仅是额外传入的参数有些差异,额外的参数多数都是可以从runningdata中获取的
+     * 系统为了方便接口的实现,额外传入了一些认为会用到的参数
+     *
+     * @return
+     */
+    @Override
+    public boolean executeRule() {
+        // 从引擎获取到核心数据对象(如果接口没有额外传入需要的数据时,可以从此对象中获取)
+        RunningData runningdata = getRunningdata();
+        Map<String, String> flowVar = runningdata.getFlowVar().getAllFlowVarMap();
+
+        //事件处理类额外传入参数
+        // 1.执行事件的节点对象
+        IFlowNode eventNode = (IFlowNode) getParameter(StaticVarExtend.Parameter_IFlowNode);
+
+        // 2.当前节点对象
+        IFlowNode curNode = (IFlowNode) getParameter(StaticVarExtend.Parameter_Current_IFlowNode);
+        // 3.引擎调用时,传入的参数对象
+        WorkParaBean paraBean = (WorkParaBean) getParameter(StaticVarExtend.Parameter_WorkParaBean);
+        // Map<String, String> varMap = paraBean.getFlowVarMap();
+        String action = paraBean.getActionname();
+        // 4.当前实例对象
+        DBWork work = (DBWork) getParameter(StaticVarExtend.Parameter_DBWork);
+        // 5.当前执行人对象
+        IRunUser user = (IRunUser) getParameter(StaticVarExtend.Parameter_RunUser);
+        // 6.当前路径对象
+        DBTrack track = (DBTrack) getParameter(StaticVarExtend.Parameter_DBTrack);
+        int status = track.getFlowstatus();
+        String nodeId = track.getNodeid();
+        String statusName = track.getFunname();
+        String nodeName = track.getNodename();
+        // 7.需要保存的SQL数据如果需要引擎来保存,请放入此 map中(key=SQL,value=List为SQL中对应的参数)
+        Map<String, List<Object>> dataMap = (Map<String, List<Object>>) getParameter(StaticVarExtend.Parameter_SaveMap);
+        // 8.事件类型
+        String eventType = (String) getParameter("eventType");
+        // 9.事件实际执行内容
+        // 10.返回 true 表示执行成功,引擎从第7步中的dataMap里获取需要保存的数据,引擎继续往下执行,
+        // 返回 false表示执行失败, 引擎会根据事件类型,确定是否继续往下执行
+
+        System.err.println(
+                ",status:" + status +
+                        ",nodeId:" + nodeId +
+                        ",nodeName:" + nodeName +
+                        ",statusName:" + statusName +
+                        ",action:" + action +
+                        ",eventNodeId:" + eventNode.getNodeid() +
+                        ",eventNodeName:" + eventNode.getNodename());
+
+        if (eventNode.getNodeid().contains("End")) {
+            status = 170;
+        } else if (eventNode.getNodeid().equals("Node1")) {
+            if (statusName.equals("JumpReject") || statusName.equals("Reject")) {
+                status = 130;
+            } else if (statusName.equals("Getback")) {
+                status = 190;
+            } else if (statusName.equals("autofirst")) {
+                status = 110;
+            }
+        } else {
+            status = 110;
+        }
+
+        // 业务使用
+        // flowVar就是业务传递过来的参数集
+        // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
+        String url = Constants.WF_PRE_URL + "/pur/PayReqHead/horizonApprovalProcess";
+        System.err.println(flowVar.toString());
+        String id = flowVar.get("id");
+        Map<String, Object> params = new HashMap<>();
+        params.put("id", id);
+        params.put("processInstanceStatus", status);
+        String result = HttpUtil.post(url, params);
+        System.err.println("result:" + result);
+        return true;
+    }
+}
+
+