新增 SystemMessage entity,Repository,dto

OASystem/EntitySync/Program.cs

@@ -74,8 +74,11 @@ db.CodeFirst.SetStringDefaultLength(50).BackupTable().InitTables(new Type[]
     //typeof(Res_CarData),
     //typeof(Res_LocalGuideData)
 
-    typeof(Grp_ScheduleInfo),
-    typeof(Grp_ScheduleDetailInfo),
-    typeof(Grp_SchedulePersonInfo)
+    //typeof(Grp_ScheduleInfo),
+    //typeof(Grp_ScheduleDetailInfo),
+    //typeof(Grp_SchedulePersonInfo)
+
+    //typeof(Sys_Message),
+    //typeof(Sys_MessageReadAuth)
 });
 Console.WriteLine("数据库结构同步完成!");

OASystem/OASystem.Api/Controllers/AuthController.cs

@@ -1,12 +1,11 @@
 
-using Microsoft.Extensions.Caching.Distributed;
 using OASystem.Infrastructure.Repositories.Login;
 using System.IdentityModel.Tokens.Jwt;
 using System.Security.Claims;
-using StackExchange.Redis;
 using OASystem.Domain.Dtos.UserDto;
-using OASystem.RedisRepository;
-using OASystem.Infrastructure.Repositories.System;
+using OASystem.API.OAMethodLib;
+using Serilog.Parsing;
+using OASystem.Domain.Dtos.System;
 
 namespace OASystem.API.Controllers
 {
@@ -19,17 +18,13 @@ namespace OASystem.API.Controllers
         private readonly IMapper _mapper;
         private readonly IConfiguration _config;
         private readonly LoginRepository _loginRep;
-        private readonly UsersRepository _usersRepository;
-      
-        //private IDatabase _redis; 
-        //private RedisHelper _redisHelper;
-        public AuthController(IConfiguration config, LoginRepository loginRep, IMapper mapper)
+        private readonly MessageRepository _message; 
+        public AuthController(IConfiguration config, LoginRepository loginRep, IMapper mapper,MessageRepository message)
         {
             _config = config;
             _loginRep = loginRep;
             _mapper = mapper;
-           
-            //_usersRepository = usersRepository;
+            _message = message;
         }
 
         /// <summary>
@@ -54,27 +49,55 @@ namespace OASystem.API.Controllers
             #endregion
             var view = new LoginView
             {
-                Expires = DateTime.Now.AddMinutes(30),
                 UserInfo = userData.Result.Data
             };
 
+
+            DateTime createZebraTime = DateTime.UtcNow;
             string authorId = dto.Number + "Token";
+            string authorToken = await RedisRepository.RedisFactory.CreateRedisRepository().StringGetAsync<string>(authorId);//string 取
+            if (authorToken !=  null)
+            {
+                #region 解析出过期时间
+                var jwtHandler = new JwtSecurityTokenHandler();
+                JwtSecurityToken securityToken = jwtHandler.ReadJwtToken(authorToken);
+                DateTime expDt = (securityToken.Payload[JwtRegisteredClaimNames.Exp] ?? 0).GetInt().GetTimeSpmpToDate();
+                #endregion
+
+                if (expDt >= createZebraTime)  //超时重新获取token
+                {
+                    authorToken = GeneralMethod.GetToken(_config, dto.Number, createZebraTime);
+                }
+
+                view.Expires = expDt;
+                view.Token = authorToken;
+
+            }
+            else
+            {
+                view.Expires = createZebraTime.AddMinutes(30);
+                view.Token = GeneralMethod.GetToken(_config, dto.Number, createZebraTime);
+                TimeSpan ts = view.Expires.AddMinutes(-1) - createZebraTime; //设置redis 过期时间 比 jwt 时间 快一分钟
+                await RedisRepository.RedisFactory.CreateRedisRepository().StringSetAsync<string>(authorId, view.Token, ts);//string 存
+            }
 
-            var claims = new[] { new Claim(ClaimTypes.NameIdentifier, "Future") };
-            var key = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_config["JwtSecurityKey"]));
-            var creds = new SigningCredentials(key, SecurityAlgorithms.HmacSha256);
-            var token = new JwtSecurityToken(
-                issuer: "OASystem.com",
-                audience: "OASystem.com",
-                claims: claims,
-                expires: view.Expires,
-                signingCredentials: creds);
-            view.Token = new JwtSecurityTokenHandler().WriteToken(token);
-
-            //Redis  String使用示例
-            //TimeSpan ts = new TimeSpan(0, 30, 0);
-            //await RedisRepository.RedisFactory.CreateRedisRepository().StringSetAsync<string>("key01", "value01", ts);//string 存
-            //string redisString = await RedisRepository.RedisFactory.CreateRedisRepository().StringGetAsync<string>("key01");//string 取
+
+            #region 测试添加系统消息
+
+            //await _message.AddMsg(new MessageDto()
+            //{
+            //    Type = 1,
+            //    IssuerId = 208,
+            //    Title = "测试添加消息标题",
+            //    Content = "消息体测试",
+            //    ReleaseTime = DateTime.Now,
+            //    UIdList = new List<int> {
+            //        5,
+            //        208,
+            //        219
+            //    }
+            //});
+            #endregion
 
             return Ok(JsonView(view));
         }
