Commit aaebbc46 authored by xianyang's avatar xianyang

优化保证金列表

parent b4239919
...@@ -12,6 +12,7 @@ from libs.token_verify import get_current_user ...@@ -12,6 +12,7 @@ from libs.token_verify import get_current_user
def get_margin(guild_id, status, page, size, start_time, end_time): def get_margin(guild_id, status, page, size, start_time, end_time):
"""保证金列表,查询""" """保证金列表,查询"""
guild_filters = [] guild_filters = []
guild_filters.append(f" m.type=1")
if guild_id: if guild_id:
guild_filters.append(f" m.guild_id={guild_id}") guild_filters.append(f" m.guild_id={guild_id}")
if status: if status:
...@@ -71,7 +72,7 @@ class GuildMargin(object): ...@@ -71,7 +72,7 @@ class GuildMargin(object):
except Exception as e: except Exception as e:
print(e) print(e)
return '操作失败' return '操作失败'
# 对接财务 给用户充值 # 对接财务 充值
self.recharge_user(guid_info.get('ice_uuid'), param.amount, param.guild_id) self.recharge_user(guid_info.get('ice_uuid'), param.amount, param.guild_id)
# 调整公会权限 # 调整公会权限
self.guild_authority(param.guild_id, param.amount, guid_info) self.guild_authority(param.guild_id, param.amount, guid_info)
...@@ -90,7 +91,6 @@ class GuildMargin(object): ...@@ -90,7 +91,6 @@ class GuildMargin(object):
'reference_number': reference_number, 'reference_number': reference_number,
'reference_type': reference_type, 'reference_type': reference_type,
'reference_info': '保证金充值', 'reference_info': '保证金充值',
} }
res = search(request_data, 'Server.UserExecute.Recharge') res = search(request_data, 'Server.UserExecute.Recharge')
insert_sql = f"insert into all_record_table(user_id, type, status, uuid, reference_number, money, amount_type, money_data, is_add, create_time, errmsg) " \ insert_sql = f"insert into all_record_table(user_id, type, status, uuid, reference_number, money, amount_type, money_data, is_add, create_time, errmsg) " \
...@@ -102,9 +102,7 @@ class GuildMargin(object): ...@@ -102,9 +102,7 @@ class GuildMargin(object):
insert_sql = f"insert into all_record_table(user_id, type, status, uuid, reference_number, money, amount_type, money_data, is_add, create_time, errmsg) " \ insert_sql = f"insert into all_record_table(user_id, type, status, uuid, reference_number, money, amount_type, money_data, is_add, create_time, errmsg) " \
f"values({guild_id}, '{reference_type}', 3, '{ice_uuid}', {reference_number}, {money * 10}, 1, '保证金充值',1,{timestamp}, '{json.dumps(res)}');" f"values({guild_id}, '{reference_type}', 3, '{ice_uuid}', {reference_number}, {money * 10}, 1, '保证金充值',1,{timestamp}, '{json.dumps(res)}');"
print(f'保证金错误,订单号:{reference_number}') print(f'保证金错误,订单号:{reference_number}')
reference = LinkMysql(env.DB_3YV2).perform_mysql(insert_sql) LinkMysql(env.DB_3YV2).perform_mysql(insert_sql)
if not reference:
print('充值失败')
def guild_authority(self, guild_id, amount, guild_info): def guild_authority(self, guild_id, amount, guild_info):
if not guild_id: if not guild_id:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment