保存审批

xh/ic/src/private/nc/bs/ic/general/plugins/GeneralDefdocPlugin.java

@@ -1,412 +1,429 @@
-package nc.bs.ic.general.plugins;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import nc.bs.framework.common.NCLocator;
-import nc.bs.ic.pub.env.ICBSContext;
-import nc.bs.logging.Logger;
-import nc.bs.pfxx.ISwapContext;
-import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
-import nc.impl.pubapp.pattern.data.vo.VOQuery;
-import nc.itf.scmpub.reference.uap.pf.PfServiceScmUtil;
-import nc.itf.uap.pf.IPFBusiAction;
-import nc.pubitf.scmf.ic.mbatchcode.IBatchcodePubService;
-import nc.vo.ic.general.define.ICBillBodyVO;
-import nc.vo.ic.general.define.ICBillFlag;
-import nc.vo.ic.general.define.ICBillHeadVO;
-import nc.vo.ic.general.define.ICBillVO;
-import nc.vo.ic.general.define.MetaNameConst;
-import nc.vo.ic.general.util.InOutHelp;
-import nc.vo.ic.pub.define.ICBillTableInfo;
-import nc.vo.ic.pub.define.ICPubMetaNameConst;
-import nc.vo.ic.pub.util.StringUtil;
-import nc.vo.ic.pub.util.ValueCheckUtil;
-import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
-import nc.vo.pfxx.util.PfxxPluginUtils;
-import nc.vo.pub.AggregatedValueObject;
-import nc.vo.pub.BusinessException;
-import nc.vo.pub.VOStatus;
-import nc.vo.pub.lang.UFBoolean;
-import nc.vo.pub.pf.workflow.IPFActionName;
-import nc.vo.pubapp.pattern.data.ValueUtils;
-import nc.vo.pubapp.pattern.exception.ExceptionUtils;
-import nc.vo.pubapp.pattern.pub.SqlBuilder;
-import nc.vo.pubapp.util.VORowNoUtils;
-import nc.vo.scmf.ic.mbatchcode.BatchcodeVO;
-
-import org.apache.commons.lang.StringUtils;
-
-/**
- * 外部交换平台，导入外部普通单数据处理类
- * 
- * @since 6.0
- * @version 2011-4-25 下午04:07:36
- * @author wanghna
- */
-public class GeneralDefdocPlugin extends AbstractPfxxPlugin {
-  @Override
-  protected Object processBill(Object vo, ISwapContext swapContext,
-      AggxsysregisterVO aggxsysvo) throws BusinessException {
-
-    if (vo == null)
-      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
-          .getStrByID("4008001_0", "04008001-0137")/*@res "转换后的vo数据为空"*/);
-
-    String vopk =
-        PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(
-            swapContext.getBilltype(), swapContext.getDocID(),
-            swapContext.getOrgPk());
-
-    if (!StringUtil.isSEmptyOrNull(vopk) && !this.canUpdate())
-      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
-          .getStrByID("4008001_0", "04008001-0138")/*@res "当前单据以前被导入过"*/);
-    // TODO 如果存在是否允许更新
-    // PfxxPluginUtils.checkBillCanBeUpdate(UfinterfaceVO swapContext);
-
-    ICBillVO icbill = (ICBillVO) vo;
-    icbill.getHead().setCgeneralhid(vopk);
-
-    ICBillVO[] icbills = null;
-    if (ValueUtils.getBoolean(swapContext.getReplace()))
-      icbills = this.doUpdate(swapContext, icbill);
-    else
-      icbills = this.doSave(swapContext, icbill);
-
-    return icbills[0].getHead().getCgeneralhid();
-  }
-
-  /**
-   * 新增
-   * 
-   * @param swapContext
-   * @param icbill
-   * @return
-   * @throws BusinessException
-   */
-  private ICBillVO[] doSave(ISwapContext swapContext, ICBillVO icbill)
-      throws BusinessException {
-    //检查是否允许保存
-    this.checkCanInster(icbill);
-    Logger.info("保存新单据前处理...");
-    this.processBeforeSave(icbill);
-
-    // TODO 单据设置有辅助信息，aggxsysvo为用户配置的具体辅助信息
-
-    Logger.info("保存新单据...");
-    IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
-    ICBillVO[] icbills =
-        (ICBillVO[]) service.processAction(IPFActionName.WRITE,
-            swapContext.getBilltype(), null, icbill, null, null);
-    //zth   
-    icbills =
-           (ICBillVO[]) service.processAction(IPFActionName.APPROVE,
-               swapContext.getBilltype(), null, icbill, null, null);
-
-    Logger.info("保存新单据完成...");
-
-    Logger.info("保存新单据后处理...");
-    this.processAfterSave(icbill);
-
-    if (ValueCheckUtil.isNullORZeroLength(icbills))
-      return null;
-
-    if (this.canUpdate())
-      PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(),
-          swapContext.getDocID(), swapContext.getOrgPk(), icbills[0].getHead()
-              .getCgeneralhid());
-    return icbills;
-  }
-
-  /**
-   * 修改：先删除，后新增
-   * 
-   * @param swapContext
-   * @param icbill
-   * @return
-   * @throws BusinessException
-   */
-  private ICBillVO[] doUpdate(ISwapContext swapContext, ICBillVO icbill)
-      throws BusinessException {
-    ICBillVO bill = getOriBillVO(icbill, swapContext.getBilltype());
-    if (bill != null) {
-      IPFBusiAction service =
-          NCLocator.getInstance().lookup(IPFBusiAction.class);
-      service.processAction(IPFActionName.DEL_DELETE,
-          swapContext.getBilltype(), null, bill, null, null);
-    }
-    return this.doSave(swapContext, icbill);
-  }
-
-  /**
-   * 根据单据号获得已存在的vo
-   * 
-   * @param icbill
-   * @param billtype
-   * @return
-   */
-  private ICBillVO getOriBillVO(ICBillVO icbill, String billtype) {
-    if (StringUtil.isSEmptyOrNull(icbill.getHead().getVbillcode()))
-      return null;
-    SqlBuilder where = new SqlBuilder();
-    where.append(" and ");
-    where.append(ICPubMetaNameConst.VBILLCODE, icbill.getHead().getVbillcode());
-    where.append(" and ");
-    where.append(ICPubMetaNameConst.PK_GROUP, icbill.getHead().getPk_group());
-    // where.append(" and ");
-    // where.append(ICPubMetaNameConst.PK_ORG,icbill.getHead().getPk_org());
-
-    ICBillTableInfo billinfo =
-        ICBillTableInfo.getICBillTableInfo(InOutHelp.getICBillType(billtype));
-    VOQuery<ICBillHeadVO> query =
-        new VOQuery<ICBillHeadVO>(billinfo.getHeadClass());
-    ICBillHeadVO[] heads = query.query(where.toString(), null);
-    if (ValueCheckUtil.isNullORZeroLength(heads))
-      return null;
-    where = new SqlBuilder();
-    where.append(" and ");
-    where.append(MetaNameConst.CGENERALHID, heads[0].getCgeneralhid());
-    VOQuery<ICBillBodyVO> bodyquery =
-        new VOQuery<ICBillBodyVO>(billinfo.getBodyClass());
-    ICBillBodyVO[] bodys = bodyquery.query(where.toString(), null);
-    if (ValueCheckUtil.isNullORZeroLength(bodys))
-      return null;
-
-    ICBillVO bill = billinfo.createBillVO();
-    bill.setParent(heads[0]);
-    bill.setChildrenVO(bodys);
-    return bill;
-  }
-
-  /**
-   * 单据保存前处理
-   * 
-   * @param vo
-   */
-  protected void processBeforeSave(ICBillVO vo) throws BusinessException {
-
-    if (null == vo)
-      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
-          .getStrByID("4008001_0", "04008001-0139")/*@res "单据不能为空"*/);
-
-    // this.checkNullValue(vo);
-    // 表头组织翻译后没有赋值，需要重表体字段重新取一边
-      if(StringUtil.isSEmptyOrNull(vo.getParentVO().getPk_org()))
-      vo.getParentVO().setPk_org(vo.getBodys()[0].getPk_org());
-      if(StringUtil.isSEmptyOrNull(vo.getParentVO().getPk_org_v()))
-      vo.getParentVO().setPk_org_v(vo.getBodys()[0].getPk_org_v());
-      if(StringUtil.isSEmptyOrNull(vo.getParentVO().getCwarehouseid()))
-      vo.getParentVO().setCwarehouseid(vo.getBodys()[0].getCbodywarehouseid());
-
-    ICBSContext context = new ICBSContext();
-    this.headVOProcess(vo.getHead(), context);
-    this.bodyVOProcess(vo, context);
-  }
-
-  /**
-   * 单据保存后处理
-   * 
-   * @param vo
-   */
-  protected void processAfterSave(ICBillVO vo) throws BusinessException {
-    if (null == vo)
-      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
-          .getStrByID("4008001_0", "04008001-0140")/*@res "单据保存失败"*/);
-  }
-
-  /**
-   * 表头处理，处理默认值，公司，单据日期，单据状态，打印次数，集团
-   * 
-   * @param vo
-   */
-  private void headVOProcess(ICBillHeadVO vo, ICBSContext context) {
-    vo.setStatus(VOStatus.NEW);
-    // 集团
-    if (StringUtil.isSEmptyOrNull(vo.getPk_group()))
-      vo.setPk_group(context.getPk_group());
-    // 打印次数
-    if (vo.getIprintcount() == null)
-      vo.setIprintcount(Integer.valueOf(0));
-    // 单据状态
-    if (vo.getFbillflag() == null)
-      vo.setFbillflag((Integer) ICBillFlag.FREE.value());
-    // 单据日期
-    if (vo.getDbilldate() == null)
-      vo.setDbilldate(context.getBizDate());
-    // 公司
-    if (StringUtil.isSEmptyOrNull(vo.getCorpoid())
-        || StringUtil.isSEmptyOrNull(vo.getCorpvid())) {
-      vo.setCorpoid(context.getOrgInfo().getCorpIDByCalBodyID(vo.getPk_org()));
-      vo.setCorpvid(context.getOrgInfo().getCorpVIDByCalBodyID(vo.getPk_org()));
-    }
-
-    if (StringUtil.isSEmptyOrNull(vo.getCtrantypeid())) {
-      // uap不支持单据类型的翻译，暂时以交易类型code查询id的方式补交易类型
-      String vtrantypecode = vo.getVtrantypecode();
-      Map<String, String> map =
-          PfServiceScmUtil.getTrantypeidByCode(new String[] {
-            vtrantypecode
-          });
-      vo.setCtrantypeid(map == null ? null : map.get(vtrantypecode));
-    }
-
-  }
-
-  /**
-   * 单据表体处理
-   * 
-   * @param vo
-   * @param context
-   * @throws BusinessException
-   */
-  private void bodyVOProcess(ICBillVO vo, ICBSContext context)
-      throws BusinessException {
-    ICBillBodyVO[] vos = vo.getBodys();
-    if (ValueCheckUtil.isNullORZeroLength(vos))
-      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
-          .getStrByID("4008001_0", "04008001-0141")/*@res "单据表体不能为空"*/);
-
-    VORowNoUtils.setVOsRowNoByRule(vos, ICPubMetaNameConst.CROWNO);// 行号处理
-
-    ICBillHeadVO head = vo.getHead();
-    Map<String, BatchcodeVO> batchmap = this.getBatchcodeVO(vos);
-    for (ICBillBodyVO body : vos) {
-      body.setStatus(VOStatus.NEW);
-      if (StringUtil.isSEmptyOrNull(body.getCmaterialoid())
-          || StringUtil.isSEmptyOrNull(body.getCmaterialvid()))
-        throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
-            .getStrByID("4008001_0", "04008001-0142")/*@res "单据表体物料不能为空"*/);
-
-      body.setBbarcodeclose(UFBoolean.FALSE);// 单据行是否条码关闭
-      body.setBonroadflag(UFBoolean.FALSE);// 是否在途
-      if (body.getNnum()!=null &&body.getNassistnum()!=null&&body.getDbizdate() == null)
-        body.setDbizdate(context.getBizDate());// 业务日期
-      // 辅单位
-      if (StringUtil.isSEmptyOrNull(body.getCastunitid()))
-        body.setCastunitid(context.getInvInfo()
-            .getInvBasVO(body.getCmaterialvid()).getPk_stockmeas());
-
-      // 有批次号但无批次主键时， 需要补全批次主键，有必要时(保质期管理)补全生产日期和失效日期
-      if (!StringUtils.isEmpty(body.getVbatchcode())
-          && StringUtils.isEmpty(body.getPk_batchcode())) {
-        BatchcodeVO batchvo =
-            batchmap.get(body.getCmaterialvid() + body.getVbatchcode());
-        if (batchvo != null) {
-          body.setPk_batchcode(batchvo.getPk_batchcode());
-          body.setDproducedate(batchvo.getDproducedate());
-          body.setDvalidate(batchvo.getDvalidate());
-        }
-      }
-      bodyVOCopyFromHeadVO(body, head);
-    }
-  }
-
-  /**
-   * 获取批次号档案
-   * 
-   * @param vos
-   * @return Map<String(cmaterialvid+vbatchcode), BatchcodeVO批次档案>
-   */
-  private Map<String, BatchcodeVO> getBatchcodeVO(ICBillBodyVO[] vos) {
-    List<String> cmaterialvidList = new ArrayList<String>();
-    List<String> vbatchcodeList = new ArrayList<String>();
-    Set<String> materialbatch = new HashSet<String>();
-    for (ICBillBodyVO body : vos) {
-      if (body.getCmaterialvid() != null && body.getVbatchcode() != null) {
-        if (materialbatch.contains(body.getCmaterialvid()
-            + body.getVbatchcode())) {
-          continue;
-        }
-        cmaterialvidList.add(body.getCmaterialvid());
-        vbatchcodeList.add(body.getVbatchcode());
-        materialbatch.add(body.getCmaterialvid() + body.getVbatchcode());
-      }
-    }
-    if (materialbatch.size() == 0) {
-      return new HashMap<String, BatchcodeVO>();
-    }
-    IBatchcodePubService batchservice =
-        NCLocator.getInstance().lookup(IBatchcodePubService.class);
-    BatchcodeVO[] batchvos = null;
-    try {
-      batchvos =
-          batchservice.queryBatchVOs(cmaterialvidList.toArray(new String[0]),
-              vbatchcodeList.toArray(new String[0]));
-    }
-    catch (BusinessException e) {
-      ExceptionUtils.wrappException(e);
-    }
-
-    if (batchvos == null || batchvos.length == 0) {
-      return new HashMap<String, BatchcodeVO>();
-    }
-    Map<String, BatchcodeVO> batchmap = new HashMap<String, BatchcodeVO>();
-    for (BatchcodeVO batchvo : batchvos) {
-      batchmap
-          .put(batchvo.getCmaterialvid() + batchvo.getVbatchcode(), batchvo);
-    }
-    return batchmap;
-  }
-
-  /**
-   * 根据表头设置表体默认值，表体集团，库存组织，公司，仓库，交易类型
-   * 
-   * @param body
-   * @param head
-   */
-  private void bodyVOCopyFromHeadVO(ICBillBodyVO body, ICBillHeadVO head) {
-    body.setPk_group(head.getPk_group());
-    body.setPk_org(head.getPk_org());
-    body.setPk_org_v(head.getPk_org_v());
-    body.setCorpoid(head.getCorpoid());
-    body.setCorpvid(head.getCorpvid());
-    body.setCbodywarehouseid(head.getCwarehouseid());
-    body.setCbodytranstypecode(head.getVtrantypecode());
-  }
-
-  /**
-   * 是否允许更新
-   * 
-   * @return
-   */
-  protected boolean canUpdate() {
-    return false;
-  }
-  
-  /**
-   * 检验vo是否可更新
-   * 
-   * @param vo
-   */
-  protected void checkCanInster(AggregatedValueObject vo) {
-    this.checkBillFlag(vo);
-    new CheckMnyUtil().checkMny(vo);
-    new CheckScaleUtil().checkScale(vo);
-  }
-
-  
-  /**
-   * 检验vo状态
-   * 
-   * @param vo
-   */
-  private void checkBillFlag(AggregatedValueObject vo) {
-    if (!Integer.valueOf(ICBillFlag.getFreeFlag()).equals(
-        vo.getParentVO().getAttributeValue(this.getBillStatusKey()))) {
-      ExceptionUtils.wrappBusinessException(nc.vo.ml.NCLangRes4VoTransl
-          .getNCLangRes().getStrByID("4008001_0", "04008001-0816")/*
-                                                                   * @res
-                                                                   * "非自由态的单据不允许导入！"
-                                                                   */);
-    }
-  }
-  
-  protected String getBillStatusKey() {
-    return ICPubMetaNameConst.FBILLFLAG;
-  }
-
-}
+package nc.bs.ic.general.plugins;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import nc.bs.framework.common.NCLocator;
+import nc.bs.ic.pub.env.ICBSContext;
+import nc.bs.logging.Logger;
+import nc.bs.pfxx.ISwapContext;
+import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
+import nc.impl.pubapp.pattern.data.vo.VOQuery;
+import nc.itf.scmpub.reference.uap.pf.PfServiceScmUtil;
+import nc.itf.uap.pf.IPFBusiAction;
+import nc.pubitf.scmf.ic.mbatchcode.IBatchcodePubService;
+import nc.vo.ic.general.define.ICBillBodyVO;
+import nc.vo.ic.general.define.ICBillFlag;
+import nc.vo.ic.general.define.ICBillHeadVO;
+import nc.vo.ic.general.define.ICBillVO;
+import nc.vo.ic.general.define.MetaNameConst;
+import nc.vo.ic.general.util.InOutHelp;
+import nc.vo.ic.pub.define.ICBillTableInfo;
+import nc.vo.ic.pub.define.ICPubMetaNameConst;
+import nc.vo.ic.pub.util.StringUtil;
+import nc.vo.ic.pub.util.ValueCheckUtil;
+import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
+import nc.vo.pfxx.util.PfxxPluginUtils;
+import nc.vo.pub.AggregatedValueObject;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.VOStatus;
+import nc.vo.pub.lang.UFBoolean;
+import nc.vo.pub.pf.workflow.IPFActionName;
+import nc.vo.pubapp.pattern.data.ValueUtils;
+import nc.vo.pubapp.pattern.exception.ExceptionUtils;
+import nc.vo.pubapp.pattern.pub.SqlBuilder;
+import nc.vo.pubapp.util.VORowNoUtils;
+import nc.vo.scmf.ic.mbatchcode.BatchcodeVO;
+
+import org.apache.commons.lang.StringUtils;
+
+/**
+ * 外部交换平台，导入外部普通单数据处理类
+ * 
+ * @since 6.0
+ * @version 2011-4-25 下午04:07:36
+ * @author wanghna
+ */
+public class GeneralDefdocPlugin extends AbstractPfxxPlugin {
+  @Override
+  protected Object processBill(Object vo, ISwapContext swapContext,
+      AggxsysregisterVO aggxsysvo) throws BusinessException {
+
+    if (vo == null)
+      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
+          .getStrByID("4008001_0", "04008001-0137")/*@res "转换后的vo数据为空"*/);
+
+    String vopk =
+        PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(
+            swapContext.getBilltype(), swapContext.getDocID(),
+            swapContext.getOrgPk());
+
+    if (!StringUtil.isSEmptyOrNull(vopk) && !this.canUpdate())
+      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
+          .getStrByID("4008001_0", "04008001-0138")/*@res "当前单据以前被导入过"*/);
+    // TODO 如果存在是否允许更新
+    // PfxxPluginUtils.checkBillCanBeUpdate(UfinterfaceVO swapContext);
+
+    ICBillVO icbill = (ICBillVO) vo;
+    icbill.getHead().setCgeneralhid(vopk);
+
+    ICBillVO[] icbills = null;
+    if (ValueUtils.getBoolean(swapContext.getReplace()))
+      icbills = this.doUpdate(swapContext, icbill);
+    else
+      icbills = this.doSave(swapContext, icbill);
+
+    return icbills[0].getHead().getCgeneralhid();
+  }
+
+  /**
+   * 新增
+   * 
+   * @param swapContext
+   * @param icbill
+   * @return
+   * @throws BusinessException
+   */
+  private ICBillVO[] doSave(ISwapContext swapContext, ICBillVO icbill)
+      throws BusinessException {
+    //检查是否允许保存
+    this.checkCanInster(icbill);
+    Logger.info("保存新单据前处理...");
+    this.processBeforeSave(icbill);
+
+    // TODO 单据设置有辅助信息，aggxsysvo为用户配置的具体辅助信息
+
+    Logger.info("保存新单据...");
+    IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+    ICBillVO[] icbills =
+        (ICBillVO[]) service.processAction(IPFActionName.WRITE,swapContext.getBilltype(), null, icbill, null, null);
+    //其它领料 
+    if(swapContext.getBilltype().equals("4C")){
+    	  service.processAction("SIGN","4C", null, icbill, null, null);
+    }
+    //其他入库
+    if(swapContext.getBilltype().equals("4A")){
+    	service.processAction("SIGN","4A", null, icbill, null, null);
+    }
+    //其他出库
+    if(swapContext.getBilltype().equals("4I")){
+    	service.processAction("SIGN","4I", null, icbill, null, null);
+    }
+    //委外领料——材料出库
+    if(swapContext.getBilltype().equals("4D")){
+    	service.processAction("SIGN","4D", null, icbill, null, null);
+    }
+    //委托加工入库
+    if(swapContext.getBilltype().equals("47")){
+    	service.processAction("SIGN","47", null, icbill, null, null);
+    }
+    if(swapContext.getBilltype().equals("45")){
+		 service.processAction("SIGN","45", null, icbill, null, null);
+	}
+    Logger.info("保存新单据完成...");
+
+    Logger.info("保存新单据后处理...");
+    this.processAfterSave(icbill);
+
+    if (ValueCheckUtil.isNullORZeroLength(icbills))
+      return null;
+
+    if (this.canUpdate())
+      PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(),
+          swapContext.getDocID(), swapContext.getOrgPk(), icbills[0].getHead()
+              .getCgeneralhid());
+    return icbills;
+  }
+
+  /**
+   * 修改：先删除，后新增
+   * 
+   * @param swapContext
+   * @param icbill
+   * @return
+   * @throws BusinessException
+   */
+  private ICBillVO[] doUpdate(ISwapContext swapContext, ICBillVO icbill)
+      throws BusinessException {
+    ICBillVO bill = getOriBillVO(icbill, swapContext.getBilltype());
+    if (bill != null) {
+      IPFBusiAction service =
+          NCLocator.getInstance().lookup(IPFBusiAction.class);
+      service.processAction(IPFActionName.DEL_DELETE,
+          swapContext.getBilltype(), null, bill, null, null);
+    }
+    return this.doSave(swapContext, icbill);
+  }
+
+  /**
+   * 根据单据号获得已存在的vo
+   * 
+   * @param icbill
+   * @param billtype
+   * @return
+   */
+  private ICBillVO getOriBillVO(ICBillVO icbill, String billtype) {
+    if (StringUtil.isSEmptyOrNull(icbill.getHead().getVbillcode()))
+      return null;
+    SqlBuilder where = new SqlBuilder();
+    where.append(" and ");
+    where.append(ICPubMetaNameConst.VBILLCODE, icbill.getHead().getVbillcode());
+    where.append(" and ");
+    where.append(ICPubMetaNameConst.PK_GROUP, icbill.getHead().getPk_group());
+    // where.append(" and ");
+    // where.append(ICPubMetaNameConst.PK_ORG,icbill.getHead().getPk_org());
+
+    ICBillTableInfo billinfo =
+        ICBillTableInfo.getICBillTableInfo(InOutHelp.getICBillType(billtype));
+    VOQuery<ICBillHeadVO> query =
+        new VOQuery<ICBillHeadVO>(billinfo.getHeadClass());
+    ICBillHeadVO[] heads = query.query(where.toString(), null);
+    if (ValueCheckUtil.isNullORZeroLength(heads))
+      return null;
+    where = new SqlBuilder();
+    where.append(" and ");
+    where.append(MetaNameConst.CGENERALHID, heads[0].getCgeneralhid());
+    VOQuery<ICBillBodyVO> bodyquery =
+        new VOQuery<ICBillBodyVO>(billinfo.getBodyClass());
+    ICBillBodyVO[] bodys = bodyquery.query(where.toString(), null);
+    if (ValueCheckUtil.isNullORZeroLength(bodys))
+      return null;
+
+    ICBillVO bill = billinfo.createBillVO();
+    bill.setParent(heads[0]);
+    bill.setChildrenVO(bodys);
+    return bill;
+  }
+
+  /**
+   * 单据保存前处理
+   * 
+   * @param vo
+   */
+  protected void processBeforeSave(ICBillVO vo) throws BusinessException {
+
+    if (null == vo)
+      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
+          .getStrByID("4008001_0", "04008001-0139")/*@res "单据不能为空"*/);
+
+    // this.checkNullValue(vo);
+    // 表头组织翻译后没有赋值，需要重表体字段重新取一边
+      if(StringUtil.isSEmptyOrNull(vo.getParentVO().getPk_org()))
+      vo.getParentVO().setPk_org(vo.getBodys()[0].getPk_org());
+      if(StringUtil.isSEmptyOrNull(vo.getParentVO().getPk_org_v()))
+      vo.getParentVO().setPk_org_v(vo.getBodys()[0].getPk_org_v());
+      if(StringUtil.isSEmptyOrNull(vo.getParentVO().getCwarehouseid()))
+      vo.getParentVO().setCwarehouseid(vo.getBodys()[0].getCbodywarehouseid());
+
+    ICBSContext context = new ICBSContext();
+    this.headVOProcess(vo.getHead(), context);
+    this.bodyVOProcess(vo, context);
+  }
+
+  /**
+   * 单据保存后处理
+   * 
+   * @param vo
+   */
+  protected void processAfterSave(ICBillVO vo) throws BusinessException {
+    if (null == vo)
+      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
+          .getStrByID("4008001_0", "04008001-0140")/*@res "单据保存失败"*/);
+  }
+
+  /**
+   * 表头处理，处理默认值，公司，单据日期，单据状态，打印次数，集团
+   * 
+   * @param vo
+   */
+  private void headVOProcess(ICBillHeadVO vo, ICBSContext context) {
+    vo.setStatus(VOStatus.NEW);
+    // 集团
+    if (StringUtil.isSEmptyOrNull(vo.getPk_group()))
+      vo.setPk_group(context.getPk_group());
+    // 打印次数
+    if (vo.getIprintcount() == null)
+      vo.setIprintcount(Integer.valueOf(0));
+    // 单据状态
+    if (vo.getFbillflag() == null)
+      vo.setFbillflag((Integer) ICBillFlag.FREE.value());
+    // 单据日期
+    if (vo.getDbilldate() == null)
+      vo.setDbilldate(context.getBizDate());
+    // 公司
+    if (StringUtil.isSEmptyOrNull(vo.getCorpoid())
+        || StringUtil.isSEmptyOrNull(vo.getCorpvid())) {
+      vo.setCorpoid(context.getOrgInfo().getCorpIDByCalBodyID(vo.getPk_org()));
+      vo.setCorpvid(context.getOrgInfo().getCorpVIDByCalBodyID(vo.getPk_org()));
+    }
+
+    if (StringUtil.isSEmptyOrNull(vo.getCtrantypeid())) {
+      // uap不支持单据类型的翻译，暂时以交易类型code查询id的方式补交易类型
+      String vtrantypecode = vo.getVtrantypecode();
+      Map<String, String> map =
+          PfServiceScmUtil.getTrantypeidByCode(new String[] {
+            vtrantypecode
+          });
+      vo.setCtrantypeid(map == null ? null : map.get(vtrantypecode));
+    }
+
+  }
+
+  /**
+   * 单据表体处理
+   * 
+   * @param vo
+   * @param context
+   * @throws BusinessException
+   */
+  private void bodyVOProcess(ICBillVO vo, ICBSContext context)
+      throws BusinessException {
+    ICBillBodyVO[] vos = vo.getBodys();
+    if (ValueCheckUtil.isNullORZeroLength(vos))
+      throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
+          .getStrByID("4008001_0", "04008001-0141")/*@res "单据表体不能为空"*/);
+
+    VORowNoUtils.setVOsRowNoByRule(vos, ICPubMetaNameConst.CROWNO);// 行号处理
+
+    ICBillHeadVO head = vo.getHead();
+    Map<String, BatchcodeVO> batchmap = this.getBatchcodeVO(vos);
+    for (ICBillBodyVO body : vos) {
+      body.setStatus(VOStatus.NEW);
+      if (StringUtil.isSEmptyOrNull(body.getCmaterialoid())
+          || StringUtil.isSEmptyOrNull(body.getCmaterialvid()))
+        throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes()
+            .getStrByID("4008001_0", "04008001-0142")/*@res "单据表体物料不能为空"*/);
+
+      body.setBbarcodeclose(UFBoolean.FALSE);// 单据行是否条码关闭
+      body.setBonroadflag(UFBoolean.FALSE);// 是否在途
+      if (body.getNnum()!=null &&body.getNassistnum()!=null&&body.getDbizdate() == null)
+        body.setDbizdate(context.getBizDate());// 业务日期
+      // 辅单位
+      if (StringUtil.isSEmptyOrNull(body.getCastunitid()))
+        body.setCastunitid(context.getInvInfo()
+            .getInvBasVO(body.getCmaterialvid()).getPk_stockmeas());
+
+      // 有批次号但无批次主键时， 需要补全批次主键，有必要时(保质期管理)补全生产日期和失效日期
+      if (!StringUtils.isEmpty(body.getVbatchcode())
+          && StringUtils.isEmpty(body.getPk_batchcode())) {
+        BatchcodeVO batchvo =
+            batchmap.get(body.getCmaterialvid() + body.getVbatchcode());
+        if (batchvo != null) {
+          body.setPk_batchcode(batchvo.getPk_batchcode());
+          body.setDproducedate(batchvo.getDproducedate());
+          body.setDvalidate(batchvo.getDvalidate());
+        }
+      }
+      bodyVOCopyFromHeadVO(body, head);
+    }
+  }
+
+  /**
+   * 获取批次号档案
+   * 
+   * @param vos
+   * @return Map<String(cmaterialvid+vbatchcode), BatchcodeVO批次档案>
+   */
+  private Map<String, BatchcodeVO> getBatchcodeVO(ICBillBodyVO[] vos) {
+    List<String> cmaterialvidList = new ArrayList<String>();
+    List<String> vbatchcodeList = new ArrayList<String>();
+    Set<String> materialbatch = new HashSet<String>();
+    for (ICBillBodyVO body : vos) {
+      if (body.getCmaterialvid() != null && body.getVbatchcode() != null) {
+        if (materialbatch.contains(body.getCmaterialvid()
+            + body.getVbatchcode())) {
+          continue;
+        }
+        cmaterialvidList.add(body.getCmaterialvid());
+        vbatchcodeList.add(body.getVbatchcode());
+        materialbatch.add(body.getCmaterialvid() + body.getVbatchcode());
+      }
+    }
+    if (materialbatch.size() == 0) {
+      return new HashMap<String, BatchcodeVO>();
+    }
+    IBatchcodePubService batchservice =
+        NCLocator.getInstance().lookup(IBatchcodePubService.class);
+    BatchcodeVO[] batchvos = null;
+    try {
+      batchvos =
+          batchservice.queryBatchVOs(cmaterialvidList.toArray(new String[0]),
+              vbatchcodeList.toArray(new String[0]));
+    }
+    catch (BusinessException e) {
+      ExceptionUtils.wrappException(e);
+    }
+
+    if (batchvos == null || batchvos.length == 0) {
+      return new HashMap<String, BatchcodeVO>();
+    }
+    Map<String, BatchcodeVO> batchmap = new HashMap<String, BatchcodeVO>();
+    for (BatchcodeVO batchvo : batchvos) {
+      batchmap
+          .put(batchvo.getCmaterialvid() + batchvo.getVbatchcode(), batchvo);
+    }
+    return batchmap;
+  }
+
+  /**
+   * 根据表头设置表体默认值，表体集团，库存组织，公司，仓库，交易类型
+   * 
+   * @param body
+   * @param head
+   */
+  private void bodyVOCopyFromHeadVO(ICBillBodyVO body, ICBillHeadVO head) {
+    body.setPk_group(head.getPk_group());
+    body.setPk_org(head.getPk_org());
+    body.setPk_org_v(head.getPk_org_v());
+    body.setCorpoid(head.getCorpoid());
+    body.setCorpvid(head.getCorpvid());
+    body.setCbodywarehouseid(head.getCwarehouseid());
+    body.setCbodytranstypecode(head.getVtrantypecode());
+  }
+
+  /**
+   * 是否允许更新
+   * 
+   * @return
+   */
+  protected boolean canUpdate() {
+    return false;
+  }
+  
+  /**
+   * 检验vo是否可更新
+   * 
+   * @param vo
+   */
+  protected void checkCanInster(AggregatedValueObject vo) {
+    this.checkBillFlag(vo);
+    new CheckMnyUtil().checkMny(vo);
+    new CheckScaleUtil().checkScale(vo);
+  }
+
+  
+  /**
+   * 检验vo状态
+   * 
+   * @param vo
+   */
+  private void checkBillFlag(AggregatedValueObject vo) {
+    if (!Integer.valueOf(ICBillFlag.getFreeFlag()).equals(
+        vo.getParentVO().getAttributeValue(this.getBillStatusKey()))) {
+      ExceptionUtils.wrappBusinessException(nc.vo.ml.NCLangRes4VoTransl
+          .getNCLangRes().getStrByID("4008001_0", "04008001-0816")/*
+                                                                   * @res
+                                                                   * "非自由态的单据不允许导入！"
+                                                                   */);
+    }
+  }
+  
+  protected String getBillStatusKey() {
+    return ICPubMetaNameConst.FBILLFLAG;
+  }
+
+}

