Iot標(biāo)簽

*/

#include "Arduino.h"

#include "DFRobot_IL0376F_SPI.h"

#define STOCK_PIN A2 // 這里可以利用環(huán)境光線傳感器收集數(shù)據(jù)模擬商品“美福記”庫存狀態(tài)變化

DFRobot_IL0376F_SPI epaper;

#define EPAPER_CS D3

#define Font_CS D6

#define EPAPER_DC D8

#define EPAPER_BUSY D7

char foodName[]="";

float price = 0.0;

int stock_per = 100;

void setup(void)

{

Serial.begin(115200);

//Select the corresponding pins

epaper.begin(EPAPER_CS, Font_CS, EPAPER_DC, EPAPER_BUSY);

}

void loop(void)

{

epaper.fillScreen(WHITE);

//Displays a string, black font

epaper.disString(1,5, 2,"食",BLACK);

epaper.disString(1,45, 2,"品",BLACK);

epaper.disString(0,83, 1,"FOOD",BLACK);

//Let me draw 2 red dotLines

for(uint8_t x=33,y=0; y<103; y+=2)

{

epaper.drawPixel(x,y,RED);

epaper.drawPixel(x+1,y,RED);

}

epaper.disString(35,1, 1,"品名:",BLACK);

epaper.disString(35,18, 1,"Name",BLACK);

epaper.disString(35,35, 1,"價格:",BLACK);

epaper.disString(35,52, 1,"Price",BLACK);

epaper.disString(35,69, 1,"庫存:",BLACK);

epaper.disString(35,86, 1,"Stock",BLACK);

epaper.disString(78,1, 1,"美福記",RED);

epaper.disString(78,30, 2,"29.8",RED);

epaper.disString(140,45, 1,"￥/Kg",RED);

epaper.disString(185,1, 1,"20%",RED);

// Draw a down arrow

epaper.fillRect(191,18, 12,40,RED);

epaper.fillTriangle(184,50, 210,50, 197,70,RED);

//Draw a black rectangle(x,y,l,r,c)

epaper.drawRoundRect(75,75, 135,23,8,BLACK);

epaper.drawRoundRect(76,76, 133,21,8,WHITE);

epaper.drawRoundRect(77,77, 131,19,8,WHITE);

stock_per =map(analogRead(A2),0,1023,0,100);

epaper.fillRoundRect(78,78, 129*stock_per/100,17,7,RED);

epaper.disString(185,1, 1,"20%",RED);

//Refresh screen display

epaper.flush();

delay(10000);

}

#include "DFRobot_Aliyun.h"

#include "DFRobot_DHT11.h"

#define DHT11_PIN D2 //定義傳感器引腳，用于收集數(shù)據(jù)模擬庫存數(shù)據(jù)

/*配置WIFI名和密碼*/

const char * WIFI_SSID = "your ssid";

const char * WIFI_PASSWORD = "your password";

/*配置設(shè)備證書信息*/

String ProductKey = "xxxxxxxxxx";

String ClientId = "12345";

String DeviceName = "STOCK";

String DeviceSecret = "xxxxxxxxxxxxxxxxxxxxxxxxxx";

/*配置域名和端口號*/

String ALIYUN_SERVER = "iot-as-mqtt.cn-shanghai.aliyuncs.com";

uint16_t PORT = 1883;

/*需要操作的產(chǎn)品標(biāo)識符(溫度和濕度兩個標(biāo)識符)*/

String TempIdentifier = "xxxxxxx";

String HumiIdentifier = "xxxxxxxx";

/*需要上報和訂閱的兩個TOPIC*/

const char * subTopic = "xxxxxxxxxxxxxxxxxxxxxxxxx/property/set";//****set

const char * pubTopic = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx/property/post";//******post

DFRobot_Aliyun myAliyun;

WiFiClient espClient;

PubSubClient client(espClient);

DFRobot_DHT11 DHT;

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[i]);[/i]

