删除评论时删除消息通知

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

@@ -140,7 +140,7 @@ public class NotificationManager {
         redisCache.evict(RedisKeyConstant.MESSAGE_NOTIFY_COUNT + userId);
         // 更新查询时间，用于删除评论
         redisCache.set(RedisKeyConstant.MESSAGE_NOTIFY_QUERY_TIME + userId,
-                String.valueOf(TimeUtils.calMillisTillNow(LocalDateTime.now())),60 * 60 * 24 * 30);
+                JsonUtil.toJson(LocalDateTime.now()),60 * 60 * 24 * 30);
 
         return themeNotifyQos;
     }

community-service/src/main/java/com/tanpu/community/service/NotificationService.java

@@ -230,9 +230,10 @@ public class NotificationService {
         }
 
         // 处理更新数量
-        LocalDateTime lastQueryTime =JsonUtil.toBean(redisCache.get(RedisKeyConstant.MESSAGE_NOTIFY_QUERY_TIME + notifyUserId),LocalDateTime.class);
+        String lastTime = redisCache.get(RedisKeyConstant.MESSAGE_NOTIFY_QUERY_TIME + notifyUserId);
+        LocalDateTime lastQueryTime =StringUtils.isNotBlank(lastTime)?JsonUtil.toBean(lastTime,LocalDateTime.class):LocalDateTime.now();
         // 如果删除的评论时时间在红点提示时间内，则缓存数-1
-        if (!TimeUtils.lessThan(lastQueryTime, commentTime)) {
+        if (StringUtils.isBlank(lastTime) || TimeUtils.lessThan(lastQueryTime, commentTime)) {
             redisCache.decr(RedisKeyConstant.MESSAGE_NOTIFY_COUNT + notifyUserId);
         }
     }