diff --git a/src/weaver/interfaces/job/WorkflowSyncCronJob.java b/src/weaver/interfaces/job/WorkflowSyncCronJob.java index 38e4603f..180415ae 100644 --- a/src/weaver/interfaces/job/WorkflowSyncCronJob.java +++ b/src/weaver/interfaces/job/WorkflowSyncCronJob.java @@ -142,6 +142,14 @@ public class WorkflowSyncCronJob extends BaseCronJob { } } + /** + * 组装流程同步API请求参数 + * @param cataCode + * @param flowcode + * @param flowname + * @param actionType + * @param workflowList + */ private void concatWorkflowCondition(String cataCode, String flowcode, String flowname, String actionType, ArrayList> workflowList) { Map workflowMap = new HashMap<>(); workflowMap.put("flowcode", flowcode); @@ -153,6 +161,15 @@ public class WorkflowSyncCronJob extends BaseCronJob { workflowList.add(workflowMap); } + /** + * 组装人员同步API请求参数 + * @param cataCode + * @param flowcode + * @param flowname + * @param actionType + * @param userList + * @param timeCondition + */ private void getUserConditionByWorkflow(String cataCode, String flowcode, String flowname, String actionType, ArrayList> userList, String timeCondition) { Map usermap = new HashMap<>(); StringBuilder staffCodeBuilder = new StringBuilder(); @@ -187,16 +204,4 @@ public class WorkflowSyncCronJob extends BaseCronJob { String sql = "insert into " + timeNodeTable + "(id,formmodeid,tblx,tbsj,zy) values(?,?,?,?,?)"; recordSet.executeUpdate(sql, UUID.randomUUID(), formmodeid, syncType, currentTime, timeNodeUse); } - -// 增量同步 - //接口查询portal_oa已同步的流程 - //查询ecology有效的流程 - //对比,portal_oa需要删除的流程 - //portal_oa需要新同步的流程 - //查询流程关联的workcode,以"|"为分隔符拼接成字符串 - //根据需要删除的流程数量循环调用同步方法 - //根据要新同步的流程数量循环调用同步方法 - //调用人员同步方法 - - }