[i] }[/i]

[i] Serial.println();[/i]

[i]}[/i]

[i]void ConnectAliyun(){[/i]

[i] while(!client.connected()){[/i]

[i] Serial.print("Attempting MQTT connection...");[/i]

[i] /*根據(jù)自動計(jì)算的用戶名和密碼連接到Alinyun的設(shè)備，不需要更改*/[/i]

[i] if(client.connect(myAliyun.client_id,myAliyun.username,myAliyun.password)){[/i]

[i] Serial.println("connected");[/i]

[i] client.subscribe(subTopic);[/i]

[i] }else{[/i]

[i] Serial.print("failed, rc=");[/i]

[i] Serial.print(client.state());[/i]

[i] Serial.println(" try again in 5 seconds");[/i]

[i] delay(5000);[/i]

[i] }[/i]

[i] }[/i]

[i]}[/i]

[i]void setup(){[/i]

[i] Serial.begin(115200);[/i]

[i] /*連接WIFI*/[/i]

[i] connectWiFi();[/i]

[i] /*初始化Alinyun的配置，可自動計(jì)算用戶名和密碼*/[/i]

[i] myAliyun.init(ALIYUN_SERVER,ProductKey,ClientId,DeviceName,DeviceSecret);[/i]

[i] client.setServer(myAliyun.mqtt_server,PORT);[/i]

[i] /*設(shè)置回調(diào)函數(shù)，當(dāng)收到訂閱信息時會執(zhí)行回調(diào)函數(shù)*/[/i]

[i] client.setCallback(callback);[/i]

[i] /*連接到Aliyun*/[/i]

[i] ConnectAliyun();[/i]

[i]}[/i]

[i]uint8_t tempTime = 0;[/i]

[i]void loop(){[/i]

[i] if(!client.connected()){[/i]

[i] ConnectAliyun();[/i]

[i] }[/i]

[i] /*一分鐘上報兩次溫濕度(模擬福美記和福美佳兩種商品的庫存狀態(tài)數(shù)據(jù))信息*/[/i]

[i] if(tempTime > 60){[/i]

[i] tempTime = 0;[/i]

[i] DHT.read(DHT11_PIN);[/i]

[i] Serial.print("DHT.temperature=");[/i]

[i] Serial.println(DHT.temperature);[/i]

[i] Serial.print("DHT.humidity=");[/i]

[i] Serial.println(DHT.humidity);[/i]

[i] client.publish(pubTopic,("{"id":"+ClientId+","params":{""+TempIdentifier+"":"+DHT.temperature+",""+HumiIdentifier+"":"+DHT.humidity+"},"method":"thing.event.property.post"}").c_str());[/i]

[i] }else{[/i]

[i] tempTime++;[/i]

[i] delay(500);[/i]

[i] }[/i]

[i] client.loop();[/i]

[i]}

#include <ArduinoJson.h>

#include "DFRobot_Aliyun.h"

#include "DFRobot_DHT11.h"

#include "DFRobot_IL0376F_SPI.h"

/////////////////////////////////////////////

DFRobot_IL0376F_SPI epaper;

#define DHT11_PIN D2 //定義傳感器引腳，用于收集數(shù)據(jù)模擬庫存數(shù)據(jù)

#define EPAPER_CS D3 //定義電子墨水屏相關(guān)

#define Font_CS D6

#define EPAPER_DC D8

#define EPAPER_BUSY D7

//////////////////////////////////////////////

/*配置WIFI名和密碼*/

const char * WIFI_SSID = "XXXXXXX";

const char * WIFI_PASSWORD = "XXXXXXXXXX";

/*配置設(shè)備證書信息*/

String ProductKey = "XXXXXXXXXXX";

String ClientId = "12345";

String DeviceName = "STOCK";

String DeviceSecret = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";

/*配置域名和端口號*/

String ALIYUN_SERVER = "iot-as-mqtt.cn-shanghai.aliyuncs.com";

