XinYu_RZMES/.svn/pristine/dc/dc9c968eeb045a2d915de4cca2febff5e2408857.svn-base

package xin.glue.ui.H.H05;

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 EstYardMove extends PosActivity{
	public String runActivity(PosContext context){
//		从页面获取数据供插入和更新使用
		String[] rowStatus = (String[]) context.get("rowStatus");
		//步进梁
		String[] WK_BEAM = (String[]) context.get("WK_BEAM");
		//钢卷号
		String[] OLD_SAMPL_NO = (String[]) context.get("OLD_SAMPL_NO");
		//生产钢卷号
		String[] COIL_NO = (String[]) context.get("COIL_NO");
		//钢卷外径 
		String[] COIL_OUTDIA = (String[]) context.get("COIL_OUTDIA");
		//钢卷重量
		String[] COIL_WGT = (String[]) context.get("COIL_WGT");
		//钢号
		String[] STL_GRD = (String[]) context.get("STL_GRD");
		//来源位置
		String[] FROM_ADDR = (String[]) context.get("FROM_ADDR");
		//到放置位置  
		String[] TO_ADDR = (String[]) context.get("TO_ADDR");
		//行车编号 
		String[] CR_NO = (String[]) context.get("CR_NO");
		//钢卷外径 
		String[] CHK = (String[]) context.get("CHK");
		//序号
		String[] ORD_SEQ = (String[]) context.get("ORD_SEQ");
		//登录用户名
		String[] REG_ID = (String[]) context.get("REG_ID");
		
		//行车命令制定序号
		Number SEQ = null;
		if(rowStatus != null){
			for(int i=0;i<rowStatus.length;i++){
				if(CHK[i].equals("Y")){
					//这里因为行车系统没有上的原因，手动将数据进入数据库
					PosParameter param0 = new PosParameter();
					//通过来源位置和去向位置找到相对应的行车命令是哪一条
					param0.setWhereClauseParameter(0, FROM_ADDR[i]);
					param0.setWhereClauseParameter(1, TO_ADDR[i]);
					
					PosRowSet rows = getDao("mesdao").find("UIH050050_CRANE_ORDER.select", param0);
					
					if(rows.hasNext()){
						PosRow row = rows.next();
						SEQ = (Number) row.getAttribute("ORD_SEQ");
					}
					
					//是否需要发送解锁命令
					if(SEQ != null){
						//得到相应的命令序号后，更新命令，并且把来源位置的钢卷放入去向位置
						PosParameter param1 = new PosParameter();
						param1.setWhereClauseParameter(0, SEQ);
						
						getDao("mesdao").update("UIH050050_CRANE_ORDER.update", param1);
						
						PosParameter param2 = new PosParameter();
						
						param2.setWhereClauseParameter(0, REG_ID[0]);
						param2.setWhereClauseParameter(1, FROM_ADDR[i]);
						
						getDao("mesdao").update("UIH050050_CRANE_ORDER.update_F", param2);
						
						PosParameter param3 = new PosParameter();
						
						//真实钢卷号
						param3.setWhereClauseParameter(0, REG_ID[0]);
						param3.setWhereClauseParameter(1, OLD_SAMPL_NO[i]);
						param3.setWhereClauseParameter(2, TO_ADDR[i]);
						
						getDao("mesdao").update("UIH050050_CRANE_ORDER.update_T", param3);
						
						//这里还需要把去向位置的数据放入到钢卷公共表的位置字段
						PosParameter param4 = new PosParameter();
						
						param4.setWhereClauseParameter(0,TO_ADDR[i]);
						param4.setWhereClauseParameter(1,OLD_SAMPL_NO[i]);
						
						//这里使用行车命令执行的SQL
						getDao("mesdao").update("UIH050050_COIL_COMM", param4);
					
					}
				}
			}
		}
		return PosBizControlConstants.SUCCESS;
	}

}