From c5d38d650d2ac4101b1293a4f17346e7d5420076 Mon Sep 17 00:00:00 2001 From: huliguo <2023611923@qq.com> Date: 星期五, 04 七月 2025 20:39:58 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/2.0' into 2.0 --- ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/coupon/CouponServiceImpl.java | 239 +++++++++++++++++++++++++++++++++++++---------------------- 1 files changed, 149 insertions(+), 90 deletions(-) diff --git a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/coupon/CouponServiceImpl.java b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/coupon/CouponServiceImpl.java index 468865d..1cfad89 100644 --- a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/coupon/CouponServiceImpl.java +++ b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/coupon/CouponServiceImpl.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.exception.ServiceException; import com.ruoyi.common.core.utils.DateUtils; import com.ruoyi.common.core.utils.StringUtils; @@ -31,13 +32,15 @@ import com.ruoyi.system.api.service.RemoteConfigService; import com.ruoyi.system.api.service.RemoteGoodsService; import com.ruoyi.system.api.service.RemoteShopService; -import org.springframework.scheduling.annotation.Async; +import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.math.BigDecimal; +import java.time.LocalDateTime; import java.util.*; +import java.util.concurrent.CompletableFuture; import java.util.concurrent.TimeUnit; import java.util.function.Function; import java.util.stream.Collectors; @@ -58,28 +61,30 @@ @Resource private CouponRelGoodsService couponRelGoodsService; - + @Resource private CouponMapper couponMapper; - + @Resource private RemoteGoodsService remoteGoodsService; - + @Resource private CouponTotalService couponTotalService; - + + @Lazy @Resource private MemberService memberService; - + + @Lazy @Resource private MemberCouponService memberCouponService; - + @Resource private RemoteActivityService remoteActivityService; - + @Resource private MemberCouponRecordService memberCouponRecordService; - + @Resource private RemoteShopService remoteShopService; @@ -261,7 +266,7 @@ * @return void */ @Override - public void editMgtCoupon(MgtCouponEditDto mgtCouponEditDto){ + public void editMgtCoupon(MgtCouponEditDto mgtCouponEditDto){ //编辑优惠券 Coupon coupon; CouponTotal couponTotal; @@ -291,6 +296,7 @@ * 三:可修改 * 1、优惠券名称 * 2、宣传海报 + * 3、分享文案、分享图片 * 四:发放对象 * 1、未到发放时间都可以修改 * 2、已到发放时间,只有自定义时可修改,且只能增加用户 @@ -301,19 +307,19 @@ if(!coupon.getSendType().equals(mgtCouponEditDto.getSendType())){ throw new ServiceException("不能修改优惠券发放方式"); } - if(null != mgtCouponEditDto.getMoneyThreshold() && !coupon.getMoneyThreshold().equals(mgtCouponEditDto.getMoneyThreshold())){ + if(null != mgtCouponEditDto.getMoneyThreshold() && coupon.getMoneyThreshold().compareTo(mgtCouponEditDto.getMoneyThreshold()) != 0){ throw new ServiceException("不能修改优惠券金额"); } - if(null != mgtCouponEditDto.getDiscountMoney() && !coupon.getDiscountMoney().equals(mgtCouponEditDto.getDiscountMoney())){ + if(null != mgtCouponEditDto.getDiscountMoney() && coupon.getDiscountMoney().compareTo(mgtCouponEditDto.getDiscountMoney()) != 0){ throw new ServiceException("不能修改优惠券金额"); } - if(null != mgtCouponEditDto.getDiscountPercent() && !coupon.getDiscountPercent().equals(mgtCouponEditDto.getDiscountPercent())){ + if(null != mgtCouponEditDto.getDiscountPercent() && coupon.getDiscountPercent().compareTo(mgtCouponEditDto.getDiscountPercent()) != 0){ throw new ServiceException("不能修改优惠券折扣"); } - if(null != mgtCouponEditDto.getValidTimeType() && !coupon.getValidTimeType().equals(mgtCouponEditDto.getValidTimeType())){ + if(coupon.getSendType() == 2 && coupon.getSendTimeType() == 2 && mgtCouponEditDto.getSendTimeType() == 2 && System.currentTimeMillis() >= coupon.getSendTime().getTime() && null != mgtCouponEditDto.getValidTimeType() && !coupon.getValidTimeType().equals(mgtCouponEditDto.getValidTimeType())){ throw new ServiceException("不能修改优惠券适用期限类型"); } - if(null != mgtCouponEditDto.getValidTimeType() && coupon.getValidTimeType() == 1 && !coupon.getValidStartTime().equals(mgtCouponEditDto.getValidStartTime())){ + if(coupon.getSendType() == 2 && coupon.getSendTimeType() == 2 && mgtCouponEditDto.getSendTimeType() == 2 && System.currentTimeMillis() >= coupon.getSendTime().getTime() && null != mgtCouponEditDto.getValidTimeType() && coupon.getValidTimeType() == 1 && !coupon.getValidStartTime().equals(mgtCouponEditDto.getValidStartTime())){ throw new ServiceException("不能修改优惠券有效期开始时间"); } if(coupon.getSendType() == 2 && coupon.getSendTimeType() == 1 && mgtCouponEditDto.getSendTimeType() != 1){ @@ -322,12 +328,13 @@ if(coupon.getSendType() == 2 && coupon.getSendTimeType() == 2 && mgtCouponEditDto.getSendTimeType() != 2 && System.currentTimeMillis() <= coupon.getSendTime().getTime()){ throw new ServiceException("不能修改优惠券发放方式"); } - if(coupon.getSendType() == 2 && coupon.getSendTimeType() == 2 && mgtCouponEditDto.getSendTimeType() == 2 && !mgtCouponEditDto.getSendTime().equals(coupon.getSendTime()) && System.currentTimeMillis() <= coupon.getSendTime().getTime()){ + if(coupon.getSendType() == 2 && coupon.getSendTimeType() == 2 && mgtCouponEditDto.getSendTimeType() == 2 && System.currentTimeMillis() >= coupon.getSendTime().getTime()){ throw new ServiceException("不能修改优惠券发放时间"); } - if(coupon.getUseScope() == 1 && !coupon.getUseScope().equals(mgtCouponEditDto.getUseScope())){ + if(coupon.getSendType() == 2 && coupon.getSendTimeType() == 2 && mgtCouponEditDto.getSendTimeType() == 2 && System.currentTimeMillis() >= coupon.getSendTime().getTime() && coupon.getUseScope() == 1 && !coupon.getUseScope().equals(mgtCouponEditDto.getUseScope())){ throw new ServiceException("不能修改优惠券适用范围"); } + if(coupon.getUseScope() == 2 && coupon.getUseScope().equals(mgtCouponEditDto.getUseScope())){ List<String> relGoodsIdList = mgtCouponEditDto.getRelGoodsIdList(); List<CouponRelGoods> list = couponRelGoodsService.list(new QueryWrapper<CouponRelGoods>().eq("coupon_id", coupon.getCouponId()).eq("del_flag", 0)); @@ -340,10 +347,10 @@ if(coupon.getSendLimitFlag() == 0 && mgtCouponEditDto.getSendLimitFlag() != 0){ throw new ServiceException("不能修改优惠券发放数量限制"); } - if(coupon.getSendLimitFlag() == 1 && !coupon.getSendLimitNumber().equals(mgtCouponEditDto.getSendLimitNumber())){ + if(coupon.getSendLimitFlag() == 1 && mgtCouponEditDto.getSendLimitFlag() == 1 && coupon.getSendLimitNumber().compareTo(mgtCouponEditDto.getSendLimitNumber()) > 0){ throw new ServiceException("不能修改优惠券发放数量限制"); } - if(coupon.getLimitNumber().compareTo(mgtCouponEditDto.getLimitNumber()) < 0){ + if(coupon.getLimitNumber().compareTo(mgtCouponEditDto.getLimitNumber()) > 0){ throw new ServiceException("只能增加优惠券领取数量"); } List<CouponRelUser> list = couponRelUserService.list(new QueryWrapper<CouponRelUser>().eq("coupon_id", coupon.getCouponId()).eq("del_flag", 0)); @@ -360,9 +367,9 @@ throw new ServiceException("只能修改优惠发放对象"); } + couponRelUserService.deleteCouponRelByCouponId(coupon.getCouponId()); + couponRelGoodsService.deleteCouponRelByCouponId(coupon.getCouponId()); -// couponRelUserService.deleteCouponRelByCouponId(coupon.getCouponId()); -// couponRelGoodsService.deleteCouponRelByCouponId(coupon.getCouponId()); }else{ coupon = new Coupon(); String couponId = IdUtils.simpleUUID(); @@ -403,6 +410,8 @@ coupon.setRelationActivityType(mgtCouponEditDto.getRelationActivityType()); coupon.setRelationActivityId(mgtCouponEditDto.getRelationActivityId()); coupon.setPropagandaPoster(mgtCouponEditDto.getPropagandaPoster()); + coupon.setSharePassage(mgtCouponEditDto.getSharePassage()); + coupon.setSharePic(mgtCouponEditDto.getSharePic()); //指定发放优惠券不做发放数限制 if(coupon.getSendType()==2){ mgtCouponEditDto.setSendLimitFlag(0); @@ -431,7 +440,7 @@ coupon.setRelGoodsIds(relGoodsIds); } //判断是否指定用户 - List<Long> relUserIdList = null; + List<Long> relUserIdList; if(coupon.getSendTarget()==5&&coupon.getRelationType()==1&&!mgtCouponEditDto.getRelUserIdList().isEmpty()){ relUserIdList = mgtCouponEditDto.getRelUserIdList(); List<CouponRelUser> couponRelUserList = new ArrayList<>(); @@ -447,10 +456,12 @@ } couponRelUserService.saveBatch(couponRelUserList); coupon.setRelUserIds(userIdSj.toString()); + } else { + relUserIdList = null; } //处理优惠券发放 - if(coupon.getSendType()==2&&coupon.getSendTimeType()==1){ - sendCoupon(coupon,relUserIdList); + if(coupon.getSendFlag() == 0 && coupon.getSendType()==2&&coupon.getSendTimeType()==1){ + CompletableFuture.runAsync(()->sendCoupon(coupon,relUserIdList)); coupon.setSendFlag(1); this.saveOrUpdate(coupon); }else{ @@ -466,7 +477,6 @@ * @param relUserIdList * @return void */ - @Async protected void sendCoupon(Coupon coupon, List<Long> relUserIdList){ //1.手动领取2.全部用户3.会员用户4非会员用户5自定义 Date nowTime = new Date(); @@ -494,19 +504,23 @@ userIdList = relUserIdList; } } + //商户发送全部,则发送没有绑定的会员及绑定了当前商户端会员 + if(coupon.getCouponFrom() == 2 && sendTarget == 2){ + shopId = coupon.getShopId(); + userIdList = memberService.listIdBySendType2(shopId); + } + + if(userIdList!=null&&!userIdList.isEmpty()){ List<MemberCoupon> memberCouponList = new ArrayList<>(); MemberCoupon memberCoupon; Integer sendTotal = 0; Integer sendPerson = 0; - String memberCouponId; Integer sendUserTotal; for(Long userId : userIdList){ if(coupon.getCouponFrom()==2){ for(int i=0;i<coupon.getLimitNumber();i++){ - memberCouponId = IdUtils.simpleUUID(); memberCoupon = new MemberCoupon(); - memberCoupon.setId(memberCouponId); memberCoupon.setDelFlag(0); memberCoupon.setCouponId(coupon.getCouponId()); memberCoupon.setUserId(userId); @@ -556,56 +570,56 @@ memberCouponRecordService.updateMemberCouponRecord(coupon,userId,1); } }else{ - memberCouponId = IdUtils.simpleUUID(); - memberCoupon = new MemberCoupon(); - memberCoupon.setId(memberCouponId); - memberCoupon.setDelFlag(0); - memberCoupon.setCouponId(coupon.getCouponId()); - memberCoupon.setUserId(userId); - //memberCoupon.setShopId(coupon.getShopId()); - memberCoupon.setCouponType(coupon.getCouponType()); - if(coupon.getCouponType()==1){ - memberCoupon.setMoneyThreshold(coupon.getMoneyThreshold()); - memberCoupon.setDiscountMoney(coupon.getDiscountMoney()); - }else if(coupon.getCouponType()==2){ - memberCoupon.setDiscountPercent(coupon.getDiscountPercent()); - }else if(coupon.getCouponType()==3){ - memberCoupon.setDiscountMoney(coupon.getDiscountMoney()); - }else{ - memberCoupon.setRelGoodsIds(coupon.getRelGoodsIds()); - } - memberCoupon.setCouponStatus(coupon.getCouponStatus()); - memberCoupon.setCouponName(coupon.getCouponName()); - memberCoupon.setSendType(coupon.getSendType()); - memberCoupon.setSendTarget(coupon.getSendTarget()); - memberCoupon.setSendTimeType(coupon.getSendTimeType()); - memberCoupon.setSendTime(coupon.getSendTime()); - memberCoupon.setUseScope(coupon.getUseScope()); - if(memberCoupon.getUseScope()==2){ - memberCoupon.setRelGoodsIds(coupon.getRelGoodsIds()); - } - memberCoupon.setValidTimeType(coupon.getValidTimeType()); - memberCoupon.setValidStartTime(coupon.getValidStartTime()); - memberCoupon.setValidEndTime(coupon.getValidEndTime()); - memberCoupon.setValidDay(coupon.getValidDay()); - memberCoupon.setCouponFrom(coupon.getCouponFrom()); - memberCoupon.setReceiveTime(nowTime); - //有效期处理1.时间段2.领取之日起 - if(coupon.getValidTimeType()==1){ - memberCoupon.setDeadlineTime(coupon.getValidEndTime()); - }else if(coupon.getValidTimeType()==2){ - memberCoupon.setDeadlineTime(DateUtils.addDays(nowTime,coupon.getValidDay())); - } - memberCouponList.add(memberCoupon); - sendTotal = sendTotal + 1; - if(coupon.getSendType()==1){ - sendUserTotal = memberCouponService.totalMemberCouponByUserAndCoupon(userId,coupon.getCouponId()); - if(sendUserTotal!=null&&sendUserTotal>0){ + for (Integer i = 0; i < coupon.getLimitNumber(); i++) { + memberCoupon = new MemberCoupon(); + memberCoupon.setDelFlag(0); + memberCoupon.setCouponId(coupon.getCouponId()); + memberCoupon.setUserId(userId); + //memberCoupon.setShopId(coupon.getShopId()); + memberCoupon.setCouponType(coupon.getCouponType()); + if(coupon.getCouponType()==1){ + memberCoupon.setMoneyThreshold(coupon.getMoneyThreshold()); + memberCoupon.setDiscountMoney(coupon.getDiscountMoney()); + }else if(coupon.getCouponType()==2){ + memberCoupon.setDiscountPercent(coupon.getDiscountPercent()); + }else if(coupon.getCouponType()==3){ + memberCoupon.setDiscountMoney(coupon.getDiscountMoney()); }else{ - sendPerson = sendPerson + 1; + memberCoupon.setRelGoodsIds(coupon.getRelGoodsIds()); } + memberCoupon.setCouponStatus(coupon.getCouponStatus()); + memberCoupon.setCouponName(coupon.getCouponName()); + memberCoupon.setSendType(coupon.getSendType()); + memberCoupon.setSendTarget(coupon.getSendTarget()); + memberCoupon.setSendTimeType(coupon.getSendTimeType()); + memberCoupon.setSendTime(coupon.getSendTime()); + memberCoupon.setUseScope(coupon.getUseScope()); + if(memberCoupon.getUseScope()==2){ + memberCoupon.setRelGoodsIds(coupon.getRelGoodsIds()); + } + memberCoupon.setValidTimeType(coupon.getValidTimeType()); + memberCoupon.setValidStartTime(coupon.getValidStartTime()); + memberCoupon.setValidEndTime(coupon.getValidEndTime()); + memberCoupon.setValidDay(coupon.getValidDay()); + memberCoupon.setCouponFrom(coupon.getCouponFrom()); + memberCoupon.setReceiveTime(nowTime); + //有效期处理1.时间段2.领取之日起 + if(coupon.getValidTimeType()==1){ + memberCoupon.setDeadlineTime(coupon.getValidEndTime()); + }else if(coupon.getValidTimeType()==2){ + memberCoupon.setDeadlineTime(DateUtils.addDays(nowTime,coupon.getValidDay())); + } + memberCouponList.add(memberCoupon); + sendTotal = sendTotal + 1; + if(coupon.getSendType()==1){ + sendUserTotal = memberCouponService.totalMemberCouponByUserAndCoupon(userId,coupon.getCouponId()); + if(sendUserTotal!=null&&sendUserTotal>0){ + }else{ + sendPerson = sendPerson + 1; + } + } + memberCouponRecordService.updateMemberCouponRecord(coupon,userId,1); } - memberCouponRecordService.updateMemberCouponRecord(coupon,userId,1); } } memberCouponService.saveBatch(memberCouponList); @@ -644,17 +658,20 @@ userIdList = relUserIdList; } } + //商户发送全部,则发送没有绑定的会员及绑定了当前商户端会员 + if(coupon.getCouponFrom() == 2 && sendTarget == 2){ + shopId = coupon.getShopId(); + userIdList = memberService.listIdBySendType2(shopId); + } + if(relUserIdList!=null&&!relUserIdList.isEmpty()){ List<MemberCoupon> memberCouponList = new ArrayList<>(); MemberCoupon memberCoupon; Integer sendTotal = 0; Integer sendPerson = 0; - String memberCouponId; Integer sendUserTotal; for(Long userId : userIdList){ - memberCouponId = IdUtils.simpleUUID(); memberCoupon = new MemberCoupon(); - memberCoupon.setId(memberCouponId); memberCoupon.setDelFlag(0); memberCoupon.setCouponId(coupon.getCouponId()); memberCoupon.setUserId(userId); @@ -724,9 +741,9 @@ public void deleteMgtCoupon(MgtBaseGetDto mgtBaseGetDto){ Coupon coupon = this.getById(mgtBaseGetDto.getId()); CouponTotal couponTotal = couponTotalService.getById(mgtBaseGetDto.getId()); - if(couponTotal.getSendCount()!=null&&couponTotal.getSendCount()>0){ - throw new ServiceException(AppErrorConstant.COUPON_SENT_DEL); - } +// if(couponTotal.getSendCount()!=null&&couponTotal.getSendCount()>0){ +// throw new ServiceException(AppErrorConstant.COUPON_SENT_DEL); +// } coupon.setCouponStatus(-1); coupon.setDelFlag(1); coupon.setUpdateUserId(mgtBaseGetDto.getUserId()); @@ -865,6 +882,26 @@ } } } + } + String useLimit = ""; + for(MgtCouponAuditPageVo mgtCouponAuditPageVo : mgtCouponAuditPageVoList){ + useLimit = null; + //处理使用限制 + String couponType = mgtCouponAuditPageVo.getCouponType(); + if(couponType.equals("满减")){ + BigDecimal moneyThreshold = mgtCouponAuditPageVo.getMoneyThreshold(); + BigDecimal discountMoney = mgtCouponAuditPageVo.getDiscountMoney(); + useLimit = "满" + moneyThreshold.toString() + "减" + discountMoney.toString() + "元"; + } + if(couponType.equals("折扣")){ + BigDecimal discountPercent = mgtCouponAuditPageVo.getDiscountPercent(); + useLimit = discountPercent.toString() + "折"; + } + if(couponType.equals("代金")){ + BigDecimal discountMoney = mgtCouponAuditPageVo.getDiscountMoney(); + useLimit = discountMoney.toString(); + } + mgtCouponAuditPageVo.setUseLimit(useLimit); } return mgtCouponAuditPageVoList; } @@ -1095,9 +1132,9 @@ CouponTotal couponTotal; if(StringUtils.isNotBlank(merCouponEditDto.getCouponId())){ coupon = this.getById(merCouponEditDto.getCouponId()); - if(coupon.getAuditStatus()!=3){ - throw new ServiceException(AppErrorConstant.COUPON_AUDIT_EDIT); - } +// if(coupon.getAuditStatus()!=3){ +// throw new ServiceException(AppErrorConstant.COUPON_AUDIT_EDIT); +// } couponRelUserService.deleteCouponRelByCouponId(coupon.getCouponId()); couponRelGoodsService.deleteCouponRelByCouponId(coupon.getCouponId()); coupon.setCouponStatus(1); @@ -1225,7 +1262,6 @@ Coupon coupon; List<MemberCoupon> memberCouponList = new ArrayList<>(); MemberCoupon memberCoupon; - String memberCouponId; // 遍历生日礼物发送DTO列表 for(BirthdayGiftSendDto birthdayGiftSendDto : giftSendDtoList){ @@ -1239,8 +1275,6 @@ // 根据优惠券数量生成会员优惠券列表 for(int i=0;i<birthdayGiftSendDto.getCouponNumber();i++){ memberCoupon = new MemberCoupon(); - memberCouponId = IdUtils.simpleUUID(); - memberCoupon.setId(memberCouponId); memberCoupon.setDelFlag(0); memberCoupon.setCouponId(couponId); memberCoupon.setUserId(userId); @@ -1411,8 +1445,6 @@ } //生成用户优惠券 MemberCoupon memberCoupon = new MemberCoupon(); - String memberCouponId = IdUtils.simpleUUID(); - memberCoupon.setId(memberCouponId); memberCoupon.setDelFlag(0); memberCoupon.setCouponId(couponId); memberCoupon.setUserId(userId); @@ -1452,8 +1484,8 @@ }else if(coupon.getValidTimeType()==2){ memberCoupon.setDeadlineTime(DateUtils.addDays(new Date(),coupon.getValidDay())); } - memberCouponService.save(memberCoupon); memberCouponRecordService.updateMemberCouponRecord(coupon,userId,1); + memberCouponService.insert(memberCoupon); } /** @@ -1484,4 +1516,31 @@ metAuditCouponTotalVo.setRefuseTotal(refuseTotal); return metAuditCouponTotalVo; } + + @Override + public R endImmediately(MgtBaseGetDto mgtBaseGetDto) { + // 将优惠券状态置为禁用 定时发放类型每小时会检查启用中的没发放的 发送了的、立即发送类型的优惠券不管 + Coupon coupon = couponMapper.selectById(mgtBaseGetDto.getId()); + if (coupon == null || coupon.getDelFlag() != 0) { + return R.fail("该优惠券不存在"); + } + if (coupon.getCouponStatus()!=1){ + return R.fail("状态错误,该优惠券未在启用中"); + } + coupon.setCouponStatus(0);//设置为禁用 + coupon.setUpdateUserId(mgtBaseGetDto.getUserId()); + coupon.setUpdateTime(new Date()); + this.updateById(coupon); + return R.ok(); + } + + @Override + public List<LotteryEventCouponListVO> getLotteryEventCouponList() { + return this.getBaseMapper().getLotteryEventCouponList(); + } + + @Override + public List<LotteryEventCouponListVO> getLotteryEventCouponListByShopId(String shopId) { + return this.getBaseMapper().getLotteryEventCouponListByShopId(shopId); + } } -- Gitblit v1.7.1