对接数据管理接口

@@ -12,21 +12,21 @@
 #include "dmpproviderregistry.h"
 #include "libpq-fe.h"
 #include "clsUtil.h"
+#include <boost/algorithm/string/predicate.hpp>
 
 DmpVectorLayer::DmpVectorLayer(const std::string &path,
-                               const std::string &baseName,
-                               const std::string &providerKey,
-                               const DmpVectorLayer::LayerOptions &options)
-  : DmpMapLayer(DmpMapLayerType::VectorLayer, baseName, path)
-  , readExtentFromXml_(options.readExtentFromXml)
+							   const std::string &baseName,
+							   const std::string &providerKey,
+							   const DmpVectorLayer::LayerOptions &options)
+	: DmpMapLayer(DmpMapLayerType::VectorLayer, baseName, path), readExtentFromXml_(options.readExtentFromXml)
 {
-  wkbType_ = options.fallbackWkbType;
-  setProviderType(providerKey);
+	wkbType_ = options.fallbackWkbType;
+	setProviderType(providerKey);
 
-  if (!path.empty() && !providerKey.empty())
-  {
-    setDataSource(path, baseName, providerKey, options.loadDefaultStyle );
-  }
+	if (!path.empty() && !providerKey.empty())
+	{
+		setDataSource(path, baseName, providerKey, options.loadDefaultStyle);
+	}
 }
 
 DmpVectorLayer::~DmpVectorLayer()
@@ -35,221 +35,254 @@ DmpVectorLayer::~DmpVectorLayer()
 
 DmpMapLayerRenderer *DmpVectorLayer::createMapRenderer(DmpRenderContext &rendererContext)
 {
-  return new DmpVectorLayerRenderer(this, rendererContext);
+	return new DmpVectorLayerRenderer(this, rendererContext);
 }
 
 bool DmpVectorLayer::readXml(const boost::property_tree::ptree &layerNode)
 {
-  //id="gzxxd_aabe200b_5b63_4b82_8546_af1fc99e4ec6" name="gzxxd" alias="中学" type="1"
-  // geometry="Point" alwaysShow="true" maxScale="0" maxScale="50000"
-  id_ = layerNode.get<std::string>("<xmlattr>.id");
-  name_ = layerNode.get<std::string>("<xmlattr>.name");
-  title_ = layerNode.get<std::string>("<xmlattr>.alias");
-  boost::property_tree::ptree pExtent = layerNode.get_child("extent");
-  extent_ = DmpXmlUtils::readRectangle(pExtent);
-  dataSource_ = layerNode.get<std::string>("datasource");
-
-  //setDataProvider("postgres");
- // boost::property_tree::ptree pResourceMetadata = layerNode.get_child("resourcemetadata");
- // schema_ = layerNode.get<std::string>("schema");
- // geom_ = layerNode.get<std::string>("geom");
- // featurecount_ = layerNode.get<unsigned int>("featurecount");
-
-  boost::property_tree::ptree ptRenderer = layerNode.get_child("renderer");
-  auto pIter = ptRenderer.begin();
-  if(pIter == ptRenderer.end())return false;
-  DmapCore_30::Renderer* renderer_30 = nullptr;
-  DmapCore_30::clsXML::XMLParse(pIter->first, pIter->second, &renderer_30);
-  renderer_30_ = shared_ptr<DmapCore_30::Renderer>(renderer_30);
-
- // geom_ = "geom";
- // schema_ = "public";
- // wkbType_ = DmpWkbTypes::MultiLineString;
-
-  return true;
+	//id="gzxxd_aabe200b_5b63_4b82_8546_af1fc99e4ec6" name="gzxxd" alias="中学" type="1"
+	// geometry="Point" alwaysShow="true" maxScale="0" maxScale="50000"
+	id_ = layerNode.get<std::string>("<xmlattr>.id");
+	name_ = layerNode.get<std::string>("<xmlattr>.name");
+	title_ = layerNode.get<std::string>("<xmlattr>.alias");
+	boost::property_tree::ptree pExtent = layerNode.get_child("extent");
+	extent_ = DmpXmlUtils::readRectangle(pExtent);
+	dataSource_ = layerNode.get<std::string>("datasource");
+
+	if (!setDataProvider(dataSource_))
+	{
+		schema_ = layerNode.get<std::string>("<xmlattr>.schema");
+		geom_ = layerNode.get<std::string>("<xmlattr>.geomfield");
+		wkbTypeString_ = layerNode.get<std::string>("<xmlattr>.geometry");
+		featurecount_ = layerNode.get<unsigned int>("<xmlattr>.featurecount");
+		srid_ = layerNode.get<std::string>("<xmlattr>.srid");
+	}
+
+	if (boost::iequals(wkbTypeString_, "POINT"))
+		wkbType_ = DmpWkbTypes::Point;
+	else if (boost::iequals(wkbTypeString_, "MULTIPOINT"))
+		wkbType_ = DmpWkbTypes::MultiPoint;
+	else if (boost::iequals(wkbTypeString_, "LINESTRING"))
+		wkbType_ = DmpWkbTypes::LineString;
+	else if (boost::iequals(wkbTypeString_, "MULTILINESTRING"))
+		wkbType_ = DmpWkbTypes::MultiLineString;
+	else if (boost::iequals(wkbTypeString_, "POLYGON"))
+		wkbType_ = DmpWkbTypes::Polygon;
+	else if (boost::iequals(wkbTypeString_, "MULTIPOLYGON"))
+		wkbType_ = DmpWkbTypes::MultiPolygon;
+	else if (boost::iequals(wkbTypeString_, "GEOMETRY"))
+		wkbType_ = DmpWkbTypes::Unknown;
+
+	boost::property_tree::ptree ptRenderer = layerNode.get_child("renderer");
+	auto pIter = ptRenderer.begin();
+	if (pIter == ptRenderer.end())
+		return false;
+	DmapCore_30::Renderer *renderer_30 = nullptr;
+	DmapCore_30::clsXML::XMLParse(pIter->first, pIter->second, &renderer_30);
+	renderer_30_ = shared_ptr<DmapCore_30::Renderer>(renderer_30);
+
+	// geom_ = "geom";
+	// schema_ = "public";
+	// wkbType_ = DmpWkbTypes::MultiLineString;
+
+	return true;
 }
 
 bool DmpVectorLayer::writeXml(boost::property_tree::ptree &layerNode)
 {
-  layerNode.add("<xmlattr>.id", id_);
-  layerNode.add("<xmlattr>.name", name_);
-  layerNode.add("<xmlattr>.alias", title_);
-
-
-  boost::property_tree::ptree ptExtent;
-  ptExtent.add("xmin", extent_.xmin());
-  ptExtent.add("ymin", extent_.ymin());
-  ptExtent.add("xmax", extent_.xmax());
-  ptExtent.add("ymax", extent_.ymax());
-  layerNode.add_child("extent", ptExtent);
-
-  layerNode.add("datasource", dataSource_);
-   boost::property_tree::ptree ptRenderer;
-  if(this->renderer_30_)
-  {
-     this->renderer_30_->ParsePtree(ptRenderer);
-  }
-  layerNode.add_child("renderer",ptRenderer);
-
-  return true;
+	layerNode.add("<xmlattr>.id", id_);
+	layerNode.add("<xmlattr>.name", name_);
+	layerNode.add("<xmlattr>.alias", title_);
+
+	boost::property_tree::ptree ptExtent;
+	ptExtent.add("xmin", extent_.xmin());
+	ptExtent.add("ymin", extent_.ymin());
+	ptExtent.add("xmax", extent_.xmax());
+	ptExtent.add("ymax", extent_.ymax());
+	layerNode.add_child("extent", ptExtent);
+
+	layerNode.add("datasource", dataSource_);
+	boost::property_tree::ptree ptRenderer;
+	if (this->renderer_30_)
+	{
+		this->renderer_30_->ParsePtree(ptRenderer);
+	}
+	layerNode.add_child("renderer", ptRenderer);
+
+	return true;
 }
 
