XinYu_RZMES/.svn/pristine/0b/0b445918684b43842a9142447b25b8cdabe2f24c.svn-base

package xin.glue.ui.H.H01;

/********
 这里为卷板移送板加单独做个类处理 TL 091223
 ************/

import java.math.BigDecimal;

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.component.PosConstants;
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;


public class saveBJTransf extends PosActivity{
	public String runActivity(PosContext context)
	{
//		从页面获取参数数据，供更新页面使用
		//行状态
		String[] rowStuts = (String[])context.get("rowStatus");
		//选择标志
		String[] CHK = (String[])context.get("CHK");
		//钢卷号
		String[] OLD_SAMPL_NO = (String[])context.get("OLD_SAMPL_NO");
		//钢号
		String[] SPEC_STL_GRD = (String[])context.get("SPEC_STL_GRD");
		//合同号
		String[] ORD_NO = (String[])context.get("ORD_NO");
		//订单号
		String[] ORD_SEQ = (String[])context.get("ORD_SEQ");
		//板坯号
		String[] SLAB_NO = (String[])context.get("SLAB_NO");
		//钢卷厚度
		String[] COIL_THK = (String[])context.get("COIL_THK");
		//钢卷宽度
		String[] COIL_WTH = (String[])context.get("COIL_WTH");
		//钢卷长度
		String[] COIL_LEN = (String[])context.get("COIL_LEN");
		//钢卷重量
		String[] ACT_WGT = (String[])context.get("ACT_WGT");
		//钢卷内径
		String[] COIL_INDIA = (String[])context.get("COIL_INDIA");
		//钢卷外径
		String[] COIL_OUTDIA = (String[])context.get("COIL_OUTDIA");
		//车号
		String[] TRANS_CAR_NO = (String[])context.get("TRANS_CAR_NO");
		//移送单号
		//String[] SHIP_INVNO = (String[])context.get("SHIP_INVNO");
		//移送目的地
		String[] ROUTE = (String[])context.get("ROUTE");
		//移送状态
		//String[] MOVE_ST = (String[])context.get("MOVE_ST");
		//交货期
		String[] DEVLMT_DTIME = (String[])context.get("DEVLMT_DTIME");
		//客户
		String[] ORDCUST_CD = (String[])context.get("ORDCUST_CD");
		//目的地
		String[] DEST_PCD = (String[])context.get("DEST_PCD");
		//产品代码
		String[] PRODNM_CD = (String[])context.get("PRODNM_CD");
		//标准号
		String[] SPEC_ABBSYM = (String[])context.get("SPEC_ABBSYM");
		//轧制时间
		String[] MILL_DTIME = (String[])context.get("MILL_DTIME");
		//订单厚度
		String[] INSTR_COIL_THK = (String[])context.get("INSTR_COIL_THK");
		//订单宽度
		String[] INSTR_COIL_WTH = (String[])context.get("INSTR_COIL_WTH");
		//订单长度
		String[] INSTR_COIL_LEN = (String[])context.get("INSTR_COIL_LEN");
		//订单重量
		String[] INSTR_COIL_WGT = (String[])context.get("INSTR_COIL_WGT");
		//订单内径
		String[] INSTR_COIL_INDIA = (String[])context.get("INSTR_COIL_INDIA");
		//订单外径
		String[] INSTR_COIL_OUTDIA = (String[])context.get("INSTR_COIL_OUTDIA");
		//外观等级
		String[] EXTSHAPE_DEC_GRD = (String[])context.get("EXTSHAPE_DEC_GRD");
		//成份等级
		String[] INGR_DEC_GRD = (String[])context.get("INGR_DEC_GRD");
		//材质等级
		String[] MATLQLTY_DEC_GRD = (String[])context.get("MATLQLTY_DEC_GRD");
		//尺寸判定
		String[] SIZE_DEC_RST = (String[])context.get("SIZE_DEC_RST");
		//重量判定
		String[] WGT_DEC_RST = (String[])context.get("WGT_DEC_RST");
		//综合判定
		String[] TOT_DEC_GRD = (String[])context.get("TOT_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");
		//暇疵代码5
		String[] CRK_CD5 = (String[])context.get("CRK_CD5");
		//登录人 
		String[] REG_ID = (String[])context.get("REG_ID");
		//移送班次 
		String[] MOVE_SHIFT = (String[])context.get("MOVE_SHIFT");
		//移送班组 
		String[] MOVE_GROUP = (String[])context.get("MOVE_GROUP");
		//移送人 
		String[] ENTRY_REG = (String[])context.get("ENTRY_REG");
		//移送时间
		String[] ENTRY_DTIME = (String[])context.get("ENTRY_DTIME");
		//流水号，整理进程用
		String[] COIL_NO = (String[])context.get("COIL_NO");
		
		String SHIP_INVNO = null;
		//这里需要获取移送板加的发运明细编号
		PosParameter param0 = new PosParameter();
		
		PosRowSet SHIP_INVNOVo = getDao("mesdao").find("UIH070010_03.select", param0);
		
		if(SHIP_INVNOVo.hasNext()){
			PosRow SHIP_INVNORow = SHIP_INVNOVo.next();
			
			SHIP_INVNO = (String) SHIP_INVNORow.getAttribute("SHIP_INVNO");
			logger.logInfo("saveBJTransf 移送板加的发货明细编号为"+SHIP_INVNO); 
		}
		
		
		String SHIP_INVNO_CR = null;
		//这里需要获取移送冷轧的发运明细编号
		PosParameter paramA = new PosParameter();
		
		PosRowSet SHIP_INVNO_CRVo = getDao("mesdao").find("UIH070010_05.select", paramA);
		
		if(SHIP_INVNO_CRVo.hasNext()){
			PosRow SHIP_INVNO_CRRow = SHIP_INVNO_CRVo.next();
			
			SHIP_INVNO_CR = (String) SHIP_INVNO_CRRow.getAttribute("SHIP_INVNO_CR");
			logger.logInfo("saveBJTransf 移送板加的发货明细编号为"+SHIP_INVNO_CR); 
		}
		
		for(int i=0;i<rowStuts.length;i++){
			//选中的情况，才能够把需要移送的卷迁入移送接口表
			if(CHK[i].equals("Y")){
				if(null != ROUTE[i] && ROUTE[i].equals("B")){
					//这里在进行移送操作前需要进行卷的下车状态效验，如果此卷已经做了发运计划不能进行移送操作
					PosParameter param00 = new PosParameter();
					
					param00.setWhereClauseParameter(0, OLD_SAMPL_NO[i]);
					PosRowSet CUR_PROG_CDVo = getDao("mesdao").find("UIH070010_06.select", param00);
					
					String CUR_PROG_CD = null;
					
					if(CUR_PROG_CDVo.hasNext()){
						PosRow CUR_PROG_CDRow = CUR_PROG_CDVo.next();
						
						CUR_PROG_CD = (String) CUR_PROG_CDRow.getAttribute("CUR_PROG_CD");
						
						if(null != CUR_PROG_CD && CUR_PROG_CD.equals("SFA")){
							//这里做效验，只有是发货待机的才能进行移送操作
							
							//这里进行的是板加的移送操作
							PosParameter param1 = new PosParameter();
							
							param1.setValueParamter(0, OLD_SAMPL_NO[i]);
							param1.setValueParamter(1, SPEC_STL_GRD[i]);
							param1.setValueParamter(2, ORD_NO[i]);
							param1.setValueParamter(3, ORD_SEQ[i]);
							param1.setValueParamter(4, SLAB_NO[i]);
							param1.setValueParamter(5, COIL_THK[i]);
							param1.setValueParamter(6, COIL_WTH[i]);
							param1.setValueParamter(7, COIL_LEN[i]);
							param1.setValueParamter(8, ACT_WGT[i]);
							param1.setValueParamter(9, COIL_INDIA[i]);
							param1.setValueParamter(10, COIL_OUTDIA[i]);
							param1.setValueParamter(11, TRANS_CAR_NO[i]);
							//这里每保存一次做为一次移送，生成一次发运明细号
							param1.setValueParamter(12, SHIP_INVNO);
							param1.setValueParamter(13, ROUTE[i]);
							//这里板加移送的，默认接收状态都为0
							param1.setValueParamter(14, "0");
							param1.setValueParamter(15, DEVLMT_DTIME[i]);
							param1.setValueParamter(16, ORDCUST_CD[i]);
							param1.setValueParamter(17, DEST_PCD[i]);
							param1.setValueParamter(18, PRODNM_CD[i]);
							param1.setValueParamter(19, SPEC_ABBSYM[i]);
							param1.setValueParamter(20, MILL_DTIME[i]);
							param1.setValueParamter(21, INSTR_COIL_THK[i]);
							param1.setValueParamter(22, INSTR_COIL_WTH[i]);
							param1.setValueParamter(23, INSTR_COIL_LEN[i]);
							param1.setValueParamter(24, INSTR_COIL_WGT[i]);
							param1.setValueParamter(25, INSTR_COIL_INDIA[i]);
							param1.setValueParamter(26, INSTR_COIL_OUTDIA[i]);
							param1.setValueParamter(27, EXTSHAPE_DEC_GRD[i]);
							param1.setValueParamter(28, INGR_DEC_GRD[i]);
							param1.setValueParamter(29, MATLQLTY_DEC_GRD[i]);
							param1.setValueParamter(30, SIZE_DEC_RST[i]);
							param1.setValueParamter(31, WGT_DEC_RST[i]);
							param1.setValueParamter(32, TOT_DEC_GRD[i]);
							param1.setValueParamter(33, CRK_CD1[i]);
							param1.setValueParamter(34, CRK_CD2[i]);
							param1.setValueParamter(35, CRK_CD3[i]);
							param1.setValueParamter(36, CRK_CD4[i]);
							param1.setValueParamter(37, CRK_CD5[i]);
							param1.setValueParamter(38, REG_ID[0]);
							//执行标准，板加使用
							param1.setValueParamter(39, SPEC_ABBSYM[i]);
							//轧批号
							param1.setValueParamter(40, OLD_SAMPL_NO[i].substring(0, 9));
							//炉号
							param1.setValueParamter(41, SLAB_NO[i].substring(0, 9));
							//移送产线
							param1.setValueParamter(42, "热轧");
							//到达产线
							param1.setValueParamter(43, "板加");
							//移送班次
							param1.setValueParamter(44, MOVE_SHIFT[0]);
							//移送班组
							param1.setValueParamter(45, MOVE_GROUP[0]);
							//移送人
							param1.setValueParamter(46, ENTRY_REG[0]);
							//移送时间
							param1.setValueParamter(47, ENTRY_DTIME[0]);
							//钢卷流水号
							param1.setValueParamter(48, COIL_NO[i]);
							
							getDao("mesdao").insert("UIH070010_01.insert", param1);
							
							logger.logInfo("saveBJTransf 数据迁移到接口表"+param1); 
							
							//更新钢卷公共表, 这里需要结束钢卷的状态。
							PosParameter param2 = new PosParameter();
							
							param2.setWhereClauseParameter(0,SHIP_INVNO);
							param2.setWhereClauseParameter(1,TRANS_CAR_NO[i]);
							param2.setWhereClauseParameter(2,ROUTE[i]);
							param2.setWhereClauseParameter(3,OLD_SAMPL_NO[i]);
							
							getDao("mesdao").update("UIH070010_01.update", param2);
							
							//更新钢卷垛位表
							PosParameter param3 = new PosParameter();
							
							param3.setWhereClauseParameter(0,OLD_SAMPL_NO[i]);
							
							getDao("mesdao").update("UIH070010_05.update", param3);
							
							//String - BigDecimal
							BigDecimal bd =new BigDecimal(ACT_WGT[i]); 

							SendProg_NIE012070( COIL_NO[i] ,ORD_NO[i],ORD_SEQ[i],"SFF","SFA","AR",bd);
							
							//进行进程整理，这里改变了进程状态
							SendProg_NIE012080();
						}else{
							//给出提示，此卷的状态不为发货待机。不能进行移送操作
							logger.logDebug("saveYSreturn 此卷的状态不为SFA，不能进行移送操作 "+CUR_PROG_CD);
							String vtemp="CUR_PROG_CD";
							context.put("rs", vtemp);
							//有一个不符合条件的，全体不能移送
							this.rollbackTransaction("tx1");
						}
					}
				}else if(null != ROUTE[i] && ROUTE[i].equals("C")){
//					//这里在进行移送操作前需要进行卷的下车状态效验，如果此卷已经做了发运计划不能进行移送操作
//					PosParameter param00 = new PosParameter();
//					
//					param00.setWhereClauseParameter(0, OLD_SAMPL_NO[i]);
//					PosRowSet CUR_PROG_CDVo = getDao("mesdao").find("UIH070010_06.select", param00);
//					
//					String CUR_PROG_CD = null;
//					
//					if(CUR_PROG_CDVo.hasNext()){
//						PosRow CUR_PROG_CDRow = CUR_PROG_CDVo.next();
//						
//						CUR_PROG_CD = (String) CUR_PROG_CDRow.getAttribute("CUR_PROG_CD");
//						
//						if(null != CUR_PROG_CD && CUR_PROG_CD.equals("SFA")){
//							//这里是对冷轧移送进行的处理，只在移送表记录一条记录。冷轧原料库与热轧成品库公用钢卷公共表
//							
//							//这里进行的是板加的移送操作
//							PosParameter param1 = new PosParameter();
//							
//							param1.setValueParamter(0, OLD_SAMPL_NO[i]);
//							param1.setValueParamter(1, SPEC_STL_GRD[i]);
//							param1.setValueParamter(2, ORD_NO[i]);
//							param1.setValueParamter(3, ORD_SEQ[i]);
//							param1.setValueParamter(4, SLAB_NO[i]);
//							param1.setValueParamter(5, COIL_THK[i]);
//							param1.setValueParamter(6, COIL_WTH[i]);
//							param1.setValueParamter(7, COIL_LEN[i]);
//							param1.setValueParamter(8, ACT_WGT[i]);
//							param1.setValueParamter(9, COIL_INDIA[i]);
//							param1.setValueParamter(10, COIL_OUTDIA[i]);
//							param1.setValueParamter(11, TRANS_CAR_NO[i]);
//							//这里每保存一次做为一次移送，生成一次发运明细号
//							param1.setValueParamter(12, SHIP_INVNO_CR);
//							param1.setValueParamter(13, ROUTE[i]);
//							//这里冷轧移送的，默认接收状态都为4
//							param1.setValueParamter(14, "4");
//							param1.setValueParamter(15, DEVLMT_DTIME[i]);
//							param1.setValueParamter(16, ORDCUST_CD[i]);
//							param1.setValueParamter(17, DEST_PCD[i]);
//							param1.setValueParamter(18, PRODNM_CD[i]);
//							param1.setValueParamter(19, SPEC_ABBSYM[i]);
//							param1.setValueParamter(20, MILL_DTIME[i]);
//							param1.setValueParamter(21, INSTR_COIL_THK[i]);
//							param1.setValueParamter(22, INSTR_COIL_WTH[i]);
//							param1.setValueParamter(23, INSTR_COIL_LEN[i]);
//							param1.setValueParamter(24, INSTR_COIL_WGT[i]);
//							param1.setValueParamter(25, INSTR_COIL_INDIA[i]);
//							param1.setValueParamter(26, INSTR_COIL_OUTDIA[i]);
//							param1.setValueParamter(27, EXTSHAPE_DEC_GRD[i]);
//							param1.setValueParamter(28, INGR_DEC_GRD[i]);
//							param1.setValueParamter(29, MATLQLTY_DEC_GRD[i]);
//							param1.setValueParamter(30, SIZE_DEC_RST[i]);
//							param1.setValueParamter(31, WGT_DEC_RST[i]);
//							param1.setValueParamter(32, TOT_DEC_GRD[i]);
//							param1.setValueParamter(33, CRK_CD1[i]);
//							param1.setValueParamter(34, CRK_CD2[i]);
//							param1.setValueParamter(35, CRK_CD3[i]);
//							param1.setValueParamter(36, CRK_CD4[i]);
//							param1.setValueParamter(37, CRK_CD5[i]);
//							param1.setValueParamter(38, REG_ID[0]);
//							//执行标准，板加使用
//							param1.setValueParamter(39, SPEC_ABBSYM[i]);
//							//轧批号
//							param1.setValueParamter(40, OLD_SAMPL_NO[i].substring(0, 9));
//							//炉号
//							param1.setValueParamter(41, SLAB_NO[i].substring(0, 9));
//							//移送产线
//							param1.setValueParamter(42, "热轧");
//							//到达产线
//							param1.setValueParamter(43, "冷轧");
//							//移送班次
//							param1.setValueParamter(44, MOVE_SHIFT[0]);
//							//移送班组
//							param1.setValueParamter(45, MOVE_GROUP[0]);
//							//移送人
//							param1.setValueParamter(46, ENTRY_REG[0]);
//							//移送时间
//							param1.setValueParamter(47, ENTRY_DTIME[0]);
//							//钢卷流水号
//							param1.setValueParamter(48, COIL_NO[i]);
//							
//							getDao("mesdao").insert("UIH070010_02.insert", param1);
//							
//							logger.logInfo("saveBJTransf 数据迁移到接口表"+param1); 
//							
//							//更新钢卷公共表, 这里需要结束钢卷的状态。
//							PosParameter param2 = new PosParameter();
//							
//							param2.setWhereClauseParameter(0,SHIP_INVNO_CR);
//							param2.setWhereClauseParameter(1,TRANS_CAR_NO[i]);
//							param2.setWhereClauseParameter(2,ROUTE[i]);
//							param2.setWhereClauseParameter(3,OLD_SAMPL_NO[i]);
//							
//							getDao("mesdao").update("UIH070010_08.update", param2);
//							
//							//更新钢卷垛位表
//							PosParameter param3 = new PosParameter();
//							
//							param3.setWhereClauseParameter(0,OLD_SAMPL_NO[i]);
//							
//							getDao("mesdao").update("UIH070010_05.update", param3);
//							
//							//进行进程整理，这里改变了进程状态
//							SendProg_NIE012080();
//						}else{
//							//给出提示，此卷的状态不为发货待机。不能进行移送操作
//							logger.logDebug("saveYSreturn 此卷的状态不为SFA，不能进行移送操作 "+CUR_PROG_CD);
//							String vtemp="CUR_PROG_CD";
//							context.put("rs", vtemp);
//						}
//					}	
				}else{
					//给出提示，没有选中移送目的地。不能进行移送操作
					//这个垛位实际不存在，在界面给出提示
					logger.logDebug("saveYSreturn 移送目的地没有选中，不能进行移送操作 "+ROUTE[i]);
					String vtemp="ROUTE";
					context.put("rs", vtemp);
				}
			}
		}
		
		return PosBizControlConstants.SUCCESS;
	}
	
