From 1a3801b7316b0a23b6d3924eb4fbb023b1edef83 Mon Sep 17 00:00:00 2001 From: 44323 <443237572@qq.com> Date: 星期二, 07 十一月 2023 10:30:14 +0800 Subject: [PATCH] 后台bug修改 --- cloud-server-activity/src/main/java/com/dsh/activity/controller/CouponController.java | 101 +++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 86 insertions(+), 15 deletions(-) diff --git a/cloud-server-activity/src/main/java/com/dsh/activity/controller/CouponController.java b/cloud-server-activity/src/main/java/com/dsh/activity/controller/CouponController.java index 63da441..7b459a7 100644 --- a/cloud-server-activity/src/main/java/com/dsh/activity/controller/CouponController.java +++ b/cloud-server-activity/src/main/java/com/dsh/activity/controller/CouponController.java @@ -16,10 +16,12 @@ import com.dsh.activity.feignclient.account.model.TStoreStaff; import com.dsh.activity.feignclient.model.CouponExamineListSearch; import com.dsh.activity.feignclient.model.CouponListOfSearch; +import com.dsh.activity.feignclient.other.OperatorClient; import com.dsh.activity.feignclient.other.RegionClient; import com.dsh.activity.feignclient.other.StoreClient; import com.dsh.activity.feignclient.other.model.CityDataAndProvinceDataVo; import com.dsh.activity.feignclient.other.model.Store; +import com.dsh.activity.feignclient.other.model.TOperatorCity; import com.dsh.activity.model.CouponListVo; import com.dsh.activity.model.CouponRecordQuery; import com.dsh.activity.model.request.CommodityRequest; @@ -38,6 +40,7 @@ import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; +import org.checkerframework.checker.units.qual.A; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -97,7 +100,7 @@ @ResponseBody @PostMapping("/coupon/queryCouponByUser/{userId}") public List<Integer> queryCouponByUser(@PathVariable("userId") Integer userId){ - List<Coupon> list = couponService.list(new QueryWrapper<Coupon>().eq("distributionMethod", 2) + List<Coupon> list = couponService.list(new QueryWrapper<Coupon>().eq("distributionMethod", 2).eq("userPopulation",2) .le("startTime", new Date()).ge("endTime", new Date()).eq("auditStatus", 2) .eq("state", 1)); @@ -259,27 +262,80 @@ } - + @Autowired + private OperatorClient operatorClient; @ResponseBody @PostMapping("/base/coupon/queryCouponListSearch") public List<Map<String,Object>> getCouponListOfSearch(@RequestBody CouponListOfSearch ofSearch){ List<Map<String, Object>> mapList1 = couponService.queryCouponListOfSearch(ofSearch); List<Map<String, Object>> mapList = new ArrayList<>(); - - if(ofSearch.getStoreId()!=null){ + if (ofSearch.getStoreIds()==null){ + ArrayList<Integer> list = new ArrayList<>(); + ofSearch.setStoreIds(list); + } + if(ofSearch.getStoreId()!=null || ofSearch.getStoreIds().size()!=0){ for (Map<String, Object> map : mapList1) { - List<CouponStore> id = couStoreService.list(new LambdaQueryWrapper<CouponStore>().eq(CouponStore::getCouponId, map.get("id").toString())); - List<Integer> collect = id.stream().map(CouponStore::getStoreId).collect(Collectors.toList()); - if(collect.size()==0){ - collect.add(-1); - } - if(collect.contains(ofSearch.getStoreId())){ - if(collect.size()>1){ - map.put("size",1); - }else { - map.put("size",0); + // 如果当前登陆人是运营商 只能查看平台添加的优惠券应只展示使用范围为全国通用、 + // 指定城市有运营商管辖的、指定门店有运营商旗下门店 + if (ofSearch.getObjType()== 2){ + if (Integer.parseInt(String.valueOf(map.get("useScope"))) == 1){ + mapList.add(map); } - mapList.add(map); + if (Integer.parseInt(String.valueOf(map.get("useScope"))) == 2){ + // 获取到优惠券id 查询这个优惠券指定了哪些城市 + Integer id = Integer.parseInt(String.valueOf(map.get("id"))); + // 获取到运营商管理的省和市 + List<TOperatorCity> cityByOperatorId = operatorClient.getCityByOperatorId(ofSearch.getOperatorId()); + // 拿到运营商市的code集合 + List<String> collect = 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", id)); + // 先判断优惠券管理的市 运营商是否有 + List<String> collect1 = couponId.stream().map(CouponCity::getCityCode) + .collect(Collectors.toList()); + // 优惠券指定的省 + List<String> collect2 = couponId.stream().map(CouponCity::getCityCode) + .collect(Collectors.toList()); + if (!Collections.disjoint(collect, collect1)){ + mapList.add(map); + }else{ + // 如果没有交集 那么还需要判断运营商是否管理了整个省 + + + } + } + if (Integer.parseInt(String.valueOf(map.get("useScope"))) == 3){ + // 获取到优惠券id 查询这个优惠券指定了哪些门店 + Integer id = Integer.parseInt(String.valueOf(map.get("id"))); + // 当前运营商管理的门店ids + List<Integer> storeIds = ofSearch.getStoreIds(); + // 优惠券指定的门店 + List<Integer> collect = couStoreService.list(new QueryWrapper<CouponStore>().eq("couponId",id) + .in("storeId", storeIds)).stream().map(CouponStore::getStoreId) + .collect(Collectors.toList()); + // 判断两个集合是否相交 + // 比较两个集合中是否有相同的元素;当两个集合中没有相同元素时返回true, + // 当有相同元素时返回false。 + if (!Collections.disjoint(collect, storeIds)){ + mapList.add(map); + } + } + }else{ + List<CouponStore> id = couStoreService.list(new LambdaQueryWrapper<CouponStore>() + .eq(CouponStore::getCouponId, map.get("id").toString())); + List<Integer> collect = id.stream().map(CouponStore::getStoreId).collect(Collectors.toList()); + if(collect.size()==0){ + collect.add(-1); + } + if(collect.contains(ofSearch.getStoreId())){ + if(collect.size()>1){ + map.put("size",1); + }else { + map.put("size",0); + } + mapList.add(map); + } } } }else { @@ -571,6 +627,21 @@ } boolean save = couponService.save(coupon); + // 自动发券 + if (dataVo.getDistributionMethod() == 3){ + // 判断用户人群 再判断限领数量 + switch (dataVo.getUserGroup()){ + case 1: + + break; + case 2: + + break; + case 3: + + break; + } + } if (save){ if (dataVo.getCompany() == 3){ String[] split = dataVo.getStoreIds().split(","); -- Gitblit v1.7.1