/**
 ******************************************************************************
 * @文件    cias_network_msg_protocol.c
 * @版本    V1.0.0
 * @日期    2019-5-9
 * @概要    接收网络端的数据，并处理
 ******************************************************************************
 * @注意
 *
 * 版权归chipintelli公司所有，未经允许不得使用或修改
 *
 ******************************************************************************
 */
#include "sdk_default_config.h"

#include <string.h>
#include "ci_log.h"

#include "cias_network_msg_protocol.h"
#include "cias_network_msg_send_task.h"

#include "prompt_player.h"

#include "cias_os_freertos.h"
#include "cias_uart_protocol.h"
#include "cias_voice_plyer_handle.h"
#include "ir_remote_driver.h"
#include "machine_status.h"

#include "audio_play_api.h"
#include "sdk_default_config.h"
#include "cias_demo_config.h"


#include "light_tencent_iot_callback.h"
#if CIAS_DOUBLE_MIC_DEMO_ENABLE | CIAS_SIGNAL_MIC_DEMO_ENABLE
#include "aux_aiot_aircondition_callback.h"
#endif
#if TUYA_IR_CTRL_DEMO_ENABLE | CI_IR_CTRL_DEMO_ENABLE
#include "cias_tuya_ir_callback.h"
#endif
#define MAX_SEND_NUM 5
#define MAX_ACK_TIME 500 // MS
#define REQ_PLAY_DATA_SIZE (10 * 1024)



pro_wait_acktypedef wait_ackstruct;
audio_play_os_stream_t cur_play_stream = PLAY_NULL;


bool recv_music_end_sem = false;
bool no_audio_data_flag = false;

int8_t package_data[1050] = {0};

uint8_t gwork_mode = WORKING_APPLICATION_MODE;
int16_t ligth_test_interval_time = 3000; // 3S默认3S



static uint32_t response_timer_cnt = 0;
static uint8_t *login_info = NULL;



int32_t wifi_msg_deal(uint8_t *msg_buf, int32_t msg_len);



uint32_t get_response_timer_cnt(void)
{
    response_timer_cnt = xTaskGetTickCount() - response_timer_cnt;
    ci_loginfo(LOG_MEDIA, "response_timer %d ms\n", response_timer_cnt);
    return response_timer_cnt;
}

uint32_t set_response_timer_cnt_start(void)
{
    return response_timer_cnt = xTaskGetTickCount();
}


void resp_file_config(void)
{
#if 0
    uint16_t login_info_len = 500;
    if(login_info == NULL)
    {
        login_info = pvPortMalloc(login_info_len);
        if(login_info == NULL)
        {
            ci_loginfo(LOG_MEDIA,"login info malloc error\n");
            return;
        }
    }
    requset_flash_ctl();
    flash_read(FLASH_SPI_PORT,(uint32_t)login_info,PRODUCT_INFO_SPIFLASH_START_ADDR,login_info_len);
    release_flash_ctl();
    cias_send_cmd_and_data(CI_PROFILE_MSG, login_info, login_info_len, DEF_FILL);
    ci_loginfo(LOG_MEDIA,"send login info\n");
#endif
}

static int32_t current_network_state_t = WIFI_DISCONNECT_STATE;
int32_t wifi_current_state_set(int32_t arg)
{
    if(arg > NETWORK_DISCONNECT_STATE||arg < WIFI_CONNECTED_STATE)
        return -1;

    current_network_state_t = arg;
    return 0;
}
int32_t wifi_current_state_get(void)
{
    return current_network_state_t;
}

/**
 * @brief 发送退出唤醒消息
 *
 */
void send_exit_wakeup_msg(char debug)
{
    ci_logdebug(LOG_USER, "send_exit_wakeup_msg = %d\n", debug);
    sys_msg_t send_msg;
    send_msg.msg_type = SYS_MSG_TYPE_CMD_INFO;
    send_msg.msg_data.cmd_info_data.cmd_info_status = MSG_CMD_INFO_STATUS_EXIT_WAKEUP;
    if (pdPASS != send_msg_to_sys_task(&send_msg, NULL))
    {
        ci_logdebug(LOG_USER, "send_exit_wakeup_msg err\n");
    }
}


typedef enum{

    NET_MSG_HEAD = 1, //
    NET_MSG_DATE = 2,
    NET_MSG_ERR  = 0,
    NET_MSG_IDE  = 3,
}wifi_communicate_state_t;



volatile bool start_recv_flag = false;//向wifi请求数据

