静态物

src/ship-test/control/static-control.js

@@ -0,0 +1,71 @@
+const StaticService = require("../service/static-service")
+const ApiResult = require("../config/api")
+const StaticControl = {
+  list: async (req, res) => {
+    try {
+      StaticService.list(req.body).then(data => {
+        res.send(new ApiResult().success(data))
+      }).catch((e) => {
+        res.send(new ApiResult().error(null, e))
+      })
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  },
+  page: async (req, res) => {
+    try {
+      StaticService.page(req.body).then(data => {
+        res.send(new ApiResult().success(data))
+      }).catch((e) => {
+        res.send(new ApiResult().error(null, e))
+      })
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  },
+  info: async (req, res) => {
+    try {
+      StaticService.info(req.params.id).then(data => {
+        res.send(new ApiResult().success(data))
+      }).catch((e) => {
+        res.send(new ApiResult().error(null, e))
+      })
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  },
+  add: async (req, res) => {
+    try {
+      StaticService.add(req.body).then(data => {
+        res.send(new ApiResult().success(data))
+      }).catch((e) => {
+        res.send(new ApiResult().error(null, e))
+      })
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  },
+  edit: async (req, res) => {
+    try {
+      StaticService.edit(req.body).then(data => {
+        res.send(new ApiResult().success(data))
+      }).catch((e) => {
+        res.send(new ApiResult().error(null, e))
+      })
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  },
+  del: async (req, res) => {
+    try {
+      StaticService.del(req.params?.ids?.split(',')).then(data => {
+        res.send(new ApiResult().success(data))
+      }).catch((e) => {
+        res.send(new ApiResult().error(null, e))
+      })
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  }
+}
+module.exports = StaticControl

src/ship-test/entity/static-entity.js

@@ -0,0 +1,15 @@
+const {objToCamel, isValue, YMDHms} = require("../../util/index")
+
+module.exports = class StaticEntity {
+  constructor(obj) {
+    objToCamel(obj)
+    this.id = isValue(obj?.id) ? obj.id : null
+    this.name = isValue(obj?.name) ? obj.name : null
+    this.sort = isValue(obj?.sort) ? obj.sort : 0
+    this.remark = isValue(obj?.remark) ? obj.remark : null
+    this.createTime = isValue(obj?.createTime) ? YMDHms(obj.createTime) : null
+    this.updateTime = isValue(obj?.updateTime) ? YMDHms(obj.updateTime) : null
+    this.color = isValue(obj?.color) ? obj.color : null
+    this.wkt = isValue(obj?.wkt) ? obj.wkt : null
+  }
+}

src/ship-test/routers/index.js

@@ -5,6 +5,7 @@ const ParamsDictControl = require("../control/params-dict-control")
 const TrackControl = require("../control/track-control")
 const HoverControl = require("../control/hover-control")
 const ShipFilterControl = require("../control/ship-filter-control")
+const StaticControl = require("../control/static-control")
 
 const shipTestRouter = express.Router()
 // 数据源
@@ -47,4 +48,11 @@ shipTestRouter.put('/hover/edit', HoverControl.edit)
 shipTestRouter.delete('/hover/del/:ids', HoverControl.del)
 // 船筛
 shipTestRouter.get('/ship-filter/get-config', ShipFilterControl.getConfig)
+// 静态物
+shipTestRouter.post('/static/list', StaticControl.list)
+shipTestRouter.post('/static/page', StaticControl.page)
+shipTestRouter.get('/static/info/:id', StaticControl.info)
+shipTestRouter.post('/static/add', StaticControl.add)
+shipTestRouter.put('/static/edit', StaticControl.edit)
+shipTestRouter.delete('/static/del/:ids', StaticControl.del)
 module.exports = shipTestRouter

src/ship-test/service/static-service.js

@@ -0,0 +1,158 @@
+const {sqlHandle} = require("../config/db")
+const {isValue, paramToUnder} = require("../../util/index")
+const PageResult = require("../config/page")
+const StaticEntity = require("../entity/static-entity")
+const StaticService = {
+  list: ({name, orderByColumn, isAsc}) => {
+    return new Promise(async (resolve, reject) => {
+      try {
+        let sql = 'SELECT * FROM ship_test_static'
+        let where = ['del_flag = 0']
+        if (isValue(name)) {
+          where.push(`name LIKE "%${name}%"`)
+        }
+        if (where.length > 0) {
+          sql += ' ' + `WHERE ${where.join(' AND ')}`
+        }
+        if (isValue(orderByColumn)) {
+          sql += ' ' + `ORDER BY ${paramToUnder(orderByColumn)} ${isAsc ? 'ASC' : 'DESC'}`
+        } else {
+          sql += ' ' + `ORDER BY sort DESC`
+        }
+        const result = await sqlHandle(sql)
+        return resolve(result.map(v => new StaticEntity(v)))
+      } catch (e) {
+        return reject(e.sqlMessage)
+      }
+    })
+  },
+  page: ({pageNum, pageSize, name, orderByColumn, isAsc}) => {
+    return new Promise(async (resolve, reject) => {
+      try {
+        let sql = 'SELECT * FROM ship_test_static'
+        let where = ['del_flag = 0']
+        if (isValue(name)) {
+          where.push(`name LIKE "%${name}%"`)
+        }
+        if (where.length > 0) {
+          sql += ' ' + `WHERE ${where.join(' AND ')}`
+        }
+        if (isValue(orderByColumn)) {
+          sql += ' ' + `ORDER BY ${paramToUnder(orderByColumn)} ${isAsc ? 'ASC' : 'DESC'}`
+        } else {
+          sql += ' ' + `ORDER BY sort DESC`
+        }
+        const result = await PageResult(sql, pageNum, pageSize, StaticEntity)
+        return resolve(result)
+      } catch (e) {
+        return reject(e.sqlMessage)
+      }
+    })
+  },
+  info: (id) => {
+    return new Promise(async (resolve, reject) => {
+      try {
+        let sql = 'SELECT * FROM ship_test_static'
+        let where = ['del_flag = 0']
+        if (!isValue(id)) {
+          return reject('id不可为空')
+        } else {
+          where.push(`id = ${id}`)
+        }
+        if (where.length > 0) {
+          sql += ' ' + `WHERE ${where.join(' AND ')}`
+        }
+        const result = await sqlHandle(sql)
+        return resolve(result.map(v => new StaticEntity(v))?.[0])
+      } catch (e) {
+        return reject(e.sqlMessage)
+      }
+    })
+  },
+  queryBy: ({name}) => {
+    return new Promise(async (resolve, reject) => {
+      try {
+        let sql = 'SELECT * FROM ship_test_static'
+        let where = ['del_flag = 0']
+        if (isValue(name)) {
+          where.push(`name = "${name}"`)
+        }
+        if (where.length > 0) {
+          sql += ' ' + `WHERE ${where.join(' AND ')}`
+        }
+        const result = await sqlHandle(sql)
+        return resolve(result.map(v => new StaticEntity(v)))
+      } catch (e) {
+        return reject(e.sqlMessage)
+      }
+    })
+  },
+  add: (form) => {
+    return new Promise(async (resolve, reject) => {
+      try {
+        const staticEntity = new StaticEntity(form)
+        const values = [
+          ['name', staticEntity.name],
+          ['remark', staticEntity.remark],
+          ['sort', staticEntity.sort],
+          ['wkt', staticEntity.wkt],
+          ['color', staticEntity.color],
+        ]
+        const sql = `INSERT INTO ship_test_static (${values.map(v => v[0]).join(',')}) VALUES (${values.map(v => '?').join(',')})`
+        const sameValid = await StaticService.queryBy({name: staticEntity.name})
+        if (sameValid.length > 0) {
+          return reject('已存在相同名称!')
+        }
+        const result = await sqlHandle(sql, values.map(v => v[1]))
+        return resolve(result.insertId)
+      } catch (e) {
+        return reject(e.sqlMessage)
+      }
+    })
+  },
+  edit: (form) => {
+    return new Promise(async (resolve, reject) => {
+      try {
+        const staticEntity = new StaticEntity(form)
+        const values = [
+          ['name', staticEntity.name],
+          ['remark', staticEntity.remark],
+          ['sort', staticEntity.sort],
+          ['wkt', staticEntity.wkt],
+          ['color', staticEntity.color],
+        ]
+        let sql = `UPDATE ship_test_static SET ${values.map(v => `${v[0]} = ?`).join(',')}`
+        if (!isValue(staticEntity.id)) {
+          return reject('id不可为空!')
+        } else {
+          sql += ' ' + `WHERE id = "${staticEntity.id}"`
+        }
+        const sameValid = await StaticService.queryBy({name: staticEntity.name})
+        if (sameValid.filter(v => v.id !== staticEntity.id).length > 0) {
+          return reject('已存在相同名称!')
+        }
+        const result = await sqlHandle(sql, values.map(v => v[1]))
+        return resolve(staticEntity.id)
+      } catch (e) {
+        return reject(e.sqlMessage)
+      }
+    })
+  },
+  del: (ids) => {
+    return new Promise(async (resolve, reject) => {
+      try {
+        let sql = 'UPDATE ship_test_static SET del_flag = "1"'
+        if (ids?.length === 0) {
+          return reject('ids不可为空!')
+        } else {
+          sql += ' ' + 'WHERE id IN (?)'
+        }
+        const result = await sqlHandle(sql, [ids])
+        return resolve('删除成功!')
+      } catch (e) {
+        return reject(e.sqlMessage)
+      }
+    })
+  }
+}
+module.exports = StaticService