gis/server-mysql.js

const express = require('express');

var bodyParser  =  require("body-parser"); 
// var pg = require('pg');
var mysql = require('mysql');

const app = express();

 const port = 8080
// var conString = "postgres://postgres:postgres@localhost/gisdb";
// var conString = {
//   host: "139.9.239.248",
//   port: "4001",
//   user: "root",
//   password: "pUxtaIoE!1^s@vDJ",
//   database: "air"
// };
var conString = {
  host: "124.71.210.242",
  port: "4000",
  user: "air",
  password: "air123456",
  database: "air"
};
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());

app.all('*', function(req, res, next) {
    //设为指定的域
    res.header('Access-Control-Allow-Origin', "*");
    res.header("Access-Control-Allow-Headers", "X-Requested-With");
    res.header('Access-Control-Allow-Headers', 'Content-Type');
    res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
    res.header('Access-Control-Allow-Credentials', true);
    res.header("X-Powered-By", ' 3.2.1');
    next();
});

app.get('/', (req, res) => res.send('Hello World!'))

// 根据定位经纬度范围行政区数据
// http://localhost:8090/getRegionByLocation?lon=106.5682&lat=29.6267
app.get('/getRegionByLocation', (req, res) => {
  var lon = req.query.lon || "";
  var lat = req.query.lat || "";
  if (lon == "" || lat == "") {
    res.send(`参数错误!
              示例： http://localhost:8090/getRegionByLocation?lon=106.5682&lat=29.6267
    `);
    return;
  }
  // var client = mysql.createConnection(conString);
  var client = mysql.createConnection(conString);
  client.connect(function (err) {
    if (err) {
      return console.error('连接数据库失败', err);
    } else {
      console.info('连接数据库成功');
    }
    var sql = `select *,st_astext(geom) as geom from xingzhengqu`    
    sqlQueryPromise(sql, client)
      .then((result) => {
        // console.log(result)
        res.send(result);
        client.end();
      })
      .catch((err)=>{
        res.send(err);
        client.end();
      });
  });
})

// 根据定位经纬度返回3公里范围内的设施数据
// http://localhost:8090/getFacilitiesByLocation?lon=106.5682&lat=29.6267
app.get('/getFacilitiesByLocation', (req, res) => {
  var lon = req.query.lon || "";
  var lat = req.query.lat || "";
  var radius = req.query.radius || 3000;
  if (lon == "" || lat == "") {
    res.send(`参数错误!
              示例： http://localhost:8090/getFacilitiesByLocation?lon=106.5682&lat=29.6267
    `);
    return;
  }
  var client = mysql.createConnection(conString);
  client.connect(function (err) {
    if (err) {
      return console.error('连接数据库失败', err);
    }
  var sql = `SELECT *,st_astext(geom) as geom1 from facilities where ST_Distance_Sphere(st_geomfromtext('POINT(${lat} ${lon})', 4326), ST_SRID(geom,4326)) < ${radius}`
sqlQueryPromise(sql, client)
    .then((result) => {
      // console.log(result)
      res.send(result);
      client.end();
    })
    .catch((err)=>{
      res.send(err);
      client.end();
    });
  });
})

// 根据定位经纬度返回5公里范围内的大组团小组团
// http://localhost:8090/getTypeRegionByLocation?lon=106.5682&lat=29.6267&type=0
app.get('/getTypeRegionByLocation', (req, res) => {
  var lon = req.query.lon || "";
  var lat = req.query.lat || "";
  var type = req.query.type || "0";
  var radius = req.query.radius || 5000000;
  if (lon == "" || lat == "") {
    res.send(`参数错误!
              示例： http://localhost:8090/getTypeRegionByLocation?lon=106.5682&lat=29.6267&type=0
    `);
    return;
  }
  var tableName = type == "0" ? "xiaozutuan" : "dazutuan"
  var client = mysql.createConnection(conString);
  client.connect(function (err) {
    if (err) {
      return console.error('连接数据库失败', err);
    }
    
  var sql = `SELECT *,st_astext(geom) as geom from ${tableName} `;
  sqlQueryPromise(sql, client)
    .then((result) => {
      res.send(result);
      client.end();
    })
    .catch((err)=>{
      res.send(err);
      client.end();
    });
  });
})
// 获取环线数据
// http://localhost:8090/getLoopLine?lon=106.5682&lat=29.6267&type=0
app.get('/getLoopLine', (req, res) => {
  
  var client = mysql.createConnection(conString);
  client.connect(function (err) {
    if (err) {
      return console.error('连接数据库失败', err);
    }
    
  var sql = `SELECT *,st_astext(geom) as geom from huanxian`;
  sqlQueryPromise(sql, client)
    .then((result) => {
      res.send(result);
      client.end();
    })
    .catch((err)=>{
      res.send(err);
      client.end();
    });
  });
})

