#include "CH392_PARAM.H"
#include "delay.h"
#include "string.h"
/* 常用变量定义 */
struct _SOCK_INF  SockInf[SOCKET_COUNT];                            // 保存Socket信息 
UINT8  MyBuffer[SOCKET_COUNT][1024] = {{0}};                        // 数据缓冲区 
struct _CH392_SYS  CH392Inf;                                        // 保存CH392信息  网卡

// CH392相关定义  本地网卡设置
const UINT8 CH392IPAddr[4] = {192, 168, 61, 10};                    // CH392IP地址   
const UINT8 CH392GWIPAddr[4] = {192, 168, 61, 100};                   // CH392网关 
const UINT8 CH392IPMask[4] = {255, 255, 255, 0};                   // CH392子网掩码 
#if 0
// socket 相关定义
//const UINT8  Socket0DesIP[4] = {255,255,255,255};                 // Socket 0目的IP地址 //SERVER广播
const UINT8  Socket0DesIP[4] = {192, 168, 61, 100};                 // Socket 0目的IP地址 
const UINT16 Socket0SourPort = 5000;                                // Socket 0源端口 
const UINT16 Socket0DesPort   = 10002;                              // Socket 0目的端口 
const UINT8  Socket0ProtoType   = PROTO_TYPE_UDP;                   // Socket0 模式 
  ;  
#endif

#if 1


SOCK_PARAM sock_params[] =
{

    {  
        .dstIP = {230, 1, 1, 1},            //组播
        //.dstIP = {255, 255, 255, 255},      //广播
        //.dstIP = {192, 168, 61, 100},       //单播
        .SrcPort = 5003,
        .DstPort = 65003,
        .ProtoType = PROTO_TYPE_UDP,
        .TCP_SERVER_CLIENT = NONE
    },
    {
        .dstIP = {192,168,61,100},
        .SrcPort = 5004,
        .DstPort = 37393,
        .ProtoType = PROTO_TYPE_UDP,
        .TCP_SERVER_CLIENT = NONE
    },
    {  
        //.dstIP = {255,255,255,255},       //广播
        .dstIP = {192,168,61,100},       //单播
        .SrcPort = 5001,
        .DstPort = 61001,
        .ProtoType = PROTO_TYPE_TCP,
        //.TCP_SERVER_CLIENT = TCP_CLIENT
        .TCP_SERVER_CLIENT = TCP_SERVER 
    },
    {  
        //.dstIP = {255,255,255,255},       //广播
        .dstIP = {192,168,61,100},       //单播
        .SrcPort = 5002,
        .DstPort = 61002,
        .ProtoType = PROTO_TYPE_TCP, 
        .TCP_SERVER_CLIENT = TCP_CLIENT 
    },  
};
/*
// socket 相关定义
const UINT8  Socket0DesIP[4] = {230, 1, 1, 1};                 		// Socket 0目的IP地址
const UINT16 Socket0SourPort = 5000;                                // Socket 0源端口 
const UINT16 Socket0DesPort   = 37393;                              // Socket 0目的端口  
const UINT8  Socket0ProtoType   = PROTO_TYPE_UDP;                   // Socket0 模式 
*/
#endif
/**********************************************************************************
* Function Name  : InitCH392InfParam
* Description    : 初始化CH392Inf参数
* Input          : None
* Output         : None
* Return         : None
**********************************************************************************/
void InitCH392InfParam(void)
{
	memset(&CH392Inf,0,sizeof(CH392Inf));                            // 将CH392Inf全部清零
	memcpy(CH392Inf.IPAddr,CH392IPAddr,sizeof(CH392IPAddr));         // 将IP地址写入CH392Inf中 
	memcpy(CH392Inf.GWIPAddr,CH392GWIPAddr,sizeof(CH392GWIPAddr));   // 将网关IP地址写入CH392Inf中 
	memcpy(CH392Inf.MASKAddr,CH392IPMask,sizeof(CH392IPMask));       // 将子网掩码写入CH392Inf中 
}

/**********************************************************************************
* Function Name  : CH392Init
* Description    : 配置CH392的IP,GWIP,MAC等参数，并初始化
* Input          : None
* Output         : None
* Return         : 函数执行结果
**********************************************************************************/
UINT8  CH392Init(void)
{
    UINT8 i;

    i = CH392CMDCheckExist(0x65);
    if(i != 0x9A)
        return CH392_ERR_UNKNOW;                            /* 测试命令，如果无法通过返回0XFA */
    /* 返回0XFA一般为硬件错误或者读写时序不对 */
#if (CH392_OP_INTERFACE_MODE == 5)
#ifdef UART_WORK_BAUDRATE
    CH392CMDSetUartBaudRate(UART_WORK_BAUDRATE);                     /* 设置波特率 */
    delay_ms(10);
    Set_MCU_BaudRate();
    i = xReadCH392Data();                                            /* 如果设置成功，CH392返回CMD_ERR_SUCCESS */
    if(i == CMD_ERR_SUCCESS)printf("Set Success\r\n");
#endif
#endif
    
    DEBUG_SHOW_VALUE(i)
    CH392CMDSetIPAddr(CH392Inf.IPAddr);                              /* 设置CH392的IP地址 */
    CH392CMDSetGWIPAddr(CH392Inf.GWIPAddr);                          /* 设置网关地址 */
    CH392CMDSetMASKAddr(CH392Inf.MASKAddr);                          /* 设置子网掩码，默认为255.255.255.0*/
    i = CH392CMDInitCH392();                                         /* 初始化CH392芯片 */
    

    DEBUG_SHOW_VALUE(i)
    return i;
}

