This commit is contained in:
yumoqing 2026-04-10 21:17:48 +08:00
parent 2dffd76d05
commit 9d1dc0880b

View File

@ -28,9 +28,9 @@ async def accounting(username):
d.productid = 'test_product' d.productid = 'test_product'
d.transamt = 123.432 d.transamt = 123.432
d.variable = { d.variable = {
"交易金额": 123.432, "交易金额": 123.432,
"交易手续费": 0 "交易手续费": 0
} }
ais.append(d) ais.append(d)
orderid = 'test_orderid' orderid = 'test_orderid'
await consume_accounting(sor, orderid, ais) await consume_accounting(sor, orderid, ais)
@ -43,5 +43,18 @@ async def main():
await accounting(username) await accounting(username)
if __name__ == '__main__': if __name__ == '__main__':
databases = {
"sage":{
"driver":"mysql",
"kwargs":{
"user":"test",
"db":"sage",
"password":"SS+C1MDMJrslBwGzYIv3nQ==",
"charset": "utf8mb4",
"host":"db"
}
}
}
DBPools(databases)
asyncio.run(main()) asyncio.run(main())