集团企业数据采集系统架构设计：多子公司协同 / 跨区域同步 /legacy 系统接入

// 统一数据模型示例
public class GroupDataModel
{
    // 集团统一标识
    public string GroupId { get; set; }
    
    // 子公司编码（符合集团标准）
    public string CompanyCode { get; set; }
    
    // 数据采集时间（UTC标准）
    public DateTime CollectedTime { get; set; }
    
    // 业务数据（JSON格式）
    public string BusinessData { get; set; }
}

// 数据采集服务接口
public interface IDataCollectService
{
    Task CollectDataAsync(GroupDataModel data);
}

// 增量同步机制示例
class DeltaSynchronizer {
  constructor() {
    this.lastSyncTime = null;
  }

  // 获取增量数据
  async fetchDeltaData() {
    const params = {
      since: this.lastSyncTime || new Date(0).toISOString(),
      limit: 1000
    };
    
    // 调用API获取增量数据
    const response = await fetch('/api/data/delta', {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify(params)
    });
    
    const deltaData = await response.json();
    if (deltaData.length > 0) {
      this.lastSyncTime = new Date().toISOString();
    }
    
    return deltaData;
  }
}

// Legacy系统适配器示例
public class LegacySystemAdapter : ILegacyAdapter
{
    private readonly ILegacySystemService _legacyService;
    
    public LegacySystemAdapter(ILegacySystemService legacyService)
    {
        _legacyService = legacyService;
    }
    
    public async Task ConvertDataAsync(object legacyData)
    {
        // 将legacy系统数据转换为标准数据模型
        return new StandardDataModel
        {
            Id = Guid.NewGuid().ToString(),
            SourceSystem = "LegacySystem",
            OriginalData = JsonSerializer.Serialize(legacyData),
            ConvertedTime = DateTime.UtcNow,
            // 更多转换逻辑...
        };
    }
    
    public async Task<>> CollectDataAsync()
    {
        var legacyData = await _legacyService.FetchDataAsync();
        var results = new List();
        
        foreach (var item in legacyData)
        {
            results.Add(await ConvertDataAsync(item));
        }
        
        return results;
    }
}