From 6a99e83107428159d321c1b77cb994e0b2f92fe5 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 10 Oct 2023 10:25:05 +0800
Subject: [PATCH] redbagprod

---
 src/main/java/cc/mrbird/febs/mall/service/impl/AdminChatServiceImpl.java |   31 +++++++++++++++++++++++++++++++
 1 files changed, 31 insertions(+), 0 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AdminChatServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AdminChatServiceImpl.java
index 6e218ca..49a1b50 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/AdminChatServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AdminChatServiceImpl.java
@@ -2,6 +2,7 @@
 
 import cc.mrbird.febs.common.entity.FebsResponse;
 import cc.mrbird.febs.common.entity.QueryRequest;
+import cc.mrbird.febs.common.utils.RedisUtils;
 import cc.mrbird.febs.mall.YesOrNoEnum;
 import cc.mrbird.febs.mall.dto.AdminSystemPayDto;
 import cc.mrbird.febs.mall.entity.ChatAmountFlow;
@@ -23,6 +24,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.StringUtils;
 
 import java.math.BigDecimal;
 
@@ -33,6 +35,7 @@
 public class AdminChatServiceImpl extends ServiceImpl<ChatUserMapper, ChatUser> implements IAdminChatService {
 
     private final ChatAmountFlowMapper chatAmountFlowMapper;
+    private final RedisUtils redisUtils;
 
     @Override
     public IPage<AdminChatUserVo> getUserList(ChatUser chatUser, QueryRequest request) {
@@ -58,6 +61,14 @@
             return new FebsResponse().fail().message("会员信息不存在");
         }
         this.baseMapper.updateStatusByUserId(userId,YesOrNoEnum.NO.getCode());
+        if (chatUser != null) {
+            // 清理token
+            String token = chatUser.getToken();
+            if (!StringUtils.isEmpty(token)) {
+                String TOKEN_REDIS_APP = "token:app:";
+                redisUtils.del(TOKEN_REDIS_APP + token);
+            }
+        }
         return new FebsResponse().success();
     }
 
@@ -148,4 +159,24 @@
         return new FebsResponse().success();
     }
 
+    @Override
+    public FebsResponse openSwitchIsRobot(String userId) {
+        ChatUser chatUser = this.baseMapper.selectByUserId(userId);
+        if(ObjectUtil.isEmpty(chatUser)) {
+            return new FebsResponse().fail().message("会员信息不存在");
+        }
+        this.baseMapper.updateIsRobotByUserId(userId,1);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse closeSwitchIsRobot(String userId) {
+        ChatUser chatUser = this.baseMapper.selectByUserId(userId);
+        if(ObjectUtil.isEmpty(chatUser)) {
+            return new FebsResponse().fail().message("会员信息不存在");
+        }
+        this.baseMapper.updateIsRobotByUserId(userId,0);
+        return new FebsResponse().success();
+    }
+
 }

--
Gitblit v1.9.1