智能家居----温湿度灯控

  前两次都是写的单个产品的用例。是方便对阿里云套件的简单认识及使用，熟悉了单个产品的使用后，我就有点不满足了。所以我尝试加上两个产品，并且会相互关联。于是我就想到用温湿度传感器和LED灯，想要实现的功能就是当温度或湿度达到某一个值时，开起LED灯，适用环境就类似种植大棚蔬菜一样（这个比喻好像不太恰当，，大家明白就好啦）   
需要材料：阿里云入门套件  x1
                  智能手机   x1
接下来就开始咯。
1.创建产品和设备
   因为阿里云与实物进行相互联系的是设备三元组，当我们挂载多个产品的时候，难道是增加多个设备吗？这样不就乱套了，而且按理这样做，多个产品挂在在ESP32上是不能同时工作的。设备是挂载在产品之下的，一个设备所属与一个产品，我们程序当中只需要一个设备三元组，所以，我们只需一个设备，同样就只需一个产品。那怎样实现同时挂在温度传感器和led呢，我们可以为产品添加多个功能。

   首先向之前的步骤一样，创建产品，选填为：温湿度灯控。然后进行功能定义，添加功能，因为温湿度是两个变量，LED灯是一个。所以这里添加了三个功能。

   温度监控，选填标识符为TEM,数据类型为整型，范围在-40--50；

   湿度监控，选填标识符为HUM,数据类型也为整型，范围在0--100；
   LED开关，选填标识符为LEDSwitch,数据类型为布尔型，0--表示关灯，1--表示开灯。
  接下来就是添加设备，为温湿度产品创建一个设备，选填为：ESP32-2019-5
  现在产品和设备都创建成功后，就可以编辑移动设备了，不懂的可参照前两篇，而且也可以选用钉钉机器人，当温湿度大于或小于某一个值时，通过钉钉机器人通知。

2.程序的编写
  多个产品的功能挂载在同一个ESP32设备上，程序就不仅仅是简单修改WiFi及WiFi密码，设备三元组，产品标识符和Post，Set，这些数据了。
  增加引脚定义，将温湿度传感器接入D2口，LED灯接入D3口。


将产品标识符填写完整。

WiFi连接函数和回调函数是不用改动的。然后要增加对挂载的产品进行判断

然后增加这部分程序

增加对接入的产品输入输出模式，温度传感器是输入模式，LED灯是输出模式

最后加上在LOOP加上你想要的功能，这里我是当温度大于31时，开启LED灯。

[mw_shl_code=applescript,true]#include <WiFi.h>
#include <PubSubClient.h>
#include <ArduinoJson.h>
#include "DFRobot_Aliyun.h"
#include "DFRobot_DHT11.h"

#define DHT11_PIN  D2
#define SOCKET_PINled  D3
/*配置WIFI名和密码*/
const char * WIFI_SSID     = "Honor 8";
const char * WIFI_PASSWORD = "11223344";

/*配置设备证书信息*/
String ProductKey = "a1L5N6eNyK1";
String ClientId = "12345";
String DeviceName = "ESP32-2019-5";
String DeviceSecret = "xAJrHPeOBJzdLcdWv1sdR9uHqqycVWpr";

/*配置域名和端口号*/
String ALIYUN_SERVER = "iot-as-mqtt.cn-shanghai.aliyuncs.com";
uint16_t PORT = 1883;

/*需要操作的产品标识符(温度和湿度两个标识符)*/
String TempIdentifier = "TEM";
String HumiIdentifier = "HUM";
String ledIdentifier = "LEDSwitch";
/*需要上报和订阅的两个TOPIC*/
const char * subTopic = "/sys/a1L5N6eNyK1/${deviceName}/thing/service/property/set";//****set
const char * pubTopic = "/sys/a1L5N6eNyK1/${deviceName}/thing/event/property/post";//******post

DFRobot_Aliyun myAliyun;
WiFiClient espClient;
PubSubClient client(espClient);
DFRobot_DHT11 DHT;


