Yu Han / Mbed 2 deprecated Raingauge_final_2019

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   libmDot mbed mbed-rtos

main.cpp@0:b11d24dd30ea, 2019-01-23 (annotated)

Committer:
yurbaggio
Date:
Wed Jan 23 02:02:23 2019 +0000
Revision:
0:b11d24dd30ea
Post Mark

Who changed what in which revision?

UserRevisionLine numberNew contents of line
yurbaggio 0:b11d24dd30ea 1 #include "mbed.h"
yurbaggio 0:b11d24dd30ea 2 #include "mDot.h"
yurbaggio 0:b11d24dd30ea 3 #include "MTSLog.h"
yurbaggio 0:b11d24dd30ea 4 #include <string>
yurbaggio 0:b11d24dd30ea 5 #include <vector>
yurbaggio 0:b11d24dd30ea 6 #include <algorithm>
yurbaggio 0:b11d24dd30ea 7 #include <sstream>
yurbaggio 0:b11d24dd30ea 8 #include <iomanip>
yurbaggio 0:b11d24dd30ea 9
yurbaggio 0:b11d24dd30ea 10
yurbaggio 0:b11d24dd30ea 11 // AppEUI
yurbaggio 0:b11d24dd30ea 12 static uint8_t AppEUI[8]={0x11, 0x22, 0x33, 0x44, 0x55, 0x66, 0x77, 0x88};
yurbaggio 0:b11d24dd30ea 13 // AppKey
yurbaggio 0:b11d24dd30ea 14 static uint8_t AppKey[16]={0x11, 0x22, 0x33, 0x44, 0x55, 0x66, 0x77, 0x88, 0x11, 0x22, 0x33, 0x44, 0x55, 0x66, 0x77, 0x88};
yurbaggio 0:b11d24dd30ea 15
yurbaggio 0:b11d24dd30ea 16 // AppEUI
yurbaggio 0:b11d24dd30ea 17 //static uint8_t AppEUI[8]={0x70, 0xB3, 0xD5, 0x7E, 0xD0, 0x01, 0x07, 0xDF};
yurbaggio 0:b11d24dd30ea 18 // AppKey
yurbaggio 0:b11d24dd30ea 19 //static uint8_t AppKey[16]={0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11, 0x11};
yurbaggio 0:b11d24dd30ea 20
yurbaggio 0:b11d24dd30ea 21 static uint8_t config_frequency_sub_band = 3;
yurbaggio 0:b11d24dd30ea 22
yurbaggio 0:b11d24dd30ea 23
yurbaggio 0:b11d24dd30ea 24 InterruptIn pulseInterrupt(PC_13);
yurbaggio 0:b11d24dd30ea 25 DigitalOut greenLed(LED1); // To turn the join LED on/off
yurbaggio 0:b11d24dd30ea 26
yurbaggio 0:b11d24dd30ea 27 int pulseCount;
yurbaggio 0:b11d24dd30ea 28 int IRQ;
yurbaggio 0:b11d24dd30ea 29
yurbaggio 0:b11d24dd30ea 30 void highPulseDetected() {
yurbaggio 0:b11d24dd30ea 31 IRQ=1;
yurbaggio 0:b11d24dd30ea 32 }
yurbaggio 0:b11d24dd30ea 33
yurbaggio 0:b11d24dd30ea 34 void no_highPulseDetected() {
yurbaggio 0:b11d24dd30ea 35 IRQ = 0;
yurbaggio 0:b11d24dd30ea 36 }
yurbaggio 0:b11d24dd30ea 37
yurbaggio 0:b11d24dd30ea 38 mDot* dot;
yurbaggio 0:b11d24dd30ea 39
yurbaggio 0:b11d24dd30ea 40 int main() {
yurbaggio 0:b11d24dd30ea 41
yurbaggio 0:b11d24dd30ea 42 Serial pc(USBTX, USBRX);
yurbaggio 0:b11d24dd30ea 43 // Set up the network
yurbaggio 0:b11d24dd30ea 44
yurbaggio 0:b11d24dd30ea 45 pc.baud(115200);
yurbaggio 0:b11d24dd30ea 46 pc.printf("TTN OTAA mDot LoRa Raingauge sensor\n\r");
yurbaggio 0:b11d24dd30ea 47
yurbaggio 0:b11d24dd30ea 48 greenLed = 1; // LED is ON
yurbaggio 0:b11d24dd30ea 49 wait_ms(2000); // 200 ms
yurbaggio 0:b11d24dd30ea 50 greenLed = 0;
yurbaggio 0:b11d24dd30ea 51
yurbaggio 0:b11d24dd30ea 52 int32_t ret;
yurbaggio 0:b11d24dd30ea 53
yurbaggio 0:b11d24dd30ea 54 std::ostringstream ss;
yurbaggio 0:b11d24dd30ea 55
yurbaggio 0:b11d24dd30ea 56 std::vector<uint8_t> nwkId;
yurbaggio 0:b11d24dd30ea 57 std::vector<uint8_t> nwkKey;
yurbaggio 0:b11d24dd30ea 58
yurbaggio 0:b11d24dd30ea 59 // get a mDot handle
yurbaggio 0:b11d24dd30ea 60 dot = mDot::getInstance();
yurbaggio 0:b11d24dd30ea 61
yurbaggio 0:b11d24dd30ea 62 // print library version information
yurbaggio 0:b11d24dd30ea 63 logInfo("Version: %s", dot->getId().c_str());
yurbaggio 0:b11d24dd30ea 64
yurbaggio 0:b11d24dd30ea 65 // reset to default config so we know what state we're in
yurbaggio 0:b11d24dd30ea 66 dot->resetConfig();
yurbaggio 0:b11d24dd30ea 67
yurbaggio 0:b11d24dd30ea 68 dot->setJoinByteOrder(mDot::LSB);
yurbaggio 0:b11d24dd30ea 69
yurbaggio 0:b11d24dd30ea 70 dot->setLogLevel(mts::MTSLog::INFO_LEVEL);
yurbaggio 0:b11d24dd30ea 71
yurbaggio 0:b11d24dd30ea 72 //joinmode: [MANUAL = ABP]/[OTA]/[AUTO_OTA]
yurbaggio 0:b11d24dd30ea 73 dot->setJoinMode(mDot::AUTO_OTA);
yurbaggio 0:b11d24dd30ea 74
yurbaggio 0:b11d24dd30ea 75 // set up the mDot with our network information: frequency sub band, network name, and network password
yurbaggio 0:b11d24dd30ea 76 // these can all be saved in NVM so they don't need to be set every time - see mDot::saveConfig()
yurbaggio 0:b11d24dd30ea 77
yurbaggio 0:b11d24dd30ea 78 // frequency sub band is only applicable in the 915 (US) frequency band
yurbaggio 0:b11d24dd30ea 79 logInfo("Setting frequency sub band");
yurbaggio 0:b11d24dd30ea 80 if ((ret = dot->setFrequencySubBand(config_frequency_sub_band)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 81 logError("Failed to set frequency sub band %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 82 }
yurbaggio 0:b11d24dd30ea 83
yurbaggio 0:b11d24dd30ea 84 std::vector<uint8_t> temp;
yurbaggio 0:b11d24dd30ea 85
yurbaggio 0:b11d24dd30ea 86 if ((ret = dot->setPublicNetwork(true)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 87 logError("Failed to enable public network %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 88 }
yurbaggio 0:b11d24dd30ea 89
yurbaggio 0:b11d24dd30ea 90 uint8_t *it = AppEUI;
yurbaggio 0:b11d24dd30ea 91 for (uint8_t i = 0; i<8; i++)
yurbaggio 0:b11d24dd30ea 92 nwkId.push_back((uint8_t) *it++);
yurbaggio 0:b11d24dd30ea 93
yurbaggio 0:b11d24dd30ea 94 it = AppKey;
yurbaggio 0:b11d24dd30ea 95 for (uint8_t i = 0; i<16; i++)
yurbaggio 0:b11d24dd30ea 96 nwkKey.push_back((uint8_t) *it++);
yurbaggio 0:b11d24dd30ea 97
yurbaggio 0:b11d24dd30ea 98 logInfo("Set Network Id");
yurbaggio 0:b11d24dd30ea 99 if ((ret = dot->setNetworkId(nwkId)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 100 logError("Failed to set Network Id %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 101 }
yurbaggio 0:b11d24dd30ea 102
yurbaggio 0:b11d24dd30ea 103 logInfo("Set Network Key");
yurbaggio 0:b11d24dd30ea 104 if ((ret = dot->setNetworkKey(nwkKey)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 105 logError("Failed to set Network Id %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 106 }
yurbaggio 0:b11d24dd30ea 107
yurbaggio 0:b11d24dd30ea 108 // a higher spreading factor allows for longer range but lower throughput
yurbaggio 0:b11d24dd30ea 109 // in the 915 (US) frequency band, spreading factors 7 - 10 are available
yurbaggio 0:b11d24dd30ea 110 // in the 868 (EU) frequency band, spreading factors 7 - 12 are available
yurbaggio 0:b11d24dd30ea 111 logInfo("Setting TX spreading factor");
yurbaggio 0:b11d24dd30ea 112 if ((ret = dot->setTxDataRate(mDot::SF_10)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 113 logError("Failed to set TX datarate %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 114 }
yurbaggio 0:b11d24dd30ea 115
yurbaggio 0:b11d24dd30ea 116 // Set configured gain of installed antenna
yurbaggio 0:b11d24dd30ea 117 logInfo("Setting Antenna Gain");
yurbaggio 0:b11d24dd30ea 118 if ((ret = dot->setAntennaGain(5)) != mDot::MDOT_OK){
yurbaggio 0:b11d24dd30ea 119 logError("Failed to set Antenna Gain %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 120 }
yurbaggio 0:b11d24dd30ea 121
yurbaggio 0:b11d24dd30ea 122 // request receive confirmation of packets from the gateway
yurbaggio 0:b11d24dd30ea 123 logInfo("Disabling ACKs");
yurbaggio 0:b11d24dd30ea 124 if ((ret = dot->setAck(0)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 125 logError("Failed to enable ACKs %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 126 }
yurbaggio 0:b11d24dd30ea 127
yurbaggio 0:b11d24dd30ea 128 // save this configuration to the mDot's NVM
yurbaggio 0:b11d24dd30ea 129 logInfo("Saving config");
yurbaggio 0:b11d24dd30ea 130 if (! dot->saveConfig()) {
yurbaggio 0:b11d24dd30ea 131 logError("Failed to save configuration");
yurbaggio 0:b11d24dd30ea 132 }
yurbaggio 0:b11d24dd30ea 133
yurbaggio 0:b11d24dd30ea 134 logInfo("Joining Network");
yurbaggio 0:b11d24dd30ea 135
yurbaggio 0:b11d24dd30ea 136 while ((ret = dot->joinNetwork()) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 137 logError("failed to join network [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 138 wait_ms(dot->getNextTxMs() + 1);
yurbaggio 0:b11d24dd30ea 139 }
yurbaggio 0:b11d24dd30ea 140
yurbaggio 0:b11d24dd30ea 141 logInfo("Joined Network");
yurbaggio 0:b11d24dd30ea 142
yurbaggio 0:b11d24dd30ea 143 pulseCount=0;
yurbaggio 0:b11d24dd30ea 144 pulseInterrupt.rise(&highPulseDetected);
yurbaggio 0:b11d24dd30ea 145 pulseInterrupt.fall(&no_highPulseDetected);
yurbaggio 0:b11d24dd30ea 146 IRQ=0;
yurbaggio 0:b11d24dd30ea 147
yurbaggio 0:b11d24dd30ea 148 // Message you want to send
yurbaggio 0:b11d24dd30ea 149 std::string data_str = "Hello!";
yurbaggio 0:b11d24dd30ea 150
yurbaggio 0:b11d24dd30ea 151 set_time(1476612300);
yurbaggio 0:b11d24dd30ea 152
yurbaggio 0:b11d24dd30ea 153 time_t start = time(NULL);
yurbaggio 0:b11d24dd30ea 154 time_t end = time(NULL);
yurbaggio 0:b11d24dd30ea 155 int cost;
yurbaggio 0:b11d24dd30ea 156
yurbaggio 0:b11d24dd30ea 157 printf("bbbbbbbbbbbbbegin to collect data.\n\r");
yurbaggio 0:b11d24dd30ea 158 time(&start);
yurbaggio 0:b11d24dd30ea 159
yurbaggio 0:b11d24dd30ea 160 // Start the loop
yurbaggio 0:b11d24dd30ea 161 while (true) {
yurbaggio 0:b11d24dd30ea 162
yurbaggio 0:b11d24dd30ea 163 time_t seconds = time(NULL);
yurbaggio 0:b11d24dd30ea 164 //pc.printf("1. Start Time as a basic string = %s", ctime(&start));
yurbaggio 0:b11d24dd30ea 165 //pc.printf("^^^^^^^^^^^^^^^^^^^^begin to sleep^^^^^^^^^^^^^^^^^^^^Sleep Time = %s", ctime(&seconds));
yurbaggio 0:b11d24dd30ea 166
yurbaggio 0:b11d24dd30ea 167 // Send the MDot to sleep.
yurbaggio 0:b11d24dd30ea 168 dot->sleep(600, mDot::RTC_ALARM_OR_INTERRUPT, false); //////////////////////////////60,3600*24
yurbaggio 0:b11d24dd30ea 169 time(&end);
yurbaggio 0:b11d24dd30ea 170 //pc.printf("^^^^^^^^^^^^^^^^^^^^wake up^^^^^^^^^^^^^^^^^^^^Wakeup Time = %s", ctime(&end));
yurbaggio 0:b11d24dd30ea 171 wait_ms(100);
yurbaggio 0:b11d24dd30ea 172
yurbaggio 0:b11d24dd30ea 173 if(IRQ==1){
yurbaggio 0:b11d24dd30ea 174 IRQ=0;
yurbaggio 0:b11d24dd30ea 175 pulseCount = pulseCount + 1;
yurbaggio 0:b11d24dd30ea 176 //pc.printf("2.data = %d\n\r", pulseCount);
yurbaggio 0:b11d24dd30ea 177 }
yurbaggio 0:b11d24dd30ea 178
yurbaggio 0:b11d24dd30ea 179 cost=(int)difftime(end,start);
yurbaggio 0:b11d24dd30ea 180
yurbaggio 0:b11d24dd30ea 181 //send data every 5000ms
yurbaggio 0:b11d24dd30ea 182 //pc.printf("5.cost = %d\n\r", cost);
yurbaggio 0:b11d24dd30ea 183 if(cost >= 600) { /////////////////////600s = 10min
yurbaggio 0:b11d24dd30ea 184 //pc.printf("3. finish collecting data.\n\r");
yurbaggio 0:b11d24dd30ea 185 //printf("++++++++++++++++++Collecting data takes %d s++++++++++++++++++++\n\r", cost);
yurbaggio 0:b11d24dd30ea 186 time_t seconds = time(NULL);
yurbaggio 0:b11d24dd30ea 187 //pc.printf("4.Finishing Time as a basic string = %s", ctime(&seconds));
yurbaggio 0:b11d24dd30ea 188 if(pulseCount == 0){
yurbaggio 0:b11d24dd30ea 189 pulseCount = pulseCount;
yurbaggio 0:b11d24dd30ea 190 } else {
yurbaggio 0:b11d24dd30ea 191 pulseCount = pulseCount;
yurbaggio 0:b11d24dd30ea 192 }
yurbaggio 0:b11d24dd30ea 193
yurbaggio 0:b11d24dd30ea 194 //pc.printf("pulseCount = %d in 5 seconds.\n\r", pulseCount);
yurbaggio 0:b11d24dd30ea 195
yurbaggio 0:b11d24dd30ea 196 // Copy the message in an array of bytes
yurbaggio 0:b11d24dd30ea 197 std::vector<uint8_t> data;
yurbaggio 0:b11d24dd30ea 198 ss.str("");
yurbaggio 0:b11d24dd30ea 199 data.clear();
yurbaggio 0:b11d24dd30ea 200 ss << pulseCount;
yurbaggio 0:b11d24dd30ea 201 data_str = "12," + ss.str();
yurbaggio 0:b11d24dd30ea 202
yurbaggio 0:b11d24dd30ea 203 for (std::string::iterator it = data_str.begin(); it != data_str.end(); it++)
yurbaggio 0:b11d24dd30ea 204 data.push_back((uint8_t) *it);
yurbaggio 0:b11d24dd30ea 205 // Send the data
yurbaggio 0:b11d24dd30ea 206 if ((ret = dot->send(data)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 207 // Oops, there was an error, check the debug screen
yurbaggio 0:b11d24dd30ea 208 logError("Failed to send", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 209 } else {
yurbaggio 0:b11d24dd30ea 210 // Sent the data
yurbaggio 0:b11d24dd30ea 211 logInfo("Successfully sent data");
yurbaggio 0:b11d24dd30ea 212 }
yurbaggio 0:b11d24dd30ea 213
yurbaggio 0:b11d24dd30ea 214 if ((ret = dot->send(data)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 215 // Oops, there was an error, check the debug screen
yurbaggio 0:b11d24dd30ea 216 logError("Failed to send", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 217 } else {
yurbaggio 0:b11d24dd30ea 218 // Sent the data
yurbaggio 0:b11d24dd30ea 219 logInfo("Successfully sent data2");
yurbaggio 0:b11d24dd30ea 220 }
yurbaggio 0:b11d24dd30ea 221
yurbaggio 0:b11d24dd30ea 222 if ((ret = dot->send(data)) != mDot::MDOT_OK) {
yurbaggio 0:b11d24dd30ea 223 // Oops, there was an error, check the debug screen
yurbaggio 0:b11d24dd30ea 224 logError("Failed to send", ret, mDot::getReturnCodeString(ret).c_str());
yurbaggio 0:b11d24dd30ea 225 } else {
yurbaggio 0:b11d24dd30ea 226 // Sent the data
yurbaggio 0:b11d24dd30ea 227 logInfo("Successfully sent data3");
yurbaggio 0:b11d24dd30ea 228 }
yurbaggio 0:b11d24dd30ea 229
yurbaggio 0:b11d24dd30ea 230 IRQ=0;
yurbaggio 0:b11d24dd30ea 231 pulseCount = 0;
yurbaggio 0:b11d24dd30ea 232
yurbaggio 0:b11d24dd30ea 233 //pc.printf("begin to collect data\n\r");
yurbaggio 0:b11d24dd30ea 234 set_time(1476612300);
yurbaggio 0:b11d24dd30ea 235 }
yurbaggio 0:b11d24dd30ea 236
yurbaggio 0:b11d24dd30ea 237
yurbaggio 0:b11d24dd30ea 238 }//end while
yurbaggio 0:b11d24dd30ea 239
yurbaggio 0:b11d24dd30ea 240 return 0;
yurbaggio 0:b11d24dd30ea 241 }