From c036557db88c6297b9a626a892dce35c14ab8ee5 Mon Sep 17 00:00:00 2001
From: nickchange <126672920+nickchange@users.noreply.github.com>
Date: 星期四, 09 十一月 2023 18:30:31 +0800
Subject: [PATCH] 11.6

---
 cloud-server-activity/src/main/java/com/dsh/activity/controller/PointMercharsController.java |  116 ++++++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 100 insertions(+), 16 deletions(-)

diff --git a/cloud-server-activity/src/main/java/com/dsh/activity/controller/PointMercharsController.java b/cloud-server-activity/src/main/java/com/dsh/activity/controller/PointMercharsController.java
index f13ab2f..d1248d5 100644
--- a/cloud-server-activity/src/main/java/com/dsh/activity/controller/PointMercharsController.java
+++ b/cloud-server-activity/src/main/java/com/dsh/activity/controller/PointMercharsController.java
@@ -9,9 +9,11 @@
 import com.dsh.activity.feignclient.course.model.CoursePackage;
 import com.dsh.activity.feignclient.course.model.CoursePackagePaymentConfig;
 import com.dsh.activity.feignclient.model.*;
+import com.dsh.activity.feignclient.other.OperatorClient;
 import com.dsh.activity.feignclient.other.StoreClient;
 import com.dsh.activity.feignclient.other.model.Store;
 import com.dsh.activity.feignclient.other.model.StoreDetailOfCourse;
+import com.dsh.activity.feignclient.other.model.TOperatorCity;
 import com.dsh.activity.model.CoachChangeStateVO;
 import com.dsh.activity.model.PointMerchandiseIncomeVo;
 import com.dsh.activity.model.PointMerchandiseVo;
@@ -25,6 +27,7 @@
 import com.dsh.activity.util.StrUtils;
 import com.dsh.activity.util.TokenUtil;
 import com.dsh.activity.util.ToolUtil;
+import io.swagger.models.auth.In;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -116,6 +119,10 @@
         byId.setVerificationUserId(dto.getVerificationUserId());
         return userPointsMerchandiseService.updateById(byId);
     }
+    @Autowired
+    private OperatorClient operatorClient;
+    @Resource
+    private CouponCityService cityService;
     @ResponseBody
     @PostMapping("/base/pointMerchars/ticketList")
     public List<Map<String,Object>> ticketList(@RequestBody IntegralGoodsOfSearch ofSearch){
@@ -155,6 +162,49 @@
                     }
                     result.add(map);
                 }