xh/ic/src/private/nc/bs/ic/special/plugins/SpecialDefdocPlugin.java

@@ -0,0 +1,250 @@
+package nc.bs.ic.special.plugins;
+
+import java.util.HashMap;
+import java.util.Map;
+import nc.bs.framework.common.NCLocator;
+import nc.bs.ic.general.plugins.CheckMnyUtil;
+import nc.bs.ic.general.plugins.CheckScaleUtil;
+import nc.bs.ic.pub.env.ICBSContext;
+import nc.bs.logging.Logger;
+import nc.bs.pfxx.ISwapContext;
+import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
+import nc.impl.pubapp.pattern.data.vo.VOQuery;
+import nc.itf.scmpub.reference.uap.pf.PfServiceScmUtil;
+import nc.itf.uap.pf.IPFBusiAction;
+import nc.vo.ic.general.util.InOutHelp;
+import nc.vo.ic.pub.define.ICSpecialTableInfo;
+import nc.vo.ic.pub.util.StringUtil;
+import nc.vo.ic.pub.util.ValueCheckUtil;
+import nc.vo.ic.special.define.ICSpecialBillFlag;
+import nc.vo.ic.special.define.ICSpecialBodyVO;
+import nc.vo.ic.special.define.ICSpecialHeadVO;
+import nc.vo.ic.special.define.ICSpecialVO;
+import nc.vo.ml.NCLangRes4VoTransl;
+import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
+import nc.vo.pfxx.util.PfxxPluginUtils;
+import nc.vo.pub.AggregatedValueObject;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.workflownote.WorkflownoteVO;
+import nc.vo.pubapp.pattern.data.ValueUtils;
+import nc.vo.pubapp.pattern.exception.ExceptionUtils;
+import nc.vo.pubapp.pattern.pub.SqlBuilder;
+import nc.vo.pubapp.util.VORowNoUtils;
+
+public class SpecialDefdocPlugin extends AbstractPfxxPlugin {
+	protected Object processBill(Object vo, ISwapContext swapContext, AggxsysregisterVO aggxsysvo)
+			throws BusinessException {
+		if (vo == null) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4008001_0", "04008001-0137"));
+		} else {
+			String vopk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(),
+					swapContext.getDocID(), swapContext.getOrgPk());
+			if (!StringUtil.isSEmptyOrNull(vopk) && !this.canUpdate()) {
+				throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4008001_0", "04008001-0138"));
+			} else {
+				ICSpecialVO icbill = (ICSpecialVO) vo;
+				icbill.getHead().setCspecialhid(vopk);
+				ICSpecialVO[] icbills = null;
+				if (ValueUtils.getBoolean(swapContext.getReplace())) {
+					icbills = this.doUpdate(swapContext, icbill);
+				} else {
+					icbills = this.doSave(swapContext, icbill);
+				}
+
+				return icbills[0].getHead().getCspecialhid();
+			}
+		}
+	}
+
+	private ICSpecialVO[] doSave(ISwapContext swapContext, ICSpecialVO icbill) throws BusinessException {
+		this.checkCanInster(icbill);
+		Logger.info("保存新单据前处理...");
+		this.processBeforeSave(icbill);
+		Logger.info("保存新单据...");
+		IPFBusiAction service = (IPFBusiAction) NCLocator.getInstance().lookup(IPFBusiAction.class);
+		ICSpecialVO[] icbills = (ICSpecialVO[]) ((ICSpecialVO[]) service.processAction("WRITE",
+				swapContext.getBilltype(), (WorkflownoteVO) null, icbill, (Object) null, (HashMap) null));
+		
+		if(swapContext.getBilltype().equals("4K")){
+	    	  service.processAction("APPROVE",
+	    	                 "4K", null, icbill, null, null);
+	    	 }
+		Logger.info("保存新单据完成...");
+		Logger.info("保存新单据后处理...");
+		this.processAfterSave(icbill);
+		if (ValueCheckUtil.isNullORZeroLength(icbills)) {
+			return null;
+		} else {
+			if (this.canUpdate()) {
+				PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(), swapContext.getDocID(),
+						swapContext.getOrgPk(), icbills[0].getHead().getCspecialhid());
+			}
+
+			return icbills;
+		}
+	}
+
+	private ICSpecialVO[] doUpdate(ISwapContext swapContext, ICSpecialVO icbill) throws BusinessException {
+		ICSpecialVO bill = this.getOriBillVO(icbill, swapContext.getBilltype());
+		if (bill != null) {
+			IPFBusiAction service = (IPFBusiAction) NCLocator.getInstance().lookup(IPFBusiAction.class);
+			service.processAction("DELETE", swapContext.getBilltype(), (WorkflownoteVO) null, bill, (Object) null,
+					(HashMap) null);
+		}
+
+		return this.doSave(swapContext, icbill);
+	}
+
+	private ICSpecialVO getOriBillVO(ICSpecialVO icbill, String billtype) {
+		if (StringUtil.isSEmptyOrNull(icbill.getHead().getVbillcode())) {
+			return null;
+		} else {
+			SqlBuilder where = new SqlBuilder();
+			where.append(" and ");
+			where.append("vbillcode", icbill.getHead().getVbillcode());
+			where.append(" and ");
+			where.append("pk_group", icbill.getHead().getPk_group());
+			ICSpecialTableInfo billinfo = ICSpecialTableInfo.getICBillTableInfo(InOutHelp.getICBillType(billtype));
+			VOQuery<ICSpecialHeadVO> query = new VOQuery(billinfo.getHeadClass(), new String[]{"cspecialhid", "ts"});
+			ICSpecialHeadVO[] heads = (ICSpecialHeadVO[]) query.query(where.toString(), (String) null);
+			if (ValueCheckUtil.isNullORZeroLength(heads)) {
+				return null;
+			} else {
+				where = new SqlBuilder();
+				where.append(" and ");
+				where.append("cspecialhid", heads[0].getCspecialhid());
+				VOQuery<ICSpecialBodyVO> bodyquery = new VOQuery(billinfo.getBodyClass(),
+						new String[]{"cspecialhid", "cspecialbid", "ts"});
+				ICSpecialBodyVO[] bodys = (ICSpecialBodyVO[]) bodyquery.query(where.toString(), (String) null);
+				if (ValueCheckUtil.isNullORZeroLength(bodys)) {
+					return null;
+				} else {
+					ICSpecialVO bill = (ICSpecialVO) billinfo.createBillVO();
+					bill.setParent(heads[0]);
+					bill.setChildrenVO(bodys);
+					return bill;
+				}
+			}
+		}
+	}
+
+	protected void processBeforeSave(ICSpecialVO vo) throws BusinessException {
+		if (null == vo) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4008001_0", "04008001-0139"));
+		} else {
+			ICBSContext context = new ICBSContext();
+			if (StringUtil.isSEmptyOrNull(vo.getParentVO().getPk_org())) {
+				vo.getParentVO().setPk_org(vo.getBodys()[0].getPk_org());
+			}
+
+			if (StringUtil.isSEmptyOrNull(vo.getParentVO().getPk_org_v())) {
+				vo.getParentVO().setPk_org_v(vo.getBodys()[0].getPk_org_v());
+			}
+
+			if (StringUtil.isSEmptyOrNull(vo.getParentVO().getCwarehouseid())) {
+				vo.getParentVO().setCwarehouseid(vo.getBodys()[0].getCbodywarehouseid());
+			}
+
+			this.headVOProcess(vo.getParentVO(), context);
+			this.bodyVOProcess(vo, context);
+		}
+	}
+
+	protected void processAfterSave(ICSpecialVO vo) throws BusinessException {
+		if (null == vo) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4008001_0", "04008001-0140"));
+		}
+	}
+
+	private void headVOProcess(ICSpecialHeadVO vo, ICBSContext context) {
+		vo.setStatus(2);
+		if (StringUtil.isSEmptyOrNull(vo.getPk_group())) {
+			vo.setPk_group(context.getPk_group());
+		}
+
+		if (vo.getIprintcount() == null) {
+			vo.setIprintcount(0);
+		}
+
+		if (vo.getFbillflag() == null) {
+			vo.setFbillflag((Integer) ICSpecialBillFlag.FREE.value());
+		}
+
+		if (vo.getDbilldate() == null) {
+			vo.setDbilldate(context.getBizDate());
+		}
+
+		if (StringUtil.isSEmptyOrNull(vo.getCorpoid()) || StringUtil.isSEmptyOrNull(vo.getCorpvid())) {
+			vo.setCorpoid(context.getOrgInfo().getCorpIDByCalBodyID(vo.getPk_org()));
+			vo.setCorpvid(context.getOrgInfo().getCorpVIDByCalBodyID(vo.getPk_org()));
+		}
+
+		if (StringUtil.isSEmptyOrNull(vo.getCtrantypeid())) {
+			String vtrantypecode = vo.getVtrantypecode();
+			Map<String, String> map = PfServiceScmUtil.getTrantypeidByCode(new String[]{vtrantypecode});
+			vo.setCtrantypeid(map == null ? null : (String) map.get(vtrantypecode));
+		}
+
+	}
+
+	private void bodyVOProcess(ICSpecialVO vo, ICBSContext context) throws BusinessException {
+		ICSpecialBodyVO[] vos = vo.getChildrenVO();
+		if (ValueCheckUtil.isNullORZeroLength(vos)) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4008001_0", "04008001-0141"));
+		} else {
+			VORowNoUtils.setVOsRowNoByRule(vos, "crowno");
+			ICSpecialHeadVO head = vo.getParentVO();
+			ICSpecialBodyVO[] arr$ = vos;
+			int len$ = vos.length;
+
+			for (int i$ = 0; i$ < len$; ++i$) {
+				ICSpecialBodyVO body = arr$[i$];
+				body.setStatus(2);
+				if (StringUtil.isSEmptyOrNull(body.getCmaterialoid())
+						|| StringUtil.isSEmptyOrNull(body.getCmaterialvid())) {
+					throw new BusinessException(
+							NCLangRes4VoTransl.getNCLangRes().getStrByID("4008001_0", "04008001-0142"));
+				}
+
+				if (StringUtil.isSEmptyOrNull(body.getCastunitid())) {
+					body.setCastunitid(context.getInvInfo().getInvBasVO(body.getCmaterialvid()).getPk_stockmeas());
+				}
+
+				this.bodyVOCopyFromHeadVO(body, head);
+			}
+
+		}
+	}
+
+	private void bodyVOCopyFromHeadVO(ICSpecialBodyVO body, ICSpecialHeadVO head) {
+		body.setPk_group(head.getPk_group());
+		body.setPk_org(head.getPk_org());
+		body.setPk_org_v(head.getPk_org_v());
+		body.setCorpoid(head.getCorpoid());
+		body.setCorpvid(head.getCorpvid());
+		body.setCbodywarehouseid(head.getCwarehouseid());
+	}
+
+	protected boolean canUpdate() {
+		return false;
+	}
+
+	protected void checkCanInster(AggregatedValueObject vo) {
+		this.checkBillFlag(vo);
+		(new CheckMnyUtil()).checkMny(vo);
+		(new CheckScaleUtil()).checkScale(vo);
+	}
+
+	private void checkBillFlag(AggregatedValueObject vo) {
+		if (!Integer.valueOf(ICSpecialBillFlag.getFreeFlag())
+				.equals(vo.getParentVO().getAttributeValue(this.getBillStatusKey()))) {
+			ExceptionUtils
+					.wrappBusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4008001_0", "04008001-0816"));
+		}
+
+	}
+
+	protected String getBillStatusKey() {
+		return "fbillflag";
+	}
+}

