电商数据对账分析图表系统设计方案

1. 系统概述

基于当前的电商数据对账系统（支持抖音、快手、视频号、天猫、小红书等平台），设计一套完整的分析图表体系，为业务决策提供数据支撑。

1.1 核心业务领域

销售收入分析：基于 SalesRevenueModel 的销售数据分析
销售退货分析：基于 SalesReturnModel 的退货数据分析
费用支出分析：基于 ExpenseBillModel 的费用数据分析
对账结果分析：基于 ReconciliationRecord 的对账质量分析
平台对比分析：跨平台业务数据对比分析
财务收入确认分析：基于权责发生制的收入确认分析
财务合规监控：税务合规、会计准则合规性监控
资金流水分析：银行流水与业务数据对账分析
成本核算分析：全链路成本分摊与毛利分析

1.2 数据源架构

原始账单数据层 (Bill Models)
    ↓
标准化对账数据层 (Reconciliation Models)  
    ↓
财务会计数据层 (Accounting Models)
    ↓
分析计算数据层 (Analysis Views)
    ↓
图表展示层 (Chart Components)

1.3 财务合规框架

会计准则遵循：符合《企业会计准则第14号——收入》要求
税务合规监控：增值税、企业所得税等税务数据监控
内控风险管理：财务内控制度执行情况监控
审计支撑：为内外部审计提供完整的数据链路

—

2. 核心分析图表设计

2.1 销售收入分析模块

2.1.1 销售收入趋势图

业务目标：展示销售收入的时间趋势变化

图表类型：多线折线图 + 面积图组合

数据模型：

# 基础数据表
class SalesRevenueTrendView(models.Model):
    date_period = models.DateField()  # 统计日期（日/周/月/季/年）
    platform = models.CharField(max_length=50)  # 平台名称
    account_id = models.IntegerField()  # 账户ID
    
    # 核心收入指标
    gross_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 总收入
    subsidy_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 补贴收入
    settlement_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 实际结算
    fee_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 总费用
    net_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 净收入
    
    # 订单量指标
    order_count = models.IntegerField()  # 订单数量
    order_amount_avg = models.DecimalField(max_digits=12, decimal_places=2)  # 客单价
    
    class Meta:
        db_table = 'analysis_sales_revenue_trend'
        indexes = [
            models.Index(fields=['date_period', 'platform']),
            models.Index(fields=['account_id', 'date_period']),
        ]

过滤参数：

date_range：时间范围（默认：最近30天）
platform_ids：平台筛选（默认：全部平台）
account_ids：账户筛选（默认：全部账户）
period_type：时间维度（日/周/月，默认：日）
metrics：指标选择（默认：[‘gross_amount’, ‘settlement_amount’]）

穿透关系：

点击数据点 → 跳转到销售收入明细表
点击平台图例 → 跳转到平台销售对比图

2.1.2 平台销售对比图

业务目标：对比各平台销售表现

图表类型：分组柱状图 + 饼图组合

数据模型：

class PlatformSalesComparisonView(models.Model):
    platform = models.CharField(max_length=50)
    date_period = models.DateField()
    
    # 收入指标
    total_revenue = models.DecimalField(max_digits=15, decimal_places=2)
    revenue_growth_rate = models.DecimalField(max_digits=5, decimal_places=2)  # 同比增长率
    market_share = models.DecimalField(max_digits=5, decimal_places=2)  # 市场份额
    
    # 运营指标  
    order_count = models.IntegerField()
    customer_unit_price = models.DecimalField(max_digits=12, decimal_places=2)
    conversion_rate = models.DecimalField(max_digits=5, decimal_places=2)
    
    # 费用率指标
    fee_rate = models.DecimalField(max_digits=5, decimal_places=2)  # 费用率
    profit_margin = models.DecimalField(max_digits=5, decimal_places=2)  # 利润率

过滤参数：

compare_period：对比周期（默认：月度对比）
sort_by：排序字段（默认：total_revenue）
top_n：显示前N个平台（默认：10）

2.1.3 商品销售排行榜

业务目标：识别畅销商品和问题商品

图表类型：水平柱状图 + 气泡图

数据模型：

class ProductSalesRankingView(models.Model):
    product_id = models.CharField(max_length=100)
    product_name = models.CharField(max_length=255)
    platform = models.CharField(max_length=50)
    
    # 销售指标
    total_revenue = models.DecimalField(max_digits=12, decimal_places=2)
    order_count = models.IntegerField()
    unit_price = models.DecimalField(max_digits=10, decimal_places=2)
    
    # 趋势指标
    revenue_trend = models.JSONField()  # 最近7天收入趋势
    ranking_change = models.IntegerField()  # 排名变化

2.2 销售退货分析模块

2.2.1 退货率趋势分析

业务目标：监控退货率变化，识别异常

图表类型：双Y轴折线图

数据模型：

class RefundRateTrendView(models.Model):
    date_period = models.DateField()
    platform = models.CharField(max_length=50)
    
    # 退货指标
    refund_count = models.IntegerField()  # 退货单数
    refund_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 退货金额
    refund_rate = models.DecimalField(max_digits=5, decimal_places=2)  # 退货率
    
    # 基准指标
    total_order_count = models.IntegerField()  # 总订单数
    total_order_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 总订单额
    
    # 原因分析
    refund_reasons = models.JSONField()  # 退货原因分布

2.2.2 退货原因分析

图表类型：旭日图 + 矩形树图

穿透关系：

点击原因分类 → 显示具体退货订单明细
点击平台 → 跳转到该平台退货详情

2.3 费用支出分析模块

2.3.1 费用结构分析

业务目标：分析费用构成，优化成本结构

