From b64d67ef01e81a857046f19dd556b4e4f0695e1c Mon Sep 17 00:00:00 2001
From: liujie <liujie>
Date: 星期三, 02 八月 2023 16:41:51 +0800
Subject: [PATCH] 后台代码  门店管理

---
 cloud-server-other/src/main/java/com/dsh/other/service/impl/SiteServiceImpl.java |  620 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 618 insertions(+), 2 deletions(-)

diff --git a/cloud-server-other/src/main/java/com/dsh/other/service/impl/SiteServiceImpl.java b/cloud-server-other/src/main/java/com/dsh/other/service/impl/SiteServiceImpl.java
index 26cdfc0..3ab0282 100644
--- a/cloud-server-other/src/main/java/com/dsh/other/service/impl/SiteServiceImpl.java
+++ b/cloud-server-other/src/main/java/com/dsh/other/service/impl/SiteServiceImpl.java
@@ -1,10 +1,30 @@
 package com.dsh.other.service.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.dsh.other.entity.Site;
+import com.dsh.other.entity.*;
+import com.dsh.other.feignclient.account.AppUserClient;
+import com.dsh.other.feignclient.account.model.AppUser;
+import com.dsh.other.feignclient.activity.CouponClient;
+import com.dsh.other.feignclient.activity.UserCouponClient;
+import com.dsh.other.feignclient.activity.model.Coupon;
+import com.dsh.other.feignclient.activity.model.QueryUserCouponByIdAndUserId;
+import com.dsh.other.feignclient.activity.model.UserCoupon;
 import com.dsh.other.mapper.SiteMapper;
