processTelegram.ino

/*
***************************************************************************
**  Program  : processTelegram, part of DSMRloggerAPI
**  Version  : v3.0
**
**  Copyright (c) 2020 .. 2022 Willem Aandewiel
**
**  TERMS OF USE: MIT License. See bottom of file.
***************************************************************************
*/
//==================================================================================
void processTelegram()
{
  DebugTf("Telegram[%d]=>DSMRdata.timestamp[%s]\r\n", telegramCount
          , DSMRdata.timestamp.c_str());

  //----- update OLED display ---------
  if (settingOledType > 0)
  {
    String DT   = buildDateTimeString(DSMRdata.timestamp.c_str(), sizeof(DSMRdata.timestamp));

    snprintf(cMsg, sizeof(cMsg), "%s - %s", DT.substring(0, 10).c_str(), DT.substring(11, 16).c_str());
    oled_Print_Msg(0, cMsg, 0);
    snprintf(cMsg, sizeof(cMsg), "-Power%7d Watt", (int)(DSMRdata.power_delivered *1000));
    oled_Print_Msg(1, cMsg, 0);
    snprintf(cMsg, sizeof(cMsg), "+Power%7d Watt", (int)(DSMRdata.power_returned *1000));
    oled_Print_Msg(2, cMsg, 0);
  }

  strcpy(newTimestamp, DSMRdata.timestamp.c_str());
  //--- newTimestamp is the timestamp from the last telegram
  newT = epoch(newTimestamp, strlen(newTimestamp), true); // update system time
  //--- actTimestamp is the timestamp from the previous telegram
  actT = epoch(actTimestamp, strlen(actTimestamp), false);

  //--- Skip first 3 telegrams .. just to settle down a bit ;-)
  if ((int32_t)(telegramCount - telegramErrors) < 3)
  {
    strCopy(actTimestamp, sizeof(actTimestamp), newTimestamp);
    actT = epoch(actTimestamp, strlen(actTimestamp), false);   // update system time
    return;
  }

  DebugTf("actHour[%02d] -- newHour[%02d]\r\n", hour(actT), hour(newT));
  //--- if we have a new hour() update the previous hour
  if (hour(actT) != hour(newT))
  {
    writeToSysLog("actHour[%02d] -- newHour[%02d]", hour(actT), hour(newT));
  }
  //--- has the hour changed (or the day or month)
  //--- in production testing on hour only would
  //--- suffice, but in testing I need all three
  //--- if we have a new hour() update the previous hour(actT)
  if (     (hour(actT) != hour(newT)  )
           ||   (day(actT) != day(newT)   )
           || (month(actT) != month(newT) ) )
  {
    writeToSysLog("Update RING-files");
    writeDataToFiles();
    writeLastStatus();
    //--- now see if the day() has changed also
    if ( day(actT) != day(newT) )
    {
      //--- YES! actTimestamp := newTimestamp
      //--- and update the files with the actTimestamp
      strCopy(actTimestamp, sizeof(actTimestamp), newTimestamp);
      writeDataToFiles();
    }
    else     //--- NO, only the hour has changed
    {
      char      record[DATA_RECLEN + 1] = "";
      //--- actTimestamp := newTimestamp
      strCopy(actTimestamp, sizeof(actTimestamp), newTimestamp);
      buildDataRecordFromSM(record);
      uint16_t recSlot = timestampToHourSlot(actTimestamp, strlen(actTimestamp));
      //--- and update the files with the actTimestamp
      writeDataToFile(HOURS_FILE, record, recSlot, HOURS);
      DebugTf(">%s\r\n", record); // record ends in a \n
    }
  }

  if ( DUE(publishMQTTtimer) )
  {
    sendMQTTData();
  }

  strCopy(actTimestamp, sizeof(actTimestamp), newTimestamp);
  actT = epoch(actTimestamp, strlen(actTimestamp), true);   // update system time

} // processTelegram()


/***************************************************************************
*
* Permission is hereby granted, free of charge, to any person obtaining a
* copy of this software and associated documentation files (the
* "Software"), to deal in the Software without restriction, including
* without limitation the rights to use, copy, modify, merge, publish,
* distribute, sublicense, and/or sell copies of the Software, and to permit
* persons to whom the Software is furnished to do so, subject to the
* following conditions:
*
* The above copyright notice and this permission notice shall be included
* in all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
* OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT
* OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR
* THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*
***************************************************************************/