Vehicle-cpp/remote_drive/EgoZJ/EgoSystem/Rtk.h

#pragma once
#include "../common/comm.h"
#include "../common/notifier.h"

#include "MqttClient.h"

class CMessageQueue;

class CRtkSensor//:public ISensorNotify
{
public:
    CRtkSensor(CMessageQueue* q);
    void Notify(int8_t* buffer, int32_t size);
    void SetSensorSocket(SensorSocket<CRtkSensor>* udp);
    void Start();
    void Stop();
    void Send_ZGJ_status(int Status);//ץ�ֻ�״̬��Ϣ�ϱ�

private:
    void Run();
    void Send_ZGJ_Rtk(float headingAngle, float lat, float lon);//ץ�ֻ�λ����Ϣ�ϱ�

private:
    CMessageQueue* _message;
    SensorSocket<CRtkSensor>* _socket;

    long long _curTick;
    bool F_SendDate;
    bool _run;
    int32_t _count=0;
};