Official reference client implementation for Cumulocity SmartREST on u-blox C027.
Dependencies: C027_Support C12832 LM75B MMA7660 MbedSmartRest mbed-rtos mbed
Fork of MbedSmartRestMain by
measurement/SignalQualityMeasurement.cpp@96:5dfdc8568e9f, 2015-04-27 (annotated)
- Committer:
- xinlei
- Date:
- Mon Apr 27 10:50:21 2015 +0000
- Revision:
- 96:5dfdc8568e9f
- Parent:
- 94:61d44636f020
- Child:
- 100:47ea098f8a47
LCDDisplay now is singleton
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Cumulocity | 41:804f6a0bda26 | 1 | #include "SignalQualityMeasurement.h" |
Cumulocity | 41:804f6a0bda26 | 2 | #include "ComposedRecord.h" |
Cumulocity | 41:804f6a0bda26 | 3 | #include "CharValue.h" |
Cumulocity | 41:804f6a0bda26 | 4 | #include "IntegerValue.h" |
Cumulocity | 41:804f6a0bda26 | 5 | #include "FloatValue.h" |
xinlei | 96:5dfdc8568e9f | 6 | #include "LCDDisplay.h" |
xinlei | 72:c5709ae7b193 | 7 | #include "logging.h" |
Cumulocity | 41:804f6a0bda26 | 8 | |
xinlei | 82:ca7430f50b2b | 9 | #define THRESHOLD_PERCENT_SIG 0.06 // Percentage cut-off for avoiding sending similar signal sensor data. |
xinlei | 73:313975bfec96 | 10 | // Time interval for forcing a sending even if analog sensor readings are constantly similar (in seconds). |
xinlei | 73:313975bfec96 | 11 | #define TIME_LIMIT_SIG 900 |
xinlei | 71:063c45e99578 | 12 | |
xinlei | 93:0acd11870c6a | 13 | SignalQualityMeasurement::SignalQualityMeasurement(AbstractSmartRest& client, |
xinlei | 96:5dfdc8568e9f | 14 | SmartRestTemplate& tpl, long& deviceId, DeviceInfo& deviceInfo) : |
xinlei | 74:ca3001991fdc | 15 | _deviceId(deviceId), |
Cumulocity | 41:804f6a0bda26 | 16 | _tpl(tpl), |
xinlei | 74:ca3001991fdc | 17 | _client(client), |
xinlei | 96:5dfdc8568e9f | 18 | _deviceInfo(deviceInfo) |
Cumulocity | 41:804f6a0bda26 | 19 | { |
Cumulocity | 41:804f6a0bda26 | 20 | _init = false; |
xinlei | 71:063c45e99578 | 21 | oldValues[0] = 0; |
xinlei | 71:063c45e99578 | 22 | oldValues[1] = 0; |
xinlei | 94:61d44636f020 | 23 | t_start = time(NULL); |
Cumulocity | 41:804f6a0bda26 | 24 | } |
Cumulocity | 41:804f6a0bda26 | 25 | |
Cumulocity | 41:804f6a0bda26 | 26 | bool SignalQualityMeasurement::init() |
Cumulocity | 41:804f6a0bda26 | 27 | { |
Cumulocity | 41:804f6a0bda26 | 28 | if (_init) |
Cumulocity | 41:804f6a0bda26 | 29 | return false; |
Cumulocity | 41:804f6a0bda26 | 30 | |
Cumulocity | 41:804f6a0bda26 | 31 | // Insert measurement |
Cumulocity | 41:804f6a0bda26 | 32 | // USAGE: 104,<DEVICE/ID>,<RSSI>,<BER> |
Cumulocity | 41:804f6a0bda26 | 33 | if (!_tpl.add("10,104,POST,/measurement/measurements,application/vnd.com.nsn.cumulocity.measurement+json,application/vnd.com.nsn.cumulocity.measurement+json,%%,NOW UNSIGNED NUMBER UNSIGNED,\"{\"\"time\"\":\"\"%%\"\",\"\"source\"\":{\"\"id\"\":\"\"%%\"\"},\"\"type\"\":\"\"c8y_SignalStrength\"\",\"\"c8y_SignalStrength\"\":{\"\"rssi\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"dBm\"\"},\"\"ber\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"%\"\"}}}\"\r\n")) |
Cumulocity | 41:804f6a0bda26 | 34 | return false; |
Cumulocity | 41:804f6a0bda26 | 35 | |
Cumulocity | 41:804f6a0bda26 | 36 | _init = true; |
Cumulocity | 41:804f6a0bda26 | 37 | return true; |
Cumulocity | 41:804f6a0bda26 | 38 | } |
Cumulocity | 41:804f6a0bda26 | 39 | |
Cumulocity | 41:804f6a0bda26 | 40 | bool SignalQualityMeasurement::run() |
Cumulocity | 41:804f6a0bda26 | 41 | { |
xinlei | 86:b49c4cfecc43 | 42 | static char signal[25] = {0}; |
xinlei | 93:0acd11870c6a | 43 | DeviceInfo::SignalQuality *signalQuality; |
Cumulocity | 41:804f6a0bda26 | 44 | if ((signalQuality = _deviceInfo.signalQuality()) == NULL) |
Cumulocity | 41:804f6a0bda26 | 45 | return false; |
xinlei | 86:b49c4cfecc43 | 46 | if (signalQuality && signalQuality->rssi) |
xinlei | 86:b49c4cfecc43 | 47 | snprintf(signal, sizeof(signal), "Network: %d dBm", signalQuality->rssi); |
xinlei | 86:b49c4cfecc43 | 48 | else |
xinlei | 86:b49c4cfecc43 | 49 | strncpy(signal, "Network: no coverage", sizeof(signal)); |
xinlei | 96:5dfdc8568e9f | 50 | if (strcmp(LCDDisplay::inst().getSecondLine(), signal)) { |
xinlei | 96:5dfdc8568e9f | 51 | LCDDisplay::inst().setSecondLine(signal); |
xinlei | 93:0acd11870c6a | 52 | } |
xinlei | 77:f6717e4eccc4 | 53 | |
xinlei | 77:f6717e4eccc4 | 54 | int data[2] = {signalQuality->rssi, signalQuality->ber}; |
xinlei | 71:063c45e99578 | 55 | if (abs(oldValues[0]-data[0]) <= abs(oldValues[0])*THRESHOLD_PERCENT_SIG && |
xinlei | 71:063c45e99578 | 56 | abs(oldValues[1]-data[1]) <= abs(oldValues[1])*THRESHOLD_PERCENT_SIG) { |
xinlei | 94:61d44636f020 | 57 | time_t t_interval = time(NULL) - t_start; |
xinlei | 94:61d44636f020 | 58 | if (t_interval < TIME_LIMIT_SIG) { |
xinlei | 96:5dfdc8568e9f | 59 | if (strcmp(LCDDisplay::inst().getThirdLine(), "")) { |
xinlei | 96:5dfdc8568e9f | 60 | LCDDisplay::inst().setThirdLine(""); |
xinlei | 85:5dc5a50e4b06 | 61 | } |
xinlei | 71:063c45e99578 | 62 | return true; |
xinlei | 71:063c45e99578 | 63 | } else { |
xinlei | 94:61d44636f020 | 64 | aDebug("Signal: Timeout at %d s.\n", t_interval); |
xinlei | 77:f6717e4eccc4 | 65 | } |
xinlei | 77:f6717e4eccc4 | 66 | } |
xinlei | 77:f6717e4eccc4 | 67 | |
xinlei | 73:313975bfec96 | 68 | char status[25] = {0}; |
xinlei | 93:0acd11870c6a | 69 | snprintf(status, 25, "Send dBm %d,%d", data[0], data[1]); |
xinlei | 96:5dfdc8568e9f | 70 | LCDDisplay::inst().setThirdLine(status); |
Cumulocity | 41:804f6a0bda26 | 71 | ComposedRecord record; |
Cumulocity | 41:804f6a0bda26 | 72 | IntegerValue msgId(104); |
Cumulocity | 41:804f6a0bda26 | 73 | IntegerValue devId(_deviceId); |
Cumulocity | 41:804f6a0bda26 | 74 | IntegerValue rssi(signalQuality->rssi); |
Cumulocity | 41:804f6a0bda26 | 75 | IntegerValue ber(signalQuality->ber); |
Cumulocity | 41:804f6a0bda26 | 76 | if ((!record.add(msgId)) || (!record.add(devId)) || (!record.add(rssi)) || (!record.add(ber))) |
Cumulocity | 41:804f6a0bda26 | 77 | return false; |
Cumulocity | 41:804f6a0bda26 | 78 | |
xinlei | 94:61d44636f020 | 79 | time_t t0 = time(NULL); |
Cumulocity | 41:804f6a0bda26 | 80 | if (_client.send(record) != SMARTREST_SUCCESS) { |
xinlei | 93:0acd11870c6a | 81 | aWarning("Signal: Send failed.\n"); |
Cumulocity | 41:804f6a0bda26 | 82 | _client.stop(); |
Cumulocity | 41:804f6a0bda26 | 83 | return false; |
Cumulocity | 41:804f6a0bda26 | 84 | } |
xinlei | 94:61d44636f020 | 85 | time_t t1 = time(NULL); |
Cumulocity | 41:804f6a0bda26 | 86 | _client.stop(); |
xinlei | 94:61d44636f020 | 87 | aDebug("Signal: Sent in %d s.\n", t1-t0); |
xinlei | 71:063c45e99578 | 88 | oldValues[0] = data[0]; |
xinlei | 71:063c45e99578 | 89 | oldValues[1] = data[1]; |
xinlei | 94:61d44636f020 | 90 | t_start = time(NULL); |
Cumulocity | 41:804f6a0bda26 | 91 | return true; |
Cumulocity | 41:804f6a0bda26 | 92 | } |