修改配置文件

2.全员观看重复调用，只通知，不写入redis

WGShare.API/AntDeploy.json

@@ -24,13 +24,23 @@
       "LinuxServerList": [
         {
           "UserName": "marking",
-          "Pwd": "0610DBF49053E6779393A74BE1ED4FD2",
+          "Pwd": "CE09921E2AD09E56095579DF1F7C614B",
           "Host": "47.109.67.254:10022",
           "NickName": "marking001",
           "IIsFireUrl": null,
           "DockerFireUrl": "",
           "WindowsServiceFireUrl": null,
           "LinuxServiceFireUrl": null
+        },
+        {
+          "UserName": "marking",
+          "Pwd": "CE09921E2AD09E56095579DF1F7C614B",
+          "Host": "47.109.193.53:10022",
+          "NickName": "meeting",
+          "IIsFireUrl": null,
+          "DockerFireUrl": "",
+          "WindowsServiceFireUrl": null,
+          "LinuxServiceFireUrl": null
         }
       ],
       "IgnoreList": [],
@@ -115,11 +125,11 @@
   "DockerConfig": {
     "Prot": "5192:5192",
     "AspNetCoreEnv": "",
-    "LastEnvName": "29dev",
+    "LastEnvName": "marking001",
     "RemoveDaysFromPublished": "10",
     "WorkDir": "",
     "Volume": "",
-    "Other": "--name wgshare-api -e ASPNETCORE_ENVIRONMENT=Development  -e TZ=Asia/Shanghai",
+    "Other": "--name wgshare-api -e ASPNETCORE_ENVIRONMENT=Production  -e TZ=Asia/Shanghai",
     "EnvPairList": [
       {
         "EnvName": "29dev",

WGShare.API/Controllers/AuthController.cs

@@ -51,6 +51,27 @@ namespace WGShare.API.Controllers
             return await _sqlSugar.Queryable<User>().AnyAsync(x => x.IsDelete == false && x.Account == account && x.IsAnonymous == false);
         }
 
+        /// <summary>
+        /// 检查用户是否在线
+        /// </summary>
+        /// <param name="account"></param>
+        /// <returns></returns>
+        [HttpGet("check-online"), AllowAnonymous]
+        public async Task<bool> CheckUserOnline([FromQuery] string account)
+        { 
+            var user = await _sqlSugar.Queryable<User>().FirstAsync(x => x.IsDelete == false && x.Account == account && x.IsAnonymous == false);
+            if (user == null)
+            {
+                return false;
+            }
+            var connectId = RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetOnlineUserKey(user.TenantId), user.Id);
+            if (!string.IsNullOrWhiteSpace(connectId))
+            {
+                return true;
+            }
+            return false;
+        }
+
         /// <summary>
         /// 正常账号登录
         /// </summary>
@@ -94,6 +115,7 @@ namespace WGShare.API.Controllers
             btnAutn.Add(new Claim("ssid", user.ScreenShareId));
             btnAutn.Add(new Claim("year", user.Year.ToString()));
             btnAutn.Add(new Claim("subject", ((int)user.Subject).ToString()));
+            btnAutn.Add(new Claim("anonymous", user.IsAnonymous ? "1" : "0"));
 
             // 获取已登录的token
             var tokens = RedisHelper.Instance.Get<AccessAndRefreshToken>(RedisKeyConstant.Data.GetAccessTokenKey(user.Id));
@@ -107,7 +129,7 @@ namespace WGShare.API.Controllers
                     pipe.Del(RedisKeyConstant.Data.GetRefreshTokenKey(tokens.RefreshToken));
                 }
                 // 设置新的刷新token
-                pipe.Set(RedisKeyConstant.Data.GetRefreshTokenKey(refreshToken), user, TimeSpan.FromDays(7).TotalSeconds.ToInt32());
+                pipe.Set(RedisKeyConstant.Data.GetRefreshTokenKey(refreshToken), user, TimeSpan.FromDays(360).TotalSeconds.ToInt32());
                 // 记录accessToken
                 pipe.Set(RedisKeyConstant.Data.GetAccessTokenKey(user.Id), new AccessAndRefreshToken
                 {
@@ -169,13 +191,14 @@ namespace WGShare.API.Controllers
             btnAutn.Add(new Claim("ssid", user.ScreenShareId));
             btnAutn.Add(new Claim("year", user.Year.ToString()));
             btnAutn.Add(new Claim("subject", ((int)user.Subject).ToString()));
+            btnAutn.Add(new Claim("anonymous", user.IsAnonymous ? "1" : "0"));
 
             var accessToken = _jwtHelper.CreateToken(user.Id, btnAutn);
             var refreshTokenNew = Guid.NewGuid().ToString();
             using (var pipe = RedisHelper.Instance.StartPipe())
             {
                 pipe.Del(RedisKeyConstant.Data.GetRefreshTokenKey(refreshToken));
-                pipe.Set(RedisKeyConstant.Data.GetRefreshTokenKey(refreshTokenNew), user, TimeSpan.FromDays(7).TotalSeconds.ToInt32());
+                pipe.Set(RedisKeyConstant.Data.GetRefreshTokenKey(refreshTokenNew), user, TimeSpan.FromDays(360).TotalSeconds.ToInt32());
                 pipe.Set(RedisKeyConstant.Data.GetAccessTokenKey(user.Id), new AccessAndRefreshToken
                 {
                     AccessToken = accessToken,
@@ -251,10 +274,10 @@ namespace WGShare.API.Controllers
                 }
 
                 // 修改用户名
-               await _sqlSugar.Updateable<User>()
+                await _sqlSugar.Updateable<User>()
-                    .SetColumns(x => x.UserName == loginDTO.NickName)
+                     .SetColumns(x => x.UserName == loginDTO.NickName)
-                    .Where(x => x.Id == user.Id)
+                     .Where(x => x.Id == user.Id)
-                    .ExecuteCommandHasChangeAsync(); 
+                     .ExecuteCommandHasChangeAsync();
             }
 
             var btnAutn = new List<Claim>();
@@ -264,11 +287,12 @@ namespace WGShare.API.Controllers
             btnAutn.Add(new Claim("account", user.Account));
             btnAutn.Add(new Claim("uname", loginDTO.NickName));
             btnAutn.Add(new Claim("ssid", user.ScreenShareId));
+            btnAutn.Add(new Claim("anonymous", user.IsAnonymous ? "1" : "0"));
 
             var accessToken = _jwtHelper.CreateToken(user.Id, btnAutn);
             return Ok(new
             {
-                perms = "0",
+                perms = 0,
                 token = accessToken,
                 refresh_token = "",
                 roleId = user.RoleId,

WGShare.API/Controllers/Basic/BasicController.cs

@@ -58,7 +58,7 @@ namespace WGShare.API.Controllers.Basic
         {
             get
             {
-                var roleId = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "roleid").Value;
+                var roleId = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "roleid")?.Value;
                 if (string.IsNullOrWhiteSpace(roleId) || !int.TryParse(roleId, out int role) || role == 0)
                 {
                     throw Oops.Oh("用户信息有误，请重新登录");
@@ -72,7 +72,7 @@ namespace WGShare.API.Controllers.Basic
         {
             get
             {
-                var tenant = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "tenant").Value;
+                var tenant = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "tenant")?.Value;
                 if (string.IsNullOrWhiteSpace(tenant))
                 {
                     throw Oops.Oh("用户信息有误，请重新登录");
@@ -85,7 +85,7 @@ namespace WGShare.API.Controllers.Basic
         {
             get
             {
-                var ssId = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "ssid").Value;
+                var ssId = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "ssid")?.Value;
                 if (string.IsNullOrWhiteSpace(ssId))
                 {
                     throw Oops.Oh("用户信息有误，请重新登录");
@@ -121,7 +121,7 @@ namespace WGShare.API.Controllers.Basic
                     return year;
                 }
 
-                var year_str = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "year").Value;
+                var year_str = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "year")?.Value;
                 if (string.IsNullOrWhiteSpace(year_str) || !int.TryParse(year_str, out year))
                 {
                     throw Oops.Oh("用户信息有误，请重新登录");
@@ -140,7 +140,7 @@ namespace WGShare.API.Controllers.Basic
                     return (SubjectType)subject;
                 }
 
-                var subject_str = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "subject").Value;
+                var subject_str = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "subject")?.Value;
                 if (string.IsNullOrWhiteSpace(subject_str) || !int.TryParse(subject_str, out subject))
                 {
                     throw Oops.Oh("用户信息有误，请重新登录");
@@ -149,5 +149,25 @@ namespace WGShare.API.Controllers.Basic
             }
         }
 
+        /// <summary>
+        /// 匿名用户
+        /// </summary>
+        public bool IsAnonymous
+        {
+            get
+            {
+                if (!HttpContext.User.Identity.IsAuthenticated)
+                {
+                    return true;
+                }
+                var anonymous_str = HttpContext.User.Claims.FirstOrDefault(x => x.Type == "anonymous")?.Value;
+                if (string.IsNullOrWhiteSpace(anonymous_str) || !int.TryParse(anonymous_str, out int anonymous))
+                {
+                    return false;
+                }
+                return anonymous == 1;
+            }
+        }
+
     }
 }

WGShare.API/Controllers/Frontend/AgoraCallbackController.cs

@@ -165,9 +165,18 @@ namespace WGShare.API.Controllers.Frontend
                 return;
             }
 
-            if(existsChannel.TryAdd(eventBody.payload.channelName, 0))
+            if (existsChannel.TryAdd(eventBody.payload.channelName, 0))
             {
-                ExceptionNotice.JoinAsync(eventBody);
+                var roomInfo = await _sqlSugarClient.Queryable<Room>()
+                    .LeftJoin<Tenant>((r, t) => r.TenantId == t.Id)
+                    .Where((r, t) => r.RoomNum == eventBody.payload.channelName)
+                    .Select((r, t) => new Room
+                    {
+                        Id = r.Id.SelectAll(),
+                        TenantName = t.TenantName
+                    })
+                    .FirstAsync(); 
+                ExceptionNotice.JoinAsync(eventBody, roomInfo);
             }
 
         }

WGShare.API/Controllers/Frontend/HomeController.cs

@@ -1,5 +1,6 @@
 using AgoraIO.Media;
 using AgoraIO.Rtm;
+using Azure;
 using Mapster;
 using Masuit.Tools;
 using Microsoft.AspNetCore.Mvc;
@@ -7,11 +8,15 @@ using MiniExcelLibs;
 using MiniExcelLibs.Attributes;
 using MiniExcelLibs.OpenXml;
 using SqlSugar;
+using SqlSugar.Extensions;
 using System.IO;
+using System.Net.Http.Headers;
 using System.Text.RegularExpressions;
 using WGShare.API.Controllers.Basic;
 using WGShare.API.Helpers;
 using WGShare.Domain.Constant;
+using WGShare.Domain.DTOs.Home;
+using WGShare.Domain.DTOs.MiniProgram;
 using WGShare.Domain.DTOs.Room;
 using WGShare.Domain.Entities;
 using WGShare.Domain.Enums;
@@ -35,6 +40,7 @@ namespace WGShare.API.Controllers.Frontend
         private readonly AgoraHelper _agoraHelper;
         private readonly ILogger<HomeController> _logger;
         private readonly OssHelper _ossHelper;
+        private readonly MiniProgramHelper _miniProgramHelper;
 
         public HomeController(
             ISqlSugarClient sqlSugar,
@@ -42,7 +48,8 @@ namespace WGShare.API.Controllers.Frontend
             IHttpClientFactory httpClientFactory,
             AgoraHelper agoraHelper,
             ILogger<HomeController> logger,
-            OssHelper ossHelper)
+            OssHelper ossHelper,
+            MiniProgramHelper miniProgramHelper)
         {
             _sqlSugar = sqlSugar;
             this._configuration = configuration;
@@ -50,6 +57,7 @@ namespace WGShare.API.Controllers.Frontend
             this._agoraHelper = agoraHelper;
             this._logger = logger;
             this._ossHelper = ossHelper;
+            this._miniProgramHelper = miniProgramHelper;
         }
 
 
@@ -83,7 +91,7 @@ namespace WGShare.API.Controllers.Frontend
                 //}
             }
 
-            return PagedResult<RoomOutputDTO>.Create(result, total.Value);
+            return PagedResult<RoomOutputDTO>.Create(result, total.Value, dto.PageSize);
         }
 
         /// <summary>
@@ -103,7 +111,9 @@ namespace WGShare.API.Controllers.Frontend
             entity.Id = YitIdHelper.NextId().ToString();
             entity.TenantId = TenantId;
 
-            if (await _sqlSugar.Queryable<Room>().AnyAsync(x => x.RoomNum == inputDTO.RoomNum))
+
+            var room = await _sqlSugar.Queryable<Room>().FirstAsync(x => x.RoomNum == inputDTO.RoomNum);
+            if (room != null)
             {
                 throw Oops.Oh("无效会议号,请重新输入");
             }
@@ -121,7 +131,7 @@ namespace WGShare.API.Controllers.Frontend
         {
             var entity = inputDTO.Adapt<Room>();
             return await _sqlSugar.Updateable(entity)
-               .UpdateColumns(x => new { x.Year, x.Subject })
+               .UpdateColumns(x => new { x.Year, x.Subject, x.RoomName, x.AllowAnonymous })
                .ExecuteCommandHasChangeAsync();
         }
 
@@ -291,5 +301,87 @@ namespace WGShare.API.Controllers.Frontend
             _ossHelper.UploadWithExpireTime(fileName, stream, 10);
             return _ossHelper.GetAccessFileUrl(fileName, 5);
         }
+
+        /// <summary>
+        /// 获取房间二维码（缓存10mins）
+        /// </summary>
+        /// <param name="roomNum"></param>
+        /// <returns></returns>
+        [HttpGet("r-qrcode")]
+        public async Task<string> GetMiniProgramQrCode([FromQuery] string roomNum, [FromQuery] string env = "release")
+        {
+            var img = RedisHelper.Instance.Get(RedisKeyConstant.WxMiniProgram.GetRoomQrCode(roomNum, env));
+            if (!string.IsNullOrWhiteSpace(img))
+            {
+                return img;
+            }
+
+            var httpClient = _httpClientFactory.CreateClient();
+            var accessToken = await _miniProgramHelper.GetAccessToken();
+
+            var result = await httpClient.PostAsync($@"https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token={accessToken}", new StringContent(new wxacodeunlimitBody
+            {
+                page = "pages/form/index",
+                scene = ("r=" + roomNum),
+                check_path = true,
+                env_version = env,
+                width = 280
+            }.ToJsonString()));
+            if (result == null || !result.IsSuccessStatusCode)
+            {
+                _logger.LogError($@"二维码生成失败,statusCode:{(int)result.StatusCode},content:{await result.Content.ReadAsStringAsync()}");
+                throw Oops.Oh("二维码生成失败！");
+            }
+            var contentType = result.Content.Headers.ContentType?.MediaType;
+            // 如果是图片类型
+            if (contentType != null && contentType.StartsWith("image/"))
+            {
+                // 处理图片数据
+                var imageArr = await result.Content.ReadAsByteArrayAsync();
+                var imgStr = Convert.ToBase64String(imageArr);
+
+                imgStr = QrCodeOptimizerHelper.CompressImage(imgStr, 50);
+                RedisHelper.Instance.Set(RedisKeyConstant.WxMiniProgram.GetRoomQrCode(roomNum, env), imgStr, TimeSpan.FromDays(1));
+                return imgStr;
+            }
+            else if (contentType != null && contentType.Contains("json"))
+            {
+                var apiResult = await result.Content.ReadFromJsonAsync<WxMiniProgramBaseApiResult>();
+                if (apiResult != null)
+                {
+                    _logger.LogError($"二维码生成失败,errorCode:{apiResult.errorcode},errmsg:{apiResult.errmsg}");
+                    throw Oops.Oh("二维码生成失败");
+                }
+            }
+            _logger.LogError("返回 ContentType 未命中");
+            throw Oops.Oh("二维码生成失败");
+        }
+
+        /// <summary>
+        /// 反馈打分
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost("feedback")]
+        public async Task FeedbackScoring([FromBody] FeedBackRequset requset)
+        {
+            var entity = requset.Adapt<FeedbackIssue>();
+            entity.UID = UId.ToInt64();
+            entity.Types = string.Join(",", requset.Types);
+
+            await _sqlSugar.Insertable(entity).ExecuteCommandAsync();
+        }
+
+        /// <summary>
+        /// 记录用户当前用户版本
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost("ver-log")]
+        public async Task RecordVersionLog([FromBody] UserVersionLogDto userVersionLog)
+        {
+            var uvl = userVersionLog.Adapt<UserVersionLog>();
+            uvl.UserId = UId.ToInt64();
+            await _sqlSugar.Insertable(uvl).ExecuteCommandAsync();
+        }
+
     }
 }

WGShare.API/Controllers/Frontend/RoomController.cs

@@ -3,6 +3,7 @@ using Hangfire.MemoryStorage.Database;
 using Mapster;
 using Masuit.Tools;
 using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Components.Forms;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.SignalR;
 using Microsoft.IdentityModel.Tokens;
@@ -62,10 +63,11 @@ namespace WGShare.API.Controllers.Frontend
         [HttpPost("manager")]
         public async Task SetRoomManager([FromBody] RoomManagerInputDTO inputDTO)
         {
+            inputDTO.SettingUserId = UId;
             var users = RedisHelper.Instance.HVals<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, inputDTO.RoomNum));
-            if (users.Count(x => x.IsRoomManager || x.RoleId == ((int)RoleEnums.Admin).ToString() || x.RoleId == ((int)RoleEnums.RoomManager).ToString()) >= 12)
+            if (users.Count(x => x.IsRoomManager || x.RoleId == ((int)RoleEnums.Admin).ToString() || x.RoleId == ((int)RoleEnums.RoomManager).ToString()) >= 20)
             {
-                throw Oops.Oh("房间已达到12个发言人限制。请移除一位发言人");
+                throw Oops.Oh("当前房间已达最大发言人数！");
             }
             var user = users.FirstOrDefault(x => x.UID == inputDTO.UserId);
             if (user == null)
@@ -73,11 +75,13 @@ namespace WGShare.API.Controllers.Frontend
                 throw Oops.Oh("用户已不在房间内！");
             }
 
-            user.IsRoomManager = true;
+            await _hubContext.Clients.User(inputDTO.UserId).SetSpeaker(inputDTO);
 
-            RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, inputDTO.RoomNum), inputDTO.UserId, user);
+            //user.IsRoomManager = true;
 
-            await _hubContext.Clients.Group(inputDTO.RoomNum).ManagerRefresh(user, UId);
+            //RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, inputDTO.RoomNum), inputDTO.UserId, user);
+
+            //await _hubContext.Clients.Group(inputDTO.RoomNum).ManagerRefresh(user, UId);
         }
 
         /// <summary>
@@ -95,23 +99,35 @@ namespace WGShare.API.Controllers.Frontend
             }
 
             user.IsRoomManager = false;
