XinYu_RZMES/.svn/pristine/0f/0f9f8921abc86335efc68da46bf8fd8f80efbe16.svn-base

package xin.glue.nui.E.E01;

import xin.glue.user.common.GlobalConstants;
import xin.glue.user.common.LogGpError;
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.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;

/* Program Name  OrdStsMain (NIE012080)
 * Description   ORDER STATUS MANAGEMENT MAIN
 * Write By      KIM SUNG HO 
 * Date          2008-10-13
 */

public class OrdStsMain extends PosActivity implements GlobalConstants {

	public String runActivity(PosContext context) {
		
		String V_TABLE_ID   = "";
		String V_TABLE_MODE = "";
		String V_ERR_DESC   = "";
		String V_RTN_NAME   = "";

		// SELECT TBE02_ORDSTS INFORMATION
		PosRowSet ordStsVO = getDao("mesdao").find("NIE012080_ORDSTS.select");
		ordStsVO.reset();

		while (ordStsVO.hasNext()) {

			PosRow ordStsRow = ordStsVO.next();

			String P_BEF_ORD_NO  = (String) ordStsRow.getAttribute("BEF_ORD_NO");
			String P_BEF_ORD_SEQ = (String) ordStsRow.getAttribute("BEF_ORD_SEQ");
			String P_ORD_NO      = (String) ordStsRow.getAttribute("ORD_NO");
			String P_ORD_SEQ     = (String) ordStsRow.getAttribute("ORD_SEQ");
			String P_BEF_PROG_CD = (String) ordStsRow.getAttribute("BEF_PROG_CD");
			String P_PROG_CD     = (String) ordStsRow.getAttribute("PROG_CD");
			String P_MAT_TYPE    = (String) ordStsRow.getAttribute("MAT_TYPE");
			String P_MAT_NO      = (String) ordStsRow.getAttribute("MAT_NO");
			String P_PGMID       = (String) ordStsRow.getAttribute("PGMID");
			String P_REG_ID      = (String) ordStsRow.getAttribute("REG_ID");

			PosMessage message = new PosMESMessageImpl();

			message.setObject("BEF_ORD_NO",  P_BEF_ORD_NO);
			message.setObject("BEF_ORD_SEQ", P_BEF_ORD_SEQ);
			message.setObject("ORD_NO",      P_ORD_NO);
			message.setObject("ORD_SEQ",     P_ORD_SEQ);
			message.setObject("BEF_PROG_CD", P_BEF_PROG_CD);
			message.setObject("PROG_CD",     P_PROG_CD);
			message.setObject("MAT_TYPE",    P_MAT_TYPE);
			message.setObject("MAT_NO",      P_MAT_NO);
			message.setObject("PGMID",       P_PGMID);
			message.setObject("REG_ID",      P_REG_ID);
			
			context.setMessage(message);
			// message.setTCID(TcId);

			if  ((P_BEF_PROG_CD == null || "".equals(P_BEF_PROG_CD)) & 
				 (P_PROG_CD     == null || "".equals(P_PROG_CD)) )  {
				
		
			} else {
				
				String SERVICE_POSTFIX = "-service";
				if (P_MAT_TYPE.equals("CH")) {
					// CALL NIE012081_OrdStsCharge
					message.setObject("MSG_ID", "NIE012081");
					context.put(PosBizControlConstants.SERVICE_NAME, "NIE012081" + SERVICE_POSTFIX);
					PosBizProvider.getController().doSubController(context, false);
					
				} else if (P_MAT_TYPE.equals("TM")) {
					// CALL NIE012082_OrdStsSlab
					message.setObject("MSG_ID", "NIE012082");
					context.put(PosBizControlConstants.SERVICE_NAME, "NIE012082" + SERVICE_POSTFIX);
					PosBizProvider.getController().doSubController(context, false);
					
				} else if (P_MAT_TYPE.equals("AR")) {
					// CALL NIE012083_OrdStsCoil
					message.setObject("MSG_ID", "NIE012083");
					context.put(PosBizControlConstants.SERVICE_NAME, "NIE012083" + SERVICE_POSTFIX);
					PosBizProvider.getController().doSubController(context, false);
				}

			}
			
			// UPDATE TBE02_ORDSTS FL = '*' (ORD STATUS PROCESS COMPLETE)
			PosParameter param1 = new PosParameter();
			param1.setValueParamter(0, ordStsRow.getAttribute("OCC_SEQ"));
			int UpdCnt = getDao("mesdao").update("NIE012080_ORDSTS.update", param1);

			if (UpdCnt == 0) {
				V_TABLE_ID = "TBE02_ORDSTS";
				V_TABLE_MODE = "U";
				V_ERR_DESC = "TBE02_ORDSTS UPDATE COUNT IS ZERO";
				V_RTN_NAME = "OrdStsMain TBE02_ORDSTS UPDATE";

				LogGpError.logMessageToDB("OrdStsMain", V_TABLE_ID, V_TABLE_MODE, V_ERR_DESC, V_RTN_NAME);
				throw new PosException(V_RTN_NAME);
			}
		}

		// DELETE TBE02_ORD_PRC_DET TOT_WGT = 0
		getDao("mesdao").delete("NIE012080_ORDPRCDET.delete");
		return PosBizControlConstants.SUCCESS;
	}
	
}