Pre Merge pull request !43 from 阿斌/N/A

src/main/java/com/genersoft/iot/vmp/gb28181/session/SSRCFactory.java

@@ -95,52 +95,43 @@ public class SSRCFactory {
     }
 
     void rebuild() {
-        try {
+        List<MediaServer> servers = mediaServerService.getAll();
-            List<MediaServer> servers = mediaServerService.getAll();
+        for (MediaServer server : servers) {
-            for (MediaServer server : servers) {
+            if (server.isRtpEnable() && userSetting.getSsrcRandom()) {
+                continue;
+            }
+            synchronized (lockMap.computeIfAbsent(server.getId(), k -> new Object())) {
+                BitSet bits = new BitSet(10000);
+                int count = 0;
                 try {
-                    if (server.isRtpEnable() && userSetting.getSsrcRandom()) {
+                    ZLMResult<?> result = zlmresTfulUtils.getMediaList(server, null, null, "rtsp", null);
-                        continue;
+                    if (result != null && result.getCode() == 0 && result.getData() != null) {
-                    }
+                        List<JSONObject> list = (List<JSONObject>) result.getData();
-                    synchronized (lockMap.computeIfAbsent(server.getId(), k -> new Object())) {
+                        for (JSONObject obj : list) {
-                        BitSet bits = new BitSet(10000);
+                            if (obj.getIntValue("originType") != 3) continue;
-                        int count = 0;
+                            String originUrl = obj.getString("originUrl");
-                        try {
+                            if (originUrl == null) continue;
-                            ZLMResult<?> result = zlmresTfulUtils.getMediaList(server, null, null, "rtsp", null);
+                            int idx = originUrl.lastIndexOf("/rtp/");
-                            if (result != null && result.getCode() == 0 && result.getData() != null) {
+                            if (idx == -1) continue;
-                                List<JSONObject> list = (List<JSONObject>) result.getData();
+                            try {
-                                for (JSONObject obj : list) {
+                                int suffix = (int) (Long.parseLong(originUrl.substring(idx + 5), 16) % 10000);
-                                    if (obj.getIntValue("originType") != 3) continue;
+                                bits.set(suffix);
-                                    String originUrl = obj.getString("originUrl");
+                                count++;
-                                    if (originUrl == null) continue;
+                            } catch (NumberFormatException ignored) {
-                                    int idx = originUrl.lastIndexOf("/rtp/");
-                                    if (idx == -1) continue;
-                                    try {
-                                        int suffix = (int) (Long.parseLong(originUrl.substring(idx + 5), 16) % 10000);
-                                        bits.set(suffix);
-                                        count++;
-                                    } catch (NumberFormatException ignored) {
-                                    }
-                                }
-                                usedMap.put(server.getId(), bits);
-                                if (count > 8000) {
-                                    log.info("[SSRC重建] 媒体节点 {} 的SSRC使用率已超过80%，请注意扩展服务提升性能", server.getId());
-                                }
-                                if (log.isDebugEnabled()) {
-                                    log.debug("[SSRC重建] 节点 {} 已占用 {} 个SSRC", server.getId(), count);
-                                }
                             }
-                        } catch (Exception e) {
-                            log.warn("[SSRC重建] 查询媒体节点 {} 失败: {}", server.getId(), e.getMessage());
                         }
-
                     }
-                }catch (Exception e) {
+                } catch (Exception e) {
-                    log.warn("[SSRC重建] 处理媒体节点 {} 失败: {}", server.getId(), e.getMessage());
+                    log.warn("[SSRC重建] 查询媒体节点 {} 失败: {}", server.getId(), e.getMessage());
+                }
+                usedMap.put(server.getId(), bits);
+                if (count > 8000) {
+                    log.info("[SSRC重建] 媒体节点 {} 的SSRC使用率已超过80%，请注意扩展服务提升性能", server.getId());
+                }
+                if (log.isDebugEnabled()) {
+                    log.debug("[SSRC重建] 节点 {} 已占用 {} 个SSRC", server.getId(), count);
                 }
             }
-        }catch (Exception e) {
-            log.error("[SSRC] 重建SSRC失败", e);
         }
     }
 }

web/src/views/common/weekTimePicker.vue

@@ -148,17 +148,10 @@ export default {
     }
   },
   watch: {
-    planArray: {
+    planArray: function(array) {
-      handler(array) {
+      for (let i = 0; i < array.length; i++) {
-        if (!array || !array.length) {
+        this.weekData[i].data = array[i].data
-          return
+      }
-        }
-        for (let i = 0; i < array.length; i++) {
-          this.weekData[i].data = array[i].data
-        }
-      },
-      deep: true,
-      immediate: true
     }
   },
   created() {