// #pragma location = ".text_sram"
void network_recv_data_task(void *parameter)
{
    static int32_t recv_package_length = 0;
    static int32_t read_start_flag = 0;
    static int32_t curr_net_player_cache = 0;
    int32_t package_length = 0;
    int8_t  msg_state = NET_MSG_IDE;
    BaseType_t err;
    cias_data_standard_head_t *data_header;
    uint32_t cache_empty_num = 0;
    cur_play_stream = tts_player;
    while (1)
    {
        /****play deal****/
        #if NETWORK_AUDIO_PLAYER_ENABLE
        curr_net_player_cache = audio_play_stream_buffer_get_spaces_size(cur_play_stream);
        if ((curr_net_player_cache == IOT_AUDIO_PLAY_BUF_SIZE) && (get_net_player_status(get_net_play_type()) == NET_PLAYER_START))
        {
            cache_empty_num++;
            int stop_empt_num = 400;
            if (get_net_play_type() == PLAY_M4A)
            {
                stop_empt_num = 5;
            }
            if ((cache_empty_num >= stop_empt_num) && (!no_audio_data_flag))
            {
                cache_empty_num = 0;
                if (!recv_music_end_sem)
                {
                    no_audio_data_flag = true;
                    if ((get_net_play_type() == PLAY_M4A))
                    {
                        if (read_start_flag == 0)
                        {
                            pause_play(NULL, NULL);
                        }
                        else
                        {
                            no_audio_data_flag = false;
                        }
                    }
                    else if (get_net_play_type() != PLAY_TTS)
                    {
                        pause_play(NULL, NULL);
                    }
                    else
                    {
                        stop_play(NULL, NULL);
                    }
                    if (no_audio_data_flag)
                        ci_logdebug(LOG_MEDIA, "send_end_sem1 play_type = %d\n", get_net_play_type());
                }
            }
        }
        else if (get_net_player_status(get_net_play_type()) == NET_PLAYER_READY)
        {
            read_start_flag = 1;
        }
        else
        {
            cache_empty_num = 0;
        }

        // if(start_recv_flag)
        // {
        //     // ci_logdebug(LOG_MEDIA, "curr_net_player_cache = %d\n",curr_net_player_cache);
        // }

/*         if(start_recv_flag && (curr_net_player_cache >= 41*1024)) 
        {
            cias_send_cmd(MP3_BUFF_START_RECV3K, DEF_FILL);
            ci_logdebug(LOG_MEDIA, "recv next data 3**\n");
            start_recv_flag = false;
        }
        else if(start_recv_flag && (curr_net_player_cache >= 21*1024)) 
        {
            cias_send_cmd(MP3_BUFF_START_RECV2K, DEF_FILL);
            ci_logdebug(LOG_MEDIA, "recv next data 2**\n");
            start_recv_flag = false;
        }*/
        if(start_recv_flag && (curr_net_player_cache >= 6*1024)) 
        {           
            //ci_logdebug(LOG_MEDIA, "curr_net_player_cache : %d\n", curr_net_player_cache);
            cias_send_cmd(PLAY_DATA_RECV, DEF_FILL);
            //ci_logdebug(LOG_MEDIA, "recv next data 1**\n");
           // ci_logdebug(LOG_MEDIA, "*");
            start_recv_flag = false;

        }
        #endif //NETWORK_AUDIO_PLAYER_ENABLE
        
       
        #if NEWORK_RECV_QUEUE_ENABLE
            //判断队列为空
            package_length = 0;
            while(pdPASS == xQueueReceive(network_msg_recv_queue, &package_data[package_length], pdMS_TO_TICKS(50)))
            {
                
                package_length++;
                if(msg_state == NET_MSG_IDE) 
                {
                    // ci_logdebug(LOG_MEDIA, "msg_state == NET_MSG_IDE(%d)\r\n",package_length);
                    msg_state = NET_MSG_HEAD;
                    
                }
                else if (msg_state == NET_MSG_HEAD && package_length > (sizeof(cias_data_standard_head_t)-2))
                {
                    // for(int i =0 ;i<sizeof(cias_data_standard_head_t)-1;i++)
                    // {
                    //     ci_logdebug(LOG_MEDIA, "%x ",package_data[i]);
                    // }
                    // ci_logdebug(LOG_MEDIA, "\r\nmsg_state == NET_MSG_HEAD\r\n");
                    data_header = (cias_data_standard_head_t *)package_data;
                    if(data_header->magic == CIAS_STANDARD_MAGIC)
                    {                        
                        msg_state = NET_MSG_DATE; 
                    }     
                    else
                        msg_state = NET_MSG_ERR;
                }
                else if(msg_state == NET_MSG_DATE && package_length > (data_header->len + sizeof(cias_data_standard_head_t) - 1))//等待数据接收完成  
                {
                    
                    // ci_logdebug(LOG_MEDIA, "msg_state == NET_MSG_DATE\r\n");
                    // memset(recv_data, 0, 1050);
                    // memcpy(recv_data, package_data, package_length+1);                    

                    data_header = (cias_data_standard_head_t *)package_data;
                    recv_package_length = data_header->len + sizeof(cias_data_standard_head_t);                   
                    
                    wifi_msg_deal((uint8_t *)package_data, recv_package_length);

                    package_length = 0;
                    memset(package_data,0,1050);
                    msg_state = NET_MSG_IDE; 
                }

                if(msg_state == NET_MSG_ERR)
                {
                    ci_logdebug(LOG_USER, "ci_standard_head_t error\r\n");
                    package_length = 0;
                    memset(package_data,0,1050);
                    msg_state = NET_MSG_IDE; 
                }


            }
            

            if(msg_state != NET_MSG_IDE)//超时处理？？？
            {
                ci_logdebug(LOG_USER, "recv data timeout error(%d)\r\n",package_length);
                package_length = 0;
                memset(package_data, 0, 1050);
                msg_state = NET_MSG_IDE; 
            }
        #endif
    }
}

