diff --git a/src/weaver/interfaces/job/WorkflowSyncCronJob.java b/src/weaver/interfaces/job/WorkflowSyncCronJob.java index c126f592..bfef7de9 100644 --- a/src/weaver/interfaces/job/WorkflowSyncCronJob.java +++ b/src/weaver/interfaces/job/WorkflowSyncCronJob.java @@ -107,14 +107,14 @@ public class WorkflowSyncCronJob extends BaseCronJob { //拼接有效流程请求参数 concatWorkflowCondition(center, cataCode, flowCode, flowName, ACTION_TYPE_ADD, addWorkflowList); //有效流程关联的人员参数拼接 - getUserConditionByWorkflow(center, cataCode, flowCode, flowName, ACTION_TYPE_ADD_USER, addUserList, timeCondition); + getUserConditionByWorkflow(workflowAuthTable, center, cataCode, flowCode, flowName, ACTION_TYPE_ADD_USER, addUserList, timeCondition); } else if (EFFECTIVE_NO.equals(effective)) { //拼接无效流程请求参数,如果有流程还有效则不删除 if (!workflowHasEffective(workflowAuthTable, recordSet2, flowCode)) { concatWorkflowCondition(center, cataCode, flowCode, flowName, ACTION_TYPE_DELETE, delWorkflowList); } //无效流程关联的人员参数拼接 - getUserConditionByWorkflow(center, cataCode, flowCode, flowName, ACTION_TYPE_DELETE_USER, delUserList, timeCondition); + getUserConditionByWorkflow(workflowAuthTable, center, cataCode, flowCode, flowName, ACTION_TYPE_DELETE_USER, delUserList, timeCondition); } } HashMap headers = new HashMap<>(); @@ -150,6 +150,7 @@ public class WorkflowSyncCronJob extends BaseCronJob { /** * 查询还在使用中的流程 + * * @param workflowAuthTable * @param recordSet2 * @param flowCode @@ -185,6 +186,7 @@ public class WorkflowSyncCronJob extends BaseCronJob { /** * 组装人员同步API请求参数 * + * @param workflowAuthTable * @param cataCode * @param flowCode * @param flowName @@ -192,10 +194,10 @@ public class WorkflowSyncCronJob extends BaseCronJob { * @param userList * @param timeCondition */ - private void getUserConditionByWorkflow(String center, String cataCode, String flowCode, String flowName, String actionType, ArrayList> userList, String timeCondition) { + private void getUserConditionByWorkflow(String workflowAuthTable, String center, String cataCode, String flowCode, String flowName, String actionType, ArrayList> userList, String timeCondition) { Map usermap = new HashMap<>(); StringBuilder staffCodeBuilder = new StringBuilder(); - String userSql = "SELECT workcode as staffCode FROM uf_workflow_aut WHERE workflowselect=?"; + String userSql = "SELECT workcode as staffCode FROM " + workflowAuthTable + " WHERE workflowselect=?"; RecordSet rs = new RecordSet(); rs.executeQuery(userSql, flowCode); while (rs.next()) {