rank log 定时清理

community-service/src/main/java/com/tanpu/community/service/RankLogService.java

@@ -95,18 +95,19 @@ public class RankLogService {
     // 定时清除ranklog，并上传到oss
     public void clearRankLog() {
         LocalDateTime t = LocalDateTime.now().minusDays(7L);
-        log.info("start clearRankLog job before {}", t.format(DateTimeFormatter.BASIC_ISO_DATE));
+        String d = t.format(DateTimeFormatter.BASIC_ISO_DATE);
+        log.info("start clearRankLog job before {}", d);
 
         for (RankLogTypeEnum type : RankLogTypeEnum.values()) {
             int idx = 0;
             while (true) {
-                List<RankLogEntity> logs = rankLogMapper.selectByTypeLimit(type.getCode(), 50);
+                List<RankLogEntity> logs = rankLogMapper.selectByTypeLimit(type.getCode(), 100);
                 if (logs.isEmpty() || logs.get(0).getRankTime().isAfter(t)) {
                     break;
                 }
 
                 try {
-                    String fileName = "ranklog_" + type.getCode() + "_" + t.format(DateTimeFormatter.BASIC_ISO_DATE) + "_" + idx;
+                    String fileName = "ranklog_" + type.getCode() + "_" + idx;
                     ByteArrayOutputStream os = new ByteArrayOutputStream();
                     IOUtils.writeLines(logs.stream().map(JSON::toJSONString).collect(Collectors.toList()), null, os);
                     ossFileService.uploadFileNoRecord(os.toByteArray(), fileName, ".txt", "rankLog/");
@@ -118,7 +119,8 @@ public class RankLogService {
                 }
 
                 // delete
-                rankLogMapper.deleteBatchIds(logs.stream().map(RankLogEntity::getId).collect(Collectors.toList()));
+                List<Long> ids = logs.stream().map(RankLogEntity::getId).collect(Collectors.toList());
+                rankLogMapper.deleteBatchIds(ids);
 
                 idx++;
             }