From 0153a314600eccba27fc094ff6e29aaca907f048 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E6=A0=8B?= Date: Mon, 31 Oct 2022 09:39:31 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E5=AD=97=E6=AE=B5?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/weaver/interfaces/job/WorkflowSyncCronJob.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/weaver/interfaces/job/WorkflowSyncCronJob.java b/src/weaver/interfaces/job/WorkflowSyncCronJob.java index 5289a6da..f2d136b4 100644 --- a/src/weaver/interfaces/job/WorkflowSyncCronJob.java +++ b/src/weaver/interfaces/job/WorkflowSyncCronJob.java @@ -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); }