thread1.cpp.bak

电信短信应用smgp1.3协议网关,中兴开发包

// Thread1.cpp : implementation file
//

#include "stdafx.h"
#include "MyThread.h"
#include "Thread1.h"
#include <afxmt.h>
#include "smgpapi.h"
#include "smgpdef.h"
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
//_ConnectionPtr m_connection;
/////////////////////////////////////////////////////////////////////////////
// Thread1

IMPLEMENT_DYNCREATE(Thread1, CWinThread)

Thread1::Thread1()
{
	m_stop_state=false;
	m_active1=false;
	m_pDlg=NULL;
}

Thread1::~Thread1()
{
}

BOOL Thread1::InitInstance()
{
	// TODO:  perform and per-thread initialization here
	return TRUE;
}

int Thread1::ExitInstance()
{
	// TODO:  perform any per-thread cleanup here
	return CWinThread::ExitInstance();
}

BEGIN_MESSAGE_MAP(Thread1, CWinThread)
	//{{AFX_MSG_MAP(Thread1)
		// NOTE - the ClassWizard will add and remove mapping macros here.
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// Thread1 message handlers

void Thread1::GetOwner(CMyThreadDlg *m_pOwner,Thread3* pThread3)
{
	m_pDlg=m_pOwner;
	m_thread3=pThread3;
}

