bug fix

src/main/java/com/horizon/third/adapter/FlowManageAdapter.java

@@ -0,0 +1,145 @@
+package com.horizon.third.adapter;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.horizon.common.base.Objects;
+import com.horizon.third.Authority;
+import com.horizon.third.Persistence;
+import com.horizon.third.init.WorkflowAdapterInit;
+
+/**
+ * 流程管理适配器
+ *
+ * @author mwr
+ *
+ */
+public class FlowManageAdapter extends WorkflowBaseAdapther implements Authority {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(FlowManageAdapter.class);
+
+    private static final String SELECT_FLOWS = "SELECT A.FLOWID FROM TW_HZ_FLOW_DEF"
+            + " A WHERE A.VERSION=(SELECT MAX(VERSION) FROM TW_HZ_FLOW_DEF WHERE FLOWID=A.FLOWID)";
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see com.horizon.third.Authority#getManager(java.lang.String)
+     */
+    @Override
+    public String getManager(String flowId) {
+
+        LOGGER.info("流程 {} 默认管理员为 admin ", flowId);
+        return "admin";
+    }
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see com.horizon.third.Authority#isStart(java.lang.String,
+     * java.lang.String)
+     */
+    @Override
+    public boolean isStart(String flowId, String userId) {
+
+        LOGGER.info("用户 {} 拥有启动流程 {},默认返回 true ", userId, flowId);
+        return true;
+    }
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see com.horizon.third.Authority#isManager(java.lang.String,
+     * java.lang.String)
+     */
+    @Override
+    public boolean isManager(String flowId, String userId) {
+
+        LOGGER.info("流程 {} 管理员 admin ", flowId);
+        return Objects.equal("1", userId);
+    }
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see com.horizon.third.Authority#getFlowManageList(java.lang.String,
+     * java.lang.String)
+     */
+    @Override
+    public List<String> getFlowManageList(String userid, String identifier) {
+
+        return getFlowDesignList(userid, identifier);
+    }
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see com.horizon.third.Authority#getFlowDesignList(java.lang.String,
+     * java.lang.String)
+     */
+    @Override
+    public List<String> getFlowDesignList(String userId, String dbIdentifier) {
+
+        Persistence access = (Persistence) WorkflowAdapterInit.getWorkflowAdapthers("access");
+        List<List<Object>> lst = access.getMultiList(SELECT_FLOWS, null, dbIdentifier);
+        List<String> lstResult = new ArrayList<String>();
+        if (lst != null && !lst.isEmpty()) {
+            for (List<Object> l : lst) {
+                lstResult.add((String) l.get(0));
+            }
+        }
+        return lstResult;
+    }
+
+    /**
+     * 获得流程启动权限列表
+     *
+     * @param userid
+     *            用户Id
+     * @param identifier
+     *            数据源标识
+     * @return 具有启动权限的流程Id
+     */
+    public List<String> getFlowStartList(String userid, String identifier) {
+
+        Persistence access = (Persistence) WorkflowAdapterInit.getWorkflowAdapthers("access");
+        List<List<Object>> lst = access.getMultiList(SELECT_FLOWS, null, identifier);
+
+        List<String> lstResult = new ArrayList<String>();
+        if (lst != null && !lst.isEmpty()) {
+            for (List<Object> lstObject : lst) {
+
+                lstResult.add(String.valueOf(lstObject.get(0)));
+            }
+        }
+        return lstResult;
+
+    }
+
+    @Override
+    public void authInit(String userId, String dataid, String resourceType, Map<String, List<Object>> saveMap,
+                         String dbIdentifier) {
+
+        // TODO Auto-generated method stub
+
+    }
+
+    @Override
+    public void releaseBizPermission(String[] dataids, Map<String, List<List<Object>>> saveMap) {
+
+        // TODO Auto-generated method stub
+
+    }
+
+    @Override
+    public boolean validateOperatorTenant(String userId, String tenantCode, String dbIdentifier) {
+
+        // TODO Auto-generated method stub
+        return false;
+    }
+
+}

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

