jiazx0107@163.com
2023-11-10 04a01be7461dc8ba86f4295599e13c74827cff6b
src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java
@@ -28,18 +28,6 @@
    }
    @Override
    public String report2GatewayBySn(double weigh, GatewayDevice device) {
        if (null == device) {
            log.error("-----------没有获取到设备配置信息-----");
            return "ERROR:没有获取到设备配置信息";
        }
        return null;
    }
    @Override
    public BaseResp reportGrainData(BaseReqData reqData) {
        String topic = ScConstant.TOPIC_REPORT;
@@ -59,7 +47,7 @@
        String topic = ScConstant.TOPIC_MESSAGE_REPORT;
        topic = topic.replace("${productId}", reqData.getProductId()).replace("{deviceId}", reqData.getDeviceId());
        topic = topic.replace("${productId}", reqData.getProductId()).replace("${deviceId}", reqData.getDeviceId());
        publishService.publishMqttWithTopic(reqData.getData(), topic);
@@ -72,7 +60,7 @@
    @Override
    public BaseResp reportLprData(BaseReqData reqData) {
        String topic = ScConstant.TOPIC_MESSAGE_REPORT;
        topic = topic.replace("${productId}", reqData.getProductId()).replace("{deviceId}", reqData.getDeviceId());
        topic = topic.replace("${productId}", reqData.getProductId()).replace("${deviceId}", reqData.getDeviceId());
        publishService.publishMqttWithTopic(reqData.getData(), topic);