|
|
|
@ -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<Map<String, Object>> workflowList) {
|
|
|
|
|
Map<String, Object> 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<Map<String, Object>> userList, String timeCondition) {
|
|
|
|
|
Map<String, Object> 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,以"|"为分隔符拼接成字符串
|
|
|
|
|
//根据需要删除的流程数量循环调用同步方法
|
|
|
|
|
//根据要新同步的流程数量循环调用同步方法
|
|
|
|
|
//调用人员同步方法
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|