图表类型：瀑布图 + 饼图

数据模型：

class ExpenseStructureView(models.Model):
    accounting_item_id = models.IntegerField()  # 核算项目ID
    accounting_item_name = models.CharField(max_length=100)
    accounting_class = models.CharField(max_length=100)  # 费用分类
    
    # 费用指标
    total_amount = models.DecimalField(max_digits=12, decimal_places=2)
    amount_percentage = models.DecimalField(max_digits=5, decimal_places=2)  # 占比
    month_over_month = models.DecimalField(max_digits=5, decimal_places=2)  # 环比
    year_over_year = models.DecimalField(max_digits=5, decimal_places=2)  # 同比
    
    # 预算对比
    budget_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 预算额度
    budget_usage_rate = models.DecimalField(max_digits=5, decimal_places=2)  # 预算使用率

2.3.2 费用趋势预测

图表类型：预测折线图

算法模型：基于时间序列的ARIMA模型或指数平滑法

2.4 对账质量分析模块

2.4.1 对账完成率仪表盘

业务目标：监控对账作业质量

图表类型：仪表盘 + 进度条

数据模型：

class ReconciliationQualityView(models.Model):
    date_period = models.DateField()
    platform = models.CharField(max_length=50)
    
    # 对账完成情况
    total_records = models.IntegerField()  # 总记录数
    completed_records = models.IntegerField()  # 已完成记录数
    completion_rate = models.DecimalField(max_digits=5, decimal_places=2)  # 完成率
    
    # 对账结果分布
    success_count = models.IntegerField()  # 对账成功数
    failed_count = models.IntegerField()  # 对账失败数
    manual_count = models.IntegerField()  # 手工调整数
    ignored_count = models.IntegerField()  # 忽略数
    
    # 差异统计
    amount_difference = models.DecimalField(max_digits=12, decimal_places=2)  # 金额差异
    quantity_difference = models.DecimalField(max_digits=10, decimal_places=2)  # 数量差异
    
    class Meta:
        db_table = 'analysis_reconciliation_quality'

2.4.2 差异分析雷达图

图表类型：雷达图

维度：完成率、准确率、及时率、差异率、人工介入率

2.5 财务收入确认分析模块

2.5.1 收入确认进度仪表盘

业务目标：监控收入确认的完成情况，确保符合会计准则要求

图表类型：进度条 + 状态卡片组合

数据模型：

class RevenueRecognitionView(models.Model):
    """收入确认分析视图"""
    date_period = models.DateField()  # 会计期间
    platform = models.CharField(max_length=50)
    account_id = models.IntegerField()
    
    # 收入确认状态统计
    pending_recognition = models.DecimalField(max_digits=15, decimal_places=2)  # 待确认收入
    recognized_revenue = models.DecimalField(max_digits=15, decimal_places=2)  # 已确认收入
    deferred_revenue = models.DecimalField(max_digits=15, decimal_places=2)  # 递延收入
    adjustment_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 调整金额
    
    # 确认依据统计
    confirmed_by_settlement = models.DecimalField(max_digits=15, decimal_places=2)  # 结算确认
    confirmed_by_delivery = models.DecimalField(max_digits=15, decimal_places=2)  # 发货确认
    confirmed_by_acceptance = models.DecimalField(max_digits=15, decimal_places=2)  # 验收确认
    
    # 时效性指标
    avg_recognition_days = models.DecimalField(max_digits=5, decimal_places=2)  # 平均确认天数
    overdue_count = models.IntegerField()  # 超期未确认数量
    
    class Meta:
        db_table = 'analysis_revenue_recognition'
        indexes = [
            models.Index(fields=['date_period', 'platform']),
            models.Index(fields=['account_id', 'date_period']),
        ]

过滤参数：

accounting_period：会计期间（默认：当前月份）
recognition_method：确认方法（结算/发货/验收，默认：全部）
status_filter：确认状态（默认：全部状态）
risk_level：风险等级筛选（高/中/低）

穿透关系：

点击待确认金额 → 跳转到收入确认待办清单
点击已确认收入 → 跳转到已确认收入明细

2.5.2 收入确认时效分析

业务目标：分析收入确认的及时性，识别流程瓶颈

图表类型：瀑布图 + 箱线图

数据模型：

class RevenueRecognitionTimingView(models.Model):
    platform = models.CharField(max_length=50)
    recognition_period = models.DateField()
    
    # 时效分布
    within_1day_count = models.IntegerField()  # 1天内确认数量
    within_3days_count = models.IntegerField()  # 3天内确认数量
    within_7days_count = models.IntegerField()  # 7天内确认数量
    overdue_count = models.IntegerField()  # 超期数量
    
    # 金额分布
    within_1day_amount = models.DecimalField(max_digits=15, decimal_places=2)
    within_3days_amount = models.DecimalField(max_digits=15, decimal_places=2)
    within_7days_amount = models.DecimalField(max_digits=15, decimal_places=2)
    overdue_amount = models.DecimalField(max_digits=15, decimal_places=2)
    
    # 风险指标
    high_risk_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 高风险金额
    compliance_rate = models.DecimalField(max_digits=5, decimal_places=2)  # 合规率

2.5.3 递延收入管理

业务目标：管理和跟踪递延收入的确认进度

图表类型：时间轴 + 分组柱状图

数据模型：

