//----------------------------------------------------------------------------- // 2022 Ahoy, https://www.mikrocontroller.net/topic/525778 // Creative Commons - http://creativecommons.org/licenses/by-nc-sa/3.0/de/ //----------------------------------------------------------------------------- #include "app.h" #include "favicon.h" #include "html/h/index_html.h" #include "html/h/setup_html.h" #include "html/h/hoymiles_html.h" //----------------------------------------------------------------------------- app::app() : Main() { DPRINTLN(DBG_VERBOSE, F("app::app():Main")); mSendTicker = 0xffff; mSendInterval = 0; mMqttTicker = 0xffff; mMqttInterval = 0; mSerialTicker = 0xffff; mSerialInterval = 0; mMqttActive = false; mTicker = 0; mRxTicker = 0; mSendLastIvId = 0; mShowRebootRequest = false; mSerialValues = true; mSerialDebug = false; memset(mPayload, 0, (MAX_NUM_INVERTERS * sizeof(invPayload_t))); mRxFailed = 0; mRxSuccess = 0; mFrameCnt = 0; mLastPacketId = 0x00; mSys = new HmSystemType(); } //----------------------------------------------------------------------------- app::~app(void) { } //----------------------------------------------------------------------------- void app::setup(uint32_t timeout) { DPRINTLN(DBG_VERBOSE, F("app::setup")); Main::setup(timeout); mWeb->on("/", std::bind(&app::showIndex, this)); mWeb->on("/favicon.ico", std::bind(&app::showFavicon, this)); mWeb->on("/setup", std::bind(&app::showSetup, this)); mWeb->on("/save", std::bind(&app::showSave, this)); mWeb->on("/erase", std::bind(&app::showErase, this)); mWeb->on("/cmdstat", std::bind(&app::showStatistics, this)); mWeb->on("/hoymiles", std::bind(&app::showHoymiles, this)); mWeb->on("/livedata", std::bind(&app::showLiveData, this)); mWeb->on("/json", std::bind(&app::showJSON, this)); if(mSettingsValid) { mEep->read(ADDR_INV_INTERVAL, &mSendInterval); if(mSendInterval < 5) mSendInterval = 5; mSendTicker = mSendInterval; // inverter uint64_t invSerial; char name[MAX_NAME_LENGTH + 1] = {0}; uint16_t modPwr[4]; Inverter<> *iv; for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i ++) { mEep->read(ADDR_INV_ADDR + (i * 8), &invSerial); mEep->read(ADDR_INV_NAME + (i * MAX_NAME_LENGTH), name, MAX_NAME_LENGTH); mEep->read(ADDR_INV_CH_PWR + (i * 2 * 4), modPwr, 4); if(0ULL != invSerial) { iv = mSys->addInverter(name, invSerial, modPwr); if(NULL != iv) { DPRINTLN(DBG_INFO, F("add inverter: ") + String(name) + ", SN: " + String(invSerial, HEX)); for(uint8_t j = 0; j < 4; j++) { mEep->read(ADDR_INV_CH_NAME + (i * 4 * MAX_NAME_LENGTH) + j * MAX_NAME_LENGTH, name, MAX_NAME_LENGTH); snprintf(iv->chName[j], MAX_NAME_LENGTH, "%s", name); } } mMqttInterval += mSendInterval; } } mEep->read(ADDR_INV_MAX_RTRY, &mMaxRetransPerPyld); if(0 == mMaxRetransPerPyld) mMaxRetransPerPyld = DEF_MAX_RETRANS_PER_PYLD; // pinout mEep->read(ADDR_PINOUT, &mSys->Radio.pinCs); mEep->read(ADDR_PINOUT+1, &mSys->Radio.pinCe); mEep->read(ADDR_PINOUT+2, &mSys->Radio.pinIrq); if(mSys->Radio.pinCs == mSys->Radio.pinCe) { mSys->Radio.pinCs = RF24_CS_PIN; mSys->Radio.pinCe = RF24_CE_PIN; mSys->Radio.pinIrq = RF24_IRQ_PIN; } // nrf24 amplifier power mEep->read(ADDR_RF24_AMP_PWR, &mSys->Radio.AmplifierPower); // serial console uint8_t tmp; mEep->read(ADDR_SER_INTERVAL, &mSerialInterval); mEep->read(ADDR_SER_ENABLE, &tmp); mSerialValues = (tmp == 0x01); mEep->read(ADDR_SER_DEBUG, &tmp); mSerialDebug = (tmp == 0x01); if(mSerialInterval < 1) mSerialInterval = 1; mSys->Radio.mSerialDebug = mSerialDebug; // mqtt uint8_t mqttAddr[MQTT_ADDR_LEN]; uint16_t mqttPort; char mqttUser[MQTT_USER_LEN]; char mqttPwd[MQTT_PWD_LEN]; char mqttTopic[MQTT_TOPIC_LEN]; mEep->read(ADDR_MQTT_ADDR, mqttAddr, MQTT_ADDR_LEN); mEep->read(ADDR_MQTT_USER, mqttUser, MQTT_USER_LEN); mEep->read(ADDR_MQTT_PWD, mqttPwd, MQTT_PWD_LEN); mEep->read(ADDR_MQTT_TOPIC, mqttTopic, MQTT_TOPIC_LEN); //mEep->read(ADDR_MQTT_INTERVAL, &mMqttInterval); mEep->read(ADDR_MQTT_PORT, &mqttPort); char addr[16] = {0}; sprintf(addr, "%d.%d.%d.%d", mqttAddr[0], mqttAddr[1], mqttAddr[2], mqttAddr[3]); if(mqttAddr[0] > 0) { mMqttActive = true; if(mMqttInterval < 1) mMqttInterval = 10; } else mMqttInterval = 0xffff; if(0 == mqttPort) mqttPort = 1883; mMqtt.setup(addr, mqttTopic, mqttUser, mqttPwd, mqttPort); mMqttTicker = 0; mSerialTicker = 0; if(mqttAddr[0] > 0) { char topic[30]; mMqtt.sendMsg("version", mVersion); for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i ++) { iv = mSys->getInverterByPos(i); if(NULL != iv) { for(uint8_t i = 0; i < 4; i++) { if(0 != iv->chName[i][0]) { snprintf(topic, 30, "%s/ch%d/%s", iv->name, i+1, "name"); mMqtt.sendMsg(topic, iv->chName[i]); yield(); } } } } } } else { DPRINTLN(DBG_DEBUG, F("CRC pos: ") + String(ADDR_SETTINGS_CRC)); DPRINTLN(DBG_DEBUG, F("NXT pos: ") + String(ADDR_NEXT)); DPRINTLN(DBG_INFO, F("Settings not valid, erasing ...")); eraseSettings(); saveValues(false); delay(100); DPRINTLN(DBG_INFO, F("... restarting ...")); delay(100); ESP.restart(); } mSys->setup(); if(!mWifiSettingsValid) DPRINTLN(DBG_WARN, F("your settings are not valid! check [IP]/setup")); else { DPRINTLN(DBG_INFO, F("\n\n----------------------------------------")); DPRINTLN(DBG_INFO, F("Welcome to AHOY!")); DPRINT(DBG_INFO, F("\npoint your browser to http://")); if(mApActive) DBGPRINTLN(F("192.168.1.1")); else DBGPRINTLN(WiFi.localIP()); DPRINTLN(DBG_INFO, F("to configure your device")); DPRINTLN(DBG_INFO, F("----------------------------------------\n")); } } //----------------------------------------------------------------------------- void app::loop(void) { DPRINTLN(DBG_VERBOSE, F("app::loop")); Main::loop(); mSys->Radio.loop(); yield(); if(checkTicker(&mRxTicker, 5)) { DPRINTLN(DBG_DEBUG, F("app_loops =") + String(app_loops)); app_loops=0; DPRINT(DBG_DEBUG, F("a")); 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)) { // process buffer only on first occurrence if(mSerialDebug) { DPRINT(DBG_DEBUG, "Received " + String(len) + " bytes channel " + String(p->rxCh) + ": "); mSys->Radio.dumpBuf(NULL, p->packet, len); } mFrameCnt++; if(0 != len) { Inverter<> *iv = mSys->findInverter(&p->packet[1]); if(NULL != iv) { uint8_t *pid = &p->packet[9]; if((*pid & 0x7F) < 5) { memcpy(mPayload[iv->id].data[(*pid & 0x7F) - 1], &p->packet[10], len-11); mPayload[iv->id].len[(*pid & 0x7F) - 1] = len-11; } if((*pid & 0x80) == 0x80) { if((*pid & 0x7f) > mPayload[iv->id].maxPackId) { mPayload[iv->id].maxPackId = (*pid & 0x7f); if(*pid > 0x81) mLastPacketId = *pid; } } } } } mSys->BufCtrl.popBack(); } yield(); if(rxRdy) { processPayload(true); } } if(mMqttActive) mMqtt.loop(); if(checkTicker(&mTicker, 1000)) { if((++mMqttTicker >= mMqttInterval) && (mMqttInterval != 0xffff)) { mMqttTicker = 0; mMqtt.isConnected(true); char topic[30], val[10]; for(uint8_t id = 0; id < mSys->getNumInverters(); id++) { Inverter<> *iv = mSys->getInverterByPos(id); if(NULL != iv) { if(iv->isAvailable(mTimestamp)) { for(uint8_t i = 0; i < iv->listLen; i++) { snprintf(topic, 30, "%s/ch%d/%s", iv->name, iv->assign[i].ch, fields[iv->assign[i].fieldId]); snprintf(val, 10, "%.3f", iv->getValue(i)); mMqtt.sendMsg(topic, val); yield(); } } } } snprintf(val, 10, "%d", millis()/1000); mMqtt.sendMsg("uptime", val); } if(mSerialValues) { if(++mSerialTicker >= mSerialInterval) { mSerialTicker = 0; char topic[30], val[10]; for(uint8_t id = 0; id < mSys->getNumInverters(); id++) { Inverter<> *iv = mSys->getInverterByPos(id); if(NULL != iv) { if(iv->isAvailable(mTimestamp)) { for(uint8_t i = 0; i < iv->listLen; i++) { if(0.0f != iv->getValue(i)) { snprintf(topic, 30, "%s/ch%d/%s", iv->name, iv->assign[i].ch, iv->getFieldName(i)); snprintf(val, 10, "%.3f %s", iv->getValue(i), iv->getUnit(i)); DPRINTLN(DBG_INFO, String(topic) + ": " + String(val)); } yield(); } } } } } } if(++mSendTicker >= mSendInterval) { mSendTicker = 0; if(0 != mTimestamp) { if(mSerialDebug) DPRINTLN(DBG_DEBUG, F("Free heap: 0x") + String(ESP.getFreeHeap(), HEX)); if(!mSys->BufCtrl.empty()) { if(mSerialDebug) DPRINTLN(DBG_DEBUG, F("recbuf not empty! #") + String(mSys->BufCtrl.getFill())); } int8_t maxLoop = MAX_NUM_INVERTERS; Inverter<> *iv = mSys->getInverterByPos(mSendLastIvId); do { if(NULL != iv) mPayload[iv->id].requested = false; mSendLastIvId = ((MAX_NUM_INVERTERS-1) == mSendLastIvId) ? 0 : mSendLastIvId + 1; iv = mSys->getInverterByPos(mSendLastIvId); } while((NULL == iv) && ((maxLoop--) > 0)); if(NULL != iv) { if(!mPayload[iv->id].complete) processPayload(false); if(!mPayload[iv->id].complete) { mRxFailed++; if(mSerialDebug) { DPRINT(DBG_INFO, F("Inverter #") + String(iv->id) + " "); DPRINTLN(DBG_INFO, F("no Payload received! (retransmits: ") + String(mPayload[iv->id].retransmits) + ")"); } } // reset payload data memset(mPayload[iv->id].len, 0, MAX_PAYLOAD_ENTRIES); mPayload[iv->id].retransmits = 0; mPayload[iv->id].maxPackId = 0; mPayload[iv->id].complete = false; mPayload[iv->id].requested = true; mPayload[iv->id].ts = mTimestamp; yield(); if(mSerialDebug) DPRINTLN(DBG_INFO, F("Requesting Inverter SN ") + String(iv->serial.u64, HEX)); mSys->Radio.sendTimePacket(iv->radioId.u64, mPayload[iv->id].ts); mRxTicker = 0; } } else if(mSerialDebug) DPRINTLN(DBG_WARN, F("time not set, can't request inverter!")); yield(); } } } //----------------------------------------------------------------------------- void app::handleIntr(void) { DPRINTLN(DBG_VERBOSE, F("app::handleIntr")); mSys->Radio.handleIntr(); } //----------------------------------------------------------------------------- bool app::buildPayload(uint8_t id) { DPRINTLN(DBG_VERBOSE, F("app::buildPayload")); uint16_t crc = 0xffff, crcRcv; if(mPayload[id].maxPackId > MAX_PAYLOAD_ENTRIES) mPayload[id].maxPackId = MAX_PAYLOAD_ENTRIES; for(uint8_t i = 0; i < mPayload[id].maxPackId; i ++) { if(mPayload[id].len[i] > 0) { if(i == (mPayload[id].maxPackId-1)) { crc = crc16(mPayload[id].data[i], mPayload[id].len[i] - 2, crc); crcRcv = (mPayload[id].data[i][mPayload[id].len[i] - 2] << 8) | (mPayload[id].data[i][mPayload[id].len[i] - 1]); } else crc = crc16(mPayload[id].data[i], mPayload[id].len[i], crc); } yield(); } if(crc == crcRcv) return true; return false; } //----------------------------------------------------------------------------- void app::processPayload(bool retransmit) { DPRINTLN(DBG_VERBOSE, F("app::processPayload")); for(uint8_t id = 0; id < mSys->getNumInverters(); id++) { Inverter<> *iv = mSys->getInverterByPos(id); if(NULL != iv) { if(!mPayload[iv->id].complete) { if(!buildPayload(iv->id)) { if(mPayload[iv->id].requested) { if(retransmit) { if(mPayload[iv->id].retransmits < mMaxRetransPerPyld) { mPayload[iv->id].retransmits++; if(mPayload[iv->id].maxPackId != 0) { for(uint8_t i = 0; i < (mPayload[iv->id].maxPackId-1); i ++) { if(mPayload[iv->id].len[i] == 0) { if(mSerialDebug) DPRINTLN(DBG_ERROR, F("while retrieving data: Frame ") + String(i+1) + F(" missing: Request Retransmit")); mSys->Radio.sendCmdPacket(iv->radioId.u64, 0x15, (0x81+i), true); break; // only retransmit one frame per loop } yield(); } } else { if(mSerialDebug) DPRINTLN(DBG_ERROR, F("while retrieving data: last frame missing: Request Retransmit")); if(0x00 != mLastPacketId) mSys->Radio.sendCmdPacket(iv->radioId.u64, 0x15, mLastPacketId, true); else mSys->Radio.sendTimePacket(iv->radioId.u64, mPayload[iv->id].ts); } mSys->Radio.switchRxCh(100); } } } } else { mPayload[iv->id].complete = true; iv->ts = mPayload[iv->id].ts; uint8_t payload[128] = {0}; uint8_t offs = 0; for(uint8_t i = 0; i < (mPayload[iv->id].maxPackId); i ++) { memcpy(&payload[offs], mPayload[iv->id].data[i], (mPayload[iv->id].len[i])); offs += (mPayload[iv->id].len[i]); yield(); } offs-=2; if(mSerialDebug) { DPRINT(DBG_INFO, F("Payload (") + String(offs) + "): "); mSys->Radio.dumpBuf(NULL, payload, offs); } mRxSuccess++; for(uint8_t i = 0; i < iv->listLen; i++) { iv->addValue(i, payload); yield(); } iv->doCalculations(); } } yield(); } } } //----------------------------------------------------------------------------- void app::showIndex(void) { DPRINTLN(DBG_VERBOSE, F("app::showIndex")); String html = FPSTR(index_html); html.replace(F("{DEVICE}"), mDeviceName); html.replace(F("{VERSION}"), mVersion); html.replace(F("{TS}"), String(mSendInterval) + " "); html.replace(F("{JS_TS}"), String(mSendInterval * 1000)); mWeb->send(200, "text/html", html); } //----------------------------------------------------------------------------- void app::showSetup(void) { DPRINTLN(DBG_VERBOSE, F("app::showSetup")); // overrides same method in main.cpp uint16_t interval; String html = FPSTR(setup_html); html.replace(F("{SSID}"), mStationSsid); // PWD will be left at the default value (for protection) // -> the PWD will only be changed if it does not match the placeholder "{PWD}" html.replace(F("{DEVICE}"), String(mDeviceName)); html.replace(F("{VERSION}"), String(mVersion)); if(mApActive) html.replace(F("{IP}"), String(F("http://192.168.1.1"))); else html.replace(F("{IP}"), ("http://" + String(WiFi.localIP().toString()))); String inv; uint64_t invSerial; char name[MAX_NAME_LENGTH + 1] = {0}; uint8_t invType; uint16_t modPwr[4]; for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i ++) { mEep->read(ADDR_INV_ADDR + (i * 8), &invSerial); mEep->read(ADDR_INV_NAME + (i * MAX_NAME_LENGTH), name, MAX_NAME_LENGTH); mEep->read(ADDR_INV_CH_PWR + (i * 2 * 4), modPwr, 4); inv += F("

