/**
 * Tencent is pleased to support the open source community by making Tars available.
 *
 * Copyright (C) 2016THL A29 Limited, a Tencent company. All rights reserved.
 *
 * Licensed under the BSD 3-Clause License (the "License"); you may not use this file except 
 * in compliance with the License. You may obtain a copy of the License at
 *
 * https://opensource.org/licenses/BSD-3-Clause
 *
 * Unless required by applicable law or agreed to in writing, software distributed 
 * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR 
 * CONDITIONS OF ANY KIND, either express or implied. See the License for the 
 * specific language governing permissions and limitations under the License.
 */

#include "ConfigImp.h"
#include "ConfigServer.h"

extern TC_Config * g_pconf;

#define CHECKLIMIT(a,b,c,f) do{\
 if(IsLimited((a),(b),(c),(f)))\
 {\
 return 0;\
 }}while(0)
 
using namespace tars;

map<ServerKey,pair<time_t,int> > ConfigImp::_loadConfigLimited;

void ConfigImp::loadconf()
{
 TC_DBConf tcDBConf;
 tcDBConf.loadFromMap(g_pconf->getDomainMap("/tars/db"));
 _mysqlConfig.init(tcDBConf);

 _limitInterval = TC_Common::strto<int>(g_pconf->get("/tars/limit<limitinterval>", "10"));
 _limitInterval = _limitInterval <= 0 ? 10 : _limitInterval;
 _interval = TC_Common::strto<int>(g_pconf->get("/tars/limit<interval>", "1"));
 _interval = _interval <= 0 ? 1 : _interval;
}

void ConfigImp::initialize()
{
 loadconf();
}

int ConfigImp::ListConfig(const string &app, const string &server, vector<string> &vf,tars::TarsCurrentPtr current)
{
 try
 {
 string host = current->getIp();

 TLOGDEBUG("ConfigImp::ListConfig app:" << app << "|server:" << server << "|host:" << host << endl);

 //查ip对应配置
 string sNULL("");
 string sSql =
 "select filename from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(app+"."+server) + "' "
 "and host='" + _mysqlConfig.escapeString(host) +"' "
 "and level=" + TC_Common::tostr<int>(eLevelIpServer) + " "
 "and set_name ='" + _mysqlConfig.escapeString(sNULL) +"' "
 "and set_area ='" + _mysqlConfig.escapeString(sNULL) +"' "
 "and set_group ='" + _mysqlConfig.escapeString(sNULL) +"' ";

 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::ListConfig sql:" << sSql << "|res.size:" << res.size() << endl);

 for(unsigned i=0; i<res.size();i++)
 {
 vf.push_back(res[i]["filename"]);
 }
 }
 catch(TC_Mysql_Exception & ex)
 {
 TLOGERROR("ConfigImp::ListConfig exception:" << ex.what() << endl);
 return -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::ListConfig unknown exception." << endl);
 return -1;
 }

 return 0;
}

bool ConfigImp::getSetInfo(string& sSetName, string& sSetArea, string& sSetGroup, const string& sSetDivision)
{
 vector<string> vtSetDivisions = TC_Common::sepstr<string>(sSetDivision, ".");
 if(vtSetDivisions.size() != 3)
 {
 return false;
 }

 sSetName = vtSetDivisions[0];
 sSetArea = vtSetDivisions[1];
 sSetGroup = vtSetDivisions[2];

 return true;
}

