![\"\"](\"https:\/\/www.cloudacm.com\/wp-content\/uploads\/2024\/01\/wemos_mini_d1_pinout_esp8266_esp12.png\")
<\/a>Since the space heater inputs operated at a 5 volt logic, a level shifter was placed between the module and space heater controller. Since the space heater provided an adequate 5 volt supply, this was fed to the module. Here is a pinout of the connections.<\/p>\nAfter reassembly, the space heater appears the same as it had before the modification.<\/p>\n Here is the Arduino code that was programmed on the module.<\/p>\n The Node-Red flows are similar to earlier posting on this blog. However, the energy usage flows use a math function to provide a daily average of watt hours used.<\/p>\n Here are the details for the watt usage flows.<\/p>\n Some of the other features handled by Node-Red are storing the values published by the module to the MQTT broker. These variables are referenced in functions to control the heater and store readings into a log file.<\/p>\n<\/a>The green line connects the module D1 pin (GPIO 5) to the space heater on\/off button. The yellow line connects the module D6 pin (GPIO 12) to the space heater mode button. Again, these traverse a level shifter to keep the module GPIO pins at 3.3 volts and the space heater pins at 5 volts. Here is a photo of the components installed in the space heater control panel.<\/p>\n<\/a><\/p>\n<\/a><\/p>\n\/**\r\n\r\n Header\r\n\r\n Title: Wemos ESP8266 with MQTT interfaced Pelonis Space Heater Controller\r\n Version: 11\r\n Filename: Wemos-184_MQTT_Pelonis-Space-Heater-Controller_ver11.ino\r\n Wemos draws 80mA ~ 400mW\r\n\r\n Date: 10\/14\/2023\r\n \r\n Author: Patrick Gilfeather - CloudACM\r\n \r\n\r\n*\/\r\n\r\n\r\n\r\n\r\n\/\/ Libraries and Declarations\r\n#include <Arduino.h>\r\n#include <ESP8266WiFi.h>\r\n#include <PubSubClient.h>\r\nWiFiClient espClient;\r\nPubSubClient MQTTclient(espClient);\r\nlong laststats = 0;\r\nint programflag = 0;\r\n\r\n\r\n\r\n\/\/ NTP Libraries, Declarations, and Variables\r\n#include <NTPClient.h>\r\n#include <WiFiUdp.h>\r\nWiFiUDP ntpUDP;\r\nNTPClient timeClient(ntpUDP, \"pool.ntp.org\");\r\n\/\/Week Days\r\nString weekDays[7]={\"Sunday\", \"Monday\", \"Tuesday\", \"Wednesday\", \"Thursday\", \"Friday\", \"Saturday\"};\r\n\/\/Month names\r\nString months[12]={\"January\", \"February\", \"March\", \"April\", \"May\", \"June\", \"July\", \"August\", \"September\", \"October\", \"November\", \"December\"};\r\n\r\n\r\n\r\n\r\n\r\n\/\/ Variables\r\n\r\n\/\/ MQTT Broker\r\nconst char* mqtt_server = \"<ip_of_mqtt_broker>\"; \/\/ Put your MQTT Broker here\r\n\r\n\/\/ Your WiFi credentials\r\nconst char* ssid = \"<wifi_network>\"; \/\/ Put your SSID here\r\nconst char* password = \"<wifi_password>\"; \/\/ Put your PASSWORD here\r\n\r\nunsigned long lasttimeupdate = 0; \/\/ Time counter for periodic NTP time checks\r\nunsigned long lasttimereboot = 0; \/\/ Time counter for periodic reboots to avoid millis rollover\r\n\r\nADC_MODE(ADC_VCC); \/\/ See comment block below for more details\r\n\/*\r\n see - http:\/\/arduino.esp8266.com\/Arduino\/versions\/2.0.0-rc2\/doc\/libraries.html\r\n\r\n ESP.getVcc() may be used to measure supply voltage. ESP needs to reconfigure the ADC at \r\n startup in order for this feature to be available. Add the following line to the top of \r\n your sketch to use getVcc:\r\n\r\n ADC_MODE(ADC_VCC);\r\n\r\n TOUT pin has to be disconnected in this mode.\r\n\r\n Note that by default ADC is configured to read from TOUT pin using analogRead(A0), and \r\n ESP.getVCC() is not available.\r\n\r\n *\/\r\n\r\n\/\/ Pelonis Space Heater Button Interfaces \r\nint OnOff = 5;\r\nint Mode = 12;\r\n\r\n\/\/ State of Pelonis Space Heater Buttons \r\nint OnOffState = 0;\r\nint ModeState = 0;\r\n\r\n\/\/ Reference State of Pelonis Space Heater Buttons \r\nint LastOnOffState = 0;\r\nint LastModeState = 0;\r\n\r\n\/\/ Pelonis Space Heater Counters, Variables, and Constants\r\nint DeBounceDelay = 250;\r\nunsigned long PanelCountdown = 0;\r\nunsigned long PanelClock = millis();\r\nint PowerState = 0;\r\nint OperationState = 0;\r\nint PanelState = 0;\r\n\r\n\r\n\/**\r\n\r\n Wattage Usage Calculations \r\n Based on Amp meter readings\r\n High Mode = 12.5 Amps with 120 Volt AC Source\r\n Low Mode = 7 Amps with 120 Volt AC Source\r\n\r\n MQTT Status message are sent every 5 seconds\r\n\r\n To cacluate watt hours used the mode amp value is multiplied by the source voltage\r\n ie. 7 * 120 = 840 Watts\r\n The result is then devided by the amount of time that has passed since the last reading\r\n ie. 840 \/ (60 * 12) = 1.1667 Watts used in 5 seconds\r\n\r\n The Watts used in 5 seconds becomes the factor to add to the variable WattsUsed\r\n\r\n High Mode = 2.08\r\n Low Mode = 1.17\r\n \r\n*\/\r\n\r\nfloat WattsUsed = 0;\r\n\r\n\r\n\r\n\/\/ MQTT Functions\r\n\r\nvoid callback(char* topic, byte* message, unsigned int length) {\r\n \r\n String messageTemp;\r\n \r\n for (int i = 0; i < length; i++) {\r\n messageTemp += (char)message[i];\r\n }\r\n\r\n if (String(topic) == \"Wemos-184\/UpdateTime\") {\r\n if(messageTemp == \"CheckTime\"){\r\n timeClient.update();\r\n }\r\n } \r\n\r\n if (String(topic) == \"Wemos-184\/Reboot\") {\r\n if(messageTemp == \"Reboot\"){\r\n ESP.restart();\r\n }\r\n }\r\n\r\n if (String(topic) == \"Wemos-184\/OnOff\") {\r\n if(messageTemp == \"Pushed\"){\r\n pinMode(OnOff, OUTPUT);\r\n digitalWrite(Mode, LOW); \r\n delay(DeBounceDelay); \r\n digitalWrite(Mode, HIGH); \r\n pinMode(OnOff, INPUT);\r\n if (PowerState == 1) {\r\n PowerState = 0;\r\n PanelState = 0;\r\n } else {\r\n PowerState = PowerState + 1;\r\n PanelState = 1;\r\n PanelClock = millis();\r\n PanelCountdown = PanelClock;\r\n }\r\n }\r\n }\r\n\r\n if (String(topic) == \"Wemos-184\/Mode\") {\r\n if (PowerState == 1) {\r\n if(messageTemp == \"Pushed\"){\r\n if (PanelState == 1) {\r\n PanelClock = millis();\r\n PanelCountdown = PanelClock;\r\n pinMode(Mode, OUTPUT);\r\n digitalWrite(Mode, LOW); \r\n delay(DeBounceDelay); \r\n digitalWrite(Mode, HIGH); \r\n pinMode(Mode, INPUT);\r\n if (OperationState == 3) {\r\n OperationState = 0;\r\n } else {\r\n OperationState = OperationState + 1;\r\n }\r\n } else {\r\n PanelState = 1;\r\n PanelClock = millis();\r\n PanelCountdown = PanelClock;\r\n pinMode(Mode, OUTPUT);\r\n digitalWrite(Mode, LOW); \r\n delay(DeBounceDelay); \r\n digitalWrite(Mode, HIGH); \r\n pinMode(Mode, INPUT);\r\n }\r\n } else {\r\n \/\/ Ignore If Power State Is Off\r\n }\r\n }\r\n }\r\n \r\n}\r\n\r\n\r\n\r\nvoid reconnect() {\r\n \/\/ Loop until we're reconnected\r\n while (!MQTTclient.connected()) {\r\n \/\/ Attempt to connect\r\n if (MQTTclient.connect(\"Wemos-184\")) {\r\n \/\/ Subscribe\r\n \/\/ Do you not subscribe to my methods?\r\n \/\/ Wemos-184\/# for everything, or Wemos-184\/Uptime for just the Uptime\r\n MQTTclient.subscribe(\"Wemos-184\/#\");\r\n } else {\r\n \/\/ Wait 5 seconds before retrying\r\n delay(5000);\r\n }\r\n }\r\n}\r\n\r\n\r\n\r\n\r\n\r\n\r\n\r\n\r\n\r\nvoid UpdateStats() {\r\n \r\n long stats = millis();\r\n if (stats - laststats > 5000) {\r\n laststats = stats;\r\n\r\n MQTTclient.publish(\"Wemos-184\/Firmware\", \"Wemos-184_MQTT_Pelonis-Space-Heater-Controller_ver11\"); \r\n String StringUptime = String(millis());\r\n MQTTclient.publish(\"Wemos-184\/Uptime\", StringUptime.c_str());\r\n String StringHWAddress = String(WiFi.macAddress());\r\n MQTTclient.publish(\"Wemos-184\/HWAddress\", StringHWAddress.c_str()); \r\n String StringWifiSignal = String(WiFi.RSSI());\r\n MQTTclient.publish(\"Wemos-184\/WifiSignal\",StringWifiSignal.c_str()); \r\n\r\n String StringPowerState = String(PowerState);\r\n MQTTclient.publish(\"Wemos-184\/PowerState\",StringPowerState.c_str()); \r\n String StringOperationState = String(OperationState);\r\n MQTTclient.publish(\"Wemos-184\/OperationState\",StringOperationState.c_str()); \r\n String StringPanelState = String(PanelState);\r\n MQTTclient.publish(\"Wemos-184\/PanelState\",StringPanelState.c_str()); \r\n\r\n if ((OperationState == 0) && (PowerState == 1)) {\r\n WattsUsed = WattsUsed + 2.08;\r\n } else if ((OperationState == 1) && (PowerState == 1)) {\r\n WattsUsed = WattsUsed + 1.17;\r\n } else {\r\n } WattsUsed = WattsUsed;\r\n String StringWattsUsed = String(WattsUsed);\r\n MQTTclient.publish(\"Wemos-184\/WattsUsed\",StringWattsUsed.c_str()); \r\n \r\n String StringFreeHeapSize = String(ESP.getFreeHeap());\r\n MQTTclient.publish(\"Wemos-184\/FreeHeapSize\",StringFreeHeapSize.c_str()); \r\n String StringHeapFragmentation = String(ESP.getHeapFragmentation());\r\n MQTTclient.publish(\"Wemos-184\/HeapFragmentation\",StringHeapFragmentation.c_str()); \r\n String StringMaxFreeBlockSize = String(ESP.getMaxFreeBlockSize());\r\n MQTTclient.publish(\"Wemos-184\/MaxFreeBlockSize\",StringMaxFreeBlockSize.c_str()); \r\n String StringSketchSize = String(ESP.getSketchSize());\r\n MQTTclient.publish(\"Wemos-184\/SketchSize\",StringSketchSize.c_str()); \r\n String StringFreeSketchSpace = String(ESP.getFreeSketchSpace());\r\n MQTTclient.publish(\"Wemos-184\/FreeSketchSpace\",StringFreeSketchSpace.c_str()); \r\n String StringCpuFreqMHz = String(ESP.getCpuFreqMHz());\r\n MQTTclient.publish(\"Wemos-184\/CpuFreqMHz\",StringCpuFreqMHz.c_str());\r\n String StringChipId = String(ESP.getChipId());\r\n MQTTclient.publish(\"Wemos-184\/ChipId\",StringChipId.c_str()); \r\n String StringVcc = String(ESP.getVcc());\r\n MQTTclient.publish(\"Wemos-184\/Vcc\",StringVcc.c_str()); \r\n\r\n \/\/Get a Time Structure\r\n String formattedTime = timeClient.getFormattedTime();\r\n String StringformattedTime = String(formattedTime);\r\n MQTTclient.publish(\"Wemos-184\/Time\",StringformattedTime.c_str()); \r\n\r\n \/\/Get a Date Structure\r\n time_t epochTime = timeClient.getEpochTime();\r\n struct tm *ptm = gmtime ((time_t *)&epochTime); \r\n int monthDay = ptm->tm_mday;\r\n int currentMonth = ptm->tm_mon+1;\r\n String currentMonthName = months[currentMonth-1];\r\n int currentYear = ptm->tm_year+1900;\r\n \r\n \/\/Publish complete date:\r\n String StringcurrentDate = String(currentMonth) + \"\/\" + String(monthDay) + \"\/\" + String(currentYear);\r\n MQTTclient.publish(\"Wemos-184\/Date\",StringcurrentDate.c_str()); \r\n \r\n \/\/Publish Epoch:\r\n String StringEpochTime = String(timeClient.getEpochTime());\r\n MQTTclient.publish(\"Wemos-184\/EpochTime\",StringEpochTime.c_str()); \r\n\r\n }\r\n \r\n}\r\n\r\n\r\n\r\n\r\nvoid InputCondition() {\r\n\r\n OnOffState = digitalRead(OnOff);\r\n if (OnOffState != LastOnOffState) {\r\n if (OnOffState == HIGH) {\r\n MQTTclient.publish(\"Wemos-184\/OnOffState\", \"0\"); \r\n LastOnOffState = OnOffState; \r\n PanelClock = millis();\r\n PanelCountdown = PanelClock;\r\n } else {\r\n MQTTclient.publish(\"Wemos-184\/OnOffState\", \"1\"); \r\n LastOnOffState = OnOffState;\r\n if (PowerState == 1) {\r\n PowerState = 0;\r\n PanelState = 0;\r\n } else {\r\n PowerState = PowerState + 1;\r\n PanelState = 1;\r\n PanelClock = millis();\r\n PanelCountdown = PanelClock;\r\n }\r\n } \r\n delay(DeBounceDelay);\r\n }\r\n\r\n ModeState = digitalRead(Mode); \r\n if (PowerState == 1) {\r\n if (ModeState != LastModeState) {\r\n if (PanelState == 1) {\r\n PanelClock = millis();\r\n PanelCountdown = PanelClock;\r\n if (ModeState == HIGH) {\r\n MQTTclient.publish(\"Wemos-184\/ModeState\", \"0\"); \r\n LastModeState = ModeState;\r\n } else {\r\n MQTTclient.publish(\"Wemos-184\/ModeState\", \"1\"); \r\n LastModeState = ModeState;\r\n if (OperationState == 3) {\r\n OperationState = 0;\r\n } else {\r\n OperationState = OperationState + 1;\r\n }\r\n }\r\n } else {\r\n PanelState = 1;\r\n PanelClock = millis();\r\n PanelCountdown = PanelClock;\r\n if (ModeState == HIGH) {\r\n MQTTclient.publish(\"Wemos-184\/ModeState\", \"0\"); \r\n LastModeState = ModeState;\r\n } else {\r\n MQTTclient.publish(\"Wemos-184\/ModeState\", \"1\"); \r\n LastModeState = ModeState;\r\n }\r\n }\r\n delay(DeBounceDelay);\r\n }\r\n }\r\n \r\n}\r\n\r\n\r\n\r\n\/\/ Setup Function\r\nvoid setup() {\r\n\r\n \/\/ Iinitialize the Pelonis Space Heater Button pins as inputs\r\n pinMode(OnOff, INPUT);\r\n pinMode(Mode, INPUT);\r\n\r\n delay(1000);\r\n \r\n WiFi.mode(WIFI_STA);\r\n WiFi.begin(ssid, password);\r\n while (WiFi.status() != WL_CONNECTED)\r\n {\r\n \/\/ Just wait it out\r\n delay(250);\r\n }\r\n \r\n MQTTclient.setServer(mqtt_server, 1883);\r\n MQTTclient.setCallback(callback);\r\n\r\n timeClient.begin(); \/\/ Initialize a NTPClient to get time\r\n timeClient.setTimeOffset(-25200);\r\n \/\/ Set offset time in seconds to adjust for your timezone, for example:\r\n \/\/ GMT -7 = -25200 (see - https:\/\/time.gov\/)\r\n delay(1000);\r\n timeClient.update();\r\n \r\n}\r\n\r\n\r\n\/\/ Main Loop Function\r\nvoid loop() {\r\n \r\n if (!MQTTclient.connected()) {\r\n reconnect();\r\n } \r\n MQTTclient.loop();\r\n UpdateStats();\r\n InputCondition();\r\n\r\n PanelClock = millis();\r\n if (PanelClock - PanelCountdown > 60000) {\r\n PanelCountdown = PanelClock;\r\n PanelState = 0;\r\n }\r\n\r\n \/\/ Update time from NTP source every 1 day (24 * 60 * 60 * 1000 = 86400000 milli-seconds)\r\n unsigned long timeupdate = millis();\r\n if (timeupdate - lasttimeupdate > 86400000) {\r\n lasttimeupdate = timeupdate;\r\n timeClient.update(); \r\n }\r\n\r\n \/\/ Reboot microcontroller every 30 day to avoid millis() rollover (30 * 24 * 60 * 60 * 1000 = 2592000000 milli-seconds)\r\n unsigned long timereboot = millis();\r\n if (timereboot - lasttimereboot > 2592000000) {\r\n \/\/ Reboot command\r\n ESP.restart();\r\n }\r\n\r\n\r\n}\r\n\r\n\r\n\/**\r\n\r\n Footer\r\n \r\n*\/<\/pre>\n<\/a><\/p>\n[\r\n {\r\n \"id\": \"417952fce84bb17d\",\r\n \"type\": \"ui_text\",\r\n \"z\": \"4d44da15033849c8\",\r\n \"group\": \"6d9b77eeca28b65c\",\r\n \"order\": 13,\r\n \"width\": 0,\r\n \"height\": 0,\r\n \"name\": \"\",\r\n \"label\": \"Watts Used\",\r\n \"format\": \"{{msg.payload}}\",\r\n \"layout\": \"row-spread\",\r\n \"className\": \"\",\r\n \"x\": 2570,\r\n \"y\": 660,\r\n \"wires\": []\r\n },\r\n {\r\n \"id\": \"308bdda3b45f03b1\",\r\n \"type\": \"ui_text\",\r\n \"z\": \"4d44da15033849c8\",\r\n \"group\": \"6d9b77eeca28b65c\",\r\n \"order\": 14,\r\n \"width\": 0,\r\n \"height\": 0,\r\n \"name\": \"\",\r\n \"label\": \"Daily Ave Watt Hour Used\",\r\n \"format\": \"{{msg.payload}}\",\r\n \"layout\": \"row-spread\",\r\n \"className\": \"\",\r\n \"x\": 2610,\r\n \"y\": 700,\r\n \"wires\": []\r\n },\r\n {\r\n \"id\": \"de1f326ceb1b70f8\",\r\n \"type\": \"function\",\r\n \"z\": \"4d44da15033849c8\",\r\n \"name\": \"Daily Ave Math\",\r\n \"func\": \"totalwatts=msg.payload;\\nmsg.payload = (totalwatts \/ 24).toFixed(2);\\nreturn msg;\",\r\n \"outputs\": 1,\r\n \"noerr\": 0,\r\n \"initialize\": \"\",\r\n \"finalize\": \"\",\r\n \"libs\": [],\r\n \"x\": 2320,\r\n \"y\": 700,\r\n \"wires\": [\r\n [\r\n \"308bdda3b45f03b1\"\r\n ]\r\n ]\r\n },\r\n {\r\n \"id\": \"b172fdf0e41a9c07\",\r\n \"type\": \"mqtt in\",\r\n \"z\": \"4d44da15033849c8\",\r\n \"name\": \"\",\r\n \"topic\": \"Wemos-184\/WattsUsed\",\r\n \"qos\": \"0\",\r\n \"datatype\": \"auto\",\r\n \"broker\": \"54b01280.e7076c\",\r\n \"nl\": false,\r\n \"rap\": false,\r\n \"inputs\": 0,\r\n \"x\": 1880,\r\n \"y\": 660,\r\n \"wires\": [\r\n [\r\n \"417952fce84bb17d\",\r\n \"de1f326ceb1b70f8\",\r\n \"dc6a31b914cc4228\"\r\n ]\r\n ]\r\n },\r\n {\r\n \"id\": \"6d9b77eeca28b65c\",\r\n \"type\": \"ui_group\",\r\n \"name\": \"Pelonis Space Heater\",\r\n \"tab\": \"6135d078965eafde\",\r\n \"order\": 3,\r\n \"disp\": true,\r\n \"width\": \"7\",\r\n \"collapse\": false,\r\n \"className\": \"\"\r\n },\r\n {\r\n \"id\": \"54b01280.e7076c\",\r\n \"type\": \"mqtt-broker\",\r\n \"name\": \"MQTT-BROKER-NAME\",\r\n \"broker\": \"MQTT-BROKER-IP\",\r\n \"port\": \"MQTT-BROKER-PORT\",\r\n \"clientid\": \"\",\r\n \"autoConnect\": true,\r\n \"usetls\": false,\r\n \"protocolVersion\": \"3\",\r\n \"keepalive\": \"60\",\r\n \"cleansession\": true,\r\n \"birthTopic\": \"\",\r\n \"birthQos\": \"0\",\r\n \"birthPayload\": \"\",\r\n \"birthMsg\": {},\r\n \"closeTopic\": \"\",\r\n \"closePayload\": \"\",\r\n \"closeMsg\": {},\r\n \"willTopic\": \"\",\r\n \"willQos\": \"0\",\r\n \"willPayload\": \"\",\r\n \"willMsg\": {},\r\n \"sessionExpiry\": \"\"\r\n },\r\n {\r\n \"id\": \"6135d078965eafde\",\r\n \"type\": \"ui_tab\",\r\n \"name\": \"Space Heater\",\r\n \"icon\": \"dashboard\",\r\n \"order\": 5,\r\n \"disabled\": false,\r\n \"hidden\": false\r\n }\r\n]<\/pre>\n