scripts/cronjob/vas/vas_deal.py

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_order.query(sql)
        if not docs:
            return
        print(type(docs), docs)
        return

    def proc(self):
        return


s = S()
s.get_orders()