marking
/
WGShare.API
19
0
Fork 0
Code Pull Requests Actions Releases 3 Activity

Compare commits

base: marking:master
Branches Tags
marking:master
marking:feautre-修复部分bug_新增修改昵称_匿名会议室
marking:feautre-小程序登录
marking:feature-签到
marking:feature-会议室区分
marking:feature-申请发言优化
marking:feature-匿名登录
marking:feature-考勤
marking:v0.8.0
marking:v0.7.1
marking:v0.7.0
..
compare: marking:feature-签到
Branches Tags
marking:master
marking:feautre-修复部分bug_新增修改昵称_匿名会议室
marking:feautre-小程序登录
marking:feature-签到
marking:feature-会议室区分
marking:feature-申请发言优化
marking:feature-匿名登录
marking:feature-考勤
marking:v0.8.0
marking:v0.7.1
marking:v0.7.0

No commits in common. "master" and "feature-签到" have entirely different histories.
master ... feature-签到

35 changed files with 122 additions and 1133 deletions
Show Stats Expand all files Collapse all files

16
WGShare.API/AntDeploy.json
View File

@ -24,23 +24,13 @@
"LinuxServerList": [
{
"UserName": "marking",
"Pwd": "CE09921E2AD09E56095579DF1F7C614B",
"Pwd": "0610DBF49053E6779393A74BE1ED4FD2",
"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": [],
@ -125,11 +115,11 @@
"DockerConfig": {
"Prot": "5192:5192",
"AspNetCoreEnv": "",
"LastEnvName": "marking001",
"LastEnvName": "29dev",
"RemoveDaysFromPublished": "10",
"WorkDir": "",
"Volume": "",
"Other": "--name wgshare-api -e ASPNETCORE_ENVIRONMENT=Production -e TZ=Asia/Shanghai",
"Other": "--name wgshare-api -e ASPNETCORE_ENVIRONMENT=Development -e TZ=Asia/Shanghai",
"EnvPairList": [
{
"EnvName": "29dev",

38
WGShare.API/Controllers/AuthController.cs
View File

@ -51,27 +51,6 @@ 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>
@ -115,7 +94,6 @@ 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));
@ -129,7 +107,7 @@ namespace WGShare.API.Controllers
pipe.Del(RedisKeyConstant.Data.GetRefreshTokenKey(tokens.RefreshToken));
}
// 设置新的刷新token
pipe.Set(RedisKeyConstant.Data.GetRefreshTokenKey(refreshToken), user, TimeSpan.FromDays(360).TotalSeconds.ToInt32());
pipe.Set(RedisKeyConstant.Data.GetRefreshTokenKey(refreshToken), user, TimeSpan.FromDays(7).TotalSeconds.ToInt32());
// 记录accessToken
pipe.Set(RedisKeyConstant.Data.GetAccessTokenKey(user.Id), new AccessAndRefreshToken
{
@ -191,14 +169,13 @@ 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(360).TotalSeconds.ToInt32());
pipe.Set(RedisKeyConstant.Data.GetRefreshTokenKey(refreshTokenNew), user, TimeSpan.FromDays(7).TotalSeconds.ToInt32());
pipe.Set(RedisKeyConstant.Data.GetAccessTokenKey(user.Id), new AccessAndRefreshToken
{
AccessToken = accessToken,
@ -274,10 +251,10 @@ namespace WGShare.API.Controllers
}
// 修改用户名
await _sqlSugar.Updateable<User>()
.SetColumns(x => x.UserName == loginDTO.NickName)
.Where(x => x.Id == user.Id)
.ExecuteCommandHasChangeAsync();
await _sqlSugar.Updateable<User>()
.SetColumns(x => x.UserName == loginDTO.NickName)
.Where(x => x.Id == user.Id)
.ExecuteCommandHasChangeAsync();
}
var btnAutn = new List<Claim>();
@ -287,12 +264,11 @@ 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,

30
WGShare.API/Controllers/Basic/BasicController.cs
View File

@ -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,25 +149,5 @@ 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;
}
}
}
}

13
WGShare.API/Controllers/Frontend/AgoraCallbackController.cs
View File

@ -165,18 +165,9 @@ namespace WGShare.API.Controllers.Frontend
return;
}
if (existsChannel.TryAdd(eventBody.payload.channelName, 0))
if(existsChannel.TryAdd(eventBody.payload.channelName, 0))
{
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);
ExceptionNotice.JoinAsync(eventBody);
}
}

100
WGShare.API/Controllers/Frontend/HomeController.cs
View File

