Browse Source

Merge remote-tracking branch 'origin/dev' into dev

cup 3 years ago
parent
commit
927ef91e69
1 changed files with 13 additions and 0 deletions
  1. 13 0
      mp-quartz/src/main/java/com/qs/mp/quartz/task/TicketPkgDataTask.java

+ 13 - 0
mp-quartz/src/main/java/com/qs/mp/quartz/task/TicketPkgDataTask.java

@@ -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, "...票包销售数量更新任务结束...");
   }
 }