lyfz_repos/经典版源码/kernelcode/lyfzIMGSelection/hp-src/helper.h

#pragma once

#include "SocketInterface.h"
#include "GeneralHelper.h"

#define USER_INFO_MSG			(WM_USER + 100)
#define MAX_LOG_RECORD_LENGTH	1000

#define EVT_ON_SEND				_T("OnSend")
#define EVT_ON_RECEIVE			_T("OnReceive")
#define EVT_ON_CLOSE			_T("OnClose")
#define EVT_ON_ERROR			_T("OnError")
#define EVT_ON_PREPARE_CONNECT	_T("OnPrepareConnect")
#define EVT_ON_PREPARE_LISTEN	_T("OnPrepareListen")
#define EVT_ON_ACCEPT			_T("OnAccept")
#define EVT_ON_CONNECT			_T("OnConnect")
#define EVT_ON_HAND_SHAKE		_T("OnHandShake")
#define EVT_ON_SHUTDOWN			_T("OnShutdown")
#define EVT_ON_END_TEST			_T("END TEST")

#define EVT_ON_MESSAGE_BEGIN	_T("OnMessageBegin")
#define EVT_ON_REQUEST_LINE		_T("OnRequestLine")
#define EVT_ON_STATUS_LINE		_T("OnStatusLine")
#define EVT_ON_HEADER			_T("OnHeader")
#define EVT_ON_HEADERS_COMPLETE	_T("OnHeadersComplete")
#define EVT_ON_BODY				_T("OnBody")
#define EVT_ON_CHUNK_HEADER		_T("OnChunkHeader")
#define EVT_ON_CHUNK_COMPLETE	_T("OnChunkComplete")
#define EVT_ON_MESSAGE_COMPLETE	_T("OnMessageComplete")
#define EVT_ON_UPGRADE			_T("OnUpgrade")
#define EVT_ON_PARSE_ERROR		_T("OnParseError")

#define MAX_STUDIOID_LENGTH		37
#define MAX_ACCOUNT_LENGTH		17
#define MAX_PASSWORD_LENGTH		17

enum EnAppState
{
	ST_STARTING, ST_STARTED, ST_CONNECTING, ST_CONNECTED, ST_STOPPING, ST_STOPPED
};

enum ProtocolCmd
{
	//----------------------------:common comand.type:  1~999----------------------------------------------------
	CMD_HEART							= 1,		// 心跳包;
	CMD_TOCHAT							= 2,		// 文字聊天;
	CMD_FILEINFO_TRANSFER				= 3,		// 文件传输-文件信息;
	CMD_FILECONT_TRANSFER				= 4,		// 文件传输-文件内容;
	CMD_UPDATA							= 5,		// 有升级信息（用户终端每次登录时,请求检测是否有新版本可升级的信息）;
	CMD_DATABASEINFO					= 6,		// 向请求端返回数据库信息;
	CMD_OHTER_INFO						= 999,		// 其他信息;


	//------------------------C2L:consumer terminal to lyfz.service: 1000~1999------------------------------------
	C2LCMD_REQ_LOGIN					= 1000,		// 用户终端请求登录利亚方舟服务端（外网ip+登录信息）;
	//C2LCMD_GET_DOG_DATA					= 1001,		// 利亚方舟获取用户终端机器加密狗数据信息;
	C2LCMD_DOGINFO						= 1001,		// 用户终端向利亚方舟发送加密狗信息;
	C2LCMD_GET_VAR						= 1002,		// 请求用户终端的版本号;
	C2LCMD_DEAL_ILLEGAL					= 1003,		// 处理盗版、过期用户：停止用户终端工作、启用定时关机、程序文件自动删除等等操作命令;
	C2LCMD_DEAL_SMS						= 1004,		// 利亚方舟服务端处理用户终端的短信发送工作;
	C2LCMD_GET_DBINFO					= 1005,		// 利亚方舟服务端获取用户终端电脑数据库信息;

	// .预留，若SQL数据库引擎未启用TCP/IP作为远程连接方式,需定义读写表的具体命令;（Jeff.100%的不建议使用这种方式获取数据，占用太多带宽和资源）
	// .若要使用SQL,则只允许SQL的updata、insert、delete、drop……等命令,不允许使用select来返回查询到数据;

	C2LCMD_OTHER_INFO					= 1999,     // 读其它信息;

