plan.startMs + DECISION_GRACE_MINUTES * 60_000;
+ // Закладку нельзя подтверждать, пока начало плана ещё в будущем: план закладывается на КА
+ // по факту наступления своего старта, а не заранее.
+ const layinStartInFuture = plan.startMs > Date.now();
// «Создать черновик на основе плана» (replace, окно 1:1, все включения) доступно для
// персистентных правимых баз. DRAFT уже имеет свои действия; PLANNED — виртуальная проекция,
// не база; LAID_IN — replace 1:1 запрещён (слот зафиксирован, только fork-forward).
@@ -232,17 +235,24 @@ export function TguPlanDetails({
- {layinConflict && (
+ {layinStartInFuture && (
+
+ Начало плана ещё в будущем — подтвердить закладку можно только после наступления его старта.
+
+ )}
+ {!layinStartInFuture && layinConflict && (
По КА уже есть заложенный план со стартом в пределах ±10 минут — подтвердить нельзя.
diff --git a/services/pcp-tgu-service/src/main/kotlin/space/nstart/pcp_tgu_service/service/HandlePlanDecisionUseCase.kt b/services/pcp-tgu-service/src/main/kotlin/space/nstart/pcp_tgu_service/service/HandlePlanDecisionUseCase.kt
index 230b7a8..a7cf27f 100644
--- a/services/pcp-tgu-service/src/main/kotlin/space/nstart/pcp_tgu_service/service/HandlePlanDecisionUseCase.kt
+++ b/services/pcp-tgu-service/src/main/kotlin/space/nstart/pcp_tgu_service/service/HandlePlanDecisionUseCase.kt
@@ -149,6 +149,10 @@ class HandlePlanDecisionUseCase(
plannedPlanRepository.save(plan)
spacecraftPlanningStateJpaRepository.save(state)
+
+ // Статусы слотов проставляем только по факту закладки на КА (LAID_IN), а не на ACCEPT:
+ // до закладки план ещё может быть вытеснен коррекцией, и занимать слоты рано.
+ acceptedPlanSlotsUpdateJobService.enqueue(plan.planId)
}
/** Гасит в SUPERSEDED ещё не заложенные планы КА, чьё окно пересекается с заложенным. */
@@ -247,9 +251,9 @@ class HandlePlanDecisionUseCase(
// ACCEPT больше НЕ запирает цепочку и не двигает базу/версию: принятый план лишь ждёт
// закладки. Базой (currentBasePlanId) и chainVersion управляет только LAID_IN
// ([handleLayinConfirmed]) — до закладки можно отправить и принять коррекцию того же окна.
+ // Статусы слотов тоже проставляются не здесь, а на закладке ([handleLayinConfirmed]).
planIssueAttemptRepository.save(attempt)
plannedPlanRepository.save(plan)
- acceptedPlanSlotsUpdateJobService.enqueue(plan.planId)
}
private fun rejectPlan(
diff --git a/services/pcp-tgu-service/src/test/kotlin/space/nstart/pcp_tgu_service/service/PlanIssueAndDecisionFlowTest.kt b/services/pcp-tgu-service/src/test/kotlin/space/nstart/pcp_tgu_service/service/PlanIssueAndDecisionFlowTest.kt
index 7e546bb..382f53a 100644
--- a/services/pcp-tgu-service/src/test/kotlin/space/nstart/pcp_tgu_service/service/PlanIssueAndDecisionFlowTest.kt
+++ b/services/pcp-tgu-service/src/test/kotlin/space/nstart/pcp_tgu_service/service/PlanIssueAndDecisionFlowTest.kt
@@ -61,7 +61,7 @@ class PlanIssueAndDecisionFlowTest {
}
@Test
- fun `accepted decision moves plan to AWAITING_LAYIN and enqueues slots without anchoring base`() {
+ fun `accepted decision moves plan to AWAITING_LAYIN without anchoring base or touching slots`() {
val spacecraftId = "25544"
val plan = plannedPlan(spacecraftId, time(12), time(13), PlannedPlanStatus.WAITING_DECISION)
val attempt = attempt(plan.planId, PlanIssueAttemptStatus.STARTED)
@@ -80,7 +80,8 @@ class PlanIssueAndDecisionFlowTest {
// ACCEPT больше НЕ делает план базой и не двигает версию — это делает только LAID_IN.
assertNull(state.currentBasePlanId)
assertEquals(0, state.chainVersion)
- verify(slotsUpdateJobService).enqueue(plan.planId)
+ // Слоты проставляются на закладке (LAID_IN), а не на ACCEPT.
+ verify(slotsUpdateJobService, never()).enqueue(plan.planId)
}
@Test
@@ -95,12 +96,13 @@ class PlanIssueAndDecisionFlowTest {
val state = SpacecraftPlanningStateEntity(spacecraftId = spacecraftId, chainVersion = 4)
val processedRepository = mock(ProcessedPlanDecisionEventRepository::class.java)
`when`(processedRepository.insertIfAbsent(anyNonNull(), anyNonNull())).thenReturn(1).thenReturn(0)
+ val slotsUpdateJobService = mock(AcceptedPlanSlotsUpdateJobService::class.java)
val useCase = HandlePlanDecisionUseCase(
processedPlanDecisionEventRepository = processedRepository,
planIssueAttemptRepository = attemptRepository(linkedMapOf()),
plannedPlanRepository = plannedRepository(store),
spacecraftPlanningStateJpaRepository = stateRepository(state),
- acceptedPlanSlotsUpdateJobService = mock(AcceptedPlanSlotsUpdateJobService::class.java),
+ acceptedPlanSlotsUpdateJobService = slotsUpdateJobService,
planningProperties = planningProperties()
)
val message = feedbackMessage(spacecraftId, laidIn.planId)
@@ -113,6 +115,8 @@ class PlanIssueAndDecisionFlowTest {
assertEquals(5, state.chainVersion)
assertEquals(PlannedPlanStatus.SUPERSEDED, competitor.status)
assertEquals(PlannedPlanStatus.AWAITING_LAYIN, unrelated.status)
+ // Слоты проставляются по факту закладки — ровно один раз (второй вызов идемпотентен).
+ verify(slotsUpdateJobService).enqueue(laidIn.planId)
}
@Test