设置NC数据源工具类

ypff/ypff/src/private/nc/bs/yp/impl/DeliveryCloseImpl.java

@@ -15,6 +15,7 @@ import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.framework.server.ISecurityTokenCallback;
 import nc.bs.servlet.service.BaseServlet;
+import nc.bs.yp.plugin.DataSourceUtil;
 import nc.itf.so.m4331.IDeliveryAssitFunc;
 import nc.itf.uap.IUAPQueryBS;
 import nc.jdbc.framework.processor.ColumnProcessor;
@@ -27,6 +28,11 @@ import nc.vo.so.m4331.entity.DeliveryVO;
 import nc.vo.so.pub.SOParameterVO;
 import net.sf.json.JSONObject;
 
+/**
+ * 
+ * ·¢»õµ¥¹Ø±Õ
+ *
+ */
 public class DeliveryCloseImpl extends BaseServlet implements IHttpServletAdaptor{
 	
 	IUAPQueryBS iuap= (IUAPQueryBS) NCLocator.getInstance().lookup(IUAPQueryBS.class.getName());
@@ -36,10 +42,10 @@ public class DeliveryCloseImpl extends BaseServlet implements IHttpServletAdapto
 	@Override
 	public void doAction(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
 		// TODO Auto-generated method stub
-		InvocationInfoProxy.getInstance().setUserDataSource("sypnctest");
-		pk_group = this.qryGroup();
-		InvocationInfoProxy.getInstance().setGroupId(pk_group);
-		NCLocator.getInstance().lookup(ISecurityTokenCallback.class).token("NCSystem".getBytes(),"pfxx".getBytes());
+//		InvocationInfoProxy.getInstance().setUserDataSource("sypnctest");
+//		pk_group = this.qryGroup();
+//		InvocationInfoProxy.getInstance().setGroupId(pk_group);
+//		NCLocator.getInstance().lookup(ISecurityTokenCallback.class).token("NCSystem".getBytes(),"pfxx".getBytes());
 		String createStr = buildJson(req, resp, this.getClass().getName());
 		JSONObject json = JSONObject.fromObject(createStr);
 		String vbillcode = "";
@@ -47,6 +53,10 @@ public class DeliveryCloseImpl extends BaseServlet implements IHttpServletAdapto
 		PrintWriter out = resp.getWriter();
 		vbillcode = json.getString("vbillcode");
 		try {
+			DataSourceUtil.setDataSource();//ÉèÖÃÊý¾ÝÔ´
+			pk_group = this.qryGroup();
+			InvocationInfoProxy.getInstance().setGroupId(pk_group);
+			NCLocator.getInstance().lookup(ISecurityTokenCallback.class).token("NCSystem".getBytes(),"pfxx".getBytes());
 			checkJson(json);
 			String qrysql = "select cdeliveryid from so_delivery where nvl(dr,0)=0 and vbillcode = '"+vbillcode+"'";
 			cdeliveryid = iuap.executeQuery(qrysql, new ColumnProcessor());

ypff/ypff/src/private/nc/bs/yp/impl/ValidateMaintainImpl.java

@@ -13,6 +13,7 @@ import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.framework.common.NCLocator;
 import nc.bs.framework.server.ISecurityTokenCallback;
 import nc.bs.servlet.service.BaseServlet;
+import nc.bs.yp.plugin.DataSourceUtil;
 import nc.bs.yp.plugin.GetBaseDAOUtil;
 import nc.itf.ct.saledaily.ISaledailyApprove;
 import nc.itf.uap.pf.IPFBusiAction;
@@ -42,8 +43,9 @@ public class ValidateMaintainImpl extends BaseServlet implements IHttpServletAda
 	@Override
 	public void doAction(HttpServletRequest req, HttpServletResponse resp)
 			throws ServletException, IOException {
-		InvocationInfoProxy.getInstance().setUserDataSource("sypnctest");
+//		InvocationInfoProxy.getInstance().setUserDataSource("sypnctest");
 		try {
+			DataSourceUtil.setDataSource();//设置数据源
 			String createStr = buildJson(req, resp, this.getClass().getName());
 			JSONObject json = JSONObject.fromObject(createStr);
 			NcLog.info("销售合同生效JSON:"+json);

ypff/ypff/src/private/nc/bs/yp/plugin/DataSourceUtil.java

@@ -0,0 +1,47 @@
+package nc.bs.yp.plugin;
+
+import nc.bcmanage.bs.IBusiCenterManageService;
+import nc.bcmanage.vo.BusiCenterVO;
+import nc.bs.framework.common.InvocationInfoProxy;
+import nc.bs.framework.common.NCLocator;
+import nc.log.NcLog;
+import nc.vo.pub.BusinessException;
+
+public class DataSourceUtil {
+	
+	
+	
+	/**
+	 * 
+	 * 设置NC数据源
+	 * 
+	 */
+	public static void setDataSource() throws BusinessException{
+	   BusiCenterVO[] centerVOs = getBusiCenterVOs();
+	   if (centerVOs != null && centerVOs.length > 0) {
+	   // 设置数据源，默认只有一个账套
+	  InvocationInfoProxy.getInstance().setUserDataSource(
+	  centerVOs[0].getDataSourceName());//设置数据源----第一条数据
+	  NcLog.info("查询数据源名称为0:"+centerVOs[0].getDataSourceName());
+	  NcLog.info("查询数据源名称为1:"+centerVOs[1].getDataSourceName());
+     }
+   }
+	
+	
+
+	/**
+	 * 
+	 * 获取当前所有数据源
+	 * 
+	 */
+	
+	  private static BusiCenterVO[] getBusiCenterVOs() throws BusinessException{
+          IBusiCenterManageService service = NCLocator.getInstance().lookup(
+                      IBusiCenterManageService.class);
+       
+          BusiCenterVO[]   centerVOs = service.getBusiCenterVOs();
+       
+          return centerVOs;
+	  }
+
+}