XinYu_RZMES/.svn/pristine/c9/c9c24953fd1e46728dba9bc6b78a855e8eee3369.svn-base

package xin.glue.nui.T.T02;

import java.math.BigDecimal;

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

public class HandlerCCMChargeIndexIns extends PosActivity {

	public String runActivity(PosContext ctx) {

		PosGenericDao	mesdao	= (PosGenericDao) getDao("mesdao");
		PosGenericDao	ccmdao	= (PosGenericDao) getDao("ccmdao");

		PosSequence 	messeq	= mesdao.getSequence();
	    PosRowSet       L3MsgVO = mesdao.find("L3.Select.ChargeIns.WithOracleSEQ");

logger.logInfo("L3MsgVO Rows = ["+ L3MsgVO.count() +"]");
		while(L3MsgVO.hasNext()) {

			PosRow L3MsgROW   = L3MsgVO.next();

			BigDecimal    sDb_SeqNo                  =    (BigDecimal)L3MsgROW.getAttribute("SEQ_NO"             ) ; //SEQ_NO
			//--------------------------------------------------------------------------------------------------------------
			String        sDb_MsgFlag                =    (String    )L3MsgROW.getAttribute("MSG_FLAG"           ) ; //MSG_FLAG
//			String        sDb_TcId                   =    (String    )L3MsgROW.getAttribute("TC_ID"              ) ; //TC_ID
			String        sDb_TransDtime             =    (String    )L3MsgROW.getAttribute("TRANS_DTIME"        ) ; //TRANS_DTIME
			String        sDb_SendSeq                =    (String    )L3MsgROW.getAttribute("SEND_SEQ"           ) ; //SEND_SEQ
//			String        sDb_SendReserv             =    (String    )L3MsgROW.getAttribute("SEND_RESERV"        ) ; //SEND_RESERV
			String        sDb_SendClf                =    (String    )L3MsgROW.getAttribute("SEND_CLF"           ) ; //SEND_CLF
			String        sDb_PlanChargeNo           =    (String    )L3MsgROW.getAttribute("PLAN_CHARGE_NO"     ) ; //PLAN_CHARGE_NO
			String        sDb_CastNo                 =    (String    )L3MsgROW.getAttribute("CAST_NO"            ) ; //CAST_NO
			BigDecimal    sDb_CastEdtChargeCnt       =    (BigDecimal)L3MsgROW.getAttribute("CAST_EDT_CHARGE_CNT") ; //CAST_EDT_CHARGE_CNT
			BigDecimal    sDb_CastChargeSeq          =    (BigDecimal)L3MsgROW.getAttribute("CAST_CHARGE_SEQ"    ) ; //CAST_CHARGE_SEQ
			String        sDb_StlGrd                 =    (String    )L3MsgROW.getAttribute("STL_GRD"            ) ; //STL_GRD
			String        sDb_SpecAbbsym             =    (String    )L3MsgROW.getAttribute("SPEC_ABBSYM"        ) ; //SPEC_ABBSYM
			BigDecimal    sDb_PlanChargeWgt          =    (BigDecimal)L3MsgROW.getAttribute("PLAN_CHARGE_WGT"    ) ; //PLAN_CHARGE_WGT
			String        sDb_HmStrDtime             =    (String    )L3MsgROW.getAttribute("HM_STR_DTIME"       ) ; //HM_STR_DTIME
			String        sDb_BlowStrDtime           =    (String    )L3MsgROW.getAttribute("BLOW_STR_DTIME"     ) ; //BLOW_STR_DTIME
			String        sDb_PreBofStrDtime         =    (String    )L3MsgROW.getAttribute("PRE_BOF_STR_DTIME"  ) ; //PRE_BOF_STR_DTIME
			String        sDb_PreBofEndDtime         =    (String    )L3MsgROW.getAttribute("PRE_BOF_END_DTIME"  ) ; //PRE_BOF_END_DTIME
			String        sDb_PreCasStrDtime         =    (String    )L3MsgROW.getAttribute("PRE_CAS_STR_DTIME"  ) ; //PRE_CAS_STR_DTIME
			String        sDb_PreCasEndDtime         =    (String    )L3MsgROW.getAttribute("PRE_CAS_END_DTIME"  ) ; //PRE_CAS_END_DTIME
			String        sDb_PreRhStrDtime          =    (String    )L3MsgROW.getAttribute("PRE_RH_STR_DTIME"   ) ; //PRE_RH_STR_DTIME
			String        sDb_PreRhEndDtime          =    (String    )L3MsgROW.getAttribute("PRE_RH_END_DTIME"   ) ; //PRE_RH_END_DTIME
			String        sDb_PreLfStrDtime          =    (String    )L3MsgROW.getAttribute("PRE_LF_STR_DTIME"   ) ; //PRE_LF_STR_DTIME
			String        sDb_PreLfEndDtime          =    (String    )L3MsgROW.getAttribute("PRE_LF_END_DTIME"   ) ; //PRE_LF_END_DTIME
			String        sDb_TreatRtCd              =    (String    )L3MsgROW.getAttribute("TREAT_RT_CD"        ) ; //TREAT_RT_CD
			BigDecimal    sDb_BofTempTgt             =    (BigDecimal)L3MsgROW.getAttribute("BOF_TEMP_TGT"       ) ; //BOF_TEMP_TGT
			BigDecimal    sDb_CasTempTgt             =    (BigDecimal)L3MsgROW.getAttribute("CAS_TEMP_TGT"       ) ; //CAS_TEMP_TGT
			BigDecimal    sDb_RhTempTgt              =    (BigDecimal)L3MsgROW.getAttribute("RH_TEMP_TGT"        ) ; //RH_TEMP_TGT
			BigDecimal    sDb_LfTempTgt              =    (BigDecimal)L3MsgROW.getAttribute("LF_TEMP_TGT"        ) ; //LF_TEMP_TGT
			//--------------------------------------------------------------------------------------------------------------
//			BigDecimal    sDb_L2SeqNo                =    (BigDecimal)L3MsgROW.getAttribute("L2_SEQ_NO"          ) ; //TBG06_L2_CHARGE_INS_SEQ.NEXTVAL
			String        sDb_L2SeqNo                =    messeq.getNextStringValue("TBG06_L2_CHARGE_INS_SEQ"    ) ; //DB Sequence Name : TBG06_L2_CHARGE_INS_SEQ.NEXTVAL
			//--------------------------------------------------------------------------------------------------------------

			PosParameter  param1	= 	new PosParameter();
			param1.setWhereClauseParameter( 0 , sDb_L2SeqNo );
			PosRowSet	  rs1		=	ccmdao.find("L2.Select.ChargeIns.WithOracleSEQ", param1);
			if( rs1.count() > 0 ) {
				ccmdao.delete("L2.Delete.ChargeIns.WithOracleSEQ", param1);
			}

			//
			PosParameter  param2	= 	new PosParameter();

			param2.setValueParamter(  0, sDb_L2SeqNo          );
			param2.setValueParamter(  1, sDb_MsgFlag          );
			param2.setValueParamter(  2, sDb_TransDtime       );
			param2.setValueParamter(  3, sDb_SendSeq          );
			param2.setValueParamter(  4, sDb_SendClf          );
			param2.setValueParamter(  5, sDb_PlanChargeNo     );
			param2.setValueParamter(  6, sDb_CastNo           );
			param2.setValueParamter(  7, sDb_CastEdtChargeCnt );
			param2.setValueParamter(  8, sDb_CastChargeSeq    );
			param2.setValueParamter(  9, sDb_StlGrd           );
			param2.setValueParamter( 10, sDb_SpecAbbsym       );
			param2.setValueParamter( 11, sDb_PlanChargeWgt    );
			param2.setValueParamter( 12, sDb_HmStrDtime       );
			param2.setValueParamter( 13, sDb_BlowStrDtime     );
			param2.setValueParamter( 14, sDb_PreBofStrDtime   );
			param2.setValueParamter( 15, sDb_PreBofEndDtime   );
			param2.setValueParamter( 16, sDb_PreCasStrDtime   );
			param2.setValueParamter( 17, sDb_PreCasEndDtime   );
			param2.setValueParamter( 18, sDb_PreRhStrDtime    );
			param2.setValueParamter( 19, sDb_PreRhEndDtime    );
			param2.setValueParamter( 20, sDb_PreLfStrDtime    );
			param2.setValueParamter( 21, sDb_PreLfEndDtime    );
			param2.setValueParamter( 22, sDb_TreatRtCd        );
			param2.setValueParamter( 23, sDb_BofTempTgt       );
			param2.setValueParamter( 24, sDb_CasTempTgt       );
			param2.setValueParamter( 25, sDb_RhTempTgt        );
			param2.setValueParamter( 26, sDb_LfTempTgt        );

			int iRow = ccmdao.insert("L2.Insert.ChargeIns.WithOracleSEQ", param2);

			//
			PosParameter  param3	= 	new PosParameter();
            if( iRow > 0 ) {
    			param3.setWhereClauseParameter(  0, sDb_SeqNo      );
    			param3.setWhereClauseParameter(  1, sDb_TransDtime );
            	mesdao.update("L3.Update.ChargeIns.WithOracleSEQ", param3);
            }

		}

		return PosBizControlConstants.SUCCESS;
	}

}