+                if (Integer.parseInt(String.valueOf(map.get("useScope"))) == 1){
+                    result.add(map);
+                }
+                if (Integer.parseInt(String.valueOf(map.get("useScope"))) == 2){
+                    // 获取到优惠券id 查询这个优惠券指定了哪些城市
+                    Integer id1 = Integer.parseInt(String.valueOf(map.get("id")));
+                    // 获取到运营商管理的省和市
+                    List<TOperatorCity> cityByOperatorId = operatorClient.getCityByOperatorId(ofSearch.getObjId());
+                    // 拿到运营商市的code集合
+                    List<String> collect1 = cityByOperatorId.stream().filter(t -> t.getPid() != 0)
+                            .map(tOperatorCity -> Integer.toString(tOperatorCity.getCode()))
+                            .collect(Collectors.toList());
+                    List<CouponCity> couponId = cityService.list(new QueryWrapper<CouponCity>().eq("couponId", id1));
+                    // 先判断优惠券管理的市  运营商是否有
+                    List<String> collect3 = couponId.stream().map(CouponCity::getCityCode)
+                            .collect(Collectors.toList());
+                    // 优惠券指定的省
+                    List<String> collect4 = couponId.stream().map(CouponCity::getCityCode)
+                            .collect(Collectors.toList());
+                    if (!Collections.disjoint(collect3, collect4)){
+                        result.add(map);
+                    }else{
+                        // 如果没有交集 那么还需要判断运营商是否管理了整个省
+
+
+                    }
+                }
+                if (Integer.parseInt(String.valueOf(map.get("useScope"))) == 3){
+                    // 获取到优惠券id 查询这个优惠券指定了哪些门店
+                    Integer id3 = Integer.parseInt(String.valueOf(map.get("id")));
+                    // 当前运营商管理的门店ids
+                    List<Integer> storeIds = ofSearch.getStoreIds();
+                    // 优惠券指定的门店
+                    List<Integer> collect5 = cstoreService.list(new QueryWrapper<CouponStore>().eq("couponId",id3)
+                            .in("storeId", storeIds)).stream().map(CouponStore::getStoreId)
+                            .collect(Collectors.toList());
+                    // 判断两个集合是否相交
+                    // 比较两个集合中是否有相同的元素;当两个集合中没有相同元素时返回true,
+                    // 当有相同元素时返回false。
+                    if (!Collections.disjoint(collect5, storeIds)){
+                        result.add(map);
+                    }
+                }
             }
         } else {
             result=result1;
@@ -193,10 +243,11 @@
                 String endTime = (String) stringObjectMap.get("endTime");
                 stringObjectMap.put("timeValue",startTime + "至"+endTime);
                 int count1 = upmseService.count(new LambdaQueryWrapper<UserPointsMerchandise>()
-                        .eq(UserPointsMerchandise::getPointsMerchandiseId, o));
-                int count2 = upmseService.count(new LambdaQueryWrapper<UserPointsMerchandise>()
                         .eq(UserPointsMerchandise::getPointsMerchandiseId, o)
                         .eq(UserPointsMerchandise::getStatus,2));
+                int count2 = upmseService.count(new LambdaQueryWrapper<UserPointsMerchandise>()
+                        .eq(UserPointsMerchandise::getPointsMerchandiseId, o)
+                        );
                 stringObjectMap.put("hasExchangeQty",count1);
                 stringObjectMap.put("hasPickQty",count2);
 
@@ -221,11 +272,24 @@
 
     @ResponseBody
     @PostMapping("/base/pointMerchars/convertGoods")
-    public List<IntegralCommodity> getConvertibleGoods(){
+    public List<IntegralCommodity> getConvertibleGoods(@RequestBody Location location) throws Exception {
         List<IntegralCommodity> commodity = new ArrayList<>();
+
+        Map<String, String> geocode = gdMapGeocodingUtil.geocode(location.getLon(), location.getLat());
+        String provinceCode = geocode.get("provinceCode");
+        String cityCode = geocode.get("cityCode");
+
+
+        List<PointsMerchandiseCity> cityCode1 = pmdsCityService.list(new QueryWrapper<PointsMerchandiseCity>().eq("cityCode", cityCode));
+        List<Integer> cIds = new ArrayList<>();
+        for (PointsMerchandiseCity pointsMerchandiseCity : cityCode1) {
+            cIds.add(pointsMerchandiseCity.getPointsMerchandiseId());
+        }
+
+
         List<PointsMerchandise> merchandises = pmdsService.list(new QueryWrapper<PointsMerchandise>()
                 .eq("state",1)
-                .eq("shelves",1)
+                .eq("shelves",1).in("id",cIds)
                 .gt("endTime",new Date()));
         if (merchandises.size() > 0){
             for (PointsMerchandise merchandise : merchandises) {
@@ -508,10 +572,13 @@
 
 //                detailsVo.setGoodId(coursePackage.getId());
                 detailsVo.setGoodId(merchandise.getId());
-                List<String> list1 = new ArrayList<>();
-                list1.add(coursePackage.getCoverDrawing());
-                list1.addAll(Arrays.asList(StrUtils.splitStr2StrArr(coursePackage.getDetailDrawing(), ",")));
-                detailsVo.setPics(list1);
+//                List<String> list1 = new ArrayList<>();
+//                list1.add(coursePackage.getCoverDrawing());
+//                list1.addAll(Arrays.asList(StrUtils.splitStr2StrArr(coursePackage.getDetailDrawing(), ",")));
+
+                String productImages = merchandise.getProductImages();
+                String[] list1 = productImages.split(",");
+                detailsVo.setPics(Arrays.asList(list1));
                 Collections.sort(detailsVo.getPics(), (s1, s2) -> {
                     if (s1.equals(coursePackage.getCoverDrawing())) {
                         return -1; // s1排在前面
@@ -701,12 +768,17 @@
         List<ExchangeDetailsResponse> responses = new ArrayList<>();
         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
         List<UserPointsMerchandise> pointsMerchandises = upmseService.list(new QueryWrapper<UserPointsMerchandise>()
-                .eq("userId",appUserId ));
+                .eq("userId",appUserId ).eq("payStatus",2));
 
 
-        List<UserCoupon> userCoupons = userCouponService.list(new QueryWrapper<UserCoupon>().eq("userId", appUserId));
-
-
+        List<Coupon> list1 = couponService.list();
+        List<Integer> ids = new ArrayList<>();
+        for (Coupon coupon : list1) {
+            if (coupon.getDistributionMethod()==1) {
+                ids.add(coupon.getId());
+            }
+        }
+        List<UserCoupon> userCoupons = userCouponService.list(new QueryWrapper<UserCoupon>().eq("userId", appUserId).in("couponId",ids));
         if (pointsMerchandises.size() > 0 ){
             for (UserPointsMerchandise pointsMerchandise : pointsMerchandises) {
                 PointsMerchandise merchandise = pmdsService.getById(pointsMerchandise.getPointsMerchandiseId());
@@ -860,8 +932,9 @@
 
         if (userCoupons.size()>0){
             for (UserCoupon userCoupon : userCoupons) {
+
                 Coupon c = couponService.getById(userCoupon.getCouponId());
-                if (c==null){
+                if (c==null|| c.getRedemptionMethod()==null){
                     continue;
                 }
 
@@ -1169,7 +1242,9 @@
 
 
     @PostMapping("/base/pointMerchars/updateDetailsUserPointMercase")
-    public void updateDetailsUserPointMercase(@RequestBody UserPointsMerchandise merchandise){
+    public void  updateDetailsUserPointMercase(@RequestBody UserPointsMerchandise merchandise){
+        merchandise.setUserId(null);
+        merchandise.setPointsMerchandiseId(null);
         upmseService.updateById(merchandise);
     }
 
@@ -1372,7 +1447,16 @@
 
     @PostMapping("/base/pointMerchars/queryPointMerchaseById")
     public PointsMerchandise queryPointMerchaseById(@RequestBody Integer id){
-        return pmdsService.getById(id);
+        PointsMerchandise byId = pmdsService.getById(id);
+        int count1 = upmseService.count(new LambdaQueryWrapper<UserPointsMerchandise>()
+                .eq(UserPointsMerchandise::getPointsMerchandiseId, byId.getId())
+                .eq(UserPointsMerchandise::getStatus,2));
+        int count2 = upmseService.count(new LambdaQueryWrapper<UserPointsMerchandise>()
+                .eq(UserPointsMerchandise::getPointsMerchandiseId, byId.getId())
+        );
+        byId.setPickUpQuantity3(count2);
+        byId.setPickUpQuantity4(count1);
+        return byId;
     }
 
     @PostMapping("/base/pointMerchars/getshopName")
@@ -1535,7 +1619,7 @@
     @PostMapping("/base/pointMerchars/add")
     public Integer add(@RequestBody PointsMerchandise pointsMerchandise){
         Integer storeId = pointsMerchandise.getShelves();
-        pointsMerchandise.setShelves(2);
+        pointsMerchandise.setShelves(1);
         boolean save = pmdsService.save(pointsMerchandise);
         if(save && ToolUtil.isNotEmpty(storeId) && pointsMerchandise.getType()==2){
             PointsMerchandiseStore pointsMerchandiseStore = new PointsMerchandiseStore();

--
Gitblit v1.7.1