#include<sys/socket.h>
#include<sys/types.h>
#include<netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <arpa/inet.h>
#include <time.h>
#include <signal.h>
#include <pthread.h>
#include <sys/time.h>
#include <stdbool.h>
#include <fcntl.h>
#include "/usr/include/mysql/mysql.h"
#include <sys/stat.h>
#define _DELETE_FILE
#include <dirent.h>
#include <limits.h>
#include <sys/io.h>
#include <signal.h>
int RealAlarmEventNum[16];
typedef struct{
	int Year;
	int Month;
	int Day;
	int Hour;
	int Min;
	int Sec;
}MyTime,*lpMyTime;
typedef struct{
   int m_id;
   char serverIP[32];
   char serverport[10];
   char port[10];
   char ip[32];
   char user[64];
   char pass[64];
   int reboot;
}sockinfo,*lpsockinfo;
typedef struct{
	   char channelId[5];
	   char eventId[10];
	   char startTime[30];
	   char soffset[20];
	   char endTime[30];
	   char eoffset[20];
	   char clipUrl[100];
	   char ruleId[10];
	   char ruleName[50];
	   char soiId[10];
	   char soiName[50];
	   char activity[50];
	   char objectType[20];
	   char aborted[15];
	   char acknowledged[15];
	   char debugMessage[512];
}AlarmInfo,*lpAlarmInfo;
typedef struct EVENT_LOG  
{
	bool mp4downed;
	bool Ack;
	bool InSearchRange;
	char Date[15];
	char Time[15];
	char Rule[20];
	char Camera[30];
	char Region[30];
	char Duration[20];
	char Object[20];
	char Activity[20];
	unsigned char ActivityNum[5];
	char clipUrl[200];
	char DebugMessageS[200];
	char DebugMessageE[200];
}EVENT_LOG;

int memorycmp(unsigned char* src ,int slen, char* token, int len);
void AurhorizationResponseBytes(char* byte_array_out,int * byte_array_length_out,char *Myuri, char *nonce,char *cnonce,char *response);
int AnalyXMLUrnEVENT(char* buff,int length,AlarmInfo* RealAlarmEvent);

/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
///// PHP API function

int CharToByte(char* chars, char* bytes, unsigned int count,char* ptr1,char* ptr2,char* ptr3,char* ptr4,unsigned char* number);	
int stringcmp(char* src ,char* token, int len);
int DivideTimeToYMDHMS(char* DateTimeStr,int* year,int* month,int* day, int* hour,int* min,int* sec);
void RequestMetaFiles(char* AnaylyIP,char* httpUri,char* Tm1,char* Tm2);
void RequestZipSerFiles(char* AnaylyIP,char* httpUri);
void UrnStringToBytes(char* byte_array_out,int * byte_array_length_out,char* StartTim,char* EndTime);

void zclock_sleep (int msecs);

typedef struct{
   char name[1024];
}filenames,*lpfilenames;
typedef struct{
	char ID[5];
	char IP[32];
}SESSION;

int doesFileExist(const char *filename);
void delete_file(const char *path);
void delete_folder(const char *path);
void AnalySerFile(char* p_save_buf,int res, int SearchStartTm, int SearchEndTm);
int GetFileNameInFolder(char* dirname,lpfilenames lpfilename);
int net_test(char* serverIP,char* port);
void GPIOinit(void);
int GPIOoutput(int no);
int RestartCommand(char* AnalyserIP,char* user,char* pass);
void MakeAuthorizedPacketRestart(char* buff,int length, char* Method,char* uri);
void MakeAuthorizedPacketReal(char* buff,int length, char* Method,char* uri);
void MakeAuthorizedPacketSimp(char* buff,int length, char* Method,char* uri);
void MakeAuthorizedPacketSimp111(char* buff,int length, char* Method,char* uri,char* Tm1,char* Tm2);
void AurhorizationResponseBytes(char* byte_array_out,int * byte_array_length_out,char *Myuri, char *nonce,char *cnonce,char *response);
void AurhorizationResponseBytesReal(char* byte_array_out,int * byte_array_length_out,char *Myuri, char *nonce,char *cnonce,char *response);
void AurhorizationResponseBytesReatart(char* byte_array_out,int * byte_array_length_out,char *Myuri, char *nonce,char *cnonce,char *response);
int Read_MysqlData();
int UpdateMysqData(int key);
int InsertMysqlData(char *AnalyserName,char* AnalyserIP,char* AnalyserPort,char* ServerIP,char* ServerPort,char* username,char* pass,char* resol,char* commType);



int GetConnectState(char* AnalyserIP);																									//1.查看分析器连接状态		参数：分析器IP。返回： 连接状态
int RestartAnalyser(char* AnalyserIP,char* user,char* pass,int RestartKind,int no);														//2.重启分析器				参数：分析器IP，协议重启或电路重启。返回： 重启成功或失败的状态值。
int RealEventStart(char* AnalyserIP,char* user,char* pass);
int RealEventStop(char* AnalyserIP);

