/** ESPRSSIF MIT License** Copyright (c) 2015 <ESPRESSIF SYSTEMS (SHANGHAI) PTE LTD>** Permission is hereby granted for use on ESPRESSIF SYSTEMS ESP8266 only, in which case,* it is free of charge, to any person obtaining a copy of this software and associated* documentation files (the "Software"), to deal in the Software without restriction, including* without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense,* and/or sell copies of the Software, and to permit persons to whom the Software is furnished* to do so, subject to the following conditions:* * The above copyright notice and this permission notice shall be included in all copies or* substantial portions of the Software.* * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.**/#include "esp_common.h"
#include "gpio.h"
#include "uart.h"
#include "esp_timer.h"
#include "hw_timer.h"
#include "pwm.h"
#include  "data_dispose.h"
#include  "espconn.h"
#include  "esp_wifi.h"
#include "lwip/api.h"//typedef void (*UartCallback)(void);extern u8  Usart1ReadBuff[Usart1ReadLen];//接收数据的数组
extern u32 Usart1ReadCnt;//串口1接收到的数据个数
extern u32 Usart1ReadCntCopy;//串口1接收到的数据个数拷贝
extern u8  Usart1ReadFlage;//串口1接收到一条完整数据#define  SSID "Learn8266" //无线名称
#define     PWD "11223344"     //密码
struct softap_config soft_ap_Config;//AP模式配置
xTaskHandle xHandleTcpSendDate;//发送数据任务的句柄,我用来删除发送任务用

