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 */