#include <SoftwareSerial.h>

#include <DallasTemperature.h>      


SoftwareSerial SIM800(4, 5);                // для новых плат начиная с 5.3.0 пины RX,TX 
#define ONE_WIRE_BUS A5                     // пин датчика DS18B20
#define FIRST_P_Pin  10                     // на реле K1 на плате ПОТРЕБИТЕЛИ
#define SECOND_P     12                     // на реле К3 на плате ЗАЖИГАНИЕ
#define STARTER_Pin  11                     // на реле К2 на плате СТАРТЕР
#define IMMO         9                      // на реле K4 на плате под иммобилайзер
#define K5           8                      // на реле K5  внешнее под различные нужды, програмно не реализован
#define Lock_Pin     6                      // на реле K6 внешнее на кнопку "заблокировать дверь"
#define Unlock_Pin   7                      // на реле K7 внешнее на кнопку "разаблокировать дверь"
#define LED_Pin      13                     // на светодиод на плате
#define STOP_Pin     A0                     // вход IN3 на концевик педали тормоза для отключения режима прогрева
#define PSO_Pin      A1                     // вход IN4  на прочие датчики через делитель 39 kOhm / 11 kΩ
#define PSO_F        A2                     // обратная связь по реле K1, проверка на ключ в замке
#define RESET_Pin    A3                     // аппаратная перезагрузка модема, по сути не задействован
#define BAT_Pin      A7                     // внутри платы соединен с +12, через делитель напряжения 39кОм / 11 кОм
#define Feedback_Pin A6                     // обратная связь по реле K3, проверка на включенное зажигание

OneWire oneWire(ONE_WIRE_BUS); 
DallasTemperature sensors(&oneWire);
/*  ----------------------------------------- НАСТРОЙКИ MQTT брокера---------------------------------------------------------   */
const char MQTT_user[10] = "drive2ru";      // api.cloudmqtt.com > Details > User  
const char MQTT_pass[15] = "martinhool221";  // api.cloudmqtt.com > Details > Password
const char MQTT_type[15] = "MQIsdp";        // тип протокола НЕ ТРОГАТЬ !
const char MQTT_CID[15] = "CITROEN";        // уникальное имя устройства в сети MQTT
String MQTT_SERVER = "m54.cloudmqtt.com";   // api.cloudmqtt.com > Details > Server  сервер MQTT брокера
String PORT = "10077";                      // api.cloudmqtt.com > Details > Port    порт MQTT брокера НЕ SSL !
/*  ----------------------------------------- ИНДИВИДУАЛЬНЫЕ НАСТРОЙКИ !!!---------------------------------------------------------   */
String call_phone=  "+375000000000";        // телефон входящего вызова  для управления DTMF
String call_phone2= "+375000000001";        // телефон для автосброса могут работать не корректно
String call_phone3= "+375000000002";        // телефон для автосброса 
String call_phone4= "+375000000003";        // телефон для автосброса 
String APN = "internet.mts.by";             // тчка доступа выхода в интернет вашего сотового оператора

/*  ----------------------------------------- ДАЛЕЕ НЕ ТРОГАЕМ ---------------------------------------------------------------   */
float Vstart = 13.20;                        // порог распознавания момента запуска по напряжению
String pin = "";                            // строковая переменная набираемого пинкода 
float TempDS[11];                           // массив хранения температуры c рахных датчиков 
float Vbat,V_min;                                 // переменная хранящая напряжение бортовой сети
float m = 68.01;                            // делитель для перевода АЦП в вольты для резистров 39/11kOm
unsigned long Time1, Time2 = 0;
int Timer, inDS, count, error_CF, error_C;
int interval = 4;                           // интервал тправки данных на сервер после загрузки ардуино
bool heating = false;                       // переменная состояния режим прогрева двигателя
bool ring = false;                          // флаг момента снятия трубки
bool broker = false;                        // статус подклюлючения к брокеру
bool Security = false;                      // состояние охраны после подачи питания

