chenzx
2024-02-20 77847fe500de2519cba82d1a5ef03d055739f0d7
wumei-smart-master/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxService.java
@@ -9,6 +9,7 @@
import com.ruoyi.iot.model.ThingsModels.ThingsModelValueItem;
import com.ruoyi.iot.model.ThingsModels.ThingsModelValueRemarkItem;
import com.ruoyi.iot.model.ThingsModels.ThingsModelValuesInput;
import com.ruoyi.iot.service.IDeviceFilterService;
import com.ruoyi.iot.service.IDeviceLogService;
import com.ruoyi.iot.service.IDeviceService;
import com.ruoyi.iot.tdengine.service.ILogService;
@@ -33,6 +34,10 @@
    @Autowired
    private IDeviceService deviceService;
    @Autowired
    private IDeviceFilterService deviceFilterService;
    @Autowired
    private ILogService logService;
@@ -167,6 +172,7 @@
            input.setDeviceNumber(deviceNum);
            input.setThingsModelValueRemarkItem(thingsModelValueRemarkItems);
            deviceService.reportDeviceThingsModelValue(input, 1, isShadow);
            deviceFilterService.reportDeviceThingsModelValueFilter(input, 1, isShadow);
        } catch (Exception e) {
            logger.error("接收属性数据,解析数据时异常 message={}", e.getMessage());
        }
@@ -187,6 +193,7 @@
            input.setDeviceNumber(deviceNum);
            input.setThingsModelValueRemarkItem(thingsModelValueRemarkItems);
            deviceService.reportDeviceThingsModelValue(input, 2, isShadow);
            deviceFilterService.reportDeviceThingsModelValueFilter(input, 1, isShadow);
        } catch (Exception e) {
            logger.error("接收功能,解析数据时异常 message={}", e.getMessage());
        }