From b8d8733ad9eeeb170a71897d1078acdbea7680f2 Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期二, 04 三月 2025 15:23:38 +0800
Subject: [PATCH] 优化

---
 ycl-platform/src/main/java/com/ycl/task/SynchronizeHKVideo.java |   32 +++++++++++++++++++-------------
 1 files changed, 19 insertions(+), 13 deletions(-)

diff --git a/ycl-platform/src/main/java/com/ycl/task/SynchronizeHKVideo.java b/ycl-platform/src/main/java/com/ycl/task/SynchronizeHKVideo.java
index 3a3b6c9..20510e4 100644
--- a/ycl-platform/src/main/java/com/ycl/task/SynchronizeHKVideo.java
+++ b/ycl-platform/src/main/java/com/ycl/task/SynchronizeHKVideo.java
@@ -1,6 +1,7 @@
 package com.ycl.task;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sun.jna.ptr.IntByReference;
 import com.ycl.dto.video.Camera;
 import com.ycl.dto.video.PageResult;
 import com.ycl.entity.video.VideoPoint;
@@ -11,6 +12,7 @@
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.io.File;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -25,27 +27,31 @@
     @Autowired
     private VideoUtil videoUtil;
 
-    @Scheduled(cron = "0/1 * * * * ?")   // 姣忕鎵ц
-//    @Scheduled(cron = "0 0/1 * ?")
+    //    @Scheduled(cron = "0 */5 * * * ?")   // 姣�5鍒嗛挓鎵ц
+    @Scheduled(cron = "0 0 1 * * ?")
     @Transactional(rollbackFor = Exception.class)
     public void scheduledTask() {
-        try {
-            findVideoList(1, 20);
-        } catch (Exception ex) {
+//        System.out.println("娴峰悍锛氬紑濮嬫墽琛�");
 
-        }
+        findVideoList(1, 5);
+
     }
 
-    private void findVideoList(Integer pageNo, Integer pageSize) throws Exception {
-        PageResult<Camera> pageResult = videoUtil.callPostCameras(pageNo, pageSize, "0");
-        if (pageResult.getTotal() > 0) {
-            if (pageResult.getList().size() > 0) {
-                saveVideoFromCamera(pageResult.getList());
 
-                if (pageResult.getList().size() >= pageSize) {
-                    findVideoList(pageNo + 1, pageSize);
+    private void findVideoList(Integer pageNo, Integer pageSize) {
+        try {
+            PageResult<Camera> pageResult = videoUtil.callPostCameras(pageNo, pageSize, "0");
+            if (pageResult.getTotal() > 0) {
+                if (pageResult.getList().size() > 0) {
+                    saveVideoFromCamera(pageResult.getList());
+
+                    if (pageResult.getList().size() >= pageSize) {
+                        findVideoList(pageNo + 1, pageSize);
+                    }
                 }
             }
+        } catch (Exception ex) {
+            System.out.println("娴峰悍锛�" + ex.getMessage());
         }
     }
 

--
Gitblit v1.8.0