OA2023/OASystem/OASystem.Infrastructure/Repositories/Login/LoginRepository.cs


using AutoMapper;
using OASystem.Domain;
using OASystem.Domain.AesEncryption;
using OASystem.Domain.Dtos.QiYeWeChat;
using OASystem.Domain.Dtos.System;
using OASystem.Domain.Dtos.UserDto;
using OASystem.Domain.Entities.System;
using OASystem.Domain.ViewModels.System;
using OASystem.Infrastructure.Repositories.System;
using SqlSugar;

namespace OASystem.Infrastructure.Repositories.Login
{
    public class LoginRepository : BaseRepository<Sys_Users, LoginView>
    {

        public LoginRepository(SqlSugarClient sqlSugar, UsersRepository usersRep) : 
            base(sqlSugar){}

        /// <summary>
        /// 用户登录
        /// 返回Token
        /// </summary>
        /// <param name="_loginRep"></param>
        /// <param name="loginDto"></param>
        /// <returns></returns>
        public async Task<Result> Login(LoginDto loginDto)
        {
            Result result = new Result() { Code = -2 };
            string SQLWhere = string.Format("Where Number='{0}' And Isdel = 0", loginDto.Number.Trim());
            string sql = string.Format("Select * From Sys_Users With(NoLock) {0}", SQLWhere);
            Sys_Users _entity = await GetSingleInfoBySqlWithNolockAsync(sql);

            if (_entity == null)
            {
                result.Msg = "暂无该账户信息!";
                return result;
            }

            if (!_entity.Password.Equals(loginDto.Password.Trim()))
            {
                result.Msg = "账户或密码错误!";
                return result;
            }

            //人事审核是否通过
            if (_entity.HrAudit != 1)
            {
                result.Msg = "该员工账号暂无登录权限,人事审核未通过!";
                return result;
            }

            //该用户是否已删除
            if (_entity.HrAudit != 1)
            {
                result.Msg = "已离职员工没有登录权限!";
                return result;
            }

            //portType 处理端口 
            dynamic longinData = null;

            //员工数据
            string sqlWhere = string.Format(" Where su.Id={0}", _entity.Id);
            string userSqlWhere = string.Format(@"Select sc.CompanyName,sd.DepName,sjp.JobName,su.Id UserId,su.CnName,su.Sex,su.Email
                                                  From Sys_Users su 
                                                  Inner Join Sys_Company sc On su.CompanyId = sc.Id
                                                  Inner Join Sys_Department sd On su.DepId = sd.Id
                                                  Inner Join Sys_JobPost sjp On su.JobPostId = sjp.Id {0}", sqlWhere);
           

            if (loginDto.PortType == 1) //web
            {
                var _userBasicInfo = await _sqlSugar.SqlQueryable<UserLoginInfoView>(userSqlWhere).FirstAsync();

                longinData = _userBasicInfo;

            }
            else if (loginDto.PortType == 2) // Android
            {
                var _userBasicInfo = await _sqlSugar.SqlQueryable<UserLoginInfoView>(userSqlWhere).FirstAsync();
                longinData = _userBasicInfo;
            }

            result.Code = 0;
            result.Msg = "登录成功!";
            result.Data = longinData;
            return result;

        }

        /// <summary>
        /// 用户注册
        /// </summary>
        /// <param name="_loginRep"></param>
        /// <param name="registerDto"></param>
        /// <returns></returns>
        public async Task<Result> Register( RegisterDto registerDto)
        {
            Result result = new Result();

            string IdCrad = registerDto.IdCrad;
            string birthDay = IdCrad.Substring(6, 4) + "-" + IdCrad.Substring(10, 2) + "-" + IdCrad.Substring(12, 2);

            string number = await CreateNumber(registerDto.DepId);
            //string number = "10001";
            if (string.IsNullOrEmpty(number))
            {
                result.Code = -2;
                result.Msg = "Number 设置失败,请前往对应部门 备注；里 设置Number前缀!";

                return result;
            }

            var _userInfo = new Sys_Users()
            {
                CnName = registerDto.CnName,
                EnName = registerDto.EnName,
                Sex = registerDto.Sex,
                Number = number,    //员工编号 人事审核通过了 由信息部经理分配
                Password = registerDto.Password, //密码由用户自己设置
                CompanyId = registerDto.CompanyId,
                DepId = registerDto.DepId,
                JobPostId = registerDto.JobPostId,
                Ext = "", //由部门主管/信息部经理 分配
                Phone = registerDto.Phone,
                UrgentPhone = registerDto.UrgencyPhone,
                Email = registerDto.Email,
                Address = registerDto.Address,
                Edate = Convert.ToDateTime(registerDto.Edate),  //入职时间默认当前数据提交时间
                Rdate = new DateTime(1990, 1, 1),  //离职时间默认最原始时间
                Seniority = 0, //工龄默认 0
                Birthday = Convert.ToDateTime(birthDay),
                IDCard = registerDto.IdCrad,
                StartWorkDate = "1900-01-01 00:00:00.000",  //开始工作时间默认最原始时间
                GraduateInstitutions = registerDto.GraduationSchhol,
                Professional = registerDto.Major,
                Education = registerDto.Education, //学历类型
                TheOrAdultEducation = registerDto.EducationType, //教育类型
                MaritalStatus = registerDto.MaritalStatus, // 未婚/已婚
                WorkExperience = registerDto.WorkExperience, // 工作经历
                HomeAddress = registerDto.HomeAddress,  //身份证上 家庭住址
                UsePeriod = "", //试用期 由该人员入职部门主管手动操作
                Certificate = "", //证件上传地址  多个证件由 | 隔开
                CreateUserId = registerDto.CreateUserId,
                CreateTime = DateTime.Now, //默认当前时间
                DeleteUserId = null,  //删除用户时操作该字段
                DeleteTime = null,   //删除用户时操作该字段
                Remark = "",         //备注
                IsDel = 0
            };

            //指定字段加密
            EncryptionProcessor.EncryptProperties(_userInfo);

            var _AddId = await _sqlSugar.Insertable(_userInfo).ExecuteReturnIdentityAsync();
            if (_AddId < 0)
            {
                result.Code = -2;
                result.Msg = "用户添加失败!";

                return result;
            }

            _userInfo.CreateUserId = _AddId;

            var updateStatus = await _sqlSugar.Updateable(_userInfo).UpdateColumns(it => new { it.CreateUserId }).Where(it => it.Id == _AddId).ExecuteCommandAsync();

            //添加员工 默认页面权限


            result.Code = 0;
            //result.Msg = string.Format("账号：{0}\r\n密码：{1}\r\n申请成功!\r\n人事主管审核后,即可登录OA!", number, registerDto.Password);
            result.Msg = string.Format("账号：{0}\r\n申请成功!\r\n人事主管审核后,即可登录OA!", number);
            return result;
        }
        
        /// <summary>
        /// 生成 Number
        /// </summary>
        /// <param name="depId"></param>
        /// <returns></returns>
        public async Task<string> CreateNumber(int depId) {
            string number = string.Empty;

            string userSql = string.Format("Select * From  Sys_Users Where Number != '' Order By Id Desc", depId);
            var userData = await _sqlSugar.SqlQueryable<Sys_Users>(userSql).ToListAsync();
            //if (userData.Count <= 0) return number;

            string depSql = string.Format("Select * From  Sys_Department Where Id = {0} ", depId);
            var depData = await _sqlSugar.SqlQueryable<Sys_Department>(depSql).FirstAsync();
            if (depData == null) return number;

            string numPrefix = depData.DepCode; 
            if (string.IsNullOrEmpty(numPrefix)) return number;

            int numSuffix = 1;
            while (true) 
            {
                number = numPrefix + numSuffix.ToString();

                var userData1 = userData.Find(it => it.Number == number); //公司验证Number 
                if (userData1 == null) break;

                numSuffix++;
            }

            return number;
        }
    
        public async Task<Result> ChangePassword(int userId,string password)
        {
            Result result = new Result() {Code = -1,Msg="操作失败!" };
            if (userId < 1) {
                result.Msg = "请输入有效的UserId参数";
                return result;
            }

            if (string.IsNullOrWhiteSpace(password))
            {
                result.Msg = "请输入有效的password参数";
                return result;
            }

            var change = await _sqlSugar.Updateable<Sys_Users>()
                                        .SetColumns(it => it.Password ==  password)
                                        .Where(it => it.Id == userId)
                                        .ExecuteCommandAsync();
            if (change >  0)
            {
                result.Code = 0;
                result.Msg = "操作成功!";
            }

            return result;
        }
    }
}