mirror of https://github.com/lumapu/ahoy.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
264 lines
9.9 KiB
264 lines
9.9 KiB
//-----------------------------------------------------------------------------
|
|
// 2022 Ahoy, https://ahoydtu.de
|
|
// Creative Commons - http://creativecommons.org/licenses/by-nc-sa/3.0/de/
|
|
//-----------------------------------------------------------------------------
|
|
|
|
#if defined(ESP32) && defined(F)
|
|
#undef F
|
|
#define F(sl) (sl)
|
|
#endif
|
|
|
|
#include "app.h"
|
|
#include <ArduinoJson.h>
|
|
#include "utils/sun.h"
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void app::setup(uint32_t timeout) {
|
|
Serial.begin(115200);
|
|
while (!Serial)
|
|
yield();
|
|
|
|
addListener(EVERY_SEC, std::bind(&app::uptimeTick, this));
|
|
addListener(EVERY_MIN, std::bind(&app::minuteTick, this));
|
|
addListener(EVERY_12H, std::bind(&app::ntpUpdateTick, this));
|
|
|
|
resetSystem();
|
|
mSettings.setup();
|
|
mSettings.getPtr(mConfig);
|
|
DPRINTLN(DBG_INFO, F("Settings valid: ") + String((mSettings.getValid()) ? F("true") : F("false")));
|
|
|
|
mWifi = new ahoywifi(mConfig);
|
|
mWifi->setup(timeout, mSettings.getValid());
|
|
|
|
mSys = new HmSystemType();
|
|
mSys->enableDebug();
|
|
mSys->setup(mConfig->nrf.amplifierPower, mConfig->nrf.pinIrq, mConfig->nrf.pinCe, mConfig->nrf.pinCs);
|
|
mSys->addInverters(&mConfig->inst);
|
|
|
|
mPayload.setup(mSys);
|
|
mPayload.enableSerialDebug(mConfig->serial.debug);
|
|
#if !defined(AP_ONLY)
|
|
if (mConfig->mqtt.broker[0] > 0) {
|
|
mMqtt.setup(&mConfig->mqtt, mConfig->sys.deviceName, mVersion, mSys, &mUtcTimestamp, &mSunrise, &mSunset);
|
|
mPayload.addListener(std::bind(&PubMqttType::payloadEventListener, &mMqtt, std::placeholders::_1));
|
|
addListener(EVERY_SEC, std::bind(&PubMqttType::tickerSecond, &mMqtt));
|
|
addListener(EVERY_MIN, std::bind(&PubMqttType::tickerMinute, &mMqtt));
|
|
}
|
|
#endif
|
|
setupLed();
|
|
|
|
mWeb = new web(this, mConfig, &mStat, mVersion);
|
|
mWeb->setup();
|
|
mWeb->setProtection(strlen(mConfig->sys.adminPwd) != 0);
|
|
addListener(EVERY_SEC, std::bind(&web::tickSecond, mWeb));
|
|
|
|
//addListener(EVERY_MIN, std::bind(&PubSerialType::tickerMinute, &mPubSerial));
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void app::loop(void) {
|
|
DPRINTLN(DBG_VERBOSE, F("app::loop"));
|
|
|
|
ah::Scheduler::loop();
|
|
|
|
mWeb->loop();
|
|
|
|
if (mFlagSendDiscoveryConfig) {
|
|
mFlagSendDiscoveryConfig = false;
|
|
mMqtt.sendMqttDiscoveryConfig(mConfig->mqtt.topic);
|
|
}
|
|
|
|
mSys->Radio.loop();
|
|
|
|
yield();
|
|
|
|
if (ah::checkTicker(&mRxTicker, 5)) {
|
|
bool rxRdy = mSys->Radio.switchRxCh();
|
|
|
|
if (!mSys->BufCtrl.empty()) {
|
|
uint8_t len;
|
|
packet_t *p = mSys->BufCtrl.getBack();
|
|
|
|
if (mSys->Radio.checkPaketCrc(p->packet, &len, p->rxCh)) {
|
|
if (mConfig->serial.debug) {
|
|
DPRINT(DBG_INFO, "RX " + String(len) + "B Ch" + String(p->rxCh) + " | ");
|
|
mSys->Radio.dumpBuf(NULL, p->packet, len);
|
|
}
|
|
mStat.frmCnt++;
|
|
|
|
if (0 != len)
|
|
mPayload.add(p, len);
|
|
}
|
|
mSys->BufCtrl.popBack();
|
|
}
|
|
yield();
|
|
|
|
if (rxRdy)
|
|
mPayload.process(true, mConfig->nrf.maxRetransPerPyld, &mStat);
|
|
}
|
|
|
|
mMqtt.loop();
|
|
|
|
if (ah::checkTicker(&mTicker, 1000)) {
|
|
if (mUtcTimestamp > 946684800 && mConfig->sun.lat && mConfig->sun.lon && (mUtcTimestamp + mCalculatedTimezoneOffset) / 86400 != (mLatestSunTimestamp + mCalculatedTimezoneOffset) / 86400) { // update on reboot or midnight
|
|
if (!mLatestSunTimestamp) { // first call: calculate time zone from longitude to refresh at local midnight
|
|
mCalculatedTimezoneOffset = (int8_t)((mConfig->sun.lon >= 0 ? mConfig->sun.lon + 7.5 : mConfig->sun.lon - 7.5) / 15) * 3600;
|
|
}
|
|
ah::calculateSunriseSunset(mUtcTimestamp, mCalculatedTimezoneOffset, mConfig->sun.lat, mConfig->sun.lon, &mSunrise, &mSunset);
|
|
mLatestSunTimestamp = mUtcTimestamp;
|
|
}
|
|
|
|
|
|
|
|
if (++mSendTicker >= mConfig->nrf.sendInterval) {
|
|
mSendTicker = 0;
|
|
|
|
if (mUtcTimestamp > 946684800 && (!mConfig->sun.disNightCom || !mLatestSunTimestamp || (mUtcTimestamp >= mSunrise && mUtcTimestamp <= mSunset))) { // Timestamp is set and (inverter communication only during the day if the option is activated and sunrise/sunset is set)
|
|
if (mConfig->serial.debug)
|
|
DPRINTLN(DBG_DEBUG, F("Free heap: 0x") + String(ESP.getFreeHeap(), HEX));
|
|
|
|
if (!mSys->BufCtrl.empty()) {
|
|
if (mConfig->serial.debug)
|
|
DPRINTLN(DBG_DEBUG, F("recbuf not empty! #") + String(mSys->BufCtrl.getFill()));
|
|
}
|
|
|
|
int8_t maxLoop = MAX_NUM_INVERTERS;
|
|
Inverter<> *iv = mSys->getInverterByPos(mSendLastIvId);
|
|
do {
|
|
mSendLastIvId = ((MAX_NUM_INVERTERS - 1) == mSendLastIvId) ? 0 : mSendLastIvId + 1;
|
|
iv = mSys->getInverterByPos(mSendLastIvId);
|
|
} while ((NULL == iv) && ((maxLoop--) > 0));
|
|
|
|
if (NULL != iv) {
|
|
if (!mPayload.isComplete(iv))
|
|
mPayload.process(false, mConfig->nrf.maxRetransPerPyld, &mStat);
|
|
|
|
if (!mPayload.isComplete(iv)) {
|
|
if (0 == mPayload.getMaxPacketId(iv))
|
|
mStat.rxFailNoAnser++;
|
|
else
|
|
mStat.rxFail++;
|
|
|
|
iv->setQueuedCmdFinished(); // command failed
|
|
if (mConfig->serial.debug)
|
|
DPRINTLN(DBG_INFO, F("enqueued cmd failed/timeout"));
|
|
if (mConfig->serial.debug) {
|
|
DPRINT(DBG_INFO, F("(#") + String(iv->id) + ") ");
|
|
DPRINTLN(DBG_INFO, F("no Payload received! (retransmits: ") + String(mPayload.getRetransmits(iv)) + ")");
|
|
}
|
|
}
|
|
|
|
mPayload.reset(iv, mUtcTimestamp);
|
|
mPayload.request(iv);
|
|
|
|
yield();
|
|
if (mConfig->serial.debug) {
|
|
DPRINTLN(DBG_DEBUG, F("app:loop WiFi WiFi.status ") + String(WiFi.status()));
|
|
DPRINTLN(DBG_INFO, F("(#") + String(iv->id) + F(") Requesting Inv SN ") + String(iv->config->serial.u64, HEX));
|
|
}
|
|
|
|
if (iv->devControlRequest) {
|
|
if (mConfig->serial.debug)
|
|
DPRINTLN(DBG_INFO, F("(#") + String(iv->id) + F(") Devcontrol request ") + String(iv->devControlCmd) + F(" power limit ") + String(iv->powerLimit[0]));
|
|
mSys->Radio.sendControlPacket(iv->radioId.u64, iv->devControlCmd, iv->powerLimit);
|
|
mPayload.setTxCmd(iv, iv->devControlCmd);
|
|
iv->clearCmdQueue();
|
|
iv->enqueCommand<InfoCommand>(SystemConfigPara);
|
|
} else {
|
|
uint8_t cmd = iv->getQueuedCmd();
|
|
DPRINTLN(DBG_INFO, F("(#") + String(iv->id) + F(") sendTimePacket"));
|
|
mSys->Radio.sendTimePacket(iv->radioId.u64, cmd, mPayload.getTs(iv), iv->alarmMesIndex);
|
|
mPayload.setTxCmd(iv, cmd);
|
|
mRxTicker = 0;
|
|
}
|
|
}
|
|
} else if (mConfig->serial.debug)
|
|
DPRINTLN(DBG_WARN, F("Time not set or it is night time, therefore no communication to the inverter!"));
|
|
yield();
|
|
|
|
updateLed();
|
|
}
|
|
}
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void app::handleIntr(void) {
|
|
DPRINTLN(DBG_VERBOSE, F("app::handleIntr"));
|
|
mSys->Radio.handleIntr();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
bool app::getWifiApActive(void) {
|
|
return mWifi->getApActive();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void app::scanAvailNetworks(void) {
|
|
mWifi->scanAvailNetworks();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void app::getAvailNetworks(JsonObject obj) {
|
|
mWifi->getAvailNetworks(obj);
|
|
}
|
|
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void app::resetSystem(void) {
|
|
snprintf(mVersion, 12, "%d.%d.%d", VERSION_MAJOR, VERSION_MINOR, VERSION_PATCH);
|
|
|
|
mShouldReboot = false;
|
|
mUptimeSecs = 0;
|
|
mUpdateNtp = false;
|
|
mFlagSendDiscoveryConfig = false;
|
|
|
|
#ifdef AP_ONLY
|
|
mUtcTimestamp = 1;
|
|
#else
|
|
mUtcTimestamp = 0;
|
|
#endif
|
|
|
|
mHeapStatCnt = 0;
|
|
|
|
mSendTicker = 0xffff;
|
|
|
|
mTicker = 0;
|
|
mRxTicker = 0;
|
|
|
|
mSendLastIvId = 0;
|
|
|
|
mShowRebootRequest = false;
|
|
|
|
memset(&mStat, 0, sizeof(statistics_t));
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void app::setupLed(void) {
|
|
/** LED connection diagram
|
|
* \\
|
|
* PIN ---- |<----- 3.3V
|
|
*
|
|
* */
|
|
if(mConfig->led.led0 != 0xff) {
|
|
pinMode(mConfig->led.led0, OUTPUT);
|
|
digitalWrite(mConfig->led.led0, HIGH); // LED off
|
|
}
|
|
if(mConfig->led.led1 != 0xff) {
|
|
pinMode(mConfig->led.led1, OUTPUT);
|
|
digitalWrite(mConfig->led.led1, HIGH); // LED off
|
|
}
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void app::updateLed(void) {
|
|
if(mConfig->led.led0 != 0xff) {
|
|
Inverter<> *iv = mSys->getInverterByPos(0);
|
|
if (NULL != iv) {
|
|
record_t<> *rec = iv->getRecordStruct(RealTimeRunData_Debug);
|
|
if(iv->isProducing(mUtcTimestamp, rec))
|
|
digitalWrite(mConfig->led.led0, LOW); // LED on
|
|
else
|
|
digitalWrite(mConfig->led.led0, HIGH); // LED off
|
|
}
|
|
}
|
|
}
|
|
|