autobuild-tools/code/sys_nicmonitor/include/db_com/sheetdataclient.h

/*********************************************/
/*********Name :hisclient.h*******************/
/*********************************************/
#ifndef _HISCLIENT_H
#define _HISCLIENT_H

#ifdef _WINDOWS64
#ifdef HIS_CLIENT_EXPORTS
#define HIS_CLIENT_API __declspec(dllexport)
#else
#define HIS_CLIENT_API __declspec(dllimport)
#endif
#else
#define HIS_CLIENT_API
#endif

#include <stdlib.h>
#include <stdio.h>
#include <string>
#include <iostream>
#include <vector>

#ifdef _WINDOWS64
#include <winsock2.h>
#include <windows.h>
#include <time.h>
#else
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <dcidefine.h>
#include <unistd.h>
#endif

#include "servicemanage.h"

#define ONE_PACKAGE_SIZE 100000

#ifdef _WIN64
extern unsigned char g_endian;
extern unsigned char net_endian;
#else
extern unsigned char g_endian;
extern unsigned char net_endian;
#endif

typedef struct HisInfo
{
	int code_id;			    //接口内部使用，用户调用时不需要指定。提供服务的类型为select，update，insert，delete等各种数据操作类型。
	int appsid;		  	  //应用的id号
	char resververd[32];	//保留空间，当结构发生改变时，可以从中抽出一部分它用，达到保持结构体大小不变，以保证免以前的程序可以兼容
	//	int  sid; //Sid号
	//	int  sourcetype;  //局域网内部服务还是外部服务
	//	int  timemode ;   //是否需要时间配对。
} HisInfo_struct;        //输入

#define  MAX_COL_DATA_LEN		300

class HIS_CLIENT_API SheetDataClientInterface
{
public:
	void GetSheetDataClient (CurvePara &param, vector<ColAttr_t> &attr,
	                         vector<ColDataItem> &data, vector<string> &colname, const char* where_str,
	                         const char* order_by, ErrorInfo &error);

	SheetDataClientInterface();
	virtual ~SheetDataClientInterface();

	bool SetDomainInfo (DomainInfo *domainInfo);
	bool CleanDomainInfo (void);

	//danath 南瑞要求异步图表提交接口 20120223
	int SetSheetDataAsync (char *model_name, vector<SheetRecData> &rec,
	                       ErrorInfo &error);
	//20141023 end

	int GetCurveData (CurvePara &param, time_t timeout, CurveData ** datap,
	                  int &items, ErrorInfo &error);
	int SetCurveData (CurvePara &param, CurveData *curvedatap, ub2 items,
	                  ErrorInfo &error);	
    int GetCurveData (CurvePara &param, time_t timeout,CurveData ** datap, 
                    int &items,ErrorInfo &error,bool is_cache, bool is_retry);

	int SetCurveDataAsync (CurvePara &param, char * user_name,
	    char * host_name, char * proc_name, CurveData *curvedatap, ub2 items, ErrorInfo &error,bool is_cache, bool is_retry);


private:
	int RestSocket (int no = 1);
	Handle requesthandle;
	Handle requesthandle_async;
	ServiceInfo servicep;
	DomainInfo *domain_info;
};
#endif