976 lines
29 KiB
C++
976 lines
29 KiB
C++
#include "StdAfx.h"
|
||
#include<iostream>
|
||
#define MAIL_DATA_SEND_COUNT_EACH_TIME 50//每次发送的邮件数
|
||
#define MAILATTACH_DATA_SEND_COUNT_EACH_TIME 500//每次发送的附件数
|
||
#define LoadDbTypeServerMail 0
|
||
#define LoadDbTypeServerMailAttach 1
|
||
#define LoadDbTypeServerMailComplete 2
|
||
void CLogicDBReqestHandler::LoadMsgList(CDataPacketReader &inPacket)
|
||
{
|
||
int nRawServerId = 0, nLoginServerId = 0;
|
||
unsigned int nActorid = 0;
|
||
INT64 nMsgId = 0;
|
||
inPacket >> nRawServerId >> nLoginServerId >> nActorid;
|
||
inPacket >> nMsgId;
|
||
LoadMsgListFromId(nActorid, nMsgId, nRawServerId, nLoginServerId);
|
||
}
|
||
|
||
void CLogicDBReqestHandler::LoadMsgListFromId(unsigned int nActorId,INT64 nMsgId, int nRawServerId, int nLoginServerId)
|
||
{
|
||
DECLARE_FUN_TIME_PROF()
|
||
|
||
CDataPacket& tmp = allocProtoPacket(dcLoadMsg);
|
||
tmp << nRawServerId << nLoginServerId;
|
||
CDataPacket* out = &tmp;
|
||
(*out) << (unsigned int)nActorId;
|
||
//数据库连接是否就绪
|
||
if ( !m_pSQLConnection->Connected() )
|
||
{
|
||
(*out) << (BYTE)reDbErr ;
|
||
}
|
||
else
|
||
{
|
||
int nError = m_pSQLConnection->Query(szSQLSP_LoadCharMsgList, nActorId,nMsgId);
|
||
if ( !nError )
|
||
{
|
||
(*out) << (BYTE)reSucc ;
|
||
MYSQL_ROW pRow = m_pSQLConnection->CurrentRow();
|
||
int nCount = m_pSQLConnection->GetRowCount();
|
||
|
||
INT_PTR pos = out->getPosition();
|
||
(*out) << (WORD)0;
|
||
nCount = 0;
|
||
|
||
|
||
while ( pRow)
|
||
{
|
||
nCount++;
|
||
if (nCount > 100)
|
||
{
|
||
WORD* pCount = (WORD*)out->getPositionPtr(pos);
|
||
*pCount = (WORD)(nCount-1);
|
||
flushProtoPacket((*out));
|
||
|
||
CDataPacket& msgNew = allocProtoPacket(dcLoadMsg);
|
||
msgNew << nRawServerId << nLoginServerId;
|
||
out = &msgNew;
|
||
(*out) << (unsigned int)nActorId;
|
||
|
||
(*out) << (BYTE)reSucc;
|
||
pos = out->getPosition();
|
||
(*out) <<(WORD)0;
|
||
nCount = 1;
|
||
}
|
||
INT64 nMsgid = StrToInt64(pRow[0]);
|
||
int nMsgtype = _StrToInt(pRow[1]);
|
||
int nBufSize = LOWORD(nMsgtype);//大小是低字节
|
||
nMsgtype = HIWORD(nMsgtype); //消息类型是高字节
|
||
|
||
if (pRow[2] == NULL)
|
||
{
|
||
nBufSize = 0;
|
||
}
|
||
|
||
(*out) << (INT64)nMsgid;
|
||
(*out) << (BYTE)nMsgtype;
|
||
(*out) << (WORD)nBufSize;
|
||
if (pRow[2])
|
||
{
|
||
out->writeBuf(pRow[2],nBufSize);
|
||
}
|
||
pRow = m_pSQLConnection->NextRow();
|
||
}
|
||
WORD* pCount = (WORD*)out->getPositionPtr(pos);
|
||
*pCount = (WORD)nCount;
|
||
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
else
|
||
{
|
||
(*out) << (BYTE)reDbErr ;
|
||
}
|
||
|
||
}
|
||
|
||
flushProtoPacket(*out);
|
||
}
|
||
|
||
void CLogicDBReqestHandler::DeleteMsg(CDataPacketReader &inPacket)
|
||
{
|
||
DECLARE_FUN_TIME_PROF()
|
||
int nRawServerId = 0, nLoginServerId = 0;
|
||
INT64 msgid = 0;
|
||
unsigned int nActorId = 0;
|
||
inPacket >> nRawServerId >> nLoginServerId;
|
||
inPacket >> nActorId;
|
||
inPacket >> msgid;
|
||
|
||
CDataPacket& retPack = allocProtoPacket(dcDeleteMsg);
|
||
retPack << nRawServerId << nLoginServerId;
|
||
retPack << nActorId;
|
||
|
||
//数据库连接是否就绪
|
||
if ( !m_pSQLConnection->Connected() )
|
||
{
|
||
retPack << (BYTE)reDbErr ;
|
||
retPack << msgid;//如果失败了，要告诉逻辑服务器那条失败了
|
||
}
|
||
else
|
||
{
|
||
int nError = m_pSQLConnection->Exec(szSQLSP_DeleteCharMsg, nActorId,msgid);
|
||
if ( !nError )
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
retPack << (BYTE)reSucc ;
|
||
retPack << msgid;//如果失败了，要告诉逻辑服务器那条失败了
|
||
}
|
||
else
|
||
{
|
||
retPack << (BYTE)reDbErr ;
|
||
retPack << msgid;//如果失败了，要告诉逻辑服务器那条失败了
|
||
}
|
||
|
||
}
|
||
|
||
flushProtoPacket(retPack);
|
||
}
|
||
|
||
void CLogicDBReqestHandler::AddMsg(CDataPacketReader &inPacket)
|
||
{
|
||
DECLARE_FUN_TIME_PROF()
|
||
int nRawServerId = 0, nLoginServerId = 0;
|
||
unsigned int nActorId = 0,nSrcActorId = 0;
|
||
int nMsgType = 0;
|
||
int bufsize = 0;
|
||
inPacket >> nRawServerId >> nLoginServerId;
|
||
inPacket >> nActorId;
|
||
inPacket >> nSrcActorId;
|
||
inPacket >> nMsgType;
|
||
inPacket >> bufsize;
|
||
|
||
CDataPacket& retPack = allocProtoPacket(dcAddMsg);
|
||
retPack << nRawServerId << nLoginServerId;
|
||
retPack << nActorId;
|
||
retPack << nSrcActorId;
|
||
nMsgType = MAKELONG(bufsize,nMsgType);//a是低直接
|
||
//数据库连接是否就绪
|
||
if ( !m_pSQLConnection->Connected() )
|
||
{
|
||
retPack << (BYTE)reDbErr ;
|
||
}
|
||
else
|
||
{
|
||
char *ptr = m_pHugeSQLBuffer;
|
||
|
||
ptr += sprintf(ptr, szSQLSP_AddCharMsg, nActorId,nMsgType);
|
||
ptr[0] = '"';
|
||
ptr += 1;
|
||
ptr += mysql_escape_string(ptr, inPacket.getOffsetPtr(), bufsize);
|
||
ptr[0] = '"';
|
||
ptr[1] = ')';
|
||
ptr += 2;
|
||
|
||
int nError = m_pSQLConnection->RealQuery(m_pHugeSQLBuffer,ptr - m_pHugeSQLBuffer);
|
||
if ( !nError )
|
||
{
|
||
retPack << (BYTE)reSucc ;
|
||
MYSQL_ROW pRow = m_pSQLConnection->CurrentRow();
|
||
if (pRow)
|
||
{
|
||
INT64 Msgid = StrToInt64(pRow[0]);
|
||
retPack << (INT64)Msgid;
|
||
}
|
||
m_pSQLConnection->ResetQuery();
|
||
|
||
}
|
||
else
|
||
{
|
||
retPack << (BYTE)reDbErr ;
|
||
}
|
||
|
||
}
|
||
|
||
flushProtoPacket(retPack);
|
||
}
|
||
|
||
void CLogicDBReqestHandler::AddMsgByName(CDataPacketReader &inPacket)
|
||
{
|
||
DECLARE_FUN_TIME_PROF()
|
||
int nRawServerId = 0, nLoginServerId = 0;
|
||
int nSrcActorId = 0;
|
||
int nServerIdx = -1;
|
||
int nMsgType = 0;
|
||
int bufsize = 0;
|
||
ACTORNAME actorName;
|
||
inPacket >> nRawServerId >> nLoginServerId;
|
||
inPacket >> nSrcActorId;
|
||
inPacket >> nServerIdx;
|
||
inPacket.readString(actorName,ArrayCount(actorName));
|
||
inPacket >> nMsgType;
|
||
inPacket >> bufsize;
|
||
|
||
int actorId = 0;
|
||
CDataPacket& retPack = allocProtoPacket(dcAddMsgByActorName);
|
||
retPack << nRawServerId << nLoginServerId;
|
||
retPack.writeString(actorName);
|
||
retPack << (int)nSrcActorId;
|
||
|
||
nMsgType = MAKELONG(bufsize,nMsgType);//a是低直接
|
||
//数据库连接是否就绪
|
||
if ( !m_pSQLConnection->Connected() )
|
||
{
|
||
retPack << (BYTE)reDbErr ;
|
||
}
|
||
else
|
||
{
|
||
char *ptr = m_pHugeSQLBuffer;
|
||
|
||
ptr += sprintf(ptr, szSQLSP_AddCharMsgByName, nServerIdx, actorName,nMsgType);
|
||
ptr[0] = '"';
|
||
ptr += 1;
|
||
ptr += mysql_escape_string(ptr, inPacket.getOffsetPtr(), bufsize);
|
||
ptr[0] = '"';
|
||
ptr[1] = ')';
|
||
ptr += 2;
|
||
|
||
int nError = m_pSQLConnection->RealQuery(m_pHugeSQLBuffer, ptr - m_pHugeSQLBuffer);
|
||
if ( !nError )
|
||
{
|
||
retPack << (BYTE)reSucc ;
|
||
MYSQL_ROW pRow = m_pSQLConnection->CurrentRow();
|
||
if (pRow)
|
||
{
|
||
unsigned int nActorId = _StrToInt(pRow[0]);
|
||
INT64 Msgid = StrToInt64(pRow[1]);
|
||
retPack << (INT64)Msgid;
|
||
}
|
||
m_pSQLConnection->ResetQuery();
|
||
|
||
}
|
||
else
|
||
{
|
||
retPack << (BYTE)reDbErr ;
|
||
}
|
||
|
||
}
|
||
|
||
flushProtoPacket(retPack);
|
||
}
|
||
|
||
|
||
//邮件相关接口
|
||
|
||
void CLogicDBReqestHandler::AddActorOfflineMail(CDataPacketReader & inPacket)
|
||
{
|
||
unsigned int nActorId = 0, nSrcId = 0, nCreateDt = 0;
|
||
byte btState = 0, btIsDel = 0;
|
||
int nServerId = 0, nRawServerId = 0;
|
||
inPacket >> nRawServerId >> nServerId >> nActorId;
|
||
int nErrorCode = reSucc;
|
||
if (!m_pSQLConnection->Connect())
|
||
{
|
||
nErrorCode = reDbNotConnected;
|
||
}
|
||
else
|
||
{
|
||
sprintf(m_pHugeSQLBuffer, szSQLSP_SaveMail);
|
||
INT64 nMailId = 0;
|
||
char sTitle[200], sContent[600], sBuff[1024];
|
||
int nCurCount = 0;
|
||
|
||
strcat(m_pHugeSQLBuffer, "(");
|
||
inPacket >> nMailId >> nSrcId;
|
||
inPacket.readString(sTitle, ArrayCount(sTitle));
|
||
inPacket.readString(sContent, ArrayCount(sContent));
|
||
inPacket >> nCreateDt >> btState >> btIsDel;
|
||
char sRealContent[700];
|
||
mysql_escape_string(sRealContent,sContent,(unsigned long)strlen(sContent));
|
||
sprintf(sBuff,"%lld,%u,%u,\"%s\",\"%s\",%d,%d,%d)", nMailId,nActorId,nSrcId,sTitle,sRealContent,nCreateDt,btState,btIsDel);
|
||
strcat(m_pHugeSQLBuffer, sBuff);
|
||
nErrorCode = m_pSQLConnection->Exec(m_pHugeSQLBuffer);
|
||
if (!nErrorCode)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
BYTE nMailAttachCount = 0;
|
||
inPacket >> nMailAttachCount;
|
||
if (nMailAttachCount > 0)
|
||
{
|
||
sprintf(m_pHugeSQLBuffer, szSQLSP_SaveMailAttach);
|
||
int nValue = 0;BYTE nType = 0;
|
||
for (int i = 0; i <nMailAttachCount ; i++)
|
||
{
|
||
strcat(m_pHugeSQLBuffer," (");
|
||
CUserItem data;
|
||
inPacket >> nType;
|
||
data << inPacket;
|
||
sprintf(sBuff,"%lld,%u,%d,%lld,", nMailId,nActorId, nType,data.series.llId); //mailid actotID,guid,type
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
|
||
//ItemId,QUALITY,strong
|
||
nValue = MAKELONG( data.wItemId, MAKEWORD( data.btQuality, data.btStrong));
|
||
|
||
sprintf(sBuff,"%d,%d,",nValue, data.wCount);//MAKELONG(data.wDura,data.wCount));
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
|
||
//wPackageType,btFlag,wHoles
|
||
nValue = MAKELONG( MAKEWORD( data.wPackageType, data.btFlag), 0);
|
||
sprintf(sBuff," %d,",nValue);
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
//BYTE bLostStar;BYTE bInSourceType;//铭刻等级WORD bStrongResereLevel;//保留(可使用)
|
||
nValue = MAKELONG( MAKEWORD( data.bLostStar, data.bInSourceType), data.wIdentifySlotNum); //bStrongResereLevel->wIdentifySlotNum
|
||
|
||
sprintf(sBuff,"%d,",nValue);
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
|
||
//data reserver
|
||
//MAKELONG(A,B) 这里A是低字节，B是高字节，类似 MAKEWORD
|
||
nValue = MAKELONG( data.nDropMonsterId, data.wStar ); //btSmithCount -> nDropMonsterId
|
||
|
||
sprintf(sBuff,"%d,%d,",data.nCreatetime.tv,nValue);
|
||
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
nValue= MAKELONG( MAKEWORD(data.btSharp, data.btDeportId), MAKEWORD(data.btHandPos, data.btLuck));
|
||
|
||
sprintf(sBuff,"%d,%d,%d,%d,%d,%d,%d",data.smithAttrs[0],data.smithAttrs[1],data.smithAttrs[2],data.smithAttrs[3],data.smithAttrs[4],nValue,data.nAreaId);
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
strcat(m_pHugeSQLBuffer," )");
|
||
if(i < nMailAttachCount -1)
|
||
{
|
||
strcat(m_pHugeSQLBuffer,",");
|
||
}
|
||
}
|
||
nErrorCode = m_pSQLConnection->Exec(m_pHugeSQLBuffer);
|
||
if (!nErrorCode)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
void CLogicDBReqestHandler::LoadActorMail(CDataPacketReader & inPacket)
|
||
{
|
||
int nServerId = 0, nRawServerId = 0;
|
||
inPacket >> nRawServerId >> nServerId;
|
||
unsigned int nActorId = 0;
|
||
inPacket >> nActorId;
|
||
QueryActorMail(nActorId, nRawServerId, nServerId);
|
||
}
|
||
|
||
void CLogicDBReqestHandler::QueryActorMail(unsigned int nActorId, int nRawServerId, int nServerId)
|
||
{
|
||
int nErrorCode = 0;
|
||
if (!m_pSQLConnection->Connected())
|
||
{
|
||
nErrorCode = reDbNotConnected;
|
||
}
|
||
else
|
||
{
|
||
nErrorCode = m_pSQLConnection->Query(szSQLSP_LoadMail, nActorId);
|
||
if (!nErrorCode)
|
||
{
|
||
MYSQL_ROW pRow = m_pSQLConnection->CurrentRow();
|
||
int nRowCount = m_pSQLConnection->GetRowCount();
|
||
if(nRowCount > 0)
|
||
{
|
||
for (int i=0,packetCount = 1; i < nRowCount; i++)
|
||
{
|
||
WORD wMailCount = 0;
|
||
CDataPacket & outPacket = allocProtoPacket(dcLoadMail);
|
||
outPacket << nRawServerId << nServerId << nActorId << (byte)nErrorCode;
|
||
outPacket << (BYTE)packetCount++;//第几个包
|
||
size_t wMailCountPos = outPacket.getPosition();
|
||
outPacket << (WORD)wMailCount;//邮件数量,读完再修改这个值
|
||
BYTE nMailAttachCount = 0; //记录每封邮件附件数量
|
||
size_t mailAttachCountPos = 0;
|
||
INT64 nLastMailId = 0;
|
||
while(pRow)
|
||
{
|
||
INT64 nCurMailId = (INT64)StrToInt64(pRow[0]);
|
||
if (nLastMailId != nCurMailId)
|
||
{
|
||
wMailCount++;
|
||
mailAttachCountPos = 0;
|
||
nMailAttachCount = 0;
|
||
nLastMailId = nCurMailId;
|
||
|
||
outPacket << nCurMailId; //mailid
|
||
outPacket << (unsigned int)atoi(pRow[1]);//srcid
|
||
outPacket.writeString(pRow[2]?pRow[2]:"");//title
|
||
outPacket.writeString(pRow[3]?pRow[3]:"");//content
|
||
outPacket << (unsigned int)atoi(pRow[4]);//createdt
|
||
outPacket << (byte)atoi(pRow[5]);//state
|
||
mailAttachCountPos = outPacket.getPosition();
|
||
outPacket << nMailAttachCount;
|
||
}
|
||
if (pRow[6] != NULL)//有附件
|
||
{
|
||
nMailAttachCount++;
|
||
int nValue = 0;
|
||
WORD wValue = 0;
|
||
CUserItem userItem;
|
||
memset(&userItem,0,sizeof(userItem));
|
||
|
||
outPacket << (BYTE)atoi(pRow[6]); //type
|
||
|
||
userItem.series.llId = StrToInt64(pRow[7]); //itemguid
|
||
|
||
nValue = atoi(pRow[8]); //itemidquastrong
|
||
userItem.wItemId = LOWORD(nValue);
|
||
wValue = HIWORD(nValue);
|
||
userItem.btQuality = LOBYTE(wValue);
|
||
userItem.btStrong = HIBYTE(wValue);
|
||
|
||
|
||
userItem.wCount = atoi(pRow[9]); //wCount
|
||
|
||
nValue = atoi(pRow[10]); //itemcountflag
|
||
wValue = LOWORD(nValue);
|
||
userItem.wPackageType = LOBYTE(wValue);
|
||
userItem.btFlag = HIBYTE(wValue);
|
||
int nCount = HIWORD(nValue);
|
||
if(nCount > userItem.wCount)
|
||
userItem.wCount = nCount;
|
||
|
||
nValue = atoi(pRow[11]); //nStrongStar ->bLostStar(BYTE) + bInSourceType(BYTE) + bStrongResereLevel(WORD)
|
||
wValue = LOWORD(nValue);
|
||
userItem.wIdentifySlotNum = HIWORD(nValue); //bStrongResereLevel->wIdentifySlotNum
|
||
userItem.bLostStar = LOBYTE(wValue);
|
||
userItem.bInSourceType = HIBYTE(wValue);
|
||
|
||
userItem.nCreatetime = atoi(pRow[12]); //itemtime
|
||
|
||
nValue = atoi(pRow[13]); //itemreservs
|
||
userItem.nDropMonsterId = LOWORD(nValue); //btSmithCount -> nDropMonsterId
|
||
wValue = HIWORD(nValue);
|
||
userItem.wStar = wValue;
|
||
|
||
sscanf(pRow[14], "%d",&userItem.smithAttrs[0]); //smith1-5
|
||
sscanf(pRow[15], "%d",&userItem.smithAttrs[1]);
|
||
sscanf(pRow[16], "%d",&userItem.smithAttrs[2]);
|
||
sscanf(pRow[17], "%d",&userItem.smithAttrs[3]);
|
||
sscanf(pRow[18], "%d",&userItem.smithAttrs[4]);
|
||
|
||
nValue = atoi(pRow[19]); //itemreservs2
|
||
wValue = HIWORD(nValue);
|
||
userItem.btLuck = HIBYTE(wValue);
|
||
userItem.btHandPos = LOBYTE(wValue);
|
||
wValue = LOWORD(nValue);
|
||
userItem.btDeportId = HIBYTE(wValue);
|
||
userItem.btSharp = LOBYTE(wValue);
|
||
|
||
sscanf(pRow[20], "%d",&userItem.nAreaId);
|
||
// outPacket << userItem;
|
||
userItem >> outPacket;
|
||
}
|
||
//附件
|
||
if (nMailAttachCount != 0)
|
||
{
|
||
BYTE* pAttachCount = (BYTE*)outPacket.getPositionPtr(mailAttachCountPos);
|
||
*pAttachCount = nMailAttachCount;
|
||
}
|
||
pRow = m_pSQLConnection->NextRow();
|
||
if (pRow && nCurMailId == (INT64)StrToInt64(pRow[0]))
|
||
{
|
||
//邮件附件没读完
|
||
continue;
|
||
}
|
||
if (/*wMailCount == MAIL_DATA_SEND_COUNT_EACH_TIME ||*/ pRow == NULL)
|
||
{
|
||
WORD* pMailCount = (WORD*)outPacket.getPositionPtr(wMailCountPos);
|
||
*pMailCount = wMailCount;
|
||
bool isEnd = pRow == NULL?true:false;
|
||
outPacket << isEnd;
|
||
flushProtoPacket(outPacket);
|
||
break;
|
||
}
|
||
}
|
||
if (!pRow)
|
||
{
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
CDataPacket & outPacket = allocProtoPacket(dcLoadMail);
|
||
outPacket << nRawServerId << nServerId << nActorId << (byte)nErrorCode;
|
||
outPacket << (BYTE)0;
|
||
outPacket << (WORD)0;
|
||
bool isEnd = true;
|
||
outPacket << isEnd;
|
||
flushProtoPacket(outPacket);
|
||
}
|
||
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
|
||
else
|
||
{
|
||
OutputMsg(rmTip, _T("%s"), mysql_error(m_pSQLConnection->GetMySql()));
|
||
}
|
||
}
|
||
}
|
||
|
||
void CLogicDBReqestHandler::SaveNewServerMail(CDataPacketReader & inPacket)
|
||
{
|
||
int nErrorCode = 0;
|
||
int nServerId = 0, nRawServerId = 0;
|
||
inPacket >> nRawServerId >> nServerId;
|
||
int nServerMailId = 0;
|
||
inPacket >> nServerMailId;
|
||
if (!m_pSQLConnection->Connected())
|
||
{
|
||
nErrorCode = reDbNotConnected;
|
||
}
|
||
else
|
||
{
|
||
nErrorCode = m_pSQLConnection->Exec(szSQLSP_SaveNewServerMail, nServerMailId);
|
||
if (!nErrorCode)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
else
|
||
{
|
||
OutputMsg(rmError,"szSQLSP_SaveNewServerMail Error,errorCode=%d,sql=%s", nErrorCode,m_pHugeSQLBuffer);
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
|
||
|
||
void CLogicDBReqestHandler::AddNewServerMail(CDataPacketReader & inPacket)
|
||
{
|
||
int nErrorCode = 0;
|
||
int nServerId = 0, nRawServerId = 0;
|
||
inPacket >> nRawServerId >> nServerId;
|
||
if (!m_pSQLConnection->Connected())
|
||
{
|
||
nErrorCode = reDbNotConnected;
|
||
}
|
||
else
|
||
{
|
||
ServerMailDef mail;
|
||
inPacket >> mail.nServerMailId;
|
||
inPacket >> mail.nActorId;
|
||
inPacket.readString(mail.sTitle);
|
||
inPacket.readString(mail.sContent);
|
||
inPacket >> mail.nMinVipLevel >> mail.nMaxVipLevel >> mail.nMinLevel >> mail.nMaxLevel;
|
||
inPacket >> mail.nMinRegisterTime >> mail.nMaxRegisterTime >> mail.nMinLoginTime >> mail.nMaxLoginTime;
|
||
inPacket >> mail.btOnline >> mail.btSex >> mail.nWay;
|
||
|
||
sprintf(m_pHugeSQLBuffer, szSQLSP_SaveServerMail);
|
||
INT64 nMailId = 0;
|
||
char sBuff[1024];
|
||
|
||
strcat(m_pHugeSQLBuffer, "(");
|
||
|
||
sprintf(sBuff,"%u,\"%s\",\"%s\",%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d)",mail.nActorId,mail.sTitle,mail.sContent,
|
||
mail.nMinVipLevel, mail.nMaxVipLevel,mail.nMinLevel, mail.nMaxLevel,
|
||
mail.nMinRegisterTime, mail.nMaxRegisterTime, mail.nMinLoginTime, mail.nMaxLoginTime,
|
||
mail.btOnline, mail.btSex, mail.nWay);
|
||
strcat(m_pHugeSQLBuffer, sBuff);
|
||
nErrorCode = m_pSQLConnection->Exec(m_pHugeSQLBuffer);
|
||
if (!nErrorCode)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
unsigned int nMaxId = 0;
|
||
nErrorCode = m_pSQLConnection->Query(szSQLSP_GetMaxMailIdServerMail);
|
||
if (!nErrorCode)
|
||
{
|
||
MYSQL_ROW pRow = m_pSQLConnection->CurrentRow();
|
||
if ( pRow && pRow[0])
|
||
{
|
||
nMaxId = (unsigned int)atoi(pRow[0]);
|
||
}
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
|
||
BYTE nMailAttachCount = 0;
|
||
inPacket >> nMailAttachCount;
|
||
|
||
if (nMailAttachCount > 0)
|
||
{
|
||
sprintf(m_pHugeSQLBuffer, szSQLSP_SaveServerMailAttach);
|
||
WORD nValue = 0;BYTE nType = 0;
|
||
int wCount = 0;
|
||
for (int i = 0; i <nMailAttachCount ; i++)
|
||
{
|
||
strcat(m_pHugeSQLBuffer," (");
|
||
inPacket >> nType >> nValue >>wCount;
|
||
sprintf(sBuff,"%lld,%d,%d,%d)",nMaxId,nType, nValue,wCount); //mailid type,id,count
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
if(i < nMailAttachCount -1)
|
||
{
|
||
strcat(m_pHugeSQLBuffer,",");
|
||
}
|
||
}
|
||
nErrorCode = m_pSQLConnection->Exec(m_pHugeSQLBuffer);
|
||
if (!nErrorCode)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
}
|
||
|
||
|
||
}
|
||
}
|
||
void CLogicDBReqestHandler::LoadNewServerMail(int nServerId, int nRawServerId, int nMaxServerMailId)
|
||
{
|
||
|
||
int nErrorCode = 0;
|
||
if (!m_pSQLConnection->Connected())
|
||
{
|
||
nErrorCode = reDbNotConnected;
|
||
}
|
||
else
|
||
{
|
||
nErrorCode = m_pSQLConnection->Query(szSQLSP_LoadNewServerMail, nMaxServerMailId);
|
||
if (!nErrorCode)
|
||
{
|
||
MYSQL_ROW pRow = m_pSQLConnection->CurrentRow();
|
||
int nRowCount = m_pSQLConnection->GetRowCount();
|
||
if (nRowCount == 0)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
return;
|
||
}
|
||
INT_PTR packetCount = (nRowCount-1)/MAIL_DATA_SEND_COUNT_EACH_TIME+1;
|
||
INT_PTR nNeedSendCount =0;
|
||
int nValue =0;
|
||
for (INT_PTR curPacketCount =1; curPacketCount <= packetCount; curPacketCount++)
|
||
{
|
||
if (curPacketCount* MAIL_DATA_SEND_COUNT_EACH_TIME > nRowCount)
|
||
{
|
||
nNeedSendCount = nRowCount - (curPacketCount-1)*MAIL_DATA_SEND_COUNT_EACH_TIME;
|
||
}
|
||
else
|
||
{
|
||
nNeedSendCount = MAIL_DATA_SEND_COUNT_EACH_TIME;
|
||
}
|
||
CDataPacket & outPacket = allocProtoPacket(dcLoadNewServerMail);
|
||
outPacket << nServerId << nServerId <<nErrorCode;
|
||
outPacket << (BYTE)LoadDbTypeServerMail<<(WORD)nNeedSendCount;//这个包里有多少邮件
|
||
for (INT_PTR i = (curPacketCount-1)* MAIL_DATA_SEND_COUNT_EACH_TIME; i < curPacketCount* MAIL_DATA_SEND_COUNT_EACH_TIME && i < nRowCount; i++)
|
||
{
|
||
if (pRow)
|
||
{
|
||
// pRow[0]?outPacket << (int)atoi(pRow[0]):outPacket <<(int)0;//nServerMailId
|
||
int nServerMailId = 0;
|
||
if(pRow[0])
|
||
{
|
||
sscanf(pRow[0], "%d", &nServerMailId);//gid
|
||
}
|
||
outPacket << nServerMailId;
|
||
// pRow[1]?outPacket << (unsigned int)atoi(pRow[1]):outPacket <<(unsigned int)0;//nActorId
|
||
unsigned int nActorId = 0;
|
||
if(pRow[1])
|
||
{
|
||
sscanf(pRow[1], "%u", &nActorId);//gid
|
||
}
|
||
outPacket << nActorId;
|
||
// pRow[2]?outPacket.writeString(pRow[2]) :outPacket.writeString("");//sTitle
|
||
char sTitle[1024] = "0";
|
||
if(pRow[2])
|
||
{
|
||
sscanf(pRow[2], "%s", &sTitle);//gid
|
||
}
|
||
outPacket.writeString(sTitle);
|
||
pRow[3]?outPacket.writeString(pRow[3]) :outPacket.writeString("");//sContent
|
||
// char sContent[1024] = "0";
|
||
// if(pRow[3])
|
||
// {
|
||
// sscanf(pRow[3], "%s", &sContent);//gid
|
||
// }
|
||
// printf("content:%s",sContent);
|
||
// outPacket.writeString(sContent);
|
||
|
||
// pRow[4]?outPacket << (int)atoi(pRow[4]):outPacket <<(int)0;//
|
||
int nMinVipLevel = 0;
|
||
if(pRow[4])
|
||
{
|
||
sscanf(pRow[4], "%d", &nMinVipLevel);//nMinVipLevel
|
||
}
|
||
outPacket << nMinVipLevel;
|
||
// pRow[5]?outPacket << (int)atoi(pRow[5]):outPacket <<(int)0;//
|
||
int nMaxVipLevel = 0;
|
||
if(pRow[5])
|
||
{
|
||
sscanf(pRow[5], "%d", &nMaxVipLevel);//gid
|
||
}
|
||
outPacket << nMaxVipLevel;
|
||
// pRow[6]?outPacket << (int)atoi(pRow[6]):outPacket <<(int)0;//nMinLevel
|
||
int nMinLevel = 0;
|
||
if(pRow[6])
|
||
{
|
||
sscanf(pRow[6], "%d", &nMinLevel);//gid
|
||
}
|
||
outPacket << nMinLevel;
|
||
// pRow[7]?outPacket << (int)atoi(pRow[7]):outPacket <<(int)0;//nMaxLevel
|
||
int nMaxLevel = 0;
|
||
if(pRow[7])
|
||
{
|
||
sscanf(pRow[7], "%d", &nMaxLevel);//gid
|
||
}
|
||
outPacket << nMaxLevel;
|
||
// pRow[8]?outPacket << (unsigned int)atoi(pRow[8]):outPacket <<(unsigned int)0;//nMinRegisterTime
|
||
unsigned int nMinRegisterTime = 0;
|
||
if(pRow[8])
|
||
{
|
||
sscanf(pRow[8], "%u", &nMinRegisterTime);//gid
|
||
}
|
||
outPacket << nMinRegisterTime;
|
||
// pRow[9]?outPacket << (unsigned int)atoi(pRow[9]):outPacket <<(unsigned int)0;//nMaxRegisterTime
|
||
unsigned int nMaxRegisterTime = 0;
|
||
if(pRow[9])
|
||
{
|
||
sscanf(pRow[9], "%u", &nMaxRegisterTime);//gid
|
||
}
|
||
outPacket << nMaxRegisterTime;
|
||
// pRow[10]?outPacket << (unsigned int)atoi(pRow[10]):outPacket <<(unsigned int)0;//nMinLoginTime
|
||
unsigned int nMinLoginTime = 0;
|
||
if(pRow[10])
|
||
{
|
||
sscanf(pRow[10], "%u", &nMinLoginTime);//gid
|
||
}
|
||
outPacket << nMinLoginTime;
|
||
// pRow[11]?outPacket << (unsigned int)atoi(pRow[11]):outPacket <<(unsigned int)0;//nMaxLoginTime
|
||
unsigned int nMaxLoginTime = 0;
|
||
if(pRow[11])
|
||
{
|
||
sscanf(pRow[11], "%u", &nMaxLoginTime);//gid
|
||
}
|
||
outPacket << nMaxLoginTime;
|
||
// pRow[12]?outPacket << (BYTE)atoi(pRow[12]):outPacket <<(BYTE)0;//btOnline
|
||
int btOnline = 0;
|
||
if(pRow[12])
|
||
{
|
||
sscanf(pRow[12], "%d", &btOnline);//gid
|
||
}
|
||
outPacket << btOnline;
|
||
// pRow[13]?outPacket << (char)atoi(pRow[13]):outPacket <<(char)0;//btSex
|
||
int btSex = 0;
|
||
if(pRow[13])
|
||
{
|
||
sscanf(pRow[13], "%d", &btSex);//gid
|
||
}
|
||
outPacket << btSex;
|
||
// pRow[14]?outPacket << (unsigned int)atoi(pRow[14]):outPacket <<(unsigned int)0;//way
|
||
int way = 0;
|
||
if(pRow[14])
|
||
{
|
||
sscanf(pRow[14], "%d", &way);//gid
|
||
}
|
||
outPacket << way;
|
||
pRow = m_pSQLConnection->NextRow();
|
||
}
|
||
}
|
||
flushProtoPacket(outPacket);
|
||
}
|
||
m_pSQLConnection->ResetQuery();
|
||
|
||
//读附件
|
||
nErrorCode = m_pSQLConnection->Query(szSQLSP_LoadNewServerMailAttach, nMaxServerMailId);
|
||
if (!nErrorCode)
|
||
{
|
||
MYSQL_ROW pRow = m_pSQLConnection->CurrentRow();
|
||
int nRowCount = m_pSQLConnection->GetRowCount();
|
||
INT_PTR packetCount = (nRowCount-1)/MAILATTACH_DATA_SEND_COUNT_EACH_TIME+1;
|
||
INT_PTR nNeedSendCount =0;
|
||
int nValue =0;
|
||
for (INT_PTR curPacketCount =1; curPacketCount <= packetCount; curPacketCount++)
|
||
{
|
||
if (curPacketCount* MAILATTACH_DATA_SEND_COUNT_EACH_TIME > nRowCount)
|
||
{
|
||
nNeedSendCount = nRowCount - (curPacketCount-1)*MAILATTACH_DATA_SEND_COUNT_EACH_TIME;
|
||
}
|
||
else
|
||
{
|
||
nNeedSendCount = MAILATTACH_DATA_SEND_COUNT_EACH_TIME;
|
||
}
|
||
CDataPacket & outPacket = allocProtoPacket(dcLoadNewServerMail);
|
||
outPacket << nServerId << nServerId <<nErrorCode;
|
||
outPacket << (BYTE)LoadDbTypeServerMailAttach<<(WORD)nNeedSendCount;//这个包里有多少附件
|
||
for (INT_PTR i = (curPacketCount-1)* MAILATTACH_DATA_SEND_COUNT_EACH_TIME; i < curPacketCount* MAILATTACH_DATA_SEND_COUNT_EACH_TIME && i < nRowCount; i++)
|
||
{
|
||
if (pRow)
|
||
{
|
||
|
||
pRow[0]?outPacket << (int)atoi(pRow[0]):outPacket <<(int)0;//nServerMailId
|
||
pRow[1]?outPacket << (BYTE)atoi(pRow[1]):outPacket <<(BYTE)0;//btType
|
||
pRow[2]?outPacket << (WORD)atoi(pRow[2]):outPacket <<(WORD)0;//wId
|
||
// pRow[3]?outPacket << (BYTE)atoi(pRow[3]):outPacket <<(BYTE)0;//btQuality
|
||
pRow[4]?outPacket << (int)atoi(pRow[4]):outPacket <<(int)0;//数量int，支持了资源数量超过word
|
||
// pRow[5]?outPacket << (BYTE)atoi(pRow[5]):outPacket <<(BYTE)0;//btBind
|
||
// pRow[6]?outPacket << (WORD)atoi(pRow[6]):outPacket <<(WORD)0;//wStar
|
||
// pRow[7]?outPacket << (BYTE)atoi(pRow[7]):outPacket <<(BYTE)0;//btStarLost
|
||
// pRow[8]?outPacket << (BYTE)atoi(pRow[8]):outPacket <<(BYTE)0;//btInscriptlevel
|
||
// pRow[9]?outPacket << (int)atoi(pRow[9]):outPacket <<(int)0;//nIncriptExp
|
||
// pRow[10]?outPacket << (BYTE)atoi(pRow[10]):outPacket <<(BYTE)0;//btLuck
|
||
// pRow[11]?outPacket << (int)atoi(pRow[11]):outPacket <<(int)0;//smith1
|
||
// pRow[12]?outPacket << (int)atoi(pRow[12]):outPacket <<(int)0;//smith2
|
||
// pRow[13]?outPacket << (int)atoi(pRow[13]):outPacket <<(int)0;//smith3
|
||
// pRow[14]?outPacket << (int)atoi(pRow[14]):outPacket <<(int)0;//smith4
|
||
// pRow[15]?outPacket << (int)atoi(pRow[15]):outPacket <<(int)0;//smith5
|
||
// pRow[16]?outPacket << (WORD)atoi(pRow[16]):outPacket <<(WORD)0;//identifyslotnum
|
||
// pRow[17]?outPacket << (WORD)atoi(pRow[17]):outPacket <<(WORD)0;//identifynum
|
||
pRow = m_pSQLConnection->NextRow();
|
||
}
|
||
}
|
||
flushProtoPacket(outPacket);
|
||
}
|
||
m_pSQLConnection->ResetQuery();
|
||
//再发一个包结束
|
||
CDataPacket & outPacket = allocProtoPacket(dcLoadNewServerMail);
|
||
outPacket << nServerId << nServerId <<nErrorCode;
|
||
outPacket << (BYTE)LoadDbTypeServerMailComplete;
|
||
flushProtoPacket(outPacket);
|
||
}
|
||
else
|
||
{
|
||
OutputMsg(rmError,"szSQLSP_LoadNewServerMail Error,errorCode=%d,sql=%s", nErrorCode,m_pHugeSQLBuffer);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
OutputMsg(rmError,"szSQLSP_LoadNewServerMail Error,errorCode=%d,sql=%s", nErrorCode,m_pHugeSQLBuffer);
|
||
}
|
||
|
||
}
|
||
}
|
||
void CLogicDBReqestHandler::SaveActorMail(CDataPacketReader & inPacket, bool bResp)
|
||
{
|
||
unsigned int nActorId = 0, nSrcId = 0, nCreateDt = 0;
|
||
byte btState = 0, btIsDel = 0;
|
||
int nServerId = 0, nRawServerId = 0;
|
||
BYTE nCurPacketCount=0, nPacketCount = 0, nPacketType=0, nDelType=0;
|
||
INT64 nMailId = 0;
|
||
inPacket >> nRawServerId >> nServerId >> nActorId ;
|
||
inPacket >> nCurPacketCount >> nPacketType >> nDelType;
|
||
//nPacketTypee :eMailSaveType
|
||
//nDelType: eMailSaveDelType
|
||
int nErrorCode = reSucc;
|
||
if (!m_pSQLConnection->Connected())
|
||
{
|
||
nErrorCode = reDbNotConnected; //db没有连接上
|
||
}
|
||
else
|
||
{
|
||
if (nCurPacketCount == 1 && nPacketType == 0 && nDelType == 0)
|
||
{
|
||
nErrorCode = m_pSQLConnection->Exec(szSQLSP_DeleteMail, nActorId);//现在只删除isdel=0的邮件,因为loadmail只读了isdel=0,。
|
||
if(!nErrorCode)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
}
|
||
if (nPacketType == 0)//每个包单独执行保存
|
||
{
|
||
BYTE nMailCount = 0;
|
||
inPacket >> nMailCount;
|
||
if (nMailCount > 0)
|
||
{
|
||
char sTitle[200], sContent[600], sBuff[1024];
|
||
sprintf(m_pHugeSQLBuffer, szSQLSP_SaveMail);
|
||
for (int i = 0; i < nMailCount; i++)
|
||
{
|
||
strcat(m_pHugeSQLBuffer, "(");
|
||
inPacket >> nMailId >> nSrcId;
|
||
inPacket.readString(sTitle, ArrayCount(sTitle));
|
||
inPacket.readString(sContent, ArrayCount(sContent));
|
||
inPacket >> nCreateDt >> btState >> btIsDel;
|
||
char sRealContent[700];
|
||
mysql_escape_string(sRealContent,sContent,(unsigned long)strlen(sContent));
|
||
sprintf(sBuff,"%lld,%u,%u,\"%s\",\"%s\",%d,%d,%d)", nMailId,nActorId,nSrcId,sTitle,sRealContent,nCreateDt,btState, btIsDel);
|
||
strcat(m_pHugeSQLBuffer, sBuff);
|
||
if (i < nMailCount -1)
|
||
{
|
||
strcat(m_pHugeSQLBuffer, ",");
|
||
}
|
||
}
|
||
// printf("%s\n", m_pHugeSQLBuffer);
|
||
nErrorCode = m_pSQLConnection->Exec(m_pHugeSQLBuffer);
|
||
if (!nErrorCode)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
}
|
||
}
|
||
}
|
||
else if (nPacketType == 1)
|
||
{
|
||
WORD nMailAttachCount = 0;
|
||
inPacket >> nMailAttachCount;
|
||
if (nMailAttachCount > 0)
|
||
{
|
||
sprintf(m_pHugeSQLBuffer, szSQLSP_SaveMailAttach);
|
||
int nValue = 0;
|
||
BYTE nType = 0;
|
||
char sBuff[1024];
|
||
for (int i = 0; i <nMailAttachCount ; i++)
|
||
{
|
||
CUserItem data;
|
||
inPacket >> nMailId >> nType;
|
||
data << inPacket;
|
||
|
||
strcat(m_pHugeSQLBuffer, "(");
|
||
sprintf(sBuff,"%lld,%u,%d,%lld,", nMailId,nActorId,nType,data.series.llId); //mailid actotID,guid,type
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
|
||
//ItemId,QUALITY,strong
|
||
nValue = MAKELONG( data.wItemId, MAKEWORD( data.btQuality, data.btStrong));
|
||
|
||
sprintf(sBuff,"%d,%d,",nValue, data.wCount);//MAKELONG(data.wDura,data.wCount));
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
|
||
//wPackageType,btFlag,wHoles
|
||
nValue = MAKELONG( MAKEWORD( data.wPackageType, data.btFlag), 0);
|
||
sprintf(sBuff," %d, ",nValue);
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
|
||
//BYTE bLostStar;BYTE bInSourceType;//铭刻等级WORD bStrongResereLevel;//保留(可使用)
|
||
nValue = MAKELONG( MAKEWORD( data.bLostStar, data.bInSourceType), data.wIdentifySlotNum); //bStrongResereLevel->wIdentifySlotNum
|
||
|
||
sprintf(sBuff,"%d,",nValue);
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
|
||
//data reserver
|
||
//MAKELONG(A,B) 这里A是低字节，B是高字节，类似 MAKEWORD
|
||
nValue = MAKELONG( data.nDropMonsterId, data.wStar ); //btSmithCount -> nDropMonsterId
|
||
|
||
sprintf(sBuff,"%d,%d,",data.nCreatetime.tv,nValue);
|
||
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
nValue= MAKELONG( MAKEWORD(data.btSharp, data.btDeportId), MAKEWORD(data.btHandPos, data.btLuck));
|
||
|
||
sprintf(sBuff,"%d,%d,%d,%d,%d,%d,%d)",data.smithAttrs[0],data.smithAttrs[1],data.smithAttrs[2],data.smithAttrs[3],data.smithAttrs[4],nValue,data.nAreaId);
|
||
strcat(m_pHugeSQLBuffer,sBuff);
|
||
if ((i>0 && i%200 == 0) || i == nMailAttachCount-1)
|
||
{
|
||
nErrorCode = m_pSQLConnection->Exec(m_pHugeSQLBuffer);
|
||
if(!nErrorCode)
|
||
{
|
||
m_pSQLConnection->ResetQuery();
|
||
strcpy(m_pHugeSQLBuffer,szSQLSP_SaveMailAttach);
|
||
}
|
||
else
|
||
{
|
||
OutputMsg(rmError,"SaveActorMailAttach Error,errorCode=%d,sql=%s", nErrorCode,m_pHugeSQLBuffer);
|
||
}
|
||
}
|
||
else if(i < nMailAttachCount -1)
|
||
{
|
||
strcat(m_pHugeSQLBuffer,",");
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
}
|