#include "main.h"

//DHT11起始信号
void DHT11_start()	
{
	Temp_data=1;
	
	delay_us(2);
	
	Temp_data=0;
	
	delay_ms(20);
	
	Temp_data=1;
	
	delay_us(13);
}

//接收一个字节
unsigned char DHT11_rec_byte()
{	
	unsigned char i,dat;

	for(i=0;i<8;i++)
	{
			while(!Temp_data);
		  delay_us(8);
			dat<<=1;
			if(Temp_data==1)
			{
				dat+=1;
			}
			while(Temp_data);
	}
	return dat;	
}

//接收温湿度数据
void DHT11_receive()
{
	unsigned int R_H,R_L,T_H,T_L;
	unsigned char RH,RL,TH,TL,revise;
	
	DHT11_start();
	Temp_data=1;
	if(Temp_data==0)
	{
		while(Temp_data==0);   //等待拉高     
        delay_us(40);  //拉高后延时80us
		
        R_H=DHT11_rec_byte();    //接收湿度高八位  
        R_L=DHT11_rec_byte();    //接收湿度低八位  
        T_H=DHT11_rec_byte();    //接收温度高八位  
        T_L=DHT11_rec_byte();    //接收温度低八位
        revise=DHT11_rec_byte(); //接收校正位
     
        delay_us(25);    //结束
        if((R_H+R_L+T_H+T_L)==revise)      //校正
        {
            RH=R_H;
            RL=R_L;
            TH=T_H;
            TL=T_L;
        }  
        rec_dat[0]=RH;
        rec_dat[1]=RL;
        rec_dat[2]=TH;
        rec_dat[3]=TL;
	}	
}

// 引入 wifi 模块，并实例化，不同的芯片这里的依赖可能不同
#include <ESP8266WiFi.h>
static WiFiClient espClient;

// 引入阿里云 IoT SDK
#include <AliyunIoTSDK.h>


// 设置产品和设备的信息，从阿里云设备信息里查看
#define PRODUCT_KEY "xxxx"      //此信息在阿里云部分PRODUCT_KEY
#define DEVICE_NAME "xxxxx"     //同上DEVICE_NAME
#define DEVICE_SECRET "xxx"     //同上DEVICE_SECRET
#define REGION_ID "cn-shanghai"     //对应阿里云华东2(上海)服务器

// 设置 wifi 信息
#define WIFI_SSID "xxx"          //自己的手机热点WiFi名字（此处为自己手机开出的热点给esp8266                
                                 //连接）
#define WIFI_PASSWD "xxxxxxx"       //自己的手机热点WiFi密码

char Serial_Buf[50];                //可根据自己定义的数据长度自行修改

unsigned int Rx_Cnt = 0;

char Temp[20];
char Hum[20];

void setup()
{
  Serial.begin(9600);

  // 初始化 wifi
  wifiInit(WIFI_SSID, WIFI_PASSWD);

  // 初始化 iot，需传入 wifi 的 client，和设备产品信息
  AliyunIoTSDK::begin(espClient, PRODUCT_KEY, DEVICE_NAME, DEVICE_SECRET, REGION_ID);

  //AliyunIoTSDK::send("temperature", 11.8);  //修改阿里云平台上对应设备的Tempature属性
}

void loop()
{
  AliyunIoTSDK::loop();
  
  Serial_Rece_Process();    //串口接收数据与数据处理
  AliyunIoTSDK::send("temperature",atof(Temp));
  AliyunIoTSDK::send("Humidity",atof(Hum));
}

// 初始化 wifi 连接
void wifiInit(const char *ssid, const char *passphrase)
{
  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, passphrase);

  while (WiFi.status() != WL_CONNECTED)
  {
    delay(1000);
    Serial.println("WiFi not Connect");
  }
  Serial.println("Connected to AP");
}




//ESP8266串口接收数据与数据处理函数
void Serial_Rece_Process(void)
{
  unsigned char i =0;
  unsigned char sg = 0;
  

  while (Serial.available())
  {
    Serial_Buf[Rx_Cnt] = Serial.read();
    Rx_Cnt++;
    delay(3);
  }

  if (Rx_Cnt != 0)    
    for(int i=0;i<Rx_Cnt;i++)
    {

      /*此段代码是因为博主从串口接收到的数据格式是t:%d.%d,h=%d.%d\r\n这种格式*/
      if(i>1&&i<6)
      {
        Temp[i-2]=Serial_Buf[i];
       }
      else if(i>8&&i<13)
      {
      Hum[i-9]=Serial_Buf[i];
      }
    }
   
    Rx_Cnt = 0;
    //此处放置串口数据处理等代码
}