	public void SendProg_NIE012070(String  MatNo,String sOrdNo,String sOrdSeq,String sProgCd,String sBefProgCd,String sKind,BigDecimal wgt  )
	{
	   
		    logger.logDebug("saveBJTransf SendProg_NIE012070 " ); 
		        
			PosContext context = new PosContext();
			PosMessage message = new PosMESMessageImpl();
		     
			String TcId = "NIE012070"; 
			  
			
			message.setTCID(TcId);
			message.setObject("MSG_ID",TcId);  
			message.setObject("BEF_ORD_NO",null);
			message.setObject("BEF_ORD_SEQ",null);
			message.setObject("ORD_NO",sOrdNo);
			message.setObject("ORD_SEQ",sOrdSeq);
			message.setObject("BEF_PROG_CD",sBefProgCd);
			message.setObject("PROG_CD",sProgCd);
			message.setObject("MAT_TYPE",sKind);
			message.setObject("MAT_NO",MatNo);
			message.setObject("WGT", wgt  );
			message.setObject("PGMID","saveBJTransf");
			message.setObject("REG_ID", "UIH070010");
			context.setMessage(message);
			this.processComponent(PosConstants.CREATE_MESSAGE, context);
			String transactionCode = context.getMessage().getTC();
			
			 
			message.setTCID(TcId); 
		 	
			String serviceName = "NIE012070"; 
			
			String SERVICE_POSTFIX = "-service"; 
			
		 	 
			context.put(PosBizControlConstants.SERVICE_NAME, serviceName + SERVICE_POSTFIX);
			 
			
			context.setMessage(message);
			
			
			PosBizControlIF controller =  PosBizProvider.getController();
			
			controller.doSubController(context,false);
		 	 
	}
	
	public void 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);
			this.processComponent(PosConstants.CREATE_MESSAGE, context);
			String transactionCode = context.getMessage().getTC();
			
		 	
			message.setTCID(TcId); 
		 	
			String serviceName = "NIE012080"; 
			
			String SERVICE_POSTFIX = "-service"; 
			
		 	 
			context.put(PosBizControlConstants.SERVICE_NAME, serviceName + SERVICE_POSTFIX);
			 
			
			context.setMessage(message);
			
			
			PosBizControlIF controller =  PosBizProvider.getController();
			
			controller.doSubController(context,false);
			 
		 	
			
			 
	  }
}