java中的工作流要怎样实现_java工作流开发要怎么实现?

java中的工作流要怎样实现_java工作流开发要怎么实现?Java工作流的应用在目前十分广泛,能够熟练的实现工作流也是一种本事,本篇文章就让小编带你了解下其中的实现关键。我们知道,工作流的实现主要依靠反射机制,想要实现它,首先我们先来创建一张工作流表创建一张工作流表如:主键|工作流Code|工作流内容其中工作流内容为Json格式工作流内容{“procCode”:”OPS”,”procName”:”c端补齐(乘客信息补全)”,”taskCo…

大家好,又见面了,我是你们的朋友全栈君。

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”

}

]

}

aava代码现根据工作流的Code 获取当前的工作流

jsonStr ————>JsonObject————>获取taskControlVoList

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;

}

d8ea3beebaec94831a5b4138d9226da3.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);

}

}

以上就是本篇文章的所有内容,需要了解其他java常见问题及解决方法的小伙伴们请持续关注本网站吧。

推荐阅读:

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/156526.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 单工,半双工,全双工区别以及TDD和FDD区别

    单工,半双工,全双工区别以及TDD和FDD区别作为一名学通信的,居然对这个概念还是没搞清楚,兼职就是丢了大脸了!现在总结如下,理解比较浅,大部分网上查的,有不对的,请批评指正!单工,半双工,全双工区别单工单工就是指A只能发信号,而B只能接收信号,通信是单向的,就象灯塔之于航船——灯塔发出光信号而航船只能接收信号以确保自己行驶在正确的航线上。半双工指一个时间段内只有一个动作发生,举个简单例子,一天窄窄的马路,同时只能有一辆车通过,

  • Android自己主动化測试解决方式

    Android自己主动化測试解决方式

    2021年11月15日
  • kali如何更换源(怎样换一个kali源)

    KaliLinux的换源和更新1.修改源文件(需要用root权限)[plain]viewplaincopyvim /etc/apt/sources.list  2.这里修改两个我认为还好的源,因为每个地方不同,选择源的时候建议使用一些常用的吧。比如:阿里云源,中科大源之类的官方源更新的速度太慢了,所以我注释掉了,只使用两

  • 浅析finalize方法「建议收藏」

    浅析finalize方法「建议收藏」昨天有个小伙伴聊到java对象finalize方法。于是就想好好总结一下。咱们都知道判断一个对象是否已经死了的方法有两种:1:引用计数法2:可达性分析算法由于我们通常使用…

  • springboot—@Async实现异步调用及异步回调Future「建议收藏」

    springboot—@Async实现异步调用及异步回调Future「建议收藏」异步调用相对的是同步调用。同步方法调用的时候必须是按照顺序执行的,上一行代码执行完,才会执行下一行。而异步方法调用是相当于多个线程执行,不需要等待上一行代码的执行结果。首先测试方法同步的情况:controller:packagespringboot_async.async_test;importorg.springframework.beans.factory.annot…

  • 万物共享的物联网架构「建议收藏」

    万物共享的物联网架构「建议收藏」前言作为物联网领域最贴近用户的一个分支,智能家居行业在这两年持续火热。但是,除了智能家居外,物联网领域还有很多重要的组成部分:车联物流、智慧医疗、智慧社区、公共基础服务、智慧农业等。由于物联网的第一批先驱者往往都是从某个具体子行业转型过来的,对于物联网的认知也如盲人摸象,管中窥豹,很难有全局性的眼光。基于国外物联网大神DanielKarzel,HanneloreMarginean,

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号