XinYu_RZMES/.svn/pristine/27/27de4a2dc82081be2a8e10cf9e4c40a55f002eff.svn-base

package xin.glue.ui.G.G04;

import java.math.BigDecimal;
import java.sql.CallableStatement;
import java.sql.SQLException;

import org.apache.commons.lang.StringUtils;

import xin.glue.ui.common.component.PosSiteLog;

import com.posdata.glue.PosException;
import com.posdata.glue.biz.activity.PosActivity;
import com.posdata.glue.biz.constants.PosBizControlConstants;
import com.posdata.glue.biz.control.PosBizControlIF;
import com.posdata.glue.biz.control.PosBizProvider;
import com.posdata.glue.context.PosContext;
import com.posdata.glue.dao.vo.PosParameter;
import com.posdata.glue.dao.vo.PosRow;
import com.posdata.glue.dao.vo.PosRowSet;
import com.posdata.glue.msg.PosMESMessageImpl;
import com.posdata.glue.msg.PosMessage;

/*
 * 中厚板移送实绩登录与查询,从我方仓库取出板坯，发货到中厚板仓库
 * 这里涉及到多个表，所以自己写一个类
 * @author tangliang
 * @date 2008.11.05
 */

public class SavePltBlabNo extends PosActivity {
	public String runActivity(PosContext context) {
		// 从页面获取数据供插入和更新使用
		// 获得所选择的行数
		String[] status = (String[]) context.get("rowStuts");
		String[] hcrClf = (String[]) context.get("HCR_CLF");
		// 车辆号
		String[] PLT_TRS_CAR_NO = (String[]) context.get("PLT_TRS_CAR_NO");
		// 移送货单_前半部分_日期
		String[] PLT_TRS_INVOICE_NO = (String[]) context
				.get("PLT_TRS_INVOICE_NO");
		// 移送货单_后半部分_编号，移送货单需要把两个数据拼起来做为一个整体插入数据库
		String[] PLT_TRS_INVOICE_NO_MANUAL = (String[]) context
				.get("PLT_TRS_INVOICE_NO_MANUAL");
		// 目的地，前台手工录入的
		String[] PLT_PLANT_ARRV_LOC = (String[]) context.get("PLT_PLANT_ARRV_LOC");
		// 班次
		String[] PLT_TRS_WKSHIFT = (String[]) context.get("PLT_TRS_WKSHIFT");
		// 组
		String[] PLT_TRS_WKGROUP = (String[]) context.get("PLT_TRS_WKGROUP");
		// 登录人
		String[] PLT_TRS_EMP_ID = (String[]) context.get("PLT_TRS_EMP_ID");
		String[] PLT_TRS_EMP_NM = (String[]) context.get("PLT_TRS_EMP_NM");
		// 板坯号SLAB_NO
		String[] SLAB_NO = (String[]) context.get("SLAB_NO");
		// 移送时间PLT_TRS_DTIME
		String[] PLT_TRS_DTIME = (String[]) context.get("PLT_TRS_DTIME");
		// 选择项，如果选择响为Y的才让它更新数据库。在前台只要是点击过选择按钮的数据都会发到后台来
		String[] CHK = (String[]) context.get("CHK");
		// 从前台获取的，移送货单的值，这里的值肯定是存在的取的是选择项的
		String[] CUR_LOAD_LOC = (String[]) context.get("CUR_LOAD_LOC");
		// 炉次号
		String[] CHARGE_NO = (String[]) context.get("CHARGE_NO");
		// 外观等级
		String[] EXTSHAPE_GRD = (String[]) context.get("EXTSHAPE_GRD");
		// 成分等级
		String[] SLAB_INGR_DEC_GRD = (String[]) context
				.get("SLAB_INGR_DEC_GRD");
		// 瑕疵代码1
		String[] CRK_CD1 = (String[]) context.get("CRK_CD1");
		// 瑕疵代码2
		String[] CRK_CD2 = (String[]) context.get("CRK_CD2");
		// 瑕疵代码3
		String[] CRK_CD3 = (String[]) context.get("CRK_CD3");
		// 瑕疵代码4
		String[] CRK_CD4 = (String[]) context.get("CRK_CD4");
		// 合同号码
		String[] ORD_NO = (String[]) context.get("L2_SCH_NO");
		// 钢码
		String[] STL_GRD = (String[]) context.get("STL_GRD");
		// 板坯厚度
		String[] SLAB_THK = (String[]) context.get("SLAB_THK");
		// 板坯宽度
		String[] SLAB_WTH = (String[]) context.get("SLAB_WTH");
		// 板坯长度
		String[] SLAB_LEN = (String[]) context.get("SLAB_LEN");
		// 板坯重量
		String[] SLAB_WGT = (String[]) context.get("SLAB_WGT");
		//称重重量
		String[] WEIGHT_WGT = (String[])context.get("WEIGHT_WGT");
		
		String CC_DEVNO = "";
		CallableStatement cstm = null;

		// 该炉次所对应的中厚板厂的板坯号
		String[] dsnSlabNo = new String[SLAB_NO.length];
		PosParameter param = null;
		PosRow rnm = null;

		for (int i = 0; i < SLAB_NO.length; i++) {
			param = new PosParameter();

			param.setWhereClauseParameter(0, SLAB_NO[i]);
			PosRowSet rowSet = getDao("mesdao").find(
					"UIG040090_DSN_SLAB_NO.select", param);
			if (rowSet.hasNext()) {
				rnm = rowSet.next();
				dsnSlabNo[i] = (String) rnm.getAttribute("DSN_SLAB_NO");
			}
		}

		// 炉次对应的成份信息
		BigDecimal C = null;
		BigDecimal SI = null;
		BigDecimal MN = null;
		BigDecimal P = null;
		BigDecimal S = null;
		BigDecimal NI = null;
		BigDecimal CR = null;
		BigDecimal CU = null;
		BigDecimal TI = null;
		BigDecimal V = null;
		BigDecimal MO = null;
		BigDecimal B = null;
		BigDecimal W = null;
		BigDecimal AL = null;
		BigDecimal ALS = null;
		BigDecimal ALT = null;
		BigDecimal ZN = null;
		BigDecimal PB = null;
		BigDecimal SN = null;
		BigDecimal CA = null;
		BigDecimal LA = null;
		BigDecimal SB = null;
		BigDecimal CE = null;
		BigDecimal SE = null;
		BigDecimal MG = null;
		BigDecimal NB = null;
		BigDecimal O = null;
		BigDecimal N = null;
		BigDecimal H = null;
		BigDecimal FE = null;
		BigDecimal AS = null;
		BigDecimal XTZ = null;
		BigDecimal CD = null;
		BigDecimal CS = null;
		BigDecimal ZR = null;
		BigDecimal PSR = null;
		BigDecimal L2AS = null;
		BigDecimal BI = null;
		// 这里必须取选中的记录才有意义，所以选择项必须为Y
		// 这里在后台不好处理，所以放在前台，如果选中的项为空就给予提示不准许提交。还是默认取第一个
		// 在插入发送到中厚板的表时需要判断移送货单号是否存在，如果存在的话要给出提示。让插入失败
		String sql = "select TRS_INVOICE_NO from tbg04_slab_transf where STAT_CD = '0' AND TRS_INVOICE_NO = ? and SLAB_NO = ? ";

		// 把现在的货单号为条件放入查询语句中，如果可以查出结果说明货单号存在，如果查不出结果说明可以插入
		PosParameter param2 = new PosParameter();

		// 如果行数不为空
		if (status != null) {
			// 循环取出每一行的内容
			// 更新表TBG02_SLAB_COMM
			for (int i = 0; i < status.length; i++) {
				param2 = new PosParameter();
				param2.setWhereClauseParameter(0, PLT_TRS_INVOICE_NO[i]
						+ PLT_TRS_INVOICE_NO_MANUAL[i]);
				param2.setWhereClauseParameter(1, SLAB_NO[i]);

				PosRowSet rows = getDao("mesdao").findByQueryStatement(sql,
						param2);
				if (rows.hasNext()) {
					context.put("MESSAGES", " 移送货单号已经存在! ");
					return PosBizControlConstants.SUCCESS;
				}

				// 在后台判断，如果选择标识为Y的才可以进行相关的数据库操作
				if (CHK[i].equals("Y")) {
					// 取出需要发送中厚板的成分信息
					PosParameter param3 = new PosParameter();
					param3.setWhereClauseParameter(0,CHARGE_NO[i]);
					PosRowSet chemRows = getDao("mesdao").find(
							"UIG040090_05.select", param3);
					if(chemRows.hasNext()){
						PosRow chemRow = chemRows.next();
						CC_DEVNO = (String)chemRow.getAttribute("CC_DEVNO");
					}
					
					param3 = new PosParameter();
					param3.setWhereClauseParameter(0, CHARGE_NO[i]);

					// 成分数据对象为
					chemRows = getDao("mesdao").find(
							"UIG040090_03.select", param3);
					PosRow chemRow = null;

					// 如果炉次不存在成分的情况
					if (chemRows.hasNext()) {
						chemRow = chemRows.next();
						// 获取具体的成分信息
						C = (BigDecimal) chemRow.getAttribute("C");
						MN = (BigDecimal) chemRow.getAttribute("MN");
						S = (BigDecimal) chemRow.getAttribute("S");
						P = (BigDecimal) chemRow.getAttribute("P");
						SI = (BigDecimal) chemRow.getAttribute("SI");
						CR = (BigDecimal) chemRow.getAttribute("CR");
						NI = (BigDecimal) chemRow.getAttribute("NI");
						CU = (BigDecimal) chemRow.getAttribute("CU");
						MO = (BigDecimal) chemRow.getAttribute("MO");
						V = (BigDecimal) chemRow.getAttribute("V");

						TI = (BigDecimal) chemRow.getAttribute("TI");
						ALS = (BigDecimal) chemRow.getAttribute("ALS");
						ALT = (BigDecimal) chemRow.getAttribute("ALT");
						NB = (BigDecimal) chemRow.getAttribute("NB");
						AL = (BigDecimal) chemRow.getAttribute("AL");
						N = (BigDecimal) chemRow.getAttribute("N");
						AS = (BigDecimal) chemRow.getAttribute("AS");
						SN = (BigDecimal) chemRow.getAttribute("SN");
						CA = (BigDecimal) chemRow.getAttribute("CA");
						B = (BigDecimal) chemRow.getAttribute("B");

						PB = (BigDecimal) chemRow.getAttribute("PB");
						ZN = (BigDecimal) chemRow.getAttribute("ZN");
						XTZ = (BigDecimal) chemRow.getAttribute("XTZ");
						LA = (BigDecimal) chemRow.getAttribute("LA");
						SB = (BigDecimal) chemRow.getAttribute("SB");
						SE = (BigDecimal) chemRow.getAttribute("SE");
						MG = (BigDecimal) chemRow.getAttribute("MG");
						CD = (BigDecimal) chemRow.getAttribute("CD");
						O = (BigDecimal) chemRow.getAttribute("O");
						H = (BigDecimal) chemRow.getAttribute("H");

						FE = (BigDecimal) chemRow.getAttribute("FE");
						CS = (BigDecimal) chemRow.getAttribute("CS");
						ZR = (BigDecimal) chemRow.getAttribute("ZR");
						PSR = (BigDecimal) chemRow.getAttribute("PSR");
						W = (BigDecimal) chemRow.getAttribute("W");
						L2AS = (BigDecimal) chemRow.getAttribute("L2AS");
						BI = (BigDecimal) chemRow.getAttribute("BI");

						/*配重自动审核*/
						try
						{
							cstm	=	this.getDao("mesdao").getCallableStatement("WEIGHT_CHECK.CAL");
							cstm.setString(1, SLAB_NO[i]);
							cstm.registerOutParameter(2, java.sql.Types.VARCHAR);
							cstm.execute();
							String err = cstm.getString(2);
						}catch(Exception ex){
							ex.printStackTrace();
						}
						finally{
							if(cstm != null){
								try{						
									cstm.close();
								}catch(Exception e)
								{
									e.printStackTrace();
								}
							}
						}
						param2 = new PosParameter();
						param2.setWhereClauseParameter(0, SLAB_NO[i]);
         				PosRowSet SlabRows = getDao("mesdao").findByQueryStatement("SELECT NVL(WEIGHT_WGT*1000,0) WEIGHT_WGT FROM TBG02_SLAB_COMM T WHERE T.SLAB_NO = ?",param2);
         				if (SlabRows.hasNext()) {
         					PosRow slabRow = SlabRows.next();
         					WEIGHT_WGT[i] = ((BigDecimal)slabRow.getAttribute("WEIGHT_WGT")).intValue() + "";
         				}
						
						
						// 同时还需要把记录插入到发送中厚版工厂的表
						PosParameter param1 = new PosParameter();

						param1.setValueParamter(0, PLT_TRS_INVOICE_NO[i]
								+ PLT_TRS_INVOICE_NO_MANUAL[i]);
						param1.setValueParamter(1, PLT_TRS_CAR_NO[i]);
						param1.setValueParamter(2, SLAB_NO[i]);
						// param1.setValueParamter(3, PLT_TRS_DTIME[i]);
						param1.setValueParamter(3, PLT_PLANT_ARRV_LOC[i]);
						param1.setValueParamter(4, CHARGE_NO[i]);
						param1.setValueParamter(5, ORD_NO[i]);
						param1.setValueParamter(6, STL_GRD[i]);
						param1.setValueParamter(7, SLAB_THK[i]);
						param1.setValueParamter(8, SLAB_WTH[i]);
						param1.setValueParamter(9, SLAB_LEN[i]);
						if(StringUtils.isBlank(WEIGHT_WGT[i]) || "0".equals(WEIGHT_WGT[i]) || WEIGHT_WGT[i] == null){
							param1.setValueParamter(10, SLAB_WGT[i]);
						}else{
							param1.setValueParamter(10, WEIGHT_WGT[i]);
						}
						param1.setValueParamter(11, SLAB_INGR_DEC_GRD[i]);
						param1.setValueParamter(12, EXTSHAPE_GRD[i]);
						// 瑕疵代码是把编号和内容一起传过来的，这里分别截取相应的位置
						param1.setValueParamter(13,
								CRK_CD1[i].length() == 0 ? "" : CRK_CD1[i]
										.substring(0, 2));
						param1.setValueParamter(14,
								CRK_CD1[i].length() == 0 ? "" : CRK_CD1[i]
										.substring(2, CRK_CD1[i].length()));
						param1.setValueParamter(15,
								CRK_CD2[i].length() == 0 ? "" : CRK_CD2[i]
										.substring(0, 2));
						param1.setValueParamter(16,
								CRK_CD2[i].length() == 0 ? "" : CRK_CD2[i]
										.substring(2, CRK_CD2[i].length()));
						param1.setValueParamter(17,
								CRK_CD3[i].length() == 0 ? "" : CRK_CD3[i]
										.substring(0, 2));
						param1.setValueParamter(18,
								CRK_CD3[i].length() == 0 ? "" : CRK_CD3[i]
										.substring(2, CRK_CD3[i].length()));
						param1.setValueParamter(19,
								CRK_CD4[i].length() == 0 ? "" : CRK_CD4[i]
										.substring(0, 2));
						param1.setValueParamter(20,
								CRK_CD4[i].length() == 0 ? "" : CRK_CD4[i]
										.substring(2, CRK_CD4[i].length()));
						param1.setValueParamter(21, C);
						param1.setValueParamter(22, MN);
						param1.setValueParamter(23, S);
						param1.setValueParamter(24, P);
						param1.setValueParamter(25, SI);
						param1.setValueParamter(26, CR);
						param1.setValueParamter(27, NI);
						param1.setValueParamter(28, CU);
						param1.setValueParamter(29, MO);
						param1.setValueParamter(30, V);

						param1.setValueParamter(31, TI);
						param1.setValueParamter(32, ALS);
						param1.setValueParamter(33, ALT);
						param1.setValueParamter(34, NB);
						param1.setValueParamter(35, AL);
						param1.setValueParamter(36, N);
						param1.setValueParamter(37, AS);
						param1.setValueParamter(38, SN);
						param1.setValueParamter(39, CA);
						param1.setValueParamter(40, B);

						param1.setValueParamter(41, PB);
						param1.setValueParamter(42, ZN);
						param1.setValueParamter(43, XTZ);
						param1.setValueParamter(44, LA);
						param1.setValueParamter(45, SB);
						param1.setValueParamter(46, SE);
						param1.setValueParamter(47, MG);
						param1.setValueParamter(48, CD);
						param1.setValueParamter(49, O);
						param1.setValueParamter(50, H);

						param1.setValueParamter(51, FE);
						param1.setValueParamter(52, CS);
						param1.setValueParamter(53, ZR);
						param1.setValueParamter(54, PSR);
						param1.setValueParamter(55, W);

						param1.setValueParamter(56, hcrClf[i]);
						param1.setValueParamter(57, dsnSlabNo[i]);

						param1.setValueParamter(58, L2AS);
						param1.setValueParamter(59, BI);
						param1.setValueParamter(60, CC_DEVNO);
						getDao("mesdao").insert("UIG040090_01.insert", param1);

						// 打印日志

						PosSiteLog.writeLog(context, getDao("mesdao"),
								"UIG040090_01.insert", param1
										.getValueParameters());

						// 更新表TBG02_SLAB_COMM,这里不传入板坯瑕疵信息。板坯公共表的瑕疵信息字段可能在别的地方使用。

						PosParameter param0 = new PosParameter();

						param0.setWhereClauseParameter(0, PLT_TRS_CAR_NO[i]);
						param0.setWhereClauseParameter(1, PLT_TRS_INVOICE_NO[i] + PLT_TRS_INVOICE_NO_MANUAL[i]);
						param0.setWhereClauseParameter(2,PLT_PLANT_ARRV_LOC[i]);
						param0.setWhereClauseParameter(3, PLT_TRS_WKSHIFT[i]);
						param0.setWhereClauseParameter(4, PLT_TRS_WKGROUP[i]);
						param0.setWhereClauseParameter(5, PLT_TRS_EMP_ID[i]);
						param0.setWhereClauseParameter(6, SLAB_NO[i]);

						// 从维护的公共表查出数据,供更新页面使用
						getDao("mesdao").update("UIG040090_02.update", param0);

						param0 = new PosParameter();

						param0.setWhereClauseParameter(0, SLAB_NO[i]);
						getDao("mesdao").update("UIG040090_SLAB_YARD.update",
								param0);

						/*
						 * try { cstm =
						 * getDao("mesdao").getCallableStatement("UIG040090_01.CALL"
						 * ); cstm.setString(1, SLAB_NO[i]);
						 * cstm.registerOutParameter(2,
						 * java.sql.Types.VARBINARY); //cstm.execute();
						 * }catch(Exception ex) { ex.printStackTrace(); }
						 * finally { if(cstm != null) { try { cstm.close(); }
						 * catch(Exception e) { e.printStackTrace(); } } }
						 * 
						 * BigDecimal SlabWgt = new BigDecimal(SLAB_WGT[i]);
						 * 
						 * 
						 * //SendProg_NIE012070(SLAB_NO[i],"","","","","RGF","RGB"
						 * ,"TM",SlabWgt); //SendProg_NIE012080();
						 */
						// 打印日志

						PosSiteLog.writeLog(context, getDao("mesdao"),
								"UIG040090_01.update", param0
										.getValueParameters());
						
						/*财务数据上抛*/
						try{
							cstm	=	this.getDao("mesdao").getCallableStatement("UPLOAD_DATA.CAL");
							cstm.setString(1, SLAB_NO[i]);
							cstm.setString(2, "55A");
							cstm.setString(3, "N");
							cstm.setString(4, "板坯移送中厚板");
							cstm.setString(5, StringUtils.isBlank(PLT_TRS_EMP_NM[0])?"3qAdmin00":PLT_TRS_EMP_NM[0]);
							cstm.registerOutParameter(6, java.sql.Types.VARCHAR);
							cstm.execute();
							
							String err = cstm.getString(6);
							if(!org.apache.commons.lang.StringUtils.isBlank(cstm.getString(6))){
								context.put("MESSAGES","数据上传失败:" + err);
							}
						}catch (Exception e) {
							// TODO: handle exception
						}finally{
							if (cstm != null){
								try{
									cstm.close();
								}
								catch (SQLException e){
									logger.logWarn(e.getMessage(), e);
								}
							}
						}

					} else {
						logger.logDebug("UIG040090,查询tbb02_work_ingr表，炉次没有相应的成分信息！");
						String vtemp = " 缺少炉次成份信息 ！";
						context.put("MESSAGES", vtemp);
					}
				}
			}
		}
		return PosBizControlConstants.SUCCESS;
	}

