package xin.glue.ui.G.G02;

import xin.glue.ui.G.G01.XTBGCreateMaterial;


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.PosGenericDao;
import com.posdata.glue.dao.vo.PosParameter;
import com.posdata.glue.dao.vo.PosRow;
import com.posdata.glue.dao.vo.PosRowSet;

public class PosCreateSlab extends PosActivity {  
	 
	
	public String runActivity(PosContext context) 
	{
		try{
			PosGenericDao dao = getDao("mesdao");
			PosParameter param;
			PosRowSet rowset;
			PosRow row;
			XTBGCreateMaterial cr = new XTBGCreateMaterial(dao);
			
			
			//从电文中获取的数据项
			String[] CHARGE_NO = (String[])context.get("CHARGE_NO");						//炉次号
			String[] PLAN_CHARGE_NO = (String[])context.get("PLAN_CHARGE_NO");				//计划炉次号  
			
			String chargeNo 	= CHARGE_NO[0];												//炉次号
			String planChargeNo = PLAN_CHARGE_NO[0];
			 	
			//通过电文中接收的炉次号查询板坯参数表 TBF01_SPEC_CHARGE 取得一个炉次的板坯的数据项 ，修改炼钢公共表 更新板坯公共表，和板坯详细公共表
			   
			String sql = "select * from tbg02_charge_comm where CHARGE_NO = ?";
			param = new PosParameter();
	        param.setWhereClauseParameter(0, chargeNo);
	        rowset = this.getDao("mesdao").findByQueryStatement(sql,param);
	        if(rowset.hasNext()){
	        	row =  rowset.next();
	        	String ROW_CHARGE_STAT             = (String)row.getAttribute("CHARGE_STAT");
	        	if (ROW_CHARGE_STAT != null && ROW_CHARGE_STAT.equals("3")){
					context.put("MESSAGES", "炉次已经结束，不能操作");
					return PosBizControlConstants.SUCCESS; 
				}
	        }
			
			param  = new PosParameter(); 
		    param.setWhereClauseParameter(0, planChargeNo); 
		    rowset = getDao("mesdao").find("NIG020200_SPEC_SLAB.select", param);    
			while(rowset.hasNext()) {
				
			   row = rowset.next();
			   String sPlanSlabNo= (String)row.getAttribute("SLAB_MANA_NO");
			     
			   String sSlabSeq = sPlanSlabNo.substring(10,13);
			   String sSlabNo = chargeNo+sSlabSeq; 
			   
			   //检查是否需要插入板坯
			   param  = new PosParameter(); 
			   param.setWhereClauseParameter(0,sSlabNo); 
			   rowset = getDao("mesdao").find("NIG020200_CREATE_SLAB.select", param);     
			   if (!rowset.hasNext()){
				   cr.CreateSlab(sPlanSlabNo);
			   } 
			}
		}catch(Exception ex){
			logger.logDebug("NUI SAVE BOFRESULT-------->" + ex);
			logger.logError("NUI SAVE BOFRESULT-------->" + ex);
		}
		
		return PosBizControlConstants.SUCCESS;
	}

}