废弃了一部分

src/main/java/com/nokia/tsl_data/dao/TaskRecordRepository.java

@@ -7,7 +7,11 @@ import org.springframework.stereotype.Repository;
 import java.time.Instant;
 import java.util.List;
 
+/*
+ * 20240205 弃用
+ */
 @Repository
+@Deprecated
 public interface TaskRecordRepository extends JpaRepository<TaskRecord, Long> {
 
     TaskRecord findFirstByTaskNameAndEndStatusOrderByStartTimeDesc(String taskName, Integer endStatus);

src/main/java/com/nokia/tsl_data/dao/TslDataDao.java

@@ -14,6 +14,7 @@ import java.util.Objects;
 /**
  * tslData 直接使用jdbcTemplate完成的操作
  */
+/* cSpell: disable */
 @Component
 public class TslDataDao {
 
@@ -25,7 +26,9 @@ public class TslDataDao {
 
     /**
      * 采用BatchSqlUpdate的方法批量insert到表tableName(可以是临时表)
+     * 20240205 不再使用
      */
+    @Deprecated
     public void batchInsertWorkFlowBasicData(List<WorkFlowBasicData> data, String tableName) {
         String sqlFormat = "INSERT INTO %s " +
                 "(order_no,is_effctive, kfsn, city_id, region_id, kd_accept_time, kd_request_reply_time, re_is_status_id, "
@@ -60,7 +63,9 @@ public class TslDataDao {
 
     /**
      * 创建临时表
+     * 20240205 不再使用
      */
+    @Deprecated
     public void createTempTableOfWorkFlowBasicData(String tempTableName) {
         String sql = "CREATE TABLE %s (  " + //
                 " order_no varchar(50) not null,  " + //
@@ -81,7 +86,9 @@ public class TslDataDao {
 
     /**
      * 删除临时表
+     * 20240205 不再使用
      */
+    @Deprecated
     public void dropTempTable(String tempTableName) {
         if (!tempTableName.contains("_temp_")) {
             throw new RuntimeException("仅支持删除命名带有 _temp_ 的临时表");
@@ -103,7 +110,9 @@ public class TslDataDao {
 
     /**
      * 从临时表中查找新增内容并插入work_flow_basic_data表
+     * 20240205 不再使用
      */
+    @Deprecated
     public int insertWorkFlowBasicDataFromTempTable(String tempTableName) {
         String sqlFormat = "insert into tsl_data.work_flow_basic_data" +
                 " (order_no, is_effctive, kfsn, city_id, region_id, kd_accept_time, kd_request_reply_time, re_is_status_id, "
@@ -119,7 +128,9 @@ public class TslDataDao {
 
     /**
      * 从临时表中查找需要更新内容并更新到work_flow_basic_data表
+     * 20240205 不再使用
      */
+    @Deprecated
     public int updateWorkFlowBasicDataFromTempTable(String tempTableName) {
         String sqlFormat = "update tsl_data.work_flow_basic_data b\n" +
                 "set kfsn = t.kfsn, is_effctive = t.is_effctive, city_id = t.city_id, region_id = t.region_id, "

src/main/java/com/nokia/tsl_data/dao/WorkFlowDao.java

@@ -15,6 +15,7 @@ import java.util.List;
 /**
  * 从 工作流数据库 读取
  */
+/* cSpell: disable */
 @Component
 public class WorkFlowDao {
 
@@ -51,11 +52,15 @@ public class WorkFlowDao {
     }
 
     // 获取update_time在start之后的全部工单信息
+    // 20240205 不再使用
+    @Deprecated
     public List<WorkFlowBasicData> findWorkFlowBasicDataByUpdateTime(Instant start) {
         return findWorkFlowBasicDataByUpdateTime(start, Instant.now());
     }
 
     // 获取update_time在两个范围之间的全部工单信息
+    // 20240205 不再使用
+    @Deprecated
     public List<WorkFlowBasicData> findWorkFlowBasicDataByUpdateTime(Instant start, Instant end) {
         // 20240112 修改 使用 serv_order 替换了kfsn
         String sql = "select order_no, " + //

src/main/java/com/nokia/tsl_data/entity/TaskRecord.java

@@ -11,6 +11,10 @@ import org.springframework.data.jpa.domain.support.AuditingEntityListener;
 import javax.persistence.*;
 import java.time.Instant;
 
+/**
+ * 20240205 不再记录
+ */
+@Deprecated
 @Data
 @Entity
 @EntityListeners(AuditingEntityListener.class)

src/main/java/com/nokia/tsl_data/entity/WorkFlowBasicData.java

@@ -6,7 +6,10 @@ import java.time.Instant;
 /**
  * 数据源是工单流程的flow_form_basic表 码表 sys_data_dictionary
  * tsl_data.work_flow_basic_data
+ * 20240205开始不再更新
  */
+/* cSpell: disable */
+@Deprecated
 @Data
 public class WorkFlowBasicData {
 

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

@@ -78,7 +78,7 @@ public class TaskService {
             messageService.error(result);
             // 延时调度，间隔一段时间后再次调度
             taskScheduleService.schedule(new RunnableTask()
-                    .setTaskId("warehouse_rescedule_" + day + "_" + System.currentTimeMillis())
+                    .setTaskId("warehouse_reSchedule_" + day + "_" + System.currentTimeMillis())
                     .setBeanName("taskService")
                     .setMethodName("warehouseTask")
                     .setMethodParameter(day)
@@ -127,8 +127,10 @@ public class TaskService {
     /**
      * 从工单系统定时更新数据
      * 调度周期每三小时的10分调度一次
+     * 20240205开始不再执行
      */
-    @Scheduled(cron = "0 10 0/3 * * *")
+    @Deprecated
+    // @Scheduled(cron = "0 10 0/3 * * *")
     public void updateWorkFlowBasicDataTask() {
         log.info("从工单系统定时更新数据 任务开始...");
         Instant start = taskRecordRepository.findLastSuccessUpdateWorkFlowBasicDataTaskEndInstant();
@@ -141,8 +143,10 @@ public class TaskService {
     /**
      * 定时删除过期的临时表
      * 调度周期，每天凌晨1点调度一次
+     * 20240205后不再执行
      */
-    @Scheduled(cron = "0 0 1 * * *")
+    @Deprecated
+    // @Scheduled(cron = "0 0 1 * * *")
     public void tempTableCleanCronTask() {
         log.info("定时删除过期的临时表 任务开始...");
         TaskRecord taskRecord = new TaskRecord();

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

@@ -55,6 +55,7 @@ public class WorkFlowService {
     /**
      * 任务名称：更新工作流数据
      */
+    @Deprecated
     public TaskRecord updateWorkFlowBasicData(Instant start, Instant end) {
         TaskRecord record = new TaskRecord();
         record.setTaskName("更新工作流数据");
@@ -143,6 +144,7 @@ public class WorkFlowService {
 
     /**
      * 平均处理时长
+     * 20240205更新
      */
     public List<List<Object>> getCostTimeInfo(String day) {
         Calendar calendar = Calendar.getInstance(Locale.CHINA);

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

@@ -1,12 +1,17 @@
 package com.nokia.tsl_data;
 
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
 import com.nokia.tsl_data.dao.TargetTsRatioMapper;
+import com.nokia.tsl_data.dao.WorkFlowBasicDataMapper;
 import com.nokia.tsl_data.service.TaskService;
 import com.nokia.tsl_data.util.TextUtil;
 
@@ -39,4 +44,17 @@ class TslDataApplicationTest {
             }
         });
     }
+
+    @Autowired
+    private WorkFlowBasicDataMapper workFlowBasicDataMapper;
+
+    @Test
+    void test3() throws ParseException {
+        String day = "20240203";
+        SimpleDateFormat dateFormat2 = new SimpleDateFormat("yyyyMMddHHmmss");
+        Date start = dateFormat2.parse(day.substring(0, 6) + "01000000");
+        Date end = dateFormat2.parse(day+"235959");
+        List<Map<String, Object>> selectTsDurationForDay = workFlowBasicDataMapper.selectTsDurationForDay(start, end);
+        selectTsDurationForDay.forEach(System.out::println);
+    }
 }