游仙协议解析-2

jiazx0107@163.com

2023-12-24 c8ff96af8647474b1d03f5f374bb18eb59f65987

游仙协议解析-2

 src/main/java/com/fzzy/gateway/api/GatewaySyncGranService.java

@@ -28,6 +28,15 @@


    /**
     * 同步粮情信息返回JSON报文
     *
     * @param reqData
     * @return
     */
    public BaseResp syncGrainTh(BaseReqData reqData);


    /**
     *  获取执行分机的参数信息，如果设备不支持则直接返回不执行即可
     * @param reqData
     * @return

 src/main/java/com/fzzy/protocol/bhzn/analysis/AnalysisService.java

@@ -190,7 +190,6 @@
    }

    private void analysisGrain2(IoMessage message, BaseReqData reqData, String grainStr) {

        GatewayDevice device = reqData.getDevice();
        // 获取完整的粮情包信息
        String[] attCable = device.getCableRule().split("-");

 src/main/java/com/fzzy/protocol/bhzn/service/Bhzn2GatewayGrainService.java

@@ -84,6 +84,11 @@
    }

    @Override
    public BaseResp syncGrainTh(BaseReqData reqData) {
        return new BaseResp();
    }

    @Override
    public BaseResp syncConf(BaseReqData reqData) {
        return new BaseResp();
    }

 src/main/java/com/fzzy/protocol/fzzy/service/FzzyGatewayGrainService.java

@@ -87,6 +87,11 @@
    }

    @Override
    public BaseResp syncGrainTh(BaseReqData reqData) {
        return new BaseResp();
    }

    @Override
    public BaseResp syncConf(BaseReqData reqData) {
        return new BaseResp();
    }

 src/main/java/com/fzzy/protocol/youxian0/ServiceUtils.java

@@ -1,6 +1,8 @@
package com.fzzy.protocol.youxian0;


import com.fzzy.api.utils.BytesUtil;

/**
 * 工具类
 */
@@ -23,4 +25,19 @@
    public static String FUNCTION_68 = "68";


    public static void main(String[] args) {
        String hex1 ="9D";
        String hex2 ="BB";

        int num1 = BytesUtil.hexToInt(hex1);
        int num2 = BytesUtil.hexToInt(hex2);

        int result = num1^num2;

        System.out.println(result);


    }


}

 src/main/java/com/fzzy/protocol/youxian0/analysis/AnalysisService.java

@@ -1,22 +1,52 @@
package com.fzzy.protocol.youxian0.analysis;

