diff --git a/src/weaver/interfaces/job/WorkflowSyncCronJob.java b/src/weaver/interfaces/job/WorkflowSyncCronJob.java
index 850b73e4..4ead1c50 100644
--- a/src/weaver/interfaces/job/WorkflowSyncCronJob.java
+++ b/src/weaver/interfaces/job/WorkflowSyncCronJob.java
@@ -202,7 +202,7 @@ public class WorkflowSyncCronJob extends BaseCronJob {
     private void getUserConditionByWorkflow(String workflowAuthTable, String center, 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();
-        String userSql = "SELECT staffid as staffCode  FROM " + workflowAuthTable + " WHERE workflowselect=?";
+        String userSql = "SELECT workcode as staffCode  FROM " + workflowAuthTable + " WHERE workflowselect=?";
         RecordSet rs = new RecordSet();
         rs.executeQuery(userSql, flowCode);
         while (rs.next()) {