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} */ 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 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, }