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