+            user.EnableCamera = false;
+            user.EnableMicr = false;
             RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, inputDTO.RoomNum), inputDTO.UserId, user);
 
             // 判断是否显示用户
             var showUserId = RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), inputDTO.RoomNum);
             if (showUserId == inputDTO.UserId || showUserId == user.ScreenShareId)
             {
-
+                if (UId == inputDTO.UserId)
-                //var users = RedisHelper.Instance.HVals<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, inputDTO.RoomNum));
+                {
-                //var showUser = users.FirstOrDefault(x => x.RoleId == ((int)RoleEnums.Admin).ToString() || x.IsRoomManager || x.RoleId == ((int)RoleEnums.RoomManager).ToString());
+                    // 表示自己取消自己的发言权限
-                //if (showUser != null)
+                    var users = RedisHelper.Instance.HVals<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, inputDTO.RoomNum));
-                //{
+                    var showUser = users.FirstOrDefault(x => x.RoleId == ((int)RoleEnums.Admin).ToString() || x.IsRoomManager || x.RoleId == ((int)RoleEnums.RoomManager).ToString());
-
+                    if (showUser != null)
-                // 取消显示用户，设置显示当前操作的管理员 
+                    {
-                RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), inputDTO.RoomNum, UId);
+                        RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), inputDTO.RoomNum, showUser.UID);
-                await _hubContext.Clients.Group(inputDTO.RoomNum).ShowUser(UId, UserName, string.Empty, string.Empty);
+                        await _hubContext.Clients.Group(inputDTO.RoomNum).ShowUser(showUser.UID, showUser.UserName, string.Empty, string.Empty);
-                //}
+                    }
-
+                    else
+                    {
+                        RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), inputDTO.RoomNum, 0);
+                    }
+                }
+                else
+                {
+                    // 取消显示用户，设置显示当前操作的管理员 
+                    RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), inputDTO.RoomNum, UId);
+                    await _hubContext.Clients.Group(inputDTO.RoomNum).ShowUser(UId, UserName, string.Empty, string.Empty);
+                }
             }
 
             await _hubContext.Clients.Group(inputDTO.RoomNum).ManagerRefresh(user, UId);
@@ -190,7 +206,34 @@ namespace WGShare.API.Controllers.Frontend
         [HttpGet("checkout"), AllowAnonymous]
         public async Task<bool> ExistsRoom([FromQuery] string roomNum)
         {
-            return await _sqlSugar.Queryable<Room>().AnyAsync(x => x.RoomNum == roomNum && x.IsDelete == false);
+            if (IsAnonymous)
+            {
+                // 匿名用户
+                var room = await _sqlSugar.Queryable<Room>().FirstAsync(x => x.RoomNum == roomNum && x.IsDelete == false);
+                if (room == null)
+                {
+                    return false;
+                }
+                if (!room.AllowAnonymous)
+                {
+                    throw Oops.Oh("房间不允许匿名用户进入");
+                }
+                return true;
+            }
+            else
+            {
+                // 非匿名用户
+                var room = await _sqlSugar.Queryable<Room>()
+                   .WhereIF(Year > 0 && RoleId == RoleEnums.User, x => x.Year == Year || x.Year == 0)
+                   .WhereIF(Subject > 0 && RoleId == RoleEnums.User, x => x.Subject == Subject || x.Subject == 0)
+                   .FirstAsync(x => x.RoomNum == roomNum && x.IsDelete == false);
+                if (room == null)
+                {
+                    return false;
+                }
+                return true;
+            }
+
         }
 
         /// <summary>
@@ -299,7 +342,7 @@ namespace WGShare.API.Controllers.Frontend
             userInfo.EnableMicr = enableMicr;
             RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, roomNum), uid, userInfo);
 
-            _logger.LogInformation($@"开闭麦克分，推送一次,roomNum:{roomNum},enableMicr:{enableMicr},uid:{uid}");
+            //_logger.LogInformation($@"开闭麦克分，推送一次,roomNum:{roomNum},enableMicr:{enableMicr},uid:{uid}");
             // 通知所有人该用户麦克风状态
             await _hubContext.Clients.Group(roomNum).OperMicr(userInfo, UId);
         }
@@ -340,13 +383,25 @@ namespace WGShare.API.Controllers.Frontend
             }
 
             // 获取全部用户
-            var uids = RedisHelper.Instance.HKeys(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, roomNum));
+            var userInfos = RedisHelper.Instance.HVals<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, roomNum));
-            if (uids.IsNullOrEmpty())
+            if (userInfos.IsNullOrEmpty())
             {
                 throw Oops.Oh("无效会议号！");
             }
 
-            return uids.FirstOrDefault();
+            var managers = userInfos.Where(x => x.RoleId == ((int)RoleEnums.Admin).ToString() || x.IsRoomManager || x.RoleId == ((int)RoleEnums.RoomManager).ToString());
+            if (managers.IsNullOrEmpty())
+            {
+                return userInfos.FirstOrDefault().UID;
+            }
+
+            var user = managers.FirstOrDefault(x => x.EnableCamera = true);
+            if (user == null)
+            {
+                return managers.FirstOrDefault().UID;
+            }
+
+            return user.UID;
         }
 
         /// <summary>
@@ -356,6 +411,13 @@ namespace WGShare.API.Controllers.Frontend
         [HttpPost("show-user")]
         public async Task SetShowUser([FromQuery] string roomNum, [FromQuery] string uid, [FromQuery] string uname)
         {
+
+            if (RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), roomNum) == uid)
+            {
+                // 如果已经是全员观看他了， 直接通知其他房间用户
+                await _hubContext.Clients.Group(roomNum).ShowUser(uid, uname, UId, UserName);
+                return;
+            }
             // 设置房间全员观看用户
             RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), roomNum, uid);
 
@@ -566,10 +628,78 @@ namespace WGShare.API.Controllers.Frontend
 
             if (connectionIds.Any())
             {
-                await _hubContext.Clients.Clients(connectionIds).ApplyToSpeak(UId, UserName);
+                var userInfo = RedisHelper.Instance.HGet<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, roomNum), UId);
+                var userName = UserName;
+                if (userInfo != null)
+                {
+                    userName = userInfo.UserName;
+                }
+                await _hubContext.Clients.Clients(connectionIds).ApplyToSpeak(UId, userName);
             }
         }
 
+        /// <summary>
+        /// 获取共享屏幕
+        /// </summary>
+        /// <returns></returns>
+        [HttpGet("shared-screen")]
+        public async Task<string> GetSharedScreen([FromQuery] string roomNum)
+        {
+            var showUserId = RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), roomNum);
+            if (!string.IsNullOrWhiteSpace(showUserId) && showUserId.Length == 9)
+            {
+                // 全员观看userid =9 表示共享屏幕
+                return showUserId;
+            }
+            return string.Empty;
+        }
+
+        /// <summary>
+        /// 设置共享屏幕
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost("shared-screen")]
+        public async Task SharedScreen([FromQuery] string roomNum)
+        {
+            //var showUserId = RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), roomNum);
+            //if (showUserId.Length == 9)
+            //{
+            //    var user = await _sqlSugar.Queryable<User>().FirstAsync(x => x.ScreenShareId == showUserId);
+            //    if (user != null)
+            //    {
+            //        // 
+            //        await _hubContext.Clients.User(user.Id).ExitSharedScreen();
+            //    }
+            //}
+
+            var connectId = RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetOnlineUserKey(TenantId), UId);
+            // 通知其他所有共享屏幕用户退出
+            await _hubContext.Clients.GroupExcept(roomNum, connectId).ExitSharedScreen();
+
+            // 设置新的共享屏幕
+            RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), roomNum, ScreenShareId);
+            // 通知全员观看新的共享屏幕
+            await _hubContext.Clients.Group(roomNum).ShowUser(UId, UserName, string.Empty, string.Empty);
+        }
+
+        /// <summary>
+        /// 共享人取消共享屏幕
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost("stop-shared-screen")]
+        public async Task StopedSharedScreen([FromQuery] string roomNum)
+        {
+            if (RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), roomNum) != ScreenShareId)
+            {
+                // 不是共享屏幕的人，不做处理
+                return;
+            }
+
+            // 设置新的共享屏幕
+            RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), roomNum, UId);
+
+            await _hubContext.Clients.Group(roomNum).StopedSharedScreen(ScreenShareId);
+        }
 
         #region 文件分享
         /// <summary>
@@ -686,5 +816,21 @@ namespace WGShare.API.Controllers.Frontend
 
             await _sqlSugar.Insertable(entitys).ExecuteCommandAsync();
         }
+
+        /// <summary>
+        /// 修改昵称
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        [HttpPut("alter-uname")]
+        public async Task ModifyNickName([FromBody] UserModifyNickNameDto dto)
+        {
+            var user = RedisHelper.Instance.HGet<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, dto.RoomNum), dto.UId.ToString());
+            user.UserName = dto.NickName;
+
+            RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, dto.RoomNum), dto.UId.ToString(), user);
+
+            await _hubContext.Clients.Group(dto.RoomNum).ModifyNickName(dto.UId, dto.NickName);
+        }
     }
 }

WGShare.API/Controllers/PublicController.cs

@@ -11,6 +11,7 @@ using System.Text.RegularExpressions;
 using WGShare.API.Controllers.Basic;
 using WGShare.API.Helpers;
 using WGShare.Domain.DTOs.Login;
+using WGShare.Domain.DTOs.MiniProgram;
 using WGShare.Domain.DTOs.User;
 using WGShare.Domain.Entities;
 using WGShare.Domain.Enums;
@@ -26,10 +27,19 @@ namespace WGShare.API.Controllers
     public class PublicController : BasicController
     {
         private readonly ISqlSugarClient _sqlSugar;
+        private readonly IHttpClientFactory _httpClientFactory;
+        private readonly Microsoft.Extensions.Configuration.IConfiguration _configuration;
+        private readonly ILogger<PublicController> _logger;
 
-        public PublicController(ISqlSugarClient sqlSugar)
+        public PublicController(ISqlSugarClient sqlSugar,
+                                IHttpClientFactory httpClientFactory,
+                                Microsoft.Extensions.Configuration.IConfiguration configuration,
+                                ILogger<PublicController> logger)
         {
             _sqlSugar = sqlSugar;
+            this._httpClientFactory = httpClientFactory;
+            this._configuration = configuration;
+            this._logger = logger;
         }
 
         /// <summary>
@@ -69,5 +79,26 @@ namespace WGShare.API.Controllers
             else
                 return value.ToString();
         }
