andy/ts-etl-point
1
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases Wiki Activity

coba config

Browse Source
This commit is contained in:
Sas Andy
2024-10-15 11:01:11 +07:00
parent 62ef52eda5
commit a13cd6fe2c
3 changed files with 27 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
config-point-member.json
View File

@@ -1,6 +1,6 @@
{ {
"base_url": "https://devone.aplikasi.web.id/one-api/", "base_url": "http://devone.aplikasi.web.id/one-api/",
"schedule": ["0 5,12,17 * * *"], "schedule": ["*/2 * * * *"],
"delay": 5, "delay": 5,
"row_per_batch": 50 "row_per_batch": 50
} }

6
package.json
View File

@@ -5,9 +5,9 @@
"main": "index.js", "main": "index.js",
"scripts": { "scripts": {
"build": "rimraf build/ && prettier --write source/ && tsc", "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", "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-result-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-result-gw.js && 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-point-member-gw.js && node ./dist/one-point-member-gw.js"
}, },
"keywords": [], "keywords": [],
"author": "", "author": "",

28
source/server.ts
View File

@@ -24,12 +24,18 @@ let isRunning: boolean = false;
logging.info(NAME_SPACE, "Starting " + VERSION); logging.info(NAME_SPACE, "Starting " + VERSION);
const on_init = async () => { const on_init = async () => {
logging.info(NAME_SPACE, "On Init Start"); logging.info(
NAME_SPACE,
"-------------------- ON INT START --------------------"
);
await one_result_job(); await one_result_job();
await cashback(); await cashback();
await payment(); await payment();
await returJob(); await returJob();
logging.info(NAME_SPACE, "On Init End"); logging.info(
NAME_SPACE,
"-------------------- ON INIT END --------------------"
);
}; };
on_init(); on_init();
@@ -52,7 +58,7 @@ async function one_result_job() {
if (mb["data"].length > 0) { if (mb["data"].length > 0) {
member = mb["data"]; member = mb["data"];
} }
logging.info(NAME_SPACE, "\t Success" + mb["data"].length); logging.info(NAME_SPACE, "\t Success, ditemuka : " + mb["data"].length);
} }
//Sleep //Sleep
logging.info(NAME_SPACE, "\t wait 1s"); logging.info(NAME_SPACE, "\t wait 1s");
@@ -87,12 +93,15 @@ async function one_result_job() {
if (mbNat["data"].length > 0) { if (mbNat["data"].length > 0) {
memberNat = mbNat["data"]; memberNat = mbNat["data"];
} }
logging.info(NAME_SPACE, "\t Success" + mbNat["data"].length); logging.info(
NAME_SPACE,
"\t Success, Ditemukan : " + mbNat["data"].length
);
} }
//Sleep //Sleep
logging.info(NAME_SPACE, "\t wait 1s"); logging.info(NAME_SPACE, "\t wait 1s");
await delay(1000); await delay(1000);
console.log("memberNat.length"); // console.log("memberNat.length");
if (memberNat.length > 0) { if (memberNat.length > 0) {
logging.info(NAME_SPACE, "Start Generate Member National"); logging.info(NAME_SPACE, "Start Generate Member National");
for (let i = 0; i < memberNat.length; i++) { 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, "\t wait 1s");
logging.info(NAME_SPACE, "End Job Retur"); logging.info(NAME_SPACE, "End Job Retur");
isRunning = false; isRunning = false;
} catch (e) { } catch (e) {
isRunning = false; isRunning = false;
@@ -298,10 +306,18 @@ for (const sched of config.schedule) {
Xcron.schedule( Xcron.schedule(
sched, sched,
async () => { async () => {
logging.info(
NAME_SPACE,
" -------------------- ON INIT SCHEDULE --------------------"
);
await one_result_job(); await one_result_job();
await cashback(); await cashback();
await payment(); await payment();
await returJob(); await returJob();
logging.info(
NAME_SPACE,
"-------------------- END SCHEDULE--------------------"
);
}, },
{ {
timezone: "Asia/Jakarta", timezone: "Asia/Jakarta",