YOHOBUY / yoho-message-sdk · Commits

Go to a project

Authored by tanling
Commit 298aae729d2f2dd27b629413d62fe925764ee821 1 parent 026a6059

限购码排队活动

Inline Side-by-side
Showing 7 changed files with 73 additions and 31 deletions
... ... @@ -13,7 +13,7 @@
<artifactId>yoho-message-sdk</artifactId>
<packaging>jar</packaging>
<name>yoho-message-sdk</name>
<version>1.1.1-SNAPSHOT</version>
<version>1.1.2-SNAPSHOT</version>
<dependencies>
<dependency>
... ...
... ... @@ -22,11 +22,6 @@ public abstract class AbstractSendMessage {
return new MessageCenterCommonEvent(sendScene, sendSceneKey, uids);
}
public MessageCenterCommonEvent genMessageCenterCommonEvent(String sendScene, int miniappType, String uid) {
List<String> uids = Arrays.asList(uid);
return new MessageCenterCommonEvent(sendScene, miniappType, uids);
}
public MessageCenterCommonEvent genMessageCenterCommonEvent(String sendScene, String sendSceneKey, int miniappType, String uid) {
List<String> uids = Arrays.asList(uid);
return new MessageCenterCommonEvent(sendScene, sendSceneKey, miniappType, uids);
... ...
... ... @@ -2,9 +2,6 @@ package com.yoho.message.sdk.service;
import com.yoho.message.sdk.common.model.SendMessageRspBo;
/**
* Created by yoho on 2017/6/27.
*/
public interface ISendLimitCodeMessage {
SendMessageRspBo queueSuccess(String uid, int miniappType, String productName, String limitProductCode);
... ...
... ... @@ -19,7 +19,8 @@ public class SendlimitCodeMessageImpl extends AbstractSendMessage implements ISe
@Override
public SendMessageRspBo queueSuccess(String uid, int miniappType, String productName, String limitProductCode) {
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(PromotionScenes.LIMIT_CODE_QUEUE_SUCCESS, miniappType, uid);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(PromotionScenes.LIMIT_CODE_QUEUE_SUCCESS,
String.valueOf(System.currentTimeMillis()), miniappType, uid);
messageCenterCommonEvent.putInParams("productName",productName);
messageCenterCommonEvent.putInParams("limitProductCode",limitProductCode);
... ... @@ -29,7 +30,8 @@ public class SendlimitCodeMessageImpl extends AbstractSendMessage implements ISe
@Override
public SendMessageRspBo prizeSuccess(String uid, int miniappType, String productName, String limitProductCode) {
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(PromotionScenes.LIMIT_CODE_PRIZE_SUCCESS, miniappType, uid);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(PromotionScenes.LIMIT_CODE_PRIZE_SUCCESS,
String.valueOf(System.currentTimeMillis()), miniappType, uid);
messageCenterCommonEvent.putInParams("productName",productName);
messageCenterCommonEvent.putInParams("limitProductCode",limitProductCode);
... ... @@ -39,7 +41,8 @@ public class SendlimitCodeMessageImpl extends AbstractSendMessage implements ISe
@Override
public SendMessageRspBo prizeFail(String uid, int miniappType,String productName, String limitProductCode) {
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(PromotionScenes.LIMIT_CODE_PRIZE_FAIL, miniappType, uid);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(PromotionScenes.LIMIT_CODE_PRIZE_FAIL,
String.valueOf(System.currentTimeMillis()), miniappType, uid);
messageCenterCommonEvent.putInParams("productName",productName);
messageCenterCommonEvent.putInParams("limitProductCode",limitProductCode);
... ... @@ -49,7 +52,8 @@ public class SendlimitCodeMessageImpl extends AbstractSendMessage implements ISe
@Override
public SendMessageRspBo helpProcess(String uid, int miniappType,String productName, String limitProductCode) {
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(PromotionScenes.LIMIT_CODE_HELP_PROCESS, miniappType, uid);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(PromotionScenes.LIMIT_CODE_HELP_PROCESS,
String.valueOf(System.currentTimeMillis()), miniappType, uid);
messageCenterCommonEvent.putInParams("productName",productName);
messageCenterCommonEvent.putInParams("limitProductCode",limitProductCode);
... ...
... ... @@ -276,7 +276,7 @@ public class SendOrderMessageImpl extends AbstractSendMessage implements ISendOr
MessageCenterCommonEvent messageCenterCommonEvent = null;
if (miniappFlg == 1){
messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_ORDER_CANCEL, orderCode, uid);
messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_ORDER_CANCEL, orderCode, miniappFlg, uid);
}else{
messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.ORDER_CANCEL, orderCode, uid);
}
... ... @@ -307,12 +307,13 @@ public class SendOrderMessageImpl extends AbstractSendMessage implements ISendOr
*/
public SendMessageRspBo waitingPay(String uid, String orderCode, String orderAmount, String productName, int miniappFlg) {
if (miniappFlg != 1) {
//yoho暂时不通知
return null;
}
// 支持多种小程序miniappFlg
// if (miniappFlg != 1) {
// //yoho暂时不通知
// return null;
// }
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_WAITING_PAY, orderCode, uid);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_WAITING_PAY, orderCode, miniappFlg, uid);
messageCenterCommonEvent.putInParams("orderCode", orderCode);
messageCenterCommonEvent.putInParams("orderAmount", orderAmount);
... ... @@ -335,12 +336,12 @@ public class SendOrderMessageImpl extends AbstractSendMessage implements ISendOr
*/
public SendMessageRspBo confirmOrder(String uid, String orderCode, int goodReceiptTime, String productName, int miniappFlg) {
if (miniappFlg != 1) {
//yoho暂时不通知
return null;
}
// if (miniappFlg != 1) {
// //yoho暂时不通知
// return null;
// }
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_GOODS_RECEIPT, orderCode, uid);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_GOODS_RECEIPT, orderCode, miniappFlg, uid);
messageCenterCommonEvent.putInParams("orderCode", orderCode);
messageCenterCommonEvent.putInParams("productName", productName);
... ... @@ -363,12 +364,12 @@ public class SendOrderMessageImpl extends AbstractSendMessage implements ISendOr
*/
public SendMessageRspBo paySuccess(String uid, String orderCode, int payTime, String productName, String goodReceiptAddress, String orderAmount, int miniappFlg) {
if (miniappFlg != 1) {
//yoho暂时不通知
return null;
}
// if (miniappFlg != 1) {
// //yoho暂时不通知
// return null;
// }
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_PAY_SUCCESS, orderCode,6, uid);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_PAY_SUCCESS, orderCode, miniappFlg, uid);
messageCenterCommonEvent.putInParams("orderCode", orderCode);
messageCenterCommonEvent.putInParams("productName", productName);
... ... @@ -445,7 +446,7 @@ public class SendOrderMessageImpl extends AbstractSendMessage implements ISendOr
MessageCenterCommonEvent messageCenterCommonEvent = null;
if (miniappFlg == 1){
messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_GOODS_REFUND, orderCode, uid);
messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_GOODS_REFUND, orderCode, miniappFlg, uid);
}else{
messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.REFUND_SUCCESS, orderCode, uid);
}
... ... @@ -493,7 +494,7 @@ public class SendOrderMessageImpl extends AbstractSendMessage implements ISendOr
MessageCenterCommonEvent messageCenterCommonEvent = null;
if (miniappFlg == 1){
messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_ORDER_DELIVERY, orderCode, uid);
messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.MINI_ORDER_DELIVERY, orderCode, miniappFlg, uid);
}else{
messageCenterCommonEvent = genMessageCenterCommonEvent(sendScene, orderCode, uid);
}
... ...
package com.yoho.message.sdk.test;
import com.yoho.message.sdk.service.ISendLimitCodeMessage;
import com.yoho.message.sdk.service.user.ISendUserMessage;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
/**
* Created by yoho on 2017/6/27.
*/
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath*:META-INF/spring/test-message-sdk-*.xml" })
public class TestLimitCodeMessage {
@Autowired
private ISendLimitCodeMessage sendLimitCodeMessage;
@Test
public void queueSuccess() {
sendLimitCodeMessage.helpProcess("500031478",4 ,"限购商品名称", "1111");
}
}
... ...
package com.yoho.message.sdk.test;
import com.yoho.message.sdk.service.ISendLimitCodeMessage;
import com.yoho.message.sdk.service.promotion.ISendPromotionMessage;
import org.junit.Test;
import org.junit.runner.RunWith;
... ... @@ -27,6 +28,17 @@ public class TestPromotionMessage {
sendPromotionMessage.inviteCouponSend("500026792", "170829027", "50元现金券", "500026806");
}
@Autowired
private ISendLimitCodeMessage sendLimitCodeMessage;
@Test
public void queueSuccess() {
sendLimitCodeMessage.queueSuccess("500031478",4 ,"限购商品名称", "1111");
}
@Test
public void assistCouponSend() {
sendPromotionMessage.assistCouponSend("54096844", 1517905629 );
... ...