大佬您好，我又来了，想来讨论一下一些问题。

[sarakii]

大佬好，这是我根据您的代码修改的自己需要的串口问答版本：

#include <Arduino.h>            //build in
#include <CustomJWT.h>          //find from library
#include <ESPAsyncWebServer.h>  // Get from https://github.com/me-no-dev/ESPAsyncWebServer
#include <ArduinoJson.h>        //find from library
#include <WiFiClientSecure.h>   //build in
#include <WiFiUdp.h>            //build in
#include <time.h>               //build in
#include <HTTPClient.h>         //find from library

void WiFiConnection();
void initTime();
void splitApiKey(const char *apikey);

char header[50];
char payload[500];
char signature[100];
char out[500];
char jsonString[500];

char idCharArray[150];
char secretCharArray[100];

const char* ssid = "FireBat";
const char* password = "123456789x";

const char *getMessage;

unsigned long timestamp;
time_t now;
struct tm timeinfo;

bool Process = false;
bool checkIP = true;

String getReturnJson, responseMessage;
HTTPClient http, http_id;

char *role = "user";

char *version = "0.0.1";

char *setApiKey = "cde3b06db9072cc9ce0c0233939207d7.AVSBoJ2P9v0NrkSf";  //Get Api key from https://open.bigmodel.cn/

//char* web_hook = "https://open.bigmodel.cn/api/paas/v3/model-api/characterglm/async-invoke";  //ChatGLM Character
//char *web_hook = "https://open.bigmodel.cn/api/paas/v3/model-api/chatglm_pro/async-invoke";  //ChatGLM Pro
char* web_hook = "https://open.bigmodel.cn/api/paas/v3/model-api/chatglm_std/async-invoke";  //ChatGLM Std
//char *web_hook = "https://open.bigmodel.cn/api/paas/v3/model-api/chatglm_lite/async-invoke";  // ChatGLM lite

const char *ntpServer = "ntp.aliyun.com";  //You can change NTP from what you want, the default is aliyun
const long gmtOffset_sec = 28800;          //Change GMT, default is China's NTP +8
const int daylightOffset_sec = 0;

DynamicJsonDocument doc(2048);

void setup() {
  Serial.begin(115200);
  WiFiConnection();
  delay(100);

  initTime();
  if(getLocalTime(&timeinfo)){
      now = mktime(&timeinfo);
      splitApiKey(setApiKey);
  } else {
      Serial.println(F("Failed to obtain Beijing time"));   //if you change your ntp you had better to change it
  }
}

void loop() {
    String userMessage="";
    if (WiFi.status() == WL_CONNECTED) {
        while(Serial.available()<0);
        while(Serial.available()>0){ // 串口有输入
            userMessage += char(Serial.read());
            delay(10);      // 延时函数用于等待字符完全进入缓冲区，可以尝试没有延时，输出结果会是什么
        }
        // 检查是否接收到数据，如果接收到数据，则输出该数据
        if(userMessage!=""){
            Serial.print("You:");
            Serial.print(userMessage);
            // userMessage = "100字内回答：" + userMessage; // 需要节约tokens时，则添加这句
            Process = true;
        }

        if(Process){
            // 开始向AI的http提问请求，获取task_id
            http.begin(web_hook);
            http.addHeader("Accept", "application/json");   
            http.addHeader("Content-Type", "application/json; charset=UTF-8");
            http.addHeader("Authorization", getReturnJson);
            // String metaData = "\"meta\": {\"user_info\": \"" + String(user_info) + "\", \"bot_info\": \"" + String(bot_info) + "\", \"bot_name\": \"" + String(bot_name) + "\", \"user_name\": \"" + String(user_name) + "\"}";
            // String payloadMessage = "{\"prompt\": [{\"role\": \"" + String(role) + "\", \"content\": \"" + userMessage + "\"}], " + metaData + "}";
            String payloadMessage = "{\"prompt\": \"" + userMessage + "\"}";

            int httpResponseCode = http.POST(payloadMessage);
            if (httpResponseCode > 0) {
                String returnJsonMessage = http.getString();
                DeserializationError error = deserializeJson(doc, returnJsonMessage);
                // Serial.println(returnJsonMessage);
                if (error) {
                  Serial.print(F("JSON parsing failed: "));
                  Serial.println(F(error.c_str()));
                }
            }
            // 结束向AI的http提问请求
            userMessage.clear();
            http.end();
            
            // 开始向AI的http处理结果请求
            String task_id = doc["data"]["task_id"]; // 获取task_id
            String web_search_id = "https://open.bigmodel.cn/api/paas/v3/model-api/-/async-invoke/" + task_id;  //GET Method(+below)
            http_id.begin(web_search_id);
            http_id.addHeader("Accept", "application/json");
            http_id.addHeader("Content-Type", "application/json; charset=UTF-8");
            http_id.addHeader("Authorization", getReturnJson);
            Serial.println();
            while(true){
              int httpResponseIDCode = http_id.GET();
              if (httpResponseIDCode > 0) {
                responseMessage = http_id.getString();
                DeserializationError error_id = deserializeJson(doc, responseMessage);
                String task_status = doc["data"]["task_status"];
                if(task_status == "PROCESSING"){
                  Serial.print('.');
                  doc.clear();
                  delay(500);
                  continue;
                }else{
                  Serial.println();
                  DeserializationError error_id = deserializeJson(doc, responseMessage);
                  String AssistantMessage = responseMessage.substring(responseMessage.indexOf('[')+35,responseMessage.lastIndexOf(']')-4);
                  Serial.println("AI:" + AssistantMessage);
                  break;
                }
              } else {
                  responseMessage = "Error: External API request failed!";
              }
            }
            http_id.end();
            task_id.clear();
            responseMessage.clear(); // 清空响应内容的本地字符串
            Process = false;
        } 
    }
}

