来客吧激活队列修复

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

@@ -70,6 +70,7 @@ public class RabbitLkbQueueListener {
             if (lkbActTrade == null) {
                 lkbActTrade = new KxsLkbActTrade();
                 lkbActTrade.setActNum(1);
+                lkbActTrade.setUserId(Integer.valueOf(parse.getUserId()));
                 lkbActTrade.setTradeMonth(Integer.valueOf(parse.getStatMonth()));
                 lkbActTrade.setTradeDate(Integer.valueOf(parse.getStatDate()));
                 lkbActTrade.setTotalType(TotalTypeEnum.SELF.getType());
@@ -91,13 +92,14 @@ public class RabbitLkbQueueListener {
                     continue;
                 }
                 KxsLkbActTrade lkbActTradeTeam = kxsLkbActTradeService.getOne(Wrappers.<KxsLkbActTrade>lambdaQuery()
-                        .eq(KxsLkbActTrade::getUserId, parse.getUserId())
+                        .eq(KxsLkbActTrade::getUserId, userId)
                         .eq(KxsLkbActTrade::getTradeMonth, parse.getStatMonth())
                         .eq(KxsLkbActTrade::getTradeDate, parse.getStatDate())
                         .eq(KxsLkbActTrade::getTotalType, TotalTypeEnum.TEAM.getType()));
                 if (lkbActTradeTeam == null) {
                     lkbActTradeTeam = new KxsLkbActTrade();
                     lkbActTradeTeam.setActNum(1);
+                    lkbActTrade.setUserId(Integer.valueOf(userId));
                     lkbActTradeTeam.setTradeMonth(Integer.valueOf(parse.getStatMonth()));
                     lkbActTradeTeam.setTradeDate(Integer.valueOf(parse.getStatDate()));
                     lkbActTradeTeam.setTotalType(TotalTypeEnum.TEAM.getType());