modify

src/main/java/com/lwby/marketing/att/bystory/DyStoryActiveConsumer.java

@@ -23,7 +23,7 @@ public class DyStoryActiveConsumer implements MessageListener<String, String> {
     @Resource
     DyStoryFlowExecutor dyStoryFlowExecutor;
 
-    @KafkaListener(topics = {"${story.novel.active.consumer.topic:testStoryNovelActive}"},groupId = "${story.novel.active.consumer.group.id:test_story_dy_active}")
+    @KafkaListener(topics = {"${system.consumer.dystory.active.topic}"},groupId = "${system.consumer.dystory.active.topic}")
     @Override
     public void onMessage(ConsumerRecord<String, String> data) {
 

src/main/java/com/lwby/marketing/att/bystory/DyStoryPayConsumer.java

@@ -24,7 +24,7 @@ public class DyStoryPayConsumer extends DyStoryFlowExecutor implements MessageLi
     @Resource
     DyStoryFlowExecutor dyStoryFlowExecutor;
 
-    @KafkaListener(topics = {"${story.novel.pay.consumer.topic:testStoryNovelpay}"},groupId = "${story.novel.pay.consumer.group.id:test_story_dy_pay}")
+    @KafkaListener(topics = {"${system.consumer.dystory.pay.topic}"},groupId = "${system.consumer.dystory.pay.group_id}")
     @Override
     public void onMessage(ConsumerRecord<String, String> data) {
 

src/main/java/com/lwby/marketing/att/novel/NovelActiveConsumer.java

@@ -33,7 +33,7 @@ public class NovelActiveConsumer implements MessageListener<String, String> {
         executorNovel = new FlowExecutor<>(ctx, Rule.create().THEN("novel_setup").THEN("novel_prize").THEN("novel_store").THEN("novel_checkerfirst").SWITCH("novel_cross","novel_plan","novel_channel"));
     }
 
-    @KafkaListener(topics = {"${novel.active.consumer.topic:testNovelActive}"},groupId = "${novel.active.consumer.group.id:test_novel_dy_active}")
+    @KafkaListener(topics = {"${system.consumer.novel.active.topic}"},groupId = "${system.consumer.novel.active.group_id}")
     @Override
     public void onMessage(ConsumerRecord<String, String> data) {
 

src/main/java/com/lwby/marketing/att/novel/NovelUniversalProcess.java

 package com.lwby.marketing.att.novel;
 
 import com.alibaba.fastjson.JSONObject;
-import com.alicp.jetcache.anno.CacheRefresh;
-import com.alicp.jetcache.anno.CacheType;
-import com.alicp.jetcache.anno.Cached;
 import com.lwby.marketing.att.UniversalProcess;
 import com.lwby.marketing.vo.NovelAction;
 import com.lwby.marketing.vo.DeliveryDeviceInfo;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.dao.EmptyResultDataAccessException;
 import org.springframework.kafka.support.SendResult;
 import org.springframework.stereotype.Component;
 import org.springframework.util.concurrent.ListenableFuture;

src/main/resources/application-prod.yml

@@ -38,26 +38,20 @@ bi:
     host: r-2zethzp7pjl3rjbelp.redis.rds.aliyuncs.com
     port: 6379
 
-story:
-  novel:
-    active:
+
+system:
   consumer:
+    dystory:
+      active:
           topic: storyNovelActive
-        group:
-          id: story_dy_active
+          group_id: story_dy_active
       pay:
-      consumer:
           topic: storeNovelpay
-        group:
-          id: story_dy_pay
-
-
-novel:
+          group_id: story_dy_pay
+    novel:
       active:
-    consumer:
           topic: novelActive
-      group:
-        id: novel_dy_active
+          group_id: novel_dy_active
 
 management:
   health:

src/main/resources/application-test.yml

@@ -38,26 +38,19 @@ bi:
     host: 172.17.243.150
     port: 6379
 
-story:
-  novel:
-    active:
+system:
   consumer:
+    dystory:
+      active:
         topic: testStoryNovelActive
-        group:
-          id: test_story_dy_active
+        group_id: test_story_dy_active
       pay:
-      consumer:
         topic: testStoryNovelpay
-        group:
-          id: test_story_dy_pay
-
-
-novel:
+        group_id: test_story_dy_pay
+    novel:
       active:
-    consumer:
         topic: testNovelActive
-      group:
-        id: test_novel_dy_active
+        group_id: test_novel_dy_active
 
 management:
   health: