const {searchHandle} = require('../tools/searchSql');
const {handle} = require('../tools/handle_cjs');
const codeMap = require("../map/rcodeMap");
const log = require("../logger").logger("c_solution","info");

const d_news = require("../database/d_news");
const d_product = require("../database/d_product");
const {filePathToUrl} = require("../tools/filePathTool");

async function addReadNum(newId){
  let [err,res] = await handle(d_news.addReadNum(newId));
  if(err){
    return [err,null];
  }
  return [null,'ok'];
}

async function searchNewsByMini(type, key, p, l){
  p = p || 1;
  l = l || 10;
  let _params = {
  }
  if(type !== 'all'){
    _params.type = type;
  }
  if(key){
    _params.key = key
  }


  return await searchHandle(
    '搜索文章失败',
    d_news.searchAllNewsMini,
    _params,
    null,
    p,
    l,
  );
}


async function addArticle(article){
  let res;
  // 获取文章类型
  let [err, typeRes] = await handle(d_news.getTypeByKey(article.type));
  if(err){
    log.error(err);
    log.error(`[新增文章] 获取文章类型失败 ${err.message}`);
    return [{
      code: codeMap.ServerError,
      message: `文章类型校验失败`
    }, null];
  }
  if(typeRes.length === 0){
    log.error(`[新增文章] 文章类型不存在`);
    return [{
      code: codeMap.NotFound,
      message: `文章类型不存在`
    }, null];
  }
  let typeItem = typeRes[0];
  [err, res] = await handle(d_news.addArticle(article, typeItem.type_id));
  if(err){
    log.error(`[新增文章] 新增文章失败 ${err.message}`);
    return [{
      code: codeMap.ServerError,
      message: `服务器错误,新增文章失败`
    }, null];
  }
  return [null, res];
}

module.exports = {
  addReadNum,
  searchNewsByMini,
  addArticle
}