package com.sandu.ximon.admin.manager.iot.frame.inner.report;

import cn.hutool.core.util.StrUtil;
import com.sandu.ximon.admin.manager.iot.frame.inner.BaseResponseInnerFrame;
import com.sandu.ximon.admin.manager.iot.frame.inner.IResponseInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.util.CRC32Utils;
import lombok.Data;
import lombok.ToString;

/**
 * @author chenjiantian
 * @date 2021/12/6 18:20
 * A5-84-01
 * 大气心跳包 应答
 */
@Data
@ToString(callSuper = true)
public class A5AtmosphereHeartbeatReportInnerFrame extends BaseResponseInnerFrame<A5AtmosphereHeartbeatReportInnerFrame> {

    //  目标地址    2
    private String destinationAddress;
    //  心跳包数据   58
    private HeartBeatDataPackage heartBeatDataPackage;

    private String originFrame;

    @Override
    public A5AtmosphereHeartbeatReportInnerFrame transformFrame(String hex) {
        //  长度不一致时，返回null
        if (StrUtil.isBlank(hex)) {
            return null;
        }
        // MQTT通信方式(1)
        setConnectType(hex.substring(0, 2));
        //  功能码(1)
        setFunctionCode(hex.substring(2, 4));
        //  负荷长度(2)
        setPayloadLength(hex.substring(4, 8));

        setDestinationAddress(hex.substring(8, 12));

        String heartBeatData = hex.substring(12, 76);
        HeartBeatDataPackage heartBeatDataPackage = new HeartBeatDataPackage();
        heartBeatDataPackage.transformFrame(heartBeatData);
        setHeartBeatDataPackage(heartBeatDataPackage);

        setCrc32(hex.substring(hex.length() - 8));
        //  校验CRC32
        String frame = hex.substring(2, hex.length() - 8);
        this.setValidate(CRC32Utils.validateFrame(frame, getCrc32()));
        return this;
    }

    @Data
    public static class HeartBeatDataPackage implements IResponseInnerFrame<HeartBeatDataPackage> {
        //  设备型号    2
        private String deviceType;
        //  模块预热状态标志    1
        private String moduleWarmUpStatusFlag;
        //  温度值
        private Double temperature;
        //  湿度值
        private Double humidity;
        //  风速
        private Double windSpeed;
        //  风向
        private Double windDirection;
        //  大气压
        private Integer pressure;
        //  光强
        private Integer lightIntensity;
        //  噪音
        private Double noise;
        //  PM2.5
        private Integer pm25;
        //  PM10
        private Integer pm10;
        //  雨量
        private Double rainfall;
        //  SO2二氧化硫相对值
        private Integer so2;
        //  甲醛相对值
        private Integer ech2o;
        //  NO2二氧化氮
        private Integer no2;
        //  TVOC
        private Integer tvoc;
        //  CO一氧化碳
        private Integer co;
        //  二氧化碳
        private Integer co2;
        //  O3臭氧
        private Integer o3;
        //  F氟化物
        private Integer fluoride;

        @Override
        public HeartBeatDataPackage transformFrame(String hex) {
            if (hex.length() != 64) {
                return null;
            }
            Integer type = 0;
            this.deviceType = hex.substring(0, 4);
            if (this.deviceType.equals(DeviceType.SENSOR_V1.getType())) {
                type = 1;
            }
            this.moduleWarmUpStatusFlag = hex.substring(4, 6);
            this.temperature = Double.parseDouble(
                    parseVal(hex, 6, 8)
                            + "."
                            + parseVal(hex, 8, 10)
            );
            this.humidity = Double.parseDouble(
                    parseVal(hex, 10, 12)
                            + "."
                            + parseVal(hex, 12, 14)
            );
            this.windSpeed = parseVal(hex, 14, 18) * .1;
            this.windDirection = parseVal(hex, 18, 22) * .1;
            this.pressure = parseVal(hex, 22, 26);
            this.lightIntensity = parseVal(hex, 26, 32);
            this.noise = parseVal(hex, 32, 36) * .1;
            this.pm25 = parseVal(hex, 36, 40);
            this.pm10 = parseVal(hex, 40, 44);
            this.rainfall = parseVal(hex, 44, 48) * .1;

            /**
             * 以下区分版本
             */
            if (type.equals(1)) {
                this.ech2o = parseVal(hex, 48, 52);
                this.tvoc = parseVal(hex, 52, 56);
                this.co2 = parseVal(hex, 56, 60);
            } else {
                this.so2 = parseVal(hex, 48, 52);
                this.ech2o = parseVal(hex, 48, 52);
                this.tvoc = parseVal(hex, 52, 56);
                this.no2 = parseVal(hex, 52, 56);
                this.co = parseVal(hex, 56, 60);
                this.co2 = parseVal(hex, 56, 60);
            }

            this.o3 = parseVal(hex, 60, 62);
            this.fluoride = parseVal(hex, 62, 64);

            return this;
        }

        private Integer parseVal(String frame, int start, int end) {
            return Integer.parseInt(frame.substring(start, end), 16);
        }
    }

    public enum DeviceType {

        SENSOR_V1("0101");

        private String type;

        DeviceType(String type) {
            this.type = type;
        }

        public String getType() {
            return type;
        }
    }
}