int ConfigImp::ListConfigByInfo(const ConfigInfo& configInfo, vector<string> &vf,tars::TarsCurrentPtr current)
{
 try
 {
 string sHost = configInfo.host.empty() ? current->getIp() : configInfo.host;

 TLOGDEBUG("ConfigImp::ListConfigByInfo app:" << configInfo.appname << "|server:" << configInfo.servername << "|set:" << configInfo.setdivision << "|host:" << sHost << endl);

 string sCondition;
 if(!configInfo.setdivision.empty())
 {
 string sSetName,sSetArea,sSetGroup;
 if(getSetInfo(sSetName,sSetArea,sSetGroup,configInfo.setdivision))
 {
 sCondition += " and set_name='" +_mysqlConfig.escapeString(sSetName)+"' ";
 sCondition += " and set_area='" +_mysqlConfig.escapeString(sSetArea)+"' ";
 sCondition += " and set_group='"+_mysqlConfig.escapeString(sSetGroup)+"' ";
 }
 else
 {
 TLOGERROR("ConfigImp::ListConfigByInfo setdivision is invalid|setdivision:" << configInfo.setdivision << endl);
 return -1;
 }
 }
 else//兼容没有set信息的业务
 {
 string sNULL("");
 sCondition += " and set_name='" + _mysqlConfig.escapeString(sNULL) +"' ";
 sCondition += " and set_area='" + _mysqlConfig.escapeString(sNULL) +"' ";
 sCondition += " and set_group='" + _mysqlConfig.escapeString(sNULL) +"' ";
 }

 //查ip对应配置
 string sSql =
 "select filename from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(configInfo.appname + "." + configInfo.servername) + "' "
 "and host='" + _mysqlConfig.escapeString(sHost) + "' "
 "and level=" + TC_Common::tostr<int>(eLevelIpServer) + sCondition;

 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::ListConfigByInfo sql:" << sSql << "|res.size:" << res.size() << endl);

 for(unsigned i=0; i<res.size();i++)
 {
 vf.push_back(res[i]["filename"]);
 }
 }
 catch(TC_Mysql_Exception & ex)
 {
 TLOGERROR("ConfigImp::ListConfigByInfo exception:" << ex.what() << endl);
 return -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::ListConfigByInfo unknown exception." << endl);
 return -1;
 }

 return 0;
}

int ConfigImp::loadConfigByInfo(const ConfigInfo & configInfo,string &config,tars::TarsCurrentPtr current)
{
 int iRet = 0 ;

 TLOGDEBUG("ConfigImp::loadConfigByInfo app:" << configInfo.appname << "|server:" << configInfo.servername << "|filename:" << configInfo.filename << "|setdivision:" << configInfo.setdivision << endl);

 CHECKLIMIT(configInfo.appname,configInfo.servername,current->getIp(),configInfo.filename);
 
 if(configInfo.bAppOnly || configInfo.servername.empty())//应用级配置或者set级配置
 {
 iRet = loadAppConfigByInfo(configInfo,config,current);
 }
 else
 {
 iRet = loadConfigByHost(configInfo,config,current);
 }

 return iRet;
}

int ConfigImp::checkConfigByInfo(const ConfigInfo & configInfo, string &result,tars::TarsCurrentPtr current)
{
 TLOGDEBUG("ConfigImp::checkConfigByInfo app:" << configInfo.appname << "|server:" << configInfo.servername << "|filename:" << configInfo.filename << "|setdivsion:" << configInfo.setdivision << endl);

 int iRet = loadConfigByHost(configInfo,result,current);
 if (iRet != 0)
 {
 TLOGERROR("ConfigImp::checkConfigByInfo loadConfigByHost fail." << endl);
 return -1;
 }

 try
 {
 TC_Config conf;
 conf.parseString(result);
 }
 catch(exception &ex)
 {
 result = ex.what();
 TLOGERROR("ConfigImp::checkConfigByInfo exception:" << ex.what() << endl);
 return -1;
 }

 return 0;
}

int ConfigImp::loadConfig(const std::string& app, const std::string& server, const std::string& fileName, string &config, tars::TarsCurrentPtr current)
{
 TLOGDEBUG("ConfigImp::loadConfig app:" << app << "|server:" << server << "|fileName:" << fileName << "|host:" << current->getIp() << endl);

 CHECKLIMIT(app,server,current->getIp(),fileName);

 if(!server.empty())
 {
 return loadConfigByHost(app + "." + server, fileName, current->getIp(), config, current);
 }
 else
 {
 return loadAppConfig(app, fileName, config, current);
 }
}

int ConfigImp::loadConfigByHost(const std::string& appServerName, const std::string& fileName, const string &host, string &config, tars::TarsCurrentPtr current)
{
 TLOGDEBUG("ConfigImp::loadConfigByHost appServerName:" << appServerName << "|fileName:" << fileName << "|host:" << host << endl);

 int iRet = 0;
 config = "";

 //多配置文件的分割符
 string sSep = "\r\n\r\n";
 try
 {
 string sAllServerConfig("");
 int iAllConfigId = 0;

 //查公有配置
 string sNULL("");
 string sSql =
 "select id,config from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(appServerName) + "' "
 "and filename='" + _mysqlConfig.escapeString(fileName) + "' "
 "and level=" + TC_Common::tostr<int>(eLevelAllServer) + " "
 "and set_name ='" + _mysqlConfig.escapeString(sNULL) + "' "
 "and set_area ='" + _mysqlConfig.escapeString(sNULL) + "' "
 "and set_group ='" + _mysqlConfig.escapeString(sNULL) + "' ";

 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::loadConfigByHost sql:" << sSql << "|res.size:" << res.size() << endl);

 if(res.size() == 1)
 {
 sAllServerConfig = res[0]["config"];
 iAllConfigId = TC_Common::strto<int>(res[0]["id"]);
 }

 vector<int> referenceIds;

 iRet = getReferenceIds(iAllConfigId,referenceIds);

 TLOGDEBUG("ConfigImp::loadConfigByHost referenceIds.size:" << referenceIds.size() << endl);

 if(iRet == 0)
 {
 for(size_t i = 0; i < referenceIds.size();i++)
 {
 int iRefId = referenceIds[i];
 string refConfig("");

 iRet = loadConfigByPK(iRefId,refConfig);
 if(iRet == 0 && (!refConfig.empty()))
 {
 if(config.empty())
 {
 config += refConfig;
 }
 else
 {
 config += sSep + refConfig;
 }
 }
 }
 }

 //添加配置本身
 if(!sAllServerConfig.empty())
 {
 if(config.empty())
 {
 config += sAllServerConfig;
 }
 else
 {
 config += sSep + sAllServerConfig;
 }
 }


 string sIpServerConfig = "";
 int iIpConfigId = 0;

 sSql =
 "select id,config from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(appServerName) + "' "
 "and filename='" + _mysqlConfig.escapeString(fileName) + "' "
 "and host='" + _mysqlConfig.escapeString(host) + "' "
 "and level=" + TC_Common::tostr<int>(eLevelIpServer) + " "
 "and set_name ='" + _mysqlConfig.escapeString(sNULL) + "' "
 "and set_area ='" + _mysqlConfig.escapeString(sNULL) + "' "
 "and set_group ='" + _mysqlConfig.escapeString(sNULL) + "' ";

 res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::loadConfigByHost sql:" << sSql << "|res.size:" << res.size() << endl);

 if(res.size() == 1)
 {
 sIpServerConfig = res[0]["config"];
 iIpConfigId = TC_Common::strto<int>(res[0]["id"]);
 }

 iRet = getReferenceIds(iIpConfigId,referenceIds);

 TLOGDEBUG("ConfigImp::loadConfigByHost referenceIds.size:" << referenceIds.size() << endl);

 if(iRet == 0)
 {
 for(size_t i = 0; i < referenceIds.size(); i++)
 {
 int iRefId = referenceIds[i];
 string refConfig("");

 iRet = loadConfigByPK(iRefId,refConfig);
 if(iRet == 0 && (!refConfig.empty()) )
 {
 if(config.empty())
 {
 config += refConfig;
 }
 else
 {
 config += sSep + refConfig;
 }
 }
 }
 }

 //添加配置本身
 if(!sIpServerConfig.empty())
 {
 if(config.empty())
 {
 config += sIpServerConfig;
 }
 else
 {
 config += sSep + sIpServerConfig;
 }
 }
 }
 catch(TC_Mysql_Exception & ex)
 {
 config = ex.what();
 TLOGERROR("ConfigImp::loadConfigByHost exception:" << ex.what() << endl);
 iRet = -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::loadConfigByHost unknown exception." << endl);
 iRet = -1;
 }

 return iRet;
}

int ConfigImp::checkConfig(const std::string& appServerName, const std::string& fileName, const string &host, string &result, tars::TarsCurrentPtr current)
{
 TLOGDEBUG("ConfigImp::checkConfig appServerName:" << appServerName << "|fileName:" << fileName << "|host:" << host << endl);

 int ret = loadConfigByHost(appServerName, fileName, host, result, current);
 if (ret != 0)
 {
 TLOGDEBUG("ConfigImp::checkConfig loadConfigByHost fail." << endl);
 return -1;
 }

 try
 {
 TC_Config conf;
 conf.parseString(result);
 }
 catch(exception &ex)
 {
 TLOGDEBUG("ConfigImp::checkConfig exception:" << ex.what() << endl);
 result = ex.what();
 return -1;
 }

 return 0;
}