Inverter ") + String(i) + "

"; inv += F(""); inv += F(""); inv += F(""); inv += F(""; inv += F(""); for(uint8_t j = 0; j < 4; j++) { inv += F(""); } inv += F("
"); for(uint8_t j = 0; j < 4; j++) { mEep->read(ADDR_INV_CH_NAME + (i * 4 * MAX_NAME_LENGTH) + j * MAX_NAME_LENGTH, name, MAX_NAME_LENGTH); inv += F(""; } } html.replace(F("{INVERTERS}"), String(inv)); // pinout String pinout; for(uint8_t i = 0; i < 3; i++) { pinout += F(""); pinout += F(""); } html.replace(F("{PINOUT}"), String(pinout)); // nrf24l01+ String rf24; for(uint8_t i = 0; i <= 3; i++) { rf24 += F(""); } html.replace(F("{RF24}"), String(rf24)); if(mSettingsValid) { html.replace(F("{INV_INTVL}"), String(mSendInterval)); html.replace(F("{INV_RETRIES}"), String(mMaxRetransPerPyld)); uint8_t tmp; mEep->read(ADDR_SER_ENABLE, &tmp); html.replace(F("{SER_INTVL}"), String(mSerialInterval)); html.replace(F("{SER_VAL_CB}"), (tmp == 0x01) ? "checked" : ""); mEep->read(ADDR_SER_DEBUG, &tmp); html.replace(F("{SER_DBG_CB}"), (tmp == 0x01) ? "checked" : ""); uint8_t mqttAddr[MQTT_ADDR_LEN] = {0}; uint16_t mqttPort; mEep->read(ADDR_MQTT_ADDR, mqttAddr, MQTT_ADDR_LEN); mEep->read(ADDR_MQTT_PORT, &mqttPort); char addr[16] = {0}; sprintf(addr, "%d.%d.%d.%d", mqttAddr[0], mqttAddr[1], mqttAddr[2], mqttAddr[3]); html.replace(F("{MQTT_ADDR}"), String(addr)); html.replace(F("{MQTT_PORT}"), String(mMqtt.getPort())); html.replace(F("{MQTT_USER}"), String(mMqtt.getUser())); html.replace(F("{MQTT_PWD}"), String(mMqtt.getPwd())); html.replace(F("{MQTT_TOPIC}"), String(mMqtt.getTopic())); html.replace(F("{MQTT_INTVL}"), String(mMqttInterval)); } mWeb->send(200, F("text/html"), html); } //----------------------------------------------------------------------------- void app::showSave(void) { DPRINTLN(DBG_VERBOSE, F("app::showSave")); saveValues(true); } //----------------------------------------------------------------------------- void app::showErase() { DPRINTLN(DBG_VERBOSE, F("app::showErase")); eraseSettings(); showReboot(); } //----------------------------------------------------------------------------- void app::showStatistics(void) { DPRINTLN(DBG_VERBOSE, F("app::showStatistics")); String content = F("Receive success: ") + String(mRxSuccess) + "\n"; content += F("Receive fail: ") + String(mRxFailed) + "\n"; content += F("Frames received: ") + String(mFrameCnt) + "\n"; content += F("Send Cnt: ") + String(mSys->Radio.mSendCnt) + String("\n\n"); Inverter<> *iv; for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i++) { iv = mSys->getInverterByPos(i); if(NULL != iv) { bool avail = true; content += F("Inverter '") + String(iv->name) + F("' is "); if(!iv->isAvailable(mTimestamp)) { content += F("not "); avail = false; } content += F("available and is "); if(!iv->isProducing(mTimestamp)) content += F("not "); content += F("producing\n"); if(!avail) { if(iv->getLastTs() > 0) content += F("-> last successful transmission: ") + getDateTimeStr(iv->getLastTs()) + "\n"; } } else { content += F("Inverter ") + String(i) + F(" not (correctly) configured\n"); } } if(!mSys->Radio.isChipConnected()) content += F("WARNING! your NRF24 module can't be reached, check the wiring and pinout (setup)\n"); if(mShowRebootRequest) content += F("INFO: reboot your ESP to apply all your configuration changes!\n"); if(!mSettingsValid) content += F("INFO: your settings are invalid, please switch to Setup to correct this.\n"); content += F("MQTT: "); if(!mMqtt.isConnected()) content += F("not "); content += F("connected\n"); mWeb->send(200, F("text/plain"), content); } //----------------------------------------------------------------------------- void app::showHoymiles(void) { DPRINTLN(DBG_VERBOSE, F("app::showHoymiles")); String html = FPSTR(hoymiles_html); html.replace(F("{DEVICE}"), mDeviceName); html.replace(F("{VERSION}"), mVersion); html.replace(F("{TS}"), String(mSendInterval) + " "); html.replace(F("{JS_TS}"), String(mSendInterval * 1000)); mWeb->send(200, F("text/html"), html); } //----------------------------------------------------------------------------- void app::showFavicon(void) { DPRINTLN(DBG_VERBOSE, F("app::showFavicon")); static const char favicon_type[] PROGMEM = "image/x-icon"; static const char favicon_content[] PROGMEM = FAVICON_PANEL_16; mWeb->send_P(200, favicon_type, favicon_content, sizeof(favicon_content)); } //----------------------------------------------------------------------------- void app::showLiveData(void) { DPRINTLN(DBG_VERBOSE, F("app::showLiveData")); String modHtml; for(uint8_t id = 0; id < mSys->getNumInverters(); id++) { Inverter<> *iv = mSys->getInverterByPos(id); if(NULL != iv) { #ifdef LIVEDATA_VISUALIZED uint8_t modNum, pos; switch(iv->type) { default: case INV_TYPE_1CH: modNum = 1; break; case INV_TYPE_2CH: modNum = 2; break; case INV_TYPE_4CH: modNum = 4; break; } modHtml += F("
" "
") + String(iv->name) + F(""); uint8_t list[] = {FLD_UAC, FLD_IAC, FLD_PAC, FLD_F, FLD_PCT, FLD_T, FLD_YT, FLD_YD, FLD_PDC, FLD_EFF}; for(uint8_t fld = 0; fld < 10; fld++) { pos = (iv->getPosByChFld(CH0, list[fld])); if(0xff != pos) { modHtml += F("
"); modHtml += F("") + String(iv->getValue(pos)); modHtml += F("") + String(iv->getUnit(pos)) + F(""); modHtml += F("") + String(iv->getFieldName(pos)) + F(""); modHtml += F("
"); } } modHtml += "
"; for(uint8_t ch = 1; ch <= modNum; ch ++) { modHtml += F("
"); if(iv->chName[ch-1][0] == 0) modHtml += F("CHANNEL ") + String(ch); else modHtml += String(iv->chName[ch-1]); modHtml += F(""); for(uint8_t j = 0; j < 6; j++) { switch(j) { default: pos = (iv->getPosByChFld(ch, FLD_UDC)); break; case 1: pos = (iv->getPosByChFld(ch, FLD_IDC)); break; case 2: pos = (iv->getPosByChFld(ch, FLD_PDC)); break; case 3: pos = (iv->getPosByChFld(ch, FLD_YD)); break; case 4: pos = (iv->getPosByChFld(ch, FLD_YT)); break; case 5: pos = (iv->getPosByChFld(ch, FLD_IRR)); break; } if(0xff != pos) { modHtml += F("") + String(iv->getValue(pos)); modHtml += F("") + String(iv->getUnit(pos)) + F(""); modHtml += F("") + String(iv->getFieldName(pos)) + F(""); } } modHtml += "
"; yield(); } modHtml += F("
Last received data requested at: ") + getDateTimeStr(iv->ts) + F("
"); modHtml += F("
"); #else // dump all data to web frontend modHtml = F("
");
            char topic[30], val[10];
            for(uint8_t i = 0; i < iv->listLen; i++) {
                snprintf(topic, 30, "%s/ch%d/%s", iv->name, iv->assign[i].ch, iv->getFieldName(i));
                snprintf(val, 10, "%.3f %s", iv->getValue(i), iv->getUnit(i));
                modHtml += String(topic) + ": " + String(val) + "\n";
            }
            modHtml += F("
"); #endif } } mWeb->send(200, F("text/html"), modHtml); } //----------------------------------------------------------------------------- void app::showJSON(void) { DPRINTLN(DBG_VERBOSE, F("app::showJSON")); String modJson; modJson = F("{\n"); for(uint8_t id = 0; id < mSys->getNumInverters(); id++) { Inverter<> *iv = mSys->getInverterByPos(id); if(NULL != iv) { char topic[40], val[25]; snprintf(topic, 30, "\"%s\": {\n", iv->name); modJson += String(topic); for(uint8_t i = 0; i < iv->listLen; i++) { snprintf(topic, 40, "\t\"ch%d/%s\"", iv->assign[i].ch, iv->getFieldName(i)); snprintf(val, 25, "[%.3f, \"%s\"]", iv->getValue(i), iv->getUnit(i)); modJson += String(topic) + ": " + String(val) + F(",\n"); } modJson += F("\t\"last_msg\": \"") + getDateTimeStr(iv->ts) + F("\"\n\t},\n"); } } modJson += F("\"json_ts\": \"") + String(getDateTimeStr(mTimestamp)) + F("\"\n}\n"); // mWeb->send(200, F("text/json"), modJson); mWeb->send(200, F("application/json"), modJson); // the preferred content-type (https://stackoverflow.com/questions/22406077/what-is-the-exact-difference-between-content-type-text-json-and-application-jso) } //----------------------------------------------------------------------------- void app::saveValues(bool webSend = true) { DPRINTLN(DBG_VERBOSE, F("app::saveValues")); Main::saveValues(false); // general configuration if(mWeb->args() > 0) { char *p; char buf[20] = {0}; uint8_t i = 0; uint16_t interval; // inverter serial_u addr; for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i ++) { // address mWeb->arg("inv" + String(i) + "Addr").toCharArray(buf, 20); if(strlen(buf) == 0) snprintf(buf, 20, "\0"); addr.u64 = Serial2u64(buf); mEep->write(ADDR_INV_ADDR + (i * 8), addr.u64); // name mWeb->arg("inv" + String(i) + "Name").toCharArray(buf, 20); mEep->write(ADDR_INV_NAME + (i * MAX_NAME_LENGTH), buf, MAX_NAME_LENGTH); // max channel power / name for(uint8_t j = 0; j < 4; j++) { uint16_t pwr = mWeb->arg("inv" + String(i) + "ModPwr" + String(j)).toInt(); mEep->write(ADDR_INV_CH_PWR + (i * 2 * 4) + (j*2), pwr); memset(buf, 0, 20); mWeb->arg("inv" + String(i) + "ModName" + String(j)).toCharArray(buf, 20); mEep->write(ADDR_INV_CH_NAME + (i * 4 * MAX_NAME_LENGTH) + j * MAX_NAME_LENGTH, buf, MAX_NAME_LENGTH); } } interval = mWeb->arg("invInterval").toInt(); mEep->write(ADDR_INV_INTERVAL, interval); i = mWeb->arg("invRetry").toInt(); mEep->write(ADDR_INV_MAX_RTRY, i); // pinout for(uint8_t i = 0; i < 3; i ++) { uint8_t pin = mWeb->arg(String(pinArgNames[i])).toInt(); mEep->write(ADDR_PINOUT + i, pin); } // nrf24 amplifier power mSys->Radio.AmplifierPower = mWeb->arg("rf24Power").toInt() & 0x03; mEep->write(ADDR_RF24_AMP_PWR, mSys->Radio.AmplifierPower); // mqtt uint8_t mqttAddr[MQTT_ADDR_LEN] = {0}; uint16_t mqttPort; char mqttUser[MQTT_USER_LEN]; char mqttPwd[MQTT_PWD_LEN]; char mqttTopic[MQTT_TOPIC_LEN]; mWeb->arg("mqttAddr").toCharArray(buf, 20); i = 0; p = strtok(buf, "."); while(NULL != p) { mqttAddr[i++] = atoi(p); p = strtok(NULL, "."); } mWeb->arg("mqttUser").toCharArray(mqttUser, MQTT_USER_LEN); mWeb->arg("mqttPwd").toCharArray(mqttPwd, MQTT_PWD_LEN); mWeb->arg("mqttTopic").toCharArray(mqttTopic, MQTT_TOPIC_LEN); //interval = mWeb->arg("mqttIntvl").toInt(); mqttPort = mWeb->arg("mqttPort").toInt(); mEep->write(ADDR_MQTT_ADDR, mqttAddr, MQTT_ADDR_LEN); mEep->write(ADDR_MQTT_PORT, mqttPort); mEep->write(ADDR_MQTT_USER, mqttUser, MQTT_USER_LEN); mEep->write(ADDR_MQTT_PWD, mqttPwd, MQTT_PWD_LEN); mEep->write(ADDR_MQTT_TOPIC, mqttTopic, MQTT_TOPIC_LEN); //mEep->write(ADDR_MQTT_INTERVAL, interval); // serial console bool tmp; interval = mWeb->arg("serIntvl").toInt(); mEep->write(ADDR_SER_INTERVAL, interval); tmp = (mWeb->arg("serEn") == "on"); mEep->write(ADDR_SER_ENABLE, (uint8_t)((tmp) ? 0x01 : 0x00)); mSerialDebug = (mWeb->arg("serDbg") == "on"); mEep->write(ADDR_SER_DEBUG, (uint8_t)((mSerialDebug) ? 0x01 : 0x00)); DPRINT(DBG_INFO, "Serial debug is "); if(mSerialDebug) DPRINTLN(DBG_INFO, "on"); else DPRINTLN(DBG_INFO, "off"); mSys->Radio.mSerialDebug = mSerialDebug; updateCrc(); mEep->commit(); if((mWeb->arg("reboot") == "on")) showReboot(); else { mShowRebootRequest = true; mWeb->send(200, F("text/html"), F("Setup saved" "

saved

")); } } else { updateCrc(); mEep->commit(); mWeb->send(200, F("text/html"), F("Error" "

Error while saving

")); } } //----------------------------------------------------------------------------- void app::updateCrc(void) { DPRINTLN(DBG_VERBOSE, F("app::updateCrc")); Main::updateCrc(); uint16_t crc; crc = buildEEpCrc(ADDR_START_SETTINGS, ((ADDR_NEXT) - (ADDR_START_SETTINGS))); DPRINTLN(DBG_DEBUG, F("new CRC: ") + String(crc, HEX)); mEep->write(ADDR_SETTINGS_CRC, crc); }