/**
 *
 * 判断是否需要回复ACK
 *
 **/
/* bool cmd_need_ack(uint16_t cmd)
{
    switch (cmd)
    {
    case DL_LOGIN_INFO_REQ:
    case DL_VER_REQ:
    case DL_WRITE_DATA_REQ:
    case DL_OTA_RSP:
    {
        return true;
    }
    default:
    {
        return false;
    }
    }
} */
#if UPLOAD_PROCESSED_VOICE_DATA_BY_NET_ENABLE
/* 语音上传最短限制 */
#define SEND_VOICE_DATA_LIMIT (256 * 40 * 2)

static int32_t send_voice_data_size = 0; //发送语音数据包大小

void upload_voice_vad_timeout_cb(uint32_t voice_size)
{
    if ((voice_size > 1024 * 10) && (!check_current_playing()))
    {
        ci_logdebug(LOG_MEDIA, "voice_size = %d!\n", voice_size);
        // cias_send_cmd(PCM_FINISH, DEF_FILL);
        voice_upload_disable();
    }
}

void pirv_vad_timeout_deal(uint32_t addr, uint16_t length)
{
}

/**
 * @brief 进入多轮对话
 *
 */
// void enter_next_dialogue(uint32_t timeout_ms)
// {
//     cias_send_cmd(WAKE_UP,NO_WAKEUP_FILL_DATA);
//     set_local_player_status(0);
//     set_upload_timeout(timeout_ms);/*updata timer*/
//     set_wake_up_cmd_status(1);
//     save_voice_data_start();
// }

#endif // UPLOAD_PROCESSED_VOICE_DATA_BY_NET_ENABLE

extern void play_done_callback(cmd_handle_t cmd_handle);

// int get_isplay_cloud(void)
// {
//     int is_play = 0;
//     if (check_current_playing())
//     {
//         is_play = 1;
//     }
//     return is_play;
// }


/**
 * @brief WIFI 消息处理
 *
 * @param msg_buf 数据信息
 * @param msg_len 数据长度
 * @return int32_t RETURN_OK 处理成功，RETURN_ERR 数据异常
 */

int32_t wifi_msg_deal(uint8_t *msg_buf, int32_t msg_len)
{

    int8_t net_config_fail_state = 0;
    if ((msg_buf == NULL) || (msg_len <= 0))
    {
        return RETURN_ERR;
    }
#if TUYA_IR_CTRL_DEMO_ENABLE | CI_IR_CTRL_DEMO_ENABLE   //涂鸦红外遥控器demo
    tuya_ir_wifi_msg_callback(msg_buf);
#endif

#if TENCENT_IOT_LIGHT_DEMO_ENABLE
    tencent_iot_light_network_callback(msg_buf);
#endif
#if CIAS_DOUBLE_MIC_DEMO_ENABLE | CIAS_SIGNAL_MIC_DEMO_ENABLE
    aux_aiot_aircondition_callback(msg_buf);
#endif
#if CIAS_FLASH_IMAGE_UPGRADE_ENABLE
    cias_data_standard_head_t *pheader = (cias_data_standard_head_t *)(msg_buf);
    
    if(pheader->type == CIAS_OTA_START)
        dpmu_software_reset_system_config();
#endif
    int32_t ret = RETURN_OK;

    return ret;
}