err_t err;//接收操作所有API函数的时候返回的错误信息
struct netconn *conn, *newconn;//conn 保存自身TCP服务器的信息    newconn-保存连接客户端的信息
int i = 0;
struct pbuf *q;//用此变量来操作链表,可以看一下    https://www.cnblogs.com/yangfengwu/p/5778872.html
u32 data_len =0;//获取接收的数据个数
unsigned char TcpRead[1024]={0};//接收数据缓存的数组,最大接收1024字节
struct netbuf *recvbuf;//创建接收数据的结构体,这是lwip提供的缓存数据用的/******************************************************************************* FunctionName : user_rf_cal_sector_set* Description  : SDK just reversed 4 sectors, used for rf init data and paramters.*                We add this function to force users to set rf cal sector, since*                we don't know which sector is free in user's application.*                sector map for last several sectors : ABCCC*                A : rf cal*                B : rf init data*                C : sdk parameters* Parameters   : none* Returns      : rf cal sector
*******************************************************************************/
uint32 user_rf_cal_sector_set(void)
{flash_size_map size_map = system_get_flash_size_map();uint32 rf_cal_sec = 0;switch (size_map) {case FLASH_SIZE_4M_MAP_256_256:rf_cal_sec = 128 - 5;break;case FLASH_SIZE_8M_MAP_512_512:rf_cal_sec = 256 - 5;break;case FLASH_SIZE_16M_MAP_512_512:case FLASH_SIZE_16M_MAP_1024_1024:rf_cal_sec = 512 - 5;break;case FLASH_SIZE_32M_MAP_512_512:case FLASH_SIZE_32M_MAP_1024_1024:rf_cal_sec = 1024 - 5;break;default:rf_cal_sec = 0;break;}return rf_cal_sec;
}//串口调用此函数就说明接收到了一条完整的数据,就可以去处理了
void UartReadCallback()//定义一个函数
{}//发送数据任务
void TcpSendDateThread(void *date)
{conn->send_timeout=5;//设置发送超时时间,一定要加,否则任务就阻塞住了while(1){if(Usart1ReadFlage)//串口接收到一条完整的数据
        {Usart1ReadFlage = 0;err = netconn_write(newconn ,Usart1ReadBuff,Usart1ReadCntCopy ,NETCONN_COPY);//发送数据if(err != ERR_OK){//发送失败
            }}vTaskDelay(10/portTICK_RATE_MS);//如果没有数据要发送会执行这个,一定要加这个任务延时哈
    }vTaskDelete(NULL);
}void TcpServerThread(void *date)
{static ip_addr_t ipaddr;//存储客户端的地址static u16_t port;//存储客户端的端口号
conn = netconn_new(NETCONN_TCP);//创建一个TCP//注意哈,首先要明白你无论创建 TCP服务器或者客户端,或者UDP,你创建的时候必须设置下TCP服务器或者客户端,或者UDP的IP地址和端口号.//网络之间通信嘛,这是必须的,只有你有IP和端口号了,别人才能和你通信netconn_bind(conn,IP_ADDR_ANY,8888);  //设置conn(TCP服务器) 的IP地址是自己网卡上的IP  设置TCP服务器通信的端口号是8888   (无论创建 TCP服务器或者客户端,或者UDP,都是必须的)
netconn_listen(conn);  //使用监听函数,说明是创建TCP服务器,只有作为服务器才是监听客户端连接嘛//设置任务阻塞时间为10ms  (注意哈,这个和vTaskDelay(10/portTICK_RATE_MS)类似,但是一定要用这个//下面的netconn_accept(conn,&newconn);函数是完全阻塞的,,如果你不设置conn->recv_timeout  程序就停止在那里了,除非有客户端连接conn->recv_timeout=5;//任务延时5mswhile(1){err = netconn_accept(conn,&newconn);//等待客户端连接,有客户机连接,或者超时了就会往下执行if (err == ERR_OK)//只有客户机连接了,并且没有其它错误才会进入
        {netconn_getaddr(newconn,&ipaddr,&port,0); //得到客户端的IP地址和端口号     最后一个参数  1获取本地IP地址，0获取远程IP地址//打印客户端的IP地址printf("ClientIP:%d.%d.%d.%d Connected\n",(uint8_t)(ipaddr.addr),(uint8_t)(ipaddr.addr >> 8),(uint8_t)(ipaddr.addr >> 16),(uint8_t)(ipaddr.addr >> 24));printf("Port:%d\n",port);//打印客户端的端口号
xTaskCreate(TcpSendDateThread, "TcpSendDateThread", 1024, NULL, 9, &xHandleTcpSendDate);//创建发送数据任务while(1)//一直在这个里面接收处理数据
            {err = netconn_recv(newconn,&recvbuf);//如果一直接受不到数据或者不是其它错误信息,不会往下执行if(err== ERR_OK)//接收到客户端发过来的数据
                {taskENTER_CRITICAL();//关闭中断,禁止其它任务打断,防止读数据出现错误
data_len = 0;for( q = recvbuf->p; q != NULL; q = q->next )  //遍历完整个pbuf链表
                    {//判断要拷贝到缓存数组中的数据是否大于缓存数组的剩余空间，如果大于//的话就只拷贝缓存数组中剩余长度的数据，否则的话就拷贝所有的数据if( q->len > ( 1024-data_len ) )memcpy(TcpRead+data_len,q->payload,(1024-data_len));//拷贝数据elsememcpy( TcpRead+data_len, q->payload, q->len );data_len += q->len;if(data_len > 1024)//超出TCP客户端接收数组,跳出break;}taskEXIT_CRITICAL();//打开中断for(i=0;i<data_len;i++){USART_SendData(UART0, TcpRead[i]);//接收的数据发给串口
                    }}else if(err == ERR_CLSD)  //客户端断开连接
                {vTaskDelete(xHandleTcpSendDate);//删除发送数据任务netconn_close(newconn);//关闭连接netconn_delete(newconn);//删除连接printf("ClientIP:%d.%d.%d.%d Disconnected\n",(uint8_t)(ipaddr.addr),(uint8_t)(ipaddr.addr >> 8),(uint8_t)(ipaddr.addr >> 16),(uint8_t)(ipaddr.addr >> 24));break;//退出
                }}}else{conn->recv_timeout=10;//任务延时10ms
        }}vTaskDelete(NULL);
}void LedThread(void *date)
{while(1){vTaskDelay(1000/portTICK_RATE_MS);GPIO_OUTPUT_SET(2,1-GPIO_INPUT_GET(2));}vTaskDelete(NULL);
}/******************************************************************************* FunctionName : user_init* Description  : entry of user application, init user function here* Parameters   : none* Returns      : none
*******************************************************************************/
void user_init(void)
{GPIO_OUTPUT_SET(5, 1);GPIO_OUTPUT_SET(2, 0);//让两个灯初始的状态一样,GOIO2是反接的,0的时候是亮
//    GPIO_OUTPUT_SET(5, 0);
    uart_init_new();printf("SDK version:%s\n", system_get_sdk_version());
//    printf("Ai-Thinker Technology Co. Ltd.\r\n%s %s\r\n", __DATE__, __TIME__);
//    printf("Hello,World!\r\n");
//    xTaskCreate(LedControl, "LedControl", 1024, NULL, 11, NULL);wifi_set_opmode(STATIONAP_MODE);//配置WiFi的模式STATION + AP AP--连接WIFI自身的无线实现通信  STATION--wifi连接路由器,手机或者电脑也连接路由器,实现通信soft_ap_Config.ssid_len = strlen(SSID);//热点名称长度，与你实际的名称长度一致就好memcpy(soft_ap_Config.ssid,SSID,soft_ap_Config.ssid_len);//实际热点名称设置，可以根据你的需要来memcpy(soft_ap_Config.password,PWD,strlen(PWD));//热点密码设置soft_ap_Config.authmode = AUTH_WPA2_PSK;//加密模式soft_ap_Config.channel = 1;//信道，共支持1~13个信道soft_ap_Config.max_connection = 4;//最大连接数量，最大支持四个，默认四个
wifi_softap_set_config_current(&soft_ap_Config);//设置 Wi-Fi SoftAP 接口配置，不保存到 Flash//    wifi_softap_set_config(&soft_ap_Config);//设置 Wi-Fi SoftAP 接口配置，保存到 Flash//下面的函数大家点进去一看注释就明白了
//    espconn_init();//"espconn.h"   195行
//    TcpServer.type = ESPCONN_TCP;     //创建TCP
//    TcpServer.state = ESPCONN_NONE;   //一开始的状态
//    TcpServer.proto.tcp = &esptcp;    //设置TCP的IP和回调函数存储用
//    TcpServer.proto.tcp->local_port = 8888;//监听的端口号
//    espconn_regist_connectcb(&TcpServer, TcpServerListen);//注册
//    espconn_accept(&TcpServer);//启动监听UartCallbackRegister(UartReadCallback);//把 UartReadCallback 函数地址传过去,在串口里面调用
xTaskCreate(TcpServerThread, "TcpServerThread", 1024, NULL, 8, NULL);xTaskCreate(LedThread, "LedThread", 1024, NULL, 11, NULL);
}

//                    00 01 70 C0 控制LED点亮  70 C0  为CRC高位和低位
//                    00 00 B0 01 控制LED熄灭   B0 01  为CRC高位和低位if(TcpRead[0] == 0){if(TcpRead[1] == 0x01 && TcpRead[2] == 0x70 && TcpRead[3] == 0xC0 )//控制LED点亮
                        {GPIO_OUTPUT_SET(5,1);}else if(TcpRead[1] == 0x00 && TcpRead[2] == 0xB0 && TcpRead[3] == 0x01 )//控制LED熄灭
                        {GPIO_OUTPUT_SET(5,0);}}