dispensereport.cpp

联通接收发送新程序

// DispenseReport.cpp: implementation of the CDispenseReport class.
//
//////////////////////////////////////////////////////////////////////

#include "DispenseReport.h"

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

CDispenseReport::CDispenseReport(XW_Connection &conn/*=DefaultConnect*/) : Connect( conn ),
																  	     t_dispense_report( conn ),
														                 t_dispense_waitlog( conn )
														  
{

}

CDispenseReport::~CDispenseReport()
{

}

int CDispenseReport::InsertWait( StruDispense &stDispense ) 
{
	long j = 0 ;

	t_dispense_report.Clear() ;
	t_dispense_report.DISPENSE_ID = stDispense.dispense_id ;
	t_dispense_report.MSG_ID = stDispense.msg_id ;	
	t_dispense_report.INFORMATION_ID = stDispense.information_id ;
	t_dispense_report.SP_CODE = stDispense.sp_code ;
	t_dispense_report.ACCT_NBR = stDispense.acct_nbr ;
	t_dispense_report.DEST_NBR = stDispense.dest_nbr ;
	t_dispense_report.REPLY_TYPE = stDispense.reply_type ;
	t_dispense_report.MSG_CONTENT = stDispense.msg_content ;
	t_dispense_report.CONTENT_TYPE = stDispense.content_type ;
	t_dispense_report.MO_TIME = stDispense.mo_time ;
	t_dispense_report.SEND_TIME = stDispense.send_time ;			
	t_dispense_report.REPLY_TIME = stDispense.reply_time ;			
	t_dispense_report.GATEWAY_STATE = stDispense.gateway_state ;	
	t_dispense_report.TRY_TIMES = stDispense.try_times ;			
	t_dispense_report.SERVICE_CODE = stDispense.service_code ;
	t_dispense_report.FEE_TYPE = stDispense.fee_type ;
	t_dispense_report.FEE_CODE = stDispense.fee_code ;
	t_dispense_report.MSG_PRI = stDispense.msg_pri ;
	t_dispense_report.VALID_TIME = stDispense.valid_time ;
	t_dispense_report.AT_TIME = stDispense.at_time ;
	t_dispense_report.REGION_CODE = stDispense.region_code ;
	t_dispense_report.AREA_CODE = stDispense.area_code ;
	
	j = t_dispense_report.Insert() ;
	if ( j > 0 )
		Connect.Commit() ;
	else
		Connect.Rollback() ;

	return int(j) ;
}

int CDispenseReport::SetReport( StruReport &stReport ) 
{
	pcSql[ 0 ] = 0 ;
	sprintf( pcSql," MSG_ID = '%s' ",stReport.message_id ) ;
	long j = t_dispense_report.Query( pcSql ) ;
	if ( j > 0 )
	{
		t_dispense_waitlog.Clear() ;
		t_dispense_waitlog = t_dispense_report ;

		oTime.GetLocalTime() ;
		string str = oTime.GetDate() ;
		str += oTime.GetTime() ;

		t_dispense_waitlog.REPLY_TIME = str.c_str() ;	
		t_dispense_waitlog.STATE_REPORT = stReport.state ;
		
		j = t_dispense_waitlog.Insert() ;
		if ( j > 0 )
			j = t_dispense_report.Delete() ;
	}

	if ( j > 0 )
		Connect.Commit() ;
	else
		Connect.Rollback() ;
	
	return (int)j ;
}