dataprocjob.h

RTMS设备通讯协议

// DataProcJob.h: interface for the CDataProcJob class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_DATAPROCJOB_H__8D8B91B4_1595_481E_AAB5_909EDF69C7A7__INCLUDED_)
#define AFX_DATAPROCJOB_H__8D8B91B4_1595_481E_AAB5_909EDF69C7A7__INCLUDED_

#include "threadjob.h"

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000


class CDataProcJob : public CThreadJob  
{
public:
	CString strUser;
	CString strPass;
	CString strDBIP;
	BOOL bDataError;

	BOOL OpenConnection(_ConnectionPtr& pConn,const char* strConn);

public:
 	_ConnectionPtr m_pDataConn; //数据数据库连接对象
	BOOL AppendDB(CString strSQL);
	BOOL ProcSpeedModel();
	BOOL ProcOccupancey();
	BOOL ProcVolumeModel();
	BOOL ProcVolLongModel();
	BYTE ConBuf[128];
	BOOL ProcData(const unsigned char *pBuf,DWORD retLen);
	CDataProcJob():CThreadJob()
	{
	}
public:
	virtual UINT DoWork();

public:
	CString GetAppPath();
	BOOL GetDBPara(CString &strUser,CString &strPass,CString &strDB);
};

#endif // !defined(AFX_DATAPROCJOB_H__8D8B91B4_1595_481E_AAB5_909EDF69C7A7__INCLUDED_)