+
+        /// <summary>
+        /// 获取小程序openid
+        /// </summary>
+        /// <returns></returns>
+        [HttpGet("mini-openid"), AllowAnonymous]
+        public async Task<string> GetOpenId(string js_code)
+        {
+            var queryString = $@"appid={_configuration["miniProgram:appId"]}&secret={_configuration["miniProgram:appSecret"]}&js_code={js_code}&grant_type=authorization_code";
+
+            var httpclient = _httpClientFactory.CreateClient();
+            var result = await httpclient.GetFromJsonAsync<JsCode2SessionApiResult>($@"https://api.weixin.qq.com/sns/jscode2session?{queryString}");
+            if (result == null || result.errorcode != 0 || string.IsNullOrWhiteSpace(result.openid))
+            {
+                _logger.LogError($"获取openid失败，错误码：{result?.errorcode}，错误信息：{result?.errmsg}");
+
+                throw Oops.Oh("小程序登录失败");
+            }
+
+            return result.openid;
+        }
     }
 }

WGShare.API/Helpers/MiniProgramHelper.cs

@@ -0,0 +1,59 @@
+using WGShare.Domain.Constant;
+using WGShare.Domain.DTOs.MiniProgram;
+using WGShare.Domain.FriendlyException;
+
+namespace WGShare.API.Helpers
+{
+    /// <summary>
+    /// 小程序帮助类
+    /// </summary>
+    public class MiniProgramHelper
+    {
+        private readonly IConfiguration _configuration; 
+
+        public MiniProgramHelper(IConfiguration configuration)
+        {
+            this._configuration = configuration; 
+        }
+
+        /// <summary>
+        /// 获取access_token
+        /// </summary>
+        /// <returns></returns>
+        public async Task<string> GetAccessToken()
+        {
+            var accessToken = RedisHelper.Instance.Get<string>(RedisKeyConstant.WxMiniProgram.AccessTokenKey);
+            if (!string.IsNullOrWhiteSpace(accessToken) )
+            {
+                return accessToken;
+            }
+
+            var appId = _configuration["miniProgram:appId"];
+            var secret = _configuration["miniProgram:appSecret"];
+
+            using var httpClient = new HttpClient();
+
+            var result = await httpClient.GetAsync($@"https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={appId}&secret={secret}");
+            if (result == null || !result.IsSuccessStatusCode)
+            {
+                Console.WriteLine($@"微信服务器授权失败,{result.StatusCode},{await result.Content.ReadAsStringAsync()}");
+                throw Oops.Oh("微信服务器授权失败");
+            }
+            var apiResult = await result.Content.ReadFromJsonAsync<AccessTokenApiResult>();
+            if (apiResult == null)
+            {
+                Console.WriteLine($@"微信服务器授权失败,接口返回数据解析失败");
+                throw Oops.Oh("微信服务器授权失败");
+            }
+            if (apiResult.errorcode != 0)
+            {
+                Console.WriteLine($@"微信服务器授权失败,errorCode:{apiResult.errorcode},errmsg:{apiResult.errmsg}");
+                throw Oops.Oh("微信服务器授权失败");
+            }
+
+            RedisHelper.Instance.Set(RedisKeyConstant.WxMiniProgram.AccessTokenKey, apiResult.access_token, TimeSpan.FromSeconds(apiResult.expires_in - 60));
+            return apiResult.access_token;
+        }
+
+    }
+}

WGShare.API/Helpers/QrCodeOptimizerHelper.cs

@@ -0,0 +1,36 @@
+using SixLabors.ImageSharp;
+using SixLabors.ImageSharp.Formats.Jpeg;
+using System.Drawing.Imaging;
+
+namespace WGShare.API.Helpers
+{
+    public class QrCodeOptimizerHelper
+    {
+        public static string CompressImage(string base64String, int quality)
+        {
+            // 将 Base64 字符串转换为字节数组
+            byte[] imageBytes = Convert.FromBase64String(base64String);
+
+            // 使用 ImageSharp 加载图像
+            using (Image image = Image.Load(imageBytes))
+            {
+                // 设置压缩参数
+                JpegEncoder jpegEncoder = new JpegEncoder
+                {
+                    Quality = quality
+                };
+
+                // 创建一个新的内存流来保存压缩后的图像
+                using (MemoryStream compressedMs = new MemoryStream())
+                {
+                    image.Save(compressedMs, jpegEncoder);
+
+                    // 将压缩后的图像转换回 Base64 字符串
+                    byte[] compressedImageBytes = compressedMs.ToArray();
+                    return Convert.ToBase64String(compressedImageBytes);
+                }
+            }
+        }
+
+    }
+}

WGShare.API/Hubs/IMessageClient.cs

@@ -1,4 +1,6 @@
-using WGShare.Domain.DTOs.User;
+using SignalRSwaggerGen.Attributes;
+using WGShare.Domain.DTOs.Room;
+using WGShare.Domain.DTOs.User;
 using WGShare.Domain.Entities;
 
 namespace WGShare.API.Hubs
@@ -6,6 +8,7 @@ namespace WGShare.API.Hubs
     /// <summary>
     /// 客户端消息
     /// </summary>
+    [SignalRHub]
     public interface IMessageClient
     {
         /// <summary>
@@ -44,7 +47,7 @@ namespace WGShare.API.Hubs
         /// </summary>
         /// <param name="type"></param>
         /// <returns></returns>
-        Task Operation(int type);
+        Task Operation(string contentString);
 
         /// <summary>
         /// 更新视图
@@ -58,6 +61,12 @@ namespace WGShare.API.Hubs
         /// <returns></returns>
         Task ShowUser(string uid, string uname, string operUid, string operUserName);
 
+        /// <summary>
+        /// 共享人取消共享屏幕
+        /// </summary>
+        /// <returns></returns>
+        Task StopedSharedScreen(string ScreenShareId);
+
         /// <summary>
         /// 用户加入频道回调
         /// </summary>
@@ -144,5 +153,37 @@ namespace WGShare.API.Hubs
         /// <param name="driversJsonString"></param>
         /// <returns></returns>
         Task ShowDriverList(string driversJsonString);
+
+        /// <summary>
+        ///     修改昵称
+        /// </summary>
+        /// <param name="UId"></param>
+        /// <param name="NickName"></param>
+        /// <returns></returns>
+        Task ModifyNickName(long UId, string NickName);
+
+        /// <summary>
+        /// 退出共享屏幕
+        /// </summary>
+        /// <returns></returns>
+        Task ExitSharedScreen();
+
+        /// <summary>
+        /// 加入频道回调
+        /// </summary>
+        Task JoinChannelCallback(bool isSuccess);
+
+        /// <summary>
+        /// 发送设置发言人指令
+        /// </summary>
+        /// <returns></returns>
+        Task SetSpeaker(RoomManagerInputDTO inputDTO);
+
+        /// <summary>
+        /// 客户端接收到消息
+        /// </summary>
+        /// <param name="contentString"></param>
+        /// <returns></returns>
+        Task ReceivedOperation(string contentString);
     }
 }

WGShare.API/Hubs/SessionManageHub.cs

@@ -2,17 +2,22 @@
 using Masuit.Tools.DateTimeExt;
 using Masuit.Tools.Maths;
 using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Components.Forms;
 using Microsoft.AspNetCore.SignalR;
 using SqlSugar;
 using SqlSugar.Extensions;
 using System;
 using System.Globalization;
+using System.Runtime.InteropServices;
 using System.Security.Claims;
+using System.Security.Cryptography;
 using System.Text;
 using WGShare.API.Helpers;
 using WGShare.Domain.Constant;
+using WGShare.Domain.DTOs.Room;
 using WGShare.Domain.Entities;
 using WGShare.Domain.Enums;
+using WGShare.Domain.FriendlyException;
 using ZstdSharp.Unsafe;
 
 namespace WGShare.API.Hubs
@@ -41,11 +46,11 @@ namespace WGShare.API.Hubs
             Context.Items.Add("account", account);
             Context.Items.Add("ssid", ssid);
             Context.Items.Add("uname", uname);
-            Context.Items.Add("roleid", roleId); 
+            Context.Items.Add("roleid", roleId);
 
-            Console.WriteLine($"{DateTime.Now}连接成功 当前租户：{tenant} account：{account} uid:{uid} connectId:{Context.ConnectionId}");
+            _logger.LogInformation($"{DateTime.Now}连接成功 当前租户：{tenant} account：{account} uid:{uid} connectId:{Context.ConnectionId}");
 
-            await ClearUserChannel(uid, tenant, account, ssid, false);
+            //await ClearUserChannel(uid, tenant, account, ssid, false);
             // 存储在线信息
             RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetOnlineUserKey(tenant), uid, Context.ConnectionId);
         }
@@ -58,11 +63,11 @@ namespace WGShare.API.Hubs
             var ssid = Context.User?.Claims.FirstOrDefault(x => x.Type == "ssid")?.Value;
 
 
-            Console.WriteLine($"{DateTime.Now}断开连接   当前租户：{tenant} account：{account} uid:{uid} connectId:{Context.ConnectionId} exception:{exception?.Message} ");
+            _logger.LogInformation($"{DateTime.Now}断开连接   当前租户：{tenant} account：{account} uid:{uid} connectId:{Context.ConnectionId} exception:{exception?.Message} ");
 
             if (Context.ConnectionId == RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetOnlineUserKey(tenant), uid))
             {
-                Console.WriteLine($"{DateTime.Now}断开连接  未重连，开始删除用户频道信息");
+                _logger.LogInformation($"{DateTime.Now}断开连接  未重连，开始删除用户频道信息");
                 // 断开后未重连则清退频道
                 await ClearUserChannel(uid, tenant, account, ssid, true);
 
@@ -72,17 +77,14 @@ namespace WGShare.API.Hubs
 
         private async Task ClearUserChannel(string uid, string tenant, string account, string ssid, bool isclose)
         {
-            Console.WriteLine($"{DateTime.Now} 执行删除开始");
+            _logger.LogInformation($"{DateTime.Now} 执行删除开始");
             // 获取用户参加得频道
             var roomNum = RedisHelper.Instance.Get(RedisKeyConstant.SessionManage.GetUserJoinChannelKey(uid));
             using (var pipe = RedisHelper.Instance.StartPipe())
             {
-                Console.WriteLine($@"{DateTime.Now} account:{account} 退出以下频道：{string.Join(',', roomNum)}");
+                _logger.LogInformation($@"{DateTime.Now} account:{account} 退出以下频道：{string.Join(',', roomNum)}");
                 if (!string.IsNullOrEmpty(roomNum))
                 {
-                    // 所有房间移除该用户
-                    pipe.HDel(RedisKeyConstant.SessionManage.GetChannelUserKey(tenant, roomNum), uid);
-
                     // 判断是否全员看他,是则移除
                     var script = $@"local value = redis.call('HGET', KEYS[1], ARGV[1]) 
                         if value == ARGV[2] or value == ARGV[3] then 
@@ -90,6 +92,9 @@ namespace WGShare.API.Hubs
                         else return -1 end";
                     // 执行 eval 命令
                     pipe.Eval(script, [RedisKeyConstant.SessionManage.GetChannelShowUserKey(tenant)], roomNum, uid, ssid);
+
+                    // 房间移除该用户
+                    pipe.HDel(RedisKeyConstant.SessionManage.GetChannelUserKey(tenant, roomNum), uid);
                 }
 
                 // 删除用户在线状态
@@ -98,14 +103,31 @@ namespace WGShare.API.Hubs
                 // 删除用户已加入频道信息
                 pipe.Del(RedisKeyConstant.SessionManage.GetUserJoinChannelKey(uid));
 
-                pipe.EndPipe();
+                var result = pipe.EndPipe();
+
+                if (!result.IsNullOrEmpty() && result[0].ObjToInt() != -1)
+                {
+                    // 如果离开的是全员看ta，则重新设置管理员为全员看ta
+                    var users = RedisHelper.Instance.HVals<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(tenant, roomNum));
+                    var showUsers = users.Where(x => x.RoleId == ((int)RoleEnums.Admin).ToString() || x.IsRoomManager || x.RoleId == ((int)RoleEnums.RoomManager).ToString()).ToList();
+                    if (!showUsers.IsNullOrEmpty())
+                    {
+                        var showUser = showUsers.FirstOrDefault(x => x.EnableCamera == true);
+                        if (showUser == null)
+                        {
+                            showUser = showUsers.FirstOrDefault();
+                        }
+                        // 通知全员看ta
+                        await Clients.Group(roomNum).ShowUser(showUser.UID, showUser.UserName, string.Empty, string.Empty);
+                    }
+                }
             }
 
             if (!string.IsNullOrEmpty(roomNum))
                 // 通知房间其他用户，该用户退出
                 await Clients.Group(roomNum).UserLeave(uid);
 
-            Console.WriteLine($"{DateTime.Now} 执行删除完成");
+            _logger.LogInformation($"{DateTime.Now} 执行删除完成");
         }
 
         /// <summary>
@@ -115,7 +137,7 @@ namespace WGShare.API.Hubs
         /// <param name="enableMicr">是否关闭麦克风，默认是</param>
         /// <param name="enableCamera">是否关闭摄像头，默认是</param>
         [HubMethodName("joinChannel")]
-        public async Task JoinChannel(string roomNum, bool enableMicr = false, bool enableCamera = false,bool isRoomManager = false)
+        public async Task JoinChannel(string roomNum, bool enableMicr = false, bool enableCamera = false, bool isRoomManager = false)
         {
             var tenant = Context.User?.Claims.FirstOrDefault(x => x.Type == "tenant")?.Value;
             var uid = Context.User?.Claims.FirstOrDefault(x => x.Type == ClaimTypes.NameIdentifier)?.Value;
@@ -123,32 +145,32 @@ namespace WGShare.API.Hubs
             var ssid = Context.User?.Claims.FirstOrDefault(x => x.Type == "ssid")?.Value;
             var uname = Context.User?.Claims.FirstOrDefault(x => x.Type == "uname")?.Value;
             var roleId = Context.User?.Claims.FirstOrDefault(x => x.Type == "roleid")?.Value;
-
+            try
-
-            Console.WriteLine($"{DateTime.Now}加入频道   会议号：" + roomNum);
-            Console.WriteLine($"{DateTime.Now}加入频道   account：" + account);
-            Console.WriteLine($"{DateTime.Now}加入频道   tenant：" + tenant);
-
-            var userInfo = new ChannelUserInfo
-            {
-                UID = uid,
-                UserName = uname,
-                EnableCamera = enableCamera,
-                EnableMicr = enableMicr,
-                ConnectId = Context.ConnectionId,
-                Account = account,
-                ScreenShareId = ssid,
-                RoleId = roleId,
-                RoleName = ((RoleEnums)roleId.ToInt32()).GetDescription(),
-                IsRoomManager = isRoomManager
-            };
-            using (var pipe = RedisHelper.Instance.StartPipe())
             {
+                _logger.LogInformation($"{DateTime.Now}加入频道   会议号：" + roomNum);
+                _logger.LogInformation($"{DateTime.Now}加入频道   account：" + account);
+                _logger.LogInformation($"{DateTime.Now}加入频道   tenant：" + tenant);
 
-                if (((RoleEnums)roleId.ToInt32()) == RoleEnums.Admin || ((RoleEnums)roleId.ToInt32()) == RoleEnums.RoomManager)
+                var userInfo = new ChannelUserInfo
                 {
-                    // 管理员进房，如果没有全员看ta，则设置
+                    UID = uid,
-                    var script = @"local hashKey = KEYS[1]
+                    UserName = uname,
+                    EnableCamera = enableCamera,
+                    EnableMicr = enableMicr,
+                    ConnectId = Context.ConnectionId,
+                    Account = account,
+                    ScreenShareId = ssid,
+                    RoleId = roleId,
+                    RoleName = ((RoleEnums)roleId.ToInt32()).GetDescription(),
+                    IsRoomManager = isRoomManager
+                };
+                using (var pipe = RedisHelper.Instance.StartPipe())
+                {
+
+                    if (((RoleEnums)roleId.ToInt32()) == RoleEnums.Admin || ((RoleEnums)roleId.ToInt32()) == RoleEnums.RoomManager)
+                    {
+                        // 管理员进房，如果没有全员看ta，则设置
+                        var script = @"local hashKey = KEYS[1]
                                 local field = ARGV[1]
                                 local value = ARGV[2]
 
@@ -158,25 +180,34 @@ namespace WGShare.API.Hubs
                                 else
                                     return 0
                                 end";
-                    pipe.Eval(script, [RedisKeyConstant.SessionManage.GetChannelShowUserKey(tenant)], roomNum, uid);
+                        pipe.Eval(script, [RedisKeyConstant.SessionManage.GetChannelShowUserKey(tenant)], roomNum, uid);
 
+                    }
+
+                    // 记录频道得用户信息
+                    pipe.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(tenant, roomNum), uid, userInfo);
+                    // 记录用户已参与频道
+                    pipe.Set(RedisKeyConstant.SessionManage.GetUserJoinChannelKey(uid), roomNum);
+                    var results = pipe.EndPipe();
+
+                    // 判断，如果有全员看ta，则通知
+                    if ((((RoleEnums)roleId.ToInt32()) == RoleEnums.Admin || ((RoleEnums)roleId.ToInt32()) == RoleEnums.RoomManager) && !results.IsNullOrEmpty() && results[0].ObjToInt() == 1)
+                        await Clients.Group(roomNum).ShowUser(uid, uname, string.Empty, string.Empty);
                 }
+                await Groups.AddToGroupAsync(Context.ConnectionId, roomNum);
+                await Clients.GroupExcept(roomNum, Context.ConnectionId).UserJoined(userInfo);
 
-                // 记录频道得用户信息
+                await Clients.Caller.JoinChannelCallback(true);
-                pipe.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(tenant, roomNum), uid, userInfo);
-                // 记录用户已参与频道
-                pipe.Set(RedisKeyConstant.SessionManage.GetUserJoinChannelKey(uid), roomNum);
-                var results = pipe.EndPipe();
 
-                // 判断，如果有全员看ta，则通知
-                if ((((RoleEnums)roleId.ToInt32()) == RoleEnums.Admin || ((RoleEnums)roleId.ToInt32()) == RoleEnums.RoomManager) && !results.IsNullOrEmpty() && results[0].ObjToInt() == 1)
-                    await Clients.Group(roomNum).ShowUser(uid, uname, string.Empty, string.Empty);
             }
-            await Groups.AddToGroupAsync(Context.ConnectionId, roomNum);
+            catch (Exception ex)
-            await Clients.GroupExcept(roomNum, Context.ConnectionId).UserJoined(userInfo);
+            {
 
+                await Clients.Caller.JoinChannelCallback(false);
+                _logger.LogError(ex, $@"加入频道异常,tenant:{tenant},uid:{uid},ssid:{ssid},uname:{uname} {Environment.NewLine}{ex.Message}");
+                await ExceptionNotice.SendAsync(ex, $@"加入频道异常,tenant:{tenant},uid:{uid},ssid:{ssid},uname:{uname} ");
+            }
         }
-
         /// <summary>
         /// 离开频道   
         /// </summary>
@@ -192,9 +223,9 @@ namespace WGShare.API.Hubs
             var roleId = Context.User?.Claims.FirstOrDefault(x => x.Type == "roleid")?.Value;
 
 
-            Console.WriteLine($" {DateTime.Now}离开频道   会议号：" + roomNum);
+            _logger.LogInformation($" {DateTime.Now}离开频道   会议号：" + roomNum);
-            Console.WriteLine($" {DateTime.Now}离开频道   account：" + account);
+            _logger.LogInformation($" {DateTime.Now}离开频道   account：" + account);
-            Console.WriteLine($" {DateTime.Now}离开频道   tenant：" + tenant);
+            _logger.LogInformation($" {DateTime.Now}离开频道   tenant：" + tenant);
 
             using (var pipe = RedisHelper.Instance.StartPipe())
             {
@@ -212,10 +243,16 @@ namespace WGShare.API.Hubs
                 var result = pipe.EndPipe();
                 if (!result.IsNullOrEmpty() && result[0].ObjToInt() != -1)
                 {
+                    // 如果离开的是全员看ta，则重新设置管理员为全员看ta
                     var users = RedisHelper.Instance.HVals<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(tenant, roomNum));
-                    var showUser = users.FirstOrDefault(x => x.RoleId == ((int)RoleEnums.Admin).ToString() || x.IsRoomManager || x.RoleId == ((int)RoleEnums.RoomManager).ToString());
+                    var showUsers = users.Where(x => x.RoleId == ((int)RoleEnums.Admin).ToString() || x.IsRoomManager || x.RoleId == ((int)RoleEnums.RoomManager).ToString()).ToList();
-                    if (showUser != null)
+                    if (!showUsers.IsNullOrEmpty())
                     {
+                        var showUser = showUsers.FirstOrDefault(x => x.EnableCamera == true);
+                        if (showUser == null)
+                        {
+                            showUser = showUsers.FirstOrDefault();
+                        }
                         // 通知全员看ta
                         await Clients.Group(roomNum).ShowUser(showUser.UID, showUser.UserName, string.Empty, string.Empty);
                     }
@@ -237,12 +274,18 @@ namespace WGShare.API.Hubs
         {
             var uname = Context.User?.Claims.FirstOrDefault(x => x.Type == "uname")?.Value;
             var uid = Context.User?.Claims.FirstOrDefault(x => x.Type == ClaimTypes.NameIdentifier)?.Value;
+            var tenant = Context.Items["tenant"].ToString();
+             
+            _logger.LogInformation($" {DateTime.Now} 发送消息   uname：{uname}  roomNum：{rooNum}   msg：{msg}");
 
-            Console.WriteLine($" {DateTime.Now}发送消息   uname：" + uname);
+            var userInfo = RedisHelper.Instance.HGet<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(tenant, rooNum), uid);
-            Console.WriteLine($" {DateTime.Now}发送消息   roomNum：" + rooNum);
+            var userName = uname;
-            Console.WriteLine($" {DateTime.Now}发送消息   msg：" + msg);
+            if (userInfo != null)
+            {
+                userName = userInfo.UserName;
+            }
 
-            await Clients.OthersInGroup(rooNum).ReceiveMessage(uid, uname, msg, DateTime.Now.GetTotalMilliseconds());            //await Clients.GroupExcept(rooNum, Context.ConnectionId).ReceiveMessage(uid, uname, msg);
+            await Clients.OthersInGroup(rooNum).ReceiveMessage(uid, userName, msg, DateTime.Now.GetTotalMilliseconds());            //await Clients.GroupExcept(rooNum, Context.ConnectionId).ReceiveMessage(uid, uname, msg);
         }
 
         /// <summary>
@@ -250,9 +293,21 @@ namespace WGShare.API.Hubs
         /// </summary>
         /// <returns></returns>
         [HubMethodName("sendOper")]
-        public async Task SendOperation(string roomNum, int type)
+        public async Task SendOperation(string roomNum, string contentString)
         {
-            await Clients.Group(roomNum).Operation(type);
+            await Clients.Group(roomNum).Operation(contentString);
+        }
+
+        /// <summary>
+        /// 发送客户端指令到指定用户
+        /// </summary>
+        /// <param name="uid"></param>
+        /// <param name="contentString"></param>
+        /// <returns></returns>
+        [HubMethodName("sendOper2User")]
+        public async Task SendOperationToUser(string uid, string contentString)
+        {
+            await Clients.User(uid).ReceivedOperation(contentString);
         }
 
         /// <summary>
@@ -290,5 +345,32 @@ namespace WGShare.API.Hubs
         {
             await Clients.User(uid).SaveDriver(driversJsonString);
         }
+
+
+        /// <summary>
+        /// 发言人设置成功回调
+        /// </summary>
+        /// <param name="inputDTO"></param>
+        /// <returns></returns>
+        [HubMethodName("setSpeakerCallback")]
+        public async Task SetSpeakerCallback(RoomManagerInputDTO inputDTO)
+        {
+            var tenantId = Context.Items["tenant"].ToString();
+
+            var users = RedisHelper.Instance.HVals<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(tenantId, inputDTO.RoomNum));
+            //if (users.Count(x => x.IsRoomManager || x.RoleId == ((int)RoleEnums.Admin).ToString() || x.RoleId == ((int)RoleEnums.RoomManager).ToString()) >= 20)
+            //{
+            //    throw Oops.Oh("房间已达到20个发言人限制。请移除一位发言人");
+            //}
+            var user = users.FirstOrDefault(x => x.UID == inputDTO.UserId);
+            if (user == null)
+            {
+                throw Oops.Oh("用户已不在房间内！");
+            }
+            user.IsRoomManager = true;
+            RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(tenantId, inputDTO.RoomNum), inputDTO.UserId, user);
+
+            await Clients.Group(inputDTO.RoomNum).ManagerRefresh(user, inputDTO.SettingUserId);
+        }
     }
 }

WGShare.API/Program.cs

@@ -59,12 +59,13 @@ namespace WGShare.API
             });
             // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
             builder.Services.AddEndpointsApiExplorer();
-            builder.Services.AddSwagger();
+            builder.Services.AddSwagger(); 
             builder.Services.AddSignalR();
             builder.Services.AddHttpClient();
             builder.Services.ConfigureHangfire();
             builder.Services.AddSingleton(new JwtHelper(configuration));
             builder.Services.AddSingleton(new AgoraHelper(configuration));
+            builder.Services.AddSingleton(new MiniProgramHelper(configuration));
             builder.Services.AddSingleton(new OssHelper(configuration));
             builder.Services.AddHostedService<AgoraCallbackComsuerService>();
             builder.Services.AddAuth(configuration["Jwt:Issuer"],
@@ -98,7 +99,6 @@ namespace WGShare.API
                     options.SwaggerEndpoint($"/swagger/frontend/swagger.json", "Ç°¶Ë");
                     options.SwaggerEndpoint($"/swagger/backend/swagger.json", "ºó¶Ë");
                     options.SwaggerEndpoint($"/swagger/public/swagger.json", "¹«¹²½Ó¿Ú");
-
                 });
                 app.UseCustomCors();
             }

WGShare.API/ServiceConfigs/SwaggerServiceExtensions.cs

