|
|
package com.yoho.message.sdk.service.product;
|
|
|
|
|
|
import com.yoho.message.sdk.common.constants.SendScenes;
|
|
|
import com.yoho.message.sdk.common.constants.PublicNumberConstants;
|
|
|
import com.yoho.message.sdk.common.constants.YouZhuanScenes;
|
|
|
import com.yoho.message.sdk.common.handler.MessageCenterMqHandler;
|
|
|
import com.yoho.message.sdk.common.model.MessageCenterCommonEvent;
|
...
|
...
|
@@ -23,55 +23,70 @@ public class SendProductMessageImpl extends AbstractSendMessage implements ISend |
|
|
private MessageCenterMqHandler messageCenterMqHandler;
|
|
|
|
|
|
/**
|
|
|
* 有货有赚项目 佣金结算提醒
|
|
|
* 有货有赚项目 申请成功提醒
|
|
|
*
|
|
|
* @param uid
|
|
|
* @param passTime 通过时间
|
|
|
*
|
|
|
* @param uid 接收用户UID
|
|
|
* @param CommissionAmount 佣金总金额
|
|
|
* @param moneyArriveTime 结算到账时间
|
|
|
* @return 返回成功标志
|
|
|
*/
|
|
|
@Override
|
|
|
public SendMessageRspBo commissionNotice(String uid, String CommissionAmount, String moneyArriveTime) {
|
|
|
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(YouZhuanScenes.YOZHUAN_COMMISSION_SETTLEMENT, uid, uid);
|
|
|
messageCenterCommonEvent.putInParams("CommissionAmount", CommissionAmount);
|
|
|
messageCenterCommonEvent.putInParams("moneyArriveTime", moneyArriveTime);
|
|
|
public SendMessageRspBo joinSuccessNotice(String uid, String passTime){
|
|
|
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEventPublicCode(YouZhuanScenes.YZ_JOIN_SUCCESS, uid, PublicNumberConstants.YOUZHUAN_SERVICE, uid);
|
|
|
messageCenterCommonEvent.putInParams("passTime", passTime);
|
|
|
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
|
|
|
return new SendMessageRspBo(200, "SUCCESS");
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 有货有赚项目 提现打款提醒
|
|
|
* 有货有赚项目 预估佣金提醒
|
|
|
*
|
|
|
* @param uid 接收用户UID
|
|
|
* @param totalAmount 打款总金额
|
|
|
* @param moneyArriveTime 打款到账时间
|
|
|
* @param uid
|
|
|
* @param orderAmount 佣金总金额
|
|
|
* @param nowTime 当前时间
|
|
|
* @return 返回成功标志
|
|
|
*/
|
|
|
@Override
|
|
|
public SendMessageRspBo cashAccountNotice(String uid, String totalAmount, String moneyArriveTime) {
|
|
|
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(YouZhuanScenes.YOZHUAN_CRASH_ACCOUNT, uid, uid);
|
|
|
messageCenterCommonEvent.putInParams("totalAmount", totalAmount);
|
|
|
messageCenterCommonEvent.putInParams("moneyArriveTime", moneyArriveTime);
|
|
|
public SendMessageRspBo estimateNotice(String uid, String orderAmount, String nowTime){
|
|
|
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEventPublicCode(YouZhuanScenes.ESTIMATE_SETTLE, uid, PublicNumberConstants.YOUZHUAN_SERVICE, uid);
|
|
|
messageCenterCommonEvent.putInParams("orderAmount", orderAmount);
|
|
|
messageCenterCommonEvent.putInParams("nowTime", nowTime);
|
|
|
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
|
|
|
return new SendMessageRspBo(200, "SUCCESS");
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 有货有赚项目 订单任务完成提醒
|
|
|
* 有货有赚项目 佣金结算提醒
|
|
|
*
|
|
|
* @param uid
|
|
|
* @param orderAmount 变为可结算状态的预估佣金
|
|
|
* @param crashTime 可提现时间
|
|
|
* @return 返回成功标志
|
|
|
*/
|
|
|
@Override
|
|
|
public SendMessageRspBo commissionNotice(String uid, String orderAmount, String crashTime) {
|
|
|
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEventPublicCode(YouZhuanScenes.YOZHUAN_COMMISSION_SETTLEMENT, uid, PublicNumberConstants.YOUZHUAN_SERVICE, uid);
|
|
|
messageCenterCommonEvent.putInParams("orderAmount", orderAmount);
|
|
|
messageCenterCommonEvent.putInParams("crashTime", crashTime);
|
|
|
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
|
|
|
return new SendMessageRspBo(200, "SUCCESS");
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 有货有赚项目 提现打款提醒
|
|
|
*
|
|
|
* @param uid 接收用户UID
|
|
|
* @param activeName 活动名称
|
|
|
* @param activeCommission 获得奖励预估收入金额
|
|
|
* @param activeEndTime 活动结束时间
|
|
|
* @param orderAmount 打款总金额
|
|
|
* @param crashTime 打款时间
|
|
|
* @return 返回成功标志
|
|
|
*/
|
|
|
@Override
|
|
|
public SendMessageRspBo orderCompletedNotice(String uid, String activeName, String activeCommission, String activeEndTime) {
|
|
|
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(YouZhuanScenes.YOZHUAN_ORDER_COMPLETE, uid, uid);
|
|
|
messageCenterCommonEvent.putInParams("activeName", activeName);
|
|
|
messageCenterCommonEvent.putInParams("activeCommission", activeCommission);
|
|
|
messageCenterCommonEvent.putInParams("activeEndTime", activeEndTime);
|
|
|
public SendMessageRspBo cashAccountNotice(String uid, String orderAmount, String crashTime) {
|
|
|
MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEventPublicCode(YouZhuanScenes.YOZHUAN_CRASH_ACCOUNT, uid, PublicNumberConstants.YOUZHUAN_SERVICE,uid);
|
|
|
messageCenterCommonEvent.putInParams("orderAmount", orderAmount);
|
|
|
messageCenterCommonEvent.putInParams("crashTime", crashTime);
|
|
|
messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
|
|
|
return new SendMessageRspBo(200, "SUCCESS");
|
|
|
}
|
|
|
|
|
|
} |
...
|
...
|
|