/* HocLapTrinhRobot G2 10 - Gui du lieu bang HTTP Board: ESP32-S3 DevKit Hardware: SHT31 I2C, LDR voltage divider, MQ-135 analog, LED status */ #include #include #include const char *WIFI_SSID = "TenMangWiFi"; const char *WIFI_PASSWORD = "MatKhauWiFi"; const char *HTTP_ENDPOINT = "http://192.168.1.100:8080/data"; const char *DEVICE_ID = "g2-env-robot-01"; const int PIN_I2C_SDA = 8; const int PIN_I2C_SCL = 9; const int PIN_LDR = 4; const int PIN_MQ135 = 6; const int PIN_LED = 2; const uint8_t SHT31_ADDR = 0x44; const unsigned long WIFI_RETRY_MS = 5000; const unsigned long SENSOR_INTERVAL_MS = 1000; const unsigned long POST_INTERVAL_MS = 10000; const float EMA_ALPHA = 0.18f; unsigned long nextWifiRetryMs = 0; unsigned long lastSensorMs = 0; unsigned long lastPostMs = 0; int gasBaselineRaw = 1800; bool filtersReady = false; bool shtOk = false; int httpPostCount = 0; int httpErrorCount = 0; float tempFiltered = 0.0f; float humFiltered = 0.0f; float lightFiltered = 0.0f; float airFiltered = 0.0f; uint8_t crc8(const uint8_t *data, int len) { uint8_t crc = 0xFF; for (int i = 0; i < len; i++) { crc ^= data[i]; for (int bit = 0; bit < 8; bit++) { crc = (crc & 0x80) ? (crc << 1) ^ 0x31 : (crc << 1); } } return crc; } bool readSht31(float &temperatureC, float &humidityPercent) { Wire.beginTransmission(SHT31_ADDR); Wire.write(0x24); Wire.write(0x00); if (Wire.endTransmission() != 0) return false; delay(20); if (Wire.requestFrom((int)SHT31_ADDR, 6) != 6) return false; uint8_t data[6]; for (int i = 0; i < 6; i++) data[i] = Wire.read(); if (crc8(data, 2) != data[2] || crc8(data + 3, 2) != data[5]) return false; uint16_t rawTemp = ((uint16_t)data[0] << 8) | data[1]; uint16_t rawHum = ((uint16_t)data[3] << 8) | data[4]; temperatureC = -45.0f + 175.0f * ((float)rawTemp / 65535.0f); humidityPercent = 100.0f * ((float)rawHum / 65535.0f); return true; } int readAnalogAverage(int pin, int sampleCount) { long total = 0; for (int i = 0; i < sampleCount; i++) { total += analogRead(pin); delay(2); } return total / sampleCount; } float constrainFloat(float value, float low, float high) { if (value < low) return low; if (value > high) return high; return value; } float lightPercentFromRaw(int raw) { return constrainFloat((raw / 4095.0f) * 100.0f, 0.0f, 100.0f); } float airScoreFromRaw(int raw) { return constrainFloat((raw - gasBaselineRaw) / 12.0f, 0.0f, 100.0f); } float updateEma(float previous, float sample, bool initialized) { if (!initialized) return sample; return previous + EMA_ALPHA * (sample - previous); } void ensureWifi() { if (WiFi.status() == WL_CONNECTED) return; if (millis() < nextWifiRetryMs) return; nextWifiRetryMs = millis() + WIFI_RETRY_MS; WiFi.mode(WIFI_STA); WiFi.begin(WIFI_SSID, WIFI_PASSWORD); Serial.println("wifi action=connect"); } void readSensors() { float tempRaw = tempFiltered; float humRaw = humFiltered; shtOk = readSht31(tempRaw, humRaw); if (!shtOk && !filtersReady) { tempRaw = 0.0f; humRaw = 0.0f; } int ldrRaw = readAnalogAverage(PIN_LDR, 12); int mqRaw = readAnalogAverage(PIN_MQ135, 12); float lightRaw = lightPercentFromRaw(ldrRaw); float airRaw = airScoreFromRaw(mqRaw); tempFiltered = updateEma(tempFiltered, tempRaw, filtersReady); humFiltered = updateEma(humFiltered, humRaw, filtersReady); lightFiltered = updateEma(lightFiltered, lightRaw, filtersReady); airFiltered = updateEma(airFiltered, airRaw, filtersReady); filtersReady = true; } String buildPayload() { String payload = "{"; payload += "\"device\":\"" + String(DEVICE_ID) + "\","; payload += "\"uptime_ms\":" + String(millis()) + ","; payload += "\"wifi_connected\":" + String(WiFi.status() == WL_CONNECTED ? "true" : "false") + ","; payload += "\"rssi\":" + String(WiFi.status() == WL_CONNECTED ? WiFi.RSSI() : 0) + ","; payload += "\"sht_ok\":" + String(shtOk ? "true" : "false") + ","; payload += "\"temperature_c\":" + String(tempFiltered, 2) + ","; payload += "\"humidity_percent\":" + String(humFiltered, 2) + ","; payload += "\"light_percent\":" + String(lightFiltered, 2) + ","; payload += "\"air_score\":" + String(airFiltered, 2); payload += "}"; return payload; } void sendHttpPayload() { String payload = buildPayload(); Serial.print("payload="); Serial.println(payload); if (WiFi.status() != WL_CONNECTED) { httpErrorCount++; Serial.println("http skip=NO_WIFI"); return; } HTTPClient http; http.setTimeout(4000); if (!http.begin(HTTP_ENDPOINT)) { httpErrorCount++; Serial.println("http error=BEGIN_FAILED"); return; } http.addHeader("Content-Type", "application/json"); int code = http.POST(payload); String response = http.getString(); http.end(); if (code > 0) { httpPostCount++; Serial.print("http post code="); Serial.print(code); Serial.print(" bytes="); Serial.print(payload.length()); Serial.print(" response="); Serial.println(response); } else { httpErrorCount++; Serial.print("http error_code="); Serial.println(code); } } void calibrateGasBaseline() { gasBaselineRaw = readAnalogAverage(PIN_MQ135, 40); Serial.print("baseline_gas_raw="); Serial.println(gasBaselineRaw); } void printStatus() { Serial.print("status wifi="); Serial.print(WiFi.status() == WL_CONNECTED ? "OK" : "WAIT"); Serial.print(" ip="); Serial.print(WiFi.status() == WL_CONNECTED ? WiFi.localIP().toString() : "none"); Serial.print(" rssi="); Serial.print(WiFi.status() == WL_CONNECTED ? WiFi.RSSI() : 0); Serial.print(" posts="); Serial.print(httpPostCount); Serial.print(" errors="); Serial.println(httpErrorCount); } void handleSerialCommand() { if (!Serial.available()) return; String command = Serial.readStringUntil('\n'); command.trim(); command.toUpperCase(); if (command == "BASELINE GAS") { calibrateGasBaseline(); } else if (command == "SEND NOW") { sendHttpPayload(); } else if (command == "STATUS") { printStatus(); } else if (command.length() > 0) { Serial.println("commands: BASELINE GAS | SEND NOW | STATUS"); } } void updateLed() { if (WiFi.status() == WL_CONNECTED) { digitalWrite(PIN_LED, HIGH); } else { digitalWrite(PIN_LED, (millis() / 300) % 2 == 0 ? HIGH : LOW); } } void setup() { Serial.begin(115200); delay(400); pinMode(PIN_LED, OUTPUT); digitalWrite(PIN_LED, LOW); analogReadResolution(12); Wire.begin(PIN_I2C_SDA, PIN_I2C_SCL); WiFi.persistent(false); WiFi.setSleep(false); Serial.println("G2 10 HTTP telemetry ready"); Serial.println("commands: BASELINE GAS | SEND NOW | STATUS"); } void loop() { handleSerialCommand(); ensureWifi(); updateLed(); unsigned long now = millis(); if (now - lastSensorMs >= SENSOR_INTERVAL_MS) { lastSensorMs = now; readSensors(); Serial.print("sensor sht="); Serial.print(shtOk ? "OK" : "ERR"); Serial.print(" temp="); Serial.print(tempFiltered, 1); Serial.print(" hum="); Serial.print(humFiltered, 1); Serial.print(" light="); Serial.print(lightFiltered, 1); Serial.print(" air="); Serial.println(airFiltered, 1); } if (now - lastPostMs >= POST_INTERVAL_MS) { lastPostMs = now; sendHttpPayload(); } }

Gửi dữ liệu bằng MQTT hoặc HTTP

Ghi danh khóa học để mở bài này