Forráskód Böngészése

crontab: estrus update

Yi 1 hónapja
szülő
commit
10627dc9a8
1 módosított fájl, 3 hozzáadás és 5 törlés
  1. 3 5
      module/crontab/estrus_warning.go

+ 3 - 5
module/crontab/estrus_warning.go

@@ -92,11 +92,9 @@ func (e *Entry) UpdateNeckRingWarningIsPeak(pastureId, minId int64) {
 		zaplog.Error("UpdateNeckRingWarningIsPeak", zap.Any("err", err))
 	}
 
-	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 {
+	// UPDATE v_v_hact v JOIN estrusact e ON v.inteaid=e.inteaid SET e.isPeak=1 WHERE v.isPeak=1;
+	if err := e.DB.Raw(`UPDATE neck_ring_estrus_warning v JOIN neck_ring_estrus e ON v.neck_ring_estrus_id = e.id SET e.is_peak = ? WHERE v.is_peak = ?`,
+		pasturePb.IsShow_Ok, pasturePb.IsShow_Ok).Error; err != nil {
 		zaplog.Error("UpdateNeckRingWarningIsPeak", zap.Any("err", err))
 	}