1

gx_api/GxPress/Repository/GxPress.Repository.Implement/GroupChatUserRepository.cs

@@ -245,5 +245,20 @@ namespace GxPress.Repository.Implement
                 .QueryAsync<int>(sql);
             return items;
         }
+        /// <summary>
+        /// 获取用户加入的群聊用户人数
+        /// </summary>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        public async Task<int> GetUserIntoGroupChatUserCountAsync(int userId)
+        {
+            string sql = $"select count(1) from tede_group_chat_user where GroupChatId in(select GroupChatId from tede_group_chat_user where UserId={userId})";
+            var databaseType = StringUtils.ToEnum<DatabaseType>(_databaseTypeStr, DatabaseType.MySql);
+            var database = new Database(databaseType, _connectionString);
+            var connection = database.GetConnection();
+            var result = await connection
+                .ExecuteScalarAsync<int>(sql);
+            return result;
+        }
     }
 }

gx_api/GxPress/Repository/GxPress.Repository.Implement/GroupUserRepository.cs

@@ -1,7 +1,5 @@
 using System;
 using System.Collections.Generic;
-using System.Linq;
-using System.Text;
 using System.Threading.Tasks;
 using AutoMapper;
 using GxPress.Common.AppOptions;
@@ -11,7 +9,6 @@ using GxPress.Entity;
 using GxPress.EnumConst;
 using GxPress.Repository.Interface;
 using GxPress.Request.App.GroupUser;
-using GxPress.Request.App.Middle;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Options;
 using SqlKata;
@@ -158,5 +155,19 @@ namespace GxPress.Repository.Implement
             var result = await connection.QueryAsync<int>(sql);
             return result;
         }
+        /// <summary>
+        /// 获取用户加入小组的人数
+        /// </summary>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        public async Task<int> GetUserIntoGroupUserCountAsync(int userId)
+        {
+            string sql = $"select count(1) from tede_group_user where GroupId in(select groupId from tede_group_user where userId={userId})";
+            var databaseType = StringUtils.ToEnum<DatabaseType>(_databaseTypeStr, DatabaseType.MySql);
+            var database = new Database(databaseType, _connectionString);
+            var connection = database.GetConnection();
+            var result = await connection.ExecuteScalarAsync<int>(sql);
+            return result;
+        }
     }
 }

gx_api/GxPress/Repository/GxPress.Repository.Interface/IGroupChatUserRepository.cs

@@ -69,5 +69,11 @@ namespace GxPress.Repository.Interface
         /// <returns></returns>
         Task<bool> InsertAsync(List<GroupChatUser> groupChatUsers);
         Task<IEnumerable<int>> GetUserIdsAsync(int userId);
+        /// <summary>
+        /// 获取用户加入的群聊用户人数
+        /// </summary>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+       Task<int> GetUserIntoGroupChatUserCountAsync(int userId);
     }
 }

gx_api/GxPress/Repository/GxPress.Repository.Interface/IGroupUserRepository.cs

@@ -42,6 +42,12 @@ namespace GxPress.Repository.Interface
         /// </summary>
         /// <param name="userId"></param>
         /// <returns></returns>
-       Task<IEnumerable<int>> GetGroupUserByUserIdAsync(int userId);
+        Task<IEnumerable<int>> GetGroupUserByUserIdAsync(int userId);
+        /// <summary>
+        /// 获取用户加入小组的人数
+        /// </summary>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        Task<int> GetUserIntoGroupUserCountAsync(int userId);
     }
 }

gx_api/GxPress/Service/GxPress.Service.Implement/UserService.cs

@@ -19,7 +19,6 @@ using Datory;
 using GxPress.Common.Tools;
 using GxPress.Result.App.User;
 using GxPress.Repository.Interface.WorkFlow;
-using GxPress.EnumConst;
 using GxPress.Request.App.Flow;
 using GxPress.Repository.Interface.WaitHandle;
 using GxPress.Request.AddressBookGroup;
@@ -400,15 +399,22 @@ namespace GxPress.Service.Implement
                     Items = userLinkModelAttributeResult
                 });
             }
-            //系统通讯录
+            //系统通讯录  查询我的小组和群聊
+            //var groupUserCount=await 
             userLinkResult.Add(
               new UserLinkModelResult
               {
                   TypeId = 2,
                   Name = "系统通讯录",
                   Items = new List<UserLinkModelAttributeResult>{
-                        new UserLinkModelAttributeResult{Id=0,Name="我的小组",TypeValue=1},
-                        new UserLinkModelAttributeResult{Id=0,Name="我的群聊",TypeValue=2},
+                        new UserLinkModelAttributeResult{Id=0,Name="我的小组"
+                        ,TypeValue=1
+                        ,UserCount=await groupUserRepository.GetUserIntoGroupUserCountAsync(userId)
+                        },
+                        new UserLinkModelAttributeResult{Id=0
+                        ,Name="我的群聊"
+                        ,TypeValue=2
+                        ,UserCount=await groupChatUserRepository.GetUserIntoGroupChatUserCountAsync(userId)},
                         //new UserLinkModelAttributeResult{Id=0,Name="我的课程",TypeValue=3}
                   }
               }