粮情协议优化

vince

2024-04-26 b1c572949997a5d82d9b609163ff280a1c49627d

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

@@ -1,13 +1,15 @@
package com.fzzy.gateway.api;

import com.fzzy.async.fzzy40.entity.Fz40Grain;
import com.fzzy.gateway.data.BaseReqData;
import com.fzzy.gateway.data.BaseResp;
import com.fzzy.gateway.entity.GatewayDevice;
import com.fzzy.gateway.hx2023.data.GrainData;
import com.fzzy.gateway.hx2023.data.KafaGrainData;


/**
 * 上报接口
 * 设备数据上报
 */
public interface GatewayDeviceReportService {

@@ -18,25 +20,40 @@
     */
    String getProtocol();


    /**
     * 通过设备序列号返回结果信息
     *
     * @param weigh
     * @param device 设备序列号
     */
    String report2GatewayBySn(double weigh, GatewayDevice device);


    /**
     * 推送粮情信息
     *
     * @param reqData
     */
    BaseResp reportGrainData(BaseReqData reqData);


    BaseResp reportGrainDataByKafka(BaseReqData reqData);

    BaseResp reportWeightData(BaseReqData reqData);

    BaseResp reportLprData(BaseReqData reqData);

    BaseResp reportGrainDataByKafka(BaseReqData reqData);
    BaseResp reportGrainDataByHand(BaseReqData reqData);



    /**
     * 粮情业务数据转换为，当前网关需要的报文
     *
     * @param grainData     第三个软件粮情数据报文
     * @param gatewayDevice 网关中设备配置信息
     * @return
     */
    BaseResp grainData2GatewayApiInfo(Fz40Grain grainData, GatewayDevice gatewayDevice);


    /**
     * 粮情业务数据转换为，当前网关需要的报文
     * @param grainData     第三个软件粮情数据报文
     * @param gatewayDevice 网关中设备配置信息
     * @return
     */

    BaseResp grainData2GatewayApiInfoKafka(GrainData grainData, GatewayDevice device);
}