转账优化事务

app/api/statement/guild.py

 import math
 import threading
-from sqlalchemy import and_, func
+from sqlalchemy import and_, func, engine
 from sqlalchemy.orm import Session
 
 from libs.functions import get_now_timestamp, get_now_datetime
@@ -159,6 +159,20 @@ def query_token(db, h_list):
     return user_info
 
 
+def transfer_trigger_task(db, data):
+    """转账验证"""
+    try:
+        dst = db.query(Account).filter(Account.id == data.dst_id).first()  # 转出
+        transfer = db.query(Account).filter(Account.id == data.transfer_id).first()  # 转入
+        dst.consumable = float(dst.consumable) - data.amount
+        transfer.consumable = float(transfer.consumable) + data.amount
+        db.commit()
+    except Exception as e:
+        db.rollback()
+        return False
+    return True
+
+
 def transfer_money(db: Session, param, h_list):
     """转账"""
     user = query_token(db, h_list)
@@ -183,7 +197,10 @@ def transfer_money(db: Session, param, h_list):
             dst_name = out.guild_name if out else ""
         income = db.query(Account).filter(Account.uuid == param.transfer_id).first()
         transfer_name = income.name if income else ""
-
+    # 转账
+    is_success = transfer_trigger_task(db, param)
+    if not is_success:
+        return False
     try:
         present = Fitransferlog(dst_id=param.dst_id, dst_name=dst_name, amount=param.amount, type=param.type,
                                 transfer_id=param.transfer_id, nick_name=param.nick_name, remark=param.remark,