class DeferredRevenueView(models.Model):
    """递延收入管理视图"""
    contract_id = models.CharField(max_length=100)  # 合同编号
    original_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 原始金额
    deferred_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 递延金额
    recognized_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 已确认金额
    remaining_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 剩余金额
    
    # 确认计划
    planned_recognition_date = models.DateField()  # 计划确认日期
    actual_recognition_date = models.DateField(null=True)  # 实际确认日期
    recognition_trigger = models.CharField(max_length=50)  # 确认触发条件
    
    # 风险评估
    risk_level = models.CharField(max_length=20)  # 风险等级
    risk_reason = models.TextField(null=True)  # 风险原因

2.6 财务合规监控模块

2.6.1 税务合规仪表盘

业务目标：监控增值税、企业所得税等税务数据的合规性

图表类型：仪表盘 + 预警指示器

数据模型：

class TaxComplianceView(models.Model):
    """税务合规监控视图"""
    tax_period = models.DateField()  # 税务期间
    platform = models.CharField(max_length=50)
    
    # 增值税相关
    vat_taxable_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 应税销售额
    vat_tax_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 增值税额
    vat_rate = models.DecimalField(max_digits=5, decimal_places=4)  # 增值税率
    
    # 企业所得税相关
    taxable_income = models.DecimalField(max_digits=15, decimal_places=2)  # 应纳税所得额
    income_tax_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 企业所得税
    
    # 合规性指标
    tax_compliance_score = models.DecimalField(max_digits=5, decimal_places=2)  # 合规得分
    exception_count = models.IntegerField()  # 异常数量
    auto_calc_accuracy = models.DecimalField(max_digits=5, decimal_places=2)  # 自动计算准确率
    
    # 风险预警
    risk_flags = models.JSONField(default=list)  # 风险标记
    audit_trail = models.JSONField(default=dict)  # 审计轨迹
    
    class Meta:
        db_table = 'analysis_tax_compliance'

2.6.2 会计科目余额表

业务目标：生成标准的会计科目余额表，支持财务报表编制

图表类型：树形表格 + 钻取表

数据模型：

class AccountBalanceView(models.Model):
    """会计科目余额表视图"""
    accounting_period = models.DateField()  # 会计期间
    account_code = models.CharField(max_length=50)  # 科目代码
    account_name = models.CharField(max_length=100)  # 科目名称
    account_level = models.IntegerField()  # 科目级次
    parent_account_code = models.CharField(max_length=50, null=True)  # 上级科目
    
    # 余额信息
    opening_balance = models.DecimalField(max_digits=15, decimal_places=2)  # 期初余额
    debit_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 借方发生额
    credit_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 贷方发生额
    ending_balance = models.DecimalField(max_digits=15, decimal_places=2)  # 期末余额
    
    # 业务分析
    platform_breakdown = models.JSONField(default=dict)  # 平台分解
    transaction_count = models.IntegerField()  # 交易笔数
    avg_transaction_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 平均交易金额
    
    class Meta:
        db_table = 'analysis_account_balance'
        indexes = [
            models.Index(fields=['accounting_period', 'account_code']),
            models.Index(fields=['account_level', 'parent_account_code']),
        ]

2.6.3 内控风险监控

业务目标：监控财务内控制度的执行情况，识别潜在风险

图表类型：风险矩阵 + 趋势图

数据模型：

class InternalControlRiskView(models.Model):
    """内控风险监控视图"""
    risk_date = models.DateField()
    risk_category = models.CharField(max_length=50)  # 风险类别
    risk_description = models.TextField()  # 风险描述
    
    # 风险评估
    probability = models.DecimalField(max_digits=3, decimal_places=2)  # 发生概率
    impact_level = models.IntegerField()  # 影响程度 1-5
    risk_score = models.DecimalField(max_digits=5, decimal_places=2)  # 风险得分
    
    # 控制措施
    control_effectiveness = models.CharField(max_length=20)  # 控制有效性
    control_frequency = models.CharField(max_length=20)  # 控制频率
    last_review_date = models.DateField()  # 最后检查日期
    
    # 处理状态
    mitigation_plan = models.TextField(null=True)  # 缓解计划
    responsible_person = models.CharField(max_length=100)  # 责任人
    target_resolution_date = models.DateField()  # 目标解决日期
    
    class Meta:
        db_table = 'analysis_internal_control_risk'

2.7 资金流水对账模块

2.7.1 银行流水对账分析

业务目标：将银行流水与业务数据进行对账，确保资金安全

图表类型：双轴对比图 + 差异分析表

数据模型：

class BankReconciliationView(models.Model):
    """银行流水对账视图"""
    reconciliation_date = models.DateField()
    bank_account = models.CharField(max_length=100)  # 银行账户
    platform = models.CharField(max_length=50)
    
    # 银行流水汇总
    bank_total_income = models.DecimalField(max_digits=15, decimal_places=2)  # 银行入账总额
    bank_total_expense = models.DecimalField(max_digits=15, decimal_places=2)  # 银行出账总额
    bank_net_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 银行净额
    
    # 业务数据汇总
    business_settlement_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 业务结算金额
    business_fee_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 业务费用金额
    business_net_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 业务净额
    
    # 对账结果
    reconciled_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 已对账金额
    unreconciled_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 未对账金额
    reconciliation_rate = models.DecimalField(max_digits=5, decimal_places=2)  # 对账率
    
    # 异常分析
    timing_differences = models.DecimalField(max_digits=12, decimal_places=2)  # 时间性差异
    amount_differences = models.DecimalField(max_digits=12, decimal_places=2)  # 金额差异
    missing_transactions = models.IntegerField()  # 缺失交易数
    
    class Meta:
        db_table = 'analysis_bank_reconciliation'

2.7.2 资金流向分析

业务目标：分析资金在各个环节的流转情况

图表类型：桑基图 + 流程图

数据模型：

