Modified by pcy 销售订单、销售发票抛异常

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

@@ -1,61 +1,56 @@
-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);
-	    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) throws BusinessException {
+		SaleOrderVO[] insertvo = new SaleOrderVO[]{(SaleOrderVO) vo};
+		InsertSaleOrderAction insertact = new InsertSaleOrderAction();
+		SaleOrderVO[] retvos = insertact.insert(insertvo);
+	    IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+	    service.processAction(IPFActionName.APPROVE,
+			     "30", null, retvos[0], null, null);
+		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/so/src/private/nc/pubimpl/so/m32/pfxx/M32PfxxPlugin.java

@@ -19,21 +19,15 @@ public class M32PfxxPlugin extends AbstractSOPfxxPlugin
     {
     }
 
-    protected AggregatedValueObject insert(AggregatedValueObject vo)
+    protected AggregatedValueObject insert(AggregatedValueObject vo) throws BusinessException
     {
         SaleInvoiceVO insertvo[] = {
             (SaleInvoiceVO)vo
         };
         SaleInvoiceVO retvos[] = (SaleInvoiceVO[])(SaleInvoiceVO[])PfServiceScmUtil.processBatch("WRITE", SOBillType.Invoice.getCode(), insertvo, null, null);
         IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
-        try {
-			service.processAction(IPFActionName.APPROVE,
-			        "F3", null, retvos[0], null, null);
-		} catch (BusinessException e) {
-			// TODO ×Ô¶¯Éú³ÉµÄ catch ¿é
-			e.printStackTrace();
-			return null;
-		}
+        service.processAction(IPFActionName.APPROVE,
+		        "F3", null, retvos[0], null, null);
 		if(null == retvos || retvos.length == 0)
             return null;
         else

xh/so/src/public/nc/pubimpl/so/pfxx/AbstractSOPfxxPlugin.java

@@ -0,0 +1,84 @@
+/*jadclipse*/// Decompiled by Jad v1.5.8g. Copyright 2001 Pavel Kouznetsov.
+
+package nc.pubimpl.so.pfxx;
+
+import java.util.Iterator;
+import java.util.List;
+import nc.bs.pfxx.ISwapContext;
+import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
+import nc.impl.pubapp.pattern.rule.IRule;
+import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
+import nc.vo.pfxx.util.PfxxPluginUtils;
+import nc.vo.pub.*;
+import nc.vo.pubapp.pattern.pub.PubAppTool;
+
+public abstract class AbstractSOPfxxPlugin extends AbstractPfxxPlugin
+{
+
+    public AbstractSOPfxxPlugin()
+    {
+    }
+
+    public List getCheckers()
+    {
+        return checkers;
+    }
+
+    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;
+        checkBill(resvo);
+        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 = insert(resvo);
+        } else
+        {
+            returnVO = update(resvo, vopk);
+        }
+        vopk = returnVO.getParentVO().getPrimaryKey();
+        PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(), swapContext.getDocID(), vopk);
+        return vopk;
+    }
+
+    protected abstract AggregatedValueObject insert(AggregatedValueObject aggregatedvalueobject) throws BusinessException;
+
+    protected abstract AggregatedValueObject update(AggregatedValueObject aggregatedvalueobject, String s);
+
+    private void checkBill(AggregatedValueObject vo)
+    {
+        if(getCheckers() != null)
+        {
+            IRule checker;
+            for(Iterator i$ = getCheckers().iterator(); i$.hasNext(); checker.process(new AggregatedValueObject[] {
+    vo
+}))
+                checker = (IRule)i$.next();
+
+        }
+    }
+
+    private List checkers;
+}
+
+
+/*
+	DECOMPILATION REPORT
+
+	Decompiled from: D:\xinhe\homebak\NC65\modules\so\lib\pubso_pub.jar
+	Total time: 18 ms
+	Jad reported messages/errors:
+	Exit status: 0
+	Caught exceptions:
+*/