|
@@ -8,6 +8,7 @@ import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
|
|
+import com.zhongzheng.common.core.redis.RedisCache;
|
|
import com.zhongzheng.common.exception.CustomException;
|
|
import com.zhongzheng.common.exception.CustomException;
|
|
import com.zhongzheng.common.utils.DateUtils;
|
|
import com.zhongzheng.common.utils.DateUtils;
|
|
import com.zhongzheng.common.utils.ServletUtils;
|
|
import com.zhongzheng.common.utils.ServletUtils;
|
|
@@ -52,6 +53,7 @@ import org.thymeleaf.util.StringUtils;
|
|
import java.text.ParseException;
|
|
import java.text.ParseException;
|
|
import java.text.SimpleDateFormat;
|
|
import java.text.SimpleDateFormat;
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
import java.util.stream.Collectors;
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -81,6 +83,8 @@ public class UserSubscribeServiceImpl extends ServiceImpl<UserSubscribeMapper, U
|
|
@Autowired
|
|
@Autowired
|
|
private CourseMapper courseMapper;
|
|
private CourseMapper courseMapper;
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
+ private RedisCache redisCache;
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private IUserService iUserService;
|
|
private IUserService iUserService;
|
|
@@ -97,6 +101,8 @@ public class UserSubscribeServiceImpl extends ServiceImpl<UserSubscribeMapper, U
|
|
@Value("${aliyun.sms.newExamFail}")
|
|
@Value("${aliyun.sms.newExamFail}")
|
|
private String newExamFail;
|
|
private String newExamFail;
|
|
|
|
|
|
|
|
+
|
|
|
|
+
|
|
@Autowired
|
|
@Autowired
|
|
private com.zhongzheng.modules.alisms.service.IAliSmsService IAliSmsService;
|
|
private com.zhongzheng.modules.alisms.service.IAliSmsService IAliSmsService;
|
|
|
|
|
|
@@ -178,6 +184,12 @@ public class UserSubscribeServiceImpl extends ServiceImpl<UserSubscribeMapper, U
|
|
|
|
|
|
|
|
|
|
public String insertByAddBoImport(UserSubscribeAddBo bo) throws ParseException {
|
|
public String insertByAddBoImport(UserSubscribeAddBo bo) throws ParseException {
|
|
|
|
+ String redsKey = "Subscribe_"+bo.getUserId();
|
|
|
|
+ String token = redisCache.getCacheObject(redsKey);
|
|
|
|
+ if(token!=null){
|
|
|
|
+ throw new CustomException("请勿频繁操作");
|
|
|
|
+ }
|
|
|
|
+ redisCache.setCacheObject(redsKey, redsKey, 3, TimeUnit.SECONDS);
|
|
UserSubscribe add = BeanUtil.toBean(bo, UserSubscribe.class);
|
|
UserSubscribe add = BeanUtil.toBean(bo, UserSubscribe.class);
|
|
if(Validator.isEmpty(add.getOrderGoodsId())){
|
|
if(Validator.isEmpty(add.getOrderGoodsId())){
|
|
throw new CustomException("缺失订单商品ID");
|
|
throw new CustomException("缺失订单商品ID");
|