-bool DmpVectorLayer::writejson(std::string& json)
+bool DmpVectorLayer::writejson(std::string &json)
 {
-   string shapeTypeString ="UNKNOWORD";
+	string shapeTypeString = "UNKNOWORD";
 
-		switch (wkbType_)
-		{
-		case  DmpWkbTypes::Point: shapeTypeString = "POINT";
-			break;
-		case DmpWkbTypes::MultiPoint: shapeTypeString = "MULTIPOINT";
-			break;
-		case DmpWkbTypes::LineString: shapeTypeString = "LINESTRING";
-			break;
-		case DmpWkbTypes::MultiLineString: shapeTypeString = "MULTILINESTRING";
-			break;
-		case DmpWkbTypes::Polygon : shapeTypeString = "POLYGON";
-			break;
-		case DmpWkbTypes::MultiPolygon : shapeTypeString = "MULTIPOLYGON";
-			break;
-		default:
-		    shapeTypeString ="UNKNOWORD";
-			break;
-		}
-	   
-	   bool alwaysShow =  this->minScale() == 0 && this->maxScale() >10000000000;
-	   char buff_maxscale[100];
-	   char buff_minscale[100];
-	   if(this->maxScale() > 100000000)
-	   {
-		    sprintf(buff_maxscale,"%e",  this->maxScale());
-	   }
-	   else
-	   {
-		   sprintf(buff_maxscale,"%.0f",  this->maxScale());
-	   }
-
-	   if(this->minScale() > 100000000)
-	   {
-		    sprintf(buff_minscale,"%e",  this->minScale() );
-	   }
-	   else
-	   {
-		   sprintf(buff_minscale,"%.0f",  this->minScale() );
-	   }
-   //Display scale setting  type="1" geometry="Point" alwaysShow="true" maxScale="0" maxScale="50000">
-       char resultbuff[1000];
-       string json_source = this->source();
-       DmapCore_30::clsUtil::ToJSONString(json_source);
-	   sprintf(resultbuff,
-	      R"({"workspace":"","type":"1","dbsource":"%s","data":"","schema":"%s","alias":"%s","name":"%s","id":"%s","filter":"%s","visible":"%s","tag":"","minScale":"%s","maxScale":"%s","geometry":"%s","alwaysShow":"%s")",
-        json_source.c_str(),
-		    this->schema().c_str(),
-		    this->title().c_str(),
-		    this->name().c_str(), 
-		    this->id().c_str(),
-		    this->wherestr_.c_str(),
-		    "true",
-		    buff_minscale,buff_maxscale,
-		  shapeTypeString.c_str(),
-		  alwaysShow?"true":"false"
-		);
-
-    json.append(resultbuff);
-		if(this->renderer_30_ != nullptr)
-		{
-			
-			json.append(",");
-      DmapCore_30::AppendBuffer ab;
-			this->renderer_30_->ToJson(&ab);
-      json.append(ab.GetString());
-		}
-    json.append("}");
-    return true;
+	switch (wkbType_)
+	{
+	case DmpWkbTypes::Point:
+		shapeTypeString = "POINT";
+		break;
+	case DmpWkbTypes::MultiPoint:
+		shapeTypeString = "MULTIPOINT";
+		break;
+	case DmpWkbTypes::LineString:
+		shapeTypeString = "LINESTRING";
+		break;
+	case DmpWkbTypes::MultiLineString:
+		shapeTypeString = "MULTILINESTRING";
+		break;
+	case DmpWkbTypes::Polygon:
+		shapeTypeString = "POLYGON";
+		break;
+	case DmpWkbTypes::MultiPolygon:
+		shapeTypeString = "MULTIPOLYGON";
+		break;
+	default:
+		shapeTypeString = "UNKNOWORD";
+		break;
+	}
+
+	bool alwaysShow = this->minScale() == 0 && this->maxScale() > 10000000000;
+	char buff_maxscale[100];
+	char buff_minscale[100];
+	if (this->maxScale() > 100000000)
+	{
+		sprintf(buff_maxscale, "%e", this->maxScale());
+	}
+	else
+	{
+		sprintf(buff_maxscale, "%.0f", this->maxScale());
+	}
+
+	if (this->minScale() > 100000000)
+	{
+		sprintf(buff_minscale, "%e", this->minScale());
+	}
+	else
+	{
+		sprintf(buff_minscale, "%.0f", this->minScale());
+	}
+	//Display scale setting  type="1" geometry="Point" alwaysShow="true" maxScale="0" maxScale="50000">
+	char resultbuff[1000];
+	string json_source = this->source();
+	DmapCore_30::clsUtil::ToJSONString(json_source);
+	sprintf(resultbuff,
+			R"({"workspace":"","type":"1","dbsource":"%s","data":"","schema":"%s","alias":"%s","name":"%s","id":"%s","filter":"%s","visible":"%s","tag":"","minScale":"%s","maxScale":"%s","geometry":"%s","alwaysShow":"%s")",
+			json_source.c_str(),
+			this->schema().c_str(),
+			this->title().c_str(),
+			this->name().c_str(),
+			this->id().c_str(),
+			this->wherestr_.c_str(),
+			"true",
+			buff_minscale, buff_maxscale,
+			shapeTypeString.c_str(),
+			alwaysShow ? "true" : "false");
+
+	json.append(resultbuff);
+	if (this->renderer_30_ != nullptr)
+	{
+
+		json.append(",");
+		DmapCore_30::AppendBuffer ab;
+		this->renderer_30_->ToJson(&ab);
+		json.append(ab.GetString());
+	}
+	json.append("}");
+	return true;
 }
 
 void DmpVectorLayer::setRenderer(DmpFeatureRenderer *renderer)
 {
-
 }
 
 void DmpVectorLayer::setDataSource(const std::string &dataSource, const std::string &baseName, const std::string &provider, bool loadDefaultStyleFlag)
 {
-  DmpWkbTypes::GeometryType geomType = GeometryType();
+	DmpWkbTypes::GeometryType geomType = GeometryType();
 }
 
 DmpWkbTypes::GeometryType DmpVectorLayer::GeometryType() const
 {
-  return DmpWkbTypes::GeometryType(wkbType_);
+	return DmpWkbTypes::GeometryType(wkbType_);
 }
 
-bool DmpVectorLayer::setDataProvider(std::string const &provider)
+bool DmpVectorLayer::setDataProvider(const std::string &provider)
 {
-  isinit_ = true;
-  //临时测试使用
-  PGconn* pPGconn = PQconnectdb(provider.c_str());
-  ConnStatusType t = PQstatus(pPGconn);
-  if (t != CONNECTION_OK)
-			return false;
-  int re = PQsetClientEncoding(pPGconn, "UTF-8");
-
-  std::string sql = "select  t.f_geometry_column, t.type ,f_table_schema,t.srid from public.geometry_columns t where lower( t.f_table_name) = lower('" + name_ + "');";
-  PGresult* pPGresult= PQexec(pPGconn, sql.c_str());
+	if (provider.size() < 50)
+		return false;
+	isinit_ = true;
+	//临时测试使用
+	PGconn *pPGconn = PQconnectdb(provider.c_str());
+	ConnStatusType t = PQstatus(pPGconn);
+	if (t != CONNECTION_OK)
+		return false;
+	int re = PQsetClientEncoding(pPGconn, "UTF-8");
+
+	std::string sql = "select  t.f_geometry_column, t.type ,f_table_schema,t.srid from public.geometry_columns t where lower( t.f_table_name) = lower('" + name_ + "');";
+	PGresult *pPGresult = PQexec(pPGconn, sql.c_str());
 	char *sz = PQerrorMessage(pPGconn);
-	if(sz != nullptr && strcmp(sz,"") !=0)
-  {
-    	PQfinish(pPGconn); return false;
-  } 
-
-  int	rowCount = PQntuples(pPGresult);
-  if(rowCount<1) 
-  {
-    	PQfinish(pPGconn); return false;
-  } 
-
-  geom_ =  PQgetvalue(pPGresult, 0, 0);
-  const char* geomtype =  PQgetvalue(pPGresult, 0, 1);
-  schema_ =  PQgetvalue(pPGresult, 0, 2);
-  //std::string srid = PQgetvalue(pPGresult, 0, 3);
+	if (sz != nullptr && strcmp(sz, "") != 0)
+	{
+		PQfinish(pPGconn);
+		return false;
+	}
+
+	int rowCount = PQntuples(pPGresult);
+	if (rowCount < 1)
+	{
+		PQfinish(pPGconn);
+		return false;
+	}
+
+	geom_ = PQgetvalue(pPGresult, 0, 0);
+	const char *geomtype = PQgetvalue(pPGresult, 0, 1);
+	schema_ = PQgetvalue(pPGresult, 0, 2);
+	std::string srid = PQgetvalue(pPGresult, 0, 3);
 	wkbTypeString_ = geomtype;
+	srid_ = srid;
 	if (!geomtype)
 		return false;
-	if (!strcmp(geomtype, "POINT")) wkbType_ = DmpWkbTypes::Point;
-	else if (!strcmp(geomtype, "MULTIPOINT")) wkbType_ = DmpWkbTypes::MultiPoint;
-	else if (!strcmp(geomtype, "LINESTRING")) wkbType_ = DmpWkbTypes::LineString;
-	else if (!strcmp(geomtype, "MULTILINESTRING"))wkbType_ = DmpWkbTypes::MultiLineString;
-	else if (!strcmp(geomtype, "POLYGON")) wkbType_ = DmpWkbTypes::Polygon;
-	else if (!strcmp(geomtype, "MULTIPOLYGON")) wkbType_ = DmpWkbTypes::MultiPolygon;
-	else if (!strcmp(geomtype, "GEOMETRY")) wkbType_ = DmpWkbTypes::Unknown;
-  PQclear(pPGresult); pPGresult = NULL;
+	if (!strcmp(geomtype, "POINT"))
+		wkbType_ = DmpWkbTypes::Point;
+	else if (!strcmp(geomtype, "MULTIPOINT"))
+		wkbType_ = DmpWkbTypes::MultiPoint;
+	else if (!strcmp(geomtype, "LINESTRING"))
+		wkbType_ = DmpWkbTypes::LineString;
+	else if (!strcmp(geomtype, "MULTILINESTRING"))
+		wkbType_ = DmpWkbTypes::MultiLineString;
+	else if (!strcmp(geomtype, "POLYGON"))
+		wkbType_ = DmpWkbTypes::Polygon;
+	else if (!strcmp(geomtype, "MULTIPOLYGON"))
+		wkbType_ = DmpWkbTypes::MultiPolygon;
+	else if (!strcmp(geomtype, "GEOMETRY"))
+		wkbType_ = DmpWkbTypes::Unknown;
+	PQclear(pPGresult);
+	pPGresult = NULL;
 	PQfinish(pPGconn);
-  
-  return true;
-
-
-  providerKey_ = provider;
-  delete dataProvider_;
-  
-  dataProvider_ = dynamic_cast<DmpVectorDataProvider *>(DmpProviderRegistry::Instance(provider)->CreateProvider(provider, dataSource_));
-  if (!dataProvider_)
-  {
-    isValid_ = false;
-    return false;
-  }
-  isValid_ = dataProvider_->IsValid()
-  ;
-  if (!isValid_)
-  {
-    return false;
-  }
-  wkbType_ = dataProvider_->WkbType();
-  return true;
-}
 
