Finalizado y testeado localmente refresher, listo para testear en

entorno.
This commit is contained in:
pablomartincalvo 2018-10-16 21:19:35 +02:00
parent 8f5a120096
commit 3fdbc5f766
5 changed files with 501 additions and 144 deletions

View file

@ -21,13 +21,41 @@ class CapturasInterface():
self.anunciosdb.query(query_statement, query_parameters)
def old_ads_exist(self):
#TODO Mira si hay algun anuncio que este viejete y necesite refresco
query_statement = """
SELECT uc.referencia
FROM anuncios.ultima_captura_full as uc
LEFT JOIN (SELECT cl.ad_url as ad_url
FROM tasks.capturing_last as cl
WHERE cl.status = 'Dead ad') as da
ON da.ad_url LIKE CONCAT('%', uc.referencia, '%')
WHERE uc.fecha_captura < (NOW() - INTERVAL 10 day)
AND da.ad_url is null
"""
cursor_result = self.anunciosdb.query(query_statement)
resultados = cursor_result.fetchall()
if resultados:
return True
else:
return False
def get_old_ad(self):
#TODO Recuperar anuncio que este viejete y que necesite refresco
def mark_dead_ad(self, referencia):
#TODO Marca un anuncio como muerto
query_statement = """
SELECT uc.referencia
FROM anuncios.ultima_captura_full as uc
LEFT JOIN (SELECT cl.ad_url as ad_url
FROM tasks.capturing_last as cl
WHERE cl.status = 'Dead ad') as da
ON da.ad_url LIKE CONCAT('%', uc.referencia, '%')
WHERE uc.fecha_captura < (NOW() - INTERVAL 10 day)
AND da.ad_url is null
LIMIT 1
"""
cursor_result = self.anunciosdb.query(query_statement, dictionary=True)
try:
return c
except:
return None