@ -1,6 +1,5 @@
using AgoraIO.Media;
using AgoraIO.Rtm;
using Azure;
using Mapster;
using Masuit.Tools;
using Microsoft.AspNetCore.Mvc;
@ -8,15 +7,11 @@ 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;
@ -40,7 +35,6 @@ 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,
@ -48,8 +42,7 @@ namespace WGShare.API.Controllers.Frontend
IHttpClientFactory httpClientFactory,
AgoraHelper agoraHelper,
ILogger<HomeController> logger,
OssHelper ossHelper,
MiniProgramHelper miniProgramHelper)
OssHelper ossHelper)
{
_sqlSugar = sqlSugar;
this._configuration = configuration;
@ -57,7 +50,6 @@ namespace WGShare.API.Controllers.Frontend
this._agoraHelper = agoraHelper;
this._logger = logger;
this._ossHelper = ossHelper;
this._miniProgramHelper = miniProgramHelper;
}
@ -91,7 +83,7 @@ namespace WGShare.API.Controllers.Frontend
//}
}
return PagedResult<RoomOutputDTO>.Create(result, total.Value, dto.PageSize);
return PagedResult<RoomOutputDTO>.Create(result, total.Value);
}
/// <summary>
@ -111,9 +103,7 @@ namespace WGShare.API.Controllers.Frontend
entity.Id = YitIdHelper.NextId().ToString();
entity.TenantId = TenantId;
var room = await _sqlSugar.Queryable<Room>().FirstAsync(x => x.RoomNum == inputDTO.RoomNum);
if (room != null)
if (await _sqlSugar.Queryable<Room>().AnyAsync(x => x.RoomNum == inputDTO.RoomNum))
{
throw Oops.Oh("无效会议号,请重新输入");
}
@ -131,7 +121,7 @@ namespace WGShare.API.Controllers.Frontend
{
var entity = inputDTO.Adapt<Room>();
return await _sqlSugar.Updateable(entity)
.UpdateColumns(x => new { x.Year, x.Subject, x.RoomName, x.AllowAnonymous })
.UpdateColumns(x => new { x.Year, x.Subject })
.ExecuteCommandHasChangeAsync();
}
@ -301,87 +291,5 @@ 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();
}
}
}

190
WGShare.API/Controllers/Frontend/RoomController.cs
View File

@ -3,7 +3,6 @@ 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;
@ -63,11 +62,10 @@ 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()) >= 20)
if (users.Count(x => x.IsRoomManager || x.RoleId == ((int)RoleEnums.Admin).ToString() || x.RoleId == ((int)RoleEnums.RoomManager).ToString()) >= 12)
{
throw Oops.Oh("当前房间已达最大发言人数！");
throw Oops.Oh("房间已达到12个发言人限制。请移除一位发言人");
}
var user = users.FirstOrDefault(x => x.UID == inputDTO.UserId);
if (user == null)
@ -75,13 +73,11 @@ namespace WGShare.API.Controllers.Frontend
throw Oops.Oh("用户已不在房间内！");
}
await _hubContext.Clients.User(inputDTO.UserId).SetSpeaker(inputDTO);
user.IsRoomManager = true;
//user.IsRoomManager = true;
RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, inputDTO.RoomNum), inputDTO.UserId, user);
//RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, inputDTO.RoomNum), inputDTO.UserId, user);
//await _hubContext.Clients.Group(inputDTO.RoomNum).ManagerRefresh(user, UId);
await _hubContext.Clients.Group(inputDTO.RoomNum).ManagerRefresh(user, UId);
}
/// <summary>
@ -99,35 +95,23 @@ 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)
{
RedisHelper.Instance.HSet(RedisKeyConstant.SessionManage.GetChannelShowUserKey(TenantId), inputDTO.RoomNum, showUser.UID);
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);
}
//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);
await _hubContext.Clients.Group(inputDTO.RoomNum).ShowUser(UId, UserName, string.Empty, string.Empty);
//}
}
await _hubContext.Clients.Group(inputDTO.RoomNum).ManagerRefresh(user, UId);
@ -206,34 +190,7 @@ namespace WGShare.API.Controllers.Frontend
[HttpGet("checkout"), AllowAnonymous]
public async Task<bool> ExistsRoom([FromQuery] string roomNum)
{
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;
}
return await _sqlSugar.Queryable<Room>().AnyAsync(x => x.RoomNum == roomNum && x.IsDelete == false);
}
/// <summary>
@ -342,7 +299,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);
}
@ -383,25 +340,13 @@ namespace WGShare.API.Controllers.Frontend
}
// 获取全部用户
var userInfos = RedisHelper.Instance.HVals<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, roomNum));
if (userInfos.IsNullOrEmpty())
var uids = RedisHelper.Instance.HKeys(RedisKeyConstant.SessionManage.GetChannelUserKey(TenantId, roomNum));
if (uids.IsNullOrEmpty())
{
throw Oops.Oh("无效会议号！");
}
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;
return uids.FirstOrDefault();
}
/// <summary>
@ -411,13 +356,6 @@ 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);
@ -628,78 +566,10 @@ namespace WGShare.API.Controllers.Frontend
if (connectionIds.Any())
{
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);
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>
@ -816,21 +686,5 @@ 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);
}
}
}

