package com.fzzy.protocol.youxian1.analysis;

import com.alibaba.fastjson.JSONObject;
import com.fzzy.api.data.GatewayDeviceType;
import com.fzzy.api.utils.BytesUtil;
import com.fzzy.api.utils.NumberUtil;
import com.fzzy.gateway.GatewayUtils;
import com.fzzy.gateway.api.GatewayDeviceReportService;
import com.fzzy.gateway.api.GatewayRemoteManager;
import com.fzzy.gateway.data.BaseReqData;
import com.fzzy.gateway.data.WeatherWebDto;
import com.fzzy.gateway.entity.GatewayDevice;
import com.fzzy.gateway.hx2023.ScConstant;
import com.fzzy.gateway.hx2023.data.*;
import com.fzzy.protocol.ProtocolUtils;
import com.fzzy.protocol.bhzn.cmd.ReMessageBuilder;
import com.fzzy.protocol.data.THDto;
import com.fzzy.protocol.youxian0.ServiceUtils;
import com.fzzy.protocol.youxian0.data.GrainRoot;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import javax.persistence.criteria.CriteriaBuilder;
import java.net.InetAddress;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 游仙分库，返回报文解析
 */
@Slf4j
@Component(AnalysisService.BEAN_ID)
public class AnalysisService {

    public static final String BEAN_ID = "youxian1.analysisService";

    @Resource
    private GatewayRemoteManager gatewayRemoteManager;

    /**
     * 用于存放返回的仓温仓湿信息
     */
    public static Map<String, THDto> contextMapTH = new HashMap<>();


    /**
     * 协议解析
     * <p>
     * 80 80 80 80 80 90 41   --90代表分机编码
     * 39 39 39 35 39 39 39 39 39 39 39 39  --四组湿度
     * B4 30 30 31 30 30 B4 30 30 B4 30 30 --四组温度
     * ---以下为粮温，3个值转换为一个点
     * 31 30 35 31 37 32 32 31 34 32 30 33 31 30 38 31 36 34 32 32 35 32 31 38 31 30 34 31 36 36 32 32 33 32 31 34 31 30 32 31 35 39 32 31 37 32 30 34 31 30 37 31 33 37 32 32 34 32 31 37 31 31 30
     *
     * @param address
     * @param port
     * @param strMsg
     */
    public void analysis(InetAddress address, int port, String strMsg) {

        //分机ID
        int start = 5 * 2;
        int end = start + 1 * 2;
        String deviceSn = strMsg.substring(start, end);
        // deviceSn =  调整转换规则 ---TODO

        GatewayDevice device = GatewayUtils.getCacheByDeviceSn(deviceSn);


        //解析温湿度
        this.analysisGrainTh(device, strMsg);


        //解析粮情
        this.analysisGrainStep1(device, strMsg);

    }

    private void analysisGrainTh(GatewayDevice device, String strMsg) {
        //湿度信息，四组，获取有效的一组数据
        int start = 7 * 2;
        int end = start + 12 * 2;
        String hHex = strMsg.substring(start, end);

        THDto thDto = new THDto();
        double h = getGrainTemp(hHex.substring(0, 6));
        if (h < 99.9) {
            thDto.setHumidityIn(h);
        }
        h = getGrainTemp(hHex.substring(6, 12));
        if (h < 99.9) {
            thDto.setHumidityIn(h);
        }
        h = getGrainTemp(hHex.substring(12, 18));
        if (h < 99.9) {
            thDto.setHumidityIn(h);
        }
        h = getGrainTemp(hHex.substring(18, 24));
        if (h < 99.9) {
            thDto.setHumidityIn(h);
        }

        //湿度信息
        start = 19 * 2;
        end = start + 12 * 2;
        String tHex = strMsg.substring(start, end);
        double t = getGrainTemp(tHex.substring(0, 6));
        if (t > -40.0) {
            thDto.setTempIn(t);
        }
        t = getGrainTemp(tHex.substring(6, 12));
        if (t > -40.0) {
            thDto.setTempIn(t);
        }
        t = getGrainTemp(tHex.substring(12, 18));
        if (t > -40.0) {
            thDto.setTempIn(t);
        }
        t = getGrainTemp(tHex.substring(18, 24));
        if (t > -40.0) {
            thDto.setTempIn(t);
        }

        this.add2Map(device.getDeviceSn(), thDto);
    }


