闲来无事-夏天防止花被渴死

扯淡时间

前段时间，办了一张流量卡。有了新的手机号码那就可以薅一波资本主义的羊毛了，所以我在京东上使用0.1大洋包邮的价格喜提了一个多肉，（在此之前我养过挺多的花，所有的都是忘了浇水被渴死了）此次痛并思痛，一定要让我0.1大洋的的多肉看到明年的太阳。
思路

养花几乎不用管，只需要两件事

• 充足的阳光：我现在住的距离太阳还是挺近的，阳光的事情不用担心。
  
• 有营养的土和充足的水： 土比较好搞定，去小区的花坛里面扣点就行了，主要就是水，经常想不起来去浇水，所以得搞一个能知道土壤湿度的东西，提醒我浇水。
  

我的思路如下

• 收集数据-首先手机花盆里面的土壤湿度
  
• 存储数据-将花盆的湿度进行持久化存储
  
• 数据展示通知-页面通过读取持久化存储的信息展示出来，并可以设定一个预警值，在一定的规则下面通知到我
  

思路有了就开干

收集数据

我的这个实现思路也算是传说中的物联网了，毕竟花盆都上网了嘛，现在实现这种的板子有很多，那个便宜来那个就行了。经过百度一下，选择了ESP8266-NodeMCU + 湿度传感器 作为数据收集方式（为啥选择这个呢？因为便宜啊，还自带wifi能上网。硬件真便宜，一共20块搞定，还包邮），esp8266可以使用Arduino进行开发，语法跟c差不多，库啥的自己搜搜吧，我也是自己搜的。俺看的是这个教程

收集数据主要是干两件事：1. 读取湿度，2. 上报数据代码如下

1. #include <ESP8266WiFi.h>
2. #include <ESP8266HTTPClient.h>
3. #include <ArduinoJson.h>
4. // 读取温度
5. #define PIN_AO A0  //土壤传感器AO接ESP8266引脚A0
6. //#define PIN_DO 4  //湿度高于设定值时，DO输出高电平，模块提示灯亮
8. int M0 = 1024;  //在空气中AO读取的值最大为1024，代表干燥时的读数
9. int M1 = 164;   //浸泡在水里的最小值 464（最小值会改变），代表100%湿度
11. float i=0;
12. float j=0;
14. #define SERVER_IP "http://局域网ip:3001/sendCurrentTemp"
16. const char* name = "名字";               //这里改成你的设备当前环境下要连接的接入点名字
17. const char* password = "密码";  //这里改成你的设备当前环境下要连接的接入点密码
18. // 上报时间间隔
19. int outTime = 1000 * 60 * 5;
20. // int outTime = 1000 * 60;
21. void setup() {
22.   // 设置引脚
23.   pinMode(PIN_AO, INPUT);
25.   Serial.begin(115200);  // 启动串口通讯，波特率设置为115200
27.   Serial.println("未连接");
30.   Serial.println("开始连接");
32.   WiFi.begin(name, password);
33.   Serial.print("正在连接到");
34.   Serial.print(name);
36.   while (WiFi.status() != WL_CONNECTED)  //判定网络状态
37.   {
38.     delay(500);
40.     Serial.print("网络连接成功");
42.     Serial.print("连接到的接入点名字:");
44.     Serial.println(name);  // 告知用户建立的接入点WiFi名
46.     Serial.print("连接到的接入点密码:");
48.     Serial.println(password);  // 显示用户建立的接入点WiFi密码
50.     Serial.print("无线模式成功开启，网络连接成功");
51.   }
52.   if (WiFi.status() == WL_CONNECTED) {
53.     Serial.print("无线IP地址为: ");
54.     Serial.println(WiFi.localIP());
55.   }
56. }
58. void loop() {
59.   // put your main code here, to run repeatedly:
61.   if (WiFi.status() == WL_CONNECTED) {
62.     http_post();
63.     WiFi.forceSleepBegin();  // Wifi Off
64.     delay(outTime);
65.     WiFi.forceSleepWake();  // Wifi On
66.   }
67. }
71. void http_post() {
73.   //创建 WiFiClient 实例化对象
74.   WiFiClient client;
76.   //创建http对象
77.   HTTPClient http;
79.   //配置请求地址
80.   http.begin(client, SERVER_IP);  //HTTP请求
81.   Serial.print("[HTTP] begin...\n");
82.   // 长度
83.   DynamicJsonDocument doc(96);
85.   float data = analogRead(PIN_AO);
86.   Serial.println(data);
87.   i = data / 1023;
88.   j = (1 - i) * 100;
90.   Serial.println(j);
92.   // 写入当前温度值
93.   doc["temp"] = j;
94.   String output;
95.   serializeJson(doc, output);
97.   //启动连接并发送HTTP报头和报文
98.   int httpCode = http.POST(output);
99.   Serial.print("[HTTP] POST...\n");
101.   //连接失败时 httpCode时为负
102.   if (httpCode > 0) {
103.     //将服务器响应头打印到串口
104.     Serial.printf("[HTTP] POST... code: %d\n", httpCode);
106.     //将从服务器获取的数据打印到串口
107.     if (httpCode == HTTP_CODE_OK) {
108.       const String& payload = http.getString();
109.       Serial.println("received payload:\n<<");
110.       Serial.println(payload);
111.       Serial.println(">>");
112.     }
113.   } else {
114.     Serial.printf("[HTTP] POST... failed, error: %s\n", http.errorToString(httpCode).c_str());
115.   }
116.   //关闭http连接
117.   http.end();
118. }

