Merge pull request #62 from IoTManagerProject/beta

Beta

data/config.json

@@ -3,8 +3,8 @@
     "chipID": "",
     "apssid": "IoTmanager",
     "appass": "",
-    "routerssid": "rise",
+    "routerssid": "VOLODYA",
-    "routerpass": "hostel3333",
+    "routerpass": "BELCHENKO",
     "timezone": 2,
     "ntp": "pool.ntp.org",
     "mqttServer": "91.204.228.124",
@@ -13,7 +13,8 @@
     "mqttUser": "rise",
     "mqttPass": "23ri22se32",
     "scen": "1",
-    "pushingboxid": "v7C133E426B0C69E",
+    "telegramApi": "1425283609:AAFf3YO8ouCJF23kU8CMiU7XXy21MFhbn9w",
+    "telegonof": "0",
     "weblogin": "admin",
     "webpass": "admin",
     "udponoff": "1",

data/index.json

@@ -37,8 +37,8 @@
     },
     {
       "type": "link",
-      "title": "Конфигурация push",
+      "title": "Конфигурация telegram",
-      "action": "/?set.push",
+      "action": "/?set.telegram",
       "class": "btn btn-block btn-default"
     },
     {

data/set.device.json

@@ -43,7 +43,7 @@
         },
         {
             "type": "h4",
-            "title": "LittleFS version: 264"
+            "title": "LittleFS version: 266"
         },
         {
             "type": "hr"

data/set.push.json

@@ -1,51 +0,0 @@
-{
-  "configs": [
-    "/config.setup.json",
-    "/lang/lang.ru.json"
-  ],
-  "class": "col-sm-offset-1 col-sm-10 col-md-offset-2 col-md-8 col-lg-offset-3 col-lg-6",
-  "content": [
-    {
-      "type": "h5",
-      "title": "{{name}}",
-      "class": "alert-default"
-    },
-    {
-      "type": "link",
-      "title": "{{ButMainPage}}",
-      "action": "/",
-      "class": "btn btn-block btn-default"
-    },
-    {
-      "type": "hr"
-    },
-    {
-      "type": "h4",
-      "style": "width:60%;float:left;",
-      "title": "Device id:"
-    },
-    {
-      "type": "input",
-      "title": "",
-      "name": "push-arg",
-      "style": "width:40%;float:right",
-      "state": "{{pushingboxid}}"
-    },
-    {
-      "type": "button",
-      "title": "{{ButSave}}",
-      "action": "set?pushingboxid=[[push-arg]]",
-      "class": "btn btn-block btn-default",
-      "style": "width:100%;display:inline"
-    },
-    {
-      "type": "hr"
-    },
-    {
-      "type": "link",
-      "title": "Перезагрузить устройство",
-      "action": "javascript:if(confirm(renameBlock(jsonResponse,'Перезагрузить?'))){send_request(this,'/restart?device=ok');}",
-      "class": "btn btn-block btn-danger"
-    }
-  ]
-}

data/set.telegram.json

@@ -0,0 +1,59 @@
+{
+  "configs": [
+    "/config.setup.json",
+    "/lang/lang.ru.json"
+  ],
+  "class": "col-sm-offset-1 col-sm-10 col-md-offset-2 col-md-8 col-lg-offset-3 col-lg-6",
+  "content": [
+    {
+      "type": "h5",
+      "title": "{{name}}",
+      "class": "alert-default"
+    },
+    {
+      "type": "link",
+      "title": "{{ButMainPage}}",
+      "action": "/",
+      "class": "btn btn-block btn-default"
+    },
+    {
+      "type": "hr"
+    },
+    {
+      "type": "checkbox",
+      "name": "tel",
+      "title": "Включить телеграм",
+      "action": "/set?telegonof=[[tel]]",
+      "state": "{{telegonof}}"
+    },
+    {
+      "type": "hr"
+    },
+    {
+      "type": "h4",
+      "style": "width:40%;float:left;",
+      "title": "Telegram API token:"
+    },
+    {
+      "type": "input",
+      "title": "",
+      "name": "telegramApi-arg",
+      "style": "width:60%;float:right",
+      "state": "{{telegramApi}}"
+    },
+    {
+      "type": "button",
+      "title": "{{ButSave}}",
+      "action": "set?telegramApi=[[telegramApi-arg]]",
+      "class": "btn btn-block btn-default",
+      "style": "width:100%;display:inline"
+    },
+    {
+      "type": "hr"
+    },
+    {
+      "type": "text",
+      "title": "<div style='margin-top:10px;margin-bottom:10px;'><font color='black'><p style='border: 1px solid #DCDCDC; border-radius: 3px; background-color: #F5F5F5; padding: 10px;'>После настройки telegram перезагрузите устройство что бы изменения вступили в силу</p></font></div>"
+    }
+  ]
+}

include/BufferExecute.h

@@ -8,3 +8,57 @@ extern void spaceCmdExecute(String& cmdStr);
 extern void loopCmdExecute();
 extern void addKey(String& key, String& keyNumberTable, int number);
 extern int getKeyNum(String& key, String& keyNumberTable);
+
+extern void buttonOut();
+extern void buttonOutSet();
+
+extern void pwmOut();
+extern void pwmOutSet();
+
+extern void buttonIn();
+extern void buttonInSet();
+
+extern void inputDigit();
+extern void inputDigitSet();
+
+extern void inputTime();
+extern void inputTimeSet();
+
+extern void textOut();
+extern void textOutSet();
+
+extern void analogAdc();
+extern void analogReading(); 
+
+extern void ultrasonicCm();
+extern void ultrasonicReading();
+
+extern void dallasTemp();
+extern void dallasReading();
+
+extern void dhtTemp();
+extern void dhtReadingTemp();
+extern void dhtHum();
+extern void dhtReadingHum();
+
+extern void bme280Temp();
+extern void bme280ReadingTemp();
+extern void bme280Hum();
+extern void bme280ReadingHum();
+extern void bme280Press();
+extern void bme280ReadingPress();
+
+extern void bmp280Temp();
+extern void bmp280ReadingTemp();
+extern void bmp280Press();
+extern void bmp280ReadingPress();
+
+//extern void modbus();
+//extern void modbusReading();
+
+extern void sysUptime();
+extern void uptimeReading();
+
+extern void logging();
+
+extern void impuls();

include/Consts.h

@@ -3,11 +3,11 @@
 //===========Firmware=============================================================================================================================================
 #ifdef ESP8266
 #define FIRMWARE_NAME "esp8266-iotm"
-#define FIRMWARE_VERSION 264
+#define FIRMWARE_VERSION 266
 #endif
 #ifdef ESP32
 #define FIRMWARE_NAME "esp32-iotm"
-#define FIRMWARE_VERSION 259
+#define FIRMWARE_VERSION 266
 #endif
 #define FLASH_4MB true
 

include/Global.h

@@ -3,6 +3,7 @@
 #include <Adafruit_BME280.h>
 #include <Adafruit_BMP280.h>
 #include <Arduino.h>
+#include "CTBot.h"
 #include <ArduinoJson.h>
 #include <ArduinoOTA.h>
 #include <Bounce2.h>
@@ -46,6 +47,7 @@ extern Bounce* buttons;
 
 //Global vars
 extern boolean just_load;
+extern boolean telegramInitBeen;
 
 // Json
 extern String configSetupJson;   //все настройки

include/ItemsCmd.h

@@ -1,55 +0,0 @@
-#pragma once
-
-extern void buttonOut();
-extern void buttonOutSet();
-
-extern void pwmOut();
-extern void pwmOutSet();
-
-extern void buttonIn();
-extern void buttonInSet();
-
-extern void inputDigit();
-extern void inputDigitSet();
-
-extern void inputTime();
-extern void inputTimeSet();
-
-extern void textOut();
-extern void textOutSet();
-
-extern void analogAdc();
-extern void analogReading(); 
-
-extern void ultrasonicCm();
-extern void ultrasonicReading();
-
-extern void dallasTemp();
-extern void dallasReading();
-
-extern void dhtTemp();
-extern void dhtReadingTemp();
-extern void dhtHum();
-extern void dhtReadingHum();
-
-extern void bme280Temp();
-extern void bme280ReadingTemp();
-extern void bme280Hum();
-extern void bme280ReadingHum();
-extern void bme280Press();
-extern void bme280ReadingPress();
-
-extern void bmp280Temp();
-extern void bmp280ReadingTemp();
-extern void bmp280Press();
-extern void bmp280ReadingPress();
-
-//extern void modbus();
-//extern void modbusReading();
-
-extern void sysUptime();
-extern void uptimeReading();
-
-extern void logging();
-
-extern void impuls();

include/RemoteOrdersUdp.h

@@ -1,7 +1,9 @@
 #pragma once
+#ifdef ESP8266
 #include "ESPAsyncUDP.h"
 extern AsyncUDP asyncUdp;
 extern void asyncUdpInit();
 extern String uint8tToString(uint8_t* data, size_t len);
 extern bool udpPacketValidation(String& data);
 extern void udpPacketParse(String& data);
+#endif

include/Telegram.h

@@ -0,0 +1,8 @@
+#pragma once
+#include "Global.h"
+
+extern void sendTelegramMsg();
+extern void telegramInit();
+extern void handleTelegram();
+extern bool isTelegramEnabled();
+extern void telegramMsgParse(String msg);

include/items/ButtonInClass.h

@@ -4,6 +4,8 @@
 #include "Class/LineParsing.h"
 #include "Global.h"
 
+
+
 class ButtonInClass : public LineParsing {
    protected:
     int numberEntering = 0;

platformio.ini

@@ -26,6 +26,7 @@ lib_deps =
 	AsyncTCP
 	madhephaestus/ESP32Servo
 	luc-github/ESP32SSDP
+	CTBot
 monitor_filters = esp32_exception_decoder
 upload_speed = 921600
 monitor_speed = 115200
@@ -43,6 +44,7 @@ lib_deps =
 	ESPAsyncTCP
 	ESPAsyncUDP
 	EspSoftwareSerial
+	CTBot
 monitor_filters = esp8266_exception_decoder
 upload_speed = 921600
 monitor_speed = 115200
@@ -58,6 +60,7 @@ lib_deps =
 	ESPAsyncTCP
 	ESPAsyncUDP
 	EspSoftwareSerial
+	CTBot
 monitor_filters = esp8266_exception_decoder
 upload_speed = 921600
 monitor_speed = 115200

src/BufferExecute.cpp

@@ -1,5 +1,5 @@
 #include "BufferExecute.h"
-
+#include "items/SensorDallas.h"
 #include "Global.h"
 #include "Module/Terminal.h"
 
@@ -23,9 +23,81 @@ void csvCmdExecute(String& cmdStr) {
     int count = 0;
     while (cmdStr.length()) {
         String buf = selectToMarker(cmdStr, "\n");
+
+
+
         buf = deleteBeforeDelimiter(buf, " ");  //отсечка чекбокса
+
         count++;
-        if (count > 1) sCmd.readStr(buf);
+        if (count > 1) {
+            SerialPrint("I", "Items", buf);
+            String order = selectToMarker(buf, " "); //отсечка самой команды
+
+            if (order == F("button-out")) {
+                sCmd.addCommand(order.c_str(), buttonOut);
+            }
+            else if (order == F("pwm-out")) {
+                sCmd.addCommand(order.c_str(), pwmOut);
+            }
+            else if (order == F("button-in")) {
+                sCmd.addCommand(order.c_str(), buttonIn);
+            }
+            else if (order == F("input-digit")) {
+                sCmd.addCommand(order.c_str(), inputDigit);
+            }
+            else if (order == F("input-time")) {
+                sCmd.addCommand(order.c_str(), inputTime);
+            }
+            else if (order == F("output-text")) {
+                sCmd.addCommand(order.c_str(), textOut);
+            }
+            else if (order == F("analog-adc")) {
+                sCmd.addCommand(order.c_str(), analogAdc);
+            }
+            else if (order == F("ultrasonic-cm")) {
+                sCmd.addCommand(order.c_str(), ultrasonicCm);
+            }
+            else if (order == F("dallas-temp")) {
+                sCmd.addCommand(order.c_str(), dallas);
+            }
+            else if (order == F("dht-temp")) {
+                sCmd.addCommand(order.c_str(), dhtTemp);
+            }
+            else if (order == F("dht-hum")) {
+                sCmd.addCommand(order.c_str(), dhtHum);
+            }
+            else if (order == F("bme280-temp")) {
+                sCmd.addCommand(order.c_str(), bme280Temp);
+            }
+            else if (order == F("bme280-hum")) {
+                sCmd.addCommand(order.c_str(), bme280Hum);
+            }
+            else if (order == F("bme280-press")) {
+                sCmd.addCommand(order.c_str(), bme280Press);
+            }
+            else if (order == F("bmp280-temp")) {
+                sCmd.addCommand(order.c_str(), bmp280Temp);
+            }
+            else if (order == F("bmp280-press")) {
+                sCmd.addCommand(order.c_str(), bmp280Press);
+            }
+            else if (order == F("modbus")) {
+                //sCmd.addCommand(order.c_str(), modbus);
+            }
+            else if (order == F("uptime")) {
+                sCmd.addCommand(order.c_str(), sysUptime);
+            }
+            else if (order == F("logging")) {
+                sCmd.addCommand(order.c_str(), logging);
+            }
+            else if (order == F("impuls-out")) {
+                sCmd.addCommand(order.c_str(), impuls);
+            }
+            
+
+
+            sCmd.readStr(buf);
+        }
         cmdStr = deleteBeforeDelimiter(cmdStr, "\n");
     }
 }
@@ -80,7 +152,7 @@ void addKey(String& key, String& keyNumberTable, int number) {
 
 int getKeyNum(String& key, String& keyNumberTable) {
     String keyNumberTableBuf = keyNumberTable;
-    //SerialPrint("","",keyNumberTable);
+
     int number = -1;
     while (keyNumberTableBuf.length()) {
         String tmp = selectToMarker(keyNumberTableBuf, ",");

src/Class/ScenarioClass.cpp

@@ -1,2 +1,9 @@
 #include "Class/ScenarioClass.h"
 Scenario* myScenario;
+
+void eventGen(String event_name, String number) {
+    if (!jsonReadBool(configSetupJson, "scen")) {
+        return;
+    }
+    eventBuf += event_name + number + ",";
+}

src/Global.cpp

@@ -18,6 +18,7 @@ DallasTemperature sensors;
 */
 
 boolean just_load = true;
+boolean telegramInitBeen = false;
 
 // Json
 String configSetupJson = "{}";

src/Init.cpp

@@ -35,19 +35,18 @@ void Device_init() {
     if (mySensorDallas2 != nullptr) {
         mySensorDallas2->clear();
     }
-
     //======clear logging params======
     if (myLogging != nullptr) {
         myLogging->clear();
     }
     loggingKeyList = "";
-
     //======clear impuls params=======
     if (myImpulsOut != nullptr) {
         myImpulsOut->clear();
     }
     impulsKeyList = "";
     impulsEnterCounter = -1;
+    //================================
 
 
 #ifdef LAYOUT_IN_RAM

src/ItemsCmd.cpp

@@ -1,60 +1,60 @@
-#include "ItemsCmd.h"
+//#include "BufferExecute.h"
+//
+//#include "BufferExecute.h"
+//#include "Class/NotAsync.h"
+//#include "Cmd.h"
+//#include "Global.h"
+//#include "Module/Terminal.h"
+//#include "Servo/Servos.h"
+//
+//#include "items/SensorDallas.h"
+//
+//Terminal *term = nullptr;
+//
+//boolean but[NUM_BUTTONS];
+//Bounce *buttons = new Bounce[NUM_BUTTONS];
+//
+//#ifdef ESP8266
+//SoftwareSerial *mySerial = nullptr;
+//#else
+//HardwareSerial *mySerial = nullptr;
+//#endif
+//
+//void getData();
+//
+//void cmd_init() {
+    //sCmd.addCommand("button-out", buttonOut);
+    //sCmd.addCommand("pwm-out", pwmOut);
+    //sCmd.addCommand("button-in", buttonIn);
 
-#include "BufferExecute.h"
+    //sCmd.addCommand("input-digit", inputDigit);
-#include "Class/NotAsync.h"
+    //sCmd.addCommand("input-time", inputTime);
-#include "Cmd.h"
+    //sCmd.addCommand("output-text", textOut);
-#include "Global.h"
-#include "Module/Terminal.h"
-#include "Servo/Servos.h"
 
-#include "items/SensorDallas.h"
+    //sCmd.addCommand("analog-adc", analogAdc);
+    //sCmd.addCommand("ultrasonic-cm", ultrasonicCm);
+    //sCmd.addCommand("dallas-temp", dallas);
 
-Terminal *term = nullptr;
+    //sCmd.addCommand("dht-temp", dhtTemp);
+    //sCmd.addCommand("dht-hum", dhtHum);
 
-boolean but[NUM_BUTTONS];
+    //sCmd.addCommand("bme280-temp", bme280Temp);
-Bounce *buttons = new Bounce[NUM_BUTTONS];
+    //sCmd.addCommand("bme280-hum", bme280Hum);
+    //sCmd.addCommand("bme280-press", bme280Press);
 
-#ifdef ESP8266
+    //sCmd.addCommand("bmp280-temp", bmp280Temp);
-SoftwareSerial *mySerial = nullptr;
+    //sCmd.addCommand("bmp280-press", bmp280Press);
-#else
-HardwareSerial *mySerial = nullptr;
-#endif
-
-void getData();
-
-void cmd_init() {
-    sCmd.addCommand("button-out", buttonOut);
-    sCmd.addCommand("pwm-out", pwmOut);
-    sCmd.addCommand("button-in", buttonIn);
-
-    sCmd.addCommand("input-digit", inputDigit);
-    sCmd.addCommand("input-time", inputTime);
-    sCmd.addCommand("output-text", textOut);
-
-    sCmd.addCommand("analog-adc", analogAdc);
-    sCmd.addCommand("ultrasonic-cm", ultrasonicCm);
-    sCmd.addCommand("dallas-temp", dallas);
-
-    sCmd.addCommand("dht-temp", dhtTemp);
-    sCmd.addCommand("dht-hum", dhtHum);
-
-    sCmd.addCommand("bme280-temp", bme280Temp);
-    sCmd.addCommand("bme280-hum", bme280Hum);
-    sCmd.addCommand("bme280-press", bme280Press);
-
-    sCmd.addCommand("bmp280-temp", bmp280Temp);
-    sCmd.addCommand("bmp280-press", bmp280Press);
 
     //sCmd.addCommand("modbus", modbus);
 
-    sCmd.addCommand("uptime", sysUptime);
+    //sCmd.addCommand("uptime", sysUptime);
 
-    sCmd.addCommand("logging", logging);
+    //sCmd.addCommand("logging", logging);
 
-    sCmd.addCommand("impuls-out", impuls);
+    //sCmd.addCommand("impuls-out", impuls);
 
-    handle_time_init();
+   
-}
+//}
 
 //    sCmd.addCommand("timerStart", timerStart_);
 //    sCmd.addCommand("timerStop", timerStop_);

src/Scenario.cpp

@@ -1,97 +0,0 @@
-#include "Cmd.h"
-#include "Global.h"
-#include "Class/ScenarioClass.h"
-
-
-
-boolean isScenarioEnabled() {
-    return jsonReadBool(configSetupJson, "scen") && eventBuf != "";
-}
-
-//void loopScenario() {
-//    if (!isScenarioEnabled()) {
-//        return;
-//    }
-//    String scenarioTmp = scenario;
-//    scenarioTmp += "\n";
-//    scenarioTmp.replace("\r\n", "\n");
-//    scenarioTmp.replace("\r", "\n");
-//
-//    while (scenarioTmp.length()) {
-//        String scenBlok = selectToMarker(scenarioTmp, "end");  //выделяем первый сценарий
-//        if (!scenBlok.length()) {
-//            return;
-//        }
-//
-//        size_t i = 0;
-//        i++;
-//        if (scenario_line_status[i] == 1) {
-//            String condition = selectToMarker(scenBlok, "\n");  //выделяем условие
-//
-//            String conditionParam = selectFromMarkerToMarker(condition, " ", 0);  //выделяем параметр условия
-//            String order = eventBuf;
-//            String eventParam = selectToMarker(order, ",");  //выделяем параметр события
-//
-//            if (conditionParam == eventParam) {  //если поступившее событие равно событию заданному buttonSet1 в файле начинаем его обработку
-//
-//                String conditionSign = selectFromMarkerToMarker(condition, " ", 1);  //выделяем знак  (=)
-//
-//                String conditionValue = selectFromMarkerToMarker(condition, " ", 2);  //выделяем значение (1)
-//
-//                boolean flag = false;
-//
-//                String eventParam = jsonReadStr(configLiveJson, conditionParam);  //получаем значение этого параметра события из json
-//
-//                if (conditionSign == "=") {
-//                    flag = eventParam == conditionValue;
-//                } else if (conditionSign == "!=") {
-//                    flag = eventParam != conditionValue;
-//                } else if (conditionSign == "<") {
-//                    flag = eventParam.toInt() < conditionValue.toInt();
-//                } else if (conditionSign == ">") {
-//                    flag = eventParam.toInt() > conditionValue.toInt();
-//                } else if (conditionSign == ">=") {
-//                    flag = eventParam.toInt() >= conditionValue.toInt();
-//                } else if (conditionSign == "<=") {
-//                    flag = eventParam.toInt() <= conditionValue.toInt();
-//                }
-//
-//                if (flag) {
-//                    scenBlok = deleteBeforeDelimiter(scenBlok, "\n");  // удаляем строку самого сценария оставляя только команды
-//                    SerialPrint("I","module","do: " + scenBlok);
-//                    spaceCmdExecute(scenBlok);  // выполняем все команды
-//                }
-//            }
-//        }
-//        scenarioTmp = deleteBeforeDelimiter(scenarioTmp, "end\n");  //удаляем первый сценарий
-//    }
-//
-//    String eventBufTmp = eventBuf;                          //читаем файл событий
-//    eventBufTmp = deleteBeforeDelimiter(eventBufTmp, ",");  //удаляем выполненное событие
-//    eventBuf = eventBufTmp;                                 //записываем обновленный файл событий
-//}
-
-void eventGen(String event_name, String number) {
-    if (!jsonReadBool(configSetupJson, "scen")) {
-        return;
-    }
-    eventBuf = event_name + number + ",";
-}
-
-//String add_set(String str) {
-//    String num1 = str.substring(str.length() - 1);
-//    String num2 = str.substring(str.length() - 2, str.length() - 1);
-//    if (isDigitStr(num1) && isDigitStr(num2)) {
-//        str = str.substring(0, str.length() - 2) + "Set" + num2 + num1;
-//    } else {
-//        if (isDigitStr(num1)) {
-//            str = str.substring(0, str.length() - 1) + "Set" + num1;
-//        }
-//    }
-//    return str;
-//}
-
-//button-out1 = 1
-//button-out2 1
-//button-out3 1
-//end

src/Telegram.cpp

@@ -0,0 +1,70 @@
+#include "Telegram.h"
+
+
+CTBot* myBot{ nullptr };
+
+void telegramInit() {
+    if (isTelegramEnabled()) {
+        telegramInitBeen = true;
+        sCmd.addCommand("telegram", sendTelegramMsg);
+        String token = jsonReadStr(configSetupJson, "telegramApi");
+        if (!myBot) {
+            myBot = new CTBot();
+        }
+        myBot->setTelegramToken(token);
+        myBot->enableUTF8Encoding(true);
+        if (myBot->testConnection()) {
+            SerialPrint("I", "Telegram", "Connected");
+        }
+        else {
+            SerialPrint("E", "Telegram", "Not connected");
+        }
+    }
+}
+
+void handleTelegram() {
+    if (telegramInitBeen) {
+        if (isTelegramEnabled()) {
+            TBMessage msg;
+            static unsigned long prevMillis;
+            unsigned long currentMillis = millis();
+            unsigned long difference = currentMillis - prevMillis;
+            if (difference >= 5000) {
+                prevMillis = millis();
+                if (myBot->getNewMessage(msg)) {
+                    SerialPrint("->", "Telegram", "chat ID: " + String(msg.sender.id) + ", msg: " + String(msg.text));
+                    jsonWriteInt(configSetupJson, "chatId", msg.sender.id);
+                    saveConfig();
+                    telegramMsgParse(String(msg.text));
+                }
+            }
+        }
+    }
+}
+
+void telegramMsgParse(String msg) {
+    SerialPrint("<-", "Telegram", "chat ID: " + String(jsonReadInt(configSetupJson, "chatId")) + ", msg: " + String(msg));
+    if (msg.indexOf("order") != -1) {
+        msg = deleteBeforeDelimiter(msg, " ");
+        orderBuf += String(msg) + ",";
+        myBot->sendMessage(jsonReadInt(configSetupJson, "chatId"), "order done");
+    }
+    else if (msg.indexOf("get") != -1) {
+        msg = deleteBeforeDelimiter(msg, " ");
+        myBot->sendMessage(jsonReadInt(configSetupJson, "chatId"), jsonReadStr(configLiveJson, msg));
+    }
+    else {
+        myBot->sendMessage(jsonReadInt(configSetupJson, "chatId"), "wrong order, use 'get id' to get value, or 'order id value' to send order");
+    }
+}
+
+void sendTelegramMsg() {
+    String msg = sCmd.next();
+    msg.replace("#", " ");
+    myBot->sendMessage(jsonReadInt(configSetupJson, "chatId"), msg);
+    SerialPrint("<-", "Telegram", "chat ID: " + String(jsonReadInt(configSetupJson, "chatId")) + ", msg: " + msg);
+}
+
+bool isTelegramEnabled() {
+    return jsonReadBool(configSetupJson, "telegonof");
+}

src/Utils/JsonUtils.cpp

@@ -2,8 +2,6 @@
 #include "Utils/FileUtils.h"
 #include "Global.h"
 
-#include <ArduinoJson.h>
-
 String jsonReadStr(String& json, String name) {
     DynamicJsonBuffer jsonBuffer;
     JsonObject& root = jsonBuffer.parseObject(json);

src/Web.cpp

@@ -1,10 +1,10 @@
 #include "Web.h"
-
 #include "Class/NotAsync.h"
 #include "Global.h"
 #include "Init.h"
 #include "ItemsList.h"
 #include "items/LoggingClass.h"
+#include "Telegram.h"
 
 bool parseRequestForPreset(AsyncWebServerRequest* request, uint8_t& preset) {
     if (request->hasArg("preset")) {
@@ -193,14 +193,20 @@ void web_init() {
             request->send(200, "text/html", payload);
         }
 
-        //        //==============================push settings=============================================
+        //==============================push settings=============================================
-        //#ifdef PUSH_ENABLED
+        if (request->hasArg("telegramApi")) {
-        //        if (request->hasArg("pushingboxid")) {
+            jsonWriteStr(configSetupJson, "telegramApi", request->getParam("telegramApi")->value());
-        //            jsonWriteStr(configSetupJson, "pushingboxid", request->getParam("pushingboxid")->value());
+            //telegramInit();
-        //            saveConfig();
+            saveConfig();
-        //            request->send(200);
+            request->send(200);
-        //        }
+        }
-        //#endif
+        if (request->hasArg("telegonof")) {
+            bool value = request->getParam("telegonof")->value().toInt();
+            jsonWriteBool(configSetupJson, "telegonof", value);
+            //telegramInit();
+            saveConfig();
+            request->send(200);
+        }
 
         //==============================utilities settings=============================================
         if (request->hasArg("i2c")) {
@@ -215,7 +221,7 @@ void web_init() {
             serverIP = jsonReadStr(configSetupJson, "serverip");
             request->send(200);
         }
-    });
+        });
 
     //==============================list of items=====================================================
     //server.on("/del", HTTP_GET, [](AsyncWebServerRequest* request) {
@@ -240,13 +246,17 @@ void web_init() {
         String msg = "";
         if (lastVersion == FIRMWARE_VERSION) {
             msg = F("Актуальная версия прошивки уже установлена.");
-        } else if (lastVersion > FIRMWARE_VERSION) {
+        }
+        else if (lastVersion > FIRMWARE_VERSION) {
             msg = F("Новая версия прошивки<a href=\"#\" class=\"btn btn-block btn-danger\" onclick=\"send_request(this, '/upgrade');setTimeout(function(){ location.href='/?set.device'; }, 90000);html('my-block','<span class=loader></span>Идет обновление прошивки, после обновления страница  перезагрузится автоматически...')\">Установить</a>");
-        } else if (lastVersion == -1) {
+        }
+        else if (lastVersion == -1) {
             msg = F("Cервер не найден. Попробуйте повторить позже...");
-        } else if (lastVersion == -2) {
+        }
+        else if (lastVersion == -2) {
             msg = F("Устройство не подключено к роутеру!");
-        } else if (lastVersion < FIRMWARE_VERSION) {
+        }
+        else if (lastVersion < FIRMWARE_VERSION) {
             msg = F("Ошибка версии. Попробуйте повторить позже...");
         }
 
@@ -262,7 +272,7 @@ void web_init() {
         jsonWriteStr(tmp, "title", "<button class=\"close\" onclick=\"toggle('my-block')\">×</button>" + msg);
         jsonWriteStr(tmp, "class", "pop-up");
         request->send(200, "text/html", tmp);
-    });
+        });
 
     /*
     * Upgrade
@@ -270,7 +280,7 @@ void web_init() {
     server.on("/upgrade", HTTP_GET, [](AsyncWebServerRequest* request) {
         myNotAsyncActions->make(do_UPGRADE);
         request->send(200, "text/html");
-    });
+        });
 }
 
 void setConfigParam(const char* param, const String& value) {

src/items/ButtonInClass.cpp

@@ -1,8 +1,12 @@
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include "items/ButtonInClass.h"
 //==========================================Модуль физических кнопок========================================
 //button-in switch1 toggle Кнопки Свет 1 pin[2] db[20]
 //==========================================================================================================
+
+boolean but[NUM_BUTTONS];
+Bounce *buttons = new Bounce[NUM_BUTTONS];
+
 ButtonInClass myButtonIn;
 void buttonIn() {
     myButtonIn.update();

src/items/ButtonOutClass.cpp

@@ -1,6 +1,6 @@
 #include "items/ButtonOutClass.h"
 
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 //==========================================Модуль кнопок===================================================
 //button-out light toggle Кнопки Свет 1 pin[12] inv[1] st[1]
 //==========================================================================================================

src/items/ImpulsOutClass.cpp

@@ -4,7 +4,7 @@
 #include "BufferExecute.h"
 #include "Class/LineParsing.h"
 #include "Global.h"
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 
 ImpulsOutClass::ImpulsOutClass(unsigned int impulsPin) {
     _impulsPin = impulsPin;

src/items/InputDigitClass.cpp

@@ -1,4 +1,4 @@
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include "items/InputClass.h"
 //==========================================Модуль ввода цифровых значений==================================
 //input-digit digit1 inputDigit Ввод Введите.цифру 4 st[60]

src/items/InputTimeClass.cpp

@@ -1,4 +1,4 @@
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include "items/InputClass.h"
 //==========================================Модуль ввода времени============================================
 //==========================================================================================================

src/items/LoggingClass.cpp

@@ -4,7 +4,7 @@
 
 #include "Class/LineParsing.h"
 #include "Global.h"
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 
 LoggingClass::LoggingClass(unsigned long period, unsigned int maxPoints, String loggingValueKey, String key) {
     _period = period * 1000;
@@ -42,7 +42,8 @@ void LoggingClass::addNewDelOldData(const String filename, size_t maxPoints, Str
                 logData += timeNow->getTimeUnix() + " " + payload + "\r\n";
                 writeFile(filename, logData);
             }
-        } else {
+        }
+        else {
             if (timeNow->hasTimeSynced()) {
                 addFileLn(filename, timeNow->getTimeUnix() + " " + payload);
             }
@@ -95,7 +96,8 @@ void sendLogData(String file, String topic) {
             jsonWriteFloat(buf, "y1", value.toFloat());
             if (log_date.length() < 3) {
                 json_array += buf;
-            } else {
+            }
+            else {
                 json_array += buf + ",";
             }
             buf = "{}";
@@ -111,10 +113,12 @@ void sendLogData(String file, String topic) {
 }
 
 void clean_log_date() {
+#ifdef ESP8266
     auto dir = LittleFS.openDir("logs");
     while (dir.next()) {
         String fname = dir.fileName();
         SerialPrint("I", "System", fname);
         removeFile("logs/" + fname);
     }
+#endif
 }

src/items/OutputTextClass.cpp

@@ -1,4 +1,4 @@
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include "items/OutputTextClass.h"
 //===============================================Модуль вывода текста============================================
 //output-text;id;anydata;Вывод;Сигнализация;order;st[Обнаружено.движение]

src/items/PwmOutClass.cpp

@@ -1,4 +1,4 @@
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include "items/PwmOutClass.h"
 //==========================================Модуль управления ШИМ===================================================
 //pwm-out volume range Кнопки Свет 1 pin[12] st[500]

src/items/SensorAnalogClass.cpp

@@ -1,4 +1,4 @@
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include "items/SensorAnalogClass.h"
 #ifdef ANALOG_ENABLED
 //==============================================Модуль аналогового сенсора===========================================================================================

src/items/SensorBme280Class.cpp

@@ -1,6 +1,6 @@
 #include "items/SensorBme280Class.h"
 
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 //#ifdef SensorBme280Enabled
 //=========================================Модуль ультрозвукового дальномера==================================================================
 //bme280-temp;id;anydata;Сенсоры;Температура;order;c[1]

src/items/SensorBmp280Class.cpp

@@ -1,6 +1,6 @@
 #include "items/SensorBmp280Class.h"
 
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 //#ifdef SensorBmp280Enabled
 //=========================================Модуль ультрозвукового дальномера==================================================================
 //bmp280-temp;id;anydata;Сенсоры;Температура;order;c[1]

src/items/SensorDallas.cpp

@@ -1,7 +1,7 @@
 #include "items/SensorDallas.h"
 #include "Class/LineParsing.h"
 #include "Global.h"
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include <Arduino.h>
 
 SensorDallas::SensorDallas(unsigned long interval, unsigned int pin, unsigned int index, String key) {

src/items/SensorDhtClass.cpp

@@ -1,6 +1,6 @@
 #include "items/SensorDhtClass.h"
 
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 //#ifdef SensorDhtEnabled
 //=========================================DHT Sensor==================================================================
 //dht-temp;id;anydata;Сенсоры;Температура;order;pin;type[dht11];c[1]

src/items/SensorModbusClass.cpp

@@ -1,6 +1,6 @@
 //#include "items/SensorModbusClass.h"
 //
-//#include "ItemsCmd.h"
+//#include "BufferExecute.h"
 ////#ifdef SensorModbusEnabled
 ////=========================================Модуль modbus===================================================================================
 ////modbus;id;anydata;Сенсоры;Температура;order;addr[1];regaddr[0];c[1]

src/items/SensorUltrasonicClass.cpp

@@ -1,4 +1,4 @@
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include "items/SensorUltrasonicClass.h"
 //#ifdef SensorUltrasonicEnabled
 //=========================================Модуль ультрозвукового дальномера==================================================================

src/items/sysUptime.cpp

@@ -1,5 +1,5 @@
 #include "Class/LineParsing.h"
-#include "ItemsCmd.h"
+#include "BufferExecute.h"
 #include "Global.h"
 #include <Arduino.h>
 

src/main.cpp

@@ -18,6 +18,7 @@
 #include "items/LoggingClass.h"
 #include "items/ImpulsOutClass.h"
 #include "items/SensorDallas.h"
+#include "Telegram.h"
 
 void not_async_actions();
 
@@ -38,44 +39,47 @@ void setup() {
     myNotAsyncActions = new NotAsync(do_LAST);
     myScenario = new Scenario();
 
-    SerialPrint("I", "FS", "FS Init");
     fileSystemInit();
+    SerialPrint("I", "FS", "FS Init");
 
-    SerialPrint("I", "Conf", "Config Init");
     loadConfig();
+    SerialPrint("I", "Conf", "Config Init");
 
-    SerialPrint("I", "Time", "Clock Init");
     clock_init();
+    SerialPrint("I", "Time", "Clock Init");
 
-    SerialPrint("I", "CMD", "Commands Init");
+    handle_time_init();
-    cmd_init();
+    SerialPrint("I", "Time", "Handle time init(");
 
-    SerialPrint("I", "Sensors", "Sensors Init");
     sensorsInit();
+    SerialPrint("I", "Sensors", "Sensors Init");
 
-    SerialPrint("I", "Items", "Items Init");
     itemsListInit();
+    SerialPrint("I", "Items", "Items Init");
 
-    SerialPrint("I", "Init", "Init Init");
     all_init();
+    SerialPrint("I", "Init", "Init Init");
 
-    SerialPrint("I", "WIFI", "Network Init");
     routerConnect();
+    SerialPrint("I", "WIFI", "Network Init");
+
+    telegramInit();
+    SerialPrint("I", "Telegram", "Telegram Init");
 
-    SerialPrint("I", "Uptime", "Uptime Init");
     uptime_init();
+    SerialPrint("I", "Uptime", "Uptime Init");
 
-    SerialPrint("I", "Update", "Updater Init");
     upgradeInit();
+    SerialPrint("I", "Update", "Updater Init");
 
-    SerialPrint("I", "HTTP", "HttpServer Init");
     HttpServer::init();
+    SerialPrint("I", "HTTP", "HttpServer Init");
 
-    SerialPrint("I", "Web", "WebAdmin Init");
     web_init();
+    SerialPrint("I", "Web", "WebAdmin Init");
 
-    SerialPrint("I", "Stat", "Stat Init");
     initSt();
+    SerialPrint("I", "Stat", "Stat Init");
 
 #ifdef UDP_ENABLED
     SerialPrint("I", "UDP", "Udp Init");
@@ -90,6 +94,8 @@ void setup() {
     SsdpInit();
 #endif
 
+
+
     //esp_log_level_set("esp_littlefs", ESP_LOG_NONE);
 
     ts.add(
@@ -99,9 +105,7 @@ void setup() {
         nullptr, true);
 
     just_load = false;
-    initialized = true;  //this second POST makes the data to be processed (you don't need to connect as "keep-alive" for that to work)
+    initialized = true;  
-
-   
 }
 
 void loop() {
@@ -124,6 +128,8 @@ void loop() {
     myNotAsyncActions->loop();
     ts.update();
 
+    handleTelegram();
+
     if (myLogging != nullptr) {
         for (unsigned int i = 0; i < myLogging->size(); i++) {
             myLogging->at(i).loop();