set taking state.no_income true in the case an event was canceled

Viva-con-Agua · Sep 21, 2023 · c0c3471 · c0c3471
1 parent a3142e9
commit c0c3471
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 22 deletions.
diff --git a/dao/event.go b/dao/event.go
@@ -138,6 +138,29 @@ func EventUpdate(ctx context.Context, i *models.EventUpdate, token *vcapool.Acce
 	); err != nil {
 		return
 	}
+	if event.EventState.State != result.EventState.State {
+		if result.EventState.State == "canceled" {
+			EventParticipantsNotification(ctx, result, "event_cancel")
+			updateTaking := bson.D{{Key: "state.no_income", Value: true}}
+			filterTaking := bson.D{{Key: "_id", Value: event.Taking.ID}}
+			if err = TakingCollection.UpdateOne(ctx, filterTaking, vmdb.UpdateSet(updateTaking), nil); err != nil {
+				return
+			}
+		}
+		if result.EventState.State == "published" ||
+			result.EventState.State == "canceled" ||
+			(result.EventState.State == "requested" && result.EventState.CrewConfirmation == "") {
+			EventStateNotification(ctx, result, "event_state")
+		}
+	} else if event.StartAt != result.StartAt ||
+		event.EndAt != result.EndAt ||
+		event.Location.PlaceID != result.Location.PlaceID ||
+		event.EventASPID != result.EventASPID {
+		EventParticipantsNotification(ctx, result, "event_update")
+	}
+	if event.EventASPID != result.EventASPID && result.EventASPID != token.ID {
+		EventASPNotification(ctx, result, "event_asp")
+	}
 	return
 }
 

diff --git a/handlers/token/events.go b/handlers/token/events.go
@@ -177,32 +177,10 @@ func (i *EventHandler) Update(cc echo.Context) (err error) {
 	if err = c.AccessToken(token); err != nil {
 		return
 	}
-	event := new(models.Event)
-	if event, err = dao.EventGetByID(c.Ctx(), &models.EventParam{ID: body.ID}, token); err != nil {
-		return
-	}
 	result := new(models.Event)
 	if result, err = dao.EventUpdate(c.Ctx(), body, token); err != nil {
 		return
 	}
-	if event.EventState.State != result.EventState.State {
-		if result.EventState.State == "canceled" {
-			dao.EventParticipantsNotification(c.Ctx(), result, "event_cancel")
-		}
-		if result.EventState.State == "published" ||
-			result.EventState.State == "canceled" ||
-			(result.EventState.State == "requested" && result.EventState.CrewConfirmation == "") {
-			dao.EventStateNotification(c.Ctx(), result, "event_state")
-		}
-	} else if event.StartAt != result.StartAt ||
-		event.EndAt != result.EndAt ||
-		event.Location.PlaceID != result.Location.PlaceID ||
-		event.EventASPID != result.EventASPID {
-		dao.EventParticipantsNotification(c.Ctx(), result, "event_update")
-	}
-	if event.EventASPID != result.EventASPID && result.EventASPID != token.ID {
-		dao.EventASPNotification(c.Ctx(), result, "event_asp")
-	}
 	result.EditorID = token.ID
 	go func() {
 		if err = dao.IDjango.Post(result, "/v1/pool/event/update/"); err != nil {