SupplierDeliveryManagementService.cs 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551
  1. using System.Text.Json;
  2. using Admin.NET.Plugin.AiDOP.Entity.DataPlatform;
  3. using Admin.NET.Plugin.AiDOP.ProcurementExecution.Dto;
  4. namespace Admin.NET.Plugin.AiDOP.ProcurementExecution;
  5. /// <summary>
  6. /// S4 供应商交货管理
  7. /// </summary>
  8. [ApiDescriptionSettings(Order = 320, Description = "S4供应商交货管理")]
  9. [Route("api/ProcurementExecution")]
  10. [AllowAnonymous]
  11. [NonUnify]
  12. public class SupplierDeliveryManagementService : IDynamicApiController, ITransient
  13. {
  14. private readonly ISqlSugarClient _db;
  15. private readonly UserManager _userManager;
  16. public SupplierDeliveryManagementService(ISqlSugarClient db, UserManager userManager)
  17. {
  18. _db = db;
  19. _userManager = userManager;
  20. }
  21. [DisplayName("供应商交货管理列表")]
  22. [HttpGet("supplier-delivery/list")]
  23. public async Task<object> GetList([FromQuery] SupplierDeliveryListInput input)
  24. {
  25. var tenantId = AidopTenantHelper.Resolve(App.HttpContext);
  26. var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
  27. var conditions = new List<string>();
  28. if (!string.IsNullOrWhiteSpace(input.Cgdd))
  29. {
  30. conditions.Add("v.cgdd LIKE @cgdd");
  31. pars.Add(new SugarParameter("@cgdd", $"%{input.Cgdd.Trim()}%"));
  32. }
  33. if (!string.IsNullOrWhiteSpace(input.DsNum))
  34. {
  35. conditions.Add("v.dsnum LIKE @dsnum");
  36. pars.Add(new SugarParameter("@dsnum", $"%{input.DsNum.Trim()}%"));
  37. }
  38. if (!string.IsNullOrWhiteSpace(input.Wlbm))
  39. {
  40. conditions.Add("v.wlbm LIKE @wlbm");
  41. pars.Add(new SugarParameter("@wlbm", $"%{input.Wlbm.Trim()}%"));
  42. }
  43. if (!string.IsNullOrWhiteSpace(input.Gys))
  44. {
  45. conditions.Add("(v.gysdm LIKE @gys OR v.gysmc LIKE @gys)");
  46. pars.Add(new SugarParameter("@gys", $"%{input.Gys.Trim()}%"));
  47. }
  48. var where = conditions.Count > 0 ? $" WHERE {string.Join(" AND ", conditions)} " : string.Empty;
  49. var orderBy = BuildOrderBy(input.SortField, input.SortOrder);
  50. var offset = (input.Page - 1) * input.PageSize;
  51. var wrapped = $"{BuildBaseSql()} {where}";
  52. var total = await _db.Ado.GetIntAsync($"SELECT COUNT(*) FROM ({wrapped}) t", pars);
  53. var list = await _db.Ado.SqlQueryAsync<SupplierDeliveryListRow>(
  54. $"SELECT * FROM ({wrapped}) t {orderBy} LIMIT {input.PageSize} OFFSET {offset}", pars);
  55. return new { total, page = input.Page, pageSize = input.PageSize, list };
  56. }
  57. [DisplayName("供应商交货管理发布")]
  58. [HttpPost("supplier-delivery/publish")]
  59. public async Task<object> Publish([FromBody] SupplierDeliveryBatchInput input)
  60. {
  61. var tenantId = AidopTenantHelper.Resolve(App.HttpContext);
  62. var userId = _userManager.UserId.ToString();
  63. var userName = _userManager.Account ?? "system";
  64. var sql = """
  65. INSERT INTO `scm_jhjh_jq`
  66. (
  67. `id`,
  68. `glid1`,
  69. `wlbm`, `wlms`, `wlgg`, `cgdd`,
  70. `jhdsl`, `wjhsl`, `jhd`, `yjjhrq`, `jqhf`,
  71. `type`, `flag`, `scrq`, `scrid`, `scrxm`,
  72. `gysdm`, `gysmc`,
  73. `hfrid`, `hfrxm`, `hfsj`,
  74. `qhdj`, `ddhh`, `dw`, `bzsl`, `ly`
  75. )
  76. SELECT
  77. UUID() AS id,
  78. ds.id AS glid1,
  79. ds.itemnum AS wlbm,
  80. im.Descr AS wlms,
  81. im.Descr1 AS wlgg,
  82. ds.ponumber AS cgdd,
  83. ds.schedqty AS jhdsl,
  84. a.wjhsl AS wjhsl,
  85. ds.dsnum AS jhd,
  86. a.yjjhrq AS yjjhrq,
  87. DATE_FORMAT(DATE(a.yjjhrq), '%Y-%m-%d') AS jqhf,
  88. a.`type` AS `type`,
  89. 2 AS flag,
  90. a.scrq AS scrq,
  91. a.scrid AS scrid,
  92. a.scrxm AS scrxm,
  93. a.gysdm AS gysdm,
  94. a.gysmc AS gysmc,
  95. @hfrid AS hfrid,
  96. @hfrxm AS hfrxm,
  97. DATE_FORMAT(NOW(), '%Y-%m-%d %H:%i:%s') AS hfsj,
  98. a.qhdj AS qhdj,
  99. a.ddhh AS ddhh,
  100. a.dw AS dw,
  101. a.bzsl AS bzsl,
  102. a.ly AS ly
  103. FROM srm_polist_ds ds
  104. LEFT JOIN ItemMaster im
  105. ON ds.itemnum = im.ItemNum
  106. LEFT JOIN vscm_jhjh a
  107. ON a.cgdd = ds.ponumber
  108. AND a.ddhh = ds.poline
  109. WHERE FIND_IN_SET(CAST(ds.id AS CHAR(50)), REPLACE(IFNULL(@ids, ''), ' ', '')) > 0
  110. AND ds.tenant_id = @TenantId
  111. AND NOT EXISTS (
  112. SELECT 1 FROM scm_jhjh_jq x
  113. WHERE x.glid1 = ds.id
  114. AND FIND_IN_SET(CAST(x.glid1 AS CHAR(50)), REPLACE(IFNULL(@ids, ''), ' ', '')) > 0
  115. );
  116. """;
  117. await _db.Ado.ExecuteCommandAsync(sql, new List<SugarParameter>
  118. {
  119. new("@ids", input.Ids),
  120. new("@hfrid", userId),
  121. new("@hfrxm", userName),
  122. new("@TenantId", tenantId)
  123. });
  124. return new { message = "发布成功" };
  125. }
  126. [DisplayName("供应商交货管理按计划日期回复")]
  127. [HttpPost("supplier-delivery/reply-by-plan-date")]
  128. public async Task<object> ReplyByPlanDate([FromBody] SupplierDeliveryBatchInput input)
  129. {
  130. if (string.IsNullOrWhiteSpace(input.Ids))
  131. throw Oops.Oh("缺少勾选行ID(ids)");
  132. var tenantId = AidopTenantHelper.Resolve(App.HttpContext);
  133. var userId = _userManager.UserId.ToString();
  134. var userName = _userManager.Account ?? "system";
  135. // 列表勾选 id 为 srm_polist_ds.id,须以交货计划表驱动(与发布一致),不能从 vscm_jhjh 驱动否则匹配不到行。
  136. var sql = """
  137. INSERT INTO `scm_jhjh_jq`
  138. (
  139. `id`, `glid`, `wlbm`, `wlms`, `wlgg`, `cgdd`, `jhdsl`, `wjhsl`,
  140. `jhd`, `yjjhrq`, `jqhf`, `type`, `flag`,
  141. `scrq`, `scrid`, `scrxm`,
  142. `gysdm`, `gysmc`,
  143. `hfrid`, `hfrxm`, `hfsj`,
  144. `qhdj`, `ddhh`, `dw`, `bzsl`, `ly`
  145. )
  146. SELECT
  147. UUID() AS id,
  148. ds.id AS glid,
  149. ds.itemnum AS wlbm,
  150. im.Descr AS wlms,
  151. im.Descr1 AS wlgg,
  152. ds.ponumber AS cgdd,
  153. CAST(ds.schedqty AS CHAR(50)) AS jhdsl,
  154. CAST(IFNULL(a.wjhsl, 0) AS CHAR(50)) AS wjhsl,
  155. ds.dsnum AS jhd,
  156. CAST(IFNULL(a.yjjhrq, ds.requestDate) AS CHAR(50)) AS yjjhrq,
  157. DATE_FORMAT(DATE(IFNULL(a.yjjhrq, ds.requestDate)), '%Y-%m-%d') AS jqhf,
  158. a.`type` AS `type`,
  159. 0 AS flag,
  160. a.scrq AS scrq,
  161. a.scrid AS scrid,
  162. a.scrxm AS scrxm,
  163. IFNULL(a.gysdm, ds.suppliercode) AS gysdm,
  164. IFNULL(a.gysmc, ds.supplier) AS gysmc,
  165. @userid AS hfrid,
  166. @username AS hfrxm,
  167. DATE_FORMAT(NOW(), '%Y-%m-%d %H:%i:%s') AS hfsj,
  168. a.qhdj AS qhdj,
  169. ds.poline AS ddhh,
  170. a.dw AS dw,
  171. a.bzsl AS bzsl,
  172. a.ly AS ly
  173. FROM srm_polist_ds ds
  174. LEFT JOIN ItemMaster im
  175. ON ds.itemnum = im.ItemNum
  176. LEFT JOIN vscm_jhjh a
  177. ON a.cgdd = ds.ponumber
  178. AND a.ddhh = ds.poline
  179. WHERE FIND_IN_SET(CAST(ds.id AS CHAR(50)), REPLACE(IFNULL(@ids, ''), ' ', '')) > 0
  180. AND ds.isactive = 1
  181. AND ds.status = 'P'
  182. AND ds.tenant_id = @TenantId;
  183. """;
  184. var affected = await _db.Ado.ExecuteCommandAsync(sql, new List<SugarParameter>
  185. {
  186. new("@ids", input.Ids),
  187. new("@userid", userId),
  188. new("@username", userName),
  189. new("@TenantId", tenantId),
  190. });
  191. if (affected <= 0)
  192. throw Oops.Oh("未插入任何回复记录。请确认勾选的是本列表中的交货计划行,且交货单 status=P、isactive=1。");
  193. return new { message = "按计划日期回复成功" };
  194. }
  195. [DisplayName("供应商交货管理回复交期")]
  196. [HttpPost("supplier-delivery/reply-due-date")]
  197. public async Task<object> ReplyDueDate([FromBody] SupplierDeliveryReplyDueDateInput input)
  198. {
  199. if (string.IsNullOrWhiteSpace(input.Ids))
  200. throw Oops.Oh("缺少勾选行ID(ids)");
  201. if (string.IsNullOrWhiteSpace(input.Jqhf))
  202. throw Oops.Oh("缺少交期回复日期(jqhf)");
  203. var tenantId = AidopTenantHelper.Resolve(App.HttpContext);
  204. var userId = _userManager.UserId.ToString();
  205. var userName = _userManager.Account ?? "system";
  206. // 列表勾选 id 为 srm_polist_ds.id,须以交货计划表驱动(与发布一致)。
  207. var sql = """
  208. INSERT INTO `scm_jhjh_jq`
  209. (
  210. `id`,
  211. `glid`, `wlbm`, `wlms`, `wlgg`, `cgdd`,
  212. `jhdsl`, `wjhsl`, `jhd`, `yjjhrq`, `jqhf`,
  213. `type`, `flag`,
  214. `scrq`, `scrid`, `scrxm`,
  215. `gysdm`, `gysmc`,
  216. `hfrid`, `hfrxm`, `hfsj`,
  217. `qhdj`, `ddhh`, `dw`, `bzsl`, `ly`
  218. )
  219. SELECT
  220. UUID() AS id,
  221. ds.id AS glid,
  222. ds.itemnum AS wlbm,
  223. im.Descr AS wlms,
  224. im.Descr1 AS wlgg,
  225. ds.ponumber AS cgdd,
  226. CAST(ds.schedqty AS CHAR(50)) AS jhdsl,
  227. CAST(IFNULL(a.wjhsl, 0) AS CHAR(50)) AS wjhsl,
  228. ds.dsnum AS jhd,
  229. CAST(IFNULL(a.yjjhrq, ds.requestDate) AS CHAR(50)) AS yjjhrq,
  230. @jqhf AS jqhf,
  231. a.`type` AS `type`,
  232. 0 AS flag,
  233. a.scrq AS scrq,
  234. a.scrid AS scrid,
  235. a.scrxm AS scrxm,
  236. IFNULL(a.gysdm, ds.suppliercode) AS gysdm,
  237. IFNULL(a.gysmc, ds.supplier) AS gysmc,
  238. @userid AS hfrid,
  239. @username AS hfrxm,
  240. DATE_FORMAT(NOW(), '%Y-%m-%d %H:%i:%s') AS hfsj,
  241. a.qhdj AS qhdj,
  242. ds.poline AS ddhh,
  243. a.dw AS dw,
  244. a.bzsl AS bzsl,
  245. a.ly AS ly
  246. FROM srm_polist_ds ds
  247. LEFT JOIN ItemMaster im
  248. ON ds.itemnum = im.ItemNum
  249. LEFT JOIN vscm_jhjh a
  250. ON a.cgdd = ds.ponumber
  251. AND a.ddhh = ds.poline
  252. WHERE FIND_IN_SET(CAST(ds.id AS CHAR(50)), REPLACE(IFNULL(@ids, ''), ' ', '')) > 0
  253. AND ds.isactive = 1
  254. AND ds.status = 'P'
  255. AND ds.tenant_id = @TenantId;
  256. """;
  257. var affected = await _db.Ado.ExecuteCommandAsync(sql, new List<SugarParameter>
  258. {
  259. new("@ids", input.Ids),
  260. new("@jqhf", input.Jqhf.Trim()),
  261. new("@userid", userId),
  262. new("@username", userName),
  263. new("@TenantId", tenantId),
  264. });
  265. if (affected <= 0)
  266. throw Oops.Oh("未插入任何回复记录。请确认勾选的是本列表中的交货计划行,且交货单 status=P、isactive=1。");
  267. return new { message = "回复交期成功" };
  268. }
  269. [DisplayName("交货单关闭")]
  270. [HttpPost("supplier-delivery/close")]
  271. public async Task<object> CloseDelivery([FromBody] DeliveryCloseInput input)
  272. {
  273. var tenantId = AidopTenantHelper.Resolve(App.HttpContext);
  274. // 检查是否已有关联的发货单明细(scm_shdzb.jhdbh = 交货单号)
  275. var shipmentCount = await _db.Ado.GetIntAsync(
  276. """
  277. SELECT COUNT(*)
  278. FROM scm_shdzb d
  279. INNER JOIN scm_shd m ON CAST(m.id AS CHAR) = d.glid
  280. WHERE d.jhdbh = @jhdbh
  281. AND m.tenant_id = @TenantId
  282. AND IFNULL(m.state, 1) <> 0
  283. """,
  284. new List<SugarParameter> { new("@jhdbh", input.DsNum), new("@TenantId", tenantId) });
  285. if (shipmentCount > 0)
  286. throw Oops.Oh("此发货单还未收完货,无法关闭交货单");
  287. await _db.Ado.ExecuteCommandAsync(
  288. "UPDATE srm_polist_ds SET status='C' WHERE DSNum=@jhdbh AND tenant_id=@TenantId",
  289. new List<SugarParameter> { new("@jhdbh", input.DsNum), new("@TenantId", tenantId) });
  290. await TryEnqueueReceiptConfirmOutboxAsync(tenantId, input.DsNum);
  291. return new { message = "交货单关闭成功" };
  292. }
  293. /// <summary>交货关闭视为收货确认信号,写 Outbox(幂等)。</summary>
  294. private async Task TryEnqueueReceiptConfirmOutboxAsync(long tenantId, string dsNum)
  295. {
  296. try
  297. {
  298. if (string.IsNullOrWhiteSpace(dsNum)) return;
  299. var payload = JsonSerializer.Serialize(new
  300. {
  301. path = "/erp/receipt/confirm",
  302. method = "POST",
  303. body = new
  304. {
  305. dsNum,
  306. status = "C",
  307. action = "S4_RECEIPT_CONFIRM"
  308. }
  309. });
  310. var exists = await _db.Ado.GetIntAsync(
  311. "SELECT COUNT(1) FROM mdp_outbox WHERE tenant_id=@tid AND target_source_code='WMS_API' AND action_code='S4_RECEIPT_CONFIRM' AND idem_key=@idem",
  312. new List<SugarParameter> { new("@tid", tenantId), new("@idem", dsNum) }) > 0;
  313. if (exists) return;
  314. await _db.Insertable(new MdpOutbox
  315. {
  316. TenantId = tenantId,
  317. TargetSourceCode = "WMS_API",
  318. ActionCode = "S4_RECEIPT_CONFIRM",
  319. IdemKey = dsNum,
  320. PayloadJson = payload,
  321. Status = 0,
  322. RetryCount = 0,
  323. CreateTime = DateTime.Now,
  324. UpdateTime = DateTime.Now
  325. }).ExecuteCommandAsync();
  326. }
  327. catch { /* Outbox 失败不影响关闭 */ }
  328. }
  329. private static string BuildOrderBy(string? sortField, string? sortOrder)
  330. {
  331. var map = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase)
  332. {
  333. ["sffb"] = "t.sffb",
  334. ["wlbm"] = "t.wlbm",
  335. ["wlms"] = "t.wlms",
  336. ["buyer"] = "t.buyer",
  337. ["gysdm"] = "t.gysdm",
  338. ["gysmc"] = "t.gysmc",
  339. ["cgdd"] = "t.cgdd",
  340. ["ddhh"] = "t.ddhh",
  341. ["jhdsl"] = "t.jhdsl",
  342. ["dfhsl"] = "t.dfhsl",
  343. ["dsnum"] = "t.dsnum",
  344. ["requestdate"] = "t.requestdate",
  345. ["schedqty"] = "t.schedqty",
  346. ["jqhfnew"] = "t.jqhfnew",
  347. ["ztsl"] = "t.ztsl",
  348. ["zsl1"] = "t.zsl1",
  349. ["rksl"] = "t.rksl",
  350. ["bhgsl"] = "t.bhgsl",
  351. ["thsl"] = "t.thsl",
  352. ["bz"] = "t.bz"
  353. };
  354. var field = map.TryGetValue(sortField ?? string.Empty, out var sqlField) ? sqlField : "t.requestdate";
  355. var order = string.Equals(sortOrder, "asc", StringComparison.OrdinalIgnoreCase) ? "ASC" : "DESC";
  356. return $" ORDER BY {field} {order} ";
  357. }
  358. private static string BuildBaseSql() => """
  359. SELECT
  360. v.*,
  361. CASE
  362. WHEN v.jhdsl - IFNULL(v.zfhl, 0) + IFNULL(v.thsl, 0) > v.wjhsl THEN v.wjhsl
  363. ELSE v.jhdsl - IFNULL(v.zfhl, 0) + IFNULL(v.thsl, 0)
  364. END AS dfhsl,
  365. CASE
  366. WHEN IFNULL(v.zsl18, 0) - IFNULL(v.thsl, 0) <= IFNULL(v.zshl, 0) THEN 0
  367. ELSE IFNULL(v.zsl18, 0) - IFNULL(v.thsl, 0) - IFNULL(v.zshl, 0)
  368. END AS ztsl,
  369. IFNULL(v.zsl, 0) AS zsl1,
  370. v.thsl AS bhgsl,
  371. CONCAT(
  372. CASE
  373. WHEN v.sfyqnew = 'wait' OR v.sfyqnew = 'NO' THEN 'jqhfnew:yellow'
  374. WHEN v.sfyqnew = 'refuse' THEN 'jqhfnew:red'
  375. WHEN v.sfyqnew = 'OK' THEN 'jqhfnew:#99FF00'
  376. ELSE ''
  377. END,
  378. v.sffbgrdnew
  379. ) AS background,
  380. CASE
  381. WHEN v.jhdsl - IFNULL(v.zfhl, 0) + IFNULL(v.thsl, 0) <= 0 THEN '完成'
  382. ELSE '待交'
  383. END AS yjzt
  384. FROM
  385. (
  386. SELECT
  387. p.PurOrd,
  388. p.Line,
  389. p.ItemNum,
  390. s.fhsl - IFNULL(dor.thsl, 0) AS zfhl,
  391. p.ReceiptQty + p.RctQty AS zshl,
  392. i.zjsl AS zsl,
  393. CASE WHEN p.PurOrd LIKE 'DO%' THEN p.RctQty ELSE p.RctQty - IFNULL(i.zjsl, 0) END AS rksl,
  394. CASE
  395. WHEN p.PurOrd LIKE 'DO%' THEN IF(p.QtyReturned > 0, p.QtyReturned, dor.thsl)
  396. ELSE IF(p.QtyReturned > 0, p.QtyReturned, p.QtyReturned + dor.thsl)
  397. END AS thsl,
  398. s.fhsl AS zsl18,
  399. sh.jhdyj,
  400. jy.jhdzj,
  401. IFNULL(ds.SchedQty, 0) - IFNULL(sh.jhdyj, 0) AS jhddj,
  402. p.QtyOrded - p.RctQty - p.ReceiptQty + p.QtyReturned AS wjhsl,
  403. p.QtyOrded AS jhdsl,
  404. ds.SchedQty,
  405. ds.DSNum,
  406. CASE WHEN b2.id IS NULL THEN 'X' ELSE b2.hfsj END AS sffb,
  407. p.ItemNum AS wlbm,
  408. im.Descr AS wlms,
  409. ds.supplier AS gysmc,
  410. p.PurOrd AS cgdd,
  411. p.Line AS ddhh,
  412. pm.Buyer AS buyer,
  413. IFNULL(ds.requestDate, p.DueDate) AS requestdate,
  414. IFNULL(b.jqhf, '') AS jqhfnew,
  415. IFNULL(b.fpjh, '') AS fpjhnew,
  416. ds.SentQty,
  417. IFNULL(im.Drawing, p.Drawing) AS th,
  418. IFNULL(im.Rev, p.Rev) AS bbh,
  419. CAST(ds.id AS CHAR) AS id,
  420. '' AS jhd,
  421. ds.suppliercode AS gysdm,
  422. CASE WHEN IFNULL(ds.id, '') = '' THEN p.Remarks ELSE ds.Remarks END AS bz,
  423. '' AS shd,
  424. ds.id AS jhdid,
  425. p.DueDate AS jhrq,
  426. p.RecID AS polid,
  427. im.Descr1 AS wlgg,
  428. CASE WHEN b2.id IS NULL THEN '' ELSE ';sffb:#99FF00' END AS sffbgrdnew,
  429. CASE
  430. WHEN IFNULL(b.jqhf, '') = '' THEN 'wait'
  431. WHEN TIMESTAMPDIFF(DAY, IFNULL(ds.requestDate, p.DueDate), b.jqhf) <= 2 THEN 'OK'
  432. WHEN TIMESTAMPDIFF(DAY, IFNULL(ds.requestDate, p.DueDate), b.jqhf) > 2 THEN 'NO'
  433. WHEN b.jqhf = '' AND IFNULL(b.qhdj, '') <> '' THEN 'refuse'
  434. ELSE 'wait'
  435. END AS sfyqnew
  436. FROM PurOrdDetail p
  437. LEFT JOIN PurOrdMaster pm ON p.PurOrd = pm.PurOrd AND pm.tenant_id = p.tenant_id
  438. LEFT JOIN (
  439. SELECT SUM(sh_delivery_quantity) AS fhsl, po_bill, po_billline, tenant_id
  440. FROM scm_shdzb
  441. WHERE tenant_id = @TenantId
  442. GROUP BY po_bill, po_billline, tenant_id
  443. ) s ON s.po_bill = p.PurOrd AND s.po_billline = p.Line
  444. LEFT JOIN (
  445. SELECT SUM(Qty) AS zjsl, PurOrd, PurLine, tenant_id
  446. FROM MissedPrint
  447. WHERE Status = 'I' AND tenant_id = @TenantId
  448. GROUP BY PurOrd, PurLine, tenant_id
  449. ) i ON i.PurOrd = p.PurOrd AND i.PurLine = p.Line
  450. LEFT JOIN (
  451. SELECT SUM(QtyReturn) AS thsl, OrdNbr, OrdLine, tenant_id
  452. FROM PurOrdRctDetail
  453. WHERE rcttype IN ('pt', 'temp') AND tenant_id = @TenantId
  454. GROUP BY OrdNbr, OrdLine, tenant_id
  455. ) dor ON dor.OrdNbr = p.PurOrd AND dor.OrdLine = p.Line
  456. LEFT JOIN srm_polist_ds ds ON p.PurOrd = ds.ponumber AND p.Line = ds.poline AND ds.tenant_id = p.tenant_id
  457. LEFT JOIN (
  458. SELECT SUM(sh_delivery_quantity) AS jhdyj, jhdbh, tenant_id
  459. FROM scm_shdzb
  460. WHERE tenant_id = @TenantId
  461. GROUP BY jhdbh, tenant_id
  462. ) sh ON ds.dsnum = sh.jhdbh
  463. LEFT JOIN (
  464. SELECT SUM(IFNULL(Qty, 0)) AS jhdzj, PurOrdDetBatchNbr, tenant_id
  465. FROM MissedPrint
  466. WHERE Status = 'I' AND tenant_id = @TenantId
  467. GROUP BY PurOrdDetBatchNbr, tenant_id
  468. ) jy ON ds.dsnum = jy.PurOrdDetBatchNbr
  469. LEFT JOIN (
  470. SELECT glid1, MIN(id) AS id, MIN(DATE_FORMAT(hfsj, '%Y.%m.%d')) AS hfsj
  471. FROM scm_jhjh_jq
  472. WHERE flag = 2
  473. GROUP BY glid1
  474. ) b2 ON ds.id = b2.glid1
  475. LEFT JOIN ItemMaster im ON p.ItemNum = im.ItemNum AND (im.tenant_id = p.tenant_id OR p.tenant_id IS NULL)
  476. LEFT JOIN (
  477. SELECT
  478. glid,
  479. GROUP_CONCAT(CONCAT(CAST(jhdsl AS CHAR(10)), '(', DATE_FORMAT(jqhf, '%Y-%m-%d'), ')') SEPARATOR '<br>') AS fpjh,
  480. GROUP_CONCAT(qhdj SEPARATOR '') AS qhdj,
  481. MAX(jqhf) AS jqhf
  482. FROM scm_jhjh_jq
  483. WHERE flag = 0
  484. GROUP BY glid
  485. ) b ON ds.id = b.glid
  486. WHERE p.Status <> 'C'
  487. AND ds.schedqty >= 0
  488. AND ds.isactive = 1
  489. AND ds.status = 'P'
  490. AND p.tenant_id = @TenantId
  491. ) v
  492. """;
  493. private sealed class SupplierDeliveryListRow
  494. {
  495. public string? Sffb { get; set; }
  496. public string? Wlbm { get; set; }
  497. public string? Wlms { get; set; }
  498. public string? Buyer { get; set; }
  499. public string? Gysdm { get; set; }
  500. public string? Gysmc { get; set; }
  501. public string? Cgdd { get; set; }
  502. public int? Ddhh { get; set; }
  503. public decimal? Jhdsl { get; set; }
  504. public decimal? Dfhsl { get; set; }
  505. public string? Dsnum { get; set; }
  506. public DateTime? Requestdate { get; set; }
  507. public decimal? Schedqty { get; set; }
  508. public string? Jqhfnew { get; set; }
  509. public decimal? Ztsl { get; set; }
  510. public decimal? Zsl1 { get; set; }
  511. public decimal? Rksl { get; set; }
  512. public decimal? Bhgsl { get; set; }
  513. public decimal? Thsl { get; set; }
  514. public string? Bz { get; set; }
  515. public string? Id { get; set; }
  516. public decimal? Wjhsl { get; set; }
  517. public decimal? Zfhl { get; set; }
  518. }
  519. }