const axios = require('axios');
const moment = require('moment');
const { Parser } = require('json2csv');
const fs = require('fs');

let head = []; // 存取 head 資料
...
let timer = null; // 定時抓取資料的計時器
let duration = 60000; // 多久抓一次資料
let token = ''; // 存取 API token
let apiURL = 'put API URL';
let appID = 'put API ID';
let appSecret = 'put API Code';
let startTime = moment().format(); // 紀錄開始時間
let grabMiniute = 3; // 設定要抓取的分鐘數
let endTime = moment(startTime).add(grabMiniute, 'minutes'); // 計算結束的時間

// 取得 API token 
async function getToken() {
  let res = await axios({
    methos: 'GET',
    url: `${apiURL}/api/auth?appId=${appID}&appSecret=${appSecret}`
  });
  token = res.data.data;
}

// 將戳 API 包裝成一個程式，若 token 過期會重戳 API
async function requestAPI(apiMethod, apiURL, retryFunc) {
  try {
    return await axios({
      method: apiMethod,
      url: apiURL,
      headers: {
        AccessToken: token,
        System: appID
      }
    });
  } catch(error) {
    if (error.message.indexOf('401') > -1) {
      // get token
      await getToken();
      retryFunc();
    }
  }
}

// 戳 head API 取資料
async function getHead() {
  let res = await requestAPI('GET', `${apiURL}/api/Head`, getHead);
  if (res) { head = head.concat(res.data); }
  console.log('head', head.length);
}

...

// 一次取得多種資料
async function getAllData() {
  // get token
  await getToken();

  console.log(`----- ${grabMiniute} minutes left -----`);

  // grab data
  getHead();
  getFeeder();
  getNozzle();

  grabMiniute = grabMiniute - 1;
}

// 寫檔案
function writeFile(data, fileName) {
  fs.writeFile(fileName, data, 'utf8', function (err) {
    if (err) {
        console.log(`An error occured while writing ${fileName}.`);
        return console.log(err);
    }

    console.log(`${fileName} has been saved.`);
  });
}

// 轉格式並儲存檔案
function saveFile() {
  try {
    // 將 json 轉 csv
    const fieldsHead = [columnA, ...];
    const fieldsFeeder = [columnA, ...];
    const fieldsNozzle = [columnA, ...];
    const parserHead = new Parser({ fieldsHead });
    const parserFeeder = new Parser({ fieldsFeeder });
    const parserNozzle = new Parser({ fieldsNozzle });
    const csvFeeder = parserFeeder.parse(feeder);
    const csvHead = parserHead.parse(head);
    const csvNozzle = parserNozzle.parse(nozzle);

    console.log(`----- SAVE FILES -----`);
    writeFile(csvHead, 'Head.csv');
    writeFile(csvFeeder, 'Feeder.csv');
    writeFile(csvNozzle, 'Nozzle.csv');
  } catch (err) {
    console.error('saveFile ERROR: ', err);
  }
}

/* ---------------
  Start from here
  ---------------*/
// 一開始先執行
getAllData();

// 啟動計時器
timer = setInterval(() => {
  let now = moment().format();
  if(moment(now).isBefore(endTime)) {
    // 如果還沒到結束時間，就繼續取資料
    getAllData();
  } else {
    // 如果時間到就停止計時器
    clearInterval(timer);
    // 將資料儲存成檔案
    saveFile();
  }
}, duration);