first commit

2024-09-20 16:41:59 +07:00
commit 6467a966c1
19 changed files with 1897 additions and 0 deletions
--- a/source/server.ts
+++ b/source/server.ts
@@ -0,0 +1,99 @@
+import config from "./config/config";
+import logging from "./config/logging";
+import * as Xcron from "node-cron";
+
+import { getJurnal, injectJurnalTx } from "./lib_jurnaltx";
+import axios from "axios";
+
+export const NAME_SPACE = "Point Member Gateway";
+const VERSION = "1.0";
+
+let isRunning: boolean = false;
+
+logging.info(NAME_SPACE, "Starting " + VERSION);
+
+const on_init = async () => {
+  logging.info(NAME_SPACE, "On Init Start");
+
+  await jurnalTxJob();
+  logging.info(NAME_SPACE, "On Init End");
+};
+
+on_init();
+
+async function jurnalTxJob() {
+  if (isRunning) {
+    logging.info(NAME_SPACE, "Still Running");
+    return;
+  }
+  isRunning = true;
+  try {
+    logging.info(NAME_SPACE, "Starting Job Jurbal TX" + VERSION);
+    // UPLOAD
+    logging.info(NAME_SPACE, "Start Get Jurnal Tx");
+    var respJurnal = await getJurnal("2024-09-18");
+    if (respJurnal["status"] != "OK") {
+      logging.error(NAME_SPACE, "\t Error", respJurnal);
+    } else {
+      logging.info(NAME_SPACE, "\t Success Get Jurnal TX ");
+    }
+    // console.log(respJurnal["data"]);
+    // console.log(respJurnal["jurnalID"]);
+    logging.info(NAME_SPACE, "\t wait 1s");
+    if (respJurnal["data"].length === 0) {
+      logging.info(NAME_SPACE, "\t Tidak ada jurnal");
+    } else {
+      for (let i = 0; i < respJurnal["data"].length; i++) {
+        const e = respJurnal["data"][i];
+        e.jurnalID = respJurnal["jurnalID"];
+        logging.info(
+          NAME_SPACE,
+          "Start Insert Jurnal Tx, JURNAL ID :" +
+            respJurnal["jurnalID"].toString()
+        );
+        var respInsert = await injectJurnalTx(e);
+        if (respInsert["status"] != "OK") {
+          logging.error(NAME_SPACE, "\t Error", respInsert);
+        } else {
+          logging.info(NAME_SPACE, "\t " + respInsert["data"]);
+        }
+        //Sleep
+        logging.info(NAME_SPACE, "\t wait 1s");
+        logging.info(
+          NAME_SPACE,
+          "End Insert Jurnal Tx, JURNAL ID :" +
+            respJurnal["jurnalID"].toString()
+        );
+        await delay(1000);
+      }
+    }
+
+    logging.info(NAME_SPACE, "End Job Jurnal TX");
+
+    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 jurnalTxJob();
+    },
+    {
+      timezone: "Asia/Jakarta",
+    }
+  );
+}
+
+// ------------- function
+async function delay(ms: number) {
+  return new Promise((resolve) => setTimeout(resolve, ms));
+}