FlowStartXxlJob.java
2.73 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package com.hotent.runtime.job;
import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.node.ObjectNode;
import com.hotent.base.constants.SystemConstants;
import com.hotent.base.exception.BaseException;
import com.hotent.base.util.BeanUtils;
import com.hotent.base.util.JsonUtil;
import com.hotent.base.util.StringUtil;
import com.hotent.runtime.controller.InstanceController;
import com.hotent.runtime.params.StartFlowParamObject;
import com.hotent.runtime.params.StartResult;
import com.hotent.uc.api.impl.util.ContextUtil;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
/**
* 定时启动流程
*
* @company 广州宏天软件股份有限公司
* @author jason
* @email liygui@jee-soft.cn
* @date 2020年5月28日
*/
@Component
public class FlowStartXxlJob {
@Resource
InstanceController instanceController;
/**
* 1、简单任务示例（Bean模式）
*/
@XxlJob("flowStartXxlJob")
public ReturnT<String> flowStartXxlJob(String param) throws Exception {
XxlJobLogger.log("XXL-JOB, 开始执行定时启动流程.");
String defaultAccount = SystemConstants.SYSTEM_ACCOUNT;
JsonNode jsonNode = JsonUtil.toJsonNode(param);
String flowkey = jsonNode.get("flowkey").asText();
String startAccount = jsonNode.get("startAccount").asText();
if(StringUtil.isNotEmpty(startAccount)) {
defaultAccount = startAccount;
}
// 定时任务中没有当前登录用户，所以需要设置到当前用户上下文中
ContextUtil.setCurrentUserByAccount(defaultAccount);
if(BeanUtils.isEmpty(flowkey)) {
throw new BaseException("定时启动流程的自动任务中必须配置flowkey来指定要启动的流程.");
}
startFlow(flowkey, defaultAccount);
return ReturnT.SUCCESS;
}
private void startFlow(String flowKey, String account) throws Exception {
// 构建启动流程的参数
ObjectNode startFlowParam = JsonUtil.getMapper().createObjectNode();
startFlowParam.put("flowKey", flowKey);
startFlowParam.put("account", account);
StartFlowParamObject startFlowParamObject = new StartFlowParamObject();
startFlowParamObject.setFlowKey(flowKey);
startFlowParamObject.setAccount(account);
// 调用接口启动流程
StartResult startFlowResult = instanceController.start(startFlowParamObject);
if(BeanUtils.isNotEmpty(startFlowResult) && !startFlowResult.getState()) {
String message = "流程启动失败";
if(BeanUtils.isNotEmpty(startFlowResult) && BeanUtils.isNotEmpty(startFlowResult.getMessage())) {
message += ":" + startFlowResult.getMessage();
}
throw new BaseException(message);
}
}
}