Browse Source

warning: update eastrus

Yi 3 days ago
parent
commit
1d48153a8a
2 changed files with 4 additions and 4 deletions
  1. 4 3
      module/backend/neck_ring_warning.go
  2. 0 1
      module/crontab/neck_ring_calculate.go

+ 4 - 3
module/backend/neck_ring_warning.go

@@ -80,12 +80,13 @@ func (s *StoreEntry) NeckRingWarningEstrusOrAbortionCowList(ctx context.Context,
 		}
 		}
 	}
 	}
 
 
+	list := model.NeckRingEstrusWarningSlice(neckRingEstrusList).ToPB(cowMap, eventLogMap, req.MatingWindowPeriod)
 	return &pasturePb.EstrusResponse{
 	return &pasturePb.EstrusResponse{
 		Code: http.StatusOK,
 		Code: http.StatusOK,
 		Msg:  "ok",
 		Msg:  "ok",
 		Data: &pasturePb.EstrusData{
 		Data: &pasturePb.EstrusData{
-			List:     model.NeckRingEstrusWarningSlice(neckRingEstrusList).ToPB(cowMap, eventLogMap, req.MatingWindowPeriod),
-			Total:    int32(count),
+			List:     list,
+			Total:    int32(len(list)),
 			PageSize: pagination.PageSize,
 			PageSize: pagination.PageSize,
 			Page:     pagination.Page,
 			Page:     pagination.Page,
 		},
 		},
@@ -300,7 +301,7 @@ func (s *StoreEntry) NeckRingNoDiseaseBatch(ctx context.Context, req *pasturePb.
 }
 }
 func (s *StoreEntry) EstrusWarningQuery(ctx context.Context, pastureId int64) (*gorm.DB, error) {
 func (s *StoreEntry) EstrusWarningQuery(ctx context.Context, pastureId int64) (*gorm.DB, error) {
 	nowTime := time.Now().Local()
 	nowTime := time.Now().Local()
-	startTime := time.Unix(util.TimeParseLocalUnix(nowTime.AddDate(0, 0, -1).Format(model.LayoutDate2)), 0).Format(model.LayoutTime)
+	startTime := time.Unix(util.TimeParseLocalUnix(nowTime.Format(model.LayoutDate2)), 0).Format(model.LayoutTime)
 	entTime := time.Unix(util.TimeParseLocalEndUnix(nowTime.Format(model.LayoutDate2)), 0).Format(model.LayoutTime)
 	entTime := time.Unix(util.TimeParseLocalEndUnix(nowTime.Format(model.LayoutDate2)), 0).Format(model.LayoutTime)
 	systemBasic, err := s.FindSystemBasic(ctx, pastureId, model.EstrusWaringDays)
 	systemBasic, err := s.FindSystemBasic(ctx, pastureId, model.EstrusWaringDays)
 	if err != nil {
 	if err != nil {

+ 0 - 1
module/crontab/neck_ring_calculate.go

@@ -334,7 +334,6 @@ func (e *Entry) FilterCorrectAndScoreUpdate(pastureId int64, processIds []int64,
 			// 活动量校正系数
 			// 活动量校正系数
 			if err := e.DB.Model(new(model.NeckActiveHabit)).
 			if err := e.DB.Model(new(model.NeckActiveHabit)).
 				Where("id = ?", v.Id).
 				Where("id = ?", v.Id).
-				//Where("neck_ring_number = ?", v.NeckRingNumber).
 				Update("filter_correct", filterCorrect).Error; err != nil {
 				Update("filter_correct", filterCorrect).Error; err != nil {
 				zaplog.Error("ActivityVolumeChanges-2", zap.Any("error", err), zap.Any("xToday", xToday))
 				zaplog.Error("ActivityVolumeChanges-2", zap.Any("error", err), zap.Any("xToday", xToday))
 				continue
 				continue