package com.ld.igds.io.impl;

import com.ld.igds.constant.BizType;
import com.ld.igds.io.notify.NotifyGrainInvoker;
import com.ld.igds.models.DepotConf;
import com.ld.igds.models.DicSysConf;
import com.ld.igds.models.Grain;
import com.ld.igds.order.ExeOrderService;
import com.ld.igds.order.data.ExeRequest;
import com.ld.igds.util.SpringUtil;
import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.Callable;

/**
 * 模拟演示粮情返回任务
 */
@Slf4j
public class DefaultAnalysisGrainTask implements Callable<String> {

    private Grain grainData;
    DepotConf depotConf;
    DicSysConf sysConf;
    String orderId;

    public DepotConf getDepotConf() {
        return depotConf;
    }

    public void setDepotConf(DepotConf depotConf) {
        this.depotConf = depotConf;
    }

    public DicSysConf getSysConf() {
        return sysConf;
    }

    public void setSysConf(DicSysConf sysConf) {
        this.sysConf = sysConf;
    }

    public Grain getGrainData() {
        return grainData;
    }

    public void setGrainData(Grain grainData) {
        this.grainData = grainData;
    }

    public String getOrderId() {
        return orderId;
    }

    public void setOrderId(String orderId) {
        this.orderId = orderId;
    }

    public DefaultAnalysisGrainTask() {
    }

    public DefaultAnalysisGrainTask(Grain grainData, DepotConf depotConf,
                                    DicSysConf sysConf, String orderId) {
        this.grainData = grainData;
        this.depotConf = depotConf;
        this.sysConf = sysConf;
        this.orderId = orderId;
    }

    @Override
    public String call() throws Exception {

        Thread.sleep(5 * 1000);

        NotifyGrainInvoker notifyGrainInvoker = SpringUtil
                .getBean(NotifyGrainInvoker.class);

        ExeOrderService exeOrderService = SpringUtil.getBean(ExeOrderService.class);

        ExeRequest exeRequest = exeOrderService.getOrderById(BizType.GRAIN.getCode(), orderId);

        if (null != notifyGrainInvoker) {
            notifyGrainInvoker.analysisSuccess(grainData, exeRequest, sysConf);
        } else {
            log.error("-------粮情子任务没有获取到：NotifyGrainInvoker的注入类");
        }

        return "SUCCESS";
    }
}