定时任务 未使用关闭

(cherry picked from commit a8cd69b3b724f2e25aad65e6b6d27bcae1397af6)

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/MatchByKeyDeleteAll.java

@@ -3,9 +3,14 @@ package com.webflux.launchadmin.mysql.task;
 import jakarta.annotation.Resource;
 import org.springframework.data.redis.core.ReactiveRedisTemplate;
 import org.springframework.data.redis.core.ScanOptions;
+import org.springframework.web.bind.annotation.GetMapping;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
 public class MatchByKeyDeleteAll {
     @Resource
     private ReactiveRedisTemplate<String,String> reactiveRedisTemplate;
@@ -27,4 +32,32 @@ public class MatchByKeyDeleteAll {
                     return reactiveRedisTemplate.delete(Flux.fromIterable(keys));
                 });
     }
+
+    public Mono<List<String>>  get16()   {
+        ScanOptions options = ScanOptions.scanOptions().match("*" + 6 + "*").build();
+        Flux<Map.Entry<Object, Object>> sync_poster_temp_info_hash_json = reactiveRedisTemplate
+                .opsForHash().scan("sync_poster_temp_info_hash_json", options);
+
+        Mono<List<String>> listMono = sync_poster_temp_info_hash_json.flatMap(entry -> {
+            return Mono.just(entry.getValue());
+        }).filter(Objects::nonNull).map(String::valueOf).collectList();
+        reactiveRedisTemplate
+                .opsForHash()
+                .entries("sync_poster_temp_info_hash_json")
+                .filter(entry -> entry.getKey().toString().contains("6"))
+                .map(entry -> entry.getKey().toString()).collectList();
+
+        return reactiveRedisTemplate
+                .opsForHash()
+                .entries("sync_poster_temp_info_hash_json")
+                .filter(entry -> entry.getKey().toString().contains("6"))
+                .map(entry -> entry.getKey().toString()).collectList();
+    }
+
+    public Mono<List<String>>  get15()   {
+        String key="sync_material_info_set_ids_*-13";
+        Mono<List<String>> listMono = reactiveRedisTemplate
+                .scan(ScanOptions.scanOptions().match(key).build()).collectList();
+        return listMono;
+    }
 }

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncAudioToRedis.java

