fix: iot设备属性同步

9d66f86f · 罗志长 · 634c7aa6 · 9d66f86f · 9d66f86f
Commit 9d66f86f authored Dec 14, 2023 by 罗志长
Showing with 52 additions and 9 deletions
server-service/src/main/java/com/makeit/service/platform/device/impl/PlatDeviceServiceImpl.java
server-web/src/main/java/com/makeit/mqtt/PushCallback.java
--- a/server-service/src/main/java/com/makeit/service/platform/device/impl/PlatDeviceServiceImpl.java
+++ b/server-service/src/main/java/com/makeit/service/platform/device/impl/PlatDeviceServiceImpl.java
@@ -38,6 +38,7 @@ import com.makeit.entity.saas.PlatTenant;
 import com.makeit.entity.saas.SaasPidManage;
 import com.makeit.enums.CodeMessageEnum;
 import com.makeit.enums.CommonEnum;
+import com.makeit.enums.platform.device.PlatDeviceEnum;
 import com.makeit.enums.report.DeviceNameEnum;
 import com.makeit.exception.BusinessException;
 import com.makeit.global.aspect.tenant.TenantIdIgnore;
@@ -381,7 +382,7 @@ public class PlatDeviceServiceImpl extends ServiceImpl<PlatDeviceMapper, PlatDev
        for (PlatDeviceOther platDeviceOther : platDeviceOtherList) {
            BeanUtils.copyProperties(dto, platDeviceOther,"id");
            platDeviceOther.setDeviceId(id);
-            platDeviceOther.setAttribute(JSON.toJSONString(getDeviceBaseAttrDTO(db.getOriDeviceId())));
+            platDeviceOther.setAttribute(JSON.toJSONString(getDeviceBaseAttrDTO(db)));
            platDeviceOther.setOriDeviceId(db.getOriDeviceId());
            platDeviceOtherService.saveOrUpdate(platDeviceOther);
        }
@@ -939,9 +940,16 @@ public class PlatDeviceServiceImpl extends ServiceImpl<PlatDeviceMapper, PlatDev
    }
    @Override
+    @TenantIdIgnore
    @Transactional(rollbackFor = Exception.class)
    public void syncIotProperties(String deviceId) {
-        PlatDeviceBaseAttrDTO platDeviceBaseAttrDTO = getDeviceBaseAttrDTO(deviceId);
+        PlatDevice device = getOne(new QueryWrapper<PlatDevice>().lambda()
+                .eq(PlatDevice::getOriDeviceId, deviceId));
+        if (device == null) {
+            log.warn("iot属性同步,设备不存在,设备id:{}", deviceId);
+            return;
+        }
+        PlatDeviceBaseAttrDTO platDeviceBaseAttrDTO = getDeviceBaseAttrDTO(device);
        String attr = JSON.toJSONString(platDeviceBaseAttrDTO);
        platDeviceOtherService.update(new UpdateWrapper<PlatDeviceOther>().lambda()
                .set(PlatDeviceOther::getAttribute, attr)
@@ -955,10 +963,22 @@ public class PlatDeviceServiceImpl extends ServiceImpl<PlatDeviceMapper, PlatDev
        }
    }
-    private PlatDeviceBaseAttrDTO getDeviceBaseAttrDTO(String deviceId) {
+    private PlatDeviceBaseAttrDTO getDeviceBaseAttrDTO(PlatDevice platDevice) {
-        String propertiesName = "radarMount,radarMode,radarHight,radarDistance,radarAngle,radarDelay,radarSence,radarSPL";
+        String category = platDevice.getCategory();
+        if (!(PlatDeviceEnum.CategoryEnum.FALL.getValue().equals(category) || PlatDeviceEnum.CategoryEnum.SPACE.getValue().equals(category))) {
+            return new PlatDeviceBaseAttrDTO();
+        }
+        String propertiesName = "";
+        // 跌倒
+        if (PlatDeviceEnum.CategoryEnum.FALL.getValue().equals(category)) {
+            propertiesName = "radarMount,radarHight,radarSence,radarSPL";
+        }
+        // 空间人体
+        if (PlatDeviceEnum.CategoryEnum.SPACE.getValue().equals(category)) {
+            propertiesName = "radarMount,radarMode,radarDistance,radarAngle,radarDelay";
+        }
        PlatDeviceAttrWechatDTO dto = new PlatDeviceAttrWechatDTO();
-        dto.setDeviceId(deviceId);
+        dto.setDeviceId(platDevice.getOriDeviceId());
        dto.setReadProperties(propertiesName);
        List<DeviceProperties> data = this.readDeviceProperties(dto);
        Map<String, Object> attrMap = data.stream().filter(p -> !Objects.isNull(p.getValue())).collect(Collectors.toMap(DeviceProperties::getProperty, DeviceProperties::getValue));

--- a/server-web/src/main/java/com/makeit/mqtt/PushCallback.java
+++ b/server-web/src/main/java/com/makeit/mqtt/PushCallback.java
@@ -18,7 +18,9 @@ import com.makeit.service.platform.device.PlatDeviceService;
 import com.makeit.service.saas.SaasSleepAnalysisModelService;
 import com.makeit.utils.AlarmConfigCacheUtil;
 import com.makeit.utils.DeviceCacheUtil;
+import com.makeit.utils.redis.RedisUtil;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
 import org.eclipse.paho.client.mqttv3.MqttCallback;
 import org.eclipse.paho.client.mqttv3.MqttClient;
@@ -35,6 +37,7 @@ import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
@@ -117,13 +120,33 @@ public class PushCallback implements MqttCallback {
     * IOT端设备属性修改后同步
     * @param device
     */
-    @TenantIdIgnore
-    @Async
    public void syncProperties(DeviceInfo device) {
-        if (!WRITE_PROPERTY.equals(device.getMessageType())) {
+        if (!(WRITE_PROPERTY.equals(device.getMessageType()) || WRITE_PROPERTY_REPLY.equals(device.getMessageType()))) {
            return;
        }
-        //platDeviceService.syncIotProperties(device.getDeviceId());
+        // 记录修改的属性
+        String key = DEVICE_WRITE_PROPERTY_KEY + device.getDeviceId();
+        if (WRITE_PROPERTY.equals(device.getMessageType())) {
+            JSONObject properties = device.getProperties();
+            String value = properties.keySet().stream().findFirst().orElse("value");
+            RedisUtil.set(key, value, 10, TimeUnit.SECONDS);
+        }
+        // 收到修改属性回复
+        if (WRITE_PROPERTY_REPLY.equals(device.getMessageType())) {
+            String value = RedisUtil.get(key);
+            if (StringUtils.isBlank(value)) {
+                return;
+            }
+            JSONObject properties = device.getProperties();
+            int success = properties.getIntValue(value);
+            if (success != 0) {
+                return;
+            }
+            CompletableFuture.runAsync(() -> {
+                platDeviceService.syncIotProperties(device.getDeviceId());
+                RedisUtil.delete(key);
+            }); // 要加线程池
+        }
    }
    /**