/**********************************************************************************
* Function Name  : mStopIfError
* Description    : 调试使用，显示错误代码，并停机
* Input          : iError
* Output         : None
* Return         : None
**********************************************************************************/
void mStopIfError(UINT8 iError)
{
	if (iError == CMD_ERR_SUCCESS) return;                           // 操作成功 
	printf("Error: %02X\r\n", (UINT16)iError);                        //显示错误 
	while ( 1 ) 
	{
		delay_ms(200);
		delay_ms(200);
	}
}


 
void InitSockets (void)
{
    uint8_t r = 0;
    for(int i=0;i<SOCKET_COUNT;i++)
    {
        memset(&SockInf[i],0,sizeof(SockInf));                           
        // 将SockInf[0]全部清零
        memcpy(SockInf[i].IPAddr,sock_params[i].dstIP,sizeof(sock_params[i].dstIP));        //将目的IP地址写入 
        SockInf[i].DesPort = sock_params[i].DstPort;                                // 目的端口 
        SockInf[i].SourPort = sock_params[i].SrcPort;                              // 源端口 
        SockInf[i].ProtoType = sock_params[i].ProtoType;                              // TCP模式 
        
        CH392SetSocketDesIP(i,SockInf[i].IPAddr);                           /* 设置socket 0目标IP地址 */         
        CH392SetSocketProtType(i,SockInf[i].ProtoType);                     /* 设置socket 0协议类型 */
        CH392SetSocketDesPort(i,SockInf[i].DesPort);                        /* 设置socket 0目的端口 */
        CH392SetSocketSourPort(i,SockInf[i].SourPort);                      /* 设置socket 0源端口 */
 
        r = CH392OpenSocket(i);                                          /* 打开socket 0 */
        mStopIfError(r);                                                 /* 检查是否成功 */
      
        if(SockInf[i].ProtoType==PROTO_TYPE_TCP)
        {                   //显示错误 
            if(sock_params[i].TCP_SERVER_CLIENT == TCP_CLIENT)
            {
                printf("TCP Client \r\n");       
                r=CH392TCPConnect(i);
                mStopIfError(r);	
                DEBUG_SHOW_VALUE(r)
            }
            else if(sock_params[i].TCP_SERVER_CLIENT == TCP_SERVER)
            {
                printf("TCP Server Start\r\n");    
                r=CH392TCPListen(i);
                mStopIfError(r);	
                DEBUG_SHOW_VALUE(r)
                
            }
               
        }
    }
    
}

/**********************************************************************************
* Function Name  : CH392GlobalInterrupt
* Description    : CH392全局中断函数
* Input          : None
* Output         : None
* Return         : None
**********************************************************************************/
void CH392GlobalInterrupt(void)
{
	UINT16  init_status;
	UINT8  buf[10]; 

	init_status = CH392CMDGetGlobIntStatus_ALL();
	if(init_status & GINT_STAT_UNREACH)                              /* 不可达中断，读取不可达信息 */
	{
		CH392CMDGetUnreachIPPT(buf);                                
	}
	if(init_status & GINT_STAT_IP_CONFLI)                            /* 产生IP冲突中断，建议重新修改CH392的 IP，并初始化CH392*/
	{
	}
	if(init_status & GINT_STAT_PHY_CHANGE)                           /* 产生PHY改变中断*/
	{
		printf("Init status : GINT_STAT_PHY_CHANGE\r\n");
    }
	if(init_status & GINT_STAT_SOCK0)
	{
		CH392SocketInterrupt(0);                                     /* 处理socket 0中断*/
	}
	if(init_status & GINT_STAT_SOCK1)                               
	{
		CH392SocketInterrupt(1);                                     /* 处理socket 1中断*/
	}
	if(init_status & GINT_STAT_SOCK2)                                
	{
		CH392SocketInterrupt(2);                                     /* 处理socket 2中断*/
	}
	if(init_status & GINT_STAT_SOCK3)                                
	{
		CH392SocketInterrupt(3);                                     /* 处理socket 3中断*/
	}
}

