pkginfobase.hpp

液晶电视完整代码可实现人机界面

//------------------------------------------------------------------- 
// 系统名：小额批量支付系统MBFE
// 文件名：PKGInfoBase.hpp
// 描  述：MBFE后台服务基础类
// 版  本：v1.0
// Copyright (c) 2005  YLINK
//------------------------------------------------------------------- 

#ifndef __PKGINFOBASE__
#define __PKGINFOBASE__

//公共头文件
#include "SvrDef.hpp"
#include "BepsMbfePub.hpp"

// 系统错
#define E_ReadBigDataFail     			21753001			// CB0S5001 查询大文本数据存储表失败
#define E_UpdateBigDataFail  			21753002			// CB0S5003 更新大文本数据存储表失败
#define E_SaveBigDataFail     			21753003			// CB0S5002 保存大文本数据存储表失败
#define E_GetCmtAttrFail     			21753004			// CB0S5001 查询报文属性表失败
#define E_SaveRunInfoFail         		21753005			// CB0S5002 保存运行信息通知表失败	
#define E_GetQueueNoFail      			21753006			// CB0S5013 产生队列序号失败 

#define E_SaveAPIMBRQFail     			21753007			// CB0S5002 保存接口数据来帐队列失败
#define E_DelBigDataFail      			21753008			// CB0S5004 删除大文本数据存储表失败
#define E_DelAPIMBSQFail      			21753009			// CB0S5004 删除接口数据往帐队列失败
#define E_DelAPIMBRQFail     			21753010			// CB0S5004 删除接口数据来帐队列失败
#define E_SaveCOMMBFESQFail  			21753011			// CB0S5002 保存通讯数据往帐队列失败
#define E_DelCOMMBFERQFail   			21753012			// CB0S5004 删除通讯数据来帐队列失败
#define E_MdyCOMMBFERQFail   			21753013			// CB0S5003 修改通讯数据来帐队列失败

#define E_BuildMsgHeaderFail 			21753014			// CB0S2004 组报文头失败
#define E_UnknownAppCode     			21753015			// CB0S9999 错误的系统编码
#define E_Pack911HeaderFail   			21753016			// CB0S2004 组911报文头失败
#define E_Pack911BusinessFail 			21753017			// CB0S2004 组911正文失败
//#define E_CallMacError     	            21753018            // CB0S9008 密押卡工作异常
#define E_MdyAPIMBSQFail                21753019            // CB0S5003 更新接口数据往帐表失败
#define E_MsgHeaderError                21753020            // CB0S2003 报文头错
#define E_GetSysWorkDateFail            21753021            // CB0S5001 取系统工作日期失败
#define E_MdyRecordStateError           21753022            // CB0S5003 修改状态失败

// 业务错
#define E_CheckRecvNodeLegFail          21753501            // CB0O1407 接收节点关系合法性检查失败
#define E_CheckSendNodeLegFail          21753502            // CB0O1406 发起节点关系合法性检查失败
#define E_CheckRdfiCodeStatusFail 		21753503           	// CB0O2004 接收行状态合法性检查失败
#define E_CheckOdfiCodeStatusFail 		21753504           	// CB0O2003 发起行状态合法性检查失败
#define E_CheckPubRecvFail        		21753505           	// CB0O1999 来帐检查失败
#define E_CheckOdfiCodeRecvGrantFail 	21753506       		// CB0O5002 接收清算行接收业务权限合法性检查失败
#define E_CheckSdfiCodeSendGrantFail 	21753507			// CB0O5001 发起清算行发起业务权限合法性检查失败
#define E_CheckOsdfiCodeFail        	21753508			// CB0O2004 接收清算行状态合法性检查失败
#define E_CheckIsdfiCodeFail 			21753509			// CB0O2003 发起清算行状态合法性检查失败
#define E_CheckOdfiCenterFail 			21753510			// CB0O1101 发报中心状态合法性检查失败
#define E_CheckDateFail 				21753511			// CB0O1005 日期合法性检查失败
#define E_CheckSdfiCenterFail 			21753512			// CB0O1102 收报中心状态合法性检查失败
#define E_CheckNpcLegFail 				21753513			// CB0O3001 NPC状态合法性检查
#define E_SendIsdfiCodeNotEq 			21753514			// CB0O1103 报文头发起清算行和正文发起清算行是否一致
#define E_SendRdfiCodeNotEq 			21753515			// CB0O1102 报文头收报中心和正文收报中心是否一致
#define E_SendOsdfiCodeNotEq 			21753516			// CB0O1104 报文头中接收清算行和正文接收清算行是否一致
#define E_GetCcpcCenterFail 			21753517			// CB0O1309 取CCPC号码失败
#define E_MsgHeaderReceiverLengthErr 	21753518 			// CB0O1999 报文头中接收方长度错误
#define E_CheckMacError                 21753519            // CB0O4001 核地方押失败
#define E_MakeMacError   	            21753520            // CB0O4002 加地方押失败
#define E_CallMacError     	            21753521            // CB0O4999 密押卡工作异常  

//extern  MainCtlToSo * strMainCtlToSo;

typedef struct
{
	char    m_sPkgType[4];				//包类型号
	char    m_sISDfiCode[13];			//发起清算行行号
	char    m_sOSDfiCode[13];			//接收清算行行号
	char    m_sPkgPreDate[9];			//包委托日期
	int     m_nPkgSerNo;				//包序号
	char		m_sDistrFlag[2];			//辖内分发标志
	char		m_sPkgExpData[65];			//包附加数据
	char    m_sTrxsType[6];				//业务类型号
	char    m_sPreDate[9];				//委托日期
	int			m_nTrxNo;					//信息业务序号
	int			m_nExpDataLen;				//信息长度
	char		m_sExpData[251];			//信息内容
	char    m_sRSFlag[2];				//往来标记
	char		m_sProcState[3];				//处理状态


}PKGInfoDetail;//通用信息明细结构

