feature(*): 修复bug

- 修复bug

feature(*): 修复bug
- 修复bug
张志伟
1 parent 89bd2e6c
Showing 2 changed files with 3 additions and 2 deletions
fw-valhalla-server/src/main/resources/application-local.yml
fw-valhalla-service/src/main/java/cn/fw/valhalla/component/consumer/FollowResultConsumer.java
@@ -7,7 +7,7 @@ spring:
       preferred-networks:
         - 10.8
   application:
-    name: fw-valhalla
+    name: fw-valhalla-local
   datasource:
     hikari:
       connection-test-query: ''
@@ -2,6 +2,7 @@ package cn.fw.valhalla.component.consumer;
  
 import cn.fw.shirasawa.sdk.enums.DataTypeEnum;
 import cn.fw.shirasawa.sdk.mq.FollowResultDTO;
+import cn.fw.valhalla.common.constant.RedisKey;
 import cn.fw.valhalla.domain.db.follow.FollowClue;
 import cn.fw.valhalla.domain.enums.FollowTypeEnum;
 import cn.fw.valhalla.service.bus.follow.FollowBizService;
@@ -47,7 +48,7 @@ public class FollowResultConsumer implements RocketMQListener&lt;FollowResultDTO&gt; {
     }
  
     @Override
-    @CacheEvict(cacheNames = "rpc:user:follow-todo:count", key = "#dto.userId", beforeInvocation = true)
+    @CacheEvict(cacheNames = RedisKey.TODO_COUNT, key = "#dto.userId", beforeInvocation = true)
     public void onMessage(FollowResultDTO dto) {
         log.info("处理跟进结果MQ消息：{}", JSONObject.toJSONString(dto));
         try {