const _ = require('lodash');
const dayjs = require('dayjs');
const {mysqlPool} = require('../../libs/mysql');
const {sendMessage} = require('../../libs/influx-report');
const {logger} = require('../../libs/logger');

module.exports = async() => {
  const insertTime = dayjs().startOf('day').unix();
  const leastDay = await mysqlPool.query('SELECT MAX(`create_time`) AS create_time FROM `price_trend_day`');
  const resultExists = await mysqlPool.query('SELECT 1 AS Num FROM `price_trend_sixty_day` WHERE `create_time` = :createTime limit 1', {
    createTime: insertTime
  });

  if (resultExists.length > 0) {
    logger.info(`[price-60day-task] exists createtime price: ${insertTime}`);
    return;
  }
  if (leastDay.length) {
    const dayTime = _.first(leastDay).create_time;

    if (dayTime) {
      const {affectedRows} = await mysqlPool.execute('INSERT INTO `price_trend_sixty_day` (`product_id`, `size_id`, `skn_price`, `sku_price`, `create_time`) SELECT `product_id`, `size_id`, `skn_price`, `sku_price`, :insertTime FROM `price_trend_day` WHERE `create_time` = :createTime', {
        createTime: dayTime,
        insertTime
      });

      logger.info(`[price-60day-task] insert ${affectedRows}`);
      sendMessage(affectedRows, new Date().getTime() * 1000000, 'price-60day-task-inserted');
    }
  }
};