///////////////////////////////////////////////private
int ConfigImp::loadConfigByPK(int iConfigId, string &sConfig)
{
 int iRet = 0 ;
 //按照建立引用的先后返回
 try
 {
 string sSql =
 "select config from t_config_files where id=" + TC_Common::tostr<int>(iConfigId) +" order by id";

 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::loadConfigByPK sql:" << sSql << "|res.size:" << res.size() << endl);

 if(res.size() == 1)
 {
 sConfig = res[0]["config"];
 }
 }
 catch(TC_Mysql_Exception & ex)
 {
 sConfig = ex.what();
 TLOGERROR("ConfigImp::loadConfigByPK exception:" << ex.what() << endl);
 return -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::loadConfigByPK unknown exception." << endl);
 return -1;
 }

 return iRet;
}

int ConfigImp::loadRefConfigByPK(int iConfigId, const string& setdivision,string &sConfig)
{
 int iRet = 0 ;
 //按照建立引用的先后返回
 try
 {
 string sSql =
 "select server_name,filename,config from t_config_files where id=" + TC_Common::tostr<int>(iConfigId) +" order by id";

 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::loadRefConfigByPK sql:" << sSql << "|res.size:" << res.size() << endl);

 if(res.size() == 1)
 {
 string sAppConfig = res[0]["config"];
 string sFileName = res[0]["filename"];
 string sServerName = res[0]["server_name"];

 string sSetName("");
 string sSetArea("");
 string sSetGroup("");
 string sSetConfig("");

 //查询该配置是否有set配置信息
 if(getSetInfo(sSetName,sSetArea,sSetGroup,setdivision))
 {
 string sCondition;
 sCondition += " and set_name='" +_mysqlConfig.escapeString(sSetName)+"' ";
 sCondition += " and set_area='" +_mysqlConfig.escapeString(sSetArea)+"' ";
 sCondition += " and set_group='" +_mysqlConfig.escapeString(sSetGroup)+"' ";

 string sSql =
 "select config from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(sServerName) + "' "
 "and filename='" + _mysqlConfig.escapeString(sFileName) + "' "
 "and level=" + TC_Common::tostr<int>(eLevelApp) + sCondition;

 TC_Mysql::MysqlData resSet = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::loadRefConfigByPK sql:" << sSql << "|resSet.size:" << resSet.size() << endl);

 if(resSet.size() == 1)
 {
 sSetConfig = resSet[0]["config"];
 }
 }

 sConfig = mergeConfig(sAppConfig,sSetConfig);
 }
 }
 catch(TC_Mysql_Exception & ex)
 {
 sConfig = ex.what();
 TLOGERROR("ConfigImp::loadRefConfigByPK exception: "<<ex.what()<<endl);
 return -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::loadRefConfigByPK unknown exception." << endl);
 return -1;
 }

 return iRet;
}

int ConfigImp::getReferenceIds(int iConfigId,vector<int> &referenceIds)
{
 int iRet = 0 ;

 referenceIds.clear();

 string sSql =
 "select reference_id from t_config_references where config_id=" + TC_Common::tostr<int>(iConfigId);

 TLOGDEBUG("ConfigImp::getReferenceIds sql:" << sSql << endl);

 try
 {
 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::getReferenceIds res.size:" << res.size() << endl);

 for(size_t i = 0 ; i < res.size(); i++)
 {
 int iRefId = TC_Common::strto<int>(res[i]["reference_id"]);
 referenceIds.push_back(iRefId);
 }
 }
 catch(TC_Mysql_Exception & ex)
 {
 TLOGERROR("ConfigImp::getReferenceIds exception:" << ex.what() << endl);
 return -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::getReferenceIds unknown exception" << endl);
 return -1;
 }

 return iRet;
}


int ConfigImp::loadAppConfig(const std::string& appName, const std::string& fileName, string &config, tars::TarsCurrentPtr current)
{
 TLOGDEBUG("ConfigImp::loadAppConfig appName:" << appName << "|fileName:" << fileName << endl);

 int iRet = 0 ;
 config = "";

 try
 {
 string sNULL;
 //查公有配置
 string sSql =
 "select id,config from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(appName) + "' "
 "and filename='" + _mysqlConfig.escapeString(fileName) + "' "
 "and level=" + TC_Common::tostr<int>(eLevelApp) + " "
 "and set_name ='" + _mysqlConfig.escapeString(sNULL) + "' "
 "and set_area ='" + _mysqlConfig.escapeString(sNULL) + "' "
 "and set_group ='" + _mysqlConfig.escapeString(sNULL) + "' ";

 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::loadAppConfig sql:" << sSql << "|res.size:" << res.size() << endl);

 if(res.size() == 1)
 {
 config = res[0]["config"];
 }
 }
 catch(TC_Mysql_Exception & ex)
 {
 config = ex.what();
 TLOGERROR("ConfigImp::loadAppConfig exception:" << ex.what() << endl);
 iRet = -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::loadAppConfig unknown exception." << endl);
 iRet = -1;
 }

 return iRet;

}