	//------------------------C2C:consumer client to consumer service: 2000~2999--------------------------------
	C2CCMD_REQ_LOGIN					= 2000,     // 客户端请求登录服务器;
	C2CCMD_REQ_LOGOUT					= 2001,		// 客户端注销;
	C2CCMD_REQ_DOG_DATA					= 2002,     // 读软件狗数据;
	C2CCMD_AUTO_UPDATA					= 2003,		// 服务端向所有客户发送自动数据更新命令;
	C2CCMD_REQ_SERVER_VAR				= 2004,		// 请求服务端的版本号;
	C2CCMD_GET_DBINFO					= 2005,		// 利亚方舟服务端获取用户终端电脑数据库信息;
	C2CCMD_ORD_PHOTO_BAK				= 2006,		// 客户端端向备份程序发送订单相片重新备份命令(导片与备份存在写备份无法锁定现象,need to Notify);
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_ORDERINFO				= 2007,		// 开单;
	C2CCMD_DEL_ORDERINFO				= 2008,		// 删除订单;
	C2CCMD_MOD_ORDERINFO				= 2009,		// 修改订单;
	C2CCMD_MOD_ORDERINFO2				= 2089,		// 修改订单;
	C2CCMD_QRY_ORDERINFO				= 2010,		// 查询订单;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_PRODUCT					= 2012,		// 添加商品;
	C2CCMD_MOD_PRODUCT					= 2013,		// 修改商品;
	C2CCMD_DEL_PRODUCT					= 2014,		// 删除商品;
	C2CCMD_QRY_PRODUCT					= 2015,		// 查询商品;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_CUSTOMERFROM				= 2016,		// 添加顾客来源;
	C2CCMD_DEL_CUSTOMERFROM				= 2017,		// 删除顾客来源;
	C2CCMD_MOD_CUSTOMERFROM				= 2018,		// 修改顾客来源;
	C2CCMD_QRY_CUSTOMERFROM				= 2019,		// 查询顾客来源;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_CUSTOMERINFO				= 2020,		// 添加新顾客信息;
	C2CCMD_DEL_CUSTOMERINFO				= 2021,		// 删除顾客信息;
	C2CCMD_MOD_CUSTOMERINFO				= 2022,		// 修改顾客信息;
	C2CCMD_QRY_CUSTOMERINFO				= 2023,		// 查询顾客信息;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_DEPARTMENT				= 2024,		// 新增部门信息;
	C2CCMD_DEL_DEPARTMENT				= 2025,		// 删除部门信息;
	C2CCMD_MOD_DEPARTMENT				= 2026,		// 修改部门信息;
	C2CCMD_QRY_DEPARTMENT				= 2027,		// 查询部门信息;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_STAFFINFO				= 2028,		// 新增员工信息;
	C2CCMD_DEL_STAFFINFO				= 2029,		// 删除员工信息;
	C2CCMD_MOD_STAFFINFO				= 2030,		// 修改员工信息;
	C2CCMD_QRY_STAFFINFO				= 2031,		// 查询员工信息;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_USERINFO					= 2032,		// 新增用户信息;
	C2CCMD_DEL_USERINFO					= 2033,		// 删除用户信息;
	C2CCMD_MOD_USERINFO					= 2034,		// 修改用户信息;
	C2CCMD_QRY_USERINFO					= 2035,		// 查询用户信息;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_SCENERY					= 2036,		// 新增景点信息;
	C2CCMD_DEL_SCENERY					= 2037,		// 删除景点信息;
	C2CCMD_MOD_SCENERY					= 2038,		// 修改景点信息;
	C2CCMD_QRY_SCENERY					= 2039,		// 查询景点信息;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_ORDERTYPE				= 2040,		// 新增订单类型信息;
	C2CCMD_DEL_ORDERTYPE				= 2041,		// 删除订单类型信息;
	C2CCMD_MOD_ORDERTYPE				= 2042,		// 修改订单类型信息;
	C2CCMD_QRY_ORDERTYPE				= 2043,		// 查询订单类型信息;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_PRODUCTTYPE				= 2044,		// 添加商品类型;
	C2CCMD_MOD_PRODUCTTYPE				= 2045,		// 修改商品类型;
	C2CCMD_DEL_PRODUCTTYPE				= 2046,		// 删除商品类型;
	C2CCMD_QRY_PRODUCTTYPE				= 2047,		// 查询商品类型;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_PACKAGETYPE				= 2048,		// 添加套系类型;
	C2CCMD_DEL_PACKAGETYPE				= 2049,		// 修改套系类型;
	C2CCMD_MOD_PACKAGETYPE				= 2050,		// 删除套系类型;
	C2CCMD_QRY_PACKAGETYPE				= 2051,		// 查询套系类型;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_PACKAGEINFO				= 2052,		// 添加套系信息;
	C2CCMD_DEL_PACKAGEINFO				= 2053,		// 删除套系信息;
	C2CCMD_MOD_PACKAGEINFO				= 2054,		// 修改套系信息;
	C2CCMD_QRY_PACKAGEINFO				= 2055,		// 查询套系信息;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_PACKAGEITEM				= 2056,		// 添加套系项目;
	C2CCMD_DEL_PACKAGEITEM				= 2057,		// 修改套系项目;
	C2CCMD_MOD_PACKAGEITEM				= 2058,		// 删除套系项目;
	C2CCMD_QRY_PACKAGEITEM				= 2059,		// 查询套系项目;
	C2CCMD_QRY_PACKAGEITEM_DETAIL		= 2072,		// 查询套系项目详情;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_ORDERPACKAGEITEM			= 2060,		// 添加套系项目;
	C2CCMD_NEW_ORDERPACKAGEITEM2		= 2087,		// 添加订单套餐项目（删除以前的）;
	C2CCMD_DEL_ORDERPACKAGEITEM			= 2061,		// 修改套系项目;
	C2CCMD_MOD_ORDERPACKAGEITEM			= 2062,		// 删除套系项目;
	C2CCMD_QRY_ORDERPACKAGEITEM			= 2063,		// 查询套系项目;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_SYSCONFING				= 2064,		// 添加影楼配置信息;
	C2CCMD_DEL_SYSCONFING				= 2065,		// 删除影楼配置信息;
	C2CCMD_MOD_SYSCONFING				= 2066,		// 修改影楼配置信息;
	C2CCMD_QRY_SYSCONFING				= 2067,		// 查询影楼配置信息;
	//////////////////////////////////////////////////////////////////////////
	C2CCMD_NEW_STUDIOINFO				= 2068,		// 添加影楼信息;
	C2CCMD_DEL_STUDIOINFO				= 2069,		// 删除影楼信息;
	C2CCMD_MOD_STUDIOINFO				= 2070,		// 修改影楼信息;
	C2CCMD_QRY_STUDIOINFO				= 2071,		// 查询影楼信息;
	// .预留，若SQL数据库引擎未启用TCP/IP作为远程连接方式,需定义读写表的具体命令;（Jeff.100%的不建议使用这种方式获取数据，占用太多带宽和资源）
	// .若要使用SQL,则只允许SQL的updata、insert、delete、drop……等命令,不允许使用select来返回查询到数据;