-  shared_ptr<DmpVectorThinLayer> DmpVectorLayer::GetCurrentScaleTable(double dx)
+	return true;
+
+	providerKey_ = provider;
+	delete dataProvider_;
+
+	dataProvider_ = dynamic_cast<DmpVectorDataProvider *>(DmpProviderRegistry::Instance(provider)->CreateProvider(provider, dataSource_));
+	if (!dataProvider_)
 	{
-	  
-/*
+		isValid_ = false;
+		return false;
+	}
+	isValid_ = dataProvider_->IsValid();
+	if (!isValid_)
+	{
+		return false;
+	}
+	wkbType_ = dataProvider_->WkbType();
+	return true;
+}
+
+shared_ptr<DmpVectorThinLayer> DmpVectorLayer::GetCurrentScaleTable(double dx)
+{
+
+	/*
 		int outTime = 600;
 		if(this->dataCount >500000 && this->m_pDataset->m_MapLayerThinning.size() ==0)
 		{
@@ -272,14 +305,14 @@ bool DmpVectorLayer::setDataProvider(std::string const &provider)
 		}
 */
 
-		for(int i =0; i< this->thinLayers_.size(); i++)
-		{
-			shared_ptr<DmpVectorThinLayer> mapLayerThinning =  this->thinLayers_[i];
+	for (int i = 0; i < this->thinLayers_.size(); i++)
+	{
+		shared_ptr<DmpVectorThinLayer> mapLayerThinning = this->thinLayers_[i];
 
-			if(mapLayerThinning->IsCurrentLayer(dx))
-			{
-				return mapLayerThinning;
-			}
+		if (mapLayerThinning->IsCurrentLayer(dx))
+		{
+			return mapLayerThinning;
 		}
-		return nullptr;
-	}
\ No newline at end of file
+	}
+	return nullptr;
+}
\ No newline at end of file

@@ -61,6 +61,7 @@ class CORE_EXPORT DmpVectorLayer : public DmpMapLayer
     std::string  geom()  { return geom_;} 
     std::string  wherestr() { return wherestr_;} 
     std::string  GeomTypeString(){return wkbTypeString_;}
+    std::string  srid(){return  srid_;}
     size_t featurecount(){return featurecount_;}
     bool IsInit(){return isinit_;}
   private:
@@ -73,6 +74,7 @@ class CORE_EXPORT DmpVectorLayer : public DmpMapLayer
     std::string  geom_;
     size_t featurecount_;
     std::string wkbTypeString_;
+    std::string srid_;
 
     std::string wherestr_;
     bool isinit_ = false;