复制代码

存储数据

数据存储，得需要一个服务器，我这里正好一个冲动消费买的树莓派，就让他当服务器吧（你要有个这个可以不用买esp8266了，直接开干就完了）我的思路，在树莓派上起一个服务，让esp8266可以通过http的协议上报温度，数据展示也可以通过这个服务来获取数据，当然了我还想外网访问：我这里用的是花生壳，搞了一个内网穿透，这个送1g流量，6块还能给一个https的域名，省了备案的事情。

• 服务简单的来就使用nodejs启动一个服务吧
  
• 数据库我使用的SQLite，看人家说这个挺小的，还支持关联查询。代码如下
  

1. const http = require('http');
2. const os = require('os');
3. const urlInfo = require('url')
4. // 读取数据库
5. const querystring = require("querystring")
6. var sqlite3 = require('sqlite3').verbose()
8. // 要使用的端口号
9. const PORT_NUMBER = 3001
12. var db = new sqlite3.Database('./temp.db', sqlite3.OPEN_READWRITE, (err) => {
13.     if (err) {
14.         return console.log(err.message)
15.     }
16.     console.log('数据库链接成功')
17. })
19. /** 追加信息 */
20. const appendTemp = (temp) => {
21.     return new Promise((resolve, reject) => {
22.         const currentTime = new Date().getTime()
23.         const addData = `INSERT INTO temp (time,temp)  VALUES(${currentTime},${temp})`
24.         db.run(addData, function (err, data) {
25.             if (err) {
26.                 console.log(err)
27.                 reject(err)
28.             }
29.             resolve()
30.         })
31.     })
33. }
35. const selectTemp = (paramInfo) => {
36.     return new Promise((resolve, reject) => {
37.         const { pageIndex = 1, pageSize = 10, all = false,startTimestamp,endTimestamp } = paramInfo
38.         let sqlStr = `select * from temp`
39.         if (startTimestamp && endTimestamp) {
40.             sqlStr = `select * from temp where time >= ${startTimestamp} and time <= ${endTimestamp}`
41.         }
42.         // 默认展示所有
43.         if (all === false) {
44.             sqlStr += ` limit(${(pageIndex - 1) * pageSize}),${pageSize}`
45.         }
46.         db.all(sqlStr, function (err, data) {
47.             if (err) {
48.                 return console.log(err)
49.             }
50.             resolve(data)
51.         })
52.     })
53. }
56. // 2. 创建服务
57. // req(request):本次请求  res(response):本次响应     每次收到浏览器的请求,它就会执行一次回调
58. const server = http.createServer(function (req, res) {
59.     const { method, url } = req
60.     // 接收到请求数据
61.     if (method === 'POST' && url === '/sendCurrentTemp') {
62.         //创建空字符叠加数据片段
63.         var data = '';
64.         //2.注册data事件接收数据（每当收到一段表单提交的数据，该方法会执行一次）
65.         req.on('data', (chunk) => {
66.             // chunk 默认是一个二进制数据，和 data 拼接会自动 toString
67.             data += chunk;
68.         })
69.         req.on('end', () => {
70.             try {
71.                 console.log(data)
72.                 const info = JSON.parse(data)
73.                 appendTemp(info.temp)
74.                 res.end('{status:200}');
75.             } catch (e) {
76.                 console.error(e)
77.             }
78.         })
79.     }
80.     const { pathname, path } = urlInfo.parse(req.url)
81.     if (method === 'GET' && pathname === '/getTemp') {
82.         // 返回查询的信息
83.         selectTemp(param2Obj(path)).then(list => {
84.             let retObj = {
85.                 status: 200,
86.                 list
87.             }
88.             res.end(JSON.stringify(retObj));
89.         })
90.     }
92.     // 获取数据请求
93. });
96. // 3. 启动服务
97. server.listen(PORT_NUMBER, function () {
98.     console.log(`服务器启动成功，请在http://${getIpAddress()}:${PORT_NUMBER}中访问....`)
99. });
102. /** 获取当前ip地址 */
103. function getIpAddress() {
104.     var ifaces = os.networkInterfaces()
105.     for (var dev in ifaces) {
106.         let iface = ifaces[dev]
107.         for (let i = 0; i < iface.length; i++) {
108.             let { family, address, internal } = iface[i]
109.             if (family === 'IPv4' && address !== '127.0.0.1' && !internal) {
110.                 return address
111.             }
112.         }
113.     }
114. }
117. function param2Obj(url) {
118.     const search = url.split('?')[1]
119.     if (!search) {
120.         return {}
121.     }
122.     const paramObj = JSON.parse('{"' + (search).replace(/"/g, '\"').replace(/&/g, '","').replace(/=/g, '":"') + '"}')
123.     Object.keys(paramObj).map(key => {
124.         paramObj[key] = decodeURIComponent(paramObj[key])
125.     })
126.     return paramObj
127. }

复制代码

数据展示

使用vue写一个页面，去从服务拉取到数据

• 展示曲线
  
• 展示所有数据分页展示（后期想加个图片，每隔一段时间上传一个图片，搞一个延迟摄影的效果）
  

全部代码地址

最后放一张效果图吧


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！