From 0f2cd1c76da5c15a95d9e510c8e833f463658e44 Mon Sep 17 00:00:00 2001 From: mzr Date: Sun, 12 Oct 2025 22:20:52 +0800 Subject: [PATCH] =?UTF-8?q?lihao-=E7=AE=B1=E5=8F=98-=E6=B5=81=E7=A8=8B?= =?UTF-8?q?=E7=94=9F=E4=BA=A7=E8=AE=A2=E5=8D=95=E5=90=8C=E6=AD=A5=E5=90=AF?= =?UTF-8?q?=E6=BA=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../action/QCRptDataPushtoQmsAction.java | 265 ++++++++++++++++++ .../arrival/config/action/arrival_action.xml | 250 +++++++++++++++++ .../config/authorize/arrival_authorize.xml | 73 +++++ 3 files changed, 588 insertions(+) create mode 100644 pu/src/client/nccloud/web/pu/arrival/action/QCRptDataPushtoQmsAction.java create mode 100644 pu/src/client/yyconfig/modules/pu/arrival/config/action/arrival_action.xml create mode 100644 pu/src/client/yyconfig/modules/pu/arrival/config/authorize/arrival_authorize.xml diff --git a/pu/src/client/nccloud/web/pu/arrival/action/QCRptDataPushtoQmsAction.java b/pu/src/client/nccloud/web/pu/arrival/action/QCRptDataPushtoQmsAction.java new file mode 100644 index 00000000..41587652 --- /dev/null +++ b/pu/src/client/nccloud/web/pu/arrival/action/QCRptDataPushtoQmsAction.java @@ -0,0 +1,265 @@ +// +// Source code recreated from a .class file by IntelliJ IDEA +// (powered by FernFlower decompiler) +// + +package nccloud.web.pu.arrival.action; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.serializer.SerializerFeature; +import nc.bs.dao.BaseDAO; +import nc.bs.dao.DAOException; +import nc.bs.framework.common.NCLocator; +import nc.bs.logging.Log; +import nc.bs.trade.business.HYPubBO; +import nc.bs.uapbd.util.MyHelper; +import nc.bs.uapbd.util.ThirdPartyPostRequestUtil; +import nc.impl.pubapp.pattern.data.bill.BillQuery; +import nc.itf.bd.supplier.baseinfo.ISupplierBaseInfoQryService; +import nc.vo.am.common.util.StringUtils; +import nc.vo.bd.material.MaterialVO; +import nc.vo.bd.material.measdoc.MeasdocVO; +import nc.vo.bd.psn.PsndocVO; +import nc.vo.bd.supplier.SupplierVersionVO; +import nc.vo.org.OrgVO; +import nc.vo.pu.m23.entity.ArriveHeaderVO; +import nc.vo.pu.m23.entity.ArriveItemVO; +import nc.vo.pu.m23.entity.ArriveVO; +import nc.vo.pub.BusinessException; +import nc.vo.qc.c003.entity.ReportHeaderVO; +import nc.vo.qc.c003.entity.ReportItemVO; +import nc.vo.qc.c003.entity.ReportVO; +import nc.vo.sm.UserVO; +import nccloud.base.exception.ExceptionUtils; +import nccloud.baseapp.core.log.NCCForUAPLogger; +import nccloud.framework.core.json.IJson; +import nccloud.framework.web.action.itf.ICommonAction; +import nccloud.framework.web.container.IRequest; +import nccloud.framework.web.json.JsonFactory; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; + +public class QCRptDataPushtoQmsAction implements ICommonAction { + + private static final String LOG_INFO_NAME = "qyMesLog"; + private static final Log logger = Log.getInstance(LOG_INFO_NAME); + private static final String reqUrl = "/IF_QyErpApi.ashx?action=addsjd"; + private Map configParams; + public QCRptDataPushtoQmsAction() { + } + public Object doAction(IRequest request) { + String str = request.read(); + IJson json = JsonFactory.create(); + Map info = json.fromJson(str, Map.class); + configParams = MyHelper.getConfigParams("xb-config", null); + if (configParams.isEmpty()) { + try { + throw new BusinessException("箱变的QMS接口缺少配置"); + } catch (BusinessException e) { + throw new RuntimeException(e); + } + } + try { + String pks = (String) info.get("pks"); // 获取所有物料编码 + if (pks == null ) { + nccloud.framework.core.exception.ExceptionUtils.wrapBusinessException("采购到货单不能为空"); + } + String[] pk =new String[]{pks}; + // 上游到货单 + // 查询上游到货单数据 + BillQuery billquery = new BillQuery(ArriveVO.class); + ArriveVO[] arriveVOS = billquery.query(pk); + +// 过滤需要推送的ArriveVO(排除BVO中存在vbdef23为"Y"或"y"的记录) + List validArriveList = new ArrayList<>(); + for (ArriveVO arriveVO : arriveVOS) { + ArriveItemVO[] bvos = arriveVO.getBVO(); + boolean needSkip = false; // 标记是否需要跳过当前ArriveVO + + // 检查当前到货单的所有明细,只要有一个明细的vbdef23为Y/y,就跳过整个到货单 + if (bvos != null && bvos.length > 0) { + for (ArriveItemVO itemVO : bvos) { + // 获取vbdef23字段值,处理null情况 + String vbdef23 = (String) itemVO.getAttributeValue("vbdef23"); + if (vbdef23 != null && "Y".equalsIgnoreCase(vbdef23)) { + needSkip = true; + break; // 只要有一个明细符合,直接跳出明细循环 + } + } + } + + // 不需要跳过的,加入有效列表 + if (!needSkip) { + validArriveList.add(arriveVO); + } + } + buildSyncData(arriveVOS); + + } catch (BusinessException e) { + ExceptionUtils.wrapException(e); + } + + return "success"; + } + /** + * 构建同步数据 + * + * @param arriveVOS 到货单VO + */ + private void buildSyncData(ArriveVO[] arriveVOS) throws BusinessException { + List update =new ArrayList<>(); + for (ArriveVO arriveVO : arriveVOS) { + ArriveHeaderVO hvo = arriveVO.getHVO(); + ArriveItemVO[] bvo = arriveVO.getBVO(); + String pk_arriveorder = hvo.getPk_arriveorder(); + String pkOrg = hvo.getPk_org(); + // 判断物料的业务单元是否是箱变公司,不是则跳过 + String orgCode = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.CODE, OrgVO.PK_ORG, pkOrg); + if (checkIfOrg(orgCode, configParams)) { + continue; + } + // 查询供应商信息 + String pk_supplier_v = hvo.getPk_supplier_v(); + SupplierVersionVO supplierVersionVO = new SupplierVersionVO(); + if (pk_supplier_v != null && !pk_supplier_v.isEmpty() && !"~".equals(pk_supplier_v)) { + ISupplierBaseInfoQryService baseQryService = NCLocator.getInstance().lookup(ISupplierBaseInfoQryService.class); + supplierVersionVO = baseQryService.querySupplierVersionByVID(pk_supplier_v); + } + // 制单人名称 + String creatorName = MyHelper.getStrValByCondition("sm_user", UserVO.USER_NAME, + UserVO.CUSERID + " = '" + hvo.getBillmaker() + "'"); + JSONObject singleObj = new JSONObject(); + // 采购合同号 + String cghth = getCghthVal(hvo, bvo); + // 启源送检单主表 + long cts = System.currentTimeMillis(); + singleObj.put("batchid", cts); + singleObj.put("csdh", hvo.getVbillcode());// 送检单号,BIP到货单号 + singleObj.put("sjrq", hvo.getDmakedate().toString());// 送检日期,格式建议为 yyyy-MM-dd + singleObj.put("wlgysid", supplierVersionVO.getCode());// 供应商编码 + singleObj.put("wlgysmc", supplierVersionVO.getName());// 供应商名称 + singleObj.put("sjr", creatorName);// 送检人,BIP制单人 + singleObj.put("cghth", cghth);// 采购合同号,关联对应的采购合同 + singleObj.put("bz", hvo.getVmemo());// 摘要备注,用于填写送检单的补充说明信息 + // 查询关联的质检报告-传入启源送检单的明细 + HYPubBO hybo = new HYPubBO(); + ReportItemVO[] reportItemVOS = (ReportItemVO[]) hybo.queryByCondition(ReportItemVO.class, " cfirstid = '" + pk_arriveorder + "'"); + JSONArray contentArray = new JSONArray(); + for (ReportItemVO reportItemVO : reportItemVOS) { + String pkReportbill = reportItemVO.getPk_reportbill(); + ReportHeaderVO reportHeaderVO = (ReportHeaderVO) hybo.queryByPrimaryKey(ReportHeaderVO.class, pkReportbill); + String pkMaterial = reportHeaderVO.getPk_material(); + Map materialMap = MyHelper.getMapValByCondition(MaterialVO.getDefaultTableName(), "code,name,materialspec,materialtype", + "pk_material = '" + pkMaterial + "'"); + String cunitid = reportHeaderVO.getCunitid();// 主单位 + String cunitname = MyHelper.getStrValByCondition(MeasdocVO.getDefaultTableName(), MeasdocVO.NAME, + MeasdocVO.PK_MEASDOC + " = '" + cunitid + "'"); + JSONObject itemObj = new JSONObject(); + itemObj.put("wlbh", materialMap.getOrDefault("code", "")); // 物料编码 + itemObj.put("wlmc", materialMap.getOrDefault("name", "")); // 物料名称 + String materialtype = skipNull(materialMap.get("materialtype")); + String materialspec = skipNull(materialMap.get("materialspec")); + itemObj.put("wlxhgg", materialtype + materialspec); // 物料型号规格 + itemObj.put("sjsl", reportHeaderVO.getNapplynum().toString()); // 送检数量(设计单位),按设计计量单位统计的送检数量 + itemObj.put("jldw", cunitname); // 计量单位 + itemObj.put("bz", reportItemVO.getVbdef1()); // 明细备注,用于填写该送检物料的补充说明 + itemObj.put("bipzyid", pkReportbill); // 质检报告ID + itemObj.put("bipqdid", reportItemVO.getPk_reportbill_b()); // 质检报告明细ID + contentArray.add(itemObj); + } + singleObj.put("Content", contentArray); + pushData(singleObj); + update.add(hvo.getPk_arriveorder()); + updateArrveOrder(hvo.getPk_arriveorder()); + } + + } + + private void updateArrveOrder(String pkArriveorder) throws DAOException { + BaseDAO dao = new BaseDAO(); + String sql = "update po_arriveorder_b set vbdef23='Y' where pk_arriveorder='" + + pkArriveorder + "'"; + dao.executeUpdate(sql); + } + + private String getCghthVal(ArriveHeaderVO hvo, ArriveItemVO[] bvo) throws BusinessException { + String cghth = ""; + String pkPupsndoc = hvo.getPk_pupsndoc(); + // 查询采购员名称 + String name = ""; + if (pkPupsndoc != null && !pkPupsndoc.isEmpty() && !"~".equals(pkPupsndoc)) { + name = MyHelper.getStrValByCondition(PsndocVO.getDefaultTableName(), PsndocVO.NAME, + PsndocVO.PK_PSNDOC + " = '" + pkPupsndoc + "'"); + } + if (bvo != null && bvo.length > 0) { + StringBuilder cghthBuilder = new StringBuilder(); + for (int i = 0; i < bvo.length; i++) { + String vsourcecode = bvo[i].getVsourcecode(); + if (vsourcecode == null || vsourcecode.isEmpty() || "~".equals(vsourcecode)) { + continue; + } + if (i > 0) { + cghthBuilder.append(","); + } + cghthBuilder.append(vsourcecode); + if (!name.isEmpty()) { + cghthBuilder.append(name); + } + } + cghth = cghthBuilder.toString(); + } + return cghth; + } + + /** + * 推送同步数据 + */ + private void pushData(JSONObject param) throws BusinessException { + // String jsonString = param.toJSONString(); + // 转json字符串的时候保留null值 + String jsonStr = JSON.toJSONString(param, + SerializerFeature.WriteMapNullValue, + SerializerFeature.WriteNullStringAsEmpty + ); + logger.error("QMS-QC-param = " + jsonStr); + NCCForUAPLogger.debug("QMS-QC-param = " + jsonStr); + String baseUrl = configParams.get("qmsBaseUrl"); + String requestUrl = baseUrl + reqUrl; + logger.error("QMS-QC-url = " + requestUrl); + String result = ThirdPartyPostRequestUtil.sendPostRequest(requestUrl, jsonStr); + NCCForUAPLogger.debug("QMS-QC-result = " + result); + JSONObject resultObj = JSONObject.parseObject(result); + logger.error("QMS-QC-res = " + result); + + if (!"true".equals(resultObj.getString("success"))) { + logger.error("QMS-QC-error,result[" + resultObj.toJSONString() + "]"); + throw new BusinessException("QMS-QC-error:" + resultObj.getString("message")); + } + } + + private boolean checkIfOrg(String code, Map configParams) throws BusinessException { + String targetCode = configParams.get("xbOrg"); + if (targetCode == null || StringUtils.isEmpty(targetCode)) { + throw new BusinessException("未配置组织参数"); + } + String[] orgItem = targetCode.split(","); + for (String orgCode : orgItem) { + if (!orgCode.isEmpty() && orgCode.equals(code)) { + return false; + } + } + return true; + } + + public String skipNull(Object value) { + if ((value == null) || (value.toString().trim().length() == 0)) { + return ""; + } + return value.toString().trim(); + } + +} diff --git a/pu/src/client/yyconfig/modules/pu/arrival/config/action/arrival_action.xml b/pu/src/client/yyconfig/modules/pu/arrival/config/action/arrival_action.xml new file mode 100644 index 00000000..9731a0aa --- /dev/null +++ b/pu/src/client/yyconfig/modules/pu/arrival/config/action/arrival_action.xml @@ -0,0 +1,250 @@ + + + + pu.arrival.insert + + nccloud.web.pu.arrival.action.InsertAction + + + pu.arrival.update + + nccloud.web.pu.arrival.action.UpdateAction + + + pu.arrival.delete + + nccloud.web.pu.arrival.action.DeleteAction + Delete + + + pu.arrival.queryScheme + + nccloud.web.pu.arrival.action.QueryAction + + + pu.arrival.pageQuery + + nccloud.web.pu.arrival.action.PageQueryAction + + + pu.arrival.queryCard + + nccloud.web.pu.arrival.action.QueryCardAction + + + pu.arrival.saveSend + + nccloud.web.pu.arrival.action.SaveSendAction + + + pu.arrival.commit + + nccloud.web.pu.arrival.action.CommitAction + Commit + + + pu.arrival.uncommit + + nccloud.web.pu.arrival.action.UncommitAction + UnCommit + + + pu.arrival.approve + + nccloud.web.pu.arrival.action.ApproveAction + + + pu.arrival.unapprove + + nccloud.web.pu.arrival.action.UnapproveAction + + + pu.arrival.afterBodyEdit + + nccloud.web.pu.arrival.action.AfterBodyEditAction + + + + pu.arrival.afterFeeEdit + + nccloud.web.pu.arrival.action.AfterFeeEditAction + + + + pu.arrival.afterFeeDetailEdit + + nccloud.web.pu.arrival.action.AfterFeeDetailEditAction + + + + pu.arrival.afterBodyForFeeEdit + + nccloud.web.pu.arrival.action.AfterBodyFeeDetailEditAction + + + + pu.arrival.crtAssert + + nccloud.web.pu.arrival.action.CrtAssertCardAction + GenAssertCard + + + pu.arrival.delAssert + + nccloud.web.pu.arrival.action.DelAssertCardAction + DelAssertCard + + + pu.arrival.qualityCheck + + nccloud.web.pu.arrival.action.QCAction + Check + + + pu.arrival.transAssert + + nccloud.web.pu.arrival.action.TransAssertAction + GenTransAssert + + + pu.arrival.delTransAssert + + nccloud.web.pu.arrival.action.DelTransAssertAction + DelTransAssert + + + pu.arrival.fixRate + + nccloud.web.pu.arrival.action.FixChangeRateAction + + + pu.arrival.print + + nccloud.web.pu.arrival.action.ArrivePrintAction + Print,OutPrint,Print_list + + + pu.arrival.printPermiss + + nccloud.web.pu.arrival.action.ArrivePrintPermissionAction + + Print,Print_list + + + pu.arrival.edit + + nccloud.web.pu.arrival.action.EditAction + Edit + + + pu.arrival.afterEditHead + + nccloud.web.pu.arrival.action.ArrivalHeadAfterEditAction + + + + pu.arrival.beforeEditHead + + nccloud.web.pu.arrival.action.ArrivalHeadBeforeEditAction + + + + pu.arrival.quickArr + + nccloud.web.pu.arrival.action.QuickArrAction + + + pu.arrival.quickArrQuery + + nccloud.web.pu.arrival.action.QuickArrQueryAction + + + pu.arrival.queryParam + + nccloud.web.pu.arrival.action.QueryParamAction + + + pu.arrival.combin + + nccloud.web.pu.arrival.action.ArrivalCombinAction + + + pu.arrival.combinprint + + nccloud.web.pu.arrival.action.ArrivalCombinPrintAction + + + pu.arrival.querysplitparam + + nccloud.web.pu.arrival.action.ArriveSplitGetParamAction + + + pu.arrival.splitprint + + nccloud.web.pu.arrival.action.ArriveSplitPrintAction + + + pu.arrival.printbarcode + + nccloud.web.pu.arrival.action.PrintBarCodeAction + + + pu.arrival.dirprintbarcode + + nccloud.web.pu.arrival.action.ArriveDirPrintBarCodeAction + + + + + pu.arrival.saveandcommit + + nccloud.web.pu.arrival.action.SaveAndCommitAction + + + + pu.arrival.materialsagacheck + + nccloud.web.pu.arrival.action.MaterialAssignAction + + + pu.arrival.exttranstypequeryaction + + nccloud.web.pu.arrival.transtype.action.ExtTransTypeQueryAction + + + + pu.arrival.copybodyinsertfeedetail + + nccloud.web.pu.arrival.action.ArriveCardCopyInsertFeeDetailAction + + + + pu.arrival.cardbodybatch + + nccloud.web.pu.arrival.action.ArrivecardBodyBatchAction + + + + pu.arrival.headafterdbillddate + + nccloud.web.pu.arrival.action.ArriveHeadAfterDbilldateAction + + + + pu.arrival.insertfeedetail + + nccloud.web.pu.arrival.action.ArriveInsertFeeDetailAction + + + + pu.arrival.feeDetailBeforeEvent + + nccloud.web.pu.arrival.action.ArrivefeeDetailBeforeAction + + + pu.arrival.pushtoQms + + nccloud.web.pu.arrival.action.QCRptDataPushtoQmsAction + + + \ No newline at end of file diff --git a/pu/src/client/yyconfig/modules/pu/arrival/config/authorize/arrival_authorize.xml b/pu/src/client/yyconfig/modules/pu/arrival/config/authorize/arrival_authorize.xml new file mode 100644 index 00000000..c595e3e0 --- /dev/null +++ b/pu/src/client/yyconfig/modules/pu/arrival/config/authorize/arrival_authorize.xml @@ -0,0 +1,73 @@ + + + + 400401200,400401204,400401206 + + pu.arrival.insert + pu.arrival.update + pu.arrival.delete + pu.arrival.queryScheme + pu.arrival.pageQuery + pu.arrival.queryCard + pu.arrival.saveSend + pu.arrival.commit + pu.arrival.uncommit + pu.arrival.uncommit + pu.arrival.approve + pu.arrival.unapprove + pu.arrival.afterBodyEdit + pu.arrival.crtAssert + pu.arrival.delAssert + pu.arrival.qualityCheck + pu.arrival.transAssert + pu.arrival.delTransAssert + pu.arrival.fixRate + pu.arrival.print + pu.arrival.printPermiss + pu.arrival.edit + pu.arrival.afterEditHead + pu.arrival.beforeEditHead + pu.arrival.quickArr + pu.arrival.quickArrQuery + pu.arrival.queryOrder + pu.arrival.queryOrderByPK + pu.arrival.queryOrderItem + pu.arrival.transferOrder + pu.arrival.querySubcont + pu.arrival.transferSubcont + pu.arrival.queryReturnSubcont + pu.arrival.queryReturnOrder + pu.arrival.transferReturnOrder + pu.arrival.transferReturnSubcont + pu.arrival.return23 + pu.arrival.queryParam + pu.arrival.combin + pu.arrival.combinprint + pu.arrival.querysplitparam + pu.arrival.splitprint + pu.arrival.printbarcode + pu.arrival.dirprintbarcode + barcode.init.barcodeinitaction + pu.arrival.pushToC005Check + pu.arrival.scanTrans> + pu.arrival.saveandcommit + pu.arrival.materialsagacheck + pu.arrival.afterFeeDetailEdit + pu.arrival.afterFeeEdit + pu.arrival.afterBodyForFeeEdit + pu.arrival.copybodyinsertfeedetail + pu.arrival.cardbodybatch + pu.arrival.insertfeedetail + pu.arrival.headafterdbillddate + pu.arrival.feeDetailBeforeEvent + pu.arrival.pushtoQms + + + + + * + + pu.arrival.exttranstypequeryaction + + +