bugfix
This commit is contained in:
parent
befa093a30
commit
6e5911ad46
@ -145,6 +145,7 @@ class TransferGateway(Gateway):
|
|||||||
from ahserver.serverenv import ServerEnv
|
from ahserver.serverenv import ServerEnv
|
||||||
self.running = True
|
self.running = True
|
||||||
while self.running:
|
while self.running:
|
||||||
|
debug(f'mail check loop running')
|
||||||
try:
|
try:
|
||||||
ec = EmailClient(self.pop3server, self.email, self.password)
|
ec = EmailClient(self.pop3server, self.email, self.password)
|
||||||
count, _ = ec.stat()
|
count, _ = ec.stat()
|
||||||
@ -155,11 +156,14 @@ class TransferGateway(Gateway):
|
|||||||
try:
|
try:
|
||||||
mail = ec.get_mail(i)
|
mail = ec.get_mail(i)
|
||||||
if mail.mailfrom != '95555@message.cmbchina.com':
|
if mail.mailfrom != '95555@message.cmbchina.com':
|
||||||
|
debug(f'ignored mail from {mail.mailfrom=}')
|
||||||
continue
|
continue
|
||||||
if not mail.body.startswith('动账业务通知'):
|
if not mail.body.startswith('动账业务通知'):
|
||||||
|
debug(f'ignored mail from {mail.mailfrom=} not start with 动账业务通知{mail.body=}')
|
||||||
continue
|
continue
|
||||||
data = self.get_transfer_data(mail)
|
data = self.get_transfer_data(mail)
|
||||||
if data is None:
|
if data is None:
|
||||||
|
debug(f'ignored mail from {mail.mailfrom=} get data error {mail.body=}')
|
||||||
continue
|
continue
|
||||||
debug(f'transfer mail matched: code={data.code}, amount={data.amount}')
|
debug(f'transfer mail matched: code={data.code}, amount={data.amount}')
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user