ListPigSickLogs

internal/app/service/monitor_service.go

@@ -17,6 +17,7 @@ type MonitorService struct {
 	pigBatchRepo          repository.PigBatchRepository
 	pigBatchLogRepo       repository.PigBatchLogRepository
 	pigTransferLogRepo    repository.PigTransferLogRepository
+	pigSickLogRepo        repository.PigSickLogRepository
 }
 
 // NewMonitorService 创建一个新的 MonitorService 实例
@@ -31,6 +32,7 @@ func NewMonitorService(
 	pigBatchRepo repository.PigBatchRepository,
 	pigBatchLogRepo repository.PigBatchLogRepository,
 	pigTransferLogRepo repository.PigTransferLogRepository,
+	pigSickLogRepo repository.PigSickLogRepository,
 ) *MonitorService {
 	return &MonitorService{
 		sensorDataRepo:        sensorDataRepo,
@@ -43,6 +45,7 @@ func NewMonitorService(
 		pigBatchRepo:          pigBatchRepo,
 		pigBatchLogRepo:       pigBatchLogRepo,
 		pigTransferLogRepo:    pigTransferLogRepo,
+		pigSickLogRepo:        pigSickLogRepo,
 	}
 }
 
@@ -115,3 +118,8 @@ func (s *MonitorService) ListWeighingRecords(opts repository.WeighingRecordListO
 func (s *MonitorService) ListPigTransferLogs(opts repository.PigTransferLogListOptions, page, pageSize int) ([]models.PigTransferLog, int64, error) {
 	return s.pigTransferLogRepo.ListPigTransferLogs(opts, page, pageSize)
 }
+
+// ListPigSickLogs 负责处理查询病猪日志列表的业务逻辑
+func (s *MonitorService) ListPigSickLogs(opts repository.PigSickLogListOptions, page, pageSize int) ([]models.PigSickLog, int64, error) {
+	return s.pigSickLogRepo.ListPigSickLogs(opts, page, pageSize)
+}