whyclxw
2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362
src/main/java/com/whyc/service/HistoryDataArchivingService.java
@@ -65,18 +65,21 @@
        for (String year : yearKeySet){
            String tableNameExists = commonMapper.existTable("db_pwrdev_alarm", "tb_pwrdev_alarm_history_" + year);
            if(tableNameExists == null) {
                commonMapper.createTable4PowerAlarmHistoryByYear(year);
                //commonMapper.createTable4PowerAlarmHistoryByYear(year);
                subService.createTable4PowerAlarmHistoryByYear(year);
            }
            List<PwrdevAlarmHistory> data = map.get(year);
            List<PwrdevAlarmHistory> temp = new LinkedList<>();
            for (int i = 0; i < data.size(); i++) {
                temp.add(data.get(i));
                if(i!=0 && i%1000 == 0){ //1000一比
                    commonMapper.insertBatch4PowerAlarmHistoryByYear(year,temp);
                    //commonMapper.insertBatch4PowerAlarmHistoryByYear(year,temp);
                    subService.insertBatch4PowerAlarmHistoryByYear(year,temp);
                    temp.clear();
                }
            }
            commonMapper.insertBatch4PowerAlarmHistoryByYear(year,temp);
            //commonMapper.insertBatch4PowerAlarmHistoryByYear(year,temp);
            subService.insertBatch4PowerAlarmHistoryByYear(year,temp);
        }
        //删除总表中已经另外存档的数据
        powerAlarmHistoryService.deleteBeforeRetentionMonth(retentionTime);
@@ -96,7 +99,8 @@
        for (String year : yearKeySet){
            String tableNameExists = commonMapper.existTable("db_alarm", "tb_battalarm_data_history_" + year);
            if(tableNameExists == null) {
                commonMapper.createTable4BattAlarmDataHistoryByYear(year);
                //commonMapper.createTable4BattAlarmDataHistoryByYear(year);
                subService.createTable4BattAlarmDataHistoryByYear(year);
            }
            List<BattalarmDataHistory> data = map.get(year);
            List<BattalarmDataHistory> temp = new LinkedList<>();
@@ -129,18 +133,21 @@
        for (String year : yearKeySet){
            String tableNameExists = commonMapper.existTable("db_alarm", "tb_devalarm_data_history_" + year);
            if(tableNameExists == null) {
                commonMapper.createTable4DevAlarmDataHistoryByYear(year);
                //commonMapper.createTable4DevAlarmDataHistoryByYear(year);
                subService.createTable4DevAlarmDataHistoryByYear(year);
            }
            List<DevalarmDataHistory> data = map.get(year);
            List<DevalarmDataHistory> temp = new LinkedList<>();
            for (int i = 0; i < data.size(); i++) {
                temp.add(data.get(i));
                if(i!=0 && i%1000 == 0){ //1000一比
                    commonMapper.insertBatch4DevAlarmDataHistoryByYear(year,temp);
                    //commonMapper.insertBatch4DevAlarmDataHistoryByYear(year,temp);
                    subService.insertBatch4DevAlarmDataHistoryByYear(year,temp);
                    temp.clear();
                }
            }
            commonMapper.insertBatch4DevAlarmDataHistoryByYear(year,temp);
            //commonMapper.insertBatch4DevAlarmDataHistoryByYear(year,temp);
            subService.insertBatch4DevAlarmDataHistoryByYear(year,temp);
        }
        //删除总表中已经另外存档的数据
        devAlarmDataHistoryService.deleteBeforeRetentionMonth(retentionTime);
@@ -160,18 +167,21 @@
        for (String year : yearKeySet){
            String tableNameExists = commonMapper.existTable("db_user", "tb_user_log_" + year);
            if(tableNameExists == null) {
                commonMapper.createTable4UserLogByYear(year);
                //commonMapper.createTable4UserLogByYear(year);
                subService.createTable4UserLogByYear(year);
            }
            List<UserLog> userLogs = userLogMap.get(year);
            List<UserLog> temp = new LinkedList<>();
            for (int i = 0; i < userLogs.size(); i++) {
                temp.add(userLogs.get(i));
                if(i!=0 && i%1000 == 0){ //1000一比
                    commonMapper.insertBatch4UserLogByYear(year,temp);
                    //commonMapper.insertBatch4UserLogByYear(year,temp);
                    subService.insertBatch4UserLogByYear(year,temp);
                    temp.clear();
                }
            }
            commonMapper.insertBatch4UserLogByYear(year,temp);
            //commonMapper.insertBatch4UserLogByYear(year,temp);
            subService.insertBatch4UserLogByYear(year,temp);
        }
        //删除总表中已经另外存档的数据
        userLogService.deleteBeforeRetentionMonth(retentionTime);