同步任务优化

slibra-quartz/src/main/java/com/slibra/quartz/task/RyTask.java

@@ -74,13 +74,13 @@ public class RyTask
         LocalDateTime endTime =  LocalDateTime.now();
         //todo
 //        LocalDateTime startTime = endTime.plusMinutes(-60);
-        //获取上次最后一条同步的数据的日期到小时维度
-        String lastDateHour = this.xinyiIndustryMapper.getLastHour();
+        //获取上次最后一条同步的数据的日期到 分钟维度
+        String lastDateHour = this.xinyiIndustryMapper.getLastMinute();
         log.info("获取上次同步工业库的最后一条记录的时间是{}", lastDateHour);
-        lastDateHour = lastDateHour + ":00:00";
-        log.info("需要从{}开始同步工业库数据", lastDateHour);
+        lastDateHour = lastDateHour + ":00";
+        //开始时间
         LocalDateTime startTime = LocalDateTime.parse(lastDateHour.replaceAll("/", "-").replace(" ", "T"));
-
+        startTime = startTime.plusMinutes(1L);//加一分钟  从上次最后一条记录的下一分钟开始
         /*LocalDateTime startTime = LocalDateTime.parse("2024-02-26T00:00:00");
         LocalDateTime endTime = LocalDateTime.parse("2024-02-27T00:00:00");*/
 
@@ -366,11 +366,11 @@ public class RyTask
         System.out.println(str);
         System.out.println(str.substring(0,10));
         System.out.println(str.substring(0,13));*/
-        String str = "2024/03/31 23";
-        str = str + ":00:00";
+        String str = "2024/04/18 08:00";
+        str = str + ":00";
         System.out.println(str);
         LocalDateTime startTime = LocalDateTime.parse(str.replaceAll("/", "-").replace(" ", "T"));
-        System.out.println(startTime.plusHours(1L).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+        System.out.println(startTime.plusMinutes(1L).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
 
     }
 }

slibra-system/src/main/java/com/slibra/business/mapper/TXinyiIndustryMapper.java

@@ -69,4 +69,6 @@ public interface TXinyiIndustryMapper
     Integer updateTXinyiIndustrySJByBetweenTime(@Param("beginTime") String beginTime, @Param("endTime") String endTime, @Param("sjtyjly") BigDecimal sjtyjly);
 
     String getLastHour();
+
+    String getLastMinute();
 }

slibra-system/src/main/resources/mapper/business/TXinyiIndustryMapper.xml

@@ -329,4 +329,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <select id="getLastHour" resultType="string">
         SELECT TEST_HOUR FROM t_xinyi_industry  ORDER BY id DESC LIMIT 1
     </select>
+
+    <select id="getLastMinute" resultType="string">
+        SELECT TEST_TIME FROM t_xinyi_industry  ORDER BY id DESC LIMIT 1
+    </select>
 </mapper>