YOHOBUY / yoho-message-sdk · Commits

Go to a project

Authored by unknown
Commit 22a9d82ef6659cb1c4c3834b9cff61103b100b8a 1 parent fe1fd967

独立拼团小程序模板

Inline Side-by-side
Showing 7 changed files with 67 additions and 28 deletions
... ... @@ -33,6 +33,15 @@ public enum MiniAppTypeEnum {
return null;
}
public static int getMiniAppTypeByAppId(String appId){
for(MiniAppTypeEnum v : values()){
if(String.valueOf(v.appId).equals(appId)){
return v.getCode();
}
}
return 0;
}
public String getAppId() {
return appId;
}
... ...
... ... @@ -25,7 +25,7 @@ public interface IGroupOrderService {
* @param endTime 截止日期
* @return 返回发送成功，返回成功，不代表最终发送成功。
*/
SendMessageRspBo startGroupSuccess(String uid, String orderCode, String productName, String groupPrice, String groupLeader, int groupNum, int endTime);
SendMessageRspBo startGroupSuccess(String uid, String orderCode, String productName, String groupPrice, String groupLeader, int groupNum, int endTime,int activityId,String groupNo,String appId);
/**
* 拼团： 参团成功提醒
... ... @@ -38,7 +38,7 @@ public interface IGroupOrderService {
* @param endTime 截止日期
* @return 返回发送成功，返回成功，不代表最终发送成功。
*/
SendMessageRspBo joinGroupSuccess(String uid, String orderCode, String productName, String groupPrice, int endTime);
SendMessageRspBo joinGroupSuccess(String uid, String orderCode, String productName, String groupPrice, int endTime,int activityId,String groupNo,String appId);
/**
* 拼团成功通知
... ... @@ -51,7 +51,7 @@ public interface IGroupOrderService {
* @param groupOrderAmount 团购价格
* @return
*/
SendMessageRspBo fightGroupsSuccess(String uid, String orderCode, int groupTime, String productName, String groupOrderAmount);
SendMessageRspBo fightGroupsSuccess(String uid, String orderCode, int groupTime, String productName, String groupOrderAmount,int activityId,String groupNo,String appId);
/**
... ... @@ -65,7 +65,7 @@ public interface IGroupOrderService {
* @param groupOrderAmount 团购价格
* @return
*/
SendMessageRspBo fightGroupsFail(String uid, String orderCode, int groupFailTime, String productName, String groupOrderAmount);
SendMessageRspBo fightGroupsFail(String uid, String orderCode, int groupFailTime, String productName, String groupOrderAmount,int activityId,String groupNo,String appId);
/**
... ... @@ -81,7 +81,7 @@ public interface IGroupOrderService {
* @param payAmount 支付金额
* @return 返回发送成功，返回成功，不代表最终发送成功。
*/
SendMessageRspBo fightGroupsSpeed(String uid, String orderCode, String leftTime, int leftNum, int groupTime, String productName, String payAmount);
SendMessageRspBo fightGroupsSpeed(String uid, String orderCode, String leftTime, int leftNum, int groupTime, String productName, String payAmount,int activityId,String groupNo,String appId);
/**
... ...
... ... @@ -10,6 +10,7 @@ import com.yoho.message.sdk.service.order.IGroupOrderService;
import com.yoho.message.sdk.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.apache.commons.lang3.StringUtils;
/**
* 拼团相关提醒
... ... @@ -36,20 +37,31 @@ public class GroupOrderServiceImpl extends AbstractSendMessage implements IGroup
* @return 返回发送成功，返回成功，不代表最终发送成功。
*/
@Override
public SendMessageRspBo startGroupSuccess(String uid, String orderCode, String productName, String groupPrice, String groupLeader, int groupNum, int endTime){
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.START_GROUP_SUCCESS, orderCode, uid);
public SendMessageRspBo startGroupSuccess(String uid, String orderCode, String productName, String groupPrice, String groupLeader, int groupNum, int endTime,int activityId,String groupNo,String appId){
int miniAppType = getMiniAppTypeByAppId(appId);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.START_GROUP_SUCCESS, orderCode,miniAppType, uid);
messageCenterCommonEvent.putInParams("orderCode", orderCode);
messageCenterCommonEvent.putInParams("productName", productName);
messageCenterCommonEvent.putInParams("groupPrice", groupPrice);
messageCenterCommonEvent.putInParams("groupNum", groupNum);
messageCenterCommonEvent.putInParams("groupLeader", groupLeader);
messageCenterCommonEvent.putInParams("activityId", activityId);
messageCenterCommonEvent.putInParams("groupNo",groupNo);
messageCenterCommonEvent.putInParams("endTime", DateUtils.long2DateStr(endTime * 1000l, DateUtils.fullDateTimeFormat));
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
return new SendMessageRspBo(200, "SUCCESS");
}
private int getMiniAppTypeByAppId(String appId) {
int miniAppType = 0;
if(StringUtils.isNotEmpty(appId)){
miniAppType = MiniAppTypeEnum.getMiniAppTypeByAppId(appId);
}
return miniAppType;
}
/**
* 拼团： 参团成功提醒
... ... @@ -62,13 +74,16 @@ public class GroupOrderServiceImpl extends AbstractSendMessage implements IGroup
* @param endTime 截止日期
* @return 返回发送成功，返回成功，不代表最终发送成功。
*/
public SendMessageRspBo joinGroupSuccess(String uid, String orderCode, String productName, String groupPrice, int endTime){
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.GROUP_JOIN_SUCCESS, orderCode, uid);
public SendMessageRspBo joinGroupSuccess(String uid, String orderCode, String productName, String groupPrice, int endTime,int activityId,String groupNo,String appId){
int miniAppType = getMiniAppTypeByAppId(appId);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.GROUP_JOIN_SUCCESS, orderCode,miniAppType, uid);
messageCenterCommonEvent.putInParams("orderCode", orderCode);
messageCenterCommonEvent.putInParams("productName", productName);
messageCenterCommonEvent.putInParams("groupPrice", groupPrice);
messageCenterCommonEvent.putInParams("endTime", DateUtils.long2DateStr(endTime * 1000l, DateUtils.fullDateTimeFormat));
messageCenterCommonEvent.putInParams("activityId", activityId);
messageCenterCommonEvent.putInParams("groupNo",groupNo);
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
return new SendMessageRspBo(200, "SUCCESS");
}
... ... @@ -86,15 +101,17 @@ public class GroupOrderServiceImpl extends AbstractSendMessage implements IGroup
* @return
*/
@Override
public SendMessageRspBo fightGroupsSuccess(String uid, String orderCode, int groupTime, String productName, String groupOrderAmount) {
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.GROUP_ORDER_SUCCESS, orderCode, uid);
public SendMessageRspBo fightGroupsSuccess(String uid, String orderCode, int groupTime, String productName, String groupOrderAmount,int activityId,String groupNo,String appId) {
int miniAppType = getMiniAppTypeByAppId(appId);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.GROUP_ORDER_SUCCESS, orderCode,miniAppType, uid);
messageCenterCommonEvent.putInParams("orderCode", orderCode);
messageCenterCommonEvent.putInParams("groupTime", DateUtils.long2DateStr(groupTime * 1000l, DateUtils.fullDateTimeFormat));
messageCenterCommonEvent.putInParams("productName", productName);
messageCenterCommonEvent.putInParams("groupOrderAmount", groupOrderAmount);
messageCenterCommonEvent.putInParams("activityId", activityId);
messageCenterCommonEvent.putInParams("groupNo",groupNo);
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
... ... @@ -113,15 +130,17 @@ public class GroupOrderServiceImpl extends AbstractSendMessage implements IGroup
* @return
*/
@Override
public SendMessageRspBo fightGroupsFail(String uid, String orderCode, int groupFailTime, String productName, String groupOrderAmount) {
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.GROUP_ORDER_FAIL, orderCode, uid);
public SendMessageRspBo fightGroupsFail(String uid, String orderCode, int groupFailTime, String productName, String groupOrderAmount,int activityId,String groupNo,String appId) {
int miniAppType = getMiniAppTypeByAppId(appId);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.GROUP_ORDER_FAIL, orderCode,miniAppType, uid);
messageCenterCommonEvent.putInParams("orderCode", orderCode);
messageCenterCommonEvent.putInParams("groupFailTime", DateUtils.long2DateStr(groupFailTime * 1000l, DateUtils.fullDateTimeFormat));
messageCenterCommonEvent.putInParams("productName", productName);
messageCenterCommonEvent.putInParams("groupOrderAmount", groupOrderAmount);
messageCenterCommonEvent.putInParams("activityId", activityId);
messageCenterCommonEvent.putInParams("groupNo",groupNo);
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
... ... @@ -142,14 +161,17 @@ public class GroupOrderServiceImpl extends AbstractSendMessage implements IGroup
* @return 返回发送成功，返回成功，不代表最终发送成功。
*/
@Override
public SendMessageRspBo fightGroupsSpeed(String uid, String orderCode, String leftTime, int leftNum, int groupTime, String productName, String payAmount) {
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.GROUP_ORDER_SPEED, orderCode, uid);
public SendMessageRspBo fightGroupsSpeed(String uid, String orderCode, String leftTime, int leftNum, int groupTime, String productName, String payAmount,int activityId,String groupNo,String appId) {
int miniAppType = getMiniAppTypeByAppId(appId);
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(GroupScenes.GROUP_ORDER_SPEED, orderCode,miniAppType, uid);
messageCenterCommonEvent.putInParams("leftTime", leftTime);
messageCenterCommonEvent.putInParams("orderCode", orderCode);
messageCenterCommonEvent.putInParams("groupTime", DateUtils.long2DateStr(groupTime * 1000l, DateUtils.fullDateTimeFormat));
messageCenterCommonEvent.putInParams("productName", productName);
messageCenterCommonEvent.putInParams("leftNum", leftNum);
messageCenterCommonEvent.putInParams("payAmount", payAmount);
messageCenterCommonEvent.putInParams("activityId", activityId);
messageCenterCommonEvent.putInParams("groupNo",groupNo);
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
return new SendMessageRspBo(200, "SUCCESS");
... ...
... ... @@ -20,23 +20,27 @@ public class TestGroupMiniMessage {
@Test
public void sendStartGroup() {
SendMessageRspBo result = groupOrderService.startGroupSuccess("500031566", "111111", "TestProduct", "12.1","leader", 3, 1533893836);
System.out.println(result);
groupOrderService.startGroupSuccess("600032916","41382090069","VANS大衣","1000元","张三",3,1542774655,42,"22017135957","wx207f18be42db9028");
}
@Test
public void fightGroupsSuccess(){
SendMessageRspBo result = groupOrderService.fightGroupsSuccess("500031566","A66666",1500758555,"xiaodongdong","100");
SendMessageRspBo result = groupOrderService.fightGroupsSuccess("600032916","A66666",1500758555,"VANS大衣","100",42,"22017135957","wx207f18be42db9028");
System.out.println(result);
}
@Test
public void fightGroupsFail(){
SendMessageRspBo result = groupOrderService.fightGroupsFail("500031566", "A66666", 1500758555, "xiaodongdong", "100");
SendMessageRspBo result = groupOrderService.fightGroupsFail("600032916", "A66666", 1500758555, "VANS大衣", "100",42,"22017135957","");
System.out.println(result);
}
@Test
public void fightGroupsSpeed(){
SendMessageRspBo result = groupOrderService.fightGroupsSpeed("600032916", "A66666", "1500758555",20, 1500758555, "VAN大衣", "100",42,"22017135957", "wx207f18be42db9028");
System.out.println(result);
}
}
... ...
... ... @@ -20,17 +20,17 @@ public class TestLimitCodeMessage {
@Test
public void queueSuccess() {
sendLimitCodeMessage.helpProcess("500031478",4 ,"限购商品名称", "1111");
sendLimitCodeMessage.helpProcess("500031566",4 ,"限购商品名称", "1111");
}
@Test
public void assitSuccess(){
sendLimitCodeMessage.assitSuccess("500031566","VANS帅气卫衣",5,"ABCDEFG");
sendLimitCodeMessage.assitSuccess("1234567","VANS帅气卫衣",5,"ABCDEFG");
}
@Test
public void getLimitCodeSuccess(){
sendLimitCodeMessage.getLimitCodeSuccess("500031566","VANS帅气卫衣","2018-12-01 14:00","ABCDEFG");
sendLimitCodeMessage.getLimitCodeSuccess("1234567","VANS帅气卫衣","2018-12-01 14:00","ABCDEFG");
}
}
... ...
... ... @@ -34,8 +34,7 @@ public class TestPromotionMessage {
@Test
public void queueSuccess() {
sendLimitCodeMessage.queueSuccess("500031566",4 ,"限购商品名称", "1111",6,"2018-11-18");
sendLimitCodeMessage.queueSuccess("1234567",4 ,"限购商品名称", "1111",6,"2018-11-18");
}
... ...
... ... @@ -188,12 +188,17 @@ public class TestSendOrderMessage {
@Test
public void fightGroupSuccess(){
groupOrderService.fightGroupsSuccess("54096844", "41312884053",1517391944,"测试商品", "1");
groupOrderService.fightGroupsSuccess("54096844", "41312884053",1517391944,"测试商品", "1",20,"12334","wx207f18be42db9028");
}
@Test
public void fightGroupsFail(){
groupOrderService.fightGroupsFail("54096844", "41382090069",1517391944,"测试商品", "99999元");
groupOrderService.fightGroupsFail("54096844", "41382090069",1517391944,"测试商品", "99999元",23,"334","wx207f18be42db9028");
}
@Test
public void startGroupSuccess(){
groupOrderService.startGroupSuccess("600032916","41382090069","VANS大衣","1000元","张三",3,1542774655,34,"23343","wx207f18be42db9028");
}
... ...