Работа устройства:

#include <ARpcDevice.h>
#include <TroykaMQ.h>

#define analogGas A0 //подключение аналогового сигналоьного пина
#define motor1 4
#define motor10 5
#define motor2 7
#define motor20 6
long duration, cm;
int distance = 0;
unsigned long newTime = 0;
unsigned long oldTime = 0;
float gasValueNow;
float optimal;
//MQ135 gasSensor = MQ135(analogGas);
MQ135 mq135(analogGas);
float gasValue; //переменная для хранения количества газа
float gasValue1; //переменная для хранения количества газа
float gasValue2; //переменная для хранения количества газа
const char *deviceName="WaterIoT";
const ARpcUuid deviceId ("{31f277f2-f021-4a2c-b8cb-2c8d2f14dd92}");

const char *sensorsDef = "<sensors>"
"<sensor name =\"gassensor\" type=\"f32_sv\"/>"
"<sensor name=\"dalsensor\" type=\"u16_sv\"/>"
"</sensors>";

class WriteCallback
:public ARpcIWriteCallback
{
public:
virtual void writeData(const char *data,unsigned long sz)
{
Serial.write(data,sz);
}
virtual void writeStr(const char *str)
{
Serial.print(str);
}
virtual void writeStr(const __FlashStringHelper *str)
{
Serial.print(str);
}
}wcb;

ARpcDevice dev(300,&wcb,&deviceId,deviceName);

int dist(){
digitalWrite(10, LOW);
delayMicroseconds(5);
digitalWrite(10, HIGH);
// Выставив высокий уровень сигнала, ждем около 10 микросекунд. В этот момент датчик будет посылать сигналы с частотой 40 КГц.
delayMicroseconds(10);
digitalWrite(10, LOW);
// Время задержки акустического сигнала на эхолокаторе.
duration = pulseIn(11, HIGH);
cm = (duration / 2) / 29.1;
return cm;
// Теперь осталось преобразовать время в расстояние

}

void setup() {
Serial.begin(9600); //инициализация Serial порта
mq135.calibrate();
pinMode(analogGas, INPUT);
pinMode(motor1, OUTPUT);
pinMode(motor10, OUTPUT);
pinMode(motor2, OUTPUT);
pinMode(motor20, OUTPUT);
pinMode(12, INPUT_PULLUP);
pinMode(A5, OUTPUT);
pinMode(10, OUTPUT);
pinMode(11, INPUT);
pinMode(8, OUTPUT);
digitalWrite(8, 1);

dev.disp().setSensors(sensorsDef);
dev.resetStream();

while (digitalRead(12) == 0)
{
digitalWrite(motor1, HIGH);
analogWrite(motor10, HIGH);
}
digitalWrite(motor1, LOW);
analogWrite(motor10, LOW);
gasValue1 = mq135.readCO2();
delay(10000);
gasValue2 = mq135.readCO2();
optimal = (gasValue2 + gasValue1)/2;
}

void loop() {
distance = dist();
Serial.print("дистанция: ");
Serial.println(distance);
gasValueNow = mq135.readCO2();
newTime = millis();
while(Serial.available())
dev.putByte(Serial.read());

if((newTime - oldTime) >= 1000)//если оно на 1000 мсек больше предыдущего
{
dev.disp().writeMeasurement("gassensor",String(gasValueNow).c_str());
dev.disp().writeMeasurement("dalsensor",String(gasValueNow).c_str());
oldTime=newTime;
}
while(digitalRead(12) == 0) {
analogWrite(motor20, 255);
analogWrite(motor10, 0);
}
//oldTime = newTime;
if (gasValueNow < optimal - 20)
{
digitalWrite(A5, LOW);
analogWrite(motor10, 255);
analogWrite(motor20, 0);
}
else if (gasValueNow > optimal + 20 || distance > 8)
{
analogWrite(motor10, 0);
analogWrite(motor20, 255);
digitalWrite(A5, HIGH);
while (gasValueNow > optimal + 20) {
gasValueNow = mq135.readCO2();
}
digitalWrite(A5, LOW);
} else {
digitalWrite(A5, LOW);
analogWrite(motor10,0);
analogWrite(motor20,0);
}

delay(300);
}