PurchaseReturnService.cs 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593
  1. using Admin.NET.Plugin.AiDOP.ProcurementExecution.Dto;
  2. using Admin.NET.Plugin.AiDOP.ProcurementExecution.Entity;
  3. using Admin.NET.Plugin.AiDOP.Supply;
  4. namespace Admin.NET.Plugin.AiDOP.ProcurementExecution;
  5. /// <summary>
  6. /// S4 采购退货单(PurOrdRctMaster / PurOrdRctDetail,RctType=pt)
  7. /// 路由:/api/ProcurementExecution/purchase-return/...
  8. /// </summary>
  9. [ApiDescriptionSettings(Order = 321, Description = "S4采购退货单")]
  10. [Route("api/ProcurementExecution")]
  11. [AllowAnonymous]
  12. [NonUnify]
  13. public class PurchaseReturnService : IDynamicApiController, ITransient
  14. {
  15. /// <summary>采购退货单号:PT + yyyyMMdd + 4 位流水,如 PT202605190001。</summary>
  16. private const int PtReceiverSerialWidth = 4;
  17. private readonly ISqlSugarClient _db;
  18. private readonly SqlSugarRepository<PurOrdRctMaster> _masterRep;
  19. private readonly SqlSugarRepository<PurOrdRctDetail> _detailRep;
  20. private readonly UserManager _userManager;
  21. public PurchaseReturnService(
  22. ISqlSugarClient db,
  23. SqlSugarRepository<PurOrdRctMaster> masterRep,
  24. SqlSugarRepository<PurOrdRctDetail> detailRep,
  25. UserManager userManager)
  26. {
  27. _db = db;
  28. _masterRep = masterRep;
  29. _detailRep = detailRep;
  30. _userManager = userManager;
  31. }
  32. private static string NormalizeOrderBy(string field, string order)
  33. {
  34. var col = (field ?? "").Trim();
  35. var ord = string.Equals(order?.Trim(), "desc", StringComparison.OrdinalIgnoreCase) ? "DESC" : "ASC";
  36. var map = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase)
  37. {
  38. // 注意:列表 SQL 外层包了 SELECT * FROM (...) t,因此 ORDER BY 只能引用外层可见列名
  39. ["receiver"] = "Receiver",
  40. ["rctdate"] = "RctDate",
  41. ["ordnbr"] = "OrdNbr",
  42. ["itemnum"] = "ItemNum",
  43. ["rctqty"] = "RctQty",
  44. ["suppname"] = "SuppName",
  45. };
  46. if (!map.TryGetValue(col, out var sqlCol))
  47. sqlCol = "RecID";
  48. return $"ORDER BY {sqlCol} {ord}, DetailRecId ASC";
  49. }
  50. [DisplayName("采购退货单分页列表")]
  51. [HttpGet("purchase-return/list")]
  52. public async Task<object> GetList([FromQuery] PurchaseReturnListInput input)
  53. {
  54. var page = input.Page <= 0 ? 1 : input.Page;
  55. var pageSize = input.PageSize <= 0 ? 10 : input.PageSize;
  56. var offset = (page - 1) * pageSize;
  57. var cond = new List<string> { "p.RctType='pt'", "p.IsActive=1" };
  58. var pars = new List<SugarParameter>();
  59. if (!string.IsNullOrWhiteSpace(input.Receiver))
  60. {
  61. cond.Add("p.Receiver LIKE @Receiver");
  62. pars.Add(new SugarParameter("@Receiver", $"%{input.Receiver.Trim()}%"));
  63. }
  64. if (!string.IsNullOrWhiteSpace(input.Supp))
  65. {
  66. cond.Add("p.Supp=@Supp");
  67. pars.Add(new SugarParameter("@Supp", input.Supp.Trim()));
  68. }
  69. if (!string.IsNullOrWhiteSpace(input.OrdNbr))
  70. {
  71. cond.Add("p.OrdNbr LIKE @OrdNbr");
  72. pars.Add(new SugarParameter("@OrdNbr", $"%{input.OrdNbr.Trim()}%"));
  73. }
  74. if (!string.IsNullOrWhiteSpace(input.ItemNum))
  75. {
  76. cond.Add("d1.ItemNum LIKE @ItemNum");
  77. pars.Add(new SugarParameter("@ItemNum", $"%{input.ItemNum.Trim()}%"));
  78. }
  79. var where = string.Join(" AND ", cond);
  80. var baseSql = $"""
  81. SELECT
  82. p.RecID AS RecID,
  83. IFNULL(d1.RecID, 0) AS DetailRecId,
  84. p.RctType AS RctType,
  85. p.Receiver AS Receiver,
  86. p.RctDate AS RctDate,
  87. p.OrdNbr AS OrdNbr,
  88. p.TaxClass AS TaxClass,
  89. IFNULL(p.TaxIn, 0) AS TaxIn,
  90. p.Curr AS Curr,
  91. p.Terms AS Terms,
  92. IFNULL(p.IsPlan, 0) AS IsPlan,
  93. TRIM(CONCAT(TRIM(IFNULL(p.Department,'')),' ',TRIM(IFNULL(d.Descr,'')))) AS DepartmentDescr,
  94. TRIM(CONCAT(TRIM(IFNULL(p.Supp,'')),' ',TRIM(IFNULL(s.SortName,'')))) AS SuppName,
  95. d1.ItemNum AS ItemNum,
  96. IFNULL(i.Descr,'') AS Descr,
  97. IFNULL(i.Descr1,'') AS Descr1,
  98. IFNULL(d1.RctQty, 0) AS RctQty
  99. FROM PurOrdRctMaster p
  100. LEFT JOIN PurOrdRctDetail d1 ON p.RecID = d1.PurOrdRctRecID AND d1.RctType='pt' AND d1.IsActive=1
  101. LEFT JOIN SuppMaster s ON p.Supp = s.Supp
  102. LEFT JOIN DepartmentMaster d ON p.Department = d.Department
  103. LEFT JOIN ItemMaster i ON d1.ItemNum = i.ItemNum
  104. WHERE {where}
  105. """;
  106. var orderBy = NormalizeOrderBy(input.SortField, input.SortOrder);
  107. var total = await _db.Ado.GetIntAsync($"SELECT COUNT(1) FROM ({baseSql}) t", pars);
  108. var list = await _db.Ado.SqlQueryAsync<PurchaseReturnListRow>(
  109. $"SELECT * FROM ({baseSql}) t {orderBy} LIMIT {pageSize} OFFSET {offset}", pars);
  110. return new { total, page, pageSize, list };
  111. }
  112. [DisplayName("采购退货供应商下拉")]
  113. [HttpGet("purchase-return/options/suppliers")]
  114. public async Task<object> GetSuppliers()
  115. {
  116. var rows = await _db.Ado.SqlQueryAsync<PurchaseReturnKvItem>(
  117. """
  118. SELECT Supp AS `Value`,
  119. TRIM(CONCAT(TRIM(IFNULL(Supp,'')),' ',TRIM(IFNULL(SortName,'')))) AS `Label`
  120. FROM SuppMaster
  121. ORDER BY Supp
  122. """);
  123. return rows;
  124. }
  125. [DisplayName("收货单号下拉(rc)")]
  126. [HttpGet("purchase-return/options/rc-receivers")]
  127. public async Task<object> GetRcReceivers([FromQuery] string supp)
  128. {
  129. if (string.IsNullOrWhiteSpace(supp))
  130. return Array.Empty<object>();
  131. var rows = await _db.Ado.SqlQueryAsync<PurchaseReturnKvItem>(
  132. """
  133. SELECT p.Receiver AS `Value`,
  134. TRIM(CONCAT(TRIM(IFNULL(p.Receiver,'')),' ',
  135. TRIM(IFNULL(d.LotSerial,'')),' ',
  136. TRIM(IFNULL(d.ItemNum,'')),' ',
  137. TRIM(IFNULL(i.Descr,'')))) AS `Label`
  138. FROM PurOrdRctMaster p
  139. LEFT JOIN PurOrdRctDetail d
  140. ON p.RctType = d.RctType AND p.Receiver = d.Receiver
  141. LEFT JOIN ItemMaster i ON d.ItemNum = i.ItemNum
  142. WHERE p.RctType = 'rc' AND p.Supp = @Supp AND d.RecID > 0 AND IFNULL(p.TermsofTrade,'') <> ''
  143. GROUP BY p.Receiver, d.LotSerial, d.ItemNum, i.Descr, p.Domain
  144. ORDER BY p.Receiver DESC
  145. """,
  146. new SugarParameter("@Supp", supp.Trim()));
  147. return rows;
  148. }
  149. [DisplayName("按收货单加载明细模板")]
  150. [HttpGet("purchase-return/rc-detail-lines")]
  151. public async Task<object> GetRcDetailLines([FromQuery] string receiver)
  152. {
  153. if (string.IsNullOrWhiteSpace(receiver))
  154. throw Oops.Oh("请先选择收货单号");
  155. var rows = await _db.Ado.SqlQueryAsync<PurchaseReturnRcLineRow>(
  156. """
  157. SELECT
  158. p.Domain AS Domain,
  159. p.Department AS Department,
  160. p.Terms AS Terms,
  161. p.TermsofTrade AS TermsofTrade,
  162. d.ItemNum AS ItemNum,
  163. d.UM AS UM,
  164. d.OrdNbr AS OrdNbr,
  165. CAST(d.OrdLine AS SIGNED) AS OrdLine,
  166. d.QtyOrded AS QtyOrded,
  167. d.Supp AS Supp,
  168. d.LotSerial AS LotSerial,
  169. CASE WHEN UPPER(IFNULL(d.Potype,'')) = 'PW' THEN d.Supp ELSE d.Location END AS Location,
  170. d.QtyReceived AS QtyReceived,
  171. d.Potype AS Potype,
  172. d.Typed AS Typed,
  173. p.TaxClass AS TaxClass,
  174. IFNULL(p.TaxIn, 0) AS TaxIn,
  175. p.Curr AS Curr,
  176. DATE_FORMAT(CURDATE(), '%Y-%m-%d') AS RctDate,
  177. d.UMConversion AS UMConversion,
  178. d.POCost AS POCost,
  179. d.QtyReceived AS QtyReturn,
  180. d.Receiver AS RctNbr,
  181. CAST(d.Line AS SIGNED) AS RctLine,
  182. d.CustPO AS CustPO,
  183. d.BlanketLine AS BlanketLine,
  184. IFNULL(d.RctQty, 0) AS RctQty,
  185. CAST(d.Line AS SIGNED) AS Line
  186. FROM PurOrdRctMaster p
  187. LEFT JOIN PurOrdRctDetail d
  188. ON p.RctType = d.RctType AND p.Receiver = d.Receiver
  189. WHERE p.RctType = 'rc' AND p.Receiver = @Receiver AND d.RecID > 0
  190. ORDER BY d.Line
  191. """,
  192. new SugarParameter("@Receiver", receiver.Trim()));
  193. PurchaseReturnRcLineRow head = null;
  194. if (rows.Count > 0)
  195. head = rows[0];
  196. return new { head, lines = rows };
  197. }
  198. [DisplayName("部门下拉")]
  199. [HttpGet("purchase-return/options/departments")]
  200. public async Task<object> GetDepartments()
  201. {
  202. return await _db.Ado.SqlQueryAsync<PurchaseReturnKvItem>(
  203. """
  204. SELECT Department AS `Value`,
  205. TRIM(CONCAT(TRIM(IFNULL(Department,'')),' ',TRIM(IFNULL(Descr,'')))) AS `Label`
  206. FROM DepartmentMaster
  207. ORDER BY Department
  208. """);
  209. }
  210. [DisplayName("库位下拉")]
  211. [HttpGet("purchase-return/options/locations")]
  212. public async Task<object> GetLocations()
  213. {
  214. return await _db.Ado.SqlQueryAsync<PurchaseReturnKvItem>(
  215. """
  216. SELECT Location AS `Value`,
  217. TRIM(CONCAT(TRIM(IFNULL(Location,'')),' ',TRIM(IFNULL(Descr,'')))) AS `Label`
  218. FROM LocationMaster
  219. WHERE IFNULL(Typed,'') <> 'Supp'
  220. ORDER BY Location
  221. """);
  222. }
  223. [DisplayName("退货原因下拉")]
  224. [HttpGet("purchase-return/options/qc-reasons")]
  225. public async Task<object> GetQcReasons()
  226. {
  227. return await _db.Ado.SqlQueryAsync<PurchaseReturnKvItem>(
  228. """
  229. SELECT Val AS `Value`,
  230. CONCAT(IFNULL(Val,''),'_',IFNULL(Comments,'')) AS `Label`
  231. FROM GeneralizedCodeMaster
  232. WHERE FldName = 'SAPTransReason'
  233. AND IFNULL(Ufld1,'') <> ''
  234. AND LOCATE('122', IFNULL(Ufld1,'')) > 0
  235. ORDER BY Val
  236. """);
  237. }
  238. [DisplayName("物料选择分页")]
  239. [HttpGet("purchase-return/item-options")]
  240. public async Task<object> GetItems([FromQuery] KeywordPageInput input)
  241. {
  242. var page = input.Page <= 0 ? 1 : input.Page;
  243. var pageSize = input.PageSize <= 0 ? 20 : input.PageSize;
  244. var offset = (page - 1) * pageSize;
  245. var pars = new List<SugarParameter>();
  246. var where = "1=1";
  247. if (!string.IsNullOrWhiteSpace(input.Keyword))
  248. {
  249. where += " AND (ItemNum LIKE @Kw OR Descr LIKE @Kw OR Descr1 LIKE @Kw)";
  250. pars.Add(new SugarParameter("@Kw", $"%{input.Keyword.Trim()}%"));
  251. }
  252. var total = await _db.Ado.GetIntAsync($"SELECT COUNT(1) FROM ItemMaster WHERE {where}", pars);
  253. var list = await _db.Ado.SqlQueryAsync<PurchaseReturnKvItem>(
  254. $"""
  255. SELECT ItemNum AS `Value`,
  256. TRIM(CONCAT(IFNULL(Descr,''),' ',IFNULL(Descr1,''))) AS `Label`
  257. FROM ItemMaster
  258. WHERE {where}
  259. ORDER BY ItemNum
  260. LIMIT {pageSize} OFFSET {offset}
  261. """,
  262. pars);
  263. return new { total, page, pageSize, list };
  264. }
  265. [DisplayName("采购退货单详情")]
  266. [HttpGet("purchase-return/{id:int}")]
  267. public async Task<object> GetDetail(int id)
  268. {
  269. var master = await _masterRep.GetFirstAsync(m => m.RecID == id && m.RctType == "pt")
  270. ?? throw Oops.Oh("单据不存在");
  271. var m = await _db.Ado.SqlQueryAsync<PurchaseReturnMasterDto>(
  272. """
  273. SELECT
  274. m.RecID AS RecID,
  275. m.Domain AS Domain,
  276. m.Receiver AS Receiver,
  277. DATE_FORMAT(m.RctDate,'%Y-%m-%d') AS RctDate,
  278. m.Supp AS Supp,
  279. m.OrdNbr AS OrdNbr,
  280. m.Department AS Department,
  281. IFNULL(m.Terms,'') AS Terms,
  282. IFNULL(m.Curr,'') AS Curr,
  283. IFNULL(m.TaxClass,'') AS TaxClass,
  284. IFNULL(m.TaxIn, 0) AS TaxIn,
  285. IFNULL(m.TermsofTrade,'') AS TermsofTrade,
  286. IFNULL(m.Remark,'') AS Remark,
  287. IFNULL(m.IsPlan, 0) AS IsPlan
  288. FROM PurOrdRctMaster m
  289. WHERE m.RecID = @Id
  290. LIMIT 1
  291. """,
  292. new SugarParameter("@Id", id));
  293. var head = m.FirstOrDefault() ?? throw Oops.Oh("单据不存在");
  294. var detailRows = await _db.Queryable<PurOrdRctDetail>()
  295. .Where(d => d.PurOrdRctRecID == id && d.RctType == "pt" && d.IsActive)
  296. .OrderBy(d => d.Line)
  297. .ToListAsync();
  298. var details = detailRows.Select(ToDetailDto).ToList();
  299. return new { master = head, details };
  300. }
  301. private static PurchaseReturnDetailDto ToDetailDto(PurOrdRctDetail d)
  302. {
  303. return new PurchaseReturnDetailDto
  304. {
  305. RecID = d.RecID,
  306. Line = d.Line,
  307. ItemNum = d.ItemNum,
  308. OrdNbr = d.OrdNbr,
  309. OrdLine = d.OrdLine,
  310. QtyOrded = d.QtyOrded,
  311. QtyReceived = d.QtyReceived,
  312. RctQty = d.RctQty,
  313. LotSerial = d.LotSerial,
  314. UM = d.UM,
  315. Location = d.Location,
  316. QCDescr = d.QCDescr,
  317. Remark = d.Remark,
  318. RctDate = d.RctDate?.ToString("yyyy-MM-dd"),
  319. Typed = d.Typed,
  320. TaxIn = d.TaxIn,
  321. TaxClass = d.TaxClass,
  322. Curr = d.Curr,
  323. Potype = d.Potype,
  324. IsActive = d.IsActive,
  325. IsConfirm = d.IsConfirm,
  326. UMConversion = d.UMConversion,
  327. POCost = d.POCost,
  328. RctNbr = d.RctNbr,
  329. RctLine = d.RctLine,
  330. CustPO = d.CustPO,
  331. BlanketLine = d.BlanketLine,
  332. QtyReturn = d.QtyReturn,
  333. Supp = d.Supp,
  334. };
  335. }
  336. [DisplayName("保存采购退货单")]
  337. [HttpPost("purchase-return/save")]
  338. public async Task<object> Save([FromBody] PurchaseReturnSaveInput input)
  339. {
  340. if (input == null) throw Oops.Oh("参数无效");
  341. if (string.IsNullOrWhiteSpace(input.Supp)) throw Oops.Oh("请选择供应商");
  342. if (string.IsNullOrWhiteSpace(input.OrdNbr)) throw Oops.Oh("请选择收货单号");
  343. if (string.IsNullOrWhiteSpace(input.Department)) throw Oops.Oh("请选择部门");
  344. if (input.Details == null || input.Details.Count == 0) throw Oops.Oh("请维护退货明细");
  345. var now = DateTime.Now;
  346. var account = _userManager.Account ?? "system";
  347. var domain = string.IsNullOrWhiteSpace(input.Domain)
  348. ? await ResolveRcDomainAsync(input.OrdNbr.Trim())
  349. : input.Domain.Trim();
  350. if (string.IsNullOrWhiteSpace(domain))
  351. domain = "100";
  352. if (input.Id is null or 0)
  353. {
  354. try
  355. {
  356. _db.Ado.BeginTran();
  357. var receiver = await AllocReceiverAsync();
  358. var rctDate = ParseDate(input.RctDate) ?? now.Date;
  359. var master = new PurOrdRctMaster
  360. {
  361. Domain = domain,
  362. RctType = "pt",
  363. Receiver = receiver,
  364. RctDate = rctDate,
  365. OrdNbr = input.OrdNbr.Trim(),
  366. Supp = input.Supp.Trim(),
  367. Department = input.Department.Trim(),
  368. Remark = input.Remark?.Trim(),
  369. Terms = input.Terms?.Trim(),
  370. Curr = input.Curr?.Trim(),
  371. TaxClass = input.TaxClass?.Trim(),
  372. TaxIn = input.TaxIn,
  373. TermsofTrade = input.TermsofTrade?.Trim(),
  374. Typed = "C",
  375. IsActive = true,
  376. IsConfirm = false,
  377. IsPlan = true,
  378. CreateUser = account,
  379. CreateTime = now,
  380. UpdateUser = account,
  381. UpdateTime = now,
  382. };
  383. var newId = await _db.Insertable(master).ExecuteReturnIdentityAsync();
  384. master.RecID = Convert.ToInt32(newId);
  385. await SaveDetailsAsync(master.RecID, domain, receiver, "pt", input.Details, account, now);
  386. _db.Ado.CommitTran();
  387. return new { id = master.RecID, receiver, message = "新增成功" };
  388. }
  389. catch
  390. {
  391. _db.Ado.RollbackTran();
  392. throw;
  393. }
  394. }
  395. var existing = await _masterRep.GetFirstAsync(m => m.RecID == input.Id!.Value && m.RctType == "pt")
  396. ?? throw Oops.Oh("单据不存在");
  397. if (!existing.IsPlan)
  398. throw Oops.Oh("该单据不允许修改");
  399. existing.RctDate = ParseDate(input.RctDate) ?? existing.RctDate;
  400. existing.OrdNbr = input.OrdNbr.Trim();
  401. existing.Supp = input.Supp.Trim();
  402. existing.Department = input.Department.Trim();
  403. existing.Remark = input.Remark?.Trim();
  404. existing.Terms = input.Terms?.Trim();
  405. existing.Curr = input.Curr?.Trim();
  406. existing.TaxClass = input.TaxClass?.Trim();
  407. existing.TaxIn = input.TaxIn;
  408. existing.TermsofTrade = input.TermsofTrade?.Trim();
  409. existing.Domain = domain;
  410. existing.UpdateUser = account;
  411. existing.UpdateTime = now;
  412. await _masterRep.UpdateAsync(existing);
  413. await SaveDetailsAsync(existing.RecID, existing.Domain, existing.Receiver, "pt", input.Details, account, now);
  414. return new { id = existing.RecID, receiver = existing.Receiver, message = "保存成功" };
  415. }
  416. private async Task SaveDetailsAsync(
  417. int masterRecId,
  418. string domain,
  419. string receiver,
  420. string rctType,
  421. List<PurchaseReturnDetailInput> entries,
  422. string account,
  423. DateTime now)
  424. {
  425. var dbRows = await _detailRep.GetListAsync(d =>
  426. d.PurOrdRctRecID == masterRecId && d.RctType == rctType);
  427. var dbById = dbRows.ToDictionary(d => d.RecID);
  428. var inputIds = new HashSet<int>(entries.Where(e => e.RecID is > 0).Select(e => e.RecID!.Value));
  429. for (var i = 0; i < entries.Count; i++)
  430. {
  431. var e = entries[i];
  432. var lineNo = e.Line > 0 ? e.Line : (short)(i + 1);
  433. if (string.IsNullOrWhiteSpace(e.ItemNum))
  434. throw Oops.Oh($"第{i + 1}行:请填写物料");
  435. var loc = string.IsNullOrWhiteSpace(e.Location) ? "00" : e.Location.Trim();
  436. if (e.RecID is > 0 && dbById.TryGetValue(e.RecID.Value, out var row))
  437. {
  438. ApplyDetailInput(row, e, domain, receiver, masterRecId, account, now, lineNo, loc);
  439. row.UpdateUser = account;
  440. row.UpdateTime = now;
  441. await _detailRep.UpdateAsync(row);
  442. }
  443. else
  444. {
  445. var detailNew = new PurOrdRctDetail();
  446. ApplyDetailInput(detailNew, e, domain, receiver, masterRecId, account, now, lineNo, loc);
  447. detailNew.CreateUser = account;
  448. detailNew.CreateTime = now;
  449. detailNew.UpdateUser = account;
  450. detailNew.UpdateTime = now;
  451. await _detailRep.InsertAsync(detailNew);
  452. }
  453. }
  454. foreach (var del in dbRows.Where(d => !inputIds.Contains(d.RecID)))
  455. await _detailRep.DeleteAsync(d => d.RecID == del.RecID);
  456. }
  457. private static void ApplyDetailInput(
  458. PurOrdRctDetail row,
  459. PurchaseReturnDetailInput e,
  460. string domain,
  461. string receiver,
  462. int masterRecId,
  463. string account,
  464. DateTime now,
  465. short lineNo,
  466. string location)
  467. {
  468. row.Domain = domain;
  469. row.RctType = "pt";
  470. row.Receiver = receiver;
  471. row.PurOrdRctRecID = masterRecId;
  472. row.Line = lineNo;
  473. row.Dimension1 = "";
  474. row.Dimension2 = "";
  475. row.ItemNum = e.ItemNum?.Trim();
  476. row.OrdNbr = string.IsNullOrWhiteSpace(e.OrdNbr) ? "" : e.OrdNbr.Trim();
  477. row.OrdLine = (short)e.OrdLine;
  478. row.RctDate = ParseDate(e.RctDate);
  479. row.UM = e.UM;
  480. row.QtyOrded = e.QtyOrded;
  481. row.QtyReceived = e.QtyReceived;
  482. row.RctQty = e.RctQty;
  483. row.LotSerial = e.LotSerial;
  484. row.Location = location;
  485. row.QCDescr = e.QCDescr;
  486. row.Remark = e.Remark;
  487. row.Typed = string.IsNullOrWhiteSpace(e.Typed) ? "C" : e.Typed.Trim();
  488. row.TaxIn = e.TaxIn;
  489. row.TaxClass = e.TaxClass;
  490. row.Curr = e.Curr;
  491. row.Potype = string.IsNullOrWhiteSpace(e.Potype) ? "P" : e.Potype.Trim();
  492. row.IsActive = true;
  493. row.IsConfirm = e.IsConfirm;
  494. row.UMConversion = e.UMConversion;
  495. row.POCost = e.POCost;
  496. row.RctNbr = e.RctNbr;
  497. row.RctLine = (short)e.RctLine;
  498. row.CustPO = e.CustPO;
  499. row.BlanketLine = e.BlanketLine;
  500. row.QtyReturn = e.QtyReturn;
  501. row.Supp = e.Supp;
  502. }
  503. [DisplayName("删除采购退货单(软删除)")]
  504. [HttpPost("purchase-return/delete/{id:int}")]
  505. public async Task<object> SoftDelete(int id)
  506. {
  507. var m = await _masterRep.GetFirstAsync(x => x.RecID == id && x.RctType == "pt")
  508. ?? throw Oops.Oh("单据不存在");
  509. if (!m.IsPlan)
  510. throw Oops.Oh("该单据不允许删除");
  511. m.IsActive = false;
  512. m.UpdateUser = _userManager.Account ?? "system";
  513. m.UpdateTime = DateTime.Now;
  514. await _masterRep.UpdateAsync(m);
  515. await _db.Ado.ExecuteCommandAsync(
  516. "UPDATE PurOrdRctDetail SET IsActive=0, UpdateUser=@U, UpdateTime=@T WHERE PurOrdRctRecID=@Id AND RctType='pt'",
  517. new SugarParameter("@U", m.UpdateUser),
  518. new SugarParameter("@T", m.UpdateTime),
  519. new SugarParameter("@Id", id));
  520. return new { message = "已删除" };
  521. }
  522. private async Task<string> ResolveRcDomainAsync(string rcReceiver)
  523. {
  524. var d = await _db.Ado.GetStringAsync(
  525. "SELECT Domain FROM PurOrdRctMaster WHERE RctType='rc' AND Receiver=@R LIMIT 1",
  526. new SugarParameter("@R", rcReceiver));
  527. return d;
  528. }
  529. private Task<string> AllocReceiverAsync() =>
  530. PurOrdNumberGenerator.NextRctReceiverAsync(_db, "PT", "pt", DateTime.Today, PtReceiverSerialWidth);
  531. private static DateTime? ParseDate(string raw)
  532. {
  533. if (string.IsNullOrWhiteSpace(raw)) return null;
  534. return DateTime.TryParse(raw.Trim(), out var d) ? d.Date : null;
  535. }
  536. }