GoodsRepository.cs 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773
  1. using AutoMapper;
  2. using OASystem.Domain.Dtos.PersonnelModule;
  3. using OASystem.Domain.Entities.Groups;
  4. using OASystem.Domain.Entities.PersonnelModule;
  5. using OASystem.Domain.ViewModels.PersonnelModule;
  6. namespace OASystem.Infrastructure.Repositories.PersonnelModule
  7. {
  8. /// <summary>
  9. /// 物品进销存
  10. /// 仓储
  11. /// </summary>
  12. public class GoodsRepository : BaseRepository<Pm_GoodsInfo, GoodsInfoView>
  13. {
  14. private readonly IMapper _mapper;
  15. private JsonView _jv;
  16. public GoodsRepository(SqlSugarClient sqlSugar, IMapper mapper) : base(sqlSugar)
  17. {
  18. _mapper = mapper;
  19. _jv = new JsonView() { Code = StatusCodes.Status400BadRequest, Msg = "操作失败!" };
  20. }
  21. /// <summary>
  22. /// 基础数据
  23. /// </summary>
  24. /// <returns></returns>
  25. public async Task<JsonView> InitDataSource()
  26. {
  27. var typeData = await _sqlSugar.Queryable<GoodsTypeView>()
  28. .Includes(x => x.SubTypeItems.Where(z => z.IsDel == 0)
  29. //.Select(z => new {
  30. // z.Id,
  31. // z.STid,
  32. // z.Name
  33. //})
  34. .ToList())
  35. .Where(x => x.IsDel == 0 &&
  36. x.Remark.Equals("GoodsType"))
  37. //.Select(x => new {
  38. // x.Id,
  39. // x.Name,
  40. // x.SubTypeItems
  41. //})
  42. .ToListAsync();
  43. var groupData = await _sqlSugar.Queryable<Grp_DelegationInfo>()
  44. .Where(x => x.IsDel == 0)
  45. .Select(x => new
  46. {
  47. id = x.Id,
  48. groupName = x.TeamName
  49. })
  50. .OrderByDescending(x => x.id)
  51. .ToListAsync();
  52. var userData = await _sqlSugar.Queryable<Sys_Users>()
  53. .Where(x => x.IsDel == 0)
  54. .Select(x => new
  55. {
  56. x.Id,
  57. UserName = x.CnName,
  58. })
  59. .ToListAsync();
  60. _jv.Code = StatusCodes.Status200OK;
  61. _jv.Data = new { goodsTypeData = typeData, groupNameData = groupData, userNameData = userData };
  62. _jv.Msg = $"操作成功";
  63. return _jv;
  64. }
  65. /// <summary>
  66. /// 物品列表
  67. /// </summary>
  68. /// <param name="dto"></param>
  69. /// <returns></returns>
  70. public async Task<JsonView> GoodsList(GoodsListDTO dto)
  71. {
  72. var ids = new List<int>();
  73. if (!string.IsNullOrEmpty(dto.TypeIds))
  74. {
  75. var strArray = dto.TypeIds.Split(',');
  76. foreach (var str in strArray)
  77. {
  78. if (int.TryParse(str, out int id))
  79. {
  80. ids.Add(id);
  81. }
  82. }
  83. }
  84. RefAsync<int> total = 0;
  85. var data = await _sqlSugar.Queryable<Pm_GoodsInfo>()
  86. .LeftJoin<Sys_SetData>((gi, sd) => gi.Type == sd.Id)
  87. .LeftJoin<Sys_Users>((gi, sd, u) => gi.LastUpdateUserId == u.Id)
  88. .Where((gi, sd, u) => gi.IsDel == 0)
  89. .WhereIF(ids.Count > 0, (gi, sd, u) => ids.Contains(gi.Type))
  90. .WhereIF(!string.IsNullOrEmpty(dto.GoodsName), (gi, sd, u) => gi.Name.Contains(dto.GoodsName))
  91. .Select((gi, sd, u) => new
  92. {
  93. gi.Id,
  94. gi.Name,
  95. gi.Type,
  96. TypeName = sd.Name,
  97. gi.StockQuantity,
  98. LastUpdateUserName = u.CnName,
  99. gi.LastUpdateTime,
  100. gi.Remark,
  101. })
  102. .OrderByDescending(gi => gi.LastUpdateTime)
  103. .ToPageListAsync(dto.PageIndex, dto.PageSize, total);
  104. _jv.Code = StatusCodes.Status200OK;
  105. _jv.Data = data;
  106. _jv.Count = total;
  107. _jv.Msg = $"操作成功";
  108. return _jv;
  109. }
  110. /// <summary>
  111. /// 物品Info
  112. /// </summary>
  113. /// <param name="portType"></param>
  114. /// <param name="id"></param>
  115. /// <returns></returns>
  116. public async Task<JsonView> GoodsInfo(int portType, int id)
  117. {
  118. var data = await _sqlSugar.Queryable<Pm_GoodsInfo>()
  119. .LeftJoin<Sys_SetData>((gi, sd) => gi.Type == sd.Id)
  120. .LeftJoin<Sys_Users>((gi, sd, u1) => gi.LastUpdateUserId == u1.Id)
  121. .LeftJoin<Sys_Users>((gi, sd, u1, u2) => gi.CreateUserId == u2.Id)
  122. .Where((gi, sd, u1, u2) => gi.IsDel == 0 && gi.Id == id)
  123. .Select((gi, sd, u1, u2) => new
  124. {
  125. gi.Id,
  126. gi.Name,
  127. ParentType = sd.STid,
  128. gi.Type,
  129. TypeName = sd.Name,
  130. gi.SQ_Total,
  131. gi.OQ_Total,
  132. gi.PriceTotal,
  133. gi.StockQuantity,
  134. gi.Remark,
  135. LastUpdateUserName = u1.CnName,
  136. gi.LastUpdateTime,
  137. CreateUserName = u2.CnName,
  138. gi.CreateTime,
  139. })
  140. .FirstAsync();
  141. _jv.Code = StatusCodes.Status200OK;
  142. _jv.Data = data;
  143. _jv.Msg = $"操作成功";
  144. return _jv;
  145. }
  146. /// <summary>
  147. /// 物品 OP(Create Or Edit)
  148. /// </summary>
  149. /// <param name="dto"></param>
  150. /// <param name="currUserId"></param>
  151. /// <returns></returns>
  152. public async Task<JsonView> GoodsOp(GoodsOPDTO dto, int currUserId)
  153. {
  154. var info = new Pm_GoodsInfo()
  155. {
  156. Id = dto.Id,
  157. Name = dto.Name,
  158. Type = dto.Type,
  159. SQ_Total = 0,
  160. OQ_Total = 0,
  161. PriceTotal = 0,
  162. StockQuantity = 0,
  163. Remark = dto.Remark,
  164. LastUpdateUserId = currUserId,
  165. LastUpdateTime = DateTime.Now,
  166. CreateUserId = currUserId
  167. };
  168. if (dto.Id > 0) //Edit
  169. {
  170. var upd = await _sqlSugar.Updateable(info)
  171. .UpdateColumns(x => new
  172. {
  173. x.Name,
  174. x.Type,
  175. x.Remark,
  176. x.LastUpdateUserId,
  177. x.LastUpdateTime,
  178. })
  179. .ExecuteCommandAsync();
  180. if (upd > 0)
  181. {
  182. _jv.Msg = $"修改成功!";
  183. _jv.Code = StatusCodes.Status200OK;
  184. return _jv;
  185. }
  186. }
  187. else if (dto.Id < 1) //添加
  188. {
  189. var selectInfo = await _sqlSugar.Queryable<Pm_GoodsInfo>().FirstAsync(x => x.Name.Equals(info.Name));
  190. if (selectInfo != null)
  191. {
  192. _jv.Msg = $"“{info.Name}”该物品已存在,请勿重新添加!";
  193. return _jv;
  194. }
  195. var add = await _sqlSugar.Insertable(info).ExecuteCommandAsync();
  196. if (add > 0)
  197. {
  198. _jv.Msg = $"添加成功!";
  199. _jv.Code = StatusCodes.Status200OK;
  200. return _jv;
  201. }
  202. }
  203. return _jv;
  204. }
  205. /// <summary>
  206. /// 物品 Del
  207. /// </summary>
  208. /// <param name="id"></param>
  209. /// <param name="currUserId"></param>
  210. /// <returns></returns>
  211. public async Task<JsonView> GoodsDel(int id, int currUserId)
  212. {
  213. _sqlSugar.BeginTran();
  214. var goods = await _sqlSugar.Updateable<Pm_GoodsInfo>()
  215. .SetColumns(x => new Pm_GoodsInfo()
  216. {
  217. IsDel = 1,
  218. DeleteUserId = currUserId,
  219. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
  220. })
  221. .Where(x => x.Id == id)
  222. .ExecuteCommandAsync();
  223. if (goods < 1)
  224. {
  225. _sqlSugar.RollbackTran();
  226. _jv.Msg = $"操作失败";
  227. return _jv;
  228. }
  229. var goodsStorage = await _sqlSugar.Updateable<Pm_GoodsStorage>()
  230. .SetColumns(x => new Pm_GoodsStorage()
  231. {
  232. IsDel = 1,
  233. DeleteUserId = currUserId,
  234. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
  235. })
  236. .Where(x => x.Id == id)
  237. .ExecuteCommandAsync();
  238. var goodsReceive = await _sqlSugar.Updateable<Pm_GoodsReceive>()
  239. .SetColumns(x => new Pm_GoodsReceive()
  240. {
  241. IsDel = 1,
  242. DeleteUserId = currUserId,
  243. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
  244. })
  245. .Where(x => x.Id == id)
  246. .ExecuteCommandAsync();
  247. _sqlSugar.CommitTran();
  248. _jv.Code = StatusCodes.Status200OK;
  249. _jv.Msg = $"操作成功!";
  250. return _jv;
  251. }
  252. /// <summary>
  253. /// 物品入库列表
  254. /// </summary>
  255. /// <param name="dto"></param>
  256. /// <returns></returns>
  257. public async Task<JsonView> GoodsStorageList(GoodsStorageListDTO dto)
  258. {
  259. RefAsync<int> total = 0;
  260. var data = await _sqlSugar.Queryable<Pm_GoodsStorage>()
  261. .LeftJoin<Pm_GoodsInfo>((gs, gi) => gs.GoodsId == gi.Id)
  262. .LeftJoin<Sys_Users>((gs, gi, u) => gs.CreateUserId == u.Id)
  263. .LeftJoin<Sys_Users>((gs, gi, u,u1) => gs.StorageUserId == u1.Id)
  264. .Where((gs, gi, u,u1) => gs.IsDel == 0)
  265. .WhereIF(dto.GoodsId > 0, (gs, gi, u,u1) => gs.GoodsId == dto.GoodsId)
  266. .Select((gs, gi, u, u1) => new
  267. {
  268. gs.Id,
  269. gs.GoodsId,
  270. GoodsName = gi.Name,
  271. gs.Quantity,
  272. gs.UnitPrice,
  273. gs.TotalPrice,
  274. gs.SupplierName,
  275. gs.SupplierTel,
  276. gs.SupplierAddress,
  277. gs.SupplierSource,
  278. StorageUserName=u1.CnName,
  279. gs.StorageTime,
  280. CreateUserName = u.CnName,
  281. gs.CreateTime,
  282. })
  283. .OrderByDescending(gs => gs.CreateTime)
  284. .ToPageListAsync(dto.PageIndex, dto.PageSize, total);
  285. _jv.Code = StatusCodes.Status200OK;
  286. _jv.Data = data;
  287. _jv.Count = total;
  288. _jv.Msg = $"操作成功";
  289. return _jv;
  290. }
  291. /// <summary>
  292. /// 物品入库详情
  293. /// </summary>
  294. /// <param name="id"></param>
  295. /// <returns></returns>
  296. public async Task<JsonView> GoodsStorageInfo(int portType, int id)
  297. {
  298. var data = await _sqlSugar.Queryable<Pm_GoodsStorage>()
  299. .LeftJoin<Pm_GoodsInfo>((gs, gi) => gs.GoodsId == gi.Id)
  300. .LeftJoin<Sys_Users>((gs, gi, u) => gs.CreateUserId == u.Id)
  301. .LeftJoin<Sys_Users>((gs, gi, u, u1) => gs.StorageUserId == u1.Id)
  302. .Where((gs, gi, u) => gs.IsDel == 0)
  303. .WhereIF(id > 0, (gs, gi, u) => gs.Id == id)
  304. .Select((gs, gi, u, u1) => new
  305. {
  306. gs.Id,
  307. gs.GoodsId,
  308. GoodsName = gi.Name,
  309. gs.Quantity,
  310. gs.UnitPrice,
  311. gs.TotalPrice,
  312. gs.SupplierName,
  313. gs.SupplierTel,
  314. gs.SupplierAddress,
  315. gs.SupplierSource,
  316. StorageUser = u1.CnName,
  317. gs.StorageTime,
  318. CreateUserName = u.CnName,
  319. gs.CreateTime,
  320. gs.Remark
  321. })
  322. .FirstAsync();
  323. _jv.Msg = $"操作成功!";
  324. _jv.Code = StatusCodes.Status200OK;
  325. _jv.Data = data;
  326. return _jv;
  327. }
  328. /// <summary>
  329. /// 物品入库 操作(Create Or Edit)
  330. /// </summary>
  331. /// <param name="dto"></param>
  332. /// <param name="currUserId"></param>
  333. /// <returns></returns>
  334. public async Task<JsonView> GoodsStorageOp(GoodsStorageOpDto dto, int currUserId)
  335. {
  336. var info = _mapper.Map<Pm_GoodsStorage>(dto);
  337. info.CreateUserId = currUserId;
  338. info.BatchNo = Guid.NewGuid().ToString("N");
  339. decimal editAgoQuantity = 0.00M,
  340. editAgoTotalPrice = 0.00M;
  341. _sqlSugar.BeginTran();
  342. if (info.Id > 0) //修改
  343. {
  344. var selectInfo = await _sqlSugar.Queryable<Pm_GoodsStorage>()
  345. .Where(x => x.Id == dto.Id)
  346. .FirstAsync();
  347. editAgoQuantity = selectInfo.Quantity;
  348. editAgoTotalPrice = selectInfo.TotalPrice;
  349. var storageEdit = await _sqlSugar.Updateable(info)
  350. .UpdateColumns(x => new
  351. {
  352. x.Quantity,
  353. x.UnitPrice,
  354. x.TotalPrice,
  355. x.SupplierName,
  356. x.SupplierTel,
  357. x.SupplierAddress,
  358. x.SupplierSource,
  359. x.StorageUserId,
  360. x.StorageTime
  361. })
  362. .Where(x => x.Id == dto.Id)
  363. .ExecuteCommandAsync();
  364. if (storageEdit < 1)
  365. {
  366. _sqlSugar.RollbackTran();
  367. _jv.Msg = $"修改失败!";
  368. return _jv;
  369. }
  370. }
  371. else if (info.Id < 1) //添加
  372. {
  373. var storageAdd = await _sqlSugar.Insertable(info).ExecuteCommandAsync();
  374. if (storageAdd < 1)
  375. {
  376. _sqlSugar.RollbackTran();
  377. _jv.Msg = $"添加失败!";
  378. return _jv;
  379. }
  380. }
  381. var goodsInfo = await _sqlSugar.Queryable<Pm_GoodsInfo>().FirstAsync(x => x.Id == info.GoodsId);
  382. goodsInfo.SQ_Total = goodsInfo.SQ_Total - editAgoQuantity + info.Quantity;
  383. goodsInfo.StockQuantity = goodsInfo.StockQuantity - editAgoQuantity + info.Quantity;
  384. goodsInfo.PriceTotal = goodsInfo.PriceTotal - editAgoTotalPrice + info.TotalPrice;
  385. goodsInfo.LastUpdateUserId = currUserId;
  386. goodsInfo.LastUpdateTime = DateTime.Now;
  387. var goodsEdit = await _sqlSugar.Updateable(goodsInfo)
  388. .UpdateColumns(x => new
  389. {
  390. x.SQ_Total,
  391. x.StockQuantity,
  392. x.PriceTotal,
  393. x.LastUpdateUserId,
  394. x.LastUpdateTime,
  395. })
  396. .Where(x => x.Id == info.GoodsId)
  397. .ExecuteCommandAsync();
  398. if (goodsEdit > 0)
  399. {
  400. _sqlSugar.CommitTran();
  401. _jv.Msg = $"操作成功!";
  402. _jv.Code = StatusCodes.Status200OK;
  403. return _jv;
  404. }
  405. _sqlSugar.RollbackTran();
  406. _jv.Msg = $"操作失败!";
  407. return _jv;
  408. }
  409. /// <summary>
  410. /// 物品入库 Del
  411. /// </summary>
  412. /// <param name="id"></param>
  413. /// <returns></returns>
  414. public async Task<JsonView> GoodsStorageDel(int id, int userId)
  415. {
  416. var storageInfo = await _sqlSugar.Queryable<Pm_GoodsStorage>()
  417. .Where(x => x.Id == id)
  418. .FirstAsync();
  419. if (storageInfo == null) return _jv;
  420. decimal delAgoQauntity = storageInfo.Quantity,
  421. delAgoTotalPrice = storageInfo.TotalPrice;
  422. int goodsId = storageInfo.GoodsId;
  423. _sqlSugar.BeginTran();
  424. var storageDel = await _sqlSugar.Updateable<Pm_GoodsStorage>()
  425. .SetColumns(x => new Pm_GoodsStorage
  426. {
  427. DeleteUserId = userId,
  428. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  429. IsDel = 1
  430. })
  431. .Where(x => x.Id == id)
  432. .ExecuteCommandAsync();
  433. if (storageDel < 1)
  434. {
  435. _sqlSugar.RollbackTran();
  436. _jv.Msg = $"操作失败!";
  437. return _jv;
  438. }
  439. var goodsInfo = await _sqlSugar.Queryable<Pm_GoodsInfo>().FirstAsync(x => x.Id == goodsId);
  440. goodsInfo.SQ_Total = goodsInfo.SQ_Total - delAgoQauntity;
  441. goodsInfo.StockQuantity = goodsInfo.StockQuantity - delAgoQauntity;
  442. goodsInfo.PriceTotal = goodsInfo.PriceTotal - delAgoTotalPrice;
  443. goodsInfo.LastUpdateUserId = userId;
  444. goodsInfo.LastUpdateTime = DateTime.Now;
  445. var goodsEdit = await _sqlSugar.Updateable(goodsInfo)
  446. .UpdateColumns(x => new
  447. {
  448. x.SQ_Total,
  449. x.StockQuantity,
  450. x.PriceTotal,
  451. x.LastUpdateUserId,
  452. x.LastUpdateTime,
  453. })
  454. .Where(x => x.Id == goodsId)
  455. .ExecuteCommandAsync();
  456. if (goodsEdit > 0)
  457. {
  458. _sqlSugar.CommitTran();
  459. _jv.Msg = $"操作成功!";
  460. _jv.Code = StatusCodes.Status200OK;
  461. return _jv;
  462. }
  463. _sqlSugar.RollbackTran();
  464. _jv.Msg = $"操作失败!";
  465. return _jv;
  466. }
  467. /// <summary>
  468. /// 物品领用列表
  469. /// </summary>
  470. /// <param name="dto"></param>
  471. /// <returns></returns>
  472. public async Task<JsonView> GoodsReceiveList(GoodsReceiveListDTO dto)
  473. {
  474. RefAsync<int> total = 0;
  475. var data = await _sqlSugar.Queryable<Pm_GoodsReceive>()
  476. .LeftJoin<Pm_GoodsInfo>((gr, gi) => gr.GoodsId == gi.Id)
  477. .LeftJoin<Sys_Users>((gr, gi, u1) => gr.AuditUserId == u1.Id)
  478. .LeftJoin<Sys_Users>((gr, gi, u1, u2) => gr.CreateUserId == u2.Id)
  479. .Where((gr, gi, u1, u2) => gr.IsDel == 0)
  480. .WhereIF(dto.GoodsId > 0, (gr, gi, u1, u2) => gr.GoodsId == dto.GoodsId)
  481. .WhereIF(dto.GoodsId > 0, (gr, gi, u1, u2) => gr.CreateUserId == dto.CurrUserId)
  482. .Select((gr, gi, u1, u2) => new GoodsReceiveListView
  483. {
  484. Id = gr.Id,
  485. GroupId = gr.GroupId,
  486. GoodsId = gr.GoodsId,
  487. GoodsName = gi.Name,
  488. Quantity = gr.Quantity,
  489. Reason = gr.Reason,
  490. Remark = gr.Remark,
  491. AuditStatus = gr.AuditStatus,
  492. //AuditStatusText = gr.AuditStatus.GetEnumDescription(),
  493. AuditUserId = gr.AuditUserId,
  494. AuditUserName = u1.CnName,
  495. AuditTime = gr.AuditTime,
  496. CreateUserName = u2.CnName,
  497. CreateTime = gr.CreateTime
  498. })
  499. .OrderByDescending(gr => gr.CreateTime)
  500. .ToPageListAsync(dto.PageIndex, dto.PageSize, total);
  501. _jv.Code = StatusCodes.Status200OK;
  502. _jv.Data = data;
  503. _jv.Count = total;
  504. _jv.Msg = $"操作成功";
  505. return _jv;
  506. }
  507. /// <summary>
  508. /// 物品领用详情
  509. /// </summary>
  510. /// <param name="portType"></param>
  511. /// <param name="id"></param>
  512. /// <returns></returns>
  513. public async Task<JsonView> GoodsReceiveInfo(int portType, int id)
  514. {
  515. var data = await _sqlSugar.Queryable<Pm_GoodsReceive>()
  516. .LeftJoin<Pm_GoodsInfo>((gr, gi) => gr.GoodsId == gi.Id)
  517. .LeftJoin<Sys_Users>((gr, gi, u1) => gr.AuditUserId == u1.Id)
  518. .LeftJoin<Sys_Users>((gr, gi, u1, u2) => gr.CreateUserId == u2.Id)
  519. .Where((gr, gi, u1, u2) => gr.IsDel == 0)
  520. .WhereIF(id > 0, (gr, gi, u1, u2u) => gr.Id == id)
  521. .Select((gr, gi, u1, u2) => new
  522. {
  523. gr.Id,
  524. gr.GroupId,
  525. gr.GoodsId,
  526. GoodsName = gi.Name,
  527. gr.Quantity,
  528. gr.Reason,
  529. gr.Remark,
  530. gr.AuditStatus,
  531. AuditStatusText = gr.AuditStatus.GetDescription(),
  532. gr.AuditUserId,
  533. AuditUserName = u1.CnName,
  534. gr.AuditTime,
  535. CreateUserName = u2.CnName,
  536. gr.CreateTime
  537. })
  538. .FirstAsync();
  539. _jv.Code = StatusCodes.Status200OK;
  540. _jv.Data = data;
  541. _jv.Msg = $"操作成功";
  542. return _jv;
  543. }
  544. /// <summary>
  545. /// 物品领用 OP(Add Or Edit)
  546. /// </summary>
  547. /// <param name="dto"></param>
  548. /// <param name="currUserId"></param>
  549. /// <returns></returns>
  550. public async Task<JsonView> GoodsReceiveOP(GoodsReceiveOPDTO dto, int currUserId)
  551. {
  552. var info = _mapper.Map<Pm_GoodsReceive>(dto);
  553. info.CreateUserId = currUserId;
  554. _sqlSugar.BeginTran();
  555. //物品现有库存
  556. var stockQuantity = _sqlSugar.Queryable<Pm_GoodsInfo>()
  557. .First(x => x.Id == info.GoodsId)
  558. ?.StockQuantity;
  559. //待审核 该物品数量
  560. var waitAuditQuantity = await _sqlSugar.Queryable<Pm_GoodsReceive>()
  561. .Where(x => x.IsDel == 0 &&
  562. x.GoodsId == dto.GoodsId &&
  563. x.AuditStatus == GoodsAuditEnum.Pending
  564. )
  565. .SumAsync(x => x.Quantity);
  566. if (info.Id > 0) //修改
  567. {
  568. //审核验证
  569. var selectInfo = await _sqlSugar.Queryable<Pm_GoodsReceive>().FirstAsync(x => x.Id == info.Id);
  570. if (selectInfo.AuditStatus == GoodsAuditEnum.Approved)
  571. {
  572. _sqlSugar.RollbackTran();
  573. _jv.Msg = $"该条数据已通过审核,不可更改!";
  574. return _jv;
  575. }
  576. //物品数量验证
  577. decimal editAfterQuantity = waitAuditQuantity - selectInfo.Quantity + info.Quantity;
  578. if (editAfterQuantity > stockQuantity)
  579. {
  580. _sqlSugar.RollbackTran();
  581. _jv.Msg = $"该物品现有库存不足,不可更改!请联系采购人员购买!";
  582. return _jv;
  583. }
  584. var edit = await _sqlSugar.Updateable(info)
  585. .UpdateColumns(x => new
  586. {
  587. x.GroupId,
  588. x.Quantity,
  589. x.Reason,
  590. x.Remark,
  591. })
  592. .Where(x => x.Id == info.Id)
  593. .ExecuteCommandAsync();
  594. if (edit > 0)
  595. {
  596. _sqlSugar.CommitTran();
  597. _jv.Msg = $"操作成功!";
  598. _jv.Code = StatusCodes.Status200OK;
  599. return _jv;
  600. }
  601. }
  602. else if (info.Id < 1) //添加
  603. {
  604. //物品数量验证
  605. decimal addAgoQuantity = waitAuditQuantity + info.Quantity;
  606. if (addAgoQuantity > stockQuantity)
  607. {
  608. _sqlSugar.RollbackTran();
  609. _jv.Msg = $"该物品现有库存不足,不可更改!请联系采购人员购买!";
  610. return _jv;
  611. }
  612. var add = await _sqlSugar.Insertable(info).ExecuteCommandAsync();
  613. if (add > 0)
  614. {
  615. _sqlSugar.CommitTran();
  616. _jv.Msg = $"操作成功!";
  617. _jv.Code = StatusCodes.Status200OK;
  618. return _jv;
  619. }
  620. }
  621. _sqlSugar.RollbackTran();
  622. return _jv;
  623. }
  624. /// <summary>
  625. /// 物品领用 Audit
  626. /// </summary>
  627. /// <param name="idArray"></param>
  628. /// <param name="userId"></param>
  629. /// <param name="auditEnum"></param>
  630. /// <returns></returns>
  631. public async Task<JsonView> GoodsReceiveAudit(int[] idArray, int userId, GoodsAuditEnum auditEnum)
  632. {
  633. if (idArray.Length < 1) return _jv;
  634. //TODO: 审核权限验证
  635. _sqlSugar.BeginTran();
  636. var receiveInfos = await _sqlSugar.Queryable<Pm_GoodsReceive>()
  637. .Where(x => x.IsDel == 0 && idArray.Contains(x.Id))
  638. .ToListAsync();
  639. bool status = true;
  640. foreach (var id in idArray)
  641. {
  642. var currInfo = receiveInfos.Find(x => x.Id == id);
  643. var edit = await _sqlSugar.Updateable<Pm_GoodsReceive>()
  644. .SetColumns(x => new Pm_GoodsReceive()
  645. {
  646. AuditStatus = auditEnum,
  647. AuditUserId = userId,
  648. AuditTime = DateTime.Now,
  649. })
  650. .Where(x => x.Id == id)
  651. .ExecuteCommandAsync();
  652. if (edit < 1) status = false;
  653. var goodsInfo = await _sqlSugar.Queryable<Pm_GoodsInfo>().Where(x => x.Id == currInfo.GoodsId).FirstAsync();
  654. goodsInfo.StockQuantity = goodsInfo.StockQuantity - currInfo.Quantity;
  655. goodsInfo.LastUpdateTime = DateTime.Now;
  656. goodsInfo.LastUpdateUserId = userId;
  657. var editGoods = await _sqlSugar.Updateable<Pm_GoodsInfo>(goodsInfo)
  658. .UpdateColumns(x => new
  659. {
  660. x.StockQuantity,
  661. x.LastUpdateUserId,
  662. x.LastUpdateTime,
  663. })
  664. .Where(x => x.Id == id)
  665. .ExecuteCommandAsync();
  666. if (editGoods < 1) status = false;
  667. }
  668. if (status)
  669. {
  670. _sqlSugar.CommitTran();
  671. _jv.Msg = $"操作成功!";
  672. _jv.Code = StatusCodes.Status200OK;
  673. return _jv;
  674. }
  675. _sqlSugar.RollbackTran();
  676. return _jv;
  677. }
  678. /// <summary>
  679. /// 物品领用 Del
  680. /// </summary>
  681. /// <param name="idArray"></param>
  682. /// <param name="userId"></param>
  683. /// <param name="auditEnum"></param>
  684. /// <returns></returns>
  685. public async Task<JsonView> GoodsReceiveDel(int id, int currUserId)
  686. {
  687. var receiveInfo = await _sqlSugar.Queryable<Pm_GoodsReceive>()
  688. .Where(x => x.IsDel == 0 && x.Id == id)
  689. .FirstAsync();
  690. if (receiveInfo.AuditStatus == GoodsAuditEnum.Approved)
  691. {
  692. _jv.Msg = $"该条数据已通过审核,不可删除!";
  693. return _jv;
  694. }
  695. var edit = await _sqlSugar.Updateable<Pm_GoodsReceive>()
  696. .UpdateColumns(x => new Pm_GoodsReceive()
  697. {
  698. IsDel = 1,
  699. DeleteUserId = currUserId,
  700. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  701. })
  702. .Where(x => x.Id == id)
  703. .ExecuteCommandAsync();
  704. if (edit > 0)
  705. {
  706. _jv.Msg = $"操作成功!";
  707. _jv.Code = StatusCodes.Status200OK;
  708. return _jv;
  709. }
  710. return _jv;
  711. }
  712. }
  713. }