N58_HPOC/app/tts.c

#include "tts.h"
#include "talk.h"
#include "nwy_osi_api.h"
#include "nwy_audio_api.h"
#define TTS_MAX_LEN (20+4*200)  //max 200 chinese
typedef struct{
	T_UINT8 plyNow:1;
	T_UINT8 ttsType;
	T_UINT16 ttsLen;
	T_UINT8 ttsData[TTS_MAX_LEN+2];//should have 2 '"'
}TTS_DEF;
TTS_DEF tts={
	.plyNow=0,
};

static void prvLsTtsPlayerEvCb(void *cb_para, nwy_neoway_result_t result){
	wlog_info("prvLsTtsPlayerEvCb:%d",result);

    switch(result){
    	case PLAY_END:
        	outterInfo("+LSHTTS: END\r\n",14);
        	wlog_warn("tts end1");
			talking.media=MEDIA_IDLE;
        	break;
    }
}

static int tts_speak(void){
	int result=-1;

	result=nwy_tts_playbuf(tts.ttsData, tts.ttsLen, tts.ttsType, prvLsTtsPlayerEvCb, NULL);
	wlog_info("TTS:%d,%d", tts.ttsType,tts.ttsLen);
	return result;
}

void tts_stop(void){
	nwy_tts_stop_play();
	talking.media=MEDIA_IDLE;
	//if(LSAPI_AUD_GetPlayerState()==LSAPI_PLAYER_PLAYING){//播放完毕
    //	outterInfo("+LSHTTS: END\r\n",14);
    //		wlog_warn("tts end2");
	//	talking.media=MEDIA_IDLE;
    //}
    //LSAPI_TTS_Stop();
}
bool LSAPI_TTS_IsPlaying(void){
	if(MEDIA_TTS==talking.media) return true;
	else return false;
}
PT_THREAD (ptTTSTask(pt_timer_t *ptPool, struct pt *pt)){
	static pt_timer_t ptTimer;
	bool status;
	PT_BEGIN(pt);
	while(1){
		if(tts.plyNow==1){
			if(MEDIA_POC==talking.media){
				//media is taken by poc, need to wait it stop
				talking.media=MEDIA_SHUT_POC;
				PTTimerStart(ptPool, &ptTimer,1000);//wait 200ms to shut poc
				PT_WAIT_UNTIL(pt, PTTimerIsExpired(&ptTimer)||MEDIA_POC_PENDING==talking.media);
				talking.media=MEDIA_POC_PENDING;
			}
			status=LSAPI_TTS_IsPlaying();
			if(MEDIA_TTS==talking.media || true==status){
				//media is taken by tts, need to shut the current pro if it is on
				wlog_info("call tts stop");
				tts_stop();
				PTTimerStart(ptPool, &ptTimer,1000);//wait 1000ms to stop 
				PT_WAIT_UNTIL(pt, PTTimerIsExpired(&ptTimer)|| false==(status=LSAPI_TTS_IsPlaying()));
			}
			if(false==status) wlog_info("tts stop ok");
			else{
				wlog_info("tts stop failed, continue");
				continue;
			}
			//start new tts
			if(0==tts_speak()){
				wlog_info("tts play ok");
				talking.media=MEDIA_TTS;
			}else{
				msgToOutter("+LSHTTS: END\r\n");
				wlog_info("tts play failed");
			}
			tts.plyNow=0;
		}

		PTTimerStart(ptPool, &ptTimer,1);//can be fast
		PT_WAIT_UNTIL(pt, PTTimerIsExpired(&ptTimer));
	}
	PT_END(pt);
}

char checkTtsData(unsigned char *data, int len){
	int i;
	unsigned char ch;
	for(i=0;i<len;i++){
		ch=data[i];
		if((ch>='0' && ch <= '9') ||
		   (ch>='a' && ch <= 'f') ||
		   (ch>='A' && ch <= 'F')) {}else return 1;
	}
	return 0;
}

void cmdTTSHandler(T_UINT8 *data, T_UINT16 len){
	//AT+LSHTTS=x,"vvvvvv"//没有回车换行了
	//x,"vvvvvv"
	T_UINT32 thisTime,i,j,k;
	T_UINT8 *ptr=data+10,type,tmp;
	T_BOOL ttsErr=FALSE;

	//如果是停止指令
	if(len==11 && ptr[0]=='0'){
		tts_stop();
		return;
	}
	//如果是播放指令
	if(len<15 || ptr[1] != ',' || (ptr[0] != '1' && ptr[0] != '2') || ptr[2]!='"' || data[len-1] != '"'){
		wlog_warn("tts invalid1");
		goto TTS_ERROR;
	}
	type=ptr[0]-0x30;
	ptr += 3;//VVVVVVV"
    k=len-10-3-1;
	//检测数据合法性
	if(type==1){
		if(k%2){
			wlog_warn("tts gbk len invalid");
			goto TTS_ERROR;
		}
		type=ENCODE_GBK;
	}else if(type==2){
		if(k%4){
			wlog_warn("tts unicode len invalid");
			goto TTS_ERROR;
		}
		type=ENCODE_UTF16BE;
	}
	
	if(k>TTS_MAX_LEN){
		wlog_warn("tts len over");
		goto TTS_LENOV;
	}

	tts.ttsLen=k;
	tts.ttsType=type;
	memcpy(tts.ttsData,ptr,tts.ttsLen);
	tts.plyNow=1;

	return;
	TTS_ERROR:
	msgToOutter("+LSHTTS: ERROR\r\n");
	return;
	TTS_LENOV:
	msgToOutter("+LSHTTS: LENOV\r\n");
}

void ttsPlayNow(unsigned char encodetype, unsigned char *ttsData, int ttslen){
	if(ttslen%4){
		wlog_warn("sms tts invalid1");
		return;
	}
	//if(0!=restoreDataFormatByHex(ttsData,ttslen)){
	//	wlog_warn("sms tts invalid2");
	//	return;
	//}
	tts.ttsLen=ttslen;///2;
	tts.ttsType=encodetype;
	memcpy(tts.ttsData,ttsData,tts.ttsLen);
	tts.plyNow=1;
}