فهرست منبع

fix 定时下架过期账号车队

zoujiajian 3 سال پیش
والد
کامیت
e827ce47b5
1فایلهای تغییر یافته به همراه3 افزوده شده و 1 حذف شده
  1. 3 1
      netflix-service/src/main/java/com/cyksj/task/Scheduler.java

+ 3 - 1
netflix-service/src/main/java/com/cyksj/task/Scheduler.java

@@ -464,11 +464,13 @@ public class Scheduler {
 				.field(CloseGroupsTripsView::getExpiryTime, nextDay).op(Operator.LessThan)
 				.field(CloseGroupsTripsView::getExpiryTime, nextDay).op(Operator.LessThan)
 				.field(CloseGroupsTripsView::getGoodsId, List.of(18, 26)).op(Operator.InList)
 				.field(CloseGroupsTripsView::getGoodsId, List.of(18, 26)).op(Operator.InList)
 				.field(CloseGroupsTripsView::getGroupsId).op(Operator.NotNull)
 				.field(CloseGroupsTripsView::getGroupsId).op(Operator.NotNull)
+				.field(CloseGroupsTripsView::getGroupsStatus, GroupsTrips.Status.down.name()).op(Operator.NotEqual)
 				.build())).orElse(new ArrayList<>());
 				.build())).orElse(new ArrayList<>());
 		log.info("下架过期账号数量:{}", closeGroupsTripsViews.size());
 		log.info("下架过期账号数量:{}", closeGroupsTripsViews.size());
-		closeGroupsTripsViews.forEach(account->{
+		closeGroupsTripsViews.forEach(account -> {
 			int update = groupsMapper.update(null, Wrappers.lambdaUpdate(GroupsTrips.class)
 			int update = groupsMapper.update(null, Wrappers.lambdaUpdate(GroupsTrips.class)
 					.set(GroupsTrips::getStatus, GroupsTrips.Status.down)
 					.set(GroupsTrips::getStatus, GroupsTrips.Status.down)
+					.ne(GroupsTrips::getStatus, GroupsTrips.Status.down)
 					.eq(GroupsTrips::getId, account.getGroupsId()));
 					.eq(GroupsTrips::getId, account.getGroupsId()));
 			if (update == 1) {
 			if (update == 1) {
 				log.info("将过期账号:{}车队:{}下架", account.getId(), account.getGroupsId());
 				log.info("将过期账号:{}车队:{}下架", account.getId(), account.getGroupsId());