v2.4上线

README.md

@@ -2,4 +2,9 @@
 
 nohup java -jar /data/tsl-data/tsl-data-exec.jar >/dev/null 2>&1 &
 
+## v2.4 更新服务请求数据源
+
+1. 更新了服请数据源
+2. 增加了任务超时的逻辑，超过12点不再继续调度前一天任务
+
 ## v2.3 更新20240611提出的需求1

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.nokia</groupId>
     <artifactId>tsl-data</artifactId>
-    <version>2.3</version>
+    <version>2.4</version>
 
     <parent>
         <groupId>org.springframework.boot</groupId>

src/main/java/com/nokia/tsl_data/properties/TslDataProperties.java

@@ -67,7 +67,12 @@ public class TslDataProperties {
     /**
      * 河北客户体验管理系统移网网络体验明细日信息
      */
-    private String dirOfCemMobileExperienceList = "/data/nenglishangdian/HE_D_CEM_MOBILE_EXPERIENCE_LIST/";
-    private String prefixOfCemMobileExperienceList = "HE_D_CEM_MOBILE_EXPERIENCE_LIST_1193846275255566336_";
+    // 20250312 更新 暂时不修改入库字段数量 有需要时再入库新增字段
+    private String dirOfCemMobileExperienceList = "/data/nenglishangdian/HE_D_CEM_MOBILE_EXPERIENCE_LIST_NEW/";
+    private String prefixOfCemMobileExperienceList = "HE_D_CEM_MOBILE_EXPERIENCE_LIST_1348973255222370304_";
+    // private String dirOfCemMobileExperienceList =
+    // "/data/nenglishangdian/HE_D_CEM_MOBILE_EXPERIENCE_LIST/";
+    // private String prefixOfCemMobileExperienceList =
+    // "HE_D_CEM_MOBILE_EXPERIENCE_LIST_1193846275255566336_";
     private Integer filedNumOfCemMobileExperienceList = 17;
 }

src/main/java/com/nokia/tsl_data/service/TaskService.java

@@ -15,6 +15,8 @@ import org.springframework.util.StringUtils;
 import java.io.File;
 import java.nio.file.Paths;
 import java.time.Instant;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 
 /**
@@ -42,6 +44,7 @@ public class TaskService {
     /**
      * 每日定时任务 每天中午1点半执行入库任务
      */
+    // 20250312 修改为 15:30执行
     @Scheduled(cron = "0 30 15 * * *")
     public void dailyWarehouseTask() {
         // 这里的时间要向前一天
@@ -64,6 +67,14 @@ public class TaskService {
         if (StringUtils.hasLength(result)) {
             // 存在异常情况，发送运维消息
             messageService.error(result);
+            // 20250312 修改延时调度逻辑 超过晚上24点后不再调度
+            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd");
+            LocalDate localDate = LocalDate.parse(day, formatter);
+            if (ChronoUnit.DAYS.between(localDate, LocalDate.now()) > 2) {
+                // 因为每天执行上一天任务，如果任务时间和当前时间差超过2天，说明任务已经超时，不再继续调度
+                log.info("账期 {} 任务数据源不具备，已超时：{}", day, result);
+                return;
+            }
             // 延时调度，间隔一段时间后再次调度
             taskScheduleService.schedule(new RunnableTask()
                     .setTaskId("warehouse_reSchedule_" + day + "_" + System.currentTimeMillis())

src/test/java/com/nokia/tsl_data/TslDataApplicationTest.java

@@ -36,7 +36,7 @@ class TslDataApplicationTest {
         lines.forEach(line -> {
             String[] split = line.split("\t");
             System.out.println(split[0] + "==" + split[2]);
-            userCountService.updateManagementUserCount("202501", split[0], Double.parseDouble(split[2]));
+            userCountService.updateManagementUserCount("202503", split[0], Double.parseDouble(split[2]));
         });
     }