import config from "./config/config";
import logging from "./config/logging";
import * as Xcron from "node-cron";
import { rpt_052_000 } from "./lib_052_master";

export const NAME_SPACE = "OneEtlTat Gateway";
const VERSION = "1.0";

let isRunning: boolean = false;
let isRefreshRunning: boolean = false;

logging.info(NAME_SPACE, "Starting " + VERSION);

const on_init = async () => {
  logging.info(NAME_SPACE, "On Init Start");
  await one_result_job();
  logging.info(NAME_SPACE, "On Init End");
};

on_init();

async function one_result_job() {
  if (isRunning) {
    logging.info(NAME_SPACE, "Still Running");
    return;
  }
  isRunning = true;
  try {
    const cur_date = new Date().toISOString().split("T")[0];

    // array kode
    const arrRpt = [
      { kode: "000", name: "from sp_rpt_052" },
      { kode: "001", name: "from sp_rpt_r_052i" },
      { kode: "002", name: "from sp_rpt_r_052ii" },
      { kode: "003", name: "from sp_rpt_r_052iii" },
      { kode: "004", name: "from sp_rpt_052iiii" },
      { kode: "005", name: "from sp_rpt_052iiiii" },
      { kode: "006", name: "from sp_rpt_052iiiiii" },
      { kode: "007", name: "from sp_rpt_052iiiiiii" },
      { kode: "008", name: "from sp_rpt_052iiiiiiii" },
      { kode: "009", name: "from sp_rpt_052iiiiiiiii" },
      // sekarang n
      { kode: "n006_unique", name: "from sp_rpt_r_052_Niiiiii" },
      { kode: "n007", name: "from sp_rpt_r_052_Niiiiiii" },
      { kode: "n008", name: "from sp_rpt_r_052_Niiiiiiii" },
      { kode: "n009", name: "from sp_rpt_r_052_Niiiiiiiii" },
      { kode: "online", name: "from sp_rpt_r_052_online" },
    ];

    const target = "0";

    logging.info(NAME_SPACE, "Starting Job " + VERSION);

    // jika adhoc
    if (
      config.is_adhoc == true &&
      config.tgl_awal != "" &&
      config.tgl_akhir != ""
    ) {
      const tgl_awal = new Date(config.tgl_awal);
      const tgl_akhir = new Date(config.tgl_akhir);

      if (arrRpt.length > 0) {
        for (
          let d = new Date(tgl_awal);
          d <= tgl_akhir;
          d.setDate(d.getDate() + 1)
        ) {
          // console.log(d.toISOString().split("T")[0]);
          const tgl_loop = d.toISOString().split("T")[0];
          for (let index = 0; index < arrRpt.length; index++) {
            const element = arrRpt[index];
            // rpt_052_000
            logging.info(NAME_SPACE, "kode : " + element.kode);
            logging.info(NAME_SPACE, "nama rpt : " + element.name);
            logging.info(NAME_SPACE, "tgl adhoc : " + tgl_loop);
            logging.info(NAME_SPACE, "is_adhoc : " + config.is_adhoc);
            var resp = await rpt_052_000(element.kode, tgl_loop, target);
            if (resp["status"] == "OK") {
              logging.info(NAME_SPACE, "\t Success");
            } else {
              logging.error(NAME_SPACE, "\t Error " + resp["message"]);
            }
            logging.info(NAME_SPACE, "Wait " + config.delay + " second");
            await delay(config.delay * 1000);
          }
        }
      }
    } else {
      // selain adhoc
      if (arrRpt.length > 0) {
        for (let index = 0; index < arrRpt.length; index++) {
          const element = arrRpt[index];
          // rpt_052_000
          logging.info(NAME_SPACE, "kode : " + element.kode);
          logging.info(NAME_SPACE, "nama rpt : " + element.name);
          logging.info(NAME_SPACE, "tgl curr date : " + cur_date);
          logging.info(NAME_SPACE, "is_adhoc : " + config.is_adhoc);
          var resp = await rpt_052_000(element.kode, cur_date, target);
          if (resp["status"] == "OK") {
            logging.info(NAME_SPACE, "\t Success");
          } else {
            logging.error(NAME_SPACE, "\t Error " + resp["message"]);
          }
          logging.info(NAME_SPACE, "Wait " + config.delay + " second");
          await delay(config.delay * 1000);
        }
      }
    }

    logging.info(NAME_SPACE, "End Job");
    isRunning = false;
  } catch (e) {
    isRunning = false;
    if (e instanceof Error) {
      logging.error(NAME_SPACE, e.message);
    } else {
      logging.error(NAME_SPACE, "Unknown");
    }
  }
}
// console.log(config);
for (const sched of config.schedule) {
  Xcron.schedule(
    sched,
    async () => {
      await one_result_job();
    },
    {
      timezone: "Asia/Jakarta",
    }
  );
}

// ------------- function
async function delay(ms: number) {
  return new Promise((resolve) => setTimeout(resolve, ms));
}