package xin.glue.ui.G.G04;

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;

/*
 * 炼钢工序管理修改工序类
 * @author 王小炎
 * @date 2008.08.11
 */
public class PosSaveToSlabYard extends PosActivity
{
	public String runActivity(PosContext context)
	{
//		从页面获取参数数据，供更新页面使用
		String[] status2 = (String[]) context.get("rowStuts2");
		
		String[] toSlabNo = (String[])context.get("TO_SLAB_NO");
		String[] fromSlabNo = (String[])context.get("FROM_SLAB_NO");
		String[] toSlabYardAddress = (String[])context.get("TO_YARD_ADDR");
		String[] fromSlabYardAddress = (String[])context.get("FROM_YARD_ADDR");
		String[] toStroelay = (String[])context.get("TO_STORELAY");
		
		int rowset = 0;
		if (status2 != null)
		{
			 
			
			for (int i = 0; i < status2.length; i++)
			{
				PosParameter param0 = new PosParameter();
				param0.setWhereClauseParameter(0, toSlabNo[i]);
				param0.setWhereClauseParameter(1, toSlabYardAddress[i]);
				param0.setWhereClauseParameter(2, toStroelay[i]);
				
//				从维护的公共表查出数据,供更新页面使用
				rowset += getDao("mesdao").update("UIG040010_02.update", param0);
				
			// TABLE ID: TB02_SLAB_COMM -->   CUR_LOAD_LOC  UPDATE        	
				PosParameter param1 = new PosParameter();
				String slabAddr = null;
				slabAddr = toSlabYardAddress[i]+toStroelay[i]; 
				param1.setWhereClauseParameter(0, slabAddr);
				param1.setWhereClauseParameter(1, toSlabNo[i]);
				
				getDao("mesdao").update("UIG040010_LOC.update",param1);
				
				// Mill Schedule delete request 
				PosParameter param6 = new PosParameter(); 
				param6.setWhereClauseParameter(0, toSlabNo[i]);
				PosRowSet SpecSlabVO = getDao("mesdao").find("UIG040042_SPEC_SLAB.select", param6); 
				if(SpecSlabVO.hasNext()) {
				  PosRow  SpecSlabROW = SpecSlabVO.next();
				  String MillFl = (String)SpecSlabROW.getAttribute("MILL_FL");
					
				  if(MillFl != null   && MillFl.equals("Y")) {
			    	 SendProg_NIF024060( toSlabNo[i]);  
			      }
				}  
				
				
			}
			context.put("saveToSlabYardResult", String.valueOf(rowset));
		}
		return PosBizControlConstants.SUCCESS;

	}
	//Mill Schedule delete request service call
		public void SendProg_NIF024060(String  SlabNo   )
	{
			   
		     
				        
			 PosContext context = new PosContext();
			 PosMessage message = new PosMESMessageImpl();
				     
			 String TcId = "NIF024060"; 

			 message.setTCID(TcId);
			 message.setObject("MSG_ID",TcId);  
			 message.setObject("TYPE","S");
			 message.setObject("FROM",SlabNo);
			 message.setObject("TO",SlabNo);
			 message.setObject("REG_ID","UIG040010");
				 
			 context.setMessage(message);
			 this.processComponent(PosConstants.CREATE_MESSAGE, context);
			 String transactionCode = context.getMessage().getTC();
				 	 
			 message.setTCID(TcId); 
				 	
			 String serviceName = "NIF024060"; 
					
			 String SERVICE_POSTFIX = "-service"; 
					
			 	 	 
			 context.put(PosBizControlConstants.SERVICE_NAME, serviceName + SERVICE_POSTFIX);
					 
					
			 context.setMessage(message);
					
					
			 PosBizControlIF controller =  PosBizProvider.getController();
					
			 controller.doSubController(context,false);
				 	 
	}
}