fs-danaus
2024-02-21 0a4f165eec7585da85a0bd58444efb5eac06d35f
提交 | 用户 | age
bfda87 1 package com.yc.open.yejibao.schedule;
F 2
3 import com.yc.factory.FactoryBean;
4 import com.yc.multiData.SpObserver;
5 import com.yc.open.init.BaseGate;
6 import com.yc.open.init.Task;
7 import com.yc.open.mutual.schedule.GateEntity;
8 import com.yc.open.yejibao.controller.YeJiBaoController;
0a4f16 9 import com.yc.open.yejibao.controller.YeJiBaoHandleController;
bfda87 10 import com.yc.open.yejibao.service.YeJiBaoIfc;
F 11 import org.slf4j.Logger;
12 import org.slf4j.LoggerFactory;
13
14 /**
15  * 推送收款单
16  */
17 public class T150101Thread extends BaseGate implements Runnable {
18     protected final Logger log = LoggerFactory.getLogger(this.getClass());
19     private static String TASKID = "OP0071";//指定任务ID,其他功能号也有对应的taskid
20     private GateEntity entity;
21     YeJiBaoIfc yeJiBaoIfc;
22     YeJiBaoController yeJiBaoController;
23
24     public T150101Thread(GateEntity entity, YeJiBaoIfc yeJiBaoIfc, YeJiBaoController yeJiBaoController) {
25         this.entity = entity;
26         this.yeJiBaoIfc = yeJiBaoIfc;
27         this.yeJiBaoController = yeJiBaoController;
28     }
29
30     @Override
31     public void run() {
32         try {
33             SpObserver.setDBtoInstance("_" + entity.getDbid());
34             Task task = checkPoint(entity, TASKID);
35             //满足条件才执行
36             if (task != null && task.getResult() == 1) {
0a4f16 37                 YeJiBaoHandleController yeJiBaoHandleController = (YeJiBaoHandleController) FactoryBean.getBean("yeJiBaoHandleController");
F 38                 yeJiBaoHandleController.call150101(entity, task);
bfda87 39             }
F 40         } catch (Exception ex) {
41             ex.printStackTrace();
42             yeJiBaoController.sendErrorLog(entity.getFormid(), entity.getDocCode(), ex);
43             log.error(ex.getMessage());
44         } finally {
45             SpObserver.setDBtoInstance();
46         }
47     }
0a4f16 48
bfda87 49 }