xh/sc/src/private/nc/bs/sc/pfxx/plugin/SCorderPfxxPlugin.java

@@ -1,97 +1,100 @@
-package nc.bs.sc.pfxx.plugin;
-
-import nc.bs.framework.common.NCLocator;
-import nc.bs.logging.Logger;
-import nc.itf.sc.m61.ISCOrderMaintain;
-import nc.itf.uap.pf.IPFBusiAction;
-import nc.itf.uap.pfxx.IPFxxEJBService;
-import nc.md.persist.framework.IMDPersistenceQueryService;
-import nc.vo.pfxx.util.FileUtils;
-import nc.vo.pfxx.util.PfxxPluginUtils;
-import nc.bs.pfxx.ISwapContext;
-import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
-import nc.vo.pub.BusinessException;
-import nc.vo.pub.VOStatus;
-import nc.vo.pub.workflownote.WorkflownoteVO;
-import nc.vo.pubapp.pattern.pub.PubAppTool;
-import nc.vo.sc.m61.entity.SCOrderHeaderVO;
-import nc.vo.sc.m61.entity.SCOrderItemVO;
-import nc.vo.sc.m61.entity.SCOrderVO;
-import nc.vo.sc.m61.entity.context.SCOrderContxt;
-
-
-
-
-/**
- * <b> 在此处简要描述此类的功能 </b>
- *
- * <p>
- *     在此处添加此类的描述信息
- * </p>
- *
- * @author ufsoft
- * @version Your Project V60
- */
-public class SCorderPfxxPlugin extends nc.bs.pfxx.plugin.AbstractPfxxPlugin  {	
-	
-	/**
-	 * 将由XML转换过来的VO导入NC系统。业务插件实现此方法即可。<br>
-	 * 请注意，业务方法的校验一定要充分
-	 * 
-	 * @param vo
-	 *            转换后的vo数据，在NC系统中可能为ValueObject,SuperVO,AggregatedValueObject,IExAggVO等。
-	 * @param swapContext
-	 *            各种交换参数，组织，接受方，发送方，帐套等等
-	 * @param aggxsysvo
-	 *            辅助信息vo
-	 * @return
-	 * @throws BusinessException
-	 */
-	protected Object processBill(Object vo, ISwapContext swapContext, AggxsysregisterVO aggxsysvo) throws BusinessException {
-
-		//1.得到转换后的VO数据,取决于向导第一步注册的VO信息
- 		SCOrderVO resvo = (SCOrderVO)vo;
- 
- 		//2.查询此单据是否已经被导入过，有两个方法，具体使用哪一个请参考方法说明javadoc
- 		String vopk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(),swapContext.getDocID());
- 		//2) String vopk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(),swapContext.getDocID(),swapContext.getOrgPk());
- 		
- 		//3. 如果单据设置有辅助信息，aggxsysvo为用户配置的具体辅助信息
- 		
- 		//4.如果此单据没有导入过，那么准备保存新单据，保存单据前请进行必要的数据检查，并给出明确的业务异常...
- 		//TODO
- 		Logger.info("如果此单据没有导入过,保存新单据...");
- 		if (PubAppTool.isNull(vopk)) {
- 			SCOrderItemVO[] sCOrderHeaderVO=resvo.getChildrenVO();
- 			for (SCOrderItemVO scOrderItemVO : sCOrderHeaderVO) {
- 				scOrderItemVO.setStatus(2);
-			}
- 			resvo.getParentVO().setStatus(2);
- 			//WorkflownoteVO Workflownote = new WorkflownoteVO();
- 			//IPFBusiAction ipf = NCLocator.getInstance().lookup(IPFBusiAction.class);
-			//ipf.processAction("SAVEBASE", "61", Workflownote, resvo, null, null);
- 			ISCOrderMaintain is = NCLocator.getInstance().lookup(ISCOrderMaintain.class);
- 			is.save(new SCOrderVO[]{resvo},new SCOrderContxt(), null);
- 		}
- 		
- 		//5.如果此单据已经导入过，请调用PfxxPluginUtils.checkBillCanBeUpdate(UfinterfaceVO swapContext)检查单据是否允许更新
- 		//  如果不允许更新,此方法会抛出业务异常
- 		//TODO
- 		Logger.info("如果单据已经导入过则进行单据更新...");
-
-
- 		 		
- 		
- 		
- 		//6.如果希望单据将来可以更新，请调用下列接口插入文档流水号与生成PK的对照关系
- 		//  第2步查询对照关系相对应，也有两个个方法，具体请看javadoc
- 		//1)PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(),swapContext.getDocID(),pk);
- 		//2)PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(),swapContext.getDocID(),swapContext.getOrgPk(),pk);
- 		
-		//7.准备返回值,此函数的返回值，最终会以字符串的形式返回给外系统，
-		//  对于普通单据可以返回NC系统生成的PK值，对于凭证可能返回凭证号，具体视单据而定
-		//  对于查询插件要求返回org.w3c.dom.Node[]数组 或者org.w3c.dom.Node
-		return "业务插件返回值";
-	}
-	
-}
+package nc.bs.sc.pfxx.plugin;
+
+import nc.bs.framework.common.NCLocator;
+import nc.bs.logging.Logger;
+import nc.itf.sc.m61.ISCOrderMaintain;
+import nc.itf.uap.pf.IPFBusiAction;
+import nc.itf.uap.pfxx.IPFxxEJBService;
+import nc.md.persist.framework.IMDPersistenceQueryService;
+import nc.vo.pfxx.util.FileUtils;
+import nc.vo.pfxx.util.PfxxPluginUtils;
+import nc.bs.pfxx.ISwapContext;
+import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.VOStatus;
+import nc.vo.pub.workflownote.WorkflownoteVO;
+import nc.vo.pubapp.pattern.pub.PubAppTool;
+import nc.vo.sc.m61.entity.SCOrderHeaderVO;
+import nc.vo.sc.m61.entity.SCOrderItemVO;
+import nc.vo.sc.m61.entity.SCOrderVO;
+import nc.vo.sc.m61.entity.context.SCOrderContxt;
+
+
+
+
+/**
+ * <b> 在此处简要描述此类的功能 </b>
+ *
+ * <p>
+ *     在此处添加此类的描述信息
+ * </p>
+ *
+ * @author ufsoft
+ * @version Your Project V60
+ */
+public class SCorderPfxxPlugin extends nc.bs.pfxx.plugin.AbstractPfxxPlugin  {	
+	
+	/**
+	 * 将由XML转换过来的VO导入NC系统。业务插件实现此方法即可。<br>
+	 * 请注意，业务方法的校验一定要充分
+	 * 
+	 * @param vo
+	 *            转换后的vo数据，在NC系统中可能为ValueObject,SuperVO,AggregatedValueObject,IExAggVO等。
+	 * @param swapContext
+	 *            各种交换参数，组织，接受方，发送方，帐套等等
+	 * @param aggxsysvo
+	 *            辅助信息vo
+	 * @return
+	 * @throws BusinessException
+	 */
+	protected Object processBill(Object vo, ISwapContext swapContext, AggxsysregisterVO aggxsysvo) throws BusinessException {
+
+		//1.得到转换后的VO数据,取决于向导第一步注册的VO信息
+ 		SCOrderVO resvo = (SCOrderVO)vo;
+ 
+ 		//2.查询此单据是否已经被导入过，有两个方法，具体使用哪一个请参考方法说明javadoc
+ 		String vopk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(),swapContext.getDocID());
+ 		//2) String vopk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(),swapContext.getDocID(),swapContext.getOrgPk());
+ 		
+ 		//3. 如果单据设置有辅助信息，aggxsysvo为用户配置的具体辅助信息
+ 		
+ 		//4.如果此单据没有导入过，那么准备保存新单据，保存单据前请进行必要的数据检查，并给出明确的业务异常...
+ 		//TODO
+ 		Logger.info("如果此单据没有导入过,保存新单据...");
+ 		if (PubAppTool.isNull(vopk)) {
+ 			SCOrderItemVO[] sCOrderHeaderVO=resvo.getChildrenVO();
+ 			for (SCOrderItemVO scOrderItemVO : sCOrderHeaderVO) {
+ 				scOrderItemVO.setStatus(2);
+			}
+ 			resvo.getParentVO().setStatus(2);
+ 			//WorkflownoteVO Workflownote = new WorkflownoteVO();
+ 			//IPFBusiAction ipf = NCLocator.getInstance().lookup(IPFBusiAction.class);
+			//ipf.processAction("SAVEBASE", "61", Workflownote, resvo, null, null);
+ 			ISCOrderMaintain is = NCLocator.getInstance().lookup(ISCOrderMaintain.class);
+ 			SCOrderVO[] scOrderVOs = is.save(new SCOrderVO[]{resvo},new SCOrderContxt(), null);
+ 			IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+ 			service.processAction("APPROVE","61", null, scOrderVOs[0], null, null);
+ 			System.out.println(1);
+ 		}
+ 		
+ 		//5.如果此单据已经导入过，请调用PfxxPluginUtils.checkBillCanBeUpdate(UfinterfaceVO swapContext)检查单据是否允许更新
+ 		//  如果不允许更新,此方法会抛出业务异常
+ 		//TODO
+ 		Logger.info("如果单据已经导入过则进行单据更新...");
+
+
+ 		 		
+ 		
+ 		
+ 		//6.如果希望单据将来可以更新，请调用下列接口插入文档流水号与生成PK的对照关系
+ 		//  第2步查询对照关系相对应，也有两个个方法，具体请看javadoc
+ 		//1)PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(),swapContext.getDocID(),pk);
+ 		//2)PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(),swapContext.getDocID(),swapContext.getOrgPk(),pk);
+ 		
+		//7.准备返回值,此函数的返回值，最终会以字符串的形式返回给外系统，
+		//  对于普通单据可以返回NC系统生成的PK值，对于凭证可能返回凭证号，具体视单据而定
+		//  对于查询插件要求返回org.w3c.dom.Node[]数组 或者org.w3c.dom.Node
+		return "业务插件返回值";
+	}
+	
+}

