hfysite/server/database/d_base.js

const mysql = require('./mysql');
const {searchSql,limitSql} = require("../tools/searchSql");
const {isEmpty} = require("../tools/typeTool_cjs");
const log = require("../logger").logger("d_base","info");

/**
 * table carousel
 * id 主键
 * sort 排序
 * image 图片地址
 * type 1: 文章 2: 产品 3: 直接链接
 * link 文章id 产品id 链接
 */

/**
 * 获取轮播图
 * @returns {Promise | Promise<unknown>}
 */
function getCarousel(){
  let sql = `SELECT c.*,f.filePath,f.fileType,f.fileId
            FROM
                hfy_carousel as c,
                hfy_files as f
            WHERE c.fileId = f.fileId`;
  return mysql.pq(sql);
}

function addCarousel(sort,fileId,type,value,valueShowText,updateTime){
  let sql = `INSERT INTO hfy_carousel (sort, fileId, type, value, valueShowText, updateTime)
                    VALUES (?,?,?,?,?,?)`;
  return mysql.pq(sql,[sort,fileId,type,value,valueShowText,updateTime]);
}

function uploadFiles(type,fileNameArr,uploadTime){
  let sql = `INSERT INTO hfy_files (fileType, filePath, uploadTime)
                    VALUES ${fileNameArr.map(f=>`(?,?,?)`).join(',')}`;
  let values = [];
  for(let fileName of fileNameArr){
    values.push(type);
    values.push(fileName);
    values.push(`${uploadTime}`);
  }
  console.log(sql);
  console.log(values);
  return mysql.pq(sql,values);
}

/**
 * 搜索文件数据
 * @param type
 * @param _params
 * @param p
 * @param l
 * @returns {*}
 */
function loadFiles(type = 'array',_params,p,l){
  let sql = ``;
  let values = [];
  if(isEmpty(_params)){
    _params = {};
  }
  if(type === 'count'){
    sql = `select count(*) as total `;
  }else {
    sql = `select * `;
  }
  sql += `from hfy_files as f
    where 1 = 1
  `
  if(_params.key){
    sql += ` and ( f.name like '%${_params.key}% or f.tags like '%${_params.key}%' )`
  }
  if(_params.type){
    sql += ` and f.fileType = ? `;
    values.push(_params.type - 1);
  }
  sql += ` order by f.uploadTime desc `;
  return searchSql(mysql.pq,type,sql,values,l,p);
}

function getFileById(fileId){
  let sql = `select * from hfy_files where fileId = ?`;
  return mysql.pq(sql,[fileId]);
}

function deleteFile(fileId){
  let sql = `delete from hfy_files where fileId = ? limit 1`;
  return mysql.pq(sql,[fileId]);
}
module.exports = {
  getCarousel,
  uploadFiles,
  loadFiles,
  getFileById,
  deleteFile,
  addCarousel
}