123 lines
3.9 KiB
C
123 lines
3.9 KiB
C
|
#pragma once
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
typedef enum tagAMServerMsg
|
|||
|
|
{
|
|||
|
|
AMC_REGIST = 10000, //注册
|
|||
|
|
AMC_QUERY_AMOUNT = 10001, //查询用户余额
|
|||
|
|
AMC_COMSUME = 10002, //发送用户消费请求
|
|||
|
|
|
|||
|
|
AMS_QUERY_AMOUNT = 20001, //返回用户余额
|
|||
|
|
AMS_COMSUME = 20002, //返回用户消费结果
|
|||
|
|
AMS_PAY_SUCCED = 20003, //返回充值成功
|
|||
|
|
};
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
typedef struct tagTASKReq
|
|||
|
|
{
|
|||
|
|
int Socket;
|
|||
|
|
int Serverid;
|
|||
|
|
int Cmdid;
|
|||
|
|
int Contractid;
|
|||
|
|
int Step;
|
|||
|
|
bool operator==(const tagTASKReq& a)const
|
|||
|
|
{
|
|||
|
|
if(Serverid == a.Serverid && Cmdid == a.Cmdid && Contractid == a.Contractid && Step == a.Step)
|
|||
|
|
return true;
|
|||
|
|
else
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
}TASKREQ, *PTASKREQ;
|
|||
|
|
typedef std::vector<TASKREQ> TASKREQ_Vec;
|
|||
|
|
typedef std::map<UINT, TASKREQ_Vec > TASKREQ_Map;
|
|||
|
|
|
|||
|
|
typedef enum tagAMErrorNumber
|
|||
|
|
{
|
|||
|
|
ERROR_NOT_CONNECT_DB = -100, //无法连接数据库
|
|||
|
|
ERROR_QUERY_DB = -101, //查询数据库错误
|
|||
|
|
ERROR_NOT_REGDIST = -102, //未注册
|
|||
|
|
ERROR_NOTFIND_PRODUCT = -103, //无法找到对应的产品
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
class CCustomJXServerClientSocket;
|
|||
|
|
class CAMServerSocket;
|
|||
|
|
class CProduct;
|
|||
|
|
|
|||
|
|
class CAMClientSocket:
|
|||
|
|
protected CCustomServerClientSocket
|
|||
|
|
{
|
|||
|
|
public:
|
|||
|
|
typedef CCustomServerClientSocket Inherited;
|
|||
|
|
|
|||
|
|
CAMClientSocket(void);
|
|||
|
|
CAMClientSocket(CAMServerSocket* pSrv,SOCKET nSocket, SOCKADDR_IN *pClientAddr);
|
|||
|
|
~CAMClientSocket(void);
|
|||
|
|
|
|||
|
|
char * GetSpid() {return m_Spid;}
|
|||
|
|
void SendPaySucceed(int nServerIndex,UINT uUserId,UINT nActorId, UINT uMoney);
|
|||
|
|
void AskTaskSituation(int nserverid, UINT uUserId, UINT cmdid, int contractid, int step );
|
|||
|
|
void AddTaskMsg(SOCKET nsocket, int nserverid, UINT uUserId, UINT cmdid, int contractid, int step );
|
|||
|
|
/* 返回true，存在这个msg并删除；返回false，没有这个msg */
|
|||
|
|
bool DelTaskMsg(SOCKET nsocket, int nserverid, UINT uUserId, UINT cmdid, int contractid, int step );
|
|||
|
|
|
|||
|
|
protected:
|
|||
|
|
virtual VOID OnDispatchRecvPacket(const jxSrvDef::INTERSRVCMD nCmd, CDataPacketReader &inPacket);
|
|||
|
|
virtual bool OnValidateRegData(const jxSrvDef::PSERVER_REGDATA pRegData);
|
|||
|
|
virtual VOID OnRun();
|
|||
|
|
//按通信协议申请一份发送数据包，nCmd是通信消息号，
|
|||
|
|
//数据包填充完毕后需要调用flushProtoPacket提交到发送队列
|
|||
|
|
CDataPacket& allocProtoPacket(const jxSrvDef::INTERSRVCMD nCmd);
|
|||
|
|
|
|||
|
|
//提交发送数据包到发送缓冲，会自动计算数据长度并向数据包的通信协议头部分写入长度值
|
|||
|
|
VOID flushProtoPacket(CDataPacket& packet);
|
|||
|
|
|
|||
|
|
VOID SendKeepAlive();
|
|||
|
|
|
|||
|
|
/* 覆盖父类的网络数据包处理函数以便实现通信协议的数据包解析 */
|
|||
|
|
VOID ProcessRecvBuffers(PDATABUFFER pDataBuffer);
|
|||
|
|
private:
|
|||
|
|
void AddMessage(jxSrvDef::INTERSRVCMD nCmd, CDataPacketReader& packet);
|
|||
|
|
CDataPacket* AllocPacket();
|
|||
|
|
void FreePacket(CDataPacket* packet);
|
|||
|
|
void DestroyPacketList(CQueueList<CDataPacket*>& pkgList);
|
|||
|
|
void HandleAMMessage(jxSrvDef::INTERSRVCMD nCmd, CDataPacket &packet);
|
|||
|
|
int GetErrorNo();
|
|||
|
|
|
|||
|
|
void RegistClient(CDataPacket &packet);
|
|||
|
|
void QueryAmount(CDataPacket &packet);
|
|||
|
|
void Consume(CDataPacket &packet);
|
|||
|
|
LPCSTR GetResultCode(int op);
|
|||
|
|
void SendResponse(SOCKET nsocket, LPCSTR sContent);
|
|||
|
|
void SendTaskSituation(CDataPacket &packet);
|
|||
|
|
//获取连接的服务器名称
|
|||
|
|
inline LPCSTR getClientName(){ return m_sClientName; }
|
|||
|
|
private:
|
|||
|
|
|
|||
|
|
//char buff[1024];
|
|||
|
|
char m_gName[10]; //游戏英文缩写
|
|||
|
|
char m_Spid[10]; //运营商英文缩写
|
|||
|
|
|
|||
|
|
CQueueList<CDataPacket*> m_sMsgList;
|
|||
|
|
CCSLock m_sMsgListLock;
|
|||
|
|
CQueueList<CDataPacket*> m_sFreeList;
|
|||
|
|
CCSLock m_sFreeListLock;
|
|||
|
|
|
|||
|
|
//CSQLConenction m_Mysql;
|
|||
|
|
CAMServerSocket* m_pSrv;
|
|||
|
|
|
|||
|
|
CProduct * m_Product;
|
|||
|
|
bool m_IsRegist;
|
|||
|
|
|
|||
|
|
|
|||
|
|
unsigned int m_nClientSrvIdx; //客户端的服务器ID
|
|||
|
|
|
|||
|
|
char m_sClientName[64]; //客户端注册的服务器名称
|
|||
|
|
|
|||
|
|
jxSrvDef::SERVERTYPE m_eClientType; //客户端注册的服务器类型
|
|||
|
|
|
|||
|
|
int m_boRegisted; //客户端是否已经注册连接
|
|||
|
|
|
|||
|
|
TASKREQ_Map m_TaskMap;
|
|||
|
|
RTL_CRITICAL_SECTION m_TaskMsgVecLock;
|
|||
|
|
};
|