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

#include "JZsdkLib.h"
#include "BaseConfig.h"

#include "../V4L2_camera/V4L2_Record.h"
#include "../V4L2_camera/V4L2_CameraParameterSetting.h"

#include "../../MultProc/MultProc.h"
#include "../../MediaParm.h"
#include "../../VideoMgmt/VideoMgmt.h"
#include "../Camera.h"

static int CameraFd = 0;

//临时方案 后续会改写法合并到t_JZsdk_TaskFuntionInput（搞起来有点麻烦）
typedef struct t_FrameCatch_TaskFuntionInput
{
    void (*task_function)(unsigned char*, unsigned int);  //任务函数指针,用于指定 执行的任务
    unsigned* data; //数据指针
    unsigned int data_size; //数据大小
} t_FrameCatch_TaskFuntionInput; 

//多线程抓取数据线程
static void *JZsdk_Catch_MultiThread(void *args)
{
    while (1)
    { 
        unsigned int buf_size = 0;
        unsigned char *buf = NULL;
        
        //从相机中读取一张照片
        V4L2_CameraFrameRecord_OnlyGetFrame(&buf, &buf_size);

        //printf("read: len:%d data[3]:%x data[4]:%x\n", buf_size, buf[3], buf[4]);

        if (buf == NULL)
        {
            JZSDK_LOG_ERROR("相机数据读取失败");
            continue;
        }
        
        //放入缓冲池 //将数据放入缓冲池，从而被其他线程使用
        VideoMgmt_write_data(&VideoMgmt_FirstVideo_index, buf, buf_size);

        //归还图片
        V4L2_CameraFrameRecord_OnlyReturnFrame();
    }
}


/******************************
 * 
 *  相机抓取初始化
 *  ThreadMode: 0为单线程 1为多线程
 * 
 * ******************************/
T_JZsdkReturnCode JZsdk_FrameCatch_Init(int ThreadMode)
{
    T_JZsdkReturnCode ret;

    //初始化数据接收线程
    pthread_t ReadDataTask;
	pthread_attr_t task_attribute; //线程属性
	pthread_attr_init(&task_attribute);  //初始化线程属性
	pthread_attr_setdetachstate(&task_attribute, PTHREAD_CREATE_DETACHED);      //设置线程分离属性

    if (ThreadMode == 0)
    {
        // int opus_Protection = pthread_create(&ReadDataTask,&task_attribute,JZsdk_Catch_SingleThread,NULL);		//线程
        // if(opus_Protection != 0)
        // {
        //     JZSDK_LOG_ERROR("创建相机抓取并处理初始化线程失败！");
        //     return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE;
        // }
    }
    else if (ThreadMode == 1)
    {
        int opus_Protection = pthread_create(&ReadDataTask,&task_attribute,JZsdk_Catch_MultiThread,NULL);		//线程
        if(opus_Protection != 0)
        {
            JZSDK_LOG_ERROR("创建相机抓取并处理初始化线程失败！");
            return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE;
        }
    }
    
    return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}


/*******************************************************************************************************************************************/


//单线程抓取数据线程
static void *JZsdk_Catch_SingleThread(void *args)
{
    JZsdk_CameraInfo *CameraInfo = (JZsdk_CameraInfo *)args;
    while (1)
    { 

        unsigned int buf_size = 0;
        unsigned char *buf = NULL;
                
        //从相机中读取一张照片
        V4L2_CameraFrameRecord_OnlyGetFrame2(CameraInfo ,&buf, &buf_size);

        //JZSDK_LOG_INFO("read: len:%d data[3]:%x data[4]:%x\n", buf_size, buf[3], buf[4]);

        if (buf == NULL)
        {
            JZSDK_LOG_ERROR("相机数据读取失败");
            continue;
        }
        
        //进行数据处理
        CameraInfo->SingleDataOutput(buf, buf_size);        
        
        //归还图片
        V4L2_CameraFrameRecord_OnlyReturnFrame2(CameraInfo);
    }
}


/********************************************
 * 
 * 
 *  相机抓取多线程单线程
 * 
 *  传入线程的处理函数 task_function
 * 
 * *****************************************/
T_JZsdkReturnCode JZsdk_FrameCatch_Single(JZsdk_CameraInfo *CameraInfo)
{
    T_JZsdkReturnCode ret;

    T_JZTaskHandle single_task = NULL;
    T_JZsdkOsalHandler *osal_handler = JZsdk_Platform_GetOsalHandler();
    osal_handler->TaskCreate("framecatch_single",JZsdk_Catch_SingleThread, 8192, (void *)CameraInfo, &single_task);

    if (single_task == NULL)
    {
        JZSDK_LOG_ERROR("创建相机抓取并处理初始化线程失败！");
        return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE;
    }

    JZSDK_LOG_INFO("创建相机抓取并处理初始化线程成功！");
    
    return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}

























//多线程抓取数据线程
static void *JZsdk_Catch_MultiThread2(void *args)
{
    while (1)
    { 
        unsigned int buf_size = 0;
        unsigned char *buf = NULL;
        
        //从相机中读取一张照片
        V4L2_CameraFrameRecord_OnlyGetFrame(&buf, &buf_size);

        //printf("read: len:%d data[3]:%x data[4]:%x\n", buf_size, buf[3], buf[4]);

        if (buf == NULL)
        {
            JZSDK_LOG_ERROR("相机数据读取失败");
            continue;
        }
        
        //放入缓冲池 //将数据放入缓冲池，从而被其他线程使用
        VideoMgmt_write_data(&args, buf, buf_size);

        //归还图片
        V4L2_CameraFrameRecord_OnlyReturnFrame();
    }
}




/*************************
 * 
 * 
 *  相机抓取多线程
 * 
 * 
 * ******************/
T_JZsdkReturnCode JZsdk_FrameCatch_Multi(void *FrameIndex)
{
    T_JZsdkReturnCode ret;

    //初始化数据接收线程
    pthread_t ReadDataTask;
	pthread_attr_t task_attribute; //线程属性
	pthread_attr_init(&task_attribute);  //初始化线程属性
	pthread_attr_setdetachstate(&task_attribute, PTHREAD_CREATE_DETACHED);      //设置线程分离属性

    if (FrameIndex == NULL)
    {
        return JZ_ERROR_SYSTEM_MODULE_CODE_INVALID_PARAMETER;
    }
    

    int opus_Protection = pthread_create(&ReadDataTask,&task_attribute,JZsdk_Catch_MultiThread2, FrameIndex);		//线程
    if(opus_Protection != 0)
    {
        JZSDK_LOG_ERROR("创建相机抓取并处理初始化线程失败！");
        return JZ_ERROR_SYSTEM_MODULE_CODE_FAILURE;
    }

    return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
}