From d98ef560c0b69f99648623a385f796e6f66fa8b5 Mon Sep 17 00:00:00 2001
From: Hermes Agent <hermes@opencomputing.cn>
Date: Mon, 15 Jun 2026 16:24:02 +0800
Subject: [PATCH] feat: add Excel export for leads and content

- export_leads.dspy: generate xlsx with openpyxl, base64 return
- export_content.dspy: generate xlsx for content list
- admin.ui: add export section with download buttons
- load_path.py: register export endpoints for RBAC
- pyproject.toml: add openpyxl dependency
---
 pyproject.toml                  |  1 +
 scripts/load_path.py            |  3 ++
 wwwroot/admin.ui                | 60 +++++++++++++++++++++++++++++++
 wwwroot/api/export_content.dspy | 63 ++++++++++++++++++++++++++++++++
 wwwroot/api/export_leads.dspy   | 64 +++++++++++++++++++++++++++++++++
 5 files changed, 191 insertions(+)
 create mode 100644 wwwroot/api/export_content.dspy
 create mode 100644 wwwroot/api/export_leads.dspy

diff --git a/pyproject.toml b/pyproject.toml
index e68c50c..67d0099 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -11,6 +11,7 @@ dependencies = [
     "sqlor",
     "bricks_for_python",
     "requests",
+    "openpyxl",
 ]
 
 [tool.setuptools.packages.find]
diff --git a/scripts/load_path.py b/scripts/load_path.py
index 4792491..30d071b 100644
--- a/scripts/load_path.py
+++ b/scripts/load_path.py
@@ -92,6 +92,9 @@ PATHS = [
     # DingTalk
     f"/{MOD}/api/submit_approval.dspy",
     f"/{MOD}/api/dingtalk_callback.dspy",
+    # Export
+    f"/{MOD}/api/export_leads.dspy",
+    f"/{MOD}/api/export_content.dspy",
 ]
 
 def run(role, paths):
diff --git a/wwwroot/admin.ui b/wwwroot/admin.ui
index 30fa308..9bbd987 100644
--- a/wwwroot/admin.ui
+++ b/wwwroot/admin.ui
@@ -309,6 +309,66 @@
                 }
             ]
         },
