mirror of
https://github.com/jomjol/AI-on-the-edge-device.git
synced 2025-12-08 12:36:52 +03:00
f6369ff237
* comment translation * translation part #2 * code translation from DE to ENG #part3 * translation #4 * dismantled =>splitted * bereich => range * Update defines.h Co-authored-by: jomjol <30766535+jomjol@users.noreply.github.com>
92 lines
2.2 KiB
C++
92 lines
2.2 KiB
C++
#include <sstream>
|
|
#include "ClassFlowWriteList.h"
|
|
#include "Helper.h"
|
|
|
|
#include "time_sntp.h"
|
|
#include "../../include/defines.h"
|
|
|
|
#include <time.h>
|
|
|
|
void ClassFlowWriteList::SetInitialParameter(void)
|
|
{
|
|
flowpostprocessing = NULL;
|
|
previousElement = NULL;
|
|
ListFlowControll = NULL;
|
|
disabled = false;
|
|
}
|
|
|
|
ClassFlowWriteList::ClassFlowWriteList()
|
|
{
|
|
SetInitialParameter();
|
|
}
|
|
|
|
ClassFlowWriteList::ClassFlowWriteList(std::vector<ClassFlow*>* lfc)
|
|
{
|
|
SetInitialParameter();
|
|
|
|
ListFlowControll = lfc;
|
|
for (int i = 0; i < ListFlowControll->size(); ++i)
|
|
{
|
|
if (((*ListFlowControll)[i])->name().compare("ClassFlowPostProcessing") == 0)
|
|
{
|
|
flowpostprocessing = (ClassFlowPostProcessing*) (*ListFlowControll)[i];
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
bool ClassFlowWriteList::ReadParameter(FILE* pfile, string& aktparamgraph)
|
|
{
|
|
std::vector<string> splitted;
|
|
|
|
aktparamgraph = trim(aktparamgraph);
|
|
|
|
if (aktparamgraph.size() == 0)
|
|
if (!this->GetNextParagraph(pfile, aktparamgraph))
|
|
return false;
|
|
|
|
if (toUpper(aktparamgraph).compare("[MQTT]") != 0)
|
|
return false;
|
|
|
|
while (this->getNextLine(pfile, &aktparamgraph) && !this->isNewParagraph(aktparamgraph))
|
|
{
|
|
splitted = ZerlegeZeile(aktparamgraph);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
|
|
|
|
bool ClassFlowWriteList::doFlow(string zwtime)
|
|
{
|
|
std::string line = "";
|
|
|
|
std::string result;
|
|
std::string resulterror = "";
|
|
std::string resultraw = "";
|
|
std::string resultrate = "";
|
|
std::string resulttimestamp = "";
|
|
string zw = "";
|
|
string namenumber = "";
|
|
|
|
if (flowpostprocessing)
|
|
{
|
|
std::vector<NumberPost*>* NUMBERS = flowpostprocessing->GetNumbers();
|
|
|
|
for (int i = 0; i < (*NUMBERS).size(); ++i)
|
|
{
|
|
result = (*NUMBERS)[i]->ReturnValue;
|
|
resultraw = (*NUMBERS)[i]->ReturnRawValue;
|
|
resulterror = (*NUMBERS)[i]->ErrorMessageText;
|
|
resultrate = (*NUMBERS)[i]->ReturnRateValue;
|
|
resulttimestamp = (*NUMBERS)[i]->timeStamp;
|
|
|
|
line = line + resulttimestamp + "\t" + resultraw + "\t" + result + "\t" + resultraw + "\t" + resultrate + "\t" + resulttimestamp + "\t";
|
|
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|