java工作流开发要怎么实现?

TheDisguiser 2020-08-28 16:56:00 java常见问答 7678

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 < TaskControlVo > taskControlVoList = procControlVo.getTaskControlVoList();
     taskControlVoList.sort((TaskControlVo h1, TaskControlVo h2) - > h1.getSortNo()
         .compareTo(h2.getSortNo()));
     Iterator < TaskControlVo > 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;
 }

java工作流开发

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 > T getBean(Class < T > clazz)
    {
        return getApplicationContext()
            .getBean(clazz);
    }
    //通过name,以及Clazz返回指定的Bean
    public static < T > T getBean(String name, Class < T > clazz)
    {
        return getApplicationContext()
            .getBean(name, clazz);
    }
}

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

推荐阅读:

java工作流的优点是什么?怎么优雅地实现它?

java工作流业务涵盖了哪些方面?自动化解决方案需要具备哪些特征?

java工作流是什么?哪些工作流框架比较好?