@@ -57,8 +57,8 @@ public class SyncAudioToRedis {
 //            .switchIfEmpty(Mono.error(new BaseException(StrUtil.format("通过计划retAudioId：{}查询音频为空", id))))
 //            .onErrorResume(throwable -> Mono.error(new BaseException(StrUtil.format("通过计划retAudioId：{}查询音频Error::{}", id, throwable.getMessage()))));
 
-    @Scheduled(fixedDelay = 130000)
-    @SchedulerLock(name = "launch:SyncAudioToRedis:syncAudioPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+    //@Scheduled(fixedDelay = 130000)
+    //@SchedulerLock(name = "launch:SyncAudioToRedis:syncAudioPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncAudioPlan(){
         Mono<List<Audio>> listMono = template
                 .select(Query.query(Criteria.where("deleted_at").isNull())

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncBackgroupGroupImageItemToRedis.java

@@ -50,8 +50,8 @@ public class SyncBackgroupGroupImageItemToRedis {
     /**
      *同步裂变计划
      */
-    @Scheduled(fixedDelay = 100000)
-    @SchedulerLock(name = "launch:SyncBackgroupGroupImageItemToRedis:syncBackgroupItemPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+    //@Scheduled(fixedDelay = 100000)
+    //@SchedulerLock(name = "launch:SyncBackgroupGroupImageItemToRedis:syncBackgroupItemPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncBackgroupItemPlan(){
 
         Mono<List<BackgroupImageItem>> listMono = template

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncGroupUsersToRedis.java

@@ -53,8 +53,8 @@ public class SyncGroupUsersToRedis {
     /**
      *同步裂变计划
      */
-    @Scheduled(fixedDelay = 110000)
-    @SchedulerLock(name = "launch:SyncPlanNewListenToRedis:syncGroupUsers", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+    //@Scheduled(fixedDelay = 110000)
+    //@SchedulerLock(name = "launch:SyncPlanNewListenToRedis:syncGroupUsers", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncGroupUsers(){
         Mono<List<GroupUsers>> listMono = template
                 .select(Query.query(Criteria.empty())

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncImageToRedis.java

@@ -59,8 +59,8 @@ public class SyncImageToRedis {
 //              .and("deleted_at").isNull()), Image.class)
 //              .onErrorResume(throwable -> Mono.error(new BaseException("获取群封面异常"))).collectList();
 
-    @Scheduled(fixedDelay = 120000)
-    @SchedulerLock(name = "launch:SyncImageToRedis:syncImagePlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+   // @Scheduled(fixedDelay = 120000)
+    //@SchedulerLock(name = "launch:SyncImageToRedis:syncImagePlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncImagePlan(){
         Query query = Query.query(Criteria
                 .where("deleted_at").isNull()

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncMaterialToRedis.java

@@ -51,8 +51,8 @@ public class SyncMaterialToRedis {
 //      Mono<List<Material>> textMono = template.select(Query.query(Criteria.where("type").is(4)
 //              .and("deleted_at").isNull()
 //              .and("group_type_id").is(f.groupId())), Material.class)
-      @Scheduled(fixedDelay = 140000)
-    @SchedulerLock(name = "launch:SyncMaterialToRedis:syncMaterialPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+     // @Scheduled(fixedDelay = 140000)
+    //@SchedulerLock(name = "launch:SyncMaterialToRedis:syncMaterialPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncMaterialPlan(){
         Query query = Query.query(Criteria
                 .where("deleted_at").isNull()

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncPlanNewCommonListenToRedis.java

@@ -47,8 +47,8 @@ public class SyncPlanNewCommonListenToRedis {
     /**
      *同步裂变计划
      */
-    @Scheduled(fixedDelay = 170000)
-    @SchedulerLock(name = "launch:SyncPlanNewCommonListenToRedis:syncPlanNewCommonPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+    //@Scheduled(fixedDelay = 170000)
+   // @SchedulerLock(name = "launch:SyncPlanNewCommonListenToRedis:syncPlanNewCommonPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncPlanNewCommonPlan(){
         Mono<List<PlanNewCommon>> listMono = template
                 .select(Query.query(Criteria.empty())

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncPlanNewToRedis.java

@@ -58,8 +58,8 @@ public class SyncPlanNewToRedis {
     /**
      *同步裂变计划
      */
-    @Scheduled(fixedDelay = 170000)
-    @SchedulerLock(name = "launch:SyncPlanNewToRedis:syncFissionPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+   // @Scheduled(fixedDelay = 170000)
+   // @SchedulerLock(name = "launch:SyncPlanNewToRedis:syncFissionPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncFissionPlan(){
         Mono<List<PlanNew>> listMono = template.select(Query.query(Criteria.empty()).columns(COLUMNARRAY),PlanNew.class).collectList();
         listMono.flatMap(list -> {

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncPosterTempAudioToRedis.java

@@ -52,8 +52,8 @@ public class SyncPosterTempAudioToRedis {
     /**
      *同步裂变计划
      */
-    @Scheduled(fixedDelay = 130000)
-    @SchedulerLock(name = "launch:SyncPosterTempAudioToRedis:syncPosterTemplatePlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+   // @Scheduled(fixedDelay = 130000)
+    //@SchedulerLock(name = "launch:SyncPosterTempAudioToRedis:syncPosterTemplatePlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncPosterTemplatePlan(){
         Mono<List<PosterTemplate>> listMono = template.select(Query.query(Criteria.empty())
                         .columns(COLUMNARRAY)

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncReactiveDomainToRedis.java

@@ -54,8 +54,8 @@ public class SyncReactiveDomainToRedis {
 //            .and("status").is(1)
 //                                .and("type").is(5)
 //                                .and("deleted_at").isNull()), DomainSelect.class)
-    @Scheduled(fixedDelay = 100000)
-    @SchedulerLock(name = "launch:SyncReactiveDomainToRedis:syncDomainSelectPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+   // @Scheduled(fixedDelay = 100000)
+    //@SchedulerLock(name = "launch:SyncReactiveDomainToRedis:syncDomainSelectPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncDomainSelectPlan(){
         // group_type_id-type-status
         Query query = Query.query(Criteria

launch-admin/src/main/java/com/webflux/launchadmin/mysql/task/SyncReturnLoopToRedis.java

@@ -52,8 +52,8 @@ public class SyncReturnLoopToRedis {
 //            .switchIfEmpty(Mono.error(new BaseException(StrUtil.format("通过计划retReturnLoopId：{}查询音频为空", id))))
 //            .onErrorResume(throwable -> Mono.error(new BaseException(StrUtil.format("通过计划retReturnLoopId：{}查询音频Error::{}", id, throwable.getMessage()))));
 
-    @Scheduled(fixedDelay = 190000)
-    @SchedulerLock(name = "launch:SyncReturnLoopToRedis:syncReturnLoopPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
+  //  @Scheduled(fixedDelay = 190000)
+   // @SchedulerLock(name = "launch:SyncReturnLoopToRedis:syncReturnLoopPlan", lockAtLeastFor = "PT5S", lockAtMostFor = "PT15M")
     public void syncReturnLoopPlan(){
         Mono<List<ReturnLoop>> listMono = template
                 .select(Query.query(Criteria.where("deleted_at").isNull())