yumoqing/kboss
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
ping 2026-08-21 10:17:41 +08:00
parent f85767c53c
commit 30da508452
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
b/baiduc/baidu_confirm_refund_order.dspy
View File

@ -777,6 +777,7 @@ async def baidu_confirm_refund_order(ns={}):
db = DBPools() db = DBPools()
async with db.sqlorContext('kboss') as sor: async with db.sqlorContext('kboss') as sor:
orderss = (await sor.R('bz_order', {'orderid': ns.get('order_id')}))[1]
users = await sor.R('baidu_users', {'user_id': ns['userid']}) users = await sor.R('baidu_users', {'user_id': ns['userid']})
ns['baidu_id'] = users[0]['baidu_id'] if users else None ns['baidu_id'] = users[0]['baidu_id'] if users else None
if not ns['baidu_id']: if not ns['baidu_id']:
@ -794,6 +795,7 @@ async def baidu_confirm_refund_order(ns={}):
db = DBPools() db = DBPools()
async with db.sqlorContext('kboss') as sor: async with db.sqlorContext('kboss') as sor:
refund_status_li = await sor.R('baidu_orders', {'orderid': order_id}) refund_status_li = await sor.R('baidu_orders', {'orderid': order_id})
refund_status_li_info = await sor.R('baidu_orders', {'orderid': order_id})[2]
refundstatus = refund_status_li[0]['refundstatus'] refundstatus = refund_status_li[0]['refundstatus']
refund_id = refund_status_li[0]['id'] refund_id = refund_status_li[0]['id']
@ -879,7 +881,7 @@ async def baidu_confirm_refund_order(ns={}):
# 分割 # 分割
# 增加延迟 # 增加延迟
await asyncio.sleep(5) await asyncio.sleep(10)
# 把 NEED_CONFIRM的本地库改为CREATED # 把 NEED_CONFIRM的本地库改为CREATED
await update_baidu_order_list({'userid': ns.get('userid')}) await update_baidu_order_list({'userid': ns.get('userid')})