import com.alibaba.fastjson.JSONObject;
import com.fzzy.api.Constant;
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 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 = "youxian0.analysisService";

    @Resource
    private GatewayRemoteManager gatewayRemoteManager;


    private static Map<String, GrainRoot> contextGrainRoot = new HashMap<>();

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


    /**
@@ -50,10 +80,28 @@

        //粮情返回
        if (ServiceUtils.FUNCTION_66.equalsIgnoreCase(funId)) {
            this.analysisGrain(device, msgId, strMsg);
            this.analysisGrainStep1(device, msgId, strMsg);
        }

        //温湿度返回
        if (ServiceUtils.FUNCTION_68.equalsIgnoreCase(funId)) {
            this.analysisGrainTh(device, strMsg);
        }

    }

    private void analysisGrainTh(GatewayDevice device, String strMsg) {
        THDto th = new THDto();

        //TODO----->>> 待解析调整，先用外部气象信息
        //系统气象站信息
        WeatherWebDto weather = WeatherWebDto.contextMap.get("default");
        th.setTempIn(Double.valueOf(weather.getTem()) - 1);
        th.setHumidityIn(Double.valueOf(weather.getHumidity()) - 1);

        this.add2ThMap(device.getDepotIdSys(), th);
    }


    /**
     * 粮情解析
@@ -64,7 +112,14 @@
     * @param device
     * @param msgId  命令ID
     */
    private void analysisGrain(GatewayDevice device, int msgId, String strMsg) {
    private void analysisGrainStep1(GatewayDevice device, int msgId, String strMsg) {

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

        //只保留粮情信息
        int start = 22 * 2;
@@ -80,17 +135,221 @@
        key = kyeNumBin.substring(4);
        int numValue = BytesUtil.hexToInt(BytesUtil.bin2Hex(key));


        //02 A4 BB BA BA B4
        start = 2 * 2;
        String tempHex;
        GrainRoot grainRoot = new GrainRoot();
        grainRoot.setKey(buildGrainRootKey(device.getDeviceSn(), msgId));
        grainRoot.setNum(msgId);
        double point = 0;
        for (int i = 0; i < numValue; i++) {
            start = start + i * 2;
            tempHex = strMsg.substring(start, start + 2);
            //实际温度＝密钥*密钥*37(溢出为无符号字节)再异或加密后的温度/2。

            point = this.getGrainTemp(keyValue, tempHex);
            log.debug("--------解析后的温度点----{}---{}", tempHex, point);
            grainRoot.getPoints().add(point);
        }


        this.add2GrainMap(grainRoot);

        //判断是不是最后一包数据，如果是最后一包执行解析
        String[] attCable = device.getCableRule().split("-");
        int cableZ = Integer.valueOf(attCable[0]);
        int cableY = Integer.valueOf(attCable[1]);
        int cableX = Integer.valueOf(attCable[2]);
        if (grainRoot.getNum() == cableX) {
            analysisGrainStep2(reqData, cableZ, cableY, cableX);
        }
    }

    /**
     * 封装粮情点位
     *
     * @param reqData
     * @param cableZ
     * @param cableY
     * @param cableX
     */
    private void analysisGrainStep2(BaseReqData reqData, int cableZ, int cableY, int cableX) {

        List<Double> points = new ArrayList<>();
        GrainRoot root;
        for (int i = 1; i <= cableX; i++) {
            root = this.getGrainRoot(buildGrainRootKey(reqData.getDevice().getDeviceSn(), i));

            if (null == root || null == root.getPoints()) {
                log.error("-----------解析获取所有粮情检测点失败，取消执行---------{}", reqData.getDevice().getDeviceName());
                return;
            }
            points.addAll(root.getPoints());
        }

        //执行封装解析
        analysisGrainStep3(reqData, cableZ, cableY, cableX, points);
    }

    private void analysisGrainStep3(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 + ""));

            sumT += curTemp;
            if (curTemp > max) {
                max = curTemp;
            }
            if (curTemp < min) {
                min = curTemp;
            }
        }

        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(min + "");
        List<GrainTH> ths = new ArrayList<>();


        //获取温湿度
        THDto thDto = this.getGrainTh(device.getDepotIdSys());

        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());
        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);
    }

    private void doPushGrain(BaseReqData reqData) {

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

    private void add2GrainMap(GrainRoot grainRoot) {
        contextGrainRoot.put(grainRoot.getKey(), grainRoot);
    }

    private GrainRoot getGrainRoot(String key) {
        return contextGrainRoot.get(key);
    }

    private String buildGrainRootKey(String deviceSn, int num) {
        return deviceSn + "_" + num;
    }

    /**
     * 计算粮情温度
     * 实际温度＝密钥*密钥*37(溢出为无符号字节)再异或加密后的温度/2。
     * 举例说明：第三个字节BB实际温度是5*5*37=039D取9D^(0xBB)＝38/2=19；
     *
     * @param keyValue
     * @param tempHex
     * @return
     */
    private double getGrainTemp(int keyValue, String tempHex) {
        int value = keyValue * keyValue * 37;
        String valueHex = BytesUtil.intToHexStr(value);

        valueHex = valueHex.substring(2);

        int num1 = BytesUtil.hexToInt(valueHex);
        int num2 = BytesUtil.hexToInt(tempHex);

        return (num1 ^ num2) / 2.0;
    }

    private void add2ThMap(String depotIdSys, THDto th) {
        String key = "TH_" + depotIdSys;
        contextMapTH.put(key, th);
    }

    private THDto getGrainTh(String depotIdSys) {
        String key = "TH_" + depotIdSys;
        return contextMapTH.get(key);
    }
}

 src/main/java/com/fzzy/protocol/youxian0/data/GrainRoot.java

@@ -3,6 +3,9 @@
import lombok.Getter;
import lombok.Setter;

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

@Getter
@Setter
public class GrainRoot {
@@ -12,7 +15,7 @@
    private int num;

    //逗号隔开的温度值
    private String points;
    private List<Double> points = new ArrayList<>();

    private String key;


 src/main/java/com/fzzy/protocol/youxian0/service/Youxian0GatewayGrainService.java

@@ -98,6 +98,11 @@
        return resp;
    }

    @Override
    public BaseResp syncGrainTh(BaseReqData reqData) {
        return new BaseResp();
    }

    /**
     * 生成粮情采集命令
     *

 src/main/java/com/fzzy/protocol/zldz/service/ZldzGatewayGrainService.java

@@ -91,6 +91,13 @@
    }

    @Override
    public BaseResp syncGrainTh(BaseReqData reqData) {
        BaseResp resp = new BaseResp();

        return resp;
    }

    @Override
    public BaseResp syncConf(BaseReqData reqData) {
        BaseResp resp = new BaseResp();