Authored by Amos_sdy

用户升级发短信场景接入

1 package com.yoho.message.sdk.common.constants; 1 package com.yoho.message.sdk.common.constants;
2 2
3 public class SendScenes { 3 public class SendScenes {
4 - 4 + // 优质晒单送优惠券
5 public static final String ORDERRE_RECOMMENDED_IN_SHOW = "ORDERRE_RECOMMENDED_IN_SHOW"; 5 public static final String ORDERRE_RECOMMENDED_IN_SHOW = "ORDERRE_RECOMMENDED_IN_SHOW";
  6 + // 首单送优惠券
6 public static final String FIRST_ORDER_GET_COUPON = "FIRST_ORDER_GET_COUPON"; 7 public static final String FIRST_ORDER_GET_COUPON = "FIRST_ORDER_GET_COUPON";
  8 + // 退换货审核通过
7 public static final String EXCHANGE_GOODS_VERIFY_PASS = "EXCHANGE_GOODS_VERIFY_PASS"; 9 public static final String EXCHANGE_GOODS_VERIFY_PASS = "EXCHANGE_GOODS_VERIFY_PASS";
  10 + // 退款预计到账时间通知
8 public static final String REFUND_EXPECT_REACH = "REFUND_EXPECT_REACH"; 11 public static final String REFUND_EXPECT_REACH = "REFUND_EXPECT_REACH";
  12 + // 订单发货
9 public static final String ORDER_SEND_OUT = "ORDER_SEND_OUT"; 13 public static final String ORDER_SEND_OUT = "ORDER_SEND_OUT";
10 14
  15 + // 用户升级
  16 + public static final String MEMBERSHIP_UPGRADE = "MEMBERSHIP_UPGRADE";
11 } 17 }
  1 +package com.yoho.message.sdk.service;
  2 +
  3 +import java.util.Arrays;
  4 +import java.util.List;
  5 +
  6 +import com.yoho.message.sdk.common.model.MessageCenterCommonEvent;
  7 +
  8 +/**
  9 + *
  10 + * <Description> 通用类<br>
  11 + *
  12 + * @author amos.shan<br>
  13 + * @version 1.0<br>
  14 + * @taskId <br>
  15 + * @CreateDate 2016年12月22日 <br>
  16 + */
  17 +public abstract class AbstractSendMessage {
  18 +
  19 + public MessageCenterCommonEvent genMessageCenterCommonEvent(String sendScene, String sendSceneKey, String uid) {
  20 + List<String> uids = Arrays.asList(uid);
  21 + return new MessageCenterCommonEvent(sendScene, sendSceneKey, uids);
  22 + }
  23 +}
1 package com.yoho.message.sdk.service.order.impl; 1 package com.yoho.message.sdk.service.order.impl;
2 2
3 -import java.util.Arrays;  
4 -import java.util.List;  
5 -  
6 import org.springframework.beans.factory.annotation.Autowired; 3 import org.springframework.beans.factory.annotation.Autowired;
7 import org.springframework.stereotype.Service; 4 import org.springframework.stereotype.Service;
8 5
@@ -10,19 +7,15 @@ import com.yoho.message.sdk.common.constants.SendScenes; @@ -10,19 +7,15 @@ import com.yoho.message.sdk.common.constants.SendScenes;
10 import com.yoho.message.sdk.common.handler.MessageCenterMqHandler; 7 import com.yoho.message.sdk.common.handler.MessageCenterMqHandler;
11 import com.yoho.message.sdk.common.model.MessageCenterCommonEvent; 8 import com.yoho.message.sdk.common.model.MessageCenterCommonEvent;
12 import com.yoho.message.sdk.common.model.SendMessageRspBo; 9 import com.yoho.message.sdk.common.model.SendMessageRspBo;
  10 +import com.yoho.message.sdk.service.AbstractSendMessage;