char* GetRealEvent(char* AnalyserIP);																									//3.查看实时监控			参数：分析器IP。返回：信道号及其对应的视频流地址
char* GetPHPSearchMetaInfo(char* AnalyserIP,char* user,char* pass,int Channel,int s_year,int s_month,int s_day,int s_hour,int s_minute,int s_sec,int e_year,int e_month,int e_day,int e_hour,int e_minute,int e_sec);	//potection function
char* GetSearchMetaInfo(char* AnalyserIP,char* user,char* pass,int Channel,lpMyTime StartTm,lpMyTime EndTm);	//4.查询记录				参数：分析器IP，开始时间，结束时间，信道号。返回：查询结果。（包括信道号，报警时间，播放地址，等。）
char* GetAnalyserNet(void);																												//5.获取当前转发器的ip		参数：无。返回：当前的ip地址子网掩码和网关
int SetAnalyserNet(char* NetInfo);	
char* GetMp4Info(char* AnalyserIP,char* user,char* pass,int Channel,char* path)	;	
char* GetAnalyserAll();																													//9.查询设备   参数：无		返回：分析器的名称和ip
int DeleteAnalyser(char* AnalyserIP);																									//8.删除设备   参数：设备ip	返回：成功或失败的提示。
int InsertAnalyser(char *AnalyserName,char* AnalyserIP,char* AnalyserPort,char* ServerIP,char* ServerPort,char* user,char* pass,char* resol,char* commType);//																	7.添加设备   参数：设备属性。返回：成功返回对应的视频流地址，失败返回一个提示。
char* GetDeviceInfo(char* AnalyserIP);
int Check_MysqlData(char *AnalyserName,char* AnalyserIP,char* AnalyserPort,char* ServerIP,char* ServerPort,char* user,char* pass,char* resol,char* commType);
//
int GPIO_OPEN(int PortNum);
void GPIO_CLOSE(int PortNum);
int GPIO_READ(int PortNum);
void GPIO_WRITE(int PortNum,unsigned char DATA);
//MD5 Function declaration******************************************
#define MD 5

#ifndef PROTOTYPES
#define PROTOTYPES 0
#endif

typedef unsigned char *POINTER;   /* POINTER defines a generic pointer type */
typedef unsigned short int UINT2; /* UINT2 defines a two byte word */
typedef unsigned long int UINT4;  /* UINT4 defines a four byte word */

/*
  PROTO_LIST is defined depending on how PROTOTYPES is defined above.
  If using PROTOTYPES, then PROTO_LIST returns the list, otherwise it
  returns an empty list.
 */
//#if PROTOTYPES
//#define PROTO_LIST(list) list
//#else
//#define PROTO_LIST(list) ()
//#endif

 /* Length of test block, number of test blocks. */
#define TEST_BLOCK_LEN 1000
#define TEST_BLOCK_COUNT 1000

 /* Constants for MD5Transform routine. */
#define S11 7     /* ¸÷ÂÖ×óÒƵÄλÊý */
#define S12 12
#define S13 17
#define S14 22
#define S21 5
#define S22 9
#define S23 14
#define S24 20
#define S31 4
#define S32 11
#define S33 16
#define S34 23
#define S41 6
#define S42 10
#define S43 15
#define S44 21

typedef struct 
{
  UINT4 state[4];               /* state (ABCD) */
  UINT4 count[2];               /* number of bits, modulo 2^64 (lsb first) */
  unsigned char buffer[64];     /* input buffer */
}MD5_CTX;

static unsigned char PADDING[64] = 
{
  0x80, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0
};

/* 
   F, G, H and I are basic MD5 functions.
*/
#define F(x, y, z) (((x) & (y)) | ((~x) & (z)))
#define G(x, y, z) (((x) & (z)) | ((y) & (~z)))
#define H(x, y, z) ((x) ^ (y) ^ (z))
#define I(x, y, z) ((y) ^ ((x) | (~z)))

/* 
   ROTATE_LEFT rotates x left n bits.
*/
#define ROTATE_LEFT(x, n) (((x) << (n)) | ((x) >> (32-(n))))

/*
   FF, GG, HH, and II transformations for rounds 1, 2, 3, and 4.
   Rotation is separate from addition to prevent recomputation.
*/
#define FF(a, b, c, d, x, s, ac) { \
 (a) += F ((b), (c), (d)) + (x) + (UINT4)(ac); \
 (a) = ROTATE_LEFT ((a), (s)); \
 (a) += (b); \
  }
#define GG(a, b, c, d, x, s, ac) { \
 (a) += G ((b), (c), (d)) + (x) + (UINT4)(ac); \
 (a) = ROTATE_LEFT ((a), (s)); \
 (a) += (b); \
  }
#define HH(a, b, c, d, x, s, ac) { \
 (a) += H ((b), (c), (d)) + (x) + (UINT4)(ac); \
 (a) = ROTATE_LEFT ((a), (s)); \
 (a) += (b); \
  }
#define II(a, b, c, d, x, s, ac) { \
 (a) += I ((b), (c), (d)) + (x) + (UINT4)(ac); \
 (a) = ROTATE_LEFT ((a), (s)); \
 (a) += (b); \
  }

char* MDString (char *string);


void MD5Init (MD5_CTX *context);
void MD5Update(MD5_CTX *context, unsigned char *input,unsigned int inputLen);
void MD5Final (unsigned char digest[16], MD5_CTX *context);
void MD5Transform  (UINT4 [4], unsigned char [64]) ;
void Encode(unsigned char *, UINT4 *, unsigned int);
void Decode (UINT4 *, unsigned char *, unsigned int);
void MD5_memcpy(POINTER, POINTER, unsigned int);
void MD5_memset(POINTER, int, unsigned int);