33
WGShare.API/Controllers/PublicController.cs
View File

@ -11,7 +11,6 @@ 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;
@ -27,19 +26,10 @@ 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,
IHttpClientFactory httpClientFactory,
Microsoft.Extensions.Configuration.IConfiguration configuration,
ILogger<PublicController> logger)
public PublicController(ISqlSugarClient sqlSugar)
{
_sqlSugar = sqlSugar;
this._httpClientFactory = httpClientFactory;
this._configuration = configuration;
this._logger = logger;
}
/// <summary>
@ -79,26 +69,5 @@ 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;
}
}
}

59
WGShare.API/Helpers/MiniProgramHelper.cs
View File

@ -1,59 +0,0 @@
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;
}
}
}

36
WGShare.API/Helpers/QrCodeOptimizerHelper.cs
View File

@ -1,36 +0,0 @@
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);
}
}
}
}
}

45
WGShare.API/Hubs/IMessageClient.cs
View File

@ -1,6 +1,4 @@
using SignalRSwaggerGen.Attributes;
using WGShare.Domain.DTOs.Room;
using WGShare.Domain.DTOs.User;
using WGShare.Domain.DTOs.User;
using WGShare.Domain.Entities;
namespace WGShare.API.Hubs
@ -8,7 +6,6 @@ namespace WGShare.API.Hubs
/// <summary>
/// 客户端消息
/// </summary>
[SignalRHub]
public interface IMessageClient
{
/// <summary>
@ -47,7 +44,7 @@ namespace WGShare.API.Hubs
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
Task Operation(string contentString);
Task Operation(int type);
/// <summary>
/// 更新视图
@ -61,12 +58,6 @@ 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>
@ -153,37 +144,5 @@ 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);
}
}

200
WGShare.API/Hubs/SessionManageHub.cs
View File