@@ -32,6 +32,7 @@ SET (DMAP_SERVER_SRCS
   dmpserverparameters.cpp
   dmpserverplugins.cpp
   dmpserverutils.cpp
+  dmpserverdes.cpp
   dmpserverloader.cpp
   dmpserverproject.cpp
   dmpserverregistry.cpp
@@ -62,6 +63,7 @@ SET (DMAP_SERVER_HDRS
   dmpserverparameters.h
   dmpserverplugins.h
   dmpserverutils.h
+  dmpserverdes.h
   dmpservice.h
   dmpservermodule.h
   dmpserverloader.h

@@ -10,7 +10,7 @@
 #include <iostream>
 #include "dmpserverconfig.h"
 #include "dmpapplication.h"
-
+#include "dmphttputils.h"
 DmpServerConfig::DmpServerConfig()
 {
     std::string iniFile = DmpApplication::Instance()->libexecPath() + iniFileName_;
@@ -82,4 +82,14 @@ std::string DmpServerConfig::getValue(const std::string &section,const std::stri
         std::cerr << "Exception: " << e.what() << "\n";
     }
     return value;
+}
+
+std::string DmpServerConfig::HttpPost(const std::string& url, std::string& postData)
+{
+    return DmpHttp::post(url, postData);
+}
+
+std::string DmpServerConfig::HttpGet(const std::string& url)
+{
+    return DmpHttp::get(url);
 }
\ No newline at end of file

@@ -22,6 +22,9 @@ public:
     std::string getPqsqlConnect();
     std::string getMetaUrl();
     std::string getValue(const std::string &section,const std::string &key);
+
+    std::string HttpPost(const std::string& url, std::string& postData);
+    std::string HttpGet(const std::string& url);
 private:
     DmpServerConfig();
     boost::property_tree::ptree ptIni_;

+/**************************************************************************
+* file:              dmpserverdes.cpp
+
+* Author:            qingxiongf
+* Date:              2022-01-13 19:20:30
+* Email:             qingxiongf@chinadci.com
+* copyright:         广州城市信息研究所有限公司
+***************************************************************************/
+#include "dmpserverdes.h"
+#include "dmpserverutils.h"
+
+//std::string RsaBase64Encrypt(const std::string &source, const char* key)
+//{
+//}
+
+std::string DmpServerDes::DesBase64Decrypt(const std::string &source, const char* key)
+{
+  //  char key[] = "Chinadci";
+    char decry[1000] = {0};
+    std::string decbase64_source;
+    if(!DmpServerUtils::Base64Decode(source, &decbase64_source))
+    {
+        return "";
+    }
+    int size = decbase64_source.size();
+    for(; size>0; size--)
+    {
+        if(decbase64_source[size-1] != 0)break;
+    }
+    DmpServerDes rsa2048;
+    rsa2048.Decrypt((unsigned char *)decbase64_source.c_str(), size, (unsigned char *)key, (unsigned char *)decry);
+    for (size_t i = 0; i < strlen(decry) && i < 1000; i++)
+    {
+        if (decry[i] == '\b')
+        {
+            decry[i] = '\0';
+            break;
+        }
+    }
+    return decry;
+}
+
+
+void DmpServerDes::generate_key(unsigned char *key)
+{
+    int i;
+    for (i = 0; i < 8; i++)
+    {
+        key[i] = rand() % 255;
+    }
+}
+
+void DmpServerDes::generate_sub_keys(unsigned char *main_key, key_set *key_sets)
+{
+    int initial_key_permutaion[] = {57, 49, 41, 33, 25, 17, 9,
+                                    1, 58, 50, 42, 34, 26, 18,
+                                    10, 2, 59, 51, 43, 35, 27,
+                                    19, 11, 3, 60, 52, 44, 36,
+                                    63, 55, 47, 39, 31, 23, 15,
+                                    7, 62, 54, 46, 38, 30, 22,
+                                    14, 6, 61, 53, 45, 37, 29,
+                                    21, 13, 5, 28, 20, 12, 4};
+
+    int key_shift_sizes[] = {-1, 1, 1, 2, 2, 2, 2, 2, 2, 1, 2, 2, 2, 2, 2, 2, 1};
+
+    int sub_key_permutation[] = {14, 17, 11, 24, 1, 5,
+                                 3, 28, 15, 6, 21, 10,
+                                 23, 19, 12, 4, 26, 8,
+                                 16, 7, 27, 20, 13, 2,
+                                 41, 52, 31, 37, 47, 55,
+                                 30, 40, 51, 45, 33, 48,
+                                 44, 49, 39, 56, 34, 53,
+                                 46, 42, 50, 36, 29, 32};
+
+    int i, j;
+    int shift_size;
+    unsigned char shift_byte, first_shift_bits, second_shift_bits, third_shift_bits, fourth_shift_bits;
+
+    memset(key_sets, 0, sizeof(key_set) * 17);
+    for (i = 0; i < 8; i++)
+    {
+        key_sets[0].k[i] = 0;
+    }
+
+    for (i = 0; i < 56; i++)
+    {
+        shift_size = initial_key_permutaion[i];
+        shift_byte = 0x80 >> ((shift_size - 1) % 8);
+        shift_byte &= main_key[(shift_size - 1) / 8];
+        shift_byte <<= ((shift_size - 1) % 8);
+
+        key_sets[0].k[i / 8] |= (shift_byte >> i % 8);
+    }
+
+    for (i = 0; i < 3; i++)
+    {
+        key_sets[0].c[i] = key_sets[0].k[i];
+    }
+
+    key_sets[0].c[3] = key_sets[0].k[3] & 0xF0;
+
+    for (i = 0; i < 3; i++)
+    {
+        key_sets[0].d[i] = (key_sets[0].k[i + 3] & 0x0F) << 4;
+        key_sets[0].d[i] |= (key_sets[0].k[i + 4] & 0xF0) >> 4;
+    }
+
+    key_sets[0].d[3] = (key_sets[0].k[6] & 0x0F) << 4;
+
+    for (i = 1; i < 17; i++)
+    {
+        for (j = 0; j < 4; j++)
+        {
+            key_sets[i].c[j] = key_sets[i - 1].c[j];
+            key_sets[i].d[j] = key_sets[i - 1].d[j];
+        }
+
+        shift_size = key_shift_sizes[i];
+        if (shift_size == 1)
+        {
+            shift_byte = 0x80;
+        }
+        else
+        {
+            shift_byte = 0xC0;
+        }
+
+        // Process C
+        first_shift_bits = shift_byte & key_sets[i].c[0];
+        second_shift_bits = shift_byte & key_sets[i].c[1];
+        third_shift_bits = shift_byte & key_sets[i].c[2];
+        fourth_shift_bits = shift_byte & key_sets[i].c[3];
+
+        key_sets[i].c[0] <<= shift_size;
+        key_sets[i].c[0] |= (second_shift_bits >> (8 - shift_size));
+
+        key_sets[i].c[1] <<= shift_size;
+        key_sets[i].c[1] |= (third_shift_bits >> (8 - shift_size));
+
+        key_sets[i].c[2] <<= shift_size;
+        key_sets[i].c[2] |= (fourth_shift_bits >> (8 - shift_size));
+
+        key_sets[i].c[3] <<= shift_size;
+        key_sets[i].c[3] |= (first_shift_bits >> (4 - shift_size));
+
+        // Process D
+        first_shift_bits = shift_byte & key_sets[i].d[0];
+        second_shift_bits = shift_byte & key_sets[i].d[1];
+        third_shift_bits = shift_byte & key_sets[i].d[2];
+        fourth_shift_bits = shift_byte & key_sets[i].d[3];
+
+        key_sets[i].d[0] <<= shift_size;
+        key_sets[i].d[0] |= (second_shift_bits >> (8 - shift_size));
+
+        key_sets[i].d[1] <<= shift_size;
+        key_sets[i].d[1] |= (third_shift_bits >> (8 - shift_size));
+
+        key_sets[i].d[2] <<= shift_size;
+        key_sets[i].d[2] |= (fourth_shift_bits >> (8 - shift_size));
+
+        key_sets[i].d[3] <<= shift_size;
+        key_sets[i].d[3] |= (first_shift_bits >> (4 - shift_size));
+
+        for (j = 0; j < 48; j++)
+        {
+            shift_size = sub_key_permutation[j];
+            if (shift_size <= 28)
+            {
+                shift_byte = 0x80 >> ((shift_size - 1) % 8);
+                shift_byte &= key_sets[i].c[(shift_size - 1) / 8];
+                shift_byte <<= ((shift_size - 1) % 8);
+            }
+            else
+            {
+                shift_byte = 0x80 >> ((shift_size - 29) % 8);
+                shift_byte &= key_sets[i].d[(shift_size - 29) / 8];
+                shift_byte <<= ((shift_size - 29) % 8);
+            }
+
+            key_sets[i].k[j / 8] |= (shift_byte >> j % 8);
+        }
+    }
+}
+
+void DmpServerDes::process_message(unsigned char *message_piece, unsigned char *processed_piece, key_set *key_sets, int mode)
+{
+
+    int initial_message_permutation[] = {58, 50, 42, 34, 26, 18, 10, 2,
+                                         60, 52, 44, 36, 28, 20, 12, 4,
+                                         62, 54, 46, 38, 30, 22, 14, 6,
+                                         64, 56, 48, 40, 32, 24, 16, 8,
+                                         57, 49, 41, 33, 25, 17, 9, 1,
+                                         59, 51, 43, 35, 27, 19, 11, 3,
+                                         61, 53, 45, 37, 29, 21, 13, 5,
+                                         63, 55, 47, 39, 31, 23, 15, 7};
+
+    int message_expansion[] = {32, 1, 2, 3, 4, 5,
+                               4, 5, 6, 7, 8, 9,
+                               8, 9, 10, 11, 12, 13,
+                               12, 13, 14, 15, 16, 17,
+                               16, 17, 18, 19, 20, 21,
+                               20, 21, 22, 23, 24, 25,
+                               24, 25, 26, 27, 28, 29,
+                               28, 29, 30, 31, 32, 1};
+    int S1[] = {14, 4, 13, 1, 2, 15, 11, 8, 3, 10, 6, 12, 5, 9, 0, 7,
+                0, 15, 7, 4, 14, 2, 13, 1, 10, 6, 12, 11, 9, 5, 3, 8,
+                4, 1, 14, 8, 13, 6, 2, 11, 15, 12, 9, 7, 3, 10, 5, 0,
+                15, 12, 8, 2, 4, 9, 1, 7, 5, 11, 3, 14, 10, 0, 6, 13};
+
+    int S2[] = {15, 1, 8, 14, 6, 11, 3, 4, 9, 7, 2, 13, 12, 0, 5, 10,
+                3, 13, 4, 7, 15, 2, 8, 14, 12, 0, 1, 10, 6, 9, 11, 5,
+                0, 14, 7, 11, 10, 4, 13, 1, 5, 8, 12, 6, 9, 3, 2, 15,
+                13, 8, 10, 1, 3, 15, 4, 2, 11, 6, 7, 12, 0, 5, 14, 9};
+
+    int S3[] = {10, 0, 9, 14, 6, 3, 15, 5, 1, 13, 12, 7, 11, 4, 2, 8,
+                13, 7, 0, 9, 3, 4, 6, 10, 2, 8, 5, 14, 12, 11, 15, 1,
+                13, 6, 4, 9, 8, 15, 3, 0, 11, 1, 2, 12, 5, 10, 14, 7,
+                1, 10, 13, 0, 6, 9, 8, 7, 4, 15, 14, 3, 11, 5, 2, 12};
+
+    int S4[] = {7, 13, 14, 3, 0, 6, 9, 10, 1, 2, 8, 5, 11, 12, 4, 15,
+                13, 8, 11, 5, 6, 15, 0, 3, 4, 7, 2, 12, 1, 10, 14, 9,
+                10, 6, 9, 0, 12, 11, 7, 13, 15, 1, 3, 14, 5, 2, 8, 4,
+                3, 15, 0, 6, 10, 1, 13, 8, 9, 4, 5, 11, 12, 7, 2, 14};
+
+    int S5[] = {2, 12, 4, 1, 7, 10, 11, 6, 8, 5, 3, 15, 13, 0, 14, 9,
+                14, 11, 2, 12, 4, 7, 13, 1, 5, 0, 15, 10, 3, 9, 8, 6,
+                4, 2, 1, 11, 10, 13, 7, 8, 15, 9, 12, 5, 6, 3, 0, 14,
+                11, 8, 12, 7, 1, 14, 2, 13, 6, 15, 0, 9, 10, 4, 5, 3};
+
+    int S6[] = {12, 1, 10, 15, 9, 2, 6, 8, 0, 13, 3, 4, 14, 7, 5, 11,
+                10, 15, 4, 2, 7, 12, 9, 5, 6, 1, 13, 14, 0, 11, 3, 8,
+                9, 14, 15, 5, 2, 8, 12, 3, 7, 0, 4, 10, 1, 13, 11, 6,
+                4, 3, 2, 12, 9, 5, 15, 10, 11, 14, 1, 7, 6, 0, 8, 13};
+
+    int S7[] = {4, 11, 2, 14, 15, 0, 8, 13, 3, 12, 9, 7, 5, 10, 6, 1,
+                13, 0, 11, 7, 4, 9, 1, 10, 14, 3, 5, 12, 2, 15, 8, 6,
+                1, 4, 11, 13, 12, 3, 7, 14, 10, 15, 6, 8, 0, 5, 9, 2,
+                6, 11, 13, 8, 1, 4, 10, 7, 9, 5, 0, 15, 14, 2, 3, 12};
+
+    int S8[] = {13, 2, 8, 4, 6, 15, 11, 1, 10, 9, 3, 14, 5, 0, 12, 7,
+                1, 15, 13, 8, 10, 3, 7, 4, 12, 5, 6, 11, 0, 14, 9, 2,
+                7, 11, 4, 1, 9, 12, 14, 2, 0, 6, 10, 13, 15, 3, 5, 8,
+                2, 1, 14, 7, 4, 10, 8, 13, 15, 12, 9, 0, 3, 5, 6, 11};
+
+    int right_sub_message_permutation[] = {16, 7, 20, 21,
+                                           29, 12, 28, 17,
+                                           1, 15, 23, 26,
+                                           5, 18, 31, 10,
+                                           2, 8, 24, 14,
+                                           32, 27, 3, 9,
+                                           19, 13, 30, 6,
+                                           22, 11, 4, 25};
+    int final_message_permutation[] = {40, 8, 48, 16, 56, 24, 64, 32,
+                                       39, 7, 47, 15, 55, 23, 63, 31,
+                                       38, 6, 46, 14, 54, 22, 62, 30,
+                                       37, 5, 45, 13, 53, 21, 61, 29,
+                                       36, 4, 44, 12, 52, 20, 60, 28,
+                                       35, 3, 43, 11, 51, 19, 59, 27,
+                                       34, 2, 42, 10, 50, 18, 58, 26,
+                                       33, 1, 41, 9, 49, 17, 57, 25};
+    int i, k;
+    int shift_size;
+    unsigned char shift_byte;
+
+    unsigned char initial_permutation[8];
+    memset(initial_permutation, 0, 8);
+    memset(processed_piece, 0, 8);
+
+    for (i = 0; i < 64; i++)
+    {
+        shift_size = initial_message_permutation[i];
+        shift_byte = 0x80 >> ((shift_size - 1) % 8);
+        shift_byte &= message_piece[(shift_size - 1) / 8];
+        shift_byte <<= ((shift_size - 1) % 8);
+
+        initial_permutation[i / 8] |= (shift_byte >> i % 8);
+    }
+
+    unsigned char l[4], r[4];
+    for (i = 0; i < 4; i++)
+    {
+        l[i] = initial_permutation[i];
+        r[i] = initial_permutation[i + 4];
+    }
+
+    unsigned char ln[4], rn[4], er[6], ser[4];
+
+    int key_index;
+    for (k = 1; k <= 16; k++)
+    {
+        memcpy(ln, r, 4);
+
+        memset(er, 0, 6);
+
+        for (i = 0; i < 48; i++)
+        {
+            shift_size = message_expansion[i];
+            shift_byte = 0x80 >> ((shift_size - 1) % 8);
+            shift_byte &= r[(shift_size - 1) / 8];
+            shift_byte <<= ((shift_size - 1) % 8);
+
+            er[i / 8] |= (shift_byte >> i % 8);
+        }
+
+        if (mode == DECRYPTION_MODE)
+        {
+            key_index = 17 - k;
+        }
+        else
+        {
+            key_index = k;
+        }
+
+        for (i = 0; i < 6; i++)
+        {
+            er[i] ^= key_sets[key_index].k[i];
+        }
+
+        unsigned char row, column;
+
+        for (i = 0; i < 4; i++)
+        {
+            ser[i] = 0;
+        }
+
+        // 0000 0000 0000 0000 0000 0000
+        // rccc crrc cccr rccc crrc cccr
+
+        // Byte 1
+        row = 0;
+        row |= ((er[0] & 0x80) >> 6);
+        row |= ((er[0] & 0x04) >> 2);
+
+        column = 0;
+        column |= ((er[0] & 0x78) >> 3);
+
+        ser[0] |= ((unsigned char)S1[row * 16 + column] << 4);
+
+        row = 0;
+        row |= (er[0] & 0x02);
+        row |= ((er[1] & 0x10) >> 4);
+
+        column = 0;
+        column |= ((er[0] & 0x01) << 3);
+        column |= ((er[1] & 0xE0) >> 5);
+
+        ser[0] |= (unsigned char)S2[row * 16 + column];
+
+        // Byte 2
+        row = 0;
+        row |= ((er[1] & 0x08) >> 2);
+        row |= ((er[2] & 0x40) >> 6);
+
+        column = 0;
+        column |= ((er[1] & 0x07) << 1);
+        column |= ((er[2] & 0x80) >> 7);
+
+        ser[1] |= ((unsigned char)S3[row * 16 + column] << 4);
+
+        row = 0;
+        row |= ((er[2] & 0x20) >> 4);
+        row |= (er[2] & 0x01);
+
+        column = 0;
+        column |= ((er[2] & 0x1E) >> 1);
+
+        ser[1] |= (unsigned char)S4[row * 16 + column];
+
+        // Byte 3
+        row = 0;
+        row |= ((er[3] & 0x80) >> 6);
+        row |= ((er[3] & 0x04) >> 2);
+
+        column = 0;
+        column |= ((er[3] & 0x78) >> 3);
+
+        ser[2] |= ((unsigned char)S5[row * 16 + column] << 4);
+
+        row = 0;
+        row |= (er[3] & 0x02);
+        row |= ((er[4] & 0x10) >> 4);
+
+        column = 0;
+        column |= ((er[3] & 0x01) << 3);
+        column |= ((er[4] & 0xE0) >> 5);
+
+        ser[2] |= (unsigned char)S6[row * 16 + column];
+
+        // Byte 4
+        row = 0;
+        row |= ((er[4] & 0x08) >> 2);
+        row |= ((er[5] & 0x40) >> 6);
+
+        column = 0;
+        column |= ((er[4] & 0x07) << 1);
+        column |= ((er[5] & 0x80) >> 7);
+
+        ser[3] |= ((unsigned char)S7[row * 16 + column] << 4);
+
+        row = 0;
+        row |= ((er[5] & 0x20) >> 4);
+        row |= (er[5] & 0x01);
+
+        column = 0;
+        column |= ((er[5] & 0x1E) >> 1);
+
+        ser[3] |= (unsigned char)S8[row * 16 + column];
+
+        for (i = 0; i < 4; i++)
+        {
+            rn[i] = 0;
+        }
+
+        for (i = 0; i < 32; i++)
+        {
+            shift_size = right_sub_message_permutation[i];
+            shift_byte = 0x80 >> ((shift_size - 1) % 8);
+            shift_byte &= ser[(shift_size - 1) / 8];
+            shift_byte <<= ((shift_size - 1) % 8);
+
+            rn[i / 8] |= (shift_byte >> i % 8);
+        }
+
+        for (i = 0; i < 4; i++)
+        {
+            rn[i] ^= l[i];
+        }
+
+        for (i = 0; i < 4; i++)
+        {
+            l[i] = ln[i];
+            r[i] = rn[i];
+        }
+    }
+
+    unsigned char pre_end_permutation[8];
+    for (i = 0; i < 4; i++)
+    {
+        pre_end_permutation[i] = r[i];
+        pre_end_permutation[4 + i] = l[i];
+    }
+
+    for (i = 0; i < 64; i++)
+    {
+        shift_size = final_message_permutation[i];
+        shift_byte = 0x80 >> ((shift_size - 1) % 8);
+        shift_byte &= pre_end_permutation[(shift_size - 1) / 8];
+        shift_byte <<= ((shift_size - 1) % 8);
+
+        processed_piece[i / 8] |= (shift_byte >> i % 8);
+    }
+}
+
+void DmpServerDes::copyUChar(unsigned char *data_block, unsigned char *source, int loc, int num)
+{
+    int i;
+    for (i = 0; i < num; i++)
+    {
+        data_block[i] = source[loc + i];
+    }
+}
+
+bool DmpServerDes::Encrypt(unsigned char *source, unsigned char *des_key, unsigned char *destination)
+{
+
+    // Generate DES key set*******************************************
+    int padding;
+    int block_count = 0, number_of_blocks;
+
+    unsigned char data_block[8];
+    unsigned char processed_block[8];
+    key_set *key_sets = (key_set *)malloc(17 * sizeof(key_set));
+
+    generate_sub_keys(des_key, key_sets);
+    // Generate DES key set*******************************************
+
+    int length = strlen((const char *)source);
+    number_of_blocks = length / 8 + ((length % 8) ? 1 : 0);
+
+    // Start read source word, encrypt to destination
+    for (int i = 0; i < length; i += 8)
+    {
+
+        block_count++;
+
+        if (block_count == number_of_blocks)
+        {
+            padding = 8 - length % 8;
+
+            copyUChar(data_block, source, i, 8 - padding);
+            if (padding < 8)
+            { // Fill empty data block bytes with padding
+                memset((data_block + 8 - padding), (unsigned char)padding, padding);
+            }
+            else if (padding == 8)
+            { // Write an extra block for padding
+                copyUChar(data_block, source, i, 8);
+            }
+        }
+        else
+        {
+            copyUChar(data_block, source, i, 8);
+        }
+
+        process_message(data_block, processed_block, key_sets, ENCRYPTION_MODE);
+        memcpy(destination + i, &processed_block, 8 * sizeof(char));
+
+        memset(data_block, 0, 8);
+    }
+
+    // Free up memory
+    free(key_sets);
+
+    return true;
+}
+
+bool DmpServerDes::Decrypt(unsigned char *source, int length, unsigned char *key, unsigned char *destination)
+{
+
+    // Generate DES key set*******************************************
+    int padding;
+    int block_count = 0, number_of_blocks;
+
+    unsigned char data_block[8];
+    unsigned char processed_block[8];
+    key_set *key_sets = (key_set *)malloc(17 * sizeof(key_set));
+
+    generate_sub_keys(key, key_sets);
+    // Generate DES key set*******************************************
+
+    //int length = strlen((const char*)source);
+    number_of_blocks = length / 8 + ((length % 8) ? 1 : 0);
+
+    // Start read source word
+    for (int i = 0; i < length; i += 8)
+    {
+
+        block_count++;
+
+        if (block_count == number_of_blocks)
+        {
+            copyUChar(data_block, source, i, 8);
+            process_message(data_block, processed_block, key_sets, DECRYPTION_MODE);
+            padding = processed_block[7];
+
+            if (padding < 8)
+            {
+                memcpy(destination + i, &processed_block, (8 - padding) * sizeof(char));
+            }
+            else
+            {
+                memcpy(destination + i, &processed_block, 8 * sizeof(char));
+            }
+        }
+        else
+        {
+            copyUChar(data_block, source, i, 8);
+            process_message(data_block, processed_block, key_sets, DECRYPTION_MODE);
+            memcpy(destination + i, &processed_block, 8 * sizeof(char));
+        }
+
+        memset(data_block, 0, 8);
+    }
+
+    // Free up memory
+    free(key_sets);
+
+    return true;
+}

+/**************************************************************************
+* file:              dmpserverdes.h
+
+* Author:            qingxiongf
+* Date:              2022-01-13 19:20:26
+* Email:             qingxiongf@chinadci.com
+* copyright:         广州城市信息研究所有限公司
+***************************************************************************/
+
+#ifndef __dmpserverdes_h__
+#define __dmpserverdes_h__
+#include "dmap_server.h"
+#include <boost/filesystem.hpp>
+#include <unordered_map>
+
+#define ENCRYPTION_MODE 1
+#define DECRYPTION_MODE 0
+
+class SERVER_EXPORT DmpServerDes
+{
+public:
+    typedef struct
+    {
+        unsigned char k[8];
+        unsigned char c[4];
+        unsigned char d[4];
+    } key_set;
+
+    bool Encrypt(unsigned char *source, unsigned char *des_key, unsigned char *destination);
+    bool Decrypt(unsigned char *source, int length, unsigned char *key, unsigned char *destination);
+
+   // static std::string RsaBase64Encrypt(const std::string &source, const char* key);
+    static std::string DesBase64Decrypt(const std::string &source, const char* key);
+
+private:
+    void generate_key(unsigned char *key);
+    void generate_sub_keys(unsigned char *main_key, key_set *key_sets);
+    void process_message(unsigned char *message_piece, unsigned char *processed_piece, key_set *key_sets, int mode);
+    void copyUChar(unsigned char *data_block, unsigned char *source, int loc, int num);
+};
+
+#endif // __dmpserverdes_h__

@@ -7,7 +7,14 @@
 * copyright:         广州城市信息研究所有限公司
 ***************************************************************************/
 #include "dmpmapserverutil.h"
-#include <string.h>
+#include <iostream>
+#include <istream>
+#include <ostream>
+#include <string>
+#include <boost/asio.hpp>
+
+
+using boost::asio::ip::tcp;
 
 namespace mapserver
 { 
@@ -281,4 +288,143 @@ void DmpMapServerUtil::responseGeojson(shared_ptr<DmpPgsql> pPgsqlConn, std::str
 		return stringList;
 		
 	}
+
+
+	int DmpMapServerUtil::HttpPost(const std::string& url, std::string& postData, std::string &reponse_data)
+	{
+        string host, port,path;
+		const std::string &http_ = "http://";
+		const std::string &https_ = "https://";
+		std::string temp_data = url;
+		if (temp_data.find(http_) == 0)
+		{
+			temp_data = temp_data.substr(http_.length());
+		}
+		else if (temp_data.find(https_) == 0)
+		{
+			temp_data = temp_data.substr(https_.length());
+		}
+		else
+		{
+			return 500;
+		}
+		// 解析域名
+		std::size_t idx = temp_data.find('/');
+		// 解析 域名后的page
+		if (std::string::npos == idx)
+		{
+			path = "/";
+			idx = temp_data.size();
+		}
+		else
+		{
+			path = temp_data.substr(idx);
+		}
+		// 解析域名
+		host = temp_data.substr(0, idx);
+		// 解析端口
+		idx = host.find(':');
+		if (std::string::npos == idx)
+		{
+			port = "80";
+		}
+		else
+		{
+			port = host.substr(idx + 1);
+			host = host.substr(0, idx);
+		}
+
+
+		try
+		{
+			boost::asio::io_service io_service;
+			//如果io_service存在复用的情况
+			if (io_service.stopped())
+				io_service.reset();
+
+			// 从dns取得域名下的所有ip
+			tcp::resolver resolver(io_service);
+			tcp::resolver::query query(host, port);
+			tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
+
+			// 尝试连接到其中的某个ip直到成功
+			tcp::socket socket(io_service);
+			boost::asio::connect(socket, endpoint_iterator);
+
+			// Form the request. We specify the "Connection: close" header so that the
+			// server will close the socket after transmitting the response. This will
+			// allow us to treat all data up until the EOF as the content.
+			boost::asio::streambuf request;
+			std::ostream request_stream(&request);
+			request_stream << "POST " << path.c_str() << " HTTP/1.0\r\n";
+			request_stream << "Host: " << host << ":" << port << "\r\n";
+			request_stream << "Accept: */*\r\n";
+			request_stream << "Content-Length: " << postData.length() << "\r\n";
+			request_stream << "Content-Type: application/x-www-form-urlencoded\r\n";
+			request_stream << "Connection: close\r\n\r\n";
+			request_stream << postData.c_str();
+
+			// Send the request.
+			boost::asio::write(socket, request);
+
+			// Read the response status line. The response streambuf will automatically
+			// grow to accommodate the entire line. The growth may be limited by passing
+			// a maximum size to the streambuf constructor.
+			boost::asio::streambuf response;
+			boost::asio::read_until(socket, response, "\r\n");
+
+			// Check that response is OK.
+			std::istream response_stream(&response);
+			std::string http_version;
+			response_stream >> http_version;
+			unsigned int status_code;
+			response_stream >> status_code;
+			std::string status_message;
+			std::getline(response_stream, status_message);
+			if (!response_stream || http_version.substr(0, 5) != "HTTP/")
+			{
+				reponse_data = "Invalid response";
+				return -2;
+			}
+			// 如果服务器返回非200都认为有错,不支持301/302等跳转
+			if (status_code != 200)
+			{
+				reponse_data = "Response returned with status code != 200 ";
+				return status_code;
+			}
+
+			// 传说中的包头可以读下来了
+			std::string header;
+			std::vector<string> headers;
+			while (std::getline(response_stream, header) && header != "\r")
+				headers.push_back(header);
+
+			// 读取所有剩下的数据作为包体
+			boost::system::error_code error;
+			while (boost::asio::read(socket, response,
+									 boost::asio::transfer_at_least(1), error))
+			{
+			}
+
+			//响应有数据
+			if (response.size())
+			{
+				std::istream response_stream(&response);
+				std::istreambuf_iterator<char> eos;
+				reponse_data = string(std::istreambuf_iterator<char>(response_stream), eos);
+			}
+
+			if (error != boost::asio::error::eof)
+			{
+				reponse_data = error.message();
+				return -3;
+			}
+		}
+		catch (std::exception &e)
+		{
+			reponse_data = e.what();
+			return -4;
+		}
+		return 0;
+	}
 }
\ No newline at end of file

@@ -14,6 +14,7 @@
 #include <memory>
 #include "dmppgsqlsourcepools.h"
 
+
 namespace mapserver 
 {
     class DmpMapServerUtil
@@ -25,6 +26,8 @@ namespace mapserver
         static std::string replace(std::string strsrc, std::string strfind, std::string strrep);
 
         static std::vector<std::string> stringSplit(const std::string &str, const std::string &pattern);
+
+        static int HttpPost(const std::string& url, std::string& postData, std::string& responseData );
     };
 }
 

@@ -13,8 +13,11 @@
 #define MAX_SIZE 40
 namespace mapserver
 {
-	DmpPgsqlPool::DmpPgsqlPool()
+	DmpPgsqlPool::DmpPgsqlPool(const std::string& guid,const std::string& name, const std::string& alias)
 	{
+		guid_ = guid;
+		name_ = name;
+		alias_ = alias;
 		waitConnectSize_ = MAX_SIZE;
 		connectionTimeout_ = 15000;
 	}

@@ -19,42 +19,42 @@
 namespace mapserver
 {
 	class DmpPgsqlPool
-	{		
-public:
-		DmpPgsqlPool();
+	{
+	public:
+		DmpPgsqlPool(const std::string& guid,const std::string& name, const std::string& alias);
 		~DmpPgsqlPool();
-	    void ScannerConnectionTask();
+		void ScannerConnectionTask();
 		std::shared_ptr<DmpPgsql> TestDmpPgsql(void);
-        std::shared_ptr<DmpPgsql> GetPgsqlConn(void);
-		void ReleaseHandle(DmpPgsql*);
+		std::shared_ptr<DmpPgsql> GetPgsqlConn(void);
+		void ReleaseHandle(DmpPgsql *);
 
 		void Close(void);
-		bool Connect(const char * s);
-		DmpPgsql* GetConnect();
-        std::string guid()const { return guid_;} 
-	    std::string name()const { return name_;} 
-	    std::string alias()const{ return alias_;} 
-
-private:
-        std::string conninfo_;
+		bool Connect(const char *s);
+		DmpPgsql *GetConnect();
+		std::string guid() const { return guid_; }
+		std::string name() const { return name_; }
+		std::string alias() const { return alias_; }
+
+
+
+	private:
+		std::string conninfo_;
 		// 存储连接的队列
-        queue<DmpPgsql*> connectionQue_;
+		queue<DmpPgsql *> connectionQue_;
 		int waitConnectSize_;
 		int connectSize_ = 0;
 		mutex mutex_;
 		//连接超时时间
-		int connectionTimeout_;  
-
-      // 设置条件变量，用于连接生产线程和连接消费线程的通信
-       condition_variable cv_;
-	   bool isClose_ = false;
-       std::string guid_;
-	   std::string name_;
-	   std::string alias_;
+		int connectionTimeout_;
+
+		// 设置条件变量，用于连接生产线程和连接消费线程的通信
+		condition_variable cv_;
+		bool isClose_ = false;
+		std::string guid_;
+		std::string name_;
+		std::string alias_;
 	};
-	
-}
 
+}
 
 #endif //__dmppgsqlpool_h__
-

@@ -11,6 +11,13 @@
 #include <iostream>
 #include "dmphttpbase.h"
 #include "dmphttputils.h"
+#include "dmpmapserverutil.h"
+#include "dmpserverutils.h"
+#include "dmpserverdes.h"
+#include <boost/property_tree/ptree.hpp> 
+#include <boost/property_tree/json_parser.hpp> 
+#include <boost/typeof/typeof.hpp>
+
 //#include "DES.h"
 //#include "StringHelp.h"
 
@@ -168,22 +175,7 @@ namespace mapserver
         return "";
     }
 
-    string DmpPgsqlSourcePools::GetDbsource(const string& serviceid)
-    {
-        string requestUrl = DmpServerConfig::Instance()->getMetaUrl();
-        if(requestUrl.size() >0 && requestUrl[requestUrl.size() -1] !='/')
-        {
-            requestUrl += "/";
-        }   
-        requestUrl.append("API/Database/Detail");
-
-        std::string strContent= DmpHttp::post(requestUrl);
-        if(strContent.length()==0)
-        {
-           return "";
-        }
-        return requestUrl;
-    }
+ 
 
 
     bool DmpPgsqlSourcePools::UpdateDatabasePool()
@@ -339,13 +331,6 @@ namespace mapserver
            string alias = pPgsqlConn->getString(2);
            string uri = pPgsqlConn->getString(3);
            string connectstr = pPgsqlConn->getString(4);
-          /* if(guid == "74c73a18-00c9-11ec-aced-0242ac110002")
-           {
-               continue;
-           }*/
-
-           
-
            string pgConnect= "";
            if(connectstr != "")
            {
@@ -460,25 +445,93 @@ namespace mapserver
 
     bool DmpPgsqlSourcePools::CreateDefaultDatabasePool(string dataType, string connStr)
     {
-        shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool());
+        shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool("","",""));
         defaultPool_ = newPool;
         bool result = defaultPool_->Connect(connStr.c_str());
-      
+
         return true;
     }
 
