MIVAS/modules/dataType/src/NettyHttpCarInfo.cpp

/*
 * @Description: 
 * @Version: 1.0
 * @Autor: lishengyin
 * @Date: 2021-11-24 15:15:35
 * @LastEditors: lishengyin
 * @LastEditTime: 2021-11-29 09:16:45
 */
#include "NettyHttpCarInfo.h"



NettyHttpCarInfo::NettyHttpCarInfo(){}

NettyHttpCarInfo::~NettyHttpCarInfo(){}


bool NettyHttpCarInfo::jsonToObject(const rapidjson::Value& object){
    const auto end = object.MemberEnd();
    if(end == object.FindMember("id") || !object["id"].IsString()){
        return false;
    }else{
        id = object["id"].GetString();
    }

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

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

    if(end == object.FindMember("attr") || !object["attr"].IsObject()){
        return false;
    }else{
        const rapidjson::Value& obj = object["attr"];
        if(!attr.jsonToObject(obj)){
            return false;
        }
    }

    if(end == object.FindMember("children")|| !(object["children"].IsArray())){
        return false;
    }else{
        const rapidjson::Value& objs = object["children"];
        for (size_t i = 0; i < objs.Size(); i++) {
            const rapidjson::Value& obj = objs[i];
            NettyHttpCarDevData data;
            if(!(data.jsonToObject(obj))){
                return false;
            }
            children.push_back(data);
        }
    }

    return true;
}

/**
 * @description: 数据同步
 * @param {*}
 * @return {*}
 */    
bool NettyHttpCarInfo::NettyClientDataSync()
{
    vector<vector<string>> sqlRet;

    // 更新TrainInfo表
    SqlWriter sqlSelectTrain("SELECT * FROM MIVA_DB.TrainInfo WHERE carId='?'");
    sqlSelectTrain << attr.carId << sqlRet;
    if(sqlRet.size() != 0){
        SqlWriter sqlUpdate("UPDATE MIVA_DB.TrainInfo SET carCode='?',carName='?',enableFlag='?' WHERE carId='?'");
        sqlUpdate << attr.carCode << attr.carName << attr.enableFlag << attr.carId << sqlRet;
    }else{
        SqlWriter sqlInstert("INSERT INTO MIVA_DB.TrainInfo(carId,carCode, carName, enableFlag) VALUES('?', '?', '?', '?')");
        sqlInstert << attr.carId << attr.carCode << attr.carName << attr.enableFlag << sqlRet;
    }

    // 更新CarData表
    vector<int> CarIds;
    CarIds.clear();
    vector<NettyHttpCarDevData>::iterator iter;
    for(iter=children.begin();iter!=children.end();iter++){
        std::string sql = "SELECT * FROM MIVA_DB.CarData WHERE CarId='?'";
        SqlWriter sqlSelect(sql.c_str());
        sqlSelect << iter->attr.carId << sqlRet;
        if(sqlRet.size() != 0){
            SqlWriter sqlUpdate("UPDATE MIVA_DB.CarData SET label='?',PId='?',enableFlag='?',addTime='?',updateTime='?',carriageCode='?' WHERE CarId='?'");
            sqlUpdate << iter->label << iter->pid << iter->attr.enableFlag  << iter->attr.addTime << iter->attr.updateTime << iter->id << iter->attr.carId << sqlRet;
        }else{
            SqlWriter sqlInstert("INSERT INTO MIVA_DB.CarData(NoLoad,DynamicLoad,Grade,Num,label,PId,CarId,enableFlag,addTime,carriageCode,updateTime)\
                VALUES('?','?','?','?','?','?','?','?','?','?','?')");
            sqlInstert << 0 << 0 << 0 << 0 << iter->label << iter->pid << iter->attr.carId << iter->attr.enableFlag << iter->attr.addTime << iter->id << iter->attr.updateTime << sqlRet;
        }
        CarIds.push_back(iter->attr.carId);
    }
    if(CarIds.empty()){
        SqlWriter sqlDel("DELETE FROM MIVA_DB.CarData");
        sqlDel << sqlRet;
    }else{
        std::string sql = "DELETE FROM MIVA_DB.CarData WHERE carId NOT IN (";
        vector<int>::iterator iter1;
        int i = 0;
        for(iter1=CarIds.begin();iter1!=CarIds.end();iter1++){
            if(i == (int)CarIds.size() - 1) sql += to_string(*iter1);
            else sql += to_string(*iter1) + ",";
            i++;
        }
        sql += ")";
        SqlWriter sqlDel(sql.c_str());
        sqlDel << sqlRet;
    }
    
    CarIds.clear();
    // 更新DataSources表
    for(iter=children.begin();iter!=children.end();iter++)
    {
        vector<CarBasicData>::iterator iter1;
        for(iter1=iter->children.begin(); iter1!=iter->children.end();iter1++){
            std::string sql = "SELECT * FROM MIVA_DB.DataSources WHERE dv_Id='?'";
            SqlWriter sqlSelect(sql.c_str());
            sqlSelect << iter1->attr.dvId << sqlRet;
            if(sqlRet.size() != 0){
                SqlWriter sqlUpdate("UPDATE MIVA_DB.DataSources SET CarId='?',Uri='?',PId='?',label='?',Del='?',addTime='?',updateTime='?',IP='?' WHERE dv_Id='?'");
                sqlUpdate << iter->attr.carId << iter1->attr.stream << iter1->pid << iter1->label << 0 << iter1->attr.addTime << iter1->attr.updateTime << iter1->attr.localIp << iter1->attr.dvId << sqlRet; 
            }else{
                SqlWriter sqlInstert("INSERT INTO MIVA_DB.DataSources(CarId,Uri,Play,PId,label,Num,Del,addTime,updateTime,IP,dv_Id)\
                    VALUES('?','?','?','?','?','?','?','?','?','?','?')");
                sqlInstert << iter->attr.carId<< iter1->attr.stream << 0 << iter1->pid << iter1->label << 0 << 0 << iter1->attr.addTime << iter1->attr.updateTime << iter1->attr.localIp << iter1->attr.dvId << sqlRet; 
            }
            CarIds.push_back(iter1->attr.dvId);
        }
    }
    
    if(CarIds.empty()){
        SqlWriter sqlUpdate("UPDATE MIVA_DB.DataSources SET Del=1");
        sqlUpdate << sqlRet;
    }else{
        std::string sql = "UPDATE MIVA_DB.DataSources SET Del=1 WHERE dv_Id NOT IN (";
        vector<int>::iterator iter1;
        int i = 0;
        for(iter1=CarIds.begin();iter1!=CarIds.end();iter1++){
            if(i == (int)CarIds.size() - 1) sql += to_string(*iter1);
            else sql += to_string(*iter1) + ",";
            i++;
        }
        sql += ")";
        SqlWriter sqlUpdate(sql.c_str());
        sqlUpdate << sqlRet;
    }

    return true;
}