void start_ai4g_connect_timer(uint32_t interval = 1000);
void stop_ai4g_connect_timer(void);
- void start_ai4g_tts_play_timer(uint32_t interval = 700);
+ void start_ai4g_tts_play_timer(uint32_t interval = 600);
void stop_ai4g_tts_play_timer(void);
- void start_update_ai_answer_timer(uint32_t interval = 200);
+ void start_update_ai_answer_timer(uint32_t interval = 300);
void stop_update_ai_answer_timer(void);
void SetSelectAiModel(int index);
WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "强制发送文本: %s (长度: %zu)",
segment.c_str(), segment.length());
uapi_start_tts_single_txt((char *)segment.c_str());
- LOS_Msleep(100);
+ // LOS_Msleep(100);
// 发送后清空累积文本
accumulatedText.clear();
WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "按标点发送分段: %s (长度: %zu)",
segment.c_str(), segment.length());
uapi_start_tts_single_txt((char *)segment.c_str());
- LOS_Msleep(100);
+ // LOS_Msleep(100);
}
// 更新累积文本
}
else
{
- if(!AiVoiceModel::cur_ai_4g_answer_update)
- {
- AiVoiceModel::cur_ai_4g_answer_update = true;
- if(AiVoiceModel::GetInstance().UpdateAiAnswerStr())
- {
- AiVoiceModel::cur_ai_4g_answer_update = false;
- LOS_Msleep(10);
- }
- }
+ SendMsgToUIService(UI_UPDATE_AI_ANSWER_STR, 0, nullptr, 0);
+ // if(!AiVoiceModel::cur_ai_4g_answer_update)
+ // {
+ // AiVoiceModel::cur_ai_4g_answer_update = true;
+ // if(AiVoiceModel::GetInstance().UpdateAiAnswerStr())
+ // {
+ // AiVoiceModel::cur_ai_4g_answer_update = false;
+ // LOS_Msleep(10);
+ // }
+ // }
}
}
TaskConfig GetServiceTaskConfig(Service *service)
{
(void)service;
- TaskConfig config = {LEVEL_HIGH, PRI_NORMAL, DATA_DIST_STACK_SIZE, DATA_DIST_MAIL_LENGTH, SINGLE_TASK};
+ TaskConfig config = {LEVEL_HIGH, PRI_BELOW_NORMAL, DATA_DIST_STACK_SIZE, DATA_DIST_MAIL_LENGTH, SINGLE_TASK};
return config;
}
{\r
// osal_msg_queue_write_head_copy(g_ble_Ai_record_queue, (void *)&mail,sizeof(blesrv_custom_cmd_t), 0);\r
int quesize = osal_msg_queue_get_msg_num(g_ble_Ai_record_queue);\r
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_MAIN_SERVICE,"do_uart_slip_cmd quesize %d\n",quesize);\r
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_MAIN_SERVICE,"osal_msg_queue_get_msg_num %d\n",quesize);\r
while(quesize)\r
{\r
- osal_msg_queue_read_copy(g_ble_Ai_record_queue, (void *)&mail, &msgsize,\r
+ ret = osal_msg_queue_read_copy(g_ble_Ai_record_queue, (void *)&mail, &msgsize,\r
OSAL_MSGQ_WAIT_FOREVER);\r
+ if (ret != OSAL_SUCCESS)\r
+ {\r
+ continue;\r
+ }\r
if(mail.msg_data)\r
{\r
free(mail.msg_data);\r