123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406 |
- using DapperORMCore.Context.DataContext;
- using DapperORMCore.Context.Extend;
- using DapperORMCore.Model.BaseModel;
- using DapperORMCore.Model.CoreModel;
- using DapperORMCore.String.Consts;
- using DapperORMCore.String.Enums;
- using NXWMS.IService.NXWMS;
- using NXWMS.Model.AppModels.Condition;
- using System;
- using System.Collections.Generic;
- using System.Text;
- using WestDistance.DapperORM.Repository.Repositorys;
- using DapperORMCore.Context;
- using NXWMS.Code;
- using System.Linq;
- using System.Security.Claims;
- using System.IdentityModel.Tokens.Jwt;
- using Microsoft.IdentityModel.Tokens;
- using Microsoft.IdentityModel.Logging;
- using Microsoft.Extensions.Configuration;
- using NXWMS.String.Enums;
- using System.Data;
- using NXWMS.Code.Converter;
- using NXWMS.DataAccess.Entity;
- using DapperORMCore.Repository.IRepositorys;
- using DapperORMCore.Dapper.BaseModel;
- using NXWMS.IService.NXWMS.SysSettings;
- using NXWMS.Model.AppModels.Result.SysSettings;
- using NXWMS.Model.AppModels.Condition.SysSettings;
- using NXWMS.Model.Common;
- namespace NXWMS.Service.NXWMS.SysSettings
- {
- /// <summary>
- /// 用户接口
- /// </summary>
- [AutoInject(typeof(IUserService), InjectType.Scope)]
- public class UserService : ServiceBase, IUserService
- {
- /// <summary>
- /// 系统操作仓储中转
- /// </summary>
- private IDataRepositoryContext _dataContext;
- /// <summary>
- /// SQL节点仓储
- /// </summary>
- private ISQLNodeRepository _iSQLNodeRepository;
- /// <summary>
- /// 配置
- /// </summary>
- private IConfiguration _configuration;
- /// <summary>
- /// 主键服务
- /// </summary>
- private ISequenceService _sequenceService;
- public UserService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISequenceService sequenceService, ISQLNodeRepository iSQLNodeRepository)
- {
- this._dataContext = dataRepositoryContext;
- this._configuration = configuration;
- this._iSQLNodeRepository = iSQLNodeRepository;
- this._sequenceService = sequenceService;
- }
- public OperateResultInfo<PageQueryResultInfo<UserResult>> GetList(UserSearchCondition info)
- {
- var sqlAndBuilder = new StringBuilder();
- var sqlOrBuilder = new StringBuilder();
- var sql = $@"SELECT
- GenderName = CASE WHEN Gender=0 THEN '男' ELSE '女' END,
- CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
- UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
- UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
- {info.ItemSQL} FROM SYS_USER WHERE 1=1 AND DEL_FLAG = 0 ";
- sqlAndBuilder = info.UserId != null ?
- info.UserId > 0 ?
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USER_ID", info.UserId, DBOperationString._Equal)) :
- sqlAndBuilder : sqlAndBuilder;
- sqlAndBuilder = info.IsUsed == null ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.Address) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("ADDRESS", info.Address, DBOperationString._ContainIn));
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.Email) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("EMAIL", info.Email, DBOperationString._ContainIn));
- sqlAndBuilder = info.Gender == null ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("GENDER", info.Gender, DBOperationString._ContainIn));
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.IphoneNumber) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PHONE_NUMBER", info.IphoneNumber, DBOperationString._ContainIn));
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.JobTitle) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("JOB_TITLE", info.JobTitle, DBOperationString._ContainIn));
- sqlOrBuilder = string.IsNullOrWhiteSpace(info.UserInfo) ?
- sqlOrBuilder :
- sqlOrBuilder.Append(_iSQLNodeRepository.GetOrCondition("USER_CODE", info.UserInfo, DBOperationString._ContainIn));
- sqlOrBuilder = string.IsNullOrWhiteSpace(info.UserInfo) ?
- sqlOrBuilder :
- sqlOrBuilder.Append(_iSQLNodeRepository.GetOrCondition("USER_NAME", info.UserInfo, DBOperationString._ContainIn));
- sqlOrBuilder = string.IsNullOrWhiteSpace(info.UserInfo) ?
- sqlOrBuilder :
- sqlOrBuilder.Append(_iSQLNodeRepository.GetOrCondition("NICK_NAME", info.UserInfo, DBOperationString._ContainIn));
- sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
- sql = sql + (sqlOrBuilder.Length > 0 ? _iSQLNodeRepository.GetOrString(sqlOrBuilder, false) : "");
- IEnumerable<UserResult> result;
- IEnumerable<UserResult> totalResult;
- totalResult = new DataRepository<UserResult>(_dataContext).Query(sql);
- if (info.PageIndex == 0 || info.PageSize == 0)
- {
- result = totalResult.ToList();
- }
- else
- {
- result = new DataRepository<UserResult>(_dataContext).QueryPage(sql,
- "CREATE_TIME", info.PageSize, info.PageIndex, true);
- }
- return SuccessStatus(new PageQueryResultInfo<UserResult>
- {
- RowData = result,
- PageConditionInfo = info,
- TotalCount = totalResult.Count(),
- TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
- });
- }
- public OperateResultInfo Deleted(UserCondition info)
- {
- var sqlAndBuilder = new StringBuilder();
- sqlAndBuilder = info.UserId != null ?
- info.UserId > 0 ?
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USER_ID", info.UserId, DBOperationString._Equal)) :
- sqlAndBuilder : sqlAndBuilder;
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.UserCode) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USER_CODE", info.UserCode, DBOperationString._Equal));
- sqlAndBuilder = string.IsNullOrWhiteSpace(info.UserIds) ?
- sqlAndBuilder :
- sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USER_ID", info.UserIds, DBOperationString._In));
- if (sqlAndBuilder.Length == 0)
- {
- return FailMessageStatus("参数错误!");
- }
- var now = DateTime.Now;
- var sql = $@"UPDATE SYS_USER SET DEL_FLAG=1,UPDATE_BY={info.OperationUserId},UPDATE_TIME='{now}'
- WHERE 1=1 {sqlAndBuilder}";
- var affectedRows = new DataRepository<SYS_USER>(_dataContext).Execute(sql);
- return GetStatus(affectedRows, info.UserIds.Split(',').Length);
- }
- public OperateResultInfo Remove(UserCondition info)
- {
- var whereList = GetFieldKeyList(info);
- var result = new DataRepository<SYS_USER>(_dataContext).Query(whereList).FirstOrDefault();
- if (result != null)
- {
- var affectedRows = 0;
- if (info.UserId != null)
- {
- affectedRows = new DataRepository<SYS_USER>(_dataContext).Remove("USER_ID", info.UserId.ToString());
- }
- if (!string.IsNullOrWhiteSpace(info.UserCode))
- {
- affectedRows = new DataRepository<SYS_USER>(_dataContext).Remove("USER_CODE", info.UserCode);
- }
- return GetStatus(affectedRows);
- }
- return FailMessageStatus("未查找到数据!");
- }
- public OperateResultInfo Add(UserCondition info)
- {
- if (info == null)
- {
- return CustomStatus(OperateStatus.ParameterError);
- }
- //接口中特定错误状态不加了,,既然要简单.
- if (new DataRepository<SYS_USER>(_dataContext).Query().Where(m => m.USER_CODE == info.UserCode
- && m.DEL_FLAG == 0 && m.USED_FLAG == 1).Any())
- {
- return FailMessageStatus("用户编码已经存在,请输入其它编码!");
- }
- var now = DateTime.Now;
- var entity = new SYS_USER();
- entity.USER_CODE = info.UserCode;
- entity.USER_NAME = info.UserName;
- entity.PASSWORD = info.Password;
- entity.NICK_NAME = info.NickName;
- entity.JOB_TITLE = info.JobTitle;
- entity.PHONE_NUMBER = info.PhoneNumber;
- entity.ADDRESS = info.Address;
- entity.EMAIL = info.Email;
- entity.GENDER = info.Gender;
- entity.ROLE_CODE = info.RoleCode;
- entity.CREATE_BY = info.OperationUserId;
- entity.CREATE_TIME = now;
- entity.UPDATE_BY = info.OperationUserId;
- entity.UPDATE_TIME = now;
- entity.PASSWORD = _configuration["default:user_password"];
- var affectedRows = new DataRepository<SYS_USER>(_dataContext).Add(entity, new string[1] { "USER_ID" });
- return GetStatus(affectedRows);
- }
- public OperateResultInfo Edit(UserCondition info)
- {
- if (info.UserId == null && string.IsNullOrWhiteSpace(info.UserCode))
- {
- return FailMessageStatus("参数错误!");
- }
- var whereList = new List<FieldKeyInfo>()
- .AddFieldKeyInfo(nameof(SYS_USER.USER_ID), info.UserId, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
- info.UserId != null)
- .AddFieldKeyInfo(nameof(SYS_USER.USER_CODE), info.UserCode, EnumCSharpPropertyType.STRING, DBOperationString._In,
- !string.IsNullOrWhiteSpace(info.UserCode));
- var result = new DataRepository<SYS_USER>(_dataContext).Query(whereList).FirstOrDefault();
- if (result != null)
- {
- var now = DateTime.Now;
- result.NICK_NAME = info.NickName;
- result.USER_NAME = info.UserName;
- result.PASSWORD = info.Password;
- result.JOB_TITLE = info.JobTitle;
- result.GENDER = info.Gender;
- result.ADDRESS = info.Address;
- result.USED_FLAG = Convert.ToInt32(info.IsUsed);
- result.USER_ID = result.USER_ID;
- result.ROLE_CODE = info.RoleCode;
- result.UPDATE_BY = info.OperationUserId;
- result.UPDATE_TIME = now;
- var affectedRows = new DataRepository<SYS_USER>(_dataContext).Update(result, "USER_ID", "NEWID");
- return GetStatus(affectedRows);
- }
- return FailMessageStatus("未查找到数据!");
- }
- public OperateResultInfo<UserLoginResult> Login(UserLoginCondition info)
- {
- if (info == null)
- {
- return FailStatus(new UserLoginResult());
- }
- var whereList = new List<FieldKeyInfo>().AddFieldKeyInfo(nameof(SYS_USER.USER_CODE), info.AccountNumber,
- EnumCSharpPropertyType.STRING, DBOperationString._Equal);
- var result = new DataRepository<SYS_USER>(_dataContext).Query(whereList).FirstOrDefault();
- if (result == null)
- {
- return FailStatus(new UserLoginResult
- {
- LoginStatus = EnumLoginStatus.AccountFail
- });
- }
- if (result.DEL_FLAG == 1)
- {
- return FailStatus(new UserLoginResult
- {
- LoginStatus = EnumLoginStatus.AccountDeleted
- });
- }
- if (result.USED_FLAG == 0)
- {
- return FailStatus(new UserLoginResult
- {
- LoginStatus = EnumLoginStatus.AccountDisable
- });
- }
- if (result.PASSWORD.ToLower() != info.Password.ToLower())
- {
- return FailStatus(new UserLoginResult
- {
- LoginStatus = EnumLoginStatus.PasswordFail
- });
- }
- SYS_ROLE ruleInfo = new SYS_ROLE();
- if (!string.IsNullOrWhiteSpace(result.ROLE_CODE))
- {
- ruleInfo = new DataRepository<SYS_ROLE>(_dataContext).Query("ROLE_CODE", result.ROLE_CODE).FirstOrDefault();
- }
- DateTime expiredTime;
- if (info.SysType != EnumSysType.PDA)
- {
- expiredTime = DateTime.Now.AddMinutes(Convert.ToDouble(_configuration["secure_config:expired_minute"]));
- }
- else
- {
- expiredTime = DateTime.Now.AddYears(1);
- }
- var claims = new[]
- {
- new Claim(JwtRegisteredClaimNames.Nbf,$"{new DateTimeOffset(DateTime.Now).ToUnixTimeSeconds()}") ,
- new Claim (JwtRegisteredClaimNames.Exp,$"{new DateTimeOffset(expiredTime).ToUnixTimeSeconds()}"),
- new Claim(JwtRegisteredClaimNames.Sub,info.AccountNumber),
- };
- var key = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_configuration["secure_config:secure_key"]));
- var creds = new SigningCredentials(key, SecurityAlgorithms.HmacSha256);
- var jwtSecurityToken = new JwtSecurityToken(
- issuer: _configuration["secure_config:Issuer"],
- audience: _configuration["secure_config:audience"],
- claims: claims,
- expires: expiredTime,
- signingCredentials: creds);
- return SuccessStatus(new UserLoginResult
- {
- WMSAllowLoginFlag = Convert.ToBoolean(ruleInfo.WMS_ALLOW_LOGIN_FLAG),
- PDAAllowLoginFlag = Convert.ToBoolean(ruleInfo.PDA_ALLOW_LOGIN_FLAG),
- WCSAllowLoginFlag = Convert.ToBoolean(ruleInfo.WCS_ALLOW_LOGIN_FLAG),
- LoginStatus = EnumLoginStatus.Success,
- UserInfo = new UserInfoResult
- {
- NickName = result.NICK_NAME,
- UserCode = result.USER_CODE,
- UserId = result.USER_ID,
- UserName = result.USER_NAME
- }, //TODO 没有做,
- TokenResult = new TokenResult
- {
- Ticket = new JwtSecurityTokenHandler().WriteToken(jwtSecurityToken),
- OverdueTime = jwtSecurityToken.ValidTo
- }
- }); ; ;
- }
- /// <summary>
- /// 修改密码
- /// </summary>
- /// <param name="info"></param>
- /// <returns></returns>
- public OperateResultInfo UpdatePS(UserCondition info)
- {
- if (info == null)
- {
- return FailMessageStatus("参数错误!");
- }
- if (info.UserId == null || info.Password.Length != 32)
- {
- return FailMessageStatus("参数错误!");
- }
- var whereList = new List<FieldKeyInfo>().AddFieldKeyInfo(nameof(SYS_USER.USER_ID), info.UserId,
- EnumCSharpPropertyType.INT, DBOperationString._Equal);
- var result = new DataRepository<SYS_USER>(_dataContext).Query(whereList).FirstOrDefault();
- if (result == null)
- {
- return FailMessageStatus("参数错误!");
- }
- var now = DateTime.Now;
- var entity = new SYS_USER
- {
- PASSWORD = info.Password,
- UPDATE_BY = info.OperationUserId,
- UPDATE_TIME = now,
- USER_ID = info.UserId.Value,
- };
- new DataRepository<SYS_USER>(_dataContext).Update(entity, "USER_ID", "NEWID");
- return SuccessStatus();
- }
- #region Private
- /// <summary>
- /// 条件统一下,用统一筛选
- /// </summary>
- /// <param name="userCondition"></param>
- /// <returns></returns>
- private List<FieldKeyInfo> GetFieldKeyList(UserCondition info)
- {
- var whereList = new List<FieldKeyInfo>();
- if (info.UserId != null)
- {
- if (info.UserId > 0)
- {
- whereList = whereList.AddFieldKeyInfo(nameof(SYS_USER.USER_ID), info.UserId,
- EnumCSharpPropertyType.STRING, DBOperationString._Equal);
- }
- }
- if (!string.IsNullOrWhiteSpace(info.UserIds))
- {
- whereList = whereList.AddFieldKeyInfo(nameof(SYS_USER.USER_ID), info.UserIds,
- EnumCSharpPropertyType.STRING, DBOperationString._In);
- }
- if (!string.IsNullOrWhiteSpace(info.UserCode))
- {
- whereList = whereList.AddFieldKeyInfo(nameof(SYS_USER.USER_CODE), info.UserCode,
- EnumCSharpPropertyType.STRING, DBOperationString._Equal);
- }
- return whereList;
- }
- #endregion
- }
- }
|