From bad4cadc4c4bc735e97247918a0555bfc1278798 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 24 Oct 2023 17:19:08 +0800
Subject: [PATCH] 版本管理

---
 src/main/java/cc/mrbird/febs/mall/service/impl/AdminChatServiceImpl.java |   98 +++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 94 insertions(+), 4 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 3c01c3c..286ef51 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
@@ -6,12 +6,10 @@
 import cc.mrbird.febs.mall.YesOrNoEnum;
 import cc.mrbird.febs.mall.dto.AdminSystemPayDto;
 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.mapper.*;
 import cc.mrbird.febs.mall.service.IAdminChatService;
 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;
@@ -34,6 +32,8 @@
     private final ChatAmountFlowMapper chatAmountFlowMapper;
     private final DataDictionaryMapper dataDictionaryMapper;
     private final ChatGroupMapper chatGroupMapper;
+    private final ChatVersionMapper chatVersionMapper;
+    private final AgentProducer agentProducer;
     private final RedisUtils redisUtils;
 
     @Override
@@ -194,6 +194,12 @@
     }
 
     @Override
+    public IPage<AdminVersionVo> getVersionList(ChatUser chatUser, QueryRequest request) {
+        Page<AdminVersionVo> page = new Page<>(request.getPageNum(), request.getPageSize());
+        return this.baseMapper.selectVersionListInPage(page, chatUser);
+    }
+
+    @Override
     public FebsResponse closeSwitchUseRobot(String id) {
         this.baseMapper.updateIsRobotByGroupId(id,0);
         return new FebsResponse().success();
@@ -218,4 +224,88 @@
         chatGroupMapper.updateById(chatGroup);
         return new FebsResponse().success();
     }
+
+    @Override
+    public FebsResponse updateVersionInfo(AdminVersionVo adminVersionVo) {
+        ChatVersion chatVersion = chatVersionMapper.selectById(adminVersionVo.getId());
+        if(ObjectUtil.isEmpty(chatVersion)) {
+            return new FebsResponse().fail().message("信息不存在");
+        }
+        chatVersion.setVersion(adminVersionVo.getVersion());
+        chatVersion.setContent(adminVersionVo.getContent());
+        chatVersion.setUrl(adminVersionVo.getUrl());
+        chatVersion.setDescr(adminVersionVo.getDescr());
+        chatVersionMapper.updateById(chatVersion);
+        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();
+    }
+
+    @Override
+    public FebsResponse openSwitchAutoSend(String id) {
+        this.baseMapper.updateAutoSendByGroupId(id,1);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse closeSwitchAutoSend(String id) {
+        this.baseMapper.updateAutoSendByGroupId(id,0);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public IPage<AdminRedBagVo> getRedBagList(ChatUser chatUser, QueryRequest request) {
+        Page<AdminRedBagVo> page = new Page<>(request.getPageNum(), request.getPageSize());
+        return this.baseMapper.selectRedBagListInPage(page, chatUser);
+    }
+
+    @Override
+    public FebsResponse openCreateGroup(String userId) {
+        ChatUser chatUser = this.baseMapper.selectByUserId(userId);
+        if(ObjectUtil.isEmpty(chatUser)) {
+            return new FebsResponse().fail().message("会员信息不存在");
+        }
+        this.baseMapper.updateCreateGroupByUserId(userId,1);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse closeCreateGroup(String userId) {
+        ChatUser chatUser = this.baseMapper.selectByUserId(userId);
+        if(ObjectUtil.isEmpty(chatUser)) {
+            return new FebsResponse().fail().message("会员信息不存在");
+        }
+        this.baseMapper.updateCreateGroupByUserId(userId,0);
+        return new FebsResponse().success();
+    }
 }

--
Gitblit v1.9.1