server/commonservices
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2020-11-26 17:36:36 +08:00
parent 5015343249
commit e2c64e7250
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server/mailsender_py/mailsender.py
View File

@ -93,10 +93,14 @@ def fetchEvent():
handled_idx.append(row[0]) handled_idx.append(row[0])
time.sleep(0.001); time.sleep(0.001);
else: else:
break for idx in handled_idx:
for idx in handled_idx: cursor.execute('UPDATE `event` SET status = 1 WHERE idx = %d '
cursor.execute('UPDATE `event` SET status = 1 WHERE idx = %d ' % (idx))
% (idx)) print('UPDATE `event` SET status = 1 WHERE idx = %d '
% (idx))
conn.commit()
if len(handled_idx) <= 0:
break
#end while #end while
db_idx_hash[conf['instance_id']] = last_idx db_idx_hash[conf['instance_id']] = last_idx
@ -107,6 +111,7 @@ def fetchEventTimerFunc(refresh_time):
f7.app.createAsyncTask(done_callback, fetchEvent, ()) f7.app.createAsyncTask(done_callback, fetchEvent, ())
def dailyMail(): def dailyMail():
return
mysql_cluster_conf = json.loads(open(CONFIG_DIR + '/mailsender.mysql.cluster.json', 'r').read()) mysql_cluster_conf = json.loads(open(CONFIG_DIR + '/mailsender.mysql.cluster.json', 'r').read())
for conf in mysql_cluster_conf: for conf in mysql_cluster_conf:
conn = pymysql.connect(host = conf['host'], conn = pymysql.connect(host = conf['host'],