ax-node/ship-test/service/params-dict-service.js

import {sqlHandle} from "../config/db.js";
import {isValue, paramToUnder} from "../../util/index.js";
import PageResult from "../config/page.js";
import ParamsDictEntity from "../entity/params-dict-entity.js";
const ParamsDictService = {
  list: ({paramsId, name, orderByColumn, isAsc}) => {
    return new Promise(async (resolve, reject) => {
      try {
        let sql = 'SELECT * FROM ship_test_params_dict'
        let where = ['del_flag = 0']
        if (isValue(paramsId)) {
          where.push(`params_id = "${paramsId}"`)
        } else {
          reject('参数ID不可为空')
        }
        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)
        resolve(result.map(v => new ParamsDictEntity(v)))
      } catch (e) {
        console.log(e)
        reject(e.sqlMessage)
      }
    })
  },
  page: ({paramsId, pageNum, pageSize, name, orderByColumn, isAsc}) => {
    return new Promise(async (resolve, reject) => {
      try {
        let sql = 'SELECT * FROM ship_test_params_dict'
        let where = ['del_flag = 0']
        if (isValue(paramsId)) {
          where.push(`params_id = "${paramsId}"`)
        } else {
          reject('参数ID不可为空')
        }
        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, ParamsDictEntity)
        resolve(result)
      } catch (e) {
        reject(e.sqlMessage)
      }
    })
  },
  info: (id) => {
    return new Promise(async (resolve, reject) => {
      try {
        let sql = 'SELECT * FROM ship_test_params_dict'
        let where = ['del_flag = 0']
        if (!isValue(id)) {
          reject('id不可为空')
          return
        } else {
          where.push(`id = ${id}`)
        }
        if (where.length > 0) {
          sql += ' ' + `WHERE ${where.join(' AND ')}`
        }
        const result = await sqlHandle(sql)
        resolve(result.map(v => new ParamsDictEntity(v))?.[0])
      } catch (e) {
        reject(e.sqlMessage)
      }
    })
  },
  queryBy: ({name}) => {
    return new Promise(async (resolve, reject) => {
      try {
        let sql = 'SELECT * FROM ship_test_params_dict'
        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)
        resolve(result.map(v => new ParamsDictEntity(v)))
      } catch (e) {
        reject(e.sqlMessage)
      }
    })
  },
  add: (form) => {
    return new Promise(async (resolve, reject) => {
      try {
        const sql = 'INSERT INTO ship_test_params_dict (params_id, name, remark, sort, cql) VALUES (?, ?, ?, ?, ?)'
        const paramsDictEntity = new ParamsDictEntity(form)
        if (!isValue(paramsDictEntity.paramsId)) {
          reject('参数ID不可为空')
        }
        if (!isValue(paramsDictEntity.cql)) {
          reject('cql不可为空')
        }
        const sameValid = await ParamsDictService.queryBy({name: paramsDictEntity.name})
        if (sameValid.length > 0) {
          reject('已存在相同名称!')
          return
        }
        const values = [
          paramsDictEntity.paramsId,
          paramsDictEntity.name,
          paramsDictEntity.remark,
          paramsDictEntity.sort,
          paramsDictEntity.cql,
        ]
        const result = await sqlHandle(sql, values)
        resolve(result.insertId)
      } catch (e) {
        reject(e.sqlMessage)
      }
    })
  },
  edit: (form) => {
    return new Promise(async (resolve, reject) => {
      try {
        let sql = 'UPDATE ship_test_params_dict SET name = ?, remark = ?, sort = ?, cql = ?'
        const paramsDictEntity = new ParamsDictEntity(form)
        if (!isValue(paramsDictEntity.id)) {
          reject('id不可为空!')
          return
        } else {
          sql += ' ' + `WHERE id = "${paramsDictEntity.id}"`
        }
        if (!isValue(paramsDictEntity.cql)) {
          reject('cql不可为空')
        }
        const sameValid = await ParamsDictService.queryBy({name: paramsDictEntity.name})
        if (sameValid.filter(v => v.id !== paramsDictEntity.id).length > 0) {
          reject('已存在相同名称!')
          return
        }
        const values = [
          paramsDictEntity.name,
          paramsDictEntity.remark,
          paramsDictEntity.sort,
          paramsDictEntity.cql,
        ]
        const result = await sqlHandle(sql, values)
        resolve(paramsDictEntity.id)
      } catch (e) {
        reject(e.sqlMessage)
      }
    })
  },
  del: (ids) => {
    return new Promise(async (resolve, reject) => {
      try {
        let sql = 'UPDATE ship_test_params_dict SET del_flag = "1"'
        if (ids?.length === 0) {
          reject('ids不可为空!')
          return
        } else {
          sql += ' ' + 'WHERE id IN (?)'
        }
        const result = await sqlHandle(sql, [ids])
        resolve('删除成功!')
      } catch (e) {
        reject(e.sqlMessage)
      }
    })
  },
  enabled: (ids) => {
    return new Promise(async (resolve, reject) => {
      try {
        let sql = 'UPDATE ship_test_params_dict SET active = 0'
        if (ids?.length === 0) {
          reject('ids不可为空!')
          return
        } else {
          sql += ' ' + 'WHERE id IN (?)'
        }
        const result = await sqlHandle(sql, [ids])
        resolve('启用成功!')
      } catch (e) {
        reject(e.sqlMessage)
      }
    })
  },
  disabled: (ids) => {
    return new Promise(async (resolve, reject) => {
      try {
        let sql = 'UPDATE ship_test_params_dict SET active = 1'
        if (ids?.length === 0) {
          reject('ids不可为空!')
          return
        } else {
          sql += ' ' + 'WHERE id IN (?)'
        }
        const result = await sqlHandle(sql, [ids])
        resolve('禁用成功!')
      } catch (e) {
        reject(e.sqlMessage)
      }
    })
  }
}
export default ParamsDictService