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


using AutoMapper;
using OASystem.Domain;
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) : 
            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}'", loginDto.Number);
            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 != loginDto.Password)
            {
                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.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(LoginRepository _loginRep, RegisterDto registerDto)
        {
            Result result = new Result();
            Sys_Users _userInfo = new Sys_Users()
            {
                CnName = registerDto.CnName,
                EnName = registerDto.EnName,
                Sex = registerDto.Sex,
                Number = "",    //员工编号 人事审核通过了 由信息部经理分配
                CompanyId = registerDto.CompanyId,
                DepId = registerDto.DepId,
                JobPostId = registerDto.JobPostId,
                Ext = "", //由部门主管/信息部经理 分配
                Phone = registerDto.Phone,
                UrgentPhone = registerDto.UrgencyPhone,
                Email = registerDto.Email,
                Address = registerDto.Address,
                Edate = DateTime.Now,  //入职时间默认当前数据提交时间
                Rdate = new DateTime(1990, 1, 1),  //离职时间默认最原始时间
                Seniority = 0, //工龄默认 0
                Birthday = registerDto.BirthDay,
                IDCard = registerDto.IdCrad,
                StartWorkDate = new DateTime(1990, 1, 1),  //开始工作时间默认最原始时间
                GraduateInstitutions = registerDto.GraduationSchhol,
                Professional = registerDto.Major,
                Education = registerDto.Education, //学历类型
                TheOrAdultEducation = registerDto.EducationType, //教育类型
                MaritalStatus = registerDto.MaritalStatus, // 未婚/已婚
                HomeAddress = registerDto.HomeAddress,  //身份证上 家庭住址
                UsePeriod = "", //试用期 由该人员入职部门主管手动操作
                Certificate = "", //证件上传地址  多个证件由 | 隔开
                CreateUserId = registerDto.CreateUserId,
                CreateTime = DateTime.Now, //默认当前时间
                DeleteUserId = null,  //删除用户时操作该字段
                DeleteTime = null,   //删除用户时操作该字段
                Remark = "",         //备注
                IsDel = 0
            };
            var _AddId = await _loginRep.AddAsyncReturnId(_userInfo);
            if (_AddId < 0)
            {
                result.Code = -2;
                result.Msg = "用户添加失败!";

                return result;
            }

            result.Code = 0;
            result.Msg = "申请成功!人事主管审核后且信息部经理分配了登录账号,可登录OA!";
            return result;
        }

    }
}