XinYu_RZMES/.svn/pristine/e9/e91cf4e8822ab6579d64fd8b2d5e65215b3f228e.svn-base

package xin.glue.ui.H.H01;

/********
 这里为卷板移送回退单独做个类处理 TL 091224
 ************/

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 saveYSreturn 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[] RTN_CUR_STORE_LOC = (String[])context.get("RTN_CUR_STORE_LOC");
		//板加货单号
		String[] SHIP_INVNO = (String[])context.get("SHIP_INVNO");
		//冷轧货单号
		String[] SHIP_INVNO_CR = (String[])context.get("SHIP_INVNO_CR");
		//移送退回状态
		String[] MOVE_ST = (String[])context.get("MOVE_ST");
		//登录人 
		String[] REG_ID = (String[])context.get("REG_ID");
		//合同号
		String[] ORD_NO = (String[])context.get("ORD_NO");
		//订单号
		String[] ORD_SEQ = (String[])context.get("ORD_SEQ");
		//流水号，整理进程用
		String[] COIL_NO1 = (String[])context.get("COIL_NO");
		//钢卷重量
		String[] ACT_WGT = (String[])context.get("ACT_WGT");
		
		String MOVE_ST_TMP = null;
		
		for(int i=0;i<rowStuts.length;i++){
			//选中的情况，才能够把需要移送的卷迁入移送接口表
			if(CHK[i].equals("Y")){
				//判断是否垛位存在之前要先判断该状态是否能够进行回退操作
				if(MOVE_ST[i].equals("0")){
					//这里在退回库之前做状态效验，不为板加待接收状态不能退回
					PosParameter paramA = new PosParameter();
					
					paramA.setWhereClauseParameter(0, OLD_SAMPL_NO[i]); 
					paramA.setWhereClauseParameter(1, SHIP_INVNO[i]); 
					
					PosRowSet MOVE_STVo = getDao("mesdao").find("UIH070010_09.select", paramA);
					
					if(MOVE_STVo.hasNext()){
						PosRow MOVE_STRow = MOVE_STVo.next();
						
						MOVE_ST_TMP = (String) MOVE_STRow.getAttribute("MOVE_ST");
						
						if(MOVE_ST_TMP.equals("0")){
							//这里处理板加接收等待的情况，进行回退操作
							//这里要判断输入的垛位信息是否被占用已经垛位信息是否存在
							PosParameter param0 = new PosParameter();
							param0.setWhereClauseParameter(0, RTN_CUR_STORE_LOC[i]);
							
							PosRowSet CoilYardVo = getDao("mesdao").find("UIH070010_04.select", param0);
							
							if(CoilYardVo.hasNext()){
								PosRow CoilYardRow = CoilYardVo.next();
								
								String COIL_NO = (String) CoilYardRow.getAttribute("COIL_NO");
								
								if(COIL_NO == null){
									//把界面输入的垛位存在垛位表和公共表,并且需要把钢卷的状态回退到库内
									PosParameter param1 = new PosParameter();
									
									param1.setWhereClauseParameter(0, OLD_SAMPL_NO[i]);
									param1.setWhereClauseParameter(1, RTN_CUR_STORE_LOC[i]);
									
									getDao("mesdao").update("UIH070010_02.update", param1);
									
									PosParameter param2 = new PosParameter();
									
									param2.setWhereClauseParameter(0, RTN_CUR_STORE_LOC[i]);
									param2.setWhereClauseParameter(1, OLD_SAMPL_NO[i]);
									
									getDao("mesdao").update("UIH070010_03.update", param2);
									
									//处理移送接口表
									PosParameter param3 = new PosParameter();
									
									//2标志为移送回退的情况
									param3.setWhereClauseParameter(0, REG_ID[0]);
									param3.setWhereClauseParameter(1, OLD_SAMPL_NO[i]);
									param3.setWhereClauseParameter(2, SHIP_INVNO[i]);
									
									getDao("mesdao").update("UIH070010_04.update", param3);
									
//									String - BigDecimal
									BigDecimal bd =new BigDecimal(ACT_WGT[i]); 
									//这里用钢卷流水号来整理进程
									SendProg_NIE012070( COIL_NO1[i] ,ORD_NO[i],ORD_SEQ[i],"SFA","SFF","AR",bd);
									
									//进行进程整理，这里改变了进程状态
									SendProg_NIE012080();
									
								}else{
									//这个垛位上面存在钢卷，请确认后重新输入
									logger.logDebug("saveYSreturn 界面输入的垛位上存在钢卷 "+COIL_NO);
									String vtemp="COIL_NO";
									context.put("rs", vtemp);
								}
							}else{
								//这个垛位实际不存在，在界面给出提示
								logger.logDebug("saveYSreturn 界面输入的垛位实际不存在 "+RTN_CUR_STORE_LOC[i]);
								String vtemp="CoilYard";
								context.put("rs", vtemp);
							}
						}else{
							//再次效验移送状态不为板加接收待机，不能进行热轧退回入库
							logger.logDebug("saveYSreturn 界面移送状态不为板加接收待机，不能进行热轧退回入库 "+MOVE_ST_TMP);
							String vtemp="MOVE_ST_TMP";
							context.put("rs", vtemp);
							//有一个不符合条件的，全体不能回退
							this.rollbackTransaction("tx1");
						}
					}
				}else if(MOVE_ST[i].equals("4")){
//					//这里处理冷轧接收等待的情况，进行回退操作
//					//这里要判断输入的垛位信息是否被占用已经垛位信息是否存在
//					PosParameter param0 = new PosParameter();
//					param0.setWhereClauseParameter(0, RTN_CUR_STORE_LOC[i]);
//					
//					PosRowSet CoilYardVo = getDao("mesdao").find("UIH070010_04.select", param0);
//					
//					if(CoilYardVo.hasNext()){
//						PosRow CoilYardRow = CoilYardVo.next();
//						
//						String COIL_NO = (String) CoilYardRow.getAttribute("COIL_NO");
//						
//						if(COIL_NO == null){
//							//把界面输入的垛位存在垛位表和公共表,并且需要把钢卷的状态回退到库内
//							PosParameter param1 = new PosParameter();
//							
//							param1.setWhereClauseParameter(0, OLD_SAMPL_NO[i]);
//							param1.setWhereClauseParameter(1, RTN_CUR_STORE_LOC[i]);
//							
//							getDao("mesdao").update("UIH070010_02.update", param1);
//							
//							PosParameter param2 = new PosParameter();
//							
//							param2.setWhereClauseParameter(0, RTN_CUR_STORE_LOC[i]);
//							param2.setWhereClauseParameter(1, OLD_SAMPL_NO[i]);
//							
//							getDao("mesdao").update("UIH070010_03.update", param2);
//							
//							//处理移送接口表
//							PosParameter param3 = new PosParameter();
//							
//							//2标志为移送回退的情况
//							param3.setWhereClauseParameter(0, REG_ID[0]);
//							param3.setWhereClauseParameter(1, OLD_SAMPL_NO[i]);
//							param3.setWhereClauseParameter(2, SHIP_INVNO_CR[i]);
//							
//							getDao("mesdao").update("UIH070010_09.update", param3);
//							
//						}else{
//							//这个垛位上面存在钢卷，请确认后重新输入
//							logger.logDebug("saveYSreturn 界面输入的垛位上存在钢卷 "+COIL_NO);
//							String vtemp="COIL_NO";
//							context.put("rs", vtemp);
//						}
//					}else{
//						//这个垛位实际不存在，在界面给出提示
//						logger.logDebug("saveYSreturn 界面输入的垛位实际不存在 "+RTN_CUR_STORE_LOC[i]);
//						String vtemp="CoilYard";
//						context.put("rs", vtemp);
//					}
				}else{
					//这个垛位实际不存在，在界面给出提示
					logger.logDebug("saveYSreturn 移送退回的状态不为板加接收等待或者冷轧接收等待，不能进行回退操作 "+MOVE_ST[i]);
					String vtemp="MOVE_ST";
					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);
	  }
}