summaryrefslogtreecommitdiff
path: root/src/matrixdisplay.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/matrixdisplay.cpp')
-rwxr-xr-xsrc/matrixdisplay.cpp585
1 files changed, 585 insertions, 0 deletions
diff --git a/src/matrixdisplay.cpp b/src/matrixdisplay.cpp
new file mode 100755
index 0000000..40433a9
--- /dev/null
+++ b/src/matrixdisplay.cpp
@@ -0,0 +1,585 @@
+#define VERTICAL 1
+#define ENA_SPRITE 1
+#include <Arduino.h>
+#include <MD_Parola.h>
+#include <MD_MAX72xx.h>
+#include <SPI.h>
+#include <Preferences.h>
+#include <WiFi.h>
+#include <WebServer.h>
+#include <ArduinoJson.h>
+#include <string.h>
+#include <stddef.h>
+#include "time.h"
+#include "index.h"
+#undef VERTICAL
+#ifdef VERTICAL
+#include "font.h"
+#endif
+
+#include <Dictionary.h>
+#include "esp_log.h"
+
+#include <ESPmDNS.h>
+#include <WiFiUdp.h>
+#include <ArduinoOTA.h>
+
+const char *ntpServer = "pool.ntp.org";
+const char *tzone = "AEST-10AEDT,M10.1.0,M4.1.0/3";
+
+Preferences preferences;
+TaskHandle_t wifitask;
+#define HARDWARE_TYPE MD_MAX72XX::FC16_HW
+#define MAX_DEVICES 16
+#define CS_PIN 5
+
+#define NUM_MESSAGES 20
+#define MSG_SIZE 200
+JsonDocument jsonDocument;
+JsonDocument jsonPumps;
+
+// ap
+const char *ssid = "dev test wip";
+const char *password = "devtest123";
+
+IPAddress dns1(1, 1, 1, 1);
+IPAddress dns2(8, 8, 8, 8);
+
+/* Put IP Address details */
+IPAddress local_ip(192, 168, 1, 1);
+IPAddress gateway(192, 168, 1, 1);
+IPAddress subnet(255, 255, 255, 0);
+WebServer server(80);
+
+struct
+{
+ int pos;
+ int brightness;
+ char cssid[256];
+ char cpassword[256];
+ char date[32];
+
+} globalconf;
+char pumpmsg[MSG_SIZE];
+struct message
+{
+ bool enabled;
+ bool invert;
+ char msg[MSG_SIZE];
+ textEffect_t effect1;
+ textEffect_t effect2;
+ int scrollpause;
+ int speed;
+};
+
+bool wificonnected;
+
+void saveconfig();
+void printLocalTime();
+void loadconfig();
+void defaultdata();
+
+struct message messages[NUM_MESSAGES] = {0};
+
+MD_Parola myDisplay = MD_Parola(HARDWARE_TYPE, CS_PIN, MAX_DEVICES);
+
+void handleroot()
+{
+ server.send(200, "text/html", index_html);
+}
+
+Dictionary *pumpDic = new Dictionary();
+
+void pumpstring()
+{
+ /*
+ pump1, pump2, pump3 ...
+ vs
+ thisvar=thisval, thatvar=thatval
+ */
+ String body = server.arg("plain");
+ deserializeJson(jsonPumps, body);
+ String msgjson = jsonPumps["pump"];
+ strncpy(pumpmsg, msgjson.c_str(), MSG_SIZE);
+ printf("pump: %s\n", pumpmsg);
+ printf("%s\n", body.c_str());
+ pumpDic->jload(body.c_str());
+ printf("value is %s: size is %d\n", pumpDic->search("test1").c_str(), pumpDic->size());
+
+ server.send(200, "text/html", pumpmsg);
+}
+
+void handlein()
+{
+ // save
+ String body = server.arg("plain");
+ deserializeJson(jsonDocument, body);
+ int brightness = jsonDocument["brightness"];
+ String cssid = jsonDocument["cssid"];
+ String cpassword = jsonDocument["cpassword"];
+ String date = jsonDocument["datep"];
+ globalconf.brightness = brightness;
+ strncpy(globalconf.cssid, cssid.c_str(), 256);
+ strncpy(globalconf.cpassword, cpassword.c_str(), 256);
+ strncpy(globalconf.date, date.c_str(), 32);
+ printf("Saving wifi: \"%s\" \"%s\"\n", globalconf.cssid, globalconf.cpassword);
+
+ char mstring[15];
+ char m[15];
+ char menabled[15];
+ char minvert[15];
+ char meffect[15];
+ char meffect2[15];
+ char mpause[15];
+ char mspeed[15];
+
+ for (int i = 0; i < NUM_MESSAGES; i++)
+ {
+ sprintf(m, "m%d", i + 1);
+ sprintf(menabled, "m%denabled", i + 1);
+ sprintf(minvert, "m%dinvert", i + 1);
+ sprintf(meffect, "m%deffect", i + 1);
+ sprintf(meffect2, "m%deffect2", i + 1);
+ sprintf(mpause, "m%dpause", i + 1);
+ sprintf(mspeed, "m%dspeed", i + 1);
+ sprintf(mstring, "m%d", i + 1);
+ String msg = jsonDocument[mstring];
+ messages[i].enabled = (jsonDocument[menabled] == "Enabled") ? true : false;
+ strncpy(messages[i].msg, msg.c_str(), MSG_SIZE);
+ if (jsonDocument[minvert] == "Invert")
+ {
+ messages[i].invert = 1;
+ }
+ else
+ {
+ messages[i].invert = 0;
+ }
+ String m1eff = jsonDocument[meffect];
+ String m2eff = jsonDocument[meffect2];
+ messages[i].effect1 = (textEffect_t)m1eff.toInt();
+ messages[i].effect2 = (textEffect_t)m2eff.toInt();
+ // if (jsonDocument[meffect] == "rtl"){messages[i].effect1 = PA_SCROLL_LEFT;} else {messages[i].effect1 = PA_SCROLL_RIGHT;}
+ // if (jsonDocument[mpause] == "Pause"){messages[i].scrollpause = 2000;} else {messages[i].scrollpause = 0;}
+ String p = jsonDocument[mpause];
+ int pause = atoi(p.c_str());
+ messages[i].scrollpause = pause;
+ if (jsonDocument[mspeed] == "slow")
+ {
+ messages[i].speed = 60;
+ }
+ else if (jsonDocument[mspeed] == "medium")
+ {
+ messages[i].speed = 40;
+ }
+ else if (jsonDocument[mspeed] == "fast")
+ {
+ messages[i].speed = 20;
+ }
+ else
+ {
+ messages[i].speed = 40;
+ }
+ printf("message to save: %s\n", messages[i].msg);
+ }
+
+ saveconfig();
+
+ server.send(200, "application/json", "{}");
+}
+
+char buffer[10800];
+char wifistatus[32] = {0};
+void handleconfigout()
+{
+ jsonDocument.clear();
+ jsonDocument["brightness"] = globalconf.brightness;
+ jsonDocument["cssid"] = globalconf.cssid;
+ jsonDocument["cpassword"] = globalconf.cpassword;
+ jsonDocument["datep"] = globalconf.date;
+
+ if (WiFi.localIP())
+ {
+ strncpy(wifistatus, WiFi.localIP().toString().c_str(), 32);
+ }
+ else
+ {
+ strncpy(wifistatus, "Not connected", 32);
+ }
+ jsonDocument["wifistatus"] = wifistatus;
+
+ char m[15];
+ char menabled[15];
+ char minvert[15];
+ char meffect[15];
+ char meffect2[15];
+ char mpause[15];
+ char mspeed[15];
+
+ for (int i = 0; i < NUM_MESSAGES; i++)
+ {
+ sprintf(m, "m%d", i + 1);
+ sprintf(menabled, "m%denabled", i + 1);
+ sprintf(minvert, "m%dinvert", i + 1);
+ sprintf(meffect, "m%deffect", i + 1);
+ sprintf(meffect2, "m%deffect2", i + 1);
+ sprintf(mpause, "m%dpause", i + 1);
+ sprintf(mspeed, "m%dspeed", i + 1);
+
+ jsonDocument[m] = messages[i].msg;
+ jsonDocument[menabled] = messages[i].enabled;
+ jsonDocument[minvert] = messages[i].invert;
+ jsonDocument[meffect] = messages[i].effect1; // TO INTERPRET
+ jsonDocument[meffect2] = messages[i].effect2; // TO INTERPRET
+ jsonDocument[mpause] = messages[i].scrollpause; // TO INTERPRET
+ jsonDocument[mspeed] = messages[i].speed; // TO INTERPRET
+ }
+
+ serializeJson(jsonDocument, buffer);
+ server.send(200, "application/json", buffer);
+}
+
+void handlenotfound()
+{
+}
+
+void resetesp32()
+{
+ ESP.restart();
+}
+
+void synctime()
+{
+ printf("Syncing time\n");
+ configTime(0, 0, ntpServer);
+}
+
+void wifi(void *pvParameters)
+{
+ Serial.println("start wifi");
+ WiFi.mode(WIFI_STA);
+ Serial.println("set wifi mode\n");
+ // web serverrouting
+ server.on("/", handleroot);
+ server.on("/msg", HTTP_POST, handlein);
+ server.on("/config", handleconfigout);
+ server.on("/reset", resetesp32);
+ server.on("/pump", pumpstring);
+
+ server.begin();
+ int retry = 0;
+ WiFi.begin(globalconf.cssid, globalconf.cpassword);
+ //WiFi.begin("nodwdw", "wqdqwr23er23");
+ printf("wifi connect to: %s : %s\n", globalconf.cssid, globalconf.cpassword);
+ Serial.println("Connecting to WiFi..");
+ while (WiFi.status() != WL_CONNECTED)
+ {
+ delay(500);
+ Serial.print(".");
+ retry++;
+ if (retry > 10)
+ {
+ printf("Too many first boot connect attempts to wifi.\nStarting AP mode..\n");
+ WiFi.disconnect();
+ WiFi.mode(WIFI_STA);
+ WiFi.softAPConfig(local_ip, gateway, subnet);
+ WiFi.softAP(ssid, password);
+ IPAddress IP = WiFi.softAPIP();
+ Serial.print("AP IP address: ");
+ Serial.println(IP);
+ break;
+ }
+ }
+ wificonnected = WiFi.status() == WL_CONNECTED;
+ if (retry <= 10 && wificonnected)
+ {
+ Serial.print("ESP32 IP on the WiFi network: ");
+ Serial.println(WiFi.localIP());
+ Serial.println(WiFi.dnsIP());
+ synctime();
+ setenv("TZ", tzone, 1);
+ tzset();
+ printLocalTime();
+ ArduinoOTA.begin();
+ }
+
+ const unsigned long hourInterval = 3600000; // 1 hour in milliseconds
+ unsigned long previousMillis = 0;
+ unsigned long currentMillis = 0;
+ while (1)
+ {
+ server.handleClient();
+ if (wificonnected)
+ {
+ ArduinoOTA.handle();
+ }
+ // sync time hourly
+ currentMillis = millis();
+ if (wificonnected && currentMillis - previousMillis >= hourInterval)
+ {
+ previousMillis = currentMillis;
+ synctime();
+ }
+ // delay(400);
+ }
+}
+
+uint8_t scrollSpeed = 40; // default frame delay value
+textEffect_t scrollEffect = PA_SCROLL_LEFT;
+textPosition_t scrollAlign = PA_LEFT;
+uint16_t scrollPause = 2000;
+
+void printLocalTime()
+{
+ struct tm timeinfo;
+ if (!getLocalTime(&timeinfo))
+ {
+ Serial.println("Failed to obtain time");
+ return;
+ }
+ Serial.println(&timeinfo, "%A, %B %d %Y %H:%M:%S");
+}
+
+void setup()
+{
+ wificonnected = false;
+ esp_log_level_set("*", ESP_LOG_VERBOSE);
+ preferences.begin("matrixdisplay", false);
+ globalconf.pos = 0;
+ globalconf.brightness = 7;
+ Serial.begin(115200);
+ // Intialize the object
+ myDisplay.begin();
+ loadconfig();
+#ifdef VERTICAL
+ myDisplay.setFont(_fontVertical);
+ myDisplay.setInvert(9);
+#endif
+ // Set the intensity (brightness) of the display (0-15)
+ myDisplay.setIntensity(5);
+
+ // Clear the display
+ myDisplay.displayClear();
+ xTaskCreatePinnedToCore(
+ wifi, /* Task function. */
+ "Task1", /* name of task. */
+ 10000, /* Stack size of task */
+ NULL, /* parameter of the task */
+ 1, /* priority of the task */
+ &wifitask, /* Task handle to keep track of created task */
+ 0); /* pin task to core 0 */
+
+ myDisplay.setTextAlignment(PA_LEFT);
+}
+void saveconfig()
+{
+ printf("saving matrixconfig of size: %ul\n", sizeof(messages));
+ size_t ret = preferences.putBytes("matrixconfig", &messages, sizeof(messages));
+ printf("actually wrote %u\n", ret);
+ preferences.putBytes("globalconfig", &globalconf, sizeof(globalconf));
+}
+
+void loadconfig()
+{
+ int res = 0;
+ res += preferences.getBytes("matrixconfig", &messages, sizeof(messages));
+ res += preferences.getBytes("globalconfig", &globalconf, sizeof(globalconf));
+ if (res == 0)
+ {
+ defaultdata();
+ }
+ // dont load pos
+ globalconf.pos = 0;
+}
+
+void defaultdata()
+{
+ globalconf.pos = 0;
+ globalconf.brightness = 4;
+ strncpy(globalconf.cssid, "Gensokyo", 256);
+ strncpy(globalconf.cpassword, "passwordhere", 256);
+ strncpy(globalconf.date, "0", 32);
+ messages[0].enabled = true;
+ messages[0].invert = false;
+ strncpy(messages[0].msg, "Not Setup", MSG_SIZE);
+ messages[0].scrollpause = 5;
+ messages[0].speed = 1;
+}
+
+void wipeconfig()
+{
+ preferences.clear();
+ saveconfig();
+}
+
+#ifdef VERTICAL
+void strrev(char *str)
+{
+ int i;
+ int j;
+ unsigned char a;
+ unsigned int len = strlen((const char *)str);
+
+ for (i = 0, j = len - 1; i < j; i++, j--)
+ {
+ a = str[i];
+ str[i] = str[j];
+ str[j] = a;
+ }
+}
+#endif
+
+char *string_replace(char *source, size_t sourceSize, char *substring, char *with)
+{
+ char *substring_source = strstr(source, substring);
+ if (substring_source == NULL)
+ {
+ return NULL;
+ }
+
+ memmove(
+ substring_source + strlen(with),
+ substring_source + strlen(substring),
+ strlen(substring_source) - strlen(substring) + 1);
+
+ memcpy(substring_source, with, strlen(with));
+ return substring_source + strlen(with);
+}
+
+char msgbuff[MSG_SIZE];
+char rtemp[15] = {0};
+void nextmessage()
+{
+ // printf("nextmessage call");
+ if (globalconf.pos >= NUM_MESSAGES)
+ {
+ globalconf.pos = 0;
+ }
+ if (messages[globalconf.pos].enabled == false)
+ {
+ // printf("skip\n");
+ globalconf.pos++;
+ nextmessage();
+ return;
+ }
+
+ memset(msgbuff, 0, MSG_SIZE);
+ strcpy(msgbuff, messages[globalconf.pos].msg);
+ time_t now = time(NULL);
+ struct tm *t = localtime(&now);
+ // replacements
+ if (strstr(msgbuff, "%date%"))
+ {
+ strftime(rtemp, sizeof(rtemp), "%d/%m/%y", t);
+ string_replace(msgbuff, strlen(msgbuff), "%date%", rtemp);
+ }
+ if (strstr(msgbuff, "%shortdate%"))
+ {
+ strftime(rtemp, sizeof(rtemp), "%d %b", t);
+ string_replace(msgbuff, strlen(msgbuff), "%shortdate%", rtemp);
+ }
+ if (strstr(msgbuff, "%time12%"))
+ {
+ strftime(rtemp, sizeof(rtemp), "%I:%M", t);
+ string_replace(msgbuff, strlen(msgbuff), "%time12%", rtemp);
+ }
+ if (strstr(msgbuff, "%time12s%"))
+ {
+ strftime(rtemp, sizeof(rtemp), "%I:%M:%S", t);
+ string_replace(msgbuff, strlen(msgbuff), "%time12s%", rtemp);
+ }
+ if (strstr(msgbuff, "%time24%"))
+ {
+ strftime(rtemp, sizeof(rtemp), "%R", t);
+ string_replace(msgbuff, strlen(msgbuff), "%time24%", rtemp);
+ }
+ if (strstr(msgbuff, "%time24s%"))
+ {
+ strftime(rtemp, sizeof(rtemp), "%T", t);
+ string_replace(msgbuff, strlen(msgbuff), "%time24s%", rtemp);
+ }
+ if (strstr(msgbuff, "%pump%"))
+ {
+ string_replace(msgbuff, strlen(msgbuff), "%pump%", pumpmsg);
+ }
+
+ /* replace pump messages */
+ for (int i = 0; i < pumpDic->count(); i++)
+ {
+ if (strstr(msgbuff, pumpDic->key(i).c_str()))
+ {
+ printf("replace: %s\n", pumpDic->value(i));
+ string_replace(msgbuff, strlen(msgbuff), (char *)pumpDic->key(i).c_str(), (char *)pumpDic->value(i).c_str());
+ }
+ }
+
+ // doomsdate stuff
+ struct tm doom = {0};
+ strptime(globalconf.date, "%Y-%m-%d", &doom);
+
+ time_t rawtime;
+ struct tm *info;
+ time(&rawtime);
+ info = localtime(&rawtime);
+
+ time_t t0 = mktime(info);
+ time_t t1 = mktime(&doom);
+
+ double diff = difftime(t1, t0); // Difference in seconds
+ const double secs_per_day = 24.0 * 60 * 60;
+ if (strstr(msgbuff, "%days%"))
+ {
+ itoa((int)ceil(diff / secs_per_day), rtemp, 10);
+ string_replace(msgbuff, strlen(msgbuff), "%days%", rtemp);
+ }
+ if (strstr(msgbuff, "%weeks%"))
+ {
+ itoa((int)ceil(diff / secs_per_day / 7), rtemp, 10);
+ string_replace(msgbuff, strlen(msgbuff), "%weeks%", rtemp);
+ }
+ if (strstr(msgbuff, "%hours%"))
+ {
+ itoa((int)ceil(floor(diff / 3600)), rtemp, 10);
+ string_replace(msgbuff, strlen(msgbuff), "%hours%", rtemp);
+ }
+ if (strstr(msgbuff, "%minutes%"))
+ {
+ itoa((int)ceil(floor(diff / 60)), rtemp, 10);
+ string_replace(msgbuff, strlen(msgbuff), "%minutes%", rtemp);
+ }
+ if (strstr(msgbuff, "%seconds%"))
+ {
+ itoa((int)ceil(floor(diff)), rtemp, 10);
+ string_replace(msgbuff, strlen(msgbuff), "%seconds%", rtemp);
+ }
+#ifdef VERTICAL
+ strrev(msgbuff);
+#endif
+ myDisplay.setIntensity(globalconf.brightness);
+ myDisplay.setInvert(messages[globalconf.pos].invert);
+ scrollAlign = PA_CENTER;
+ printf("%s\n", msgbuff);
+ myDisplay.displayText(msgbuff, scrollAlign, messages[globalconf.pos].speed, messages[globalconf.pos].scrollpause * 1000, messages[globalconf.pos].effect1, messages[globalconf.pos].effect2);
+ globalconf.pos++;
+}
+
+void doom()
+{
+ myDisplay.displayText("DAYS", PA_CENTER, 40, 2000, PA_SCROLL_DOWN, PA_FADE);
+ while (!myDisplay.displayAnimate())
+ {
+ }
+ myDisplay.displayText("LEFT", PA_CENTER, 40, 2000, PA_OPENING, PA_OPENING);
+ while (!myDisplay.displayAnimate())
+ {
+ }
+}
+
+void loop()
+{
+ if (myDisplay.displayAnimate())
+ {
+ nextmessage();
+ // doom();
+ myDisplay.displayReset();
+ }
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-10-16 11:20:42 +0000