TIMOR-TELECOM/gps-backend
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

concurrect 20

Browse Source
This commit is contained in:
Pringgosutono
2025-10-02 21:59:25 +07:00
parent 677ee6325f
commit 5c55b915e1
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
cron/ReverseGeocodeWorker.js
View File

@ -23,12 +23,12 @@ const go = async () => {
host: process.env.PROXY_URL, host: process.env.PROXY_URL,
port: Number(process.env.PROXY_PORT), port: Number(process.env.PROXY_PORT),
}, },
timeout: 10_000, timeout: 15_000,
headers: { "User-Agent": "movana-fleet-management/1.0 (emirsyafmun@gmail.com)" }, // headers: { "User-Agent": "movana-fleet-management/1.0 (emirsyafmun@gmail.com)" },
}) })
const urlBase = request.osm_reverse_geo.urlFull const urlBase = request.osm_reverse_geo.urlFull
function processTrack(track) { function processTrack(track, i) {
return (async () => { return (async () => {
console.log("track:", track.id, track.device_id, track.latitude, track.longitude) console.log("track:", track.id, track.device_id, track.latitude, track.longitude)
let now = moment().unix() let now = moment().unix()
@ -77,8 +77,10 @@ const go = async () => {
return return
} }
const resp = await axInstance.get(`${urlBase}?${params.toString()}`) const resp = await axInstance.get(`${urlBase}?${params.toString()}`, {
const data = resp.data || {} headers: { "User-Agent": `movana-fleet-management-${i}/1.0` },
})
const respData = resp.data || {}
if (resp.status === 200) { if (resp.status === 200) {
console.log("SUCCESS respReverseGeo:", track.id) console.log("SUCCESS respReverseGeo:", track.id)
if (respData.features.length < 1) { if (respData.features.length < 1) {
@ -271,10 +273,10 @@ const go = async () => {
respData.msg = e.message respData.msg = e.message
} }
GpsTracksModels.create2Address({ GpsTracksModels.create2Address({
device_id: tracks[i].device_id, device_id: track.device_id,
master_id: tracks[i].id, master_id: track.id,
lat: tracks[i].latitude, lat: track.latitude,
lng: tracks[i].longitude, lng: track.longitude,
stts_reverse_geo: GpsTracksModels.STTS_REVERSE_GEO_ER, stts_reverse_geo: GpsTracksModels.STTS_REVERSE_GEO_ER,
// log_reverse_geo: JSON.stringify(respData.data), // log_reverse_geo: JSON.stringify(respData.data),
log_reverse_geo: stringify(respData.data), log_reverse_geo: stringify(respData.data),
@ -282,12 +284,12 @@ const go = async () => {
crt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), crt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"),
}) })
updtData.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_ER updtData.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_ER
await GpsTracksModels.update2(tracks[i].id, updtData) await GpsTracksModels.update2(track.id, updtData)
} }
})() })()
} }
// let tracks = []; // let tracks = [];
let tracks = await GpsTracksModels.get2ForReverseGeo(1) let tracks = await GpsTracksModels.get2ForReverseGeo(20)
await Promise.allSettled(tracks.map(processTrack)) await Promise.allSettled(tracks.map(processTrack))