-import com.dsh.other.service.ISiteService;
+import com.dsh.other.model.*;
+import com.dsh.other.service.*;
+import com.dsh.other.util.*;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.text.SimpleDateFormat;
+import java.util.*;
 
 /**
  * @author zhibing.pu
@@ -12,4 +32,600 @@
  */
 @Service
 public class SiteServiceImpl extends ServiceImpl<SiteMapper, Site> implements ISiteService {
+
+    @Autowired
+    private ISiteTypeService siteTypeService;
+
+    @Autowired
+    private StoreService storeService;
+
+    @Autowired
+    private ISiteBookingService siteBookingService;
+
+    @Autowired
+    private ISiteLockService siteLockService;
+
+    @Resource
+    private AppUserClient appUserClient;
+
+    @Resource
+    private UserCouponClient userCouponClient;
+
+    @Resource
+    private CouponClient couponClient;
+
+    @Autowired
+    private PayMoneyUtil payMoneyUtil;
+
+
+
+
+
+    /**
+     * 获取场地列表
+     * @param querySiteList
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public List<QuerySiteListVo> querySiteList(QuerySiteList querySiteList) throws Exception {
+        querySiteList.setPageNum((querySiteList.getPageNum() - 1) *querySiteList.getPageSize());
+        List<QuerySiteListVo> querySiteListVos = this.baseMapper.querySiteList(querySiteList);
+        for (QuerySiteListVo querySiteListVo : querySiteListVos) {
+            if(ToolUtil.isEmpty(querySiteList.getLon())){
+                querySiteListVo.setDistance(0D);
+                continue;
+            }
+            Map<String, Double> distance = GeodesyUtil.getDistance(querySiteList.getLon() + "," + querySiteList.getLat(), querySiteListVo.getStoreLon() + "," + querySiteListVo.getStoreLat());
+            querySiteListVo.setDistance(distance.get("WGS84"));
+        }
+        return querySiteListVos;
+    }
+
+
+    /**
+     * 获取场地详情
+     * @param id
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public QuerySiteInfoVo querySiteInfo(Integer id, String lon, String lat) throws Exception {
+        Site site = this.getById(id);
+        SiteType siteType = siteTypeService.getById(site.getSiteTypeId());
+        Store store = storeService.getById(site.getStoreId());
+        QuerySiteInfoVo querySiteInfoVo = new QuerySiteInfoVo();
+        querySiteInfoVo.setId(site.getId());
+        querySiteInfoVo.setName(site.getName());
+        querySiteInfoVo.setSiteTypeName(siteType.getName());
+        querySiteInfoVo.setStoreName(store.getName());
+        querySiteInfoVo.setStoreCoverDrawing(store.getCoverDrawing());
+        querySiteInfoVo.setStoreAddress(store.getAddress());
+        querySiteInfoVo.setStoreLon(store.getLon());
+        querySiteInfoVo.setStoreLat(store.getLat());
+        querySiteInfoVo.setStorePhone(store.getPhone());
+        querySiteInfoVo.setDistance(0D);
+        if(ToolUtil.isNotEmpty(lon) && ToolUtil.isNotEmpty(lat)){
+            Map<String, Double> distance = GeodesyUtil.getDistance(lon + "," + lat, store.getLon() + "," + store.getLat());
+            double wgs84 = new BigDecimal(distance.get("WGS84")).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            querySiteInfoVo.setDistance(wgs84);
+        }
+        querySiteInfoVo.setCashPrice(site.getCashPrice());
+        querySiteInfoVo.setPlayPaiCoin(site.getPlayPaiCoin());
+        return querySiteInfoVo;
+    }
+
+
+    /**
+     * 获取场地预约日期数据
+     * @param id
+     * @param day
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public List<QuerySiteTimes> querySiteTimes(Integer id, String day) throws Exception {
+        Site site = this.getById(id);
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
+        Calendar s = Calendar.getInstance();
+        s.setTime(sdf.parse(day + " " + site.getAppointmentStartTime()));
+        Calendar e = Calendar.getInstance();
+        e.setTime(sdf.parse(day + " " + site.getAppointmentEndTime()));
+
+        int hour = e.get(Calendar.HOUR_OF_DAY);
+        int minute = e.get(Calendar.MINUTE);
+        List<QuerySiteTimes> list = new ArrayList<>();
+        SimpleDateFormat sdfs = new SimpleDateFormat("HH:mm");
+        while (true){
+            String start = sdfs.format(s.getTime());
+
+            s.set(Calendar.MINUTE, s.get(Calendar.MINUTE) + 30);
+            int e_hour = s.get(Calendar.HOUR_OF_DAY);
+            int e_minute = s.get(Calendar.MINUTE);
+            String end = sdfs.format(s.getTime());
+
+            QuerySiteTimes querySiteTimes = new QuerySiteTimes();
+            querySiteTimes.setTime(start + "-" + end);
+            querySiteTimes.setSelectable(1);
+
+            SiteBooking siteBooking = siteBookingService.getOne(new QueryWrapper<SiteBooking>().eq("siteId", id).eq("state", 1)
+                    .in("status", Arrays.asList(3, 4, 5)).last(" and DATE_FORMAT(startTime, '%Y-%m-%d %H:%i') <= '" + day + " " + start + "' and DATE_FORMAT(endTime, '%Y-%m-%d %H:%i') >= '" + day + " " + end + "'"));
+            if(null != siteBooking){
+                querySiteTimes.setSelectable(0);
+            }
+            int count = siteLockService.count(new QueryWrapper<SiteLock>().eq("siteId", id).last(" and DATE_FORMAT(startTime, '%Y-%m-%d %H:%i') <= '" + day + " " + start + "' and DATE_FORMAT(endTime, '%Y-%m-%d %H:%i') >= '" + day + " " + end + "'"));
+            if(count > 0){
+                querySiteTimes.setSelectable(0);
+            }
+
+            list.add(querySiteTimes);
+
+            if(e_hour == hour && minute == e_minute){
+                break;
+            }
+        }
+        return list;
+    }
+
+
+    /**
+     * 预约场地
+     * @param reservationSite
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public ResultUtil reservationSite(Integer uid, ReservationSite reservationSite) throws Exception {
+        Site site = this.getById(reservationSite.getId());
+        AppUser appUser = appUserClient.queryAppUser(uid);
+        String[] split = reservationSite.getTimes().split(";");
+
+        for (String s : split) {
+            String day = s.split(" ")[0];
+            String time = s.split(" ")[1];
+            List<QuerySiteTimes> querySiteTimes = querySiteTimes(reservationSite.getId(), day);
+            for (QuerySiteTimes querySiteTime : querySiteTimes) {
+                if(querySiteTime.getTime().equals(time) && querySiteTime.getSelectable() == 0){
+                    return ResultUtil.error("【" + s + "】时间段已被使用");
+                }
+            }
+        }
+
+        String s_time = split[0];
+        String e_time = split[split.length - 1];
+        s_time = s_time.substring(0,s_time.lastIndexOf("-"));
+        String[] s1 = e_time.split(" ");
+        e_time = s1[0] + " " + s1[1].split("-")[1];
+        SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm");
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
+        Double payMoney = 0D;
+        if(reservationSite.getPayType() == 3){
+            payMoney = new BigDecimal(site.getCashPrice()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            if(appUser.getPlayPaiCoins().compareTo(payMoney.intValue()) < 0){
+                return ResultUtil.error("玩湃币不足");
+            }
+        }else{
+            payMoney = new BigDecimal(site.getCashPrice()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+        }
+
+        //校验优惠券
+        Long couponId = reservationSite.getCouponId();
+        if(null != couponId && reservationSite.getPayType() != 3){
+            UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(reservationSite.getCouponId(),uid));
+            if(userCoupon.getStatus() == 2){
+                return ResultUtil.error("优惠券已被核销");
+            }
+            Coupon coupon = couponClient.queryCouponById(userCoupon.getCouponId());
+            long time = coupon.getEndTime().getTime();
+            if(System.currentTimeMillis() >= time){
+                return ResultUtil.error("优惠券已过期");
+            }
+            if(coupon.getType() == 1){//满减
+                JSONObject jsonObject = JSON.parseObject(coupon.getContent());
+                Double num1 = jsonObject.getDouble("num1");
+                Double num2 = jsonObject.getDouble("num2");
+                if(payMoney.compareTo(num1) <= 0){
+                    return ResultUtil.error("该优惠券无法使用");
+                }
+
+                payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num2)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            }
+            if(coupon.getType() == 2){//代金券
+                JSONObject jsonObject = JSON.parseObject(coupon.getContent());
+                Double num1 = jsonObject.getDouble("num1");
+                if(payMoney.compareTo(num1) <= 0){
+                    return ResultUtil.error("该优惠券无法使用");
+                }
+                payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num1)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            }
+            userCoupon.setStatus(2);
+            userCouponClient.updateUserCoupon(userCoupon);
+        }
+
+
+        SiteBooking siteBooking = new SiteBooking();
+        siteBooking.setOrderNo(sdf.format(new Date()) + UUIDUtil.getNumberRandom(3));
+        siteBooking.setProvince(site.getProvince());
+        siteBooking.setProvinceCode(site.getProvinceCode());
+        siteBooking.setCity(site.getCity());
+        siteBooking.setCityCode(site.getCityCode());
+        siteBooking.setStoreId(site.getStoreId());
+        siteBooking.setSiteId(reservationSite.getId());
+        siteBooking.setAppUserId(uid);
+        siteBooking.setTimes(reservationSite.getTimes());
+        siteBooking.setStartTime(sdf1.parse(s_time));
+        siteBooking.setEndTime(sdf1.parse(e_time));
+        siteBooking.setBooker(reservationSite.getBooker());
+        siteBooking.setPhone(reservationSite.getPhone());
+        siteBooking.setPayType(reservationSite.getPayType());
+        siteBooking.setPayMoney(payMoney);
+        siteBooking.setUserCouponId(reservationSite.getCouponId());
+        siteBooking.setStatus(0);
+        siteBooking.setState(1);
+        siteBooking.setInsertTime(new Date());
+        siteBookingService.save(siteBooking);
+
+        if(reservationSite.getPayType() == 1){//微信支付
+            return weChatPaymentSite(payMoney, siteBooking);
+        }
+        if(reservationSite.getPayType() == 2){//支付宝支付
+            return aliPaymentSite(payMoney, siteBooking);
+        }
+        if(reservationSite.getPayType() == 3){//玩湃币支付
+            return playPaiCoinPaymentSite(appUser, payMoney, siteBooking);
+        }
+        return ResultUtil.success();
+    }
+
+    public static void main(String[] args) {
+        String a ="2023-07-28 10:30-15:30";
+        String substring = a.substring(0,a.lastIndexOf("-"));
+        System.out.println(substring);
+    }
+    /**
+     * 课程微信支付
+     * @param paymentPrice
+     * @return
+     * @throws Exception
+     */
+    public ResultUtil weChatPaymentSite(Double paymentPrice, SiteBooking siteBooking) throws Exception{
+        String code = siteBooking.getOrderNo();
+        Integer id = siteBooking.getId();
+        ResultUtil weixinpay = payMoneyUtil.weixinpay("预约场地", "", code, paymentPrice.toString(), "/base/site/weChatPaymentSiteCallback", "APP", "");
+        if(weixinpay.getCode() == 200){
+            new Thread(new Runnable() {
+                @Override
+                public void run() {
+                    try {
+                        int num = 1;
+                        int wait = 0;
+                        while (num <= 10){
+                            int min = 5000;
+                            wait += (min * num);
+                            Thread.sleep(wait);
+                            SiteBooking siteBooking = siteBookingService.getById(id);
+                            if(siteBooking.getStatus() != 0){
+                                break;
+                            }
+                            ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(siteBooking.getOrderNo(), "");
+                            if(resultUtil.getCode() == 200 && siteBooking.getStatus() == 0){
+                                /**
+                                 * SUCCESS—支付成功,
+                                 * REFUND—转入退款,
+                                 * NOTPAY—未支付,
+                                 * CLOSED—已关闭,
+                                 * REVOKED—已撤销(刷卡支付),
+                                 * USERPAYING--用户支付中,
+                                 * PAYERROR--支付失败(其他原因,如银行返回失败)
+                                 */
+                                Map<String, String> data1 = resultUtil.getData();
+                                String s = data1.get("trade_state");
+                                String transaction_id = data1.get("transaction_id");
+                                if("REFUND".equals(s) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10){
+                                    break;
+                                }
+                                if("SUCCESS".equals(s)){
+                                    siteBooking.setPayTime(new Date());
+                                    siteBooking.setStatus(1);
+                                    siteBooking.setPayOrderNo(transaction_id);
+                                    siteBookingService.updateById(siteBooking);
+                                    break;
+                                }
+                                if("USERPAYING".equals(s)){
+                                    num++;
+                                }
+                            }
+                        }
+                    }catch (Exception e){
+                        e.printStackTrace();
+                    }
+                }
+            }).start();
+        }
+        return weixinpay;
+    }
+
+
+    /**
+     * 课程支付宝支付
+     * @param paymentPrice
+     * @return
+     * @throws Exception
+     */
+    public ResultUtil aliPaymentSite(Double paymentPrice, SiteBooking siteBooking) throws Exception{
+        String code = siteBooking.getOrderNo();
+        Integer id = siteBooking.getId();
+        ResultUtil alipay = payMoneyUtil.alipay("预约场地", "预约场地", "", code, paymentPrice.toString(), "/base/site/aliPaymentSiteCallback");
+        if(alipay.getCode() == 200){
+            new Thread(new Runnable() {
+                @Override
+                public void run() {
+                    try {
+                        int num = 1;
+                        int wait = 0;
+                        while (num <= 10){
+                            int min = 5000;
+                            wait += (min * num);
+                            Thread.sleep(wait);
+                            SiteBooking siteBooking = siteBookingService.getById(id);
+                            if(siteBooking.getStatus() != 0){
+                                break;
+                            }
+                            ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryALIOrder(code);
+                            if(resultUtil.getCode() == 200 && siteBooking.getStatus() == 0){
+                                /**
+                                 * WAIT_BUYER_PAY(交易创建,等待买家付款)、
+                                 * TRADE_CLOSED(未付款交易超时关闭,或支付完成后全额退款)、
+                                 * TRADE_SUCCESS(交易支付成功)、
+                                 * TRADE_FINISHED(交易结束,不可退款)
+                                 */
+                                Map<String, String> data1 = resultUtil.getData();
+                                String s = data1.get("tradeStatus");
+                                String tradeNo = data1.get("tradeNo");
+                                if("TRADE_CLOSED".equals(s) || "TRADE_FINISHED".equals(s) || num == 10){
+                                    break;
+                                }
+                                if("TRADE_SUCCESS".equals(s)){
+                                    siteBooking.setPayTime(new Date());
+                                    siteBooking.setStatus(1);
+                                    siteBooking.setPayOrderNo(tradeNo);
+                                    siteBookingService.updateById(siteBooking);
+                                    break;
+                                }
+                                if("WAIT_BUYER_PAY".equals(s)){
+                                    num++;
+                                }
+                            }
+                        }
+                    }catch (Exception e){
+                        e.printStackTrace();
+                    }
+                }
+            }).start();
+        }
+        return alipay;
+    }
+
+
+    /**
+     * 玩湃币支付
+     * @param appUser
+     * @param paymentPrice
+     * @return
+     * @throws Exception
+     */
+    public ResultUtil playPaiCoinPaymentSite(AppUser appUser, Double paymentPrice, SiteBooking siteBooking) throws Exception{
+        Integer playPaiCoins = appUser.getPlayPaiCoins();
+        appUser.setPlayPaiCoins(playPaiCoins - paymentPrice.intValue());
+        appUserClient.updateAppUser(appUser);
+        siteBooking.setPayTime(new Date());
+        siteBooking.setStatus(1);
+        siteBookingService.updateById(siteBooking);
+        return ResultUtil.success();
+    }
+
+
+    /**
+     * 获取我的场地预约
+     * @param uid
+     * @param status
+     * @param pageNo
+     * @param pageSize
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public List<QueryMySiteVo> queryMySite(Integer uid, Integer status, Integer pageNo, Integer pageSize) throws Exception {
+        pageNo = (pageNo - 1) * pageSize;
+        List<QueryMySiteVo> queryMySiteVos = this.baseMapper.queryMySite(uid, status, pageNo, pageSize);
+        for (QueryMySiteVo queryMySiteVo : queryMySiteVos) {
+            SiteBooking siteBooking = siteBookingService.getById(queryMySiteVo.getId());
+            Site site = this.getById(siteBooking.getSiteId());
+            String[] split = siteBooking.getTimes().split(";");
+            queryMySiteVo.setPlayPaiCoin(site.getPlayPaiCoin() * split.length);
+        }
+        return queryMySiteVos;
+    }
+
+
+    /**
+     * 取消我的预约场地
+     * @param id
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public ResultUtil cancelMySite(Integer uid, Integer id) throws Exception {
+        SiteBooking siteBooking = siteBookingService.getById(id);
+        if(siteBooking.getStatus() == 0){
+            return ResultUtil.error("请先进行支付");
+        }
+        if(siteBooking.getStatus() != 1 && siteBooking.getStatus() != 2){
+            return ResultUtil.error("不能进行取消操作");
+        }
+        if(siteBooking.getPayType() == 1){//微信支付
+            Map<String, String> map = payMoneyUtil.wxRefund(siteBooking.getPayOrderNo(), siteBooking.getOrderNo(), siteBooking.getPayMoney().toString(), siteBooking.getPayMoney().toString(), "/base/site/cancelMySiteCallback");
+            if(null == map){
+                return ResultUtil.error("取消退款异常");
+            }
+            String result_code = map.get("result_code");
+            if(!"SUCCESS".equals(result_code)){
+                return ResultUtil.error(map.get("return_msg"));
+            }
+            siteBooking.setCancelUserId(uid);
+            siteBookingService.updateById(siteBooking);
+        }
+        if(siteBooking.getPayType() == 2){//支付宝
+            Map<String, String> map = payMoneyUtil.aliRefund(siteBooking.getPayOrderNo(), siteBooking.getPayMoney().toString());
+            if(null == map){
+                return ResultUtil.error("取消退款异常");
+            }
+            String code = map.get("code");
+            if(!"10000".equals(code)){
+                return ResultUtil.error(map.get("return_msg"));
+            }
+            String trade_no = map.get("trade_no");
+            siteBooking.setStatus(5);
+            siteBooking.setCancelUserId(uid);
+            siteBooking.setCancelTime(new Date());
+            siteBooking.setRefundOrderNo(trade_no);
+            siteBookingService.updateById(siteBooking);
+            if(null != siteBooking.getUserCouponId()){
+                UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),siteBooking.getAppUserId()));
+                userCoupon.setStatus(1);
+                userCouponClient.updateUserCoupon(userCoupon);
+            }
+        }
+
+        if(siteBooking.getPayType() == 3){//玩湃币
+            AppUser appUser = appUserClient.queryAppUser(siteBooking.getAppUserId());
+            appUser.setPlayPaiCoins(appUser.getPlayPaiCoins() + siteBooking.getPayMoney().intValue());
+            appUserClient.updateAppUser(appUser);
+
+            siteBooking.setStatus(5);
+            siteBooking.setCancelUserId(uid);
+            siteBooking.setCancelTime(new Date());
+            siteBookingService.updateById(siteBooking);
+            if(null != siteBooking.getUserCouponId()){
+                UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),appUser.getId()));
+                userCoupon.setStatus(1);
+                userCouponClient.updateUserCoupon(userCoupon);
+            }
+        }
+
+        return ResultUtil.success();
+    }
+
+
+    /**
+     * 继续支付我预约的场地
+     * @param id
+     * @param payType
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public ResultUtil continuePaymentMySite(Integer uid, Integer id, Integer payType) throws Exception {
+        SiteBooking siteBooking = siteBookingService.getById(id);
+        if(siteBooking.getStatus() != 0){
+            return ResultUtil.error("不能继续支付");
+        }
+        Site site = this.getById(siteBooking.getSiteId());
+        AppUser appUser = appUserClient.queryAppUser(uid);
+        String[] split = siteBooking.getTimes().split(";");
+        Double payMoney = 0D;
+        if(payType == 3){
+            payMoney = new BigDecimal(site.getPlayPaiCoin()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            if(appUser.getPlayPaiCoins().compareTo(payMoney.intValue()) < 0){
+                return ResultUtil.error("玩湃币不足");
+            }
+        }else{
+            payMoney = new BigDecimal(site.getCashPrice()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+        }
+
+        //校验优惠券
+        Long couponId = siteBooking.getUserCouponId();
+        if(null != couponId && payType != 3){
+            UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),appUser.getId()));
+            Coupon coupon = couponClient.queryCouponById(userCoupon.getCouponId());
+            if(coupon.getType() == 1){//满减
+                JSONObject jsonObject = JSON.parseObject(coupon.getContent());
+                Double num1 = jsonObject.getDouble("num1");
+                Double num2 = jsonObject.getDouble("num2");
+                payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num2)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            }
+            if(coupon.getType() == 2){//代金券
+                JSONObject jsonObject = JSON.parseObject(coupon.getContent());
+                Double num1 = jsonObject.getDouble("num1");
+                payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num1)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            }
+            userCoupon.setStatus(2);
+            userCouponClient.updateUserCoupon(userCoupon);
+        }
+        if(null != couponId && payType == 3){
+            UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),appUser.getId()));
+            userCoupon.setStatus(1);
+            userCouponClient.updateUserCoupon(userCoupon);
+        }
+
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
+        siteBooking.setOrderNo(sdf.format(new Date()) + UUIDUtil.getNumberRandom(3));
+        siteBooking.setPayType(payType);
+        siteBooking.setPayMoney(payMoney);
+        if(payType == 3){
+            siteBooking.setUserCouponId(null);
+        }
+        siteBookingService.updateById(siteBooking);
+        if(payType == 1){//微信支付
+            return weChatPaymentSite(payMoney, siteBooking);
+        }
+        if(payType == 2){//支付宝支付
+            return aliPaymentSite(payMoney, siteBooking);
+        }
+        if(payType == 3){//玩湃币支付
+            return playPaiCoinPaymentSite(appUser, payMoney, siteBooking);
+        }
+        return ResultUtil.success();
+    }
+
+
+    /**
+     * 获取继续支付金额
+     * @param id
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public ResultUtil<Map<String, Double>> queryContinuePaymentMySitePrice(Integer id) throws Exception {
+        SiteBooking siteBooking = siteBookingService.getById(id);
+        if(siteBooking.getStatus() != 0){
+            return ResultUtil.error("不能继续支付");
+        }
+        Site site = this.getById(siteBooking.getSiteId());
+        String[] split = siteBooking.getTimes().split(";");
+        Map<String, Double> map = new HashMap<>();
+        Double payMoney = new BigDecimal(site.getPlayPaiCoin()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+        map.put("playPaiCoin", payMoney);
+        payMoney = new BigDecimal(site.getCashPrice()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+
+        //校验优惠券
+        Long couponId = siteBooking.getUserCouponId();
+        if(null != couponId){
+            UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),siteBooking.getAppUserId()));
+            Coupon coupon = couponClient.queryCouponById(userCoupon.getCouponId());
+            if(coupon.getType() == 1){//满减
+                JSONObject jsonObject = JSON.parseObject(coupon.getContent());
+                Double num1 = jsonObject.getDouble("num1");
+                Double num2 = jsonObject.getDouble("num2");
+                payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num2)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            }
+            if(coupon.getType() == 2){//代金券
+                JSONObject jsonObject = JSON.parseObject(coupon.getContent());
+                Double num1 = jsonObject.getDouble("num1");
+                payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num1)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+            }
+        }
+        map.put("cash", payMoney);
+        return ResultUtil.success(map);
+    }
 }

--
Gitblit v1.7.1