void setup() {
 // pinMode(RESET_Pin, OUTPUT);  
  pinMode(FIRST_P_Pin, OUTPUT);          
  pinMode(SECOND_P,    OUTPUT);           
  pinMode(STARTER_Pin, OUTPUT);          
  pinMode(Lock_Pin,    OUTPUT);           
  pinMode(Unlock_Pin,  OUTPUT);          
  pinMode(LED_Pin,     OUTPUT);            
  pinMode(IMMO,        OUTPUT);  
  pinMode(K5,          OUTPUT);                
  
  pinMode(3, INPUT_PULLUP);                
  pinMode(2, INPUT_PULLUP);                 

 
  delay(100); 
  Serial.begin(9600);                       //скорость порта
//  Serial.setTimeout(50);
  
  SIM800.begin(9600);                       //скорость связи с модемом
 // SIM800.setTimeout(500);                 // тайм аут ожидания ответа
  
  Serial.println("MQTT |13/11/2018"); 
  delay (1000);
  SIM800_reset();
 

              }



void loop() {

if (SIM800.available())  resp_modem();                                    // если что-то пришло от SIM800 в Ардуино отправляем для разбора
if (Serial.available())  resp_serial();                                 // если что-то пришло от Ардуино отправляем в SIM800
if (millis()> Time2 + 60000) {Time2 = millis(); 
    if (Timer > 0 ) Timer--, Serial.print("Тм:"), Serial.println (Timer);}
                                               
if (millis()> Time1 + 10000) Time1 = millis(), detection();               // выполняем функцию detection () каждые 10 сек 
if (heating == true &&  digitalRead(STOP_Pin)==1) heatingstop();           // для платок 1,7,2

            }



void enginestart() {                                              // программа запуска двигателя
 // detachInterrupt(1);                                           // отключаем аппаратное прерывание, что бы не мешало запуску
 Serial.println("E-start");
   Timer = 5;                                                     // устанавливаем таймер на 5 минут 
    digitalWrite(IMMO, HIGH),          delay (100);               // включаем реле иммобилайзера
 if (analogRead(Feedback_Pin) < 30)                               // проверка на выключенное зажигание
   {int StTime  = map(TempDS[0], 20, -15, 700, 5000);                // Задаем время работы стартера в зависимости т температуры
 // StTime = 1000;                                                // Жестко указываем время кручения стартером в милисекундах ! (0,001сек)
    StTime = constrain(StTime, 700, 6000);                        // ограничиваем нижний и верхний диапазон работы стартера от 0,7 до 6 сек. 
    Serial.println("Еgnition. ON");
    digitalWrite(FIRST_P_Pin, HIGH),   delay (1000);              // включаем реле первого положения замка зажигания, ждем 1 сек.
    digitalWrite(SECOND_P,    HIGH),   delay (4000);              // включаем зажигание, и выжидаем 4 сек.
    
    if (TempDS[0] < -20)                                          // если температура ниже -20 градусов, дополнителльно выключаем 
       {digitalWrite(SECOND_P, LOW),   delay(2000);               // и снова включаем зажигание для прогрева свечей на дизелях
       digitalWrite(SECOND_P, HIGH),   delay(8000);}
    
    if (digitalRead(STOP_Pin) == LOW);                            // если на входе STOP_Pin (он же IN3 в версиии 5.3.0) нет напряжения то...
       {Serial.println("ST. ON"); 
       digitalWrite(STARTER_Pin, HIGH), delay(StTime), digitalWrite(STARTER_Pin, LOW);    // включаем и выключаем стартер на время установленное ранее
        Serial.println("ST. OFF"),      delay (6000);}            // ожидаем 6 секунд.
      }
if (VoltRead() > Vstart){Serial.println ("VBAT OK"), heating = true;} else heatingstop(); // проверяем идет ли зарядка АКБ

Serial.println ("OUT"), interval = 1;
        
//delay(3000), SIM800.println("ATH0");                            // вешаем трубку (для SIM800L) 
//attachInterrupt(1, callback, FALLING);                          // включаем прерывание на обратный звонок
 }


float VoltRead()    {                                             // замеряем напряжение на батарее и переводим значения в вольты
              float ADCC = analogRead(BAT_Pin);
                    ADCC = ADCC / m ;
                    Serial.print("АКБ: "), Serial.print(ADCC), Serial.println("V");    
                    if (ADCC < V_min) V_min = ADCC;                   
                    return(ADCC); }                  // переводим попугаи в вольты
                    


void heatingstop() {                                // программа остановки прогрева двигателя
    digitalWrite(SECOND_P,    LOW), delay (100);
    digitalWrite(FIRST_P_Pin, LOW), delay (100);
    digitalWrite(IMMO, LOW),        delay (100);
    digitalWrite(K5, LOW), digitalWrite(13, LOW);
    heating= false, Timer = 0;
    Serial.println ("All OFF"); }