13 import com.yoho.message.sdk.service.order.ISendOrderMessage; 11 import com.yoho.message.sdk.service.order.ISendOrderMessage;
14 12
15 @Service 13 @Service
16 -public class SendOrderMessageImpl implements ISendOrderMessage{ 14 +public class SendOrderMessageImpl extends AbstractSendMessage implements ISendOrderMessage {
17 15
18 @Autowired 16 @Autowired
19 private MessageCenterMqHandler messageCenterMqHandler; 17 private MessageCenterMqHandler messageCenterMqHandler;
20 18
21 - private MessageCenterCommonEvent genMessageCenterCommonEvent(String sendScene,String sendSceneKey,String uid){  
22 - List<String> uids = Arrays.asList(uid);  
23 - return new MessageCenterCommonEvent(sendScene,sendSceneKey,uids);  
24 - }  
25 -  
26 @Override 19 @Override
27 public SendMessageRspBo orderRecommendedInShowGetCoupon(String uid, String orderCode) { 20 public SendMessageRspBo orderRecommendedInShowGetCoupon(String uid, String orderCode) {
28 MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.ORDERRE_RECOMMENDED_IN_SHOW,orderCode,uid); 21 MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.ORDERRE_RECOMMENDED_IN_SHOW,orderCode,uid);
  1 +package com.yoho.message.sdk.service.user;
  2 +
  3 +import com.yoho.message.sdk.common.model.SendMessageRspBo;
  4 +
  5 +/**
  6 + *
  7 + * <Description> 用户模块消息发送<br>
  8 + *
  9 + * @author amos.shan<br>
  10 + * @version 1.0<br>
  11 + * @taskId <br>
  12 + * @CreateDate 2016年12月22日 <br>
  13 + */
  14 +public interface ISendUserMessage {
  15 + /**
  16 + *
  17 + * Description: 会员升级<br>
  18 + *
  19 + * @author amos.shan<br>
  20 + * @taskId <br>
  21 + * @param vipLevel
  22 + * @param vipDiscount
  23 + * @return <br>
  24 + */
  25 + SendMessageRspBo membershipUpgrade(String vipLevel, String vipDiscount, String uid);
  26 +}
  1 +package com.yoho.message.sdk.service.user.impl;
  2 +
  3 +import org.springframework.beans.factory.annotation.Autowired;
  4 +import org.springframework.stereotype.Service;
  5 +
  6 +import com.yoho.message.sdk.common.constants.SendScenes;
  7 +import com.yoho.message.sdk.common.handler.MessageCenterMqHandler;
  8 +import com.yoho.message.sdk.common.model.MessageCenterCommonEvent;
  9 +import com.yoho.message.sdk.common.model.SendMessageRspBo;
  10 +import com.yoho.message.sdk.service.AbstractSendMessage;
  11 +import com.yoho.message.sdk.service.user.ISendUserMessage;
  12 +
  13 +/**
  14 + *
  15 + * <Description> 用户模块发消息<br>
  16 + *
  17 + * @author amos.shan<br>
  18 + * @version 1.0<br>
  19 + * @taskId <br>
  20 + * @CreateDate 2016年12月22日 <br>
  21 + */
  22 +@Service
  23 +public class SendUserMessageImpl extends AbstractSendMessage implements ISendUserMessage {
  24 + @Autowired
  25 + private MessageCenterMqHandler messageCenterMqHandler;
  26 +
  27 + @Override
  28 + public SendMessageRspBo membershipUpgrade(String vipLevel, String vipDiscount, String uid) {
  29 + MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MEMBERSHIP_UPGRADE, String.valueOf(System.currentTimeMillis()), uid);
  30 + messageCenterCommonEvent.putInParams("vipLevel", vipLevel);
  31 + messageCenterCommonEvent.putInParams("vipDiscount", vipDiscount);
  32 + messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
  33 +
  34 + return new SendMessageRspBo(200, "SUCCESS");
  35 + }
  36 +
  37 +}