#ifndef APPPACONTROLLER_H
#define APPPACONTROLLER_H

#include <basic/pipe/PipeController.h>
#include <basic/pipe_element/ffmpeg/FfmpegElement.h>
#include <basic/pipe_element/ImageShowElement.h>
#include <basic/util/curl/HttpRequestWithCrul.hpp>
#include "PaImageDrawElement.h"
#include "../StructureApp/RecordVideoElement.h"
#include "PaYoloRpcElement.h"
#include <TriggerElement.h>
#include <QtCore/QDateTime>
#include <jsoncpp/json/json.h>
//#include <basic/rpc/IceRpc.hpp>
//#include "../Alarm/rpc/Alarm.h"
//#include "../netsoundbox/rpc/NetSoundBox.h"
//#include <QtCore/QVector>
//网络音箱配置
struct SoundPlayInfo
{
    SoundPlayInfo():nSoundDuration(-1)
    {}
    //int nID;
    std::string strIP;//音箱IP
    int nSoundDuration;//声音间隔时间
    std::string strPath;//声音路径
};
//摄像头信息
struct CamInfo
{
    int nFps;//帧率
    std::string strCamId;
    std::string strAdrr;
    std::string strRtsp;//RTSP地址
};

//报警信息
struct PaAlarmInfo
{
//    int nWallNum;//墙号
//    int nWallSubNum;//子墙号
//    int nWindowNum;//窗口号
    int nTriggerDelay;//报警开始延时时间间隔
    int nAlarmDelay;//报警结束延时时间间隔
    QString strMaskPath; //alarm maskPath解码器报警的ROI区域小图路径
    float fSensitivity;//alarm sensitivity报警的检测阈值
    int nAssembleCount;//聚集的人数
};

//聚集信息
struct AssembleInfo
{
    int nAssembleCount;//聚集的人数
    float fSensitivity;//AssembleInfo sensitivity聚集的检测阈值
    //std::string strProxy;
    std::string strMaskPath;// AssembleInfo maskPath聚集的ROI区域小图路径
    std::vector<SoundPlayInfo> sounds;//网络音箱播放信息
};

struct RuleWeekInfo
{
    RuleWeekInfo()
    {
        m_nType = 1;
        m_strBegin = "";
        m_strEnd = "";
    }

    int m_nType; //周几
    QString m_strBegin;//00:00
    QString m_strEnd;
};
//addcamera配置项
struct ControllerConfig
{

    //NONE neither alarm nor assemble
    //ALARM alarm
    //ASSEMBLE Assemble

    //camInfo
    CamInfo camInfo;//摄像头信息

    //alarmInfo
    PaAlarmInfo paAlarmInfo;//报警信息

    //AssembleInfo
  //  AssembleInfo assembleInfo;//聚集信息

    QVector<RuleWeekInfo> ruleWeekInfoVec;

};

class AppPaController : public PipeController {
public:
    /***
     * 用于快速视频结构化
     * @param folderPath 任务根目录，用于做共享内存id
     * @param json 参数为rtsp流地址 sdk是否启用的标识
     */

    AppPaController(int index, const ControllerConfig& cfg);

    virtual ~AppPaController();

    void sendVideoAlarm(bool value);
    //通知报警服务报警
    void openSoundAlarm();
    //通知报警服务关闭报警
    void closeSoundAlarm();
    //通知网络音箱播放音乐
    void playSound();
    //通知网络音箱停止播放音乐
    void stopSound();

    //void alarmResultSaveToDB(std::string&,std::string&,std::string&);

    //保存人体裁剪图
    static int saveRectsImage(const vector<cv::Rect2f>& rects,const cv::Mat& img,const char* path);


    bool isSaveVideo();

    bool isSaveResult();

    bool isSaveImage();


    bool getRunning();

    std::string getRtmp();

    void setfdfsClient(FastFdsWithLock *p_fdfsClient);

private:
    void init();

private:
    ffmpeg::VideoCaptureElement videoCaptureElement;
    PaYoloRpcElement yoloRpcElement;
    PaImageDrawElement imageDrawElement;
    RecordVideoElement recordVideoElement;
//    VideoPublishElement videoPublishElement;

    int m_index;
    std::string m_folderPath;
    Json::Value m_json_Record;

    Json::FastWriter m_fastWriter;
    FastFdsWithLock *fdfsClient;


    TriggerElement triggerElement;
    std::atomic<bool> bUp;

    QDateTime m_dt;


    const ControllerConfig m_cfg;

  //  NetSoundBox::SoundInfos soundInfos;
//    IceRpcClient<Alarm::AlarmInterfacePrx> alarmRpc;
//    IceRpcClient<NetSoundBox::SoundInterfacePrxPtr> soundRpc;
  //  IceRpcClient<SaveModule::SaveAlarmPrx> m_SaveAlarmRpc;

};

#endif // APPPIPECONTROLLER_H