XinYu_RZMES/.svn/pristine/93/9313c97b53e5abd63246b1bf46c0ad9edd61b587.svn-base

package xin.glue.ui.J.J01;

import java.io.ByteArrayOutputStream;
import java.io.PrintStream;
import java.sql.CallableStatement;

import xin.glue.cargocnHttpClient.WayBillClient;

import com.posdata.glue.biz.activity.PosActivity;
import com.posdata.glue.biz.constants.PosBizControlConstants;
import com.posdata.glue.context.PosContext;
import com.posdata.glue.dao.PosGenericDao;
/**
 * 明细发送结束的同时将明细数据保存到货运中国、铁前数据库中去
 * @author KangMiao
 * @Date 2015-5-8 下午04:48:31
 *
 */
public class SendCargocnOfCoils extends PosActivity {

	public String runActivity(PosContext context) {
		
        //车辆号加入
		String[] TRANS_CAR_NO    = (String[]) context.get("TRANS_CAR_NO");
		// 运输指示号
		String[] pDlivDirNo      = (String[]) context.get("DLIV_DIRNO");
		// 钢种牌号
		String[] SPEC_STL_GRD    = (String[]) context.get("SPEC_STL_GRD");
		// 重量
		String[] COIL_WGT        = (String[]) context.get("COIL_WGT");
		// 发货时间
		String[] TRNF_DTIME      = (String[]) context.get("TRNF_DTIME");
		// 收货单位
		String[] ORD_NM          = (String[]) context.get("ORD_NM");
		// 到站点
		String[] DEST_PCD_DESC   = (String[]) context.get("DEST_PCD_DESC");
		// 合同单位
		String[] CUST_NM         = (String[]) context.get("CUST_NM");
		// 运输公司
		String[] SHIP_COMP_CD    = (String[]) context.get("SHIP_COMP_CD");
		// 运输公司
		String[] SHIP_COMP_NM    = (String[]) context.get("SHIP_COMP_NM");
		// 钢卷号
		String[] OLD_SAMPL_NO    = (String[]) context.get("OLD_SAMPL_NO");
		// 产品名称
		String[] SM_CFNM         = (String[]) context.get("SM_CFNM");
		
		CallableStatement cstm = null;
		try{				
			cstm=getDao("mesdao").getCallableStatement("UIJ010060_03.CALL");

			cstm.setString(1, pDlivDirNo[0]);
			cstm.setString(2, "热轧线");
			cstm.setString(3, "");
			
			cstm.execute();
			}
			catch (Exception ex) {
				//System.out.println(pDlivDirNo[i] + "明细数据发送到铁前数据库执行失败UIJ010060_01.CALL**********");
				ByteArrayOutputStream baos = new ByteArrayOutputStream();  
				ex.printStackTrace(new PrintStream(baos));  
	            String exception = baos.toString(); 
	            String errStr = "\n异常原因：" + exception;
				logger.logInfo(pDlivDirNo[0] + "明细数据发送到铁前数据库执行失败UIJ010060_03.CALL；" + errStr);
				//ex.printStackTrace();
			} 
			if (cstm != null) {
				try {
					cstm.close();
				} catch (Exception e) {
				}
			}
		
		PosGenericDao dao = this.getDao("mesdao");
		//将发运信息直接发给物流跟踪平台系统
		WayBillClient wb = new WayBillClient();
		String retStr = wb.cargocnClientPost(pDlivDirNo, TRNF_DTIME, ORD_NM, DEST_PCD_DESC,COIL_WGT,CUST_NM,  
								SHIP_COMP_CD, TRANS_CAR_NO, OLD_SAMPL_NO, SPEC_STL_GRD, SM_CFNM,SHIP_COMP_NM,dao);
		context.put("returnInfoMsg", retStr);
		System.out.println("-----------" + retStr);
		return PosBizControlConstants.SUCCESS;
	}
}