int ConfigImp::loadConfigByHost(const ConfigInfo & configInfo, string &config, tars::TarsCurrentPtr current)
{
 string sHost = configInfo.host.empty() ? current->getIp() : configInfo.host;

 TLOGDEBUG("ConfigImp::loadConfigByHost app:" << configInfo.appname << "|server:" << configInfo.servername << "|filename:" << configInfo.filename
 << "|host:" << sHost << "|setdivision:" <<configInfo.setdivision << endl);

 int iRet = 0 ;
 config = "";
 string sTemp = "";

 //多配置文件的分割符
 string sSep = "\r\n\r\n";
 try
 {
 string sCondition;
 if(!configInfo.setdivision.empty())
 {
 string sSetName,sSetArea,sSetGroup;
 if(getSetInfo(sSetName,sSetArea,sSetGroup,configInfo.setdivision))
 {
 sCondition += " and set_name='" +_mysqlConfig.escapeString(sSetName)+"' ";
 sCondition += " and set_area='" +_mysqlConfig.escapeString(sSetArea)+"' ";
 sCondition += " and set_group='" +_mysqlConfig.escapeString(sSetGroup)+"' ";
 }
 else
 {
 TLOGERROR("ConfigImp::loadConfigByHost setdivision is invalid|setdivision:" << configInfo.setdivision << endl);
 return -1;
 }
 }
 else//兼容没有set信息的业务
 {
 string sNULL;
 sCondition += " and set_name='" + _mysqlConfig.escapeString(sNULL) + "' ";
 sCondition += " and set_area='" + _mysqlConfig.escapeString(sNULL) + "' ";
 sCondition += " and set_group='" + _mysqlConfig.escapeString(sNULL) + "' ";
 }

 string sAllServerConfig("");
 int iAllConfigId = 0;

 //查服务配置
 string sSql =
 "select id,config from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(configInfo.appname+"."+configInfo.servername) + "' "
 "and filename='" + _mysqlConfig.escapeString(configInfo.filename) + "' "
 "and level=" + TC_Common::tostr<int>(eLevelAllServer) + sCondition;

 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::loadConfigByHost sql:" << sSql << "|res.size:" << res.size() << endl);

 if(res.size() == 1)
 {
 sAllServerConfig = res[0]["config"];
 iAllConfigId = TC_Common::strto<int>(res[0]["id"]);
 }

 //查服务配置的引用配置
 vector<int> referenceIds;
 iRet = getReferenceIds(iAllConfigId,referenceIds);

 TLOGDEBUG("ConfigImp::loadConfigByHost referenceIds.size:" << referenceIds.size() << endl);

 if(iRet == 0)
 {
 for(size_t i = 0; i < referenceIds.size();i++)
 {
 int iRefId = referenceIds[i];
 string refConfig("");

 //此处获取的服务配置的引用配置信息
 iRet = loadRefConfigByPK(iRefId,configInfo.setdivision,refConfig);
 if(iRet == 0 && (!refConfig.empty()))
 {
 sTemp = mergeConfig(sTemp,refConfig);
 }
 }
 }

 //添加服务配置本身
 config = mergeConfig(sTemp,sAllServerConfig);

 sTemp.clear();

 string sIpServerConfig("");
 int iIpConfigId = 0;

 //查看节点级配置
 sSql =
 "select id,config from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(configInfo.appname + "." + configInfo.servername) + "' "
 "and filename='" + _mysqlConfig.escapeString(configInfo.filename) + "' "
 "and host='" + _mysqlConfig.escapeString(sHost) + "' "
 "and level=" + TC_Common::tostr<int>(eLevelIpServer);

 res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::loadConfigByHost sql:" << sSql<< "|res.size:" << res.size() << endl);

 if(res.size() == 1)
 {
 sIpServerConfig = res[0]["config"];
 iIpConfigId = TC_Common::strto<int>(res[0]["id"]);
 }

 iRet = getReferenceIds(iIpConfigId, referenceIds);

 TLOGDEBUG("ConfigImp::loadConfigByHost referenceIds.size:" << referenceIds.size() << endl);

 if(iRet == 0)
 {
 string refAppConfig("");
 string refSetConfig("");
 for(size_t i = 0; i < referenceIds.size();i++)
 {
 int iRefId = referenceIds[i];
 string refConfig("");

 //此处获取的节点配置的引用配置信息
 iRet = loadRefConfigByPK(iRefId,configInfo.setdivision,refConfig);
 if(iRet == 0 && (!refConfig.empty()))
 {
 sTemp = mergeConfig(sTemp,refConfig);
 }
 }
 }

 config = mergeConfig(config,mergeConfig(sTemp, sIpServerConfig));

 }
 catch(TC_Mysql_Exception & ex)
 {
 config = ex.what();
 TLOGERROR("ConfigImp::loadConfigByHost exception:" << ex.what() << endl);
 iRet = -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::loadConfigByHost unknown exception" << endl);
 iRet = -1;
 }

 return iRet;
}

