d3b6d79a03
- 查询 API 增加 date_from/date_to 参数（前端日期+时间选择器） - 新增 /api/device-logs/export CSV 导出端点 - 新增 export_device_logs() 模型函数（全量不分页） - 删除校验放宽：允许纯时间范围作为删除条件 - 前端增加导出 CSV 按钮，遵循 test_data 页面模式
96 lines
2.9 KiB
Python
96 lines
2.9 KiB
Python
"""设备事件日志 API"""
|
||
|
||
import csv
|
||
import io
|
||
|
||
from flask import Blueprint, jsonify, render_template, request, Response
|
||
from flask_login import login_required, current_user
|
||
from app.models import get_device_logs, export_device_logs, delete_device_logs, insert_log
|
||
|
||
bp = Blueprint("device_logs", __name__)
|
||
|
||
|
||
@bp.route("/device-logs")
|
||
@login_required
|
||
def index():
|
||
"""设备日志页面"""
|
||
return render_template("device_logs.html")
|
||
|
||
|
||
@bp.route("/api/device-logs")
|
||
@login_required
|
||
def api_device_logs():
|
||
"""查询设备事件日志"""
|
||
page = request.args.get("page", 1, type=int)
|
||
per_page = request.args.get("per_page", 30, type=int)
|
||
serial = request.args.get("serial", "", type=str)
|
||
event_type = request.args.get("event_type", "", type=str)
|
||
date_from = request.args.get("date_from", "", type=str)
|
||
date_to = request.args.get("date_to", "", type=str)
|
||
|
||
records, total = get_device_logs(
|
||
page=page, per_page=per_page,
|
||
serial=serial, event_type=event_type,
|
||
date_from=date_from, date_to=date_to,
|
||
)
|
||
pages = max(1, (total + per_page - 1) // per_page)
|
||
return jsonify({"records": records, "total": total, "pages": pages})
|
||
|
||
|
||
@bp.route("/api/device-logs/export")
|
||
@login_required
|
||
def api_export():
|
||
"""导出设备事件日志为 CSV"""
|
||
serial = request.args.get("serial", "", type=str)
|
||
event_type = request.args.get("event_type", "", type=str)
|
||
date_from = request.args.get("date_from", "", type=str)
|
||
date_to = request.args.get("date_to", "", type=str)
|
||
|
||
records = export_device_logs(
|
||
serial=serial, event_type=event_type,
|
||
date_from=date_from, date_to=date_to,
|
||
)
|
||
|
||
output = io.StringIO()
|
||
writer = csv.writer(output)
|
||
|
||
if records:
|
||
headers = list(records[0].keys())
|
||
writer.writerow(headers)
|
||
for r in records:
|
||
writer.writerow(r.values())
|
||
|
||
output.seek(0)
|
||
return Response(
|
||
output.getvalue(),
|
||
mimetype="text/csv",
|
||
headers={"Content-Disposition": "attachment; filename=device_logs.csv"},
|
||
)
|
||
|
||
|
||
@bp.route("/api/device-logs/delete", methods=["POST"])
|
||
@login_required
|
||
def api_device_logs_delete():
|
||
"""删除设备日志（admin 权限）"""
|
||
if current_user.role != "admin":
|
||
return jsonify({"ok": False, "error": "无权限"}), 403
|
||
|
||
data = request.get_json()
|
||
serial = data.get("serial", "")
|
||
event_type = data.get("event_type", "")
|
||
date_from = data.get("date_from", "")
|
||
date_to = data.get("date_to", "")
|
||
|
||
deleted = delete_device_logs(
|
||
serial=serial, event_type=event_type,
|
||
date_from=date_from, date_to=date_to,
|
||
)
|
||
insert_log(
|
||
current_user.id, current_user.username, "delete",
|
||
target="device_log",
|
||
detail=f"删除 {deleted} 条设备日志 serial={serial} type={event_type}",
|
||
result="ok",
|
||
ip=request.remote_addr or "",
|
||
)
|
||
return jsonify({"ok": True, "deleted": deleted})
|