#ifndef THREAD_H
#define THREAD_H

#include <QThread>
#include "opencv2/core/core.hpp"
#include "opencv2/highgui/highgui.hpp"
#include "opencv2/opencv.hpp"
#include <QMutex>
#include <Python.h>
#include <arrayobject.h>
#include <QVector>
#include <modbus-tcp.h>
#include <modbus.h>


extern PyObject* pFun;

typedef struct
{
    int pointA_x;
    int pointA_y;
    int pointB_x;
    int pointB_y;
}bad_candy_box;


class PyThreadStateLock
{
public:
    PyThreadStateLock(void)
    {
        state = PyGILState_Ensure( );
    }

    ~PyThreadStateLock(void)
    {
         PyGILState_Release( state );
    }
private:
    PyGILState_STATE state;
};


class QThreadDeal: public QThread
{   Q_OBJECT

private:
    QMutex stop_mutex;
    bool m_stop;

protected:
    void run();

public:
    explicit QThreadDeal(QObject *parent = NULL);
    void exitThread();
    PyObject* call_python_file(npy_intp* diminfo,unsigned char* buff);
    void deal_ret_from_python(PyObject* ret);


signals:
    void send_image(cv::Mat);
    void send_res(QVector<bad_candy_box>);

};


class QThreadModbus: public QThread
{   Q_OBJECT
private:
    QMutex stop_mutex;
    bool m_stop;
protected:
    void run();

public:
    explicit QThreadModbus(QObject *parent = NULL);
    void exitThread();
signals:
    void stop_all_thread();
};


class QThreadDebug: public QThread
{   Q_OBJECT
private:
    QMutex stop_mutex;
    bool m_stop;
    bool correct_flag;
    QMutex correct_mutex;

protected:
    void run();

public:
    explicit QThreadDebug(QObject *parent = NULL);
    void exitThread();

public slots:
    void get_correct_siganl();

signals:
    void send_image_debug(cv::Mat);

};

class QThreadValveTest: public QThread
{   Q_OBJECT
private:

protected:
    void run();

public:
    explicit QThreadValveTest(QObject *parent = NULL);
    void exitThread();
};



#endif // THREAD_H