136 lines
4.4 KiB
Python
136 lines
4.4 KiB
Python
"""后台操作日志：xiugaijilu 按俱乐部过滤 + admin_audit_log 写入。"""
|
||
import logging
|
||
|
||
from jituan.constants import DATA_SCOPE_ALL
|
||
from jituan.models import AdminAuditLog
|
||
from jituan.services.club_context import resolve_club_id_from_request, resolve_club_scope
|
||
from jituan.services.club_user import get_user_club_id
|
||
|
||
logger = logging.getLogger(__name__)
|
||
|
||
|
||
def club_id_for_yonghuid(yonghuid):
|
||
from users.business_models import User
|
||
user = User.query.filter(UserUID=str(yonghuid)).first()
|
||
return get_user_club_id(user)
|
||
|
||
|
||
def filter_admin_audit_by_request(qs, request):
|
||
"""集团 ALL 视图看全部；子公司按 club_id 过滤。"""
|
||
if resolve_club_scope(request) == DATA_SCOPE_ALL:
|
||
return qs
|
||
return qs.filter(club_id=resolve_club_id_from_request(request))
|
||
|
||
|
||
def list_admin_audit_logs(request, page=1, page_size=20, **filters):
|
||
"""分页查询 admin_audit_log。"""
|
||
qs = AdminAuditLog.query.all().order_by('-CreateTime')
|
||
qs = filter_admin_audit_by_request(qs, request)
|
||
|
||
operator = (filters.get('operator_yonghuid') or '').strip()
|
||
target = (filters.get('target_yonghuid') or '').strip()
|
||
action = (filters.get('action') or '').strip()
|
||
keyword = (filters.get('keyword') or '').strip()
|
||
|
||
if operator:
|
||
qs = qs.filter(operator_yonghuid=operator)
|
||
if target:
|
||
qs = qs.filter(target_yonghuid=target)
|
||
if action:
|
||
qs = qs.filter(action=action)
|
||
if keyword:
|
||
qs = qs.filter(remark__icontains=keyword)
|
||
|
||
page = max(1, int(page or 1))
|
||
page_size = min(100, max(1, int(page_size or 20)))
|
||
total = qs.count()
|
||
start = (page - 1) * page_size
|
||
rows = qs[start:start + page_size]
|
||
|
||
data_list = []
|
||
for r in rows:
|
||
data_list.append({
|
||
'id': r.id,
|
||
'club_id': r.club_id,
|
||
'operator_yonghuid': r.operator_yonghuid,
|
||
'operator_role_code': r.operator_role_code,
|
||
'target_yonghuid': r.target_yonghuid,
|
||
'action': r.action,
|
||
'resource_type': r.resource_type,
|
||
'resource_id': r.resource_id,
|
||
'field_name': r.field_name,
|
||
'value_before': r.value_before,
|
||
'value_after': r.value_after,
|
||
'remark': r.remark,
|
||
'request_ip': r.request_ip,
|
||
'CreateTime': r.CreateTime.strftime('%Y-%m-%d %H:%M:%S') if r.CreateTime else '',
|
||
})
|
||
|
||
return {
|
||
'list': data_list,
|
||
'total': total,
|
||
'page': page,
|
||
'page_size': page_size,
|
||
}
|
||
|
||
|
||
def filter_xiugaijilu_by_request(qs, request):
|
||
"""集团 ALL 视图看全部；子公司仅看本 club 用户相关记录。"""
|
||
if resolve_club_scope(request) == DATA_SCOPE_ALL:
|
||
return qs
|
||
club_id = resolve_club_id_from_request(request)
|
||
from users.business_models import User
|
||
uids = User.query.filter(ClubID=club_id).values_list('UserUID', flat=True)
|
||
uid_list = [str(u) for u in uids]
|
||
if not uid_list:
|
||
return qs.none()
|
||
return qs.filter(yonghuid__in=uid_list)
|
||
|
||
|
||
def resolve_operator_yonghuid(xiugaiid):
|
||
"""
|
||
xiugaijilu.xiugaiid 多为客服手机号；admin_audit_log.operator_yonghuid 存 UserUID。
|
||
解析失败时回落为原值（列宽已放宽至 16）。
|
||
"""
|
||
s = str(xiugaiid or '').strip()
|
||
if not s:
|
||
return ''
|
||
if len(s) <= 7:
|
||
return s
|
||
from users.business_models import User
|
||
u = User.query.filter(Phone=s).first()
|
||
if u and getattr(u, 'UserUID', None):
|
||
return str(u.UserUID)
|
||
u = User.query.filter(UserUID=s).first()
|
||
if u and getattr(u, 'UserUID', None):
|
||
return str(u.UserUID)
|
||
return s[:16]
|
||
|
||
|
||
def log_admin_audit_from_xiugai(
|
||
*,
|
||
yonghuid,
|
||
xiugaiid,
|
||
leixing,
|
||
qitashuoming,
|
||
club_id=None,
|
||
request_ip='',
|
||
):
|
||
"""与 write_xiugai_log 同步写入 admin_audit_log（失败不影响主流程）。"""
|
||
try:
|
||
cid = club_id or club_id_for_yonghuid(yonghuid)
|
||
operator_uid = resolve_operator_yonghuid(xiugaiid)
|
||
AdminAuditLog.query.create(
|
||
club_id=cid,
|
||
operator_yonghuid=operator_uid,
|
||
target_yonghuid=str(yonghuid),
|
||
action='xiugaijilu',
|
||
resource_type='user',
|
||
resource_id=str(yonghuid),
|
||
field_name=str(leixing),
|
||
remark=(qitashuoming or '')[:500],
|
||
request_ip=(request_ip or '')[:64],
|
||
)
|
||
except Exception as e:
|
||
logger.warning('写入 admin_audit_log 失败: %s', e)
|