diff --git a/config-point-member.json b/config-point-member.json index 6435b0c..2f47650 100644 --- a/config-point-member.json +++ b/config-point-member.json @@ -1,6 +1,6 @@ { - "base_url": "https://devone.aplikasi.web.id/one-api/", - "schedule": ["0 5,12,17 * * *"], + "base_url": "http://devone.aplikasi.web.id/one-api/", + "schedule": ["*/2 * * * *"], "delay": 5, "row_per_batch": 50 } diff --git a/package.json b/package.json index 7d8f423..53948e5 100644 --- a/package.json +++ b/package.json @@ -5,9 +5,9 @@ "main": "index.js", "scripts": { "build": "rimraf build/ && prettier --write source/ && tsc", - "compile": "cross-env NODE_OPTIONS=--openssl-legacy-provider ncc build build/server.js -m -o dist && move dist\\index.js dist\\one-result-gw.js", - "start": "node ./dist/one-result-gw.js", - "bcs": "rimraf build/ && prettier --write source/ && tsc && cross-env NODE_OPTIONS=--openssl-legacy-provider ncc build build/server.js -m -o dist && move dist\\index.js dist\\one-result-gw.js && node ./dist/one-result-gw.js" + "compile": "cross-env NODE_OPTIONS=--openssl-legacy-provider ncc build build/server.js -m -o dist && move dist\\index.js dist\\one-point-member-gw.js", + "start": "node ./dist/one-point-member-gw.js", + "bcs": "rimraf build/ && prettier --write source/ && tsc && cross-env NODE_OPTIONS=--openssl-legacy-provider ncc build build/server.js -m -o dist && move dist\\index.js dist\\one-point-member-gw.js && node ./dist/one-point-member-gw.js" }, "keywords": [], "author": "", diff --git a/source/server.ts b/source/server.ts index bc21ed6..20de894 100644 --- a/source/server.ts +++ b/source/server.ts @@ -24,12 +24,18 @@ let isRunning: boolean = false; logging.info(NAME_SPACE, "Starting " + VERSION); const on_init = async () => { - logging.info(NAME_SPACE, "On Init Start"); + logging.info( + NAME_SPACE, + "-------------------- ON INT START --------------------" + ); await one_result_job(); await cashback(); await payment(); await returJob(); - logging.info(NAME_SPACE, "On Init End"); + logging.info( + NAME_SPACE, + "-------------------- ON INIT END --------------------" + ); }; on_init(); @@ -52,7 +58,7 @@ async function one_result_job() { if (mb["data"].length > 0) { member = mb["data"]; } - logging.info(NAME_SPACE, "\t Success" + mb["data"].length); + logging.info(NAME_SPACE, "\t Success, ditemuka : " + mb["data"].length); } //Sleep logging.info(NAME_SPACE, "\t wait 1s"); @@ -87,12 +93,15 @@ async function one_result_job() { if (mbNat["data"].length > 0) { memberNat = mbNat["data"]; } - logging.info(NAME_SPACE, "\t Success" + mbNat["data"].length); + logging.info( + NAME_SPACE, + "\t Success, Ditemukan : " + mbNat["data"].length + ); } //Sleep logging.info(NAME_SPACE, "\t wait 1s"); await delay(1000); - console.log("memberNat.length"); + // console.log("memberNat.length"); if (memberNat.length > 0) { logging.info(NAME_SPACE, "Start Generate Member National"); for (let i = 0; i < memberNat.length; i++) { @@ -282,7 +291,6 @@ async function returJob() { logging.info(NAME_SPACE, "\t wait 1s"); logging.info(NAME_SPACE, "End Job Retur"); - isRunning = false; } catch (e) { isRunning = false; @@ -298,10 +306,18 @@ for (const sched of config.schedule) { Xcron.schedule( sched, async () => { + logging.info( + NAME_SPACE, + " -------------------- ON INIT SCHEDULE --------------------" + ); await one_result_job(); await cashback(); await payment(); await returJob(); + logging.info( + NAME_SPACE, + "-------------------- END SCHEDULE--------------------" + ); }, { timezone: "Asia/Jakarta",