#include <stdio.h>
#include <pthread.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>


#include "JZsdkLib.h"
#include "Megaphone/Megaphone.h"
#include "AudioDeal/AudioDeal.h"

static int RealTimeMp2_StatusFlag = JZ_FLAGCODE_OFF;

//解码播放部分
static unsigned char RealTimeMP2_PlayData_Loop[ (256 + 1) ][128];//解码缓存池 
static int RealTimeMP2_PlayData_LoopHead	=	0;				//池数头
static int RealTimeMP2_PlayData_LoopEnd	=	0;				//池数尾
static int RealTimeMP2s_PlayData_LoopReadFlag=0;//读取标志位0为停止，1为开始

//写入数据部分
static unsigned char RealTimeMP2_WriteData_Loop[(15 + 1)][128];  //实时mp2缓冲输入池
static int RealTimeMP2_WriteData_LoopHead	=	0;				//池数头
static int RealTimeMP2_WriteData_LoopEnd	=	0;				//池数尾
static int RealTimeMP2_WriteData_ResidueLenth; // 写入缓存池池子残余物长度
static int RealTimeMP2_WriteFlag=0;//读取标志位0为停止，1为开始

pthread_mutex_t RealTimeMP2_WriteDataLock = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t  RealTimeMP2_WriteCond = PTHREAD_COND_INITIALIZER;
int             RealTimeMP2_WriteDataFlag = 0;

static T_JZsdkReturnCode RealTimeMP2_WriteData_init();
static T_JZsdkReturnCode RealTimeMP2_Play_init();
static T_JZsdkReturnCode RealTimeMP2_WriteDataToLoop(unsigned char *buf,int length);
static T_JZsdkReturnCode RealTimeMP2_ClearLoop();
static void *RealTimeMP2_LoopPlay(void *arg);
static void RealTimeMP2_PlayLoop_HeadReset();
static void RealTimeMP2_PlayLoopEndReset();
static int RealTimeMP2_WriteDataClear();
static void *RealTimeMP2_WriteData_Task(void *arg);
static void RealTimeMP2_WriteDataHeadReset();


static T_JZsdkReturnCode RealTimeMp2_Init()
{
	T_JZsdkReturnCode ret;

    //1、开启实时mp2模式
    RealTimeMp2_StatusFlag = JZ_FLAGCODE_ON;

  	//2、创建输入缓冲线程
    ret = RealTimeMP2_WriteData_init();
	if (ret != JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS)
	{
		return ret;
	}
	
    //3、创建播放线程
    ret = RealTimeMP2_Play_init();
	if (ret != JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS)
	{
		return ret;
	}

	return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}

T_JZsdkReturnCode RealTimeMP2_start()
{
	//如果实时mp2开启
	if (RealTimeMp2_StatusFlag == JZ_FLAGCODE_ON)
	{
		JZSDK_LOG_ERROR("实时mp2已开启,禁止反复开启");
		return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE;
	}

	//打开标志位
	Megaphone_MegDataGenFlag(JZ_FLAGCODE_SET, JZ_FLAGCODE_ON);
    Megaphone_MegDataGenFinshFlag(JZ_FLAGCODE_SET, JZ_FLAGCODE_ON);

	//3、开启功放
    int amplifier = JZ_FLAGCODE_ON;
    Megaphone_Amplifier_param(JZ_FLAGCODE_SET, &amplifier);

	T_JZsdkReturnCode ret = RealTimeMp2_Init();
	if (ret != JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS)
	{
		JZSDK_LOG_ERROR("mp2实时语音初始化失败");

		RealTimeMp2_StatusFlag = JZ_FLAGCODE_OFF;
		Megaphone_MegDataGenFlag(JZ_FLAGCODE_SET, JZ_FLAGCODE_OFF);
		Megaphone_MegDataGenFinshFlag(JZ_FLAGCODE_SET, JZ_FLAGCODE_OFF);

		amplifier = JZ_FLAGCODE_OFF;
		Megaphone_Amplifier_param(JZ_FLAGCODE_SET, &amplifier);

		return ret;
	}

	JZSDK_LOG_INFO("MP2实时喊话初始化成功");

	return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}

