ops/promotion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

revome gameid from localtion

Browse Source
This commit is contained in:
pengtao 2019-07-17 10:03:48 +08:00
parent c8385c347f
commit 9728d1eb6e
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ad_interface_tornado.py
View File

@ -18,6 +18,7 @@ log = logging.getLogger(__name__)
def send_cache_data(): def send_cache_data():
print("send cache start!")
mydb = MysqlBase(**mysql_promotion_config) mydb = MysqlBase(**mysql_promotion_config)
log.info("start!") log.info("start!")
now = datetime.datetime.today().strftime("%Y-%m-%d %H:%M:%S") now = datetime.datetime.today().strftime("%Y-%m-%d %H:%M:%S")
@ -76,7 +77,7 @@ def send_cache_data():
len_all = len(all) len_all = len(all)
log.info(f"write {len_all} to cache!") log.info(f"write {len_all} to cache!")
log.info("bengin revome !") log.info("bengin revome !")
print("remove old recording!")
remove_sql = f"select id,gameid,locationid from ad where '{now}'>=end_time" remove_sql = f"select id,gameid,locationid from ad where '{now}'>=end_time"
rm_data = mydb.query(remove_sql) rm_data = mydb.query(remove_sql)
if rm_data: if rm_data:
@ -159,10 +160,9 @@ def make_app():
if __name__ == "__main__": if __name__ == "__main__":
import pdb import pdb
send_cache_data() #send_cache_data()
print('start!') print('start!')
app = make_app() app = make_app()
app.listen(ad_list_interface_port) app.listen(ad_list_interface_port)
tornado.ioloop.PeriodicCallback(send_cache_data, 60000).start() tornado.ioloop.PeriodicCallback(send_cache_data, 60000).start()
# tornado.ioloop.IOLoop.current().call_at(time.time() + 60, lambda: sendNotify(conf, conf['sendtime1']))
tornado.ioloop.IOLoop.current().start() tornado.ioloop.IOLoop.current().start()