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)
blank

相关推荐

  • AndroidStudio入门基础(一)——基础布局

    AndroidStudio入门基础(一)——基础布局写在前面:上学期学习了Android,从一开始的什么都不懂到后来成功做出一个课程设计作品,回忆起来一路还是充满坎坷和辛酸泪的啊。遗忘是可怕的,为了防止以后把好不容易学到的东西忘得一干二净,我打算写一系列的AndroidStudio教程记录一些有用的知识点,当然,我会从最基础的地方写起,希望可以帮助到一些初学者~最后,如果时间和精力允许的情况下,我会一步步的还原我的课程设计,喵喵喵~(…

  • Python 解决 :NameError: name ‘reload’ is not defined 问题

    Python 解决 :NameError: name ‘reload’ is not defined 问题

    2021年10月21日
  • maven常用打包命令

    maven常用打包命令maven常用打包命令1、mvncompile编译,将Java源程序编译成class字节码文件。2、mvntest测试,并生成测试报告3、mvnclean将以前编译得到的旧的class字节码文件删除4、mvnpakage打包,动态web工程打war包,Java工程打jar包。5、mvninstall将项目生成jar包放在仓库中,以便别的模块调用6、mvncleaninstall-Dmaven.test.skip=true打成jar包,并且抛弃测

  • onedrive免费扩容15g_onedrive怎样免费扩容

    onedrive免费扩容15g_onedrive怎样免费扩容免费扩容onedrive最高可以免费获得10G,每邀请一个新用户就可以双方共同获得0.5G内存扩容链接:https://onedrive.live.com?invref=2ef0e90fd6f1bed7&invscr=90

  • CLion2022.01.13激活码(JetBrains全家桶)

    (CLion2022.01.13激活码)JetBrains旗下有多款编译器工具(如:IntelliJ、WebStorm、PyCharm等)在各编程领域几乎都占据了垄断地位。建立在开源IntelliJ平台之上,过去15年以来,JetBrains一直在不断发展和完善这个平台。这个平台可以针对您的开发工作流进行微调并且能够提供…

  • hacker.4

    hacker.4

发表回复

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

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