XinYu_RZMES/.svn/pristine/fc/fc461536d3a7a8c0e3264ec22e5016f535838aa8.svn-base

package xin.glue.ui.J.J01;

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.msg.PosMESMessageImpl;
import com.posdata.glue.msg.PosMessage;

public class SyncCoilProgCdStatusWithE extends PosActivity {

	public String runActivity(PosContext context) {
		
        String[]    pCoilNo         =   (String[]) context.get("COIL_NO"            );
      //String[]    pCoilStat       =   (String[]) context.get("COIL_STAT"          );
        String[]    pCurProgCd      =   (String[]) context.get("CUR_PROG_CD"        );
        String[]    pCurProgCdPgm   =   (String[]) context.get("CUR_PROG_CD_PGM"    );	//PGM_ID
        String[]    pBefProgCd      =   (String[]) context.get("BEF_PROG_CD"        );
      //String[]    pBefProgCdDtime =   (String[]) context.get("BEF_PROG_CD_DTIME"  );
      //String[]    pBefProgCdPgm   =   (String[]) context.get("BEF_PROG_CD_PGM"    );

        String[]    pOrdNo          =   (String[]) context.get("ORD_NO"  			);
        String[]    pOrdSeq         =   (String[]) context.get("ORD_SEQ"    		);
        String[]    pCoilWgt   		=   (String[]) context.get("COIL_WGT"    		);
      //String[]    pProgramId      =   (String[]) context.get("PGM_ID"  			);	//CUR_PROG_CD_PGM
        String[]    pRegId          =   (String[]) context.get("REG_ID"    			);

		int			iCnt			= 	0;
		if( pCoilNo != null ) {
			iCnt	=	pCoilNo.length;
		}

		//Begin CALL NIE012070_SaveOrdSts
		//NIE012070_CALL(pCoilNo, Long.parseLong(sDb_PrevChargeWgt), sDb_RegId, P_PGM_ID );
		PosContext ctx             = null;
		PosMessage msg             = null;
		String     TcId            = "NIE012070";
		String     sMatType        = "AR";
		String     SERVICE_POSTFIX = "-service";

		for( int i = 0; i < iCnt; i++ ) {

			ctx 	= new PosContext();
			msg     = new PosMESMessageImpl();
			
			msg.setTCID(TcId);
			msg.setObject("MSG_ID"      ,   TcId                                         );
			msg.setObject("BEF_ORD_NO"  ,   ""                                           );
			msg.setObject("BEF_ORD_SEQ" ,   ""                                           ); 
			msg.setObject("ORD_NO"      ,   pOrdNo[i]                                    );
			msg.setObject("ORD_SEQ"     ,   pOrdSeq[i]                                   );
			msg.setObject("BEF_PROG_CD" ,   pBefProgCd[i]                                ); 
			msg.setObject("PROG_CD"     ,   pCurProgCd[i]                                );
			msg.setObject("MAT_TYPE"    ,   sMatType                                     );
			msg.setObject("MAT_NO"      ,   pCoilNo[i]                                   ); 
			msg.setObject("WGT"         ,   new BigDecimal(Long.parseLong(pCoilWgt[i]))	 );
			msg.setObject("PGMID"       ,   pCurProgCdPgm[i]                             ); 
			msg.setObject("REG_ID"      ,   pRegId[i]                                    ); 
			
			ctx.setMessage(msg);		
			msg.setTCID(TcId);
			
			ctx.put(PosBizControlConstants.SERVICE_NAME, TcId + SERVICE_POSTFIX);
			PosBizProvider.getController().doSubController(ctx, false);
			
			String SERVICE_ERR_MSG = (String) ctx.get("SERVICE_ERR_MSG");
			
			if( SERVICE_ERR_MSG != null ) {
				throw new PosException(SERVICE_ERR_MSG);
			}

		}
		//End CALL NIE012070_SaveOrdSts


		if( iCnt > 0 ) {
			//Begin Calling NIE012080	    //xin.glue.nui.E.E01.OrdStsMain
			TcId    = "NIE012080";
	
			ctx 	= new PosContext();
			ctx.put(PosBizControlConstants.SERVICE_NAME, TcId + SERVICE_POSTFIX);
			PosBizProvider.getController().doSubController(ctx, false);
	
			String SERVICE_ERR_MSG = (String) ctx.get("SERVICE_ERR_MSG");
			
			if( SERVICE_ERR_MSG != null ) {
				throw new PosException(SERVICE_ERR_MSG);
			}
			//End Calling NIE012080
		}

		return PosBizControlConstants.SUCCESS;

	}

}