Cleanup Routine3
parent
cd04980b6c
commit
31b1261d23
|
@ -193,11 +193,13 @@ async def cleanupSent():
|
||||||
dest = await db.execute(select(Destinatario).where(Destinatario.timestamp<oneMonth, Destinatario.enviado>0).limit(1))
|
dest = await db.execute(select(Destinatario).where(Destinatario.timestamp<oneMonth, Destinatario.enviado>0).limit(1))
|
||||||
|
|
||||||
for destinatario in dest.scalars():
|
for destinatario in dest.scalars():
|
||||||
|
await log.debug('Deleting Dest: {}'.format(destinatario.id))
|
||||||
cartaid = destinatario.cartaid
|
cartaid = destinatario.cartaid
|
||||||
await db.execute(delete(Destinatario).where(Destinatario.id==destinatario.id))
|
await db.execute(delete(Destinatario).where(Destinatario.id==destinatario.id))
|
||||||
result = await db.execute(select(Destinatario).where(Destinatario.cartaid==cartaid).limit(1))
|
result = await db.execute(select(Destinatario).where(Destinatario.cartaid==cartaid).limit(1))
|
||||||
more = result.scalar_one_or_none()
|
more = result.scalar_one_or_none()
|
||||||
if more is None:
|
if more is None:
|
||||||
|
await log.info('Deleting Carta: {}'.format(cartaid))
|
||||||
await db.execute(delete(Carta).where(Carta.id==cartaid))
|
await db.execute(delete(Carta).where(Carta.id==cartaid))
|
||||||
returnvalue = False
|
returnvalue = False
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue