from lib.all import *

mysql = get_mysql_db_vas()

data = Csv("id_pair.csv").read_all()
idx = 0
for d in data:
    idx += 1
    _id = d[0]
    oid3 = d[1]
    sql = '''update vas_order set oid3=%s where id=%s'''

    ret = mysql.exec(sql, (oid3, _id))
    print(_id, idx, ret)

'''
select * from vas_order where order_status>0 and oid3=2021004115647165 and product_id='membership' and order_status=1 order by ct asc limit 10;

select * from vas_order where id=1759363707747446784;

update vas_order set ct=1707742486 where id=1759363707747446784;

select * from vas_ch_income where order_id=1759363707747446784;

curl -d '{"order_id":"1759363707747446784"}' 'https://api.tiefen.fun/api/vas/deal_one_order'
'''