来客吧消费bug修复统计判断

kxs-stat/kxs-stat-biz/src/main/java/com/kxs/stat/biz/mq/RabbitLkbQueueListener.java

@@ -114,7 +114,7 @@ public class RabbitLkbQueueListener {
                         .eq(KxsLkbTrade::getTradeDate, tradeDate)
                         .eq(KxsLkbTrade::getTotalType, TotalTypeEnum.TEAM.getType())
                 );
-                if(lkbTrade == null){
+                if(lkbTradeTeam == null){
                     KxsLkbTrade kxsLkbTrade = new KxsLkbTrade();
                     kxsLkbTrade.setTradeMonth(tradeMonth);
                     kxsLkbTrade.setTradeDate(tradeDate);

kxs-stat/kxs-stat-biz/src/main/java/com/kxs/stat/biz/service/impl/KxsUserTradeServiceImpl.java

@@ -66,6 +66,7 @@ public class KxsUserTradeServiceImpl extends ServiceImpl<KxsUserTradeMapper, Kxs
         String version = LocalDateTimeUtil.format(LocalDateTime.now(), DatePattern.PURE_DATETIME_FORMATTER);
         //计算增量的pos交易
         String tableName = PREFIX_TABLE_NAME + "after_" + thisMoth;
+//        String tableName = PREFIX_TABLE_NAME + thisMoth;
         String tempTableName = PREFIX_TABLE_NAME_TEMP + thisMoth;
 
         int batchSize = 100;