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