|
@@ -214,7 +214,15 @@ def procesar_trabajo(pendiente):
|
|
|
if i['id'] == e['id'] and i['anuncio'] == anuncio:
|
|
if i['id'] == e['id'] and i['anuncio'] == anuncio:
|
|
|
if 'encontrados' not in i:
|
|
if 'encontrados' not in i:
|
|
|
i['encontrados'] = []
|
|
i['encontrados'] = []
|
|
|
- i['encontrados'].append(e)
|
|
|
|
|
|
|
+ obj = {
|
|
|
|
|
+ "fecha": e["fecha"],
|
|
|
|
|
+ "anuncio": anuncio,
|
|
|
|
|
+ "longitud": int(e["longitud"] / 1000),
|
|
|
|
|
+ "confianza": e["confianza"],
|
|
|
|
|
+ "timestamp": e["timestamp"],
|
|
|
|
|
+ "desfase_segundos": e["desfase_segundos"]
|
|
|
|
|
+ }
|
|
|
|
|
+ i['encontrados'].append(obj)
|
|
|
break
|
|
break
|
|
|
|
|
|
|
|
log.info("[Resultado] %s" % (json.dumps(resultados)))
|
|
log.info("[Resultado] %s" % (json.dumps(resultados)))
|