	//C2CCMD_QRY_PACKAGEITEM_DETAIL		= 2072,		// 查询套系项详情;
	C2CCMD_QRY_PACKAGEITEM_VIEW			= 2073,		// 查询套系项详情;
	C2CCMD_NEW_PACKAGEITEM_MUTI			= 2074,		// 多个项同时插入到套系中;	
	C2CCMD_NEW_PACKAGEITEM2				= 2075,		// 添加套系项目;

	// 订单景点信息;
	C2CCMD_NEW_ORDERSCENERY				= 2076,		// 添加订单景点信息;
	C2CCMD_NEW_ORDERSCENERY2			= 2088,		// 添加订单景点信息（删除以前的）;
	C2CCMD_DEL_ORDERSCENERY				= 2077,		// 删除订单景点信息,使用autoid;
	C2CCMD_MOD_ORDERSCENERY				= 2078,		// 修改订单景点信息;
	C2CCMD_QRY_ORDERSCENERY				= 2079,		// 查询订单景点信息;
	C2CCMD_DEL_ORDERSCENERY2			= 2080,		// 删除订单景点信息,使用订单号+景点名;

	// 订单商品信息;
	C2CCMD_NEW_ORDERPRODUCT				= 2081,		// 添加订单商品信息;
	C2CCMD_DEL_ORDERPRODUCT				= 2082,		// 删除订单商品信息;
	C2CCMD_MOD_ORDERPRODUCT				= 2083,		// 修改订单商品信息;
	C2CCMD_QRY_ORDERPRODUCT				= 2084,		// 查询订单商品信息;

