调整 ChirpStackListener

internal/app/service/transport/chirp_stack.go

@@ -32,7 +32,7 @@ type ChirpStackListener struct {
 	logger                *logs.Logger
 	sensorDataRepo        repository.SensorDataRepository
 	deviceRepo            repository.DeviceRepository
-	areaControllerRepo    repository.AreaControllerRepository // 新增
+	areaControllerRepo    repository.AreaControllerRepository
 	deviceCommandLogRepo  repository.DeviceCommandLogRepository
 	pendingCollectionRepo repository.PendingCollectionRepository
 }
@@ -42,7 +42,7 @@ func NewChirpStackListener(
 	logger *logs.Logger,
 	sensorDataRepo repository.SensorDataRepository,
 	deviceRepo repository.DeviceRepository,
-	areaControllerRepo repository.AreaControllerRepository, // 新增
+	areaControllerRepo repository.AreaControllerRepository,
 	deviceCommandLogRepo repository.DeviceCommandLogRepository,
 	pendingCollectionRepo repository.PendingCollectionRepository,
 ) ListenHandler { // 返回接口类型
@@ -50,7 +50,7 @@ func NewChirpStackListener(
 		logger:                logger,
 		sensorDataRepo:        sensorDataRepo,
 		deviceRepo:            deviceRepo,
-		areaControllerRepo:    areaControllerRepo, // 新增
+		areaControllerRepo:    areaControllerRepo,
 		deviceCommandLogRepo:  deviceCommandLogRepo,
 		pendingCollectionRepo: pendingCollectionRepo,
 	}
@@ -151,14 +151,6 @@ func (c *ChirpStackListener) handler(data []byte, eventType string) {
 
 // --- 业务处理函数 ---
 
-// GenericSensorReading 表示单个传感器读数，包含设备ID、类型和值。
-// 此结构体已不再使用，但保留以供参考或兼容旧代码。
-type GenericSensorReading struct {
-	DeviceID uint    `json:"device_id"` // 传感器设备的ID
-	Type     string  `json:"type"`      // 传感器类型 (现在直接使用 ValueDescriptor.Name)
-	Value    float64 `json:"value"`     // 传感器读数
-}
-
 // handleUpEvent 处理上行数据事件
 func (c *ChirpStackListener) handleUpEvent(event *UpEvent) {
 	c.logger.Infof("开始处理 'up' 事件, DevEui: %s", event.DeviceInfo.DevEui)
@@ -187,9 +179,9 @@ func (c *ChirpStackListener) handleUpEvent(event *UpEvent) {
 			RssiDbm: rx.Rssi,
 			SnrDb:   rx.Snr,
 		}
-		// 记录信号强度，使用 ValueDescriptor 的 Name 作为 sensorName
-		// 简化处理，只记录 RSSI，如果需要记录 SNR，可以再添加一个 ValueDescriptor
-		c.recordSensorData(regionalController.ID, regionalController.ID, event.Time, "signal_strength", float64(signalMetrics.RssiDbm))
+
+		// 记录信号强度
+		c.recordSensorData(regionalController.ID, regionalController.ID, event.Time, models.SensorTypeSignalMetrics, signalMetrics)
 		c.logger.Infof("已记录区域主控 (ID: %d) 的信号强度: RSSI=%d, SNR=%.2f", regionalController.ID, rx.Rssi, rx.Snr)
 	} else {
 		c.logger.Warnf("处理 'up' 事件时未找到 RxInfo，无法记录信号数据。DevEui: %s", event.DeviceInfo.DevEui)
@@ -292,9 +284,24 @@ func (c *ChirpStackListener) handleUpEvent(event *UpEvent) {
 		// 5.3 应用乘数和偏移量计算最终值
 		parsedValue := float64(rawSensorValue)*valueDescriptor.Multiplier + valueDescriptor.Offset
 
-		// 5.4 记录传感器数据
-		c.recordSensorData(regionalController.ID, dev.ID, event.Time, valueDescriptor.Name, parsedValue)
-		c.logger.Infof("成功记录传感器数据: 设备ID=%d, 类型=%s, 原始值=%d, 解析值=%.2f", dev.ID, valueDescriptor.Name, rawSensorValue, parsedValue)
+		// 5.4 根据传感器类型构建具体的数据结构
+		var dataToRecord interface{}
+		switch valueDescriptor.Type {
+		case models.SensorTypeTemperature:
+			dataToRecord = models.TemperatureData{TemperatureCelsius: parsedValue}
+		case models.SensorTypeHumidity:
+			dataToRecord = models.HumidityData{HumidityPercent: parsedValue}
+		case models.SensorTypeWeight:
+			dataToRecord = models.WeightData{WeightKilograms: parsedValue}
+		default:
+			// TODO 未知传感器的数据需要记录吗
+			c.logger.Warnf("未知的传感器类型 '%s'，将使用通用格式记录", valueDescriptor.Type)
+			dataToRecord = map[string]float64{"value": parsedValue}
+		}
+
+		// 5.5 记录传感器数据
+		c.recordSensorData(regionalController.ID, dev.ID, event.Time, valueDescriptor.Type, dataToRecord)
+		c.logger.Infof("成功记录传感器数据: 设备ID=%d, 类型=%s, 原始值=%f, 解析值=%.2f", dev.ID, valueDescriptor.Type, rawSensorValue, parsedValue)
 	}
 
 	// 6. 更新请求状态为“已完成”
@@ -309,18 +316,19 @@ func (c *ChirpStackListener) handleUpEvent(event *UpEvent) {
 func (c *ChirpStackListener) handleStatusEvent(event *StatusEvent) {
 	c.logger.Infof("处接收到理 'status' 事件: %+v", event)
 
-	// 记录信号强度
-	signalMetrics := models.SignalMetrics{
-		MarginDb: event.Margin,
-	}
-	// 这里的 event.DeviceInfo.DevEui 对应的是区域主控的 DevEui
+	// 查找区域主控设备
 	regionalController, err := c.areaControllerRepo.FindByNetworkID(event.DeviceInfo.DevEui)
 	if err != nil {
 		c.logger.Errorf("处理 'status' 事件失败：无法通过 DevEui '%s' 找到区域主控设备: %v", event.DeviceInfo.DevEui, err)
 		return
 	}
-	// 记录区域主控的信号强度
-	c.recordSensorData(regionalController.ID, regionalController.ID, event.Time, "signal_metrics", float64(signalMetrics.RssiDbm))
+
+	// 记录信号强度
+	signalMetrics := models.SignalMetrics{
+		MarginDb: event.Margin,
+	}
+	c.recordSensorData(regionalController.ID, regionalController.ID, event.Time, models.SensorTypeSignalMetrics, signalMetrics)
+	c.logger.Infof("已记录区域主控 (ID: %d) 的信号状态: %+v", regionalController.ID, signalMetrics)
 
 	// 记录电量
 	batteryLevel := models.BatteryLevel{
@@ -328,9 +336,8 @@ func (c *ChirpStackListener) handleStatusEvent(event *StatusEvent) {
 		BatteryLevelUnavailable: event.BatteryLevelUnavailable,
 		ExternalPower:           event.ExternalPower,
 	}
-	// 记录区域主控的电池电量
-	c.recordSensorData(regionalController.ID, regionalController.ID, event.Time, "battery_level", float64(batteryLevel.BatteryLevelRatio))
-
+	c.recordSensorData(regionalController.ID, regionalController.ID, event.Time, models.SensorTypeBatteryLevel, batteryLevel)
+	c.logger.Infof("已记录区域主控 (ID: %d) 的电池状态: %+v", regionalController.ID, batteryLevel)
 }
 
 // handleAckEvent 处理下行确认事件
@@ -397,14 +404,11 @@ func (c *ChirpStackListener) handleIntegrationEvent(event *IntegrationEvent) {
 // recordSensorData 是一个通用方法，用于将传感器数据存入数据库。
 // regionalControllerID: 区域主控设备的ID
 // sensorDeviceID: 实际产生传感器数据的普通设备的ID
-// sensorName: 传感器值的名称 (例如 "temperature", "weight")
-// parsedValue: 已经解析并应用了乘数和偏移量的浮点数值
-func (c *ChirpStackListener) recordSensorData(regionalControllerID uint, sensorDeviceID uint, eventTime time.Time, sensorName string, parsedValue float64) {
-	// 1. 将解析后的值封装成一个简单的 JSON 对象
-	dataToMarshal := map[string]float64{
-		"value": parsedValue,
-	}
-	jsonData, err := json.Marshal(dataToMarshal)
+// sensorType: 传感器值的类型 (例如 models.SensorTypeTemperature)
+// data: 具体的传感器数据结构体实例 (例如 models.TemperatureData)
+func (c *ChirpStackListener) recordSensorData(regionalControllerID uint, sensorDeviceID uint, eventTime time.Time, sensorType models.SensorType, data interface{}) {
+	// 1. 将传入的结构体序列化为 JSON
+	jsonData, err := json.Marshal(data)
 	if err != nil {
 		c.logger.Errorf("记录传感器数据失败：序列化数据为 JSON 时出错: %v", err)
 		return
@@ -415,7 +419,7 @@ func (c *ChirpStackListener) recordSensorData(regionalControllerID uint, sensorD
 		Time:                 eventTime,
 		DeviceID:             sensorDeviceID,
 		RegionalControllerID: regionalControllerID,
-		SensorDataType:       sensorName, // 直接使用 sensorName 作为数据类型
+		SensorType:           sensorType,
 		Data:                 datatypes.JSON(jsonData),
 	}