ソースを参照

格式化统计文本格式

dai xiaodan 3 年 前
コミット
b50aa91088

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

@@ -113,6 +113,7 @@ public class DayStatTask {
     sb.append("累计用户:").append(allUserCnt - allSiteCnt - allChannelCnt).append(",当日新增:").append(userCnt - siteCnt - channelCnt).append("\n");
     sb.append("===================\n");
 
+    StringBuffer sbDetail = new StringBuffer("");
     LambdaQueryWrapper<TicketBox> queryWrapper = new LambdaQueryWrapper<TicketBox>()
         .nested(wrapper -> {
           wrapper.eq(TicketBox::getType, TicketTypeEnum.ONLINE).eq(TicketBox::getStatus,
@@ -126,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);
@@ -149,15 +150,17 @@ public class DayStatTask {
               2, RoundingMode.DOWN);
           sumAllSaleAmt = sumAllSaleAmt.add(allOrderAmt);
 
-          sb.append(ticketBox.getTitle()).append("|").append(ticketBox.getType().getDesc())
+          sbDetail.append(ticketBox.getTitle()).append("|").append(ticketBox.getType().getDesc())
               .append("(").append(
                   new BigDecimal(ticketBox.getSalePrice()).divide(new BigDecimal(100), 2,
                       RoundingMode.DOWN)).append("元),累计销售额:")
               .append(allOrderAmt).append("元,当日:")
               .append(orderAmt).append("元\n");
+          sbDetail.append("------------------------");
         }
       }
     }
+
     sb.append("累计销售额:").append(sumAllSaleAmt).append("元,当日:").append(sumSaleAmt).append("元\n");
 
     Map<String, Object> commMap = channelCommissionService.getMap(
@@ -248,6 +251,8 @@ public class DayStatTask {
           .append("颗,当日:").append(0 - Integer.valueOf(String.valueOf(exchangeMap.get("exchangeAmt"))))
           .append("颗\n");
     }
+    sb.append("===================\n");
+    sb.append(sbDetail);
     WebhookService.sendBizData(sb.toString());
     LogUtil.info(logger, "...日统计任务结束..." );
   }