void WiFiConnection() {
    WiFi.begin(ssid,password);
    Serial.print("Connecting to WiFi");
    while(WiFi.status() != WL_CONNECTED){
        Serial.print('.');
        delay(500);
    }
    Serial.println();
    Serial.println("WiFi successfully connected!");
    Serial.print("IP address:");
    Serial.println(WiFi.localIP());
}

void initTime() { // 时间同步
  Serial.println("Initializing time synchronization...");
  configTime(gmtOffset_sec, daylightOffset_sec, ntpServer);
  for (int i = 0; i < 10; i++) {
    if (time(nullptr)) {
      Serial.println(F("Time synchronized"));
      return;
    }
    delay(1000);
    Serial.println(F("Waiting for time synchronization..."));
  }
  Serial.println(F("Time synchronization failed. Check NTP server and network."));
}

void splitApiKey(const char *apikey) {  //IMPORTANT
  const char *delimiter = strchr(apikey, '.');

  if (delimiter != NULL) {
    size_t idLength = delimiter - apikey;

    if (idLength < sizeof(idCharArray)) {
      strncpy(idCharArray, apikey, idLength);
      idCharArray[idLength] = '\0';
      strcpy(secretCharArray, delimiter + 1);
      snprintf(jsonString, sizeof(jsonString), "{\"api_key\":\"%s\",\"exp\":%lu,\"timestamp\":%lu}", idCharArray, now * 5, now);  //expire time is set 5 * now
      CustomJWT jwt(secretCharArray, header, sizeof(header), payload, sizeof(payload), signature, sizeof(signature), out, sizeof(out));
      jwt.encodeJWT(jsonString);
      getReturnJson = jwt.out;  //return jwt
      jwt.clear();
    } else {
      Serial.println("ID part of API key is too long.");
    }
  } else {
    Serial.println("Invalid API key format.");
  }
}

这段代码能在串口进行AI问答，但是有几个问题想请教一下：

1. 大佬打算写一个SSE版本的吗？我看官方也推荐这个，可以实现流式传输，感觉快很多。我能照猫画虎照着您的代码改出SSE的版本吗？

2. 怎么解析JSON获取content比较好，我用的是处理字符串的方法，感觉比较方便，没用解析JSON的方式

DeserializationError error_id = deserializeJson(doc, responseMessage);
String AssistantMessage = responseMessage.substring(responseMessage.indexOf('[')+35,responseMessage.lastIndexOf(']')-4);
Serial.println("AI:" + AssistantMessage);

3. content比较长时有回车换行符号“\n\n”那些，怎么处理比较好呢？

4. 我用轮询的方式0.5秒HTTP GET读取一次结果请求响应的task_status，当读取到它是SUCCESS时再读取content内容，这样是正确的做法吗？总感觉有点笨比，代码片段如下：