xh/so/src/private/nc/bs/mmpac/pmo/pfxx/plugin/MMpacPmoPfxxPlugin.java

@@ -0,0 +1,54 @@
+package nc.bs.mmpac.pmo.pfxx.plugin;
+
+import nc.bs.framework.common.NCLocator;
+import nc.bs.pfxx.ISwapContext;
+import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
+import nc.itf.mmpac.pmo.pac0002.IPMOMaintainService;
+import nc.vo.mmpac.pmo.pac0002.entity.PMOAggVO;
+import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
+import nc.vo.pfxx.util.PfxxPluginUtils;
+import nc.vo.pub.AggregatedValueObject;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.CircularlyAccessibleValueObject;
+import nc.vo.pubapp.pattern.pub.PubAppTool;
+
+public class MMpacPmoPfxxPlugin extends AbstractPfxxPlugin {
+	private IPMOMaintainService service = null;
+
+	private IPMOMaintainService getIPMOMaintainService() {
+		if (this.service == null) {
+			this.service = (IPMOMaintainService) NCLocator.getInstance().lookup(IPMOMaintainService.class);
+		}
+
+		return this.service;
+	}
+
+	protected Object processBill(Object vo, ISwapContext swapContext, AggxsysregisterVO aggxsysvo)
+			throws BusinessException {
+		AggregatedValueObject resvo = (AggregatedValueObject) vo;
+		String vopk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(), swapContext.getDocID());
+		AggregatedValueObject returnVO = null;
+		if (PubAppTool.isNull(vopk)) {
+			resvo.getParentVO().setStatus(2);
+			CircularlyAccessibleValueObject[] arr$ = resvo.getChildrenVO();
+			int len$ = arr$.length;
+
+			for (int i$ = 0; i$ < len$; ++i$) {
+				CircularlyAccessibleValueObject bvo = arr$[i$];
+				bvo.setStatus(2);
+			}
+
+			returnVO = this.getIPMOMaintainService().insert(new PMOAggVO[]{(PMOAggVO) resvo})[0];
+			// ±£´æÉóÅú  2022-11-08  yaoy  Á÷³ÌÉú²ú¶©µ¥
+			if(swapContext.getBilltype().equals("55A2")){
+				returnVO = this.getIPMOMaintainService().approve(new PMOAggVO[]{(PMOAggVO) resvo})[0];
+		    }
+		} else {
+			returnVO = this.getIPMOMaintainService().update(new PMOAggVO[]{(PMOAggVO) resvo})[0];
+		}
+
+		vopk = returnVO.getParentVO().getPrimaryKey();
+		PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(), swapContext.getDocID(), vopk);
+		return vopk;
+	}
+}

