From 9c6740ce3038e1041979537ecbe7d801c21d0559 Mon Sep 17 00:00:00 2001
From: luoyisheng <2855143437@qq.com>
Date: 星期二, 19 九月 2023 22:53:39 +0800
Subject: [PATCH] 9.19
---
cloud-server-activity/src/main/java/com/dsh/activity/controller/CouponController.java | 458 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 456 insertions(+), 2 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 c52a588..4829342 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,17 +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.List;
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.stream.Collectors;
/**
* @author zhibing.pu
@@ -27,6 +61,34 @@
@Autowired
private TokenUtil tokenUtil;
+ @Autowired
+ private UserCouponService ucService;
+
+ @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;
@@ -37,7 +99,7 @@
@ApiImplicitParam(value = "1=积分购买，2=注册赠送", name = "distributionMethod", dataType = "int", required = true),
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
})
- public ResultUtil<List<CouponListVo>> queryCouponList(@RequestBody Integer distributionMethod){
+ public ResultUtil<List<CouponListVo>> queryCouponList(Integer distributionMethod){
if(null == distributionMethod){
return ResultUtil.paranErr("distributionMethod");
}
@@ -71,4 +133,396 @@
return null;
}
}
+
+
+ /**
+ * 我的券包列表
+ * @param req
+ * @return
+ */
+ @ResponseBody
+ @PostMapping("/api/coupon/queryCouponPackage")
+ @ApiOperation(value = "我的券包列表", tags = {"APP-使用福利"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
+ })
+ public ResultUtil<List<CouponPackageResp>> queryAppuserCouponList( CouponPackageReq req){
+ try {
+ Integer uid = tokenUtil.getUserIdFormRedis();
+ if(null == uid){
+ return ResultUtil.tokenErr();
+ }
+ return ResultUtil.success(ucService.queryCouponPackagesList(uid, req));
+ }catch (Exception e){
+ e.printStackTrace();
+ return ResultUtil.success();
+ }
+ }
+
+
+ @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");
+ cityCode = geocode.get("cityCode");
+ }catch (Exception e){
+ e.printStackTrace();
+ }
+ try {
+ couponList = couponService.list(new QueryWrapper<Coupon>()
+ .eq("auditStatus",2)
+ .eq("state",1)
+ .eq("status",2));
+ if (couponList.size() > 0 ){
+ Iterator<Coupon> iterator = couponList.iterator();
+ while (iterator.hasNext()) {
+ Coupon merchandise = iterator.next();
+ 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;
+ }
+ }
+ }
+ }
+ }
+ }
+ return couponList;
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+
+ }
+
+ @PostMapping("/base/coupon/getRedeemedNums")
+ public int getRedeemedQuantity(@RequestBody Integer id){
+ return ucService.count(new QueryWrapper<UserCoupon>()
+ .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/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