void detection(){                                                 // условия проверяемые каждые 10 сек  
    
    Vbat = VoltRead();                                            // замеряем напряжение на батарее
    Serial.print("Инт:"), Serial.println(interval);
    inDS = 0;
    sensors.requestTemperatures();                                // читаем температуру с трех датчиков
    while (inDS < 10){
          TempDS[inDS] = sensors.getTempCByIndex(inDS);           // читаем температуру
      if (TempDS[inDS] == -127.00){TempDS[inDS]= 80;
                                   break; }                       // пока не доберемся до неподключенного датчика
              inDS++;} 
              
    for (int i=0; i < inDS; i++) Serial.print("Temp"), Serial.print(i), Serial.print("= "), Serial.println(TempDS[i]); 
    Serial.println ("");
    
    if (heating == true && Timer <1)    heatingstop();      // остановка прогрева если закончился отсчет таймера
 //   if (heating == true && TempDS[0] > 86)  heatingstop();   // остановить прогрев если температура выше 86 град
    interval--;
    if (interval <1) interval = 6, SIM800.println("AT+SAPBR=2,1"), delay (200);    // подключаемся к GPRS 
                      
}  



 
void resp_serial (){     // ---------------- ТРАНСЛИРУЕМ КОМАНДЫ из ПОРТА В МОДЕМ ----------------------------------
     String at = "";   
 //    while (Serial.available()) at = Serial.readString();
  int k = 0;
   while (Serial.available()) k = Serial.read(),at += char(k),delay(1);
     SIM800.println(at), at = "";   }   


void  MQTT_FloatPub (const char topic[15], float val, int x) {char st[10]; dtostrf(val,0, x, st), MQTT_PUB (topic, st);}

void MQTT_CONNECT () {
  SIM800.println("AT+CIPSEND"), delay (100);
     
  SIM800.write(0x10);                                                              // маркер пакета на установку соединения
  SIM800.write(strlen(MQTT_type)+strlen(MQTT_CID)+strlen(MQTT_user)+strlen(MQTT_pass)+12);
  SIM800.write((byte)0),SIM800.write(strlen(MQTT_type)),SIM800.write(MQTT_type);   // тип протокола
  SIM800.write(0x03), SIM800.write(0xC2),SIM800.write((byte)0),SIM800.write(0x3C); // просто так нужно
  SIM800.write((byte)0), SIM800.write(strlen(MQTT_CID)),  SIM800.write(MQTT_CID);  // MQTT  идентификатор устройства
  SIM800.write((byte)0), SIM800.write(strlen(MQTT_user)), SIM800.write(MQTT_user); // MQTT логин
  SIM800.write((byte)0), SIM800.write(strlen(MQTT_pass)), SIM800.write(MQTT_pass); // MQTT пароль

  MQTT_PUB ("C5/status", "Подключено");                                            // пакет публикации
  MQTT_SUB ("C5/comand");                                                          // пакет подписки на присылаемые команды
  MQTT_SUB ("C5/settimer");                                                        // пакет подписки на присылаемые значения таймера
  SIM800.write(0x1A),  broker = true;    }                                         // маркер завершения пакета

void  MQTT_PUB (const char MQTT_topic[15], const char MQTT_messege[15]) {          // пакет на публикацию

  SIM800.write(0x30), SIM800.write(strlen(MQTT_topic)+strlen(MQTT_messege)+2);
  SIM800.write((byte)0), SIM800.write(strlen(MQTT_topic)), SIM800.write(MQTT_topic); // топик
  SIM800.write(MQTT_messege);   }                                                  // сообщение

void  MQTT_SUB (const char MQTT_topic[15]) {                                       // пакет подписки на топик
  
  SIM800.write(0x82), SIM800.write(strlen(MQTT_topic)+5);                          // сумма пакета 
  SIM800.write((byte)0), SIM800.write(0x01), SIM800.write((byte)0);                // просто так нужно
  SIM800.write(strlen(MQTT_topic)), SIM800.write(MQTT_topic);                      // топик
  SIM800.write((byte)0);  }                          