	// 获取订单序号;
	C2CCMD_GET_ORDER_SERIALNUMBER		= 2085,		// 获取订单序号;
	// 获取打印序号;
	C2CCMD_GET_PRINT_SERIALNUMBER		= 2086,		// 获取打印序号;

	C2CCMD_OTHER_INFO					= 2999,     // 读其它信息;
};

enum PackageFlag
{
	PACKAGE_ONESELF		= 0,			// 协议包-独立;
	PACKAGE_MULTIPLE	= 1,			// 协议包-多个;
};

enum UserLogInStatus
{
	USER_LOGIN			= 1,				// 登录成功;
	USER_PW_MISTAKE		= 2,				// 密码错误;
	USER_HAVE_LOGIN		= 3,				// 用户已经登录;
	USER_NULL			= 0					// 没有用户;
};

typedef struct __LogInUser__
{
	TCHAR				szStudioId[MAX_STUDIOID_LENGTH];		// 影楼Guid;
	TCHAR				szAccount[MAX_ACCOUNT_LENGTH];			// 账号;
	TCHAR				szPassword[MAX_PASSWORD_LENGTH];		// 密码;
}LogInUser,*pLogInUser;


#pragma pack(push,1)  
// 协议头-勿更改;
typedef struct __THEPROPACKAGE__
{
	byte				flag;				// 协议包类型标识;
	short				nCmd;				// 协议携带的命令标识;
	//unsigned int		nUnCompressLen;
	unsigned int		nDataLen;			// 数据长度,除了头之外的数据;
	unsigned int		nSubDataLen;		// 分包大小;
	DWORD				dwReserve;			// 预留填0;
	TCHAR				szStudioId[MAX_STUDIOID_LENGTH];		// 影楼Guid;
	TCHAR				szAccount[MAX_ACCOUNT_LENGTH];			// 账号;
	TCHAR				szPassword[MAX_PASSWORD_LENGTH];		// 密码;
	//BYTE				byProp[5];
	BYTE				byBody[2];			// 包数据;

	__THEPROPACKAGE__(){
		flag = PACKAGE_ONESELF;
		nCmd = 0;
		nDataLen = 0;
		nSubDataLen = 0;
		dwReserve = 0;
		memset(byBody, 0, 2);
		//memset(byProp, 0, 5);
		memset(szStudioId, 0, sizeof(TCHAR)*MAX_STUDIOID_LENGTH);
		memset(szAccount, 0, sizeof(TCHAR)*MAX_ACCOUNT_LENGTH);
		memset(szPassword, 0, sizeof(TCHAR)*MAX_PASSWORD_LENGTH);
	}
}TheProPackage,*pTheProPackage;

#pragma pack(pop) 


struct info_msg
{
	LPCTSTR name;
	CONNID connID;
	LPCTSTR evt;
	int contentLength;
	LPCTSTR content;

	static info_msg* Construct(CONNID dwConnID, LPCTSTR lpszEvent, int iContentLength = 0, LPCTSTR lpszContent = nullptr, LPCTSTR lpszName = nullptr);
	static void Destruct(info_msg* pMsg);

private:
	info_msg(CONNID dwConnID, LPCTSTR lpszEvent, int iContentLength = 0, LPCTSTR lpszContent = nullptr, LPCTSTR lpszName = nullptr);
	~info_msg();
};

struct TPkgHeader 
{
	DWORD seq;
	int body_len;
};

struct TPkgBody 
{
	char name[30];
	short age;
	char desc[1];
};

struct TPkgInfo
{
	bool is_header;
	int length;

	TPkgInfo(bool header = true, int len = sizeof(TPkgHeader)) : is_header(header), length(len) {}
	void Reset() {is_header = true, length = sizeof(TPkgHeader);}
	~TPkgInfo() {}
};

CBufferPtr* GeneratePkgBuffer(DWORD seq, LPCTSTR lpszName, short age, LPCTSTR lpszDesc);
CBufferPtr* GeneratePkgBuffer(const TPkgHeader& header, const TPkgBody& body);

void SetMainWnd(CWnd* pWnd);
void SetInfoList(CListBox* pInfoList);

