diff --git a/pu/src/client/nccloud/web/pu/arrival/action/QualityCheckAction.java b/pu/src/client/nccloud/web/pu/arrival/action/QualityCheckAction.java new file mode 100644 index 00000000..b88bcd3d --- /dev/null +++ b/pu/src/client/nccloud/web/pu/arrival/action/QualityCheckAction.java @@ -0,0 +1,253 @@ +package nccloud.web.pu.arrival.action; + +import nc.itf.pu.m23.qc.IArriveForQC; +import nc.pubitf.pu.m23.pubquery.IArrivePubQuery; +import nc.pubitf.qc.c001.pu.ReturnObjectFor23; +import nc.vo.pu.m23.entity.ArriveHeaderVO; +import nc.vo.pu.m23.entity.ArriveItemVO; +import nc.vo.pu.m23.entity.ArriveVO; +import nc.vo.pu.m23.entity.ArriveViewVO; +import nc.vo.pu.pub.util.AggVOUtil; +import nc.vo.pub.lang.UFDouble; +import nc.vo.pubapp.pattern.model.entity.view.AbstractDataView; +import nc.vo.pubapp.pattern.model.tool.BillComposite; +import nc.vo.qc.pub.enumeration.StrictLevelEnum; +import nccloud.commons.lang.ArrayUtils; +import nccloud.dto.pu.puinvoice.entity.DataInfo; +import nccloud.framework.core.exception.ExceptionUtils; +import nccloud.framework.core.json.IJson; +import nccloud.framework.service.ServiceLocator; +import nccloud.framework.web.action.itf.ICommonAction; +import nccloud.framework.web.container.IRequest; +import nccloud.framework.web.json.JsonFactory; +import nccloud.framework.web.processor.template.GridConvertProcessor; +import nccloud.pubitf.pu.arrival.service.IArrivalQueryService; +import nccloud.web.pu.arrivalqc.entity.QualityCheckInfo; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.Set; + + +/** + * @description 检验 + * @author ligangt + * @date 2018年8月28日 下午1:43:35 + * @version ncc1.0 + */ +public class QualityCheckAction implements ICommonAction { + + @Override + public Object doAction(IRequest request) { + try { + // 获取前台json + IJson json = JsonFactory.create(); + QualityCheckInfo info = json.fromJson(request.read(), + QualityCheckInfo.class); + + ArriveViewVO[] views = null; + if (info.isQcEnable()) { + DataInfo[] idTs = info.getIdTs(); + views = queryViewVOs(idTs); + } else { + GridConvertProcessor processor = new GridConvertProcessor(); + views = processor.fromGrid(info.getGrid()); + } + + if (views != null && views.length > 0) { + // IPubUtilService pubService = ServiceLocator + // .find(IPubUtilService.class); + // if (pubService.isOrgQcEnable(info.getPk_org())) { + // 非紧急放行入库数量>0,即根据质检入库 + // ArriveItemVO item = views[0].getBVO(); + // if + // (MathTool.compareTo(MathTool.sub(item.getNaccumstorenum(), + // item.getNaccumletgoinnum()), UFDouble.ZERO_DBL) > 0) { + // //ExceptionUtils.wrapBusinessException("紧急放行数量大于入库数量"); + // return false; + // } + // } + ArriveVO[] vos = this.getArriveVOs(views); + for (ArriveVO vo : vos) { + ArriveItemVO[] bvos = vo.getBVO(); + for (ArriveItemVO bvo : bvos) { + UFDouble nchecknum = bvo.getNchecknum(); + UFDouble nwillelignum = bvo.getNwillelignum(); + if (nchecknum != null && nwillelignum != null) { + if (nchecknum.compareTo(UFDouble.ZERO_DBL) < 0 + || nwillelignum.compareTo(UFDouble.ZERO_DBL) < 0) { + ExceptionUtils.wrapBusinessException( + nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID( + "4004100_0", "04004100-0010")/* + * @res "报检数量和合格主数量不允许为负数" + */); + } + } + UFDouble naccumchecknum = bvo.getNaccumchecknum(); + if (naccumchecknum != null) { + if (naccumchecknum.compareTo(bvo.getNnum()) == 0) { + UFDouble naccumstorenum = bvo.getNaccumstorenum(); + if (naccumstorenum != null + && naccumstorenum.compareTo(UFDouble.ZERO_DBL) > 0) { +// ExceptionUtils.wrapBusinessException( +// nc.vo.ml.NCLangRes4VoTransl.getNCLangRes() +// .getStrByID("4004100_0", "04004100-0012") +// /* @res "第" */ + bvo.getCrowno() +// + nc.vo.ml.NCLangRes4VoTransl.getNCLangRes() +// .getStrByID("4004100_0", +// "04004100-0307")/* @res 04004100-0062 "行已经完全入库，不能生成报检单" +// NCC-362748 修改后：行已经生成过报检单且正在检验中，不允许复检！*/); + ExceptionUtils.wrapBusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("4008015_0", + "04008015-0077"+"\n", null, new String[] { + bvo.getCrowno() + })); + /* @res 04004100-0062 "行已经完全入库，不能生成报检单" + NCC-362748 修改后：第{0}行已经生成过报检单且正在检验中，不允许复检！*/ + + + } + } + } + } + } + ArriveVO[] returnVos = this.check(vos, info.isCheck()); + if (null == returnVos) { + ExceptionUtils.wrapBusinessException( + nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("4004100_0", + "04004100-0011")/* @res "到货单检验失败！" */); + } + ServiceLocator.find(IArriveForQC.class).pushWmsByArriveVOs(vos); + // 把后台返回的轻量级聚合VO转换为视图VO + // new ClientBillCombinServer().combine(vos, + // returnVos); + // ArriveViewVO[] newViews = ArrivePublicUtil + // .convertAggToViewVO(vos); + // grid = processor.convert(info.getGrid().getPageid(), + // newViews); + + // String[] successIds = this.getSuccessBIDs(returnVos); + // return successIds; + } + } catch (Exception e) { + ExceptionUtils.wrapException(e); + } + return null; + } + + private ArriveViewVO[] queryViewVOs(DataInfo[] idTs) { + List bids = new ArrayList(); + Map idTsIndex = new HashMap(); + for (DataInfo item : idTs) { + bids.add(item.getId()); + idTsIndex.put(item.getId(), item.getTs()); + } + + IArrivalQueryService qryService = ServiceLocator + .find(IArrivalQueryService.class); + ArriveViewVO[] viewvos = qryService + .queryViewByBIDs(bids.toArray(new String[0])); + // 重设ts + for (ArriveViewVO viewvo : viewvos) { + viewvo.setAttributeValue("ts", + idTsIndex.get(viewvo.getPk_arriveorder_b())); + } + + return viewvos; + } + + // private String[] getSuccessBIDs(ArriveVO[] returnVos) { + // List bid_l = new ArrayList(); + // for (ArriveVO arrivevo : returnVos) { + // ArriveItemVO[] itemvos = arrivevo.getBVO(); + // for (ArriveItemVO item : itemvos) { + // bid_l.add(item.getPk_arriveorder_b()); + // } + // } + // return bid_l.toArray(new String[0]); + // } + + private ArriveVO[] getArriveVOs(ArriveViewVO[] views) { + List headers = new ArrayList(); + List items = new ArrayList(); + for (AbstractDataView view : views) { + headers.add((ArriveHeaderVO) view.getVO(ArriveHeaderVO.class)); + items.add((ArriveItemVO) view.getVO(ArriveItemVO.class)); + } + + BillComposite bc = new BillComposite(ArriveVO.class); + ArriveVO tempVO = new ArriveVO(); + bc.append(tempVO.getMetaData().getParent(), + headers.toArray(new ArriveHeaderVO[headers.size()])); + bc.append(tempVO.getMetaData().getVOMeta(ArriveItemVO.class), + items.toArray(new ArriveItemVO[items.size()])); + return bc.composite(); + } + + /** + * 调用后台接口进行检验 + * + * @param vos + * 到货单vo + * @param isCheck + * @return 检验结果数组 + * @throws Exception + */ + private ArriveVO[] check(ArriveVO[] vos, boolean isCheck) throws Exception { + Object[] objs = ServiceLocator.find(IArriveForQC.class).qualityCheck(vos, + isCheck); + ArriveVO[] result = (ArriveVO[]) objs[0]; + ReturnObjectFor23 rof = (ReturnObjectFor23) objs[1]; + // 得到质检模块的提示信息 + if (rof != null) { + Map strictMap = rof.getCsourcebid_strictlevel(); + Set keySet = strictMap.keySet(); + IArrivePubQuery arriveQuery = ServiceLocator.find(IArrivePubQuery.class); + ArriveItemVO[] items = arriveQuery + .queryItemVOByBids(keySet.toArray(new String[keySet.size()])); + + String[] bpks = AggVOUtil.getPrimaryKeys(items); + if (strictMap.size() > 0) { + for (Map.Entry entry : strictMap.entrySet()) { + String itempk = entry.getKey(); + int dji = entry.getValue().intValue(); + if (StrictLevelEnum.FREE.getReturnType() == dji) { + int i = Arrays.binarySearch(bpks, itempk); + items[i].getCrowno(); + ExceptionUtils.wrapBusinessException( + nc.vo.ml.NCLangRes4VoTransl.getNCLangRes() + .getStrByID("4004100_0", "04004100-0012")/* @res "第" */ + + items[i].getCrowno() + + nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID( + "4004100_0", + "04004100-0013")/* + * @res "行为质检连续批的严格程度为免检，不需要生成报检单！" + */); + } else if (StrictLevelEnum.PAUSE.getReturnType() == dji) { + int i = Arrays.binarySearch(bpks, itempk); + items[i].getCrowno(); + ExceptionUtils.wrapBusinessException( + nc.vo.ml.NCLangRes4VoTransl.getNCLangRes() + .getStrByID("4004100_0", "04004100-0012")/* @res "第" */ + + items[i].getCrowno() + + nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID( + "4004100_0", + "04004100-0014")/* + * @res "行为质检连续批的严格程度为暂停， 不能生成报检单！" + */);/* + * 第 { 0 } 行为质检连续批的严格程度为暂停 ， + * 不能生成报检单 ！ + */ + } + } + } + } + if (!ArrayUtils.isEmpty(result)) { + return result; + } + return null; + } + +} \ No newline at end of file diff --git a/pu/src/private/nc/impl/pu/m23/qc/ArriveForQCImpl.java b/pu/src/private/nc/impl/pu/m23/qc/ArriveForQCImpl.java new file mode 100644 index 00000000..ca818bff --- /dev/null +++ b/pu/src/private/nc/impl/pu/m23/qc/ArriveForQCImpl.java @@ -0,0 +1,649 @@ +package nc.impl.pu.m23.qc; + +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import nc.bs.dao.BaseDAO; +import nc.bs.framework.common.InvocationInfoProxy; +import nc.bs.framework.common.NCLocator; +import nc.bs.logging.Log; +import nc.impl.pu.m23.qc.action.AntiQualityCheckAction; +import nc.impl.pu.m23.qc.action.QualityCheckAction; +import nc.impl.pubapp.bd.material.assistant.MarAssistantCheckUtils; +import nc.impl.pubapp.pattern.data.vo.VOQuery; +import nc.impl.pubapp.pattern.data.vo.VOUpdate; +import nc.itf.arap.goldentax.SysParaInitQuery; +import nc.itf.pu.m23.qc.IArriveForQC; +import nc.jdbc.framework.SQLParameter; +import nc.jdbc.framework.processor.ColumnProcessor; +import nc.jdbc.framework.processor.ResultSetProcessor; +import nc.pubitf.uapbd.IMaterialPubService_C; +import nc.vo.am.common.util.StringUtils; +import nc.vo.bd.material.MaterialVO; +import nc.vo.bd.stordoc.StordocVO; +import nc.vo.org.OrgQueryUtil; +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.pub.lang.UFDouble; +import nc.vo.pubapp.pattern.exception.ExceptionUtils; +import nc.vo.pubapp.pattern.pub.SqlBuilder; +import nc.vo.qc.c001.entity.ApplyHeaderVO; +import nc.vo.qc.c001.entity.ApplySourceItemVO; +import nc.vo.qc.c001.entity.ApplyVO; +import nccloud.api.uapbd.wms.utils.WmsSyncUtils; +import nccloud.pubitf.scmpub.pub.service.ISCMPubQueryService; + +import java.util.*; + +/** + *

+ * 本类主要完成以下功能： + *

    + *
  • 到货单的质检 + *
  • 到货单的反检 + *
+ *

+ *

+ * + * @author hanbin + * @version 6.0 + * @time 2010-9-28 下午01:26:15 + * @since 6.0 + */ +public class ArriveForQCImpl implements IArriveForQC { + private static final Log log = Log.getInstance("wmslog"); + private final WmsSyncUtils wmsSyncUtils = new WmsSyncUtils(); + private static final BaseDAO dao = new BaseDAO(); + + @Override + public ArriveItemVO[] antiQualityCheck(ArriveItemVO[] bills) throws BusinessException { + try { + AntiQualityCheckAction action = new AntiQualityCheckAction(); + return action.antiQualityCheck(bills); + } catch (Exception ex) { + ExceptionUtils.marsh(ex); + } + return null; + } + + @Override + public Object[] qualityCheck(ArriveVO[] bills, boolean isCheck) + throws BusinessException { + try { + QualityCheckAction action = new QualityCheckAction(); + return action.qualityCheck(bills, isCheck); + } catch (Exception ex) { + ExceptionUtils.marsh(ex); + } + return null; + } + + @Override + public ApplyVO[] pushWmsByArriveVOs(ArriveVO[] bills) throws Exception { + //检查到货单组织是否全是成套 + log.error("到货单检验推送wms--检查组织是否为WMSORG里参数开始"); + boolean isWmsCt = checkOrgBeyondSysParam(bills); + log.error("到货单检验推送wms--检查组织是否为WMSORG里参数结束"); + if(!isWmsCt){ + log.error("到货单检验推送wms--检查组织不为WMSORG里参数，结束推送"); + return null; + } + String wmsBJPKS = InvocationInfoProxy.getInstance().getProperty("wmsBJPKS"); + if (wmsBJPKS == null || wmsBJPKS.length() < 1) { + throw new BusinessException("发送WMS数据未查询到报检单pk或已存在下游报检单，请检查！！！"); + } + log.error("到货单检验推送wms--到货单推送生成报检单主键字符串【"+wmsBJPKS+"】"); + String[] pks = wmsBJPKS.split("_"); + if (pks == null || pks.length < 1) { + throw new BusinessException("解析报检单pk失败，请检查！！！"); + } + //根据表头主键查询报检单 + ApplyVO[] applyVOs = (ApplyVO[]) ((ISCMPubQueryService) NCLocator.getInstance().lookup(ISCMPubQueryService.class)).billquery(ApplyVO.class, pks); + this.pushWms(applyVOs); + InvocationInfoProxy.getInstance().setProperty("wmsBJPKS", null); + return applyVOs; + } + + private boolean checkOrgBeyondSysParam(ArriveVO[] bills) throws BusinessException { + String targetCode = SysParaInitQuery.getParaString("GLOBLE00000000000000", "WMSORG"); + if (targetCode == null || StringUtils.isEmpty(targetCode)) { + throw new BusinessException("未配置组织参数,请前往 [业务参数设置-全局] 配置WMSORG 参数"); + } + String[] orgItem = targetCode.split(";"); + if(orgItem==null || orgItem.length<1){ + throw new BusinessException("WMSORG全局参数解析失败，请检查"); + } + //使用Stream将orgItem转成list + List orgList = Arrays.asList(orgItem); + Set orgPKs=new HashSet<>(); + for(ArriveVO arriveVO: bills){ + String pkOrg = arriveVO.getHVO().getPk_org(); + orgPKs.add(pkOrg); + } + OrgVO[] orgVOS = OrgQueryUtil.queryOrgVOByPks(orgPKs.toArray(new String[0])); + if(orgVOS==null || orgVOS.length<1){ + throw new BusinessException("未查询到组织信息，请检查"); + } + boolean containCT=false; + boolean containOther=false; + for(OrgVO orgVO:orgVOS){ + if(orgList.contains(orgVO.getCode())){ + containCT=true; + }else{ + containOther=true; + } + } + if(containCT && containOther){ + throw new BusinessException("存在非【"+targetCode+"】组织数据与其一起检验，请检查"); + } + return containCT; + } + + private void pushWms(ApplyVO[] applyVOs) throws BusinessException { + try { + JSONObject wmsData = new JSONObject(); + // 构造表头数据 + JSONArray jsonArray = new JSONArray(); + //2025年10月17日09点19分--过滤虚拟仓 + List filterData = new ArrayList<>(); + for (ApplyVO applyVO : applyVOs) { + this.checkInfo(applyVO); + ApplyHeaderVO headVO = applyVO.getHVO(); + String vbillcode = headVO.getVbillcode(); + // 检查是否为虚拟仓 + String isVirtual = wmsSyncUtils.transferFieldByPkAllowNull(StordocVO.getDefaultTableName(), + "def1", StordocVO.PK_STORDOC, + headVO.getPk_stordoc()); + if ("Y".equals(isVirtual)) { + log.error("ArriveForQCImpl -到货单检验，生成的报检单【"+vbillcode+"】 仓库[" + headVO.getPk_stordoc() + "]为虚拟仓，跳过同步"); + continue; + } + filterData.add(applyVO); + //2025年10月17日09点19分--过滤虚拟仓 + } + if(filterData.isEmpty()){ + log.error("ArriveForQCImpl -到货单检验，筛选完之后无可同步报检单，结束WMS同步"); + return; + } + ApplyVO[] syncApplyVOs=filterData.toArray(new ApplyVO[0]); + this.constructWMSData(jsonArray, syncApplyVOs); + if (jsonArray == null || jsonArray.isEmpty()) { + throw new BusinessException("当前报检单号同步数据为空,不同步WMS"); + } + wmsData.put("header", jsonArray); + String method = "TK_BIP_QC_ORDER"; + //同步前更新上游和本单--失败回滚，成功落库 + log.error("回写报检单Vdef3开始--接口失败回滚，接口成功落库"); + // 标记同步成功 + List headvos = new ArrayList<>(); + for (ApplyVO applyVO : syncApplyVOs) { + applyVO.getHVO().setVdef3("Y"); + applyVO.getHVO().setStatus(1); + headvos.add(applyVO.getHVO()); + } + VOUpdate applyVOUpdater = new VOUpdate<>(); + applyVOUpdater.update(headvos.toArray(new ApplyHeaderVO[0]), new String[]{"vdef3"}); + log.error("回写报检单Vdef结束--接口失败回滚，接口成功落库"); + // 回写上游到货单成功 + handleUpstreamArriveOrderSuccess(syncApplyVOs); + // 后规则最后一个 更新 + + log.error("开始同步报检单到WMS"); +// log.error("同步报文【" + wmsData.toJSONString() + "】"); + wmsSyncUtils.sendToExternalSystem(method, wmsData); + log.error("报检单同步WMS成功"); + + } catch (Exception e) { + log.error("检验结束，同步WMS失败" + e.getMessage()); + throw new BusinessException("同步WMS失败" + e.getMessage()); + } + } + + private void constructWMSData(JSONArray jsonArray, ApplyVO[] applyVOs) throws Exception { + //获取时间戳 + long timestamp = System.currentTimeMillis(); + for (ApplyVO applyVO : applyVOs) { + ApplyHeaderVO headVO = applyVO.getHVO(); + String vbillcode = headVO.getVbillcode(); + log.error("到货单检验推送wms--到货单推送生成报检单单号【"+vbillcode+"】"); + ApplySourceItemVO[] itemVOs = applyVO.getB2VO(); + + ApplySourceItemVO itemExampleVO = itemVOs[0]; + + JSONObject headData = new JSONObject(); +// Map headData = new HashMap<>(); + // 构建仓库ID: "CK" + 组织编码 + "001" + String orgCode = wmsSyncUtils.transferCodeByPk("org_stockorg", "code", "pk_stockorg", + headVO.getPk_stockorg()); + String warehouseId = "CK" + (orgCode != null ? orgCode : "") + "001"; + headData.put("organizationId", "TK"); // 组织 默认TK + headData.put("warehouseId", warehouseId); // 仓库ID（必填） +// headData.put("customerId", "TKJT"); // 货主（必填，默认值） + //2025年9月3日10点37分--货主改为和仓库编码一致 --sdlizheng start + headData.put("customerId", warehouseId); + //2025年9月3日10点37分--货主改为和仓库编码一致 --sdlizheng end + + // 根据表体源头单据类型编码确定订单类型 + String asnType = getAsnTypeByFirstTypeCode(itemVOs); + if (asnType == null) { + throw new BusinessException("报检单号【" + vbillcode + "】 - 未知的源头单据类型编码，不同步此报检单"); + } + headData.put("asnType", asnType); // 订单类型（必填，根据源头单据类型编码确定） + headData.put("QCNO", headVO.getVbillcode()); // 质检单号（必填） + + //2025年9月2日09点01分--表头添加到货日期--sdlizheng start + headData.put("BIP_TIME", headVO.getDapplydate().toString()); + //2025年9月2日09点01分--表头添加到货日期--sdlizheng end + headData.put("MSG_BATCH", String.valueOf( timestamp)); + headData.put("QCSTATUS", "00"); // 质检单状态（必填，默认00） + // 到货单号取来源单据号 + headData.put("SOURCEORDERNO1", itemExampleVO.getVsourcecode() != null ? itemExampleVO.getVsourcecode() : ""); // 到货单号（必填） + headData.put("qty_rejected", headVO.getNnum() != null ? headVO.getNnum().toString() : ""); // 报检数量（必填） + headData.put("supplierId", wmsSyncUtils.transferCodeByPk("bd_supplier", "code", "pk_supplier", headVO.getPk_supplier())); + headData.put("DEPARTMENT", + wmsSyncUtils.transferCodeByPk("org_dept", "code", "pk_dept", headVO.getPk_applydept())); // 报检部门（必填） + headData.put("hedi02", headVO.getPk_applybill() != null ? headVO.getPk_applybill() : ""); // 报检单主键（必填） + headData.put("hedi03", headVO.getPk_stordoc() != null ? headVO.getPk_stordoc() : ""); // 仓库回传主键 + headData.put("hedi05", itemExampleVO.getCsourceid()); + headData.put("hedi06", itemExampleVO.getCsourcetypecode()); + headData.put("hedi07", wmsSyncUtils.transferFieldByPkAllowNull("sm_user", "user_name", "cuserid", headVO.getBillmaker())); + + headData.put("hedi08", wmsSyncUtils.transferCodeByPk(StordocVO.getDefaultTableName(), StordocVO.NAME, StordocVO.PK_STORDOC, headVO.getPk_stordoc())); + + //2025年9月7日16点26分--增加检验方案字段--sdlizheng start +// WMS报检单下发WMS新增两个字段：pk_defaultstd，pk_defaultstd_v WMS回传质检报告时：hedi11,hedi12,分别对应pk_chkstd，pk_chkstd_v + headData.put("hedi11", wmsSyncUtils.transferCodeByPk("qc_checkstandard", "vchkstandardcode", "pk_checkstandard", headVO.getPk_defaultstd())); + headData.put("hedi12", wmsSyncUtils.transferCodeByPk("qc_checkstandard_v", "vchkstandardcode", "pk_checkstandard", headVO.getPk_defaultstd_v())); + //2025年9月7日16点26分--增加检验方案字段--sdlizheng end + + // 构造表体数据（遍历itemVOs表体VO数组） +// List> bodyDataList = new ArrayList<>(); + JSONArray bodyDataList = new JSONArray(); + String old_manufacturer = null, old_cprojectid = null, old_productionDept = null, old_vbatchcode = null; + +// for (ApplySourceItemVO itemVO : itemVOs) { + + // 查询一下上游的到货单明细,然后拿到生产厂商和部门 + VOQuery voQuery = new VOQuery<>(ArriveItemVO.class); + ArriveItemVO[] arriveItemVO = voQuery.query(new String[]{itemVOs[0].getCsourcebid()}); + if (arriveItemVO != null && arriveItemVO.length > 0) { + ArriveItemVO arriveItem = arriveItemVO[0]; + old_vbatchcode = arriveItem.getVbatchcode(); + old_manufacturer = arriveItem.getCproductorid(); + old_cprojectid = arriveItem.getCprojectid(); + old_productionDept = arriveItem.getVfree1(); + }else{ + throw new BusinessException("到货单检验推送wms--根据报检单来源子表id【"+itemVOs[0].getCsourcebid()+"】未查询到到货单明细，请检查"); + } + // 校验物料属性--2025年9月2日09点50分 变更--如果启用校验报错--不启用则先留存数据，清空vo数据，后续赋值数据 sdlizheng start +// wmsSyncUtils.checkMaterialBatchCode(itemVOs[0].getPk_material(), itemVOs[0].getVbatchcode(), orgCode); + this.checkMaterialInfo(itemVOs[0], headVO.getPk_stockorg(), arriveItemVO[0]); +// wmsSyncUtils.checkMaterialFreeAssistantProps(itemVOs[0].getPk_material(), orgCode, manufacturer, cprojectid, productionDept); + // 校验物料属性--2025年9月2日09点50分 变更--如果启用校验报错--不启用则先留存数据，清空vo数据，后续赋值数据 sdlizheng end + +// } +// Map bodyData = new HashMap<>(); + JSONObject bodyData = new JSONObject(); + //2025年10月10日11点29分--增加到货单字段推送wms-start +// 一、到货单表体自定义项28货位编码发送给WMS的WGKWBH字段（传编码）。 +// 二、到货单表体自定义项29产品编码发送给WMS的CCPBH字段（传编码）。 +// 三、到货单表体自定义项30流程生产订单号发送给WMS的LCSCDDH字段（传编码）。 +// 四、到货单表体生产日期dproducedate字段发送给WMS的JHKGSJ字段（传日期）。 +// 五、到货单表体备注字段vmemob字段发送给WMS的BOMBZ字段（传字符串）。 +// 六、到货单表头的采购部门pk_dept字段发送给WMS的CGBM字段（传编码）。 +// 七、到货单表头的采购员pk_pupsndoc字段发给WMS的CGY字段（传编码）。 + VOQuery headQueryVO = new VOQuery<>(ArriveHeaderVO.class); + ArriveHeaderVO[] arriveVOs = headQueryVO.query(new String[]{itemVOs[0].getCsourceid()}); + if(arriveVOs==null || arriveVOs.length==0){ + throw new BusinessException("到货单检验推送wms--根据报检单来源子表id【"+itemVOs[0].getCsourceid()+"】未查询到到货单明细，请检查"); + } + String vbdef28 = arriveItemVO[0].getVbdef28(); + bodyData.put("WGKWBH",vbdef28); + String vbdef29 = arriveItemVO[0].getVbdef29(); + bodyData.put("CCPBH",vbdef29); + String vbdef30 = arriveItemVO[0].getVbdef30(); + bodyData.put("LCSCDDH",vbdef30); + String dproducedate= arriveItemVO[0].getDproducedate() != null ? arriveItemVO[0].getDproducedate().toStdString() : null; + bodyData.put("JHKGSJ", dproducedate); + bodyData.put("BOMBZ", arriveItemVO[0].getVmemob()); + String pkDept = arriveVOs[0].getPk_dept(); + headData.put("CGBM", wmsSyncUtils.transferCodeByPk("org_dept", "code", "pk_dept", pkDept)); + String pkPupsndoc = arriveVOs[0].getPk_pupsndoc(); + headData.put("CGY", wmsSyncUtils.transferCodeByPk("bd_psndoc", "code", "pk_psndoc", pkPupsndoc)); + //2025年10月10日11点29分--增加到货单字段推送wms-end + //2025年10月17日13点41分--增加数量字段推送wms-start + UFDouble nastnum = arriveItemVO[0].getNastnum()==null?UFDouble.ZERO_DBL:arriveItemVO[0].getNastnum(); + bodyData.put("DEDI09", nastnum.toString()); + //2025年10月21日10点54分--添加到货字段DEDI10-start + bodyData.put("DEDI10", nastnum.toString()); + //2025年10月21日10点54分--添加到货字段DEDI10-end + bodyData.put("DEDI05", wmsSyncUtils.transferCodeByPk("bd_measdoc", "code", "pk_measdoc", arriveItemVO[0].getCastunitid())); + //2025年10月17日13点41分--增加字段推送wms-start + + // 检验项目明细表体使用表头物料信息（因为itemVO是检验项目明细，不是物料明细） + bodyData.put("sku", wmsSyncUtils.transferCodeByPk("bd_material", "code", "pk_material", + headVO.getPk_material())); // 产品（必填）- 使用表头物料 + bodyData.put("skuDescr1", wmsSyncUtils.transferFieldByPkAllowNull("bd_material", "materialshortname", "pk_material", headVO.getPk_material())); // 产品描述（必填）- 使用表头物料 + + //2025年10月17日13点50分--改取nnum +// bodyData.put("QTY_REJECTED", headVO.getNastnum() != null ? headVO.getNastnum().toString() : ""); // 报检数量（必填）- + bodyData.put("QTY_REJECTED", headVO.getNnum() != null ? headVO.getNnum().toString() : ""); + + // 使用表头数量 + bodyData.put("qcQty_Completed", headVO.getNnum() != null ? headVO.getNnum().doubleValue() : ""); // 质检数量（可选） + bodyData.put("LOTATT01", + headVO.getDproducedate() != null ? headVO.getDproducedate().toString() : ""); // 生产日期（必填）- + bodyData.put("LOTATT04", headVO.getVbatchcode() != null ? headVO.getVbatchcode() : ""); // ERP批次号（必填）- + // 使用表头批次号 + bodyData.put("LOTATT05", wmsSyncUtils.transferCodeByPk("bd_stordoc", "code", "pk_stordoc", + headVO.getPk_stordoc())); // ERP仓库（必填）- 使用表头仓库 + bodyData.put("LOTATT06", wmsSyncUtils.transferCodeByPk("bd_supplier", "code", "pk_supplier", + headVO.getPk_supplier())); // 供应商（必填）- 使用表头供应商 + // 从上游抽出生产厂商字段 + bodyData.put("LOTATT07", wmsSyncUtils.transferFieldByPkAllowNull("bd_defdoc", "code", "pk_defdoc", arriveItemVO[0].getCproductorid())); + bodyData.put("LOTATT08", "DJ"); + // 项目号（必填）- 使用表头项目 + bodyData.put("LOTATT09", wmsSyncUtils.transferCodeByPk("bd_project", "project_code", "pk_project", arriveItemVO[0].getCprojectid())); + // 检验项目明细相关字段 + bodyData.put("DEDI01", itemVOs[0].getCsourcebid()); + bodyData.put("DEDI02", headVO.getCtrantypeid()); // 检验项目名称（可选） + bodyData.put("DEDI03", wmsSyncUtils.transferFieldByPkAllowNull("bd_supplier", "name", "pk_supplier", headVO.getPk_supplier())); // 供应商名称 +// bodyData.put("DEDI04", wmsSyncUtils.transferFieldByPkAllowNull("bd_stordoc", "name", "pk_stordoc", headVO.getPk_stordoc())); // ERP仓库名称 + //2025年9月28日19点24分--换报检明细主键 + bodyData.put("DEDI04", itemVOs[0].getPk_applybill_s()); + // 采购部门（可选）- 使用表头采购部门 + bodyData.put("PURCHASE_DEPARMENT", wmsSyncUtils.transferCodeByPk("org_dept", "code", "pk_dept", arriveItemVO[0].getVfree1())); + // 采购员（可选）- 使用表头采购员 + bodyData.put("PURCHASE_CGY", wmsSyncUtils.transferCodeByPk("bd_psndoc", "code", "pk_psndoc", headVO.getPk_pupsndoc())); + // 单位（可选）- 使用表头单位 + bodyData.put("UNIT", wmsSyncUtils.transferCodeByPk("bd_measdoc", "code", "pk_measdoc", headVO.getCastunitid())); +// bodyData.put("addWho", headVO.getCreator() != null ? headVO.getCreator() : ""); // 新增人员（可选）- 使用表头创建人 + String s = wmsSyncUtils.transferCodeByPk("sm_user", "user_code", "cuserid", headVO.getCreator()); + //将s转大写 + bodyData.put("addWhos",s==null?"" : s.toUpperCase() ); // 新增人员（可选）- 使用表头创建人 + headData.put("addWhos",s==null?"" : s.toUpperCase() ); // 新增人员（可选）- 使用表头创建人 + + bodyData.put("addTime", headVO.getCreationtime() != null ? headVO.getCreationtime().toString() : ""); // 新增时间（可选）- 使用表头创建时间 +// bodyData.put("editWho", headVO.getModifier() != null ? headVO.getModifier() : ""); // 编辑人（可选）- 使用表头修改人 + bodyData.put("editWho", wmsSyncUtils.transferCodeByPk("sm_user","user_code","pk_user", headVO.getModifier())); // 新增人员（可选）- 使用表头创建人 + bodyData.put("editTime", headVO.getModifiedtime() != null ? headVO.getModifiedtime().toString() : ""); // 编辑时间（可选）- 使用表头修改时间 + + bodyDataList.add(bodyData); + + arriveItemVO[0].setVfree1(old_productionDept); + arriveItemVO[0].setVbatchcode(old_vbatchcode); + arriveItemVO[0].setCproductorid(old_manufacturer); + arriveItemVO[0].setCprojectid(old_cprojectid); + // 组装最终数据结构 + headData.put("details", bodyDataList); + jsonArray.add(headData); + } + } + + private void checkInfo(ApplyVO applyVO) throws BusinessException { + ApplyHeaderVO headVO = applyVO.getHVO(); + ApplySourceItemVO[] itemVOs = applyVO.getB2VO(); + if (headVO == null) { + throw new BusinessException("报检单表头或明细为空，无法构造WMS数据"); + } + + String vbillcode = headVO.getVbillcode(); + if (itemVOs == null || itemVOs.length == 0) { + throw new BusinessException("报检单报检单【" + vbillcode + "】明细为空，无法构造WMS数据"); + } + String orgCode = null; + try { + orgCode = wmsSyncUtils.transferCodeByPk("org_stockorg", "code", "pk_stockorg", headVO.getPk_stockorg()); + } catch (Exception e) { + throw new BusinessException("报检单【" + vbillcode + "】， 查询组织编码失败" + e.getMessage()); + } + if (orgCode == null || StringUtils.isEmpty(orgCode)) { + throw new BusinessException("报检单【" + vbillcode + "】， 未获取到组织编码"); + } + if (!wmsSyncUtils.checkIfIncludeOrg(orgCode)) { + throw new BusinessException("报检单【" + vbillcode + "】， 不在WMS同步范围内"); + } + if ("Y".equalsIgnoreCase(headVO.getVdef3())) { + throw new BusinessException("报检单【" + vbillcode + "】， 已同步成功，无法再次同步"); + } + } + + /** + * 回写上游到货单明细的自定义项2成功 + */ + private void handleUpstreamArriveOrderSuccess(ApplyVO[] applyVOs) throws BusinessException { + //获取所有明细信息 + log.error("回写到货单Vbdef22和Vmemob开始--接口失败回滚，接口成功落库"); + Set arriveItemIds = new HashSet<>(); + for (ApplyVO applyVO : applyVOs) { + String vbillcode = applyVO.getHVO().getVbillcode(); + ApplySourceItemVO[] b2VOs = applyVO.getB2VO(); + if (b2VOs == null || b2VOs.length < 1) { + throw new BusinessException("发送wms前回写上游到货单失败,明细行为空"); + } + for (ApplySourceItemVO itemVO : b2VOs) { + String csourcebid = itemVO.getCsourcebid(); + if (StringUtils.isEmpty(csourcebid)) { + throw new BusinessException("发送wms前回写上游到货单失败,明细行[Csourcebid]字段为空"); + } + arriveItemIds.add(csourcebid); + } + } + VOQuery voQuery = new VOQuery<>(ArriveItemVO.class); + ArriveItemVO[] arriveItems = voQuery.query(arriveItemIds.toArray(new String[0])); + + if (arriveItems == null || arriveItems.length < 1) { + throw new BusinessException("发送wms前回写上游到货单失败,未查询到上游到货单明细信息"); + } + //检查回写的到货单是否为质检的 + for (ArriveItemVO arriveItem : arriveItems) { + String vbdef50 = arriveItem.getVbdef50(); + String pkOrderB = arriveItem.getPk_order_b(); + if(!"Y".equals(vbdef50)){ + throw new BusinessException("请检查，存在到货单明细为免检，生成报检单，到货单明细【"+pkOrderB+"】"); + } + arriveItem.setVbdef22("Y"); // 标记同步成功 + arriveItem.setVmemob("发送WMS成功"); // 记录失败原因 + arriveItem.setStatus(1); + } + new VOUpdate().update(arriveItems, new String[]{"vbdef22", "vmemob"}); + log.error("回写到货单Vbdef22和Vmemob结束--接口失败回滚，接口成功落库"); + } + + private void checkMaterialInfo(ApplySourceItemVO itemVO, String orgCode, ArriveItemVO arriveItemVO) throws BusinessException { + String materialPk = itemVO.getPk_material(); + String vbatchcode = arriveItemVO.getVbatchcode(); + String manufacturer = arriveItemVO.getCproductorid(); + String projectNo = arriveItemVO.getCprojectid(); + String productionDept = arriveItemVO.getVfree1(); + if (materialPk == null || materialPk.trim().isEmpty()) { + log.error("物料主键为空，无法检查自由辅助属性"); + throw new BusinessException("物料主键为空"); + } + + if (orgCode == null || orgCode.trim().isEmpty()) { + log.error("组织主键为空，无法检查自由辅助属性"); + throw new BusinessException("组织主键为空"); + } + + try { + // 查询物料库存信息中的自由辅助属性 + String sql = "SELECT fixasst2, fixasst4, freeasst1,wholemanaflag " + + "FROM bd_materialstock " + + "WHERE pk_material = ? AND pk_org = ?"; + + SQLParameter sqlParameter = new SQLParameter(); + sqlParameter.addParam(materialPk); + sqlParameter.addParam(orgCode); + + Object result = dao.executeQuery(sql, sqlParameter, (ResultSetProcessor) rs -> { + if (rs.next()) { + Map row = new HashMap<>(); + row.put("fixasst2", rs.getString("fixasst2")); // 对应项目号 + row.put("fixasst4", rs.getString("fixasst4")); // 对应生产厂商 + row.put("freeasst1", rs.getString("freeasst1")); // 对应生产部门 + row.put("wholemanaflag", rs.getString("wholemanaflag")); // 批次管理标识 + return row; + } + return null; + }); + + if (result == null) { + log.error("未查询到物料库存信息，物料主键：" + materialPk + "，组织主键：" + orgCode); + throw new BusinessException("未查询到物料库存信息，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + + @SuppressWarnings("unchecked") + Map materialStockInfo = (Map) result; + + log.debug("查询到物料库存信息，物料主键：" + materialPk + "，组织主键：" + orgCode + + "，自由辅助属性配置：" + materialStockInfo); + // 如果物料启用了批次管理 + String batchManageFlag = materialStockInfo.get("wholemanaflag"); + if ("Y".equals(batchManageFlag)) { + if (vbatchcode == null || vbatchcode.trim().isEmpty()) { + log.error("物料启用了批次管理，但批次号为空，物料主键：" + materialPk); + throw new BusinessException("物料启用了批次管理，但批次号为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + log.debug("物料启用了批次管理且批次号不为空，检查通过，物料主键：" + materialPk + "，批次号：" + vbatchcode); + } else { + if (vbatchcode != null && !vbatchcode.trim().isEmpty()) { + log.error("物料没有启用批次管理，但批次号不为空，物料主键：" + materialPk); + arriveItemVO.setVbatchcode(null); +// throw new BusinessException("物料没有启用批次管理，但批次号不为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + // 不需要批次管理的物料，直接返回true + log.debug("物料未启用批次管理，检查通过，物料主键：" + materialPk); + } + // 检查项目号（对应fixasst2） + String projectFlag = materialStockInfo.get("fixasst2"); + if ("Y".equals(projectFlag)) { + if (projectNo == null || projectNo.trim().isEmpty()) { + log.error("物料启用了项目号属性，但项目号为空，物料主键：" + materialPk); + throw new BusinessException("物料启用了项目号属性，但项目号为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + log.debug("项目号属性校验通过，物料主键：" + materialPk + "，项目号：" + projectNo); + } else { + if (projectNo != null && !projectNo.trim().isEmpty()) { + log.error("物料未启用项目号属性，但项目号不为空，物料主键：" + materialPk); + arriveItemVO.setCprojectid(null); +// throw new BusinessException("物料未启用项目号属性，但项目号不为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + log.debug("物料未启用项目号属性，跳过校验，物料主键：" + materialPk); + } + + // 检查生产厂商（对应fixasst4） + String manufacturerFlag = materialStockInfo.get("fixasst4"); + if ("Y".equals(manufacturerFlag)) { + if (manufacturer == null || manufacturer.trim().isEmpty()) { + log.error("物料启用了生产厂商属性，生产厂商不能为空，物料主键：" + materialPk); + throw new BusinessException("物料启用了生产厂商属性，生产厂商不能为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + log.debug("生产厂商属性校验通过，物料主键：" + materialPk + "，生产厂商：" + manufacturer); + } else { + if (manufacturer != null && !manufacturer.trim().isEmpty()) { + log.error("物料未启用生产厂商属性，生产厂商应为空，物料主键：" + materialPk); + arriveItemVO.setCproductorid(null); +// throw new BusinessException("物料未启用生产厂商属性，生产厂商应为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + log.debug("物料未启用生产厂商属性，跳过校验，物料主键：" + materialPk); + } + + //2025年8月28日15点32分--生产部门按照物料基本信息页签控制 --start + IMaterialPubService_C marService = NCLocator.getInstance().lookup(IMaterialPubService_C.class); + Map materialMap = marService.queryMaterialBaseInfoByPks(new String[]{materialPk}, + new String[]{MaterialVO.PK_MARASSTFRAME, MaterialVO.NAME, MaterialVO.NAME2, MaterialVO.NAME3, + MaterialVO.NAME4, MaterialVO.NAME5, MaterialVO.NAME6}); + Set marFramePkSet = new HashSet(); + for (Map.Entry entry : materialMap.entrySet()) { + String pk_marasstframe = entry.getValue().getPk_marasstframe(); + if (pk_marasstframe != null) { + marFramePkSet.add(pk_marasstframe); + } + } + Map> marFrameMap = MarAssistantCheckUtils + .queryMarAsstFrameIncludeDefPropIndex(marFramePkSet.toArray(new String[0])); + if (marFrameMap == null || marFrameMap.size() < 1) { + if (productionDept != null && !productionDept.trim().isEmpty()) { + log.error("物料基础信息页签未启用生产部门属性，但生产部门不为空，物料主键：" + materialPk); + arriveItemVO.setVfree1(null); +// throw new BusinessException("物料基础信息页签未启用生产部门属性，但生产部门不为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + log.debug("物料基础信息页签未启用生产部门属性，跳过校验，物料主键：" + materialPk); + } else { + String pkMarasstframe = materialMap.get(materialPk).getPk_marasstframe(); + List integers = marFrameMap.get(pkMarasstframe); + if (integers.contains(6)) { + //启用生产部门 + if (productionDept == null || productionDept.trim().isEmpty()) { + log.error("物料基础信息页签启用了生产部门属性，但生产部门为空，物料主键：" + materialPk); + throw new BusinessException("物料基础信息页签启用了生产部门属性，但生产部门为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + log.debug("生产部门属性校验通过，物料主键：" + materialPk + "，生产部门：" + productionDept); + } else { + if (productionDept != null && !productionDept.trim().isEmpty()) { + log.error("物料基础信息页签未启用生产部门属性，但生产部门不为空，物料主键：" + materialPk); + arriveItemVO.setVfree1(null); +// throw new BusinessException("物料基础信息页签未启用生产部门属性，但生产部门不为空，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + } + } + //2025年8月28日15点32分--生产部门按照物料基本信息页签控制 --end + + } catch (BusinessException e) { + throw e; + } catch (Exception e) { + log.error("检查物料自由辅助属性失败：" + e.getMessage() + "，物料主键：" + materialPk + "，组织主键：" + orgCode, e); + throw new BusinessException("检查物料自由辅助属性失败：" + e.getMessage() + "，物料编码：" + this.transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, materialPk)); + } + } + + public String transferCodeByPk(String tableName, String selectField, String pkField, String pk) throws BusinessException { + if (pk == null || pk.trim().isEmpty()) { + log.error("未传入主键信息，无法查询编码：" + pkField + ":" + tableName + ":" + selectField); + return null; + } + SqlBuilder sqlBuilder = new SqlBuilder(); + sqlBuilder.append(" select " + selectField); + sqlBuilder.append(" from " + tableName); + sqlBuilder.append(" where "); + sqlBuilder.append(pkField, pk); + Object o = dao.executeQuery(sqlBuilder.toString(), new ColumnProcessor()); + if (o == null) { + throw new BusinessException("未查询到编码信息，sql【" + sqlBuilder + "】"); + } + return o.toString(); + } + + /** + * 根据表体源头单据类型编码确定WMS订单类型 + * + * @param itemVOs 报检点明细数组 + * @return WMS订单类型 + */ + private String getAsnTypeByFirstTypeCode(ApplySourceItemVO[] itemVOs) throws BusinessException { + if (itemVOs == null || itemVOs.length == 0) { + log.error("ArriveForQCImpl - 报检点明细为空，使用默认类型CGRK"); + throw new BusinessException("报检点明细为空，无法确定WMS订单类型"); + } + + // 取第一个表体行的源头单据类型编码 + String firstTypeCode = itemVOs[0].getCfirsttypecode(); + if (StringUtils.isEmpty(firstTypeCode)) { + log.error("ArriveForQCImpl - 源头单据类型编码为空，使用默认类型CGRK"); + throw new BusinessException("源头单据类型编码为空，无法确定WMS订单类型"); + } + return switch (firstTypeCode) { + case "21" -> // 采购订单 + "CGRK"; + case "61" -> // 委外订单 + "WWRK"; + default -> { + log.error("ArriveForQCImpl - 未知的源头单据类型编码: " + firstTypeCode + "，不同步此报检单"); + yield null; + } + }; + } +} diff --git a/pu/src/public/nc/itf/pu/m23/qc/IArriveForQC.java b/pu/src/public/nc/itf/pu/m23/qc/IArriveForQC.java new file mode 100644 index 00000000..7a47017b --- /dev/null +++ b/pu/src/public/nc/itf/pu/m23/qc/IArriveForQC.java @@ -0,0 +1,57 @@ +package nc.itf.pu.m23.qc; + +import nc.vo.pu.m23.entity.ArriveItemVO; +import nc.vo.pu.m23.entity.ArriveVO; +import nc.vo.pub.BusinessException; +import nc.vo.qc.c001.entity.ApplyVO; + +/** + *

+ * 到货单的针对质量管理的接口定义,本类主要完成以下功能： + *

    + *
  • 到货单的质检 + *
  • 到货单的反检 + *
+ *

+ *

+ * + * @version 6.0 + * @since 6.0 + * @author hanbin + * @time 2010-1-11 下午01:40:39 + */ +public interface IArriveForQC { + + /** + * 方法功能描述：>到货单的反检 + *

+ * 参数说明 + * + * @param aggVO + * @throws BusinessException + *

+ * @since 6.0 + * @author hanbin + * @time 2010-1-13 上午09:43:38 + */ + public ArriveItemVO[] antiQualityCheck(ArriveItemVO[] bills) throws BusinessException; + + /** + * 方法功能描述：到货单的质检 + *

+ * 参数说明 + * + * @param aggVO + * @param isCheck 免检存货是否报检 + * @throws BusinessException + *

+ * @since 6.0 + * @author hanbin + * @time 2010-1-13 上午09:43:38 + */ + public Object[] qualityCheck(ArriveVO[] bills, boolean isCheck) + throws BusinessException; + + public ApplyVO[] pushWmsByArriveVOs(ArriveVO[] bills) + throws Exception; +}