XinYu_RZMES/.svn/pristine/01/0153373a1779a819ce95dabd0f6c78b09e10088c.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 TestYardMove 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;
		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");
				}
				
				//得到相应的命令序号后，更新命令，并且把来源位置的钢卷放入去向位置
				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("UIH050030_COIL_COMM", param4);
				
			}
			
		}
	
		return PosBizControlConstants.SUCCESS;
	}

}