/****************************************************************
Copyright ?, 1989-2002, Hisunsray Tech. Co., Ltd.
File name: SMGModule.h
Author: lizhigang
Version:  V3.0.0.0#20030320-1
Date: 2003-03-20
Description:
History:
*****************************************************************/


#ifndef __APPSERVERMODULE_H_
#define __APPSERVERMODULE_H_

#include "BaseService.h"
#include "SessionObject.h"
#include "AppFlow.h"

class TSMGModule : public TBaseService
{
//屬性
public:
	RTCS_CTuint			m_AlarmStation;		//告警模塊站點號

	TSessionObjectTable	m_SessionObjectTable;//會話對象表

	TAppFlowTable		m_AppFlowTable;		//流程信息表
	
	RTCS_TraceLog *		logfile;			//日志文件

	RTCS_CTstring		m_ModuleName;		//模塊名

	RTCS_CTuint			m_SMAIGOR;


private:
	RTCS_CTuint m_DataSourceCount;
	RTCS_CTuint m_DataSourceGOR[64];
	RTCS_CTstring m_DataSourceName[64];
	RTCS_CTuint UnpacketMsg(RTCS_CTbyteArray Msg_Content,RTCS_CTuint Msg_Content_lenth,RTCS_CTbyte flag,char *prefix);

public:
	TSMGModule(RTCS_CTstring clientname);
	~TSMGModule();

public:
	//取配置參數
	void GetParam();
	//初始化流程表
	void InitAppFlowTable();
	//系統初始化
    int SysInit();

	//添加統計信息:處理個數
	void AddHandleCount(); 
	//添加統計信息:繳費成功個數
	void AddPaymentSuccess(RTCS_CTdouble Money);
	//向維護終端發送告警信息
	RTCS_CTuint SendAlarm(RTCS_CTuint AlarmLevel, RTCS_CTstring AlarmObject, RTCS_CTstring AlarmDetial);
	//內存快照
	void Snapshot();
	//數據源
	RTCS_CTuint GetDataSource(RTCS_CTuint index);

//重載RTCS_Client的函數
	virtual RTCS_CTuint OnBusInserted();
	virtual RTCS_CTuint OnClientOnline(RTCS_CTstring clientname);
	virtual RTCS_CTuint OnClientOffline(RTCS_CTstring clientname);

//重載BaseService的函數
	// 初始化原子動作函數
	virtual void InitActions();
    // 初始化流程事件
	virtual void InitEvents();
	// 初始化系統變量
	virtual void InitSystemVars();
	// 初始化消息預處理函數
	void InitMsgAPI();
	// 非流程消息處理，相當于沒有流程時的RTCS_Client的HandleMessage的作用
	virtual TRealtimeObject * HandleExceptionAPI(RTCS_CTpdu & message);
	//流程結束處理
	virtual void OnObjectIdle(TRealtimeObject * object);

//一般消息處理函數
    RTCS_CTuint OnPing(RTCS_CTpdu& pdu);
	RTCS_CTuint OnQueryInfo(RTCS_CTpdu& pdu);
	RTCS_CTuint OnRespQueryInfoFromDBAccessModule(RTCS_CTpdu& pdu);

//消息預處理函數
	//從接口模塊發來的請求
	TRealtimeObject * OnISMGDeliver(RTCS_CTpdu& pdu);
	TRealtimeObject * OnISMGBindResp(RTCS_CTpdu& pdu);
	TRealtimeObject * OnISMGSubmitResp(RTCS_CTpdu& pdu);
	TRealtimeObject * OnISMGUnBindResp(RTCS_CTpdu& pdu);
	TRealtimeObject * OnDataAccessResp(RTCS_CTpdu& pdu);

	//從數據庫訪問模塊返回的響應
	TRealtimeObject * OnEvtReturn(RTCS_CTpdu& pdu);
	TRealtimeObject * OnEvtTimerExpired(RTCS_CTpdu& pdu);
	TRealtimeObject * OnEvtFail(RTCS_CTpdu& pdu);


//消息發送函數
	//向接入網關發回應消息
	RTCS_CTint Report2Exterm(RTCS_CTstring FlowID,RTCS_CTstring CardID,RTCS_CTstring PhoneNumber,RTCS_CTstring FullTime,RTCS_CTstring FullMoney);
};

#endif