void resp_modem (){     //------------------ АНЛИЗИРУЕМ БУФЕР ВИРТУАЛЬНОГО ПОРТА МОДЕМА------------------------------
     String at = "";
 //    while (SIM800.available()) at = SIM800.readString();  // набиваем в переменную at
  int k = 0;
   while (SIM800.available()) k = SIM800.read(),at += char(k),delay(1);           
   Serial.println(at);  
 
      if (at.indexOf("+CLIP: \""+call_phone+"\",") > -1) {delay(200), SIM800.println("ATA"), ring = true;}

     
else if (at.indexOf("+DTMF: ")  > -1)        {String key = at.substring(at.indexOf("")+9, at.indexOf("")+10);
                                                     pin = pin + key;
                                                     if (pin.indexOf("*") > -1 ) pin= ""; }
else if (at.indexOf("SMS Ready") > -1 || at.indexOf("NO CARRIER") > -1 ) {SIM800.println("AT+CLIP=1;+DDET=1");} // Активируем АОН и декодер DTMF
/*  -------------------------------------- проверяем соеденеиние с ИНТЕРНЕТ, конектимся к серверу------------------------------------------------------- */
else if (at.indexOf("+SAPBR: 1,3") > -1)                                  {SIM800.println("AT+SAPBR=3,1,\"CONTYPE\",\"GPRS\""), delay(200);} 
else if (at.indexOf("AT+SAPBR=3,1,\"CONTYPE\",\"GPRS\"\r\r\nOK") > -1)    {SIM800.println("AT+SAPBR=3,1, \"APN\",\""+APN+"\""), delay (500); }
else if (at.indexOf("AT+SAPBR=3,1, \"APN\",\""+APN+"\"\r\r\nOK") > -1 )   {SIM800.println("AT+SAPBR=1,1"), interval = 2 ;} // устанавливаем соеденение   
else if (at.indexOf("+SAPBR: 1,1") > -1 )        {delay (200),  SIM800.println("AT+CIPSTART=\"TCP\",\""+MQTT_SERVER+"\",\""+PORT+"\""), delay (1000);}
else if (at.indexOf("CONNECT FAIL") > -1 )       {SIM800.println("AT+CFUN=1,1"), error_CF++, delay (1000), interval = 3 ;}  // костыль 1
else if (at.indexOf("CLOSED") > -1 )             {SIM800.println("AT+CFUN=1,1"), error_C++,  delay (1000), interval = 3 ;}  // костыль 2
else if (at.indexOf("+CME ERROR:") > -1 )        {error_CF++; if (error_CF > 5) {error_CF = 0, SIM800.println("AT+CFUN=1,1");}}   // костыль 4 
else if (at.indexOf("CONNECT OK") > -1)          {MQTT_CONNECT();}


else if (at.indexOf("+CIPGSMLOC: 0,") > -1   )   {String LOC = at.substring(26,35)+","+at.substring(16,25);
                                                  SIM800.println("AT+CIPSEND"), delay (200);
                                                  MQTT_PUB ("C5/ussl", LOC.c_str()), SIM800.write(0x1A);} 
                                                  
else if (at.indexOf("+CUSD:") > -1   )           {String BALANS = at.substring(13, 26);
                                                  SIM800.println("AT+CIPSEND"), delay (200);
                                                  MQTT_PUB ("C5/ussd", BALANS.c_str()), SIM800.write(0x1A);} 
                                                  
else if (at.indexOf("+CSQ:") > -1   )            {String RSSI = at.substring(at.lastIndexOf(":")+1,at.lastIndexOf(","));  // +CSQ: 31,0
                                                  SIM800.println("AT+CIPSEND"), delay (200);
                                                  MQTT_PUB ("C5/rssi", RSSI.c_str()), SIM800.write(0x1A);} 
 
//else if (at.indexOf("ALREADY CONNECT") > -1)     {SIM800.println("AT+CIPSEND"), delay (200); 
else if (at.indexOf("ALREAD") > -1)              {SIM800.println("AT+CIPSEND"), delay (200); // если не "влезает" "ALREADY CONNECT"
                                                  MQTT_FloatPub ("C5/ds0",      TempDS[0],2);
                                                  MQTT_FloatPub ("C5/ds1",      TempDS[1],2);
                                          //      MQTT_FloatPub ("C5/ds2",      TempDS[2],2);
                                          //      MQTT_FloatPub ("C5/ds3",      TempDS[3],2);
                                                  MQTT_FloatPub ("C5/vbat",     Vbat,2);
                                                  MQTT_FloatPub ("C5/timer",    Timer,0);
                                                 // MQTT_PUB("C5/security", digitalRead(A3) ? "lock1" : "lock0");
                                                  MQTT_PUB      ("C5/security", Security ? "lock1" : "lock0");
                                                  MQTT_PUB      ("C5/engine",   heating ? "start" : "stop");
                                                  MQTT_FloatPub ("C5/engine",   heating,0);
                                                  MQTT_FloatPub ("C5/uptime",   millis()/3600000,0); 
                                                  SIM800.write(0x1A);}
                     


else if (at.indexOf("C5/comandlock1",4) > -1 )      {blocking(1), attachInterrupt(1, callback, FALLING);}     // команда постановки на охрану и включения прерывания по датчику вибрации     
else if (at.indexOf("C5/comandlock0",4) > -1 )      {blocking(0), detachInterrupt(1);}                         // команда снятия с хораны и отключения прерывания на датчик вибрации 
else if (at.indexOf("C5/settimer",4) > -1 )         {Timer = at.substring(at.indexOf("")+15, at.indexOf("")+18).toInt();}
else if (at.indexOf("C5/comandbalans",4) > -1 )     {SIM800.println("AT+CUSD=1,\"*100#\""); }     // запрос баланса
else if (at.indexOf("C5/comandrssi",4) > -1 )       {SIM800.println("AT+CSQ"); }                  // запрос уровня сигнала
else if (at.indexOf("C5/comandlocation",4) > -1 )   {SIM800.println("AT+CIPGSMLOC=1,1"); }        // запрос локации
else if (at.indexOf("C5/comandrelay6on",4) > -1 )   {Timer = 30, digitalWrite(13, HIGH), heating = true; }      //  включение реле K6
else if (at.indexOf("C5/comandstop",4) > -1 )       {heatingstop(); }     // команда остановки прогрева
else if (at.indexOf("C5/comandstart",4) > -1 )      {enginestart(); }     // команда запуска прогрева
else if (at.indexOf("C5/comandRefresh",4) > -1 )    {// Serial.println ("Команда обнвления");
                                                          SIM800.println("AT+CIPSEND"), delay (200);  
                                                          MQTT_FloatPub ("C5/ds0",      TempDS[0],2);
                                                          MQTT_FloatPub ("C5/ds1",      TempDS[1],2);
                                                  //      MQTT_FloatPub ("C5/ds2",      TempDS[2],2);
                                                  //      MQTT_FloatPub ("C5/ds3",      TempDS[3],2);
                                                          MQTT_FloatPub ("C5/vbat",     Vbat,2);
                                                          MQTT_FloatPub ("C5/timer",    Timer,0);
                                                          MQTT_PUB      ("C5/security", Security ? "lock1" : "lock0");
                                                          MQTT_PUB      ("C5/engine",   heating ? "start" : "stop");
                                                          MQTT_FloatPub ("C5/C", error_C,0);
                                                          MQTT_FloatPub ("C5/CF", error_CF,0); 
                                                          MQTT_FloatPub ("C5/uptime",   millis()/3600000,0); 
                                                          SIM800.write(0x1A); 
                                                          interval = 6; // швырнуть данные на сервер и ждать 60 сек
            
   at = "";      }                                                  // Возвращаем ответ можема в монитор порта , очищаем переменную

       if (pin.indexOf("123") > -1 ){ pin= "", enginestart();} 
  else if (pin.indexOf("777") > -1 ){ pin= "", SIM800.println("AT+CFUN=1,1");}           // костыль 3
  else if (pin.indexOf("789") > -1 ){ pin= "", delay(1500), SIM800.println("ATH0"),heatingstop();} 
  else if (pin.indexOf("#")   > -1 ){ pin= "", SIM800.println("ATH0");}
                              
 } 


void blocking (bool st) {digitalWrite(st ? Lock_Pin : Unlock_Pin, HIGH), delay(500), digitalWrite(st ? Lock_Pin : Unlock_Pin, LOW), Security = st, Serial.println(st ? "На охране":"Открыто");}
void SIM800_reset() {SIM800.println("AT+CFUN=1,1");}                        // перезагрузка модема 
void callback()     {SIM800.println("ATD"+call_phone+";"),    delay(3000);} // обратный звонок при появлении напряжения на входе IN1




change program, remove software sim800 module (call_phone),   write program for arduino nano 33 iot.