-      bool DmpPgsqlSourcePools::AddDatabasePool(string guid)
+    bool DmpPgsqlSourcePools::AddDatabasePool(string guid)
     {
-       
-        shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool());
-       // newPool->guid() = guid;
-        //  newPool->m_name = databaseName;
-        //  newPool->m_alias = alias;
-        std::string connStr = this->GetDbsource(guid);
-        newPool->Connect(connStr.c_str());
-         //newPool->Connect("PostgreSQLConn=hostaddr=172.26.99.173 port=5433 dbname='postgres' user='postgres' password='chinadci'");
-        pgsqlPool_[guid] = newPool;
-        return true;
+        if (guid.find(" ") != string::npos && guid.size() > 50)
+        {
+            std::string connStr = guid;
+            shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool(guid,guid,guid));
+            newPool->Connect(connStr.c_str());
+            //newPool->Connect("PostgreSQLConn=hostaddr=172.26.99.173 port=5433 dbname='postgres' user='postgres' password='chinadci'");
+            pgsqlPool_[guid] = newPool;
+            return true;
+        }
+        else
+        {
+            string requestUrl = DmpServerConfig::Instance()->getMetaUrl();
+            if (requestUrl.size() > 0 && requestUrl[requestUrl.size() - 1] != '/')
+            {
+                requestUrl += "/";
+            }
+            requestUrl.append("API/Database/Detail?guid=");
+            requestUrl.append(guid);
+            std::string reponse_data = DmpServerConfig::Instance()->HttpGet(requestUrl);
+            if (!reponse_data.empty())
+            {
+                try
+                {
+                    std::stringstream stream(reponse_data);
+                    boost::property_tree::ptree pt;
+                    boost::property_tree::read_json(stream, pt);
+                    std::string name = pt.get<std::string>("data.name");
+                    std::string alias = pt.get<std::string>("data.alias");
+                    std::string sqlalchemy_uri_base64 = pt.get<std::string>("data.connectstr");
+                    std::string sqlalchemy_uri = DmpServerDes::DesBase64Decrypt(sqlalchemy_uri_base64, "Chinadci");
+
+                    shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool(guid,name,alias));
+                    if (newPool->Connect(sqlalchemy_uri.c_str()))
+                    {
+                        pgsqlPool_[guid] = newPool;
+                        return true;
+                    }
+                  
+                }
+                catch (...)
+                {
+                    return false;
+                }
+            }
+        }
+        return false;
+    }
+
+    string DmpPgsqlSourcePools::GetDbsource(const string& serviceid)
+    {
+        string requestUrl = DmpServerConfig::Instance()->getMetaUrl();
+        if (requestUrl.size() > 0 && requestUrl[requestUrl.size() - 1] != '/')
+        {
+            requestUrl += "/";
+        }
+        requestUrl.append("API/Database/Detail?guid=");
+        requestUrl.append(serviceid);
+        std::string reponse_data = DmpServerConfig::Instance()->HttpGet(requestUrl);
+        if (!reponse_data.empty())
+        {
+            try
+            {
+                std::stringstream stream(reponse_data);
+                boost::property_tree::ptree pt;
+                boost::property_tree::read_json(stream, pt);
+                std::string name = pt.get<std::string>("data.name");
+                std::string alias = pt.get<std::string>("data.alias");
+                std::string sqlalchemy_uri_base64 = pt.get<std::string>("data.connectstr");
+                std::string sqlalchemy_uri = DmpServerDes::DesBase64Decrypt(sqlalchemy_uri_base64, "Chinadci");
+
+                return sqlalchemy_uri;
+            }
+            catch (...)
+            {
+                return "";
+            }
+        }
+        return "";
     }
 
     bool DmpPgsqlSourcePools::AddDatabasePool(string dataType,
@@ -488,7 +541,7 @@ namespace mapserver
                                           string connStr)
     {
        
-        shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool());
+        shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool(guid,databaseName,alias));
        // newPool->guid() = guid;
         //  newPool->m_name = databaseName;
         //  newPool->m_alias = alias;
