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;
}
}
}