|
|
|
@ -64,11 +64,11 @@ public class WorkflowSyncCronJob extends BaseCronJob {
|
|
|
|
|
private void IncrementSynchronizeWorkflow(BaseBean bb, String synchronizeFlowUrl, String synchronizeUserUrl, String cataCode, String workflowAuthTable, String timeNodeTable, String accountName, String password) {
|
|
|
|
|
RecordSet recordSet = new RecordSet();
|
|
|
|
|
//查询时间节点表,上次流程推送增量同步的时间
|
|
|
|
|
String timeSql = "select tbsj from " + timeNodeTable + " where tblx=? and zy=? order by tbsj desc";
|
|
|
|
|
String timeSql = "select timenode from " + timeNodeTable + " where type=? and useto=? order by timenode desc";
|
|
|
|
|
recordSet.executeQuery(timeSql, SYNC_INCREMENT, TIME_NODE_USE_WORKFLOW_SYNC);
|
|
|
|
|
String preTime = "";
|
|
|
|
|
if (recordSet.next()) {
|
|
|
|
|
preTime = recordSet.getString("tbsj");
|
|
|
|
|
preTime = recordSet.getString("timenode");
|
|
|
|
|
}
|
|
|
|
|
syncWorkflowByCondition(bb, synchronizeFlowUrl, synchronizeUserUrl, cataCode, workflowAuthTable, accountName, password, preTime);
|
|
|
|
|
}
|
|
|
|
|