class CashFlowAnalysisView(models.Model):
    """资金流向分析视图"""
    flow_date = models.DateField()
    flow_type = models.CharField(max_length=50)  # 流向类型
    
    # 流向节点
    source_account = models.CharField(max_length=100)  # 来源账户
    target_account = models.CharField(max_length=100)  # 目标账户
    flow_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 流转金额
    
    # 流转特征
    flow_frequency = models.IntegerField()  # 流转频次
    avg_flow_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 平均流转金额
    flow_velocity = models.DecimalField(max_digits=5, decimal_places=2)  # 资金周转速度
    
    # 风险指标
    concentration_risk = models.DecimalField(max_digits=5, decimal_places=2)  # 集中度风险
    liquidity_risk = models.DecimalField(max_digits=5, decimal_places=2)  # 流动性风险

2.8 成本核算分析模块

2.8.1 全链路成本分析

业务目标：分析从采购到销售的全链路成本构成

图表类型：成本瀑布图 + 成本结构饼图

数据模型：

class FullChainCostView(models.Model):
    """全链路成本分析视图"""
    cost_period = models.DateField()
    product_category = models.CharField(max_length=100)
    platform = models.CharField(max_length=50)
    
    # 直接成本
    purchase_cost = models.DecimalField(max_digits=12, decimal_places=2)  # 采购成本
    logistics_cost = models.DecimalField(max_digits=12, decimal_places=2)  # 物流成本
    packaging_cost = models.DecimalField(max_digits=12, decimal_places=2)  # 包装成本
    
    # 平台费用
    platform_commission = models.DecimalField(max_digits=12, decimal_places=2)  # 平台佣金
    advertising_cost = models.DecimalField(max_digits=12, decimal_places=2)  # 广告费用
    payment_fee = models.DecimalField(max_digits=12, decimal_places=2)  # 支付手续费
    
    # 间接成本
    storage_cost = models.DecimalField(max_digits=12, decimal_places=2)  # 仓储成本
    labor_cost = models.DecimalField(max_digits=12, decimal_places=2)  # 人工成本
    overhead_cost = models.DecimalField(max_digits=12, decimal_places=2)  # 管理费用
    
    # 成本分析
    total_cost = models.DecimalField(max_digits=12, decimal_places=2)  # 总成本
    unit_cost = models.DecimalField(max_digits=10, decimal_places=2)  # 单位成本
    cost_margin = models.DecimalField(max_digits=5, decimal_places=2)  # 成本利润率
    
    class Meta:
        db_table = 'analysis_full_chain_cost'

2.8.2 毛利分析仪表盘

业务目标：实时监控各维度毛利率情况

图表类型：仪表盘 + 热力图

数据模型：

class GrossProfitAnalysisView(models.Model):
    """毛利分析视图"""
    analysis_date = models.DateField()
    dimension_type = models.CharField(max_length=50)  # 分析维度（平台/品类/商品）
    dimension_value = models.CharField(max_length=100)  # 维度值
    
    # 收入成本
    gross_revenue = models.DecimalField(max_digits=15, decimal_places=2)  # 总收入
    total_cost = models.DecimalField(max_digits=15, decimal_places=2)  # 总成本
    gross_profit = models.DecimalField(max_digits=15, decimal_places=2)  # 毛利润
    gross_margin = models.DecimalField(max_digits=5, decimal_places=2)  # 毛利率
    
    # 趋势分析
    margin_trend = models.JSONField()  # 毛利率趋势
    benchmark_margin = models.DecimalField(max_digits=5, decimal_places=2)  # 基准毛利率
    margin_variance = models.DecimalField(max_digits=5, decimal_places=2)  # 毛利率偏差
    
    # 预警指标
    margin_alert_level = models.CharField(max_length=20)  # 预警级别
    improvement_suggestion = models.TextField(null=True)  # 改善建议
    
    class Meta:
        db_table = 'analysis_gross_profit'

—

3. 高级分析功能

3.1 智能异常检测

3.1.1 异常订单识别

算法：基于孤立森林(Isolation Forest)算法

检测维度：

订单金额异常（过高/过低）
退货率异常
费用率异常
结算时间异常

数据模型：

class AnomalyDetectionResult(models.Model):
    detection_date = models.DateTimeField()
    anomaly_type = models.CharField(max_length=50)  # 异常类型
    severity_level = models.IntegerField()  # 严重级别 1-5
    
    # 异常数据
    source_table = models.CharField(max_length=100)  # 来源表
    source_id = models.IntegerField()  # 来源记录ID
    anomaly_score = models.DecimalField(max_digits=5, decimal_places=4)  # 异常得分
    
    # 分析结果
    description = models.TextField()  # 异常描述
    suggested_action = models.TextField()  # 建议操作
    
    # 处理状态
    status = models.CharField(max_length=20, default='pending')  # 处理状态
    processed_by = models.IntegerField(null=True)  # 处理人
    processed_at = models.DateTimeField(null=True)  # 处理时间

3.2 预测分析

3.2.1 销售预测模型

模型类型：时间序列预测 + 机器学习

预测维度：

未来30天销售收入预测
月度销售目标达成概率
季节性销售波动预测

3.3 对比分析

3.3.1 同店对比分析

对比维度：

同平台不同店铺对比
同店铺不同时期对比
同品类不同商品对比

—

4. 穿透分析体系

4.1 多层级穿透设计

仪表盘总览
    ↓ (点击指标卡片)
趋势分析图表
    ↓ (点击数据点)
明细统计表格
    ↓ (点击行记录)  
原始账单详情
    ↓ (点击关联字段)
关联业务数据

4.2 明细表设计

4.2.1 销售收入明细表

表名：SalesRevenueDetailView