xh/so/src/private/nc/bs/pu/m21/pfxx/M21PfxxPlugin.java

@@ -0,0 +1,278 @@
+package nc.bs.pu.m21.pfxx;
+
+import nc.bs.framework.common.NCLocator;
+import nc.bs.pu.m21.maintain.OrderSaveBP;
+import nc.bs.pu.m21.maintain.rule.SupplierFrozeChkRule;
+import nc.bs.pu.m21.plugin.OrderPluginPoint;
+import nc.impl.pu.m21.action.OrderDeleteAction;
+import nc.impl.pu.m21.action.rule.approve.ApproveAfterEventRule;
+import nc.impl.pu.m21.action.rule.approve.ApproveBeforeEventRule;
+import nc.impl.pu.m21.action.rule.approve.ApproveBudgetCtrlRule;
+import nc.impl.pu.m21.action.rule.approve.ApproveSupplyRule;
+import nc.impl.pu.m21.action.rule.approve.ApproveVOValidateRule;
+import nc.impl.pu.m21.action.rule.approve.FillNcaninnumRule;
+import nc.impl.pu.m21.action.rule.approve.FilterOrderByStatusRule;
+import nc.impl.pu.m21.action.rule.approve.InsertPayPlanRule;
+import nc.impl.pu.m21.action.rule.approve.InsertStatusOnWayRule;
+import nc.impl.pubapp.pattern.data.bill.BillQuery;
+import nc.impl.pubapp.pattern.rule.processer.AroundProcesser;
+import nc.itf.pu.m21.IOrderApprove;
+import nc.itf.pu.m21.IOrderMaintain;
+import nc.itf.scmpub.reference.uap.bd.vat.BuySellFlagEnum;
+import nc.itf.uap.pf.IPFBusiAction;
+import nc.md.persist.framework.IMDPersistenceQueryService;
+import nc.pubitf.pu.m21.api.IOrderMaintainAPI;
+import nc.vo.ml.NCLangRes4VoTransl;
+import nc.vo.pu.m21.context.OrderContext;
+import nc.vo.pu.m21.entity.OrderHeaderVO;
+import nc.vo.pu.m21.entity.OrderItemVO;
+import nc.vo.pu.m21.entity.OrderVO;
+import nc.vo.pu.pfxx.plugins.AbstractPuPfxxPlugin;
+import nc.vo.pu.pub.enumeration.POEnumBillStatus;
+import nc.vo.pu.pub.enumeration.PuBusiLogActionCode;
+import nc.vo.pu.pub.enumeration.PuBusiLogPathCode;
+import nc.vo.pu.pub.rule.busilog.WriteOperateLogRule;
+import nc.vo.pub.AggregatedValueObject;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.compiler.PfParameterVO;
+import nc.vo.pub.lang.UFDate;
+import nc.vo.pub.lang.UFDouble;
+import nc.vo.pub.pf.workflow.IPFActionName;
+import nc.vo.pubapp.pattern.exception.ExceptionUtils;
+import nc.vo.scmf.pub.util.BatchNCBaseTypeUtils;
+import org.apache.commons.lang.ArrayUtils;
+
+public class M21PfxxPlugin extends AbstractPuPfxxPlugin {
+	private void checkMny(AggregatedValueObject vo) {
+		StringBuilder errrows = new StringBuilder();
+		OrderItemVO[] bodyvos = ((OrderVO) vo).getBVO();
+		OrderItemVO[] arr$ = bodyvos;
+		int len$ = bodyvos.length;
+
+		for (int i$ = 0; i$ < len$; ++i$) {
+			OrderItemVO orderItemVO = arr$[i$];
+			Integer fbuysellflag = orderItemVO.getFbuysellflag();
+			UFDouble nmny = orderItemVO.getNmny();
+			UFDouble ntaxmny = orderItemVO.getNtaxmny();
+			UFDouble ntax = orderItemVO.getNtax();
+			if (BuySellFlagEnum.IMPORT.value().equals(fbuysellflag)) {
+				if (!nmny.equals(ntaxmny)) {
+					errrows.append(orderItemVO.getCrowno() + ",");
+				}
+			} else if (BuySellFlagEnum.NATIONAL_BUY.value().equals(fbuysellflag)) {
+				if (!nmny.add(ntax).equals(ntaxmny)) {
+					errrows.append(orderItemVO.getCrowno() + ",");
+				}
+			} else {
+				ExceptionUtils.wrappBusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4004000_0",
+						"04004000-0139", (String) null, new String[]{orderItemVO.getCrowno()}));
+			}
+		}
+
+		if (errrows.length() > 0) {
+			errrows.deleteCharAt(errrows.length() - 1);
+			ExceptionUtils.wrappBusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4004000_0",
+					"04004000-0137", (String) null, new String[]{errrows.toString()}));
+		}
+	}
+
+	private void checkRwite(AggregatedValueObject vo) {
+		OrderItemVO[] bodyvos = ((OrderVO) vo).getBVO();
+		OrderItemVO[] arr$ = bodyvos;
+		int len$ = bodyvos.length;
+
+		for (int i$ = 0; i$ < len$; ++i$) {
+			OrderItemVO orderItemVO = arr$[i$];
+			StringBuilder errstr = new StringBuilder();
+			UFDouble nacccancelinvmny = orderItemVO.getNacccancelinvmny();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(nacccancelinvmny)) {
+				errstr.append("nacccancelinvmny,");
+			}
+
+			UFDouble naccuminvoicemny = orderItemVO.getNaccuminvoicemny();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccuminvoicemny)) {
+				errstr.append("naccuminvoicemny,");
+			}
+
+			UFDouble nfeemny = orderItemVO.getNfeemny();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(nfeemny)) {
+				errstr.append("nfeemny,");
+			}
+
+			UFDouble naccumarrvnum = orderItemVO.getNaccumarrvnum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccumarrvnum)) {
+				errstr.append("naccumarrvnum,");
+			}
+
+			UFDouble naccumstorenum = orderItemVO.getNaccumstorenum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccumstorenum)) {
+				errstr.append("naccumstorenum,");
+			}
+
+			UFDouble naccuminvoicenum = orderItemVO.getNaccuminvoicenum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccuminvoicenum)) {
+				errstr.append("naccuminvoicenum,");
+			}
+
+			UFDouble naccumwastnum = orderItemVO.getNaccumwastnum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccumwastnum)) {
+				errstr.append("naccumwastnum,");
+			}
+
+			UFDouble naccumrpnum = orderItemVO.getNaccumrpnum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccumrpnum)) {
+				errstr.append("naccumrpnum,");
+			}
+
+			UFDouble naccumdevnum = orderItemVO.getNaccumdevnum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccumdevnum)) {
+				errstr.append("naccumdevnum,");
+			}
+
+			UFDouble nbackarrvnum = orderItemVO.getNbackarrvnum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(nbackarrvnum)) {
+				errstr.append("nbackarrvnum,");
+			}
+
+			UFDouble nbackstorenum = orderItemVO.getNbackstorenum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(nbackstorenum)) {
+				errstr.append("nbackstorenum,");
+			}
+
+			if (errstr.length() <= 0) {
+				return;
+			}
+
+			errstr.deleteCharAt(errstr.length() - 1);
+			ExceptionUtils.wrappBusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4004000_0",
+					"04004000-0138", (String) null, new String[]{orderItemVO.getCrowno(), errstr.toString()}));
+		}
+
+	}
+
+	private AggregatedValueObject save(AggregatedValueObject updatevo, AggregatedValueObject origVO) {
+		OrderVO[] returnVOs = (new OrderSaveBP(new OrderContext())).save(new OrderVO[]{(OrderVO) updatevo},
+				new OrderVO[]{(OrderVO) origVO});
+		return returnVOs[0];
+	}
+
+	protected void checkCanInster(AggregatedValueObject vo) {
+		OrderVO order = (OrderVO) vo;
+		int status = order.getHVO().getForderstatus();
+		if (POEnumBillStatus.APPROVE.toInt() == status) {
+			String approver = order.getHVO().getApprover();
+			if (approver == null || approver.isEmpty()) {
+				ExceptionUtils.wrappBusinessException("导入失败：审批态单据不能没有审批人！");
+			}
+
+			UFDate ufDate = order.getHVO().getTaudittime();
+			if (ufDate == null) {
+				ExceptionUtils.wrappBusinessException("导入失败：审批态单据审批日期不能为空！");
+			}
+
+			this.checkMny(vo);
+		} else {
+			super.checkCanInster(vo);
+			this.checkMny(vo);
+			this.checkRwite(vo);
+		}
+
+	}
+
+	protected void deleteVO(AggregatedValueObject vo) {
+		(new OrderDeleteAction()).delete(new OrderVO[]{(OrderVO) vo}, (OrderContext) null);
+	}
+
+	protected String getBillStatusKey() {
+		return "forderstatus";
+	}
+
+	protected String getChildrenPkFiled() {
+		return "pk_order_b";
+	}
+
+	protected String getParentPkFiled() {
+		return "pk_order";
+	}
+
+	protected AggregatedValueObject insert(AggregatedValueObject vo) {
+		OrderVO orderVO;
+		
+		if (vo != null) {
+			this.checkCanInster(vo);
+		}
+
+		OrderVO order = (OrderVO) vo;
+		int status = order.getHVO().getForderstatus();
+		if (POEnumBillStatus.APPROVE.toInt() == status) {
+			OrderHeaderVO hvo = order.getHVO();
+			String approver = hvo.getApprover();
+			hvo.setApprover((String) null);
+			hvo.setForderstatus(POEnumBillStatus.FREE.toInt());
+			UFDate taudittime = hvo.getTaudittime();
+			hvo.setTaudittime((UFDate) null);
+			AggregatedValueObject save = this.save(vo, (AggregatedValueObject) null);
+			orderVO = this.approve(save, approver, taudittime);
+			return orderVO;
+		} else {
+//			orderVO = (OrderVO) this.save(vo, (AggregatedValueObject) null);
+			IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+			try {
+//				service.processAction(IPFActionName.APPROVE,
+//				     "21", null, orderVO, null, null);
+				
+				IMDPersistenceQueryService service2=NCLocator.getInstance().lookup(IMDPersistenceQueryService.class);
+				OrderVO finProdInVO=(OrderVO) service2.queryBillOfNCObjectByPKWithDR(OrderVO.class,"1001ZZ1000000000RWWQ",true).getContainmentObject();
+				
+				NCLocator.getInstance().lookup(IOrderMaintain.class).delete(new OrderVO[] {finProdInVO},null);
+			} catch (BusinessException e) {
+				// TODO 自动生成的 catch 块
+				e.printStackTrace();
+			}
+			return null;
+					
+		}
+	}
+
+	private OrderVO approve(AggregatedValueObject vo, String approver, UFDate taudittime) {
+		AroundProcesser<OrderVO> processer = new AroundProcesser(OrderPluginPoint.APPROVE);
+		OrderVO order = (OrderVO) vo;
+		this.addBeforeRule(processer);
+		this.addAfterRule(processer);
+		processer.before(new OrderVO[]{order});
+		OrderHeaderVO hvo = order.getHVO();
+		hvo.setApprover(approver);
+		hvo.setForderstatus(POEnumBillStatus.APPROVE.toInt());
+		hvo.setTaudittime(taudittime);
+		processer.after(new OrderVO[]{order});
+		return order;
+	}
+
+	private void addBeforeRule(AroundProcesser<OrderVO> processer) {
+		processer.addBeforeRule(new ApproveVOValidateRule());
+		processer.addBeforeRule(new SupplierFrozeChkRule());
+		processer.addBeforeRule(new ApproveBeforeEventRule());
+	}
+
+	private void addAfterRule(AroundProcesser<OrderVO> processer) {
+		processer.addAfterRule(new WriteOperateLogRule(PuBusiLogPathCode.orderApprovePath.getCode(),
+				PuBusiLogActionCode.approve.getCode()));
+		processer.addAfterRule(new FilterOrderByStatusRule(POEnumBillStatus.APPROVE.toInt()));
+		processer.addAfterRule(new ApproveSupplyRule());
+		processer.addAfterRule(new ApproveBudgetCtrlRule());
+		processer.addAfterRule(new InsertStatusOnWayRule());
+		processer.addAfterRule(new InsertPayPlanRule());
+		processer.addAfterRule(new FillNcaninnumRule());
+		processer.addAfterRule(new ApproveAfterEventRule());
+	}
+
+	protected AggregatedValueObject queryVOByPk(String voPk) {
+		BillQuery<OrderVO> billquery = new BillQuery(OrderVO.class);
+		OrderVO[] vos = (OrderVO[]) billquery.query(new String[]{voPk});
+		return ArrayUtils.isEmpty(vos) ? null : vos[0];
+	}
+
+	protected AggregatedValueObject update(AggregatedValueObject updatevo, AggregatedValueObject origVO) {
+		return this.save(updatevo, origVO);
+	}
+}