@@ -134,7 +157,7 @@ namespace OASystem.API.Controllers
         /// </summary>
         /// <param name="dto"></param>
         /// <returns></returns>
-        [Authorize]
+        [OASystemAuthentication]
         [HttpPost("TestToken")]
         [ProducesResponseType(typeof(LoginView), StatusCodes.Status200OK)]
         public async Task<IActionResult> TestToken(LoginDto dto)

OASystem/OASystem.Api/Controllers/SystemController.cs

@@ -477,6 +477,7 @@ namespace OASystem.API.Controllers
         /// </summary>
         /// <param name="dto"></param>
         /// <returns></returns>
+        //[OASystemAuthentication]
         [HttpPost]
         [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
         public async Task<IActionResult> GetUserList(DtoBase dto)

OASystem/OASystem.Api/OAMethodLib/GeneralMethod.cs

@@ -0,0 +1,127 @@
+using OASystem.Domain.Entities.System;
+using System.IdentityModel.Tokens.Jwt;
+using System.Security.Claims;
+
+namespace OASystem.API.OAMethodLib
+{
+    public static class GeneralMethod
+    {
+       
+        #region 消息
+
+        
+
+        #endregion
+
+        #region md5 加密
+
+        /// <summary>
+        /// MD5加密,和动网上的16/32位MD5加密结果相同,
+        /// 使用的UTF8编码
+        /// </summary>
+        /// <param name="source">待加密字串</param>
+        /// <param name="length">16或32值之一,其它则采用.net默认MD5加密算法</param>
+        /// <returns>加密后的字串</returns>
+        public static string Encrypt(string source, int length = 32)
+        {
+            if (string.IsNullOrWhiteSpace(source))
+                return string.Empty;
+            HashAlgorithm hashAlgorithm = CryptoConfig.CreateFromName("MD5") as HashAlgorithm;
+            byte[] bytes = Encoding.UTF8.GetBytes(source);
+            byte[] hashValue = hashAlgorithm.ComputeHash(bytes);
+            StringBuilder sb = new StringBuilder();
+            switch (length)
+            {
+                case 16://16位密文是32位密文的9到24位字符
+                    for (int i = 4; i < 12; i++)
+                    {
+                        sb.Append(hashValue[i].ToString("x2"));
+                    }
+                    break;
+                case 32:
+                    for (int i = 0; i < 16; i++)
+                    {
+                        sb.Append(hashValue[i].ToString("x2"));
+                    }
+                    break;
+                default:
+                    for (int i = 0; i < hashValue.Length; i++)
+                    {
+                        sb.Append(hashValue[i].ToString("x2"));
+                    }
+                    break;
+            }
+            return sb.ToString();
+        }
+
+
+        #endregion
+
+        #region jwt
+
+        /// <summary>
+        ///  获取token 
+        /// </summary>
+        /// <param name="_config"></param>
+        /// <param name="Number"></param>
+        /// <param name="exp"></param>
+        /// <returns></returns>
+        public static string GetToken(IConfiguration _config,string Number,DateTime exp) 
+        {
+            var claims = new[] {
+                new Claim(ClaimTypes.NameIdentifier, "Future"),
+                new Claim("Number",Number)
+            };
+            var key = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_config["JwtSecurityKey"]));
+            var creds = new SigningCredentials(key, SecurityAlgorithms.HmacSha256);
+            var token = new JwtSecurityToken(
+                issuer: "OASystem.com",
+                audience: "OASystem.com",
+                claims: claims,
+                expires: exp,
+                signingCredentials: creds);
+           
+            
+            return   new JwtSecurityTokenHandler().WriteToken(token);
+
+        }
+
+
+        #endregion
+
+        #region  数据类型转换
+
+        /// <summary>
+        /// object 转 Int
+        /// </summary>
+        /// <param name="obj"></param>
+        /// <returns></returns>
+        public static int GetInt(this object obj)
+        {
+            if (obj == null)
+                return 0;
+            int _number = 0;
+            bool reslut = Int32.TryParse(obj.ToString(), out _number);
+            return _number;
+
+        }
+
+        private static DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
+        private static long longTime = 621355968000000000;
+        private static int samllTime = 10000000;
+        /// <summary>
+        /// 时间戳 转 datetime
+        /// </summary>
+        /// <param name="timeStamp"></param>
+        /// <returns></returns>
+        public static DateTime GetTimeSpmpToDate(this object timeStamp)
+        {
+            if (timeStamp == null) return dateStart;
+            DateTime dateTime = new DateTime(longTime + Convert.ToInt64(timeStamp) * samllTime, DateTimeKind.Utc).ToLocalTime();
+            return dateTime;
+        }
+
+        #endregion
+
+    }
+}

