java工作流_Java 实现简单工作流
大家好,又见面了,我是你们的朋友全栈君。
工作流主要运用到反射机制
创建一张工作流表
如:主键 | 工作流Code | 工作流内容
其中工作流,内容为Json格式
工作流内容如下
{
“procCode”: “OPS”,
“procName”: “c端补齐(乘客信息补全)”,
“taskControlVoList”: [
{
“sortNo”: “10”,
“taskCode”: “OPC”,
“taskName”: “检查对应的订单信息是否存在”,
“tasklassName”: “com.xf.flow.service.impl.OrderPeople10ServImpl”
},
{
“sortNo”: “20”,
“taskCode”: “OPD”,
“taskName”: “乘客数据库落库”,
“tasklassName”: “com.xf.flow.service.impl.OrderPeople20ServImpl”
},
{
“sortNo”: “90”,
“taskCode”: “RSP”,
“taskName”: “响应消息”,
“tasklassName”: “com.xf.flow.service.impl.ApiResponseServImpl”
}
]
}
3.java代码现根据工作流的Code 获取当前的工作流
4.jsonStr ————>JsonObject————>获取taskControlVoList
5.java的工作流代码
@Override
public ApiResponse deal(String itemNo, Object objVo, String skey, InnerVo innerVo) {
ApiResponse apiResponse = new ApiResponse();
//查询itemNo获取流程实例
ProcControlVo procControlVo = codeLibraryDao.queryProcConfig(itemNo);
if (procControlVo == null) {
return new ApiResponse(ResponseCodeEnums.stream_no_exist);
}
List taskControlVoList = procControlVo.getTaskControlVoList();
taskControlVoList.sort((TaskControlVo h1, TaskControlVo h2) -> h1.getSortNo().compareTo(h2.getSortNo()));
Iterator itTask = taskControlVoList.iterator();
//初始化内部数据表
String dataNo = taskManagerServ.initData(itemNo,skey,innerVo);
//循环依次执行流程任务
String taskNo = null;
while (itTask.hasNext()){
TaskControlVo taskControlVo = itTask.next();
String taskClassName = taskControlVo.getTasklassName();
String taskItemNo = taskControlVo.getTaskCode();
String taskName = taskControlVo.getTaskName();
try {
//初始化任务
taskNo = taskManagerServ.initTask(taskItemNo,dataNo,innerVo);
//执行任务
TaskServ taskServ = (TaskServ) SpringFactory.getBean(Class.forName(taskClassName));
taskServ.init(taskNo,objVo);
TaskAnswerVo taskAnwserVo = taskServ.deal(taskNo,objVo);
//判断任务执行结果
apiResponse = taskAnwserVo.getApiResponse();
if(StringUtils.equals(ResponseCodeEnums.success.getStatus(),apiResponse.getStatus())) {
//完成任务
logger.info(“==========>>>>> task execute success !!! taskCode={}, taskName={}, status={}, msg={}, nextTask={}”,
taskItemNo,taskName,apiResponse.getStatus(),apiResponse.getMessage(),taskAnwserVo.isNextTask());
taskManagerServ.finTask(taskNo, apiResponse.getMessage());
}else {
//异常任务
logger.info(“==========>>>>> task execute error !!! taskCode={}, taskName={}, status={}, msg={}, nextTask={}”,
taskItemNo,taskName,apiResponse.getStatus(),apiResponse.getMessage(),taskAnwserVo.isNextTask());
taskManagerServ.errTask(taskNo, apiResponse.getMessage());
}
//判断流程是否继续
if(!taskAnwserVo.isNextTask()){
break;
}
} catch (Exception e) {
//异常任务
String errorMsg = getStackTrace(e);
taskManagerServ.errTask(taskNo, errorMsg);
logger.error(“==========>>>>> Execute Task Error!!! skey={}, taskControlVo={}, errorMsg={}”,skey,taskControlVo,errorMsg);
//响应异常
return new ApiResponse(ResponseCodeEnums.flow_error);
}
}
if(StringUtils.equals(ResponseCodeEnums.success.getStatus(),apiResponse.getStatus())) {
//归档完成流程
taskManagerServ.finData(dataNo);
}
return apiResponse;
}
image.png
SpringFactory实现类
/**
* Created by
*/
@Component
public class SpringFactory implements ApplicationContextAware {
private static ApplicationContext applicationContext;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
if(SpringFactory.applicationContext == null) {
SpringFactory.applicationContext = applicationContext;
}
}
//获取applicationContext
public static ApplicationContext getApplicationContext() {
return applicationContext;
}
//通过name获取 Bean.
public static Object getBean(String name){
return getApplicationContext().getBean(name);
}
//通过class获取Bean.
public static T getBean(Class clazz){
return getApplicationContext().getBean(clazz);
}
//通过name,以及Clazz返回指定的Bean
public static T getBean(String name,Class clazz){
return getApplicationContext().getBean(name, clazz);
}
}
发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/156591.html原文链接:https://javaforall.cn
相关文章
- java实现MD5加密
- java 实现 按位异或_Java 按位异或的性质及其妙用
- java启动器_JAVA基础:Java 启动器如何查找类
- md5 java 实现_MD5加密的Java实现
- MySQL字段类型如何转为java_Java JDBC中,MySQL字段类型到JAVA类型的转换
- java webservice实现_JAVA WebService的实现方式
- rtsp 获取视频流 java_Java获取rtsp视频流,实现rtsp流预览功能,并将视频流每帧保存成图片…
- java 异或加密_使用异或实现一个简单的加密或解密
- java药店网站药店系统药店源码刷脸支付源码
- Java 连接 MySQL 数据库简易实现(java连mysql)
- Java连接MySQL数据库的简单步骤(java如何连接mysql数据库)
- Java轻松使用Redis实现数据高效存储(java使用redis)
- 时间Java程序操纵Redis实现过期时间设置(redisjava过期)
- 时钟实现Redis Java实现的过期时钟机制(redisjava过期)
- 时间Redis在Java中设置过期时间的实现方法(redisjava过期)
- 处理Java实现Redis过期键的简单处理法(redisjava过期)
- 自动清理Redis中Java实现自动过期清理(redisjava过期)
- 挑战未来:学习Linux与Java(学linux还是java)
- Java与MySQL的无缝衔接:实现高效数据操作(java中使用mysql)
- 秘籍学习实现纯Java版Redis(纯java版redis)
- Java实现九九乘法表的小例子
- JAVA简单链接Oracle数据库注册和登陆功能的实现代码