/**
******************************************************************************
* @file    			tcp_demo.c                                               
* @version 			V1.2										  		
* @date    			2017-11-01								 
* @brief 			  TCP 演示函数     					        
*
* @company  		深圳炜世科技有限公司
* @information  WIZnet W5500官方代理商，全程技术支持，价格绝对优势！
* @website  		www.wisioe.com																							 	 				
* @forum        www.w5500.cn																								 		
* @qqGroup      383035001																										 
******************************************************************************
*/

#include <stdio.h>
#include <string.h>
#include "tcp_demo.h"
#include "W5500_conf.h"
#include "w5500.h"
#include "socket.h"

#include "base_core_user.h"
#include "function_interface.h"
#include "platform_interface.h"


uint8 buff[2048];				                              	        /*定义一个2KB的缓存*/


unsigned char tcp_send_data_to_pc(unsigned char *buff,unsigned short len)
{
		return send(SOCK_TCPS,buff,len);
}


/**
*@brief		TCP Server回环演示函数。
*@param		无
*@return	无
*/
unsigned char test_stat;
void do_tcp_server(void)
{	
	uint16 len=0; 
	unsigned char sr_stat;
	
	if( !function.TCPIP__SW) return ;
	platform.disable_interrupt();

	sr_stat =getSn_SR(SOCK_TCPS);
	
	/*20200327 解决拔插网线后不能再连接的问题: 
	a,网线拔出后重新初始化socket;
	b,和sdk连接时有时会进入到SOCK_SYNRECV状态导致无法连接，why?  重新初始化socket；*/
	if( ( ((0x01&getPHYStatus() )==0) &&(sr_stat !=SOCK_LISTEN) ) || (sr_stat ==SOCK_SYNRECV) ){		
		socket(SOCK_TCPS ,Sn_MR_TCP,local_port,Sn_MR_ND);	        /*打开socket*/
		listen(SOCK_TCPS);												                /*socket建立监听*/
	}
	
	switch(sr_stat )											            	/*获取socket的状态*/
	{
		case SOCK_CLOSED:													                  /*socket处于关闭状态*/
			socket(SOCK_TCPS ,Sn_MR_TCP,local_port,Sn_MR_ND);	        /*打开socket*/
			break;     
		
		case SOCK_INIT:														                  /*socket已初始化状态*/
			listen(SOCK_TCPS);												                /*socket建立监听*/
			break;
		
		case SOCK_ESTABLISHED:												              /*socket处于连接建立状态*/

			if(getSn_IR(SOCK_TCPS) & Sn_IR_CON)
			{
				setSn_IR(SOCK_TCPS, Sn_IR_CON);								          /*清除接收中断标志位*/
			}
			len=getSn_RX_RSR(SOCK_TCPS);									            /*定义len为已接收数据的长度*/
//			if(len>0)
//			{
//				recv(SOCK_TCPS,buff,len);								              	/*接收来自Client的数据*/
//				buff[len]=0x00; 											                  /*添加字符串结束符*/
//				//printf("%s\r\n",buff);
//				send(SOCK_TCPS,buff,len);									              /*向Client发送数据*/
//			}
			
			if(len>0)
			{
				recv(SOCK_TCPS,buff,len);								              	/*接收来自Client的数据*/
				if( (buff[0] ==0xf5)&&(buff[1] ==0xaa)&&(buff[2] ==0xaa) ){
					void set_pc_communication_type(unsigned char type);
					set_pc_communication_type(1);
					base_core.sdk_data_fifo_in(buff+3);
				}				
			}		
			break;
		
		case SOCK_SYNRECV:
			break;
			
		case SOCK_CLOSE_WAIT:												                /*socket处于等待关闭状态*/
			close(SOCK_TCPS);
			break;
	}
	
	platform.enable_interrupt();	
}

/**
*@brief		TCP Client回环演示函数。
*@param		无
*@return	无
*/
void do_tcp_client(void)
{	
	uint16 len=0;	

	switch(getSn_SR(SOCK_TCPC))								  				         /*获取socket的状态*/
	{
		case SOCK_CLOSED:											        		         /*socket处于关闭状态*/
		  //printf("初始化\r\n");
			socket(SOCK_TCPC,Sn_MR_TCP,local_port,Sn_MR_ND);
			break;

		case SOCK_INIT:													        	         /*socket处于初始化状态*/
		  //printf("连接\r\n");
			connect(SOCK_TCPC,remote_ip,remote_port);                /*socket连接服务器*/ 
			break;

	case SOCK_ESTABLISHED: 												             /*socket处于连接建立状态*/
		  if(getSn_IR(SOCK_TCPC) & Sn_IR_CON)
		  {
		  	setSn_IR(SOCK_TCPC, Sn_IR_CON); 							         /*清除接收中断标志位*/
		  }
      
		  len=getSn_RX_RSR(SOCK_TCPC); 								  	         /*定义len为已接收数据的长度*/
		  if(len>0)
		  {
		  	recv(SOCK_TCPC,buff,len); 							   		         /*接收来自Server的数据*/
		  	buff[len]=0x00;  											                 /*添加字符串结束符*/
		  	//printf("%s\r\n",buff);
		  	send(SOCK_TCPC,buff,len);								     	         /*向Server发送数据*/
		  }		  
		  break;

	case SOCK_CLOSE_WAIT: 											    	         /*socket处于等待关闭状态*/
		  //printf("关闭\r\n");
		  close(SOCK_TCPC);
		  break;
	}
}