瀏覽代碼

videoPool batch audit

wangyunpeng 2 月之前
父節點
當前提交
a64738af46

+ 6 - 0
long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/recommend/VideoPoolAuditService.java

@@ -196,6 +196,7 @@ public class VideoPoolAuditService {
                     json.put("id", obj.getContentTraceId());
                     json.put("timestamp", now + (120 * 60 * 1000));
                     redisTemplate.opsForList().rightPush(inAuditListRedisKey, json.toJSONString());
+                    redisTemplate.expire(inAuditListRedisKey, 12, TimeUnit.HOURS);
                 }
                 String auditAccountListKey = "video-pool-audit-account-list-" + dateStr;
                 redisTemplate.opsForSet().add(auditAccountListKey, param.getAuditAccountName());
@@ -400,4 +401,9 @@ public class VideoPoolAuditService {
         result.setWaitingAuditCount(waitingAuditCount);
         return result;
     }
+
+    public void getOff(VideoPoolAuditDataParam param) {
+        String inAuditListRedisKey = "video-pool-in-audit-list-" + param.getAuditAccountName();
+        redisTemplate.delete(inAuditListRedisKey);
+    }
 }

+ 6 - 0
long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/web/recommend/VideoPoolAuditController.java

@@ -35,6 +35,12 @@ public class VideoPoolAuditController {
         return CommonResponse.success(service.auditData(param));
     }
 
+    @PostMapping("/getOff")
+    public CommonResponse<Void> getOff(@RequestBody VideoPoolAuditDataParam param) {
+        service.getOff(param);
+        return CommonResponse.success();
+    }
+
     @PostMapping("/auditArticle")
     public CommonResponse<Void> auditArticle(@RequestBody ArticleAuditParam param) {
         service.auditArticle(param);