From ee9cb0da4a43bcf523ebb157678f64a2895fba1a Mon Sep 17 00:00:00 2001 From: nickchange <126672920+nickchange@users.noreply.github.com> Date: 星期二, 10 十月 2023 15:30:38 +0800 Subject: [PATCH] 10.10 --- cloud-server-other/src/main/java/com/dsh/other/controller/SiteController.java | 178 ++++++++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 156 insertions(+), 22 deletions(-) diff --git a/cloud-server-other/src/main/java/com/dsh/other/controller/SiteController.java b/cloud-server-other/src/main/java/com/dsh/other/controller/SiteController.java index 3d3f7e9..52181c6 100644 --- a/cloud-server-other/src/main/java/com/dsh/other/controller/SiteController.java +++ b/cloud-server-other/src/main/java/com/dsh/other/controller/SiteController.java @@ -1,13 +1,24 @@ package com.dsh.other.controller; +import cn.hutool.http.HttpRequest; +import cn.hutool.http.HttpResponse; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.dsh.other.entity.Site; import com.dsh.other.entity.SiteBooking; import com.dsh.other.entity.SiteType; +import com.dsh.other.feignclient.account.CityManagerClient; import com.dsh.other.feignclient.activity.UserCouponClient; +import com.dsh.other.feignclient.activity.model.QueryUserCouponByIdAndUserId; import com.dsh.other.feignclient.activity.model.UserCoupon; +import com.dsh.other.feignclient.model.BillingDataRequestVo; +import com.dsh.other.feignclient.model.SiteChangeStateVO; import com.dsh.other.feignclient.model.SiteVo; import com.dsh.other.model.*; +import com.dsh.other.model.dto.siteDto.TSiteDTO; +import com.dsh.other.model.vo.siteVo.ExpireSiteSearchVO; +import com.dsh.other.model.vo.siteVo.SiteSearchVO; import com.dsh.other.service.ISiteBookingService; import com.dsh.other.service.ISiteService; import com.dsh.other.service.ISiteTypeService; @@ -18,16 +29,14 @@ import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.PrintWriter; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; -import java.util.Map; +import java.util.*; /** * @author zhibing.pu @@ -54,10 +63,92 @@ @Resource private UserCouponClient userCouponClient; + @Autowired + private CityManagerClient cityManagerClient; + + /** + * 获取所有场地 + */ + @RequestMapping("/base/site/getList") + @ResponseBody + public List<Site> getList(){ + return siteService.list(new QueryWrapper<Site>().ne("state",3)); + } + /** + * 获取场地预约记录 + */ + @RequestMapping("/base/site/listAll") + public List<SiteBooking> listAll(@RequestBody SiteBookingQuery query){ + return siteBookingService.listAll(query); + } + /** + * 获取所有场地 + * @return + */ + @RequestMapping("/base/site/list") + public List<TSiteDTO> listAll(@RequestBody SiteSearchVO vo){ + return siteTypeService.listAll(vo); + } + /** + * 获取场地有效期在两个月内的场地列表 + * @return + */ + @RequestMapping("/base/site/listExipre") + public List<TSiteDTO> listExipre(@RequestBody ExpireSiteSearchVO vo){ + + return siteTypeService.listExipre(vo); + + } + + /** + * 上/下架、删除常见问题 type=1为上架 2为下架 3为删除 + */ + @RequestMapping("/base/site/changeState") + public Object changeState(@RequestBody SiteChangeStateVO vo){ + + return siteService.changeState(vo); + } + /** + * 添加场地管理 + * @return + */ + @RequestMapping("/base/site/addSite") + public Object addSite(@RequestBody Site site){ + if(site.getId()!= null ){ + + return siteService.updateById(site); + }else { + return siteService.save(site); + } + } + /** + * 添加场地管理 + * @return + */ + @RequestMapping("/base/site/addSiteBooking") + public Object addSiteBooking(@RequestBody SiteBooking siteBooking){ + if(siteBooking.getId()!= null ){ + + return siteBookingService.updateById(siteBooking); + }else { + return siteBookingService.save(siteBooking); + } + } + + @RequestMapping("/base/site/listById") + public Site listById(@RequestParam("id") Integer id){ + Site byId = siteService.getById(id); + return byId; + } + @RequestMapping("/base/site/listBooks") + public List<SiteBooking> listBooks(@RequestParam("id") Integer id){ + List<SiteBooking> siteId = siteBookingService.list(new QueryWrapper<SiteBooking>().eq("siteId", id)); + return siteId; + } @ResponseBody @PostMapping("/base/site/querySiteType") @ApiOperation(value = "获取场地类型", tags = {"用户—预约场地"}) @@ -88,7 +179,6 @@ return ResultUtil.runErr(); } } - @@ -166,10 +256,6 @@ return ResultUtil.runErr(); } } - - - - /** * 购买课程微信支付回调 @@ -258,6 +344,44 @@ return ResultUtil.runErr(); } } + @ResponseBody + @PostMapping("/api/site/queryMySiteById") + @ApiOperation(value = "获取我的预约场地列表详情2.0", tags = {"用户—预约场地"}) + @ApiImplicitParams({ + @ApiImplicitParam(value = "id", name = "id", dataType = "int", required = true), + @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."), + }) + public ResultUtil<Map<String,Object>> queryMySiteById(Integer id){ + try { + HashMap<String, Object> map = new HashMap<>(); + SiteBooking byId = siteBookingService.getById(id); + List<Integer> ids = getIds(byId.getSiteId()); + map.put("data",byId); + map.put("ids",ids); + return ResultUtil.success(map); + }catch (Exception e){ + e.printStackTrace(); + return ResultUtil.runErr(); + } + } + + public List<Integer> getIds(Integer siteId) { + HttpRequest httpRequest = HttpRequest.get("https://try.daowepark.com/v7/user_api/general/get_space_area?space_id=" + siteId); + HttpResponse execute = httpRequest.execute(); + String body = execute.body(); + JSONObject jsonObject = JSONObject.parseObject(body); + Object data = jsonObject.get("data"); + JSONArray array = JSONArray.parseArray(data.toString()); + List<Integer> ids =new ArrayList<>(); + for (Object o : array) { + JSONObject jsonObject1 = JSONObject.parseObject(o.toString()); + Object id = jsonObject1.get("id"); + Integer integer = Integer.valueOf(id.toString()); + ids.add(integer); + } + return ids; + + } @ResponseBody @@ -273,6 +397,8 @@ if(null == uid){ return ResultUtil.tokenErr(); } + + return siteService.cancelMySite(uid, id); }catch (Exception e){ e.printStackTrace(); @@ -302,7 +428,7 @@ siteBooking.setRefundOrderNo(refund_id); siteBookingService.updateById(siteBooking); if(null != siteBooking.getUserCouponId()){ - UserCoupon userCoupon = userCouponClient.queryUserCouponById(siteBooking.getUserCouponId()); + UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),siteBooking.getAppUserId())); userCoupon.setStatus(1); userCouponClient.updateUserCoupon(userCoupon); } @@ -358,21 +484,18 @@ /** * 查询所有现金支付的预约记录 - * @param appUserId + * @param requestVo * @return */ + @ResponseBody @PostMapping("/base/site/queryPaymentSiteDetail") - public List<SiteBooking> getAllSiteBookingList(@RequestBody Integer appUserId){ - ArrayList<Integer> integers = new ArrayList<>(); - integers.add(1); - integers.add(2); - integers.add(3); - integers.add(4); - integers.add(5); - return siteBookingService.list(new QueryWrapper<SiteBooking>() - .in("status",integers) - .ne("payType",3) - .eq("appUserId",appUserId)); + public RequestOfTypeVo getAllSiteBookingList(@RequestBody BillingDataRequestVo requestVo){ + RequestOfTypeVo typeVo = new RequestOfTypeVo(); + List<BillingRequestOfType> billingRequestOfTypes = siteBookingService.queryDatas(requestVo.getAppUserId(), requestVo.getMonthStart(), requestVo.getMonthEnd()); + if (billingRequestOfTypes.size() > 0 ){ + typeVo.setRequest(billingRequestOfTypes); + } + return typeVo; } /** @@ -380,6 +503,7 @@ * @param appUserId * @return */ + @ResponseBody @PostMapping("/base/site/queryPlaypaiGoldSiteDetail") public List<SiteBooking> wanpaiGoldSiteBookingList(@RequestBody Integer appUserId){ ArrayList<Integer> integers = new ArrayList<>(); @@ -395,6 +519,16 @@ } + @ResponseBody + @PostMapping("/base/site/queryByCode") + public Integer queryByCode(@RequestBody String code){ + + return siteBookingService.queryByCode(code); + } + + + + @ResponseBody @PostMapping("/base/site/getNewAddSiteList") public List<SiteVo> getAppUserSiteList(){ List<SiteVo> siteVos = new ArrayList<>(); -- Gitblit v1.7.1