commonFun.js 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. const pgClient = require("../../DataBase/Postgresql/pgClient.js") //pg 查询引擎
  2. const sqlUtil = require("../util/sqlUtil.js")
  3. // 通用查询函数,查询表内所有数据
  4. function showAll(req, res) {
  5. const sql = sqlUtil.listTableByName(req);
  6. pgClient.query(sql).then(data => {
  7. res.send(data);
  8. })
  9. }
  10. // 通用查询函数,查询表内所有数据
  11. function showTime(req, res) {
  12. const sql = sqlUtil.listTableByTime(req);
  13. pgClient.query(sql).then(data => {
  14. res.send(data);
  15. })
  16. }
  17. // 通用查询函数,查询表内所有数据
  18. function showTable(req, res) {
  19. const sql = sqlUtil.listTable(req);
  20. pgClient.query(sql).then(data => {
  21. res.send(data);
  22. })
  23. }
  24. // 新增JingTaiJC 列表
  25. function addJingTaiJCAll(tableName, item, res, time) {
  26. const sql = sqlUtil.addJingTaiJCExcel(tableName, item, time);
  27. pgClient.query(sql).then(data => {
  28. res.send(data);
  29. })
  30. }
  31. // 新增Chezaiyi 列表
  32. function addCheZaiYiAll(tableName, item, res, time) {
  33. const sql = sqlUtil.addCheZaiYiExcel(tableName, item, time); //修改sql
  34. pgClient.query(sql).then(data => {
  35. res.send(data);
  36. })
  37. }
  38. // 新增算法输出列表
  39. function addSuanFaSCAll(tableName, item, res, time) {
  40. const sql = sqlUtil.addSuanFaSCExcel(tableName, item, time); //修改sql
  41. pgClient.query(sql).then(data => {
  42. res.send(data);
  43. })
  44. }
  45. // 新增轮轨力
  46. function addLunGuiLiAll(tableName, item, res, time) {
  47. const sql = sqlUtil.addLunGuiLiExcel(tableName, item, time); //修改sql
  48. pgClient.query(sql).then(data => {
  49. res.send(data);
  50. })
  51. }
  52. // 新增轨道几何
  53. function addGuiDaoJhAll(tableName, item, res, time) {
  54. const sql = sqlUtil.addGuiDaoJhExcel(tableName, item, time); //修改sql
  55. pgClient.query(sql).then(data => {
  56. res.send(data);
  57. })
  58. }
  59. // 新增轨道沉降趋势
  60. function addGuiDaoCjAll(tableName, item, res, time) {
  61. const sql = sqlUtil.addGuiDaoCjExcel(tableName, item, time); //修改sql
  62. pgClient.query(sql).then(data => {
  63. res.send(data);
  64. })
  65. }
  66. // 新增道岔评分
  67. function addDaoChaPfAll(tableName, item, res, time) {
  68. const sql = sqlUtil.addDaoChaPfExcel(tableName, item, time); //修改sql
  69. pgClient.query(sql).then(data => {
  70. res.send(data);
  71. })
  72. }
  73. // 电务监测缺口数据
  74. function addDianWuJcAll(tableName, item, res, time) {
  75. const sql = sqlUtil.addDianWuJcExcel(tableName, item, time); //修改sql
  76. pgClient.query(sql).then(data => {
  77. res.send(data);
  78. })
  79. }
  80. // 接触网检测数据
  81. function addJieChuWAll(tableName, item, res, time) {
  82. const sql = sqlUtil.addJieChuWExcel(tableName, item, time); //修改sql
  83. pgClient.query(sql).then(data => {
  84. res.send(data);
  85. })
  86. }
  87. // 道岔台账数据
  88. function addDaoChaTzAll(tableName, item, res, time) {
  89. const sql = sqlUtil.addDaoChaTzExcel(tableName, item, time); //修改sql
  90. pgClient.query(sql).then(data => {
  91. res.send(data);
  92. })
  93. }
  94. // 全局道岔台账数据
  95. function addQjDaoChaTzAll(tableName, item, res, time) {
  96. const sql = sqlUtil.addQjDaoChaTzExcel(tableName, item, time); //修改sql
  97. pgClient.query(sql).then(data => {
  98. res.send(data);
  99. })
  100. }
  101. // 新增JingTaiJC 记录
  102. function addJingTaiJCFlies(tableName, fileName, res, time) {
  103. const sql = sqlUtil.addJingTaiJCFlie(tableName, fileName, time);
  104. pgClient.query(sql).then(data => {
  105. res.send(data);
  106. })
  107. }
  108. // 桥梁台账数据
  109. function addQiaoLiangTzAll(tableName, item, res, time) {
  110. const sql = sqlUtil.addQiaoLiangTzExcel(tableName, item, time); //修改sql
  111. pgClient.query(sql).then(data => {
  112. res.send(data);
  113. })
  114. }
  115. // 隧道台账数据
  116. function addSuiDaoTzAll(tableName, item, res, time) {
  117. const sql = sqlUtil.addSuiDaoTzExcel(tableName, item, time); //修改sql
  118. pgClient.query(sql).then(data => {
  119. res.send(data);
  120. })
  121. }
  122. // 坡度台账数据
  123. function addPoDuTzAll(tableName, item, res, time) {
  124. const sql = sqlUtil.addPoDuTzExcel(tableName, item, time); //修改sql
  125. pgClient.query(sql).then(data => {
  126. res.send(data);
  127. })
  128. }
  129. // 沪蓉道台账数据
  130. function addHuRongDaoTzAll(tableName, item, res, time) {
  131. const sql = sqlUtil.addHuRongDaoTzExcel(tableName, item, time); //修改sql
  132. pgClient.query(sql).then(data => {
  133. res.send(data);
  134. })
  135. }
  136. // 道岔动态检测
  137. function addDongTaiJcAll(tableName, item, res, time) {
  138. const sql = sqlUtil.addDongTaiJcExcel(tableName, item, time); //修改sql
  139. pgClient.query(sql).then(data => {
  140. res.send(data);
  141. })
  142. }
  143. module.exports = {
  144. showAll,
  145. showTime,
  146. showTable,
  147. addJingTaiJCAll,
  148. addCheZaiYiAll,
  149. addJingTaiJCFlies,
  150. addSuanFaSCAll,
  151. addLunGuiLiAll,
  152. addGuiDaoJhAll,
  153. addGuiDaoCjAll,
  154. addDaoChaPfAll,
  155. addDianWuJcAll,
  156. addJieChuWAll,
  157. addDaoChaTzAll,
  158. addQjDaoChaTzAll,
  159. addQiaoLiangTzAll,
  160. addSuiDaoTzAll,
  161. addPoDuTzAll,
  162. addHuRongDaoTzAll,
  163. addDongTaiJcAll
  164. }