Merge remote-tracking branch 'origin/master'

MercuryZ

2022-03-31 ef270bd1855b5ce3f398c5df024840a498e33a8f

 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/frame/inner/report/A5LightPoleHeelingHeartbeatReportInnerFrame.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,135 @@
package com.sandu.ximon.admin.manager.iot.frame.inner.report;

import cn.hutool.core.util.HexUtil;
import cn.hutool.core.util.NumberUtil;
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;

/**
 * ç¯æ†å€¾æ–œå¿ƒè·³åŒ…上报
 */
@Data
@ToString(callSuper = true)
public class A5LightPoleHeelingHeartbeatReportInnerFrame extends BaseResponseInnerFrame<A5LightPoleHeelingHeartbeatReportInnerFrame> {

    //  ç›®æ ‡åœ°å€    4
    private String destinationAddress;
    //  å¿ƒè·³åŒ…数据
    private HeartBeatDataPackage heartBeatDataPackage;


    @Override
    public A5LightPoleHeelingHeartbeatReportInnerFrame 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, hex.length() - 8);
        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> {
        //设备型号
        private String equipmentModel;
        //Xè½´
        private double theXAxis;
        //Yè½´
        private double theYAxis;
        //Zè½´
        private double theZAxis;
        //预留
        private String reservedA;
        private String reservedB;
        private String reservedC;
        private String reservedD;

        @Override
        public HeartBeatDataPackage transformFrame(String hex) {
            if (StrUtil.isBlank(hex)) {
                return null;
            }
            this.equipmentModel = "V" + (parseVal(hex, 0, 2)) + "." + String.format("%02d", parseVal(hex, 2, 4));
            this.theXAxis = NumberUtil.round(temperatureTransition(hex.substring(4, 8)) * 0.1, 1).doubleValue();
            this.theYAxis = NumberUtil.round(temperatureTransition(hex.substring(8, 12)) * 0.1, 1).doubleValue();
            this.theZAxis = NumberUtil.round(temperatureTransition(hex.substring(12, 16)) * 0.1, 1).doubleValue();
            this.reservedA = hex.substring(16, 20);
            this.reservedB = hex.substring(20, 24);
            this.reservedC = hex.substring(24, 28);
            this.reservedD = hex.substring(28, 32);
            //72-80保留，暂未使用

            return this;
        }

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

        private String parseVal(String hex) {
            return Integer.parseInt(hex, 16) + "";
        }

        /**
         * å°†16进制转成2进制，进行补码（反码基础上+1），得到正确数值
         * ä¼ å…¥16进制的温度，类型为String
         * å¦‚F500
         */
        public Double temperatureTransition(String temperature) {

            //将传进来的16进制的转为2进制
            String twoBinStr = hexStr2BinStr(temperature);

            if ("1".equals(twoBinStr.substring(0, 1))) {
                //最高位是1，为负数,将16进制的进行补码，返回
                int max = 0b1111111111111111;
                double result = (max - HexUtil.hexToInt(temperature)) * (-0.01);
                return result;

            } else if ("0".equals(twoBinStr.substring(0, 1))) {
                //最高位是0，正数，直接返回
                double result = (HexUtil.hexToInt(temperature)) * (0.01);
                return result;

            }
            //
            return 0.00;
        }

        /**
         * 16进制字符串转为二进制
         */
        public String hexStr2BinStr(String hexStr) {
            if (hexStr == null || hexStr.length() % 2 != 0) {
                return null;
            }
            String bString = "", tmp;
            for (int i = 0; i < hexStr.length(); i++) {
                tmp = "0000" + Integer.toBinaryString(Integer.parseInt(hexStr.substring(i, i + 1), 16));
                bString += tmp.substring(tmp.length() - 4);
            }
            return bString;
        }
    }
}