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 {

    /**
     * 协议定义
     *
     * @return
     */
    String getProtocol();

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


    BaseResp reportGrainDataByKafka(BaseReqData reqData);

    BaseResp reportWeightData(BaseReqData reqData);

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