// 获取拟挂牌地块数据
app.get('/getLandToList', (req, res) => {
  var lon = req.query.lon || "";
  var lat = req.query.lat || "";
  var radius = req.query.radius || 5000000;
  if (lon == "" || lat == "") {
    res.send(`参数错误!
              示例： http://localhost:8090/getLandToList?lon=106.5682&lat=29.6267
    `);
    return;
  }
  var client = mysql.createConnection(conString);
  client.connect(function (err) {
    if (err) {
      return console.error('连接数据库失败', err);
    }
    var sql = `SELECT *,st_astext(st_centroid(geom)) as centerPoint,st_astext(geom) as geom from land_to_list_lon_lat 
    where   geom is not null`
  sqlQueryPromise(sql, client)
    .then((result) => {
      // console.log(result)
      res.send(result);
      client.end();
    })
    .catch((err)=>{
      res.send(err);
      client.end();
    });
  });
})

// 获取挂牌中数据
app.get('/getLandListing', (req, res) => {
  var lon = req.query.lon || "";
  var lat = req.query.lat || "";
  var radius = req.query.radius || 5000000;
  if (lon == "" || lat == "") {
    res.send(`参数错误!
              示例： http://localhost:8090/getLandListing?lon=106.5682&lat=29.6267
    `);
    return;
  }
  
  var client = mysql.createConnection(conString);
  client.connect(function (err) {
    if (err) {
      return console.error('连接数据库失败', err);
    }
    
  var sql = ` 
            SELECT b.auction_date,a.*,st_astext(st_centroid(a.geom)) as centerPoint,st_astext(a.geom) as geom from land_listed_lon_lat a
              left join
              land_listed b
              on a.land_listed_id = b.land_listed_id
              where   geom is not null`
  sqlQueryPromise(sql, client)
    .then((result) => {
      // console.log(result)
      for(var i = 0; i < result.length; i++) {
        var item = result[i]
        if (!item.auction_date) item.status = '挂牌中';
        if (item.auction_date &&  new Date(item.auction_date).getTime() < new Date().getTime()) {
          item.status = '已出让';
          result.splice(i, 1);
          i--;
        } else {
          item.status = '挂牌中';
        }
      }
      res.send(result);
      client.end();
    })
    .catch((err)=>{
      res.send(err);
      client.end();
    });
  });
})

// 获取出让地块数据
app.get('/getLandList', (req, res) => {
  var lon = req.query.lon || "";
  var lat = req.query.lat || "";
  var radius = req.query.radius || 5000000;
  var start = req.query.start || "1900-01-01";
  var end = req.query.end || "9999-01-01";
  if (lon == "" || lat == "") {
    res.send(`参数错误!
              示例： http://localhost:8090/getLandList?lon=106.5682&lat=29.6267&type=0
    `);
    return;
  }
  
  var client = mysql.createConnection(conString);
  client.connect(function (err) {
    if (err) {
      return console.error('连接数据库失败', err);
    }

      
  var sql = `SELECT b.auction_date,st_astext(st_centroid(a.geom)) as centerPoint,a.*,st_astext(a.geom) as geom from land_listed_lon_lat a
  left join
  land_listed b
  on a.land_listed_id = b.land_listed_id 
  where   geom is not null`
  sqlQueryPromise(sql, client)
    .then((result) => {
      // console.log(result)
      for(var i = 0; i < result.length; i++) {
        var item = result[i]
        if (item.auction_date &&  new Date(item.auction_date).getTime() < new Date().getTime()) {
          item.status = '已出让';
          if (new Date(item.auction_date).getTime() > new Date(end).getTime() || new Date(item.auction_date).getTime() < new Date(start).getTime()) {
            result.splice(i, 1);
            i--;
          }
        } else {
          item.status = '挂牌中';
          result.splice(i, 1);
          i--;
        }
      }
      res.send(result);
      client.end();
    })
    .catch((err)=>{
      res.send(err);
      client.end();
    });
  });
})

function sqlQueryPromise(sql, client) {
  return new Promise((resolve, reject)=>{
    client.query(sql, function (err, data, fields) {
      if (err) {
        reject(err);
      } else {
        resolve(data);
      }
    })
  })
}

app.listen(port, () => console.log(`Example app listening on port ${port}!`))