| | |
| | | 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); |
| | |
| | | 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<>(); |
| | |
| | | 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); |
| | |
| | | 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); |