int Thread1::Run()
{
	CString phone,content,srcPhone,chargetermid,command,buffer,service_id,service,feeType,fixedFee,feeCode,nowtime;
	FILE*file;
	CString result;
	CTime t;
	/* Semd Msg Msg Id */
	char 		g_sMsgID[10];
/* Send Msg Error Num */
    int			g_nErrorCode = 0xff;
	char			sValidTime[18];			/* 17 bytes */
	char			sAtTime[18];
	char f_name[30];
	int m_second=0;
	char time1[20];
	int msgtype=0,contentType=0,saveType=0,isPhs=0,haveDate=0;
	try
	{
			m_recordset.CreateInstance("ADODB.Recordset");
	}
	catch(_com_error e)
 	{
		m_pDlg->AddString("Thread1创建数据集失败！");
 		return FALSE;
 	}
//////////////////////
int res=-1;

while(!m_active1)
//while(!m_stop_state)
{
	m_pDlg->g_cs.Lock();
	m_active1=m_pDlg->m_active;
	m_pDlg->g_cs.Unlock();
	if(!m_stop_state) Sleep(1000);
	else break;
}
m_pDlg->AddString("Thread1 开始");
while(!m_stop_state)
{
	try
 	{
		if(haveDate==0)
		{
			m_recordset=m_pDlg->m_connection->Execute("SELECT  convert(varchar(20),getdate()) nowtime,datepart(second,getdate()) m_second ",&RecordsAffected,adCmdText);
			nowtime.Empty();
			if(m_recordset->GetCollect("nowtime").vt == VT_NULL) continue;
			nowtime=m_recordset->GetCollect("nowtime").bstrVal;
			if(m_recordset->GetCollect("m_second").vt != VT_NULL)
			m_second=m_recordset->GetCollect("m_second").lVal;
			m_recordset->Close();
		}
		command.Empty();
	    command.Format("SELECT *FROM T_gwdx_submit where time< dateadd(second,%d,convert(datetime,'%s'))",m_second,nowtime);
		m_recordset=m_pDlg->m_connection->Execute(command.GetBuffer(0),&RecordsAffected,adCmdText);		
		if(!m_recordset->adoEOF)///	m_pDlg->AddString("读取数据ok");
			{
					haveDate=1;
					m_pDlg->g_cs.Lock();
					m_active1=m_pDlg->m_active;
					m_pDlg->g_cs.Unlock();
					if(m_active1)
					{
						while(!m_recordset->adoEOF)
 						{
						Sleep(50);
						if(m_recordset->GetCollect("msgtype").vt != VT_NULL)msgtype=m_recordset->GetCollect("msgtype").lVal;
						if(m_recordset->GetCollect("contentType").vt != VT_NULL)contentType=m_recordset->GetCollect("contentType").lVal;
						if(m_recordset->GetCollect("saveType").vt != VT_NULL)saveType=m_recordset->GetCollect("saveType").lVal;
						srcPhone.Empty();
						if(m_recordset->GetCollect("srctermid").vt != VT_NULL)srcPhone=m_recordset->GetCollect("srctermid").bstrVal;
						phone.Empty();
						if(m_recordset->GetCollect("desttermid").vt != VT_NULL)phone=m_recordset->GetCollect("desttermid").bstrVal;
						chargetermid.Empty();
						if(m_recordset->GetCollect("chargetermid").vt != VT_NULL)chargetermid=m_recordset->GetCollect("chargetermid").bstrVal;
					    content.Empty();
						if(m_recordset->GetCollect("msgcontent").vt != VT_NULL)content=m_recordset->GetCollect("msgcontent").bstrVal;
 						service_id.Empty();
						if(m_recordset->GetCollect("service_id").vt != VT_NULL)service_id=m_recordset->GetCollect("service_id").bstrVal;
						service.Empty();
						if(m_recordset->GetCollect("service").vt != VT_NULL)service=m_recordset->GetCollect("service").bstrVal;
						feeType.Empty();
						if(m_recordset->GetCollect("feetype").vt != VT_NULL)feeType=m_recordset->GetCollect("feetype").bstrVal;
						fixedFee.Empty();
						if(m_recordset->GetCollect("fixedFee").vt != VT_NULL)fixedFee=m_recordset->GetCollect("fixedFee").bstrVal;
						feeCode.Empty();
						if(m_recordset->GetCollect("feeCode").vt != VT_NULL) feeCode=m_recordset->GetCollect("feeCode").bstrVal;
						/////////
						int i=0;
						while(i<3)
						{
								memset(sValidTime,0,18);
								memset(sAtTime,0,18);
								g_nErrorCode=0;
							res=SMGPSendSingle(	0,SUBMIT_PRIORITY_ABOVE_NORMAL,service_id.GetBuffer(0),MSG_FORMAT_GB,
								feeType.GetBuffer(0),feeCode.GetBuffer(0),fixedFee.GetBuffer(0),
								sValidTime,sAtTime,chargetermid.GetBuffer(0),
								phone.GetBuffer(0),srcPhone.GetBuffer(0),content.GetLength(),
								content.GetBuffer(0),g_sMsgID,&g_nErrorCode,msgtype);
							if(res!=0)
							{
								if(g_nErrorCode!=20&&g_nErrorCode!=99)i=2;
								else
								{
								CString result;
 								result.Format("Thread1 Submit FAIL! Err=%d,res=%d",g_nErrorCode,res);
 								m_pDlg->AddString((char*)result.GetBuffer(0));
								m_pDlg->g_cs.Lock();
								m_pDlg->m_active=false;
								m_pDlg->g_cs.Unlock();
								Sleep(15000);
								}
							}
							else
							{							
								t = CTime::GetCurrentTime();
								memset(time1,0,20);
								sprintf(time1,"%d%02d%02d%02d%02d%02d",t.GetYear(),t.GetMonth(),t.GetDay(),t.GetHour(),t.GetMinute(),t.GetSecond());
								memset(f_name,0,30);
								sprintf(f_name,"log/1Thread%d%02d%02dok.txt",t.GetYear(),t.GetMonth(),t.GetDay());
								buffer.Empty();
								//buffer.Format("%s,%s,%s,%s,%d\n",srcPhone,phone,time1,content,g_nErrorCode);
								buffer.Format("%s,%s,%s,%s,%s,%s,%s,%s,%s\n",time1,feeType,fixedFee,feeCode,service_id,chargetermid,srcPhone,phone,content);
								if((file=fopen(f_name,"a"))==NULL) break;
								fwrite(buffer.GetBuffer(0),sizeof(char),buffer.GetLength(),file);
								fclose(file);
								break;
							}
							i++;
							if(i==3)
							{
								t = CTime::GetCurrentTime();								
								memset(time1,0,20);
								sprintf(time1,"%d%02d%02d%02d%02d%02d",t.GetYear(),t.GetMonth(),t.GetDay(),t.GetHour(),t.GetMinute(),t.GetSecond());
								memset(f_name,0,30);
								sprintf(f_name,"log/1Thread%d%02d%02dfail.txt",t.GetYear(),t.GetMonth(),t.GetDay());
								buffer.Empty();
								buffer.Format("%s,%s,%s,%s,%s,%s,%s,%s,%s,%d\n",time1,feeType,fixedFee,feeCode,service_id,chargetermid,srcPhone,phone,content,g_nErrorCode);
								if((file=fopen(f_name,"a"))==NULL) break;
								fwrite(buffer.GetBuffer(0),sizeof(char),buffer.GetLength(),file);
								fclose(file);
							}
						}//while i
						m_recordset->MoveNext();
 					}//end while !m_recordset->adoEOF	
					m_recordset->Close();
					command.Empty();
					command.Format("delete from T_gwdx_submit where time< dateadd(second,%d,convert(datetime,'%s'))",m_second,nowtime);
					m_pDlg->m_connection->Execute(command.GetBuffer(0),&RecordsAffected,adCmdText);			
					Sleep(100);
				}//active
				else
				{
					m_recordset->Close();
					result.Format("Thread1 say SMGP not active res=%d",res);
 					m_pDlg->AddString((char*)result.GetBuffer(0));					
					Sleep(5000);		
				}				
		}//有数据
		else 
		{
			m_recordset->Close();
			if(haveDate==1)Sleep(500);
			else Sleep(5000);
			haveDate=0;
		}
	}//end try
	catch(_com_error e)
 	{
		m_pDlg->AddString("Thread1操作数据库失败！");
		if(m_recordset->State)m_recordset->Close();
		if (m_pDlg->m_connection->State)  m_pDlg->m_connection->Close();
		//PreStop();
		//m_pDlg->g_cs.Lock();
		//m_pDlg->m_active=false;
		//m_pDlg->g_cs.Unlock();
		Sleep(5000);
		m_pDlg->ConnectDB();
 		//return FALSE;
	}
}//线程while
PreStop();
m_pDlg->AddString("thread1退出");
return 0;
}

BOOL Thread1::PreStop()
{
	try
	{	
			if (m_pDlg->m_connection->State)  m_pDlg->m_connection->Close();
			if(m_recordset->State)m_recordset->Close();
			m_pDlg->m_connection=NULL;
			m_recordset=NULL;
			m_pDlg->AddString("Thread1关闭数据库");
	}
	catch(_com_error e)
	{
		CString errormessage;
		errormessage.Format("thread1关闭数据库失败！\r\n错误信息:%s",e.ErrorMessage());
		m_pDlg->AddString((char*)&errormessage);
		return false;
	}
	return true;
}