146 lines
4.1 KiB
C++
146 lines
4.1 KiB
C++
#pragma once
|
||
|
||
/************************************************************************/
|
||
/*
|
||
/* AM(Amount Manager)金额管理系统客户端类
|
||
/*
|
||
/* 提供查询用户余额以及对用户进行扣费的操作接口。
|
||
/*
|
||
/************************************************************************/
|
||
class CSSManager;
|
||
|
||
class CAMClient :
|
||
public CCustomClientSocket
|
||
{
|
||
public:
|
||
typedef CCustomClientSocket Inherited;
|
||
|
||
//定义AM操作类型
|
||
enum eAMOPType
|
||
{
|
||
amQueryAmount = 1, //查询余额
|
||
amConsume = 2, //扣费
|
||
amPaySucceed =3, //充值成功了
|
||
};
|
||
|
||
//定义AM操作数据
|
||
typedef struct AMOPData
|
||
{
|
||
int opType; //操作类型
|
||
unsigned int nUserId; //用户ID
|
||
INT nServerId; //服务器ID
|
||
INT nResult; //负数表示失败或发生错误，否则表示操作结果（查询余额则表示余额，扣费时为0表示成功-1表示余额不足）
|
||
INT64 lOPPtr; //操作对象（客户端穿透服务器的数据）
|
||
}AMOPDATA, *PAMOPDATA;
|
||
|
||
typedef struct tagTASKMsg
|
||
{
|
||
INT nServerId;//服务器Id
|
||
unsigned int nUserId; //UserID 账号id
|
||
INT nCmd;
|
||
INT nContractid; //任务id
|
||
INT nStep;
|
||
INT nResult; //返回值
|
||
INT64 lOPPtr;//操作对象（客户端穿透服务器的数据）
|
||
}TASKMSG, *PTASKMSG;
|
||
public:
|
||
CAMClient();
|
||
~CAMClient();
|
||
|
||
static char * GetOpCode(int nOp)
|
||
{
|
||
switch(nOp)
|
||
{
|
||
case amQueryAmount:
|
||
return "Query Yb";
|
||
break;
|
||
case amConsume:
|
||
return "Draw Yb";
|
||
break;
|
||
case amPaySucceed:
|
||
return "Pay Ok";
|
||
break;
|
||
default:
|
||
return "Error op";
|
||
}
|
||
}
|
||
|
||
|
||
/*
|
||
* Comments: 获取AM操作结果队列
|
||
* Param wylib::container::CBaseList<AMOPDATA> & list: 保存操作结果的列表
|
||
* @Return INT_PTR: 函数返回向list中保存了多少个操作结果
|
||
* @REMARKS: 将操作结果保存到list后会清空类本身内部的操作结果
|
||
*/
|
||
INT_PTR GetAMOPResults(wylib::container::CBaseList<AMOPDATA> &list);
|
||
|
||
INT_PTR GetTaskOPResults(wylib::container::CBaseList<TASKMSG> &list);
|
||
|
||
/*
|
||
* Comments: 发送查询用户余额的数据
|
||
* Param INT_PTR nUserId: 用户ID
|
||
* Param INT_PTR nServerId: 服务器ID
|
||
* Param INT64 lOPPtr: 穿透数据
|
||
* @Return VOID:
|
||
*/
|
||
VOID PostQueryAmount(unsigned int nUserId, INT_PTR nServerId, INT64 lOPPtr);
|
||
/*
|
||
* Comments: 发送对用户进行扣费的数据
|
||
* Param INT_PTR nUserId: 用户ID
|
||
* Param INT_PTR nServerId: 服务器ID
|
||
* Param INT_PTR nAmount: 扣费数量，必须是正整数
|
||
* Param LPCSTR sCharName: 进行消费的角色名称
|
||
* Param INT64 lOPPtr:提取的角色id
|
||
* Param BYTE nLevel: 提取等级
|
||
* @Return VOID:
|
||
*/
|
||
VOID PostConsume(unsigned int nUserId, INT_PTR nServerId, INT_PTR nAmount, LPCSTR sCharName, INT64 lOPPtr, BYTE nLevel);
|
||
|
||
|
||
//发送集市任务等信息给am
|
||
VOID PostAmTaskData(tagTASKMsg &data);
|
||
public:
|
||
//获取产品名称
|
||
LPCSTR GetProductName();
|
||
|
||
//设置产品名称
|
||
VOID SetProductName(LPCSTR sProductName);
|
||
|
||
//获取SPID
|
||
LPCSTR GetSPID();
|
||
|
||
//设置SPID
|
||
VOID SetSPID(LPCSTR sSPID);
|
||
|
||
protected:
|
||
//处理接受到的服务器数据包
|
||
VOID ProcessRecvBuffers(PDATABUFFER pDataBuffer);
|
||
//连接到服务器成功后发送注册客户端的消息
|
||
VOID SendRegisteClient();
|
||
//当长时间没有通信后发送保持连接的消息
|
||
VOID SendKeepAlive();
|
||
|
||
private:
|
||
//处理单个通信数据包
|
||
VOID ProcessRecvPacket(CDataPacketReader &packet);
|
||
//重载申请数据包的函数，在包头写入数据包起始标志
|
||
//CDataPacket& allocSendPacket();
|
||
|
||
CDataPacket& allocProtoPacket(int nCmd);
|
||
|
||
//重载提交数据包的函数，在包尾写入数据包起始标志
|
||
VOID flushProtoPacket(CDataPacket& packet);
|
||
|
||
VOID OnDispatchRecvPacket(int nCmd, CDataPacketReader &inPacket) ;
|
||
|
||
private:
|
||
//CHAR m_RecvForCompilerError[1024];//VC2010 编译器BUG，编译后会使得此类的成员地址与父类成员相交，因此此处腾出1K字节避开此BUG
|
||
CHAR m_sProductName[32]; //产品名称
|
||
CHAR m_sProviderId[32]; //SPID
|
||
wylib::container::CQueueList<AMOPDATA> m_OPResultList;//操作结果队列
|
||
|
||
wylib::container::CQueueList<TASKMSG> m_OPRTaskList;//操作结果队列
|
||
CCSLock m_OPResultLock; //操作结果队列锁
|
||
|
||
CCSLock m_OPTaskLock; //操作结果队列锁
|
||
}; |