#include "eth-board.h"
#include "usart.h"
#include "proto-sl651.h"
#include <string.h>




// 尝试创建Socket
const char



void EthMqttTick (void)
{
	if (s_tx_timeout > 1)
		s_tx_timeout--;
	if (s_run_timer > 1)
		s_run_timer--;
	if (s_lost_timer > 1)
		s_lost_timer--;
}

//void EthMqttReboot(void)
//{
//	DelayMs(500);
//	HAL_GPIO_WritePin(GPIOB,GPIO_PIN_1,GPIO_PIN_SET);
//}

static enum
{
	DeviceReboot,
	DeviceConfig,
	DeviceGetPara,
	DeviceSetPara,
	DeviceReset,
	DeviceLink,
	DeviceIdle,
} DeviceState = DeviceReboot ;
static enum
{
	FistIn,
	Runing,
	End,
	JumpUp
} s_run = FistIn;



//		NetFunc.Init = EthMqttInit;
//		NetFunc.IsConnected = EthMqttIsConnect;
//		NetFunc.IsReady = EthMqttIsReady;
//		NetFunc.ReadData = EthMqttReadData;
//		NetFunc.WriteData = EthMqttWriteData;
//		NetFunc.IsIdle = EthMqttIsIdle;
//		NetFunc.ReSubTopic = EthMqttReSubTopic;
//		NetFunc.Task = EthMqttTask;

void EthMqttInit (void)
{
	// char str[128];
	// char addr_str[10];

	// GPIO_InitTypeDef   GPIO_InitStruct;
	// GPIO_InitStruct.Mode = GPIO_MODE_OUTPUT_PP;
	// GPIO_InitStruct.Pull = GPIO_PULLUP;
	// GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_VERY_HIGH;

	// GPIO_InitStruct.Pin = GPIO_PIN_1;
	// HAL_GPIO_Init (GPIOB, &GPIO_InitStruct);
	// HAL_GPIO_WritePin(GPIOB,GPIO_PIN_1,GPIO_PIN_SET);

	// GPIO_InitStruct.Mode = GPIO_MODE_INPUT;
	// GPIO_InitStruct.Pull = GPIO_PULLUP;
	// GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_VERY_HIGH;
	// // 状态
	// GPIO_InitStruct.Pin = GPIO_PIN_4;
	// HAL_GPIO_Init (GPIOC, &GPIO_InitStruct);
	// memset(addr_str,0,10);
	// hexbyte_to_hex_str((char *)SysInfo.Addr,addr_str,4);
	// UartInfoInit(uEth); // 初始化以太网接口
	// memset(sub_topic,0,64);
	// sprintf(sub_topic,"device/sluice/tx/22000073%s",addr_str);
	// memset(pub_topic,0,64);
	// sprintf(pub_topic,"device/sluice/rx/22000073%s",addr_str);
	// s_tx_timeout = 1;

}


// // 上线
// void EthMqttConnectd (void)
// {
// 	s_isconnect = 1;
// 	//DisWriteNetSte (1, QUEUE);
// 	s_lost_timer = 60000;
// 	dbg_printf("Eth Device Isconnected \r\n");
// }

// 掉线
void EthMqttDisConnectd (void)
{
	s_lost_timer = 0;
	DisWriteNetSte (2, QUEUE);
	DeviceState = DeviceReboot;
	dbg_printf ("Eth Device IsDisconnected \r\n");
}

int  EthMqttReadData (char * buf, int length)
{
	int k = 0;
	if (UartInfoRxIsReady (uEth) == 1)
	{
		k =  UartInfoReadData (uEth, (char *) buf, length);
		dbg_printf ("<<<<<<<<<<<<%d\r\n", k);
		s_lost_timer = 60000;
		DisWriteNetSte (1, QUEUE);
	}
	return k;
}

int EthMqttIsReady (void)
{
	if (DeviceState != DeviceIdle)
	{
		return 0;
	}
	else
	{
		return UartInfoRxIsReady (uEth);
	}
}


void EthMqttWriteData (char * data, int length)
{
	UartInfoWriteData (uEth, data, length);
}


int EthMqttIsIdle (void)
{
	if (EthMqttIsConnect() == 0)
	{
		return 0;
	}
	if (DeviceState == DeviceIdle)
		return 1;
	return 0;
}


int EthMqttIsConnect (void)
{
	if (HAL_GPIO_ReadPin (GPIOC, GPIO_PIN_4) == GPIO_PIN_SET)
		return 1;
	else
		return 0;
	//return s_isconnect;
}

