📄 shppsessioninterface.cpp

📁 本源码为移动公司话费查询中间件TUXEDO使用的实例
💻 CPP
📖 第 1 页 / 共 3 页
字号:
12 3 下一页
/*******************************************
* file name:   SHPPSessionInterface.h
* date:        2002.7.27
* 用途：       定义自助话打印协议SHPP
* 作者：       林游海
*******************************************/

#include "SHPPSessionInterface.h"
#ifndef _WIN32
#include <arpa/inet.h>
#endif
#include <time.h>

#include "OS.h"
#define FILDECOUND     7
#define PRINTEND       1
#define PROC_PROCESS   0

/*
CStrPtrLen CSHPPSessionInterface::s_splTelType[] = 
{
	CStrPtrLen("漫主"),
	CStrPtrLen("漫被"),
	CStrPtrLen("本主"),
	CStrPtrLen("本被"), 
	CStrPtrLen("国主"), 
	CStrPtrLen("国被")
};
*/
#ifndef _WIN32
pthread_mutex_t CSHPPSessionInterface::db_mutex ;//PTHREAD_MUTEX_INITALIZER;
#else
HANDLE          CSHPPSessionInterface::db_mutex ;//PTHREAD_MUTEX_INITALIZER;
#endif

CStrPtrLen CSHPPSessionInterface::s_splTelType[] = 
{
	CStrPtrLen("主"),
	CStrPtrLen("被"),
};


char CSHPPSessionInterface::s_chSeparator[] = 
{"------------------------------------------------"};

CSHPPSessionInterface::CSHPPSessionInterface(CSHPPSocket* pSocket,CDBAdmin *pDBAmin,UInt32 nSessionID,long nPosNO,char* pClientIP)
:	m_shppRequest(&m_sConnect)
{
	m_nSessionID = nSessionID;
//by yhl 2002 9 01
#if PROC_PROCESS
	m_pDBAmin = NULL;
#else 
	m_pDBAmin = pDBAmin;
#endif //PROC_PROCESS
// by end

	m_sConnect.m_hSocket = pSocket->m_hSocket;
	m_nPopedom = knUserPopedom;
	memset(m_chPhone,0,knTelOffset);
	memset(m_chPass,0,PHONEBUFFER);

	strcpy(m_chClientIP, pClientIP);
	m_chBusinessTitle[0] = '\0';
	m_chBusinessAddr[0] = '\0';
	m_splClientIP.Set(m_chClientIP);
	m_splSessionID.Set((char*)&m_nSessionID,sizeof(UInt32));
	m_nPosNO = nPosNO;

	memset(m_chMonth,'\0',7);
	m_fFeeCount = 0.0;
	m_nCountLine = 0;
	m_nTelType = 0;
	m_IsSelect= 1 ;

	m_nLiveTime = 0;

}

CSHPPSessionInterface::~CSHPPSessionInterface()
{
	m_shppRequest.GetSocker()->Cleanup();

#ifdef _WIN32
	::CoUninitialize();
#endif

	//add yhl 2002 9 02 
/*	if(m_pDBAmin )
	{
		m_pDBAmin->DBDisconnectDatabase();
		delete m_pDBAmin;
	}
*/	//end add
}

int CSHPPSessionInterface::Initialize()
{
#ifndef _WIN32
	pthread_mutex_init (&db_mutex,NULL);
#else
	db_mutex = ::CreateMutex(NULL,FALSE,NULL);
#endif //_WIN32
	return 0;
}

void CSHPPSessionInterface::SHPPClose()
{
	if(fRunning == false)
		return ;

	m_sConnect.Cleanup();
//	Join();
}

