加入导出案件日志功能
This commit is contained in:
27942
@@ -5153,21 +5153,20 @@ class deleteSystem(APIView):
|
||||
class ExportCaseLogExcel(APIView):
|
||||
def post(self, request, *args, **kwargs):
|
||||
"""
|
||||
导出案件日志到Excel
|
||||
导出指定案件的日志到Excel
|
||||
必填参数：case_id（案件ID）
|
||||
可选参数：start_time（开始时间）、end_time（结束时间）
|
||||
返回：Excel文件下载
|
||||
"""
|
||||
import pandas as pd
|
||||
from django.http import HttpResponse
|
||||
from io import BytesIO
|
||||
|
||||
case_id = request.data.get('case_id') # 案件ID（必填）
|
||||
start_time = request.data.get('start_time') # 开始时间（可选）
|
||||
end_time = request.data.get('end_time') # 结束时间（可选）
|
||||
case_id = request.data.get('case_id')
|
||||
start_time = request.data.get('start_time')
|
||||
end_time = request.data.get('end_time')
|
||||
|
||||
if not case_id:
|
||||
return Response({'status': 'error', 'message': '缺少参数case_id（案件ID）', 'code': 1}, status=status.HTTP_400_BAD_REQUEST)
|
||||
return Response({'status': 'error', 'message': '缺少参数case_id', 'code': 1}, status=status.HTTP_400_BAD_REQUEST)
|
||||
|
||||
# 获取案件信息
|
||||
try:
|
||||
@@ -5177,18 +5176,16 @@ class ExportCaseLogExcel(APIView):
|
||||
|
||||
# 构建查询条件
|
||||
Q_obj = Q(is_deleted=False, case_id=case_id)
|
||||
|
||||
# 时间范围筛选（可选）
|
||||
if start_time:
|
||||
Q_obj &= Q(times__gte=start_time)
|
||||
if end_time:
|
||||
Q_obj &= Q(times__lte=end_time)
|
||||
|
||||
# 查询日志数据
|
||||
# 查询日志
|
||||
logs = Caselog.objects.filter(Q_obj).order_by('-times', '-id')
|
||||
|
||||
if not logs.exists():
|
||||
return Response({'status': 'error', 'message': '没有找到案件日志数据', 'code': 1}, status=status.HTTP_404_NOT_FOUND)
|
||||
return Response({'status': 'error', 'message': '该案件没有日志记录', 'code': 1}, status=status.HTTP_404_NOT_FOUND)
|
||||
|
||||
# 解析案件负责人信息
|
||||
responsiblefor_info = ""
|
||||
@@ -5197,54 +5194,36 @@ class ExportCaseLogExcel(APIView):
|
||||
resp_data = json.loads(case.responsiblefor) if isinstance(case.responsiblefor, str) else case.responsiblefor
|
||||
if isinstance(resp_data, dict):
|
||||
parts = []
|
||||
if resp_data.get('responsible_person'):
|
||||
parts.append(f"承办人：{resp_data.get('responsible_person')}")
|
||||
if resp_data.get('main_lawyer'):
|
||||
parts.append(f"主办律师：{resp_data.get('main_lawyer')}")
|
||||
if resp_data.get('assist_lawyer'):
|
||||
parts.append(f"协办律师：{resp_data.get('assist_lawyer')}")
|
||||
if resp_data.get('trainee_lawyer'):
|
||||
parts.append(f"实习律师：{resp_data.get('trainee_lawyer')}")
|
||||
if resp_data.get('secretary'):
|
||||
parts.append(f"秘书/助理：{resp_data.get('secretary')}")
|
||||
responsiblefor_info = "；".join(parts) if parts else str(case.responsiblefor)
|
||||
else:
|
||||
responsiblefor_info = str(case.responsiblefor)
|
||||
except (json.JSONDecodeError, TypeError):
|
||||
for key, label in [('responsible_person', '承办人'), ('main_lawyer', '主办律师'),
|
||||
('assist_lawyer', '协办律师'), ('trainee_lawyer', '实习律师'), ('secretary', '秘书/助理')]:
|
||||
if resp_data.get(key):
|
||||
parts.append(f"{label}：{resp_data.get(key)}")
|
||||
responsiblefor_info = "；".join(parts)
|
||||
except:
|
||||
responsiblefor_info = str(case.responsiblefor) if case.responsiblefor else ""
|
||||
|
||||
# 获取案件标签
|
||||
tags_str = ""
|
||||
try:
|
||||
tags = case.tags.filter(is_deleted=False).values_list('name', flat=True)
|
||||
tags_str = "、".join(tags) if tags else ""
|
||||
tags_str = "、".join(case.tags.filter(is_deleted=False).values_list('name', flat=True))
|
||||
except:
|
||||
tags_str = ""
|
||||
pass
|
||||
|
||||
# 构建Excel数据
|
||||
excel_data = []
|
||||
for log in logs:
|
||||
# 解析附件信息
|
||||
# 解析附件
|
||||
file_info = ""
|
||||
if log.file:
|
||||
try:
|
||||
files = json.loads(log.file) if isinstance(log.file, str) else log.file
|
||||
if isinstance(files, list):
|
||||
file_names = []
|
||||
for f in files:
|
||||
if isinstance(f, dict):
|
||||
file_names.append(f.get('name', f.get('url', '未知文件')))
|
||||
elif isinstance(f, str):
|
||||
file_names.append(f)
|
||||
file_info = "；".join(file_names) if file_names else ""
|
||||
else:
|
||||
file_info = str(files)
|
||||
except (json.JSONDecodeError, TypeError):
|
||||
file_info = "；".join([f.get('name', f.get('url', '')) if isinstance(f, dict) else str(f) for f in files])
|
||||
except:
|
||||
file_info = str(log.file) if log.file else ""
|
||||
|
||||
excel_data.append({
|
||||
'日志ID': log.id,
|
||||
'案件ID': case_id,
|
||||
'合同编号': case.contract_no or '',
|
||||
'项目类型': case.project_type or '',
|
||||
'客户名称': case.client_name or '',
|
||||
@@ -5260,43 +5239,26 @@ class ExportCaseLogExcel(APIView):
|
||||
'日志内容': log.content or '',
|
||||
'记录时间': log.times or '',
|
||||
'记录人': log.username or '',
|
||||
'附件信息': file_info,
|
||||
'附件': file_info,
|
||||
})
|
||||
|
||||
# 创建DataFrame
|
||||
df = pd.DataFrame(excel_data)
|
||||
|
||||
# 导出Excel
|
||||
df = pd.DataFrame(excel_data)
|
||||
output = BytesIO()
|
||||
with pd.ExcelWriter(output, engine='openpyxl') as writer:
|
||||
df.to_excel(writer, index=False, sheet_name='案件日志')
|
||||
|
||||
# 调整列宽
|
||||
worksheet = writer.sheets['案件日志']
|
||||
ws = writer.sheets['案件日志']
|
||||
for idx, col in enumerate(df.columns):
|
||||
max_length = max(
|
||||
df[col].astype(str).map(len).max() if len(df) > 0 else 0,
|
||||
len(str(col))
|
||||
)
|
||||
# 限制最大列宽为50
|
||||
adjusted_width = min(max_length + 2, 50)
|
||||
worksheet.column_dimensions[chr(65 + idx) if idx < 26 else 'A' + chr(65 + idx - 26)].width = adjusted_width
|
||||
width = min(max(df[col].astype(str).map(len).max(), len(col)) + 2, 50)
|
||||
ws.column_dimensions[chr(65 + idx) if idx < 26 else chr(64 + idx // 26) + chr(65 + idx % 26)].width = width
|
||||
|
||||
output.seek(0)
|
||||
filename = f'{case.contract_no or f"案件{case_id}"}_日志_{datetime.now().strftime("%Y%m%d%H%M%S")}.xlsx'
|
||||
|
||||
# 生成文件名
|
||||
contract_no = case.contract_no or f'案件{case_id}'
|
||||
filename = f'{contract_no}_案件日志_{datetime.now().strftime("%Y%m%d_%H%M%S")}.xlsx'
|
||||
|
||||
# 返回Excel文件
|
||||
response = HttpResponse(
|
||||
output.read(),
|
||||
content_type='application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'
|
||||
)
|
||||
# 处理中文文件名
|
||||
response = HttpResponse(output.read(), content_type='application/vnd.openxmlformats-officedocument.spreadsheetml.sheet')
|
||||
from urllib.parse import quote
|
||||
response['Content-Disposition'] = f'attachment; filename*=UTF-8\'\'{quote(filename)}'
|
||||
response['Access-Control-Expose-Headers'] = 'Content-Disposition'
|
||||
|
||||
return response
|
||||
|
||||
|
||||
60
query_caselog.py
Normal file
60
query_caselog.py
Normal file
@@ -0,0 +1,60 @@
|
||||
import pymysql
|
||||
|
||||
conn = pymysql.connect(
|
||||
host='47.108.113.7',
|
||||
port=3306,
|
||||
user='jzls',
|
||||
password='Ls123456',
|
||||
database='jzls',
|
||||
charset='utf8'
|
||||
)
|
||||
|
||||
cursor = conn.cursor()
|
||||
|
||||
# 查询案件日志总数
|
||||
cursor.execute('SELECT COUNT(*) FROM business_caselog WHERE is_deleted=0')
|
||||
total = cursor.fetchone()[0]
|
||||
print(f'案件日志总数: {total}')
|
||||
|
||||
# 查询案件总数
|
||||
cursor.execute('SELECT COUNT(*) FROM business_case WHERE is_deleted=0')
|
||||
case_total = cursor.fetchone()[0]
|
||||
print(f'案件总数: {case_total}')
|
||||
|
||||
# 查询每个案件的日志数量
|
||||
sql = """
|
||||
SELECT c.id, c.contract_no, COUNT(l.id) as log_count
|
||||
FROM business_case c
|
||||
LEFT JOIN business_caselog l ON c.id = l.case_id AND l.is_deleted=0
|
||||
WHERE c.is_deleted=0
|
||||
GROUP BY c.id, c.contract_no
|
||||
ORDER BY c.id
|
||||
LIMIT 20
|
||||
"""
|
||||
cursor.execute(sql)
|
||||
|
||||
print('\n案件日志统计（前20条）:')
|
||||
print('-' * 60)
|
||||
print(f'{"案件ID":<10}{"合同编号":<30}{"日志数量":<10}')
|
||||
print('-' * 60)
|
||||
for row in cursor.fetchall():
|
||||
print(f'{row[0]:<10}{(row[1] or "无"):<30}{row[2]:<10}')
|
||||
|
||||
# 查询最近10条日志
|
||||
print('\n最近10条案件日志:')
|
||||
print('-' * 80)
|
||||
sql2 = """
|
||||
SELECT l.id, l.case_id, l.content, l.times, l.username
|
||||
FROM business_caselog l
|
||||
WHERE l.is_deleted=0
|
||||
ORDER BY l.id DESC
|
||||
LIMIT 10
|
||||
"""
|
||||
cursor.execute(sql2)
|
||||
for row in cursor.fetchall():
|
||||
content = (row[2][:30] + '...') if row[2] and len(row[2]) > 30 else row[2]
|
||||
print(f'日志ID:{row[0]}, 案件ID:{row[1]}, 时间:{row[3]}, 记录人:{row[4]}')
|
||||
print(f' 内容: {content}')
|
||||
|
||||
cursor.close()
|
||||
conn.close()
|
||||
Reference in New Issue
Block a user