首单 + 发单日志记录

yujian

2020-06-30 b457131dda80427bbd47b05b9ad27366cafa1718

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java

@@ -58,22 +58,22 @@
               LogHelper.errorDetailInfo(e);

            }

            

            boolean verifyOrder = redPackWinInviteService.verifyOrder(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());

            if (verifyOrder) {

               // 发送48小时延时消息

               int hour = 48;

               if (Constant.IS_TEST) {

                  hour = 1;

               }

               mqMsg.setDelayHour(hour);

               Message msg = new Message(message.getTopic(), OrderTopicTagEnum.orderStatisticDelay.name(),

                     new Gson().toJson(mqMsg).getBytes());

               if (mqMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour > System.currentTimeMillis())// 时间是否已经过了

                  msg.setStartDeliverTime(mqMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour);

               else

                  msg.setStartDeliverTime(System.currentTimeMillis() + 1000 * 60);

               producer.send(msg);

            }

//            // 发送48小时延时消息

//            boolean verifyOrder = redPackWinInviteService.verifyOrder(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());

//            if (verifyOrder) {

//               int hour = 48;

//               if (Constant.IS_TEST) {

//                  hour = 1;

//               }

//               mqMsg.setDelayHour(hour);

//               Message msg = new Message(message.getTopic(), OrderTopicTagEnum.orderStatisticDelay.name(),

//                     new Gson().toJson(mqMsg).getBytes());

//               if (mqMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour > System.currentTimeMillis())// 时间是否已经过了

//                  msg.setStartDeliverTime(mqMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour);

//               else

//                  msg.setStartDeliverTime(System.currentTimeMillis() + 1000 * 60);

//               producer.send(msg);

//            }

            return Action.CommitMessage;

         } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatisticDelay.name())) {// 订单统计

            OrderMQMsg mqMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);

@@ -82,14 +82,14 @@
               hour = 1;

            }



            if (mqMsg.getDelayHour() == hour) {

               try {

                  redPackWinInviteService.winFreeCoupon(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());

               } catch (Exception e) {

                  LogHelper.errorDetailInfo(e);

                  return Action.ReconsumeLater;

               }

            }

//            if (mqMsg.getDelayHour() == hour) {

//               try {

//                  redPackWinInviteService.winFreeCoupon(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());

//               } catch (Exception e) {

//                  LogHelper.errorDetailInfo(e);

//                  return Action.ReconsumeLater;

//               }

//            }

            return Action.CommitMessage;

         }

      }