wishpal_ironfan
/
scripts
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add

This commit is contained in:
lwl0608 2024-02-04 23:50:55 +08:00
parent 99b3d936b6
commit 126804da37
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cronjob/vas/vas_deal.py
View File

@ -7,23 +7,19 @@ logger = Logger(service_name, log_dir=log_dir)
class S: class S:
def __init__(self): def __init__(self):
self.table_vas_order = Mysql( self.mysql_db_vas = Mysql(
"rm-bp11t1616a1kjvmx5.mysql.rds.aliyuncs.com", 3306, "vas", "vas_order" "rm-bp11t1616a1kjvmx5.mysql.rds.aliyuncs.com", 3306, "vas", "root", "Wishpal2024"
)
self.table_vas_coin_order = Mysql(
"rm-bp11t1616a1kjvmx5.mysql.rds.aliyuncs.com", 3306, "vas", "vas_coin_order"
) )
def __del__(self): def __del__(self):
self.table_vas_order.close() self.mysql_db_vas.close()
self.table_vas_coin_order.close()
# 获取订单 # 获取订单
def get_orders(self): def get_orders(self):
sql = ''' sql = '''
select * from vas_coin_order where ct<{} and order_status=1 and product_id='membership' select * from vas_coin_order where ct<{} and order_status=1 and product_id='membership'
'''.format(time.time() - 86400 * 7) '''.format(time.time() - 86400 * 7)
docs = self.table_vas_order.query(sql) docs = self.mysql_db_vas.query(sql)
if not docs: if not docs:
return return
print(type(docs), docs) print(type(docs), docs)