void EthMqttTask (void)
{
	int rx_size;
	char str[128];
	//static pst_Work_Pragma pstWork_Pragma;
	switch (DeviceState)
	{
	case DeviceReboot:
	{
		if (s_run == FistIn)
		{
			dbg_printf ("EthDeviceReboot\r\n");
			HAL_GPIO_WritePin (GPIOB, GPIO_PIN_1, GPIO_PIN_RESET);
			s_run_timer = 500;
			s_run = Runing;
		}
		else if (s_run == Runing)
		{
			if (s_run_timer == 1)
			{
				s_run_timer = 0;
				s_run = End;
				HAL_GPIO_WritePin (GPIOB, GPIO_PIN_1, GPIO_PIN_SET);
				dbg_printf ("Reboot Finsh\r\n");
				s_run_timer = 5000;
			}
		}
		else if (s_run == End)
		{
			if (s_run_timer == 1)
			{
				//dbg_printf("Reboot Finsh\r\n");
				s_run = JumpUp;
				s_run_timer = 0;
			}
		}
		else
		{
			s_run = FistIn  ;
			DeviceState = DeviceConfig;
		}
		break;
	}
	// 这里要等待3s
	case DeviceConfig: // 进入配置模式
	{
		if (s_run == FistIn)
		{
			dbg_printf ("DeviceConfig\r\n");
			UartInfoClearData (uEth) ;
			UartInfoWriteData (uEth, "++++++++++", 10);
			s_run_timer = 50;
			s_run = Runing;
		}
		else if (s_run == Runing)
		{
			if (s_run_timer == 1)
			{
				s_run_timer = 0;
				UartInfoWriteData (uEth, "{\"Command\":\"config\"}", strlen ("{\"Command\":\"config\"}"));
				dbg_printf ("Command\r\n");
				s_run = End;
				s_run_timer = 3000;
			}
			// 获取发送的数据
		}
		else if (s_run == End)
		{
			if (s_run_timer == 1)
			{
				s_run = JumpUp;
				s_run_timer = 0;
			}
		}
		else
		{
			s_run = FistIn;
			DeviceState = DeviceGetPara;
		}
		break;
	}
	case DeviceGetPara:
	{
		if (UartInfoRxIsReady (uEth) == 1)
		{
			dbg_printf ("DeviceGetPara\r\n");
			rx_size =  UartInfoReadData (uEth, (char *) s_buffer, 1024);
			dbg_printf ("(%d)[%d]\r\n", rx_size, s_buffer[0]) ;
			DeviceState = DeviceSetPara;
		}
		break;
	}
	case DeviceSetPara:
	{
		if (s_run == FistIn)
		{
			memset (s_buffer, 0, 1024);
			//dbg_printf("subtopic:%s\r\n",(char *)pstWork_Pragma->stExternPragma.stMQTTClient.SubTopic);
			sprintf (s_buffer,
			         "{\"%s\":\"%s\",\"%s\":\"%s\",\"%s\":%d,\"%s\":\"%s\",\"%s\":\"%s\",\"%s\":\"%s\",\"%s\":\"%s\",\"%s\":\"%s\"}",
			         "Command", "config",
			         "RemoteHost", SysInfo.remoteAddr,
			         "RemotePort", SysInfo.remotePort,
			         "WorkMode", "MQTT",
			         "UserName", SysInfo.remoteuser,
			         "Password", SysInfo.remotepass,
			         "PubTopic", pub_topic,
			         "SubTopic", sub_topic
			        );
			//SetParametersToData(pstWork_Pragma,(char *)s_buffer,1024);
			dbg_printf ("%s\r\n", s_buffer);
			UartInfoWriteData (uEth, s_buffer, strlen (s_buffer));
			s_run_timer = 1000;
			s_run = Runing;
		}
		else if (s_run == Runing)
		{
			if (s_run_timer == 1)
			{
				s_run_timer = 0;
				UartInfoWriteData (uEth, "{\"Command\":\"exit\"}", strlen ("{\"Command\":\"exit\"}"));
				dbg_printf ("Command\r\n");
				s_run = End;
				s_run_timer = 50;
			}
			// 获取发送的数据
		}
		else if (s_run == End)
		{
			if (s_run_timer == 1)
			{
				s_run = JumpUp;
				s_run_timer = 0;
			}
		}
		else
		{
			s_run = FistIn;
			DeviceState = DeviceReset;
		}
		break;
	}
	case DeviceReset:
	{
		if (s_run == FistIn)
		{

			HAL_GPIO_WritePin (GPIOB, GPIO_PIN_1, GPIO_PIN_RESET);
			s_run_timer = 500;
			s_run = Runing;
		}
		else if (s_run == Runing)
		{
			if (s_run_timer == 1)
			{
				s_run_timer = 0;
				s_run = End;
				HAL_GPIO_WritePin (GPIOB, GPIO_PIN_1, GPIO_PIN_SET);
				dbg_printf ("Reboot Finsh\r\n");
				s_run_timer = 3000;
			}
		}
		else if (s_run == End)
		{
			if (s_run_timer == 1)
			{
				dbg_printf ("Reboot Finsh\r\n");
				UartInfoClearData (uEth) ;
				s_run = JumpUp;
				s_run_timer = 0;
			}
		}
		else
		{
			s_run = FistIn  ;
			DeviceState = DeviceIdle;
		}
		break;
	}
	case DeviceLink:// 检查上线
	{
		s_isconnect = 1;
		DeviceState = DeviceIdle;
		break;
	}
	case DeviceIdle:
	{
		if (s_lost_timer == 0)
		{
			if (EthMqttIsConnect())
			{
				EthMqttConnectd();
				s_lost_timer = 60000;
			}
			// 第一次上线
		}
		break;
	}
	}
	if (s_lost_timer == 1)
	{
		EthMqttDisConnectd();
		s_run = FistIn  ;
	}
}
int EthMqttReSubTopic (char * topic)
{
	char addr_str[10];
	memset (addr_str, 0, 10);
	hexbyte_to_hex_str ( (char *) SysInfo.Addr, addr_str, 4);
	memset (sub_topic, 0, 64);
	sprintf (sub_topic, "device/%s/tx/22000073%s", topic, addr_str);
	memset (pub_topic, 0, 64);
	sprintf (pub_topic, "device/%s/rx/22000073%s", topic, addr_str);

	dbg_printf ("EthMqttReSubTopic\r\n");
//	memset(sub_topic,0,64);
//	sprintf(sub_topic,"device/%s/tx/22000000%08x",topic,SysInfo.Addr);
//	memset(pub_topic,0,64);
//	sprintf(pub_topic,"device/%s/rx/22000000%08x",topic,SysInfo.Addr);
	EthMqttDisConnectd();
}