销售统计口径调整

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

@@ -127,7 +127,7 @@ public class DayStatTask {
     if (totalSize > pageSize) {
       totalPage = totalSize % pageSize == 0 ? totalSize / pageSize : totalSize / pageSize + 1;
     }
-      BigDecimal sumSaleAmt = BigDecimal.ZERO;
+    BigDecimal sumSaleAmt = BigDecimal.ZERO;
     BigDecimal sumAllSaleAmt = BigDecimal.ZERO;
     for (int i = 0; i < totalPage; i++) {
       queryWrapper.orderByAsc(TicketBox::getBoxNo);
@@ -146,7 +146,14 @@ public class DayStatTask {
               Integer.valueOf(String.valueOf(orderMap.get("orderAmt")))).divide(new BigDecimal(100),
               2, RoundingMode.DOWN);
           sumSaleAmt = sumSaleAmt.add(orderAmt);
-          BigDecimal allOrderAmt = new BigDecimal(ticketBox.getSalePrice() * ticketBox.getSaleQty()).divide(new BigDecimal(100),
+
+          Map<String, Object> allOrderMap = userTicketOrderService.getMap(
+              new QueryWrapper<UserTicketOrder>()
+                  .select("IFNULL(sum(pay_amt) ,0) as orderAmt")
+                  .lambda().eq(UserTicketOrder::getBoxId, ticketBox.getBoxId())
+                  .eq(UserTicketOrder::getStatus, UserTicketOrderStatusEnum.FINISHED));
+          BigDecimal allOrderAmt = new BigDecimal(
+              Integer.valueOf(String.valueOf(allOrderMap.get("orderAmt")))).divide(new BigDecimal(100),
               2, RoundingMode.DOWN);
           sumAllSaleAmt = sumAllSaleAmt.add(allOrderAmt);
 
@@ -173,11 +180,11 @@ public class DayStatTask {
             .select("IFNULL(sum(comm_amt) ,0) as commAmt"));
     if (null != commMap) {
       sb.append("累计分佣：").append(
-          new BigDecimal(Integer.valueOf(String.valueOf(allCommMap.get("commAmt")))).divide(
-              new BigDecimal(100), 2, RoundingMode.DOWN))
+              new BigDecimal(Integer.valueOf(String.valueOf(allCommMap.get("commAmt")))).divide(
+                  new BigDecimal(100), 2, RoundingMode.DOWN))
           .append("元，当日：").append(
-          new BigDecimal(Integer.valueOf(String.valueOf(commMap.get("commAmt")))).divide(
-              new BigDecimal(100), 2, RoundingMode.DOWN)).append("元\n");
+              new BigDecimal(Integer.valueOf(String.valueOf(commMap.get("commAmt")))).divide(
+                  new BigDecimal(100), 2, RoundingMode.DOWN)).append("元\n");
     }
 
     Map<String, Object> couponMap = channelCouponVerifyLogService.getMap(
@@ -211,11 +218,11 @@ public class DayStatTask {
             .lambda().eq(ChannelWithdraw::getStatus, ChannelWithdrawStatusEnum.FINISHED));
     if (null != withdrawMap) {
       sb.append("累计提现：").append(
-          new BigDecimal(Integer.valueOf(String.valueOf(allWithdrawMap.get("withdrawAmt")))).divide(
-              new BigDecimal(100), 2, RoundingMode.DOWN))
+              new BigDecimal(Integer.valueOf(String.valueOf(allWithdrawMap.get("withdrawAmt")))).divide(
+                  new BigDecimal(100), 2, RoundingMode.DOWN))
           .append("元，当日：").append(
-          new BigDecimal(Integer.valueOf(String.valueOf(withdrawMap.get("withdrawAmt")))).divide(
-              new BigDecimal(100), 2, RoundingMode.DOWN)).append("元\n");
+              new BigDecimal(Integer.valueOf(String.valueOf(withdrawMap.get("withdrawAmt")))).divide(
+                  new BigDecimal(100), 2, RoundingMode.DOWN)).append("元\n");
     }
 
     int exCnt = userExchangeOrderService.count(new LambdaQueryWrapper<UserExchangeOrder>()