From b0b52cbabf7a4bc8e00fc328d14ac05336d0221e Mon Sep 17 00:00:00 2001
From: jiangqs <jiangqs>
Date: 星期六, 15 七月 2023 20:07:44 +0800
Subject: [PATCH] 员工端

---
 ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberCouponServiceImpl.java |  105 +++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 102 insertions(+), 3 deletions(-)

diff --git a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberCouponServiceImpl.java b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberCouponServiceImpl.java
index df39976..e127461 100644
--- a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberCouponServiceImpl.java
+++ b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberCouponServiceImpl.java
@@ -1,21 +1,29 @@
 package com.ruoyi.member.service.impl.member;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ruoyi.common.core.exception.ServiceException;
+import com.ruoyi.common.core.utils.StringUtils;
+import com.ruoyi.member.domain.dto.AppMemberCouponPageDto;
+import com.ruoyi.member.domain.vo.AppMemberCouponPageVo;
 import com.ruoyi.member.mapper.member.MemberCouponMapper;
 import com.ruoyi.member.service.member.MemberCouponService;
 import com.ruoyi.system.api.constant.AppErrorConstant;
+import com.ruoyi.system.api.domain.dto.MgtBaseBathDto;
 import com.ruoyi.system.api.domain.poji.goods.Goods;
 import com.ruoyi.system.api.domain.poji.member.MemberCoupon;
 import com.ruoyi.system.api.domain.vo.AppMemberCouponVo;
 import com.ruoyi.system.api.domain.vo.MerVerifyCouponGetVo;
+import com.ruoyi.system.api.domain.vo.MgtSimpleShopVo;
 import com.ruoyi.system.api.service.RemoteGoodsService;
+import com.ruoyi.system.api.service.RemoteShopService;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -33,6 +41,9 @@
 
     @Resource
     private RemoteGoodsService remoteGoodsService;
+
+    @Resource
+    private RemoteShopService remoteShopService;
 
 
     /**
@@ -88,6 +99,7 @@
         } else {
             merVerifyCouponGetVo.setCouponFrom("平台");
         }
+        merVerifyCouponGetVo.setMemberCoupon(memberCoupon);
         return merVerifyCouponGetVo;
     }
 
@@ -108,7 +120,7 @@
             throw new ServiceException(AppErrorConstant.COUPON_EXPIRED);
         }else if(memberCoupon.getCouponStatus()==2){
             throw new ServiceException(AppErrorConstant.COUPON_USED);
-        }else if(memberCoupon.getCouponStatus()!=0){
+        }else if(memberCoupon.getCouponStatus()==-1){
             throw new ServiceException(AppErrorConstant.COUPON_NO_FIND);
         }
         if(memberCoupon.getCouponType()!=4){
@@ -150,4 +162,91 @@
         Integer total = this.count(queryWrapper);
         return total;
     }
+
+    /**
+     * @description 用户分页获取已领取优惠券列表
+     * @author  jqs
+     * @date    2023/7/11 16:25
+     * @param page
+     * @param appMemberCouponPageDto
+     * @return  List<AppMemberCouponPageVo>
+     */
+    @Override
+    public List<AppMemberCouponPageVo> pageAppUserGetCoupon(Page page, AppMemberCouponPageDto appMemberCouponPageDto){
+        List<AppMemberCouponPageVo> memberCouponPageVoList = memberCouponMapper.pageAppUserGetCoupon(page, appMemberCouponPageDto);
+        if(!memberCouponPageVoList.isEmpty()){
+            String relGoodsIds;
+            List<Goods> goodsList;
+            List<String> goodsLimitList = null;
+            HashSet<Long> shopIdSet = new HashSet<>();
+            for(AppMemberCouponPageVo appGetAbleCouponPageVo : memberCouponPageVoList){
+                shopIdSet.add(appGetAbleCouponPageVo.getShopId());
+            }
+            String shopJoinedString = String.join(",", shopIdSet.stream().map(Object::toString).collect(Collectors.toList()));
+            MgtBaseBathDto mgtBaseBathDto = new MgtBaseBathDto();
+            mgtBaseBathDto.setIds(shopJoinedString);
+            List<MgtSimpleShopVo> simpleShopVoList = remoteShopService.listShopSimpleVoByIds(mgtBaseBathDto).getData();
+            Map<Long, MgtSimpleShopVo> shopMap = simpleShopVoList.stream()
+                    .collect(Collectors.toMap(MgtSimpleShopVo::getShopId, Function.identity()));
+            for(AppMemberCouponPageVo appGetAbleCouponPageVo : memberCouponPageVoList){
+                relGoodsIds = appGetAbleCouponPageVo.getRelGoodsIds();
+                if(StringUtils.isNotBlank(relGoodsIds)){
+                    goodsList = remoteGoodsService.listGoodsByGoodsId(relGoodsIds).getData();
+                    if(!goodsList.isEmpty()){
+                        goodsLimitList = goodsList.stream().map(goods -> {
+                            String goodsName = goods.getGoodsName();
+                            goodsName = "限制" + goodsName + "适用";
+                            return goodsName;
+                        }).collect(Collectors.toList());
+                    }
+                }else{
+                    goodsLimitList = new ArrayList<>();
+                    if(appGetAbleCouponPageVo.getShopId()!=null){
+                        goodsLimitList.add(shopMap.get(appGetAbleCouponPageVo.getShopId()).getShopName()+"通用");
+                    }else{
+                        goodsLimitList.add("全场通用");
+                    }
+                }
+                appGetAbleCouponPageVo.setGoodsLimitList(goodsLimitList);
+                appGetAbleCouponPageVo.setVerifyShopName(shopMap.get(appGetAbleCouponPageVo.getShopId()).getShopName());
+            }
+        }
+        return memberCouponPageVoList;
+    }
+
+    /**
+     * @description  定时检查优惠券过期
+     * @author  jqs
+     * @date    2023/7/12 19:19
+     * @param
+     * @return  void
+     */
+    @Override
+    public void timingCheckMemberCoupon(){
+        memberCouponMapper.timingCheckMemberCoupon();
+    }
+
+    /**
+     * @description  使用优惠券
+     * @author  jqs
+     * @date    2023/7/13 19:38
+     * @param memberCouponIds
+     * @return  void
+     */
+    @Override
+    public void useMemberCoupon(String memberCouponIds){
+        memberCouponMapper.useMemberCoupon(memberCouponIds);
+    }
+
+    /**
+     * @description  使用优惠券
+     * @author  jqs
+     * @date    2023/7/13 19:38
+     * @param memberCouponIds
+     * @return  void
+     */
+    @Override
+    public void backMemberCoupon(String memberCouponIds){
+        memberCouponMapper.backMemberCoupon(memberCouponIds);
+    }
 }

--
Gitblit v1.7.1