    /**
     * 协议解析
     * <p>
     * 80 80 80 80 80 90 41   --90代表分机编码
     * 39 39 39 35 39 39 39 39 39 39 39 39  --四组湿度
     * B4 30 30 31 30 30 B4 30 30 B4 30 30 --四组温度
     * ---以下为粮温，3个值转换为一个点
     * 31 30 35 31 37 32 32 31 34 32 30 33 31 30 38 31 36 34 32 32 35 32 31 38 31 30 34 31 36 36 32 32 33 32 31 34 31 30 32 31 35 39 32 31 37 32 30 34 31 30 37 31 33 37 32 32 34 32 31 37 31 31 30
     *
     * @param device
     * @Param strMsg
     */
    private void analysisGrainStep1(GatewayDevice device, String strMsg) {

        String[] attCable = device.getCableRule().split("-");
        int cableZ = Integer.valueOf(attCable[0]);
        int cableY = Integer.valueOf(attCable[1]);
        int cableX = Integer.valueOf(attCable[2]);
        log.info("z={},x={},y={}", cableZ, cableX, cableY);

        //获取请求信息
        BaseReqData reqData = ProtocolUtils.getSyncReq(device.getDepotIdSys());
        if (null == reqData) {
            log.error("---------没有获取到请求信息，不执行解析------{}", device.getDeviceName());
            return;
        }

        //只保留粮情信息
        int start = 31 * 2;
        strMsg = strMsg.substring(start);
        int num = cableZ * cableY * cableX;
        String tempStr = "";
        List<Double> points = new ArrayList<>();
        double point = 0;
        for (int i = 0; i < num; i++) {
            tempStr = strMsg.substring(i * 3 * 2, i * 3 * 2 + 3 * 2);
            point = this.getGrainTemp(tempStr);

            //处理无效的数据
            if (point > 50) {
                point = -100.0;
            }

            points.add(point);
        }


        analysisGrainStep2(reqData, cableZ, cableY, cableX, points);
    }


    /**
     * 数据转换
     *
     * @param reqData
     * @param cableZ
     * @param cableY
     * @param cableX
     * @param points
     */
    private void analysisGrainStep2(BaseReqData reqData, int cableZ, int cableY, int cableX, List<Double> points) {

        GatewayDevice device = reqData.getDevice();
        //数据封装
        GrainData grain = new GrainData();
        grain.setMessageId(ScConstant.getMessageId());
        grain.setDeviceId(device.getDeviceId());
        grain.setTimestamp(System.currentTimeMillis() + "");

        ClientHeaders headers = new ClientHeaders();
        headers.setDeviceName(device.getDeviceName());
        headers.setProductId(device.getProductId());
        headers.setOrgId(device.getOrgId());
        headers.setMsgId(reqData.getMessageId());
        grain.setHeaders(headers);


        GrainOutPut outPut = new GrainOutPut();


        double max = ReMessageBuilder.MAX_TEMP, min = ReMessageBuilder.MIN_TEMP, sumT = 0.0, sumNum = cableX * cableY * cableZ;

        List<GrainTemp> temperature = new ArrayList<>();
        //根号
        int cableNum = 1, position = 0;

        double curTemp;
        int x = 0, y = 0, z = 0;
        for (int i = 0; i < points.size(); i++) {
            curTemp = points.get(i);
            position = i;
            z = i % cableZ + 1;
            x = i / (cableZ * cableY);
            y = x * (cableZ * cableY);
            y = (i - y) / cableZ;
            //根号
            cableNum = (i / cableZ) + 1;

            temperature.add(new GrainTemp(cableNum + "", z + "", curTemp + "", position + ""));

            if (curTemp > max  && curTemp < 40) {
                max = curTemp;
            }
            if (curTemp < min && curTemp > 3) {
                min = curTemp;
            }
            if(curTemp > 3 &&  curTemp < 40){
                sumT += curTemp;
                sumNum++;
            }
        }

        if (sumNum == 0) {
            sumNum = 1;
            log.warn("---当前粮情采集异常--");
        }
        //过滤比较用的最大最小值
        if (max == ReMessageBuilder.MAX_TEMP) {
            max = 0.0;
        }
        if (min == ReMessageBuilder.MIN_TEMP) {
            min = 0.0;
        }

        outPut.setTemperature(temperature);
        outPut.setAvgTemperature(NumberUtil.keepPrecision((sumT / sumNum), 1) + "");
        outPut.setMinTemperature(min + "");
        outPut.setMaxTemperature(max + "");
        List<GrainTH> ths = new ArrayList<>();


        //获取温湿度
        THDto thDto = this.getTH(device.getDeviceSn());

        ths.add(new GrainTH(thDto.getTempIn() != null ? thDto.getTempIn() + "" : "", thDto.getHumidityIn() != null ? thDto.getHumidityIn() + "" : "", "1"));
        outPut.setTemperatureAndhumidity(ths);
        grain.setOutput(JSONObject.toJSONString(outPut));

        GatewayDevice gatewayDeviceWeather = GatewayUtils.getCacheByDeviceTypeOne(GatewayDeviceType.TYPE_09.getCode());

        //系统气象站信息
        WeatherWebDto weather = WeatherWebDto.contextMap.get("default");

        //气象信息
        GrainWeather weatherStation = new GrainWeather();
        weatherStation.setMessageId(ScConstant.getMessageId());
        weatherStation.setMessgeId(weatherStation.getMessageId());

        if (null != gatewayDeviceWeather) {
            weatherStation.setId(gatewayDeviceWeather.getDeviceId());
        } else {
            weatherStation.setId(device.getDeviceId());
        }
        weatherStation.setAirPressure(weather.getPressure());
        weatherStation.setHumidity(weather.getHumidity().replaceAll("%",""));
        weatherStation.setPm(weather.getAir_pm25());
        weatherStation.setRadiation("0");
        weatherStation.setRainfallAmount(weather.getWea());
        weatherStation.setTemperature(weather.getTem());
        weatherStation.setWindDirection(weather.getWin());
        weatherStation.setWindPower(weather.getWin_meter());
        weatherStation.setWindSpeed(weather.getWin_speed());

        grain.setWeatherStation(JSONObject.toJSONString(weatherStation));

        //封装好的数据
        log.info("---粮情信息封装完成-开始执行推送");

        reqData.setData(JSONObject.toJSONString(grain));

        doPushGrain(reqData,grain);
    }


