modularization/src1/decision/interface/ivdecision.h

#ifndef IVDECISION_H
#define IVDECISION_H

#include "ivmodule.h"

#include "modulecomm.h"

#include "gps_type.h"
#include "obstacle_type.h"
#include "gpsimu.pb.h"
#include "radarobjectarray.pb.h"
#include "mobileye.pb.h"
#include "hmi.pb.h"
#include "decition.pb.h"
#include "vbox.pb.h"
#include "v2x.pb.h"
#include "ultrasonic.pb.h"

#include <QMutex>

#include <memory>

namespace iv {

class ivdecision : public ivmodule
{
public:
    ivdecision();

public:
    virtual void modulerun();


public:
    virtual int getdecision(iv::brain::decition & xdecition) = 0;
    virtual void sharemsg() = 0;

private:
    std::string mstrgpsmsgname = "hcp2_gpsimu";
    std::string mstrlidarmsgname = "lidar_obs";
    std::string mstrradarmsgname = "radar";
    std::string mstrmapmsgname = "tracemap";
    std::string mstrmobileyemsgname = "mobileye";
    std::string mstrhmimsgname = "hmi";
    std::string mstrpadmsgname = "pad";

private:
    void * mpagpsmsg;
    void * mpalidarmsg;
    void * mparadarmsg;
    void * mpamapmsg;
    void * mpamobileyemsg;
    void * mpahmimsg;
    void * mpapadmsg;

private:
    void UpdateGPS(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
    void UpdateRADAR(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
    void UpdateLIDAR(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
    void UpdateMAP(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
    void UpdateMobileye(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
    void UpdateHMI(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
    void UpdateVbox(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
    void Updatev2x(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);
    void Updateultrasonic(const char * strdata,const unsigned int nSize,const unsigned int index,const QDateTime * dt,const char * strmemname);

private:

    iv::GPSData mNowGPS;
    std::shared_ptr<iv::gps::gpsimu> mGPSIMUptr = 0;
    qint64 mnGPSUpdateTime = 0;
    QMutex mMutexGPS;

    std::shared_ptr<iv::radar::radarobjectarray> mRADAR = 0;
    qint64 mnRADARUpdateTime = 0;
    QMutex mMutexRADAR;

    std::shared_ptr<std::vector<iv::ObstacleBasic> > mlidar_obs;
    qint64 mnLIDARUpdateTime = 0;
    QMutex mMutexLIDAR;

    std::vector<iv::GPSData> mnavigation_data;	//导航数据，GPS结构体数组
    qint64 mnMAPUpdateTime = 0;
    QMutex mMutexMAP;

    std::shared_ptr<iv::mobileye::mobileye> mmobileye;
    qint64 mnmobileyeUpdateTime = 0;
    QMutex mMutexmobileye;

    std::shared_ptr<iv::hmi::hmimsg> mHMImsg;
    qint64 mnHMIUpdateTime = 0;
    QMutex mMutexHMI;

    std::shared_ptr<iv::vbox::vbox> mvboxmsg;
    qint64 mnvboxUpdateTime = 0;
    QMutex mMutexvbox;

    std::shared_ptr<iv::v2x::v2x> mv2xmsg;
    qint64 mnv2xUpdateTime = 0;
    QMutex mMutexv2x;

    std::shared_ptr<iv::ultrasonic::ultrasonic> multrasonicmsg;
    qint64 mnultrasonicUpdateTime = 0;
    QMutex mMutexultrasonic;

private:
    const qint64 mnNewThresh = 1000; //1 seconds


public:
    bool GetGPS(iv::GPSData & xGPSData);
    bool GetRADAR(std::shared_ptr<iv::radar::radarobjectarray> & xRADAR);
    bool GetLIDARGrid(iv::LidarGridPtr & lidargridptr);
    bool GetLIDARObs(std::shared_ptr<std::vector<iv::ObstacleBasic> > & xlidar_obs);
    bool IsMAPUpdate(qint64 & nLastUpdateTime);
    bool GetMAP(std::vector<iv::GPSData> & navigation_data,qint64 & nLastUpdateTime);
    bool GetMobileye(std::shared_ptr<iv::mobileye::mobileye> & xmobileye);
    bool GetHMImsg(std::shared_ptr<iv::hmi::hmimsg> & xhmimsg);
    bool Getvboxmsg(std::shared_ptr<iv::vbox::vbox> & xvboxmsg);
    bool Getv2xmsg(std::shared_ptr<iv::v2x::v2x> & xv2xmsg);
    bool Getultrasonic(std::shared_ptr<iv::ultrasonic::ultrasonic> & xultramsg);

//    void GetLidarPtr();
//    void GetRadar();
//    void GetMap();
//    bool IsMapUpdate();
//    void GetMobileye();

};

}

#endif // IVDECISION_H