34 lines
915 B
Python
34 lines
915 B
Python
|
from lib.all import *
|
||
|
|
|
||
|
|
service_name = 'rev_period_data'
|
||
|
|
log_dir = '/app/log'
|
||
|
|
logger = Logger(service_name, log_dir=log_dir)
|
||
|
|
|
||
|
|
|
||
|
|
class S:
|
||
|
|
def __init__(self):
|
||
|
|
self.table_vas_order = Mysql(
|
||
|
|
"rm-bp11t1616a1kjvmx5.mysql.rds.aliyuncs.com", 3306, "vas", "vas_order"
|
||
|
|
)
|
||
|
|
self.table_vas_coin_order = Mysql(
|
||
|
|
"rm-bp11t1616a1kjvmx5.mysql.rds.aliyuncs.com", 3306, "vas", "vas_coin_order"
|
||
|
|
)
|
||
|
|
|
||
|
|
def __del__(self):
|
||
|
|
self.table_vas_order.close()
|
||
|
|
self.table_vas_coin_order.close()
|
||
|
|
|
||
|
|
# 获取订单
|
||
|
|
def get_orders(self):
|
||
|
|
sql = '''
|
||
|
|
select * from vas_coin_order where ct<{} and order_status=1 and product_id='membership'
|
||
|
|
'''.format(time.time() - 86400 * 7)
|
||
|
|
docs = self.table_vas_coin_order.query(sql)
|
||
|
|
if not docs:
|
||
|
|
return
|
||
|
|
print(type(docs), docs)
|
||
|
|
return
|
||
|
|
|
||
|
|
def proc(self):
|
||
|
|
return
|