XinYu_RZMES/.svn/pristine/d5/d5082bb0cbd51f85e9669dc0758f639b18fe5287.svn-base

package xin.glue.ui.B.B02;

import java.math.BigDecimal;

import com.posdata.glue.PosException;
import com.posdata.glue.biz.activity.PosActivity;
import com.posdata.glue.biz.constants.PosBizControlConstants;
import com.posdata.glue.biz.control.PosBizProvider;
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;
import com.posdata.glue.msg.PosMESMessageImpl;
import com.posdata.glue.msg.PosMessage;

public class XTotChangeOrdsts extends PosActivity
{

	public String runActivity(PosContext context)
	{
		String[] v_rowStatus	=	(String[])context.get("rowStatus");
		String[] V_COIL_NO		=	(String[])context.get("COIL_NO");//试样号
		String[] V_REG_ID		=	(String[])context.get("REG_ID");//实验人
		long	 V_WGT			=	0;

		if(v_rowStatus==null)
			return PosBizControlConstants.SUCCESS;
		
		PosParameter	param	=	new PosParameter();
		PosGenericDao	dao		=	this.getDao("mesdao");
		PosRowSet		rowset	=	null;
		PosRow			row		=	null;
		PosContext	ctx			=	null;
		PosMessage	message		=	new PosMESMessageImpl();
				
		int				len		=	v_rowStatus.length;
		String 			TcId 	= 	"NIE012070";
		for(int i = 0; i < len; i++)
		{
			param	=	new PosParameter();
			param.setWhereClauseParameter(0, V_COIL_NO[i]);
			rowset	=	dao.find("UIB020235_02.SELECT", param);
			while(rowset.hasNext())
			{
				row		=	rowset.next();
				ctx		=	new PosContext();
				message	=	new PosMESMessageImpl();
				message.setTCID(TcId);
				message.setObject("MSG_ID",      TcId);
				if("2".equals(row.getAttribute("ORD_FL")))//若钢卷为余才
				{
					message.setObject("BEF_ORD_NO" , row.getAttribute("ORD_NO"));
					message.setObject("BEF_ORD_SEQ", row.getAttribute("ORD_SEQ"));
					message.setObject("ORD_NO"  ,     "");
					message.setObject("ORD_SEQ" ,     "");
				}
				if("1".equals(row.getAttribute("ORD_FL")))//若钢卷为订单材
				{
					message.setObject("BEF_ORD_NO" , "");
					message.setObject("BEF_ORD_SEQ", "");
					message.setObject("ORD_NO" ,     row.getAttribute("ORD_NO"));
					message.setObject("ORD_SEQ",     row.getAttribute("ORD_SEQ"));
				}
				message.setObject("BEF_PROG_CD", row.getAttribute("BEF_PROG_CD")); //之前进程
				message.setObject("PROG_CD"    , row.getAttribute("CUR_PROG_CD"));//当前进程
				message.setObject("MAT_TYPE"   , "AR");
				message.setObject("MAT_NO"     , row.getAttribute("COIL_NO")); 
				V_WGT	=	Long.parseLong(row.getAttribute("ACT_WGT")==null?"0":row.getAttribute("ACT_WGT").toString());
				message.setObject("WGT"        , new BigDecimal(V_WGT));//实重
				message.setObject("PGMID"      , "UIB020235"); 
				message.setObject("REG_ID"     , V_REG_ID[0]); 
				
				ctx.setMessage(message);		
				message.setTCID(TcId);
				
				ctx.put(PosBizControlConstants.SERVICE_NAME, TcId+"-service");		
				PosBizProvider.getController().doSubController(ctx, false);
			}//while end
		}
		
		NIE012080_CALL();
		
		return PosBizControlConstants.SUCCESS;
	}
	
	public PosContext NIE012080_CALL()
	{
		PosContext context = new PosContext();
		PosMessage message = new PosMESMessageImpl();
		
		String TcId = "NIE012080";
		message.setTCID(TcId);
		message.setObject("MSG_ID", TcId);
		message.setObject("AA",     ""); 
		context.setMessage(message);		
		message.setTCID(TcId);
		
		String SERVICE_POSTFIX = "-service";
		context.put(PosBizControlConstants.SERVICE_NAME, TcId + SERVICE_POSTFIX);
		PosBizProvider.getController().doSubController(context, false);
		
		String SERVICE_ERR_MSG = (String) context.get("SERVICE_ERR_MSG");
		
		if (SERVICE_ERR_MSG != null)
		{
			throw new PosException(SERVICE_ERR_MSG);
		}
		
		return context; 
	}

}