|
...
|
...
|
@@ -2,26 +2,33 @@ package com.yohobuy.platform.operations.service.impl; |
|
|
|
|
|
|
|
import com.google.common.collect.Lists;
|
|
|
|
import com.yoho.core.rest.client.ServiceCaller;
|
|
|
|
import com.yoho.message.sdk.utils.DateUtils;
|
|
|
|
import com.yohobuy.platform.common.util.DateUtil;
|
|
|
|
import com.yohobuy.platform.common.util.StringUtil;
|
|
|
|
import com.yohobuy.platform.dal.operations.IHtmlContentDao;
|
|
|
|
import com.yohobuy.platform.dal.operations.IRedpacketConfigDao;
|
|
|
|
import com.yohobuy.platform.dal.operations.RedpacketRuleConfigMapper;
|
|
|
|
import com.yohobuy.platform.dal.operations.model.HtmlContent;
|
|
|
|
import com.yohobuy.platform.dal.operations.model.RedpacketConfig;
|
|
|
|
import com.yohobuy.platform.dal.operations.model.RedpacketRuleConfig;
|
|
|
|
import com.yohobuy.platform.model.common.PageResponseVO;
|
|
|
|
import com.yohobuy.platform.model.common.ServiceException;
|
|
|
|
import com.yohobuy.platform.model.operations.RedPacketConfigBo;
|
|
|
|
import com.yohobuy.platform.model.operations.RedPacketRuleRespBo;
|
|
|
|
import com.yohobuy.platform.model.operations.request.RedPacketRuleReqBo;
|
|
|
|
import com.yohobuy.platform.model.operations.request.RedpacketConfigReq;
|
|
|
|
import com.yohobuy.platform.operations.service.IRedpacketConfigService;
|
|
|
|
import org.apache.commons.codec.digest.DigestUtils;
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
import java.util.HashMap;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.Map;
|
|
|
|
import java.util.concurrent.ExecutorService;
|
|
|
|
import java.util.concurrent.Executors;
|
|
|
|
import java.text.SimpleDateFormat;
|
|
|
|
import java.util.*;
|
|
|
|
|
|
|
|
@Service
|
|
|
|
public class RedpacketConfigServiceImpl implements IRedpacketConfigService {
|
|
...
|
...
|
@@ -31,6 +38,15 @@ public class RedpacketConfigServiceImpl implements IRedpacketConfigService { |
|
|
|
|
|
|
|
@Autowired
|
|
|
|
IRedpacketConfigDao redpacketConfigDao;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
RedpacketRuleConfigMapper redpacketRuleConfigMapper;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
IHtmlContentDao iHtmlContentDao;
|
|
|
|
|
|
|
|
public static final String RED_PACKAET_NODE_CODE = "20181002-161516";
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
ServiceCaller serviceCaller;
|
|
|
|
|
|
...
|
...
|
@@ -38,6 +54,115 @@ public class RedpacketConfigServiceImpl implements IRedpacketConfigService { |
|
|
|
private String apiUrl;
|
|
|
|
|
|
|
|
|
|
|
|
private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 获取红包使用规则配置
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
public RedPacketRuleRespBo getRedpacketRule(){
|
|
|
|
|
|
|
|
// 获取(我的红包问号中的介绍)以外的红包配置信息
|
|
|
|
RedpacketRuleConfig redpacketRuleConfig = redpacketRuleConfigMapper.selectRedpacketRule();
|
|
|
|
if (redpacketRuleConfig == null){
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
|
|
|
|
RedPacketRuleRespBo redPacketRuleBo = new RedPacketRuleRespBo();
|
|
|
|
BeanUtils.copyProperties(redpacketRuleConfig, redPacketRuleBo);
|
|
|
|
redPacketRuleBo.setShowEndTime(getDate(redpacketRuleConfig.getShowEndTime()));
|
|
|
|
redPacketRuleBo.setShowStartTime(getDate(redpacketRuleConfig.getShowStartTime()));
|
|
|
|
redPacketRuleBo.setOrderStartTime(getDate(redpacketRuleConfig.getOrderStartTime()));
|
|
|
|
redPacketRuleBo.setOrderEndTime(getDate(redpacketRuleConfig.getOrderEndTime()));
|
|
|
|
|
|
|
|
HtmlContent htmlContent = iHtmlContentDao.selectOneByNodeCode(RED_PACKAET_NODE_CODE);
|
|
|
|
if (htmlContent != null && StringUtils.isNotBlank(htmlContent.getInuseContent())){
|
|
|
|
redPacketRuleBo.setMyRedpacketQuestion(htmlContent.getInuseContent());
|
|
|
|
}
|
|
|
|
|
|
|
|
return redPacketRuleBo;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private String getDate(Integer mills) {
|
|
|
|
if (mills == null || mills == 0) {
|
|
|
|
return "";
|
|
|
|
}
|
|
|
|
return format.format(new Date(mills * 1000L));
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 更新红包规则
|
|
|
|
* @param redPacketRuleBo
|
|
|
|
* @throws ServiceException
|
|
|
|
*/
|
|
|
|
public void addRedPacketRule(RedPacketRuleReqBo redPacketRuleBo) throws ServiceException{
|
|
|
|
|
|
|
|
// 校验
|
|
|
|
if (StringUtil.isBlank(redPacketRuleBo.getToken())){
|
|
|
|
logger.warn("addRedPacketRule token is empty");
|
|
|
|
throw new ServiceException(411, "token不能为空！");
|
|
|
|
}
|
|
|
|
|
|
|
|
// token是否存在
|
|
|
|
RedpacketConfig redpacketConfig = redpacketConfigDao.selectByToken(redPacketRuleBo.getToken());
|
|
|
|
if (redpacketConfig == null){
|
|
|
|
logger.warn("addRedPacketRule token[{}] not exist", redPacketRuleBo.getToken());
|
|
|
|
throw new ServiceException(501, "token不存在，请确认！");
|
|
|
|
}
|
|
|
|
|
|
|
|
// token红包的有效期间>商品详情页红包显示的有效期间
|
|
|
|
if (redPacketRuleBo.getShowStartTime() != null && redPacketRuleBo.getShowEndTime() != null
|
|
|
|
&& !Objects.isNull(redpacketConfig.getStartTime()) && !Objects.isNull(redpacketConfig.getEndTime())){
|
|
|
|
|
|
|
|
if (Integer.compare(redPacketRuleBo.getShowStartTime(), redpacketConfig.getStartTime())< 0
|
|
|
|
|| Integer.compare(redPacketRuleBo.getShowEndTime(), redpacketConfig.getEndTime())>0){
|
|
|
|
logger.warn("addRedPacketRule token time [start {}] [end {}] < show time [start {}] [end {}] error.",
|
|
|
|
redpacketConfig.getStartTime(), redpacketConfig.getEndTime(), redPacketRuleBo.getShowStartTime(), redPacketRuleBo.getShowEndTime());
|
|
|
|
throw new ServiceException(502, "Token的有效期必须>领取时间");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// 随机金额
|
|
|
|
if (Objects.isNull(redpacketConfig.getType()) || redpacketConfig.getType() == 1
|
|
|
|
|| Objects.isNull(redpacketConfig.getAmount())){
|
|
|
|
logger.warn("addRedPacketRule token[{}] type[{}] amount[{}]", redPacketRuleBo.getToken(), redpacketConfig.getType(), redpacketConfig.getAmount());
|
|
|
|
throw new ServiceException(501, "指定的token对应的红包必须是固定金额类型！");
|
|
|
|
}
|
|
|
|
|
|
|
|
// 是否存在红包规则配置
|
|
|
|
RedpacketRuleConfig redpacketRuleConfig = redpacketRuleConfigMapper.selectRedpacketRule();
|
|
|
|
if (redpacketRuleConfig == null){
|
|
|
|
|
|
|
|
redpacketRuleConfig = new RedpacketRuleConfig();
|
|
|
|
BeanUtils.copyProperties(redPacketRuleBo, redpacketRuleConfig);
|
|
|
|
int now = DateUtils.getCurrentTimeSeconds();
|
|
|
|
redpacketRuleConfig.setCreateTime(now);
|
|
|
|
redpacketRuleConfig.setUpdateTime(now);
|
|
|
|
|
|
|
|
redpacketRuleConfigMapper.insertSelective(redpacketRuleConfig);
|
|
|
|
|
|
|
|
}else{
|
|
|
|
BeanUtils.copyProperties(redPacketRuleBo, redpacketRuleConfig);
|
|
|
|
|
|
|
|
int now = DateUtils.getCurrentTimeSeconds();
|
|
|
|
redpacketRuleConfig.setUpdateTime(now);
|
|
|
|
redpacketRuleConfigMapper.updateByPrimaryKeySelective(redpacketRuleConfig);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 更新红包规则中的-我的红包中的问号介绍
|
|
|
|
HtmlContent htmlContent = iHtmlContentDao.selectOneByNodeCode(RED_PACKAET_NODE_CODE);
|
|
|
|
// 不考虑不存在的情况
|
|
|
|
if (htmlContent != null){
|
|
|
|
htmlContent.setInuseContent(redPacketRuleBo.getMyRedpacketQuestion());
|
|
|
|
iHtmlContentDao.updateInuseContent(htmlContent);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
...
|
...
|
|
