mcu executive test

config-etl-upload-national.json

@@ -1,6 +1,6 @@
 {
-  "base_url": "http://<isi sesuai cabang>/one-api/",
+  "base_url": "http://riau/one-api/",
-  "schedule": ["0 5,12,17 * * *"],
+  "schedule": ["0,10,15 5,12,14,15 * * *"],
   "delay": 5,
   "row_per_batch": 50
 }

source/lib-etl.ts

@@ -656,3 +656,36 @@ export const uploadMgmCompany = async (branchCode: any, mgmMcuID: any) => {
     }
   }
 };
+export const uploadMcuExecutiveTest = async (mgmMcuID: any) => {
+  const url =
+    config.base_url + "etl/Uploadnational/uploadExecutiveTest/" + mgmMcuID;
+  logging.info(NAME_SPACE, "\t\t INFO : " + url);
+  // logging.info(NAME_SPACE, "PRM : ", prm);
+  try {
+    const resp = await axios.post(
+      url,
+      {},
+      {
+        headers: { "Content-Type": "application/json; charset=UTF-8" },
+        responseType: "arraybuffer",
+      }
+    );
+    // console.log(resp.data);
+    const jresp = JSON.parse(resp.data.toString());
+    return jresp;
+  } catch (e) {
+    if (axios.isAxiosError(e)) {
+      logging.error(NAME_SPACE, e.response?.data.toString());
+      return {
+        status: "ERR",
+        message: e.response?.data.toString(),
+      };
+    } else if (e instanceof Error) {
+      logging.error(NAME_SPACE, e.message);
+      return {
+        status: "ERR",
+        message: e.message,
+      };
+    }
+  }
+};

source/server.ts

@@ -8,6 +8,7 @@ import {
   getBranch,
   getMcuorder,
   getMcuSnapshotNote,
+  uploadMcuExecutiveTest,
   getMgmDetail,
   getMgmHeader,
   getMgmMcu,
@@ -424,6 +425,7 @@ async function Upload() {
       }
       logging.info(NAME_SPACE, "\t END JOB MCU SNAPSHOT NOTE");
       logging.info(NAME_SPACE, "\t ----------");
+
       // logging.info(NAME_SPACE, "\t wait 1s");
       // await delay(1000);
 
@@ -462,6 +464,19 @@ async function Upload() {
         // await delay(1000);
       }
 
+      //GET MCU EXECUTIVE TEST
+      logging.info(NAME_SPACE, "\t START GET MCU TEST");
+      var respMcuTest = await uploadMcuExecutiveTest(mgmMcu.Mgm_McuID);
+
+      if (respMcuTest["status"] != "OK") {
+        logging.error(NAME_SPACE, "\t Error : ", respMcuTest);
+      } else {
+        mcuSnapshotNoteList = respMcuTest.data;
+        logging.info(NAME_SPACE, "\t Success");
+      }
+      logging.info(NAME_SPACE, "\t END JOB MCU TEST");
+      logging.info(NAME_SPACE, "\t ----------");
+
       logging.info(NAME_SPACE, "END PROCESS MGM MCU");
       logging.info(NAME_SPACE, "----------");
       // logging.info(NAME_SPACE, "wait 1s");
@@ -501,6 +516,7 @@ async function Upload() {
       // await delay(1000);
     }
     logging.info(NAME_SPACE, "End Job Upload national " + VERSION);
+    isRunning = false;
   } catch (e) {
     console.log("ini eror");
     isRunning = false;
@@ -510,6 +526,7 @@ async function Upload() {
       logging.error(NAME_SPACE, "Unknown");
     }
   }
+  isRunning = false;
 }
 
 // console.log(config);
@@ -521,7 +538,7 @@ for (const sched of config.schedule) {
         NAME_SPACE,
         " -------------------- ON INIT SCHEDULE --------------------"
       );
-
+      await Upload();
       logging.info(
         NAME_SPACE,
         "-------------------- END SCHEDULE--------------------"