Viktor Shin
Initial release
Diff: main.cpp
- Revision:
- 0:3e84b0310c96
- Child:
- 1:0a30ef7e2613
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp Thu Feb 13 00:03:24 2020 +0000
@@ -0,0 +1,481 @@
+
+/* mbed Example Program
+ * Copyright (c) 2006-2014 ARM Limited
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "mbed.h"
+
+#include "Dht11.h"
+
+// ----------------------------------------------------------------------------------------------------
+// Define
+// ----------------------------------------------------------------------------------------------------
+/* Default setting */
+#define ON 1
+#define OFF 0
+#define ENABLE 1
+#define DISABLE 0
+#define RET_OK 1
+#define RET_NOK -1
+
+/* Pin configuraiton */
+#define MBED_CONF_WIZFI360_TX D8
+#define MBED_CONF_WIZFI360_RX D2
+#define MBED_CONF_WIZFI360_RESET D9
+#define MBED_CONF_WIZFI360_SENSOR_CDS A0
+#define MBED_CONF_WIZFI360_SENSOR_DHT D14
+
+/* Serial setting */
+#define WIZFI360_DEFAULT_BAUD_RATE 115200
+
+/* Parser setting */
+#define WIZFI360_PARSER_DELIMITER "\r\n"
+
+/* Debug message setting */
+#define DEBUG_ENABLE 1
+#define DEBUG_DISABLE 0
+
+#define WIZFI360_PARSER_DEBUG DEBUG_DISABLE
+
+/* Timeout setting */
+#define WIZFI360_DEFAULT_TIMEOUT 1000
+
+/* Wi-Fi */
+#define STATION 1
+#define SOFTAP 2
+#define STATION_SOFTAP 3
+
+#define WIFI_MODE STATION
+
+/* MQTT */
+#define MQTT_PORT 8883
+
+// ----------------------------------------------------------------------------------------------------
+// Variables
+// ----------------------------------------------------------------------------------------------------
+Serial pc(USBTX, USBRX);
+
+UARTSerial *_serial;
+ATCmdParser *_parser;
+
+DigitalOut _RESET_WIZFI360(MBED_CONF_WIZFI360_RESET);
+AnalogIn _cdsVal(MBED_CONF_WIZFI360_SENSOR_CDS);
+Dht11 _dhtVal(MBED_CONF_WIZFI360_SENSOR_DHT);
+
+/* Sensor info */
+struct sensor
+{
+ int ill; // illuminance
+ int cel; // celsius
+ float fah; // fahrenheit
+ int hum; // humidity
+};
+
+/* WiFi info */
+char ssid[] = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";
+char password[] = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";
+
+/* MQTT info */
+char hub_name[] = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";
+char device_id[] = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";
+char device_primary_key[] = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";
+
+// ----------------------------------------------------------------------------------------------------
+// Functions
+// ----------------------------------------------------------------------------------------------------
+/* Util */
+void delay(int ms);
+
+/* Serial */
+void serialPcInit(void);
+void serialDeviceInit(PinName tx, PinName rx, int baudrate);
+void serialAtParserInit(const char *delimiter, bool debug_en);
+
+/* Device */
+void deviceInit_WizFi360(void);
+void deviceReset_WizFi360(void);
+void deviceIsReady_WizFi360(void);
+
+/* Sensor */
+int deviceGetIllVal_WizFi360(void);
+int deviceGetCelVal_WizFi360(void);
+float deviceGetFahVal_WizFi360(void);
+int deviceGetHumVal_WizFi360(void);
+
+/* Wi-Fi */
+int8_t deviceSetWifiMode_WizFi360(int mode);
+int8_t deviceSetDhcp_WizFi360(int mode, int en_dhcp);
+int8_t deviceConnAP_WizFi360(int mode, char *ssid, char *password);
+
+/* MQTT */
+int8_t deviceSetAzureConf_WizFi360(char *iot_hub, char *device_id, char *sas_token);
+int8_t devicePublishMsg_WizFi360(char *device_id, sensor *sensor_info);
+int8_t deviceAzureCon_WizFi360();
+int8_t deviceSetTopic_WizFi360(char *device_id);
+
+
+// ----------------------------------------------------------------------------------------------------
+// Main
+// ----------------------------------------------------------------------------------------------------
+int main()
+{
+ sensor sensor_info;
+
+ /* Set serial */
+ serialPcInit();
+
+ /* Set device */
+ deviceInit_WizFi360();
+ deviceReset_WizFi360();
+ deviceIsReady_WizFi360();
+
+ /* Set Wi-Fi */
+ deviceSetWifiMode_WizFi360(WIFI_MODE);
+ deviceSetDhcp_WizFi360(WIFI_MODE, ENABLE);
+ deviceConnAP_WizFi360(WIFI_MODE, ssid, password);
+
+ /* Set MQTT */
+
+ deviceSetAzureConf_WizFi360(hub_name,device_id,device_primary_key);
+ deviceSetTopic_WizFi360(device_id);
+ deviceAzureCon_WizFi360();
+
+ //deviceSetMqttConnConf_WizFi360(host_name, device_id, sas_token, alive_time);
+ //deviceSetTopic_WizFi360(device_id);
+ //deviceConnBroker_WizFi360(ENABLE, host_name, MQTT_PORT);
+
+ while(true)
+ {
+ /* Get sensor info */
+ sensor_info.ill = deviceGetIllVal_WizFi360();
+ sensor_info.cel = deviceGetCelVal_WizFi360();
+ sensor_info.fah = deviceGetFahVal_WizFi360();
+ sensor_info.hum = deviceGetHumVal_WizFi360();
+
+ /* Publish message */
+ devicePublishMsg_WizFi360(device_id, &sensor_info);
+
+ delay(3000);
+ }
+}
+
+// ----------------------------------------------------------------------------------------------------
+// Functions : Util
+// ----------------------------------------------------------------------------------------------------
+void delay(int ms)
+{
+ wait_us(ms * 1000);
+}
+
+// ----------------------------------------------------------------------------------------------------
+// Functions : Serial
+// ----------------------------------------------------------------------------------------------------
+void serialPcInit(void)
+{
+ pc.baud(115200);
+ pc.format(8, Serial::None, 1);
+}
+
+void serialDeviceInit(PinName tx, PinName rx, int baudrate)
+{
+ _serial = new UARTSerial(tx, rx, baudrate);
+}
+
+void serialAtParserInit(const char *delimiter, bool debug_en)
+{
+ _parser = new ATCmdParser(_serial);
+ _parser->debug_on(debug_en);
+ _parser->set_delimiter(delimiter);
+ _parser->set_timeout(WIZFI360_DEFAULT_TIMEOUT);
+}
+
+// ----------------------------------------------------------------------------------------------------
+// Functions : Device
+// ----------------------------------------------------------------------------------------------------
+void deviceInit_WizFi360(void)
+{
+ serialDeviceInit(MBED_CONF_WIZFI360_TX, MBED_CONF_WIZFI360_RX, WIZFI360_DEFAULT_BAUD_RATE);
+ serialAtParserInit(WIZFI360_PARSER_DELIMITER, WIZFI360_PARSER_DEBUG);
+}
+
+void deviceReset_WizFi360(void)
+{
+ _RESET_WIZFI360 = 1;
+ delay(300);
+
+ _RESET_WIZFI360 = 0;
+ delay(400);
+
+ _RESET_WIZFI360 = 1;
+ delay(1000);
+}
+
+void deviceIsReady_WizFi360(void)
+{
+ while(1)
+ {
+ if(_parser->recv("ready"))
+ {
+ pc.printf("WizFi360 is available\r\n");
+
+ return;
+ }
+ else if(_parser->send("AT") && _parser->recv("OK"))
+ {
+ pc.printf("WizFi360 is already available\r\n");
+
+ return;
+ }
+ else
+ {
+ pc.printf("WizFi360 is not available\r\n");
+
+ return;
+ }
+ }
+}
+
+// ----------------------------------------------------------------------------------------------------
+// Functions : Sensor
+// ----------------------------------------------------------------------------------------------------
+/* illuminance */
+int deviceGetIllVal_WizFi360(void)
+{
+ int val = _cdsVal.read_u16() / 100;
+
+ return val;
+}
+
+/* celsius */
+int deviceGetCelVal_WizFi360(void)
+{
+ _dhtVal.read();
+
+ int val = _dhtVal.getCelsius();
+
+ return val;
+}
+
+/* fahrenheit */
+float deviceGetFahVal_WizFi360(void)
+{
+ _dhtVal.read();
+
+ int val = _dhtVal.getFahrenheit();
+
+ return val;
+}
+
+/* humidity */
+int deviceGetHumVal_WizFi360(void)
+{
+ _dhtVal.read();
+
+ int val = _dhtVal.getHumidity();
+
+ return val;
+}
+
+// ----------------------------------------------------------------------------------------------------
+// Functions : Wi-Fi
+// ----------------------------------------------------------------------------------------------------
+int8_t deviceSetWifiMode_WizFi360(int mode)
+{
+ int8_t ret = RET_NOK;
+
+ if(_parser->send("AT+CWMODE_CUR=%d", mode) && _parser->recv("OK"))
+ {
+ pc.printf("Set Wi-Fi mode : %d\r\n", mode);
+
+ ret = RET_OK;
+ }
+ else
+ {
+ pc.printf("Set Wi-Fi mode : ERROR\r\n");
+ }
+
+ return ret;
+}
+
+int8_t deviceSetDhcp_WizFi360(int mode, int en_dhcp)
+{
+ int8_t ret = RET_NOK;
+ int mode_dhcp;
+
+ if(mode == STATION)
+ {
+ mode_dhcp = 1;
+ }
+ else if(mode == SOFTAP)
+ {
+ mode_dhcp = 0;
+ }
+ else if(mode == STATION_SOFTAP)
+ {
+ mode_dhcp = 2;
+ }
+ else
+ {
+ pc.printf("Set DHCP : ERROR\r\n");
+ }
+
+ if(_parser->send("AT+CWDHCP_CUR=%d,%d", mode_dhcp, en_dhcp) && _parser->recv("OK"))
+ {
+ pc.printf("Set DHCP : %d, %d\r\n", mode_dhcp, en_dhcp);
+
+ ret = RET_OK;
+ }
+ else
+ {
+ pc.printf("Set DHCP : ERROR\r\n");
+ }
+
+ return ret;
+}
+
+int8_t deviceConnAP_WizFi360(int mode, char *ssid, char *password)
+{
+ int8_t ret = RET_NOK;
+ bool done = false;
+ Timer t;
+
+ if((mode == STATION) || (mode == STATION_SOFTAP))
+ {
+ _parser->send("AT+CWJAP_CUR=\"%s\",\"%s\"", ssid ,password);
+
+ t.start();
+
+ while(done != true)
+ {
+ done = (_parser->recv("WIFI CONNECTED") && _parser->recv("WIFI GOT IP") && _parser->recv("OK"));
+
+ if(t.read_ms() >= (WIZFI360_DEFAULT_TIMEOUT * 20))
+ {
+ t.stop();
+ t.reset();
+
+ break;
+ }
+ }
+
+ if(done)
+ {
+ pc.printf("Connect AP : %s, %s\r\n", ssid, password);
+
+ ret = RET_OK;
+ }
+ else
+ {
+ pc.printf("Connect AP : ERROR\r\n");
+ }
+ }
+ else
+ {
+ pc.printf("Connect AP : ERROR\r\n");
+ }
+
+ return ret;
+}
+
+// ----------------------------------------------------------------------------------------------------
+// Functions : MQTT
+// ----------------------------------------------------------------------------------------------------
+
+int8_t deviceSetAzureConf_WizFi360(char *iot_hub, char *device_id, char *sas_token)
+{
+ int8_t ret = RET_NOK;
+
+ if(_parser->send("AT+AZSET=\"%s\",\"%s\",\"%s\"", iot_hub, device_id, sas_token) && _parser->recv("OK"))
+ {
+ pc.printf("Azure Set configuration : %s, %s, %s\r\n", iot_hub, device_id, sas_token);
+
+ ret = RET_OK;
+ }
+ else
+ {
+ pc.printf("Azure Set configuration : ERROR\r\n");
+ }
+
+ return ret;
+
+}
+
+
+
+int8_t deviceSetTopic_WizFi360(char *device_id)
+{
+ int8_t ret = RET_NOK;
+
+ if(_parser->send("AT+MQTTTOPIC=\"devices/%s/messages/events/\",\"devices/%s/messages/devicebound/#\"", device_id, device_id) && _parser->recv("OK"))
+ {
+ pc.printf("Set topic : %s\r\n", device_id);
+
+ ret = RET_OK;
+ }
+ else
+ {
+ pc.printf("Set topic : ERROR\r\n");
+ }
+
+ return ret;
+}
+
+int8_t deviceAzureCon_WizFi360()
+{
+ int8_t ret = RET_NOK;
+ bool done = false;
+ Timer t;
+
+ _parser->send("AT+AZCON");
+
+ t.start();
+
+ while(done != true)
+ {
+ done = (_parser->recv("CONNECT") && _parser->recv("OK"));
+
+ if(t.read_ms() >= (WIZFI360_DEFAULT_TIMEOUT * 3))
+ {
+ t.stop();
+ t.reset();
+
+ break;
+ }
+ }
+
+ if(done)
+ {
+ pc.printf("Connected to Azure successfully\r\n");
+
+ ret = RET_OK;
+ }
+ else
+ {
+ pc.printf("Connection to Azure failed: ERROR\r\n");
+ }
+
+ return ret;
+}
+
+int8_t devicePublishMsg_WizFi360(char *device_id, sensor *sensor_info)
+{
+ int8_t ret = RET_NOK;
+
+ if(_parser->send("AT+MQTTPUB=\"{\"deviceId\":\"%s\",\"temperature\":%d,\"humidity\":%d}\"",device_id, sensor_info->cel, sensor_info->hum))
+ {
+ pc.printf("Publish message : %d, %d\r\n", sensor_info->cel, sensor_info->hum);
+ }
+
+ return ret;
+}
\ No newline at end of file