字段设计：

# 核心业务字段
order_no = models.CharField(max_length=100)  # 订单号
order_time = models.DateTimeField()  # 下单时间
settlement_time = models.DateTimeField()  # 结算时间
platform = models.CharField(max_length=50)  # 平台
account_name = models.CharField(max_length=100)  # 账户名称

# 商品信息
product_id = models.CharField(max_length=100)
product_name = models.CharField(max_length=255)
product_quantity = models.IntegerField()

# 金额信息
gross_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 总收入
fee_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 总费用
settlement_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 结算金额

# 对账状态
reconciliation_status = models.CharField(max_length=20)
reconciliation_result = models.CharField(max_length=20)

# 操作字段
actions = models.JSONField()  # 可执行操作列表

过滤功能：

时间范围筛选（精确到小时）
平台/账户多选筛选
订单状态筛选
金额范围筛选
商品分类筛选
对账状态筛选

排序功能：支持所有数值字段和时间字段排序

导出功能：支持Excel/CSV格式导出，包含当前筛选条件

4.2.2 费用明细穿透表

业务目标：从费用汇总穿透到具体费用项目

表设计：

class ExpenseDetailView(models.Model):
    # 费用基本信息
    expense_date = models.DateField()
    accounting_item_name = models.CharField(max_length=100)
    amount = models.DecimalField(max_digits=12, decimal_places=2)
    
    # 关联信息
    related_order_no = models.CharField(max_length=100, null=True)
    platform = models.CharField(max_length=50)
    account_name = models.CharField(max_length=100)
    
    # 来源追溯
    source_bill_file = models.CharField(max_length=255)  # 来源文件
    source_row_number = models.IntegerField()  # 来源行号
    
    # 对账信息
    reconciliation_status = models.CharField(max_length=20)
    reconciliation_result = models.CharField(max_length=20)
    
    # 审核信息
    verified_by = models.CharField(max_length=100, null=True)
    verified_at = models.DateTimeField(null=True)

—

5. 关联分析设计

5.1 原始账单关联

关联路径：

分析图表数据
    ↓ (source_model + source_id)
ReBaseModel (对账数据)
    ↓ (source_model + source_id)  
BillXxxSales (原始账单)
    ↓ (bill_file_id)
BillFile (账单文件)

实现方案：

# 在分析视图中添加关联字段
class AnalysisBaseView(models.Model):
    # 原始数据追溯
    source_model = models.CharField(max_length=100)
    source_id = models.BigIntegerField()
    bill_file_id = models.IntegerField()
    
    # 关联查询方法
    def get_source_record(self):
        """获取原始账单记录"""
        model_class = apps.get_model('bill', self.source_model)
        return model_class.objects.get(id=self.source_id)
    
    def get_bill_file(self):
        """获取账单文件信息"""
        return BillFile.objects.get(id=self.bill_file_id)
    
    class Meta:
        abstract = True
        indexes = [
            models.Index(fields=['source_model', 'source_id']),
            models.Index(fields=['bill_file_id']),
        ]

5.2 跨模块关联

5.2.1 销售-退货关联

关联字段：order_no (订单号)

业务场景：

从销售订单查看关联退货记录
从退货记录回溯原始销售订单
计算净销售额（销售额-退货额）

5.2.2 销售-费用关联

关联字段：related_order_no (关联订单号)

业务场景：

查看订单相关的所有费用
计算订单真实利润
费用分摊分析

5.2.3 财务会计关联

关联字段：accounting_voucher_no (会计凭证号)

业务场景：

业务数据到会计凭证的完整追溯
收入确认与业务发生的时点匹配
成本费用的会计分录关联

5.3 财务合规关联设计

5.3.1 收入确认关联链路

销售订单 (SalesRevenueModel)
    ↓ (order_no)
收入确认记录 (RevenueRecognitionRecord)
    ↓ (voucher_no)
会计凭证 (AccountingVoucher)
    ↓ (account_code)
会计科目余额 (AccountBalance)

实现方案：

class RevenueRecognitionRecord(models.Model):
    """收入确认记录模型"""
    # 业务关联
    sales_revenue = models.ForeignKey(
        'reconciliation.SalesRevenueModel',
        on_delete=models.CASCADE,
        verbose_name='关联销售收入'
    )
    
    # 确认信息
    recognition_date = models.DateField(verbose_name='确认日期')
    recognition_amount = models.DecimalField(max_digits=12, decimal_places=2)
    recognition_method = models.CharField(max_length=50)  # 确认方法
    recognition_criteria = models.TextField()  # 确认依据
    
    # 会计处理
    voucher_no = models.CharField(max_length=100, null=True)  # 凭证号
    debit_account = models.CharField(max_length=50)  # 借方科目
    credit_account = models.CharField(max_length=50)  # 贷方科目
    
    # 合规性字段
    compliance_check = models.BooleanField(default=False)  # 合规性检查
    audit_trail = models.JSONField(default=dict)  # 审计轨迹
    approval_status = models.CharField(max_length=20)  # 审批状态
    
    class Meta:
        db_table = 'revenue_recognition_record'
        indexes = [
            models.Index(fields=['recognition_date', 'sales_revenue']),
            models.Index(fields=['voucher_no']),
        ]

5.3.2 税务数据关联

