#ifndef _ZA_ACSPROC
#define _ZA_ACSPROC

#pragma once
//#include "daq/daq_cmddef.h"
#include <string>
#include "thirdparty/json.h"
#include <vector>
#include <map>
#include "daq/daq_protocol.h"

#include "ZJ_ACSputRdb.h"
using namespace std;


class CZJACS : public CProtocol
{
public:
	CZJACS();
	~CZJACS();
public:
	CRawDataWrapper	* 	iotPRawCtrl;
	//对应规约处理对应的生资料（包括所有需要提交给SCADA的资料）存放
	//对应于各种其它功能的接口类；
	//如产生一个YX变位,产生一个事项，递交一个变化资料等等
	CRawBuff		*	iotpRxBuf, *iotpTxBuf;
	//对应该规约对应的收发缓冲区

	CRawCmdMem		*	iotpCmdMem;
	//对应处理由其它模块发送过来的命令信息

	CRawRtu 		*	iotpRtu;
	//对应该规约对应的终端信息

	CRawLink		*	iotpLink;
	//对应该规约对应的链路信息

	void ReadIni();

	virtual sint32 TxProc();
	virtual sint32 RxProc();

	virtual void Init(S_PROTOCOLCFG* pcfg);
	putRdb strCallback;
	void restfulServer();

	int RemoteOpened();
	int PostSubscribe(int type);
	int DeleteSubscribe(string id);

	bool rxflag;
	bool txflag;
	bool seflag;
	bool subscribeflag;
	bool subscribeflag2;

	int subid_Verification;
	int subid_Alarm;

private:
	string server_urls;
	string client_ip;
	int client_port;
	sint32 rxthread;
	sint32 txthread;
	sint32 sethread;
};

#endif