列表接口

ais-test/config/api.js

@@ -1,35 +0,0 @@
-const resultCode = {
-    200: '请求成功',
-    500: '请求失败'
-}
-class Response {
-    constructor(code, data, msg) {
-        this.code = code
-        this.data = data
-        this.msg = msg
-    }
-    success() {
-        const c = 200
-        return new Response(c, null, resultCode[c])
-    }
-    success(data) {
-        const c = 200
-        return new Response(c, data, resultCode[c])
-    }
-    success(data, msg) {
-        const c = 200
-        return new Response(c, data, msg)
-    }
-    error() {
-        const c = 500
-        return new Response(c, null, resultCode[c])
-    }
-    error(data) {
-        const c = 500
-        return new Response(c, data, resultCode[c])
-    }
-    error(data, msg) {
-        const c = 500
-        return new Response(c, data, msg)
-    }
-}

ais-test/controll/index.js

@@ -1,10 +0,0 @@
-import {sqlHandle} from "../config/db.js";
-const AisTestControl = {
-  selectAll: (req, res) => {
-    const sql = 'select * from ais_test'
-    sqlHandle(sql).then(result => {
-      res.send(result)
-    })
-  }
-}
-export default AisTestControl

ais-test/routers/index.js

@@ -1,5 +0,0 @@
-import express from 'express'
-import AisTestControl from "../controll/index.js";
-const aisTestRouter = express.Router()
-aisTestRouter.get('/sss', AisTestControl.selectAll)
-export default aisTestRouter

app.js

