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/TemperatureMeasurement.cpp
- Committer:
- xinlei
- Date:
- 2015-02-25
- Revision:
- 76:b07effe83fb8
- Parent:
- 74:ca3001991fdc
- Child:
- 77:f6717e4eccc4
File content as of revision 76:b07effe83fb8:
#include "TemperatureMeasurement.h" #include "ComposedRecord.h" #include "CharValue.h" #include "IntegerValue.h" #include "FloatValue.h" #include "logging.h" #define THRESHOLD_PERCENT_TEMP 0.02 // Percentage cut-off for avoiding sending similar temperature sensor data. // Time interval for forcing a sending even if analog sensor readings are constantly similar (in seconds). #define TIME_LIMIT_TEMP 900 TemperatureMeasurement::TemperatureMeasurement(AbstractSmartRest& client, SmartRestTemplate& tpl, long& deviceId, LM75B& sensor, DeviceIO& io, DeviceInfo& deviceInfo, DeviceBootstrap& bootstrap) : _client(client), _tpl(tpl), _deviceId(deviceId), _sensor(sensor), oldValue(0), _io(io), _deviceInfo(deviceInfo), _bootstrap(bootstrap) { _init = false; sendingTimer.start(); } bool TemperatureMeasurement::init() { if (_init) return false; // Insert measurement // USAGE: 105,<DEVICE/ID>,<TEMPERATURE> if (!_tpl.add("10,105,POST,/measurement/measurements,application/vnd.com.nsn.cumulocity.measurement+json,application/vnd.com.nsn.cumulocity.measurement+json,%%,NOW UNSIGNED NUMBER,\"{\"\"time\"\":\"\"%%\"\",\"\"source\"\":{\"\"id\"\":\"\"%%\"\"},\"\"type\"\":\"\"c8y_TemperatureMeasurement\"\",\"\"c8y_TemperatureMeasurement\"\":{\"\"T\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"C\"\"}}}\"\r\n")) return false; _open = _sensor.open(); _init = true; return true; } bool TemperatureMeasurement::run() { if (!_open) return false; float data = 0; data = _sensor.temp(); char tenant[25] = {0}; const char* user= _bootstrap.username(); int len = strchr(user, '/')-user+1+8; // 8: length of "Tenant: "; len = len <= 25 ? len : 25; snprintf(tenant, len, "Tenant: %s", user); char signal[25] = {0}; if (_deviceInfo.signalQuality()) snprintf(signal, 25, "Network: %d dBm", _deviceInfo.signalQuality()->rssi); else strncpy(signal, "Network: ? dBm", 25); if (abs(oldValue-data) <= abs(oldValue)*THRESHOLD_PERCENT_TEMP) { if (sendingTimer.read() < TIME_LIMIT_TEMP) { _io.lcdPrint(tenant, signal); aDebug("Similar temperature readings found, no sending!\r\n"); return true; } else { aDebug("Sending timer of temperature sensor timed out at %f s, a sending is forced.\r\n", sendingTimer.read()); } } char status[25] = {0}; snprintf(status, 25, "Sending Temp %.1f", data); _io.lcdPrint(tenant, signal, status); ComposedRecord record; IntegerValue msgId(105); IntegerValue devId(_deviceId); FloatValue temperature(data, 1); if ((!record.add(msgId)) || (!record.add(devId)) || (!record.add(temperature))) return false; float t_start = sendingTimer.read(); if (_client.send(record) != SMARTREST_SUCCESS) { aWarning("Sending temperature readings failed.\r\n"); _client.stop(); return false; } float t_end = sendingTimer.read(); _client.stop(); aInfo("Temperature readings sent in %.1f.\r\n", t_end-t_start); oldValue = data; sendingTimer.reset(); return true; }