设置线程时间

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

@@ -1,12 +1,15 @@
 package nc.bs.ic.general.plugins;
 
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
+import java.util.Date;
 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.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.ic.pub.env.ICBSContext;
 import nc.bs.logging.Logger;
@@ -70,6 +73,18 @@ public class GeneralDefdocPlugin extends AbstractPfxxPlugin {
 
     ICBillVO icbill = (ICBillVO) vo;
     icbill.getHead().setCgeneralhid(vopk);
+	try {
+		// 线程设置业务日期
+		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		Object dateTimeString  = icbill.getParentVO().getAttributeValue("dbilldate");
+		if(dateTimeString != null) {
+			Date date = format.parse(dateTimeString.toString());
+			long timestamp = date.getTime();
+			InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+		}
+	} catch (Exception e) {
+		throw new BusinessException("时间戳转换失败!");
+	}
 
     ICBillVO[] icbills = null;
     if (ValueUtils.getBoolean(swapContext.getReplace()))

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

@@ -0,0 +1,266 @@
+package nc.bs.ic.special.plugins;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+import nc.bs.framework.common.InvocationInfoProxy;
+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("保存新单据...");
+		try {
+			// 线程设置业务日期
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			Object dateTimeString  = icbill.getParentVO().getAttributeValue("dbilldate");
+			if(dateTimeString != null) {
+				Date date = format.parse(dateTimeString.toString());
+				long timestamp = date.getTime();
+				InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+			}
+		} catch (Exception e) {
+			throw new BusinessException("时间戳转换失败!");
+		}
+		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,8 +1,11 @@
 package nc.bs.sc.pfxx.plugin;
 
+import java.text.SimpleDateFormat;
+import java.util.Date;
 import java.util.HashMap;
 
 import nc.bs.ecn.eco.pf.PfParameterUtil;
+import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.logging.Logger;
 import nc.itf.sc.m61.ISCOrderMaintain;
@@ -65,6 +68,18 @@ public class SCorderPfxxPlugin extends nc.bs.pfxx.plugin.AbstractPfxxPlugin  {
  				scOrderItemVO.setStatus(2);
 			}
  			resvo.getParentVO().setStatus(2);
+ 			try {
+ 				// 线程设置业务日期
+ 				SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ 				Object dateTimeString  = resvo.getParentVO().getAttributeValue("dbilldate");
+ 				if(dateTimeString != null) {
+ 					Date date = format.parse(dateTimeString.toString());
+ 					long timestamp = date.getTime();
+ 					InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+ 				}
+ 			} catch (Exception e) {
+ 				throw new BusinessException("时间戳转换失败!");
+ 			}
  			ISCOrderMaintain is = NCLocator.getInstance().lookup(ISCOrderMaintain.class);
  			SCOrderVO[] scOrderVOs = is.save(new SCOrderVO[]{resvo},new SCOrderContxt(), null);
  			

xh/so/src/private/nc/bs/mmpac/pickm/pfxx/plugin/MMPacPickmPfxxPlugin.java

@@ -1,5 +1,9 @@
 package nc.bs.mmpac.pickm.pfxx.plugin;
 
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.pfxx.ISwapContext;
 import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
@@ -33,7 +37,18 @@ public class MMPacPickmPfxxPlugin extends AbstractPfxxPlugin {
 
         // 2.如果此单据没有导入过，那么准备保存新单据，保存单据前请进行必要的数据检查，并给出明确的业务异常...
         AggregatedValueObject returnVO = null;
-
+		try {
+			// 线程设置业务日期
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			Object dateTimeString  = resvo.getParentVO().getAttributeValue("dmakedate");
+			if(dateTimeString != null) {
+				Date date = format.parse(dateTimeString.toString());
+				long timestamp = date.getTime();
+				InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+			}
+		} catch (Exception e) {
+			throw new BusinessException("时间戳转换失败!");
+		}
         if (PubAppTool.isNull(vopk)) {
             resvo.getParentVO().setStatus(VOStatus.NEW);
             for (CircularlyAccessibleValueObject bvo : resvo.getChildrenVO()) {

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

@@ -1,5 +1,9 @@
 package nc.bs.mmpac.pmo.pfxx.plugin;
 
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.pfxx.ISwapContext;
 import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
@@ -37,7 +41,18 @@ public class MMpacPmoPfxxPlugin extends AbstractPfxxPlugin {
 				CircularlyAccessibleValueObject bvo = arr$[i$];
 				bvo.setStatus(2);
 			}
-
+			try {
+				// 线程设置业务日期
+				SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+				Object dateTimeString  = resvo.getParentVO().getAttributeValue("dbilldate");
+				if(dateTimeString != null) {
+					Date date = format.parse(dateTimeString.toString());
+					long timestamp = date.getTime();
+					InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+				}
+			} catch (Exception e) {
+				throw new BusinessException("时间戳转换失败!");
+			}
 			returnVO = this.getIPMOMaintainService().insert(new PMOAggVO[]{(PMOAggVO) resvo})[0];
 			// 保存审批  2022-11-08  yaoy  流程生产订单 
 			if(swapContext.getBilltype().equals("55A2")){

xh/so/src/private/nc/bs/mmpac/wr/pfxx/plugin/MMPacWrPfxxPlugin.java

@@ -1,5 +1,9 @@
 package nc.bs.mmpac.wr.pfxx.plugin;
 
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.pfxx.ISwapContext;
 import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
@@ -29,6 +33,18 @@ public class MMPacWrPfxxPlugin extends AbstractPfxxPlugin {
 	protected Object processBill(Object vo, ISwapContext swapContext, AggxsysregisterVO aggxsysvo)
 			throws BusinessException {
 		AggregatedValueObject resvo = (AggregatedValueObject) vo;
+		try {
+			// 线程设置业务日期
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			Object dateTimeString  = resvo.getParentVO().getAttributeValue("dbilldate");
+			if(dateTimeString != null) {
+				Date date = format.parse(dateTimeString.toString());
+				long timestamp = date.getTime();
+				InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+			}
+		} catch (Exception e) {
+			throw new BusinessException("时间戳转换失败!");
+		}
 		String vopk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(), swapContext.getDocID());
 		AggregatedValueObject returnVO = null;
 		IPFBusiAction iPFBusiAction = NCLocator.getInstance().lookup(IPFBusiAction.class);

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

@@ -1,8 +1,11 @@
 package nc.bs.pu.m21.pfxx;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 
 import nc.vo.pu.m21.entity.PayPlanVO;
+import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.pu.m21.maintain.OrderSaveBP;
 import nc.bs.pu.m21.maintain.rule.SupplierFrozeChkRule;
@@ -269,6 +272,20 @@ public class M21PfxxPlugin extends AbstractPuPfxxPlugin {
 			this.checkCanInster(vo);
 		}
 		OrderVO order = (OrderVO) vo;
+		
+		
+		try {
+			// Ïß³ÌÉèÖÃÒµÎñÈÕÆÚ
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			Object dateTimeString  = vo.getParentVO().getAttributeValue("dbilldate");
+			if(dateTimeString != null) {
+				Date date = format.parse(dateTimeString.toString());
+				long timestamp = date.getTime();
+				InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+			}
+		} catch (Exception e) {
+			ExceptionUtils.wrappException(e);
+		}
 		int status = order.getHVO().getForderstatus();
 		if (POEnumBillStatus.APPROVE.toInt() == status) {
 			OrderHeaderVO hvo = order.getHVO();

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

@@ -1,6 +1,7 @@
 package nc.bs.pu.m25.pfxx;
 
 import nc.bs.ecn.eco.pf.PfParameterUtil;
+import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.pu.m25.maintain.InvoiceSaveBP;
 import nc.impl.pu.m25.action.InvoiceDeleteAction;
@@ -25,6 +26,8 @@ import nc.vo.scmf.pub.util.BatchNCBaseTypeUtils;
 import nc.vo.scmpub.res.billtype.POBillType;
 import nc.vo.util.CloneUtil;
 
+import java.text.SimpleDateFormat;
+import java.util.Date;
 import java.util.HashMap;
 
 import org.apache.commons.lang.ArrayUtils;
@@ -115,6 +118,19 @@ public class M25PfxxPlugin extends AbstractPuPfxxPlugin {
 		if (vo != null) {
 			this.checkCanInster(vo);
 		}
+		
+		try {
+			// Ïß³ÌÉèÖÃÒµÎñÈÕÆÚ
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			Object dateTimeString  = vo.getParentVO().getAttributeValue("dbilldate");
+			if(dateTimeString != null) {
+				Date date = format.parse(dateTimeString.toString());
+				long timestamp = date.getTime();
+				InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+			}
+		} catch (Exception e) {
+			ExceptionUtils.wrappException(e);
+		}
 		InvoiceHeaderVO orderHVO = (InvoiceHeaderVO) vo.getParentVO();
 		orderHVO.setFinvoicetype(0);
 		vo.setParentVO(orderHVO);

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

@@ -1,6 +1,8 @@
 package nc.pubimpl.so.m30.pfxx;
 
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 
 import nc.bs.framework.common.InvocationInfoProxy;
@@ -36,6 +38,18 @@ public class M30PfxxPlugin extends AbstractSOPfxxPlugin {
 
 	protected AggregatedValueObject insert(AggregatedValueObject vo) {
 		SaleOrderVO[] insertvo = new SaleOrderVO[]{(SaleOrderVO) vo};
+		try {
+			// Ïß³ÌÉèÖÃÒµÎñÈÕÆÚ
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			Object dateTimeString  = vo.getParentVO().getAttributeValue("dbilldate");
+			if(dateTimeString != null) {
+				Date date = format.parse(dateTimeString.toString());
+				long timestamp = date.getTime();
+				InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+			}
+		} catch (Exception e) {
+			ExceptionUtils.wrappException(e);
+		}
 		InsertSaleOrderAction insertact = new InsertSaleOrderAction();
 		SaleOrderVO[] retvos = insertact.insert(insertvo);
 	    IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);

xh/so/src/private/nc/pubimpl/so/m32/pfxx/M32PfxxPlugin.java

@@ -2,6 +2,10 @@
 
 package nc.pubimpl.so.m32.pfxx;
 
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.itf.scmpub.reference.uap.pf.PfServiceScmUtil;
 import nc.itf.uap.pf.IPFBusiAction;
@@ -22,6 +26,19 @@ public class M32PfxxPlugin extends AbstractSOPfxxPlugin
 
     protected AggregatedValueObject insert(AggregatedValueObject vo)
     {
+		try {
+			// Ïß³ÌÉèÖÃÒµÎñÈÕÆÚ
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			Object dateTimeString  = vo.getParentVO().getAttributeValue("dbilldate");
+			if(dateTimeString != null) {
+				Date date = format.parse(dateTimeString.toString());
+				long timestamp = date.getTime();
+				InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+			}
+		} catch (Exception e) {
+			ExceptionUtils.wrappException(e);
+		}
+    	
         SaleInvoiceVO insertvo[] = {
             (SaleInvoiceVO)vo
         };

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

@@ -1,308 +1,324 @@
-package nc.bs.arap.plugin;
-
-import nc.bs.arap.bill.ArapBillPubUtil;
-import nc.bs.arap.util.ArapFlowUtil;
-import nc.bs.arap.util.ArapVOUtils;
-import nc.bs.arap.util.BillMoneyVUtils;
-import nc.bs.framework.common.InvocationInfoProxy;
-import nc.bs.framework.common.NCLocator;
-import nc.bs.pf.pub.PfDataCache;
-import nc.bs.pfxx.ISwapContext;
-import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
-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;
-import nc.pubitf.arap.bill.IArapBillPubService;
-import nc.vo.arap.basebill.BaseAggVO;
-import nc.vo.arap.basebill.BaseBillVO;
-import nc.vo.arap.basebill.BaseItemVO;
-import nc.vo.arap.gathering.AggGatheringBillVO;
-import nc.vo.arap.pay.AggPayBillVO;
-import nc.vo.arap.payable.AggPayableBillVO;
-import nc.vo.arap.pub.BillEnumCollection.BillSatus;
-import nc.vo.arap.pub.BillEnumCollection.FromSystem;
-import nc.vo.arap.pub.BillEnumCollection.InureSign;
-import nc.vo.arap.receivable.AggReceivableBillVO;
-import nc.vo.arap.utils.ArrayUtil;
-import nc.vo.ml.NCLangRes4VoTransl;
-import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
-import nc.vo.pfxx.util.PfxxPluginUtils;
-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 {
-	private PfUserObject[] userObjs;
-
-	protected Object processBill(Object vo, ISwapContext swapContext, AggxsysregisterVO aggxsysvo)
-			throws BusinessException {
-		BaseAggVO newBill = null;
-		BaseAggVO bill = (BaseAggVO) vo;
-		BaseBillVO head = this.setHeaderDefault(bill.getHeadVO());
-		if (head.getPk_billtype() == null) {
-			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0316"));
-		} else if (!head.getPk_billtype().equals("F0") && !head.getPk_billtype().equals("F1")
-				&& !head.getPk_billtype().equals("F2") && !head.getPk_billtype().equals("F3")) {
-			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0650"));
-		} else if (head.getPk_tradetype() == null) {
-			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0649"));
-		} else if (head.getPk_group() == null) {
-			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0317"));
-		} else if (head.getPk_org() == null) {
-			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0318"));
-		} else {
-			String pk;
-			try {
-				IPFConfig ipf = (IPFConfig) NCLocator.getInstance().lookup(IPFConfig.class);
-				if (!StringUtils.isEmpty(head.getPk_billtype()) && !StringUtils.isEmpty(head.getPk_tradetype())) {
-					if (head.getCreator() == null) {
-						head.setCreator(InvocationInfoProxy.getInstance().getUserId());
-					}
-
-					pk = ipf.retBusitypeCanStart(head.getPk_billtype(), head.getPk_tradetype(), head.getPk_org(),
-							head.getCreator());
-					if (pk == null) {
-						throw new BusinessException("busitype is null");
-					}
-
-					head.setPk_busitype(pk);
-				}
-			} catch (Exception var13) {
-				pk = NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0127") + head.getPk_tradetype()
-						+ NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0239")
-						+ head.getPk_tradetype()
-						+ NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0240");
-				throw new BusinessRuntimeException(pk);
-			}
-
-			if (head.getIsinit().booleanValue()) {
-				boolean isAr = ArapBillPubUtil.isARSysBilltype(head.getPk_billtype());
-				UFDate billdate = ArapBillPubUtil.getArapCreateDate(isAr, head.getPk_org());
-				if (null == billdate) {
-					throw new BusinessRuntimeException(
-							NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0007"));
-				}
-
-				if (head.getBilldate().after(billdate)) {
-					head.setBilldate(billdate);
-					BaseItemVO[] arr$ = (BaseItemVO[]) ((BaseItemVO[]) bill.getChildrenVO());
-					int len$ = arr$.length;
-
-					for (int i$ = 0; i$ < len$; ++i$) {
-						BaseItemVO item = arr$[i$];
-						item.setBilldate(billdate);
-					}
-				}
-			}
-
-			this.setBodyDefault(head, (BaseItemVO[]) ((BaseItemVO[]) bill.getChildrenVO()));
-			BillMoneyVUtils.sumBodyToHead(head, (BaseItemVO[]) ((BaseItemVO[]) bill.getChildrenVO()));
-			String oldPk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(),
-					swapContext.getDocID());
-			if (oldPk != null) {
-				if (swapContext.getReplace().equalsIgnoreCase("N")) {
-					throw new BusinessException(
-							NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0319"));
-				}
-
-				BaseAggVO preVO = null;
-				if (head.getPk_billtype().equals("F2")) {
-					preVO = (BaseAggVO) MDPersistenceService.lookupPersistenceQueryService()
-							.queryBillOfVOByPK(AggGatheringBillVO.class, oldPk, false);
-				} else if (head.getPk_billtype().equals("F3")) {
-					preVO = (BaseAggVO) MDPersistenceService.lookupPersistenceQueryService()
-							.queryBillOfVOByPK(AggPayBillVO.class, oldPk, false);
-				} else if (head.getPk_billtype().equals("F0")) {
-					preVO = (BaseAggVO) MDPersistenceService.lookupPersistenceQueryService()
-							.queryBillOfVOByPK(AggReceivableBillVO.class, oldPk, false);
-				} else if (head.getPk_billtype().equals("F1")) {
-					preVO = (BaseAggVO) MDPersistenceService.lookupPersistenceQueryService()
-							.queryBillOfVOByPK(AggPayableBillVO.class, oldPk, false);
-				}
-
-				if (preVO != null && preVO.getParentVO() != null) {
-					if (((BaseBillVO) preVO.getParentVO()).getBillstatus() == null) {
-						throw new BusinessException(
-								NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0320"));
-					}
-
-					if (((BaseBillVO) preVO.getParentVO()).getBillstatus() == BillSatus.Audit.VALUE) {
-						throw new BusinessException(
-								NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0321"));
-					}
-
-					if (head.getIsinit().booleanValue()) {
-						this.deleteInitBill(preVO);
-					} else {
-						((IArapBillPubService) NCLocator.getInstance().lookup(IArapBillPubService.class)).delete(preVO);
-					}
-				}
-			}
-
-			ArapExpPfxxValidater.getInstance().validate(bill);
-			ArapVOUtils.validateVoCopyRed(bill);
-			
-			if (!head.getPk_billtype().equals("F3")&&!head.getPk_billtype().equals("F2")) {
-				head.setBillno((String) null);
-			}
-			
-			if (head.getIsinit().booleanValue()) {
-				newBill = this.insertInitBill(bill);
-			} else {
-				newBill = this.insertBill(bill);
-			}
-
-			pk = null;
-			if (newBill != null) {
-				pk = newBill.getParent().getPrimaryKey();
-			}
-
-			if (oldPk != null) {
-				PfxxPluginUtils.deleteIDvsPKByDocPK(oldPk);
-			}
-
-			PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(), swapContext.getDocID(), pk);
-			return pk;
-		}
-	}
-
-	private BaseAggVO insertBill(BaseAggVO bill) throws BusinessException {
-		BaseAggVO res = null;
-		IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
-		if (bill.getHeadVO().getPk_billtype().equals("F0")) {
-			res = (AggReceivableBillVO) ArrayUtil.getFirstInArrays((Object[]) ((Object[]) NCPfServiceUtils.processBatch(
-					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F0"),
-					bill.getHeadVO().getPk_billtype(), new AggReceivableBillVO[]{(AggReceivableBillVO) bill},
-					this.getUserObj(), new WorkflownoteVO())));
-		} else if (bill.getHeadVO().getPk_billtype().equals("F1")) {
-			res = (AggPayableBillVO) ArrayUtil.getFirstInArrays((Object[]) ((Object[]) NCPfServiceUtils.processBatch(
-					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F1"),
-					bill.getHeadVO().getPk_billtype(), new AggPayableBillVO[]{(AggPayableBillVO) bill},
-					this.getUserObj(), new WorkflownoteVO())));
-			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"),
-					bill.getHeadVO().getPk_billtype(), new AggGatheringBillVO[]{(AggGatheringBillVO) bill},
-					this.getUserObj(), new WorkflownoteVO())));
-			service.processAction(IPFActionName.APPROVE,
-	                "F2", null, res, null, null);
-		} else if (bill.getHeadVO().getPk_billtype().equals("F3")) {
-			res = (AggPayBillVO) ArrayUtil.getFirstInArrays((Object[]) ((Object[]) NCPfServiceUtils.processBatch(
-					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F3"),
-					bill.getHeadVO().getPk_billtype(), new AggPayBillVO[]{(AggPayBillVO) bill}, this.getUserObj(),
-					new WorkflownoteVO())));
-			service.processAction(IPFActionName.APPROVE,
-	                "F3", null, res, null, null);
-		}
-
-		return (BaseAggVO) res;
-	}
-
-	@SuppressWarnings({ "unchecked", "rawtypes" })
-	private BaseAggVO insertInitBill(BaseAggVO bill) throws BusinessException {
-		BaseAggVO res = null;
-		IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
-		if (bill.getHeadVO().getPk_billtype().equals("F0")) {
-			res = ((IArapInitRecService) NCLocator.getInstance().lookup(IArapInitRecService.class))
-					.save((AggReceivableBillVO) bill);
-		} else if (bill.getHeadVO().getPk_billtype().equals("F1")) {
-			res = ((IArapInitPayableService) NCLocator.getInstance().lookup(IArapInitPayableService.class))
-					.save((AggPayableBillVO) bill);
-			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);
-			service.processAction(IPFActionName.APPROVE,
-	                "F2", null, res, null, null);
-		} else if (bill.getHeadVO().getPk_billtype().equals("F3")) {
-			res = ((IArapInitPaybillService) NCLocator.getInstance().lookup(IArapInitPaybillService.class))
-					.save((AggPayBillVO) bill);
-			
-			service.processAction(IPFActionName.APPROVE,
-	                "F3", null, res, null, null);
-		}
-
-		return res;
-	}
-
-	public PfUserObject[] getUserObj() {
-		if (this.userObjs == null) {
-			this.userObjs = new PfUserObject[]{new PfUserObject()};
-		}
-
-		return this.userObjs;
-	}
-
-	@SuppressWarnings({ "unchecked", "rawtypes" })
-	private void deleteInitBill(BaseAggVO bill) throws BusinessException {
-		if (bill.getHeadVO().getPk_billtype().equals("F0")) {
-			((IArapInitRecService) NCLocator.getInstance().lookup(IArapInitRecService.class))
-					.delete((AggReceivableBillVO) bill);
-		} else if (bill.getHeadVO().getPk_billtype().equals("F1")) {
-			((IArapInitPayableService) NCLocator.getInstance().lookup(IArapInitPayableService.class))
-					.delete((AggPayableBillVO) bill);
-		} else if (bill.getHeadVO().getPk_billtype().equals("F2")) {
-			((IArapInitGatheringService) NCLocator.getInstance().lookup(IArapInitGatheringService.class))
-					.delete((AggGatheringBillVO) bill);
-		} else if (bill.getHeadVO().getPk_billtype().equals("F3")) {
-			((IArapInitPaybillService) NCLocator.getInstance().lookup(IArapInitPaybillService.class))
-					.delete((AggPayBillVO) bill);
-		}
-
-	}
-
-	private BaseBillVO setHeaderDefault(BaseBillVO header) throws BusinessException {
-		Integer ZERO = 0;
-		header.setBillstatus(BillSatus.Save.VALUE);
-		header.setEffectstatus(InureSign.NOINURE.VALUE);
-		header.setDr(ZERO);
-		header.setSrc_syscode(FromSystem.WBJHPT.VALUE);
-		header.setCreationtime(new UFDateTime());
-		header.setCoordflag((Integer) null);
-
-		try {
-			AccountCalendar ac = AccountCalendar.getInstanceByPk_org(header.getPk_org());
-			ac.setDate(header.getBilldate());
-			header.setBillyear(ac.getYearVO().getPeriodyear());
-			header.setBillperiod(ac.getMonthVO().getAccperiodmth());
-		} catch (BusinessException var4) {
-			;
-		}
-
-		header.setPk_tradetypeid(
-				PfDataCache.getBillTypeInfo(header.getPk_group(), header.getPk_tradetype()).getPk_billtypeid());
-		return header;
-	}
-
-	void setBodyDefault(BaseBillVO head, BaseItemVO[] items) throws BusinessException {
-		int len = items == null ? 0 : items.length;
-
-		for (int i = 0; i < len; ++i) {
-			this.setBodyDefault(head, items[i]);
-		}
-
-	}
-
-	void setBodyDefault(BaseBillVO head, BaseItemVO item) throws BusinessException {
-		item.setPk_org(head.getPk_org());
-		item.setDr(0);
-		item.setPk_tradetypeid(
-				PfDataCache.getBillTypeInfo(head.getPk_group(), head.getPk_tradetype()).getPk_billtypeid());
-		item.setCoordflag((Integer) null);
-	}
+package nc.bs.arap.plugin;
+
+import nc.bs.arap.bill.ArapBillPubUtil;
+import nc.bs.arap.util.ArapFlowUtil;
+import nc.bs.arap.util.ArapVOUtils;
+import nc.bs.arap.util.BillMoneyVUtils;
+import nc.bs.framework.common.InvocationInfoProxy;
+import nc.bs.framework.common.NCLocator;
+import nc.bs.pf.pub.PfDataCache;
+import nc.bs.pfxx.ISwapContext;
+import nc.bs.pfxx.plugin.AbstractPfxxPlugin;
+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;
+import nc.pubitf.arap.bill.IArapBillPubService;
+import nc.vo.arap.basebill.BaseAggVO;
+import nc.vo.arap.basebill.BaseBillVO;
+import nc.vo.arap.basebill.BaseItemVO;
+import nc.vo.arap.gathering.AggGatheringBillVO;
+import nc.vo.arap.pay.AggPayBillVO;
+import nc.vo.arap.payable.AggPayableBillVO;
+import nc.vo.arap.pub.BillEnumCollection.BillSatus;
+import nc.vo.arap.pub.BillEnumCollection.FromSystem;
+import nc.vo.arap.pub.BillEnumCollection.InureSign;
+import nc.vo.arap.receivable.AggReceivableBillVO;
+import nc.vo.arap.utils.ArrayUtil;
+import nc.vo.ml.NCLangRes4VoTransl;
+import nc.vo.pfxx.auxiliary.AggxsysregisterVO;
+import nc.vo.pfxx.util.PfxxPluginUtils;
+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 java.text.SimpleDateFormat;
+import java.util.Date;
+
+import org.apache.commons.lang.StringUtils;
+
+public class ArapExpPfxxPlugin<T extends BaseAggVO> extends AbstractPfxxPlugin {
+	private PfUserObject[] userObjs;
+
+	protected Object processBill(Object vo, ISwapContext swapContext, AggxsysregisterVO aggxsysvo)
+			throws BusinessException {
+		BaseAggVO newBill = null;
+		BaseAggVO bill = (BaseAggVO) vo;
+		BaseBillVO head = this.setHeaderDefault(bill.getHeadVO());
+		
+		try {
+			// 线程设置业务日期
+			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			Object dateTimeString  = bill.getParentVO().getAttributeValue("billdate");
+			if(dateTimeString != null) {
+				Date date = format.parse(dateTimeString.toString());
+				long timestamp = date.getTime();
+				InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+			}
+		} catch (Exception e) {
+			throw new BusinessException("时间戳转换失败!");
+		}
+		if (head.getPk_billtype() == null) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0316"));
+		} else if (!head.getPk_billtype().equals("F0") && !head.getPk_billtype().equals("F1")
+				&& !head.getPk_billtype().equals("F2") && !head.getPk_billtype().equals("F3")) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0650"));
+		} else if (head.getPk_tradetype() == null) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0649"));
+		} else if (head.getPk_group() == null) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0317"));
+		} else if (head.getPk_org() == null) {
+			throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0318"));
+		} else {
+			String pk;
+			try {
+				IPFConfig ipf = (IPFConfig) NCLocator.getInstance().lookup(IPFConfig.class);
+				if (!StringUtils.isEmpty(head.getPk_billtype()) && !StringUtils.isEmpty(head.getPk_tradetype())) {
+					if (head.getCreator() == null) {
+						head.setCreator(InvocationInfoProxy.getInstance().getUserId());
+					}
+
+					pk = ipf.retBusitypeCanStart(head.getPk_billtype(), head.getPk_tradetype(), head.getPk_org(),
+							head.getCreator());
+					if (pk == null) {
+						throw new BusinessException("busitype is null");
+					}
+
+					head.setPk_busitype(pk);
+				}
+			} catch (Exception var13) {
+				pk = NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0127") + head.getPk_tradetype()
+						+ NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0239")
+						+ head.getPk_tradetype()
+						+ NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0240");
+				throw new BusinessRuntimeException(pk);
+			}
+
+			if (head.getIsinit().booleanValue()) {
+				boolean isAr = ArapBillPubUtil.isARSysBilltype(head.getPk_billtype());
+				UFDate billdate = ArapBillPubUtil.getArapCreateDate(isAr, head.getPk_org());
+				if (null == billdate) {
+					throw new BusinessRuntimeException(
+							NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0007"));
+				}
+
+				if (head.getBilldate().after(billdate)) {
+					head.setBilldate(billdate);
+					BaseItemVO[] arr$ = (BaseItemVO[]) ((BaseItemVO[]) bill.getChildrenVO());
+					int len$ = arr$.length;
+
+					for (int i$ = 0; i$ < len$; ++i$) {
+						BaseItemVO item = arr$[i$];
+						item.setBilldate(billdate);
+					}
+				}
+			}
+
+			this.setBodyDefault(head, (BaseItemVO[]) ((BaseItemVO[]) bill.getChildrenVO()));
+			BillMoneyVUtils.sumBodyToHead(head, (BaseItemVO[]) ((BaseItemVO[]) bill.getChildrenVO()));
+			String oldPk = PfxxPluginUtils.queryBillPKBeforeSaveOrUpdate(swapContext.getBilltype(),
+					swapContext.getDocID());
+			if (oldPk != null) {
+				if (swapContext.getReplace().equalsIgnoreCase("N")) {
+					throw new BusinessException(
+							NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0319"));
+				}
+
+				BaseAggVO preVO = null;
+				if (head.getPk_billtype().equals("F2")) {
+					preVO = (BaseAggVO) MDPersistenceService.lookupPersistenceQueryService()
+							.queryBillOfVOByPK(AggGatheringBillVO.class, oldPk, false);
+				} else if (head.getPk_billtype().equals("F3")) {
+					preVO = (BaseAggVO) MDPersistenceService.lookupPersistenceQueryService()
+							.queryBillOfVOByPK(AggPayBillVO.class, oldPk, false);
+				} else if (head.getPk_billtype().equals("F0")) {
+					preVO = (BaseAggVO) MDPersistenceService.lookupPersistenceQueryService()
+							.queryBillOfVOByPK(AggReceivableBillVO.class, oldPk, false);
+				} else if (head.getPk_billtype().equals("F1")) {
+					preVO = (BaseAggVO) MDPersistenceService.lookupPersistenceQueryService()
+							.queryBillOfVOByPK(AggPayableBillVO.class, oldPk, false);
+				}
+
+				if (preVO != null && preVO.getParentVO() != null) {
+					if (((BaseBillVO) preVO.getParentVO()).getBillstatus() == null) {
+						throw new BusinessException(
+								NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0320"));
+					}
+
+					if (((BaseBillVO) preVO.getParentVO()).getBillstatus() == BillSatus.Audit.VALUE) {
+						throw new BusinessException(
+								NCLangRes4VoTransl.getNCLangRes().getStrByID("2006pub_0", "02006pub-0321"));
+					}
+
+					if (head.getIsinit().booleanValue()) {
+						this.deleteInitBill(preVO);
+					} else {
+						((IArapBillPubService) NCLocator.getInstance().lookup(IArapBillPubService.class)).delete(preVO);
+					}
+				}
+			}
+
+			ArapExpPfxxValidater.getInstance().validate(bill);
+			ArapVOUtils.validateVoCopyRed(bill);
+			
+			if (!head.getPk_billtype().equals("F3")&&!head.getPk_billtype().equals("F2")) {
+				head.setBillno((String) null);
+			}
+			
+			if (head.getIsinit().booleanValue()) {
+				newBill = this.insertInitBill(bill);
+			} else {
+				newBill = this.insertBill(bill);
+			}
+
+			pk = null;
+			if (newBill != null) {
+				pk = newBill.getParent().getPrimaryKey();
+			}
+
+			if (oldPk != null) {
+				PfxxPluginUtils.deleteIDvsPKByDocPK(oldPk);
+			}
+
+			PfxxPluginUtils.addDocIDVsPKContrast(swapContext.getBilltype(), swapContext.getDocID(), pk);
+			return pk;
+		}
+	}
+
+	private BaseAggVO insertBill(BaseAggVO bill) throws BusinessException {
+		BaseAggVO res = null;
+		IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+		if (bill.getHeadVO().getPk_billtype().equals("F0")) {
+			res = (AggReceivableBillVO) ArrayUtil.getFirstInArrays((Object[]) ((Object[]) NCPfServiceUtils.processBatch(
+					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F0"),
+					bill.getHeadVO().getPk_billtype(), new AggReceivableBillVO[]{(AggReceivableBillVO) bill},
+					this.getUserObj(), new WorkflownoteVO())));
+		} else if (bill.getHeadVO().getPk_billtype().equals("F1")) {
+			res = (AggPayableBillVO) ArrayUtil.getFirstInArrays((Object[]) ((Object[]) NCPfServiceUtils.processBatch(
+					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F1"),
+					bill.getHeadVO().getPk_billtype(), new AggPayableBillVO[]{(AggPayableBillVO) bill},
+					this.getUserObj(), new WorkflownoteVO())));
+			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"),
+					bill.getHeadVO().getPk_billtype(), new AggGatheringBillVO[]{(AggGatheringBillVO) bill},
+					this.getUserObj(), new WorkflownoteVO())));
+			service.processAction(IPFActionName.APPROVE,
+	                "F2", null, res, null, null);
+		} else if (bill.getHeadVO().getPk_billtype().equals("F3")) {
+			res = (AggPayBillVO) ArrayUtil.getFirstInArrays((Object[]) ((Object[]) NCPfServiceUtils.processBatch(
+					ArapFlowUtil.getCommitActionCode(bill.getHeadVO().getPk_org(), "F3"),
+					bill.getHeadVO().getPk_billtype(), new AggPayBillVO[]{(AggPayBillVO) bill}, this.getUserObj(),
+					new WorkflownoteVO())));
+			service.processAction(IPFActionName.APPROVE,
+	                "F3", null, res, null, null);
+		}
+
+		return (BaseAggVO) res;
+	}
+
+	@SuppressWarnings({ "unchecked", "rawtypes" })
+	private BaseAggVO insertInitBill(BaseAggVO bill) throws BusinessException {
+		BaseAggVO res = null;
+		IPFBusiAction service = NCLocator.getInstance().lookup(IPFBusiAction.class);
+		if (bill.getHeadVO().getPk_billtype().equals("F0")) {
+			res = ((IArapInitRecService) NCLocator.getInstance().lookup(IArapInitRecService.class))
+					.save((AggReceivableBillVO) bill);
+		} else if (bill.getHeadVO().getPk_billtype().equals("F1")) {
+			res = ((IArapInitPayableService) NCLocator.getInstance().lookup(IArapInitPayableService.class))
+					.save((AggPayableBillVO) bill);
+			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);
+			service.processAction(IPFActionName.APPROVE,
+	                "F2", null, res, null, null);
+		} else if (bill.getHeadVO().getPk_billtype().equals("F3")) {
+			res = ((IArapInitPaybillService) NCLocator.getInstance().lookup(IArapInitPaybillService.class))
+					.save((AggPayBillVO) bill);
+			
+			service.processAction(IPFActionName.APPROVE,
+	                "F3", null, res, null, null);
+		}
+
+		return res;
+	}
+
+	public PfUserObject[] getUserObj() {
+		if (this.userObjs == null) {
+			this.userObjs = new PfUserObject[]{new PfUserObject()};
+		}
+
+		return this.userObjs;
+	}
+
+	@SuppressWarnings({ "unchecked", "rawtypes" })
+	private void deleteInitBill(BaseAggVO bill) throws BusinessException {
+		if (bill.getHeadVO().getPk_billtype().equals("F0")) {
+			((IArapInitRecService) NCLocator.getInstance().lookup(IArapInitRecService.class))
+					.delete((AggReceivableBillVO) bill);
+		} else if (bill.getHeadVO().getPk_billtype().equals("F1")) {
+			((IArapInitPayableService) NCLocator.getInstance().lookup(IArapInitPayableService.class))
+					.delete((AggPayableBillVO) bill);
+		} else if (bill.getHeadVO().getPk_billtype().equals("F2")) {
+			((IArapInitGatheringService) NCLocator.getInstance().lookup(IArapInitGatheringService.class))
+					.delete((AggGatheringBillVO) bill);
+		} else if (bill.getHeadVO().getPk_billtype().equals("F3")) {
+			((IArapInitPaybillService) NCLocator.getInstance().lookup(IArapInitPaybillService.class))
+					.delete((AggPayBillVO) bill);
+		}
+
+	}
+
+	private BaseBillVO setHeaderDefault(BaseBillVO header) throws BusinessException {
+		Integer ZERO = 0;
+		header.setBillstatus(BillSatus.Save.VALUE);
+		header.setEffectstatus(InureSign.NOINURE.VALUE);
+		header.setDr(ZERO);
+		//header.setSrc_syscode(FromSystem.WBJHPT.VALUE);
+		header.setCreationtime(new UFDateTime());
+		header.setCoordflag((Integer) null);
+
+		try {
+			AccountCalendar ac = AccountCalendar.getInstanceByPk_org(header.getPk_org());
+			ac.setDate(header.getBilldate());
+			header.setBillyear(ac.getYearVO().getPeriodyear());
+			header.setBillperiod(ac.getMonthVO().getAccperiodmth());
+		} catch (BusinessException var4) {
+			;
+		}
+
+		header.setPk_tradetypeid(
+				PfDataCache.getBillTypeInfo(header.getPk_group(), header.getPk_tradetype()).getPk_billtypeid());
+		return header;
+	}
+
+	void setBodyDefault(BaseBillVO head, BaseItemVO[] items) throws BusinessException {
+		int len = items == null ? 0 : items.length;
+
+		for (int i = 0; i < len; ++i) {
+			this.setBodyDefault(head, items[i]);
+		}
+
+	}
+
+	void setBodyDefault(BaseBillVO head, BaseItemVO item) throws BusinessException {
+		item.setPk_org(head.getPk_org());
+		item.setDr(0);
+		item.setPk_tradetypeid(
+				PfDataCache.getBillTypeInfo(head.getPk_group(), head.getPk_tradetype()).getPk_billtypeid());
+		item.setCoordflag((Integer) null);
+	}
 }

xh/xh/src/private/nc/bs/xh/impl/TransformAddImpl.java

@@ -3,6 +3,8 @@ package nc.bs.xh.impl;
 import java.io.IOException;
 import java.io.PrintWriter;
 import java.io.StringWriter;
+import java.text.SimpleDateFormat;
+import java.util.Date;
 import java.util.HashMap;
 
 import javax.servlet.ServletException;
@@ -52,8 +54,18 @@ public class TransformAddImpl extends BaseServlet implements IHttpServletAdaptor
 			PrintWriter out = resp.getWriter();
 			vbillcode = json.getString("vbillcode");
 			checkJson(json);//非空判断
-			
-			
+			try {
+				// 线程设置业务日期
+				SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+				Object dateTimeString  = json.getString("dbilldate");
+				if(dateTimeString != null) {
+					Date date = format.parse(dateTimeString.toString());
+					long timestamp = date.getTime();
+					InvocationInfoProxy.getInstance().setBizDateTime(timestamp);
+				}
+			} catch (Exception e) {
+				throw new BusinessException("时间戳转换失败!");
+			}
 			InvocationInfoProxy.getInstance().setGroupId(SqlexecuteQuery("pk_group", "org_group", "code", json.getString("pk_group")));
 			InvocationInfoProxy.getInstance().setUserId(SqlexecuteQuery("cuserid", "sm_user", "user_code", json.getString("creator")));