uint16_t PORT = 1883;

/*需要操作的產(chǎn)品標(biāo)識符(溫度和濕度兩個標(biāo)識符)*/

String TempIdentifier = "meifuji";

String HumiIdentifier = "meifujia";

/*需要上報和訂閱的兩個TOPIC*/

const char * subTopic = "/sys/XXXXXXXXXXX/STOCK/thing/service/property/set";//****set

const char * pubTopic = "/sys/XXXXXXXXXXX/STOCK/thing/event/property/post";//******post

DFRobot_Aliyun myAliyun;

WiFiClient espClient;

PubSubClient client(espClient);

DFRobot_DHT11 DHT;

///////////////////////////////////////////////

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[i]);[/i]

}

Serial.println();

}

///////////////////////////////////////////////

void ConnectAliyun(){

while(!client.connected()){

Serial.print("Attempting MQTT connection...");

/*根據(jù)自動計(jì)算的用戶名和密碼連接到Alinyun的設(shè)備，不需要更改*/

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);

//Select the corresponding pins

epaper.begin(EPAPER_CS, Font_CS, EPAPER_DC, EPAPER_BUSY);

/*連接WIFI*/

connectWiFi();

/*初始化Alinyun的配置，可自動計(jì)算用戶名和密碼*/

myAliyun.init(ALIYUN_SERVER,ProductKey,ClientId,DeviceName,DeviceSecret);

client.setServer(myAliyun.mqtt_server,PORT);

/*設(shè)置回調(diào)函數(shù)，當(dāng)收到訂閱信息時會執(zhí)行回調(diào)函數(shù)*/

client.setCallback(callback);

/*連接到Aliyun*/

ConnectAliyun();

}

//////////////////////////////////////////////////

uint8_t tempTime = 0;

uint8_t stock_per = 100;

void loop(){

if(!client.connected()){

ConnectAliyun();

}

/*上報溫濕度(模擬福美記和福美佳兩種商品的庫存狀態(tài)數(shù)據(jù))信息*/

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());

client.loop();

/*借用DH11傳感器的溫度數(shù)據(jù)顯示福美記商品的庫存狀態(tài)信息*/

stock_per = DHT.temperature;

epaper.fillScreen(WHITE);

//Displays a string, black font

epaper.disString(1,5, 2,"食",BLACK);

epaper.disString(1,45, 2,"品",BLACK);

epaper.disString(0,83, 1,"FOOD",BLACK);

//Let me draw 2 red dotLines

for(uint8_t x=33,y=0; y<103; y+=2)

{

epaper.drawPixel(x,y,RED);

epaper.drawPixel(x+1,y,RED);

}

epaper.disString(35,1, 1,"品名:",BLACK);

epaper.disString(35,18, 1,"Name",BLACK);

epaper.disString(35,35, 1,"價格:",BLACK);

epaper.disString(35,52, 1,"Price",BLACK);

epaper.disString(35,69, 1,"庫存:",BLACK);

epaper.disString(35,86, 1,"Stock",BLACK);

epaper.disString(78,1, 1,"美福記",RED);

epaper.disString(78,30, 2,"29.8",RED);

epaper.disString(140,45, 1,"￥/Kg",RED);

epaper.disString(185,1, 1,"20%",RED);

// Draw a down arrow

epaper.fillRect(191,18, 12,40,RED);

epaper.fillTriangle(184,50, 210,50, 197,70,RED);

//Draw a black rectangle(x,y,l,r,c)

epaper.drawRoundRect(75,75, 135,23,8,BLACK);

epaper.drawRoundRect(76,76, 133,21,8,WHITE);

epaper.drawRoundRect(77,77, 131,19,8,WHITE);

epaper.fillRoundRect(78,78, 129*stock_per/100,17,7,RED);

epaper.disString(185,1, 1,"20%",RED);

//Refresh screen display

epaper.flush();

delay(12000);

}