From d1cb75947e47e62f2eb35e4ad2cd017a8c825e03 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 12 Oct 2023 11:15:56 +0800
Subject: [PATCH] redbagprod

---
 src/main/java/cc/mrbird/febs/mall/service/impl/AdminChatServiceImpl.java |   87 ++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 80 insertions(+), 7 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 49a1b50..9f8f4e4 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
@@ -5,16 +5,14 @@
 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;
-import cc.mrbird.febs.mall.entity.ChatUser;
-import cc.mrbird.febs.mall.entity.MemberCoinWithdraw;
+import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.ChatAmountFlowMapper;
+import cc.mrbird.febs.mall.mapper.ChatGroupMapper;
 import cc.mrbird.febs.mall.mapper.ChatUserMapper;
+import cc.mrbird.febs.mall.mapper.DataDictionaryMapper;
 import cc.mrbird.febs.mall.service.IAdminChatService;
-import cc.mrbird.febs.mall.vo.AdminChatAmountFlowVo;
-import cc.mrbird.febs.mall.vo.AdminChatCahrgeVo;
-import cc.mrbird.febs.mall.vo.AdminChatUserVo;
-import cc.mrbird.febs.mall.vo.AdminChatWithDrawVo;
+import cc.mrbird.febs.mall.vo.*;
+import cc.mrbird.febs.rabbit.producter.AgentProducer;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -35,6 +33,9 @@
 public class AdminChatServiceImpl extends ServiceImpl<ChatUserMapper, ChatUser> implements IAdminChatService {
 
     private final ChatAmountFlowMapper chatAmountFlowMapper;
+    private final DataDictionaryMapper dataDictionaryMapper;
+    private final ChatGroupMapper chatGroupMapper;
+    private final AgentProducer agentProducer;
     private final RedisUtils redisUtils;
 
     @Override
@@ -179,4 +180,76 @@
         return new FebsResponse().success();
     }
 
+    @Override
+    public void updateDataDic(String type, String code, String modelType) {
+        DataDictionary dic = this.baseMapper.selectDicDataByTypeAndCode(type, code);
+        if (dic != null) {
+            dic.setValue(modelType);
+            dataDictionaryMapper.updateById(dic);
+        }
+    }
+
+    @Override
+    public IPage<AdminGroupVo> getGroupList(ChatUser chatUser, QueryRequest request) {
+        Page<AdminGroupVo> page = new Page<>(request.getPageNum(), request.getPageSize());
+        return this.baseMapper.selectGroupListInPage(page, chatUser);
+    }
+
+    @Override
+    public FebsResponse closeSwitchUseRobot(String id) {
+        this.baseMapper.updateIsRobotByGroupId(id,0);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse openSwitchUseRobot(String id) {
+        this.baseMapper.updateIsRobotByGroupId(id,1);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse updateGroupInfo(AdminGroupInfoVo adminGroupInfoVo) {
+        ChatGroup chatGroup = chatGroupMapper.selectById(adminGroupInfoVo.getId());
+        if(ObjectUtil.isEmpty(chatGroup)) {
+            return new FebsResponse().fail().message("信息不存在");
+        }
+        chatGroup.setAmountMin(adminGroupInfoVo.getAmountMin());
+        chatGroup.setAmountMax(adminGroupInfoVo.getAmountMax());
+        chatGroup.setRedBagCnt(adminGroupInfoVo.getRedBagCnt());
+        chatGroup.setModelType(adminGroupInfoVo.getModelType());
+        chatGroupMapper.updateById(chatGroup);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse registerMember() {
+        agentProducer.sendAddRobotMsg("20845477");
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse openModelType(String userId) {
+        ChatUser chatUser = this.baseMapper.selectByUserId(userId);
+        if(ObjectUtil.isEmpty(chatUser)) {
+            return new FebsResponse().fail().message("会员信息不存在");
+        }
+        this.baseMapper.updateModelTypeByUserId(userId,1);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse closeModelType(String userId) {
+        ChatUser chatUser = this.baseMapper.selectByUserId(userId);
+        if(ObjectUtil.isEmpty(chatUser)) {
+            return new FebsResponse().fail().message("会员信息不存在");
+        }
+        this.baseMapper.updateModelTypeByUserId(userId,2);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse updateRegisterMember(AdminRegisterMemberVo adminRegisterMemberVo) {
+        agentProducer.sendAddRobotMsg(adminRegisterMemberVo.getInviteId());
+        return new FebsResponse().success();
+    }
 }

--
Gitblit v1.9.1