流程推送优化-增加全量方法

src/weaver/interfaces/dito/job/WorkflowUserCronJob.java

@@ -15,6 +15,7 @@ import java.util.*;
 
 import static com.engine.dito.ssologin.constant.DitoConstant.ACTION_TYPE_ADD_USER;
 import static com.engine.dito.ssologin.constant.DitoConstant.ACTION_TYPE_DELETE;
+import static com.engine.dito.ssologin.constant.DitoConstant.SYNC_ALL;
 
 /**
  * @version 1.0
@@ -25,20 +26,27 @@ import static com.engine.dito.ssologin.constant.DitoConstant.ACTION_TYPE_DELETE;
  * @Author Lee
  */
 public class WorkflowUserCronJob extends BaseCronJob {
+    private String isAll;
     private static final Log logger = LogFactory.getLog(WorkflowUserCronJob.class);
 
     @Override
     public void execute() {
         BaseBean bb = new BaseBean();
         bb.writeLog("start WorkflowAuthModelingCronJob");
+        RecordSet rs = new RecordSet();
         try {
+            //全量则删除建模表数据重新同步
+            if (StringUtils.isNotEmpty(isAll) && SYNC_ALL.equals(isAll)) {
+                bb.writeLog("DELETE ALL uf_workflow_auth");
+                rs.execute("delete from uf_workflow_auth");
+            }
             String center = PropBean.getUfPropValue("newWorkflowCenter");
             String formModeId = PropBean.getUfPropValue("uf_workflow_auth_formModeId");
             String synchronizeUserUrl = PropBean.getUfPropValue("synchronizeUserUrl");
             String accountName = PropBean.getUfPropValue("username");
             String password = PropBean.getUfPropValue("passwd");
 
-            RecordSet rs = new RecordSet();
+
         /*
         查询出所有E9有效流程id，Set
          */