worker sp

require('dotenv').config()
const axios = require('axios')
const moment = require('moment')
const periodic = process.env.periodic
const karyawan_api = process.env.karyawan_api
const cek_presensi_api = process.env.cek_presensi_api
const input_sp_api = process.env.input_sp_api
const interval_axios = process.env.interval_axios

let tanggal = moment().format("YYYY-MM-DD")

function sleep(millis) {
    return new Promise(resolve => setTimeout(resolve, millis));
}

async function main() {
    try {
        axios.get(karyawan_api).then(async function (karyawan_request) {
            if(karyawan_request.status == 200) {
                console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + "data karyawan sudah didapat")
                let karyawan = karyawan_request.data
                for(let i = 0; i < karyawan.length; i++) {
                    let request_cek_kehadiran = {
                        karyawan_id: karyawan[i].id,
                        tanggal: tanggal
                    }
                    axios.post(cek_presensi_api, request_cek_kehadiran).then(async function (presensi_request) {
                        if(presensi_request.status == 200) {
                            let request_input_sp = {
                                karyawan_id: presensi_request.data.karyawan_id,
                                jadwal_id: presensi_request.data.jadwal_id,
                                tipe_jadwal: presensi_request.data.tipe_jadwal,
                                status_libur: presensi_request.data.status_libur,
                                status_izin: presensi_request.data.status_izin,
                                status_sakit: presensi_request.data.status_sakit,
                                status_cuti: presensi_request.data.status_cuti,
                                status_tap: presensi_request.data.status_tap,
                                tanggal: presensi_request.data.tanggal
                            }
                            axios.post(input_sp_api, request_input_sp).then(async function (sp_response) {
                                if(sp_response.status == 200) {
                                    console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + "memproses karyawan id:" + karyawan[i].id + " nama: " + karyawan[i].nama)
                                    console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + JSON.stringify(presensi_request.data))
                                    console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + JSON.stringify(sp_response.data))
                                } else {
                                    console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + "memproses karyawan id:" + karyawan[i].id + " nama: " + karyawan[i].nama)
                                    console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + JSON.stringify(presensi_request.data))
                                    console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + "Input Gagal")
                                }
                            })
                            await sleep(interval_axios)
                        } else {
                            console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + "Gagal Cek Presensi")
                        }
                    })
                    await sleep(interval_axios)
                }
            } else {
                console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + "Gagal Ambil Data Karyawan")
            }
        })
        await sleep(interval_axios)
    } catch (e) {
        console.log("[" + moment().format("YYYY-MM-DD HH:mm:ss") + "] " + "Error: " + e.message)
    }
    await sleep(periodic)
}

main()