xh/so/src/private/nc/bs/pu/m25/pfxx/M25PfxxPlugin.java

@@ -0,0 +1,138 @@
+package nc.bs.pu.m25.pfxx;
+
+import nc.bs.framework.common.NCLocator;
+import nc.bs.pu.m25.maintain.InvoiceSaveBP;
+import nc.impl.pu.m25.action.InvoiceDeleteAction;
+import nc.impl.pu.m25.action.InvoiceInsertAction;
+import nc.impl.pubapp.pattern.data.bill.BillQuery;
+import nc.itf.scmpub.reference.uap.bd.vat.BuySellFlagEnum;
+import nc.itf.uap.pf.IPFBusiAction;
+import nc.vo.ml.NCLangRes4VoTransl;
+import nc.vo.pu.m25.entity.InvoiceHeaderVO;
+import nc.vo.pu.m25.entity.InvoiceItemVO;
+import nc.vo.pu.m25.entity.InvoiceVO;
+import nc.vo.pu.m25.env.InvoiceUIToBSEnv;
+import nc.vo.pu.pfxx.plugins.AbstractPuPfxxPlugin;
+import nc.vo.pub.AggregatedValueObject;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.lang.UFDouble;
+import nc.vo.pub.pf.workflow.IPFActionName;
+import nc.vo.pubapp.pattern.exception.ExceptionUtils;
+import nc.vo.scmf.pub.util.BatchNCBaseTypeUtils;
+import org.apache.commons.lang.ArrayUtils;
+
+public class M25PfxxPlugin extends AbstractPuPfxxPlugin {
+	private void checkMny(AggregatedValueObject vo) {
+		StringBuilder errrows = new StringBuilder();
+		InvoiceHeaderVO orderHVO = (InvoiceHeaderVO) vo.getParentVO();
+		Integer fbuysellflag = orderHVO.getFbuysellflag();
+		InvoiceItemVO[] bodyvos = ((InvoiceVO) vo).getChildrenVO();
+		InvoiceItemVO[] arr$ = bodyvos;
+		int len$ = bodyvos.length;
+
+		for (int i$ = 0; i$ < len$; ++i$) {
+			InvoiceItemVO bodyvo = arr$[i$];
+			UFDouble nmny = bodyvo.getNmny();
+			UFDouble ntaxmny = bodyvo.getNtaxmny();
+			UFDouble ntax = bodyvo.getNtax();
+			if (BuySellFlagEnum.IMPORT.value().equals(fbuysellflag)) {
+				if (!nmny.equals(ntaxmny)) {
+					errrows.append(bodyvo.getCrowno() + ",");
+				}
+			} else if (BuySellFlagEnum.NATIONAL_BUY.value().equals(fbuysellflag)) {
+				if (!nmny.add(ntax).equals(ntaxmny)) {
+					errrows.append(bodyvo.getCrowno() + ",");
+				}
+			} else {
+				ExceptionUtils.wrappBusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4004000_0",
+						"04004000-0140", (String) null, new String[]{bodyvo.getCrowno()}));
+			}
+		}
+
+		if (errrows.length() > 0) {
+			errrows.deleteCharAt(errrows.length() - 1);
+			ExceptionUtils.wrappBusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4004000_0",
+					"04004000-0137", (String) null, new String[]{errrows.toString()}));
+		}
+	}
+
+	private void checkRwite(AggregatedValueObject vo) {
+		InvoiceItemVO[] bodyvos = ((InvoiceVO) vo).getChildrenVO();
+		InvoiceItemVO[] arr$ = bodyvos;
+		int len$ = bodyvos.length;
+
+		for (int i$ = 0; i$ < len$; ++i$) {
+			InvoiceItemVO bodyvo = arr$[i$];
+			StringBuilder errstr = new StringBuilder();
+			UFDouble naccumsettmny = bodyvo.getNaccumsettmny();
+			UFDouble naccumsettnum = bodyvo.getNaccumsettnum();
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccumsettmny)) {
+				errstr.append("naccumsettmny,");
+			}
+
+			if (!BatchNCBaseTypeUtils.isNullOrZero(naccumsettnum)) {
+				errstr.append("naccumsettnum,");
+			}
+
+			if (errstr.length() <= 0) {
+				return;
+			}
+
+			errstr.deleteCharAt(errstr.length() - 1);
+			ExceptionUtils.wrappBusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("4004000_0",
+					"04004000-0138", (String) null, new String[]{bodyvo.getCrowno(), errstr.toString()}));
+		}
+
+	}
+
+	protected void checkCanInster(AggregatedValueObject vo) {
+		super.checkCanInster(vo);
+		this.checkMny(vo);
+		this.checkRwite(vo);
+	}
+
+	protected void deleteVO(AggregatedValueObject vo) {
+		(new InvoiceDeleteAction()).delete(new InvoiceVO[]{(InvoiceVO) vo}, (InvoiceUIToBSEnv[]) null);
+	}
+
+	protected String getChildrenPkFiled() {
+		return "pk_invoice_b";
+	}
+
+	protected String getParentPkFiled() {
+		return "pk_invoice";
+	}
+
+	protected AggregatedValueObject insert(AggregatedValueObject vo) {
+		if (vo != null) {
+			this.checkCanInster(vo);
+		}
+		InvoiceHeaderVO orderHVO = (InvoiceHeaderVO) vo.getParentVO();
+		orderHVO.setFinvoicetype(0);
+		vo.setParentVO(orderHVO);
+		InvoiceVO  savedVos = (new InvoiceInsertAction()).insert(new InvoiceVO[]{(InvoiceVO) vo}, (InvoiceUIToBSEnv) null)[0];
+		
+		IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class); 
+		try {
+			 service.processAction(IPFActionName.APPROVE,
+				     "25", null, savedVos, null, null);
+			} catch (BusinessException e) {
+				// TODO ×Ô¶¯Éú³ÉµÄ catch ¿é
+				e.printStackTrace();
+			}
+		return savedVos;
+	}
+
+	protected AggregatedValueObject queryVOByPk(String voPk) {
+		BillQuery<InvoiceVO> billquery = new BillQuery(InvoiceVO.class);
+		InvoiceVO[] vos = (InvoiceVO[]) billquery.query(new String[]{voPk});
+		return ArrayUtils.isEmpty(vos) ? null : vos[0];
+	}
+
+	protected AggregatedValueObject update(AggregatedValueObject updatevo, AggregatedValueObject origVO) {
+		InvoiceUIToBSEnv env = new InvoiceUIToBSEnv();
+		InvoiceVO[] savedVos = (new InvoiceSaveBP(env)).save((InvoiceVO[]) null, new InvoiceVO[]{(InvoiceVO) updatevo},
+				new InvoiceVO[]{(InvoiceVO) origVO});
+		return savedVos[0];
+	}
+}