int ConfigImp::loadAppConfigByInfo(const ConfigInfo & configInfo, string &config, tars::TarsCurrentPtr current)
{
 int iRet = 0;
 config="";
 try
 {
 string sSql =
 "select id,config from t_config_files "
 "where server_name = '" + _mysqlConfig.escapeString(configInfo.appname) + "' "
 "and filename='" + _mysqlConfig.escapeString(configInfo.filename) + "' "
 "and level=" + TC_Common::tostr<int>(eLevelApp);

 string sNULL("");
 string sCondition("");
 sCondition += " and set_name='" + _mysqlConfig.escapeString(sNULL) +"' ";
 sCondition += " and set_area='" + _mysqlConfig.escapeString(sNULL) +"' ";
 sCondition += " and set_group='" + _mysqlConfig.escapeString(sNULL) +"' ";

 //先获取app配置
 string sSqlAppNoSet = sSql + sCondition;

 TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSqlAppNoSet);

 TLOGDEBUG("ConfigImp::loadAppConfigByInfo sSqlAppNoSet:" << sSqlAppNoSet << "|res.size:" << res.size() << endl);

 string sAppConfig("");

 if(res.size() == 1)
 {
 sAppConfig = res[0]["config"];
 }

 //再获取app下有set信息的配置
 string sSetConfig;
 if(!configInfo.setdivision.empty())//存在set信息
 {
 string sSetName,sSetArea,sSetGroup;

 if(getSetInfo(sSetName,sSetArea,sSetGroup,configInfo.setdivision))
 {
 string sCondition;
 sCondition += " and set_name='" +_mysqlConfig.escapeString(sSetName)+"' ";
 sCondition += " and set_area='" +_mysqlConfig.escapeString(sSetArea)+"' ";
 sCondition += " and set_group='" +_mysqlConfig.escapeString(sSetGroup)+"' ";

 string sSqlSet = sSql + sCondition;
 res = _mysqlConfig.queryRecord(sSqlSet);

 TLOGDEBUG("ConfigImp::loadAppConfigByInfo sSqlSet:" << sSqlSet << "|res.size:" << res.size() << endl);

 if(res.size() == 1)
 {
 sSetConfig = res[0]["config"];
 }
 }
 else
 {
 TLOGERROR("ConfigImp::loadAppConfigByInfo setdivision is invalid|configInfo.setdivision:" << configInfo.setdivision << endl);
 return -1;
 }
 }

 config = mergeConfig(sAppConfig,sSetConfig);

 }
 catch(TC_Mysql_Exception & ex)
 {
 config = ex.what();
 TLOGERROR("ConfigImp::loadAppConfigByInfo exception:" << ex.what() << endl);
 iRet = -1;
 }
 catch(...)
 {
 TLOGERROR("ConfigImp::loadAppConfigByInfo unknown exception" << endl);
 iRet = -1;
 }

 return iRet;
}

string ConfigImp::mergeConfig(const string& sLowConf,const string& sHighConf)
{

 if(sLowConf.empty())
 {
 return sHighConf;
 }
 else if(sHighConf.empty())
 {
 return sLowConf;
 }
 else
 {
 return sLowConf + "\r\n\r\n" + sHighConf;
 }
}

