package com.ruoyi.account.service.impl;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.account.api.vo.PaymentUserCouponVo;
|
import com.ruoyi.account.mapper.UserCouponMapper;
|
import com.ruoyi.account.api.model.UserCoupon;
|
import com.ruoyi.account.service.UserCouponService;
|
import com.ruoyi.other.api.domain.CouponInfo;
|
import com.ruoyi.other.api.feignClient.CouponInfoClient;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
import static org.aspectj.util.LangUtil.split;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author luodangjia
|
* @since 2024-11-21
|
*/
|
@Service
|
public class UserCouponServiceImpl extends ServiceImpl<UserCouponMapper, UserCoupon> implements UserCouponService {
|
|
@Resource
|
private CouponInfoClient couponInfoClient;
|
|
|
|
/**
|
* 获取支付页面的优惠券列表数据
|
* @param userId
|
* @return
|
*/
|
@Override
|
public List<PaymentUserCouponVo> getUserCoupon(Long userId, Integer type) {
|
List<UserCoupon> list = this.list(new LambdaQueryWrapper<UserCoupon>().eq(UserCoupon::getAppUserId, userId).eq(UserCoupon::getDelFlag, 0)
|
.isNull(UserCoupon::getUseTime).gt(UserCoupon::getEndTime, LocalDateTime.now()).last(" and now() between start_time and end_time"));
|
|
|
List<CouponInfo> couponInfoList = new ArrayList<>();
|
for (String jsonStr : list.stream().map(UserCoupon::getCouponInfo).collect(Collectors.toList())) {
|
CouponInfo couponInfo = JSONObject.parseObject(jsonStr, CouponInfo.class);
|
couponInfoList.add(couponInfo);
|
}
|
//构建返回数据
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy.MM.dd HH:mm");
|
List<PaymentUserCouponVo> infoVoList = new ArrayList<>();
|
for (UserCoupon userCoupon : list) {
|
CouponInfo couponInfo = couponInfoList.stream().filter(s -> s.getId().equals(userCoupon.getCouponId())).findFirst().get();
|
//排除商品券（商品券线下领取）
|
if(4 == couponInfo.getCouponType()){
|
continue;
|
}
|
PaymentUserCouponVo couponInfoVo = new PaymentUserCouponVo();
|
couponInfoVo.setId(userCoupon.getId().toString());
|
couponInfoVo.setName(couponInfo.getCouponName());
|
couponInfoVo.setCouponType(couponInfo.getCouponType());
|
couponInfoVo.setConditionAmount(couponInfo.getConditionAmount());
|
couponInfoVo.setDiscountAmount(couponInfo.getDiscountAmount());
|
couponInfoVo.setMoneyAmount(couponInfo.getMoneyAmount());
|
couponInfoVo.setDiscount(couponInfo.getDiscount());
|
if(null != userCoupon.getStartTime()){
|
couponInfoVo.setPeriodStartTime(userCoupon.getStartTime().format(formatter));
|
couponInfoVo.setPeriodEndTime(userCoupon.getEndTime().format(formatter));
|
}
|
String forGoodIds = couponInfo.getForGoodIds();
|
String[] split = forGoodIds.split(",");
|
if("-1".equals(forGoodIds)){
|
couponInfoVo.setForGoodIds(null);
|
}else{
|
couponInfoVo.setForGoodIds(Arrays.asList(split));
|
}
|
couponInfoVo.setAvailable(false);
|
infoVoList.add(couponInfoVo);
|
}
|
return infoVoList;
|
}
|
}
|
