daocha_serve/Source/server/jiance-echartServer/common/commonFun.js

const pgClient = require("../../DataBase/Postgresql/pgClient.js"); //pg 查询引擎
const sqlUtil = require("../util/sqlUtil.js");

// 通用查询函数，查询表内所有数据
function showAll(req, res) {
  let sql = sqlUtil.listTableByName(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 新增
function addRecord(req, res) {
  let sql = sqlUtil.listTableByName(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 删除
function deleteRecord(req, res) {
  let sql = sqlUtil.listTableByName(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 更新
function updateRecord(req, res) {
  let sql = sqlUtil.listTableByName(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function weiyouchen(req, res) {
  let sql = sqlUtil.wyc(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function dwjcBX(req, res) {
  let sql = sqlUtil.dwjc(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 通用查询函数，查询表内所有数据
function dcpfQS(req, res) {
  let sql = sqlUtil.dcpf(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 通用查询函数，查询表内所有数据
function gdjhBX(req, res) {
  let sql = sqlUtil.gdjh(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

function f1(req, res) {
  let sql = sqlUtil.fjcdg1(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function f2(req, res) {
  let sql = sqlUtil.fjcdg2(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function lc(req, res) {
  let sql = sqlUtil.licheng(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function jt(req, res) {
  let sql = sqlUtil.jtjc(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function czy(req, res) {
  let sql = sqlUtil.czy(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function czylc(req, res) {
  let sql = sqlUtil.czylc(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function jtjclc(req, res) {
  let sql = sqlUtil.jtjclc(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function bxlc(req, res) {
  let sql = sqlUtil.bxlc(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function yuzhixiugai(req, res) {
  let sql = sqlUtil.yuzhixiugai(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 通用查询函数，查询表内所有数据
function yuzhixiugai2(req, res) {
  let sql = sqlUtil.yuzhixiugai2(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 更新函数，修改表内数据
function updateyuzhi(req, res) {
  let sql = sqlUtil.updateyuzhi(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 更新函数，修改表内数据
function updateDwyuzhi(req, res) {
  let sql = sqlUtil.updateDwyuzhi(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通用查询函数，查询表内所有数据
function shaixuanyuzhi(req, res) {
  let sql = sqlUtil.shaixuanyuzhi(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 新增点位
function addPoint(req, res) {
  let sql = sqlUtil.addPoint(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 获取点位列表
function getPointList(req, res) {
  let sql = sqlUtil.getPointList(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通过sql获取报警列表
function getAlertList(req, res) {
  let sql = sqlUtil.getAlertList(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 通过sql获取报警列表
function getqkAlertList(req, res) {
  let sql = sqlUtil.getqkAlertList(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}
// 通过sql获取报警列表
function getglAlertList(req, res) {
  let sql = sqlUtil.getglAlertList(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通过sql获取报警列表
function getPointCurrent(req, res) {
  let sql = sqlUtil.getPointCurrent(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}


// 通过sql获取报警列表
function getqkCurrent(req, res) {
  let sql = sqlUtil.getqkCurrent(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通过sql获取报警列表
function getGlCurrent(req, res) {
  let sql = sqlUtil.getGlCurrent(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通过sql获取报警列表
function getBoXing(req, res) {
  let sql = sqlUtil.getBoXing(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通过sql获取工务列表
function getDataManage(req, res) {
  let sql = sqlUtil.getDataManage(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

// 通过sql获取电务列表
function getDwDataManage(req, res) {
  let sql = sqlUtil.getDwDataManage(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}


// 通过sql获取缺口列表
function getQkDataManage(req, res) {
  let sql = sqlUtil.getQkDataManage(req);
  pgClient.query(sql).then((data) => {
    res.send(data);
  });
}

module.exports = {
  showAll,
  addRecord,
  deleteRecord,
  updateRecord,
  weiyouchen,
  dwjcBX,
  f1,
  f2,
  lc,
  bxlc,
  dcpfQS,
  gdjhBX,
  jt,
  czy,
  czylc,
  jtjclc,
  yuzhixiugai,
  yuzhixiugai2,
  updateyuzhi,
  updateDwyuzhi,
  shaixuanyuzhi,
  addPoint,
  getPointList,
  getAlertList,
  getqkAlertList,
  getglAlertList,
  getPointCurrent,
  getqkCurrent,
  getGlCurrent,
  getBoXing,
  getDataManage,
  getDwDataManage,
  getQkDataManage,
};