commit 67970f7eb22e6ce05f43a56e260cada7987d26b8 Author: feie9456 Date: Tue Nov 11 22:45:50 2025 +0800 init diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..89cc49c --- /dev/null +++ b/.gitignore @@ -0,0 +1,5 @@ +.pio +.vscode/.browse.c_cpp.db* +.vscode/c_cpp_properties.json +.vscode/launch.json +.vscode/ipch diff --git a/.vscode/extensions.json b/.vscode/extensions.json new file mode 100644 index 0000000..080e70d --- /dev/null +++ b/.vscode/extensions.json @@ -0,0 +1,10 @@ +{ + // See http://go.microsoft.com/fwlink/?LinkId=827846 + // for the documentation about the extensions.json format + "recommendations": [ + "platformio.platformio-ide" + ], + "unwantedRecommendations": [ + "ms-vscode.cpptools-extension-pack" + ] +} diff --git a/.vscode/settings.json b/.vscode/settings.json new file mode 100644 index 0000000..bfa6f57 --- /dev/null +++ b/.vscode/settings.json @@ -0,0 +1,6 @@ +{ + "files.associations": { + "*.dbclient-js": "javascript", + "functional": "cpp" + } +} \ No newline at end of file diff --git a/data/index.html.gz b/data/index.html.gz new file mode 100644 index 0000000..58d7f01 Binary files /dev/null and b/data/index.html.gz differ diff --git a/include/README b/include/README new file mode 100644 index 0000000..49819c0 --- /dev/null +++ b/include/README @@ -0,0 +1,37 @@ + +This directory is intended for project header files. + +A header file is a file containing C declarations and macro definitions +to be shared between several project source files. You request the use of a +header file in your project source file (C, C++, etc) located in `src` folder +by including it, with the C preprocessing directive `#include'. + +```src/main.c + +#include "header.h" + +int main (void) +{ + ... +} +``` + +Including a header file produces the same results as copying the header file +into each source file that needs it. Such copying would be time-consuming +and error-prone. With a header file, the related declarations appear +in only one place. If they need to be changed, they can be changed in one +place, and programs that include the header file will automatically use the +new version when next recompiled. The header file eliminates the labor of +finding and changing all the copies as well as the risk that a failure to +find one copy will result in inconsistencies within a program. + +In C, the convention is to give header files names that end with `.h'. + +Read more about using header files in official GCC documentation: + +* Include Syntax +* Include Operation +* Once-Only Headers +* Computed Includes + +https://gcc.gnu.org/onlinedocs/cpp/Header-Files.html diff --git a/lib/README b/lib/README new file mode 100644 index 0000000..9379397 --- /dev/null +++ b/lib/README @@ -0,0 +1,46 @@ + +This directory is intended for project specific (private) libraries. +PlatformIO will compile them to static libraries and link into the executable file. + +The source code of each library should be placed in a separate directory +("lib/your_library_name/[Code]"). + +For example, see the structure of the following example libraries `Foo` and `Bar`: + +|--lib +| | +| |--Bar +| | |--docs +| | |--examples +| | |--src +| | |- Bar.c +| | |- Bar.h +| | |- library.json (optional. for custom build options, etc) https://docs.platformio.org/page/librarymanager/config.html +| | +| |--Foo +| | |- Foo.c +| | |- Foo.h +| | +| |- README --> THIS FILE +| +|- platformio.ini +|--src + |- main.c + +Example contents of `src/main.c` using Foo and Bar: +``` +#include +#include + +int main (void) +{ + ... +} + +``` + +The PlatformIO Library Dependency Finder will find automatically dependent +libraries by scanning project source files. + +More information about PlatformIO Library Dependency Finder +- https://docs.platformio.org/page/librarymanager/ldf.html diff --git a/platformio.ini b/platformio.ini new file mode 100644 index 0000000..f7b6e37 --- /dev/null +++ b/platformio.ini @@ -0,0 +1,18 @@ +; PlatformIO Project Configuration File +; +; Build options: build flags, source filter +; Upload options: custom upload port, speed and extra flags +; Library options: dependencies, extra library storages +; Advanced options: extra scripting +; +; Please visit documentation for the other options and examples +; https://docs.platformio.org/page/projectconf.html + +[env:rymcu-esp32-s3-devkitc-1] +platform = espressif32 +board = rymcu-esp32-s3-devkitc-1 +framework = arduino +upload_speed = 921600 +monitor_speed = 115200 +build_flags = -std=gnu++2a +board_build.filesystem = littlefs diff --git a/src/main.cpp b/src/main.cpp new file mode 100644 index 0000000..bd498af --- /dev/null +++ b/src/main.cpp @@ -0,0 +1,321 @@ +#include +#include +#include +#include +#include +#include + +#define FS LittleFS + +// ================== WiFi AP 配置 ================== +const char* AP_SSID = "AD7606_AP"; +const char* AP_PASS = "12345678"; + +WiFiServer httpServer(80); +WiFiClient streamClient; +bool streamClientActive = false; + +// Captive Portal 用 DNS 服务器 +const byte DNS_PORT = 53; +DNSServer dnsServer; + +// ================== AD7606 引脚配置（按实际改） ================== +static const int PIN_AD_MISO = 8; // DB7 / DOUTA +static const int PIN_AD_SCK = 11; // RD/SC +static const int PIN_AD_CS = 12; // CS_N + +static const int PIN_AD_CONVSTA = 13; // CO-A +static const int PIN_AD_CONVSTB = 13; // CO-B（与 CO-A 共用） + +static const int PIN_AD_RESET = 5; // REST +static const int PIN_AD_BUSY = 14; // BUSY + +static const int PIN_AD_OS0 = 6; // OSI0 +static const int PIN_AD_OS1 = 7; // OSI1 +static const int PIN_AD_OS2 = 15; // OSI2 + +// 如果 SER / STBY 直接焊到 3.3V，这两个 PIN 物理上可以不接 +static const int PIN_AD_SER = 3; // SER +static const int PIN_AD_STBY = 4; // STBY + +SPIClass AD7606_SPI(FSPI); +int16_t g_samples[8]; + +// ================== AD7606 相关函数 ================== + +void AD7606_reset() { + digitalWrite(PIN_AD_RESET, LOW); + delayMicroseconds(2); + digitalWrite(PIN_AD_RESET, HIGH); + delayMicroseconds(2); + digitalWrite(PIN_AD_RESET, LOW); +} + +void AD7606_startConvst() { + digitalWrite(PIN_AD_CONVSTA, LOW); + digitalWrite(PIN_AD_CONVSTB, LOW); + delayMicroseconds(1); + digitalWrite(PIN_AD_CONVSTA, HIGH); + digitalWrite(PIN_AD_CONVSTB, HIGH); + delayMicroseconds(1); +} + +void AD7606_readAll(int16_t* data) { + // 1. 触发转换 + AD7606_startConvst(); + + // 2. 等 BUSY 变低（BUSY 高 = 正在转换） + while (digitalRead(PIN_AD_BUSY) == HIGH) { + // 可选的小延时 + // delayMicroseconds(1); + } + + // 3. SPI 连续读取 8 个 16-bit + AD7606_SPI.beginTransaction(SPISettings(8000000, // 8MHz + MSBFIRST, SPI_MODE0)); + + digitalWrite(PIN_AD_CS, LOW); + + for (int i = 0; i < 8; ++i) { + uint16_t raw = AD7606_SPI.transfer16(0x0000); + data[i] = static_cast(raw); + } + + digitalWrite(PIN_AD_CS, HIGH); + AD7606_SPI.endTransaction(); +} + +float AD7606_codeToVolt(int16_t code, bool range10V) { + float fullScale = range10V ? 10.0f : 5.0f; + return (float)code * (fullScale / 32768.0f); +} + +void AD7606_init() { + pinMode(PIN_AD_CS, OUTPUT); + pinMode(PIN_AD_SCK, OUTPUT); + pinMode(PIN_AD_MISO, INPUT); + pinMode(PIN_AD_CONVSTA, OUTPUT); + pinMode(PIN_AD_CONVSTB, OUTPUT); + pinMode(PIN_AD_RESET, OUTPUT); + pinMode(PIN_AD_BUSY, INPUT); + + pinMode(PIN_AD_OS0, OUTPUT); + pinMode(PIN_AD_OS1, OUTPUT); + pinMode(PIN_AD_OS2, OUTPUT); + + pinMode(PIN_AD_SER, OUTPUT); + pinMode(PIN_AD_STBY, OUTPUT); + + digitalWrite(PIN_AD_CS, HIGH); + digitalWrite(PIN_AD_CONVSTA, HIGH); + digitalWrite(PIN_AD_CONVSTB, HIGH); + + // 串行模式 & 正常工作（如果硬件已拉 3.3V，这两句只是保险） + digitalWrite(PIN_AD_SER, HIGH); // SER=1 -> 串行 + digitalWrite(PIN_AD_STBY, HIGH); // STBY=1 -> 正常工作 + + // 不过采样 OS[2:0] = 000 + digitalWrite(PIN_AD_OS0, LOW); + digitalWrite(PIN_AD_OS1, LOW); + digitalWrite(PIN_AD_OS2, LOW); + + AD7606_reset(); + delay(1); + + const int dummyMosi = 9; // MOSI 随便给个没用的脚 + AD7606_SPI.begin(PIN_AD_SCK, PIN_AD_MISO, dummyMosi, PIN_AD_CS); + + AD7606_startConvst(); +} + +// ================== HTTP + Captive Portal 部分 ================== + +// 返回 gzip 压缩的 index.html.gz +void serveIndexHtml(WiFiClient& client) { + File f = FS.open("/index.html.gz", "r"); + if (!f || f.isDirectory()) { + client.print( + "HTTP/1.1 500 Internal Server Error\r\n" + "Content-Type: text/plain\r\n" + "Connection: close\r\n" + "\r\n" + "index.html not found\r\n"); + client.stop(); + return; + } + + client.print( + "HTTP/1.1 200 OK\r\n" + "Content-Type: text/html; charset=utf-8\r\n" + "Content-Encoding: gzip\r\n" + "Connection: close\r\n" + "Cache-Control: no-cache\r\n" + "Access-Control-Allow-Origin: *\r\n" + "\r\n"); + + uint8_t buf[1024]; + while (true) { + size_t n = f.read(buf, sizeof(buf)); + if (n == 0) break; + client.write(buf, n); + } + f.close(); + client.stop(); +} + +// 发送 302 重定向到 /index.html（可选用） +void redirectToPortal(WiFiClient& client) { + client.print( + "HTTP/1.1 302 Found\r\n" + "Location: /index.html\r\n" + "Connection: close\r\n" + "Cache-Control: no-cache\r\n" + "Access-Control-Allow-Origin: *\r\n" + "\r\n"); + client.stop(); +} + +// 简易 HTTP 服务器 + Captive Portal 路由 +void acceptOrServeHttp() { + // 1) 如果已有 stream 客户端，先检测是否掉线 + if (streamClientActive && !streamClient.connected()) { + Serial.println("[HTTP] stream client disconnected"); + streamClient.stop(); + streamClientActive = false; + } + + // 2) 接受新连接 + WiFiClient client = httpServer.available(); + if (!client) { + return; // 没有新客户端 + } + + client.setTimeout(200); // 避免 readStringUntil 长时间阻塞 (ms) + + // 3) 读取首行 + String reqLine = client.readStringUntil('\r'); + client.readStringUntil('\n'); // 丢弃 \n + if (reqLine.length() == 0) { + client.stop(); + return; + } + + // 4) 解析 path + String path; + int firstSpace = reqLine.indexOf(' '); + int secondSpace = reqLine.indexOf(' ', firstSpace + 1); + if (firstSpace >= 0 && secondSpace > firstSpace) { + path = reqLine.substring(firstSpace + 1, secondSpace); + } + + // 5) 丢弃其余 header（最多读取一定行数防御） + for (int i = 0; i < 40 && client.connected(); ++i) { + String line = client.readStringUntil('\n'); + if (line == "\r" || line.length() == 0) break; + } + + // 6) 路由： + // - /stream: 长连接输出采样 + // - 其他任意路径 -> Captive Portal 页面 (index.html) + if (path == "/stream") { + if (streamClientActive) { + // 已经有一个 streaming，占用中 + client.print( + "HTTP/1.1 409 Conflict\r\n" + "Content-Type: text/plain\r\n" + "Connection: close\r\n" + "Cache-Control: no-cache\r\n" + "Access-Control-Allow-Origin: *\r\n" + "\r\n" + "stream already active\r\n"); + client.stop(); + } else { + client.print( + "HTTP/1.1 200 OK\r\n" + "Content-Type: text/plain\r\n" + "Cache-Control: no-cache\r\n" + "Connection: keep-alive\r\n" + "Access-Control-Allow-Origin: *\r\n" + "\r\n"); + streamClient = client; // 复制句柄，保持长连接 + streamClientActive = true; + Serial.println("[HTTP] stream client connected /stream"); + // 不调用 stop() + } + } else { + // 这里可以选择 serveIndexHtml 或 redirectToPortal + // 为了简单，直接返回 index.html 内容 + serveIndexHtml(client); + // 或者改成： + // redirectToPortal(client); + } +} + +// 发送一帧 CH0 原始码值（只有一个数字 + '\n'） +void sendRawSample(int16_t ch0_code) { + if (!streamClientActive || !streamClient.connected()) { + return; + } + + streamClient.print(ch0_code); + streamClient.print('\n'); + // 一般不用每次 flush，WiFi 底层会合包 +} + +// ================== Arduino 入口 ================== + +void setup() { + Serial.begin(115200); + delay(1000); + + Serial.println("Mounting LittleFS..."); + if (!FS.begin(true)) { // true = 如果挂载失败就尝试格式化 + Serial.println("LittleFS mount failed"); + } else { + Serial.println("LittleFS mounted OK"); + } + + Serial.println("Init AD7606 (ESP32-S3 + SPI)..."); + AD7606_init(); + Serial.println("AD7606 init done."); + + // 启动 AP + WiFi.mode(WIFI_AP); + bool apOk = WiFi.softAP(AP_SSID, AP_PASS); + if (apOk) { + Serial.print("AP started, SSID: "); + Serial.println(AP_SSID); + Serial.print("AP IP: "); + Serial.println(WiFi.softAPIP()); + } else { + Serial.println("AP start FAILED"); + } + + // 启动 DNS Server：所有域名都解析到 AP IP + IPAddress apIP = WiFi.softAPIP(); + dnsServer.start(DNS_PORT, "*", apIP); + Serial.print("DNS server started on "); + Serial.print(apIP); + Serial.print(":"); + Serial.println(DNS_PORT); + + // 启动 HTTP Server + httpServer.begin(); + Serial.println("HTTP server started on port 80"); +} + +void loop() { + // 1. 先处理 DNS（Captive Portal 必须） + dnsServer.processNextRequest(); + + // 2. 处理 HTTP 连接 + acceptOrServeHttp(); + + // 3. 采样一次 + AD7606_readAll(g_samples); + + // 4. 如果有客户端，就发一行 CH0 raw code + sendRawSample(g_samples[0]); + + delay(1); +} diff --git a/test/README b/test/README new file mode 100644 index 0000000..9b1e87b --- /dev/null +++ b/test/README @@ -0,0 +1,11 @@ + +This directory is intended for PlatformIO Test Runner and project tests. + +Unit Testing is a software testing method by which individual units of +source code, sets of one or more MCU program modules together with associated +control data, usage procedures, and operating procedures, are tested to +determine whether they are fit for use. Unit testing finds problems early +in the development cycle. + +More information about PlatformIO Unit Testing: +- https://docs.platformio.org/en/latest/advanced/unit-testing/index.html