OASystem/OASystem.Api/OASystemAuthentication.cs

@@ -1,13 +1,49 @@
 using Microsoft.AspNetCore.Mvc.Filters;
-using Microsoft.IdentityModel.Tokens;
 using System.IdentityModel.Tokens.Jwt;
-using IAuthorizationFilter = Microsoft.AspNetCore.Mvc.Filters.IAuthorizationFilter;
 
 namespace OASystem.API
 {
     public class OASystemAuthentication : AuthorizeAttribute
     {
+        public void OnAuthorization(AuthorizationFilterContext context)
+        {
+            string id = context.HttpContext.User.FindFirst("id")?.Value;
+            if (string.IsNullOrEmpty(id))
+            {
+                context.Result = new StatusCodeResult(401); //返回鉴权失败
+                return;
+            }
 
+            Console.WriteLine("我是Authorization过滤器");
+            // 请求的地址
+            //var url = context.HttpContext.Request.Path.Value;
+            // 请求头信息
+            var heads = context.HttpContext.Request.Headers;
 
+
+
+            string token = heads["Authorization"];
+            token = token.Replace("Bearer ", "");//去掉 "Bearer "才是真正的token
+            if (string.IsNullOrEmpty(token))
+            {
+                Console.WriteLine("校验不通过");
+                return;
+            }
+
+            //redis校验这个token的有效性，确定来源是sso和确定会话没过期
+            //解析员工userNumber
+            var jwtHandler = new JwtSecurityTokenHandler();
+            JwtSecurityToken securityToken = jwtHandler.ReadJwtToken(token);
+            //DateTime expDt = (securityToken.Payload[JwtRegisteredClaimNames.c] ?? 0).GetInt().GetTimeSpmpToDate();
+
+
+            //if (!_cacheService.StringGet<bool>($"token:{token}"))
+            //{
+            //    Console.WriteLine($"token无效,token:{token}");
+            //    context.Result = new StatusCodeResult(401); //返回鉴权失败
+            //    return;
+            //}
+
+        }
     }
 }

