From f962534ae431779f3e341365af2e30fdd0afeb0f Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期日, 13 十月 2024 16:20:13 +0800
Subject: [PATCH] 点位在线率恢复为取优云和海康数据

---
 ycl-server/src/main/java/com/ycl/platform/service/impl/YwPointServiceImpl.java |   18 ++++--------------
 1 files changed, 4 insertions(+), 14 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/YwPointServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/YwPointServiceImpl.java
index 4a4cbb4..15e8456 100644
--- a/ycl-server/src/main/java/com/ycl/platform/service/impl/YwPointServiceImpl.java
+++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/YwPointServiceImpl.java
@@ -37,6 +37,7 @@
 import constant.PointHeaderConstant;
 import jakarta.servlet.http.HttpServletResponse;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -60,6 +61,7 @@
  */
 @Service
 @RequiredArgsConstructor
+@Slf4j
 public class YwPointServiceImpl extends ServiceImpl<YwPointMapper, YwPoint> implements YwPointService {
 
     private final SysDeptMapper sysDeptMapper;
@@ -371,21 +373,9 @@
         this.waitAllFinishAndGetResult(pointList);
     }
 
-    public void waitAllFinishAndGetResult(List<YwPoint> dataList) throws
-            InterruptedException, ExecutionException {
-        int start = 0;
+    public void waitAllFinishAndGetResult(List<YwPoint> dataList) {
         Date startTime = new Date();
-        while (true) {
-            if (dataList.size() < start + 800) {
-                List<YwPoint> list = dataList.subList(start, dataList.size() - 1);
-                this.baseMapper.updatePoint(list);
-                break;
-            } else {
-                List<YwPoint> list = dataList.subList(start, start + 800);
-                this.baseMapper.updatePoint(list);
-                start += 800;
-            }
-        }
+        this.baseMapper.updatePoint(dataList);
         Date endTime = new Date();
         log.error("鎬诲叡鑰楁椂锛�" + (endTime.getTime() - startTime.getTime()));
     }

--
Gitblit v1.8.0