|
@ -100,7 +100,7 @@ class PubMqttIvData { |
|
|
if(found) { |
|
|
if(found) { |
|
|
mState = SEND_DATA; |
|
|
mState = SEND_DATA; |
|
|
if(!mIv->isAvailable(*mUtcTimestamp)) |
|
|
if(!mIv->isAvailable(*mUtcTimestamp)) |
|
|
mSendTotals = false; // avoid send total values on not producing, because the sum of values is not built
|
|
|
mSendTotals = false; // avoid send total values on no availability, because the sum of values is not built
|
|
|
} |
|
|
} |
|
|
else if(mSendTotals) |
|
|
else if(mSendTotals) |
|
|
mState = SEND_TOTALS; |
|
|
mState = SEND_TOTALS; |
|
@ -125,12 +125,12 @@ class PubMqttIvData { |
|
|
if(FLD_YT == rec->assign[mPos].fieldId) |
|
|
if(FLD_YT == rec->assign[mPos].fieldId) |
|
|
retained = true; |
|
|
retained = true; |
|
|
else if(FLD_YD == rec->assign[mPos].fieldId) { |
|
|
else if(FLD_YD == rec->assign[mPos].fieldId) { |
|
|
if(!mZeroValues) { |
|
|
/*if(!mZeroValues) {
|
|
|
if ((rec->assign[mPos].ch == CH0) && (!mIv->isProducing(*mUtcTimestamp))) { // avoids returns to 0 on restart
|
|
|
if ((rec->assign[mPos].ch == CH0) && (!mIv->isProducing(*mUtcTimestamp))) { // avoids returns to 0 on restart
|
|
|
mPos++; |
|
|
mPos++; |
|
|
return; |
|
|
return; |
|
|
} |
|
|
} |
|
|
} |
|
|
}*/ |
|
|
retained = true; |
|
|
retained = true; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|