@@ -0,0 +1,100 @@
+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 SignRule 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表示执行失败, 引擎会根据事件类型,确定是否继续往下执行
+
+        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;
+        }
+        System.err.println(
+                "status:" + status +
+                        ",nodeId:" + nodeId +
+                        ",nodeName:" + nodeName +
+                        ",statusName:" + statusName +
+                        ",action:" + action +
+                        ",eventNodeId:" + eventNode.getNodeid() +
+                        ",eventNodeName:" + eventNode.getNodename());
+
+        String url = Constants.WF_PRE_URL + "/cot/SignRequest/horizonApprovalProcess";
+        // String url = Constants.WF_PRE_URL + "/framework/Schedule/horizonApprovalProcess";
+        String id = varMap.get("id");
+        System.err.println(id);
+        System.err.println(varMap.toString());
+        Map<String, Object> params = new HashMap<>();
+        params.put("id", id);
+        params.put("processInstanceStatus", status);
+        System.err.println(url);
+        String result = HttpUtil.post(url, params);
+        System.err.println("result:" + result);
+        return true;
+    }
+}
+
+

src/main/java/com/horizon/workflow/rest/web/RestFlowSupportController.java

@@ -0,0 +1,173 @@
+//
+// Source code recreated from a .class file by IntelliJ IDEA
+// (powered by FernFlower decompiler)
+//
+
+package com.horizon.workflow.rest.web;
+
+import com.horizon.common.base.Function;
+import com.horizon.common.base.Objects;
+import com.horizon.common.collect.Collections2;
+import com.horizon.common.collect.Lists;
+import com.horizon.core.HorizonCore;
+import com.horizon.language.Hi18n;
+import com.horizon.utils.HorizonPorps;
+import com.horizon.utils.StringUtil;
+import com.horizon.utils.json.JsonUtil;
+import com.horizon.wf.bean.WorkParaBean;
+import com.horizon.wf.core.mem.MemCacheUtil;
+import com.horizon.wf.entity.db.DBLog;
+import com.horizon.workflow.form.entity.FieldAuth;
+import com.horizon.workflow.form.service.ISimpleFormFieldAuthService;
+import com.horizon.workflow.monitor.service.IFlowLogService;
+import com.horizon.workflow.rest.model.RequestParams;
+import com.horizon.workflow.rest.model.ResponseResult;
+import com.horizon.workflow.rest.util.RestWorkUtil;
+import com.horizon.workflow.rest.web.base.RestSuperController;
+import com.horizon.workflow.support.model.FlowAction;
+import com.horizon.workflow.support.model.FlowForm;
+import com.horizon.workflow.support.model.FlowResult;
+import com.horizon.workflow.support.service.IFlowSupportService;
+import com.horizon.workflow.tenant.service.ITenantGrantService;
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import javax.servlet.http.HttpServletRequest;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+@Controller
+@RequestMapping({"${url.prefix}/rest"})
+public class RestFlowSupportController extends RestSuperController {
+    @Autowired
+    private IFlowSupportService flowSupportService;
+    @Autowired
+    private IFlowLogService flowLogService;
+    @Autowired
+    private ISimpleFormFieldAuthService simpleFormFieldAuthService;
+    @Autowired
+    private ITenantGrantService tenantGrantService;
+
+    public RestFlowSupportController() {
+    }
+
+    @ResponseBody
+    @RequestMapping({"/flow/support/open${url.suffix}"})
+    public String open() {
+        WorkParaBean workParaBean = null;
+        ResponseResult result = super.getParamWithToken();
+        if (!result.isSuccess()) {
+            return this.renderJson(result);
+        } else {
+            RequestParams params = (RequestParams)result.getData();
+            workParaBean = RestWorkUtil.workParaBeanSet(params);
+            String workId = workParaBean.getWorkId();
+            List activeInstanceIds;
+            if ("true".equals(HorizonPorps.getConfig("isValidateOfTenant"))) {
+                activeInstanceIds = this.findActiveInstanceIds();
+                if (!activeInstanceIds.contains(workId)) {
+                    boolean check = this.tenantGrantService.checkTenantWork(HorizonCore.TENANT_CODE.value(), activeInstanceIds.size());
+                    if (!check) {
+                        return this.renderJson(ResponseResult.failure(Hi18n.getVal("tenant-grant", "checkWork")));
+                    }
+                }
+            }
+
+            activeInstanceIds = null;
+            FlowResult flowResult;
+            if (StringUtil.hasValue(workId)) {
+                flowResult = this.flowSupportService.open(workParaBean);
+            } else {
+                //2023-06-09 yangff add 创建流程增加变量传递
+                if (null != params.get("actionData")) {
+                    String actionData = JsonUtil.toJson(params.get("actionData"));
+                    FlowAction flowAction = JsonUtil.fromJson(actionData, FlowAction.class);
+                    if(null!=flowAction.getFlowVars()) workParaBean.setFlowVarMap(flowAction.getFlowVars());
+                }
+                //2023-06-09 add 创建流程增加变量传递 end
+                flowResult = this.flowSupportService.create(workParaBean);
+            }
+
+            this.setFormFieldAuth(flowResult.getFlowForms());
+            return this.renderJson(flowResult);
+        }
+    }
+
+    @ResponseBody
+    @RequestMapping({"/flow/support/action${url.suffix}"})
+    public String action(HttpServletRequest request) {
+        ResponseResult result = super.getParamWithToken();
+        if (!result.isSuccess()) {
+            return this.renderJson(result);
+        } else {
+            RequestParams params = (RequestParams)result.getData();
+            WorkParaBean workParaBean = new WorkParaBean();
+            FlowAction flowAction = RestWorkUtil.getFlowPara(params, workParaBean);
+            String data = "";
+            if (flowAction != null) {
+                if (!Objects.equal("close", flowAction.getOperate())) {
+                    RestWorkUtil.setMessageType(workParaBean, flowAction.getMessageType());
+                    RestWorkUtil.setFormData(request, workParaBean);
+                    data = this.flowSupportService.operate(workParaBean, flowAction);
+                } else if (Objects.equal(flowAction.getReOpen(), "false")) {
+                    this.flowSupportService.close(flowAction.getWorkId(), flowAction.getTrackId(), workParaBean.getUserId());
+                    flowAction.setOperateStatus("success");
+                    data = flowAction.toString();
+                }
+            }
+
+            return data;
+        }
+    }
+
+    @ResponseBody
+    @RequestMapping({"/flow/support/history${url.suffix}"})
+    public String history() {
+        ResponseResult result = super.getParamWithToken();
+        if (!result.isSuccess()) {
+            return this.renderJson(result);
+        } else {
+            RequestParams params = (RequestParams)result.getData();
+            String workId = (String)params.get("workId");
+            List<DBLog> flowLogs = this.flowLogService.findFlowLogById(workId);
+            ResponseResult responseResult = ResponseResult.success().data(flowLogs).recordsTotal(flowLogs.size() + "");
+            return super.skipFieldsToJson(responseResult, params);
+        }
+    }
+
+    protected void setFormFieldAuth(List<FlowForm> forms) {
+        if (forms != null && !forms.isEmpty()) {
+            Iterator var2 = forms.iterator();
+
+            while(var2.hasNext()) {
+                FlowForm flowForm = (FlowForm)var2.next();
+                String formId = flowForm.getFormId();
+                if (!"FlowTrack".equals(formId)) {
+                    String authId = flowForm.getFormAuthId();
+                    if (!"allreadonly".equals(authId) && !"alleditable".equals(authId)) {
+                        FieldAuth fieldAuth = this.simpleFormFieldAuthService.getFieldAuth(authId);
+                        flowForm.setFormFieldAuth(fieldAuth);
+                    }
+                }
+            }
+        }
+
+    }
+
+    private List<String> findActiveInstanceIds() {
+        List<Map<String, Object>> instanceLst = MemCacheUtil.getInstanceLstFromMemory(HorizonCore.TENANT_CODE.value());
+        if (instanceLst == null && instanceLst.isEmpty()) {
+            return Lists.newArrayList();
+        } else {
+            Collection<String> instanceIds = Collections2.transform(instanceLst, new Function<Map<String, Object>, String>() {
+                public String apply(Map<String, Object> instance) {
+                    return (String)instance.get("workid");
+                }
+            });
+            return Lists.newArrayList(instanceIds.iterator());
+        }
+    }
+}