From 789c519cbea5de0b3dc027edb6dd51781f647df0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=98=8E?= <125556714+Topfunplus@users.noreply.github.com> Date: Thu, 29 May 2025 16:47:44 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9E=E7=8E=B0=E6=89=B9=E9=87=8F=E8=BD=AC?= =?UTF-8?q?=E6=8D=A2=E8=AF=B7=E8=B4=AD=E5=8D=95=E5=88=B0=E9=87=87=E8=B4=AD?= =?UTF-8?q?=E8=AE=A2=E5=8D=95=E5=8A=9F=E8=83=BD-=20=E6=96=B0=E5=A2=9E=20Ba?= =?UTF-8?q?tchTransferToPurchaseOrder=20=E7=B1=BB=E5=AE=9E=E7=8E=B0=20IBac?= =?UTF-8?q?kgroundWorkPlugin=20=E6=8E=A5=E5=8F=A3=20-=20=E5=AE=8C=E6=88=90?= =?UTF-8?q?=E8=AF=B7=E8=B4=AD=E5=8D=95=E6=9F=A5=E8=AF=A2=E3=80=81=E8=81=9A?= =?UTF-8?q?=E5=90=88=20VO=20=E7=BB=84=E8=A3=85=E3=80=81=E6=89=B9=E9=87=8F?= =?UTF-8?q?=E8=BD=AC=E6=8D=A2=E5=92=8C=E4=BF=9D=E5=AD=98=E9=87=87=E8=B4=AD?= =?UTF-8?q?=E8=AE=A2=E5=8D=95=E7=AD=89=E5=8A=9F=E8=83=BD=20-=20=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0=E6=97=A5=E5=BF=97=E8=AE=B0=E5=BD=95=E5=92=8C=E5=BC=82?= =?UTF-8?q?=E5=B8=B8=E5=A4=84=E7=90=86=EF=BC=8C=E7=A1=AE=E4=BF=9D=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E6=89=A7=E8=A1=8C=E7=9A=84=E7=A8=B3=E5=AE=9A=E6=80=A7?= =?UTF-8?q?=E5=92=8C=E5=8F=AF=E8=BF=BD=E8=B8=AA=E6=80=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../plugin/BatchTransferToPurchaseOrder.java | 213 ++++++++++++++++++ 1 file changed, 213 insertions(+) create mode 100644 pu/src/private/nc/bs/pu/m21/plugin/BatchTransferToPurchaseOrder.java diff --git a/pu/src/private/nc/bs/pu/m21/plugin/BatchTransferToPurchaseOrder.java b/pu/src/private/nc/bs/pu/m21/plugin/BatchTransferToPurchaseOrder.java new file mode 100644 index 0000000..4d80136 --- /dev/null +++ b/pu/src/private/nc/bs/pu/m21/plugin/BatchTransferToPurchaseOrder.java @@ -0,0 +1,213 @@ +package nc.bs.pu.m21.plugin; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; + +import nc.bs.logging.Log; +import nc.bs.pub.common.PfServiceScmUtil; +import nc.bs.pub.pa.PreAlertObject; +import nc.bs.pub.pa.PreAlertReturnType; +import nc.bs.pub.taskcenter.BgWorkingContext; +import nc.bs.pub.taskcenter.IBackgroundWorkPlugin; +import nc.bs.pubapp.AppBsContext; +import nc.impl.pubapp.pattern.data.vo.VOQuery; +import nc.impl.pubapp.pattern.page.db.IDDBPage; +import nc.util.mmf.framework.base.MMArrayUtil; +import nc.util.mmf.framework.db.MMSqlBuilder; +import nc.vo.pu.m20.entity.PraybillHeaderVO; +import nc.vo.pu.m20.entity.PraybillItemVO; +import nc.vo.pu.m20.entity.PraybillVO; +import nc.vo.pu.m21.entity.OrderItemVO; +import nc.vo.pu.m21.entity.OrderVO; +import nc.vo.pub.BusinessException; +import nc.vo.pubapp.pattern.exception.ExceptionUtils; + +public class BatchTransferToPurchaseOrder implements IBackgroundWorkPlugin { + private static final Log logger = Log.getInstance("devpoordertask"); + + @Override + public PreAlertObject executeTask(BgWorkingContext bgWorkingContext) throws BusinessException { + logger.info("开始执行批量转换请购单到采购订单任务", this.getClass(), "executeTask"); + PreAlertObject retObj = new PreAlertObject(); + retObj.setReturnType(PreAlertReturnType.RETURNNOTHING); + try { + // 1. 查询满足条件的请购单聚合VO + PraybillVO[] purchaseRequestVOs = getQualifiedPurchaseRequests(bgWorkingContext); + logger.info("查询到满足条件的请购单数量: " + purchaseRequestVOs.length, this.getClass(), "executeTask"); + if (purchaseRequestVOs.length > 0) { + // 2. 批量转换处理 + processBatchTransfer(purchaseRequestVOs, bgWorkingContext); + logger.info("批量转换请购单到采购订单完成", this.getClass(), "executeTask"); + } else { + logger.info("未找到满足条件的请购单，任务结束", this.getClass(), "executeTask"); + } + } catch (Exception e) { + logger.error("执行批量转换请购单到采购订单任务失败", e, this.getClass(), "executeTask"); + ExceptionUtils.marsh(e); + } + logger.info("批量转换请购单到采购订单任务执行完成", this.getClass(), "executeTask"); + return retObj; + } + + /** + * 查询满足条件的请购单 + * 条件：表体请购单主数量-累计订货主数量>0，且没有行关闭 + */ + private PraybillVO[] getQualifiedPurchaseRequests(BgWorkingContext bgWorkingContext) throws BusinessException { + logger.info("开始查询满足条件的请购单", this.getClass(), "getQualifiedPurchaseRequests"); + try { + String sql = getSql(bgWorkingContext); + if (sql == null) { + logger.warn("生成的SQL为空，返回空结果", this.getClass(), "getQualifiedPurchaseRequests"); + return new PraybillVO[0]; + } + List resultList = new ArrayList<>(); + int pageSize = 2048; + IDDBPage page = new IDDBPage(sql, pageSize); + logger.info("开始分页查询，页大小: " + pageSize, this.getClass(), "getQualifiedPurchaseRequests"); + int pageCount = 0; + while (page.hasNext()) { + pageCount++; + String[] ids = page.next(); + PraybillVO[] aggvos = getBGWorkInfo(ids); + if (MMArrayUtil.isNotEmpty(aggvos)) { + resultList.addAll(Arrays.asList(aggvos)); + logger.debug("第" + pageCount + "页处理得到聚合VO数量: " + aggvos.length, this.getClass(), "getQualifiedPurchaseRequests"); + } + } + logger.info("分页查询完成，总页数: " + pageCount + ", 最终结果数量: " + resultList.size(), this.getClass(), "getQualifiedPurchaseRequests"); + return resultList.toArray(new PraybillVO[resultList.size()]); + } catch (Exception e) { + logger.error("查询满足条件的请购单失败", e, this.getClass(), "getQualifiedPurchaseRequests"); + // marsh 抛出异常 + ExceptionUtils.marsh(e); + return new PraybillVO[0]; + } + } + + /** + * 构建查询SQL 查询视图 + */ + private String getSql(BgWorkingContext bgwc) { + logger.debug("开始构建查询SQL", this.getClass(), "getSql"); + String[] pkorgs = bgwc.getPk_orgs(); + String pkGroup = AppBsContext.getInstance().getPkGroup(); + MMSqlBuilder sb = new MMSqlBuilder(); + sb.append(" SELECT PK_PRAYBILL_B"); + sb.append(" FROM TRANS_PRAYBILL_PURCHASE"); + if (pkGroup != null) { + sb.append(" WHERE PK_GROUP ", pkGroup); + } + if (MMArrayUtil.isNotEmpty(pkorgs)) { + sb.append(" AND"); + sb.append(" PK_ORG", pkorgs); + } + String finalSql = sb.toString(); + logger.debug("SQL构建完成", this.getClass(), "getSql"); + return finalSql; + } + + /** + * 根据ID获取请购单聚合VO + */ + private PraybillVO[] getBGWorkInfo(String[] ids) { + if (logger.isDebugEnabled()) { + logger.debug("开始根据ID获取请购单聚合VO，ID数量: " + ids.length, this.getClass(), "getBGWorkInfo"); + } + // 查询请购单表体 + VOQuery itemQuery = new VOQuery<>(PraybillItemVO.class); + PraybillItemVO[] itemVOs = itemQuery.query(ids); + if (MMArrayUtil.isEmpty(itemVOs)) { + logger.warn("根据ID未查询到请购单表体数据", this.getClass(), "getBGWorkInfo"); + return new PraybillVO[0]; + } + logger.debug("查询到请购单表体数量: " + itemVOs.length, this.getClass(), "getBGWorkInfo"); + // 获取表头ID + List headerIds = new ArrayList<>(); + for (PraybillItemVO itemVO : itemVOs) { + if (!headerIds.contains(itemVO.getPk_praybill())) { + headerIds.add(itemVO.getPk_praybill()); + } + } + logger.debug("需要查询的表头ID数量: " + headerIds.size(), this.getClass(), "getBGWorkInfo"); + // 查询请购单表头 + VOQuery headerQuery = new VOQuery<>(PraybillHeaderVO.class); + PraybillHeaderVO[] headerVOs = headerQuery.query(headerIds.toArray(new String[headerIds.size()])); + logger.debug("查询到请购单表头数量: " + (headerVOs != null ? headerVOs.length : 0), this.getClass(), "getBGWorkInfo"); + return this.getAggvofromHeaderAndItem(headerVOs, + itemVOs); + } + + /** + * 组装采购订单聚合VO + */ + private PraybillVO[] getAggvofromHeaderAndItem(PraybillHeaderVO[] headerVOs, PraybillItemVO[] itemVOs) { + if (logger.isDebugEnabled()) { + logger.debug("开始组装聚合VO，表头数量: " + (headerVOs != null ? headerVOs.length : 0) + + ", 表体数量: " + (itemVOs != null ? itemVOs.length : 0), this.getClass(), "getAggvofromHeaderAndItem"); + } + + if (MMArrayUtil.isEmpty(headerVOs) || MMArrayUtil.isEmpty(itemVOs)) { + logger.warn("表头或表体数据为空，无法组装聚合VO", this.getClass(), "getAggvofromHeaderAndItem"); + return new PraybillVO[0]; + } + + List aggList = new ArrayList<>(); + + for (PraybillHeaderVO headerVO : headerVOs) { + List itemList = new ArrayList<>(); + + for (PraybillItemVO itemVO : itemVOs) { + if (headerVO.getPk_praybill().equals(itemVO.getPk_praybill())) { + itemList.add(itemVO); + } + } + + if (!itemList.isEmpty()) { + PraybillVO aggVO = new PraybillVO(); + aggVO.setParentVO(headerVO); + aggVO.setChildrenVO(itemList.toArray(new PraybillItemVO[itemList.size()])); + aggList.add(aggVO); + } + } + + logger.debug("聚合VO组装完成，数量: " + aggList.size(), this.getClass(), "getAggvofromHeaderAndItem"); + return aggList.toArray(new PraybillVO[aggList.size()]); + } + + /** + * 批量转换请购单到采购订单 + */ + private void processBatchTransfer(PraybillVO[] vos, BgWorkingContext bgWorkingContext) throws BusinessException { + logger.info("开始批量转换请购单到采购订单，请购单数量: " + vos.length, this.getClass(), "processBatchTransfer"); + + try { + // 调用单据转换规则生成采购订单（20->21） + logger.info("调用单据转换规则，从请购单(20)转换为采购订单(21)", this.getClass(), "processBatchTransfer"); + OrderVO[] orderVOs = PfServiceScmUtil.exeVOChangeByBillItfDef("20", "21", vos); + + if (orderVOs != null && orderVOs.length > 0) { + logger.info("单据转换成功，生成采购订单数量: " + orderVOs.length, this.getClass(), "processBatchTransfer"); + // 调用订单保存动作脚本 + logger.info("开始保存采购订单", this.getClass(), "processBatchTransfer"); + for (OrderVO orderVO : orderVOs) { + // 对采购订单赋值行号 + OrderItemVO[] bvo = orderVO.getBVO(); + for (int j = 0; j < bvo.length; j++) { + int rowNum = (j + 1) * 10; + bvo[j].setCrowno(String.valueOf(rowNum)); + } + } + PfServiceScmUtil.processBatch("SAVEBASE", "21", orderVOs, null, null); + logger.info("采购订单保存完成", this.getClass(), "processBatchTransfer"); + } else { + logger.warn("单据转换未生成任何采购订单", this.getClass(), "processBatchTransfer"); + } + + } catch (Exception e) { + logger.error("批量转换请购单到采购订单失败", e, this.getClass(), "processBatchTransfer"); + throw new BusinessException("批量转换请购单到采购订单失败: " + e.getMessage(), e); + } + } +}