step 1 : setting konfigurasi

source/config/config.ts

@@ -0,0 +1,17 @@
+import { readFileSync } from "fs";
+
+interface IConfig {
+  base_url: string;
+  schedule: string[];
+  delay: number;
+  row_per_batch: number;
+}
+const j_config = JSON.parse(readFileSync("./config-etl-tat.json").toString());
+
+const config: IConfig = {
+  base_url: j_config["base_url"],
+  schedule: j_config["schedule"],
+  delay: j_config["delay"],
+  row_per_batch: j_config["row_per_batch"],
+};
+export default config;

source/config/logging.ts

@@ -0,0 +1,48 @@
+import moment from "moment";
+
+const getTimeStamp = (): string => {
+  const dt = moment().format("yyyy-MM-DD HH:mm:ss");
+  return dt;
+};
+
+const info = (namespace: string, message: string, object?: any) => {
+  if (object) {
+    console.log(
+      `[${getTimeStamp()}] [INFO] [${namespace}] [${message}]`,
+      object
+    );
+  } else {
+    console.log(`[${getTimeStamp()}] [INFO] [${namespace}] [${message}]`);
+  }
+};
+
+const warning = (namespace: string, message: string, object?: any) => {
+  if (object) {
+    console.log(
+      `[${getTimeStamp()}] [WARNING] [${namespace}] [${message}]`,
+      object
+    );
+  } else {
+    console.log(`[${getTimeStamp()}] [WARNING] [${namespace}] [${message}]`);
+  }
+};
+
+const error = (namespace: string, message: string, object?: any) => {
+  if (object) {
+    console.log(
+      `[${getTimeStamp()}] [ERROR] [${namespace}] [${message}]`,
+      object
+    );
+  } else {
+    console.log(`[${getTimeStamp()}] [ERROR] [${namespace}] [${message}]`);
+  }
+};
+
+const delay = (time: number) => new Promise((res) => setTimeout(res, time));
+
+export default {
+  info,
+  warning,
+  error,
+  delay,
+};

source/interfaces.ts

@@ -0,0 +1,10 @@
+export interface IOrder {
+  T_OrderHeaderID: string;
+  T_OrderHeaderDate: string;
+  T_OrderHeaderLabNumber: string;
+  T_OrderHeaderLabNumberExt: string;
+  M_PatientNoreg: string;
+  M_PatientIDNumber: string;
+  orderYear: string;
+  branchCode: string;
+}

source/lib_order.ts

@@ -0,0 +1,23 @@
+import axios from "axios";
+import config from "./config/config";
+import logging from "./config/logging";
+import { NAME_SPACE } from "./server";
+
+export const get_order = async (row_per_batch: number) => {
+  const url_patient =
+    config.base_url + "/etl/getorder/getdata?limit=" + row_per_batch;
+  logging.info(NAME_SPACE, "Info : " + url_patient);
+  try {
+    const resp = await axios.get(url_patient, {
+      responseType: "arraybuffer",
+    });
+    const jresp = JSON.parse(resp.data.toString());
+    return jresp;
+  } catch (e) {
+    if (axios.isAxiosError(e)) {
+      logging.error(NAME_SPACE, e.response?.data.toString());
+    } else if (e instanceof Error) {
+      logging.error(NAME_SPACE, e.message);
+    }
+  }
+};

source/server.ts

@@ -0,0 +1,98 @@
+import config from "./config/config";
+import logging from "./config/logging";
+import * as Xcron from "node-cron";
+import { get_order } from "./lib_order";
+import axios from "axios";
+
+export const NAME_SPACE = "OneEtlTat Gateway";
+const VERSION = "1.0";
+
+const pre_url_lab = config.base_url + "/etl/mgmmcu/generate_kelainan_lab/";
+const pre_url_nonlab =
+  config.base_url + "/etl/mgmmcu/generate_kelainan_nonlab/";
+const pre_url_fisik = config.base_url + "/etl/fisik/generate/";
+
+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 {
+    logging.info(NAME_SPACE, "Starting Job " + VERSION);
+    //Get Order
+    logging.info(NAME_SPACE, "Get Etl Mcu");
+    var req = await get_order(config.row_per_batch);
+    if (req["status"] != "OK") {
+      logging.error(NAME_SPACE, "\t Error", req);
+    } else {
+      logging.info(NAME_SPACE, "\t Process Etl start");
+      for (var i = 0; i < req["data"].length; i++) {
+        var nolab = req["data"][i]["no_reg"];
+        logging.info(NAME_SPACE, "\t Process Etl : " + nolab);
+        var headerID = req["data"][i]["T_OrderHeaderID"];
+        var mgmMcuID = req["data"][i]["Mgm_McuID"];
+        var etl_resp = "";
+        //Etl Lab
+        var url_lab = pre_url_lab + "/" + mgmMcuID + "/" + headerID;
+        logging.info(NAME_SPACE, "\t\t Lab :" + url_lab);
+        etl_resp = await axios.get(url_lab);
+        logging.info(NAME_SPACE, "\t\t\t", etl_resp);
+        //Etl NonLab
+        var url_nonlab = pre_url_nonlab + "/" + mgmMcuID + "/" + headerID;
+        logging.info(NAME_SPACE, "\t\t NonLab:" + url_nonlab);
+        etl_resp = await axios.get(url_nonlab);
+        var j_resp = JSON.parse(etl_resp);
+        logging.info(NAME_SPACE, "\t\t\t", j_resp["status"]);
+        //Etl Fisik
+        var url_fisik = pre_url_fisik + "/" + mgmMcuID + "/" + headerID;
+        logging.info(NAME_SPACE, "\t\t Fisik :" + url_fisik);
+        etl_resp = await axios.get(url_fisik);
+        j_resp = JSON.parse(etl_resp);
+        logging.info(NAME_SPACE, "\t\t\t", j_resp["status"]);
+        //Sleep
+        logging.info(NAME_SPACE, "\t wait 3s");
+        await delay(3000);
+      }
+    }
+    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));
+}