#include "PerimeterAlarmManager.h"
#include <basic/core/JsonFile.h>
#include <basic/util/app/AppPreference.hpp>
#include <map>
#include <mutex>
#include <sys/time.h>
#include "../VideoServer/QiaoJia/DB/LDBTool.h"
#include <basic/util/fastdfs/FastFds.hpp>
PerimeterAlarmManager::PerimeterAlarmManager(LDBTool *lDBTool):
m_lDBTool(lDBTool)
{
   init();
}

PerimeterAlarmManager::~PerimeterAlarmManager()
{
   PA_removeAll();
}


void PerimeterAlarmManager::printConfigInfo(const ControllerConfig& config)
{
    //INFO("nFps "<<config.camInfo.nFps);

//    INFO("strRtsp "<<config.camInfo.strRtsp);
//    INFO("nTriggerDelay "<<config.paAlarmInfo.nTriggerDelay);
//    INFO("nAlarmDelay "<<config.paAlarmInfo.nAlarmDelay);
//    INFO("fSensitivity "<<config.paAlarmInfo.fSensitivity);
//    INFO("strMaskPath "<<config.paAlarmInfo.strMaskPath);
//    INFO("nAssembleCount "<<config.paAlarmInfo.nAssembleCount);


//    for(auto ele:config.assembleInfo.sounds)
//    {
//        INFO("soundPlayInfo.nID "<<ele.strIP);
//        INFO("soundPlayInfo.nSoundDuration "<<ele.nSoundDuration);
//        INFO("soundPlayInfo.strPath "<<ele.strPath);
//    }
}


int PerimeterAlarmManager::PA_addCamera(int index, const ControllerConfig& config)
{
    static int gpucount = 0;

    gpucount++;

    if(g_mapControls[index] == nullptr)
    {
        auto control = new AppPaController(index,config);
        g_mapControls[index] = control;
        control->start();
        return 0;
    }else{
        PA_removeCamera(index);
        return PA_addCamera(index, config);
    }
}

int PerimeterAlarmManager::PA_removeCamera(int index)
{
    INFO("PA_removeCamera remove_index : "<<index);
    if(g_mapControls[index] != nullptr)
    {
        AppPaController* control = g_mapControls[index];
        control->stop();
        control->wait();
        delete control;
        g_mapControls[index] = nullptr;
        g_mapControls.erase(index);
        return 0;
    }
    return -1;
}

int PerimeterAlarmManager::PA_removeAll()
{
    INFO("PA_removeAll");
    for(auto iter = g_mapControls.begin();iter!=g_mapControls.end();iter++){
        AppPaController* control = iter->second;
        if(nullptr!=control)
        {
            control->stop();
            control->wait();
            delete control;
        }
        control = nullptr;
    }
    g_mapControls.clear();
    return 0;
}




bool PerimeterAlarmManager::PA_hasIndex(int index)
{
    return g_mapControls[index] != nullptr;
}


static std::string rtspAddrBuild(std::string ip, const int port, std::string username,
                                 std::string passwd, std::string brand) {
    std::string rtsp_url;
    if (brand == "haikang") {
        rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) +
                   "/h264/ch1/main/av_stream";
    } else if (brand == "dahua") {
        //rtsp://username:password@ip:port/cam/realmonitor?channel=1&subtype=0
        rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) +
                   "/cam/realmonitor?channel=1&subtype=0";
        //TODO
    } else if (brand == "yushi") {
        rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) +
                   "/video1";
    } else {
        //TODO
    }

    return rtsp_url;
}

void PerimeterAlarmManager::init()
{
    auto lst = m_lDBTool->searchCamDevTableAll();
    auto lst_dev = m_lDBTool->searchConfigTableWithinServerInfo();

    appPref.setIntData("n_cut_max_duration", lst_dev.n_cut_max_duration);

    if (lst.size() > 0)
    {
        Json::Value json;
        Json::Value rules;
        for (auto item : lst)
        {
           int camId=item.str_cam_dev_id.toInt();
           AlarmRule rule=m_lDBTool->searchCameraRuleByCamId(camId);
           QVector<LActRuleWeekRecord> vec=m_lDBTool->searchCameraWeekRuleByCamId(camId);
           ControllerConfig config;
           for(int i=0;i<vec.size();++i)
           {
               RuleWeekInfo info;
               info.m_nType=vec[i].m_nType;
               info.m_strBegin=vec[i].m_strBegin;
               info.m_strEnd=vec[i].m_strEnd;
               config.ruleWeekInfoVec.push_back(info);
           }


           config.camInfo.strCamId= item.str_cam_dev_id.toStdString();


            config.camInfo.strRtsp= rtspAddrBuild(item.str_ip.toStdString(), 554, item.str_username.toStdString(),
                                                 item.str_password.toStdString(), item.str_brand.toStdString());

            config.camInfo.strAdrr = item.str_addr.toStdString();

            config.paAlarmInfo.fSensitivity=rule.sensitivity;
            config.paAlarmInfo.nAlarmDelay=rule.alarm_delay;
            config.paAlarmInfo.nTriggerDelay=rule.trigger_delay;
            config.paAlarmInfo.strMaskPath=rule.str_mask_path;
            config.paAlarmInfo.nAssembleCount=rule.assemble_count;

            PA_addCamera(camId, config);
        }
    }
    else
    {
        ERR("searchCamDevTableAll size is 0");
    }
}
std::string PerimeterAlarmManager::resetFdfs(std::string ip, unsigned int port, std::string content) {

    std::thread reset([&]() {
        fdfsClient.rwLock.rdlock();
        if (fdfsClient.fastFds != nullptr) {
            delete fdfsClient.fastFds;
        }
        fdfsClient.fastFds = new FastFds("fastDfsClient.conf");
        fdfsClient.rwLock.unlock();
    });
    reset.detach();

    return "";
}