xh/so/src/private/nc/pubimpl/so/m30/pfxx/M30PfxxPlugin.java

@@ -1,62 +1,62 @@
-package nc.pubimpl.so.m30.pfxx;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import nc.bs.framework.common.NCLocator;
-import nc.impl.pubapp.pattern.data.bill.BillQuery;
-import nc.impl.pubapp.pattern.data.bill.tool.BillConcurrentTool;
-import nc.impl.pubapp.pattern.rule.IRule;
-import nc.impl.so.m30.action.main.InsertSaleOrderAction;
-import nc.impl.so.m30.action.main.UpdateSaleOrderAction;
-import nc.itf.uap.pf.IPFBusiAction;
-import nc.pubimpl.so.pfxx.AbstractSOPfxxPlugin;
-import nc.pubimpl.so.pfxx.check.BillFreeStatusCheckRule;
-import nc.pubimpl.so.pfxx.check.MnyTaxCheckRule;
-import nc.pubimpl.so.pfxx.check.WriteBackInfoCheckRule;
-import nc.vo.pub.AggregatedValueObject;
-import nc.vo.pub.BusinessException;
-import nc.vo.pub.pf.workflow.IPFActionName;
-import nc.vo.so.m30.entity.SaleOrderVO;
-
-public class M30PfxxPlugin extends AbstractSOPfxxPlugin {
-	public List<IRule<AggregatedValueObject>> getCheckers() {
-		List<IRule<AggregatedValueObject>> rules = new ArrayList();
-		rules.add(new BillFreeStatusCheckRule());
-		rules.add(new MnyTaxCheckRule("ntax", "nmny", "ntaxmny"));
-		rules.add(new WriteBackInfoCheckRule(new String[]{"ntotalsendnum", "ntotalinvoicenum", "ntotaloutnum",
-				"ntotalnotoutnum", "ntotalsignnum", "ntranslossnum", "ntotalrushnum", "ntotalestarnum", "ntotalarnum",
-				"ntotalcostnum", "ntotalestarmny", "ntotalarmny", "ntotalpaymny", "norigsubmny", "narrangescornum",
-				"narrangepoappnum", "narrangetoornum", "narrangetoappnum", "narrangemonum", "narrangeponum",
-				"ntotalplonum", "ntotalreturnnum", "ntotaltradenum"}));
-		return rules;
-	}
-
-	protected AggregatedValueObject insert(AggregatedValueObject vo) {
-		SaleOrderVO[] insertvo = new SaleOrderVO[]{(SaleOrderVO) vo};
-		InsertSaleOrderAction insertact = new InsertSaleOrderAction();
-		SaleOrderVO[] retvos = insertact.insert(insertvo);
-		
-	    //add by ZTH 销售订单审批
-	    IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
-	    try {
-			service.processAction(IPFActionName.APPROVE,
-			     "30", null, retvos[0], null, null);
-		} catch (BusinessException e) {
-			// TODO 自动生成的 catch 块
-			e.printStackTrace();
-		}
-		return null != retvos && retvos.length != 0 ? retvos[0] : null;
-	}
-
-	protected AggregatedValueObject update(AggregatedValueObject vo, String vopk) {
-		SaleOrderVO[] updatevo = new SaleOrderVO[]{(SaleOrderVO) vo};
-		BillQuery<SaleOrderVO> billquery = new BillQuery(SaleOrderVO.class);
-		SaleOrderVO[] origvos = (SaleOrderVO[]) billquery.query(new String[]{vopk});
-		BillConcurrentTool tool = new BillConcurrentTool();
-		tool.lockBill(origvos);
-		UpdateSaleOrderAction insertact = new UpdateSaleOrderAction();
-		SaleOrderVO[] retvos = insertact.update(updatevo, origvos);
-		return null != retvos && retvos.length != 0 ? retvos[0] : null;
-	}
+package nc.pubimpl.so.m30.pfxx;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import nc.bs.framework.common.InvocationInfoProxy;
+import nc.bs.framework.common.NCLocator;
+import nc.impl.pubapp.pattern.data.bill.BillQuery;
+import nc.impl.pubapp.pattern.data.bill.tool.BillConcurrentTool;
+import nc.impl.pubapp.pattern.rule.IRule;
+import nc.impl.so.m30.action.main.InsertSaleOrderAction;
+import nc.impl.so.m30.action.main.UpdateSaleOrderAction;
+import nc.itf.uap.pf.IPFBusiAction;
+import nc.pubimpl.so.pfxx.AbstractSOPfxxPlugin;
+import nc.pubimpl.so.pfxx.check.BillFreeStatusCheckRule;
+import nc.pubimpl.so.pfxx.check.MnyTaxCheckRule;
+import nc.pubimpl.so.pfxx.check.WriteBackInfoCheckRule;
+import nc.vo.pub.AggregatedValueObject;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.pf.workflow.IPFActionName;
+import nc.vo.so.m30.entity.SaleOrderVO;
+
+public class M30PfxxPlugin extends AbstractSOPfxxPlugin {
+	public List<IRule<AggregatedValueObject>> getCheckers() {
+		List<IRule<AggregatedValueObject>> rules = new ArrayList();
+		rules.add(new BillFreeStatusCheckRule());
+		rules.add(new MnyTaxCheckRule("ntax", "nmny", "ntaxmny"));
+		rules.add(new WriteBackInfoCheckRule(new String[]{"ntotalsendnum", "ntotalinvoicenum", "ntotaloutnum",
+				"ntotalnotoutnum", "ntotalsignnum", "ntranslossnum", "ntotalrushnum", "ntotalestarnum", "ntotalarnum",
+				"ntotalcostnum", "ntotalestarmny", "ntotalarmny", "ntotalpaymny", "norigsubmny", "narrangescornum",
+				"narrangepoappnum", "narrangetoornum", "narrangetoappnum", "narrangemonum", "narrangeponum",
+				"ntotalplonum", "ntotalreturnnum", "ntotaltradenum"}));
+		return rules;
+	}
+
+	protected AggregatedValueObject insert(AggregatedValueObject vo) {
+		SaleOrderVO[] insertvo = new SaleOrderVO[]{(SaleOrderVO) vo};
+		InsertSaleOrderAction insertact = new InsertSaleOrderAction();
+		SaleOrderVO[] retvos = insertact.insert(insertvo);
+		InvocationInfoProxy.getInstance().setUserId(vo.getParentVO().getAttributeValue("approver").toString());
+	    IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+	    try {
+			service.processAction(IPFActionName.APPROVE,
+			     "30", null, retvos[0], null, null);
+		} catch (BusinessException e) {
+			// TODO 自动生成的 catch 块
+			e.printStackTrace();
+		}
+		return null != retvos && retvos.length != 0 ? retvos[0] : null;
+	}
+
+	protected AggregatedValueObject update(AggregatedValueObject vo, String vopk) {
+		SaleOrderVO[] updatevo = new SaleOrderVO[]{(SaleOrderVO) vo};
+		BillQuery<SaleOrderVO> billquery = new BillQuery(SaleOrderVO.class);
+		SaleOrderVO[] origvos = (SaleOrderVO[]) billquery.query(new String[]{vopk});
+		BillConcurrentTool tool = new BillConcurrentTool();
+		tool.lockBill(origvos);
+		UpdateSaleOrderAction insertact = new UpdateSaleOrderAction();
+		SaleOrderVO[] retvos = insertact.update(updatevo, origvos);
+		return null != retvos && retvos.length != 0 ? retvos[0] : null;
+	}
 }

xh/xh/src/private/nc/bs/arap/plugin/ArapExpPfxxPlugin.java

@@ -13,6 +13,7 @@ import nc.itf.arap.initgatheringbill.IArapInitGatheringService;
 import nc.itf.arap.initpayablebill.IArapInitPayableService;
 import nc.itf.arap.initpaybill.IArapInitPaybillService;
 import nc.itf.arap.initreceivable.IArapInitRecService;
+import nc.itf.uap.pf.IPFBusiAction;
 import nc.itf.uap.pf.IPFConfig;
 import nc.md.persist.framework.MDPersistenceService;
 import nc.pubitf.accperiod.AccountCalendar;
@@ -35,9 +36,11 @@ import nc.vo.pub.BusinessException;
 import nc.vo.pub.BusinessRuntimeException;
 import nc.vo.pub.lang.UFDate;
 import nc.vo.pub.lang.UFDateTime;
+import nc.vo.pub.pf.workflow.IPFActionName;
 import nc.vo.pub.workflownote.WorkflownoteVO;
 import nc.vo.pubapp.pflow.PfUserObject;
 import nc.vo.pubapp.util.NCPfServiceUtils;
+
 import org.apache.commons.lang.StringUtils;
 
 public class ArapExpPfxxPlugin<T extends BaseAggVO> extends AbstractPfxxPlugin {
@@ -187,6 +190,9 @@ public class ArapExpPfxxPlugin<T extends BaseAggVO> extends AbstractPfxxPlugin {
 					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F1"),
 					bill.getHeadVO().getPk_billtype(), new AggPayableBillVO[]{(AggPayableBillVO) bill},
 					this.getUserObj(), new WorkflownoteVO())));
