新增处理大表-天维度按照某个时间 获取之后的数据处理

slibra-admin/src/main/java/com/slibra/web/controller/business/HandleDataController.java

@@ -1191,17 +1191,16 @@ public class HandleDataController extends BaseController
      * @return
      */
     @GetMapping("/handleBigTableDayHistoryData")
-    public String handleBigTableDayHistoryData() {
+    public String handleBigTableDayHistoryData(@RequestParam String date) {
         log.info("进入了 处理big_table_day历史数据");
         long begin = System.currentTimeMillis();
 
-        List<TXinyiBigTableHour> tXinyiBigTableHours = tXinyiBigTableHourMapper.selectTXinyiBigTableHourByTestDate();
+        List<TXinyiBigTableHour> tXinyiBigTableHours = tXinyiBigTableHourMapper.selectTXinyiBigTableHourByTestDate(date);
         if ( !CollectionUtils.isEmpty(tXinyiBigTableHours) ) {
 
             List<TXinyiBigTableDay> bigTableDayList = new ArrayList<>();
 
-            for (int i = 0; i < tXinyiBigTableHours.size(); i++) {
-                TXinyiBigTableHour tXinyiBigTableHour = tXinyiBigTableHours.get(i);
+            for (TXinyiBigTableHour tXinyiBigTableHour : tXinyiBigTableHours) {
                 String testDate = tXinyiBigTableHour.getTestDate();
 
                 TXinyiBigTableDay tableDay = tXinyiBigTableDayMapper.selectTXinyiBigTableHourAvg(testDate);
@@ -1350,7 +1349,7 @@ public class HandleDataController extends BaseController
                 if (!CollectionUtils.isEmpty(tXinyiBigTableHourList)) {
                     SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
                     TXinyiBigTableHourMapper sqlSessionMapper = sqlSession.getMapper(TXinyiBigTableHourMapper.class);
-                    tXinyiBigTableHourList.stream().forEach(item -> sqlSessionMapper.insertTXinyiBigTableHour(item));
+                    tXinyiBigTableHourList.forEach(sqlSessionMapper::insertTXinyiBigTableHour);
                     sqlSession.commit();
                     sqlSession.close();
                 }

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

@@ -2,7 +2,6 @@ package com.slibra.business.mapper;
 
 import java.util.List;
 
-import com.slibra.business.domain.TXinyiBigTableDay;
 import com.slibra.business.domain.TXinyiBigTableHour;
 
 /**
@@ -61,6 +60,6 @@ public interface TXinyiBigTableHourMapper
      */
     public int deleteTXinyiBigTableHourByIDs(Long[] IDs);
 
-    List<TXinyiBigTableHour> selectTXinyiBigTableHourByTestDate();
+    List<TXinyiBigTableHour> selectTXinyiBigTableHourByTestDate(String date);
 
 }

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

@@ -781,8 +781,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </delete>
 
     <select id="selectTXinyiBigTableHourByTestDate" resultMap="TXinyiBigTableHourResult">
-        <!-- select TEST_DATE from t_xinyi_big_table_hour WHERE TEST_DATE > '2024/07/26' group by TEST_DATE -->
-        select TEST_DATE from t_xinyi_big_table_hour group by TEST_DATE
+         select TEST_DATE from t_xinyi_big_table_hour WHERE TEST_DATE >= #{date} group by TEST_DATE
+        <!-- select TEST_DATE from t_xinyi_big_table_hour group by TEST_DATE -->
     </select>
 
     <select id="selectTXinyiBigTableHourList" parameterType="TXinyiBigTableHour" resultMap="TXinyiBigTableHourResult">