#!/bin/bash
# CloudBase 数据同步脚本
# 运行所有 MCP pipeline → 上传更新的 JSON 到 CloudBase
set -e

WORKDIR="$HOME/Desktop/Hermes输出-工作类"
CB_ENV="bier-sales-d0gatbvlx288724e9"
LOG="$WORKDIR/数据/cb_sync.log"

echo "=== $(date '+%Y-%m-%d %H:%M:%S') 开始同步 ===" >> "$LOG"

cd "$WORKDIR/数据"

# 1. 运行 MCP 刷新脚本（客诉+活动+阻塞）
echo ">>> 刷新 MCP 客诉+活动..." >> "$LOG"
python3 mcp_refresh.py >> "$LOG" 2>&1 || echo "⚠️ mcp_refresh 失败" >> "$LOG"

# 2. 运行 KPI pipeline
echo ">>> 刷新 KPI..." >> "$LOG"
python3 mcp_kpi_pipeline.py >> "$LOG" 2>&1 || echo "⚠️ mcp_kpi 失败" >> "$LOG"

# 3. 刷新 ERP 数据
cd "$WORKDIR/脚本"
echo ">>> 刷新 ERP 数据..." >> "$LOG"
python3 refresh_erp.py >> "$LOG" 2>&1 || echo "⚠️ refresh_erp 失败" >> "$LOG"

# 4. 更新 KPI 进度
python3 update_kpi_progress.py >> "$LOG" 2>&1 || echo "⚠️ update_kpi 失败" >> "$LOG"

# 5. 上传所有数据 JSON 到 CloudBase
cd "$WORKDIR"
echo ">>> 上传数据文件到 CloudBase..." >> "$LOG"

FILES=(
  "数据/mcp_customers.json"
  "数据/mcp_complaints.json"
  "数据/opportunity_sandbox.json"
  "数据/shipment_status.json"
  "数据/kpi_dashboard.json"
  "数据/kpi_progress.json"
  "数据/my_activities.json"
  "数据/pricing/_key_customers.json"
  "数据/pricing/_personnel.json"
)

for f in "${FILES[@]}"; do
  if [ -f "$f" ]; then
    tcb hosting deploy "$f" "$f" -e "$CB_ENV" >> "$LOG" 2>&1 && echo "  ✓ $f" >> "$LOG" || echo "  ✗ $f" >> "$LOG"
  fi
done

echo "=== 同步完成 ===" >> "$LOG"
echo "" >> "$LOG"

# 6. 合并所有数据 JSON 为单一文件
echo ">>> 合并 workbench_data.json..." >> "$LOG"
python3 "$WORKDIR/脚本/merge_workbench_data.py" >> "$LOG" 2>&1 && echo "  ✓ workbench_data.json" >> "$LOG" || echo "  ✗ merge 失败" >> "$LOG"

# 7. 上传合并文件 + 部署 HTML 到 CloudBase
echo ">>> 上传合并数据 + HTML..." >> "$LOG"
tcb hosting deploy "$WORKDIR/数据/workbench_data.json" 数据/workbench_data.json -e "$CB_ENV" >> "$LOG" 2>&1 && echo "  ✓ workbench_data.json" >> "$LOG" || echo "  ✗ workbench_data.json" >> "$LOG"
tcb hosting deploy "$WORKDIR/工具/index.html" /workbench/index.html -e "$CB_ENV" >> "$LOG" 2>&1 && echo "  ✓ workbench/index.html" >> "$LOG" || echo "  ✗ workbench/index.html" >> "$LOG"