package com.ld.igds.protocol.fzzy.analysis;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.constant.BizType;
import com.ld.igds.gas.dto.GasProgressData;
import com.ld.igds.io.notify.NotifyWebInvoker;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.models.DepotConf;
import com.ld.igds.models.DeviceSer;
import com.ld.igds.models.Pest;
import com.ld.igds.models.PestInfo;
import com.ld.igds.order.ExeOrderService;
import com.ld.igds.pest.CorePestService;
import com.ld.igds.protocol.fzzy.ServerUtils;
import com.ld.igds.protocol.fzzy.command.BaseRemoteImpl;
import com.ld.igds.protocol.fzzy.dto.ReMessage;
import com.ld.igds.protocol.fzzy.dto.SendMessage;
import com.ld.igds.protocol.fzzy.req.Request2202;
import com.ld.igds.protocol.fzzy.req.Request2203;
import com.ld.igds.protocol.fzzy.req.RequestBody2203;
import com.ld.igds.protocol.fzzy.builder.SimpleCommandBuilder;
import com.ld.igds.util.ContextUtil;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 气体解析
 *
 * @author vince
 */
@Slf4j
@Component(AnalysisPest.BEAN_ID)
public class AnalysisPest extends BaseRemoteImpl {

    public static final String BEAN_ID = "fzzy.analysisPest";

    @Autowired
    private CorePestService pestService;
    @Autowired
    private CoreCommonService commonService;
    @Autowired
    private ExeOrderService exeOrderService;

    @Autowired
    private NotifyWebInvoker notifyInvoker;


    public void analysis2201(ReMessage reMessage, DeviceSer ser) {
        //DO NOTHING
    }

    public void analysis2202(ReMessage reMessage, DeviceSer ser) {
        //平台不反馈

        //终端请求-返回的进度信息
        Request2202 request2202 = JSONObject.parseObject(reMessage.getContent().replaceAll(" ", ""), Request2202.class);

        GasProgressData gasProgress = new GasProgressData();
        gasProgress.setCompanyId(ser.getCompanyId());
        gasProgress.setCheckPoint(request2202.getPoint());
        gasProgress.setSerId(ser.getId());
        gasProgress.setDepotId(request2202.getHouseId());
        gasProgress.setSumCheckNum(0);

        DepotConf depotConf = commonService.getCacheDepotConf(
                ser.getCompanyId(), request2202.getHouseId());


        gasProgress.setMsg("虫害检测进度：仓库=" + depotConf.getDepotName() + " 当前："
                + gasProgress.getCheckPoint());

        notifyInvoker.notifyGasProgress(gasProgress);
    }

    //检测结果
    public void analysis2203(ReMessage reMessage, DeviceSer ser) {

        //平台反馈
        SimpleCommandBuilder commandBuilder = SimpleCommandBuilder.getInstance();
        SendMessage message = commandBuilder.buildMessage(ser, ServerUtils.FUNCTION_2203);
        send(message);


        // 清除采集锁
      //  exeOrderService.removeCache(ser.getCompanyId(), ser.getId(), BizType.PEST.getCode());

        //解析结果
        Request2203 request2203 = JSONObject.parseObject(reMessage.getContent().replaceAll(" ", ""), Request2203.class);


        DepotConf depotConf = commonService.getCacheDepotConf(ser.getCompanyId(), request2203.getHouseId());


        //主体信息
        Pest pest = new Pest();
        pest.setBatchId(request2203.getTime().substring(0, 12));
        pest.setCheckNum(request2203.getPoints().size());
        pest.setCompanyId(ser.getCompanyId());
        pest.setDepotId(request2203.getHouseId());
        pest.setPestEnd(depotConf.getPestEnd());
        pest.setPestStart(depotConf.getPestStart());
        pest.setReceiveDate(new Date());
        pest.setPestMax(0);

        StringBuffer points = new StringBuffer();
        List<PestInfo> items = new ArrayList<>();
        PestInfo info;

        for (RequestBody2203 point : request2203.getPoints()) {
            if (point.getNum() > pest.getPestMax()) {
                pest.setPestMax(point.getNum());
            }

            info = new PestInfo();
            info.setId(ContextUtil.buildInfoId(pest.getCompanyId(), pest.getDepotId(), pest.getBatchId()));
            info.setPassCode(point.getPoint());
            info.setPestNum(point.getNum());
            info.setPestType(point.getType());
            items.add(info);

            points.append(info.getPassCode() + ",");
            points.append(info.getPestNum() + ";");
        }
        pest.setPoints(points.toString());


        pestService.saveInfoPest(items);
        pestService.saveOrUpdateData(pest);

        // 调用通知前端
        notifyInvoker.notifyWeb(pest.getCompanyId(), OrderRespEnum.MSG_SUCCESS,
                BizType.PEST, depotConf.getDepotName() + " 虫害检测：结果返回成功.");


        log.info("控制柜----->>>平台：虫害解析完成-仓库={}，批次={}", depotConf.getDepotName(), pest.getBatchId());
    }

    public void analysis2204(ReMessage reMessage, DeviceSer ser) {
        //DO NOTHING
    }
}