票组检查

mp-quartz/src/main/java/com/qs/mp/quartz/task/TicketBoxTask.java

@@ -31,6 +31,7 @@ import java.util.stream.Collectors;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import org.springframework.util.Assert;
 
@@ -53,7 +54,8 @@ public class TicketBoxTask {
   @Autowired
   private ITicketBoxService ticketBoxService;
 
-  private final int PAGE_SIZE = 1000;
+  @Value("${export.page-size}")
+  private int pageSize;
 
   /**
    * 检查票组中奖分布任务
@@ -77,13 +79,13 @@ public class TicketBoxTask {
       LogUtil.info(logger, "票组票数为0，boxId:{0}", boxId);
     }
 
-    if(totalSize > PAGE_SIZE) {
-      int totalPage = totalSize%PAGE_SIZE == 0 ? totalSize/PAGE_SIZE : totalSize/PAGE_SIZE+1;
+    if(totalSize > pageSize) {
+      int totalPage = totalSize%pageSize == 0 ? totalSize/pageSize : totalSize/pageSize+1;
       for (int i = 0; i < totalPage; i++) {
         LambdaQueryWrapper<Ticket> pageQueryWrapper = new LambdaQueryWrapper<Ticket>();
         pageQueryWrapper.select(Ticket::getSerialNo, Ticket::getDrawNum, Ticket::getCipherLuckyNum, Ticket::getPkgId);
         pageQueryWrapper.eq(Ticket::getBoxId, boxId);
-        pageQueryWrapper.last("limit "+ (i*PAGE_SIZE) +", " + PAGE_SIZE);
+        pageQueryWrapper.last("limit "+ (i*pageSize) +", " + pageSize);
         List<Ticket> list = ticketService.list(pageQueryWrapper);
         if(null != list && list.size() > 0 ) {
           listAll.addAll(list);