+        {
+            "widgettype": "HBox",
+            "options": {
+                "width": "100%",
+                "gap": "12px",
+                "marginTop": "16px",
+                "padding": "12px",
+                "css": "card",
+                "alignItems": "center"
+            },
+            "subwidgets": [
+                {
+                    "widgettype": "Text",
+                    "options": {
+                        "text": "📥 数据导出",
+                        "fontSize": "16px",
+                        "fontWeight": "bold"
+                    }
+                },
+                {
+                    "widgettype": "Filler"
+                },
+                {
+                    "widgettype": "Button",
+                    "id": "btn_export_leads",
+                    "options": {
+                        "label": "导出商机线索",
+                        "css": "primary"
+                    },
+                    "binds": [
+                        {
+                            "wid": "self",
+                            "event": "click",
+                            "actiontype": "script",
+                            "options": {
+                                "code": "var btn=this;btn.setLabel('生成中...');fetch(bricks.absurl('/cms/api/export_leads.dspy',btn)).then(function(r){return r.json()}).then(function(d){if(d.status==='ok'){var bin=atob(d.data);var bytes=new Uint8Array(bin.length);for(var i=0;i<bin.length;i++)bytes[i]=bin.charCodeAt(i);var blob=new Blob([bytes],{type:'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'});var url=URL.createObjectURL(blob);var a=document.createElement('a');a.href=url;a.download=d.filename;a.click();URL.revokeObjectURL(url);btn.setLabel('导出商机线索')}else{btn.setLabel('导出失败');setTimeout(function(){btn.setLabel('导出商机线索')},2000)}}).catch(function(){btn.setLabel('网络错误');setTimeout(function(){btn.setLabel('导出商机线索')},2000)})"
+                            }
+                        }
+                    ]
+                },
+                {
+                    "widgettype": "Button",
+                    "id": "btn_export_content",
+                    "options": {
+                        "label": "导出内容列表",
+                        "css": "primary"
+                    },
+                    "binds": [
+                        {
+                            "wid": "self",
+                            "event": "click",
+                            "actiontype": "script",
+                            "options": {
+                                "code": "var btn=this;btn.setLabel('生成中...');fetch(bricks.absurl('/cms/api/export_content.dspy',btn)).then(function(r){return r.json()}).then(function(d){if(d.status==='ok'){var bin=atob(d.data);var bytes=new Uint8Array(bin.length);for(var i=0;i<bin.length;i++)bytes[i]=bin.charCodeAt(i);var blob=new Blob([bytes],{type:'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'});var url=URL.createObjectURL(blob);var a=document.createElement('a');a.href=url;a.download=d.filename;a.click();URL.revokeObjectURL(url);btn.setLabel('导出内容列表')}else{btn.setLabel('导出失败');setTimeout(function(){btn.setLabel('导出内容列表')},2000)}}).catch(function(){btn.setLabel('网络错误');setTimeout(function(){btn.setLabel('导出内容列表')},2000)})"
+                            }
+                        }
+                    ]
+                }
+            ]
+        },
         {
             "widgettype": "VBox",
             "id": "sage_main_content",
diff --git a/wwwroot/api/export_content.dspy b/wwwroot/api/export_content.dspy
new file mode 100644
index 0000000..7fd8807
--- /dev/null
+++ b/wwwroot/api/export_content.dspy
@@ -0,0 +1,63 @@
+
+import io
+import base64
+from openpyxl import Workbook
+from openpyxl.styles import Font, Alignment, PatternFill, Border, Side
+
+config = getConfig('.')
+DBPools(config.databases)
+dbname = get_module_dbname('cms')
+
+async with db.sqlorContext(dbname) as sor:
+    rows = await sor.R('cms_content', {'sort': 'sort_order asc, created_at desc'})
+
+    wb = Workbook()
+    ws = wb.active
+    ws.title = '内容列表'
+
+    # Headers
+    headers = ['标题', '类型', '摘要', '状态', '标签', '排序', '创建时间', '发布时间']
+    header_font = Font(bold=True, color='FFFFFF')
+    header_fill = PatternFill(start_color='4472C4', end_color='4472C4', fill_type='solid')
+    thin_border = Border(
+        left=Side(style='thin'), right=Side(style='thin'),
+        top=Side(style='thin'), bottom=Side(style='thin')
+    )
+
+    for col, h in enumerate(headers, 1):
+        cell = ws.cell(row=1, column=col, value=h)
+        cell.font = header_font
+        cell.fill = header_fill
+        cell.alignment = Alignment(horizontal='center')
+        cell.border = thin_border
+
+    # Mappings
+    type_map = {'banner': 'Banner', 'product': '产品', 'case': '案例', 'news': '新闻'}
+    status_map = {'draft': '草稿', 'pending': '待审批', 'approved': '已审批', 'published': '已发布', 'archived': '已归档'}
+
+    # Data rows
+    for i, row in enumerate(rows, 2):
+        ws.cell(row=i, column=1, value=row.get('title', ''))
+        ws.cell(row=i, column=2, value=type_map.get(row.get('content_type', ''), row.get('content_type', '')))
+        ws.cell(row=i, column=3, value=row.get('summary_text', '')[:200] if row.get('summary_text') else '')
+        ws.cell(row=i, column=4, value=status_map.get(row.get('status', ''), row.get('status', '')))
+        ws.cell(row=i, column=5, value=row.get('tags', ''))
+        ws.cell(row=i, column=6, value=row.get('sort_order', 0))
+        ws.cell(row=i, column=7, value=str(row.get('created_at', ''))[:19])
+        ws.cell(row=i, column=8, value=str(row.get('published_at', ''))[:19] if row.get('published_at') else '')
+        for col in range(1, 9):
+            ws.cell(row=i, column=col).border = thin_border
+
+    # Auto-width
+    col_widths = [30, 10, 40, 10, 20, 8, 20, 20]
+    for i, w in enumerate(col_widths, 1):
+        col_letter = chr(64 + i) if i <= 26 else 'A'
+        ws.column_dimensions[col_letter].width = w
+
+    # Save to buffer and encode
+    buf = io.BytesIO()
+    wb.save(buf)
+    b64 = base64.b64encode(buf.getvalue()).decode()
+
+    filename = f'cms_content_{curDateString()}.xlsx'
+    return {'status': 'ok', 'filename': filename, 'data': b64, 'total': len(rows)}
diff --git a/wwwroot/api/export_leads.dspy b/wwwroot/api/export_leads.dspy
new file mode 100644
index 0000000..b24e842
--- /dev/null
+++ b/wwwroot/api/export_leads.dspy
@@ -0,0 +1,64 @@
+
+import io
+import base64
+from openpyxl import Workbook
+from openpyxl.styles import Font, Alignment, PatternFill, Border, Side
+
+config = getConfig('.')
+DBPools(config.databases)
+dbname = get_module_dbname('cms')
+
+async with db.sqlorContext(dbname) as sor:
+    rows = await sor.R('cms_leads', {'sort': 'created_at desc'})
+
+    wb = Workbook()
+    ws = wb.active
+    ws.title = '商机线索'
+
+    # Headers
+    headers = ['姓名', '公司', '电话', '邮箱', '行业', '地区', '来源', '感兴趣产品', '状态', '留言', '创建时间']
+    header_font = Font(bold=True, color='FFFFFF')
+    header_fill = PatternFill(start_color='4472C4', end_color='4472C4', fill_type='solid')
+    thin_border = Border(
+        left=Side(style='thin'), right=Side(style='thin'),
+        top=Side(style='thin'), bottom=Side(style='thin')
+    )
+
+    for col, h in enumerate(headers, 1):
+        cell = ws.cell(row=1, column=col, value=h)
+        cell.font = header_font
+        cell.fill = header_fill
+        cell.alignment = Alignment(horizontal='center')
+        cell.border = thin_border
+
+    # Status mapping
+    status_map = {'new': '新建', 'contacted': '已联系', 'qualified': '已确认', 'converted': '已转化', 'closed': '已关闭'}
+    source_map = {'website': '官网', 'phone': '电话', 'referral': '推荐', 'ai_extract': 'AI抽取'}
+
+    # Data rows
+    for i, row in enumerate(rows, 2):
+        ws.cell(row=i, column=1, value=row.get('name', ''))
+        ws.cell(row=i, column=2, value=row.get('company', ''))
+        ws.cell(row=i, column=3, value=row.get('phone', ''))
+        ws.cell(row=i, column=4, value=row.get('email', ''))
+        ws.cell(row=i, column=5, value=row.get('industry', ''))
+        ws.cell(row=i, column=6, value=row.get('region', ''))
+        ws.cell(row=i, column=7, value=source_map.get(row.get('source', ''), row.get('source', '')))
+        ws.cell(row=i, column=8, value=row.get('interest_products', ''))
+        ws.cell(row=i, column=9, value=status_map.get(row.get('status', ''), row.get('status', '')))
+        ws.cell(row=i, column=10, value=row.get('message', ''))
+        ws.cell(row=i, column=11, value=str(row.get('created_at', ''))[:19])
+        for col in range(1, 12):
+            ws.cell(row=i, column=col).border = thin_border
+
+    # Auto-width
+    for col in range(1, 12):
+        ws.column_dimensions[chr(64 + col) if col <= 26 else 'A'].width = 15
+
+    # Save to buffer and encode
+    buf = io.BytesIO()
+    wb.save(buf)
+    b64 = base64.b64encode(buf.getvalue()).decode()
+
+    filename = f'shangji_leads_{curDateString()}.xlsx'
+    return {'status': 'ok', 'filename': filename, 'data': b64, 'total': len(rows)}