From 6ea57afc103281db3e298bffa2edbee5865e589b Mon Sep 17 00:00:00 2001 From: shikong <919411476@qq.com> Date: Wed, 23 Aug 2023 01:56:14 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E5=A4=87=20=E5=AA=92=E4=BD=93?= =?UTF-8?q?=E8=AE=B0=E5=BD=95=E6=9F=A5=E8=AF=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/skcks/docking/gb28181/service/record/RecordService.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/service/record/RecordService.java b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/service/record/RecordService.java index 2a9fd44..ea61790 100644 --- a/gb28181-service/src/main/java/cn/skcks/docking/gb28181/service/record/RecordService.java +++ b/gb28181-service/src/main/java/cn/skcks/docking/gb28181/service/record/RecordService.java @@ -87,9 +87,8 @@ public class RecordService { public void onNext(RecordInfoResponseDTO item) { sum.set(item.getSumNum()); getNum.getAndAdd(item.getRecordList().size()); - log.info("{}", item); list.addAll(item.getRecordList()); - log.info("{}/{}", getNum.get(), sum.get()); + log.info("获取订阅 => {}, {}/{}", key, getNum.get(), sum.get()); if (getNum.get() >= sum.get()) { onComplete(); } else {