class TaxCalculationRecord(models.Model):
    """税务计算记录模型"""
    # 业务数据关联
    source_model = models.CharField(max_length=100)  # 来源模型
    source_id = models.BigIntegerField()  # 来源ID
    
    # 税务信息
    tax_period = models.DateField()  # 税务期间
    tax_type = models.CharField(max_length=50)  # 税种
    tax_rate = models.DecimalField(max_digits=5, decimal_places=4)  # 税率
    taxable_amount = models.DecimalField(max_digits=15, decimal_places=2)  # 计税金额
    tax_amount = models.DecimalField(max_digits=12, decimal_places=2)  # 税额
    
    # 合规性信息
    calculation_method = models.CharField(max_length=100)  # 计算方法
    tax_policy_reference = models.CharField(max_length=255)  # 税收政策依据
    declaration_status = models.CharField(max_length=20)  # 申报状态
    
    class Meta:
        db_table = 'tax_calculation_record'

—

6. 图表配置体系

6.1 图表配置模型

class ChartConfiguration(models.Model):
    """图表配置模型"""
    chart_id = models.CharField(max_length=100, unique=True)  # 图表唯一标识
    chart_name = models.CharField(max_length=200)  # 图表名称
    chart_type = models.CharField(max_length=50)  # 图表类型
    
    # 数据配置
    data_source = models.CharField(max_length=100)  # 数据源
    default_filters = models.JSONField(default=dict)  # 默认筛选条件
    available_metrics = models.JSONField(default=list)  # 可选指标
    available_dimensions = models.JSONField(default=list)  # 可选维度
    
    # 显示配置
    default_metrics = models.JSONField(default=list)  # 默认显示指标
    chart_options = models.JSONField(default=dict)  # 图表显示选项
    
    # 穿透配置
    drill_down_config = models.JSONField(default=dict)  # 穿透配置
    
    # 权限配置
    required_permissions = models.JSONField(default=list)  # 所需权限
    
    class Meta:
        db_table = 'chart_configuration'

6.2 动态筛选器设计

class FilterConfiguration(models.Model):
    """筛选器配置"""
    filter_id = models.CharField(max_length=100)
    filter_name = models.CharField(max_length=100)
    filter_type = models.CharField(max_length=50)  # date_range, select, multi_select
    
    # 数据源配置
    data_source = models.CharField(max_length=100)
    value_field = models.CharField(max_length=50)
    label_field = models.CharField(max_length=50)
    
    # 默认值配置
    default_value = models.JSONField(null=True)
    
    # 级联配置
    parent_filter = models.CharField(max_length=100, null=True)
    cascade_field = models.CharField(max_length=50, null=True)

6.3 财务合规配置体系

6.3.1 收入确认规则配置

class RevenueRecognitionRule(models.Model):
    """收入确认规则配置"""
    rule_id = models.CharField(max_length=100, unique=True)
    rule_name = models.CharField(max_length=200)
    platform = models.CharField(max_length=50)  # 适用平台
    business_type = models.CharField(max_length=50)  # 业务类型
    
    # 确认条件
    recognition_trigger = models.CharField(max_length=50)  # 确认触发条件
    trigger_conditions = models.JSONField()  # 触发条件详情
    
    # 会计处理
    debit_account_template = models.CharField(max_length=50)  # 借方科目模板
    credit_account_template = models.CharField(max_length=50)  # 贷方科目模板
    voucher_template = models.JSONField()  # 凭证模板
    
    # 合规性配置
    accounting_standard = models.CharField(max_length=50)  # 会计准则
    approval_required = models.BooleanField(default=True)  # 是否需要审批
    auto_process = models.BooleanField(default=False)  # 是否自动处理
    
    class Meta:
        db_table = 'revenue_recognition_rule'

6.3.2 税务合规规则配置

class TaxComplianceRule(models.Model):
    """税务合规规则配置"""
    rule_id = models.CharField(max_length=100, unique=True)
    tax_type = models.CharField(max_length=50)  # 税种
    applicable_region = models.CharField(max_length=100)  # 适用地区
    
    # 税率配置
    tax_rates = models.JSONField()  # 税率配置（支持阶梯税率）
    exemption_conditions = models.JSONField()  # 免税条件
    
    # 计算规则
    calculation_formula = models.TextField()  # 计算公式
    rounding_rule = models.CharField(max_length=50)  # 取整规则
    
    # 申报要求
    declaration_frequency = models.CharField(max_length=50)  # 申报频率
    declaration_deadline = models.CharField(max_length=100)  # 申报期限
    required_documents = models.JSONField()  # 所需单据
    
    class Meta:
        db_table = 'tax_compliance_rule'

—

7. 性能优化策略

7.1 数据预计算

实时指标：最近24小时数据实时计算
准实时指标：最近7天数据每小时计算
历史指标：历史数据每日凌晨计算

7.2 缓存策略

# Redis缓存键设计
CACHE_KEYS = {
    'daily_sales_trend': 'chart:sales_trend:daily:{date_range}:{platforms}',
    'platform_comparison': 'chart:platform_comp:{period}:{accounts}',
    'product_ranking': 'chart:product_rank:{platform}:{date_range}:{top_n}',
}

# 缓存时间设置
CACHE_TIMEOUT = {
    'realtime': 300,      # 5分钟
    'near_realtime': 3600, # 1小时  
    'daily': 86400,       # 24小时
}

7.3 索引优化

复合索引设计：

-- 销售收入趋势查询索引
CREATE INDEX idx_sales_revenue_trend ON analysis_sales_revenue_trend 
(date_period, platform, account_id);

-- 费用结构分析索引  
CREATE INDEX idx_expense_structure ON analysis_expense_structure 
(accounting_class, date_period);

-- 对账质量查询索引
CREATE INDEX idx_reconciliation_quality ON analysis_reconciliation_quality 
(platform, date_period, completion_rate);

—

8. 扩展功能设计

8.1 自定义仪表盘

功能特性：

拖拽式图表布局
自定义筛选器组合
个人/团队仪表盘模板
仪表盘分享功能