@@ -18,12 +18,8 @@ app.use(bodyParser.urlencoded({
 app.use(bodyParser.json())
 // 处理 mutipart/form-data
 app.use(multiparty())
-import aisTestRouter from "./ais-test/routers/index.js";
-app.use('/ais-test', aisTestRouter)
-// 测试接口能否正常调用
-app.get('/info', (req, res) => {
-    res.send("Hello s是 !")
-})
+import shipTestRouter from "./ship-test/routers/index.js";
+app.use('/ship-test', shipTestRouter)
 // 启动
 app.listen(port, () => {
     console.log('express server running at ' + port);

ship-test/config/api.js

@@ -0,0 +1,19 @@
+const resultCode = {
+    200: '请求成功',
+    500: '请求失败'
+}
+export default class ApiResult {
+    constructor(code, data, msg) {
+        this.code = code
+        this.data = data
+        this.msg = msg
+    }
+    success(data, msg) {
+        const c = 200
+        return new ApiResult(c, data, msg || resultCode[c])
+    }
+    error(data, msg) {
+        const c = 500
+        return new ApiResult(c, data, msg || resultCode[c])
+    }
+}

ais-test/config/db.js

@@ -7,7 +7,7 @@ const db_config = {
     database: 'seat-tool'
 }
 // 进行数据库交互
-const sqlHandle = (sql) => {
+const sqlHandle = (sql, values) => {
     let connect = mysql.createConnection(db_config)
     // 开始链接数据库
     connect.connect(function (err) {
@@ -19,12 +19,15 @@ const sqlHandle = (sql) => {
     })
     // 返回一个Promise承诺对象
     return new Promise((resolve, reject) => {
-        connect.query(sql, (err, result) => {
+        connect.query(sql, values, (err, result) => {
             if (err) {
                 reject(err)
             } else {
                 // 此处需要将返回数据转为JSON再转回来,否则原数据不为任何数据类型
                 let res = JSON.parse(JSON.stringify(result))
+                console.log('执行：', sql)
+                console.log('参数：', values)
+                console.log('结果：', res)
                 closeMysql(connect)
                 resolve(res)
             }

ship-test/config/page.js

@@ -0,0 +1,10 @@
+import {sqlHandle} from "./db.js";
+
+const PageResult = async (sql, pageNum, pageSize, Entity) => {
+    const result = await sqlHandle(sql)
+    return {
+        data: result.slice((pageNum - 1) * pageSize, pageNum * pageSize).map(v => Entity ? new Entity(v) : v),
+        total: result.length
+    }
+}
+export default PageResult

ship-test/control/source-control.js

@@ -0,0 +1,29 @@
+import SourceService from "../service/source-service.js";
+import ApiResult from "../config/api.js";
+const SourceControl = {
+  list: async (req, res) => {
+    try {
+      const data = await SourceService.list(req.body)
+      res.send(new ApiResult().success(data))
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  },
+  page: async (req, res) => {
+    try {
+      const data = await SourceService.page(req.body)
+      res.send(new ApiResult().success(data))
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  },
+  add: async (req, res) => {
+    try {
+      const data = await SourceService.add(req.body)
+      res.send(new ApiResult().success(data))
+    } catch (e) {
+      res.send(new ApiResult().error(e))
+    }
+  }
+}
+export default SourceControl

ship-test/entity/source-entity.js

@@ -0,0 +1,12 @@
+import {convertToCamelCase, isValue, YMDHms} from "../../util/index.js";
+
+export default class SourceEntity {
+  constructor(obj) {
+    convertToCamelCase(obj)
+    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
+  }
+}

ship-test/routers/index.js

@@ -0,0 +1,7 @@
+import express from 'express'
+import SourceControl from "../control/source-control.js";
+const shipTestRouter = express.Router()
+shipTestRouter.post('/source/list', SourceControl.list)
+shipTestRouter.post('/source/page', SourceControl.page)
+shipTestRouter.post('/source/add', SourceControl.add)
+export default shipTestRouter

ship-test/service/source-service.js

@@ -0,0 +1,42 @@
+import {sqlHandle} from "../config/db.js";
+import {isValue} from "../../util/index.js";
+import PageResult from "../config/page.js";
+import SourceEntity from "../entity/source-entity.js";
+const SourceService = {
+  list: async ({name}) => {
+    let sql = 'SELECT * FROM ship_test_source'
+    let where = ['del_flag = 0']
+    if (isValue(name)) {
+      where.push(`name LIKE "%${name}%"`)
+    }
+    if (where.length > 0) {
+      sql += ' ' + `WHERE ${where.join(' AND ')}`
+    }
+    const result = await sqlHandle(sql)
+    return result.map(v => new SourceEntity(v))
+  },
+  page: async ({pageNum, pageSize, name}) => {
+    let sql = 'SELECT * FROM ship_test_source'
+    let where = ['del_flag = 0']
+    if (isValue(name)) {
+      where.push(`name LIKE "%${name}%"`)
+    }
+    if (where.length > 0) {
+      sql += ' ' + `WHERE ${where.join(' AND ')}`
+    }
+    const result = await PageResult(sql, pageNum, pageSize, SourceEntity)
+    return result
+  },
+  add: async (form) => {
+    const sql = 'INSERT INTO ship_test_source (name, remark, sort) VALUES (?, ?, ?)'
+    const sourceEntity = new SourceEntity(form)
+    const values = [
+      sourceEntity.name,
+      sourceEntity.remark,
+      sourceEntity.sort,
+    ]
+    const result = await sqlHandle(sql, values)
+    return result
+  },
+}
+export default SourceService

util/index.js

@@ -0,0 +1,43 @@
+export const isValue = (val) => {
+  if (val === null || val === undefined || (typeof val === 'string' && val.trim() === '') || (typeof val === 'object' && val?.length === 0)) {
+    return false
+  }
+  return true
+}
+
+export const convertToCamelCase = (obj) => {
+  for (let key in obj) {
+    let newKey = key.replace(/_([a-z])/g, function($0, $1){ return $1.toUpperCase(); });
+    if (newKey !== key) {
+      obj[newKey] = obj[key];
+      delete obj[key];
+    }
+  }
+}
+
+export const YMDHms = (date) => {
+  const _date = new Date(date)
+  const Y = `${_date.getFullYear()}`;
+  const M = `${_date.getMonth() + 1 < 10 ? `0${_date.getMonth() + 1}` : _date.getMonth() + 1}`;
+  const D = `${_date.getDate() < 10 ? `0${_date.getDate()}` : _date.getDate()}`;
+  const H = `${_date.getHours() < 10 ? `0${_date.getHours()}` : _date.getHours()}`;
+  const m = `${_date.getMinutes() < 10 ? `0${_date.getMinutes()}` : _date.getMinutes()}`;
+  const s = _date.getSeconds() < 10 ? `0${_date.getSeconds()}` : _date.getSeconds();
+  return `${Y}-${M}-${D} ${H}:${m}:${s}`;
+}
+
+export const YMD = (date, format = false) => {
+  const _date = new Date(date)
+  const Y = `${_date.getFullYear()}`;
+  const M = `${_date.getMonth() + 1 < 10 ? `0${_date.getMonth() + 1}` : _date.getMonth() + 1}`;
+  const D = `${_date.getDate() < 10 ? `0${_date.getDate()}` : _date.getDate()}`;
+  return format ? `${Y}年${M}月${D}日` : `${Y}-${M}-${D}`;
+}
+
+export const Hms = (date, format = false) => {
+  const _date = new Date(date)
+  const H = `${_date.getHours() < 10 ? `0${_date.getHours()}` : _date.getHours()}`;
+  const m = `${_date.getMinutes() < 10 ? `0${_date.getMinutes()}` : _date.getMinutes()}`;
+  const s = _date.getSeconds() < 10 ? `0${_date.getSeconds()}` : _date.getSeconds();
+  return format ? `${H}时${m}分${s}秒` : `${H}:${m}:${s}`;
+}