From edf83149d0f26fb99eb6548d9e68bcc81a8cc893 Mon Sep 17 00:00:00 2001 From: nickchange <126672920+nickchange@users.noreply.github.com> Date: 星期五, 13 十月 2023 17:03:37 +0800 Subject: [PATCH] 10.13bug2 --- cloud-server-activity/src/main/java/com/dsh/activity/controller/CouponController.java | 408 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 398 insertions(+), 10 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 a3feebf..e9a3473 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 @@ -1,27 +1,51 @@ package com.dsh.activity.controller; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.dsh.activity.entity.Coupon; +import com.dsh.activity.entity.CouponCity; +import com.dsh.activity.entity.CouponStore; import com.dsh.activity.entity.UserCoupon; +import com.dsh.activity.feignclient.account.AppUserClient; +import com.dsh.activity.feignclient.account.CityClient; +import com.dsh.activity.feignclient.account.StoreStaffClient; +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.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.model.CouponListVo; +import com.dsh.activity.model.CouponRecordQuery; import com.dsh.activity.model.request.CommodityRequest; +import com.dsh.activity.model.request.CouponDataVo; import com.dsh.activity.model.request.CouponPackageReq; import com.dsh.activity.model.response.CouponPackageResp; +import com.dsh.activity.service.CouponCityService; +import com.dsh.activity.service.CouponStoreService; import com.dsh.activity.service.ICouponService; import com.dsh.activity.service.UserCouponService; import com.dsh.activity.util.GDMapGeocodingUtil; import com.dsh.activity.util.ResultUtil; import com.dsh.activity.util.TokenUtil; +import com.dsh.activity.util.ToolUtil; +import com.google.gson.Gson; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; -import java.util.Iterator; -import java.util.List; -import java.util.Map; -import java.util.Objects; +import javax.annotation.Resource; +import java.math.BigDecimal; +import java.text.SimpleDateFormat; +import java.util.*; +import java.util.stream.Collectors; /** * @author zhibing.pu @@ -43,6 +67,28 @@ @Autowired private GDMapGeocodingUtil gdMapGeocodingUtil; + @Resource + private CityClient citClient; + + @Resource + private StoreStaffClient stoStaClient; + + + @Resource + private StoreClient stoClient; + + + @Resource + private RegionClient regionClient; + + @Resource + private CouponStoreService couStoreService; + + @Resource + private CouponCityService cityService; + + @Autowired + private AppUserClient appUserClient; @@ -116,8 +162,12 @@ @PostMapping("/base/coupon/getAllCoupons") public List<Coupon> getAllCoupons(@RequestBody CommodityRequest request){ + List<Coupon> couponList = new ArrayList<>(); String provinceCode = ""; String cityCode = ""; + if (ToolUtil.isEmpty(request.getLat()) && ToolUtil.isEmpty(request.getLon())){ + return couponList; + } try { Map<String, String> geocode = gdMapGeocodingUtil.geocode(request.getLon(), request.getLat()); provinceCode = geocode.get("provinceCode"); @@ -126,10 +176,7 @@ e.printStackTrace(); } try { - Integer userAppId = tokenUtil.getUserIdFormRedis(); - List<UserCoupon> list = ucService.list(new QueryWrapper<UserCoupon>() - .eq("userId",userAppId )); - List<Coupon> couponList = couponService.list(new QueryWrapper<Coupon>() + couponList = couponService.list(new QueryWrapper<Coupon>() .eq("auditStatus",2) .eq("state",1) .eq("status",2)); @@ -137,8 +184,17 @@ Iterator<Coupon> iterator = couponList.iterator(); while (iterator.hasNext()) { Coupon merchandise = iterator.next(); - if (merchandise.getUseScope() == 2 && (!Objects.equals(merchandise.getCityCode(), cityCode) && !Objects.equals(merchandise.getProvinceCode(), provinceCode))) { - iterator.remove(); // 移除符合条件的商品 + if (merchandise.getUseScope() == 2){ + List<CouponCity> couponCities = cityService.list(new LambdaQueryWrapper<CouponCity>() + .eq(CouponCity::getCouponId,merchandise.getId())); + if (couponCities.size() > 0){ + for (CouponCity couponCity : couponCities) { + if (!Objects.equals(couponCity.getCityCode(), cityCode) && !Objects.equals(couponCity.getProvinceCode(), provinceCode)){ + iterator.remove(); // 移除符合条件的商品 + break; + } + } + } } } } @@ -155,4 +211,336 @@ .eq("couponId",id)); } + + @PostMapping("/base/coupon/insertToAppuserCoupon") + public void insertToAppuserCoupon(@RequestBody UserCoupon coupon){ + coupon.setInsertTime(new Date()); + ucService.save(coupon); + } + + + + @ResponseBody + @PostMapping("/base/coupon/queryCouponListSearch") + public List<Map<String,Object>> getCouponListOfSearch(@RequestBody CouponListOfSearch ofSearch){ + List<Map<String, Object>> mapList = couponService.queryCouponListOfSearch(ofSearch); + if (mapList.size() > 0){ + for (Map<String, Object> stringObjectMap : mapList) { + Integer o = (Integer) stringObjectMap.get("id"); + Object startTime = stringObjectMap.get("startTime"); + Object endTime = stringObjectMap.get("endTime"); + stringObjectMap.put("timeValue",startTime + "至"+endTime); + int count = ucService.count(new LambdaQueryWrapper<UserCoupon>() + .eq(UserCoupon::getCouponId, o)); + stringObjectMap.put("hasPickQty",count); + } + } + return mapList; + } + + + @ResponseBody + @PostMapping("/base/coupon/queryCouponListSearch1") + public List<Map<String,Object>> getCouponListOfSearch1(@RequestBody CouponListOfSearch ofSearch){ + List<Map<String, Object>> mapList = couponService.queryCouponListOfSearch1(ofSearch); + if (mapList.size() > 0){ + for (Map<String, Object> stringObjectMap : mapList) { + Integer o = (Integer) stringObjectMap.get("id"); + Object startTime = stringObjectMap.get("startTime"); + Object endTime = stringObjectMap.get("endTime"); + stringObjectMap.put("timeValue",startTime + "至"+endTime); + int count = ucService.count(new LambdaQueryWrapper<UserCoupon>() + .eq(UserCoupon::getCouponId, o)); + stringObjectMap.put("hasPickQty",count); + } + } + return mapList; + } + @ResponseBody + @PostMapping("/base/coupon/couponExamineListSearch") + public List<Map<String,Object>> getCouponExamineListOfSearch(@RequestBody CouponExamineListSearch ofSearch){ + List<Map<String, Object>> mapList = couponService.queryCouponExamineList(ofSearch); + if (mapList.size() > 0){ + for (Map<String, Object> stringObjectMap : mapList) { + Object startTime = stringObjectMap.get("startTime"); + Object endTime = stringObjectMap.get("endTime"); + stringObjectMap.put("timeValue",startTime + "至"+endTime); + Integer publisherType = (Integer) stringObjectMap.get("publisherType"); + if ( publisherType == 1) { + Integer cityManagerId = (Integer) stringObjectMap.get("cityManagerId"); + TCityManager byId = citClient.getById(cityManagerId); + stringObjectMap.put("province", byId.getProvince()); + stringObjectMap.put("city", byId.getCity()); + } + } + } + return mapList; + } + + + @ResponseBody + @PostMapping("/base/coupon/couponExamineDetail") + Map<String, Object> queryCouponExamineDetail(@RequestBody Integer id){ + Map<String, Object> couponInfo = new HashMap<>(); + Coupon coupon = couponService.getById(id); + SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd"); + if (ToolUtil.isNotEmpty(coupon)){ + 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()); + switch (coupon.getType()){ + case 1: +// {"conditionalAmount":50,"deductionAmount":10,"experienceName":""} + couponInfo.put("num1",jsonObject.getDouble("conditionalAmount")); + couponInfo.put("num2",jsonObject.getDouble("deductionAmount")); + break; + case 2: + couponInfo.put("num1",jsonObject.getDouble("conditionalAmount")); + break; + case 3: + couponInfo.put("num1",jsonObject.getString("experienceName")); + break; + default: + break; + } + couponInfo.put("illustrate",coupon.getIllustrate()); + switch (coupon.getDistributionMethod()){ + case 1: + couponInfo.put("distributionMethod","积分注册"); + break; + case 2: + couponInfo.put("distributionMethod","注册赠送"); + break; + case 3: + couponInfo.put("distributionMethod","自动发券"); + break; + default: + break; + } + couponInfo.put("redemptionMethod",coupon.getRedemptionMethod()); + couponInfo.put("integral",coupon.getIntegral()); + couponInfo.put("cash",coupon.getCash()); + switch (coupon.getUserPopulation()){ + case 1: + couponInfo.put("userPopulation","全部用户"); + break; + case 2: + couponInfo.put("userPopulation","年度会员"); + break; + case 3: + couponInfo.put("userPopulation","已有学员用户"); + break; + default: + break; + } + couponInfo.put("quantityIssued",coupon.getQuantityIssued()); + couponInfo.put("pickUpQuantity",coupon.getPickUpQuantity()); + String startTime = simpleDateFormat.format(coupon.getStartTime()); + String endTime = simpleDateFormat.format(coupon.getEndTime()); + couponInfo.put("timeValue",startTime + "至"+endTime); + couponInfo.put("useScope",coupon.getUseScope()); + ArrayList<Map<String, Object>> maps = new ArrayList<>(); + switch (coupon.getUseScope()){ + case 2: + List<CouponCity> couponCities = cityService.list(new LambdaQueryWrapper<CouponCity>() + .eq(CouponCity::getCouponId,coupon.getId())); + if (couponCities.size() > 0){ + for (CouponCity couponCity : couponCities) { + HashMap<String, Object> stringObjectHashMap = new HashMap<>(); + stringObjectHashMap.put("province",couponCity.getProvince()); + stringObjectHashMap.put("city",couponCity.getCity()); + maps.add(stringObjectHashMap); + } + couponInfo.put("rangeData",maps); + } + break; + case 3: + List<CouponStore> list = couStoreService.list(new LambdaQueryWrapper<CouponStore>() + .eq(CouponStore::getCouponId,coupon.getId())); + if (list.size() > 0){ + 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()); + HashMap<String, Object> stringObjectHashMap = new HashMap<>(); + stringObjectHashMap.put("procity",store.getProvince()+store.getCity()); + stringObjectHashMap.put("storeAccount",list1.getName()+"+"+list1.getPhone()); + stringObjectHashMap.put("storeName",store.getName()); + maps.add(stringObjectHashMap); + } + couponInfo.put("rangeData",maps); + } + + } + break; + default: + break; + } + } + return couponInfo; + } + + + + @ResponseBody + @PostMapping("/base/coupon/updateCouponExamine") + public boolean updateCouponData(@RequestBody Coupon coupon){ + try { + return couponService.updateById(coupon); + }catch (Exception e){ + return false; + } + } + + @ResponseBody + @PostMapping("/base/coupon/insertIntoCouponData") + public boolean saveCouponData(@RequestBody CouponDataVo dataVo){ + SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd"); + try { + System.out.println(dataVo); + Coupon coupon = new Coupon(); + coupon.setName(dataVo.getCouponName()); + coupon.setType(dataVo.getPrescription()); + HashMap<String, Object> stringObjectHashMap = new HashMap<>(); + Gson gson = new Gson(); + switch (dataVo.getPrescription()){ +// {"conditionalAmount":50,"deductionAmount":10,"experienceName":""} + case 1: + stringObjectHashMap.put("conditionalAmount",dataVo.getCondition()); + stringObjectHashMap.put("deductionAmount",dataVo.getSubtraction()); + coupon.setContent(gson.toJson(stringObjectHashMap)); + break; + case 2: + stringObjectHashMap.put("conditionalAmount",dataVo.getDiscount()); + coupon.setContent(gson.toJson(stringObjectHashMap)); + break; + case 3: + stringObjectHashMap.put("experienceName",dataVo.getExperience()); + coupon.setContent(gson.toJson(stringObjectHashMap)); + break; + default: + break; + } + coupon.setIllustrate(dataVo.getIllustrate()); + coupon.setDistributionMethod(dataVo.getDistributionMethod()); + coupon.setRedemptionMethod(dataVo.getExchangeMethod()); + switch (dataVo.getExchangeMethod()){ + 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; + default: + break; + } + coupon.setQuantityIssued(dataVo.getQuantityIssued()); + coupon.setPickUpQuantity(dataVo.getPickUpQuantity()); + coupon.setUseScope(dataVo.getCompany()); + coupon.setUserPopulation(dataVo.getUserGroup()); + String timeDeal = dataVo.getPeriodOfValidity(); + if (ToolUtil.isNotEmpty(timeDeal)){ + String[] split = timeDeal.split(" - "); + coupon.setStartTime(simpleDateFormat.parse(split[0])); + coupon.setEndTime(simpleDateFormat.parse(split[1])); + } + coupon.setAuditStatus(1); + coupon.setStatus(1); + coupon.setState(1); + coupon.setInsertTime(new Date()); + coupon.setCover(dataVo.getGoodImg()); + String goodImgs = dataVo.getGoodImgs(); + String[] imgsSplit = goodImgs.split(","); + if (imgsSplit.length > 0){ + if (imgsSplit.length == 1){ + coupon.setProductImages(imgsSplit[0]); + }else { + coupon.setProductImages(goodImgs); + } + } + if (dataVo.getUserType() == 1){ + coupon.setPublisherType(2); + } + if (dataVo.getUserType() == 2){ + coupon.setPublisherType(1); + coupon.setCityManagerId(dataVo.getCityManagerId()); + } + boolean save = couponService.save(coupon); + if (save){ + if (dataVo.getCompany() == 3){ + String[] split = dataVo.getStoreIds().split(","); + for (String storeId : split) { + CouponStore couponStore = new CouponStore(); + couponStore.setCouponId(coupon.getId()); + couponStore.setStoreId(Integer.parseInt(storeId)); + couStoreService.save(couponStore); + } + } + String cityIds = dataVo.getCityIds(); + String[] split = cityIds.split(","); + List<Integer> cityIdss = new ArrayList<>(); + if (dataVo.getCompany() == 2 && split.length > 0 ){ + for (String s : split) { + int intValue = Integer.parseInt(s); + cityIdss.add(intValue); + } + List<CityDataAndProvinceDataVo> cityAndProvince = regionClient.getCityAndProvince(cityIdss); + for (CityDataAndProvinceDataVo cityId : cityAndProvince) { + CouponCity couponCity = new CouponCity(); + couponCity.setCouponId(coupon.getId()); + couponCity.setCityCode(cityId.getCityCode()); + couponCity.setCity(cityId.getCityName()); + couponCity.setProvinceCode(cityId.getProvinceCode()); + couponCity.setProvince(cityId.getProvinceName()); + System.out.println(couponCity); + cityService.save(couponCity); + } + } + } + return true; + }catch (Exception e){ + return false; + } + } + + @ResponseBody + @PostMapping("/base/coupon/queryCity") + public List<CouponCity> queryCity(@RequestBody Integer id){ + List<CouponCity> list = cityService.list(new LambdaQueryWrapper<CouponCity>().eq(CouponCity::getCouponId, id)); + return list; + } + + @ResponseBody + @PostMapping("/base/coupon/queryStore") + public List<Integer> queryStore(@RequestBody Integer id){ + return couStoreService.list(new LambdaQueryWrapper<CouponStore>().eq(CouponStore::getCouponId,id)).stream().map(CouponStore::getStoreId).collect(Collectors.toList()); + } + + + @PostMapping("/base/coupon/listRecord") + @ResponseBody + public List<Map<String,Object>> listRecord(@RequestBody CouponRecordQuery ofSearch){ + Page<Object> objectPage = new Page<>(ofSearch.getOffset(), ofSearch.getLimit()); + return couponService.listRecord(objectPage,ofSearch.getId(),ofSearch.getIds(),ofSearch.getType()); + } + + + + @PostMapping("/base/coupon/updateType") + public void updateType(@RequestBody Long id){ + couponService.updateType(id); + } } -- Gitblit v1.7.1