@@ -502,7 +555,7 @@ namespace mapserver
      {
          if(pgsqlPool_.find(guid) == pgsqlPool_.end())
          {
-            shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool());
+            shared_ptr<DmpPgsqlPool> newPool(new DmpPgsqlPool(guid,databaseName,alias));
            // newPool->guid() = guid;
            // newPool->m_name = databaseName;
            // newPool->m_alias = alias;

@@ -7,7 +7,6 @@
 * copyright:         广州城市信息研究所有限公司
 ***************************************************************************/
 
-
 #ifndef __dmppgsqlsourcepools_h__
 #define __dmppgsqlsourcepools_h__
 
@@ -22,50 +21,47 @@
 
 namespace mapserver
 {
-    class DmpPgsqlPool;
-    class DmpPgsqlSourcePools
-    {
-    public:
-
-        DmpPgsqlSourcePools();
-        ~DmpPgsqlSourcePools();
-        static DmpPgsqlSourcePools* get_instance();
+  class DmpPgsqlPool;
+  class DmpPgsqlSourcePools
+  {
+  public:
+    DmpPgsqlSourcePools();
+    ~DmpPgsqlSourcePools();
+    static DmpPgsqlSourcePools *get_instance();
 
-        //获取默认数据库连接
-        shared_ptr<DmpPgsql> GetDefaultPgsqlConn();
+    //获取默认数据库连接
+    shared_ptr<DmpPgsql> GetDefaultPgsqlConn();
 
-        //获取数据库连接
-        shared_ptr<DmpPgsql> GetPgsqlConn(const string& name);
+    //获取数据库连接
+    shared_ptr<DmpPgsql> GetPgsqlConn(const string &name);
 
-       // shared_ptr<DmpPgsql> GetPgsqlConn(char* name);
+    // shared_ptr<DmpPgsql> GetPgsqlConn(char* name);
 
-        string GetDbSourceID(string name);
+    string GetDbSourceID(string name);
 
-        string GetDbsource(const string& serviceid);
+    string GetDbsource(const string& serviceid);
 
+    bool InitDatabasePool();
 
-        bool InitDatabasePool();
+    bool UpdateDatabasePool();
+    //创建默认数据库连接池
+    bool CreateDefaultDatabasePool(string dataType, string connStr);
+    // 添加数据库连接池
+    bool AddDatabasePool(string dataType, string guid, string databaseName, string alias, string connStr);
+    // Update 数据库连接池
+    bool UpdDatabasePool(string dataType, string guid, string databaseName, string alias, string connStr);
 
-        bool UpdateDatabasePool();
-        //创建默认数据库连接池
-        bool CreateDefaultDatabasePool(string dataType, string connStr);
-        // 添加数据库连接池
-        bool AddDatabasePool(string dataType, string guid, string databaseName, string alias, string connStr);
-        // Update 数据库连接池
-        bool UpdDatabasePool(string dataType, string guid, string databaseName, string alias, string connStr);
+    bool AddDatabasePool(string guid);
 
-        bool AddDatabasePool(string guid);
-      private:
-        shared_ptr<DmpPgsqlPool> defaultPool_;
-        map<string, shared_ptr<DmpPgsqlPool>> pgsqlPool_;
-        bool updateLock_ = false;
+  private:
+    shared_ptr<DmpPgsqlPool> defaultPool_;
+    map<string, shared_ptr<DmpPgsqlPool>> pgsqlPool_;
+    bool updateLock_ = false;
 
-     private:
-       mutex mutex_;
-       static DmpPgsqlSourcePools* instance_ptr;
-    };
+  private:
+    mutex mutex_;
+    static DmpPgsqlSourcePools *instance_ptr;
+  };
 }
 
-
 #endif //__dmppgsqlsourcepools_h__
-

@@ -58,16 +58,6 @@ namespace DmpMapping
     {
       editService(context, vectorMappingProjects_);
     }
-    else if (boost::iequals(request, "getmap"))
-    {
-      const std::string mapGuid = params.MapGuid();
-      if(vectorMappingProjects_.find(mapGuid) != vectorMappingProjects_.end())
-      {
-          shared_ptr<DmpProject> project = vectorMappingProjects_.find(mapGuid)->second;
-          const DmpWms::DmpWmsParameters wmsParams(context.request()->serverParameters());
-          DmpWms::writeGetMap(context, wmsParams, project.get());
-      }
-    }
     else if (boost::iequals(request,"gettypefacelist")) {
        getTypefaceList(context);
     }
@@ -80,6 +70,57 @@ namespace DmpMapping
     else if (boost::iequals(request,"getimage")) {
        getImage(context);
     }
+    else if (boost::iequals(request, "getmap"))
+    {
+      const std::string mapGuid = params.MapGuid();
+      if (vectorMappingProjects_.find(mapGuid) != vectorMappingProjects_.end())
+      {
+        shared_ptr<DmpProject> project = vectorMappingProjects_.find(mapGuid)->second;
+        const DmpWms::DmpWmsParameters wmsParams(context.request()->serverParameters());
+        DmpWms::writeGetMap(context, wmsParams, project.get());
+      }
+      else
+      {
+        writeLock(rwmutex_);
+        if (vectorMappingProjects_.find(mapGuid) != vectorMappingProjects_.end())
+        {
+          shared_ptr<DmpProject> project = vectorMappingProjects_.find(mapGuid)->second;
+          const DmpWms::DmpWmsParameters wmsParams(context.request()->serverParameters());
+          DmpWms::writeGetMap(context, wmsParams, project.get());
+        }
+        else
+        {
+          std::string mapRenderer = params.MapRenderer();
+          if (!mapRenderer.empty())
+          {
+            std::string projData;
+            for(int i = 0; i< mapRenderer.size(); i++)
+            {
+                if(mapRenderer[i] == ' ')mapRenderer[i]= '+';
+            }
+            if (!DmpServerUtils::Base64Decode(mapRenderer, &projData))
+            {
+              context.response()->writeJson("{\"status\":\"false\",\"message\":\""+ mapRenderer +"  base64转码错误\"}");
+              return;
+            }
+            shared_ptr<DmpProject> project(new DmpProject());
+            if (!project->Read(projData))
+            {
+              context.response()->writeJson("{\"status\":\"false\",\"message\":\"DMD文档错误\"}");
+              return;
+            }
+            const DmpWms::DmpWmsParameters wmsParams(context.request()->serverParameters());
+            DmpWms::writeGetMap(context, wmsParams, project.get());
+            if(!mapGuid.empty())
+            {
+              vectorMappingProjects_[mapGuid] = project;
+            }
+            return;
+          }
+        }
+      }
+    }
+   
   }
 
 

