来客吧交易数据时间格式修复

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

@@ -42,11 +42,11 @@ public class RabbitLkbQueueListener {
     private final RemoteKxsUserService remoteKxsUserService;
 
     public static void main(String[] args) {
-        System.out.println(TotalDateUtil.getMonthNumber(LocalDateTimeUtil.parseDate("2020-01-23 10:00:00", DatePattern.NORM_DATETIME_PATTERN)));
-        System.out.println(TotalDateUtil.getDateNumber(LocalDateTimeUtil.parseDate("2020-01-23 10:00:00", DatePattern.NORM_DATETIME_PATTERN)));
+        System.out.println(TotalDateUtil.getMonthNumber(LocalDateTimeUtil.parseDate("2024-03-14T12:54:41", DatePattern.UTC_SIMPLE_PATTERN)));
+        System.out.println(TotalDateUtil.getDateNumber(LocalDateTimeUtil.parseDate("2024-03-14T12:54:41", DatePattern.UTC_SIMPLE_PATTERN)));
     }
     /**
-     * 监听 商品下单过期 队列的处理器
+     * 监听 来客吧交易 队列的处理器
      *
      * @param message 消息
      */
@@ -57,8 +57,8 @@ public class RabbitLkbQueueListener {
             RabbitLkbTradeQueueMQ.MsgEntity parse = RabbitLkbTradeQueueMQ.parse(msg);
             log.info("来客吧交易消费端Payload: " + parse);
 
-            Integer tradeMonth = TotalDateUtil.getMonthNumber(LocalDateTimeUtil.parseDate(parse.getCreateDate(), DatePattern.NORM_DATETIME_PATTERN));
-            Integer tradeDate = TotalDateUtil.getDateNumber(LocalDateTimeUtil.parseDate(parse.getCreateDate(), DatePattern.NORM_DATETIME_PATTERN));
+            Integer tradeMonth = TotalDateUtil.getMonthNumber(LocalDateTimeUtil.parseDate(parse.getCreateDate(), DatePattern.UTC_SIMPLE_PATTERN));
+            Integer tradeDate = TotalDateUtil.getDateNumber(LocalDateTimeUtil.parseDate(parse.getCreateDate(), DatePattern.UTC_SIMPLE_PATTERN));
 
 
             //个人业绩
@@ -118,7 +118,7 @@ public class RabbitLkbQueueListener {
                     KxsLkbTrade kxsLkbTrade = new KxsLkbTrade();
                     kxsLkbTrade.setTradeMonth(tradeMonth);
                     kxsLkbTrade.setTradeDate(tradeDate);
-                    kxsLkbTrade.setUserId(parse.getUserId());
+                    kxsLkbTrade.setUserId(pid);
                     kxsLkbTrade.setBrandId(parse.getBrandId());
 
                     //活动标识（1活动，0非活动）