update
This commit is contained in:
@ -24,11 +24,11 @@ const go = async () => {
|
|||||||
port: Number(process.env.PROXY_PORT),
|
port: Number(process.env.PROXY_PORT),
|
||||||
},
|
},
|
||||||
timeout: 10_000,
|
timeout: 10_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,7 +77,9 @@ const go = async () => {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
const resp = await axInstance.get(`${urlBase}?${params.toString()}`)
|
const resp = await axInstance.get(`${urlBase}?${params.toString()}`, {
|
||||||
|
headers: { "User-Agent": `movana-fleet-management-` + i },
|
||||||
|
})
|
||||||
const respData = resp.data || {}
|
const respData = resp.data || {}
|
||||||
if (resp.status === 200) {
|
if (resp.status === 200) {
|
||||||
console.log("SUCCESS respReverseGeo:", track.id)
|
console.log("SUCCESS respReverseGeo:", track.id)
|
||||||
@ -287,7 +289,7 @@ const go = async () => {
|
|||||||
})()
|
})()
|
||||||
}
|
}
|
||||||
// let tracks = [];
|
// let tracks = [];
|
||||||
let tracks = await GpsTracksModels.get2ForReverseGeo(10)
|
let tracks = await GpsTracksModels.get2ForReverseGeo(20)
|
||||||
|
|
||||||
await Promise.allSettled(tracks.map(processTrack))
|
await Promise.allSettled(tracks.map(processTrack))
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user