+			IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+			service.processAction(IPFActionName.APPROVE,
+	                "F1", null, res, null, null);
 		} else if (bill.getHeadVO().getPk_billtype().equals("F2")) {
 			res = (AggGatheringBillVO) ArrayUtil.getFirstInArrays((Object[]) ((Object[]) NCPfServiceUtils.processBatch(
 					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F2"),
@@ -197,6 +203,9 @@ public class ArapExpPfxxPlugin<T extends BaseAggVO> extends AbstractPfxxPlugin {
 					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F3"),
 					bill.getHeadVO().getPk_billtype(), new AggPayBillVO[]{(AggPayBillVO) bill}, this.getUserObj(),
 					new WorkflownoteVO())));
+			IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+			service.processAction(IPFActionName.APPROVE,
+	                "F3", null, res, null, null);
 		}
 
 		return (BaseAggVO) res;
@@ -211,12 +220,18 @@ public class ArapExpPfxxPlugin<T extends BaseAggVO> extends AbstractPfxxPlugin {
 		} else if (bill.getHeadVO().getPk_billtype().equals("F1")) {
 			res = ((IArapInitPayableService) NCLocator.getInstance().lookup(IArapInitPayableService.class))
 					.save((AggPayableBillVO) bill);
+			IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+			service.processAction(IPFActionName.APPROVE,
+	                "F1", null, res, null, null);
 		} else if (bill.getHeadVO().getPk_billtype().equals("F2")) {
 			res = ((IArapInitGatheringService) NCLocator.getInstance().lookup(IArapInitGatheringService.class))
 					.save((AggGatheringBillVO) bill);
 		} else if (bill.getHeadVO().getPk_billtype().equals("F3")) {
 			res = ((IArapInitPaybillService) NCLocator.getInstance().lookup(IArapInitPaybillService.class))
 					.save((AggPayBillVO) bill);
+			IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+			service.processAction(IPFActionName.APPROVE,
+	                "F3", null, res, null, null);
 		}
 
 		return res;