@@ -22,6 +22,7 @@ namespace WGShare.API.ServiceConfigs
         {
             services.AddSwaggerGen(w =>
             {
+                w.AddSignalRSwaggerGen();
                 w.SwaggerDoc("frontend", new OpenApiInfo { Title = "前端", Version = "frontend" });
                 w.SwaggerDoc("backend", new OpenApiInfo { Title = "后端", Version = "backend" });
                 w.SwaggerDoc("public", new OpenApiInfo { Title = "公共接口", Version = "public" });

WGShare.API/WGShare.API.csproj

@@ -15,6 +15,7 @@
 		<PackageReference Include="Hangfire.AspNetCore" Version="1.8.14" />
 		<PackageReference Include="Hangfire.Core" Version="1.8.14" />
 		<PackageReference Include="Hangfire.MemoryStorage" Version="1.8.1.1" />
+		<PackageReference Include="SignalRSwaggerGen" Version="4.7.0" />
 		<PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
 	</ItemGroup>
 

WGShare.API/WGShare.API.xml

@@ -11,6 +11,13 @@
             <param name="account"></param>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Controllers.AuthController.CheckUserOnline(System.String)">
+            <summary>
+            检查用户是否在线
+            </summary>
+            <param name="account"></param>
+            <returns></returns>
+        </member>
         <member name="M:WGShare.API.Controllers.AuthController.Login(WGShare.Domain.DTOs.Login.UserLoginDTO)">
             <summary>
             正常账号登录
@@ -68,6 +75,11 @@
             <param name="file"></param>
             <returns></returns>
         </member>
+        <member name="P:WGShare.API.Controllers.Basic.BasicController.IsAnonymous">
+            <summary>
+            匿名用户
+            </summary>
+        </member>
         <member name="T:WGShare.API.Controllers.Frontend.AgoraCallbackController">
             <summary>
             Agora接口
@@ -144,6 +156,25 @@
             </summary>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Controllers.Frontend.HomeController.GetMiniProgramQrCode(System.String,System.String)">
+            <summary>
+            获取房间二维码（缓存10mins）
+            </summary>
+            <param name="roomNum"></param>
+            <returns></returns>
+        </member>
+        <member name="M:WGShare.API.Controllers.Frontend.HomeController.FeedbackScoring(WGShare.Domain.DTOs.Home.FeedBackRequset)">
+            <summary>
+            反馈打分
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:WGShare.API.Controllers.Frontend.HomeController.RecordVersionLog(WGShare.Domain.DTOs.Home.UserVersionLogDto)">
+            <summary>
+            记录用户当前用户版本
+            </summary>
+            <returns></returns>
+        </member>
         <member name="T:WGShare.API.Controllers.Frontend.RoomController">
             <summary>
             会议室接口
@@ -268,6 +299,24 @@
             </summary>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Controllers.Frontend.RoomController.GetSharedScreen(System.String)">
+            <summary>
+            获取共享屏幕
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:WGShare.API.Controllers.Frontend.RoomController.SharedScreen(System.String)">
+            <summary>
+            设置共享屏幕
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:WGShare.API.Controllers.Frontend.RoomController.StopedSharedScreen(System.String)">
+            <summary>
+            共享人取消共享屏幕
+            </summary>
+            <returns></returns>
+        </member>
         <member name="M:WGShare.API.Controllers.Frontend.RoomController.AddFile(WGShare.Domain.DTOs.File.ShareFileInputDTO)">
             <summary>
             分享上传文件
@@ -316,6 +365,13 @@
             <param name="list"></param>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Controllers.Frontend.RoomController.ModifyNickName(WGShare.Domain.DTOs.User.UserModifyNickNameDto)">
+            <summary>
+            修改昵称
+            </summary>
+            <param name="dto"></param>
+            <returns></returns>
+        </member>
         <member name="M:WGShare.API.Controllers.Frontend.UserController.GetUserList(System.String,System.Nullable{System.Boolean},WGShare.Domain.GeneralModel.PagedBaseDto)">
             <summary>
             获取用户列表
@@ -402,6 +458,12 @@
             </summary>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Controllers.PublicController.GetOpenId(System.String)">
+            <summary>
+            获取小程序openid
+            </summary>
+            <returns></returns>
+        </member>
         <member name="F:WGShare.API.Helpers.AgoraHelper.Constant.REDIS_CHANNEL_USERCOUNT">
             <summary>
             Redis 键，hash ，每个频道用户数量
@@ -465,6 +527,17 @@
             <returns></returns>
             <exception cref="T:System.ArgumentException"></exception>
         </member>
+        <member name="T:WGShare.API.Helpers.MiniProgramHelper">
+            <summary>
+            小程序帮助类
+            </summary>
+        </member>
+        <member name="M:WGShare.API.Helpers.MiniProgramHelper.GetAccessToken">
+            <summary>
+            获取access_token
+            </summary>
+            <returns></returns>
+        </member>
         <member name="M:WGShare.API.Helpers.OssHelper.GetUploadUrl(System.String,System.String,System.UInt32)">
             <summary>
             获取上传url
@@ -546,7 +619,7 @@
             </summary>
             <returns></returns>
         </member>
-        <member name="M:WGShare.API.Hubs.IMessageClient.Operation(System.Int32)">
+        <member name="M:WGShare.API.Hubs.IMessageClient.Operation(System.String)">
             <summary>
             客户端操作
             </summary>
@@ -565,6 +638,12 @@
             </summary>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Hubs.IMessageClient.StopedSharedScreen(System.String)">
+            <summary>
+            共享人取消共享屏幕
+            </summary>
+            <returns></returns>
+        </member>
         <member name="M:WGShare.API.Hubs.IMessageClient.UserJoined(WGShare.Domain.Entities.ChannelUserInfo)">
             <summary>
             用户加入频道回调
@@ -652,6 +731,38 @@
             <param name="driversJsonString"></param>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Hubs.IMessageClient.ModifyNickName(System.Int64,System.String)">
+            <summary>
+                修改昵称
+            </summary>
+            <param name="UId"></param>
+            <param name="NickName"></param>
+            <returns></returns>
+        </member>
+        <member name="M:WGShare.API.Hubs.IMessageClient.ExitSharedScreen">
+            <summary>
+            退出共享屏幕
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:WGShare.API.Hubs.IMessageClient.JoinChannelCallback(System.Boolean)">
+            <summary>
+            加入频道回调
+            </summary>
+        </member>
+        <member name="M:WGShare.API.Hubs.IMessageClient.SetSpeaker(WGShare.Domain.DTOs.Room.RoomManagerInputDTO)">
+            <summary>
+            发送设置发言人指令
+            </summary>
+            <returns></returns>
+        </member>
+        <member name="M:WGShare.API.Hubs.IMessageClient.ReceivedOperation(System.String)">
+            <summary>
+            客户端接收到消息
+            </summary>
+            <param name="contentString"></param>
+            <returns></returns>
+        </member>
         <member name="M:WGShare.API.Hubs.SessionManageHub.JoinChannel(System.String,System.Boolean,System.Boolean,System.Boolean)">
             <summary>
             加入频道
@@ -673,12 +784,20 @@
             <param name="rooNum"></param>
             <param name="msg"></param>
         </member>
-        <member name="M:WGShare.API.Hubs.SessionManageHub.SendOperation(System.String,System.Int32)">
+        <member name="M:WGShare.API.Hubs.SessionManageHub.SendOperation(System.String,System.String)">
             <summary>
             发送客户端指令
             </summary>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Hubs.SessionManageHub.SendOperationToUser(System.String,System.String)">
+            <summary>
+            发送客户端指令到指定用户
+            </summary>
+            <param name="uid"></param>
+            <param name="contentString"></param>
+            <returns></returns>
+        </member>
         <member name="M:WGShare.API.Hubs.SessionManageHub.GetDriversList(System.String)">
             <summary>
             获取设备列表
@@ -701,6 +820,13 @@
             <param name="driversJsonString"></param>
             <returns></returns>
         </member>
+        <member name="M:WGShare.API.Hubs.SessionManageHub.SetSpeakerCallback(WGShare.Domain.DTOs.Room.RoomManagerInputDTO)">
+            <summary>
+            发言人设置成功回调
+            </summary>
+            <param name="inputDTO"></param>
+            <returns></returns>
+        </member>
         <member name="M:WGShare.API.Program.ResetRedisKey">
             <summary>
             程序启动前，删除redis中得数据

WGShare.API/appsettings.Development.json

@@ -36,12 +36,12 @@
     "Issuer": "WGshareApi",
     "Audience": "WGshareClient",
     // 过期 秒  
-    "Expires": 86400
+    "Expires": 600000 
   },
   "Agora": {
     "appId": "4a4f7be64fa1404ebda74784fe9ac381",
     "appSecret": "255e05d96c794251b282a0de84242355",
-    "tokenExpireTimeInSecond": 7200,
+    "tokenExpireTimeInSecond": 86400,
     "apiPrefix": "https://api.sd-rtn.com/",
     "clientId": "80cdc24f7dfa4497a37d98da95a3c4a4",
     "clientSecret": "8323581d4d464114b1f324b26cc62e09",

WGShare.API/appsettings.json

@@ -13,20 +13,20 @@
     "SecretKey": "apDbztyqjSNuvWnezhbdUxduhDidZbF897t2uTJs53RMdY9Cai7eexavBhka3HN6mcTe9oohjFg6bNffRRkcfMqnVKNBnmyPzkRgNopHGJAL7KMwkeZdZ7BaWnT57jCi11",
     "Issuer": "WGshareApi",
     "Audience": "WGshareClient",
-    // 过期 秒  
+    // 过期 秒   360 天
-    "Expires": 86400
+    "Expires": 31104000
   },
   "ConnectionStrings": {
-    "metting": "Database=metting;Server=rds-proxy-internal.rwlb.cn-chengdu.rds.aliyuncs.com;Port=3306;Uid=marking;Pwd=poiuytPOIUYT098765)(*&^%;AllowZeroDateTime=True;ConvertZeroDateTime=True;",
+    "metting": "Database=metting;Server=rds-external.23544.com;Port=3306;Uid=marking;Pwd=poiuytPOIUYT098765)(*&^%;AllowZeroDateTime=True;ConvertZeroDateTime=True;",
-    "usercenter": "Database=usercenter;Server=rds-proxy-internal.rwlb.cn-chengdu.rds.aliyuncs.com;Port=3306;Uid=marking;Pwd=poiuytPOIUYT098765)(*&^%;AllowZeroDateTime=True;ConvertZeroDateTime=True;"
+    "usercenter": "Database=usercenter;Server=rds-external.23544.com;Port=3306;Uid=marking;Pwd=poiuytPOIUYT098765)(*&^%;AllowZeroDateTime=True;ConvertZeroDateTime=True;"
   },
   "Redis": {
-    "master": "172.29.33.83:16379,password=poiuyt)(*&^%,defaultDatabase=6,prefix=wgshare:"
+    "master": "redis-internal.23544.com:16379,password=poiuyt)(*&^%,defaultDatabase=6,prefix=wgshare:"
   },
   "Agora": {
     "appId": "dcfc466a6ecb4a1f972630065dfb1e75",
     "appSecret": "fc77000e329b4be7a0e26fa789e20d00",
-    "tokenExpireTimeInSecond": 7200,
+    "tokenExpireTimeInSecond": 72000,
     "apiPrefix": "https://api.sd-rtn.com/",
     "clientId": "80cdc24f7dfa4497a37d98da95a3c4a4",
     "clientSecret": "8323581d4d464114b1f324b26cc62e09",
@@ -38,5 +38,9 @@
     "Endpoint": "oss-cn-chengdu.aliyuncs.com",
     "Host": "https://wgshare.oss-cn-chengdu.aliyuncs.com/",
     "BucketName": "wgshare"
+  },
+  "miniProgram": {
+    "appId": "wx99885b1c181cda72",
+    "appSecret": "edd9cdb04c3f59fe70f2a70c396e5b0d"
   }
 }

WGShare.Domain/Constant/RedisKeyConstant.cs

@@ -86,5 +86,12 @@ namespace WGShare.Domain.Constant
         {
             public static string MeetingRecord => "meeting_record";
         }
+
+        public class WxMiniProgram
+        {
+            public static string AccessTokenKey => $@"wx_mini_program:accessToken";
+
+            public static string GetRoomQrCode(string roomNum, string env) => $@"wx_mini_program:room_qrcode:{env}:{roomNum}";
+        }
     }
 }

WGShare.Domain/DTOs/Home/FeedBackRequset.cs

@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using WGShare.Domain.Enums;
+
+namespace WGShare.Domain.DTOs.Home
+{
+    public class FeedBackRequset
+    {
+        /// <summary>
+        /// 分值
+        /// </summary>
+        public double Score { get; set; }
+
+        /// <summary>
+        /// 反馈内容
+        /// </summary>
+        public string OtherContent { get; set; }
+
+        /// <summary>
+        /// 反馈类型
+        /// </summary>
+        public List<int> Types { get; set; }
+    }
+}

WGShare.Domain/DTOs/Home/UserVersionLogDto.cs

@@ -0,0 +1,29 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Yitter.IdGenerator;
+
+namespace WGShare.Domain.DTOs.Home
+{
+    public class UserVersionLogDto
+    {
+
+           
+        /// <summary>
+        /// 使用版本
+        ///</summary> 
+        public string Version { get; set; }
+        /// <summary>
+        /// 平台类型 1:PC 2:微信小程序
+        ///</summary> 
+        public int PlatformType { get; set; }
+
+        /// <summary>
+        /// 房间号
+        ///</summary> 
+        public string RoomNum { get; set; } 
+    }
+}

WGShare.Domain/DTOs/MiniProgram/AccessTokenApiResult.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace WGShare.Domain.DTOs.MiniProgram
+{
+    public class AccessTokenApiResult : WxMiniProgramBaseApiResult
+    {
+        public string access_token { get; set; }
+        public int expires_in { get; set; }
+    }
+}

