RocketMQ的消息整改

admin

2019-11-20 8b2191df2f7d94aa299bd43dcbe97c94e5a61bbd

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

@@ -8,8 +8,8 @@
import com.aliyun.openservices.ons.api.ConsumeContext;

import com.aliyun.openservices.ons.api.Message;

import com.aliyun.openservices.ons.api.MessageListener;

import com.aliyun.openservices.ons.api.Producer;

import com.google.gson.Gson;

import com.yeshi.fanli.dto.mq.BaseMQMsgBody;

import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;

import com.yeshi.fanli.dto.mq.order.body.OrderMQMsg;

import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;

@@ -23,6 +23,7 @@
import com.yeshi.fanli.service.inter.redpack.RedPackWinInviteService;

import com.yeshi.fanli.service.inter.user.UserSystemCouponService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.rocketmq.MQTopicName;



/**

@@ -39,9 +40,12 @@


   @Resource

   private RedPackWinInviteService redPackWinInviteService;

	


   @Resource

   private RedPackGiveRecordService redPackGiveRecordService;



   @Resource(name = "producer")

   private Producer producer;



   @Override

   public Action consume(Message message, ConsumeContext context) {

@@ -57,12 +61,13 @@
                  OrderMoneyRecievedMQMsg.class);

            // 分享订单奖励

            if (orderMoneyRecievedMQMsg.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {

//               try {

//                  redPackWinInviteService.orderArriveReward(orderMoneyRecievedMQMsg.getUid(),

//                        orderMoneyRecievedMQMsg.getSourceType(), orderMoneyRecievedMQMsg.getOrderId());

//               } catch (Exception e) {

//                  e.printStackTrace();

//               }

               // try {

               // redPackWinInviteService.orderArriveReward(orderMoneyRecievedMQMsg.getUid(),

               // orderMoneyRecievedMQMsg.getSourceType(),

               // orderMoneyRecievedMQMsg.getOrderId());

               // } catch (Exception e) {

               // e.printStackTrace();

               // }

            }

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

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

@@ -73,8 +78,46 @@
                  e.printStackTrace();

               }

            }

            // 发送24小时延时消息

            // 测试时发送

            int hour = 24;

            if (Constant.IS_TEST) {

               hour = 1;

            }

            orderMQMsg.setDelayHour(hour);

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

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

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

               msg.setStartDeliverTime(orderMQMsg.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 orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);

         int hour = 24;

         if (Constant.IS_TEST) {

            hour = 1;

         }



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

            // TODO 处理延时消息

         }

         return Action.CommitMessage;

      } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiSeparateByOrderNo.name())) {// 订单到账（按订单号处理）

         OrderMoneyRecievedMQMsg orderMoneyRecievedMQMsg = new Gson().fromJson(new String(message.getBody()),

               OrderMoneyRecievedMQMsg.class);

         if (orderMoneyRecievedMQMsg.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU

               || orderMoneyRecievedMQMsg.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {

            if (!StringUtil.isNullOrEmpty(orderMoneyRecievedMQMsg.getOrderId())

                  && orderMoneyRecievedMQMsg.getUid() != null) {

               // TODO 自购与分享订单到账处理

            }

         }



         return Action.CommitMessage;

      } else if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {

         boolean inviteSucceedReward = false;

         Long uid = null;

@@ -110,11 +153,10 @@


         if (inviteSucceedReward) {

            try {// 邀请奖励

               if(uid==6269748)

               {

               if (uid == 6269748) {

                  System.out.println(uid);

               }

//               redPackWinInviteService.inviteSucceedReward(uid);

               // redPackWinInviteService.inviteSucceedReward(uid);

            } catch (Exception e) {

               e.printStackTrace();

            }