T_JZsdkReturnCode RealTimeMP2_trans(unsigned char *getdata, int len)
{
	//如果实时mp2未开启	
	if (RealTimeMp2_StatusFlag != JZ_FLAGCODE_ON)
	{
		return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE ;
	}

    RealTimeMP2_WriteDataToLoop(getdata, len);

    return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}

T_JZsdkReturnCode RealTimeMP2_Close()
{
	//如果实时mp2未开启	
	if (RealTimeMp2_StatusFlag != JZ_FLAGCODE_ON)
	{
		return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE ;
	}

    RealTimeMp2_StatusFlag = JZ_FLAGCODE_OFF;
    RealTimeMP2s_PlayData_LoopReadFlag = JZ_FLAGCODE_OFF;
    RealTimeMP2_WriteFlag = JZ_FLAGCODE_OFF;

	Megaphone_MegDataGenFlag(JZ_FLAGCODE_SET, JZ_FLAGCODE_OFF);
    Megaphone_MegDataGenFinshFlag(JZ_FLAGCODE_SET, JZ_FLAGCODE_OFF);

    int amplifier = JZ_FLAGCODE_OFF;
    Megaphone_Amplifier_param(JZ_FLAGCODE_SET, &amplifier);

	//关闭音频库
	AudioDeal_StopDeal();

    return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS; 
}


/************************************************************************************************************************************************
 * 
 *      解码播放部分
 * 
 * 
*************************************************************************************************************************************************/
static T_JZsdkReturnCode RealTimeMP2_Play_init()
{
	//清空播放数据缓冲区
	RealTimeMP2_ClearLoop();

	//创建循环播放线程
	pthread_t loop_play_task;
	pthread_attr_t task_attribute; //线程属性
	pthread_attr_init(&task_attribute);  //初始化线程属性
	pthread_attr_setdetachstate(&task_attribute, PTHREAD_CREATE_DETACHED);      //设置线程分离属性
	int opus_Protection = pthread_create(&loop_play_task,&task_attribute,RealTimeMP2_LoopPlay,NULL);		//线程
	if(opus_Protection != 0)
	{
		JZSDK_LOG_ERROR("创建自动mp2播放线程失败!\n");
		RealTimeMp2_StatusFlag = JZ_FLAGCODE_OFF;
		return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE;
	}

	return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}

//解码并播放
static T_JZsdkReturnCode RealTimeMP2_PlayData(unsigned char *data,int len)
{
	unsigned char playFile[len];

    //清空
    memset(playFile, 0, len);
	
	memcpy(playFile, data, len);

	AudioDeal_Mp3DataInput(8000, playFile, len);

    return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}



static void *RealTimeMP2_LoopPlay(void *arg)
{
	RealTimeMP2s_PlayData_LoopReadFlag = JZ_FLAGCODE_ON;
	int ret;
	printf("实施喊话，数据播放线程建立\n");

	//设立缓冲区域
	int range = 0;
	while (range < 15)  //  1.5s
	{
		range = (RealTimeMP2_PlayData_LoopEnd-RealTimeMP2_PlayData_LoopHead);
		if (range < 0)
		{
			range = range;
		}
	}
	
    printf("开始播放函数\n");
	
	while(RealTimeMP2s_PlayData_LoopReadFlag != JZ_FLAGCODE_OFF)
	{
		if(RealTimeMP2_PlayData_LoopHead!=RealTimeMP2_PlayData_LoopEnd)
		{
			//printf("播放线程执行中\n");

			ret = RealTimeMP2_PlayData(RealTimeMP2_PlayData_Loop[RealTimeMP2_PlayData_LoopHead],128);
			RealTimeMP2_PlayData_LoopHead++;
			RealTimeMP2_PlayLoop_HeadReset(); //池满判断
		}
	}

}

// 池子头部到底了，重置池头
static void RealTimeMP2_PlayLoop_HeadReset()
{
	if (RealTimeMP2_PlayData_LoopHead >= 256)
	{
		RealTimeMP2_PlayData_LoopHead = 0;
	}
}