while(true){
  // 循环GET获取服务器处理状态
  int httpResponseIDCode = http_id.GET();
  if (httpResponseIDCode > 0) {
    responseMessage = http_id.getString();
    DeserializationError error_id = deserializeJson(doc, responseMessage);
    String task_status = doc["data"]["task_status"];
    if(task_status == "PROCESSING"){
      // 等待
      delay(500);
      continue;
    }else{
      // 查询到状态是SUCCESS时打印content的内容
      break;
    }
  } else {
      responseMessage = "Error: External API request failed!";
  }
}

5. 今天突然遇到一个情况：响应内容的task_status长时间处于PROCESSING的状态，卡很久都拿不到content，等个几分钟才能得到响应结果，昨天还没这个情况的，可能是被限流还是什么原因呢，但是我用python的API例程去问它又嘎嘎快。

6. 最后，还有一个bug：发送要问的问题后，偶尔会直接显示上一个问题的回复，我记得您的版本和我改出来的版本都出现过这个问题。

问题有点多，大佬您有空的时候再回复我吧，期待您的回复😋。

[blueokanna]

1. 问：我能照猫画虎照着您的代码改出SSE的版本吗？

流式传输我是没有计划写的，我觉得异步算是很快的了，所以没有考虑SSE的版本（主要是好写）

2. 问：怎么解析JSON获取content比较好，我用的是处理字符串的方法，感觉比较方便，没用解析JSON的方式？

对于这个问题的话，我这里将答案先通过单片机接受，再发送到网页上面去，显示出来。官方的显示比较奇怪，我的处理比较基础。我已经简单处理了一下，如果带 \n\n 就是你的文本太长了，一般情况下应该是不会显示出来的才是对的呀。因为我在index.h换掉这个了（官方的返回有的很奇怪，我是使用的正则表达式来处理这个事情的）

3. 问 结果请求响应的task_status，当读取到它是SUCCESS时再读取content内容，这样是正确的做法吗

因为我是采用异步的做法，如果没有使用异步的话，同步的做法我记得有的时候内容太长有时候又不返回啥的，而且为了减少单片机压力，减少请求的次数，你轮询的话我也做过，没啥笨比的。你的代码如果斜杆插入内容没错的话那是正确的。

4. 问：响应内容的task_status长时间处于PROCESSING的状态，卡很久都拿不到content
   以及发送要问的问题后，偶尔会直接显示上一个问题的回复，我记得您的版本和我改出来的版本都出现过这个问题。

这个问题我之前好像也遇到过，我那时候网络不好或者是服务器原因，我自己怀疑过是官方的问题，至于偶尔会显示之前的问题这个问题我也一直都没办法解决，我目前也在寻找对应的方法，我用 Postman 试过但是，一切又都正常，但是我自己不知道为啥，不知道是我写的问题还是？因为我自己也研究了很久，但是还是会有这个问题，难道是代码设计的问题？ 🤔 💡

[sarakii]

老哥抱歉，这么晚才回复，这几天一直在搞东搞西，头都大了。
这几天我根据您的代码改出了SSE的版本，可以直接通过串口进行AI问答了，写这个版本的过程中遇到了一个很棘手的问题，就是：获取到了流式数据，但是却不知道该怎么处理这一段段数据，卡了好几天，人都傻了，可喜可贺的是最后总算解决了目所能及的bug。
其实我发现代码量比异步的少很多，复杂程度比异步也要低很多。
还有SSE版本卡PROCESSING和“\n\n”这两个bug也不翼而飞了，也不用写轮询，对我这种新手比较友好。
非常谢谢您，没有您的代码我不可能改出来，如果老哥需要的话，我发邮件把代码发给您看一下，之后再考虑把代码发到github上。

[blueokanna]

流式传输的话不错的，只是目前我在Java上写了 SSE 的版本。

java 的版本就是有点BUG，对于 ESP32 的话应该是可以正常输出，这个应该是没有问题的，不过解决了是非常棒的事情，你能坚持做开发。

[blueokanna]

至于发给我代码的话可以发到Github上面我可以讨论，或者发给我邮件。

邮箱：blueokanna@gmail.com

[sarakii]

现在在想怎么实现连续对话😂

[blueokanna]

连续对话的话你是做SSE的版本可以推荐直接将非配置代码放到

void loop(){
//需要执行的代码
}

这样就一直保持在线