void ble_set_ai_Answer_str_(char *buf, uint8_t type)
{
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "ble_set_ai_Answer_str_:%s,type:%d",buf,type);
+ WEARABLE_LOGD(WEARABLE_LOG_MODULE_APP, "ble_set_ai_Answer_str_:%s,type:%d",buf,type);
// chat_filter_result_chars(buf);
OHOS::AiVoiceModel::GetInstance().SetAiAnswerStrStr(std::string(buf), type);
}
}
fclose(file);
- MEDIA_INFO_LOG("Successfully wrote %u bytes to file cache", msg.size);
+ // MEDIA_INFO_LOG("Successfully wrote %u bytes to file cache", msg.size);
MediaMutexUnLock(g_fileCacheMutex);
return 0;
} else {
// 写入文件缓存
int32_t result = AI_WriteToFileCache(msg);
if (result == 0) {
- MEDIA_DEBUG_LOG("Successfully wrote %u bytes to file cache", size);
+ // MEDIA_DEBUG_LOG("Successfully wrote %u bytes to file cache", size);
free(dataCopy);
return 0;
} else {
// 写入文件缓存以保持顺序
int32_t result = AI_WriteToFileCache(msg);
if (result == 0) {
- MEDIA_INFO_LOG("Successfully wrote %u bytes to file cache to maintain order", size);
+ // MEDIA_INFO_LOG("Successfully wrote %u bytes to file cache to maintain order", size);
free(dataCopy);
return 0;
} else {
// 发送本次携带的内容
if (buf && strlen(buf) > 0) {
- printf("TTS ready, sending current text: %s\n", buf);
+ // printf("TTS ready, sending current text: %s\n", buf);
bool result = uapi_send_single_tts_text(tts_client, buf);
if (!result) {
printf("Failed to send current text: %s\n", buf);
bool result = false;
if (send_websocket_message(tts_client, (uint8_t *)jsonString, strlen(jsonString), WS_TEXT) == 0) {
result = true;
- printf("TTS text %s\n", jsonString);
+ // printf("TTS text %s\n", jsonString);
} else {
printf("TTS text message send failed\n");
}
break;
case WS_EVENT_DATA_RECEIVED:
- printf("WebSocket data received: type=%d, len=%d\n",
- event_data->server_type, event_data->data_len);
+ // printf("WebSocket data received: type=%d, len=%d\n",
+ // event_data->server_type, event_data->data_len);
// 根据服务器类型处理数据
switch (event_data->server_type) {
void handle_tts_data(const ws_event_data_t *event_data)
{
if (event_data->msg_type == WS_BINARY) {
- printf("TTS binary data: %d bytes\n", event_data->data_len);
+ // printf("TTS binary data: %d bytes\n", event_data->data_len);
AI_SendAudioDataToQueue(event_data->data,event_data->data_len);
} else if (event_data->msg_type == WS_TEXT) {
- printf("TTS text data: %s\n", (char *)event_data->data);
+ // printf("TTS text data: %s\n", (char *)event_data->data);
tts_event_type_t event = tts_analysis((char *)event_data->data);
switch (event) {
void handle_chat_data(const ws_event_data_t *event_data)
{
if ((event_data->msg_type == WS_TEXT || event_data->msg_type == WS_BINARY) && event_data->data) {
- printf("Chat text data: %s\n", (char *)event_data->data);
+ // printf("Chat text data: %s\n", (char *)event_data->data);
// 解析Chat结果
char buf[512]={0};
break;
case CHAT_EVENT_MIDDLE:
- printf("Chat event: MIDDLE - Content: %s\n", buf);
+ // printf("Chat event: MIDDLE - Content: %s\n", buf);
if (g_ai_answer_cb) g_ai_answer_cb(buf, 2); else printf("[WS][CHAT] ai_answer 回调未注册,丢弃内容: %s\n", buf);
uapi_tts_process_text(g_tts_server->client,buf,(tts_is_ready == TTS_READY_SUCCESS_READY));
break;
offset += message_len;
// 发送帧
- WS_LOG_INFO("offset %d", offset);
+ // WS_LOG_INFO("offset %d", offset);
// 再次检查socket有效性
if (client->sockfd < 0) {