【定时任务】如何在系统里面设置定时任务？

guoguo

一、实现效果
在JEpaas里面设置定时任务，让系统每隔一段时间进行一些操作。
二、实现思路
三、具体操作
1、如图1，在开发->定时任务里面增加一条定时任务。
2、如图2，设置对应的审批任务和开始时间，结束时间如果不写则默认是永远。

3、执行策略可以选择方法或者sql语句，如果选择方法，则只需要输入该方法的业务bean名称和该方法的方法名即可。在后台service里面实现该方法，并将该service注入到Spring容器中。如果选择sql直接在下面写sql语句即可。
4、在方法里面对时间进行判断，如果满足条件，则进行一些操作，本案例代码是每隔4小时往微信公众号上发送一条消息。
四、相关代码（可选）

1. /**
   
2.      * 启动定时任务，微信公众号每隔四小时推送未审批的消息
   
3.      */
   
4.     @Override
   
5.     public void sendWxgzhApproveInfo () {
   
6.         //判断当前时间，如果不在8：00-20：00内，直接返回;在：true
   
7.         Boolean flag = true;
   
8.         long times = System.currentTimeMillis();
   
9.         Date date = new Date(times);
   
10.         SimpleDateFormat format = new SimpleDateFormat("HH");
    
11.         String hour = format.format(date);//2021-10-11 12:08:22
    
12.                 int hourInt = Integer.parseInt(hour);
    
13.                 if (hourInt > 8 && hourInt < 20) {
    
14.                     flag = true;
    
15.                 }else {flag = false;}}}
    
16.         if (!flag) {
    
17.             return;
    
18.         }
    
19.         String title = ""; //审核题目
    
20.         String context = "";
    
21. 
    
22.         //String pcShowFunc = ""; //表单展示
    
23.         String funcCode = "";//获取功能编码    0
    
24.         String AppFunc = funcCode; //APP的功能编码与原功能相同
    
25.         String funcName = "";  //  1
    
26.         String tableName = "";//  2
    
27.         String funcId = ""; //主键名  3
    
28.         String pkValue = ""; //表单主键 4
    
29.         String userId = "";//流程待执行人ID
    
30.         String sql = "select EXECUTION_ID_ as executionId,ASSIGNEE_ as userId from JBPM4_TASK where  EXECUTION_ IS NOT NULL " +
    
31.                 "AND SUPERTASK_ IS NULL " +
    
32.                 "AND NAME_ NOT IN ( 'NODE_REJECT_TASK', 'ENTRUST_TRANSMIT_TASK', 'NODE_JOINCHILD_TASK' ) " +
    
33.                 "AND EXECUTION_ID_ IN ( SELECT ID_ FROM JBPM4_EXECUTION WHERE PROCDEFID_ IN ( SELECT PROCESSINFO_PROCESSDEFINIT_ID FROM JE_CORE_PROCESSINFO WHERE PROCESSINFO_DEPLOYSTATUS = '1' AND PROCESSINFO_ENABLED = '1' ) ) " +
    
34.                 "AND EXECUTION_ID_ NOT IN ( SELECT ID_ FROM JBPM4_HIST_PROCINST WHERE STATE_ = 'HANDUPED' ) " +
    
35.                 "AND DELAYTASK_ = '0' ";
    
36.         List<Map> taskInfos = serviceTemplate.queryMapBySql(sql);
    
37.         for (Map task:taskInfos) {
    
38.             String executionId = (String)task.get("executionId");//流程实例
    
39.             userId = (String)task.get("userId"); //当前审批用户ID
    
40.             //如果查不到该用户直接返回
    
41.             List<DynaBean> users = serviceTemplate.selectList("JE_CORE_ENDUSER","and USERID = '" + userId + "'");
    
42.             if (users.size() <= 0) {
    
43.                 continue;
    
44.             }
    
45.             String[] res = getRes(executionId);
    
46.             if (res.length > 6 && !res[4].equals(" ")) { //返回了所有参数
    
47.                 funcCode = res[0];
    
48.                 funcName = res[1];
    
49.                 tableName = res[2];
    
50.                 funcId = res[3];
    
51.                 pkValue = res[4];
    
52.                 context = "您有一条" + funcName + "的流程已经超过4小时未审批，请您及时审批。";
    
53.                 //pcShowFunc="<a href="javascript:void(0)" onclick="JE.showFunc(" + funcCode + ",{type:'form',id:"+pkValue+",readOnly:true  })">查看</a>";
    
54.                 List<UserMsgAppInfo> userMsgAppInfos = Lists.newArrayList();
    
55.                 net.sf.json.JSONObject params = new net.sf.json.JSONObject();
    
56.                 params.put("pkValue", pkValue);
    
57.                 UserMsgAppInfo appInfo = new UserMsgAppInfo("流程审核", "APPFUNC", AppFunc, "form", params);
    
58.                 userMsgAppInfos.add(appInfo);
    
59.                 title = funcName + "流程审批提醒";
    
60.                 userMsgManaer.sendMsg(userId, title, context, "MSG", pkValue, userMsgAppInfos);
    
61.                 String wxTitle = funcName + "提醒";
    
62.                 DynaBean dynaBean=serviceTemplate.selectOneByPk(tableName,pkValue);
    
63.                 if (dynaBean == null ) {
    
64.                     continue;
    
65.                 }
    
66.                 StringBuffer context1 = new StringBuffer(context);
    
67.                 SendGzhMsg(dynaBean,wxTitle,context1,pkValue,userId,funcId);
    
68.             }
    
69.         }
    
70.     }

复制代码

五、总结（可选）
系统设置定时任务比较简单，设置好之后直接写对应的service代码即可。
六、关键字
定时任务、发送微信公众号消息、