四川省网关接口相关13

jiazx0107@163.com

2023-10-31 9934bdd6043c55155fea761d0dd687c443849b4b

 src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java

@@ -6,9 +6,11 @@
import com.fzzy.gateway.api.DeviceReportService;
import com.fzzy.gateway.entity.GatewayDevice;
import com.fzzy.gateway.hx2023.ScConstant;
import com.fzzy.gateway.hx2023.data.KafaGrainData;
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;
@@ -22,6 +24,8 @@

    @Resource
    private WebSocketDeviceReport webSocketDeviceReport;
    @Resource
    private KafkaDeviceReport kafkaDeviceReport;

    @Override
    public String getProvinceProtocol() {
@@ -71,4 +75,10 @@

        return null;
    }

    @Override
    public String pushGrainData2Cloud(KafaGrainData data) {

        return kafkaDeviceReport.sendGrainData2Cloud(data);
    }
}