class PKGInfoBase 
{
public: 
	static MainCtlToSo * strMainCtlToSo;
    PKGInfoBase();
    virtual ~PKGInfoBase(){};
    void    PkgHdle();		
        
protected:
/*
    功能    ：解析包头，放入到包头结构m_strPkgBatHeader       
	入口参数：sPkgBatHeader：包头报文
	出口参数：
*/
	virtual void ParsePkgBatHeader(char *sPkgBatHeader) = 0;
	
/*
    功能    ：往帐检查(重帐检查等)  
    入口参数：无
	出口参数：无
*/                            
	virtual void SendPrvCheckGrant() = 0; 

/*
    功能    ：往帐保存数据          
    入口参数：无
	出口参数：无
*/ 
    virtual void SaveSendData() = 0;
    
/*
    功能    ：来帐检查(重帐检查等)    
    入口参数：无
	出口参数：无
*/                         
   
	virtual void RecvPrvCheckGrant() = 0; 	
/*
    功能    ：来帐保存数据          
    入口参数：无 
	出口参数：无
*/                  
    virtual void SaveRecvData() = 0;	
    
/*
    功能    ：判断业务是来帐还是往帐
    入口参数：无
	出口参数：无
	返回    ：true:往帐 false:来帐
*/  
	BOOL IsSendTrans();
	
/*
    功能    ：判断业务是否要转发
    入口参数：无
	出口参数：无
	返回    ：true：转发 false：不转发 
*/         
    BOOL IsRouteTrans();
    /*
    功能    ：解析行内单笔报文     
    入口参数：无 
    出口参数：无 
    add by lihai 2005-9-1
*/
	virtual void ParseMBMsg();		
   /*
    功能    ：发送报文至行内     
    入口参数：无 
    出口参数：无 
    add by lihai 2005-9-8
*/
	void SendMsgToMb();
	
	void Save012();

private:        
	void ReadBigData();
	void SendPubCheckGrant();
	void RecvPubCheckGrant();
	void BuilderHeader(const char *sCmtNo, const char *sSender, const char *sReceiver, char *sMsgId,char *strMsgHeader);
	void ProcSendBusiness();
	void ProcRecvBusiness(char *sMsgHeader);
	void SendPkgHdle();
	void RecvPkgHdle();
	void Build912BusinessData(char *sAppCode, char *strBusinessData);
	void Build911BusinessData(char *sAppCode, char *strBusinessData);
	void BuildMb920BusinessData(char *sAppCode, char *strBusinessData);
	void SendCheckFailProc();
	void SendPackFailProc();
	void SendRspMb(char *sAppCode);
	void ParseMBMsgHeader();

protected:
	SybServer          *m_clsSybServer;                  // 数据库对象
	QueueData   	   *m_strQueueData;                  // 数据队列结构
	BepsInit		   *m_strBepsInit;		             // 系统配置参数
	SysCtlPar   	   *m_strSysCtlPar;                  // 系统控制参数
	
	BepsPub  		m_clsMbfePub;                    // 数据库执行类
	CheckGrant   		m_strCheckGrant;                 // 公共权限检查结构
	
	CMTMsgHeader        m_strMsgHeader;         		 //小额报文头
	MsgHeader		    m_strMBMsgHeader;				//MB报文头结构
	PKGInfoDetail			m_strDetail;					//MB通用信息明细结构
	MbfeToMbHeader		m_clsMbfeMsgHeader;			//MBFE发来的报文头
	PkgBatHeader		m_strPkgBatHeader;		    	 // 包头结构
	BigData             m_strBigData;                    // 大文本数据
	SybCommand          m_clsSybCommand;                 //
	
	int                 m_nModuleNo;
	char                m_sModuleNo[21];
	CString				m_clsMBMsgHeader;				 //行内报文头
	CString				m_clsMBMsgBody;						//行内报文体
};

inline BOOL PKGInfoBase::IsSendTrans()
{
	return strcmp(m_strQueueData->m_sQueueName, T_APIMBSQ) == 0;
}

//*************Declare PkgInfoReal********************
class PkgInfoReal: public PKGInfoBase
{
public:
	                                                
			// 功能描述：构造函数，初始化类成员变量                                  
    
			 PkgInfoReal();

                                        
			// 功能描述：析构函数，释放资源                                             
			virtual	~PkgInfoReal()
			{
			
			}


protected:
            	
			//组包
			void CreatPkg();     	
			//设置包头
			virtual	void MapPKG(CMTOperator * cmtOperator);		 
			//设置正文体                  
			virtual void MapBody(CMTOperator * cmtOperator,CString *ExtDatatmp,BOOL bPack);		  
			//解包
			void 	UnpackPkg();

			//组行内报文
			void BuildMBMsg();
			
			//将处理过的明细改为已打包
			void PkgUpdateDetail();	  

			//组行内报文体
			virtual void BuildMBMsgBody(char *sMsgBody);		  

			CMTPkgMsg      	m_clsCmtPkgMsg;    //pkg报文结构类

			int m_nPkgLength;               //包长度
			int m_nPkgSerno;				//生成的包号
			char m_sProcState[3];			//处理状态  
			char m_sDealDesc[61];			//处理描述

private:
			//组批量包头
			void CreatPkgHeader(CMTOperator &clsCmtOperator); 
			//组正文体
			void CreateDetail();	
			//更新包头
			void UpdatePkgHeader();
			//发送包
			void SendPkg(int &iDataIndex);
			
			//插入包头汇总表
			void  InsertPkg(int iDataIndex);
};
#endif