WGShare.Domain/DTOs/MiniProgram/JsCode2SessionApiResult.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace WGShare.Domain.DTOs.MiniProgram
+{
+    public class JsCode2SessionApiResult
+    {
+        public string openid { get; set; }
+        public string seesionkey { get; set; }
+        public string unionid { get; set; }
+        public int errorcode { get; set; }
+        public string errmsg { get; set; }
+    }
+}

WGShare.Domain/DTOs/MiniProgram/WxMiniProgramBaseApiResult.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace WGShare.Domain.DTOs.MiniProgram
+{
+    public class WxMiniProgramBaseApiResult
+    {
+        public int errorcode { get; set; }
+        public string errmsg { get; set; }
+    }
+}

WGShare.Domain/DTOs/MiniProgram/wxacodeunlimitBody.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace WGShare.Domain.DTOs.MiniProgram
+{
+    public class wxacodeunlimitBody
+    {
+        public string scene { get; set; }
+        public string page { get; set; }
+        public bool check_path { get; set; }
+        public string env_version { get; set; }
+        public int width { get; set; }
+
+    }
+}

WGShare.Domain/DTOs/Room/RoomInputDTO.cs

@@ -28,6 +28,7 @@ namespace WGShare.Domain.DTOs.Room
         /// 科目
         ///</summary> 
         public SubjectType Subject { get; set; }
+
     }
 
 
@@ -47,5 +48,10 @@ namespace WGShare.Domain.DTOs.Room
         ///  会议室名称
         /// </summary>
         public string RoomName { get; set; }
+
+        /// <summary>
+        /// 是否允许匿名
+        /// </summary>
+        public bool AllowAnonymous { get; set; } = true;
     }
 }

WGShare.Domain/DTOs/Room/RoomManagerInputDTO.cs

@@ -12,5 +12,9 @@ namespace WGShare.Domain.DTOs.Room
         public string RoomId { get; set; }
         public string RoomNum { get; set; }
         public string UserId { get; set; }
+        /// <summary>
+        /// 设置人Id
+        /// </summary>
+        public string SettingUserId { get; set; }
     }
 }

WGShare.Domain/DTOs/Room/RoomOutputDTO.cs

@@ -34,5 +34,7 @@ namespace WGShare.Domain.DTOs.Room
         /// 科目
         ///</summary> 
         public SubjectType Subject { get; set; }
+
+        public bool AllowAnonymous { get; set; }
     } 
 }

WGShare.Domain/DTOs/User/UserModifyNickNameDto.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace WGShare.Domain.DTOs.User
+{
+    public class UserModifyNickNameDto
+    {
+        public string RoomNum { get; set; }
+        public string NickName { get; set; }
+        public long  UId { get; set; }
+    }
+}

WGShare.Domain/Entities/FeedbackIssue.cs

@@ -0,0 +1,52 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using SqlSugar;
+using WGShare.Domain.Enums;
+using Yitter.IdGenerator;
+namespace WGShare.Domain.Entities
+{
+    /// <summary>
+    /// 反馈问题表
+    ///</summary>
+    [SugarTable("feedback_issue")]
+    public class FeedbackIssue
+    {
+        /// <summary>
+        ///  
+        ///</summary>
+        [SugarColumn(ColumnName = "id", IsPrimaryKey = true)]
+        public string Id { get; set; } = YitIdHelper.NextId().ToString();
+       
+        /// <summary>
+        /// 创建时间 
+        /// 默认值: CURRENT_TIMESTAMP
+        ///</summary>
+        [SugarColumn(ColumnName = "create_time", IsOnlyIgnoreInsert = true, IsOnlyIgnoreUpdate = true)]
+        public DateTime CreateTime { get; set; }
+        
+        /// <summary>
+        /// 用户id 
+        ///</summary>
+        [SugarColumn(ColumnName = "uid")]
+        public long UID { get; set; }
+
+        /// <summary>
+        /// 分值 
+        ///</summary>
+        [SugarColumn(ColumnName = "score")]
+        public double Score { get; set; }
+
+        /// <summary>
+        /// 反馈其他 
+        ///</summary>
+        [SugarColumn(ColumnName = "other_content")]
+        public string OtherContent { get; set; }
+
+        /// <summary>
+        /// 反馈其他 
+        ///</summary>
+        [SugarColumn(ColumnName = "types")]
+        public string Types { get; set; }
+    }
+}

WGShare.Domain/Entities/Room.cs

@@ -62,5 +62,18 @@ namespace WGShare.Domain.Entities
         ///</summary>
         [SugarColumn(ColumnName = "subject")]
         public SubjectType Subject { get; set; }
+
+        /// <summary>
+        /// 是否允许匿名
+        ///</summary>
+        [SugarColumn(ColumnName = "allow_anonymous")]
+        public bool AllowAnonymous { get; set; } = true;
+
+
+        /// <summary>
+        /// 租户名称
+        /// </summary>
+        [SugarColumn(IsIgnore = true)]
+        public string TenantName { get; set; }
     }
 }

WGShare.Domain/Entities/UserVersionLog.cs

@@ -0,0 +1,52 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Security.Principal;
+using System.Text;
+using System.Threading.Tasks;
+using Yitter.IdGenerator;
+
+namespace WGShare.Domain.Entities
+{
+    /// <summary>
+    /// 用户版本记录表
+    /// </summary>
+    [SugarTable("user_version_log")]
+    public class UserVersionLog
+    {
+        /// <summary>
+        ///  
+        ///</summary>
+        [SugarColumn(ColumnName = "id", IsPrimaryKey = true, IsIdentity = true)]
+        public string Id { get; set; } = YitIdHelper.NextId().ToString();
+        /// <summary>
+        /// 用户Id
+        ///</summary>
+        [SugarColumn(ColumnName = "user_id")]
+        public long UserId { get; set; }
+        /// <summary>
+        /// 使用版本
+        ///</summary>
+        [SugarColumn(ColumnName = "version")]
+        public string Version { get; set; }
+        /// <summary>
+        /// 平台类型
+        ///</summary>
+        [SugarColumn(ColumnName = "platform_type")]
+        public int PlatformType { get; set; }
+
+        /// <summary>
+        /// 房间号
+        ///</summary>
+        [SugarColumn(ColumnName = "room_num")]
+        public string RoomNum { get; set; }
+
+        /// <summary>
+        /// 进房时间
+        ///</summary>
+        [SugarColumn(ColumnName = "join_time", IsOnlyIgnoreInsert = true, IsOnlyIgnoreUpdate = true)]
+        public DateTime JoinTime { get; set; }
+
+    }
+}

WGShare.Domain/Enums/FeedbackIssueEnums.cs

@@ -0,0 +1,48 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace WGShare.Domain.Enums
+{
+    /// <summary>
+    /// 反馈问题枚举
+    /// </summary>
+    public enum FeedbackIssueEnums
+    {
+        /// <summary>
+        /// 其他
+        /// </summary>
+        Other = 1,
+        /// <summary>
+        /// 软件卡顿
+        /// </summary>
+        SoftwareLag = 2,
+
+        /// <summary>
+        /// 设计不合理
+        /// </summary>
+        UnreasonableDesign = 3,
+
+        /// <summary>
+        /// 功能太少
+        /// </summary>
+        TooLittleFeatures = 4,
+
+        /// <summary>
+        /// 通话不流畅
+        /// </summary>
+        CallIsNotSmooth = 5,
+
+        /// <summary>
+        /// 视频卡顿
+        /// </summary>
+        VideoLag = 6,
+
+        /// <summary>
+        /// 操作麻烦
+        /// </summary>
+        OperationTrouble
+    }
+}

WGShare.Domain/FriendlyException/ExceptionNotice.cs

@@ -1,5 +1,6 @@
 using System.Net.Http.Json;
 using WGShare.Domain.DTOs.AgoraCallback;
+using WGShare.Domain.Entities;
 
 namespace WGShare.Domain.FriendlyException
 {
@@ -41,7 +42,7 @@ namespace WGShare.Domain.FriendlyException
 
         }
 
-        public static async Task JoinAsync(EventBody eventBody)
+        public static async Task JoinAsync(EventBody eventBody, Room roomInfo)
         {
             // 获取当前的日期
             DateTime today = DateTime.Today;
@@ -69,7 +70,7 @@ namespace WGShare.Domain.FriendlyException
                 markdown = new
                 {
                     title = "有人入会通知",
-                    text = $"有人进入会议室了,会议号:{eventBody.payload.channelName}，点击查看：https://analytics-lab.agora.io/analytics/call/search?projectId=0tOpVUrmf&fromTs={startTimestamp}&toTs={endTimestamp}"
+                    text = $"有人进入会议室了,学校:{roomInfo.TenantName},会议室名称:{roomInfo.RoomName},会议号:{eventBody.payload.channelName}. \r\n 点击查看：https://analytics-lab.agora.io/analytics/call/search?projectId=0tOpVUrmf&fromTs={startTimestamp}&toTs={endTimestamp}"
                 },
             }));
         }

WGShare.Domain/GeneralModel/PagedResult.cs

@@ -11,7 +11,7 @@ namespace WGShare.Domain.GeneralModel
     public class PagedResult<TEntity>
     {
         public PagedResult() { }
-        public PagedResult(IEnumerable<TEntity> list, int total)
+        public PagedResult(IEnumerable<TEntity> list, int total, int pageSize = 10)
         {
             Total = total;
             Items = list;
@@ -20,9 +20,19 @@ namespace WGShare.Domain.GeneralModel
         public int Total { get; set; }
         public IEnumerable<TEntity> Items { get; private set; }
 
-        public static PagedResult<TEntity> Create(IEnumerable<TEntity> list, int total)
+        private int pageSize = 10;
+
+        public int TotalPage
         {
-            return new PagedResult<TEntity>(list, total);
+            get
+            {
+                return (int)Math.Ceiling(Total / (double)pageSize);
+            }
+        }
+
+        public static PagedResult<TEntity> Create(IEnumerable<TEntity> list, int total, int pageSize = 10)
+        {
+            return new PagedResult<TEntity>(list, total, pageSize);
         }
     }
 }