OASystem/OASystem.Api/Program.cs

@@ -31,8 +31,6 @@ builder.Services.AddCors(policy =>
 
 #endregion
 
-
-
 #region 接口分组
 var groups = new List<Tuple<string, string>>
 {
@@ -140,21 +138,22 @@ if (AppSettingsHelper.Get("UseSwagger").ToBool())
 #region 添加校验
 
 //builder.Services.AddTransient<OASystemAuthentication>();
-builder.Services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme).AddJwtBearer(options =>
-{
-    options.TokenValidationParameters = new TokenValidationParameters
-    {
-        ValidateIssuer = true,
-        ValidateAudience = true,
-        ValidateLifetime = true,
-        ValidateIssuerSigningKey = true,
-        ValidAudience = "OASystem.com",
-        ValidIssuer = "OASystem.com",
-        IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_config["JwtSecurityKey"])),
-        ClockSkew = TimeSpan.FromSeconds(30), //过期时间容错值，解决服务器端时间不同步问题（秒）
-        RequireExpirationTime = true,
-    };
-});
+builder.Services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme)
+    .AddJwtBearer(options =>
+        {
+            options.TokenValidationParameters = new TokenValidationParameters
+            {
+                ValidateIssuer = true,
+                ValidateAudience = true,
+                ValidateLifetime = true,
+                ValidateIssuerSigningKey = true,
+                ValidAudience = "OASystem.com",
+                ValidIssuer = "OASystem.com",
+                IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_config["JwtSecurityKey"])),
+                ClockSkew = TimeSpan.FromSeconds(30), //过期时间容错值，解决服务器端时间不同步问题（秒）
+                RequireExpirationTime = true,
+            };
+        });
 #endregion
 
 #region 初始化日志

OASystem/OASystem.Domain/AutoMappers/_baseMappingProfile.cs

