#include <ESP8266WiFi.h>
#include <TickerScheduler.h>
#include <sqlite3.h>
#include <vfs.h>
#include <FS.h>
// Для файловой системы
File fsUploadFile;
//Планировщик задач (Число задач)
TickerScheduler ts(1);
int ihour = 0;
int imin = 0;
int isec = 0;
void setup() {
Serial.begin(115200);
FS_init();
sqlite_init();
}
void loop() {
ts.update();
}
// Инициализация FFS
void FS_init() {
char *fileName = "";
system_update_cpu_freq(SYS_CPU_160MHZ);
if (!SPIFFS.begin()) {
Serial.println("Failed to mount SPIFFS");
return;
}
Dir dir = SPIFFS.openDir("/");
while (dir.next()) {
size_t fileSize = dir.fileSize();
Serial.println(fileSize);
}
}
void sqlite_init() {
sqlite3_initialize();
ts.add(0, 10000, [&](void*) {
char query[180] = "";
char zn[3]= ", ";
char fin[3]= ");";
char tIn[5] = "27.5";//(String)GettIn();
char tOut[6] = "-4.3";//(String)GettOut();
char humidity[5] = "21";//(String)Gethumidity();
char pressure[6] = "745";//(String)Getpressure();
char chour[3];
sprintf(chour, "%u", ihour);
char cmin[3];
sprintf(cmin, "%u", imin);
char str1[77] = "INSERT INTO day_p (cyear, cmonth, cday, chour, cmin, tin, tout, vlag, davl) ";
char str2[22] = "VALUES (2021, 2, 28, ";
char str3[47] = "SELECT COUNT(cyear) FROM day_p ORDER BY cyear;";
strcat(query, str1);
strcat(query, str2);
strcat(query, chour);
strcat(query, zn);
strcat(query, cmin);
strcat(query, zn);
strcat(query, tIn);
strcat(query, zn);
strcat(query, tOut);
strcat(query, zn);
strcat(query, humidity);
strcat(query, zn);
strcat(query, pressure);
strcat(query, fin);
strcat(query, str3);
//Serial.println(query);
db_exec(query);
isec = isec + 10;
if (isec == 60) {
isec = 0;
imin++;
}
if (imin == 60) {
imin = 0;
ihour++;
}
}, nullptr, true);
}
void db_exec(const char *sql) {
sqlite3 *db;
int rc;
char *fileName = "";
const char *dbf = "/FLASH/db.db";
char *ErrMsg = 0;
const char* data = 0;
Serial.println(sql);
File db_file_obj;
vfs_set_spiffs_file_obj(&db_file_obj);
if (sqlite3_open(dbf, &db)) {
Serial.print(F("Can't open database: "));
Serial.println(sqlite3_errmsg(db));
return;
}
else Serial.println("DB opened");
rc = sqlite3_exec(db, sql, callback, (void*)data, &ErrMsg);
if (rc != SQLITE_OK) {
Serial.print(F("SQL error: "));
Serial.println(ErrMsg);
sqlite3_free(ErrMsg);
}
Serial.println(rc);
sqlite3_close(db);
Dir dir = SPIFFS.openDir("/");
while (dir.next()) {
size_t fileSize = dir.fileSize();
Serial.println(fileSize);
}
Serial.print("Память ");Serial.println(ESP.getFreeHeap());
}
static int callback(void *data, int argc, char **argv, char **azColName) {
for (int i = 0; i < argc; i++){
if (i > 0) {
Serial.print(" | ");
}
Serial.print(argv[i]);
}
Serial.println();
return 0;
}
