XinYu_RZMES/.svn/pristine/c1/c15ac3f4198980db0ea89e51dd3f1be5be4c5e07.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 saveBJreturn 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[] 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("3")){
					//这里在退回库之前做状态效验，不为板加退回状态
					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("3")){
							//这里要判断输入的垛位信息是否被占用已经垛位信息是否存在
							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();
									
									param3.setWhereClauseParameter(0, REG_ID[0]);
									param3.setWhereClauseParameter(1, OLD_SAMPL_NO[i]);
									param3.setWhereClauseParameter(2, SHIP_INVNO[i]);
									
									getDao("mesdao").update("UIH070010_06.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{
					//移送退回的状态不为板加退回，在界面给出提示
					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);
	  }
}