requestwait.cpp

联通接收发送新程序

// RequestWait.cpp: implementation of the CRequestWait class.
//
//////////////////////////////////////////////////////////////////////

#include "RequestWait.h"

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CRequestWait::CRequestWait( XW_Connection &conn/*= DefaultConnect*/) : Connect(conn),
																	   oCode( conn ) ,
	  																   t_request_wait( conn ),
																	   m_cNbrSeg( conn )
{

}

CRequestWait::~CRequestWait()
{

}

int CRequestWait::InsertRequest( StruRequest &stRequest )
{
	long j = 0 ;
	long RequestID = oCode.NewCode( "REQUEST_ID" ) ;
	if ( RequestID > 0 )
	{
		oTime.GetLocalTime() ;
		string str = oTime.GetDate() ;
		str += oTime.GetTime() ;

		t_request_wait.Clear() ;
		t_request_wait.REQUEST_ID = RequestID ;
		t_request_wait.ACCT_NBR = stRequest.acct_nbr ;
		t_request_wait.MSG_LENGTH = stRequest.msg_length ;
		t_request_wait.MSG_CONTENT = stRequest.msg_content ;
		t_request_wait.MO_TIME = str.c_str() ;
		t_request_wait.SP_CODE = stRequest.sp_code ;
		t_request_wait.INF_TYPE_ID = stRequest.inf_type_id ;
		t_request_wait.REGION_CODE = stRequest.region_code ;
		
		strcpy( stRequest.area_code,m_cNbrSeg.LookUp(stRequest.acct_nbr) );
		t_request_wait.AREA_CODE = stRequest.area_code ;
		
		str = GATEWAY_ID ; //char[1]
		t_request_wait.GATEWAY_ID = str.c_str() ;
		
		j = t_request_wait.Insert() ;
		
		char s[128];
		strcpy( s,Connect.GetMsg() ) ;

		if( j > 0 )
			Connect.Commit() ;
		else
			Connect.Rollback() ;
	}
	else
		j = -1 ;

	return (int)j ;
}