package com.yc.open.yejibao.schedule;

import com.yc.factory.FactoryBean;
import com.yc.multiData.SpObserver;
import com.yc.open.init.BaseGate;
import com.yc.open.init.Task;
import com.yc.open.mutual.schedule.GateEntity;
import com.yc.open.yejibao.controller.YeJiBaoController;
import com.yc.open.yejibao.controller.YeJiBaoHandleController;
import com.yc.open.yejibao.service.YeJiBaoIfc;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 推送收款单
 */
public class T150101Thread extends BaseGate implements Runnable {
    protected final Logger log = LoggerFactory.getLogger(this.getClass());
    private static String TASKID = "OP0071";//指定任务ID，其他功能号也有对应的taskid
    private GateEntity entity;
    YeJiBaoIfc yeJiBaoIfc;
    YeJiBaoController yeJiBaoController;

    public T150101Thread(GateEntity entity, YeJiBaoIfc yeJiBaoIfc, YeJiBaoController yeJiBaoController) {
        this.entity = entity;
        this.yeJiBaoIfc = yeJiBaoIfc;
        this.yeJiBaoController = yeJiBaoController;
    }

    @Override
    public void run() {
        try {
            SpObserver.setDBtoInstance("_" + entity.getDbid());
            Task task = checkPoint(entity, TASKID);
            //满足条件才执行
            if (task != null && task.getResult() == 1) {
                YeJiBaoHandleController yeJiBaoHandleController = (YeJiBaoHandleController) FactoryBean.getBean("yeJiBaoHandleController");
                yeJiBaoHandleController.call150101(entity, task);
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            yeJiBaoController.sendErrorLog(entity.getFormid(), entity.getDocCode(), ex);
            log.error(ex.getMessage());
        } finally {
            SpObserver.setDBtoInstance();
        }
    }

}