@ -2,22 +2,17 @@
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
@ -46,11 +41,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);
_logger.LogInformation($"{DateTime.Now}连接成功 当前租户：{tenant} account：{account} uid:{uid} connectId:{Context.ConnectionId}");
Console.WriteLine($"{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);
}
@ -63,11 +58,11 @@ namespace WGShare.API.Hubs
var ssid = Context.User?.Claims.FirstOrDefault(x => x.Type == "ssid")?.Value;
_logger.LogInformation($"{DateTime.Now}断开连接 当前租户：{tenant} account：{account} uid:{uid} connectId:{Context.ConnectionId} exception:{exception?.Message} ");
Console.WriteLine($"{DateTime.Now}断开连接 当前租户：{tenant} account：{account} uid:{uid} connectId:{Context.ConnectionId} exception:{exception?.Message} ");
if (Context.ConnectionId == RedisHelper.Instance.HGet(RedisKeyConstant.SessionManage.GetOnlineUserKey(tenant), uid))
{
_logger.LogInformation($"{DateTime.Now}断开连接 未重连，开始删除用户频道信息");
Console.WriteLine($"{DateTime.Now}断开连接 未重连，开始删除用户频道信息");
// 断开后未重连则清退频道
await ClearUserChannel(uid, tenant, account, ssid, true);
@ -77,14 +72,17 @@ namespace WGShare.API.Hubs
private async Task ClearUserChannel(string uid, string tenant, string account, string ssid, bool isclose)
{
_logger.LogInformation($"{DateTime.Now} 执行删除开始");
Console.WriteLine($"{DateTime.Now} 执行删除开始");
// 获取用户参加得频道
var roomNum = RedisHelper.Instance.Get(RedisKeyConstant.SessionManage.GetUserJoinChannelKey(uid));
using (var pipe = RedisHelper.Instance.StartPipe())
{
_logger.LogInformation($@"{DateTime.Now} account:{account} 退出以下频道：{string.Join(',', roomNum)}");
Console.WriteLine($@"{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
@ -92,9 +90,6 @@ 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);
}
// 删除用户在线状态
@ -103,31 +98,14 @@ namespace WGShare.API.Hubs
// 删除用户已加入频道信息
pipe.Del(RedisKeyConstant.SessionManage.GetUserJoinChannelKey(uid));
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);
}
}
pipe.EndPipe();
}
if (!string.IsNullOrEmpty(roomNum))
// 通知房间其他用户，该用户退出
await Clients.Group(roomNum).UserLeave(uid);
_logger.LogInformation($"{DateTime.Now} 执行删除完成");
Console.WriteLine($"{DateTime.Now} 执行删除完成");
}
/// <summary>
@ -137,7 +115,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;
@ -145,32 +123,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);
var userInfo = new ChannelUserInfo
if (((RoleEnums)roleId.ToInt32()) == RoleEnums.Admin || ((RoleEnums)roleId.ToInt32()) == RoleEnums.RoomManager)
{
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())
{
if (((RoleEnums)roleId.ToInt32()) == RoleEnums.Admin || ((RoleEnums)roleId.ToInt32()) == RoleEnums.RoomManager)
{
// 管理员进房，如果没有全员看ta，则设置
var script = @"local hashKey = KEYS[1]
// 管理员进房，如果没有全员看ta，则设置
var script = @"local hashKey = KEYS[1]
local field = ARGV[1]
local value = ARGV[2]
@ -180,34 +158,25 @@ 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);
}
catch (Exception ex)
{
await Groups.AddToGroupAsync(Context.ConnectionId, roomNum);
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>
@ -223,9 +192,9 @@ namespace WGShare.API.Hubs
var roleId = Context.User?.Claims.FirstOrDefault(x => x.Type == "roleid")?.Value;
_logger.LogInformation($" {DateTime.Now}离开频道 会议号：" + roomNum);
_logger.LogInformation($" {DateTime.Now}离开频道 account：" + account);
_logger.LogInformation($" {DateTime.Now}离开频道 tenant：" + tenant);
Console.WriteLine($" {DateTime.Now}离开频道 会议号：" + roomNum);
Console.WriteLine($" {DateTime.Now}离开频道 account：" + account);
Console.WriteLine($" {DateTime.Now}离开频道 tenant：" + tenant);
using (var pipe = RedisHelper.Instance.StartPipe())
{
@ -243,16 +212,10 @@ 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 showUsers = users.Where(x => x.RoleId == ((int)RoleEnums.Admin).ToString() || x.IsRoomManager || x.RoleId == ((int)RoleEnums.RoomManager).ToString()).ToList();
if (!showUsers.IsNullOrEmpty())
var showUser = users.FirstOrDefault(x => x.RoleId == ((int)RoleEnums.Admin).ToString() || x.IsRoomManager || x.RoleId == ((int)RoleEnums.RoomManager).ToString());
if (showUser != null)
{
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);
}
@ -274,18 +237,12 @@ 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}");
var userInfo = RedisHelper.Instance.HGet<ChannelUserInfo>(RedisKeyConstant.SessionManage.GetChannelUserKey(tenant, rooNum), uid);
var userName = uname;
if (userInfo != null)
{
userName = userInfo.UserName;
}
Console.WriteLine($" {DateTime.Now}发送消息 uname：" + uname);
Console.WriteLine($" {DateTime.Now}发送消息 roomNum：" + rooNum);
Console.WriteLine($" {DateTime.Now}发送消息 msg：" + msg);
await Clients.OthersInGroup(rooNum).ReceiveMessage(uid, userName, msg, DateTime.Now.GetTotalMilliseconds()); //await Clients.GroupExcept(rooNum, Context.ConnectionId).ReceiveMessage(uid, uname, msg);
await Clients.OthersInGroup(rooNum).ReceiveMessage(uid, uname, msg, DateTime.Now.GetTotalMilliseconds()); //await Clients.GroupExcept(rooNum, Context.ConnectionId).ReceiveMessage(uid, uname, msg);
}
/// <summary>
@ -293,21 +250,9 @@ namespace WGShare.API.Hubs
/// </summary>
/// <returns></returns>
[HubMethodName("sendOper")]
public async Task SendOperation(string roomNum, string contentString)
public async Task SendOperation(string roomNum, int 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);
await Clients.Group(roomNum).Operation(type);
}
/// <summary>
@ -345,32 +290,5 @@ 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);
}
}
}

4
WGShare.API/Program.cs
View File

