SupplierService.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252
  1. using DapperORMCore.Context.DataContext;
  2. using DapperORMCore.Model.BaseModel;
  3. using DapperORMCore.Model.CoreModel;
  4. using DapperORMCore.Repository.IRepositorys;
  5. using DapperORMCore.String.Consts;
  6. using DapperORMCore.String.Enums;
  7. using Microsoft.Extensions.Configuration;
  8. using NXWMS.Code;
  9. using NXWMS.DataAccess.Entity;
  10. using NXWMS.IService.NXWMS.Base;
  11. using NXWMS.Model.AppModels.Condition.Base;
  12. using NXWMS.Model.AppModels.Result.Base;
  13. using NXWMS.Model.Common;
  14. using NXWMS.String.Enums;
  15. using System;
  16. using System.Collections.Generic;
  17. using System.Linq;
  18. using System.Text;
  19. using System.Threading.Tasks;
  20. using WestDistance.DapperORM.Repository.Repositorys;
  21. namespace NXWMS.Service.NXWMS.Base
  22. {
  23. /// <summary>
  24. /// 供应商服务
  25. /// </summary>
  26. [AutoInject(typeof(ISupplierService), InjectType.Scope)]
  27. public class SupplierService : ServiceBase, ISupplierService
  28. {
  29. /// <summary>
  30. /// 系统操作仓储中转
  31. /// </summary>
  32. private IDataRepositoryContext _dataContext;
  33. /// <summary>
  34. /// SQL节点仓储
  35. /// </summary>
  36. private ISQLNodeRepository _iSQLNodeRepository;
  37. /// <summary>
  38. /// 配置
  39. /// </summary>
  40. private IConfiguration _configuration;
  41. public SupplierService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
  42. {
  43. this._dataContext = dataRepositoryContext;
  44. this._configuration = configuration;
  45. this._iSQLNodeRepository = iSQLNodeRepository;
  46. }
  47. public OperateResultInfo Add(SupplierCondition info)
  48. {
  49. if (string.IsNullOrWhiteSpace(info.SupplierCode))
  50. {
  51. return FailMessageStatus("参数错误!");
  52. }
  53. if (new DataRepository<BAS_SUPPLIER>(_dataContext).Query().Where(m => m.SUPPLIER_CODE == info.SupplierCode
  54. && m.DEL_FLAG == 0 && m.USED_FLAG == 1).Any())
  55. {
  56. return FailMessageStatus("供应商编码已经存在,请输入其它编码!");
  57. }
  58. var now = DateTime.Now;
  59. var entity = new BAS_SUPPLIER
  60. {
  61. CREATE_BY = info.OperationUserId,
  62. CREATE_TIME = now,
  63. UPDATE_BY = info.OperationUserId,
  64. UPDATE_TIME = now,
  65. DESCRIBE = info.Describe,
  66. USED_FLAG = Convert.ToInt32(info.IsUsed),
  67. DEL_FLAG = 0,
  68. ADDRESS = info.Address,
  69. SUPPLIER_CODE = info.SupplierCode,
  70. POSTAL_CODE = info.PostalCode,
  71. AREA = info.Area,
  72. CITY = info.City,
  73. CONTRACT = info.Contract,
  74. CONTRACT_PHONE = info.ContractPhone,
  75. SUPPLIER_NAME = info.SupplierName,
  76. SUPPLIER_TYPE = info.SupplierType,
  77. PROVINCE = info.Province,
  78. ROUTE = info.Route,
  79. STREET = info.Street,
  80. };
  81. var affectedRows = new DataRepository<BAS_SUPPLIER>(_dataContext).Add(entity, new string[1] { "SUPPLIER_ID" });
  82. return GetStatus(affectedRows);
  83. }
  84. public OperateResultInfo Deleted(SupplierCondition info)
  85. {
  86. var sqlAndBuilder = new StringBuilder();
  87. sqlAndBuilder = info.Id != null ?
  88. info.Id > 0 ?
  89. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("SUPPLIER_ID", info.Id, DBOperationString._Equal)) :
  90. sqlAndBuilder : sqlAndBuilder;
  91. sqlAndBuilder = string.IsNullOrWhiteSpace(info.SupplierCode) ?
  92. sqlAndBuilder :
  93. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("SUPPLIER_CODE", info.SupplierCode, DBOperationString._Equal));
  94. sqlAndBuilder = string.IsNullOrWhiteSpace(info.Ids) ?
  95. sqlAndBuilder :
  96. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("SUPPLIER_ID", info.Ids, DBOperationString._In));
  97. if (sqlAndBuilder.Length == 0)
  98. {
  99. return FailMessageStatus("参数错误!");
  100. }
  101. var now = DateTime.Now;
  102. var sql = $@"UPDATE BAS_SUPPLIER SET DEL_FLAG=1,UPDATE_BY={info.OperationUserId},UPDATE_TIME='{now}'
  103. WHERE 1=1 {sqlAndBuilder}";
  104. var affectedRows = new DataRepository<BAS_SUPPLIER>(_dataContext).Execute(sql);
  105. return GetStatus(affectedRows, info.Ids.Split(',').Length);
  106. }
  107. public OperateResultInfo Edit(SupplierCondition info)
  108. {
  109. if (info == null)
  110. {
  111. return FailStatus();
  112. }
  113. if (string.IsNullOrWhiteSpace(info.SupplierCode))
  114. {
  115. return FailMessageStatus("参数错误!");
  116. }
  117. var regionData = new DataRepository<BAS_SUPPLIER>(_dataContext).Query().Where(m => m.SUPPLIER_CODE == info.SupplierCode
  118. && m.DEL_FLAG == 0 && m.USED_FLAG == 1).FirstOrDefault();
  119. if (regionData == null)
  120. {
  121. return FailMessageStatus("供应商编码已经存在,请输入其它编码!");
  122. }
  123. var whereList = new List<FieldKeyInfo>()
  124. .AddFieldKeyInfo(nameof(BAS_SUPPLIER.SUPPLIER_CODE), info.SupplierCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  125. string.IsNullOrWhiteSpace(info.SupplierCode))
  126. .AddFieldKeyInfo(nameof(BAS_SUPPLIER.SUPPLIER_ID), info.Id, EnumCSharpPropertyType.INT, DBOperationString._Equal,
  127. info.Id != null);
  128. var result = new DataRepository<BAS_SUPPLIER>(_dataContext).Query(whereList).FirstOrDefault();
  129. if (result != null)
  130. {
  131. var now = DateTime.Now;
  132. result.DESCRIBE = info.Describe;
  133. result.ADDRESS = info.Address;
  134. result.AREA = info.Area;
  135. result.CITY = info.City;
  136. result.CONTRACT = info.Contract;
  137. result.CONTRACT_PHONE = info.ContractPhone;
  138. result.SUPPLIER_CODE = info.SupplierCode;
  139. result.SUPPLIER_NAME = info.SupplierName;
  140. result.SUPPLIER_TYPE = info.SupplierType;
  141. result.DESCRIBE = info.Describe;
  142. result.POSTAL_CODE = info.PostalCode;
  143. result.PROVINCE = info.Province;
  144. result.ROUTE = info.Route;
  145. result.STREET = info.Street;
  146. result.SUPPLIER_ID = result.SUPPLIER_ID;
  147. result.UPDATE_BY = info.OperationUserId;
  148. result.UPDATE_TIME = now;
  149. result.USED_FLAG = info.IsUsed ? 1 : 0;
  150. var affectedRows = new DataRepository<BAS_SUPPLIER>(_dataContext).Update(result, "SUPPLIER_ID", "NEWID");
  151. return GetStatus(affectedRows);
  152. }
  153. return FailMessageStatus("未查找到数据!");
  154. }
  155. public OperateResultInfo<PageQueryResultInfo<SupplierResult>> GetList(SupplierSearchCondition info)
  156. {
  157. var sqlAndBuilder = new StringBuilder();
  158. var sqlOrBuilder = new StringBuilder();
  159. var sql = $@"SELECT
  160. CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
  161. UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
  162. UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
  163. {info.ItemSQL} FROM BAS_SUPPLIER WHERE 1=1 AND DEL_FLAG = 0 ";
  164. sqlAndBuilder = info.Id != null ?
  165. info.Id > 0 ?
  166. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("SUPPLIER_ID", info.Id, DBOperationString._Equal)) :
  167. sqlAndBuilder : sqlAndBuilder;
  168. sqlAndBuilder = info.IsUsed == null ?
  169. sqlAndBuilder :
  170. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
  171. sqlAndBuilder = string.IsNullOrWhiteSpace(info.SupplierCode) ?
  172. sqlAndBuilder :
  173. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("SUPPLIER_CODE", info.SupplierCode, DBOperationString._ContainIn));
  174. sqlAndBuilder = string.IsNullOrWhiteSpace(info.SupplierName) ?
  175. sqlAndBuilder :
  176. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("SUPPLIER_NAME", info.SupplierName, DBOperationString._ContainIn));
  177. sqlAndBuilder = string.IsNullOrWhiteSpace(info.SupplierType) ?
  178. sqlAndBuilder :
  179. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("SUPPLIER_TYPE", info.SupplierType, DBOperationString._ContainIn));
  180. sqlAndBuilder = string.IsNullOrWhiteSpace(info.Province) ?
  181. sqlAndBuilder :
  182. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("PROVINCE", info.Province, DBOperationString._ContainIn));
  183. sqlAndBuilder = string.IsNullOrWhiteSpace(info.City) ?
  184. sqlAndBuilder :
  185. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("CITY", info.City, DBOperationString._ContainIn));
  186. sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
  187. IEnumerable<SupplierResult> result;
  188. IEnumerable<SupplierResult> totalResult;
  189. totalResult = new DataRepository<SupplierResult>(_dataContext).Query(sql);
  190. if (info.PageIndex == 0 || info.PageSize == 0)
  191. {
  192. result = totalResult.ToList();
  193. }
  194. else
  195. {
  196. result = new DataRepository<SupplierResult>(_dataContext).QueryPage(sql,
  197. "CREATE_TIME", info.PageSize, info.PageIndex, true);
  198. }
  199. return SuccessStatus(new PageQueryResultInfo<SupplierResult>
  200. {
  201. RowData = result,
  202. PageConditionInfo = info,
  203. TotalCount = totalResult.Count(),
  204. TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
  205. });
  206. }
  207. public OperateResultInfo Remove(SupplierCondition info)
  208. {
  209. if (info == null)
  210. {
  211. return FailStatus();
  212. }
  213. if (string.IsNullOrWhiteSpace(info.SupplierCode))
  214. {
  215. return FailMessageStatus("参数错误!");
  216. }
  217. var whereList = new List<FieldKeyInfo>()
  218. .AddFieldKeyInfo(nameof(BAS_SUPPLIER.SUPPLIER_CODE), info.SupplierCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  219. string.IsNullOrWhiteSpace(info.SupplierCode))
  220. .AddFieldKeyInfo(nameof(BAS_SUPPLIER.SUPPLIER_ID), info.Id, EnumCSharpPropertyType.INT, DBOperationString._Equal,
  221. info.Id != null);
  222. var result = new DataRepository<BAS_SUPPLIER>(_dataContext).Query(whereList).FirstOrDefault();
  223. if (result != null)
  224. {
  225. var affectedRows = new DataRepository<BAS_SUPPLIER>(_dataContext).Remove("SUPPLIER_ID", result.SUPPLIER_ID.ToString());
  226. return GetStatus(affectedRows);
  227. }
  228. return FailMessageStatus("未查找到数据!");
  229. }
  230. }
  231. }