From acad524bfb7f376c09ff8e6600fab207780156e1 Mon Sep 17 00:00:00 2001 From: 44323 <443237572@qq.com> Date: 星期四, 23 十一月 2023 18:46:05 +0800 Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/PlayPai --- cloud-server-activity/src/main/java/com/dsh/activity/controller/CouponController.java | 79 +++++++++++++++++++++++++-------------- 1 files changed, 50 insertions(+), 29 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 1e8866d..8958ca7 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,7 +16,6 @@ import com.dsh.activity.feignclient.account.StudentClient; import com.dsh.activity.feignclient.account.model.AppUserByNameAndPhoneDTO; import com.dsh.activity.feignclient.account.model.TCityManager; -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.model.TAppUser; @@ -25,6 +24,7 @@ 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.StoreInfoDto; import com.dsh.activity.feignclient.other.model.TOperatorCity; import com.dsh.activity.model.CouponListVo; import com.dsh.activity.model.CouponRecordQuery; @@ -44,6 +44,7 @@ import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; +import io.swagger.models.auth.In; import org.checkerframework.checker.units.qual.A; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -86,6 +87,7 @@ private StoreClient stoClient; + @Resource private RegionClient regionClient; @@ -106,7 +108,9 @@ @ResponseBody @PostMapping("/coupon/queryCouponByUser/{userId}") public List<Integer> queryCouponByUser(@PathVariable("userId") Integer userId){ - List<Coupon> list = couponService.list(new QueryWrapper<Coupon>().eq("distributionMethod", 2).eq("userPopulation",2) + + System.err.println("到达了赠送优惠价"); + List<Coupon> list = couponService.list(new QueryWrapper<Coupon>().eq("distributionMethod", 2) .le("startTime", new Date()).ge("endTime", new Date()).eq("auditStatus", 2) .eq("state", 1)); @@ -173,6 +177,35 @@ try { Coupon coupon = couponService.getById(id); return coupon; + }catch (Exception e){ + e.printStackTrace(); + return null; + } + } + + + @Autowired + private UserCouponService userCouponService; + @ResponseBody + @PostMapping("/coupon/queryCouponByUid") + public List<Coupon> queryCouponByUid(@RequestBody Integer uid){ + try { + LocalDateTime currentTime = LocalDateTime.now(); + LocalDateTime oneMinuteAgo = currentTime.minusSeconds(20); + + List<UserCoupon> list = userCouponService.list(new QueryWrapper<UserCoupon>().eq("userId", uid).ge("insertTime", oneMinuteAgo)); + List<Integer> ids = new ArrayList<>(); + for (UserCoupon userCoupon : list) { + ids.add(userCoupon.getCouponId()); + } + + if (ids.size()>0){ + List<Coupon> userId = couponService.list(new QueryWrapper<Coupon>().in("id",ids)); + return userId; + + } + + return null; }catch (Exception e){ e.printStackTrace(); return null; @@ -274,6 +307,7 @@ @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.getStoreIds()==null){ ArrayList<Integer> list = new ArrayList<>(); @@ -291,7 +325,7 @@ // 获取到优惠券id 查询这个优惠券指定了哪些城市 Integer id = Integer.parseInt(String.valueOf(map.get("id"))); // 获取到运营商管理的省和市 - List<TOperatorCity> cityByOperatorId = operatorClient.getCityByOperatorId(ofSearch.getOperatorId()); + List<TOperatorCity> cityByOperatorId = ofSearch.getOperatorCities(); // 拿到运营商市的code集合 List<String> collect = cityByOperatorId.stream().filter(t -> t.getPid() != 0) .map(tOperatorCity -> Integer.toString(tOperatorCity.getCode())) @@ -365,12 +399,11 @@ @ResponseBody @PostMapping("/base/coupon/queryCouponListSearch1") public List<Map<String,Object>> getCouponListOfSearch1(@RequestBody CouponListOfSearch ofSearch){ + // 查询全国通用的优惠券和包含指定门店的优惠券 List<Map<String, Object>> mapList = couponService.queryCouponListOfSearch1(ofSearch); - Date currentDate = new Date(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String currentDateStr = sdf.format(currentDate); - // Iterate over the mapList and remove entries where endTime is less than the current date Iterator<Map<String, Object>> iterator = mapList.iterator(); while (iterator.hasNext()) { @@ -407,11 +440,7 @@ Integer publisherType = (Integer) stringObjectMap.get("publisherType"); if (publisherType!=null) { if (publisherType == 1) { - Integer cityManagerId = (Integer) stringObjectMap.get("cityManagerId"); - TCityManager byId = citClient.getById(cityManagerId); - stringObjectMap.put("province", byId.getProvince()); - stringObjectMap.put("city", byId.getCity()); } } } @@ -430,11 +459,7 @@ couponInfo.put("id",coupon.getId()); couponInfo.put("auditStatus",coupon.getAuditStatus()); couponInfo.put("publisherType",coupon.getPublisherType()); - if (coupon.getPublisherType() == 1){ - TCityManager byId = citClient.getById(coupon.getCityManagerId()); - couponInfo.put("province",byId.getProvince()); - couponInfo.put("city",byId.getCity()); - } + couponInfo.put("name",coupon.getName()); couponInfo.put("type",coupon.getType()); JSONObject jsonObject = JSON.parseObject(coupon.getContent()); @@ -508,14 +533,16 @@ List<CouponStore> list = couStoreService.list(new LambdaQueryWrapper<CouponStore>() .eq(CouponStore::getCouponId,coupon.getId())); if (list.size() > 0){ + // 获取门店ids List<Integer> collect = list.stream().map(CouponStore::getStoreId).collect(Collectors.toList()); List<Store> storeList = stoClient.queryStoreByIds(collect); if (storeList.size() > 0){ for (Store store : storeList) { - TStoreStaff list1 = stoStaClient.baseInfo(store.getStoreStaffId()); + + StoreInfoDto storeInfo = stoClient.getStoreInfo(store.getStoreStaffId()); HashMap<String, Object> stringObjectHashMap = new HashMap<>(); stringObjectHashMap.put("procity",store.getProvince()+store.getCity()); - stringObjectHashMap.put("storeAccount",list1.getName()+"+"+list1.getPhone()); + stringObjectHashMap.put("storeAccount",storeInfo.getInfo()); stringObjectHashMap.put("storeName",store.getName()); maps.add(stringObjectHashMap); } @@ -580,10 +607,7 @@ case 1: coupon.setIntegral(BigDecimal.valueOf(dataVo.getRequiredPoints())); break; - case 2: - coupon.setCash(dataVo.getRequiredCash()); - coupon.setIntegral(BigDecimal.valueOf(dataVo.getRequiredPoints())); - break; + case 3: coupon.setCash(dataVo.getRequiredCash()); break; @@ -618,21 +642,18 @@ } if (dataVo.getUserType() == 1){ coupon.setPublisherType(2); + coupon.setAuditStatus(2); + coupon.setCityManagerId(dataVo.getCityManagerId()); } if (dataVo.getUserType() == 2){ coupon.setPublisherType(1); + coupon.setAuditStatus(1); coupon.setCityManagerId(dataVo.getCityManagerId()); } - if(dataVo.getObjType()!=1){ + if (dataVo.getUserType() == 3){ + coupon.setPublisherType(3); coupon.setAuditStatus(1); - } - if (dataVo.getUserType()==1){ - coupon.setAuditStatus(2); - }else{ - coupon.setAuditStatus(1); - } - if(dataVo.getObjType()!=1){ - coupon.setAuditStatus(1); + coupon.setCityManagerId(dataVo.getCityManagerId()); } boolean save = couponService.save(coupon); -- Gitblit v1.7.1