@@ -11,11 +11,17 @@ namespace OASystem.Domain.AutoMappers
     {
         public _baseMappingProfile()
         {
-            //CreateMap<OrderDto, Order>();
             #region Login
             CreateMap<LoginDto, Sys_Users>();
             #endregion
 
+
+            #region 消息
+
+            CreateMap<Sys_Message, DepartmentIView>();
+            CreateMap<Sys_MessageReadAuth, DepartmentIView>();
+            #endregion
+
             #region 公司板块
             CreateMap<Sys_Company, CompanyView>();
             CreateMap<AddCompanyDto, Sys_Company>();

OASystem/OASystem.Domain/Dtos/System/MessageDto.cs

@@ -0,0 +1,47 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OASystem.Domain.Dtos.System
+{
+    /// <summary>
+    /// 发布消息 提交参数实体类
+    /// </summary>
+    public class MessageDto
+    {
+        /// <summary>
+        /// 消息类型
+        /// 0 用户登录消息
+        /// 1 系统消息
+        /// 2 业务消息
+        /// </summary>
+        public int Type { get; set; }
+
+        /// <summary>
+        /// 发布人
+        /// </summary>
+        public int IssuerId { get; set; }
+
+        /// <summary>
+        /// 消息标题
+        /// </summary>
+        public string Title { get; set; }
+
+        /// <summary>
+        /// 消息内容
+        /// </summary>
+        public string Content { get; set; }
+
+        /// <summary>
+        /// 发布时间
+        /// </summary>
+        public DateTime ReleaseTime { get; set; }
+
+        /// <summary>
+        /// 可阅读员工
+        /// </summary>
+        public List<int> UIdList { get; set; }
+    }
+}

OASystem/OASystem.Domain/Entities/System/Sys_Message.cs

@@ -0,0 +1,47 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OASystem.Domain.Entities.System
+{
+    /// <summary>
+    /// 系统消息 表
+    /// </summary>
+    public class Sys_Message :EntityBase
+    {
+        /// <summary>
+        /// 类型
+        /// 0 用户登录消息
+        /// 1 系统消息
+        /// 2 业务消息
+        /// </summary>
+        [SugarColumn(IsNullable = true,ColumnDataType = "int")]
+        public int Type { get; set; }
+
+        /// <summary>
+        /// 发布者用户Id
+        /// </summary>
+        [SugarColumn(IsNullable = true,ColumnDataType = "int")]
+        public int IssuerId { get; set; }
+
+        /// <summary>
+        /// 消息标题
+        /// </summary>
+        [SugarColumn(IsNullable = true,ColumnDataType = "varchar(100)")]
+        public string Title { get; set; }
+
+        /// <summary>
+        /// 消息内容
+        /// </summary>
+        [SugarColumn(IsNullable = true,ColumnDataType = "varchar(500)")]
+        public string Content { get; set; }
+
+        /// <summary>
+        /// 发布时间
+        /// </summary>
+        [SugarColumn(IsNullable = true , ColumnDataType = "datetime")]
+        public DateTime ReleaseTime { get; set; }
+    }
+}

OASystem/OASystem.Domain/Entities/System/Sys_MessageReadAuth.cs

@@ -0,0 +1,40 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OASystem.Domain.Entities.System
+{
+    /// <summary>
+    /// 消息可读员工
+    /// </summary>
+    public class Sys_MessageReadAuth:EntityBase
+    {
+        /// <summary>
+        /// 消息Id
+        /// </summary>
+        [SugarColumn(IsNullable = true,ColumnDataType = "int")]
+        public int MsgId { get; set; }
+
+        /// <summary>
+        /// 可读用户Id
+        /// </summary>
+        [SugarColumn(IsNullable = true,ColumnDataType = "int")]
+        public int ReadableUId { get; set; }
+
+        /// <summary>
+        /// 是否已读
+        /// 0 未读
+        /// 1 已读
+        /// </summary>
+        [SugarColumn(IsNullable = true,ColumnDataType = "int")]
+        public int IsRead { get; set; }
+
+        /// <summary>
+        /// 阅读时间
+        /// </summary>
+        [SugarColumn(IsNullable = true,ColumnDataType = "datetime")]
+        public DateTime ReadTime { get; set; }
+    }
+}

OASystem/OASystem.Domain/ViewModels/System/MessageReadAuthView.cs

@@ -0,0 +1,13 @@
+using OASystem.Domain.Entities.System;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OASystem.Domain.ViewModels.System
+{
+    public class MessageReadAuthView : Sys_MessageReadAuth
+    {
+    }
+}

OASystem/OASystem.Domain/ViewModels/System/MessageView.cs

@@ -0,0 +1,14 @@
+using OASystem.Domain.Entities.System;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OASystem.Domain.ViewModels.System
+{
+    public class MessageView : Sys_Message
+    {
+    }
+
+}

OASystem/OASystem.Infrastructure/Repositories/System/MessageReadAuthRepository.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OASystem.Infrastructure.Repositories.System
+{
+    public class MessageReadAuthRepository : BaseRepository<Sys_MessageReadAuth, MessageReadAuthView>
+    {
+
+        public MessageReadAuthRepository(SqlSugarClient sqlSugar) : base(sqlSugar) { }
+
+    }
+}

OASystem/OASystem.Infrastructure/Repositories/System/MessageRepository.cs

@@ -0,0 +1,88 @@
+using OASystem.Domain.Dtos.System;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OASystem.Infrastructure.Repositories.System
+{
+    public class MessageRepository : BaseRepository<Sys_Message, MessageView>
+    {
+        public MessageRepository(SqlSugarClient sqlSugar) : base(sqlSugar) { }
+
+
+        /// <summary>
+        /// 发布消息
+        /// </summary>
+        /// <param name="msgDto"></param>
+        /// <returns></returns>
+        public async Task<bool> AddMsg(MessageDto msgDto)
+        {
+            #region 参数处理
+
+            if (msgDto == null) { return false; }
+            if (string.IsNullOrEmpty(msgDto.Title)) { return false; }
+            if (string.IsNullOrEmpty(msgDto.Content)) { return false; }
+            if (msgDto.UIdList.Count <= 0) { return false; }
+
+            #endregion
+
+            _sqlSugar.BeginTran();
+            try
+            {
+                Sys_Message message = new Sys_Message()
+                {
+                    Type = msgDto.Type,
+                    IssuerId = msgDto.IssuerId,
+                    Title = msgDto.Title,
+                    Content = msgDto.Content,
+                    ReleaseTime = msgDto.ReleaseTime,
+                    CreateUserId = msgDto.IssuerId,
+                    CreateTime = DateTime.Now,
+                    DeleteUserId = null,
+                    DeleteTime = "1990-01-01 00:00:00.000",
+                    Remark = "",
+                    IsDel = 0
+                };
+
+                int? msgId = await _sqlSugar.Insertable(message).ExecuteReturnIdentityAsync();
+                if (!msgId.HasValue) { _sqlSugar.RollbackTran(); return false; }
+
+                List<Sys_MessageReadAuth> messageReadAuths = new List<Sys_MessageReadAuth>();
+                foreach (int item in msgDto.UIdList)
+                {
+                    Sys_MessageReadAuth messageReadAuth = new Sys_MessageReadAuth() 
+                    {
+                        MsgId = msgId.Value,
+                        ReadableUId = item,
+                        ReadTime = new DateTime(1990,1,1),
+                        CreateUserId = msgDto.IssuerId,
+                        CreateTime = DateTime.Now,
+                        DeleteUserId = null,
+                        DeleteTime = "1990-01-01 00:00:00.000",
+                        Remark = "",
+                        IsDel = 0
+                    };
+                    messageReadAuths.Add(messageReadAuth);
+                }
+
+                int? readIds = await _sqlSugar.Insertable<Sys_MessageReadAuth>(messageReadAuths).ExecuteCommandAsync();
+                if (!readIds.HasValue)
+                {
+                    _sqlSugar.RollbackTran();
+                    return false;
+                }
+                _sqlSugar.CommitTran();
+            }
+            catch (Exception)
+            {
+                _sqlSugar.RollbackTran();
+                return false;
+            }
+
+            return true;
+        }
+
+    }
+}

OASystem/OASystem.Infrastructure/Repositories/System/UsersRepository.cs

@@ -13,11 +13,7 @@ namespace OASystem.Infrastructure.Repositories.System
 {
     public class UsersRepository : BaseRepository<UserInfo, JsonView>
     {
-        private readonly IMapper _mapper;
-        public UsersRepository(SqlSugarClient sqlSugar, IMapper mapper) : base(sqlSugar)
-        {
-            _mapper = mapper;
-        }
+        public UsersRepository(SqlSugarClient sqlSugar) : base(sqlSugar){}
 
         /// <summary>
         /// 用户查询列表

OASystem/_Doc/OA2023数据字典.docx

@@ -43,6 +43,79 @@ Null
 删除时间
 
 
+1. 系统消息
+
+1) 存储消息表：Sys_Message
+                                   字段名
+                                 类型长度
+                                 字段属性
+                                 字段约束
+                                 字段描述
+                                    备注
+Type
+Int
+Null
+
+类型ID
+0 用户登录消息1 系统消息
+2 业务消息
+IssuerId
+Int
+Null
+
+发布者Id
+用户Id
+Title
+Varchar(100)
+Null
+
+消息标题
+
+Content
+Varchar(500)
+Null
+
+消息内容
+
+ReleaseTime
+DateTime
+Null
+
+发布时间
+
+
+2) 消息关联用户表：Sys_MessageReadAuth
+                                   字段名
+                                 类型长度
+                                 字段属性
+                                 字段约束
+                                 字段描述
+                                    备注
+MsgId
+Id
+Null
+
+消息Id
+Sys_Message
+ReadableUId
+Int
+Null
+
+可读用户Id
+用户Id
+IsRead
+Int
+Null
+
+是否已读
+0 未读1 已读
+ReadTime
+DateTime
+Null
+
+阅读时间
+
+
 1. 数据类型
 
 1) 数据类型表：Sys_SetDataType（挪用）