void LogServerStart(LPCTSTR lpszAddress, USHORT port, LPCTSTR lpszName = nullptr);
void LogServerStartFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
void LogServerStop(LPCTSTR lpszName = nullptr);
void LogServerStopFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
void LogClientStart(LPCTSTR lpszAddress, USHORT port, LPCTSTR lpszName = nullptr);
void LogClientStarting(LPCTSTR lpszAddress, USHORT port, LPCTSTR lpszName = nullptr);
void LogClientStartFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
void LogClientStopping(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void LogClientStopFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
void LogSend(CONNID dwConnID, LPCTSTR lpszContent, LPCTSTR lpszName = nullptr);
void LogClientSendFail(int iSequence, int iSocketIndex, DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
void LogSendFail(CONNID dwConnID, DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
void LogDisconnect(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void LogDisconnectFail(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void LogRelease(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void LogReleaseFail(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void LogDetect(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void LogDetectFail(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void LogOnConnect(CONNID dwConnID, const CString& strAddress, USHORT usPort);
void LogOnConnect2(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void LogOnHandShake2(CONNID dwConnID, LPCTSTR lpszName = nullptr);

void PostOnSend(CONNID dwConnID, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
void PostOnReceive(CONNID dwConnID, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
void PostOnReceiveCast(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
void PostOnClose(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void PostOnError(CONNID dwConnID, int enOperation, int iErrorCode, LPCTSTR lpszName = nullptr);
void PostOnAccept(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, BOOL bPass, LPCTSTR lpszName = nullptr);
void PostOnAccept2(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void PostOnHandShake(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void PostOnPrepareListen(LPCTSTR lpszAddress, USHORT usPort, LPCTSTR lpszName = nullptr);
void PostOnPrepareConnect(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void PostOnConnect(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, LPCTSTR lpszName = nullptr);
void PostOnConnect2(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, LPCTSTR lpszName = nullptr);
void PostOnConnect3(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void PostOnShutdown(LPCTSTR lpszName = nullptr);
void PostServerStatics(const LONGLONG& llTotalSent, const LONGLONG& llTotalReceived, LPCTSTR lpszName = nullptr);
void PostTimeConsuming(DWORD dwTickCount, LPCTSTR lpszName = nullptr);

void PostOnMessageBegin(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void PostOnRequestLine(CONNID dwConnID, LPCSTR lpszMethod, USHORT usUrlFieldSet, LPCSTR lpszUrl, LPCTSTR lpszName = nullptr);
void PostOnStatusLine(CONNID dwConnID, USHORT usStatusCode, LPCSTR lpszDesc, LPCTSTR lpszName = nullptr);
void PostOnHeader(CONNID dwConnID, LPCSTR lpszHeaderName, LPCSTR lpszHeaderValue, LPCTSTR lpszName = nullptr);
void PostOnHeadersComplete(CONNID dwConnID, LPCSTR lpszSummary, LPCTSTR lpszName = nullptr);
void PostOnBody(CONNID dwConnID, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
void PostOnChunkHeader(CONNID dwConnID, int iLength, LPCTSTR lpszName = nullptr);
void PostOnChunkComplete(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void PostOnMessageComplete(CONNID dwConnID, LPCTSTR lpszName = nullptr);
void PostOnUpgrade(CONNID dwConnID, EnHttpUpgradeType enUpgradeType, LPCTSTR lpszName = nullptr);
void PostOnParseError(CONNID dwConnID, int iErrorCode, LPCSTR lpszErrorDesc, LPCTSTR lpszName = nullptr);

void PostInfoMsg(info_msg* msg);
void LogInfoMsg(info_msg* pInfoMsg);
void LogMsg(const CString& msg);

#ifdef _SSL_SUPPORT

extern int g_c_iVerifyMode;
extern BOOL g_c_bNeedClientVerification;
extern LPCTSTR g_c_lpszCAPemCertFileOrPath;
extern LPCTSTR g_c_lpszPemCertFile;
extern LPCTSTR g_c_lpszPemKeyFile;
extern LPCTSTR g_c_lpszKeyPasswod;

extern int g_s_iVerifyMode;
extern BOOL g_s_bNeedClientVerification;
extern LPCTSTR g_s_lpszCAPemCertFileOrPath;
extern LPCTSTR g_s_lpszPemCertFile;
extern LPCTSTR g_s_lpszPemKeyFile;
extern LPCTSTR g_s_lpszKeyPasswod;

#endif