@ -59,13 +59,12 @@ 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"],
@ -99,6 +98,7 @@ namespace WGShare.API
options.SwaggerEndpoint($"/swagger/frontend/swagger.json", "Ç°¶Ë");
options.SwaggerEndpoint($"/swagger/backend/swagger.json", "ºó¶Ë");
options.SwaggerEndpoint($"/swagger/public/swagger.json", "¹«¹²½Ó¿Ú");
});
app.UseCustomCors();
}

1
WGShare.API/ServiceConfigs/SwaggerServiceExtensions.cs
View File

@ -22,7 +22,6 @@ 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" });

1
WGShare.API/WGShare.API.csproj
View File

@ -15,7 +15,6 @@
<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>

130
WGShare.API/WGShare.API.xml
View File

@ -11,13 +11,6 @@
<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>
正常账号登录
@ -75,11 +68,6 @@
<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接口
@ -156,25 +144,6 @@
</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>
会议室接口
@ -299,24 +268,6 @@
</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>
分享上传文件
@ -365,13 +316,6 @@
<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>
获取用户列表
@ -458,12 +402,6 @@
</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 ，每个频道用户数量
@ -527,17 +465,6 @@
<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
@ -619,7 +546,7 @@
</summary>
<returns></returns>
</member>
<member name="M:WGShare.API.Hubs.IMessageClient.Operation(System.String)">
<member name="M:WGShare.API.Hubs.IMessageClient.Operation(System.Int32)">
<summary>
客户端操作
</summary>
@ -638,12 +565,6 @@
</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>
用户加入频道回调
@ -731,38 +652,6 @@
<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>
加入频道
@ -784,20 +673,12 @@
<param name="rooNum"></param>
<param name="msg"></param>
</member>
<member name="M:WGShare.API.Hubs.SessionManageHub.SendOperation(System.String,System.String)">
<member name="M:WGShare.API.Hubs.SessionManageHub.SendOperation(System.String,System.Int32)">
<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>
获取设备列表
@ -820,13 +701,6 @@
<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中得数据

4
WGShare.API/appsettings.Development.json
View File

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

16
WGShare.API/appsettings.json
View File

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

BIN
WGShare.API/signInListImportTemplate.xlsx
View File

Binary file not shown.

7
WGShare.Domain/Constant/RedisKeyConstant.cs
View File

@ -86,12 +86,5 @@ 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}";
}
}
}

27
WGShare.Domain/DTOs/Home/FeedBackRequset.cs
View File

@ -1,27 +0,0 @@
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; }
}
}

29
WGShare.Domain/DTOs/Home/UserVersionLogDto.cs
View File

@ -1,29 +0,0 @@
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; }
}
}

14
WGShare.Domain/DTOs/MiniProgram/AccessTokenApiResult.cs
View File

@ -1,14 +0,0 @@
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; }
}
}

17
WGShare.Domain/DTOs/MiniProgram/JsCode2SessionApiResult.cs
View File

@ -1,17 +0,0 @@
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; }
}
}

14
WGShare.Domain/DTOs/MiniProgram/WxMiniProgramBaseApiResult.cs
View File

@ -1,14 +0,0 @@
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; }
}
}

18
WGShare.Domain/DTOs/MiniProgram/wxacodeunlimitBody.cs
View File

@ -1,18 +0,0 @@
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; }
}
}

6
WGShare.Domain/DTOs/Room/RoomInputDTO.cs
View File

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

4
WGShare.Domain/DTOs/Room/RoomManagerInputDTO.cs
View File

@ -12,9 +12,5 @@ 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; }
}
}

2
WGShare.Domain/DTOs/Room/RoomOutputDTO.cs
View File

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

15
WGShare.Domain/DTOs/User/UserModifyNickNameDto.cs
View File

@ -1,15 +0,0 @@
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; }
}
}

52
WGShare.Domain/Entities/FeedbackIssue.cs
View File

@ -1,52 +0,0 @@
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; }
}
}

13
WGShare.Domain/Entities/Room.cs
View File

@ -62,18 +62,5 @@ 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; }
}
}

52
WGShare.Domain/Entities/UserVersionLog.cs
View File

@ -1,52 +0,0 @@
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; }
}
}

48
WGShare.Domain/Enums/FeedbackIssueEnums.cs
View File

@ -1,48 +0,0 @@
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
}
}

5
WGShare.Domain/FriendlyException/ExceptionNotice.cs
View File

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

16
WGShare.Domain/GeneralModel/PagedResult.cs
View File

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