如何构建专业的销售数据分析系统

// 销售数据模型定义
public class SalesData
{
    public int Id { get; set; }
    public string ProductId { get; set; }
    public string Region { get; set; }
    public DateTime SalesDate { get; set; }
    public decimal Amount { get; set; }
    public int Quantity { get; set; }
    public string CustomerSegment { get; set; }
}

// 数据清洗服务
public class DataCleaningService
{
    public SalesData CleanSalesData(SalesData rawData)
    {
        // 去除金额为负数的异常记录
        if (rawData.Amount < 0)
            return null;
            
        // 标准化地区名称
        rawData.Region = StandardizeRegionName(rawData.Region);
        
        return rawData;
    }
    
    private string StandardizeRegionName(string region)
    {
        // 地区名称标准化逻辑
        return region.Trim().ToUpper();
    }
}

// 销售趋势分析函数
class SalesAnalyzer {
  // 计算月度销售增长率
  calculateMonthlyGrowth(salesData) {
    const monthlySales = this.aggregateByMonth(salesData);
    const growthRates = [];
    
    for (let i = 1; i < monthlySales.length; i++) {
      const current = monthlySales[i].amount;
      const previous = monthlySales[i - 1].amount;
      const growthRate = previous === 0 ? 0 : ((current - previous) / previous) * 100;
      growthRates.push({
        month: monthlySales[i].month,
        growthRate: Math.round(growthRate * 100) / 100
      });
    }
    
    return growthRates;
  }
  
  // 按月份聚合销售数据
  aggregateByMonth(salesData) {
    const monthlyMap = new Map();
    
    salesData.forEach(record => {
      const monthKey = record.date.substring(0, 7); // YYYY-MM
      const current = monthlyMap.get(monthKey) || { amount: 0, count: 0 };
      current.amount += record.amount;
      current.count += 1;
      monthlyMap.set(monthKey, current);
    });
    
    return Array.from(monthlyMap.entries()).map(([month, data]) => ({
      month,
      amount: data.amount,
      average: data.amount / data.count
    }));
  }
}

// 数据质量验证服务
public class DataQualityService
{
    public DataQualityReport ValidateSalesData(List data)
    {
        var report = new DataQualityReport();
        
        foreach (var record in data)
        {
            // 检查必填字段
            if (string.IsNullOrEmpty(record.ProductId))
                report.AddIssue("缺失产品ID", record.Id);
                
            // 检查数据范围
            if (record.Amount < 0)
                report.AddIssue("销售金额为负", record.Id);
                
            // 检查数据逻辑
            if (record.Quantity == 0 && record.Amount > 0)
                report.AddIssue("数量为零但金额为正", record.Id);
        }
        
        report.CalculateMetrics(data.Count);
        return report;
    }
}

public class DataQualityReport
{
    public int TotalRecords { get; set; }
    public int ErrorCount { get; set; }
    public List Issues { get; set; } = new List();
    
    public void AddIssue(string description, int recordId)
    {
        Issues.Add(new DataIssue { Description = description, RecordId = recordId });
        ErrorCount++;
    }
    
    public void CalculateMetrics(int totalRecords)
    {
        TotalRecords = totalRecords;
    }
}