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("未查找到数据!"); } } }