Quellcode durchsuchen

定时任务启动流程不跳过第一步修改

szjbdgzl vor 2 Jahren
Ursprung
Commit
069e595b31

+ 7 - 1
ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/task/services/impl/CycleTaskServiceImpl.java

@@ -1,11 +1,14 @@
 package com.lc.ibps.task.services.impl;
 
+import com.lc.ibps.base.core.constants.StringPool;
+import com.lc.ibps.base.web.context.ContextUtil;
 import com.lc.ibps.bpmn.api.IBpmInstService;
 import com.lc.ibps.bpmn.api.model.inst.IBpmProcInst;
 import com.lc.ibps.bpmn.api.service.BpmProcInstService;
 import com.lc.ibps.bpmn.cmd.IbpsProcInstCmd;
 import com.lc.ibps.bpmn.provider.BpmInstProvider;
 import com.lc.ibps.cloud.entity.APIRequest;
+import com.lc.ibps.org.party.persistence.entity.DefaultPartyUserPo;
 import com.lc.ibps.task.dao.TzqxdsrwbMapper;
 import com.lc.ibps.task.entity.Tzqxdsrwb;
 import com.lc.ibps.task.services.CycleTaskService;
@@ -82,7 +85,10 @@ public class CycleTaskServiceImpl implements CycleTaskService {
                 cmd = pmInstProvider.getStartCmd(request);
                 cmd.setSubject(varTzqxdsrwb.getRenWuMingCheng());
                 cmd.setCurUser(varTzqxdsrwb.getBianZhiRen());
-
+                DefaultPartyUserPo user = new DefaultPartyUserPo();
+                user.setUserId(varTzqxdsrwb.getBianZhiRen());
+                ContextUtil.setCurrentUser(user);
+                cmd.addVariable("ignoreSkipFirstNode", StringPool.TRUE);
                 IBpmProcInst inst = bpmProcInstService.startProcInst(cmd);
                 log.info(inst.toString());
             }