static void openSocketled(){
  digitalWrite(SOCKET_PINled, HIGH);//led控制
}

static void closeSocketled(){
  digitalWrite(SOCKET_PINled, LOW);
}

void connectWiFi(){
  Serial.print("Connecting to ");
  Serial.println(WIFI_SSID);
  WiFi.begin(WIFI_SSID,WIFI_PASSWORD);
  while(WiFi.status() != WL_CONNECTED){
    delay(500);
    Serial.print(".");
  }
  Serial.println();
  Serial.println("WiFi connected");
  Serial.print("IP Adderss: ");
  Serial.println(WiFi.localIP());
}

void callback(char * topic, byte * payload, unsigned int len){
  Serial.print("Recevice [");
  Serial.print(topic);
  Serial.print("] ");
  for (int i = 0; i < len; i++){
    Serial.print((char)payload);
  }
  Serial.println();

StaticJsonBuffer<300> jsonBuffer;
  JsonObject& root = jsonBuffer.parseObject((const char *)payload);
  if(!root.success()){
    Serial.println("parseObject() failed");
    return;
  }
  uint8_t SocketStatus1,ledStatus ;//定义局部变量
  const char* ledtval =  root["params"][ledIdentifier];//判断Identifier是否存在，不存在返回NULL
if( ledtval != NULL )
{
       // Serial.println("------------");
       ledStatus = root["params"][ledIdentifier];
      Serial.print("ledStatus=");
      Serial.print(ledStatus);
      if(ledStatus == 1){
        /*打开灯*/
        openSocketled();
      }else{
        /*关掉灯*/
        closeSocketled();
      }
}


  String tempMsegled = "{\"id\":"+ClientId+",\"params\":{\""+ledIdentifier+"\":"+(String)ledStatus+"},\"method\":\"thing.event.property.post\"}";

  char ledsendMseg[tempMsegled.length()];

  strcpy(ledsendMseg,tempMsegled.c_str());

  client.publish(pubTopic,ledsendMseg);
}
  
void ConnectAliyun(){
  while(!client.connected()){
    Serial.print("Attempting MQTT connection...");
    /*根据自动计算的用户名和密码连接到Alinyun的设备，不需要更改*/
    if(client.connect(myAliyun.client_id,myAliyun.username,myAliyun.password)){
      Serial.println("connected");
      client.subscribe(subTopic);
    }else{
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      delay(5000);
    }
  }
}
void setup(){
  Serial.begin(115200);
  
   pinMode(SOCKET_PINled,OUTPUT);
     pinMode(DHT11_PIN,INPUT);
       closeSocketled();
  /*连接WIFI*/
  connectWiFi();
  
  /*初始化Alinyun的配置，可自动计算用户名和密码*/
  myAliyun.init(ALIYUN_SERVER,ProductKey,ClientId,DeviceName,DeviceSecret);
  
  client.setServer(myAliyun.mqtt_server,PORT);
  
  /*设置回调函数，当收到订阅信息时会执行回调函数*/
  client.setCallback(callback);
  
  /*连接到Aliyun*/
  ConnectAliyun();
}

uint8_t tempTime = 0;
void loop(){
  if(!client.connected()){
    ConnectAliyun();
  }
  /*一分钟上报两次温湿度信息*/
  if(tempTime > 60){
    tempTime = 0;
    DHT.read(DHT11_PIN);
    Serial.print("DHT.temperature=");
    Serial.println(DHT.temperature);
    Serial.print("DHT.humidity=");
    Serial.println(DHT.humidity);
    client.publish(pubTopic,("{\"id\":"+ClientId+",\"params\":{\""+TempIdentifier+"\":"+DHT.temperature+",\""+HumiIdentifier+"\":"+DHT.humidity+"},\"method\":\"thing.event.property.post\"}").c_str());
  }else{
    tempTime++;
    delay(500);
  }
  if(DHT.temperature > 31){
    openSocketled();
  
  }else
      closeSocketled();
  
  
  client.loop();
}[/mw_shl_code]