const dayjs = require('dayjs');
const nodeLockup = require('node-lockup');
const spider = require('../libs/spider');
const {logger} = require('../libs/logger');
const fs = require('fs');
const _ = require('lodash');


const REG_HOUR = /^[1,2]小时/;
const REG_MINUES = /^\d+分钟/;

const fetchBuys = async(productId, lsId = 0) => {
  let lastList = [];
  const result = await spider.spiderFetch(productId, 'https://du.hupu.com/mapi/product/lastSoldList', {
    lastId: lsId
  });

  if (result.status === 200) {
    const {list, lastId} = result.data;

    lastList = list.filter(info => {
      return REG_HOUR.test(info.formatTime) || REG_MINUES.test(info.formatTime) || info.formatTime.indexOf('刚刚') >= 0;
    });

    if (lastList.length) {
      const nextList = await fetchBuys(productId, lastId);

      lastList = lastList.concat(nextList);
    }
  }

  return lastList;
};

const processBuys = async(data) => {
  const allList = await fetchBuys(data.productId);

  data.sizes.forEach(size => {
    const buys = allList.filter(info => {
      return info.item && info.item.size === size.size;
    });

    size.soldNum += buys.length;
  });

  return data;
};


const task = async(id) => {
  const result = await spider.spiderFetch(id);

  if (result.status === 200) {
    const {detail, sizeList} = result.data;

    const productId = detail.productId;
    const soldNum = detail.soldNum;
    const articleNumber = detail.articleNumber;

    // const sizes = sizeList.map(sizeItem => {
    //   return {
    //     size: sizeItem.size,
    //     price: _.isEmpty(sizeItem.item) ? 0 : sizeItem.item.price,
    //     soldNum: 0
    //   };
    // });

    // const dest = await processBuys({
    //   productId,
    //   soldNum,
    //   sizes
    // });

    return {
      productId,
      soldNum,
      articleNumber
    };
  }
};

module.exports = async() => {
  const now = dayjs().format('YYYY-MM-DD_HH');
  const fw = fs.createWriteStream(`/Data/logs/node/prices/${now}.log`, {
    flags: 'a'
  });
  const lockTask = nodeLockup(task, 1);

  const ids = Array.from(new Array(22080)).map((v, i) => i + 1);

  try {
    ids.forEach((id, inx) => {
      lockTask(id).then(async result => {
        if (result) {

          logger.info(`time:${now}; productId:${id}; soldNum:${result.soldNum};`);

          fw.write(`${JSON.stringify(result)}\n`);
        }
        if (inx >= ids.length - 1) {
          fw.end('');
        }
      });
    });
  } catch (error) {
    fw.end(error.toString());
  }
};