using DapperORMCore.Context.DataContext; using DapperORMCore.Model.BaseModel; using DapperORMCore.Model.CoreModel; using DapperORMCore.Repository.IRepositorys; using DapperORMCore.String.Consts; using DapperORMCore.String.Enums; using Microsoft.Extensions.Configuration; using NXWMS.Code; using NXWMS.DataAccess.Entity; using NXWMS.IService.NXWMS.SysSettings; using NXWMS.Model.AppModels.Condition.SysSettings; using NXWMS.Model.AppModels.Result.SysSettings; using NXWMS.Model.Common; using NXWMS.String.Enums; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WestDistance.DapperORM.Repository.Repositorys; namespace NXWMS.Service.NXWMS.SysSettings { /// /// 参数服务 /// [AutoInject(typeof(IOperationRecordService), InjectType.Scope)] public class OperationRecordService : ServiceBase, IOperationRecordService { /// /// 系统操作仓储中转 /// private IDataRepositoryContext _dataContext; /// /// SQL节点仓储 /// private ISQLNodeRepository _iSQLNodeRepository; /// /// 配置 /// private IConfiguration _configuration; public OperationRecordService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository) { this._dataContext = dataRepositoryContext; this._configuration = configuration; this._iSQLNodeRepository = iSQLNodeRepository; } /// /// 获取操作列表,支持分页 /// /// /// public OperateResultInfo> GetList(OperationRecordSearchCondition info) { if (info == null) { return FailStatus(new PageQueryResultInfo { }); } if (info.OperationBeginTime == null || info.OperationEndTime == null) { return FailMessageStatus("请传递开始时间和结束时间参数!", new PageQueryResultInfo()); } if (info.PageIndex == 0 || info.PageSize == 0) { return FailMessageStatus("请传递分页码和分页个数!", new PageQueryResultInfo()); } var sqlAndBuilder = new StringBuilder(); var sqlOrBuilder = new StringBuilder(); var sql = $@"SELECT UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString("USED_FLAG")}, OperationUserName = (SELECT USER_NAME FROM SYS_USER C WHERE C.USER_ID=OPERATION_USER_ID), 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), ApiOperationTypeName = CASE OPERATION_TYPE WHEN 'edit' then '新增' when 'add' then '新增' when 'get' then '查询' when 'deleted' then '逻辑删除' when 'remove' then '物理删除' when 'edit' then '编辑' else '其它' end, {info.ItemSQL} FROM WMS_LOG_OPERATION_RECORD WHERE 1=1 AND DEL_FLAG = 0 "; sqlAndBuilder = info.Id != null ? info.Id > 0 ? sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("LOG_OPERATION_RECORD_ID", info.Id, DBOperationString._Equal)) : sqlAndBuilder : sqlAndBuilder; sqlAndBuilder = string.IsNullOrWhiteSpace(info.OperationContent) ? sqlAndBuilder : sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("OPERATION_CONTENT", info.OperationContent, DBOperationString._ContainIn)); sqlAndBuilder = string.IsNullOrWhiteSpace(info.OperationType) ? sqlAndBuilder : sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("OPERATION_TYPE", info.OperationType, DBOperationString._Equal)); sqlAndBuilder = string.IsNullOrWhiteSpace(info.OperationType) ? sqlAndBuilder : sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("OPERATION_TYPE", info.OperationType, DBOperationString._Equal)); sqlAndBuilder = info.UserId != null ? info.UserId > 0 ? sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("OPERATION_USER_ID", info.UserId, DBOperationString._Equal)) : sqlAndBuilder : sqlAndBuilder; sqlAndBuilder = string.IsNullOrWhiteSpace(info.OperationObjectName) ? sqlAndBuilder : sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("OPERATION_STATUS", info.OperationStatus, DBOperationString._Equal)); sqlAndBuilder = string.IsNullOrWhiteSpace(info.OperationResult) ? sqlAndBuilder : sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("OPERATION_RESULT", info.OperationResult, DBOperationString._ContainIn)); sqlAndBuilder = info.Id != null ? info.Id > 0 ? sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("LOG_OPERATION_RECORD_ID", info.Id, DBOperationString._Equal)) : sqlAndBuilder : sqlAndBuilder; sqlAndBuilder = info.OperationBeginTime != null ? sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("OPERATION_TIME", info.OperationBeginTime, DBOperationString._LargeEqual)) : sqlAndBuilder; sqlAndBuilder = info.OperationEndTime != null ? sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("OPERATION_TIME", info.OperationEndTime, DBOperationString._SmallEqual)) : sqlAndBuilder; sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : ""); var result = new DataRepository(_dataContext).QueryPage(sql, "OPERATION_TIME", info.PageSize, info.PageIndex, true); var totalResult = new DataRepository(_dataContext).Query(sql); return SuccessStatus(new PageQueryResultInfo { RowData = result, PageConditionInfo = info, TotalCount = totalResult.Count(), TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize) }); } public OperateResultInfo Remove(OperationRecordCondition info) { var whereList = new List() .AddFieldKeyInfo(nameof(WMS_LOG_OPERATION_RECORD.LOG_OPERATION_RECORD_ID), info.Id, EnumCSharpPropertyType.INT32, DBOperationString._Equal, info.Id != null); var result = new DataRepository(_dataContext).Query(whereList).FirstOrDefault(); if (result != null) { var affectedRows = new DataRepository(_dataContext).Remove("LOG_OPERATION_RECORD_ID", result.LOG_OPERATION_RECORD_ID.ToString()); return GetStatus(affectedRows); } return FailMessageStatus("未查找到数据!"); } public OperateResultInfo Add(OperationRecordCondition info) { if (info == null) { return FailStatus(); } var now = DateTime.Now; var entity = new WMS_LOG_OPERATION_RECORD { CREATE_BY = info.OperationUserId, CREATE_TIME = now, UPDATE_BY = info.OperationUserId, UPDATE_TIME = now, OPERATION_CONDITION = info.OperationCondition, OPERATION_CONTENT = info.OperationContent, OPERATION_OBJECT_NAME = info.OperationObjectName, OPERATION_RESULT = info.OperationResult, DESCRIBE = info.Describe, USED_FLAG = 1, OPERATION_STATUS = info.OperationStatus, OPERATION_TIME = info.OperationInTime, OPERATION_TYPE = info.OperationType, DEL_FLAG = 0, OPERATION_USER_ID = info.OperationUserId, }; var affectedRows = new DataRepository(_dataContext).Add(entity, new string[1] { "LOG_OPERATION_RECORD_ID" }); return GetStatus(affectedRows); } public OperateResultInfo Delete(OperationRecordCondition info) { var whereList = new List() .AddFieldKeyInfo(nameof(WMS_LOG_OPERATION_RECORD.LOG_OPERATION_RECORD_ID), info.Id, EnumCSharpPropertyType.INT32, DBOperationString._Equal, info.Id != null); var result = new DataRepository(_dataContext).Query(whereList).FirstOrDefault(); if (result != null) { var now = DateTime.Now; result.DEL_FLAG = 1; result.UPDATE_BY = info.OperationUserId; result.UPDATE_TIME = now; result.LOG_OPERATION_RECORD_ID = result.LOG_OPERATION_RECORD_ID; var affectedRows = new DataRepository(_dataContext).Update(result, "LOG_OPERATION_RECORD_ID"); return SuccessStatus(affectedRows); } return FailMessageStatus("未查找到数据!"); } public OperateResultInfo Edit(OperationRecordCondition info) { //操作日志编辑功能目前不添加 return null; } } }