OrderDistributionRuleService.cs 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359
  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.Rule;
  11. using NXWMS.Model.AppModels.Condition.Rule;
  12. using NXWMS.Model.AppModels.Result.Rule;
  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.Rule
  22. {
  23. /// <summary>
  24. /// 订单分配规则服务
  25. /// </summary>
  26. [AutoInject(typeof(IOrderDistributionRuleService), InjectType.Scope)]
  27. public class OrderDistributionRuleService : ServiceBase, IOrderDistributionRuleService
  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 OrderDistributionRuleService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository)
  42. {
  43. this._dataContext = dataRepositoryContext;
  44. this._configuration = configuration;
  45. this._iSQLNodeRepository = iSQLNodeRepository;
  46. }
  47. public OperateResultInfo Add(OrderDistributionRuleCondition info)
  48. {
  49. if (new DataRepository<BAS_RULE>(_dataContext).Query().Where(m => m.RULE_CODE == info.RuleCode
  50. && m.DEL_FLAG == 0 && m.USED_FLAG == 1).Any())
  51. {
  52. return FailMessageStatus("上架规则编码已经存在,请输入其它编码!");
  53. }
  54. var affectedRows = 0;
  55. try
  56. {
  57. _dataContext.BeginTran();
  58. var now = DateTime.Now;
  59. var ruleId =
  60. new DataRepository<BAS_RULE>(_dataContext).Query().Count() == 0 ? 1 :
  61. new DataRepository<BAS_RULE>(_dataContext).Query().Select(s => s.RULE_ID).Max() + 1;
  62. var entity = new BAS_RULE
  63. {
  64. CREATE_BY = info.OperationUserId,
  65. CREATE_TIME = now,
  66. UPDATE_BY = info.OperationUserId,
  67. UPDATE_TIME = now,
  68. USED_FLAG = Convert.ToInt32(info.IsUsed),
  69. DESCRIBE = info.RuleDescribe,
  70. DEL_FLAG = 0,
  71. RULE_CODE = info.RuleCode,
  72. RULE_NAME = info.RuleName,
  73. RULE_TYPE = (int)RuleType.OrderDistribution, //TODO 规则只有这里区别
  74. RULE_ID = ruleId,
  75. };
  76. new DataRepository<BAS_RULE>(_dataContext).Add(entity);
  77. foreach (var item in info.DetailList)
  78. {
  79. var permission = new BAS_RULE_DTL
  80. {
  81. CREATE_TIME = now,
  82. UPDATE_TIME = now,
  83. CREATE_BY = info.OperationUserId,
  84. UPDATE_BY = info.OperationUserId,
  85. DEL_FLAG = 0,
  86. DESCRIBE = item.RuleItemDescribe,
  87. RULE_ID = ruleId,
  88. RULE_ITEM_CODE = item.RuleItemCode,
  89. RULE_ITEM_DESC = item.RuleItemDescribe,
  90. PARAM_FLAG = item.ParamFlag,
  91. RULE_ITEM_PARAM1 = item.RuleItemParam1,
  92. RULE_ITEM_PARAM2 = item.RuleItemParam2,
  93. RULE_ITEM_PARAM3 = item.RuleItemParam3,
  94. USED_FLAG = 1,
  95. };
  96. affectedRows = affectedRows + new DataRepository<BAS_RULE_DTL>(_dataContext).Add(permission,
  97. new string[1] { "RULE_DTL_ID" });
  98. }
  99. if (affectedRows != info.DetailList.Count)
  100. {
  101. _dataContext.Rollback();
  102. return GetStatus(affectedRows, info.DetailList.Count);
  103. }
  104. }
  105. catch (Exception ex)
  106. {
  107. _dataContext.Rollback();
  108. return FailStatus(ex.Message);
  109. }
  110. _dataContext.Commit();
  111. return GetStatus(affectedRows);
  112. }
  113. public OperateResultInfo Deleted(OrderDistributionRuleCondition info)
  114. {
  115. var sqlAndBuilder = new StringBuilder();
  116. var sql = $@"SELECT
  117. CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
  118. UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
  119. UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
  120. RuleTypeName = {_iSQLNodeRepository.GetEnumIntCaseString<RuleType>("RULE_TYPE")},
  121. {info.ItemSQL} FROM BAS_RULE WHERE 1=1 AND DEL_FLAG = 0 ";
  122. sqlAndBuilder = info.RuleId == null ?
  123. sqlAndBuilder :
  124. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("RULE_ID", info.RuleId, DBOperationString._Equal));
  125. sqlAndBuilder = string.IsNullOrWhiteSpace(info.RuleCode) ?
  126. sqlAndBuilder :
  127. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("RULE_CODE", info.RuleCode, DBOperationString._Equal));
  128. sqlAndBuilder = string.IsNullOrWhiteSpace(info.RuleIds) ?
  129. sqlAndBuilder :
  130. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("RULE_ID", info.RuleIds, DBOperationString._In));
  131. sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
  132. var result = new DataRepository<OrderDistributionRuleResult>(_dataContext).Query(sql);
  133. if (!result.Any())
  134. {
  135. return FailMessageStatus("参数错误");
  136. }
  137. var now = DateTime.Now;
  138. var affectedRows = 0;
  139. foreach (var item in result)
  140. {
  141. sql = $@"UPDATE BAS_RULE SET DEL_FLAG=1,UPDATE_BY={info.OperationUserId},UPDATE_TIME='{now}'
  142. WHERE RULE_ID={item.RULE_ID}";
  143. affectedRows = new DataRepository<BAS_RULE>(_dataContext).Execute(sql);
  144. sql = $@"UPDATE BAS_RULE SET DEL_FLAG=1,UPDATE_BY={info.OperationUserId},UPDATE_TIME='{now}'
  145. WHERE RULE_ID={item.RULE_ID}";
  146. affectedRows = new DataRepository<BAS_RULE_DTL>(_dataContext).Execute(sql);
  147. }
  148. return SuccessStatus();
  149. }
  150. public OperateResultInfo Edit(OrderDistributionRuleCondition info)
  151. {
  152. if (!new DataRepository<BAS_RULE>(_dataContext).Query().Where(m => m.RULE_CODE == info.RuleCode
  153. && m.DEL_FLAG == 0 && m.USED_FLAG == 1).Any())
  154. {
  155. return FailMessageStatus("上架规则编码不存在,请检查!");
  156. }
  157. var affectedRows = 0;
  158. try
  159. {
  160. _dataContext.BeginTran();
  161. var now = DateTime.Now;
  162. var whereList = new List<FieldKeyInfo>()
  163. .AddFieldKeyInfo(nameof(BAS_RULE.RULE_CODE),
  164. info.RuleCode, EnumCSharpPropertyType.STRING, DBOperationString._Equal,
  165. !string.IsNullOrWhiteSpace(info.RuleCode))
  166. .AddFieldKeyInfo(nameof(BAS_RULE.RULE_ID),
  167. info.RuleId, EnumCSharpPropertyType.INT, DBOperationString._Equal,
  168. info.RuleId != null);
  169. var result = new DataRepository<BAS_RULE>(_dataContext).Query(whereList).FirstOrDefault();
  170. if (result == null)
  171. {
  172. return FailMessageStatus("参数错误");
  173. }
  174. var entity = new BAS_RULE
  175. {
  176. RULE_ID = result.RULE_ID,
  177. RULE_NAME = info.RuleName,
  178. DESCRIBE = info.RuleDescribe,
  179. USED_FLAG = info.IsUsed ? 1 : 0
  180. };
  181. new DataRepository<BAS_RULE>(_dataContext).Update(entity, "RULE_ID", "NEWID");
  182. foreach (var item in new DataRepository<BAS_RULE_DTL>(_dataContext).Query("RULE_ID", result.RULE_ID.ToString()).ToList())
  183. {
  184. var entitydtl = new BAS_RULE_DTL
  185. {
  186. RULE_ID = result.RULE_ID,
  187. UPDATE_TIME = now,
  188. DEL_FLAG = 1,
  189. UPDATE_BY = info.OperationUserId,
  190. RULE_DTL_ID = item.RULE_DTL_ID,
  191. };
  192. new DataRepository<BAS_RULE_DTL>(_dataContext).Update(entitydtl, "RULE_DTL_ID", "NEWID");
  193. }
  194. foreach (var item in info.DetailList)
  195. {
  196. //新增
  197. if (item.RuleItemId == null)
  198. {
  199. var dtlEntity = new BAS_RULE_DTL
  200. {
  201. CREATE_TIME = now,
  202. UPDATE_TIME = now,
  203. CREATE_BY = info.OperationUserId,
  204. UPDATE_BY = info.OperationUserId,
  205. DEL_FLAG = 0,
  206. DESCRIBE = item.RuleItemDescribe,
  207. RULE_ID = result.RULE_ID,
  208. RULE_ITEM_CODE = item.RuleItemCode,
  209. RULE_ITEM_DESC = item.RuleItemDescribe,
  210. PARAM_FLAG = item.ParamFlag,
  211. RULE_ITEM_PARAM1 = item.RuleItemParam1,
  212. RULE_ITEM_PARAM2 = item.RuleItemParam2,
  213. RULE_ITEM_PARAM3 = item.RuleItemParam3,
  214. USED_FLAG = 1,
  215. };
  216. affectedRows = affectedRows + new DataRepository<BAS_RULE_DTL>(_dataContext).Add(dtlEntity, new string[1] { "RULE_DTL_ID" });
  217. }
  218. //修改
  219. else
  220. {
  221. var itemDetail = new DataRepository<BAS_RULE_DTL>(_dataContext).Query("RULE_DTL_ID", item.RuleItemId.ToString()).FirstOrDefault();
  222. itemDetail.PARAM_FLAG = item.ParamFlag;
  223. itemDetail.RULE_ITEM_PARAM1 = item.RuleItemParam1;
  224. itemDetail.RULE_ITEM_PARAM2 = item.RuleItemParam2;
  225. itemDetail.RULE_ITEM_PARAM3 = item.RuleItemParam3;
  226. itemDetail.RULE_ITEM_CODE = item.RuleItemCode;
  227. itemDetail.RULE_ITEM_DESC = item.RuleItemDescribe;
  228. itemDetail.UPDATE_BY = info.OperationUserId;
  229. itemDetail.DEL_FLAG = 0;
  230. itemDetail.UPDATE_TIME = now;
  231. affectedRows = affectedRows + new DataRepository<BAS_RULE_DTL>(_dataContext).Update(itemDetail,
  232. "RULE_DTL_ID", "NEWID");
  233. }
  234. }
  235. if (affectedRows != info.DetailList.Count)
  236. {
  237. _dataContext.Rollback();
  238. return GetStatus(affectedRows, info.DetailList.Count);
  239. }
  240. _dataContext.Commit();
  241. return SuccessStatus();
  242. }
  243. catch (Exception ex)
  244. {
  245. _dataContext.Rollback();
  246. return FailStatus(ex.Message);
  247. }
  248. }
  249. public OperateResultInfo<List<OrderDistributionRuleDetailResult>> GetDetailList(OrderDistributionRuleDetailSearchCondition info)
  250. {
  251. if (info.RuleId == null)
  252. {
  253. return FailMessageStatus("参数错误!", new List<OrderDistributionRuleDetailResult>());
  254. }
  255. var sqlAndBuilder = new StringBuilder();
  256. var sql = $@"SELECT
  257. CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
  258. UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
  259. UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
  260. ParamFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<RuleParamFlag>("PARAM_FLAG")},
  261. {info.ItemSQL} FROM BAS_RULE_DTL WHERE 1=1 AND DEL_FLAG = 0 AND RULE_ID={info.RuleId}";
  262. sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
  263. var result = new DataRepository<OrderDistributionRuleDetailResult>(_dataContext).Query(sql);
  264. return SuccessStatus(result.ToList());
  265. }
  266. public OperateResultInfo<PageQueryResultInfo<OrderDistributionRuleResult>> GetList(OrderDistributionRuleSearchCondition info)
  267. {
  268. var sqlAndBuilder = new StringBuilder();
  269. var sqlOrBuilder = new StringBuilder();
  270. var sql = $@"SELECT
  271. CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
  272. UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
  273. UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
  274. RuleTypeName = {_iSQLNodeRepository.GetEnumIntCaseString<RuleType>("USED_FLAG")},
  275. {info.ItemSQL} FROM BAS_RULE WHERE 1=1 AND DEL_FLAG = 0 AND RULE_TYPE={(int)RuleType.OrderDistribution} ";
  276. sqlAndBuilder = string.IsNullOrWhiteSpace(info.Describe) ?
  277. sqlAndBuilder :
  278. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("DESCRIBE", info.Describe, DBOperationString._Equal));
  279. sqlAndBuilder = string.IsNullOrWhiteSpace(info.RuleCode) ?
  280. sqlAndBuilder :
  281. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("RULE_CODE", info.RuleCode, DBOperationString._Equal));
  282. sqlAndBuilder = info.IsUsed == null ?
  283. sqlAndBuilder :
  284. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("USED_FLAG", info.IsUsed, DBOperationString._Equal));
  285. sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
  286. IEnumerable<OrderDistributionRuleResult> result;
  287. IEnumerable<OrderDistributionRuleResult> totalResult;
  288. totalResult = new DataRepository<OrderDistributionRuleResult>(_dataContext).Query(sql);
  289. if (info.PageIndex == 0 || info.PageSize == 0)
  290. {
  291. result = totalResult.ToList();
  292. }
  293. else
  294. {
  295. result = new DataRepository<OrderDistributionRuleResult>(_dataContext).QueryPage(sql,
  296. "CREATE_TIME", info.PageSize, info.PageIndex, true);
  297. }
  298. return SuccessStatus(new PageQueryResultInfo<OrderDistributionRuleResult>
  299. {
  300. RowData = result,
  301. PageConditionInfo = info,
  302. TotalCount = totalResult.Count(),
  303. TotalPageCount = (int)Math.Ceiling((double)totalResult.Count() / info.PageSize)
  304. });
  305. }
  306. public OperateResultInfo Remove(OrderDistributionRuleCondition info)
  307. {
  308. if (string.IsNullOrWhiteSpace(info.RuleCode) && info.RuleId == null)
  309. {
  310. return FailMessageStatus("参数错误!");
  311. }
  312. var sqlAndBuilder = new StringBuilder();
  313. var sqlOrBuilder = new StringBuilder();
  314. var sql = $@"SELECT
  315. CreateName = (SELECT USER_NAME FROM SYS_USER A WHERE A.USER_ID=CREATE_BY),
  316. UpdateName = (SELECT USER_NAME FROM SYS_USER B WHERE B.USER_ID=UPDATE_BY),
  317. UsedFlagName = {_iSQLNodeRepository.GetEnumIntCaseString<UsedFlag>("USED_FLAG")},
  318. {info.ItemSQL} FROM BAS_RULE WHERE 1=1 AND DEL_FLAG = 0 ";
  319. sqlAndBuilder = string.IsNullOrWhiteSpace(info.RuleCode) ?
  320. sqlAndBuilder :
  321. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("RULE_CODE", info.RuleCode, DBOperationString._Equal));
  322. sqlAndBuilder = info.RuleId != null ?
  323. sqlAndBuilder :
  324. sqlAndBuilder.Append(_iSQLNodeRepository.GetAddCondition("RULE_ID", info.RuleId, DBOperationString._Equal));
  325. sql = sql + (sqlAndBuilder.Length > 0 ? _iSQLNodeRepository.GetAndString(sqlAndBuilder, false) : "");
  326. var result = new DataRepository<BAS_RULE>(_dataContext).Query(sql);
  327. if (result.Count() != 1)
  328. {
  329. return FailMessageStatus("参数错误!");
  330. }
  331. var affectedRows = 0;
  332. affectedRows = new DataRepository<BAS_RULE>(_dataContext).Remove("RULE_ID", result.FirstOrDefault().RULE_ID.ToString());
  333. affectedRows = new DataRepository<BAS_RULE_DTL>(_dataContext).Remove("RULE_ID", result.FirstOrDefault().RULE_ID.ToString());
  334. return SuccessStatus();
  335. }
  336. }
  337. }