缓存 bugfix

community-service/src/main/java/com/tanpu/community/dao/entity/community/CommentEntity.java

 package com.tanpu.community.dao.entity.community;
 
-import com.baomidou.mybatisplus.annotation.TableName;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
-import java.time.LocalDateTime;
-import java.io.Serializable;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
+import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.NoArgsConstructor;
 
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
 /**
  * <p>
  * 评论
@@ -59,8 +64,12 @@ public class CommentEntity implements Serializable {
     @ApiModelProperty(value = "举报状态 0：未被举报  1:被举报 2：已处理")
     private Integer reportStatus;
 
+    @JsonDeserialize(using = LocalDateTimeDeserializer.class)
+    @JsonSerialize(using = LocalDateTimeSerializer.class)
     private LocalDateTime createTime;
 
+    @JsonDeserialize(using = LocalDateTimeDeserializer.class)
+    @JsonSerialize(using = LocalDateTimeSerializer.class)
     private LocalDateTime updateTime;
 
     private Integer deleteTag;

community-service/src/main/java/com/tanpu/community/manager/CommentManager.java

@@ -73,12 +73,8 @@ public class CommentManager {
         for (CommentQo commentQo : commentQos) {
             //查询用户信息
             String authorId = commentQo.getAuthorId();
-            CommonResp<UserInfoNew> userInfoNewCommonResp = redisCache.getObject(StringUtils.joinWith(CACGE_FEIGN_USER_INFO, authorId),
-                    60 * 10, () -> feignClientForFatools.queryUsersListNew(authorId), CommonResp.class);
-            if (userInfoNewCommonResp.isNotSuccess()) {
-                throw new BizException("内部接口调用失败");
-            }
-            UserInfoNew userInfo = userInfoNewCommonResp.getData();
+            UserInfoNew userInfo = redisCache.getObject(StringUtils.joinWith(CACGE_FEIGN_USER_INFO, authorId),
+                    60 * 10, () ->this.getUserInfo(authorId) , UserInfoNew.class);
             if (userInfo != null) {
                 commentQo.setUserImg(userInfo.getHeadImageUrl());
                 commentQo.setNickName(userInfo.getNickName());
@@ -101,6 +97,14 @@ public class CommentManager {
                 .collect(Collectors.toList());
     }
 
+    private UserInfoNew getUserInfo(String authorId){
+        CommonResp<UserInfoNew> userInfoNewCommonResp = feignClientForFatools.queryUsersListNew(authorId);
+        if (userInfoNewCommonResp.isNotSuccess()) {
+            throw new BizException("内部接口调用失败");
+        }
+        return userInfoNewCommonResp.getData();
+    }
+
     //点赞评论/取消点赞
     public void likeComment(LikeCommentReq req, String userId) {
         if (OperationTypeEnum.CONFIRM.getCode().equals(req.getType())) {