XinYu_RZMES/.svn/pristine/47/4716fc107acf73ae978051bea065d13c2e2ae544.svn-base

package xin.glue.ui.H.H05;

import java.math.BigDecimal;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

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.vo.PosParameter;
import com.posdata.glue.dao.vo.PosRow;
import com.posdata.glue.dao.vo.PosRowSet;

public class saveCoilResult extends PosActivity{
	public String runActivity(PosContext context){
		//行状态
		String[] rowStuts = (String[]) context.get("rowStuts");
		//选择项目
		String[] CHK = (String[]) context.get("CHK");
		//钢卷号
		String[] OLD_SAMPL_NO = (String[]) context.get("OLD_SAMPL_NO");
		//生产流水号
		String[] COIL_NO = (String[]) context.get("COIL_NO");
		//炉号
		String[] CHARE_NO = (String[]) context.get("CHARE_NO");
		//标准牌号
		String[] SPEC_STL_GRD = (String[]) context.get("SPEC_STL_GRD");
		//订单号
		String[] ORD_NO = (String[]) context.get("ORD_NO");
		//钢卷重量
		String[] ACT_WGT = (String[]) context.get("ACT_WGT");
		//钢卷规格
		String[] THK_WTH = (String[]) context.get("THK_WTH");
		//生产日期
		String[] MILL_DTIME = (String[]) context.get("MILL_DTIME");
		//标准信息
		String[] SPEC_ABBSYM = (String[]) context.get("SPEC_ABBSYM");
		//检验员
		String[] CHECKER_ID = (String[]) context.get("CHECKER_ID");
		//修改后牌号
		String[] LICENSE_NO = (String[]) context.get("LICENSE_NO");
		//许可证标识
		String[] LICENSE_MARK = (String[]) context.get("LICENSE_MARK");
		//打印备注,使用的是预留字段1
		String[] COIL_MARK_RESVER = (String[]) context.get("COIL_MARK_RESVER");
		//操作人
		String[] REG_ID = (String[]) context.get("REG_ID");
		//发运指示号
		String[] DLIV_DIRNO = (String[]) context.get("DLIV_DIRNO");
		//打印页数，新增的数据项目。只添加到打印接口表，使用打印接口表的预留字段2
		String[] COIL_PAGES = (String[]) context.get("COIL_PAGES");
		String[] CHANGE_SPEC_STL_GRD=(String[])context.get("CHANGE_SPEC_STL_GRD");//更改后的牌号
		
		String LICENSE_NO_Auto = "";
		
		
		
		//为了防止空指针异常
		if(rowStuts != null){
			//循环所有的结果，一个一个的录入表中
			for(int i=0;i<rowStuts.length;i++){
				if(CHK[i].equals("Y")){
					//火运和汽运的情况分看来考虑
					PosParameter param0 = new PosParameter();
					param0.setWhereClauseParameter(0,DLIV_DIRNO[i]);
					
					PosRowSet rows0 = getDao("mesdao").find("UIH050500_03.select", param0);
					
					String DLIV_TP = null;
					
					PosParameter paramA = new PosParameter();
					paramA.setWhereClauseParameter(0,ORD_NO[i]);					
					PosRowSet rowsA = getDao("mesdao").find("UIH050500_05.select", paramA);					
					if(rowsA.hasNext()){
						PosRow rowA = rowsA.next();
						LICENSE_NO_Auto = rowA.getAttribute("LICENSE_NO") != null ? rowA.getAttribute("LICENSE_NO").toString():"";
					}
					
					if(rows0.hasNext()){
						PosRow row0 = rows0.next();
						
						DLIV_TP = (String) row0.getAttribute("DLIV_TP");
						
						if(null != DLIV_TP && DLIV_TP.equals("T")){
							PosParameter param1 = new PosParameter();
							param1.setWhereClauseParameter(0,OLD_SAMPL_NO[i]);
							
							PosRowSet rows = getDao("mesdao").find("UIH050500_04.select", param1);
							
							if(rows.hasNext()){
								//这里需要取出修改前的重量，记录备注
								PosRow row = rows.next();
								BigDecimal ACT_WGT_HIS = (BigDecimal) row.getAttribute("ACT_WGT");
								logger.logDebug("saveCoilResult 里面，获取修改前的重量："+ACT_WGT_HIS);
											
								//进行更新操作
								PosParameter param2 = new PosParameter();
								//这里只允许更新系统没有的数据
//								param2.setWhereClauseParameter(0, COIL_NO[i]);
//								param2.setWhereClauseParameter(1, CHARE_NO[i]);
//								param2.setWhereClauseParameter(2, SPEC_STL_GRD[i]);
//								param2.setWhereClauseParameter(3, ORD_NO[i]);
//								param2.setWhereClauseParameter(4, ACT_WGT[i]);
//								param2.setWhereClauseParameter(5, THK_WTH[i]);
//								param2.setWhereClauseParameter(6, MILL_DTIME[i]);
//								param2.setWhereClauseParameter(7, SPEC_ABBSYM[i]);
								param2.setWhereClauseParameter(0, CHANGE_SPEC_STL_GRD[i]);
								param2.setWhereClauseParameter(1, CHECKER_ID[i]);
								param2.setWhereClauseParameter(2, LICENSE_NO[i]);
								param2.setWhereClauseParameter(3, LICENSE_MARK[i]);
								param2.setWhereClauseParameter(4, COIL_MARK_RESVER[i]);
								param2.setWhereClauseParameter(5, REG_ID[0]);
								param2.setWhereClauseParameter(6, ACT_WGT[i]);
								param2.setWhereClauseParameter(7, "修改前重量为："+ACT_WGT_HIS+" 修改后重量为： "+ACT_WGT[i]);
								param2.setWhereClauseParameter(8, SPEC_STL_GRD[i]);
								param2.setWhereClauseParameter(9, OLD_SAMPL_NO[i]);
								
								getDao("mesdao").update("UIH050500_02.update", param2);
								
								//把标签需要的数据写入接口表，
								
								PosParameter param3 = new PosParameter();
								
								param3.setValueParamter(0, OLD_SAMPL_NO[i]);
								param3.setValueParamter(1, OLD_SAMPL_NO[i].substring(0, 10));
								param3.setValueParamter(2, "");//CHARE_NO[i]
								param3.setValueParamter(3, ORD_NO[i]);
								param3.setValueParamter(4, MILL_DTIME[i]);
								param3.setValueParamter(5, SPEC_ABBSYM[i]);
								param3.setValueParamter(6, "".equals(CHANGE_SPEC_STL_GRD[i])?SPEC_STL_GRD[i]:CHANGE_SPEC_STL_GRD[i]);
								param3.setValueParamter(7, THK_WTH[i]);
								param3.setValueParamter(8, ACT_WGT[i]);
								param3.setValueParamter(9, CHECKER_ID[i]);
								param3.setValueParamter(10, LICENSE_MARK[i]);
								param3.setValueParamter(11, LICENSE_NO[i]);
								param3.setValueParamter(12, COIL_MARK_RESVER[i]);
								param3.setValueParamter(13, REG_ID[0]);
								//做为打印页数使用
								param3.setValueParamter(14, COIL_PAGES[i]);
								
								getDao("mesdao").insert("UIH050500_01.insert", param3);
								getDao("mesdao").insert("UIH050500_01bak.insert", param3);//日志
								
								 String Dtime = null;
							    //在执行完后，清除一次电文表。避免以后主键冲突
							    DateFormat formatter =  new SimpleDateFormat("yyyyMMdd");
							    Dtime = formatter.format(new Date());
							    
							    logger.logDebug("saveCoilResult 里面，获取系统时间："+Dtime);
							   
							    PosParameter paramT = new PosParameter(); 
							    paramT.setWhereClauseParameter(0, String.valueOf((Integer.parseInt(Dtime) -3)));
							   
							    getDao("mesdao").delete("UIH050500_01.delete", paramT);
								
							}else{
								//抛出异常
								logger.logInfo("UIH050500的saveCoilResult类中,实际钢卷号"+OLD_SAMPL_NO[i]+"没有排车不能进行标签打印");
								String vtemp="ERRORT";
								context.put("rs", vtemp);
							}
						}else if(null != DLIV_TP && DLIV_TP.equals("C")){
							PosParameter param1 = new PosParameter();
							param1.setWhereClauseParameter(0,OLD_SAMPL_NO[i]);
							
							PosRowSet rows = getDao("mesdao").find("UIH050500_02.select", param1);
							
							if(rows.hasNext()){
//								这里需要取出修改前的重量，记录备注
								PosRow row = rows.next();
								BigDecimal ACT_WGT_HIS = (BigDecimal) row.getAttribute("ACT_WGT");
								logger.logDebug("saveCoilResult 里面，获取修改前的重量："+ACT_WGT_HIS);
								
								//进行更新操作
								PosParameter param2 = new PosParameter();
								//这里只允许更新系统没有的数据
//								param2.setWhereClauseParameter(0, COIL_NO[i]);
//								param2.setWhereClauseParameter(1, CHARE_NO[i]);
//								param2.setWhereClauseParameter(2, SPEC_STL_GRD[i]);
//								param2.setWhereClauseParameter(3, ORD_NO[i]);
//								param2.setWhereClauseParameter(4, ACT_WGT[i]);
//								param2.setWhereClauseParameter(5, THK_WTH[i]);
//								param2.setWhereClauseParameter(6, MILL_DTIME[i]);
//								param2.setWhereClauseParameter(7, SPEC_ABBSYM[i]);
								param2.setWhereClauseParameter(0, CHANGE_SPEC_STL_GRD[i]);
								param2.setWhereClauseParameter(1, CHECKER_ID[i]);
								param2.setWhereClauseParameter(2, LICENSE_NO[i]);
								param2.setWhereClauseParameter(3, LICENSE_MARK[i]);
								param2.setWhereClauseParameter(4, COIL_MARK_RESVER[i]);
								param2.setWhereClauseParameter(5, REG_ID[0]);
								param2.setWhereClauseParameter(6, SPEC_STL_GRD[i]);
								param2.setWhereClauseParameter(7, OLD_SAMPL_NO[i]);
								
								getDao("mesdao").update("UIH050500_01.update", param2);
								
								//把标签需要的数据写入接口表，
								
								PosParameter param3 = new PosParameter();
								
								param3.setValueParamter(0, OLD_SAMPL_NO[i]);
								param3.setValueParamter(1, OLD_SAMPL_NO[i].substring(0, 10));
								param3.setValueParamter(2, "");//CHARE_NO[i]
								param3.setValueParamter(3, ORD_NO[i]);
								param3.setValueParamter(4, MILL_DTIME[i]);
								param3.setValueParamter(5, SPEC_ABBSYM[i]);
								param3.setValueParamter(6, "".equals(CHANGE_SPEC_STL_GRD[i])?SPEC_STL_GRD[i]:CHANGE_SPEC_STL_GRD[i]);
								param3.setValueParamter(7, THK_WTH[i]);
								//这里获取明细修改后的重量，汽运打标签的时候不能改重量
								param3.setValueParamter(8, ACT_WGT_HIS);
								param3.setValueParamter(9, CHECKER_ID[i]);
								param3.setValueParamter(10, LICENSE_MARK[i]);
								param3.setValueParamter(11, LICENSE_NO[i]);
								param3.setValueParamter(12, COIL_MARK_RESVER[i]);
								param3.setValueParamter(13, REG_ID[0]);
								param3.setValueParamter(14, COIL_PAGES[i]);
								
								getDao("mesdao").insert("UIH050500_01.insert", param3);
								getDao("mesdao").insert("UIH050500_01bak.insert", param3);//日志
								
								
								 String Dtime = null;
							    //在执行完后，清除一次电文表。避免以后主键冲突
							    DateFormat formatter =  new SimpleDateFormat("yyyyMMdd");
							    Dtime = formatter.format(new Date());
							    
							    logger.logDebug("saveCoilResult 里面，获取系统时间："+Dtime);
							   
							    PosParameter paramT = new PosParameter(); 
							    paramT.setWhereClauseParameter(0, String.valueOf((Integer.parseInt(Dtime) -3)));
							   
							    getDao("mesdao").delete("UIH050500_01.delete", paramT);
								
							}else{
								//抛出异常
								logger.logInfo("UIH050500的saveCoilResult类中,实际钢卷号"+OLD_SAMPL_NO[i]+"没有打印出明细不能进行标签打印");
								String vtemp="ERRORC";
								context.put("rs", vtemp);
							}
						}else{
//							抛出异常
							logger.logInfo("UIH050500的saveCoilResult类中,发运号"+DLIV_DIRNO[i]+"没有区分标志");
							String vtemp="DLIV_TP";
							context.put("rs", vtemp);
						}
					}
				}else{
					//没有选中的行，不进行打印操作
				}
			}
		}	
		return PosBizControlConstants.SUCCESS;
	}
}