Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8592ba94aa | ||
|
|
f3e2e0181a | ||
|
|
92c1aaefbe | ||
|
|
08f90010e7 | ||
|
|
d2b821c46e | ||
|
|
4fd870e6d5 | ||
|
|
c61b89d1f1 | ||
|
|
13d58eecc1 | ||
|
|
e26fc4051b | ||
|
|
3f348f2abb | ||
|
|
d4a67b1803 | ||
|
|
4c021ff34a |
@@ -3,3 +3,33 @@
|
|||||||
Code fuer den LoraWAN Node
|
Code fuer den LoraWAN Node
|
||||||
|
|
||||||
Autor: Joerg Lehmann, nbit Informatik GmbH
|
Autor: Joerg Lehmann, nbit Informatik GmbH
|
||||||
|
|
||||||
|
| Parameter | Value |
|
||||||
|
| ----------------- | --------------------------- |
|
||||||
|
| Board | MCCI Catena 4610 |
|
||||||
|
| LoraWAN Subband | "Default, works everywhere" |
|
||||||
|
| Serial interface | Generic Serial |
|
||||||
|
| LoraWAN Network | Swisscom |
|
||||||
|
| System Clock | 24 MHz |
|
||||||
|
| LoraWAN Region | Europe 868 MHz |
|
||||||
|
| Optimize | Smallest (-Os default) |
|
||||||
|
|
||||||
|
Das sind die verwendeten Libraries [1]:
|
||||||
|
|
||||||
|
| URL | Commit | Commit Date |
|
||||||
|
| --- | ----- | ----------- |
|
||||||
|
| https://github.com/mcci-catena/Adafruit_BME280_Library.git | 3dafbe1 | Wed, 13 Dec 2017 13:56:30 -0500 |
|
||||||
|
| https://github.com/mcci-catena/Adafruit_Sensor.git | f2af6f4 | Tue, 1 Sep 2015 15:57:59 +0200 |
|
||||||
|
| https://github.com/mcci-catena/arduino-lmic.git | f67121c | Mon, 10 Feb 2020 10:57:04 -0500 |
|
||||||
|
| https://github.com/mcci-catena/arduino-lorawan.git | a0577e1 | Mon, 10 Feb 2020 13:21:30 -0500 |
|
||||||
|
| https://github.com/mcci-catena/Catena-Arduino-Platform.git | 85c010c | Tue, 11 Feb 2020 19:58:25 -0500 |
|
||||||
|
| https://github.com/mcci-catena/Catena-mcciadk.git | a428006 | Sat, 21 Dec 2019 20:45:26 -0500 |
|
||||||
|
| https://github.com/mcci-catena/MCCI_FRAM_I2C.git | f0a5ea5 | Sat, 21 Dec 2019 16:17:01 -0500 |
|
||||||
|
| https://github.com/tatobari/Q2-HX711-Arduino-Library.git | ccda8d8 | Wed, 13 Mar 2019 12:41:44 -0300 |
|
||||||
|
| https://github.com/mcci-catena/OneWire.git | d814a7b | Thu, 26 Apr 2018 03:45:27 +0800 |
|
||||||
|
| https://github.com/mcci-catena/SHT1x.git | be7042c | Tue, 20 Sep 2011 13:56:23 +1000 |
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
`[1]:
|
||||||
|
[joerg@cinnamon libraries]$ for i in Adafruit_BME280_Library Adafruit_Sensor arduino-lmic arduino-lorawan Catena-Arduino-Platform Catena-mcciadk MCCI_FRAM_I2C Q2-HX711-Arduino-Library OneWire SHT1x ; do cd $i; echo "| $(git remote -v |grep fetch |awk '{print $2}' |tr '\n' ' ') | $(git log --pretty=format:'%h | %cD ' -n 1) |" ; cd ..; done`
|
||||||
|
|||||||
+316
-66
@@ -25,7 +25,7 @@
|
|||||||
#include <cmath>
|
#include <cmath>
|
||||||
#include <type_traits>
|
#include <type_traits>
|
||||||
|
|
||||||
#include <HX711.h>
|
#include <Q2HX711.h>
|
||||||
#include "mini_beieli_node.h"
|
#include "mini_beieli_node.h"
|
||||||
|
|
||||||
using namespace McciCatena;
|
using namespace McciCatena;
|
||||||
@@ -99,6 +99,7 @@ long package_counter = 0; // sent package counter
|
|||||||
bool send_in_progress = false;
|
bool send_in_progress = false;
|
||||||
bool stop_iterations = false;
|
bool stop_iterations = false;
|
||||||
bool next_package_is_init_package = true;
|
bool next_package_is_init_package = true;
|
||||||
|
uint32_t gRebootMs;
|
||||||
|
|
||||||
// generic timer
|
// generic timer
|
||||||
long t_cur;
|
long t_cur;
|
||||||
@@ -131,7 +132,7 @@ Catena_Mx25v8035f gFlash;
|
|||||||
bool fFlash;
|
bool fFlash;
|
||||||
|
|
||||||
// Scales
|
// Scales
|
||||||
HX711 LoadCell;
|
Q2HX711 hx711(A1, A0);
|
||||||
|
|
||||||
// USB power
|
// USB power
|
||||||
bool fUsbPower;
|
bool fUsbPower;
|
||||||
@@ -143,6 +144,11 @@ bool g_fPrintedSleeping = false;
|
|||||||
static osjob_t iterationJob;
|
static osjob_t iterationJob;
|
||||||
static osjob_t sendJob;
|
static osjob_t sendJob;
|
||||||
|
|
||||||
|
// the cycle time to use
|
||||||
|
unsigned gTxCycle;
|
||||||
|
// remaining before we reset to default
|
||||||
|
unsigned gTxCycleCount;
|
||||||
|
|
||||||
void setup(void)
|
void setup(void)
|
||||||
{
|
{
|
||||||
gCatena.begin();
|
gCatena.begin();
|
||||||
@@ -175,7 +181,7 @@ void setup_platform(void)
|
|||||||
if (config_data.debug_level > 0) {
|
if (config_data.debug_level > 0) {
|
||||||
gCatena.SafePrintf("%010d - Reading Calibration Config from FRAM...\n", millis());
|
gCatena.SafePrintf("%010d - Reading Calibration Config from FRAM...\n", millis());
|
||||||
}
|
}
|
||||||
gCatena.getFram()->getField(cFramStorage::kBme680Cal, (uint8_t *)&config_data, sizeof(config_data));
|
gCatena.getFram()->getField(cFramStorage::kAppConf, (uint8_t *)&config_data, sizeof(config_data));
|
||||||
|
|
||||||
if (config_data.debug_level > 0) {
|
if (config_data.debug_level > 0) {
|
||||||
gCatena.SafePrintf("%010d - setup_platform, this is the configuration\n", millis());
|
gCatena.SafePrintf("%010d - setup_platform, this is the configuration\n", millis());
|
||||||
@@ -301,18 +307,8 @@ bool setup_scales(void)
|
|||||||
// Enable Power
|
// Enable Power
|
||||||
digitalWrite(D10, HIGH);
|
digitalWrite(D10, HIGH);
|
||||||
|
|
||||||
// Initialize library with data output pin, clock input pin and gain factor.
|
// we wait 400ms (settling time according HX711 datasheet @ 10 SPS
|
||||||
// Channel selection is made by passing the appropriate gain:
|
delay(400);
|
||||||
// - With a gain factor of 64 or 128, channel A is selected
|
|
||||||
// - With a gain factor of 32, channel B is selected
|
|
||||||
// By omitting the gain factor parameter, the library
|
|
||||||
// default "128" (Channel A) is used here.
|
|
||||||
LoadCell.begin(A1, A0, 32);
|
|
||||||
|
|
||||||
if (!(LoadCell.wait_ready_timeout(2000))) {
|
|
||||||
gCatena.SafePrintf("%010d - Scale not ready after Init.\n");
|
|
||||||
res = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (config_data.debug_level > 0) {
|
if (config_data.debug_level > 0) {
|
||||||
gCatena.SafePrintf("%010d - setup_scale done\n", millis());
|
gCatena.SafePrintf("%010d - setup_scale done\n", millis());
|
||||||
@@ -350,12 +346,11 @@ void setup_uplink(void)
|
|||||||
gCatena.SafePrintf("%010d - setup_uplink\n", millis());
|
gCatena.SafePrintf("%010d - setup_uplink\n", millis());
|
||||||
}
|
}
|
||||||
|
|
||||||
#if defined(_mcci_arduino_version) && _mcci_arduino_version >= _mcci_arduino_version_calc(2,4,0,90) && \
|
LMIC_setClockError(1 * 65536 / 100);
|
||||||
defined(CATENA_ARDUINO_PLATFORM_VERSION_CALC) && CATENA_ARDUINO_PLATFORM_VERSION >= CATENA_ARDUINO_PLATFORM_VERSION_CALC(0,17,0,10)
|
|
||||||
LMIC_setClockError(5 * 65536 / 100);
|
/* figure out when to reboot */
|
||||||
#else
|
gRebootMs = (CATCFG_T_REBOOT + os_getRndU2() - 32768) * 1000;
|
||||||
LMIC_setClockError(10 * 65536 / 100);
|
|
||||||
#endif
|
|
||||||
|
|
||||||
// Do an unjoin, so every reboot will trigger a join
|
// Do an unjoin, so every reboot will trigger a join
|
||||||
if (config_data.debug_level > 0) {
|
if (config_data.debug_level > 0) {
|
||||||
@@ -536,37 +531,65 @@ void DoDeepSleep(uint32_t sleep_time)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//Following functions are based on "https://github.com/dndubins/QuickStats", by David Dubins
|
||||||
|
|
||||||
|
long median(long samples[], int m) //calculate the median
|
||||||
|
{
|
||||||
|
//First bubble sort the values: https://en.wikipedia.org/wiki/Bubble_sort
|
||||||
|
long sorted[m]; // Define and initialize sorted array.
|
||||||
|
long temp = 0; // Temporary float for swapping elements
|
||||||
|
|
||||||
|
for (int i = 0; i < m; i++) {
|
||||||
|
sorted[i] = samples[i];
|
||||||
|
}
|
||||||
|
bubbleSort(sorted, m); // Sort the values
|
||||||
|
|
||||||
|
if (bitRead(m, 0) == 1) { //If the last bit of a number is 1, it's odd. This is equivalent to "TRUE". Also use if m%2!=0.
|
||||||
|
return sorted[m / 2]; //If the number of data points is odd, return middle number.
|
||||||
|
} else {
|
||||||
|
return (sorted[(m / 2) - 1] + sorted[m / 2]) / 2; //If the number of data points is even, return avg of the middle two numbers.
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void bubbleSort(long A[], int len) {
|
||||||
|
unsigned long newn;
|
||||||
|
unsigned long n = len;
|
||||||
|
long temp = 0;
|
||||||
|
do {
|
||||||
|
newn = 1;
|
||||||
|
for (int p = 1; p < len; p++) {
|
||||||
|
if (A[p - 1] > A[p]) {
|
||||||
|
temp = A[p]; //swap places in array
|
||||||
|
A[p] = A[p - 1];
|
||||||
|
A[p - 1] = temp;
|
||||||
|
newn = p;
|
||||||
|
} //end if
|
||||||
|
} //end for
|
||||||
|
n = newn;
|
||||||
|
} while (n > 1);
|
||||||
|
}
|
||||||
|
|
||||||
long my_read_average(byte gain, byte times) {
|
long my_read_average(byte gain, byte times) {
|
||||||
// highest and lowest value will be ignored
|
|
||||||
long sum = 0;
|
|
||||||
long v = 0;
|
|
||||||
long L = 2147483647;
|
|
||||||
long H = -2147483648;
|
|
||||||
long res;
|
long res;
|
||||||
|
int const num_scale_readings = 25; // number of instantaneous scale readings to calculate the median
|
||||||
|
|
||||||
|
// we use the median, not the average, see https://community.particle.io/t/boron-gpio-provides-less-current-than-electrons-gpio/46647/13
|
||||||
|
long readings[num_scale_readings]; // create arry to hold readings
|
||||||
|
|
||||||
if (config_data.debug_level > 0) {
|
if (config_data.debug_level > 0) {
|
||||||
gCatena.SafePrintf("%010d - my_read_average, measurements: ", millis());
|
gCatena.SafePrintf("%010d - my_read_average, measurements: ", millis());
|
||||||
}
|
}
|
||||||
|
|
||||||
LoadCell.set_gain(gain);
|
hx711.setGain(gain);
|
||||||
// we wait 400ms (settling time according HX711 datasheet @ 10 SPS
|
|
||||||
delay(400);
|
|
||||||
|
|
||||||
for (byte i = 0; i < times; i++) {
|
for (int i = 0; i < num_scale_readings; i++) {
|
||||||
// we wait 400ms (settling time according HX711 datasheet @ 10 SPS)
|
readings[i] = hx711.read(); // fill the array with instantaneous readings from the scale
|
||||||
v = LoadCell.read();
|
|
||||||
|
|
||||||
if (L > v) L = v; // find lowest value
|
|
||||||
if (H < v) H = v; // find highest value
|
|
||||||
sum += v;
|
|
||||||
if (config_data.debug_level > 0) {
|
|
||||||
gCatena.SafePrintf("%d ", v);
|
|
||||||
}
|
|
||||||
gCatena.poll();
|
|
||||||
delay(WAITTIMELOADSAMPLES);
|
|
||||||
}
|
}
|
||||||
res = (sum - L - H) / (times - 2);
|
|
||||||
|
res = median(readings, num_scale_readings); // calculate median
|
||||||
|
|
||||||
if (config_data.debug_level > 0) {
|
if (config_data.debug_level > 0) {
|
||||||
gCatena.SafePrintf("; average (without highest [%d] and lowest [%d] value): %d\n", H, L, res);
|
gCatena.SafePrintf("; median of %d samples: %d\n", num_scale_readings, res);
|
||||||
}
|
}
|
||||||
|
|
||||||
return res;
|
return res;
|
||||||
@@ -575,6 +598,8 @@ long my_read_average(byte gain, byte times) {
|
|||||||
void ReadSensors(SENSOR_data &sensor_data) {
|
void ReadSensors(SENSOR_data &sensor_data) {
|
||||||
SENSOR_data res;
|
SENSOR_data res;
|
||||||
int32_t weight_current32;
|
int32_t weight_current32;
|
||||||
|
long w1_0_real;
|
||||||
|
long w2_0_real;
|
||||||
|
|
||||||
// vBat
|
// vBat
|
||||||
gCatena.poll();
|
gCatena.poll();
|
||||||
@@ -585,19 +610,37 @@ void ReadSensors(SENSOR_data &sensor_data) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Read Scales
|
// Read Scales
|
||||||
|
w1_0_real = config_data.cal_w1_0;
|
||||||
|
w2_0_real = config_data.cal_w2_0;
|
||||||
if (setup_scales()) {
|
if (setup_scales()) {
|
||||||
if (config_data.debug_level > 0) {
|
if (config_data.debug_level > 0) {
|
||||||
gCatena.SafePrintf("%010d - HX711 LoadCell is ready.\n", millis());
|
gCatena.SafePrintf("%010d - HX711 LoadCell is ready.\n", millis());
|
||||||
}
|
}
|
||||||
gCatena.poll();
|
gCatena.poll();
|
||||||
res.weight1 = (int32_t)my_read_average(32, 7);
|
if (config_data.cal_w1_0 != NOT_ATTACHED) {
|
||||||
if (config_data.debug_level > 0) {
|
res.weight1 = (int32_t)my_read_average(32, 7);
|
||||||
gCatena.SafePrintf("%010d - Load_cell 1 weight1_current: %ld\n", millis(), res.weight1);
|
if (config_data.debug_level > 0) {
|
||||||
|
gCatena.SafePrintf("%010d - Load_cell 1 weight1_current: %ld\n", millis(), res.weight1);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
res.weight1 = 0;
|
||||||
|
w1_0_real = 0;
|
||||||
|
if (config_data.debug_level > 0) {
|
||||||
|
gCatena.SafePrintf("%010d - Load_cell 1 is disabled\n", millis());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
gCatena.poll();
|
gCatena.poll();
|
||||||
res.weight2 = (int32_t)my_read_average(128, 7);
|
if (config_data.cal_w2_0 != NOT_ATTACHED) {
|
||||||
if (config_data.debug_level > 0) {
|
res.weight2 = (int32_t)my_read_average(128, 7);
|
||||||
gCatena.SafePrintf("%010d - Load_cell 2 weight2_current: %ld\n", millis(), res.weight2);
|
if (config_data.debug_level > 0) {
|
||||||
|
gCatena.SafePrintf("%010d - Load_cell 2 weight2_current: %ld\n", millis(), res.weight2);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
res.weight2 = 0;
|
||||||
|
w2_0_real = 0;
|
||||||
|
if (config_data.debug_level > 0) {
|
||||||
|
gCatena.SafePrintf("%010d - Load_cell 2 is disabled\n", millis());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
@@ -611,11 +654,18 @@ void ReadSensors(SENSOR_data &sensor_data) {
|
|||||||
digitalWrite(D10, LOW);
|
digitalWrite(D10, LOW);
|
||||||
|
|
||||||
// Gewicht berechnen
|
// Gewicht berechnen
|
||||||
weight_current32 = (int32_t)((((res.weight1 - config_data.cal_w1_0) / config_data.cal_w1_factor) + ((res.weight2 - config_data.cal_w2_0) / config_data.cal_w2_factor)) / 5.0);
|
weight_current32 = (int32_t)((((res.weight1 - w1_0_real) / config_data.cal_w1_factor) + ((res.weight2 - w2_0_real) / config_data.cal_w2_factor)) / 5.0);
|
||||||
|
|
||||||
if (weight_current32 < 0) {
|
if (weight_current32 < 0) {
|
||||||
weight_current32 = 0;
|
weight_current32 = 0;
|
||||||
} else if (weight_current32 > UINT16_MAX) {
|
} else if (weight_current32 > UINT16_MAX) {
|
||||||
weight_current32 = UINT16_MAX;
|
//weight_current32 = UINT16_MAX;
|
||||||
|
// we set the weight to 0, as such high values are not realistic and probably a sign for bad calibration...
|
||||||
|
weight_current32 = 0;
|
||||||
|
}
|
||||||
|
if (config_data.cal_w1_0 == NOT_ATTACHED || config_data.cal_w2_0 == NOT_ATTACHED) {
|
||||||
|
// when at least one load cell is disabled, we multiply the measured weight by 2
|
||||||
|
weight_current32 = weight_current32 * 2;
|
||||||
}
|
}
|
||||||
res.weight = (uint16_t)weight_current32;
|
res.weight = (uint16_t)weight_current32;
|
||||||
|
|
||||||
@@ -874,6 +924,8 @@ static void txNotProvisionedCb(
|
|||||||
static void settleDoneCb(
|
static void settleDoneCb(
|
||||||
osjob_t* pSendJob)
|
osjob_t* pSendJob)
|
||||||
{
|
{
|
||||||
|
const bool fDeepSleep = checkDeepSleep();
|
||||||
|
|
||||||
if (config_data.debug_level > 0) {
|
if (config_data.debug_level > 0) {
|
||||||
gCatena.SafePrintf("%010d - settleDoneCb\n", millis());
|
gCatena.SafePrintf("%010d - settleDoneCb\n", millis());
|
||||||
}
|
}
|
||||||
@@ -889,7 +941,191 @@ static void settleDoneCb(
|
|||||||
// Terry ^^
|
// Terry ^^
|
||||||
}
|
}
|
||||||
|
|
||||||
sleepDoneCb(pSendJob);
|
if (uint32_t(millis()) > gRebootMs) {
|
||||||
|
// time to reboot
|
||||||
|
NVIC_SystemReset();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (! g_fPrintedSleeping)
|
||||||
|
doSleepAlert(fDeepSleep);
|
||||||
|
|
||||||
|
/* count what we're up to */
|
||||||
|
updateSleepCounters();
|
||||||
|
|
||||||
|
if (fDeepSleep)
|
||||||
|
doDeepSleep(pSendJob);
|
||||||
|
else
|
||||||
|
doLightSleep(pSendJob);
|
||||||
|
}
|
||||||
|
|
||||||
|
bool checkDeepSleep(void)
|
||||||
|
{
|
||||||
|
bool const fDeepSleepTest = gCatena.GetOperatingFlags() &
|
||||||
|
static_cast<uint32_t>(gCatena.OPERATING_FLAGS::fDeepSleepTest);
|
||||||
|
bool fDeepSleep;
|
||||||
|
|
||||||
|
if (fDeepSleepTest)
|
||||||
|
{
|
||||||
|
fDeepSleep = true;
|
||||||
|
}
|
||||||
|
#ifdef USBCON
|
||||||
|
else if (Serial.dtr())
|
||||||
|
{
|
||||||
|
fDeepSleep = false;
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
else if (gCatena.GetOperatingFlags() &
|
||||||
|
static_cast<uint32_t>(gCatena.OPERATING_FLAGS::fDisableDeepSleep))
|
||||||
|
{
|
||||||
|
fDeepSleep = false;
|
||||||
|
}
|
||||||
|
else if ((gCatena.GetOperatingFlags() &
|
||||||
|
static_cast<uint32_t>(gCatena.OPERATING_FLAGS::fUnattended)) != 0)
|
||||||
|
{
|
||||||
|
fDeepSleep = true;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
fDeepSleep = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
return fDeepSleep;
|
||||||
|
}
|
||||||
|
|
||||||
|
void doSleepAlert(const bool fDeepSleep)
|
||||||
|
{
|
||||||
|
g_fPrintedSleeping = true;
|
||||||
|
|
||||||
|
if (fDeepSleep)
|
||||||
|
{
|
||||||
|
bool const fDeepSleepTest = gCatena.GetOperatingFlags() &
|
||||||
|
static_cast<uint32_t>(gCatena.OPERATING_FLAGS::fDeepSleepTest);
|
||||||
|
const uint32_t deepSleepDelay = fDeepSleepTest ? 10 : 30;
|
||||||
|
if (config_data.debug_level > 2) {
|
||||||
|
gCatena.SafePrintf("using deep sleep in %u secs"
|
||||||
|
#ifdef USBCON
|
||||||
|
" (USB will disconnect while asleep)"
|
||||||
|
#endif
|
||||||
|
": ",
|
||||||
|
deepSleepDelay
|
||||||
|
);
|
||||||
|
|
||||||
|
}
|
||||||
|
// sleep and print
|
||||||
|
if (config_data.debug_level > 2) {
|
||||||
|
gLed.Set(LedPattern::TwoShort);
|
||||||
|
}
|
||||||
|
|
||||||
|
for (auto n = deepSleepDelay; n > 0; --n)
|
||||||
|
{
|
||||||
|
uint32_t tNow = millis();
|
||||||
|
|
||||||
|
while (uint32_t(millis() - tNow) < 1000)
|
||||||
|
{
|
||||||
|
gCatena.poll();
|
||||||
|
yield();
|
||||||
|
}
|
||||||
|
if (config_data.debug_level > 2) {
|
||||||
|
gCatena.SafePrintf(".");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (config_data.debug_level > 2) {
|
||||||
|
gCatena.SafePrintf("\nStarting deep sleep.\n");
|
||||||
|
}
|
||||||
|
uint32_t tNow = millis();
|
||||||
|
while (uint32_t(millis() - tNow) < 100)
|
||||||
|
{
|
||||||
|
gCatena.poll();
|
||||||
|
yield();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (config_data.debug_level > 2) {
|
||||||
|
gCatena.SafePrintf("using light sleep\n");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void updateSleepCounters(void)
|
||||||
|
{
|
||||||
|
// update the sleep parameters
|
||||||
|
if (gTxCycleCount > 1)
|
||||||
|
{
|
||||||
|
// values greater than one are decremented and ultimately reset to default.
|
||||||
|
--gTxCycleCount;
|
||||||
|
}
|
||||||
|
else if (gTxCycleCount == 1)
|
||||||
|
{
|
||||||
|
// it's now one (otherwise we couldn't be here.)
|
||||||
|
if (config_data.debug_level > 2) {
|
||||||
|
gCatena.SafePrintf("resetting tx cycle to default: %u\n", CATCFG_T_CYCLE);
|
||||||
|
}
|
||||||
|
|
||||||
|
gTxCycleCount = 0;
|
||||||
|
gTxCycle = CATCFG_T_CYCLE;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
// it's zero. Leave it alone.
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void doDeepSleep(osjob_t *pJob)
|
||||||
|
{
|
||||||
|
bool const fDeepSleepTest = gCatena.GetOperatingFlags() &
|
||||||
|
static_cast<uint32_t>(gCatena.OPERATING_FLAGS::fDeepSleepTest);
|
||||||
|
uint32_t const sleepInterval = CATCFG_GetInterval(
|
||||||
|
fDeepSleepTest ? CATCFG_T_CYCLE_TEST : gTxCycle
|
||||||
|
);
|
||||||
|
|
||||||
|
/* ok... now it's time for a deep sleep */
|
||||||
|
gLed.Set(LedPattern::Off);
|
||||||
|
deepSleepPrepare();
|
||||||
|
|
||||||
|
/* sleep */
|
||||||
|
gCatena.Sleep(sleepInterval);
|
||||||
|
|
||||||
|
/* recover from sleep */
|
||||||
|
deepSleepRecovery();
|
||||||
|
|
||||||
|
/* and now... we're awake again. trigger another measurement */
|
||||||
|
sleepDoneCb(pJob);
|
||||||
|
}
|
||||||
|
|
||||||
|
void deepSleepPrepare(void)
|
||||||
|
{
|
||||||
|
Serial.end();
|
||||||
|
Wire.end();
|
||||||
|
SPI.end();
|
||||||
|
if (fFlash)
|
||||||
|
gSPI2.end();
|
||||||
|
}
|
||||||
|
|
||||||
|
void deepSleepRecovery(void)
|
||||||
|
{
|
||||||
|
Serial.begin();
|
||||||
|
Wire.begin();
|
||||||
|
SPI.begin();
|
||||||
|
if (fFlash)
|
||||||
|
gSPI2.begin();
|
||||||
|
}
|
||||||
|
|
||||||
|
void doLightSleep(osjob_t *pJob)
|
||||||
|
{
|
||||||
|
uint32_t interval = sec2osticks(CATCFG_GetInterval(gTxCycle));
|
||||||
|
|
||||||
|
gLed.Set(LedPattern::Sleeping);
|
||||||
|
|
||||||
|
if (gCatena.GetOperatingFlags() &
|
||||||
|
static_cast<uint32_t>(gCatena.OPERATING_FLAGS::fQuickLightSleep))
|
||||||
|
{
|
||||||
|
interval = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
gLed.Set(LedPattern::Sleeping);
|
||||||
|
os_setTimedCallback(
|
||||||
|
&iterationJob,
|
||||||
|
os_getTime() + interval,
|
||||||
|
sleepDoneCb
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void sleepDoneCb(osjob_t* pJob)
|
static void sleepDoneCb(osjob_t* pJob)
|
||||||
@@ -1020,7 +1256,7 @@ static void receiveMessage(void *pContext, uint8_t port, const uint8_t *pMessage
|
|||||||
|
|
||||||
config_data.cal_w1_0 = cal_w1_0;
|
config_data.cal_w1_0 = cal_w1_0;
|
||||||
config_data.cal_w2_0 = cal_w2_0;
|
config_data.cal_w2_0 = cal_w2_0;
|
||||||
gCatena.getFram()->saveField(cFramStorage::kBme680Cal, (const uint8_t *)&config_data, sizeof(config_data));
|
gCatena.getFram()->saveField(cFramStorage::kAppConf, (const uint8_t *)&config_data, sizeof(config_data));
|
||||||
lora_data_first.cal_w1_0 = config_data.cal_w1_0;
|
lora_data_first.cal_w1_0 = config_data.cal_w1_0;
|
||||||
lora_data_first.cal_w2_0 = config_data.cal_w2_0;
|
lora_data_first.cal_w2_0 = config_data.cal_w2_0;
|
||||||
}
|
}
|
||||||
@@ -1036,7 +1272,7 @@ static void receiveMessage(void *pContext, uint8_t port, const uint8_t *pMessage
|
|||||||
config_data.cal_w2_0 = cal_w2_0;
|
config_data.cal_w2_0 = cal_w2_0;
|
||||||
config_data.cal_w1_factor = cal_w1_factor;
|
config_data.cal_w1_factor = cal_w1_factor;
|
||||||
config_data.cal_w2_factor = cal_w2_factor;
|
config_data.cal_w2_factor = cal_w2_factor;
|
||||||
gCatena.getFram()->saveField(cFramStorage::kBme680Cal, (const uint8_t *)&config_data, sizeof(config_data));
|
gCatena.getFram()->saveField(cFramStorage::kAppConf, (const uint8_t *)&config_data, sizeof(config_data));
|
||||||
|
|
||||||
lora_data_first.cal_w1_0 = config_data.cal_w1_0;
|
lora_data_first.cal_w1_0 = config_data.cal_w1_0;
|
||||||
lora_data_first.cal_w2_0 = config_data.cal_w2_0;
|
lora_data_first.cal_w2_0 = config_data.cal_w2_0;
|
||||||
@@ -1105,7 +1341,7 @@ cCommandStream::CommandStatus cmdCalibrateZeroScaleA(cCommandStream *pThis, void
|
|||||||
{
|
{
|
||||||
setup_scales();
|
setup_scales();
|
||||||
config_data.cal_w1_0 = (int32_t)my_read_average(32, 10);
|
config_data.cal_w1_0 = (int32_t)my_read_average(32, 10);
|
||||||
gCatena.getFram()->saveField(cFramStorage::kBme680Cal, (const uint8_t *)&config_data, sizeof(config_data));
|
gCatena.getFram()->saveField(cFramStorage::kAppConf, (const uint8_t *)&config_data, sizeof(config_data));
|
||||||
pThis->printf("{ \"msg\": \"calibrate_zero_scale_a was successful\" }\n");
|
pThis->printf("{ \"msg\": \"calibrate_zero_scale_a was successful\" }\n");
|
||||||
|
|
||||||
return cCommandStream::CommandStatus::kSuccess;
|
return cCommandStream::CommandStatus::kSuccess;
|
||||||
@@ -1115,7 +1351,7 @@ cCommandStream::CommandStatus cmdCalibrateZeroScaleB(cCommandStream *pThis, void
|
|||||||
{
|
{
|
||||||
setup_scales();
|
setup_scales();
|
||||||
config_data.cal_w2_0 = (int32_t)my_read_average(128, 10);
|
config_data.cal_w2_0 = (int32_t)my_read_average(128, 10);
|
||||||
gCatena.getFram()->saveField(cFramStorage::kBme680Cal, (const uint8_t *)&config_data, sizeof(config_data));
|
gCatena.getFram()->saveField(cFramStorage::kAppConf, (const uint8_t *)&config_data, sizeof(config_data));
|
||||||
pThis->printf("{ \"msg\": \"calibrate_zero_scale_b was successful\" }\n");
|
pThis->printf("{ \"msg\": \"calibrate_zero_scale_b was successful\" }\n");
|
||||||
|
|
||||||
return cCommandStream::CommandStatus::kSuccess;
|
return cCommandStream::CommandStatus::kSuccess;
|
||||||
@@ -1125,11 +1361,18 @@ cCommandStream::CommandStatus cmdCalibrateScaleA(cCommandStream *pThis, void *pC
|
|||||||
{
|
{
|
||||||
String w1_gramm(argv[1]);
|
String w1_gramm(argv[1]);
|
||||||
long weight1;
|
long weight1;
|
||||||
setup_scales();
|
|
||||||
weight1 = my_read_average(32, 10);
|
|
||||||
config_data.cal_w1_factor = (float)((weight1 - config_data.cal_w1_0) / w1_gramm.toFloat());
|
|
||||||
|
|
||||||
gCatena.getFram()->saveField(cFramStorage::kBme680Cal, (const uint8_t *)&config_data, sizeof(config_data));
|
if (w1_gramm == "NA") {
|
||||||
|
// scale a is not connected
|
||||||
|
config_data.cal_w1_factor = 1.0;
|
||||||
|
config_data.cal_w1_0 = NOT_ATTACHED;
|
||||||
|
} else {
|
||||||
|
setup_scales();
|
||||||
|
weight1 = my_read_average(32, 10);
|
||||||
|
config_data.cal_w1_factor = (float)((weight1 - config_data.cal_w1_0) / w1_gramm.toFloat());
|
||||||
|
}
|
||||||
|
|
||||||
|
gCatena.getFram()->saveField(cFramStorage::kAppConf, (const uint8_t *)&config_data, sizeof(config_data));
|
||||||
|
|
||||||
pThis->printf("{ \"msg\": \"calibrate_scale_a was successful\" }\n");
|
pThis->printf("{ \"msg\": \"calibrate_scale_a was successful\" }\n");
|
||||||
|
|
||||||
@@ -1140,11 +1383,18 @@ cCommandStream::CommandStatus cmdCalibrateScaleB(cCommandStream *pThis, void *pC
|
|||||||
{
|
{
|
||||||
String w2_gramm(argv[1]);
|
String w2_gramm(argv[1]);
|
||||||
long weight2;
|
long weight2;
|
||||||
setup_scales();
|
|
||||||
weight2 = my_read_average(128, 10);
|
|
||||||
config_data.cal_w2_factor = (float)((weight2 - config_data.cal_w2_0) / w2_gramm.toFloat());
|
|
||||||
|
|
||||||
gCatena.getFram()->saveField(cFramStorage::kBme680Cal, (const uint8_t *)&config_data, sizeof(config_data));
|
if (w2_gramm == "NA") {
|
||||||
|
// scale b is not connected
|
||||||
|
config_data.cal_w2_factor = 1.0;
|
||||||
|
config_data.cal_w2_0 = NOT_ATTACHED;
|
||||||
|
} else {
|
||||||
|
setup_scales();
|
||||||
|
weight2 = my_read_average(128, 10);
|
||||||
|
config_data.cal_w2_factor = (float)((weight2 - config_data.cal_w2_0) / w2_gramm.toFloat());
|
||||||
|
}
|
||||||
|
|
||||||
|
gCatena.getFram()->saveField(cFramStorage::kAppConf, (const uint8_t *)&config_data, sizeof(config_data));
|
||||||
|
|
||||||
pThis->printf("{ \"msg\": \"calibrate_scale_b was successful\" }\n");
|
pThis->printf("{ \"msg\": \"calibrate_scale_b was successful\" }\n");
|
||||||
|
|
||||||
@@ -1155,7 +1405,7 @@ cCommandStream::CommandStatus cmdSetDebugLevel(cCommandStream *pThis, void *pCon
|
|||||||
{
|
{
|
||||||
String s_debug_level(argv[1]);
|
String s_debug_level(argv[1]);
|
||||||
config_data.debug_level = s_debug_level.toInt();
|
config_data.debug_level = s_debug_level.toInt();
|
||||||
gCatena.getFram()->saveField(cFramStorage::kBme680Cal, (const uint8_t *)&config_data, sizeof(config_data));
|
gCatena.getFram()->saveField(cFramStorage::kAppConf, (const uint8_t *)&config_data, sizeof(config_data));
|
||||||
|
|
||||||
pThis->printf("{ \"msg\": \"set_debug_level was successful\" }\n");
|
pThis->printf("{ \"msg\": \"set_debug_level was successful\" }\n");
|
||||||
|
|
||||||
@@ -1164,7 +1414,7 @@ cCommandStream::CommandStatus cmdSetDebugLevel(cCommandStream *pThis, void *pCon
|
|||||||
|
|
||||||
cCommandStream::CommandStatus cmdGetDebugLevel(cCommandStream *pThis, void *pContext, int argc, char **argv)
|
cCommandStream::CommandStatus cmdGetDebugLevel(cCommandStream *pThis, void *pContext, int argc, char **argv)
|
||||||
{
|
{
|
||||||
gCatena.getFram()->saveField(cFramStorage::kBme680Cal, (const uint8_t *)&config_data, sizeof(config_data));
|
gCatena.getFram()->saveField(cFramStorage::kAppConf, (const uint8_t *)&config_data, sizeof(config_data));
|
||||||
|
|
||||||
pThis->printf("{ \"msg\": \"debug_level is %d\" }\n", config_data.debug_level);
|
pThis->printf("{ \"msg\": \"debug_level is %d\" }\n", config_data.debug_level);
|
||||||
|
|
||||||
|
|||||||
+7
-8
@@ -19,6 +19,7 @@ enum {
|
|||||||
CATCFG_T_CYCLE_TEST = 30, // every 10 seconds
|
CATCFG_T_CYCLE_TEST = 30, // every 10 seconds
|
||||||
CATCFG_T_CYCLE_INITIAL = 30, // every 30 seconds initially
|
CATCFG_T_CYCLE_INITIAL = 30, // every 30 seconds initially
|
||||||
CATCFG_INTERVAL_COUNT_INITIAL = 30, // repeat for 15 minutes
|
CATCFG_INTERVAL_COUNT_INITIAL = 30, // repeat for 15 minutes
|
||||||
|
CATCFG_T_REBOOT = 30 * 24 * 60 * 60, // reboot every 30 days
|
||||||
};
|
};
|
||||||
|
|
||||||
/* additional timing parameters; ususually you don't change these. */
|
/* additional timing parameters; ususually you don't change these. */
|
||||||
@@ -55,10 +56,7 @@ enum {
|
|||||||
|
|
|
|
||||||
\****************************************************************************/
|
\****************************************************************************/
|
||||||
|
|
||||||
static const int32_t fwVersion = 20200109;
|
static const int32_t fwVersion = 20200229;
|
||||||
|
|
||||||
// wait between samples in milliseconds
|
|
||||||
const int WAITTIMELOADSAMPLES = 100;
|
|
||||||
|
|
||||||
static const byte INIT_PACKAGE_INTERVAL = 100; // send an init package every 100 packages;
|
static const byte INIT_PACKAGE_INTERVAL = 100; // send an init package every 100 packages;
|
||||||
static const byte MAX_VALUES_TO_SEND = 8;
|
static const byte MAX_VALUES_TO_SEND = 8;
|
||||||
@@ -67,15 +65,16 @@ static const uint8_t LORA_DATA_VERSION = 1;
|
|||||||
static const uint8_t LORA_DATA_VERSION_FIRST_PACKAGE = 128;
|
static const uint8_t LORA_DATA_VERSION_FIRST_PACKAGE = 128;
|
||||||
static const uint32_t PRESSURE_OFFSET = 825;
|
static const uint32_t PRESSURE_OFFSET = 825;
|
||||||
static const uint16_t SEND_DIFF_THRESHOLD_5GRAMS = 10; // when weight value drops by 50g, then send data
|
static const uint16_t SEND_DIFF_THRESHOLD_5GRAMS = 10; // when weight value drops by 50g, then send data
|
||||||
|
static const long NOT_ATTACHED = -2147483648;
|
||||||
|
|
||||||
// must be 139 bytes long (size of kBme680Cal)
|
// must be 64 bytes long (size of kAppConf)
|
||||||
typedef struct {
|
typedef struct {
|
||||||
long cal_w1_0; // 4 Bytes, Wert Waegezelle 1 ohne Gewicht
|
long cal_w1_0; // 4 Bytes, Wert Waegezelle 1 ohne Gewicht, LONG_MIN when not connected
|
||||||
long cal_w2_0; // 4 Bytes, Wert Waegezelle 2 ohne Gewicht
|
long cal_w2_0; // 4 Bytes, Wert Waegezelle 2 ohne Gewicht, LONG_MIN when not connected
|
||||||
float cal_w1_factor; // 4 Bytes, Kalibrationsfaktor Waegezelle 1
|
float cal_w1_factor; // 4 Bytes, Kalibrationsfaktor Waegezelle 1
|
||||||
float cal_w2_factor; // 4 Bytes, Kalibrationsfaktor Waegezelle 2
|
float cal_w2_factor; // 4 Bytes, Kalibrationsfaktor Waegezelle 2
|
||||||
byte debug_level; // 0 => no debugging, no led, 1 => infos, no led, 2 => infos, 3 => error, 4 => highest level
|
byte debug_level; // 0 => no debugging, no led, 1 => infos, no led, 2 => infos, 3 => error, 4 => highest level
|
||||||
byte fill[122];
|
byte fill[47];
|
||||||
} __attribute__((packed)) CONFIG_data;
|
} __attribute__((packed)) CONFIG_data;
|
||||||
|
|
||||||
typedef struct {
|
typedef struct {
|
||||||
|
|||||||
Reference in New Issue
Block a user