pig/pig-farm-controller
1
0
Fork 0
Code Issues 11 Pull Requests Actions Packages Projects Releases Wiki Activity

调整 ReleaseFeedWeightTask

Browse Source
This commit is contained in:
huang
2025-09-29 22:26:58 +08:00
parent 8392438dc5
commit 4bed3e51b2
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/app/service/task/release_feed_weight_task.go
View File

@@ -95,7 +95,7 @@ func (r *ReleaseFeedWeightTask) Execute() error {
// 获取当前搅拌罐重量 // 获取当前搅拌罐重量
func (r *ReleaseFeedWeightTask) getNowWeight() (float64, error) { func (r *ReleaseFeedWeightTask) getNowWeight() (float64, error) {
sensorData, err := r.sensorDataRepo.GetLatestSensorDataByDeviceIDAndSensorType(r.mixingTankDeviceID, models.SensorDataTypeWeight) sensorData, err := r.sensorDataRepo.GetLatestSensorDataByDeviceIDAndSensorType(r.mixingTankDeviceID, models.SensorTypeWeight)
if err != nil { if err != nil {
r.logger.Errorf("获取设备 %v 最新传感器数据失败: %v , 日志ID: %v", r.mixingTankDeviceID, err, r.claimedLog.ID) r.logger.Errorf("获取设备 %v 最新传感器数据失败: %v , 日志ID: %v", r.mixingTankDeviceID, err, r.claimedLog.ID)
return 0, err return 0, err

4
internal/infra/models/sensor_data.go
View File

@@ -58,8 +58,8 @@ type SensorData struct {
// RegionalControllerID 是上报此数据的区域主控的ID。 // RegionalControllerID 是上报此数据的区域主控的ID。
RegionalControllerID uint `json:"regional_controller_id"` RegionalControllerID uint `json:"regional_controller_id"`
// SensorDataType 是传感数据的类型 // SensorType 是传感数据的类型
SensorDataType SensorType `gorm:"not null;index" json:"sensor_data_type"` SensorType SensorType `gorm:"not null;index" json:"sensor_type"`
// Data 存储一个或多个传感器读数，格式为 JSON。 // Data 存储一个或多个传感器读数，格式为 JSON。
Data datatypes.JSON `gorm:"type:jsonb" json:"data"` Data datatypes.JSON `gorm:"type:jsonb" json:"data"`

6
internal/infra/repository/sensor_data_repository.go
View File

@@ -10,7 +10,7 @@ import (
// SensorDataRepository 定义了与传感器数据相关的数据库操作接口。 // SensorDataRepository 定义了与传感器数据相关的数据库操作接口。
type SensorDataRepository interface { type SensorDataRepository interface {
Create(sensorData *models.SensorData) error Create(sensorData *models.SensorData) error
GetLatestSensorDataByDeviceIDAndSensorType(deviceID uint, sensorType models.SensorDataType) (*models.SensorData, error) GetLatestSensorDataByDeviceIDAndSensorType(deviceID uint, sensorType models.SensorType) (*models.SensorData, error)
} }
// gormSensorDataRepository 是 SensorDataRepository 的 GORM 实现。 // gormSensorDataRepository 是 SensorDataRepository 的 GORM 实现。
@@ -30,10 +30,10 @@ func (r *gormSensorDataRepository) Create(sensorData *models.SensorData) error {
} }
// GetLatestSensorDataByDeviceIDAndSensorType 根据设备ID和传感器类型查询最新的传感器数据。 // GetLatestSensorDataByDeviceIDAndSensorType 根据设备ID和传感器类型查询最新的传感器数据。
func (r *gormSensorDataRepository) GetLatestSensorDataByDeviceIDAndSensorType(deviceID uint, sensorDataType models.SensorDataType) (*models.SensorData, error) { func (r *gormSensorDataRepository) GetLatestSensorDataByDeviceIDAndSensorType(deviceID uint, sensorType models.SensorType) (*models.SensorData, error) {
var sensorData models.SensorData var sensorData models.SensorData
// 增加一个时间范围来缩小查询范围, 从而加快查找速度, 当使用时序数据库时时间范围可以让数据库忽略时间靠前的分片 // 增加一个时间范围来缩小查询范围, 从而加快查找速度, 当使用时序数据库时时间范围可以让数据库忽略时间靠前的分片
err := r.db.Where("device_id = ? AND sensor_data_type = ? AND time >=?", deviceID, sensorDataType, time.Now().Add(-24*time.Hour)). err := r.db.Where("device_id = ? AND sensor_type = ? AND time >=?", deviceID, sensorType, time.Now().Add(-24*time.Hour)).
Order("time DESC"). Order("time DESC").
First(&sensorData).Error First(&sensorData).Error
return &sensorData, err return &sensorData, err