diff --git a/cron/ReverseGeocodeWorker.js b/cron/ReverseGeocodeWorker.js index e4efb6a..7def228 100644 --- a/cron/ReverseGeocodeWorker.js +++ b/cron/ReverseGeocodeWorker.js @@ -23,12 +23,12 @@ const go = async () => { host: process.env.PROXY_URL, port: Number(process.env.PROXY_PORT), }, - timeout: 10_000, - headers: { "User-Agent": "movana-fleet-management/1.0 (emirsyafmun@gmail.com)" }, + timeout: 15_000, + // headers: { "User-Agent": "movana-fleet-management/1.0 (emirsyafmun@gmail.com)" }, }) const urlBase = request.osm_reverse_geo.urlFull - function processTrack(track) { + function processTrack(track, i) { return (async () => { console.log("track:", track.id, track.device_id, track.latitude, track.longitude) let now = moment().unix() @@ -77,8 +77,10 @@ const go = async () => { return } - const resp = await axInstance.get(`${urlBase}?${params.toString()}`) - const data = resp.data || {} + const resp = await axInstance.get(`${urlBase}?${params.toString()}`, { + headers: { "User-Agent": `movana-fleet-management-${i}/1.0` }, + }) + const respData = resp.data || {} if (resp.status === 200) { console.log("SUCCESS respReverseGeo:", track.id) if (respData.features.length < 1) { @@ -271,10 +273,10 @@ const go = async () => { respData.msg = e.message } GpsTracksModels.create2Address({ - device_id: tracks[i].device_id, - master_id: tracks[i].id, - lat: tracks[i].latitude, - lng: tracks[i].longitude, + device_id: track.device_id, + master_id: track.id, + lat: track.latitude, + lng: track.longitude, stts_reverse_geo: GpsTracksModels.STTS_REVERSE_GEO_ER, // log_reverse_geo: JSON.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"), }) 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 = await GpsTracksModels.get2ForReverseGeo(1) + let tracks = await GpsTracksModels.get2ForReverseGeo(20) await Promise.allSettled(tracks.map(processTrack))