@@ -787,6 +787,7 @@ public class WorkerLogic {
Policy policy = policyService.lambdaQuery()
.eq(Policy::getType, "DS")
+ .ge(Policy::getEndTime, new Date())
.orderByDesc(Policy::getEndTime)
.last("limit 1").one();
if (policy == null)