//频率限制
bool ConfigImp::IsLimited(const std::string & app, const std::string & server, const std::string & sIp,const string& sFile)
{
 const time_t INTERVAL = 1 * 60;
 bool bLimited = false;

 {
 ServerKey sKey = {app, server, sIp,sFile};

 static TC_ThreadLock s_mutex;

 TC_ThreadLock::Lock lock(s_mutex);

 map<ServerKey,pair<time_t,int> >::iterator it = _loadConfigLimited.find(sKey);
 if(it != _loadConfigLimited.end())
 {
 ///1分钟内最多允许拉取10次
 if((TNOW - it->second.first) <= (INTERVAL*_interval))
 {
 if(it->second.second <= _limitInterval)
 {
 it->second.second++;
 }
 else
 {
 bLimited = true;
 TLOGERROR("ConfigImp::IsLimited app:" << app << "|server:" << server << "|sIp:" << sIp << "|sFile:" << sFile 
 << "|out of limit,now:" << it->second.second << "|limitInterval:" << _limitInterval << endl);
 }
 }
 //已经超过1分钟了
 else
 {
 _loadConfigLimited.erase(sKey);
 }
 }
 else
 {
 _loadConfigLimited.insert(std::make_pair(sKey,std::make_pair(TNOW,1)));
 }
 }

 return bLimited;
}

int ConfigImp::ListAllConfigByInfo(const tars::GetConfigListInfo & configInfo, vector<std::string> &vf, tars::TarsCurrentPtr current)
{
	CHECKLIMIT(configInfo.appname,configInfo.servername,current->getIp(),"");

	try
	{
		if(configInfo.bAppOnly)
		{
			//查ip对应配置
			string sSql = "select distinct filename from t_config_files "
				"where server_name = '" + _mysqlConfig.escapeString(configInfo.appname) + "' "
				"and level=" + TC_Common::tostr<int>(eLevelApp);

 TLOGDEBUG("ConfigImp::ListAllConfigByInfo sql:" << sSql << endl);

			TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::ListAllConfigByInfo sql:" << sSql << "|res:" << res.size() << endl);

			for(unsigned i=0; i<res.size();i++)
			{
				vf.push_back(res[i]["filename"]);
			}

			return 0;
		}
		else
		{
			string sHost = configInfo.host;
			string sContainer = configInfo.containername;
			string sSql = "select distinct filename from t_config_files where server_name = '" + _mysqlConfig.escapeString(configInfo.appname+"."+configInfo.servername) + "' ";
			
			string sCondition("");
			if(!sHost.empty())
			{
				sCondition += " and host='"+_mysqlConfig.escapeString(sHost)+"' ";
				sCondition += " and level=" + TC_Common::tostr<int>(eLevelIpServer);
			}
			
			if(!configInfo.setdivision.empty())
			{
				string sSetName,sSetArea,sSetGroup;
				if(getSetInfo(sSetName,sSetArea,sSetGroup,configInfo.setdivision))
				{
					sCondition += " and set_name='" +_mysqlConfig.escapeString(sSetName)+"' ";
					sCondition += " and set_area='" +_mysqlConfig.escapeString(sSetArea)+"' ";
					sCondition += " and set_group='" +_mysqlConfig.escapeString(sSetGroup)+"' ";
				}
				else
				{
					TLOGERROR("ConfigImp::ListAllConfigByInfo setdivision is invalid:" << configInfo.setdivision << endl);
					return -1;
				}
			}
			else//兼容没有set信息的业务
			{
				string sNULL;
				sCondition += " and set_name='" + _mysqlConfig.escapeString(sNULL) +"' ";
				sCondition += " and set_area='" + _mysqlConfig.escapeString(sNULL) +"' ";
				sCondition += " and set_group='" + _mysqlConfig.escapeString(sNULL) +"' ";
			}

			sSql += sCondition;

 TLOGDEBUG("ConfigImp::ListAllConfigByInfo sql:" << sSql << endl);

			TC_Mysql::MysqlData res = _mysqlConfig.queryRecord(sSql);

 TLOGDEBUG("ConfigImp::ListAllConfigByInfo sql:" << sSql << "|res:" << res.size() << endl);

			for(unsigned i=0; i<res.size();i++)
			{
				vf.push_back(res[i]["filename"]);
			}
		}
	}
	catch(TC_Mysql_Exception & ex)
	{
		TLOGERROR("ConfigImp::ListAllConfigByInfo mysql exception:" << ex.what() << endl);
		return -1;
	}
 catch(exception& ex)
	{
		TLOGERROR("ConfigImp::ListAllConfigByInfo exception:" << ex.what() << endl);
		return -1;
	}

	return 0;
}