	public PosContext SendProg_NIE012070(String MatNo, String sOrdNo,
			String sOrdSeq, String sBefOrdNo, String sBefOrdSeq,
			String sProgCd, String BefProcCd, String sKind, BigDecimal nwgt) {

		PosContext context = new PosContext();
		PosMessage message = new PosMESMessageImpl();

		String TcId = "NIE012070";

		message.setTCID(TcId);
		message.setObject("MSG_ID", TcId);
		message.setObject("BEF_ORD_NO", sBefOrdNo);
		message.setObject("BEF_ORD_SEQ", sBefOrdSeq);
		message.setObject("ORD_NO", sOrdNo);
		message.setObject("ORD_SEQ", sOrdSeq);
		message.setObject("BEF_PROG_CD", BefProcCd);
		message.setObject("PROG_CD", sProgCd);
		message.setObject("MAT_TYPE", sKind);
		message.setObject("MAT_NO", MatNo);
		message.setObject("WGT", nwgt);
		message.setObject("PGMID", "UIG040090");
		message.setObject("REG_ID", "UIG040090");
		message.setTCID(TcId);

		context.setMessage(message);

		// this.processComponent(PosConstants.CREATE_MESSAGE, context);
		// String transactionCode = context.getMessage().getTC();

		String SERVICE_POSTFIX = "-service";

		context
				.put(PosBizControlConstants.SERVICE_NAME, TcId
						+ SERVICE_POSTFIX);

		// context.setMessage(message);

		PosBizControlIF controller = PosBizProvider.getController();

		controller.doSubController(context, false);

		return null;
	}

	public String SendProg_NIE012080() {

		PosContext context = new PosContext();
		PosMessage message = new PosMESMessageImpl();

		String TcId = "NIE012080";

		message.setTCID(TcId);
		message.setObject("MSG_ID", TcId);
		message.setObject("AA", null);

		context.setMessage(message);
		message.setTCID(TcId);

		String SERVICE_POSTFIX = "-service";
		context
				.put(PosBizControlConstants.SERVICE_NAME, TcId
						+ SERVICE_POSTFIX);
		PosBizProvider.getController().doSubController(context, false);

		String SERVICE_ERR_MSG = (String) context.get("SERVICE_ERR_MSG");

		logger.logInfo("PosSaveSlabCutting SendProg_NIE012080 SERVICE_ERR_MSG:"
				+ SERVICE_ERR_MSG);

		if (SERVICE_ERR_MSG != null) {
			throw new PosException(SERVICE_ERR_MSG);
		}

		return null;
	}
}