| | |
| | | import com.fzzy.gateway.api.DeviceReportService; |
| | | import com.fzzy.gateway.entity.GatewayDevice; |
| | | import com.fzzy.gateway.hx2023.ScConstant; |
| | | import com.fzzy.gateway.hx2023.data.GrainData; |
| | | import com.fzzy.gateway.hx2023.data.WebSocketPacket; |
| | | import com.fzzy.gateway.hx2023.data.WebSocketPacketHeader; |
| | | import com.fzzy.gateway.hx2023.data.WeightInfo; |
| | | import com.fzzy.gateway.hx2023.kafka.KafkaDeviceReport; |
| | | import com.fzzy.gateway.hx2023.websocket.WebSocketDeviceReport; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.stereotype.Component; |
| | |
| | | |
| | | @Resource |
| | | private WebSocketDeviceReport webSocketDeviceReport; |
| | | @Resource |
| | | private KafkaDeviceReport kafkaDeviceReport; |
| | | |
| | | @Override |
| | | public String getProvinceProtocol() { |
| | |
| | | |
| | | return null; |
| | | } |
| | | |
| | | @Override |
| | | public String pushGrainData2Cloud(GrainData data) { |
| | | |
| | | return kafkaDeviceReport.sendGrainData2Cloud(data); |
| | | } |
| | | } |