d_base.js 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. const mysql = require('./mysql');
  2. const {searchSql,limitSql} = require("../tools/searchSql");
  3. const {isEmpty} = require("../tools/typeTool_cjs");
  4. const log = require("../logger").logger("d_base","info");
  5. /**
  6. * table carousel
  7. * id 主键
  8. * sort 排序
  9. * image 图片地址
  10. * type 1: 文章 2: 产品 3: 直接链接
  11. * link 文章id 产品id 链接
  12. */
  13. /**
  14. * 获取轮播图
  15. * @returns {Promise | Promise<unknown>}
  16. */
  17. function getCarousel(){
  18. let sql = `SELECT c.*,f.filePath,f.fileType,f.fileId
  19. FROM
  20. hfy_carousel as c,
  21. hfy_files as f
  22. WHERE c.fileId = f.fileId`;
  23. return mysql.pq(sql);
  24. }
  25. function uploadFiles(type,fileNameArr,uploadTime){
  26. let sql = `INSERT INTO hfy_files (fileType, filePath, uploadTime)
  27. VALUES ${fileNameArr.map(f=>`(?,?,?)`).join(',')}`;
  28. let values = [];
  29. for(let fileName of fileNameArr){
  30. values.push(type);
  31. values.push(fileName);
  32. values.push(`${uploadTime}`);
  33. }
  34. console.log(sql);
  35. console.log(values);
  36. return mysql.pq(sql,values);
  37. }
  38. /**
  39. * 搜索文件数据
  40. * @param type
  41. * @param _params
  42. * @param p
  43. * @param l
  44. * @returns {*}
  45. */
  46. function loadFiles(type = 'array',_params,p,l){
  47. let sql = ``;
  48. let values = [];
  49. if(isEmpty(_params)){
  50. _params = {};
  51. }
  52. if(type === 'count'){
  53. sql = `select count(*) as total `;
  54. }else {
  55. sql = `select * `;
  56. }
  57. sql += `from hfy_files as f
  58. where 1 = 1
  59. `
  60. if(_params.key){
  61. sql += ` and ( f.name like '%${_params.key}% or f.tags like '%${_params.key}%' )`
  62. }
  63. if(_params.type){
  64. sql += ` and f.fileType = ? `;
  65. values.push(_params.type - 1);
  66. }
  67. sql += ` order by f.uploadTime desc `;
  68. return searchSql(mysql.pq,type,sql,values,l,p);
  69. }
  70. function getFileById(fileId){
  71. let sql = `select * from hfy_files where fileId = ?`;
  72. return mysql.pq(sql,[fileId]);
  73. }
  74. function deleteFile(fileId){
  75. let sql = `delete from hfy_files where fileId = ? limit 1`;
  76. return mysql.pq(sql,[fileId]);
  77. }
  78. module.exports = {
  79. getCarousel,
  80. uploadFiles,
  81. loadFiles,
  82. getFileById,
  83. deleteFile,
  84. }