package com.yeshi.fanli.service.impl.user;
|
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.core.task.TaskExecutor;
|
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.support.DefaultTransactionDefinition;
|
import org.yeshi.utils.DateUtil;
|
import org.yeshi.utils.entity.DateInfo;
|
|
import com.aliyun.openservices.ons.api.Message;
|
import com.aliyun.openservices.ons.api.SendResult;
|
import com.aliyun.openservices.ons.api.transaction.LocalTransactionExecuter;
|
import com.aliyun.openservices.ons.api.transaction.TransactionProducer;
|
import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.dao.mybatis.user.UserSystemCouponMapper;
|
import com.yeshi.fanli.dto.msg.MsgOtherCouponActivateDTO;
|
import com.yeshi.fanli.dto.msg.MsgOtherGiveContentDTO;
|
import com.yeshi.fanli.dto.user.coupon.UserSystemCouponUseMQMsgDTO;
|
import com.yeshi.fanli.entity.accept.AcceptData;
|
import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail.MsgTypeOtherTypeEnum;
|
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
|
import com.yeshi.fanli.entity.bus.user.Order;
|
import com.yeshi.fanli.entity.bus.user.TokenRecord;
|
import com.yeshi.fanli.entity.bus.user.TokenRecord.TokenTypeEnum;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
|
import com.yeshi.fanli.entity.bus.user.UserSystemCoupon;
|
import com.yeshi.fanli.entity.bus.user.UserSystemCouponGiveRecord;
|
import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;
|
import com.yeshi.fanli.entity.common.JumpDetailV2;
|
import com.yeshi.fanli.entity.money.UserMoneyDetail;
|
import com.yeshi.fanli.entity.order.CommonOrder;
|
import com.yeshi.fanli.entity.system.SystemCoupon;
|
import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.exception.money.UserMoneyDetailException;
|
import com.yeshi.fanli.exception.order.HongBaoException;
|
import com.yeshi.fanli.exception.user.UserInfoExtraException;
|
import com.yeshi.fanli.exception.user.UserSystemCouponException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.config.SystemCouponService;
|
import com.yeshi.fanli.service.inter.money.UserMoneyDetailService;
|
import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService;
|
import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
|
import com.yeshi.fanli.service.inter.order.CommonOrderCountService;
|
import com.yeshi.fanli.service.inter.order.CommonOrderService;
|
import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
|
import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
|
import com.yeshi.fanli.service.inter.order.OrderHongBaoMapService;
|
import com.yeshi.fanli.service.inter.order.OrderService;
|
import com.yeshi.fanli.service.inter.push.PushCouponRecordService;
|
import com.yeshi.fanli.service.inter.push.PushCouponService;
|
import com.yeshi.fanli.service.inter.user.TokenRecordService;
|
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponGiveRecordService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
|
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.TokenUtil;
|
import com.yeshi.fanli.util.VersionUtil;
|
import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
|
import com.yeshi.fanli.util.factory.msg.MsgOtherSystemGiveDTOFactory;
|
import com.yeshi.fanli.util.rocketmq.MQTagConstant;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
import com.yeshi.fanli.vo.msg.ClientTextStyleVO;
|
import com.yeshi.fanli.vo.order.CommonOrderVO;
|
import com.yeshi.fanli.vo.user.UserSystemCouponRecordVO;
|
import com.yeshi.fanli.vo.user.UserSystemCouponVO;
|
|
import net.sf.json.JSONObject;
|
|
@Service
|
public class UserSystemCouponServiceImpl implements UserSystemCouponService {
|
|
@Resource(name = "taskExecutor")
|
private TaskExecutor executor;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private UserSystemCouponMapper userSystemCouponMapper;
|
|
@Resource
|
private UserSystemCouponGiveRecordService userSystemCouponGiveRecordService;
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private JumpDetailV2Service jumpDetailV2Service;
|
|
@Resource
|
private SystemCouponService systemCouponService;
|
|
@Resource
|
private CommonOrderService commonOrderService;
|
|
@Resource
|
private UserSystemCouponRecordService userSystemCouponRecordService;
|
|
@Resource
|
@Lazy
|
private HongBaoV2Service hongBaoV2Service;
|
|
@Resource
|
private HongBaoOrderService hongBaoOrderService;
|
|
@Resource
|
private OrderHongBaoMapService orderHongBaoMapService;
|
|
@Resource
|
private OrderService orderService;
|
|
@Resource
|
private UserMoneyDetailService userMoneyDetailService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
private UserMoneyMsgNotificationService userMoneyMsgNotificationService;
|
|
@Resource
|
private UserInfoExtraService userInfoExtraService;
|
|
@Resource
|
private ThreeSaleSerivce threeSaleSerivce;
|
|
@Resource
|
private UserOtherMsgNotificationService userOtherMsgNotificationService;
|
|
@Resource
|
private CommonOrderCountService commonOrderCountService;
|
|
@Resource
|
@Lazy
|
private PushCouponService pushCouponService;
|
|
@Resource
|
private PushCouponRecordService pushCouponRecordService;
|
|
@Resource
|
private TokenRecordService tokenRecordService;
|
|
@Resource(name = "transactionManager")
|
private DataSourceTransactionManager transactionManager;
|
|
@Resource(name = "orderTransactionProducer")
|
private TransactionProducer orderTransactionProducer;
|
|
@Override
|
public int insertSelective(UserSystemCoupon record) {
|
return userSystemCouponMapper.insertSelective(record);
|
}
|
|
@Override
|
public UserSystemCoupon selectByPrimaryKey(Long id) {
|
return userSystemCouponMapper.selectByPrimaryKey(id);
|
}
|
|
@Override
|
public int updateByPrimaryKeySelective(UserSystemCoupon record) {
|
return userSystemCouponMapper.updateByPrimaryKeySelective(record);
|
}
|
|
@Override
|
public int updateByPrimaryKey(UserSystemCoupon record) {
|
return userSystemCouponMapper.updateByPrimaryKey(record);
|
}
|
|
@Override
|
public List<UserSystemCoupon> getUserCouponList(long start, int count, Long uid) {
|
return userSystemCouponMapper.getUserCouponList(start, count, uid);
|
}
|
|
@Override
|
public List<UserSystemCoupon> getUserCouponBySource(Long uid, String source) {
|
return userSystemCouponMapper.getUserCouponBySource(uid, source);
|
}
|
|
@Override
|
public int countTodatyUserCouponBySource(Long uid, String source) {
|
return userSystemCouponMapper.countTodatyUserCouponBySource(uid, source);
|
}
|
|
@Override
|
public long countCouponOld(Long uid) {
|
return userSystemCouponMapper.countCouponOld(uid);
|
}
|
|
@Override
|
public long countUserCouponList(Long uid) {
|
return userSystemCouponMapper.countUserCouponList(uid);
|
}
|
|
@Override
|
@Transactional
|
public UserSystemCoupon insertUserCoupon(Long uid, String couponType, String source, BigDecimal percent,
|
Boolean needNotify) throws UserSystemCouponException, Exception {
|
|
if (couponType == null || uid == null) {
|
throw new UserSystemCouponException(1, "参数不正确");
|
}
|
|
SystemCoupon coupon = null;
|
if (couponType.equals(CouponTypeEnum.welfareFreeCoupon.name())
|
|| couponType.equals(CouponTypeEnum.freeCoupon.name())
|
| couponType.equals(CouponTypeEnum.freeCouponBuy.name())) {
|
// 免单券
|
coupon = systemCouponService.getCouponByType(couponType);
|
} else if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) {
|
// 随机奖励券
|
if (percent == null || percent.compareTo(new BigDecimal(0)) < 1) {
|
randomRewardCoupon(1, uid, source);
|
return null;
|
} else {
|
coupon = systemCouponService.getCouponByTypeAndPercent(couponType, percent);
|
}
|
}
|
|
if (coupon == null) {
|
throw new UserSystemCouponException(1, "券类型不正确");
|
}
|
|
int stateActivated = 1;
|
if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
|
// 福利券状态
|
long countSuccess = threeSaleSerivce.countSuccessFirstTeam(uid);
|
// 没有下级队员 --待激活
|
if (countSuccess == 0) {
|
stateActivated = 0;
|
}
|
} else if (coupon.getType() == CouponTypeEnum.freeCoupon) {
|
stateActivated = 0;
|
}
|
|
Integer expiryDay = null;
|
if (stateActivated == 0)
|
expiryDay = coupon.getActivateDay();
|
|
if (expiryDay == null || expiryDay == 0)
|
expiryDay = coupon.getExpiryDay();
|
|
// 结束日期
|
// 今天在内 减去一天
|
String endDay = DateUtil.plusDay(expiryDay - 1, new Date());
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
if (endDay != null && endDay.trim().length() > 0) {
|
endDay += " 23:59:59";
|
}
|
Date endTime = format.parse(endDay);
|
|
UserSystemCoupon userCoupon = new UserSystemCoupon();
|
userCoupon.setUid(uid);
|
userCoupon.setSource(source);
|
userCoupon.setSystemCoupon(coupon);
|
userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
|
userCoupon.setStateActivated(stateActivated);
|
userCoupon.setStartTime(new Date());
|
userCoupon.setEndTime(endTime);
|
userCoupon.setCreateTime(new Date());
|
userCoupon.setUpdateTime(new Date());
|
// 插入数据库
|
insertSelective(userCoupon);
|
|
executor.execute(new Runnable() {
|
@Override
|
public void run() {
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
// 添加一条消息
|
if (userInfoExtra != null) {
|
if (userInfoExtra.getCouponNews() == null) {
|
userInfoExtra.setCouponNews(1);
|
} else {
|
userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1);
|
}
|
|
try {
|
userInfoExtraService.saveUserInfoExtra(userInfoExtra);
|
} catch (UserInfoExtraException e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
});
|
|
// 消息推送
|
if (needNotify) {
|
try {
|
if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
|
userOtherMsgNotificationService.welfareCouponGet(userCoupon);
|
} else if (coupon.getType() == CouponTypeEnum.freeCoupon) {
|
userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);
|
} else if (coupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
|
userOtherMsgNotificationService.rewardCouponGet(userCoupon, coupon.getPercent().intValue());
|
}
|
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
return userCoupon;
|
}
|
|
@Transactional
|
@Override
|
public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid, boolean changeJump)
|
throws UserSystemCouponException, Exception {
|
|
if (uid == null) {
|
return null;
|
}
|
|
// 过期券
|
updateInvalidSate(uid);
|
|
// 退回券
|
sendBackTimeOutCoupon(uid);
|
|
List<UserSystemCouponVO> listVO = userSystemCouponMapper.getCouponListOld(start, count, uid);
|
if (listVO == null || listVO.size() == 0) {
|
return listVO;
|
}
|
|
// 数据组织
|
listDataFactory(listVO, uid, changeJump);
|
|
return listVO;
|
}
|
|
/**
|
* 数据组织
|
*
|
* @param listVO
|
*/
|
public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid, boolean changeJump) throws Exception {
|
|
String inviteCode = null;
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra != null) {
|
inviteCode = userInfoExtra.getInviteCode();
|
}
|
|
for (UserSystemCouponVO userCouponVO : listVO) {
|
|
SystemCoupon systemCoupon = userCouponVO.getSystemCoupon();
|
if (systemCoupon != null && systemCoupon.getId() != null) {
|
systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
}
|
|
if (systemCoupon == null) {
|
continue; // 券信息不完整
|
}
|
|
String source = userCouponVO.getSource();
|
userCouponVO.setSource("来源：" + source);
|
|
userCouponVO.setCouponName(systemCoupon.getName());
|
userCouponVO.setCouponPicture(systemCoupon.getPicture());
|
userCouponVO.setCouponEffect(systemCoupon.getEffect());
|
userCouponVO.setCouponRule(systemCoupon.getRule());
|
userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid());
|
|
// 使用状态
|
Integer state = userCouponVO.getState();
|
|
// 券类型
|
CouponTypeEnum type = systemCoupon.getType();
|
|
// 按钮跳转
|
Map<String, Object> jumpBtn = null;
|
|
Integer stateActivated = userCouponVO.getStateActivated();
|
|
if (stateActivated == null || stateActivated == 0) {
|
// 显示规则
|
userCouponVO.setCouponRule(systemCoupon.getRemark());
|
userCouponVO.setCouponEffect("待激活");
|
// 状态未激活 -且未被使用
|
if (UserSystemCoupon.STATE_CAN_USE == state) {
|
userCouponVO.setState(0);
|
}
|
|
jumpBtn = new HashMap<String, Object>();
|
|
// 福利券需要激活界面
|
if (!changeJump) {
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite"));
|
} else {
|
if (inviteCode != null && inviteCode.trim().length() > 0) {
|
// 邀请好友界面
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_friends"));
|
} else {
|
// 邀请激活界面
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_activate"));
|
}
|
}
|
|
} else if (stateActivated == 1) {
|
// 显示规则
|
userCouponVO.setCouponRule(systemCoupon.getRule());
|
|
if (UserSystemCoupon.STATE_CAN_USE == state) {
|
Map<String, Object> jumpLink = new HashMap<String, Object>();
|
|
if (CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type) {
|
// 免单券、 福利免单券
|
|
// 免单商品列表
|
jumpLink.put("url", configService.get("free_goods_list"));
|
|
jumpBtn = new HashMap<String, Object>();
|
jumpBtn.put("params", jumpLink);
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("web"));
|
|
} else if (CouponTypeEnum.rebatePercentCoupon == type) {
|
// 返利奖励券- 跳转至订单到账界面
|
jumpLink.put("state", "2");
|
|
jumpBtn = new HashMap<String, Object>();
|
jumpBtn.put("params", jumpLink);
|
// 跳转订单列表
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("orderList"));
|
}
|
|
} else if (UserSystemCoupon.STATE_IN_USE == state) {
|
// 使用中
|
userCouponVO.setInUseExplain(configService.get("free_coupon_using-help"));
|
}
|
}
|
|
// 券失效图片替换
|
if (UserSystemCoupon.STATE_END_USE == state || UserSystemCoupon.STATE_OVERDUE == state) {
|
userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());
|
}
|
|
userCouponVO.setJumpBtn(jumpBtn);
|
|
String couponTerm = "有效期：";
|
Date startTime = userCouponVO.getStartTime();
|
Date endTime = userCouponVO.getEndTime();
|
if (endTime != null && startTime != null) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
|
couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);
|
}
|
userCouponVO.setCouponTerm(couponTerm);
|
|
if (UserSystemCoupon.STATE_CAN_USE == state) {
|
int differentDays = 0;
|
if (endTime != null && startTime != null) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
differentDays = DateUtil.daysBetween(sdf.format(new Date()), sdf.format(endTime)) + 1;
|
if (differentDays < 0) {
|
differentDays = 0;
|
}
|
}
|
// 剩余天数
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "还剩" + differentDays + "天过期");
|
remainDays.put("fontColor", "#F14242");
|
userCouponVO.setRemainDays(remainDays);
|
}
|
}
|
}
|
|
@Override
|
public List<UserSystemCouponVO> getEnableListByCouponId(Long uid, Integer activated, List<SystemCoupon> couponList)
|
throws UserSystemCouponException, Exception {
|
|
List<Long> listCouponId = new ArrayList<Long>();
|
for (SystemCoupon systemCoupon : couponList) {
|
listCouponId.add(systemCoupon.getId());
|
}
|
|
List<UserSystemCouponVO> listVO = userSystemCouponMapper.getEnableListByCouponId(uid, activated, listCouponId);
|
|
if (listVO == null || listVO.size() == 0) {
|
return null;
|
}
|
|
for (UserSystemCouponVO userCouponVO : listVO) {
|
|
SystemCoupon systemCoupon = userCouponVO.getSystemCoupon();
|
if (systemCoupon == null) {
|
continue; // 券信息不完整
|
}
|
|
for (SystemCoupon coupon : couponList) {
|
if (coupon.getId().equals(systemCoupon.getId()) || coupon.getId() == systemCoupon.getId()) {
|
systemCoupon = coupon;
|
break;
|
}
|
}
|
|
String source = userCouponVO.getSource();
|
if (source != null && "奖励券天天抽".equals(source)) {
|
source = "天天抽";
|
}
|
|
userCouponVO.setSource("来源：" + source);
|
userCouponVO.setCouponName(systemCoupon.getName());
|
userCouponVO.setCouponEffect(systemCoupon.getEffect());
|
userCouponVO.setCouponRule(systemCoupon.getRule());
|
userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink());
|
userCouponVO.setCouponPicture(systemCoupon.getPicture());
|
userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid());
|
|
int differentDays = 0;
|
String couponTerm = "有效期：";
|
Date startTime = userCouponVO.getStartTime();
|
Date endTime = userCouponVO.getEndTime();
|
if (endTime != null && startTime != null) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
|
couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);
|
|
SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");
|
differentDays = DateUtil.daysBetween(sdf2.format(new Date()), sdf2.format(endTime)) + 1;
|
if (differentDays < 0) {
|
differentDays = 0;
|
}
|
}
|
userCouponVO.setCouponTerm(couponTerm);
|
|
// 剩余天数
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "还剩" + differentDays + "天过期");
|
String remainDaysFontColor = "";
|
|
Integer stateActivated = userCouponVO.getStateActivated();
|
if (stateActivated == null || stateActivated == 0) {
|
userCouponVO.setState(0);
|
userCouponVO.setCouponEffect("待激活");
|
userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());
|
remainDaysFontColor = "#CCCCCC";
|
} else {
|
userCouponVO.setCouponPicture(systemCoupon.getPicture());
|
remainDaysFontColor = "#F14242";
|
}
|
|
remainDays.put("fontColor", remainDaysFontColor);
|
userCouponVO.setRemainDays(remainDays);
|
}
|
|
return listVO;
|
}
|
|
/**
|
* 是否存在奖励券
|
*
|
* @param uid
|
* @return
|
*/
|
@Override
|
public boolean hasRewardCoupon(Long uid) {
|
boolean hasCoupon = false;
|
|
try {
|
List<UserSystemCouponVO> orderCouponList = getOrderCouponList(uid);
|
if (orderCouponList != null && orderCouponList.size() > 0) {
|
hasCoupon = true;
|
}
|
} catch (UserSystemCouponException e) {
|
e.printStackTrace();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
return hasCoupon;
|
}
|
|
@Transactional
|
@Override
|
public List<UserSystemCouponVO> getOrderCouponList(Long uid) throws UserSystemCouponException, Exception {
|
|
if (uid == null) {
|
throw new UserSystemCouponException(1, "用户未登录");
|
}
|
|
// 过期券
|
updateInvalidSate(uid);
|
|
// 退回券
|
sendBackTimeOutCoupon(uid);
|
|
// 订单相关的券
|
List<SystemCoupon> couponList = systemCouponService.getOrderCouponList();
|
if (couponList == null || couponList.size() == 0) {
|
return null;
|
}
|
|
return getEnableListByCouponId(uid, 1, couponList);
|
}
|
|
@Transactional
|
@Override
|
public List<UserSystemCouponVO> getGoodsCouponList(Long uid, Long auctionId)
|
throws UserSystemCouponException, Exception {
|
|
if (uid == null) {
|
throw new UserSystemCouponException(1, "用户未登录");
|
}
|
|
if (auctionId == null) {
|
throw new UserSystemCouponException(1, "商品ID为空");
|
}
|
|
// 过期券
|
updateInvalidSate(uid);
|
|
// 退回券
|
sendBackTimeOutCoupon(uid);
|
|
// 商品相关的券
|
List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
|
if (couponList == null || couponList.size() == 0) {
|
return null;
|
}
|
|
List<UserSystemCouponVO> list = getEnableListByCouponId(uid, null, couponList);
|
|
// 获取商品详情
|
TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
|
if (taoBaoGoodsBrief != null) {
|
BigDecimal quanPrice = TaoBaoUtil.getAfterUseCouplePrice(taoBaoGoodsBrief);
|
// 券后价 大于10元 不能免单
|
if (quanPrice.compareTo(new BigDecimal(10)) > 0) {
|
if (list != null && list.size() > 0) {
|
for (UserSystemCouponVO userCouponVO : list) {
|
// 显示不能使用
|
userCouponVO.setState(0);
|
userCouponVO.setCouponPicture(userCouponVO.getCouponPictureInvalid());
|
|
Map<String, Object> map = userCouponVO.getRemainDays();
|
if (map != null) {
|
map.put("fontColor", "#CCCCCC");
|
}
|
userCouponVO.setRemainDays(map);
|
}
|
}
|
}
|
}
|
|
return list;
|
}
|
|
@Override
|
public long countUsableFreeCouponForBuy(Long uid) {
|
if (uid == null)
|
return 0;
|
|
List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
|
if (couponList == null || couponList.size() == 0)
|
return 0;
|
|
List<Long> listCouponId = new ArrayList<Long>();
|
for (SystemCoupon systemCoupon : couponList) {
|
listCouponId.add(systemCoupon.getId());
|
}
|
|
return userSystemCouponMapper.countUsableByUid(uid, listCouponId);
|
}
|
|
@Override
|
public long countUsableRewardCoupon(Long uid) {
|
if (uid == null)
|
return 0;
|
|
List<SystemCoupon> couponList = systemCouponService.getOrderCouponList();
|
if (couponList == null || couponList.size() == 0)
|
return 0;
|
|
List<Long> listCouponId = new ArrayList<Long>();
|
for (SystemCoupon systemCoupon : couponList) {
|
listCouponId.add(systemCoupon.getId());
|
}
|
|
return userSystemCouponMapper.countUsableByUid(uid, listCouponId);
|
}
|
|
@Transactional
|
@Override
|
public void useGoodsCoupon(Long uid, Long id, Long goodId, Integer sourceType)
|
throws UserSystemCouponException, Exception {
|
if (uid == null) {
|
throw new UserSystemCouponException(1, "用户未登录");
|
}
|
|
if (id == null) {
|
throw new UserSystemCouponException(1, "券数据有误");
|
}
|
|
UserSystemCoupon userSystemCoupon = selectByPrimaryKey(id);
|
if (userSystemCoupon == null) {
|
throw new UserSystemCouponException(1, "券数据不正确");
|
}
|
|
if (userSystemCoupon.getUid().longValue() != uid) {
|
throw new UserSystemCouponException(1, "不属于该用户的券");
|
}
|
|
Integer state = userSystemCoupon.getState();
|
Integer stateActivated = userSystemCoupon.getStateActivated();
|
if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated) {
|
throw new UserSystemCouponException(1, "该券不能被使用");
|
}
|
|
Long couponUid = userSystemCoupon.getUid();
|
if (!uid.equals(couponUid)) {
|
throw new UserSystemCouponException(1, "传递参数不匹配");
|
}
|
|
SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
|
|
SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
if (baseCoupon == null || baseCoupon.getId() == null) {
|
throw new UserSystemCouponException(1, "未找到券基本信息");
|
}
|
|
if (baseCoupon.getType() != CouponTypeEnum.freeCoupon
|
&& baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon
|
&& baseCoupon.getType() != CouponTypeEnum.freeCouponBuy) {
|
throw new UserSystemCouponException(1, "券类型不匹配");
|
}
|
|
Date date = new Date();
|
// 更新券使用
|
userSystemCoupon.setState(UserSystemCoupon.STATE_IN_USE); // 正在匹配
|
userSystemCoupon.setUseTime(date);
|
userSystemCoupon.setUpdateTime(date);
|
userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|
// 插入使用券记录
|
UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();
|
couponRecord.setGoodId(goodId);
|
couponRecord.setGoodSource(sourceType); // 默认淘宝
|
couponRecord.setState(UserSystemCouponRecord.STATE_WAIT); // 正在匹配
|
couponRecord.setUserSystemCoupon(userSystemCoupon);
|
couponRecord.setCouponType(baseCoupon.getType().name());
|
couponRecord.setCreateTime(date);
|
couponRecord.setUpdateTime(date);
|
userSystemCouponRecordService.insertSelective(couponRecord);
|
|
// 消息推送
|
try {
|
if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
|
// userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon,order.get);
|
} else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) {
|
// userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);
|
}
|
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
}
|
|
@Transactional
|
@Override
|
public void useOrderCoupon(Long uid, Long id, String orderNo, Integer sourceType, AcceptData acceptData)
|
throws UserSystemCouponException, Exception {
|
if (id == null)
|
throw new UserSystemCouponException(1, "券id不存在");
|
|
if (sourceType == null)
|
sourceType = Constant.SOURCE_TYPE_TAOBAO;
|
|
// 用户券
|
UserSystemCoupon userSystemCoupon = selectByPrimaryKey(id);
|
if (userSystemCoupon == null)
|
throw new UserSystemCouponException(1, "券信息不存在");
|
|
if (userSystemCoupon.getUid().longValue() != uid)
|
throw new UserSystemCouponException(1, "不属于该用户的券");
|
|
Integer state = userSystemCoupon.getState();
|
Integer stateActivated = userSystemCoupon.getStateActivated();
|
if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated)
|
throw new UserSystemCouponException(1, "该券不能被使用");
|
|
// 系统券信息
|
SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
|
if (systemCoupon != null && systemCoupon.getId() != null) {
|
systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
if (systemCoupon == null)
|
throw new UserSystemCouponException(1, "券已不存在");
|
}
|
|
if (systemCoupon.getType() != CouponTypeEnum.rebatePercentCoupon)
|
throw new UserSystemCouponException(1, "券类型不匹配");
|
|
if (orderNo == null || orderNo.trim().length() == 0)
|
throw new UserSystemCouponException(1, "订单号不存在");
|
|
// 订单
|
CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(uid, orderNo, CommonOrder.STATE_JS,
|
sourceType);
|
if (orderVO == null)
|
throw new UserSystemCouponException(1, "订单信息获取失败");
|
|
// 版本区分：2.0.2
|
if (VersionUtil.greaterThan_2_0_2(acceptData.getPlatform(), acceptData.getVersion())) {
|
Date thirdCreateTime = orderVO.getThirdCreateTime();
|
if (thirdCreateTime != null) {
|
long downOrderTime = thirdCreateTime.getTime();
|
long limitDate = Long.parseLong("1573315200000"); // TODO
|
// 日期待确定2019-11-10
|
if (downOrderTime > limitDate) {
|
Date endDay = DateUtil.plusDayDate(4, thirdCreateTime);
|
long currentTime = java.lang.System.currentTimeMillis();
|
if (endDay.getTime() > currentTime) {
|
boolean valid = false;
|
DateInfo dateInfo = DateUtil.dateDiff3(currentTime, endDay.getTime());
|
if (dateInfo != null) {
|
if (dateInfo.getDay() > 0)
|
valid = true;
|
|
if (!valid && dateInfo.getHour() > 0)
|
valid = true;
|
|
if (!valid && dateInfo.getMinute() > 0)
|
valid = true;
|
|
if (!valid && dateInfo.getSecond() >= 0)
|
valid = true;
|
}
|
|
if (!valid)
|
throw new UserSystemCouponException(1, "该订单已不能使用使用奖励券，详情请咨询客服");
|
}
|
}
|
}
|
}
|
|
BigDecimal hongBao = orderVO.getHongBao();
|
// 红包状态
|
Integer hongBaoState = orderVO.getHongBaoState();
|
// 红包类型
|
Integer hongBaoType = orderVO.getHongBaoType();
|
|
// 条件: A:必须是返利订单 、B:必须已经处于已到账状态
|
if (HongBaoV2.TYPE_ZIGOU == hongBaoType && HongBaoV2.STATE_YILINGQU == hongBaoState || hongBao != null) {
|
|
Order order = orderService.findOrderByOrderIdAndType(orderNo, sourceType);
|
if (order == null)
|
return;
|
|
/* 奖金计算 以及相关红包信息处理 */
|
|
// 转换成小数点
|
BigDecimal percent = MoneyBigDecimalUtil.mul(systemCoupon.getPercent(), new BigDecimal(0.01));
|
// 提成金额
|
BigDecimal money = MoneyBigDecimalUtil.mul(hongBao, percent);
|
|
UserSystemCouponUseMQMsgDTO mqMsg = new UserSystemCouponUseMQMsgDTO(userSystemCoupon.getId(),
|
order.getOrderId(), sourceType);
|
// 事务消息
|
Message msg = new Message(MQTopicName.TOPIC_SYSTEM_COUPON_USE.name(), systemCoupon.getType().name(),
|
new Gson().toJson(mqMsg).getBytes());
|
try {
|
SendResult result = orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
@Override
|
public TransactionStatus execute(Message arg0, Object arg1) {
|
try {
|
useRewardCouponCore(userSystemCoupon, money, hongBao, uid, order);
|
return TransactionStatus.CommitTransaction;
|
} catch (Exception e) {
|
return TransactionStatus.RollbackTransaction;
|
}
|
}
|
}, null);
|
System.out.println(result);
|
} catch (Exception e) {
|
throw new Exception();
|
}
|
}
|
}
|
|
@Transactional
|
public void useRewardCouponCore(UserSystemCoupon userSystemCoupon, BigDecimal money, BigDecimal hongBao, Long uid,
|
Order order) throws Exception {
|
org.springframework.transaction.TransactionStatus transactionStatus = transactionManager
|
.getTransaction(new DefaultTransactionDefinition());
|
try {
|
// 1、插入红包数据
|
HongBaoV2 hongBaoV2 = new HongBaoV2();
|
hongBaoV2.setMoney(money);
|
hongBaoV2.setType(HongBaoV2.TYPE_COUPON);
|
hongBaoV2.setState(HongBaoV2.STATE_YILINGQU);
|
hongBaoV2.setVersion(2);
|
hongBaoV2.setCreateTime(new Date());
|
hongBaoV2.setUpdateTime(new Date());
|
hongBaoV2.setUserInfo(new UserInfo(uid));
|
hongBaoV2.setPreGetTime(new Date());
|
hongBaoV2.setGetTime(new Date());
|
|
hongBaoV2Service.insertSelective(hongBaoV2);
|
|
// 2.插入关联
|
orderHongBaoMapService.addOrderHongBaoMap(hongBaoV2, order);
|
|
// 3.插入资金明细,用户余额
|
UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createOrderReward(order.getOrderId(),
|
order.getOrderType(), money, new UserInfo(uid));
|
userMoneyDetailService.addUserMoneyDetail(userMoneyDetail);
|
userInfoService.addMoney(new UserInfo(uid), money);
|
|
/* 用户券信息状态及记录处理 */
|
|
Date date = new Date();
|
// 更新券状态：已使用
|
userSystemCoupon.setState(UserSystemCoupon.STATE_END_USE);
|
userSystemCoupon.setUseTime(date);
|
userSystemCoupon.setUpdateTime(date);
|
userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|
SystemCoupon coupon = systemCouponService.selectByPrimaryKey(userSystemCoupon.getSystemCoupon().getId());
|
|
// 插入使用券记录
|
UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();
|
couponRecord.setState(UserSystemCouponRecord.STATE_SUCCESS);
|
couponRecord.setGoodSource(order.getOrderType());
|
couponRecord.setOrderNo(order.getOrderId());
|
couponRecord.setUserSystemCoupon(userSystemCoupon);
|
couponRecord.setCouponType(coupon.getType().name());
|
couponRecord.setCreateTime(date);
|
couponRecord.setUpdateTime(date);
|
userSystemCouponRecordService.insertSelective(couponRecord);
|
|
// 插入资金通知
|
userMoneyMsgNotificationService.orderReward(uid, order.getOrderId(), order.getOrderType(), money,
|
userInfoService.selectByPKey(uid).getMyHongBao());
|
// 消息推送
|
try {
|
userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon, hongBao, money, order.getOrderId());
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
transactionManager.commit(transactionStatus);
|
} catch (Exception e) {
|
e.printStackTrace();
|
transactionManager.rollback(transactionStatus);
|
throw new Exception();
|
}
|
|
}
|
|
@Override
|
public UserSystemCouponRecordVO getRewardCouponRecord(String orderNo, Integer sourceType)
|
throws UserSystemCouponException, Exception {
|
|
if (orderNo == null || orderNo.trim().length() == 0) {
|
throw new UserSystemCouponException(1, "订单号不存在");
|
}
|
|
// 查询记录
|
UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo,
|
UserSystemCouponRecord.STATE_SUCCESS);
|
if (record == null) {
|
throw new UserSystemCouponException(1, "没有使用券记录");
|
}
|
|
UserSystemCoupon userSystemCoupon = record.getUserSystemCoupon();
|
if (userSystemCoupon == null) {
|
throw new UserSystemCouponException(1, "未找到用户的券信息");
|
}
|
|
SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
|
if (systemCoupon == null || systemCoupon.getId() == null) {
|
throw new UserSystemCouponException(1, "未找到用户的券信息");
|
}
|
|
SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
if (baseCoupon == null || baseCoupon.getId() == null) {
|
throw new UserSystemCouponException(1, "未找到券基本信息");
|
}
|
|
CouponTypeEnum couponType = baseCoupon.getType();
|
if (CouponTypeEnum.rebatePercentCoupon != couponType) {
|
throw new UserSystemCouponException(1, "券类型不正确");
|
}
|
|
Long uid = userSystemCoupon.getUid();
|
|
CommonOrderVO commonOrderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo,
|
CommonOrder.STATE_JS, sourceType);
|
|
if (commonOrderVO == null) {
|
throw new UserSystemCouponException(1, "订单信息获取失败");
|
}
|
|
// 获取奖励金额
|
BigDecimal couponMoney = orderHongBaoMapService.getCouponHongbaoByOrderNo(orderNo, uid);
|
|
UserSystemCouponRecordVO userRecordVO = new UserSystemCouponRecordVO();
|
userRecordVO.setCouponMoneyState("已到账");
|
userRecordVO.setCommonOrder(commonOrderVO);
|
userRecordVO.setCouponName("奖励金: ¥" + couponMoney.setScale(2, BigDecimal.ROUND_DOWN));
|
|
// 比例
|
BigDecimal percent = baseCoupon.getPercent();
|
BigDecimal hongBao = commonOrderVO.getHongBao();
|
if (hongBao == null) {
|
hongBao = new BigDecimal(0);
|
}
|
userRecordVO.setCouponEffect("返利¥" + hongBao.setScale(2, BigDecimal.ROUND_DOWN) + "已返" + percent + "%");
|
|
// 资金明细
|
JumpDetailV2 welfareCore = jumpDetailV2Service.getByTypeCache("moneyDetails");
|
Map<String, Object> jumpWelfare = new HashMap<String, Object>();
|
jumpWelfare.put("jumpDetail", welfareCore);
|
Map<String, Object> jumpparms = new HashMap<String, Object>();
|
jumpWelfare.put("parms", jumpparms);
|
userRecordVO.setJumpWelfare(jumpWelfare);
|
|
// 跳转奖励券规则
|
userRecordVO.setRuleLink(configService.get("reward_coupon_help"));
|
|
String rewardCouponRemark = configService.get("reward_coupon_remark");
|
if (rewardCouponRemark != null && rewardCouponRemark.trim().length() > 0) {
|
userRecordVO.setRemark(JSONObject.fromObject(rewardCouponRemark));
|
}
|
|
return userRecordVO;
|
}
|
|
@Override
|
public UserSystemCouponRecordVO getFreeCouponRecord(String orderNo, Integer sourceType)
|
throws UserSystemCouponException, Exception {
|
|
if (orderNo == null || orderNo.trim().length() == 0) {
|
throw new UserSystemCouponException(1, "订单号不存在");
|
}
|
|
// 查询记录
|
UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, null);
|
if (record == null) {
|
throw new UserSystemCouponException(1, "没有使用券记录");
|
}
|
|
UserSystemCoupon userSystemCoupon = record.getUserSystemCoupon();
|
if (userSystemCoupon == null) {
|
throw new UserSystemCouponException(1, "未找到用户的券信息");
|
}
|
|
SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
|
if (systemCoupon == null || systemCoupon.getId() == null) {
|
throw new UserSystemCouponException(1, "未找到用户的券信息");
|
}
|
|
SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
if (baseCoupon == null || baseCoupon.getId() == null) {
|
throw new UserSystemCouponException(1, "未找到券基本信息");
|
}
|
|
// 订单
|
CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo, null,
|
sourceType);
|
if (orderVO == null) {
|
throw new UserSystemCouponException(1, "订单信息获取失败");
|
}
|
|
UserSystemCouponRecordVO userRecordVO = new UserSystemCouponRecordVO();
|
userRecordVO.setCommonOrder(orderVO);
|
|
ClientTextStyleVO fanMoney = new ClientTextStyleVO();
|
fanMoney.setContent("返利: ¥" + orderVO.getHongBao().setScale(2, BigDecimal.ROUND_DOWN));
|
fanMoney.setColor("#000000"); // 默认黑色
|
userRecordVO.setFanMoney(fanMoney);
|
|
ClientTextStyleVO payMoney = new ClientTextStyleVO();
|
payMoney.setContent("实付款:¥" + orderVO.getPayment().setScale(2, BigDecimal.ROUND_DOWN));
|
payMoney.setColor("#000000"); // 默认黑色
|
|
String progressMsg = "";
|
String progressColor = "";
|
// 跳转奖励券规则
|
userRecordVO.setRuleLink(configService.get("free_coupon_help"));
|
|
// 进度： 1 灰色 2 红色 3 绿色
|
String progressState1 = "3";
|
String progressState2 = "1";
|
String progressState3 = "1";
|
String progressState4 = "1";
|
|
String goodsState = "商品收货";
|
// 文字状态
|
String text2Color = "#999999";
|
String text3Color = "#999999";
|
String text4Color = "#999999";
|
|
// 底部备注
|
String rewardCouponRemark = "";
|
// 状态跳转
|
JumpDetailV2 jumpDetail = null;
|
// 进度状态 1等待 2 失败 3成功
|
int progressState = 1;
|
|
Integer stateRecord = record.getState();
|
if (UserSystemCouponRecord.STATE_FAIL_RULE == stateRecord) {
|
// 规则不匹配
|
progressState = 2;
|
|
progressColor = "#E41212";
|
progressMsg = "抱歉不符合免单规则，免单失败";
|
|
progressState1 = "2"; // 不匹配
|
|
payMoney.setColor("#E41212");
|
|
userRecordVO.setCouponMoneyState("已退回");
|
userRecordVO.setCouponName(baseCoupon.getName());
|
|
jumpDetail = jumpDetailV2Service.getByTypeCache("welfareCore");
|
|
rewardCouponRemark = configService.get("free_coupon_back_remark");
|
|
} else if (UserSystemCouponRecord.STATE_FAIL_DRAWBACK == stateRecord) {
|
// 退款
|
progressState = 2;
|
|
progressColor = "#E41212";
|
progressMsg = "商品已退款，免单失败";
|
|
text2Color = "#E41212";
|
goodsState = "商品已退款";
|
|
progressState2 = "2";
|
|
userRecordVO.setCouponMoneyState("已退回");
|
userRecordVO.setCouponName(baseCoupon.getName());
|
|
jumpDetail = jumpDetailV2Service.getByTypeCache("welfareCore");
|
|
rewardCouponRemark = configService.get("free_coupon_back_remark");
|
|
} else if (UserSystemCouponRecord.STATE_FREE_ON == stateRecord) {
|
// 免单中
|
if (CommonOrder.STATE_JS == orderVO.getState()) {
|
progressColor = "#ECA01B";
|
progressMsg = "免单进行中，等待返利到账";
|
text2Color = "#000000";
|
progressState2 = "3";
|
} else {
|
progressColor = "#ECA01B";
|
progressMsg = "免单发起，等待收货";
|
}
|
|
rewardCouponRemark = configService.get("free_coupon_remark");
|
|
} else if (UserSystemCouponRecord.STATE_SUCCESS == stateRecord) {
|
// 免单成功
|
progressState = 3;
|
|
progressColor = "#3EBF13";
|
progressMsg = "免单成功，免单金已转入余额";
|
|
progressState2 = "3";
|
progressState3 = "3";
|
progressState4 = "3";
|
|
text2Color = "#000000";
|
text3Color = "#000000";
|
text4Color = "#000000";
|
|
userRecordVO.setCouponMoneyState("已到账");
|
userRecordVO.setCouponName("返利: ¥" + orderVO.getHongBao().setScale(2, BigDecimal.ROUND_DOWN));
|
|
jumpDetail = jumpDetailV2Service.getByTypeCache("capitalDetails");
|
|
rewardCouponRemark = configService.get("free_coupon_remark");
|
}
|
userRecordVO.setProgressState(progressState);
|
userRecordVO.setPayMoney(payMoney);
|
|
// 显示提示较大字
|
ClientTextStyleVO progressMsgStyle = new ClientTextStyleVO();
|
progressMsgStyle.setContent(progressMsg);
|
progressMsgStyle.setColor(progressColor);
|
userRecordVO.setProgressMsg(progressMsgStyle);
|
|
/* --- 进度点 ---- */
|
Map<String, Object> map1 = new HashMap<String, Object>();
|
map1.put("state", progressState1);
|
|
Map<String, Object> map2 = new HashMap<String, Object>();
|
map2.put("state", progressState2);
|
ClientTextStyleVO style2 = new ClientTextStyleVO();
|
style2.setContent(goodsState);
|
style2.setColor(text2Color);
|
map2.put("text", style2);
|
|
Map<String, Object> map3 = new HashMap<String, Object>();
|
map3.put("state", progressState3);
|
ClientTextStyleVO style3 = new ClientTextStyleVO();
|
style3.setContent("返利到账");
|
style3.setColor(text3Color);
|
map3.put("text", style3);
|
|
Map<String, Object> map4 = new HashMap<String, Object>();
|
map4.put("state", progressState4);
|
ClientTextStyleVO style4 = new ClientTextStyleVO();
|
style4.setContent("免单成功");
|
style4.setColor(text4Color);
|
map4.put("text", style4);
|
|
// 圆点颜色
|
List<Object> progressList = new ArrayList<Object>();
|
progressList.add(map1);
|
progressList.add(map2);
|
progressList.add(map3);
|
progressList.add(map4);
|
userRecordVO.setProgressList(progressList);
|
|
if (jumpDetail != null) {
|
Map<String, Object> jumpState = new HashMap<String, Object>();
|
jumpState.put("jumpDetail", jumpDetail);
|
Map<String, Object> jumpparms = new HashMap<String, Object>();
|
jumpState.put("parms", jumpparms);
|
userRecordVO.setJumpWelfare(jumpState);
|
}
|
|
if (rewardCouponRemark != null && rewardCouponRemark.trim().length() > 0) {
|
userRecordVO.setRemark(JSONObject.fromObject(rewardCouponRemark));
|
}
|
|
return userRecordVO;
|
}
|
|
@Transactional
|
@Override
|
public void activatedWelfareFreeCoupon(Long uid, String fromNickName) {
|
|
LogHelper.test("券激活:" + uid);
|
if (uid == null) {
|
return;
|
}
|
// 福利免单券
|
String welfareFree = CouponTypeEnum.welfareFreeCoupon.name();
|
|
SystemCoupon systemCoupon = systemCouponService.getCouponByType(welfareFree);
|
if (systemCoupon == null) {
|
return;
|
}
|
|
// 待活福利免单券
|
List<UserSystemCoupon> list = userSystemCouponMapper.getCouponByTypeAndNotActivated(uid, systemCoupon.getId());
|
if (list == null || list.size() == 0) {
|
return;
|
}
|
|
for (UserSystemCoupon userSystemCoupon : list) {
|
// 激活
|
UserSystemCoupon update = new UserSystemCoupon();
|
update.setId(userSystemCoupon.getId());
|
update.setStateActivated(1);
|
update.setUpdateTime(new Date());
|
userSystemCouponMapper.updateByPrimaryKeySelective(update);
|
|
Integer state = userSystemCoupon.getState();
|
if (UserSystemCoupon.STATE_OVERDUE == state) {
|
continue; // 已失效不做消息推送
|
}
|
|
// 消息推送
|
try {
|
UserInfo userInfo = new UserInfo();
|
userInfo.setId(uid);
|
userInfo.setNickName(fromNickName);
|
|
userOtherMsgNotificationService.welfareCouponActive(userSystemCoupon, userInfo);
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
}
|
|
@Transactional
|
@Override
|
public void updateStateByDrawback(String orderNo) throws Exception {
|
|
if (orderNo == null || orderNo.trim().length() == 0) {
|
return;
|
}
|
|
UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, null);
|
if (record == null) {
|
return;
|
}
|
|
record.setOrderNo(orderNo);
|
record.setUpdateTime(new Date());
|
record.setState(UserSystemCouponRecord.STATE_FAIL_DRAWBACK);
|
userSystemCouponRecordService.updateByPrimaryKeySelective(record);
|
|
// 券退回
|
sendBackCoupon(record.getUserSystemCoupon(), record);
|
}
|
|
@Transactional
|
@Override
|
public void updateStateByArrivalAccount(String orderNo) throws Exception {
|
|
if (orderNo == null || orderNo.trim().length() == 0) {
|
return;
|
}
|
|
UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, 2);
|
if (record == null) {
|
return;
|
}
|
|
record.setOrderNo(orderNo);
|
record.setUpdateTime(new Date());
|
record.setState(UserSystemCouponRecord.STATE_SUCCESS);
|
userSystemCouponRecordService.updateByPrimaryKeySelective(record);
|
|
// 消息推送
|
if (CouponTypeEnum.welfareFreeCoupon.name().equals(record.getCouponType())) {
|
userOtherMsgNotificationService.welfareCouponUsed(record.getUserSystemCoupon(), orderNo);
|
} else if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())) {
|
userOtherMsgNotificationService.freeSheetCouponUsed(record.getUserSystemCoupon(), orderNo);
|
} else if (CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) {
|
userOtherMsgNotificationService.couponUsedFreeSheet(record.getUserSystemCoupon(), orderNo,
|
MsgTypeOtherTypeEnum.freeCouponBuy);
|
}
|
}
|
|
@Override
|
public List<UserSystemCoupon> getCounponNowInvalid(int count) {
|
return userSystemCouponMapper.getCounponNowInvalid(count);
|
}
|
|
@Transactional
|
@Override
|
public boolean updateCouponRecordUsed(Long uid, String orderNo, BigDecimal payment, Long auctionId)
|
throws Exception {
|
|
boolean isfree = false;
|
|
if (uid == null || payment == null || auctionId == null || orderNo == null || orderNo.trim().length() == 0) {
|
throw new Exception("传递参数不能为空");
|
}
|
|
// 查询等待匹配的券记录
|
List<UserSystemCouponRecord> list = userSystemCouponRecordService.getRecordByState(uid,
|
UserSystemCouponRecord.STATE_WAIT);
|
if (list == null || list.size() == 0) {
|
return isfree;
|
}
|
|
// 匹配
|
boolean matching = false;
|
UserSystemCouponRecord record = null;
|
|
for (UserSystemCouponRecord userSystemCouponRecord : list) {
|
Long goodId = userSystemCouponRecord.getGoodId();
|
if (auctionId.equals(goodId)) {
|
matching = true; // 匹配成功
|
record = userSystemCouponRecord;
|
break;
|
}
|
}
|
|
// 商品匹配成功
|
if (matching) {
|
|
record.setOrderNo(orderNo);
|
record.setUpdateTime(new Date());
|
|
UserSystemCoupon userSystemCoupon = record.getUserSystemCoupon();
|
|
if (payment.compareTo(new BigDecimal(10)) > 0) {
|
// 更新记录 -- 金额不匹配 大10元
|
record.setState(UserSystemCouponRecord.STATE_FAIL_RULE);
|
userSystemCouponRecordService.updateByPrimaryKeySelective(record);
|
|
// 退回券
|
sendBackCoupon(userSystemCoupon, record);
|
|
} else {
|
// 免单匹配成功
|
isfree = true;
|
|
// 更新记录--免单中
|
record.setState(UserSystemCouponRecord.STATE_FREE_ON);
|
userSystemCouponRecordService.updateByPrimaryKeySelective(record);
|
|
// 券结束使用
|
userSystemCoupon.setState(UserSystemCoupon.STATE_END_USE);
|
userSystemCoupon.setUpdateTime(new Date());
|
userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|
String couponType = record.getCouponType();
|
if (couponType == null || couponType.trim().length() == 0) {
|
throw new Exception("券类型未被记录");
|
}
|
|
if (CouponTypeEnum.welfareFreeCoupon.name().equals(couponType)) {
|
userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon, orderNo, payment);
|
} else if (CouponTypeEnum.freeCoupon.name().equals(couponType)) {
|
userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon, orderNo, payment);
|
} else if (CouponTypeEnum.freeCouponBuy.name().equals(couponType)) {
|
userOtherMsgNotificationService.couponUsingFreeSheet(userSystemCoupon, orderNo, payment,
|
MsgTypeOtherTypeEnum.freeCouponBuy);
|
}
|
}
|
}
|
|
return isfree;
|
}
|
|
@Override
|
@Transactional
|
public void copyLotteryPrize(Long uid, int platform, String device) throws Exception {
|
|
return;
|
|
/*
|
* if (uid == null || device == null) { return; }
|
*
|
* // 未登陆之前抽奖记录 List<DeviceLotteryRecord> list =
|
* deviceLotteryRecordService.listByPlatformAndDevice(platform, device);
|
* if (list == null || list.size() == 0) { return; }
|
*
|
* // 获取额外信息 UserInfoExtra userInfoExtra =
|
* userInfoExtraService.getUserInfoExtra(uid);
|
*
|
* // 已经抽过奖的或者已经进入过抽奖页面的 if (userInfoExtra != null &&
|
* userInfoExtra.getLotteryNewbies() != null) { return; }
|
*
|
* // 是否是新用户 boolean isNewUser = userInfoExtraService.isNewUser(uid); if
|
* (!isNewUser) { return; }
|
*
|
* int coupon = 0;
|
*
|
* for (DeviceLotteryRecord reviceLotteryRecord : list) {
|
*
|
* // 删除记录
|
* deviceLotteryRecordService.deleteByPrimaryKey(reviceLotteryRecord.
|
* getId());
|
*
|
* Long systemCouponId = reviceLotteryRecord.getSystemCouponId(); if
|
* (systemCouponId == null) { continue; } SystemCoupon systemCoupon =
|
* systemCouponService.selectByPrimaryKey(systemCouponId); if
|
* (systemCoupon == null) { continue; }
|
*
|
* int stateActivated = 1; if (systemCoupon.getType() ==
|
* CouponTypeEnum.welfareFreeCoupon) { // 福利券状态 long countSuccess =
|
* threeSaleSerivce.countSuccessFirstTeam(uid); // 没有下级队员 --待激活 if
|
* (countSuccess == 0) { stateActivated = 0; } }
|
*
|
* // 结束日期 // 今天在内 减去一天 String endDay =
|
* DateUtil.plusDay(systemCoupon.getExpiryDay() - 1, new Date());
|
* SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"
|
* ); if (endDay != null && endDay.trim().length() > 0) { endDay +=
|
* " 23:59:59"; } Date endTime = format.parse(endDay);
|
*
|
* UserSystemCoupon userCoupon = new UserSystemCoupon();
|
* userCoupon.setUid(uid);
|
* userCoupon.setSource(UserSystemCoupon.SOURCE_NEWBIES);
|
* userCoupon.setSystemCoupon(systemCoupon);
|
* userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
|
* userCoupon.setStateActivated(stateActivated);
|
* userCoupon.setStartTime(new Date()); userCoupon.setEndTime(endTime);
|
* userCoupon.setCreateTime(new Date()); userCoupon.setUpdateTime(new
|
* Date()); // 插入数据库 insertSelective(userCoupon);
|
*
|
* // 券数量 coupon++;
|
*
|
* // 消息推送 try { if (systemCoupon.getType() ==
|
* CouponTypeEnum.welfareFreeCoupon) {
|
* userOtherMsgNotificationService.welfareCouponGet(userCoupon); } else
|
* if (systemCoupon.getType() == CouponTypeEnum.freeCoupon) {
|
* userOtherMsgNotificationService.freeSheetCouponGet(userCoupon); }
|
* else if (systemCoupon.getType() ==
|
* CouponTypeEnum.rebatePercentCoupon) {
|
* userOtherMsgNotificationService.rewardCouponGet(userCoupon,
|
* systemCoupon.getPercent().intValue()); }
|
*
|
* } catch (Exception e) { try { LogHelper.errorDetailInfo(e); } catch
|
* (Exception e1) { e1.printStackTrace(); } } }
|
*
|
* if (userInfoExtra == null) { userInfoExtra = new UserInfoExtra();
|
* userInfoExtra.setUserInfo(new UserInfo(uid)); }
|
*
|
* userInfoExtra.setLotteryNewbies(Constant.MAX_COUNT_LOTTERY_NEWBIES -
|
* list.size()); Integer couponNews = userInfoExtra.getCouponNews(); if
|
* (couponNews == null) { userInfoExtra.setCouponNews(coupon); } else {
|
* userInfoExtra.setCouponNews(couponNews + coupon); }
|
* userInfoExtraService.saveUserInfoExtra(userInfoExtra);
|
*/
|
|
}
|
|
@Override
|
@Transactional
|
public void randomRewardCoupon(int num, Long uid, String source) throws Exception {
|
if (num < 1) {
|
return;
|
}
|
|
for (int i = 0; i < num; i++) {
|
|
// 返利比-随机
|
BigDecimal percent = new BigDecimal(randomNum());
|
// 查询奖励券
|
SystemCoupon systemCoupon = systemCouponService
|
.getCouponByTypeAndPercent(CouponTypeEnum.rebatePercentCoupon.name(), percent);
|
if (systemCoupon == null) {
|
return;
|
}
|
|
// 结束日期 今天在内 减去一天
|
String endDay = DateUtil.plusDay(systemCoupon.getExpiryDay() - 1, new Date());
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
if (endDay != null && endDay.trim().length() > 0) {
|
endDay += " 23:59:59";
|
}
|
Date endTime = format.parse(endDay);
|
|
UserSystemCoupon userCoupon = new UserSystemCoupon();
|
userCoupon.setUid(uid);
|
userCoupon.setSource(source);
|
userCoupon.setSystemCoupon(systemCoupon);
|
userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
|
userCoupon.setStateActivated(1);
|
userCoupon.setStartTime(new Date());
|
userCoupon.setEndTime(endTime);
|
userCoupon.setCreateTime(new Date());
|
userCoupon.setUpdateTime(new Date());
|
// 插入数据库
|
insertSelective(userCoupon);
|
|
// 消息推送
|
try {
|
userOtherMsgNotificationService.rewardCouponGet(userCoupon, systemCoupon.getPercent().intValue());
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
// 福利中心红点
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra == null) {
|
return;
|
}
|
Integer couponNews = userInfoExtra.getCouponNews();
|
if (couponNews == null) {
|
userInfoExtra.setCouponNews(num);
|
} else {
|
userInfoExtra.setCouponNews(couponNews + num);
|
}
|
userInfoExtraService.saveUserInfoExtra(userInfoExtra);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void systemGiveRewardCoupon(Long uid, int num, String orderId, Integer orderType, String reason)
|
throws Exception {
|
// 添加奖励券
|
insertUserCoupon(uid, CouponTypeEnum.rebatePercentCoupon.name(), "系统赠送",
|
new BigDecimal(configService.get("exchange_rebate_percent")), false);
|
// 添加奖励券消息
|
userOtherMsgNotificationService.systemGiveRewardCoupon(uid, null, MsgOtherSystemGiveDTOFactory
|
.createRewardCouponGive(num, "请按照返利奖励券规则使用", "返利奖励券", orderId, orderType, reason));
|
}
|
|
/**
|
* 随机券比例
|
*
|
* @return
|
*/
|
public int randomNum() {
|
|
int result = 1;
|
|
List<RandomProportion> list = new ArrayList<RandomProportion>();
|
list.add(new RandomProportion(1, 22));
|
list.add(new RandomProportion(2, 22));
|
list.add(new RandomProportion(3, 22));
|
list.add(new RandomProportion(4, 22));
|
list.add(new RandomProportion(5, 20));
|
list.add(new RandomProportion(6, 18));
|
list.add(new RandomProportion(7, 16));
|
list.add(new RandomProportion(8, 14));
|
list.add(new RandomProportion(9, 12));
|
list.add(new RandomProportion(10, 10));
|
list.add(new RandomProportion(11, 8));
|
list.add(new RandomProportion(12, 6));
|
list.add(new RandomProportion(13, 4));
|
list.add(new RandomProportion(14, 2));
|
list.add(new RandomProportion(15, 1));
|
|
int minRange = 0;
|
int maxRange = 0;
|
int randomNum = (int) (1 + Math.round(Math.random() * (199)));
|
|
for (int i = 0; i < list.size(); i++) {
|
|
RandomProportion proportion = list.get(i);
|
int probability = proportion.probability;
|
|
maxRange = maxRange + probability;
|
minRange = maxRange - probability;
|
|
if (randomNum > minRange && randomNum <= maxRange) {
|
result = proportion.num;
|
break;
|
}
|
}
|
|
return result;
|
}
|
|
class RandomProportion {
|
public int num;// 券值
|
public int probability; // 概率
|
|
RandomProportion() {
|
}
|
|
RandomProportion(int num, int probability) {
|
this.num = num;
|
this.probability = probability;
|
}
|
}
|
|
@Override
|
@Transactional
|
public void exchangeCoupon(Long uid, String couponType, String source, BigDecimal percent)
|
throws UserSystemCouponException, Exception {
|
if (couponType == null || uid == null) {
|
throw new UserSystemCouponException(1, "参数不正确");
|
}
|
|
SystemCoupon coupon = null;
|
if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) {
|
coupon = systemCouponService.getCouponByTypeAndPercent(couponType, percent);
|
} else {
|
coupon = systemCouponService.getCouponByType(couponType);
|
}
|
|
if (coupon == null) {
|
throw new UserSystemCouponException(1, "券类型不正确");
|
}
|
|
int stateActivated = 1;
|
if (couponType == CouponTypeEnum.freeCoupon.name()) {
|
stateActivated = 0; //
|
} else if (couponType == CouponTypeEnum.welfareFreeCoupon.name()
|
&& threeSaleSerivce.countSuccessFirstTeam(uid) <= 0) {
|
stateActivated = 0; // 无下级队员 --待激活
|
}
|
|
Integer expiryDay = null;
|
if (stateActivated == 0)
|
expiryDay = coupon.getActivateDay();
|
|
if (expiryDay == null || expiryDay == 0)
|
expiryDay = coupon.getExpiryDay();
|
|
// 计算结束日期：今天在内 减去一天
|
String endDay = DateUtil.plusDay(expiryDay - 1, new Date());
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
if (endDay != null && endDay.trim().length() > 0) {
|
endDay += " 23:59:59";
|
}
|
Date endTime = format.parse(endDay);
|
|
UserSystemCoupon userCoupon = new UserSystemCoupon();
|
userCoupon.setUid(uid);
|
userCoupon.setSource(source);
|
userCoupon.setSystemCoupon(coupon);
|
userCoupon.setStateActivated(stateActivated);
|
userCoupon.setStartTime(new Date());
|
userCoupon.setEndTime(endTime);
|
userCoupon.setGive(false);
|
userCoupon.setCreateTime(new Date());
|
userCoupon.setUpdateTime(new Date());
|
userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
|
|
insertSelective(userCoupon);
|
}
|
|
@Transactional
|
@Override
|
public List<UserSystemCouponVO> getCouponList(long start, int count, Long uid)
|
throws UserSystemCouponException, Exception {
|
|
// 过期券
|
updateInvalidSate(uid);
|
|
// 退回券
|
sendBackTimeOutCoupon(uid);
|
|
// 赠送的退回
|
sendBackGiveUser(uid);
|
|
List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid);
|
if (listVO == null || listVO.size() == 0) {
|
return listVO;
|
}
|
|
// 是否激活邀请码
|
String inviteCode = null;
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra != null) {
|
inviteCode = userInfoExtra.getInviteCode();
|
}
|
|
for (UserSystemCouponVO userCouponVO : listVO) {
|
SystemCoupon systemCoupon = userCouponVO.getSystemCoupon();
|
if (systemCoupon != null && systemCoupon.getId() != null) {
|
systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
}
|
|
if (systemCoupon == null) {
|
continue; // 券信息不完整
|
}
|
|
String source = userCouponVO.getSource();
|
if (source != null && "奖励券天天抽".equals(source)) {
|
source = "天天抽";
|
}
|
|
userCouponVO.setSource("来源：" + source);
|
userCouponVO.setCouponName(systemCoupon.getName());
|
userCouponVO.setCouponEffect(systemCoupon.getEffect());
|
userCouponVO.setCouponRule(systemCoupon.getRule());
|
userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink());
|
|
String couponTerm = "有效期：";
|
Date startTime = userCouponVO.getStartTime();
|
Date endTime = userCouponVO.getEndTime();
|
if (endTime != null && startTime != null) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
|
couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);
|
}
|
userCouponVO.setCouponTerm(couponTerm);
|
|
Integer state = userCouponVO.getState();
|
if (UserSystemCoupon.STATE_END_USE == state || UserSystemCoupon.STATE_OVERDUE == state) {
|
userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());
|
} else {
|
userCouponVO.setCouponPicture(systemCoupon.getPicture());
|
}
|
|
if (UserSystemCoupon.STATE_CAN_USE == state || UserSystemCoupon.STATE_IN_USE == state) {
|
int differentDays = 0;
|
if (endTime != null && startTime != null) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
differentDays = DateUtil.daysBetween(sdf.format(new Date()), sdf.format(endTime)) + 1;
|
if (differentDays < 0) {
|
differentDays = 0;
|
}
|
}
|
// 剩余天数
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "还剩" + differentDays + "天过期");
|
remainDays.put("fontColor", "#F14242");
|
userCouponVO.setRemainDays(remainDays);
|
}
|
|
Map<String, Object> jumpBtn = null;
|
CouponTypeEnum type = systemCoupon.getType();
|
Integer stateActivated = userCouponVO.getStateActivated();
|
|
// 未激活
|
if (stateActivated == null || stateActivated == 0) {
|
userCouponVO.setCouponEffect("待激活");
|
userCouponVO.setCouponRule(systemCoupon.getRemark());
|
if (UserSystemCoupon.STATE_CAN_USE == state) {
|
state = 0;
|
userCouponVO.setState(state);
|
if (CouponTypeEnum.freeCoupon == type) {
|
List<String> listTip = new ArrayList<String>();
|
listTip.add("本免单券由好友赠送，从获赠日起60天内需产生3笔返利订单；");
|
listTip.add("返利订单“已到账”后，方能视为订单产生成功；");
|
listTip.add("满足条件后，系统将自动激活，并在消息-其它消息中提醒。");
|
userCouponVO.setTips(listTip);
|
userCouponVO.setPopup(true);
|
|
// 验证是否已累计3单
|
executor.execute(new Runnable() {
|
@Override
|
public void run() {
|
freeCouponActivate(userCouponVO.getId(), uid, userCouponVO.getCreateTime());
|
}
|
});
|
|
} else if (CouponTypeEnum.welfareFreeCoupon == type) {
|
jumpBtn = new HashMap<String, Object>();
|
if (inviteCode != null && inviteCode.trim().length() > 0) {
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_friends"));
|
} else {
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_activate"));
|
}
|
}
|
}
|
}
|
|
if (UserSystemCoupon.STATE_IN_USE == state && (CouponTypeEnum.freeCouponBuy == type
|
|| CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type)) {
|
List<String> listTip = new ArrayList<String>();
|
listTip.add("系统正在判断是否符合免单需求；");
|
listTip.add("系统正在同步淘宝订单；");
|
listTip.add("未使用成功的免单券会原路退回。");
|
userCouponVO.setTipsUsing(listTip);
|
}
|
|
// 是否已赠送
|
Boolean give = userCouponVO.getGive();
|
if (give == null) {
|
give = false;
|
}
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
|
|
if (UserSystemCoupon.STATE_CAN_USE == state) {
|
Map<String, Object> jumpLink = new HashMap<String, Object>();
|
if (CouponTypeEnum.freeCouponGive == type) {
|
userCouponVO.setState(UserSystemCoupon.STATE_GIVE_ONLY);
|
} else if (CouponTypeEnum.freeCoupon == type || CouponTypeEnum.welfareFreeCoupon == type
|
|| CouponTypeEnum.freeCouponBuy == type) {
|
jumpLink.put("url", configService.get("free_goods_list"));
|
jumpBtn = new HashMap<String, Object>();
|
jumpBtn.put("params", jumpLink);
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("web"));
|
} else if (CouponTypeEnum.rebatePercentCoupon == type) {
|
// 可使用、 可赠送
|
userCouponVO.setState(UserSystemCoupon.STATE_USE_GIVE);
|
|
// 订单列表
|
jumpLink.put("state", "2"); // 已收货
|
jumpLink.put("showNav", false); // 不显示上方统计信息
|
jumpLink.put("type", "1"); // 返利订单
|
jumpLink.put("title", "返利订单"); // 标题名
|
jumpLink.put("goodsType", "0"); // 订单来源
|
jumpBtn = new HashMap<String, Object>();
|
jumpBtn.put("params", jumpLink);
|
jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("order_screen_list"));
|
}
|
} else if (UserSystemCoupon.STATE_IN_USE == state && give) {
|
userCouponVO.setCouponEffect("赠送中");
|
userCouponVO.setCouponRule(systemCoupon.getRemark());
|
String tips = null;
|
|
TokenTypeEnum tokenType = null;
|
if (CouponTypeEnum.freeCouponGive == type) {
|
userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN);
|
tips = configService.get("give_free_coupon_tips");
|
tokenType = TokenTypeEnum.freeCoupon;
|
}
|
|
if (CouponTypeEnum.rebatePercentCoupon == type) {
|
userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN);
|
tips = configService.get("give_rebate_percent_coupon_tips");
|
tokenType = TokenTypeEnum.rebatePercentCoupon;
|
}
|
|
if (!StringUtil.isNullOrEmpty(tips) && tokenType != null) {
|
UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid,
|
userCouponVO.getId());
|
if (record != null) {
|
TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenType.name(),
|
record.getId().toString());
|
if (tokenRecord != null && !StringUtil.isNullOrEmpty(tokenRecord.getToken())) {
|
String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();
|
while (tips.contains("{APP名称}")) {
|
tips = tips.replace("{APP名称}", projectChineseName);
|
}
|
tips = tips.replace("{口令}", tokenRecord.getToken()).replace("{下载链接}",
|
configService.get("app_down_link"));
|
userCouponVO.setGiveTips(tips);
|
}
|
|
Date endTimeGive = record.getEndTime();
|
if (endTimeGive != null) {
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "剩余" + DateUtil.dateDiff2(new Date(), endTimeGive) + "过期");
|
remainDays.put("fontColor", "#F14242");
|
userCouponVO.setRemainDays(remainDays);
|
}
|
}
|
}
|
} else if (UserSystemCoupon.STATE_END_USE == state) {
|
|
if (give) {
|
userCouponVO.setCouponRule(systemCoupon.getRemark());
|
if (CouponTypeEnum.freeCouponGive == type) {
|
userCouponVO.setCouponEffect("任性0元购");
|
userCouponVO.setState(UserSystemCoupon.STATE_GIVE_END);
|
}
|
|
if (CouponTypeEnum.rebatePercentCoupon == type) {
|
userCouponVO.setState(UserSystemCoupon.STATE_GIVE_END);
|
}
|
|
Date useTime = userCouponVO.getUseTime();
|
if (useTime != null) {
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "于" + sdf.format(useTime) + "赠送");
|
remainDays.put("fontColor", "#CCCCCC");
|
userCouponVO.setRemainDays(remainDays);
|
}
|
} else {
|
Date useTime = userCouponVO.getUseTime();
|
if (useTime != null) {
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "于" + sdf.format(useTime) + "使用");
|
remainDays.put("fontColor", "#CCCCCC");
|
userCouponVO.setRemainDays(remainDays);
|
}
|
}
|
|
} else if (UserSystemCoupon.STATE_OVERDUE == state) {
|
if (endTime != null) {
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "于" + sdf.format(endTime) + "过期");
|
remainDays.put("fontColor", "#CCCCCC");
|
userCouponVO.setRemainDays(remainDays);
|
}
|
|
if (give)
|
userCouponVO.setCouponRule(systemCoupon.getRemark());
|
}
|
userCouponVO.setJumpBtn(jumpBtn);
|
}
|
return listVO;
|
}
|
|
@Transactional
|
@Override
|
public UserSystemCouponVO giveCoupon(Long uid, Long id) throws UserSystemCouponException {
|
UserSystemCoupon userSystemCoupon = userSystemCouponMapper.selectByPrimaryKey(id);
|
if (userSystemCoupon == null)
|
throw new UserSystemCouponException(1, "该券已不存在");
|
|
SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
|
if (systemCoupon == null)
|
throw new UserSystemCouponException(1, "该券已不存在");
|
|
systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
if (systemCoupon == null)
|
throw new UserSystemCouponException(1, "该券已失效");
|
|
Integer state = userSystemCoupon.getState();
|
if (state != UserSystemCoupon.STATE_CAN_USE)
|
throw new UserSystemCouponException(1, "该券已被使用或赠送");
|
|
CouponTypeEnum type = systemCoupon.getType();
|
if (type != CouponTypeEnum.freeCouponGive && type != CouponTypeEnum.rebatePercentCoupon)
|
throw new UserSystemCouponException(1, "该券不支持赠送");
|
|
String tips = null;
|
TokenTypeEnum tokenTypeEnum = null;
|
if (type == CouponTypeEnum.freeCouponGive) {
|
tokenTypeEnum = TokenTypeEnum.freeCoupon;
|
tips = configService.get("give_free_coupon_tips");
|
} else if (type == CouponTypeEnum.rebatePercentCoupon) {
|
tokenTypeEnum = TokenTypeEnum.rebatePercentCoupon;
|
tips = configService.get("give_rebate_percent_coupon_tips");
|
} else {
|
throw new UserSystemCouponException(1, "该券不支持赠送");
|
}
|
|
if (StringUtil.isNullOrEmpty(tips))
|
throw new UserSystemCouponException(1, "tips数据缺失");
|
|
// 是否最近生成口令有效
|
UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid, id);
|
if (record != null) {
|
TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenTypeEnum.name(), id + "");
|
if (tokenRecord != null && !StringUtil.isNullOrEmpty(tokenRecord.getToken())) {
|
String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();
|
while (tips.contains("{APP名称}")) {
|
tips = tips.replace("{APP名称}", projectChineseName);
|
}
|
tips = tips.replace("{口令}", tokenRecord.getToken()).replace("{下载链接}",
|
configService.get("app_down_link"));
|
|
return createUserCouponVOo(userSystemCoupon, systemCoupon, record, tips);
|
}
|
}
|
|
Date nowDate = new Date();
|
// 插入赠送记录
|
UserSystemCouponGiveRecord giveRecord = new UserSystemCouponGiveRecord();
|
giveRecord.setCouponId(id);
|
giveRecord.setGiveUid(uid);
|
giveRecord.setGiveTime(nowDate);
|
giveRecord.setEndTime(DateUtil.plusDayDate(Constant.GIVE_DAYS, nowDate));
|
userSystemCouponGiveRecordService.insertSelective(giveRecord);
|
|
// 创建记录
|
TokenRecord tokenRecord = new TokenRecord();
|
tokenRecord.setUid(uid);
|
tokenRecord.setIdentify(giveRecord.getId() + "");
|
tokenRecord.setType(tokenTypeEnum);
|
tokenRecord.setStartTime(nowDate);
|
tokenRecord.setEndTime(DateUtil.plusDayDate(Constant.TOKEN_DAYS, nowDate));
|
tokenRecord.setState(0);
|
tokenRecordService.insertSelective(tokenRecord);
|
|
// 创建口令
|
String token = TokenUtil.createToken(tokenRecord.getId());
|
tokenRecord.setToken(token);
|
tokenRecordService.updateByPrimaryKeySelective(tokenRecord);
|
|
// 券状态
|
userSystemCoupon.setState(UserSystemCoupon.STATE_IN_USE);
|
userSystemCoupon.setGive(true);
|
userSystemCoupon.setUpdateTime(nowDate);
|
userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|
// 插入使用券记录
|
UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();
|
couponRecord.setState(UserSystemCouponRecord.STATE_GIVE_ON);
|
couponRecord.setUserSystemCoupon(userSystemCoupon);
|
couponRecord.setCouponType(type.name());
|
couponRecord.setCreateTime(nowDate);
|
couponRecord.setUpdateTime(nowDate);
|
userSystemCouponRecordService.insertSelective(couponRecord);
|
|
String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();
|
while (tips.contains("{APP名称}")) {
|
tips = tips.replace("{APP名称}", projectChineseName);
|
}
|
tips = tips.replace("{口令}", token).replace("{下载链接}", configService.get("app_down_link"));
|
|
return createUserCouponVOo(userSystemCoupon, systemCoupon, giveRecord, tips);
|
}
|
|
private UserSystemCouponVO createUserCouponVOo(UserSystemCoupon userSystemCoupon, SystemCoupon systemCoupon,
|
UserSystemCouponGiveRecord record, String tips) {
|
UserSystemCouponVO userCouponVO = new UserSystemCouponVO();
|
userCouponVO.setId(userSystemCoupon.getId());
|
userCouponVO.setUid(userSystemCoupon.getUid());
|
userCouponVO.setSource("来源：" + userSystemCoupon.getSource());
|
userCouponVO.setCouponName(systemCoupon.getName());
|
userCouponVO.setCouponEffect("赠送中");
|
userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN);
|
userCouponVO.setCouponRule(systemCoupon.getRemark());
|
userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink());
|
userCouponVO.setCouponPicture(systemCoupon.getPicture());
|
userCouponVO.setGiveTips(tips);
|
|
String couponTerm = "有效期：";
|
Date startTime = userCouponVO.getStartTime();
|
Date endTime = userCouponVO.getEndTime();
|
if (endTime != null && startTime != null) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
|
couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);
|
}
|
userCouponVO.setCouponTerm(couponTerm);
|
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "剩余23时59分过期");
|
remainDays.put("fontColor", "#F14242");
|
userCouponVO.setRemainDays(remainDays);
|
|
return userCouponVO;
|
}
|
|
/**
|
* 免单券激活
|
*
|
* @param uid
|
*/
|
public void freeCouponActivate(Long id, Long uid, Date date) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
long count = commonOrderCountService.countValidOrderByDate(uid, sdf.format(date));
|
|
String activateNum = configService.get("free_coupon_activate_num");
|
int num = Integer.parseInt(activateNum);
|
|
if (count >= num) {
|
UserSystemCoupon coupon = userSystemCouponMapper.selectByPrimaryKey(id);
|
if (coupon == null || coupon.getState() != UserSystemCoupon.STATE_CAN_USE
|
|| coupon.getStateActivated() != 0)
|
return;
|
|
Date nowDate = new Date();
|
Date endTime2 = coupon.getEndTime();
|
if (endTime2 != null && endTime2.getTime() <= nowDate.getTime())
|
return;
|
|
SystemCoupon systemCoupon = coupon.getSystemCoupon();
|
if (systemCoupon == null)
|
return;
|
|
systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
if (systemCoupon == null || systemCoupon.getType() != CouponTypeEnum.freeCoupon)
|
return;
|
|
try {
|
Integer expiryDay = systemCoupon.getExpiryDay();
|
String endDay = DateUtil.plusDay(expiryDay - 1, nowDate);
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
if (endDay != null && endDay.trim().length() > 0) {
|
endDay += " 23:59:59";
|
}
|
Date endTime = format.parse(endDay);
|
|
UserSystemCoupon userCoupon = new UserSystemCoupon();
|
userCoupon.setId(coupon.getId());
|
userCoupon.setStateActivated(1);
|
userCoupon.setEndTime(endTime);
|
userCoupon.setStartTime(nowDate);
|
userCoupon.setUpdateTime(new Date());
|
userSystemCouponMapper.updateByPrimaryKeySelective(userCoupon);
|
|
// 赠送记录
|
UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService.getByReceiveId(id);
|
if (giveRecord == null)
|
return;
|
|
Long giveUid = giveRecord.getGiveUid();
|
UserInfo userInfo = userInfoService.selectByPKey(giveUid);
|
if (userInfo == null)
|
return;
|
|
String beiZhu = "请到我的-福利中心中查看";
|
SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
|
MsgOtherCouponActivateDTO msgOther = new MsgOtherCouponActivateDTO();
|
msgOther.setTitle("免单券激活");
|
msgOther.setType("免单券系统已自动激活");
|
msgOther.setExplain("满足" + systemCoupon.getActivateDay() + "天内产生" + num + "笔已到账返利订单");
|
msgOther.setGiveUser("昵称：" + userInfo.getNickName() + " ID：" + giveUid);
|
msgOther.setReceiveTime(sd.format(giveRecord.getReceiveTime()));
|
msgOther.setValidityTime(expiryDay + "天");
|
userOtherMsgNotificationService.giveCouponActivateMsg(uid, beiZhu, msgOther);
|
} catch (Exception e) {
|
e.printStackTrace();
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
}
|
|
@Transactional
|
@Override
|
public void updateInvalidSate(Long uid) {
|
List<UserSystemCoupon> list = userSystemCouponMapper.getCounponNowInvalidByUid(uid);
|
if (list == null || list.size() == 0) {
|
return;
|
}
|
updateCounponInvalid(list);
|
}
|
|
@Override
|
public void updateCounponInvalid(List<UserSystemCoupon> list) {
|
if (list == null || list.size() == 0) {
|
return;
|
}
|
|
for (UserSystemCoupon userSystemCoupon : list) {
|
UserSystemCoupon userCoupon = new UserSystemCoupon();
|
userCoupon.setUpdateTime(new Date());
|
userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE);
|
userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|
SystemCoupon baseCoupon = userSystemCoupon.getSystemCoupon();
|
if (baseCoupon == null) {
|
continue;
|
}
|
|
baseCoupon = systemCouponService.selectByPrimaryKey(baseCoupon.getId());
|
if (baseCoupon == null || baseCoupon.getId() == null) {
|
continue;
|
}
|
|
// 消息推送
|
try {
|
if (baseCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
|
userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon);
|
} else if (baseCoupon.getType() == CouponTypeEnum.freeCoupon) {
|
userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon);
|
} else if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
|
userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon);
|
} else if (baseCoupon.getType() == CouponTypeEnum.freeCouponBuy) {
|
userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponBuy);
|
} else if (baseCoupon.getType() == CouponTypeEnum.freeCouponGive) {
|
userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponGive);
|
}
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
}
|
|
/**
|
* 退回券 初始数据
|
*
|
* @param userSystemCoupon
|
*/
|
public void sendBackCoupon(UserSystemCoupon userCoupon, UserSystemCouponRecord record) throws Exception {
|
if (userCoupon == null)
|
return;
|
|
Integer state = userCoupon.getState();
|
if (state != UserSystemCoupon.STATE_IN_USE)
|
return;
|
|
Date now = new Date();
|
Date endTime = userCoupon.getEndTime();
|
if (endTime != null && endTime.getTime() < now.getTime()) {
|
// 过期
|
List<UserSystemCoupon> list = new ArrayList<UserSystemCoupon>();
|
list.add(userCoupon);
|
updateCounponInvalid(list);
|
return;
|
}
|
|
// 退回券
|
UserSystemCoupon userSystemCoupon = new UserSystemCoupon();
|
userSystemCoupon.setId(userCoupon.getId());
|
userSystemCoupon.setGive(false);
|
userSystemCoupon.setUseTime(null);
|
userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
|
userSystemCoupon.setUpdateTime(new Date());
|
userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|
// 使用记录
|
if (record != null) {
|
if (CouponTypeEnum.welfareFreeCoupon.name().equals(record.getCouponType())) {
|
userOtherMsgNotificationService.welfareCouponDrawBack(userSystemCoupon, record.getOrderNo());
|
} else if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())) {
|
userOtherMsgNotificationService.freeSheetCouponDrawBack(userSystemCoupon, record.getOrderNo());
|
} else if (CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) {
|
userOtherMsgNotificationService.couponDrawBack(userSystemCoupon, record.getOrderNo(),
|
MsgTypeOtherTypeEnum.freeCouponBuy);
|
}
|
}
|
}
|
|
@Async()
|
@Transactional
|
@Override
|
public void sendBackTimeOutCoupon(Long uid) {
|
// 商品相关的券
|
List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
|
if (couponList == null || couponList.size() == 0) {
|
return;
|
}
|
|
List<Long> list = new ArrayList<Long>();
|
for (SystemCoupon systemCoupon : couponList) {
|
list.add(systemCoupon.getId());
|
}
|
|
// 超过10分钟 未被匹配的免单券
|
List<UserSystemCoupon> listUserCoupon = userSystemCouponMapper.getCouponByUsingTimeOut(uid, list, 600L);
|
if (listUserCoupon == null || listUserCoupon.size() == 0) {
|
return;
|
}
|
|
for (UserSystemCoupon userCoupon : listUserCoupon) {
|
// 状态初始化
|
UserSystemCoupon userSystemCoupon = new UserSystemCoupon();
|
userSystemCoupon.setId(userCoupon.getId());
|
userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
|
userSystemCoupon.setUseTime(null);
|
userSystemCoupon.setUpdateTime(new Date());
|
userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|
UserSystemCouponRecord record = userSystemCouponRecordService.getNearByUserCouponId(userCoupon.getId());
|
if (record != null) {
|
UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();
|
couponRecord.setId(record.getId());
|
couponRecord.setUpdateTime(new Date());
|
couponRecord.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
|
userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord);
|
}
|
}
|
}
|
|
@Transactional
|
@Override
|
public void sendBackGiveUser(Long uid) {
|
List<UserSystemCouponGiveRecord> list = userSystemCouponGiveRecordService.overdueListByUser(uid);
|
if (list == null || list.size() == 0) {
|
return;
|
}
|
sendBackGiveCoupon(list);
|
}
|
|
@Override
|
public void sendBackGiveCoupon(List<UserSystemCouponGiveRecord> overdueList) {
|
for (UserSystemCouponGiveRecord record : overdueList) {
|
// 更新赠送记录
|
UserSystemCouponGiveRecord updateRecord = new UserSystemCouponGiveRecord();
|
updateRecord.setId(record.getId());
|
updateRecord.setState(UserSystemCouponGiveRecord.STATE_OVERDUE);
|
userSystemCouponGiveRecordService.updateByPrimaryKeySelective(updateRecord);
|
|
// 更新券信息
|
Long couponId = record.getCouponId();
|
if (couponId == null) {
|
continue;
|
}
|
|
// 券列表
|
UserSystemCoupon userCoupon = userSystemCouponMapper.selectByPrimaryKey(couponId);
|
if (userCoupon == null)
|
continue;
|
|
Integer state = userCoupon.getState();
|
if (state != UserSystemCoupon.STATE_IN_USE)
|
return;
|
|
Date now = new Date();
|
Date endTime = userCoupon.getEndTime();
|
if (endTime != null && endTime.getTime() < now.getTime()) {
|
List<UserSystemCoupon> list = new ArrayList<UserSystemCoupon>();
|
list.add(userCoupon);
|
updateCounponInvalid(list);
|
continue;
|
}
|
|
// 退回券
|
UserSystemCoupon userSystemCoupon = new UserSystemCoupon();
|
userSystemCoupon.setId(userCoupon.getId());
|
userSystemCoupon.setGive(false);
|
userSystemCoupon.setUseTime(null);
|
userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
|
userSystemCoupon.setUpdateTime(new Date());
|
userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|
// 使用记录
|
UserSystemCouponRecord useRecord = userSystemCouponRecordService.getNearByUserCouponId(couponId);
|
if (useRecord != null) {
|
UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord();
|
useRecordUpdate.setId(useRecord.getId());
|
useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
|
useRecordUpdate.setUpdateTime(new Date());
|
userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate);
|
}
|
|
SystemCoupon systemCoupon = userCoupon.getSystemCoupon();
|
if (systemCoupon != null)
|
systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
|
if (systemCoupon == null)
|
continue;
|
|
// 退回消息
|
String couponName = systemCoupon.getName();
|
if (CouponTypeEnum.freeCouponGive == systemCoupon.getType()) {
|
couponName = "免单券";
|
} else if (CouponTypeEnum.rebatePercentCoupon == systemCoupon.getType()) {
|
couponName = "奖励券";
|
}
|
|
String beiZhu = "请到我的-福利中心查看";
|
SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
|
MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO();
|
msgOther.setType(MsgOtherGiveContentDTO.TYEP_COUPON);
|
msgOther.setTitle(couponName + "退回");
|
msgOther.setGiveType("你赠送的" + couponName + "未被成功领取");
|
msgOther.setGiveTime(sd.format(record.getGiveTime()));
|
msgOther.setReturnTime(sd.format(new Date()));
|
userOtherMsgNotificationService.tokenGiveMsg(record.getGiveUid(), beiZhu, msgOther);
|
}
|
}
|
|
@Override
|
public boolean getIncludeExchange(Long uid) {
|
// 过期券
|
updateInvalidSate(uid);
|
|
String percent = configService.get("exchange_rebate_percent");
|
if (StringUtil.isNullOrEmpty(percent))
|
percent = "35";
|
List<UserSystemCoupon> listCoupon = userSystemCouponMapper.getIncludeExchange(uid, Integer.parseInt(percent),
|
CouponTypeEnum.rebatePercentCoupon.name());
|
if (listCoupon == null || listCoupon.size() == 0)
|
return false;
|
return true;
|
}
|
|
@Override
|
public boolean getIncludeNotExchange(Long uid) {
|
// 过期券
|
updateInvalidSate(uid);
|
|
String percent = configService.get("exchange_rebate_percent");
|
if (StringUtil.isNullOrEmpty(percent))
|
percent = "35";
|
List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getIncludeNotExchange(uid,
|
Integer.parseInt(percent), CouponTypeEnum.rebatePercentCoupon.name());
|
if (listCoupon == null || listCoupon.size() == 0)
|
return false;
|
return true;
|
}
|
|
@Override
|
public List<UserSystemCouponVO> listIncludeNotExchange(Long uid) throws Exception {
|
// 过期券
|
updateInvalidSate(uid);
|
|
// 退回券
|
sendBackTimeOutCoupon(uid);
|
|
String percent = configService.get("exchange_rebate_percent");
|
if (StringUtil.isNullOrEmpty(percent))
|
percent = "35";
|
|
List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getIncludeNotExchange(uid,
|
Integer.parseInt(percent), CouponTypeEnum.rebatePercentCoupon.name());
|
if (listCoupon == null || listCoupon.size() == 0)
|
return null;
|
|
for (UserSystemCouponVO userCouponVO : listCoupon) {
|
String source = userCouponVO.getSource();
|
if (source != null && "奖励券天天抽".equals(source)) {
|
source = "天天抽";
|
}
|
|
SystemCoupon systemCoupon = userCouponVO.getSystemCoupon();
|
if (systemCoupon == null) {
|
continue; // 券信息不完整
|
}
|
|
systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
|
userCouponVO.setSource("来源：" + source);
|
userCouponVO.setCouponName(systemCoupon.getName());
|
userCouponVO.setCouponEffect(systemCoupon.getEffect());
|
userCouponVO.setCouponRule(systemCoupon.getRule());
|
userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink());
|
userCouponVO.setCouponPicture(systemCoupon.getPicture());
|
userCouponVO.setCouponPictureInvalid(systemCoupon.getPictureInvalid());
|
|
int differentDays = 0;
|
String couponTerm = "有效期：";
|
Date startTime = userCouponVO.getStartTime();
|
Date endTime = userCouponVO.getEndTime();
|
if (endTime != null && startTime != null) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
|
couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);
|
|
SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");
|
differentDays = DateUtil.daysBetween(sdf2.format(new Date()), sdf2.format(endTime)) + 1;
|
if (differentDays < 0) {
|
differentDays = 0;
|
}
|
}
|
userCouponVO.setCouponTerm(couponTerm);
|
|
// 剩余天数
|
Map<String, Object> remainDays = new HashMap<String, Object>();
|
remainDays.put("content", "还剩" + differentDays + "天过期");
|
String remainDaysFontColor = "";
|
|
Integer stateActivated = userCouponVO.getStateActivated();
|
if (stateActivated == null || stateActivated == 0) {
|
userCouponVO.setState(0);
|
userCouponVO.setCouponEffect("待激活");
|
userCouponVO.setCouponPicture(systemCoupon.getPictureInvalid());
|
remainDaysFontColor = "#CCCCCC";
|
} else {
|
userCouponVO.setCouponPicture(systemCoupon.getPicture());
|
remainDaysFontColor = "#F14242";
|
}
|
|
remainDays.put("fontColor", remainDaysFontColor);
|
userCouponVO.setRemainDays(remainDays);
|
}
|
|
return listCoupon;
|
}
|
|
@Override
|
public List<UserSystemCoupon> getFreeCouponByType(Long uid, String type) {
|
return userSystemCouponMapper.getFreeCouponByType(uid, type);
|
}
|
|
}
|
