package com.xiaopeng.account.util;
|
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.xiaopeng.account.constant.I18nKeyConstant;
|
import com.xiaopeng.account.service.IXpAppUserCouponService;
|
import com.xiaopeng.account.service.impl.XpAppUserCouponServiceImpl;
|
import com.xiaopeng.api.dto.account.UcUserInfo;
|
import com.xiaopeng.api.dto.operation.SmsDto;
|
import com.xiaopeng.api.feignClient.account.UserResourcesClient;
|
import com.xiaopeng.api.feignClient.account.XpAppUserCouponClient;
|
import com.xiaopeng.api.feignClient.operation.SmsClient;
|
import com.xiaopeng.api.feignClient.operation.XpActicityClient;
|
import com.xiaopeng.api.feignClient.operation.XpCouponClient;
|
import com.xiaopeng.api.feignClient.order.XpOrderClient;
|
import com.xiaopeng.api.feignClient.pushMessage.SubscribeMessageClient;
|
import com.xiaopeng.api.feignClient.pushMessage.WebSocketMessageClient;
|
import com.xiaopeng.api.model.account.XpAppUserCoupon;
|
import com.xiaopeng.api.model.operation.XpActicityStrategy;
|
import com.xiaopeng.api.model.operation.XpActivity;
|
import com.xiaopeng.api.model.operation.XpCoupon;
|
import com.xiaopeng.api.vo.operation.SmsVo;
|
import com.xiaopeng.api.vo.pushMessage.SendCouponMessageVo;
|
import com.xiaopeng.api.vo.pushMessage.SendSubscribeMessageVo;
|
import com.xiaopeng.common.core.constant.Constants;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.common.core.enums.MessageTemplateEnum;
|
import com.xiaopeng.common.core.exception.ServiceException;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.util.StringUtils;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.time.ZoneOffset;
|
import java.time.format.DateTimeFormatter;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.concurrent.LinkedBlockingQueue;
|
import java.util.concurrent.ThreadFactory;
|
import java.util.concurrent.ThreadPoolExecutor;
|
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Component
|
public class UserCouponTask {
|
|
@Resource
|
private IXpAppUserCouponService xpAppUserCouponService;
|
|
@Resource
|
private XpActicityClient acticityClient;
|
|
@Resource
|
private SubscribeMessageClient subscribeMessageClient;
|
|
@Resource
|
private XpCouponClient xpCouponClient;
|
|
@Resource
|
private SmsClient smsClient;
|
|
@Value("${sms.appid}")
|
private String sms_appid;
|
|
@Resource
|
private UserResourcesClient userResourcesClient;
|
|
@Resource
|
private WebSocketMessageClient webSocketMessageClient;
|
|
private static final ThreadPoolExecutor RETRY_EXECUTOR = new ThreadPoolExecutor(
|
4,
|
16,
|
60L, TimeUnit.SECONDS,
|
new LinkedBlockingQueue<>(512),
|
new ThreadFactory() {
|
private final AtomicInteger counter = new AtomicInteger(0);
|
@Override
|
public Thread newThread(Runnable r) {
|
Thread t = new Thread(r, "route-push-retry-" + counter.incrementAndGet());
|
t.setDaemon(true);
|
return t;
|
}
|
},
|
new ThreadPoolExecutor.CallerRunsPolicy()
|
);
|
|
|
/**
|
* 定时任务发送优惠券通知
|
*/
|
@Scheduled(fixedDelay = 30000)
|
public void taskOrder() {
|
List<XpActivity> activityList = acticityClient.getAllEffectiveActivity().getData();
|
List<XpActivity> collect1 = activityList.stream().filter(xpActivity -> null != xpActivity.getWechatNotification() && xpActivity.getWechatNotification() == 1).collect(Collectors.toList());
|
pushWxCouponMessage(collect1);
|
List<XpActivity> collect2 = activityList.stream().filter(xpActivity -> null != xpActivity.getSmsNotification() && xpActivity.getSmsNotification() == 1).collect(Collectors.toList());
|
pushSmsCouponMessage(collect2);
|
List<XpActivity> collect3 = activityList.stream().filter(xpActivity -> null != xpActivity.getMiniProgramNotification() && xpActivity.getMiniProgramNotification() == 1).collect(Collectors.toList());
|
pushMiniProgramCouponMessage(collect3);
|
editUserCouponStatus();
|
}
|
|
|
/**
|
* 微信通知
|
*/
|
private void pushWxCouponMessage(List<XpActivity> activityList) {
|
log.info("开始执行优惠券微信提醒消息发送 {}", activityList.size());
|
for (XpActivity xpActivity : activityList) {
|
//微信通知活动开始提醒（0=否，1=是）
|
Integer wechatActicityStart = xpActivity.getWechatActicityStart();
|
if(null != wechatActicityStart && 1 == wechatActicityStart){
|
RETRY_EXECUTOR.execute(() -> {
|
//即将到期提前通知
|
Integer wechatActicityStartMinutes = xpActivity.getWechatActicityStartMinutes();
|
//获取满足微信通知的即将生效的优惠券
|
long time = LocalDateTime.now().plusMinutes(wechatActicityStartMinutes).toEpochSecond(ZoneOffset.of("+8"));
|
List<XpAppUserCoupon> list = xpAppUserCouponService.list(new LambdaUpdateWrapper<XpAppUserCoupon>()
|
.eq(XpAppUserCoupon::getActivityId, xpActivity.getId()).eq(XpAppUserCoupon::getStatus, 1)
|
.last(" and UNIX_TIMESTAMP(effective_time) >= " + time + " and " + time + "> UNIX_TIMESTAMP(effective_time) - 100"));
|
if(list.isEmpty()){
|
return;
|
}
|
log.info("开始执行生效前优惠券微信提醒消息发送");
|
for (XpAppUserCoupon xpAppUserCoupon : list) {
|
XpCoupon coupon = xpCouponClient.getCouponById(xpAppUserCoupon.getCouponId()).getData();
|
SendSubscribeMessageVo vo = new SendSubscribeMessageVo();
|
vo.setUserId(xpAppUserCoupon.getAppUserId());
|
vo.setTemplateId(MessageTemplateEnum.C.getTemplateId());
|
String json = MessageTemplateEnum.C.getRemarks();
|
json = json.replace("活动名称", xpAppUserCoupon.getCouponName());
|
json = json.replace("温馨提示", coupon.getCouponDescription());
|
vo.setJson(json);
|
R<?> r = subscribeMessageClient.sendSubscribeMessage(vo);
|
}
|
});
|
}
|
|
//微信通知即将过期提醒（0=否，1=是）
|
Integer wechatAboutExpireReminder = xpActivity.getWechatAboutExpireReminder();
|
if(null != wechatAboutExpireReminder && 1 == wechatAboutExpireReminder){
|
RETRY_EXECUTOR.execute(() -> {
|
//即将到期提前通知
|
Integer wechatAboutExpireDays = xpActivity.getWechatAboutExpireDays();
|
//微信通知即将过期天数
|
long time = LocalDateTime.now().plusDays(wechatAboutExpireDays).toEpochSecond(ZoneOffset.of("+8"));
|
List<XpAppUserCoupon> list = xpAppUserCouponService.list(new LambdaUpdateWrapper<XpAppUserCoupon>()
|
.eq(XpAppUserCoupon::getActivityId, xpActivity.getId()).eq(XpAppUserCoupon::getStatus, 1)
|
.last(" and UNIX_TIMESTAMP(expiration_time) >= " + time + " and " + time + "> UNIX_TIMESTAMP(expiration_time) - 100"));
|
if(list.isEmpty()){
|
return;
|
}
|
log.info("开始执行优惠券即将过期微信提醒消息发送");
|
for (XpAppUserCoupon xpAppUserCoupon : list) {
|
XpCoupon coupon = xpCouponClient.getCouponById(xpAppUserCoupon.getCouponId()).getData();
|
SendSubscribeMessageVo vo = new SendSubscribeMessageVo();
|
vo.setUserId(xpAppUserCoupon.getAppUserId());
|
vo.setTemplateId(MessageTemplateEnum.F.getTemplateId());
|
String json = MessageTemplateEnum.F.getRemarks();
|
json = json.replace("优惠券名称", xpAppUserCoupon.getCouponName());
|
json = json.replace("券过期时间", xpAppUserCoupon.getExpirationTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm")));
|
json = json.replace("使用规则", coupon.getCouponDescription());
|
vo.setJson(json);
|
R<?> r = subscribeMessageClient.sendSubscribeMessage(vo);
|
}
|
});
|
}
|
}
|
}
|
|
|
/**
|
* 短信通知
|
* @param activityList
|
*/
|
private void pushSmsCouponMessage(List<XpActivity> activityList) {
|
log.info("开始执行优惠券短信提醒消息发送 {}", activityList.size());
|
aa: for (XpActivity xpActivity : activityList) {
|
Integer now = Integer.valueOf(LocalDateTime.now().format(DateTimeFormatter.ofPattern("HHmm")));
|
Integer smsAboutExpireReminder = xpActivity.getSmsAboutExpireReminder();
|
if(StringUtils.hasLength(xpActivity.getSmsStartBlockingTime())){
|
String[] smsStartBlockingTime = xpActivity.getSmsStartBlockingTime().split(",");
|
String[] smsEndBlockingTime = xpActivity.getSmsEndBlockingTime().split(",");
|
for (int i = 0; i < smsStartBlockingTime.length; i++) {
|
Integer start = Integer.valueOf(smsStartBlockingTime[i].replace(":", ""));
|
Integer end = Integer.valueOf(smsEndBlockingTime[i].replace(":", ""));
|
if(start <= now && now <= end){
|
log.info("当前时间在短信发送时间区间内，不发送短信");
|
continue aa;
|
}
|
}
|
}
|
|
|
//微信通知活动开始提醒（0=否，1=是）
|
Integer smsActicityStart = xpActivity.getSmsActicityStart();
|
if(null != smsActicityStart && 1 == smsActicityStart){
|
RETRY_EXECUTOR.execute(() -> {
|
//短信通知临近券生效前X分钟通知
|
Integer smsActicityStartMinutes = xpActivity.getSmsActicityStartMinutes();
|
//获取满足微信通知的即将生效的优惠券
|
long time = LocalDateTime.now().plusMinutes(smsActicityStartMinutes).toEpochSecond(ZoneOffset.of("+8"));
|
List<XpAppUserCoupon> list = xpAppUserCouponService.list(new LambdaUpdateWrapper<XpAppUserCoupon>()
|
.eq(XpAppUserCoupon::getActivityId, xpActivity.getId()).eq(XpAppUserCoupon::getStatus, 1)
|
.last(" and UNIX_TIMESTAMP(effective_time) >= " + time + " and " + time + "> UNIX_TIMESTAMP(effective_time) - 100"));
|
if(list.isEmpty()){
|
return;
|
}
|
log.info("开始执行生效前优惠券短信提醒消息发送");
|
for (XpAppUserCoupon xpAppUserCoupon : list) {
|
UcUserInfo ucUserInfo = userResourcesClient.getBaseUserByUid(xpAppUserCoupon.getAppUserId().toString());
|
if(null == ucUserInfo || !StringUtils.hasLength(ucUserInfo.getMobile())){
|
log.info("用户信息不存在，跳过");
|
continue;
|
}
|
XpCoupon coupon = xpCouponClient.getCouponById(xpAppUserCoupon.getCouponId()).getData();
|
SmsVo vo = new SmsVo();
|
vo.setAppId(sms_appid);
|
vo.setPushType(1);
|
vo.setReceivers(ucUserInfo.getMobile());
|
vo.setTemplateCode("RTActivityStartTpl");
|
vo.setAppPushConfigCode("RTActivityStartSms");
|
vo.setParams(new HashMap<>());
|
vo.getParams().put("name", xpAppUserCoupon.getCouponName());
|
SmsDto smsDto = smsClient.pushSms(vo);
|
if(null == smsDto || smsDto.getCode() != 200){
|
log.info("短信发送失败");
|
}
|
}
|
});
|
}
|
|
//短信通知即将过期提醒（0=否，1=是）
|
if(null != smsAboutExpireReminder && 1 == smsAboutExpireReminder){
|
RETRY_EXECUTOR.execute(() -> {
|
//即将到期提前通知
|
Integer smsAboutExpireDays = xpActivity.getSmsAboutExpireDays();
|
//微信通知即将过期天数
|
long time = LocalDateTime.now().plusDays(smsAboutExpireDays).toEpochSecond(ZoneOffset.of("+8"));
|
List<XpAppUserCoupon> list = xpAppUserCouponService.list(new LambdaUpdateWrapper<XpAppUserCoupon>()
|
.eq(XpAppUserCoupon::getActivityId, xpActivity.getId()).eq(XpAppUserCoupon::getStatus, 1)
|
.last(" and UNIX_TIMESTAMP(expiration_time) >= " + time + " and " + time + "> UNIX_TIMESTAMP(expiration_time) - 100"));
|
if(list.isEmpty()){
|
return;
|
}
|
log.info("开始执行优惠券即将过期短信提醒消息发送");
|
for (XpAppUserCoupon xpAppUserCoupon : list) {
|
UcUserInfo ucUserInfo = userResourcesClient.getBaseUserByUid(xpAppUserCoupon.getAppUserId().toString());
|
if(null == ucUserInfo || !StringUtils.hasLength(ucUserInfo.getMobile())){
|
log.info("用户信息不存在，跳过");
|
continue;
|
}
|
SmsVo vo = new SmsVo();
|
vo.setAppId(sms_appid);
|
vo.setPushType(1);
|
vo.setReceivers(ucUserInfo.getMobile());
|
vo.setTemplateCode("RTCouponExpireSoonTpl");
|
vo.setAppPushConfigCode("RTCouponExpireSoonSms");
|
vo.setParams(new HashMap<>());
|
vo.getParams().put("name", xpAppUserCoupon.getCouponName());
|
SmsDto smsDto = smsClient.pushSms(vo);
|
if(null == smsDto || smsDto.getCode() != 200){
|
log.info("短信发送失败");
|
}
|
}
|
});
|
}
|
}
|
|
|
}
|
|
|
/**
|
* 小程序通知
|
* @param activityList
|
*/
|
private void pushMiniProgramCouponMessage(List<XpActivity> activityList) {
|
log.info("开始执行优惠券小程序提醒消息发送 {}", activityList.size());
|
for (XpActivity xpActivity : activityList) {
|
//小程序弹窗券到账提醒（0=否，1=是）
|
Integer miniProgramReceivedReminder = xpActivity.getMiniProgramReceivedReminder();
|
String expireMinutesNotificationContent = xpActivity.getExpireMinutesNotificationContent();
|
if(null != miniProgramReceivedReminder && 1 == miniProgramReceivedReminder){
|
RETRY_EXECUTOR.execute(() -> {
|
//即将到期提前通知
|
Integer miniProgramAboutExpireMinutes = xpActivity.getMiniProgramAboutExpireMinutes();
|
//获取满足微信通知的即将生效的优惠券
|
long time = LocalDateTime.now().plusMinutes(miniProgramAboutExpireMinutes).toEpochSecond(ZoneOffset.of("+8"));
|
List<XpAppUserCoupon> list = xpAppUserCouponService.list(new LambdaUpdateWrapper<XpAppUserCoupon>()
|
.eq(XpAppUserCoupon::getActivityId, xpActivity.getId()).eq(XpAppUserCoupon::getStatus, 1)
|
.last(" and UNIX_TIMESTAMP(effective_time) >= " + time + " and " + time + "> UNIX_TIMESTAMP(effective_time) - 100"));
|
if(list.isEmpty()){
|
return;
|
}
|
log.info("开始执行生效前优惠券小程序提醒消息发送");
|
for (XpAppUserCoupon xpAppUserCoupon : list) {
|
SendCouponMessageVo vo = new SendCouponMessageVo();
|
vo.setAppUserId(xpAppUserCoupon.getAppUserId());
|
JSONObject message = new JSONObject();
|
message.put("type", "COUPON_MESSAGE");
|
message.put("content", expireMinutesNotificationContent);
|
message.put("timestamp", System.currentTimeMillis());
|
vo.setMessage(message.toString());
|
webSocketMessageClient.sendCouponMessage(vo);
|
}
|
});
|
}
|
|
//小程序弹窗即将过期提醒（0=否，1=是）
|
Integer miniProgramAboutExpireReminder = xpActivity.getMiniProgramAboutExpireReminder();
|
String expireDaysNotificationContent = xpActivity.getExpireDaysNotificationContent();
|
if(null != miniProgramAboutExpireReminder && 1 == miniProgramAboutExpireReminder){
|
RETRY_EXECUTOR.execute(() -> {
|
//即将到期提前通知
|
Integer aboutExpireDays = xpActivity.getAboutExpireDays();
|
//微信通知即将过期天数
|
long time = LocalDateTime.now().plusDays(aboutExpireDays).toEpochSecond(ZoneOffset.of("+8"));
|
List<XpAppUserCoupon> list = xpAppUserCouponService.list(new LambdaUpdateWrapper<XpAppUserCoupon>()
|
.eq(XpAppUserCoupon::getActivityId, xpActivity.getId()).eq(XpAppUserCoupon::getStatus, 1)
|
.last(" and UNIX_TIMESTAMP(expiration_time) >= " + time + " and " + time + "> UNIX_TIMESTAMP(expiration_time) - 100"));
|
if(list.isEmpty()){
|
return;
|
}
|
log.info("开始执行优惠券即将过期小程序提醒消息发送");
|
for (XpAppUserCoupon xpAppUserCoupon : list) {
|
SendCouponMessageVo vo = new SendCouponMessageVo();
|
vo.setAppUserId(xpAppUserCoupon.getAppUserId());
|
JSONObject message = new JSONObject();
|
message.put("type", "COUPON_MESSAGE");
|
message.put("content", expireDaysNotificationContent);
|
message.put("timestamp", System.currentTimeMillis());
|
vo.setMessage(message.toString());
|
webSocketMessageClient.sendCouponMessage(vo);
|
}
|
});
|
}
|
}
|
}
|
|
|
|
private void editUserCouponStatus(){
|
log.info("开始执行编辑用户优惠券状态");
|
RETRY_EXECUTOR.execute(() -> {
|
xpAppUserCouponService.update(new LambdaUpdateWrapper<XpAppUserCoupon>()
|
.set(XpAppUserCoupon::getStatus, 3)
|
.eq(XpAppUserCoupon::getStatus, 1)
|
.le(XpAppUserCoupon::getExpirationTime, LocalDateTime.now()));
|
});
|
}
|
}
|