@@ -12,6 +12,12 @@
 #include <string>
 #include "dmpeditservice.h"
 #include "dmpservice.h"
+#include <boost/thread/shared_mutex.hpp>
+#include <boost/thread.hpp>
+
+typedef boost::shared_mutex rwmutex;
+typedef boost::shared_lock<rwmutex> readLock;
+typedef boost::unique_lock<rwmutex> writeLock;
 namespace DmpMapping
 {
     class DmpMappingService : public DmpService
@@ -28,6 +34,7 @@ namespace DmpMapping
        
     //存储工程文档实例
        ProjectMap vectorMappingProjects_;
+       rwmutex rwmutex_;
     };
 }
 

@@ -104,4 +104,11 @@ namespace DmpMapping
         return value;
     }
 
+    std::string DmpMappingParameters::MapRenderer() const
+    {
+        std::string value = "";
+        GetStringParameter("MapRenderer", value);
+        return value;
+    }
+
 } // namespace DmpWms
\ No newline at end of file

@@ -25,6 +25,7 @@ namespace DmpMapping
 
         std::string Map() const; 
         std::string MapGuid() const; 
+        std::string MapRenderer() const;
 
     private:
         bool GetStringParameter(const char* key, std::string &value) const;

@@ -72,9 +72,14 @@ namespace DmpWms
 			mapRenderer.SetExtent(rect);
 			string responseData;
 			mapRenderer.GetFeatureInfo(responseData, x, y, featureCount);
