#pragma once

#include <iostream>
using namespace std;
#include <rapidjson/document.h>
#include <rapidjson/rapidjson.h>
#include <rapidjson/stringbuffer.h>
#include <rapidjson/writer.h>

#include "Util/logger.h"
#include "Util/NoticeCenter.h"
#include "Poller/EventPoller.h"
#include "Player/PlayerProxy.h"
#include "Rtmp/RtmpPusher.h"
#include "Common/config.h"
#include "Pusher/MediaPusher.h"
#include "Extension/Frame.h"
#include "Util/SqlPool.h"
#include "Network/TcpClient.h"
#include "Poller/Timer.h"


class NettyHttpDeviceConfig
{
public:
    std::string addTime;
    std::string updateTime;
    int createBy;
    int updateBy;
    int enableFlag;
    std::string attr1;
    std::string attr2;
    std::string attr3;
    int appId;
    int dvConfigId;
    int dvId;
    int algoType;
    std::string remark;

public:
    NettyHttpDeviceConfig() {}
    ~NettyHttpDeviceConfig() {}
    bool jsonToObject(const rapidjson::Value& object){
        const auto end = object.MemberEnd();

        if(end == object.FindMember("addTime") || !object["addTime"].IsString()){
            return false;
        }else{
            addTime = object["addTime"].GetString();
        }

        if(end == object.FindMember("updateTime") || !object["updateTime"].IsString()){
            return false;
        }else{
            updateTime = object["updateTime"].GetString();
        }

        if(end == object.FindMember("createBy") || !object["createBy"].IsInt()){
            return false;
        }else{
            createBy = object["createBy"].GetInt();
        }

        if(end == object.FindMember("updateBy") || !object["updateBy"].IsInt()){
            return false;
        }else{
            updateBy = object["updateBy"].GetInt();
        }

        if(end == object.FindMember("enableFlag") || !object["enableFlag"].IsInt()){
            return false;
        }else{
            enableFlag = object["enableFlag"].GetInt();
        }

        if(end == object.FindMember("attr1")){
            return false;
        }else{
            if(object["attr1"].IsString()) attr1 = object["attr1"].GetString();
            else attr1 = "";
        }

        if(end == object.FindMember("appId") || !object["appId"].IsInt()){
            return false;
        }else{
            appId = object["appId"].GetInt();
        }

        if(end == object.FindMember("dvConfigId") || !object["dvConfigId"].IsInt()){
            return false;
        }else{
            dvConfigId = object["dvConfigId"].GetInt();
        }

        if(end == object.FindMember("dvId") || !object["dvId"].IsInt()){
            return false;
        }else{
            dvId = object["dvId"].GetInt();
        }
        
        if(end == object.FindMember("algoType") || !object["algoType"].IsInt()){
            return false;
        }else{
            algoType = object["algoType"].GetInt();
        }

        return true;
    }

    /**
     * @description: 数据同步
     * @param {*}
     * @return {*}
     */    
    bool NettyClientDataSync()
    {
        // 同步数据
        vector<vector<string>> sqlRet;
        SqlWriter sqlUpdate("UPDATE MIVA_DB.DataSources SET RecognitionRange = '?', Play='?' WHERE dv_Id='?' ");
        sqlUpdate << attr1 << enableFlag << dvId << sqlRet;

        return true;
    }

};