SInt64 CSHPPSessionInterface::Run()
{
//printf("######开始#####\n");
	KN_Error knError;
	UInt16 nServerType ;
	char chPhone[21];
	

	try{
#ifdef _WIN32
		::CoInitialize(NULL);
#endif

		m_nLiveTime = 5; //收到请求这个系数就是满的.

		knError = m_shppRequest.Parse();
		WriteLog(m_sConnect.GetReadBuf());
//		printf(m_sConnect.GetReadBuf());
//		printf("m_shppRequest.Parse返回结果:%d\n",knError);
		if(knError != KN_OK)
		{
			printf("数据:%s\n",m_sConnect.GetReadBuf());
			return m_shppRequest.SendError(knError);
		}

		nServerType = m_shppRequest.GetServerType();
		m_shppRequest.PutServerType(nServerType);

		strcpy(chPhone,m_shppRequest.GetPhone());
	//	m_shppRequest.GetTel(m_shppRequest.GetSocker()->GetReadBuf(),m_chPhone);
		printf("%s服务类型：%d,参数：%s\n",chPhone,nServerType,m_shppRequest.GetParameter());
		
		if(nServerType == shppGetInfoMethod || nServerType == shppLookCommMethod)
		{
			//获得打印机信息
			char chInfo[512];

			sprintf(chInfo,"%d\t%d\t%d\t%s",m_sysParamStruct.nTelType,m_sysParamStruct.nIsView,
				m_sysParamStruct.nIsSelfQuery,m_chBusinessTitle);

	//		printf("打印机信息:\n%s\n",chInfo);

			m_shppRequest.PutParameter(chInfo);
			if(m_sysParamStruct.nTelType > 0)
				m_shppRequest.PutParameter(m_sysParamStruct.chTelType);
			 m_shppRequest.Flush();

			return KN_OK;
		}
		else if(nServerType == shppServerlife)
		{
			return m_shppRequest.SendError(KN_OK);
		}

#if PROC_PROCESS
		if(m_pDBAmin == NULL)
		{
			m_pDBAmin = new CDBAdmin;
		}
		knError = m_pDBAmin->DBConnectDatabase("known","known","known");
		
		if(knError != KN_OK)
		{
			printf("CSHPPSessionInterface:连接数据库失败,服务器无法启动\r\n");
			m_sConnect.Cleanup();
			WriteLog("线程退出!",-1);
			return m_shppRequest.SendError(shppH2ServerErr);
		}
#endif //PROC_PROCESS
		
		if(nServerType == shppLoginMethod)
		{
			char chParam[3][FIELDBUFFER];
			strcpy(m_chPhone,m_shppRequest.GetPhone());


			//获取参数
			knError = m_shppRequest.GetNextParameter(3,(char**)chParam);
			if(chParam[0][0] == '\0')
			{
				return m_shppRequest.SendError(shppPhoneErr);
			}
			strcpy(m_chPass,chParam[0]);

			if(knError != KN_OK)
				return m_shppRequest.SendError(knError);
			knError = -1;//KN_OK;

			//是否电话号
			
/*			if(m_chPhone[0] != '1' || m_chPhone[1] != '3')
			{
				return m_shppRequest.SendError(shppPhoneErr);
			}*/

			//是否是管理帐号
			if(memcmp(m_chPhone,"04",2) == 0 )
			{
				printf("输入的管理员号码为:%s",m_chPhone);
#ifndef _WIN32
				pthread_mutex_lock(&db_mutex);
#else
				WaitForSingleObject(db_mutex,INFINITE);
#endif //_WIN32
				printf("DB密码检测号码:%s,pass = %s---开始--,\n",m_chPhone,m_chPass);
				knError = m_pDBAmin->DBCheckOperPasswd(m_nPosNO,m_chPhone,m_chPass,&m_nPopedom);
				printf("DB检测完号码:%s,pass = %s,knError = %d---结束---\n",m_chPhone,m_chPass,knError);
#ifndef _WIN32
				pthread_mutex_unlock(&db_mutex);
#else
				ReleaseMutex(db_mutex);
#endif //_WIN32
			}

			if(knError != KN_OK)
			{
				//密码登入
				if(m_sysParamStruct.PrintDefPwd != '1')
				{
					if(strcmp(m_chPass,"123456") == 0)
					{
						m_nPopedom = knUserPopedom;
						return m_shppRequest.SendError(shppDefaultIsPrint);
					}
				}
				//==================================
				char numbuf[4];
				int renum=20;
				strncpy(numbuf,m_chPhone,3);
				numbuf[3]='\0';
				renum=atoi(numbuf);
				if(renum<135)//不是移动用户
					return m_shppRequest.SendError(shppnouser);//要加注释	

#ifndef _WIN32
				pthread_mutex_lock(&db_mutex);
#else
				WaitForSingleObject(db_mutex,INFINITE);
#endif //_WIN32
				char phonetemp[8];//取中间件地址
				memset(phonetemp,'\0',8);
				strncpy(phonetemp,m_chPhone,7);
				memset(m_sysParamStruct.wsaddrlist,'\0',30);
				renum=20;
				renum=m_pDBAmin->DBQuerysddrlist(phonetemp,m_sysParamStruct.wsaddrlist);
#ifndef _WIN32
				pthread_mutex_unlock(&db_mutex);
#else
				ReleaseMutex(db_mutex);
#endif //_WIN32
				
				if(renum!=0)
				{
					FILE*  f = NULL;
					if((f = fopen("c:\\log.txt","a+"))==NULL)
					{
						printf("打开临时文件失败\n");
					}
					else
					{
						fseek(f,0,SEEK_END);
						fwrite(phonetemp, sizeof(char), strlen(phonetemp), f);		
						fclose(f);
						f=NULL;	
					}			
					return m_shppRequest.SendError(shppnoadrlist);//要加注释	
				}			
				
				//=================================

				
				chParam[0][0] = 0;
			//	knError = UserCheckPass(m_chPhone,m_chPass,NULL,chParam[0]);
				knError = UserCheckPass(m_chPhone,m_chPass,m_sysParamStruct.wsaddrlist,chParam[0]);
				
				if(knError != KN_OK)
				{
					m_nPopedom = knNULLPopedom;
					
					if(knError == shppServerErr)
						return m_shppRequest.SendError(shppServerErr);
					else if(knError==1000)
						return m_shppRequest.SendError(shppTryAgain);
					else if(knError==1001)
						return m_shppRequest.SendError(shppTryAgain);
					else if(knError==1003)
						return m_shppRequest.SendError(shppTryAgain);
					else
						return m_shppRequest.SendError(shppPasswordErr);
				}
				m_shppRequest.PutResult(knError);

				m_nPopedom = knUserPopedom;

				//需要发送打印时间

				GetPrintTime(m_sysParamStruct.chPrintTime,m_sysParamStruct.nBeginDay ,
					m_sysParamStruct.nEndDay ,m_sysParamStruct.nBackDay ,
								m_sysParamStruct.bRealTimeQuery,m_sysParamStruct.nMonthSize);

				char pass2[10];
				memset(pass2,'\0',10);
				knError = UserCheck2Pass(m_chPhone,pass2,m_sysParamStruct.wsaddrlist,chParam[0]);
				
				m_shppRequest.PutParameter("2");

				if((knError==0)&&(atoi(pass2)!=0))
					m_shppRequest.PutParameter(pass2);
				else
					m_shppRequest.PutParameter("KNOWN");
				
				m_shppRequest.PutParameter(m_sysParamStruct.chPrintTime);
				//by yhl end
				m_shppRequest.Flush();
				return KN_OK;

			}
			m_shppRequest.PutParameter("1");
			return m_shppRequest.SendError(knError);

		}
		else if(nServerType == shppLiveOpdata)
		{
			knError = OnLiveOpdata();
		}
		else{


			if(strcmp(chPhone,m_chPhone) != 0 )
				return m_shppRequest.SendError(shppPopedomErr);

			switch(m_nPopedom)
			{
			case knAdimiPopedom:
				knError = AdmiPopedom();
				break;
			case knManagePopedom:
				knError = ManagePopedom();
				break;
			case knUserPopedom:
				knError = UserPopedom();
				break;
			default:
				{
				knError = shppPopedomErr;
				}
				break;
			}
		}

	}
	catch(...)
	{
		printf("##异常出错，线程退出err=%d##\n",::GetLastError());
		m_sConnect.Cleanup();
#ifdef _WIN32
	::CoUninitialize();
#endif
		return 1;
	}

	if(knError != KN_OK)
	{
		m_shppRequest.Reset();

		//WriteLog(CSHPPProtocol::GetErrorString(knError).m_pchPtr,2);
		m_shppRequest.SendError(knError);
	}
//	m_sConnect.Cleanup();
//	WriteLog("线程退出!",2);
#if PROC_PROCESS
	m_pDBAmin->DBDisconnectDatabase();
#endif //PROC_PROCESS

#ifdef _WIN32
	::CoUninitialize();
#endif
	return 1;
}

KN_Error CSHPPSessionInterface::Popedom()
{
	m_nPopedom = knAdimiPopedom;
	return KN_OK;
}

int CSHPPSessionInterface::WriteLog(char *pLog,UInt16 nType)
{
	int nLen;
	char chLog[512],chTime[21];

	OS::GetSysDateTime(chTime);

	switch(nType)
	{
	case 0:
		nLen = sprintf(chLog,"%s %s收到请求:\r\n%s",chTime,m_chClientIP,pLog);
12 3 下一页
💿 文件大小 387 K
👤 上传用户 fengkuangyidao
📂 所属分类中间件编程
🏷️ 相关标签

#TUXEDO #源码 #查询 #移动
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -