server/notify.py

from fastapi import APIRouter, HTTPException, Request
from fastapi.responses import JSONResponse
from .hook import *
from .pydanticModel import *
from .dao import tableStore

router = APIRouter()
#afdian的回调是post  huggingfaceb不知道抽什么风只能二级路由
# @router.get('/uu',response_model=AfdianResp)
# @router.post('/uu',response_model=AfdianResp)
# async def update_balance(afdianHookjson: AfdianHookJson):

#     resp = {'ec': 200}
#     # 检查 ec 是否为 200
#     if afdianHookjson.ec != 200:
#         return {'ec': "afdian hook错误，ec 不是 200"}

#     # 提取订单详情和可选参数
#     order_details = afdianHookjson.data.order
#     custom_order_id = order_details.custom_order_id
#     total_amount = order_details.total_amount

#     table_store = tableStore(ots_client=router.ots_client, table_name=router.table_name)

#     if all([custom_order_id is not None, total_amount is not None]):

#         # 说明是余额类型
#         try:
#             # 先给mysql的数据库添加 - 这个毕竟久 稳定 但是不应该影响其他数据库添加(万一不用了)--------------------
#             updateBalance(email=custom_order_id, amount=total_amount)
#             # 先给mysql的数据库添加 - 这个毕竟久 稳定 但是不应该影响其他数据库添加(万一不用了)--------------------
#         except Exception as e:
#             print("updateBalance v2b digitalocean mysql failed",e)

#         try:
#             #应该改成从原来的余额基础上加total_amount的值
#             table_store.getUserInfo(email=custom_order_id)
#             cur_balance  = table_store.balance
#             balance_new = cur_balance+ total_amount
#             # 更新余额列
#             update_balance_result = table_store.updateColumnByPrimaryKey(
#                 key=router.key,
#                 key_value=custom_order_id,
#                 update_column='balance',
#                 update_column_value=balance_new
#             )
#             if update_balance_result:
#                 return resp #全部成功运行则返回爱发电要求的ec =200
#             else:
#                 return {'ec': "updateBalance tablestore 结果失败"}
#         except Exception as e:
#             print(e)
#             return {'ec': "尝试 updateBalance tablestore 失败"}
#     else:
#         #这个直接返回200吧，反正测试接口的时候需要 ，平时也不用到
#         # return {'ec': "afdian hook custom_order_id 或者 total_amount 为 None"}
#         return resp

# test
@router.post('/uu')
async def prinf_test_json(request: Request):
    json_data = await request.json()
    print("收到afdian请求:", json_data)
    return {'ec': 200}