添加设备上线下线通知

smart-office-manager/src/main/java/com/mortals/xhx/busiz/web/DeviceCallbackController.java

 package com.mortals.xhx.busiz.web;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.mortals.framework.annotation.UnAuth;
 import com.mortals.framework.common.Rest;
@@ -11,6 +12,8 @@ import com.mortals.xhx.common.pdu.device.DeviceReq;
 import com.mortals.xhx.module.device.model.DeviceEntity;
 import com.mortals.xhx.module.device.model.DeviceQuery;
 import com.mortals.xhx.module.device.service.DeviceService;
+import com.mortals.xhx.module.room.model.RoomDeviceEntity;
+import com.mortals.xhx.module.room.service.RoomDeviceService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.util.ObjectUtils;
@@ -19,7 +22,9 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.Arrays;
 import java.util.Date;
+import java.util.List;
 
 import static com.mortals.xhx.common.key.ErrorCode.*;
 
@@ -30,6 +35,8 @@ public class DeviceCallbackController {
 
     @Autowired
     private DeviceService deviceService;
+    @Autowired
+    private RoomDeviceService roomDeviceService;
 
     @PostMapping("callback")
     @UnAuth
@@ -141,6 +148,11 @@ public class DeviceCallbackController {
         //根据设备编码查询设备
         DeviceEntity deviceEntity = checkDeviceExist(req);
         deviceService.remove(new Long[]{deviceEntity.getId()}, null);
+        //关联删除
+        RoomDeviceEntity condition = new RoomDeviceEntity();
+        condition.setDeviceId(deviceEntity.getId());
+        roomDeviceService.getDao().delete(condition);
+
 
     }