From 8b2191df2f7d94aa299bd43dcbe97c94e5a61bbd Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 20 十一月 2019 14:53:34 +0800 Subject: [PATCH] RocketMQ的消息整改 --- fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java | 97 ++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 77 insertions(+), 20 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java index 40f81da..30be42b 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java +++ b/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; @@ -17,10 +17,13 @@ import com.yeshi.fanli.dto.mq.user.body.IntegralTaskMQMsg; import com.yeshi.fanli.dto.mq.user.body.UserAccountBindingMQMsg; import com.yeshi.fanli.dto.mq.user.body.UserInviteMQMsg; +import com.yeshi.fanli.dto.mq.user.body.UserRedPackGiftMQMsg; import com.yeshi.fanli.log.LogHelper; +import com.yeshi.fanli.service.inter.redpack.RedPackGiveRecordService; 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; /** @@ -34,37 +37,40 @@ @Resource private UserSystemCouponService userSystemCouponService; - + @Resource private RedPackWinInviteService redPackWinInviteService; + @Resource + private RedPackGiveRecordService redPackGiveRecordService; + + @Resource(name = "producer") + private Producer producer; + @Override public Action consume(Message message, ConsumeContext context) { - LogHelper.mqInfo("consumer-RedPackMessageListener",message.getMsgID(), message.getTopic(), message.getTag(), + LogHelper.mqInfo("consumer-RedPackMessageListener", message.getMsgID(), message.getTopic(), message.getTag(), new String(message.getBody())); String tag = message.getTag(); if (tag == null) tag = ""; - BaseMQMsgBody baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class); - if (baseBody.isTest() != Constant.IS_TEST) - return Action.ReconsumeLater; - if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) { if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {// 杩斿埄鍒拌处 OrderMoneyRecievedMQMsg orderMoneyRecievedMQMsg = new Gson().fromJson(new String(message.getBody()), 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); + OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class); if (orderMQMsg.isValid()) { try {// 閭�璇峰鍔� redPackWinInviteService.inviteSucceedReward(orderMQMsg.getUid()); @@ -72,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; @@ -95,16 +139,29 @@ IntegralTaskMQMsg.class); inviteSucceedReward = true; uid = integralTaskMQMsg.getUid(); + } else if (tag.equalsIgnoreCase(UserTopicTagEnum.redPackGiftDrawback.name())) {// 绾㈠寘璧犻�� + UserRedPackGiftMQMsg userRedPackGiftMQMsg = new Gson().fromJson(new String(message.getBody()), + UserRedPackGiftMQMsg.class); + // 绾㈠寘璧犻�佸埌鏈熸湭棰嗗彇 + try { + redPackGiveRecordService.overdueByPrimaryKey(userRedPackGiftMQMsg.getId()); + } catch (Exception e) { + e.printStackTrace(); + } + return Action.CommitMessage; } - - if (inviteSucceedReward ) { + + if (inviteSucceedReward) { try {// 閭�璇峰鍔� - redPackWinInviteService.inviteSucceedReward(uid); + if (uid == 6269748) { + System.out.println(uid); + } + // redPackWinInviteService.inviteSucceedReward(uid); } catch (Exception e) { e.printStackTrace(); } } - + } return Action.CommitMessage; } -- Gitblit v1.8.0