#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_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();
    }
}


//单线程抓取数据线程
static void *JZsdk_Catch_SingleThread2(void *args)
{
    t_FrameCatch_TaskFuntionInput *task = (t_FrameCatch_TaskFuntionInput *)args;

    while (1)
    { 

        unsigned int buf_size = 0;
        unsigned char *buf = NULL;
                
        //从相机中读取一张照片
        V4L2_CameraFrameRecord_OnlyGetFrame(&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;
        }
        
        //进行数据处理
        task->task_function(buf, buf_size);        
        
        //归还图片
        V4L2_CameraFrameRecord_OnlyReturnFrame();
    }
}


/********************************************
 * 
 * 
 *  相机抓取多线程单线程
 * 
 *  传入线程的处理函数 task_function
 * 
 * *****************************************/
T_JZsdkReturnCode JZsdk_FrameCatch_Single(T_JZsdkReturnCode (*task_function)(unsigned char*, unsigned int))
{
    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 (task_function == NULL)
    {
        return JZ_ERROR_SYSTEM_MODULE_CODE_INVALID_PARAMETER;
    }
    
    t_FrameCatch_TaskFuntionInput *task = (t_FrameCatch_TaskFuntionInput*)malloc(sizeof(t_FrameCatch_TaskFuntionInput));
    if (task == NULL) 
    {
        // 处理内存分配失败的情况
        return JZ_ERROR_SYSTEM_MODULE_CODE_INVALID_PARAMETER;
    }

    //task->task_function = task_function;
    task->task_function = (void (*)(unsigned char *, unsigned int))task_function;

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

/*************************
 * 
 * 
 *  相机抓取多线程
 * 
 * 
 * ******************/
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;
}