/// 池子尾部到底了，重置池尾
static void RealTimeMP2_PlayLoopEndReset()
{
	if (RealTimeMP2_PlayData_LoopEnd >= 256)
	{
		RealTimeMP2_PlayData_LoopEnd = 0;
	}
}

//清空缓存池
static T_JZsdkReturnCode RealTimeMP2_ClearLoop()
{
	RealTimeMP2_PlayData_LoopHead=0;
	RealTimeMP2_PlayData_LoopEnd=0;
}

/************************************************************************************************************************************************
 * 
 *      写入缓冲池部分
 * 
 * 
*************************************************************************************************************************************************/
//写入数据部分初始化
static T_JZsdkReturnCode RealTimeMP2_WriteData_init()
{
	//清空写入数据池
	RealTimeMP2_WriteDataClear();

	pthread_t WriteDataTask;
	pthread_attr_t task_attribute; //线程属性
	pthread_attr_init(&task_attribute);  //初始化线程属性
	pthread_attr_setdetachstate(&task_attribute, PTHREAD_CREATE_DETACHED);      //设置线程分离属性
	int opus_Protection = pthread_create(&WriteDataTask,&task_attribute,RealTimeMP2_WriteData_Task,NULL);		//线程
	if(opus_Protection != 0)
	{
		printf("创建输入缓冲池线程线程失败！\n");
		RealTimeMp2_StatusFlag = JZ_FLAGCODE_OFF;
		return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE;
	}

	return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}

//将输入缓冲池的数据放入播放缓冲池
static int RealTimeMP2_Put_WriteData_In_PlayLoop()
{
	memcpy(RealTimeMP2_PlayData_Loop[RealTimeMP2_PlayData_LoopEnd], RealTimeMP2_WriteData_Loop[RealTimeMP2_WriteData_LoopHead],128);
	RealTimeMP2_PlayData_LoopEnd ++;
	RealTimeMP2_WriteData_LoopHead ++;

	RealTimeMP2_PlayLoopEndReset();
	RealTimeMP2_WriteDataHeadReset();
}

//输入缓冲池任务
static void *RealTimeMP2_WriteData_Task(void *arg)
{

	int ret;
	JZSDK_LOG_DEBUG("MP2实施喊话,输入数据缓冲线程建立");
	RealTimeMP2_WriteFlag = JZ_FLAGCODE_ON;
	
	while(RealTimeMP2_WriteFlag == JZ_FLAGCODE_ON)
	{
		pthread_mutex_lock(&RealTimeMP2_WriteDataLock);


		if(RealTimeMP2_WriteData_LoopHead!=RealTimeMP2_WriteData_LoopEnd)
		{
			//printf("缓冲线程写入中\n");
	
			//将输入缓冲池的数据放入播放缓冲池
			RealTimeMP2_Put_WriteData_In_PlayLoop();
		}

		// 在写入数据后解锁
		RealTimeMP2_WriteDataFlag = 1;
        pthread_cond_signal(&RealTimeMP2_WriteCond);
        pthread_mutex_unlock(&RealTimeMP2_WriteDataLock);
	}
}

//写入数据缓存池重置
static int RealTimeMP2_WriteDataClear()
{
	RealTimeMP2_WriteData_LoopHead=0;
	RealTimeMP2_WriteData_LoopEnd=0;
	RealTimeMP2_WriteData_ResidueLenth = 0;
}


// 写入池子头部到底了，重置池头
static void RealTimeMP2_WriteDataHeadReset()
{
	if (RealTimeMP2_WriteData_LoopHead >= 15)
	{
		RealTimeMP2_WriteData_LoopHead = 0;
	}
}

//	写入池子尾部到底了，重置池尾
static void RealTimeMP2_WriteDataEndReset()
{
	if (RealTimeMP2_WriteData_LoopEnd >= 15)
	{
		RealTimeMP2_WriteData_LoopEnd = 0;
	}
}



