?? shppsessioninterface.cpp
字號:
/*******************************************
* file name: SHPPSessionInterface.h
* date: 2002.7.27
* 用途： 定義自助話打印協(xié)議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; //收到請求這個系數(shù)就是滿的.
knError = m_shppRequest.Parse();
WriteLog(m_sConnect.GetReadBuf());
// printf(m_sConnect.GetReadBuf());
// printf("m_shppRequest.Parse返回結(jié)果:%d\n",knError);
if(knError != KN_OK)
{
printf("數(shù)據(jù):%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服務(wù)類型：%d,參數(shù)：%s\n",chPhone,nServerType,m_shppRequest.GetParameter());
if(nServerType == shppGetInfoMethod || nServerType == shppLookCommMethod)
{
//獲得打印機(jī)信息
char chInfo[512];
sprintf(chInfo,"%d\t%d\t%d\t%s",m_sysParamStruct.nTelType,m_sysParamStruct.nIsView,
m_sysParamStruct.nIsSelfQuery,m_chBusinessTitle);
// printf("打印機(jī)信息:\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:連接數(shù)據(jù)庫失敗,服務(wù)器無法啟動\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());
//獲取參數(shù)
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---結(jié)束---\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;
//需要發(fā)送打印時間
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);
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -