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

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.common.CoreDeviceService;
import com.ld.igds.common.CoreSerService;
import com.ld.igds.constant.BizType;
import com.ld.igds.constant.Constant;
import com.ld.igds.io.notify.NotifyWebInvoker;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.models.Depot;
import com.ld.igds.models.DepotConf;
import com.ld.igds.models.Device;
import com.ld.igds.models.DeviceSer;
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.Request1004;
import com.ld.igds.protocol.fzzy.req.Request1006;
import com.ld.igds.protocol.fzzy.req.Request1007;
import com.ld.igds.protocol.fzzy.resp.Response1001;
import com.ld.igds.protocol.fzzy.resp.Response1003;
import com.ld.igds.protocol.fzzy.resp.Response1010;
import com.ld.igds.protocol.fzzy.builder.ObjectCommandBuilder;
import com.ld.igds.protocol.fzzy.builder.SimpleCommandBuilder;
import com.ld.igds.util.ContextUtil;

import lombok.extern.slf4j.Slf4j;

import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * 系统类协议解析
 */
@Slf4j
@Component(AnalysisSystem.BEAN_ID)
public class AnalysisSystem extends BaseRemoteImpl {

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

    @Autowired
    private CoreSerService coreSerService;
    @Autowired
    private CoreCommonService coreCommonService;
    @Autowired
    private CoreDeviceService deviceService;
    @Autowired
    private NotifyWebInvoker notifyWebInvoker;


    public void analysis1001(ReMessage reMessage) {
        //返回当前系统时间
        Response1001 response = new Response1001();
        response.setTime(DateFormatUtils.format(new Date(), "yyyyMMddHHmmss"));
        ObjectCommandBuilder commandBuilder = ObjectCommandBuilder.getInstance();
        SendMessage message = commandBuilder.buildMessage(reMessage, ServerUtils.FUNCTION_1001, response);
        send(message);

        if (null == reMessage.getContent()) return;

        DeviceSer ser = coreSerService.getCacheSer(reMessage.getCompanyId(), reMessage.getIedId());
        if (null == ser) {
            log.warn("控制柜----->>>平台：组织编码={}，分机ID={}，系统没有获取到分机信息，报文无法进行解析", reMessage.getCompanyId(), reMessage.getIedId());
            return;
        }

        //更新分机上线信息
        ser.setIp(reMessage.getIp());
        ser.setPort(reMessage.getPort());
        ser.setStatus(Constant.YN_Y);
        coreSerService.updateByData(ser);

        // Request1001 resp = JSONObject.parseObject(reMessage.getContent(), Request1001.class);

        log.info("控制柜----->>>平台：控制柜上线更新完成-IP={}", reMessage.getIp());
    }

    public void analysis1003(ReMessage reMessage, DeviceSer ser) {
        List<Response1003> list = JSONObject.parseArray(reMessage.getContent(), Response1003.class);

        Device device;
        int index = 0;
        for (Response1003 response1003 : list) {
            device = new Device();
            device.setCompanyId(ser.getCompanyId());
            device.setDepotId(response1003.getHouseId());
            device.setSerId(ser.getId());
            device.setPassCode(Integer.valueOf(response1003.getDeviceId()));
            if (StringUtils.isNotEmpty(response1003.getFanId())) {
                device.setLink(response1003.getFanId());
            }
            device.setName(response1003.getName());
            device.setLocation(ServerUtils.analysisLocation(response1003.getPos(),response1003.getName()));

            device.setType(ServerUtils.analysisDeviceType(response1003.getType(), response1003.isFan()));

            index++;

            if (index == list.size()) {
                deviceService.updateDeviceNoId(device, true);
            } else {
                deviceService.updateDeviceNoId(device, false);
            }
        }
        notifyWebInvoker.notifyWeb(ser.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.SYS, ser.getName() + " 远程获取设备信息并解析完成！");

        log.info("控制柜----->>>平台：控制柜设备列表同步到平台完成-控制柜={}", ser.getName());
    }

    public void analysis1004(ReMessage reMessage, DeviceSer ser) {
        Request1004 request = JSONObject.parseObject(reMessage.getContent(), Request1004.class);

        log.info("控制柜----->>>平台：控制柜推送警告信息-控制柜={}", request.toString());

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

    public void analysis1005(ReMessage reMessage, DeviceSer ser) {
        //请求不处理

        //直接返回
        SimpleCommandBuilder commandBuilder = SimpleCommandBuilder.getInstance();
        SendMessage message = commandBuilder.buildMessage(ser, ServerUtils.FUNCTION_1005);
        send(message);
    }

    public void analysis1006(ReMessage reMessage, DeviceSer ser) {

        //返回
        Request1006 request = JSONObject.parseObject(reMessage.getContent(), Request1006.class);

        //TODO
    }

    public void analysis1007(ReMessage reMessage, DeviceSer ser) {
        //直接返回
        SimpleCommandBuilder commandBuilder = SimpleCommandBuilder.getInstance();
        SendMessage message = commandBuilder.buildMessage(ser, ServerUtils.FUNCTION_1007);
        send(message);


        //開始解析
        List<Request1007> requestList = JSONObject.parseArray(reMessage.getContent(), Request1007.class);
        //获取到仓库状态变更信息
        String status;
        for (Request1007 request : requestList) {
            status = ServerUtils.analysisDepotStatus(request.getStatus());
            if (null != status) coreCommonService.updateDepotStatus(ser.getCompanyId(), request.getHouseId(), status);
        }

        log.info("控制柜----->>>平台：控制柜仓库状态信息同步完成-控制柜={}", ser.getName());

    }

    public void analysis1008(ReMessage message, DeviceSer ser) {

        notifyWebInvoker.notifyWeb(ser.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.SYS, "仓库状态远程同步成功！");
    }

    public void analysis1009(ReMessage message, DeviceSer ser) {

        notifyWebInvoker.notifyWeb(ser.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.SYS, ser.getName() + " 远程授权成功！");
    }

    public void analysis1010(ReMessage reMessage, DeviceSer ser) {
        List<Response1010> list = JSONObject.parseArray(reMessage.getContent(), Response1010.class);

        Depot depot;
        DepotConf depotConf;
        for (Response1010 resp : list) {
            depot = new Depot();
            depot.setId(resp.getHouseId());
            depot.setName(resp.getName());
            depot.setDepotType(ServerUtils.analysisDepotType(resp.getHouseType()));
            depot.setCompanyId(ser.getCompanyId());
            //默认添加所属分库
            depot.setDeptId(ContextUtil.subDeptId(null));

            coreCommonService.updateDepot(depot);

            depotConf = new DepotConf();
            depotConf.setCompanyId(ser.getCompanyId());
            depotConf.setDepotId(resp.getHouseId());
            depotConf.setThConf(resp.getTempHumChn());
            depotConf.setCableRule(resp.getLay() + "-" + resp.getRow() + "-" + resp.getCol());

            depotConf.setCableStart(resp.getStartCol());
            depotConf.setCableEnd(resp.getEndCol());

            depotConf.setGasStart(resp.getStartNo());
            depotConf.setGasEnd(resp.getEndNo());

            depotConf.setPestStart(resp.getStartNo());
            depotConf.setPestEnd(resp.getEndNo());
            depotConf.setGrainSer(ser.getId());

            if (StringUtils.isNotEmpty(resp.getLayout())) {
                depotConf.setCableRule(resp.getLayout());
            }
            depotConf.setCableCir(resp.getLayerPerCircle());

            coreCommonService.updateDepotConf(depotConf);

        }
        notifyWebInvoker.notifyWeb(ser.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.SYS, ser.getName() + " 远程获取仓库信息并解析完成！");

        log.info("控制柜----->>>平台：控制柜仓库配置信息同步完成-控制柜={}", ser.getName());
    }
}