/* HocLapTrinhRobot G2 12 - Ghi log du lieu theo thoi gian Board: ESP32-S3 DevKit Hardware: SHT31 I2C, LDR voltage divider, MQ-135 analog, LED status, WiFi */ #include #include #include #include enum DataState { STATE_NORMAL, STATE_WATCH, STATE_ALERT }; struct LogEntry { uint32_t sampleId; unsigned long uptimeMs; time_t epoch; int rssi; bool shtOk; float tempC; float humidityPercent; float lightPercent; float airScore; DataState state; }; const char *WIFI_SSID = "TenMangWiFi"; const char *WIFI_PASSWORD = "MatKhauWiFi"; 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 int LOG_CAPACITY = 60; const unsigned long SENSOR_INTERVAL_MS = 1000; const unsigned long LOG_INTERVAL_MS = 5000; const float EMA_ALPHA = 0.18f; WebServer server(80); LogEntry logBuffer[LOG_CAPACITY]; int logWriteIndex = 0; int logCount = 0; uint32_t nextSampleId = 1; int gasBaselineRaw = 1800; bool filtersReady = false; bool shtOk = false; bool timeConfigured = false; unsigned long lastSensorMs = 0; unsigned long lastLogMs = 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); } const char *stateName(DataState state) { if (state == STATE_ALERT) return "ALERT"; if (state == STATE_WATCH) return "WATCH"; return "NORMAL"; } DataState chooseState() { if (tempFiltered > 34.0f || humFiltered > 85.0f || lightFiltered < 15.0f || airFiltered > 60.0f) { return STATE_ALERT; } if (tempFiltered > 32.0f || humFiltered > 78.0f || lightFiltered < 25.0f || airFiltered > 45.0f) { return STATE_WATCH; } return STATE_NORMAL; } 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; } time_t currentEpoch() { time_t now; time(&now); if (now < 1700000000) return 0; return now; } void appendLog() { LogEntry entry; entry.sampleId = nextSampleId++; entry.uptimeMs = millis(); entry.epoch = currentEpoch(); entry.rssi = WiFi.status() == WL_CONNECTED ? WiFi.RSSI() : 0; entry.shtOk = shtOk; entry.tempC = tempFiltered; entry.humidityPercent = humFiltered; entry.lightPercent = lightFiltered; entry.airScore = airFiltered; entry.state = chooseState(); logBuffer[logWriteIndex] = entry; logWriteIndex = (logWriteIndex + 1) % LOG_CAPACITY; if (logCount < LOG_CAPACITY) logCount++; Serial.print(entry.sampleId); Serial.print(','); Serial.print(entry.uptimeMs); Serial.print(','); Serial.print((long)entry.epoch); Serial.print(','); Serial.print(entry.rssi); Serial.print(','); Serial.print(entry.shtOk ? "OK" : "ERR"); Serial.print(','); Serial.print(entry.tempC, 2); Serial.print(','); Serial.print(entry.humidityPercent, 2); Serial.print(','); Serial.print(entry.lightPercent, 2); Serial.print(','); Serial.print(entry.airScore, 2); Serial.print(','); Serial.println(stateName(entry.state)); } String csvHeader() { return "sample_id,uptime_ms,epoch,rssi,sht_ok,temp_c,humidity_percent,light_percent,air_score,state\n"; } String entryToCsv(const LogEntry &entry) { String line = ""; line += String(entry.sampleId) + ","; line += String(entry.uptimeMs) + ","; line += String((long)entry.epoch) + ","; line += String(entry.rssi) + ","; line += String(entry.shtOk ? "OK" : "ERR") + ","; line += String(entry.tempC, 2) + ","; line += String(entry.humidityPercent, 2) + ","; line += String(entry.lightPercent, 2) + ","; line += String(entry.airScore, 2) + ","; line += String(stateName(entry.state)) + "\n"; return line; } String buildCsv() { String csv = csvHeader(); int first = (logWriteIndex - logCount + LOG_CAPACITY) % LOG_CAPACITY; for (int i = 0; i < logCount; i++) { int index = (first + i) % LOG_CAPACITY; csv += entryToCsv(logBuffer[index]); } return csv; } String buildJsonLog() { String json = "{\"count\":" + String(logCount) + ",\"capacity\":" + String(LOG_CAPACITY) + ",\"items\":["; int first = (logWriteIndex - logCount + LOG_CAPACITY) % LOG_CAPACITY; for (int i = 0; i < logCount; i++) { int index = (first + i) % LOG_CAPACITY; const LogEntry &e = logBuffer[index]; if (i > 0) json += ","; json += "{"; json += "\"sample_id\":" + String(e.sampleId) + ","; json += "\"uptime_ms\":" + String(e.uptimeMs) + ","; json += "\"epoch\":" + String((long)e.epoch) + ","; json += "\"rssi\":" + String(e.rssi) + ","; json += "\"temp_c\":" + String(e.tempC, 2) + ","; json += "\"humidity_percent\":" + String(e.humidityPercent, 2) + ","; json += "\"light_percent\":" + String(e.lightPercent, 2) + ","; json += "\"air_score\":" + String(e.airScore, 2) + ","; json += "\"state\":\"" + String(stateName(e.state)) + "\""; json += "}"; } json += "]}"; return json; } void clearLog() { logWriteIndex = 0; logCount = 0; nextSampleId = 1; Serial.println("log_cleared=OK"); } void handleRoot() { String html = ""; html += "G2 Log

G2 Time Log

"; html += "

Download CSV | View JSON | Clear log

"; html += "

";
  html += buildCsv();
  html += "

"; server.send(200, "text/html", html); } void handleLogCsv() { server.send(200, "text/csv", buildCsv()); } void handleApiLog() { server.send(200, "application/json", buildJsonLog()); } void handleClear() { clearLog(); server.send(200, "text/plain", "log cleared"); } void setupRoutes() { server.on("/", handleRoot); server.on("/log.csv", handleLogCsv); server.on("/api/log", handleApiLog); server.on("/clear", handleClear); server.begin(); } void connectWifiAndTime() { WiFi.mode(WIFI_STA); WiFi.begin(WIFI_SSID, WIFI_PASSWORD); Serial.print("wifi connecting"); unsigned long started = millis(); while (WiFi.status() != WL_CONNECTED && millis() - started < 15000) { Serial.print("."); digitalWrite(PIN_LED, (millis() / 250) % 2 == 0 ? HIGH : LOW); delay(250); } Serial.println(); if (WiFi.status() == WL_CONNECTED) { digitalWrite(PIN_LED, HIGH); configTime(7 * 3600, 0, "pool.ntp.org", "time.nist.gov"); timeConfigured = true; Serial.print("log url=http://"); Serial.print(WiFi.localIP()); Serial.println("/log.csv"); } else { digitalWrite(PIN_LED, LOW); Serial.println("wifi failed; log still works on Serial with uptime_ms"); } } void calibrateGasBaseline() { gasBaselineRaw = readAnalogAverage(PIN_MQ135, 40); Serial.print("baseline_gas_raw="); Serial.println(gasBaselineRaw); } void printStatus() { Serial.print("status count="); Serial.print(logCount); Serial.print(" capacity="); Serial.print(LOG_CAPACITY); Serial.print(" wifi="); Serial.print(WiFi.status() == WL_CONNECTED ? "OK" : "WAIT"); Serial.print(" time="); Serial.print(currentEpoch() > 0 ? "OK" : "UPTIME_ONLY"); Serial.print(" timeConfigured="); Serial.println(timeConfigured ? "YES" : "NO"); } void handleSerialCommand() { if (!Serial.available()) return; String command = Serial.readStringUntil('\n'); command.trim(); command.toUpperCase(); if (command == "BASELINE GAS") { calibrateGasBaseline(); } else if (command == "CLEAR LOG") { clearLog(); } else if (command == "PRINT CSV") { Serial.print(buildCsv()); } else if (command == "STATUS") { printStatus(); } else if (command.length() > 0) { Serial.println("commands: BASELINE GAS | CLEAR LOG | PRINT CSV | STATUS"); } } 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 12 time-series log ready"); Serial.print(csvHeader()); connectWifiAndTime(); setupRoutes(); } void loop() { server.handleClient(); handleSerialCommand(); if (WiFi.status() == WL_CONNECTED) { digitalWrite(PIN_LED, HIGH); } else { digitalWrite(PIN_LED, (millis() / 500) % 2 == 0 ? HIGH : LOW); } unsigned long now = millis(); if (now - lastSensorMs >= SENSOR_INTERVAL_MS) { lastSensorMs = now; readSensors(); } if (now - lastLogMs >= LOG_INTERVAL_MS) { lastLogMs = now; appendLog(); } }

Ghi log dữ liệu theo thời gian

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