57 lines
2.1 KiB
Python
57 lines
2.1 KiB
Python
"""提现流水按俱乐部隔离。"""
|
||
from rest_framework.response import Response
|
||
|
||
from jituan.constants import DATA_SCOPE_ALL
|
||
from jituan.services.club_context import filter_queryset_by_club, resolve_club_id_from_request, resolve_club_scope
|
||
from jituan.services.club_user import get_user_club_id
|
||
from jituan.services.wechat_pay import club_id_for_tixian_yonghuid
|
||
|
||
|
||
def club_id_for_tixian_user(user):
|
||
return get_user_club_id(user)
|
||
|
||
|
||
def club_id_for_tixian_yonghuid_safe(yonghuid):
|
||
return club_id_for_tixian_yonghuid(yonghuid)
|
||
|
||
|
||
def resolve_payout_club_id(*, audit=None, jilu=None, yonghuid=None, user=None):
|
||
"""
|
||
打款商户归属俱乐部：优先提现单/审核单上的 club_id，再回落用户归属。
|
||
避免用户迁店后用新俱乐部商户号打旧单资金。
|
||
"""
|
||
for obj in (audit, jilu):
|
||
if obj is None:
|
||
continue
|
||
cid = (getattr(obj, 'club_id', None) or '').strip()
|
||
if cid:
|
||
return cid
|
||
if user is not None:
|
||
return get_user_club_id(user) or ''
|
||
if yonghuid:
|
||
return club_id_for_tixian_yonghuid(yonghuid) or ''
|
||
return ''
|
||
|
||
|
||
def filter_tixianjilu_by_request(qs, request):
|
||
return filter_queryset_by_club(qs, request, club_field='club_id')
|
||
|
||
|
||
def forbid_if_tixian_out_of_scope(request, tixian_record):
|
||
"""提现记录不在当前俱乐部范围时返回 Response。"""
|
||
if resolve_club_scope(request) == DATA_SCOPE_ALL:
|
||
from jituan.services.group_finance_gate import has_group_finance_exec
|
||
if not has_group_finance_exec(request.user, request):
|
||
return Response({
|
||
'code': 403,
|
||
'msg': '跨俱乐部提现操作仅集团高管可执行，请切换到具体俱乐部',
|
||
})
|
||
return None
|
||
club_id = resolve_club_id_from_request(request)
|
||
rec_club = getattr(tixian_record, 'club_id', None) or club_id_for_tixian_yonghuid_safe(
|
||
tixian_record.yonghuid,
|
||
)
|
||
if rec_club != club_id:
|
||
return Response({'code': 403, 'msg': '该提现记录不属于当前俱乐部数据范围'})
|
||
return None
|