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