void CH392SocketInterrupt(UINT8 sockindex)
{
   UINT8  sock_int_socket;
   UINT16 len;
   printf("socket id = %d\r\n",sockindex);
   sock_int_socket = CH392GetSocketInt(sockindex);                   /* 获取socket 的中断状态 */
   if(sock_int_socket & SINT_STAT_SENBUF_FREE)                       /* 发送缓冲区空闲，可以继续写入要发送的数据 */
   {
       printf("SINT_STAT_SENBUF_FREE_OK\r\n");
   }
   if(sock_int_socket & SINT_STAT_SEND_OK)                           /* 发送完成中断 */
   {
       printf("SINT_STAT_SEND_OK\r\n");
   }
   if(sock_int_socket & SINT_STAT_RECV)                              /* 接收中断 */
   { 
       len = CH392GetRecvLength(sockindex);                          /* 获取当前缓冲区内数据长度 */
       printf("receive len = %d\r\n",len);
       CH392GetRecvData(sockindex,len,MyBuffer[sockindex]);
       //printf("receive MyBuffer = %s\r\n",MyBuffer[sockindex]);
	   //for(int i=0;i<len;i++){MyBuffer[i]+=5;}
       CH392SendData(sockindex,MyBuffer[sockindex],len);
   }
   if(sock_int_socket & SINT_STAT_CONNECT)                          /* 连接中断，仅在TCP模式下有效*/
   {
       printf("SINT_STAT_CONNECT\r\n");
   }
   if(sock_int_socket & SINT_STAT_DISCONNECT)                        /* 断开中断，仅在TCP模式下有效 */
   {
      printf("SINT_STAT_DISCONNECT \r\n");
   }
   if(sock_int_socket & SINT_STAT_TIM_OUT)                           /* 超时中断，仅在TCP模式下有效 */
   {                                                              
       printf("SINT_STAT_TIM_OUT\r\n");
   }
} 


void InitEXIT(void)
{  
    GPIO_Init(GPIO_SPI0_INT, PORT_SPI0_INT, 0, 1, 0, 0);	
    GPIO_Init(GPIO_SPI1_INT, PORT_SPI1_INT, 0,1,  0, 0);		
    /*
#if(USE_SPI0==1) 
    if(_pSPIx==SPI0)
    { 
        EXTI_Open(GPIO_SPI0_INT, PORT_SPI0_INT);
        //PC12
    } 
#endif
    
#if(USE_SPI1==1)  
    if(_pSPIx==SPI1)
    {
        EXTI_Open(GPIO_SPI1_INT, PORT_SPI1_INT);
        //PC13
    }
#endif
	NVIC_EnableIRQ(GPIOC_IRQn);   
    */
}


void GPIOC_Handler(void)
{ 
    int NET_INT = 0;
    
#if(USE_SPI0==1) 
    if(_pSPIx==SPI0)
    {
        if(EXTI_State(GPIO_SPI0_INT, PORT_SPI0_INT))
        {
            EXTI_Clear(GPIO_SPI0_INT, PORT_SPI0_INT);  
            NET_INT = 1;
        } 
	}
#endif    
    
#if(USE_SPI1==1)  
    if(_pSPIx==SPI1)
    {
        if(EXTI_State(GPIO_SPI1_INT, PORT_SPI1_INT))
        {  
            EXTI_Clear(GPIO_SPI1_INT, PORT_SPI1_INT);  
            NET_INT= 1;  
        }
    }
#endif
    if(NET_INT)
        CH392GlobalInterrupt();
}


void  InitNet(void)
{ 
    SPI_TypeDef *spiPort = CH392_SPI_PORT_NO==0?SPI0:SPI1;
   
    UINT8 i = 0;
    CH392_Port_Init(spiPort); 
    InitEXIT( );
    CH392CMDReset();
    delay_ms(100);
    printf("CH392EVT Test Demo\r\n");
    i = CH392CMDGetVer();
    printf("CH392VER : %2x\r\n", (UINT16)i);
    delay_ms(50);
    InitCH392InfParam();                                             // 初始化CH392相关变量
    i = CH392Init();
    mStopIfError(i);
    while(1)
    {
        // 等待以太网连接成功
        if(CH392CMDGetPHYStatus() == PHY_DISCONN)                     // 查询CH392是否连接
        {
            //TODO: 应该重启,切换另外一条网线
            delay_ms(200);                                            // 未连接则等待200MS后再次查询
        }
        else
        {
            printf("CH392 Connect Ethernet\r\n");                       // CH392芯片连接到以太网，此时会产生中断
            break;
        }
    }
    InitSockets ();
}

unsigned char pBuf[] = "Hello world!\r\n\0";
void NetRouting(int i)
{
    
    if(Query392Interrupt() == 0)
        CH392GlobalInterrupt();
    
    if((i%500000)==0)
	{   
		//CH392SendData(2,pBuf,sizeof(pBuf));
	}
}