#define AT          "ATrn"    //测试esp8266是否工作正常
#define CWMODE      "AT+CWMODE=3rn"       //设置wifi模块的模式，3为STA+AP模式
#define RST         "AT+RSTrn"        //重启
#define CIFSR       "AT+CIFSRrn"      //查看ip
#define CWJAP       "AT+CWJAP="nb","123456789"rn" // 设置要连接的无线路由器的 ssid 和 password
#define CIPSTART    "AT+CIPSTART="TCP","119.29.201.31",4001rn"        //设置服务器IP和端口
#define CIPMODE0    "AT+CIPMODE=0rn"      //非透传模式
#define CIPMODE1    "AT+CIPMODE=1rn"      //透传模式
#define CIPSEND     "AT+CIPSENDrn"        //发送
#define CIPSTATUS   "AT+CIPSTATUSrn"      //网络状态查询

extern void ESP8266_Rst(void);  
extern void ESP8266_Init(void);

/**
  * @brief  ESP8266硬件复位
**/
void ESP8266_Rst(void)
{
    GPIO_InitTypeDef GPIO_InitStructure;
    //Pb5--对应ESP8266的reset引脚;
    RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOB, ENABLE);
    GPIO_InitStructure.GPIO_Pin = GPIO_Pin_5;
    GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;
    GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP;
    GPIO_Init(GPIOB, &GPIO_InitStructure);
    
    GPIO_ResetBits(GPIOB,GPIO_Pin_5);
    mDelay(100);
    GPIO_SetBits(GPIOB,GPIO_Pin_5);
    mDelay(100);
}


/*
 *  @brief ESP8266模块初始化
 */
void ESP8266_Init(void)
{
    ESP8266_Rst();
#if 1
    SendCmd(AT, "OK", 1000);          //模块有效性检查
    SendCmd(CWMODE, "OK", 1000);    //模块工作模式
    SendCmd(RST, "OK", 2000);         //模块重置
    SendCmd(CIFSR, "OK", 1000);     //查询网络信息
    SendCmd(CWJAP, "OK", 2000);     //配置需要连接的WIFI热点SSID和密码
    SendCmd(CIPSTART, "OK", 2000);  //TCP连接
    SendCmd(CIPMODE1, "OK", 1000);  //配置透传模式
    SendCmd(CIPSEND, ">", 1000);    //进入透传模式
    USART2_Clear();
#endif
}

void SendCmd(char* cmd, char* result, int timeOut)
{
    while(1)
    {
        USART2_Clear();
        USART2_Write(USART2, (unsigned char *)cmd, strlen((const char *)cmd));
        mDelay(timeOut);
        printf("%s %d cmd:%s,rsp:%sn", __func__, __LINE__, cmd, usart2_rcv_buf);
        if((NULL != strstr((const char *)usart2_rcv_buf, result)))  //判断是否有预期的结果
        {
            break;
        }
        else
        {
            mDelay(100);
        }
    }
}

        /* 获取温湿度 */
        SHT2x_MeasureHM(SHT20_Measurement_T_HM, &temp);
        mDelay(500);
        SHT2x_MeasureHM(SHT20_Measurement_RH_HM, &humi);

        /* 转化为字符串形式 */
        sprintf(tempStr, "%d", temp);
        sprintf(humiStr, "%d", humi);

/**
  * @brief   拼接
  * @param   pkt   缓存指针
  * @param   dsid1  数据流1ID
  * @param   val1   字符串形式的数据点1的值
  * @param   dsid2  数据流2ID
  * @param   val2   字符串形式的数据点2的值
  * @retval  整个包的长度
  */
uint32_t HTTP_NewPostPacket(char *pkt, char *dsid1, char *val1, char *dsid2, char *val2)
{
    char dataBuf[50] = {0};
    char lenBuf[10] = {0};
    *pkt = 0;
    sprintf(dataBuf, "{"%s":"%s","%s":"%s"}", dsid1, val1, dsid2, val2);
    sprintf(lenBuf, "%d", strlen(dataBuf));

    strcat(pkt, dataBuf);

    return strlen(pkt);
}

var net = require('net')
net.createServer(function(socket){
    socket.on('data',function(data){//接受处理
        console.log('got:',data.toString());//打印接收到的数据
        socket.write('I have received') //接受后回复
    });
    socket.write('Ready to receive your message!')//客户端连接成功后回复
}).listen(4001);