package com.ld.igds.protocol.quantity.shuhan;

import com.ld.igds.camera.CameraUtil;
import com.ld.igds.camera.data.ApiSnapReq;
import com.ld.igds.constant.BizType;
import com.ld.igds.constant.RedisConst;
import com.ld.igds.io.request.QuantityRequest;
import com.ld.igds.models.QuantityConf;
import com.ld.igds.models.SnapSer;
import com.ld.igds.protocol.quantity.shuhan.command.BaseRemoteImpl;
import com.ld.igds.protocol.quantity.shuhan.command.RemoteQuantityServiceImpl;
import com.ld.igds.protocol.snap.SnapPluginService;
import com.ld.igds.quantity.service.CoreQuantityService;
import com.ld.igds.util.DateUtil;
import com.ld.igds.util.RedisUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateUtils;

import java.util.Date;
import java.util.concurrent.Callable;

/**
 *
 * @author andy.jia
 */
@Slf4j
public class QueryStatusTask extends BaseRemoteImpl implements Callable<String> {


    private RedisUtil redisUtil;

    private CoreQuantityService coreQuantityService;

    private String redisKey;

    private String queryMsg;

    private RemoteQuantityServiceImpl remoteQuantityService;

    private SnapPluginService snapService;

    public QueryStatusTask() {
        super();
    }

    public QueryStatusTask(RedisUtil redisUtil, RemoteQuantityServiceImpl remoteQuantityService, CoreQuantityService coreQuantityService, SnapPluginService snapService, String redisKey, String queryMsg) {
        super();
        this.redisUtil = redisUtil;
        this.coreQuantityService = coreQuantityService;
        this.remoteQuantityService = remoteQuantityService;
        this.snapService = snapService;
        this.redisKey = redisKey;
        this.queryMsg = queryMsg;
    }

    @Override
    public String call() throws Exception {
        //记录抓拍次数
        int num = 1;
        //记录抓拍时间间隔
        Date lastTime = new Date();
        Date curTime = null;

    	boolean flag = true;
        QuantityConf conf = null;
    	while (flag){
            Thread.sleep(1000 * 60 * 2 );
    	    //发起状态查询命令
            try{
                QuantityRequest res = (QuantityRequest) redisUtil.get(redisKey);
                if(res != null ){
                    conf = coreQuantityService.getCacheQuantityConf(res.getCompanyId(),res.getDepotId());
                    if(conf == null )return "子流程结束，没有获取到分机。";
                    log.info("发送数量检测查询命令：" + res.toString());
                    remoteQuantityService.send(conf.getIp(),conf.getPort(),queryMsg.getBytes(ShuHanUtils.CHARSET));

                    //调用抓拍
                    if(num <= 3){
                        curTime = new Date();
                        if(DateUtil.difMin(lastTime, curTime) >= 4){
                            lastTime = curTime;
                            num ++;
                            this.snapImg(conf, res.getBatchId());
                        }
                    }
                }else{
                    flag = false;
                    log.info("检测流程结束，子线程关闭！");
                }
            }catch (Exception e){
                log.error("子线程查询进度出现异常。");
                log.error(e.getMessage(),e);
            }

        }
        return "子任务执行完成,数量结果应该已经正确解析。 ";
    }

    /**
     * 调用抓拍
     * @param conf
     * @return
     */
    private String snapImg(QuantityConf conf, String batchId) {
        if(null == conf){
            log.error("---配置参数为空，不抓拍---");
            return null;
        }
        if(StringUtils.isEmpty(conf.getDeptId()) || StringUtils.isEmpty(conf.getDepotId()) || StringUtils.isEmpty(conf.getMediaAddr())){
            log.error("---配置参数为空，不抓拍---,{}", conf);
            return null;
        }

        if(StringUtils.isEmpty(batchId)){
            log.error("---未获取到批次号，不抓拍---");
            return null;
        }

        String mediaAddr = CameraUtil.updateMediaAddr(conf.getMediaAddr(), conf.getLoginId(),
                conf.getPwd(), conf.getYtIp(), conf.getYtPort(), 1);

        ApiSnapReq req = new ApiSnapReq();
        req.setCompanyId(conf.getCompanyId());
        req.setDeptId(conf.getDeptId());
        req.setMediaAddr(mediaAddr);
        req.setBizId(batchId);
        req.setCameraName(BizType.QUANTITY.getCode());
        snapService.snapImg(req);
        return null;
    }
}