websocket调整

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/impl/BaseAlarmServiceImpl.java

@@ -225,7 +225,7 @@ public class BaseAlarmServiceImpl extends AbstractCrudService<BaseAlarmMapper, B
                 .eq(DmpProductInfo::getDeleteFlag,0);
         List<DmpProductInfo> records = dmpProductInfoService.list(lambdaQuery);
         if(records.size()>0){
-            baseAlarm.setTenantId(SecurityUtils.getTenantId());
+            baseAlarm.setTenantId(records.get(0).getTenantId());
             if (StringUtils.isNotBlank(baseAlarm.getHandleBy()) || StringUtils.isNotBlank(baseAlarm.getHandlePhone())){
                 baseAlarm.setHandleStatus(1);
                 LambdaQueryWrapper<BaseAlarm> queryWrapper = Wrappers.lambdaQuery();
@@ -235,7 +235,7 @@ public class BaseAlarmServiceImpl extends AbstractCrudService<BaseAlarmMapper, B
                         .eq(BaseAlarm::getAlarmGrade,baseAlarm.getAlarmGrade());
                 return this.update(baseAlarm,queryWrapper);
             }else {
-                webSocket.sendMessage(baseAlarm,"123");
+                webSocket.sendMessage(baseAlarm,records.get(0).getTenantId().toString());
                 return this.save(baseAlarm);
             }
         }else {