制造业企业信息化解决方案案例：从生产模糊管理到全流程数据可控（实操）

// 生产数据模型定义
public class ProductionData
{
    public int Id { get; set; }
    public string EquipmentId { get; set; }
    public DateTime RecordTime { get; set; }
    public int Output { get; set; }
    public int QualifiedCount { get; set; }
    public string Status { get; set; }
    
    // 计算合格率
    public decimal GetQualifiedRate()
    {
        return Output > 0 ? (decimal)QualifiedCount / Output : 0;
    }
}

// 生产数据服务接口
public interface IProductionService
{
    Task GetRealTimeDataAsync(string equipmentId);
    Task<>> GetHistoricalDataAsync(string equipmentId, DateTime start, DateTime end);
}

// 设备数据采集示例
class EquipmentDataCollector {
  constructor(equipmentId) {
    this.equipmentId = equipmentId;
    this.connection = null;
  }
  
  // 连接数据采集设备
  async connect() {
    try {
      this.connection = await establishConnection(this.equipmentId);
      this.startListening();
      console.log(`设备 ${this.equipmentId} 连接成功`);
    } catch (error) {
      console.error(`设备连接失败: ${error.message}`);
    }
  }
  
  // 监听数据变化
  startListening() {
    this.connection.on('data', (data) => {
      this.processData(data);
    });
  }
  
  // 处理采集到的数据
  processData(rawData) {
    const processedData = {
      equipmentId: this.equipmentId,
      timestamp: new Date(),
      output: rawData.output,
      status: rawData.status,
      energyConsumption: rawData.energy
    };
    
    // 发送到服务器
    this.sendToServer(processedData);
  }
  
  // 数据发送方法
  async sendToServer(data) {
    try {
      const response = await fetch('/api/production/data', {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify(data)
      });
      
      if (!response.ok) {
        throw new Error('数据上传失败');
      }
    } catch (error) {
      console.error('数据发送错误:', error);
    }
  }
}