feature(*): 添加缓存

- 添加缓存

feature(*): 添加缓存
- 添加缓存
张志伟
1 parent 97e9f0cc
Showing 3 changed files with 6 additions and 0 deletions
fw-valhalla-rpc/src/main/java/cn/fw/valhalla/rpc/shirasawa/ShirasawaRpcService.java
fw-valhalla-server/src/main/resources/application.yml
fw-valhalla-service/src/main/java/cn/fw/valhalla/component/consumer/FollowResultConsumer.java
@@ -13,6 +13,7 @@ import cn.fw.valhalla.rpc.shirasawa.dto.FollowInitDTO;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
  
 import java.time.LocalDate;
@@ -124,6 +125,7 @@ public class ShirasawaRpcService {
      * @param userId
      * @return
      */
+    @Cacheable(cacheNames = "rpc:user:follow-todo:count", key = "#userId", condition = "#result!=null")
     public Boolean hasOngoingFollow(Long userId) {
         try {
             if (Objects.isNull(userId)) {
@@ -21,6 +21,8 @@ spring:
           ttl: 10m
         - name: rpc:mkt:qualification
           ttl: 30m
+        - name: rpc:user:follow-todo:count
+          ttl: 30m
  
   cloud:
     nacos:
@@ -12,6 +12,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.stereotype.Component;
  
 import java.util.HashSet;
@@ -45,6 +46,7 @@ public class FollowResultConsumer implements RocketMQListener&lt;FollowResultDTO&gt; {
     }
  
     @Override
+    @CacheEvict(cacheNames = "rpc:user:follow-todo:count", key = "#dto.userId")
     public void onMessage(FollowResultDTO dto) {
         log.info("处理跟进结果MQ消息：{}", JSONObject.toJSONString(dto));
         try {