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.Base;
using NXWMS.Model.AppModels.Condition.Base;
using NXWMS.Model.AppModels.Result.Base;
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.Base
{
///
/// 物品服务
///
[AutoInject(typeof(IMaterielService), InjectType.Scope)]
public class MaterielService : ServiceBase, IMaterielService
{
///
/// 系统操作仓储中转
///
private IDataRepositoryContext _dataContext;
///
/// SQL节点仓储
///
private ISQLNodeRepository _iSQLNodeRepository;
///
/// 配置
///
private IConfiguration _configuration;
public MaterielService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
{
this._dataContext = dataRepositoryContext;
this._configuration = configuration;
this._iSQLNodeRepository = iSQLNodeRepository;
}
public OperateResultInfo Add(MaterielCondition info)
{
if (string.IsNullOrWhiteSpace(info.MaterielCode))
{
return FailMessageStatus("参数错误!");
}
if (new DataRepository(_dataContext).Query().Where(m => m.MATERIEL_CODE == info.MaterielCode
&& m.DEL_FLAG == 0 && m.USED_FLAG == 1).Any())
{
return FailMessageStatus("供应商编码已经存在,请输入其它编码!");
}
var now = DateTime.Now;
var entity = new BAS_MATERIEL
{
CREATE_BY = info.OperationUserId,
CREATE_TIME = now,
UPDATE_BY = info.OperationUserId,
UPDATE_TIME = now,
DESCRIBE = info.Describe,
USED_FLAG = Convert.ToInt32(info.IsUsed),
DEL_FLAG = 0,
MATERIEL_CODE = info.MaterielCode,
MATERIEL_NAME = info.MaterielName,
DELAY_EFFECTIVE_TIME = info.DelayEffectiveTime,
MATERIEL_PACKAGE_CODE = info.MaterielPackageCode,
OUTBOUND_EFFECTIVE_TIME = info.OutboundEffectiveTime,
SPECS_MODEL = info.SpecsModel,
UNIT_CODE = info.UnitCode,
EFFECTIVE_TIME = info.EffectiveTime,
MATERIEL_TYPE = info.MaterielType,
HEIGHT = info.Height,
WIDE = info.Wide,
LENGTH = info.Length,
MAX_STOCK = info.MaxStock,
MIN_STOCK = info.MinStock,
UNIT_PRICE = info.UnitPrice,
VOLUME = info.Volume,
WEIGHT = info.Weight,
};
var affectedRows = new DataRepository(_dataContext).Add(entity, new string[1] { "MATERIEL_ID" });
return GetStatus(affectedRows);
}
public OperateResultInfo Deleted(MaterielCondition info)
{
var sqlAndBuilder = new StringBuilder();
sqlAndBuilder = info.Id != null ?
info.Id > 0 ?
sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MATERIEL_ID", info.Id, DBOperationString._Equal)) :
sqlAndBuilder : sqlAndBuilder;
sqlAndBuilder = string.IsNullOrWhiteSpace(info.MaterielCode) ?
sqlAndBuilder :
sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MATERIEL_CODE", info.MaterielCode, DBOperationString._Equal));
sqlAndBuilder = string.IsNullOrWhiteSpace(info.Ids) ?
sqlAndBuilder :
sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MATERIEL_ID", info.Ids, DBOperationString._In));
if (sqlAndBuilder.Length == 0)
{
return FailMessageStatus("参数错误!");
}
var now = DateTime.Now;
var sql = $@"UPDATE BAS_MATERIEL SET DEL_FLAG=1,UPDATE_BY={info.OperationUserId},UPDATE_TIME='{now}'
WHERE 1=1 {sqlAndBuilder}";
var affectedRows = new DataRepository(_dataContext).Execute(sql);
return GetStatus(affectedRows, info.Ids.Split(',').Length);
}
public OperateResultInfo Edit(MaterielCondition info)
{
if (info == null)
{
return FailStatus();
}
if (string.IsNullOrWhiteSpace(info.MaterielCode) && info.Id == null)
{
return FailMessageStatus("参数错误!");
}
var whereList = new List()
.AddFieldKeyInfo(nameof(BAS_MATERIEL.MATERIEL_CODE), info.MaterielCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
!string.IsNullOrWhiteSpace(info.MaterielCode))
.AddFieldKeyInfo(nameof(BAS_MATERIEL.MATERIEL_ID), info.Id, EnumCSharpPropertyType.INT, DBOperationString._Equal,
info.Id != null);
var result = new DataRepository(_dataContext).Query(whereList).FirstOrDefault();
if (result != null)
{
var now = DateTime.Now;
result.DESCRIBE = info.Describe;
result.DELAY_EFFECTIVE_TIME = info.DelayEffectiveTime;
result.DESCRIBE = info.Describe;
result.EFFECTIVE_TIME = info.EffectiveTime;
result.HEIGHT = info.Height;
result.LENGTH = info.Length;
result.MATERIEL_CODE = info.MaterielCode;
result.MATERIEL_NAME = info.MaterielName;
result.MATERIEL_PACKAGE_CODE = info.MaterielPackageCode;
result.MATERIEL_TYPE = info.MaterielType;
result.MAX_STOCK = info.MaxStock;
result.MIN_STOCK = info.MinStock;
result.OUTBOUND_EFFECTIVE_TIME = info.OutboundEffectiveTime;
result.SPECS_MODEL = info.SpecsModel;
result.UNIT_CODE = info.UnitCode;
result.UNIT_PRICE = info.UnitPrice;
result.VOLUME = info.Volume;
result.WEIGHT = info.Weight;
result.WIDE = info.Wide;
result.MATERIEL_ID = result.MATERIEL_ID;
result.UPDATE_BY = info.OperationUserId;
result.UPDATE_TIME = now;
result.USED_FLAG = info.IsUsed ? 1 : 0;
var affectedRows = new DataRepository(_dataContext).Update(result, "MATERIEL_ID", "NEWID");
return GetStatus(affectedRows);
}
return FailMessageStatus("未查找到数据!");
}
public OperateResultInfo> GetList(MaterielSearchCondition info)
{
var sqlAndBuilder = new StringBuilder();
var sqlOrBuilder = new StringBuilder();
var sql = $@"SELECT
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),
MaterielTypeName = (SELECT C.MATERIEL_TYPE_NAME FROM BAS_MATERIEL_TYPE C WHERE C.MATERIEL_TYPE_CODE=BAS_MATERIEL.MATERIEL_TYPE),
UnitName = (SELECT D.UNIT_NAME FROM BAS_UNIT D WHERE D.UNIT_CODE=BAS_MATERIEL.UNIT_CODE),
UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString("USED_FLAG")},
{info.ItemSQL} FROM BAS_MATERIEL WHERE 1=1 AND DEL_FLAG = 0 ";
sqlAndBuilder = info.Id != null ?
info.Id > 0 ?
sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("MATERIEL_ID", info.Id, DBOperationString._Equal)) :
sqlAndBuilder : sqlAndBuilder;
sqlAndBuilder = info.IsUsed == null ?
sqlAndBuilder :
sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
sqlOrBuilder = string.IsNullOrWhiteSpace(info.MaterielInfo) ?
sqlOrBuilder :
sqlOrBuilder.Append(_iSQLNodeRepository.GetOrCondition("MATERIEL_CODE", info.MaterielInfo, DBOperationString._ContainIn));
sqlOrBuilder = string.IsNullOrWhiteSpace(info.MaterielInfo) ?
sqlOrBuilder :
sqlOrBuilder.Append(_iSQLNodeRepository.GetOrCondition("MATERIEL_NAME", info.MaterielInfo, DBOperationString._ContainIn));
sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
sql = sql + (sqlOrBuilder.Length > 0 ? _iSQLNodeRepository.GetOrString(sqlOrBuilder, false) : "");
IEnumerable result;
IEnumerable totalResult;
totalResult = new DataRepository(_dataContext).Query(sql);
if (info.PageIndex == 0 || info.PageSize == 0)
{
result = totalResult.ToList();
}
else
{
result = new DataRepository(_dataContext).QueryPage(sql,
"CREATE_TIME", info.PageSize, info.PageIndex, true);
}
return SuccessStatus(new PageQueryResultInfo
{
RowData = result,
PageConditionInfo = info,
TotalCount = totalResult.Count(),
TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
});
}
public OperateResultInfo Remove(MaterielCondition info)
{
if (info == null)
{
return FailStatus();
}
if (string.IsNullOrWhiteSpace(info.MaterielCode) && info.Id == null)
{
return FailMessageStatus("参数错误!");
}
var whereList = new List()
.AddFieldKeyInfo(nameof(BAS_MATERIEL.MATERIEL_CODE), info.MaterielCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
!string.IsNullOrWhiteSpace(info.MaterielCode))
.AddFieldKeyInfo(nameof(BAS_MATERIEL.MATERIEL_ID), info.Id, EnumCSharpPropertyType.INT, DBOperationString._Equal,
info.Id != null);
var result = new DataRepository(_dataContext).Query(whereList).FirstOrDefault();
if (result != null)
{
var affectedRows = new DataRepository(_dataContext).Remove("MATERIEL_ID", result.MATERIEL_ID.ToString());
return GetStatus(affectedRows);
}
return FailMessageStatus("未查找到数据!");
}
}
}