| | |
|---|
| | | 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;
|
|---|
| | | }
|
|---|
| | | } 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) {
|
|---|
| | | try {// 邀请奖励
|
|---|
| | | redPackWinInviteService.inviteSucceedReward(orderMQMsg.getUid());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | if (orderMQMsg.getDelayHour() == hour) {
|
|---|
| | | try {// 邀请奖励
|
|---|
| | | redPackWinInviteService.inviteSucceedReward(orderMQMsg.getUid());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | return Action.ReconsumeLater;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | 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_INVITE) {
|
|---|
| | | if (!StringUtil.isNullOrEmpty(orderMoneyRecievedMQMsg.getOrderId())
|
|---|
| | | && orderMoneyRecievedMQMsg.getUid() != null) {
|
|---|
| | | try {
|
|---|
| | | redPackWinInviteService.inviteOrderArriveReward(orderMoneyRecievedMQMsg.getUid(), |
|---|
| | | orderMoneyRecievedMQMsg.getSourceType(), orderMoneyRecievedMQMsg.getOrderId()); |
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | 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_INVITE) {
|
|---|
| | | if (!StringUtil.isNullOrEmpty(orderMoneyRecievedMQMsg.getOrderId())
|
|---|
| | | && orderMoneyRecievedMQMsg.getUid() != null) {
|
|---|
| | | try {
|
|---|
| | | redPackWinInviteService.inviteOrderArriveReward(orderMoneyRecievedMQMsg.getUid(),
|
|---|
| | | orderMoneyRecievedMQMsg.getSourceType(), orderMoneyRecievedMQMsg.getOrderId());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | return Action.CommitMessage;
|
|---|
| | | }
|
|---|
| | | return Action.CommitMessage;
|
|---|
| | | } else if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
|
|---|
| | | boolean inviteSucceedReward = false;
|
|---|
| | | Long uid = null;
|
|---|
| | |
|---|
| | | UserInviteMQMsg.class);
|
|---|
| | | inviteSucceedReward = true;
|
|---|
| | | uid = userInviteMQMsg.getWorkerId();
|
|---|
| | |
|
|---|
| | | redPackWinInviteService.initCreateRedPackWin(userInviteMQMsg.getBossId(),
|
|---|
| | | userInviteMQMsg.getWorkerId());
|
|---|
| | |
|
|---|
| | | } else if (tag.equalsIgnoreCase(UserTopicTagEnum.redPackGiftDrawback.name())) {// 红包赠送
|
|---|
| | | UserRedPackGiftMQMsg userRedPackGiftMQMsg = new Gson().fromJson(new String(message.getBody()),
|
|---|
| | | UserRedPackGiftMQMsg.class);
|
|---|
