查看用户还有多少聊天时长

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/controller/MessageController.java

@@ -79,6 +79,13 @@ public class MessageController  extends BaseController{
         return messageService.insertUserMessage(messageVO,this.getUserLoginInfoFromRedis(request).getUserAccountId());
     }
 
+    @ApiOperation(value = "查看用户是否购买聊天")
+    @ApiResponses({@ApiResponse(code = 200, message = "OK", response = ResultBody.class)})
+    @PostMapping("/isPurchaseTime")
+    public ResultBody isPurchaseTime(HttpServletRequest request){
+        return messageService.isPurchaseTime(this.getUserLoginInfoFromRedis(request).getUserAccountId());
+    }
+
     @ApiOperation(value = "用户聊天详细信息")
     @ApiResponses({@ApiResponse(code = 200, message = "OK", response = ResultBody.class)})
     @PostMapping("/selectUserMessage")

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/MessageService.java

@@ -65,6 +65,16 @@ public interface MessageService {
      */
     ResultBody insertUserMessage(UserMessageVO messageVO,Integer senderUserId);
 
+
+    /**
+     * 查看用户是否购买聊天时长
+     * @param UserId
+     * @return {@link ResultBody}
+     */
+    ResultBody isPurchaseTime(Integer UserId);
+
+
+
     PageResult selectUserMessage(MessageUserQO messageQO,Integer senderUserId);
 
     ResultBody selectUserList(Integer senderUserId);

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/impl/MessageServiceImpl.java

@@ -178,6 +178,26 @@ public class MessageServiceImpl implements MessageService {
         return ResultBody.error("消息发送失败");
     }
 
+    /**
+     * 查看用户是否购买聊天时长
+     *
+     * @param UserId
+     * @return {@link ResultBody}
+     */
+    @Override
+    public ResultBody isPurchaseTime(Integer UserId) {
+        redisTemplate.setValueSerializer(RedisSerializer.json());
+        String s = redisTemplate.opsForValue().get("Message" + UserId);
+        if(s == null || s == ""){
+            return ResultBody.error("请先花费积分购买聊天时长");
+        }
+        Long seconds  = redisTemplate.getExpire("Message" + UserId, TimeUnit.SECONDS);
+        Date date = new Date(seconds * 1000); // 将秒数转换为毫秒
+        SimpleDateFormat sdf = new SimpleDateFormat("dd HH:mm:ss");
+        String formattedTime = sdf.format(date);
+        return ResultBody.success("还剩下：" + formattedTime);
+    }
+
     @Override
     public PageResult selectUserMessage(MessageUserQO messageQO,Integer senderUserId) {
         scheduledTaskUtil.destroy(senderUserId);