package xin.glue.ui.G.G06;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

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.PosJobScheduler;
import com.posdata.glue.component.layout.PosMessageLayoutIF;
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;
import com.posdata.glue.msg.PosMessageAttributeDefinition;
import com.posdata.glue.msg.PosMessageDefinition;
import com.posdata.glue.util.log.PosLog;
import com.posdata.glue.util.log.PosLogFactory;


public class XinSaveRecieveData extends PosActivity {
	private final PosLog log = PosLogFactory.getLogger(getClass());

	public String runActivity(PosContext context) {
		
		  log.logInfo("======== XinSaveRecieveData start ==== " );
				
	 
//	  PosContext.getBeanFactory().getBeanObject("scheduler");
	   
 	  PosGenericDao mesdao  = (PosGenericDao)getDao("mesdao");	 
//	//  PosGenericDao krmdao  = (PosGenericDao)getDao("krdao");		
//	//  PosGenericDao bofmdao = (PosGenericDao)getDao("bofmdao");
//	//  PosGenericDao casdao  = (PosGenericDao)getDao("casdao");
//	//  PosGenericDao lfdao   = (PosGenericDao)getDao("lfdao");
//	//  PosGenericDao rhdao   = (PosGenericDao)getDao("rhdao");
  	  PosGenericDao ccmdao  = (PosGenericDao)getDao("ccmdao");
//      
	  
	  
      PosParameter param1 = new PosParameter();   
      PosRowSet L2MsgVO = ccmdao.find("UIG060010_CCM_L2_MSG.select");
      
      String MSG_DATA =   null;
      String MSG_ID   =   null; 
      
      if(L2MsgVO.hasNext()) {
    		 
    	  PosRow L2MsgROW = L2MsgVO.next();
    	  
    	  MSG_DATA      = (String)L2MsgROW.getAttribute("MSG_DATA");
    	  MSG_ID        = (String)L2MsgROW.getAttribute("MSG_ID");
    	  Number SeqNo  = (Number)L2MsgROW.getAttribute("SEQ_NO");
    	  
    	  log.logInfo("======== XinSaveDataLevel2 MSG_DATA["+MSG_DATA+"]" );
    	  log.logInfo("======== XinSaveDataLevel2 SeqNo["+SeqNo+"]" );
    	  
    	 
   	      
   	      PosParameter param3 = new PosParameter();
          param3.setValueParamter(0,SeqNo    ); 
          ccmdao.update("UIG060010_L2_MSG.update", param3);
          
 	  
          PosParameter param2 = new PosParameter();
    	  param2.setValueParamter(0,MSG_DATA    ); 
   	      mesdao.update("UIG060010_MES_MSG.insert", param2);
    	  
   	      TC_SEND(MSG_DATA,MSG_ID); 
   	     	   
      }  
         	
 
			 
      log.logInfo("======== XinSaveRecieveData  cend :" );
      
     
      
	  return PosBizControlConstants.SUCCESS;
	}
	public void TC_SEND(String sMsg, String TcId  ) {
		PosContext context = new PosContext();
		PosMessage message = new PosMESMessageImpl();
	 
		String TC_MSG = TcId+sMsg;
		 
	 
		message.setTC(TC_MSG);
		message.setTCID(TcId);
		 
		context.setMessage(message);		
	 	
		String SERVICE_POSTFIX = "-service";
		context.put(PosBizControlConstants.SERVICE_NAME, TcId + SERVICE_POSTFIX);
		PosBizProvider.getController().doSubController(context, false);
		
      		
		log.logInfo("controller context: "+context );
	}
}