//写入数据进缓存池,以用于后续播放
static T_JZsdkReturnCode RealTimeMP2_WriteDataToLoop(unsigned char *buf,int length)
{
	int temp_lenth = 0;  //临时长度

	//判断输入的数据长度是否正常
	if (length <= 0)
	{
		printf("输入进缓冲池的数据长度有误:%d\n",length);
		return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE;
	}

	//写入处理
	//① 、检查池子当前组内有无剩余数据，如果池子当前组有剩  上次写入的语音数据， 接着往里面写入
	if (RealTimeMP2_WriteData_ResidueLenth > 0) //如果残留物有长度
	{

		if (RealTimeMP2_WriteData_ResidueLenth + length < 128)
		{
			for (   ; temp_lenth < length ; RealTimeMP2_WriteData_ResidueLenth++)
			{
				RealTimeMP2_WriteData_Loop[RealTimeMP2_WriteData_LoopEnd] [RealTimeMP2_WriteData_ResidueLenth] = buf [temp_lenth];
				temp_lenth ++;
			}	

			return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
		}
		else
		{
			// 在写入解码前加锁
			pthread_mutex_lock(&RealTimeMP2_WriteDataLock);

			while (RealTimeMP2_WriteDataFlag != 1)
			{
				pthread_cond_wait(&RealTimeMP2_WriteCond, &RealTimeMP2_WriteDataLock);
			}

			//数据进池，每组128数据
			for(  ; RealTimeMP2_WriteData_ResidueLenth < 128 ; RealTimeMP2_WriteData_ResidueLenth ++)
			{
				RealTimeMP2_WriteData_Loop[RealTimeMP2_WriteData_LoopEnd] [RealTimeMP2_WriteData_ResidueLenth] = buf [temp_lenth];
				temp_lenth ++;
			}
			RealTimeMP2_WriteData_LoopEnd+=1;    //池尾后移一组
			RealTimeMP2_WriteData_ResidueLenth = 0;       //残留物长度归0

			RealTimeMP2_WriteDataEndReset(); //池满判断

			// 在解码数据后解锁
			RealTimeMP2_WriteDataFlag = 0;
			pthread_cond_signal(&RealTimeMP2_WriteCond);
			pthread_mutex_unlock(&RealTimeMP2_WriteDataLock);
		}
	}

	//②、从新的组处理数据
	//待处理数据超过128长度时
	while( (length - temp_lenth) >= 128)
	{	
		// 在写入解码前加锁
        pthread_mutex_lock(&RealTimeMP2_WriteDataLock);

		while (RealTimeMP2_WriteDataFlag != 1)
        {
            pthread_cond_wait(&RealTimeMP2_WriteCond, &RealTimeMP2_WriteDataLock);
        }
		
		//数据进池，每组128数据
		//printf("往池子里的第%d号里写入数据\n",RealTimeMP2_WriteData_LoopEnd);
		
		for(int ucLen = 0 ; ucLen < 128 ; ucLen ++)
		{
			RealTimeMP2_WriteData_Loop[RealTimeMP2_WriteData_LoopEnd] [ucLen] = buf [temp_lenth];
			temp_lenth ++;
		}
		
		RealTimeMP2_WriteData_LoopEnd+=1;  //池尾后移一组
		RealTimeMP2_WriteDataEndReset(); //池满判断

		// 在解码数据后解锁
        RealTimeMP2_WriteDataFlag = 0;
        pthread_cond_signal(&RealTimeMP2_WriteCond);
        pthread_mutex_unlock(&RealTimeMP2_WriteDataLock);
	}

	//③、如果长度还有剩，把数据存到池子内的新组，并记录残留物长度
	if( (length - temp_lenth) > 0)
	{
		for (   ; temp_lenth < length ; RealTimeMP2_WriteData_ResidueLenth++)
		{
			RealTimeMP2_WriteData_Loop[RealTimeMP2_WriteData_LoopEnd] [RealTimeMP2_WriteData_ResidueLenth] = buf [temp_lenth];
			temp_lenth ++;
		}	
	
	}

	return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}


/************************************************************************************************************************************************
 * 
 *      状态相关
 * 
 * 
*************************************************************************************************************************************************/
/********************
 * 
 *  获取实时MP2模式
 * 
 * **************/
T_JZsdkReturnCode RealTimeMP2_GetStatusFlag()
{
	return RealTimeMp2_StatusFlag;
}