|
@@ -15,6 +15,7 @@ import com.qs.mp.channel.service.IChannelOrderService;
|
|
|
import com.qs.mp.common.enums.ChannelOrderStatusEnum;
|
|
|
import com.qs.mp.common.enums.TicketPkgSaleStatusEnum;
|
|
|
import com.qs.mp.common.enums.TicketStatusEnum;
|
|
|
+import com.qs.mp.common.enums.TicketTypeEnum;
|
|
|
import com.qs.mp.common.utils.DateUtils;
|
|
|
import com.qs.mp.common.utils.LogUtil;
|
|
|
import java.time.LocalDateTime;
|
|
@@ -74,6 +75,18 @@ public class TicketPkgDataTask {
|
|
|
.set(TicketPackage::getSaleStatus, saleStatusEnum)
|
|
|
.eq(TicketPackage::getPkgId, ticketPackage.getPkgId()));
|
|
|
}
|
|
|
+
|
|
|
+ List<TicketBox> ticketBoxList = ticketBoxService.list(new LambdaQueryWrapper<TicketBox>()
|
|
|
+ .eq(TicketBox::getType, TicketTypeEnum.OFFLINE));
|
|
|
+
|
|
|
+ for (TicketBox ticketBox : ticketBoxList) {
|
|
|
+ int saleQty = ticketService.count(new LambdaQueryWrapper<Ticket>()
|
|
|
+ .eq(Ticket::getBoxId, ticketBox.getBoxId())
|
|
|
+ .gt(Ticket::getStatus, TicketStatusEnum.NOT_PAY));
|
|
|
+ ticketBoxService.update(new LambdaUpdateWrapper<TicketBox>()
|
|
|
+ .set(TicketBox::getSaleQty, saleQty)
|
|
|
+ .eq(TicketBox::getBoxId, ticketBox.getBoxId()));
|
|
|
+ }
|
|
|
LogUtil.info(logger, "...票包销售数量更新任务结束...");
|
|
|
}
|
|
|
}
|