fix: 呼吸上报过滤组织

server-service/src/main/java/com/makeit/external/strategy/HuiNengStrategy.java

@@ -22,6 +22,7 @@ import org.springframework.stereotype.Service;
 
 
 import java.time.LocalDateTime;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.time.format.DateTimeFormatter;
+import java.util.Arrays;
 import java.util.List;
 import java.util.List;
 
 
 @Service
 @Service
@@ -42,6 +43,9 @@ public class HuiNengStrategy implements OpenApiBaseStrategy {
         if (platDevice == null) {
         if (platDevice == null) {
             return;
             return;
         }
         }
+        if (!isSupportAlarm(platTenant, platDevice)) {
+            return;
+        }
         if (StringUtils.isEmpty(platTenant.getUrl())) {
         if (StringUtils.isEmpty(platTenant.getUrl())) {
             log.info("当前租户为配置openapi地址");
             log.info("当前租户为配置openapi地址");
             return;
             return;
@@ -95,6 +99,15 @@ public class HuiNengStrategy implements OpenApiBaseStrategy {
         log.info("接口：{}，返回信息：{}", url, JSON.toJSONString(responseMessage));
         log.info("接口：{}，返回信息：{}", url, JSON.toJSONString(responseMessage));
     }
     }
 
 
+    private boolean isSupportAlarm(PlatTenant platTenant, PlatDevice platDevice) {
+        String reportOrgIds = platTenant.getReportOrgIds();
+        if (StringUtils.isBlank(reportOrgIds)) {
+            return false;
+        }
+        List<String> orgIds = Arrays.asList(StringUtils.split(reportOrgIds, ","));
+        return orgIds.contains(platDevice.getOrgId());
+    }
+
     @Override
     @Override
     @TenantIdIgnore
     @TenantIdIgnore
     public void alarm(PlatTenant platTenant, String deviceId, JSONObject jsonObject) {
     public void alarm(PlatTenant platTenant, String deviceId, JSONObject jsonObject) {