    private void doPushGrain(BaseReqData reqData,GrainData grainData) {

        GatewayDeviceReportService reportService = gatewayRemoteManager.getDeviceReportService(reqData.getDevice().getPushProtocol());
        if (null == reportService) {
            log.error("------------粮情推送失败，系统不存在当前协议执行类----{}", reqData.getDevice().getDeviceName());
            return;
        }
        reportService.reportGrainData(reqData);
        reqData.setData(reportService.grainData2GatewayApiInfoKafka(grainData,reqData.getDevice()).getData());
        reportService.reportGrainDataByKafka(reqData);
    }


    /**
     * 计算粮情温度 3组温度
     *
     * @param tempHex
     * @return
     */
    public static double getGrainTemp(String tempHex) {
        String strAscii = "";
        strAscii += toAscii(tempHex.substring(0, 2));
        strAscii += toAscii(tempHex.substring(2, 4));
        strAscii += toAscii(tempHex.substring(4, 6));

        Integer value = Integer.valueOf(strAscii);

        return value / 10.0;
    }

    private void add2Map(String deviceSn, THDto thDto) {
        contextMapTH.put("TH_" + deviceSn, thDto);
    }

    private THDto getTH(String deviceSn) {
        return contextMapTH.get("TH_" + deviceSn);
    }


    public static void main(String[] args) {
        String strMsg = "31 30 35 31 37 32 32 31 34 32 30 33 31 30 38 31 36 34 32 32 35 32 31 38 31 30 34 31 36 36 32 32 33 32 31 34 31 30 32 31 35 39 32 31 37 32 30 34 31 30 37 31 33 37 32 32 34 32 31 37 31 31 30";
        strMsg = strMsg.replaceAll(" ", "");
        System.out.println("---" + strMsg);
        int num = 20;
        String tempStr = "";
        double tem;
        for (int i = 0; i < num; i++) {
            tempStr = strMsg.substring(i * 3 * 2, i * 3 * 2 + 3 * 2);
            System.out.println("---" + tempStr);
            tem = getGrainTemp(tempStr);
            System.out.println("-tem--" + tem);
        }
    }

    public static char toAscii(String hexString) {
        int decimal = Integer.parseInt(hexString, 16);
        return (char) decimal;
    }

}