准实时任务调度服务设计开发说明

准实时任务调度服务：客户端提供任务，服务端提供服务，通过任务调度框架自动调度任务来实现准实时（异步）任务调度。

数据库设计说明

异步任务表（每个子系统都有此表）：tb_bat_job_statue

核心调度组件Easy ETL介绍

Easy ETL：任务调度框架，内置线程池模块，任务调度模块和远程控制模块。

服务端任务添加接口

添加准实时任务接口

基本信息

接口名称：添加准实时任务

接口路径（POST）：/ejob/addTask

请求参数

批量添加准实时任务接口

基本信息

接口名称：批量添加准实时任务

接口路径（POST）：/ejob/batchAddTask

请求参数

服务端任务开发说明

服务端任务编写示例：

package com.git.easyloan.loan.jobs;
import com.git.easyloan.commons.base.BaseEasyJob;
import com.git.easyloan.loan.service.batch.LoanBusinessChangeService;
import javacommon.coreframe.beans.Responder;
import javacommon.coreframe.holder.ApplicationContextHolder;
import java.util.HashMap;
import java.util.Map;
public class LoanBusinessChangeJob extends BaseEasyJob {
    /**
     * 按合同号移交业务
     * @param map
     * @return
     */
    public Responder change4contractNo(Map<String, String> map) {
        logBefore("移交合同【{}】",map.get("contractNo"));
        Map<String,String> retMap = new HashMap<String,String>();
        try {
            LoanBusinessChangeService loanBusinessChangeService = (LoanBusinessChangeService) ApplicationContextHolder.getServiceBean("LoanBusinessChangeService");
            loanBusinessChangeService.change4contractNo(map);
            logAfter();
            return success();
        }catch (Exception e){
            e.printStackTrace();
            logAfter();
            throw error(ERROR_CODE,ERROR_MESSAGE + e.getMessage());
        }
    }
    /**
     * 按客户号移交业务
     * @param map
     * @return
     */
    public Responder change4partyId(Map<String,String> map) {
        logBefore("移交客户【{}】",map.get("partyId"));
        Map<String,String> retMap = new HashMap<String,String>();
        try {
            LoanBusinessChangeService loanBusinessChangeService = (LoanBusinessChangeService) ApplicationContextHolder.getServiceBean("LoanBusinessChangeService");
            loanBusinessChangeService.change4partyId(map);
            logAfter();
            return success();
        }catch (Exception e){
            e.printStackTrace();
            logAfter();
            throw error(ERROR_CODE,ERROR_MESSAGE + e.getMessage());
        }
    }
}

客户端任务调度说明

客户端示例代码：

     @GetMapping("/addContractTask")
    @ResponseStatus(value = HttpStatus.OK)
    @ApiOperation(value = "添加合同移交任务", notes = "添加合同移交任务")
    public void addContractTask() {
        PoolHelpUtil poolHelpUtil = new PoolHelpUtilImpl();
        try {
            ThreadPool pool = ThreadPool.getInstance(poolHelpUtil);
            PageData pd = new PageData();
            pd.put("taskName","移交合同");  //任务名称：根据需要插入任务名称
            pd.put("taskPath","com.git.easyloan.loan.jobs");    // 任务路径：服务方提供的任务执行包路径
            pd.put("taskClasse","LoanBusinessChangeJob");   //任务执行器：服务方提供的执行任务的java类
            pd.put("taskFunc","change4contractNo"); //任务逻辑：服务方提供的任务执行器调用的逻辑方法
            pd.put("taskNo","change4contractNo");   //任务编号：默认存放任务逻辑名称即可
            Map<String,String> params = new HashMap<String,String>();
            params.put("contractNo","22622019205578");
            params.put("b_userNum","220476");
            params.put("b_orgNum","061226");
            params.put("b_bankCode","22699");
            params.put("a_userNum","220476");
            params.put("a_orgNum","061226");
            params.put("a_bankCode","22699");
            pd.put("taskParams", params);   //任务参数：服务方提供的任务执行逻辑需要的参数，必须使用Map<String,String>格式存放
            loanFeignClient.addTask(pd);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }