crontab: estrus 更新发情ispeak字段

module/crontab/estrus_warning.go

@@ -92,13 +92,14 @@ func (e *Entry) UpdateNeckRingWarningIsPeak(pastureId, minId int64) {
 		zaplog.Error("UpdateNeckRingWarningIsPeak", zap.Any("err", err))
 	}
 
-	if err := e.DB.Table(fmt.Sprintf("%s as b", new(model.NeckRingEstrus).TableName())).
-		Joins(fmt.Sprintf("JOIN %s as a on b.neck_ring_estrus_id = a.id", new(model.NeckRingEstrusWarning).TableName())).
-		Where("b.pasture_id = ?", pastureId).
-		Where("a.is_peak = ?", pasturePb.IsShow_Ok).
-		Update("is_peak", pasturePb.IsShow_Ok).Error; err != nil {
+	if err := e.DB.Table(fmt.Sprintf("%s as e", new(model.NeckRingEstrus).TableName())).
+		Joins(fmt.Sprintf("JOIN %s as n on n.neck_ring_estrus_id = e.id", new(model.NeckRingEstrusWarning).TableName())).
+		Where("n.pasture_id = ?", pastureId).
+		Where("n.is_peak = ?", pasturePb.IsShow_Ok).
+		Update("e.is_peak", pasturePb.IsShow_Ok).Error; err != nil {
 		zaplog.Error("UpdateNeckRingWarningIsPeak", zap.Any("err", err))
 	}
+
 }
 
 func (e *Entry) UpdateHighChange(pastureId, minId int64) {