粮情协议优化

vince

2024-04-26 b1c572949997a5d82d9b609163ff280a1c49627d

 src/main/java/com/fzzy/protocol/fzzy/analysis/AnalysisGrain.java

@@ -13,6 +13,7 @@
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.fzzy.builder.SimpleCommandBuilder;
import com.fzzy.protocol.fzzy.cmd.BaseRemoteImpl;
import com.fzzy.protocol.fzzy.data.ReMessage;
@@ -68,7 +69,7 @@


            //粮情解析
            log.info("控制柜--->平台，推动的粮情信息--{}", response);
            log.info("控制柜--->平台，控制柜返回粮情检测结果--{}", response);

            //粮情封装和处理
            if (StringUtils.isEmpty(response.getLayerPerCircle())) {
@@ -91,10 +92,9 @@

    //信息调整封装
    private void buildBizInfo1(Response2102 response) {
        String depotId = response.getHouseId();

        //获取请求信息
        BaseReqData reqData = ServerUtils.getSyncReq(depotId);
        BaseReqData reqData = ProtocolUtils.getSyncReq(response.getHouseId());

        if (null == reqData) {
            log.error("--粮情封装解析，未获取到请求相关参数----");
@@ -132,7 +132,7 @@
        //根号
        int cableNum = 1, position = 0;

        double curTemp = response.getTMin();
        double curTemp;
        String[] attr = response.getPoints().split(",");
        int x = 0, y = 0, z = 0;
        for (int i = 0; i < attr.length; i++) {
@@ -159,7 +159,11 @@
        }

        outPut.setTemperature(temperature);
        List<GrainTH> ths = new ArrayList<>();

        ths.add(new GrainTH(response.getTIn()!=null?response.getTIn()+"":"",response.getHIn()!=null?response.getHIn()+"":"","1"));
        outPut.setTemperatureAndhumidity(ths);
        //grain.setOutput(JSONObject.toJSONString(outPut));
        grain.setOutput(com.alibaba.fastjson2.JSONObject.toJSONString(outPut));


@@ -195,16 +199,19 @@
        log.info("---粮情机械封装完成----开始执行推送");

        reqData.setData(JSONObject.toJSONString(grain));
        doPushGrain(reqData);
        doPushGrain(reqData,grain);
    }

    private void doPushGrain(BaseReqData reqData) {
    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);
    }

    private void returnMsg(ApiCommonDevice ser) {