step 2 : try build

source/config/config.ts

@@ -5,6 +5,10 @@ interface IConfig {
   schedule: string[];
   delay: number;
   row_per_batch: number;
+  // kode, date, target
+  // kode:string,
+  // date:string,
+  // target:string
 }
 const j_config = JSON.parse(readFileSync("./config-etl-tat.json").toString());
 
@@ -13,5 +17,9 @@ const config: IConfig = {
   schedule: j_config["schedule"],
   delay: j_config["delay"],
   row_per_batch: j_config["row_per_batch"],
+  // kode, date, target
+  // kode: j_config["kode"],
+  // date: j_config["date"],
+  // target: j_config["target"]
 };
 export default config;

source/lib_052_000.ts

@@ -0,0 +1,28 @@
+import axios from "axios";
+import config from "./config/config";
+import logging from "./config/logging";
+import { NAME_SPACE } from "./server";
+
+export const rpt_052_000 = async (
+  kode: string,
+  date: string,
+  target: string
+) => {
+  // etl/Tat/proses_etl/000/2021-06-12/0
+  const url_patient =
+    config.base_url + "etl/Tat/proses_etl/" + kode + "/" + date + "/" + target;
+  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

@@ -1,17 +1,10 @@
 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;
 
@@ -32,42 +25,23 @@ async function one_result_job() {
   }
   isRunning = true;
   try {
+    let dateTime = new Date();
+    let dateTimeString = dateTime.toString();
+
     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, "dateTimeString " + dateTimeString);
+
+    // rpt_052_000
+    // logging.info(NAME_SPACE, "rpt_052_000");
+    // var resp = await rpt_052_000("000",dateTimeString,"0");
+    // 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) {