From b0bd83945612bf7994933fe0fd0c1f8555a26322 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E6=A0=8B?= Date: Tue, 27 Dec 2022 17:22:35 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=81=E7=A8=8B=E6=8E=A8=E9=80=81=E4=BC=98?= =?UTF-8?q?=E5=8C=96-=E5=A2=9E=E5=8A=A0=E5=85=A8=E9=87=8F=E6=96=B9?= =?UTF-8?q?=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../interfaces/dito/job/WorkflowUserCronJob.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/weaver/interfaces/dito/job/WorkflowUserCronJob.java b/src/weaver/interfaces/dito/job/WorkflowUserCronJob.java index 19cb583d..2d11e8e6 100644 --- a/src/weaver/interfaces/dito/job/WorkflowUserCronJob.java +++ b/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 */