8.2 数据订阅与告警

订阅类型：

定时报表订阅（日报/周报/月报）
异常数据告警
指标阈值提醒

告警规则示例：

class AlertRule(models.Model):
    rule_name = models.CharField(max_length=100)
    metric_name = models.CharField(max_length=100)  # 监控指标
    threshold_type = models.CharField(max_length=20)  # 阈值类型：gt/lt/eq
    threshold_value = models.DecimalField(max_digits=12, decimal_places=2)
    
    # 检查频率
    check_frequency = models.CharField(max_length=20)  # hourly/daily/weekly
    
    # 通知配置
    notification_channels = models.JSONField()  # 通知渠道：email/sms/webhook
    recipients = models.JSONField()  # 接收人列表

8.3 数据导出与API

导出格式：Excel、CSV、PDF报告
API接口：RESTful API支持第三方系统集成
数据权限：基于角色的数据访问控制

—

9. 技术实现建议

9.1 前端技术栈

图表库：ECharts / D3.js
UI框架：Vue 3 + Element Plus 或 React + Ant Design
状态管理：Vuex/Pinia 或 Redux
数据获取：Axios + 数据缓存

9.2 后端实现

数据聚合：Django ORM + 原生SQL优化
缓存层：Redis集群
任务队列：Celery + Redis
数据库：PostgreSQL（主）+ ClickHouse（分析）

9.3 部署架构

Load Balancer
    ↓
API Gateway  
    ↓
Application Servers (Django)
    ↓
Cache Layer (Redis)
    ↓
Database Layer (PostgreSQL + ClickHouse)

通过以上设计，可以构建一个功能完整、性能优良、易于扩展的电商数据对账分析图表系统，为业务决策提供强有力的数据支撑。

—

10. 财务合规专项设计

10.1 收入确认合规体系

10.1.1 收入确认合规检查清单

核心合规要点：

履约义务识别：明确各平台业务的履约义务边界
控制权转移判断：确定收入确认的精确时点
交易价格分摊：多元素交易的价格合理分摊
可变对价处理：返利、折扣等可变对价的会计处理

实施监控：

class ComplianceCheckList(models.Model):
    """合规检查清单"""
    check_date = models.DateField()
    check_type = models.CharField(max_length=50)  # 检查类型
    business_scope = models.CharField(max_length=100)  # 业务范围
    
    # 检查项目
    check_items = models.JSONField()  # 检查项目清单
    passed_items = models.JSONField()  # 通过项目
    failed_items = models.JSONField()  # 未通过项目
    
    # 结果统计
    total_checks = models.IntegerField()  # 总检查项
    passed_checks = models.IntegerField()  # 通过项数
    compliance_rate = models.DecimalField(max_digits=5, decimal_places=2)  # 合规率
    
    # 风险评估
    risk_level = models.CharField(max_length=20)  # 风险等级
    remediation_required = models.BooleanField()  # 是否需要整改
    remediation_plan = models.TextField(null=True)  # 整改计划

10.1.2 收入确认时点验证

验证规则：

电商销售：以商品发出且客户签收为确认时点
数字商品：以客户下载或激活为确认时点
服务收入：以服务提供完成为确认时点
预付费业务：按服务期间分期确认

10.2 税务合规自动化

10.2.1 增值税自动计算与核验

class VATCalculationEngine:
    """增值税计算引擎"""
    
    def calculate_vat(self, sales_data, tax_config):
        """
        增值税自动计算
        
        Args:
            sales_data: 销售数据
            tax_config: 税务配置
            
        Returns:
            计算结果包含：应税销售额、增值税额、税率适用情况
        """
        result = {
            'taxable_amount': 0,
            'vat_amount': 0,
            'tax_rate': 0,
            'exemption_amount': 0,  # 免税金额
            'special_items': []     # 特殊项目
        }
        
        # 按商品类别和地区计算不同税率
        for item in sales_data:
            rate = self.get_applicable_rate(item, tax_config)
            vat = item['amount'] * rate / (1 + rate)
            result['vat_amount'] += vat
            
        return result
    
    def validate_calculation(self, calculated_result, declared_result):
        """验证计算结果与申报结果的一致性"""
        tolerance = 0.01  # 容差范围
        
        amount_diff = abs(calculated_result['vat_amount'] - declared_result['vat_amount'])
        if amount_diff > tolerance:
            return {
                'status': 'failed',
                'difference': amount_diff,
                'risk_level': 'high' if amount_diff > 1000 else 'medium'
            }
        
        return {'status': 'passed'}

10.2.2 税务申报数据准备

自动化流程：

数据提取：从业务系统提取应税数据
分类汇总：按税种、税率分类汇总
合规性检查：验证数据完整性和准确性
申报表生成：自动生成标准申报表格
差异分析：与上期数据对比分析

10.3 内控制度数字化

10.3.1 财务内控自动化监控

class InternalControlMonitor:
    """财务内控监控系统"""
    
    def check_segregation_of_duties(self, transaction_data):
        """职责分离检查"""
        violations = []
        
        for transaction in transaction_data:
            # 检查同一人是否同时具有不相容职责
            if self.has_incompatible_roles(transaction['operator']):
                violations.append({
                    'transaction_id': transaction['id'],
                    'violation_type': 'segregation_of_duties',
                    'description': '同一操作员执行不相容职责'
                })
        
        return violations
    
    def check_authorization_limits(self, approval_data):
        """授权额度检查"""
        violations = []
        
        for approval in approval_data:
            limit = self.get_authorization_limit(approval['approver'])
            if approval['amount'] > limit:
                violations.append({
                    'approval_id': approval['id'],
                    'violation_type': 'authorization_exceeded',
                    'amount': approval['amount'],
                    'limit': limit
                })
        
        return violations
    
    def check_supporting_documents(self, voucher_data):
        """支撑单据完整性检查"""
        violations = []
        
        for voucher in voucher_data:
            required_docs = self.get_required_documents(voucher['type'])
            attached_docs = voucher.get('attachments', [])
            
            missing_docs = set(required_docs) - set(attached_docs)
            if missing_docs:
                violations.append({
                    'voucher_id': voucher['id'],
                    'violation_type': 'missing_documents',
                    'missing_docs': list(missing_docs)
                })
        
        return violations

