Browse Source

feat(gateway): 增加设备初始化时的人员进出和设备掉线记录逻辑删除

- 注入 PersonInOutService 和 DevOnOffInfoService 服务- 在设备初始化逻辑中增加对监测人员进出表的逻辑删除处理- 增加对监测设备掉线表的逻辑删除处理
hxd 1 tuần trước cách đây
mục cha
commit
54d28b3ad0

+ 24 - 0
portal-service-infrastructure/src/main/java/com/hfln/portal/infrastructure/gateway/impl/WebAdminDealGatewayImpl.java

@@ -47,6 +47,10 @@ public class WebAdminDealGatewayImpl implements WebAdminDealGateway {
     private EventsService eventsService;
     @Autowired
     private EventListService eventListService;
+    @Autowired
+    private PersonInOutService personInOutService;
+    @Autowired
+    private DevOnOffInfoService devOnOffInfoService;
 
 
     @Override
@@ -62,6 +66,8 @@ public class WebAdminDealGatewayImpl implements WebAdminDealGateway {
         // 6 设备下房间 逻辑删除
         // 7 设备下跌倒事件 逻辑删除
         // 8 设备下告警事件 逻辑删除
+        // 9 监测人员进出表 逻辑删除
+        // 10 监测设备掉线表 逻辑删除
         log.info("超管对设备devId:{}, 进行设备初始化", param.getDevId());
 
         DevInfo devInfo = devInfoService.getById(param.getDevId());
@@ -132,6 +138,24 @@ public class WebAdminDealGatewayImpl implements WebAdminDealGateway {
                         .eq(EventList::getIsDeleted, 0)
                         .set(EventList::getIsDeleted, 1)
         );
+        // 监测人员进出表 逻辑删除
+        List<PersonInOutInfo> personInOutInfos = personInOutService.list(new LambdaQueryWrapper<PersonInOutInfo>().eq(PersonInOutInfo::getDevId, devInfo.getDevId()));
+        log.info("监测人员进出表:{}", JSON.toJSONString(personInOutInfos));
+        personInOutService.update(
+                Wrappers.<PersonInOutInfo>lambdaUpdate()
+                        .eq(PersonInOutInfo::getDevId, devInfo.getDevId())
+                        .eq(PersonInOutInfo::getIsDeleted, 0)
+                        .set(PersonInOutInfo::getIsDeleted, 1)
+        );
+        // 监测设备掉线表 逻辑删除
+        List<DevOnOffInfo> devOnOffInfos = devOnOffInfoService.list(new LambdaQueryWrapper<DevOnOffInfo>().eq(DevOnOffInfo::getDevId, devInfo.getDevId()));
+        log.info("监测设备掉线表:{}", JSON.toJSONString(devOnOffInfos));
+        devOnOffInfoService.update(
+                Wrappers.<DevOnOffInfo>lambdaUpdate()
+                        .eq(DevOnOffInfo::getDevId, devInfo.getDevId())
+                        .eq(DevOnOffInfo::getIsDeleted, 0)
+                        .set(DevOnOffInfo::getIsDeleted, 1)
+        );
 
         // 对设备 绑定信息置空信息
         devInfoService.resetDevInfo(devInfo.getDevId());