-			context.response()->removeHeader("Content-Type");
-			context.response()->setHeader("Content-Type", "image/png");
-			context.response()->write(responseData);
+			if(responseData.empty())
+			{
+				context.response()->writeJson("null");
+			}
+			else
+			{
+				context.response()->writeJson(responseData);
+			}
 			return "";
 		}
 		catch (const std::exception &e)

@@ -522,7 +522,7 @@ ST_GeometryFromText('POLYGON((%f %f, %f %f,  %f %f, %f %f,  %f %f))',%s),\
 					else if (typeString == "integer")
 					{
 						typeInt = PGFieldType::BigIntFieldType;
-						fields_str += " \"" + (fieldname) + "\" ";
+						fields_str += " \"" + (fieldname) + "\"::varchar ";
 					}
 					else if (typeString == "bigint")
 					{
@@ -532,7 +532,7 @@ ST_GeometryFromText('POLYGON((%f %f, %f %f,  %f %f, %f %f,  %f %f))',%s),\
 					else if (typeString == "double precision" || typeString == "real" || typeString == "numeric")
 					{
 						typeInt = PGFieldType::DoubleFieldType;
-						fields_str += " \"" + (fieldname) + "\" ";
+						fields_str += " \"" + (fieldname) + "\"::varchar ";
 					}
 					else if (typeString == "character varying" || typeString == "text")
 					{
@@ -572,7 +572,7 @@ ST_GeometryFromText('POLYGON((%f %f, %f %f,  %f %f, %f %f,  %f %f))',%s),\
 
 		string shapeName = layer->geom();
 		sql += format(" ST_DWithin(\"%s\", ST_GeometryFromText('POINT(%f %f)',%s), %f) limit %d ",
-					  shapeName.c_str(), x, y, layer->crs().srid(), dis, feature_count);
+					  shapeName.c_str(), x, y, layer->srid().c_str(), dis, feature_count);
 		//cout<<sql.c_str() <<endl;
 		return sql;
 	}
@@ -604,7 +604,7 @@ ST_GeometryFromText('POLYGON((%f %f, %f %f,  %f %f, %f %f,  %f %f))',%s),\
 			string sql = this->GetFeatureInfoSQL(layer, x0, y0, dis, feature_count); //sql语句中使用 ::box
 			if (sql == "")
 				continue;
-
+			printf("%s\r\n",sql.c_str());
 			string layerName = layer->name();
 			try
 			{