10.3.2 审计轨迹完整性

轨迹记录要求：

操作日志：记录所有财务操作的详细日志
数据变更：记录关键数据的变更前后值
审批流程：记录完整的审批流程和审批意见
系统访问：记录系统访问和权限使用情况

10.4 会计准则合规监控

10.4.1 会计政策一致性检查

class AccountingPolicyChecker:
    """会计政策一致性检查器"""
    
    def check_revenue_recognition_consistency(self, current_period, prior_period):
        """收入确认政策一致性检查"""
        inconsistencies = []
        
        # 比较确认时点政策
        if current_period['recognition_timing'] != prior_period['recognition_timing']:
            inconsistencies.append({
                'policy_type': 'revenue_recognition_timing',
                'current': current_period['recognition_timing'],
                'prior': prior_period['recognition_timing'],
                'impact_assessment': self.assess_policy_change_impact()
            })
        
        # 比较计量方法
        if current_period['measurement_method'] != prior_period['measurement_method']:
            inconsistencies.append({
                'policy_type': 'revenue_measurement',
                'requires_disclosure': True,
                'retroactive_adjustment': True
            })
        
        return inconsistencies
    
    def validate_expense_matching(self, revenue_data, expense_data):
        """费用配比原则检查"""
        matching_issues = []
        
        for revenue_item in revenue_data:
            related_expenses = self.get_related_expenses(revenue_item, expense_data)
            
            # 检查时间配比
            if not self.check_timing_match(revenue_item, related_expenses):
                matching_issues.append({
                    'revenue_id': revenue_item['id'],
                    'issue_type': 'timing_mismatch',
                    'description': '收入与费用确认期间不匹配'
                })
        
        return matching_issues

10.4.2 财务报表项目核验

核验内容：

科目余额：验证科目余额的借贷平衡
报表勾稽：检查报表之间的勾稽关系
项目完整性：确保所有应披露项目完整披露
重要性判断：评估项目的重要性水平

10.5 合规风险预警系统

10.5.1 实时风险监控

class ComplianceRiskAlert:
    """合规风险预警系统"""
    
    def monitor_realtime_risks(self):
        """实时风险监控"""
        alerts = []
        
        # 收入确认异常监控
        revenue_anomalies = self.detect_revenue_anomalies()
        if revenue_anomalies:
            alerts.extend(self.generate_revenue_alerts(revenue_anomalies))
        
        # 税务风险监控
        tax_risks = self.assess_tax_risks()
        if tax_risks:
            alerts.extend(self.generate_tax_alerts(tax_risks))
        
        # 内控缺陷监控
        control_deficiencies = self.detect_control_deficiencies()
        if control_deficiencies:
            alerts.extend(self.generate_control_alerts(control_deficiencies))
        
        return alerts
    
    def calculate_risk_score(self, risk_factors):
        """计算综合风险得分"""
        weights = {
            'revenue_risk': 0.3,
            'tax_risk': 0.25,
            'control_risk': 0.25,
            'compliance_risk': 0.2
        }
        
        total_score = sum(
            risk_factors.get(factor, 0) * weight 
            for factor, weight in weights.items()
        )
        
        return min(total_score, 100)  # 最高100分

10.5.2 预警处理流程

处理机制：

自动识别：系统自动识别潜在合规风险
风险评级：按影响程度和紧急性分级
智能分派：自动分派给相应责任人
跟踪处理：全程跟踪处理进展
效果评估：评估处理效果和改进建议

10.6 审计支撑体系

10.6.1 审计数据包准备

数据包内容：

会计账簿：总账、明细账、日记账
会计凭证：记账凭证及附件
对账资料：银行对账单、往来对账
纳税资料：税务申报表、完税凭证
内控资料：内控制度、执行记录

10.6.2 审计轨迹可视化

class AuditTrailVisualizer:
    """审计轨迹可视化"""
    
    def generate_transaction_flow(self, transaction_id):
        """生成交易流程图"""
        flow_data = {
            'nodes': [],  # 流程节点
            'edges': [],  # 连接关系
            'timeline': []  # 时间线
        }
        
        # 获取交易的完整生命周期
        lifecycle = self.get_transaction_lifecycle(transaction_id)
        
        for step in lifecycle:
            flow_data['nodes'].append({
                'id': step['id'],
                'label': step['description'],
                'timestamp': step['timestamp'],
                'operator': step['operator'],
                'documents': step['supporting_docs']
            })
        
        return flow_data
    
    def create_compliance_dashboard(self, period):
        """创建合规性仪表盘"""
        dashboard_data = {
            'compliance_score': self.calculate_compliance_score(period),
            'risk_distribution': self.get_risk_distribution(period),
            'trend_analysis': self.analyze_compliance_trends(period),
            'action_items': self.get_pending_actions(period)
        }
        
        return dashboard_data

通过这套完善的财务合规体系设计，可以确保电商业务在快速发展的同时，始终保持高水平的财务合规性，为企业的可持续发展提供坚实保障。