324 lines
8.0 KiB
C
324 lines
8.0 KiB
C
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <stdlib.h>
|
|
|
|
#include "ql_rtos.h"
|
|
#include "ql_application.h"
|
|
#include "ql_audio.h"
|
|
#include "ql_iic.h"
|
|
#include "ql_gpio.h"
|
|
#include "ql_fs.h"
|
|
|
|
#include "webclient.h"
|
|
#include <netdb.h>
|
|
#include "sockets.h"
|
|
#include "layer3.h"
|
|
#include "ql_uart.h"
|
|
const char *mp3_file[] ={
|
|
"test.mp3",// 0
|
|
"network_connect_zh.mp3",//1 系统启动中，正在等待网络连接
|
|
"network_check.mp3",//2 网络不好 请检查网络
|
|
"upgrading.mp3",//3
|
|
"volume20.mp3",//4
|
|
"volume40.mp3",//5
|
|
"volume60.mp3",//6
|
|
"volume80.mp3",//7
|
|
"volume100.mp3",//8
|
|
"tts_error.mp3",//9
|
|
"have_rest_zh.mp3",//10 小憩一下，待会儿见
|
|
"network_ok_zh.mp3",//11 已连上网络可以按键或刷卡跟我对话喔
|
|
"device_sleep_mode_zh.mp3",//12 进入休眠模式
|
|
"device_wake_up_zh.mp3",//13 设备已唤醒
|
|
"low_power_zh.mp3",//14 电量低
|
|
"low_power_off_zh.mp3",//15 电量严重不足，马上关机
|
|
"volume_up_zh.mp3",//16
|
|
"volume_down_zh.mp3",//17
|
|
"ai_active_zh.mp3",//18
|
|
"barge_in_cute.mp3",//19 对话打断提示音
|
|
};
|
|
|
|
//http://banban.api.talkingq.com:8080/assets/roles/banban/tts_error.mp3
|
|
|
|
//#define PCM_FILE "http://47.113.99.138:7050/output_16k.pcm"
|
|
|
|
int http_file_download(const char *uri)
|
|
{
|
|
int res=0, length,total_length = 0;
|
|
int resp_status = (-1);
|
|
QFILE * fp = NULL;
|
|
char fd_buff[128]={0x00};
|
|
|
|
u8 *buffer_read = NULL;
|
|
|
|
//从url中分离文件名字
|
|
char *filename = strrchr(uri, '/');
|
|
if (filename==NULL) return -1;
|
|
|
|
filename++;//remove '/'
|
|
|
|
sprintf(fd_buff, "U:/%s", filename);
|
|
|
|
printf("http_file_download:%s\n", fd_buff);
|
|
|
|
ql_remove(fd_buff);
|
|
|
|
fp = ql_fopen(fd_buff, "wb+");
|
|
if(fp==NULL) {
|
|
printf("open file error\n");
|
|
res = -1;
|
|
goto __exit;
|
|
}
|
|
|
|
|
|
struct webclient_session *session = NULL;
|
|
|
|
session = webclient_session_create(1024);
|
|
if (!session)
|
|
{
|
|
printf("open uri failed.");
|
|
res = -1;
|
|
goto __exit;
|
|
}
|
|
|
|
resp_status = webclient_get(session, uri);
|
|
if (resp_status == 304)
|
|
{
|
|
printf("file download failed! Server http response : 304 not modified!");
|
|
res = -1;
|
|
goto __exit;
|
|
}
|
|
|
|
if (resp_status != 200)
|
|
{
|
|
printf("file download failed! Server http response : %d !", resp_status);
|
|
res = -1;
|
|
goto __exit;
|
|
}
|
|
|
|
if (session->content_length == 0)
|
|
{
|
|
printf("Request file size is 0!");
|
|
res = -1;
|
|
goto __exit;
|
|
}
|
|
|
|
// LOG_I("file size is (%d)", session->content_length);
|
|
|
|
buffer_read = web_malloc(4096);
|
|
|
|
if ((buffer_read == NULL))
|
|
{
|
|
printf("No memory for http ota!");
|
|
res = -1;
|
|
goto __exit;
|
|
}
|
|
|
|
printf("download start:%d\n", session->content_length);
|
|
|
|
do
|
|
{
|
|
u32 nw;
|
|
u32 page_pos;
|
|
|
|
nw = 4096;
|
|
if ((nw + total_length) > session->content_length)
|
|
{
|
|
nw = session->content_length - total_length;
|
|
//log_i("last page, content_length:%d, total_length:%d, nw:%d\n", session->content_length, total_length, nw);
|
|
}
|
|
|
|
/* read */
|
|
page_pos = 0;
|
|
do
|
|
{
|
|
length = webclient_read(session, buffer_read + page_pos, nw - page_pos);
|
|
if (length <= 0)
|
|
{
|
|
printf("read error: %d, content_pos:%d, page_pos:%d\n", length, total_length, page_pos);
|
|
break;
|
|
}
|
|
//LOG_I("webclient_read %d\n", length);
|
|
page_pos += length;
|
|
}
|
|
while (page_pos < nw); /* read */
|
|
|
|
if (page_pos != nw)
|
|
{
|
|
res = -1;
|
|
printf("page_pos error, %d:%d\n", page_pos, nw);
|
|
goto __exit;
|
|
}
|
|
|
|
ql_fwrite(buffer_read, nw, 1, fp);
|
|
|
|
total_length += nw;
|
|
//print_progress(total_length, session->content_length);
|
|
}
|
|
while (total_length != session->content_length);
|
|
|
|
printf("download end:%d\n", total_length);
|
|
|
|
__exit:
|
|
|
|
if(res==-1){
|
|
ql_remove(fd_buff);
|
|
}
|
|
|
|
if (session != NULL)
|
|
webclient_close(session);
|
|
if (buffer_read != NULL)
|
|
web_free(buffer_read);
|
|
|
|
if(fp!=NULL){
|
|
ql_fclose(fp);
|
|
fp = NULL;
|
|
}
|
|
|
|
return res;
|
|
}
|
|
|
|
void app_file_check_download(void)
|
|
{
|
|
int index = 1;
|
|
char url_buff[128]={0x00};
|
|
char filename_buff[64]={0x00};
|
|
int ret = 0, cnt = 0;
|
|
|
|
for(index=1;index<20;index++){
|
|
|
|
/* barge_in_cute.mp3 is shipped in customer_fs and is not hosted by the
|
|
* legacy prompt download service. */
|
|
if(index==4||index==5||index==6||index==7||index==8||index==19){
|
|
continue;
|
|
}
|
|
|
|
if(strlen(mp3_file[index])>0){
|
|
sprintf(filename_buff, "U:/%s", mp3_file[index]);
|
|
if(ql_access(filename_buff, 0)!=0){
|
|
printf("downing mp3 file %d,%s\r\n", index,filename_buff);
|
|
down_loop:
|
|
sprintf(url_buff, "http://banban.api.talkingq.com:8080/assets/roles/banban/%s", mp3_file[index]);
|
|
|
|
ret = http_file_download(url_buff);
|
|
if(ret!=0&&cnt++<3) goto down_loop;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
void app_file_check_del(void)
|
|
{
|
|
int index = 1;
|
|
char filename_buff[64]={0x00};
|
|
|
|
for(index=1;index<20;index++){
|
|
|
|
/* Keep the bundled barge-in prompt across app-only FOTA. Unlike the
|
|
* server-managed prompts, it cannot be restored by the downloader. */
|
|
if(index==4||index==5||index==6||index==7||index==8||index==19){
|
|
continue;
|
|
}
|
|
|
|
if(strlen(mp3_file[index])>0){
|
|
sprintf(filename_buff, "U:/%s", mp3_file[index]);
|
|
if(ql_access(filename_buff, 0)==0){
|
|
ql_remove(filename_buff);
|
|
ql_rtos_task_sleep_ms(5);
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
#if 0
|
|
//注意目前文件系统大小默认为256k
|
|
uint8_t g_mp3_test1_buff[1024*60];
|
|
int32 g_mp3_test1_buff_len = 0;
|
|
|
|
u16 pcm_buff[2*SHINE_MAX_SAMPLES];
|
|
u16 *pbuff=pcm_buff;
|
|
void app_file_download(void)
|
|
{
|
|
|
|
QFILE *pcm_file_point=NULL;
|
|
uint8_t* data_out=NULL;
|
|
int count = 0;
|
|
int nread = 0;
|
|
struct lfs_info pcm_file;
|
|
|
|
ql_rtos_task_sleep_ms(10000);
|
|
|
|
pcm_file_point = ql_fopen("U:/output_16k.pcm","rb");
|
|
if(pcm_file_point==NULL) {
|
|
printf("ql_fopen output_16k.pcm error\n");
|
|
http_file_download(PCM_FILE);
|
|
pcm_file_point = ql_fopen("U:/output_16k.pcm","rb");
|
|
if(pcm_file_point==NULL) return;
|
|
}
|
|
|
|
ql_stat("U:/output_16k.pcm", &pcm_file);
|
|
|
|
printf("pcm_file.size:%d\n", pcm_file.size);
|
|
printf("pcm_file.name:%s\n", pcm_file.name);
|
|
|
|
shine_t sh_shine;
|
|
shine_config_t sh_config;
|
|
|
|
//--------初始化config.mpeg结构 ------
|
|
shine_set_config_mpeg_defaults(&(sh_config.mpeg)); //--init sh_config struct
|
|
|
|
//-------- 配置 config 结构 -------------
|
|
sh_config.wave.channels=PCM_MONO; //PCM_STEREO;//PCM_MONO;
|
|
sh_config.wave.samplerate=16000;//valid samplerates: 44100,48000,32000,22050,24000,16000,11025,12000,8000
|
|
sh_config.mpeg.copyright=1;
|
|
sh_config.mpeg.original=1;
|
|
sh_config.mpeg.mode=MONO;//STEREO;//MONO;
|
|
sh_config.mpeg.bitr=16; //64kbps for 16k //32kbps for 8k samplerate
|
|
sh_shine=shine_initialise(&sh_config);
|
|
|
|
do
|
|
{
|
|
nread=ql_fread(pcm_buff,sizeof(u16),576,pcm_file_point);
|
|
printf("nread:%d\n", nread);
|
|
if(nread<=0){
|
|
break;
|
|
}
|
|
else if(nread < 576){ //---小于喂给采样数时，剩余用0填充
|
|
printf("nread < samples_per_pass! nread = %d\n",nread);
|
|
memset(pcm_buff+nread,0,(576-nread)*sizeof(u16));
|
|
}else{
|
|
data_out = shine_encode_buffer(sh_shine,&pbuff,&count);
|
|
memcpy(g_mp3_test1_buff+g_mp3_test1_buff_len, data_out, count);
|
|
g_mp3_test1_buff_len+=count;
|
|
}
|
|
}while(1);
|
|
|
|
data_out=shine_flush(sh_shine,&count);
|
|
memcpy(g_mp3_test1_buff+g_mp3_test1_buff_len, data_out, count);
|
|
g_mp3_test1_buff_len+=count;
|
|
printf("app_file_download:%d\n", g_mp3_test1_buff_len);
|
|
|
|
|
|
if(pcm_file_point!=NULL){
|
|
ql_fclose(pcm_file_point);
|
|
pcm_file_point = NULL;
|
|
}
|
|
|
|
|
|
if(sh_shine!=NULL){
|
|
shine_close(sh_shine);
|
|
sh_shine = NULL;
|
|
}
|
|
|
|
unsigned char value = 0;
|
|
for(count=0;count<g_mp3_test1_buff_len;count++){
|
|
value = g_mp3_test1_buff[count];
|
|
ql_uart_write(QL_USB_CDC_PORT, &value, 1);
|
|
}
|
|
|
|
g_mp3_test1_buff_len = 0;
|
|
|
|
}
|
|
#endif
|
|
|