ondemand/ondemand.py

@@ -164,55 +164,57 @@ def procesar_trabajo(pendiente):
     except Exception as err:
         log.info(err)
 
-    if len(media) == 0 or len(anuncio) == 0:
-        log.info("No hay media o anuncios para comparar")
-        return
-
-    dejavu = None
-    resultados = {}
     try:
-        dejavu = Dejavu({"database_type": "mem"})
-        try:
-            x = 0
-            for ruta, fecha, ts in media:
-                log.info("Huellando %s" % (ruta,))
-                dejavu.fingerprint_file(ruta, ts)
-        except Exception as ex:
-            log.info(ex)
-
-        for anuncio in anuncios:
-            log.info("Buscando anuncio %s" % (anuncio,))
-            for i in dejavu.recognize(recognizer, anuncio, segmento):
-                if not "id" in i:
-                    continue
-
-                if i["confidence"] < 35:
-                    continue
-
-                obj = i
-                obj["match_time"] = None
-                nombre_anuncio = os.path.split(anuncio)[-1]
-                id = id_by_ad[nombre_anuncio]
-                dict = {
-                    "id": id,
-                    "anuncio": anuncio,
-                    "fecha": obj["name"],
-                    "timestamp": obj["name"] + int(obj['offset_seconds']),
-                    "confianza": obj["confidence"],
-                    "longitud": obj["length"],
-                    "desfase_segundos": obj["offset_seconds"]
-                }
-
-                if id in resultados.keys():
-                    resultados[id]["longitud"] += dict["longitud"]
-                    resultados[id]["confianza"] += dict["confianza"]
-                    continue
-
-                resultados[id] = dict
+
+        dejavu = None
+        resultados = {}
+        if len(media) > 0 or len(anuncio) > 0:
+            dejavu = Dejavu({"database_type": "mem"})
+            try:
+                x = 0
+                for ruta, fecha, ts in media:
+                    log.info("Huellando %s" % (ruta,))
+                    dejavu.fingerprint_file(ruta, ts)
+            except Exception as ex:
+                log.info(ex)
+
+            for anuncio in anuncios:
+                log.info("Buscando anuncio %s" % (anuncio,))
+                for i in dejavu.recognize(recognizer, anuncio, segmento):
+                    if not "id" in i:
+                        continue
+
+                    if i["confidence"] < 35:
+                        continue
+
+                    obj = i
+                    obj["match_time"] = None
+                    nombre_anuncio = os.path.split(anuncio)[-1]
+                    id = id_by_ad[nombre_anuncio]
+                    dict = {
+                        "id": id,
+                        "anuncio": anuncio,
+                        "fecha": obj["name"],
+                        "timestamp": obj["name"] + int(obj['offset_seconds']),
+                        "confianza": obj["confidence"],
+                        "longitud": obj["length"],
+                        "desfase_segundos": obj["offset_seconds"]
+                    }
+
+                    if id in resultados.keys():
+                        resultados[id]["longitud"] += dict["longitud"]
+                        resultados[id]["confianza"] += dict["confianza"]
+                        continue
+
+                    resultados[id] = dict
+        else:
+            for i in pendiente['elementos']:
+                i['comentario'] = 'Problemas técnicos'
 
         for id in resultados:
             e = resultados[id]
             for i in pendiente['elementos']:
+                i['comentario'] = ''
                 anuncio = e['anuncio'].replace('/tmp/ads/', '')
                 if i['id'] == e['id'] and i['anuncio'] == anuncio:
                     if 'encontrados' not in i: