| | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.alibaba.nacos.api.config.filter.IFilterConfig; |
| | | import com.alipay.api.AlipayClient; |
| | | import com.alipay.api.DefaultAlipayClient; |
| | | import com.alipay.api.request.AlipayTradeOrderSettleRequest; |
| | | import com.alipay.api.response.AlipayTradeOrderSettleResponse; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.dsh.other.entity.*; |
| | | import com.dsh.other.feignclient.StoreClient; |
| | | import com.dsh.other.feignclient.account.AppUserClient; |
| | | import com.dsh.other.feignclient.account.model.AppUser; |
| | | import com.dsh.other.feignclient.activity.CouponClient; |
| | |
| | | import org.aspectj.weaver.ast.Var; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.StringUtils; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.math.BigDecimal; |
| | | import java.math.RoundingMode; |
| | | import java.text.ParseException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.time.DayOfWeek; |
| | | import java.time.LocalDate; |
| | | import java.time.LocalTime; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * @author zhibing.pu |
| | |
| | | @Resource |
| | | private UserCouponClient userCouponClient; |
| | | |
| | | |
| | | @Resource |
| | | private CouponClient couponClient; |
| | | |
| | |
| | | @Autowired |
| | | private TBackRecordService backRecordService; |
| | | |
| | | @Autowired |
| | | private ISiteBookingService iSiteBookingService; |
| | | @Autowired |
| | | private ITSitePriceService sitePriceService; |
| | | |
| | | @Autowired |
| | | private ISiteService siteService; |
| | | |
| | | |
| | | |
| | | // public static void main(String[] args) { |
| | | // String now = DateUtil.now().substring(11, 19); |
| | | // System.err.println(now); |
| | | // if ("17:00:00".compareTo(now) <= 0 && "19:00:00".compareTo(now) >= 0) { |
| | | // System.err.println("yes"); |
| | | // } |
| | | // |
| | | // } |
| | | |
| | | /** |
| | | * 获取场地列表 |
| | | * |
| | | * @param querySiteList |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | @Override |
| | | public List<QuerySiteListVo> querySiteList(QuerySiteList querySiteList) throws Exception { |
| | | querySiteList.setPageNum((querySiteList.getPageNum() - 1) *querySiteList.getPageSize()); |
| | | querySiteList.setPageNum((querySiteList.getPageNum() - 1) * querySiteList.getPageSize()); |
| | | DayOfWeek dayOfWeek = LocalDate.now().getDayOfWeek(); |
| | | Map<Integer, List<TSitePrice>> priceMap = sitePriceService.lambdaQuery().eq(TSitePrice::getDayOfWeek, dayOfWeek.getValue()) |
| | | .eq(querySiteList.getTargetAudience() != null, TSitePrice::getTargetAudience, querySiteList.getTargetAudience()) |
| | | .list() |
| | | .stream().collect(Collectors.groupingBy(TSitePrice::getSiteId)); |
| | | List<QuerySiteListVo> querySiteListVos = this.baseMapper.querySiteList(querySiteList); |
| | | // 获取当前时间 只需要时分秒 格式hh:mm:ss |
| | | String now = DateUtil.now().substring(11, 19); |
| | | for (QuerySiteListVo querySiteListVo : querySiteListVos) { |
| | | if(ToolUtil.isEmpty(querySiteList.getLon())){ |
| | | querySiteListVo.setPrice(0.0); |
| | | querySiteListVo.setTimes(""); |
| | | if (ToolUtil.isEmpty(querySiteList.getLon())) { |
| | | querySiteListVo.setDistance(0D); |
| | | continue; |
| | | } |
| | | List<TSitePrice> tSitePrices = priceMap.get(querySiteListVo.getId()); |
| | | if (tSitePrices != null && !tSitePrices.isEmpty()) { |
| | | BigDecimal bigDecimal = BigDecimal.ZERO; |
| | | // 遍历 查询最小的价格 |
| | | for (TSitePrice tSitePrice : tSitePrices) { |
| | | // 当前时间再范围之内 |
| | | if (tSitePrice.getStartTime().compareTo(now) <= 0 && tSitePrice.getEndTime().compareTo(now) >= 0) { |
| | | if (tSitePrice.getCashPrice().compareTo(bigDecimal) > 0) { |
| | | bigDecimal = tSitePrice.getCashPrice(); |
| | | } |
| | | } |
| | | } |
| | | querySiteListVo.setPrice(bigDecimal.doubleValue()); |
| | | querySiteListVo.setTimes(tSitePrices.get(0).getStartTime() + "-" + tSitePrices.get(tSitePrices.size() - 1).getEndTime()); |
| | | } |
| | | Map<String, Double> distance = GeodesyUtil.getDistance(querySiteList.getLon() + "," + querySiteList.getLat(), querySiteListVo.getStoreLon() + "," + querySiteListVo.getStoreLat()); |
| | | double wgs84 = new BigDecimal(distance.get("WGS84")).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | |
| | | |
| | | /** |
| | | * 获取场地详情 |
| | | * |
| | | * @param id |
| | | * @return |
| | | * @throws Exception |
| | |
| | | SiteType siteType = siteTypeService.getById(site.getSiteTypeId()); |
| | | Store store = storeService.getById(site.getStoreId()); |
| | | QuerySiteInfoVo querySiteInfoVo = new QuerySiteInfoVo(); |
| | | if (site.getTargetAudience().contains("1")) { |
| | | querySiteInfoVo.setTargetAudience(1); |
| | | } |
| | | if (site.getTargetAudience().contains("2")) { |
| | | querySiteInfoVo.setTargetAudience(2); |
| | | } |
| | | if (site.getTargetAudience().contains("1") && site.getTargetAudience().contains("2")) { |
| | | querySiteInfoVo.setTargetAudience(3); |
| | | } |
| | | |
| | | querySiteInfoVo.setId(site.getId()); |
| | | querySiteInfoVo.setTypeName(site.getTypeName()); |
| | | querySiteInfoVo.setName(site.getName()); |
| | |
| | | |
| | | |
| | | querySiteInfoVo.setCashPriceOne(site.getCashPriceOne()); |
| | | if(site.getPlayPaiCoinOne()!=null){ |
| | | if (site.getPlayPaiCoinOne() != null) { |
| | | querySiteInfoVo.setPlayPaiCoinOne(site.getPlayPaiCoinOne().intValue()); |
| | | } |
| | | |
| | |
| | | } |
| | | querySiteInfoVo.setHalfName(halfName); |
| | | querySiteInfoVo.setNextName(nextName); |
| | | if(ToolUtil.isNotEmpty(lon) && ToolUtil.isNotEmpty(lat)){ |
| | | 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); |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | @Autowired |
| | | private ISiteBookingService iSiteBookingService; |
| | | @Autowired |
| | | private ISiteService siteService; |
| | | /** |
| | | * 获取场地预约日期数据 |
| | | * |
| | | * @param id |
| | | * @param day |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | @Override |
| | | public List<QuerySiteTimes> querySiteTimes(Integer id, String day,String halfName,String siteName) throws Exception { |
| | | public List<QuerySiteTimes> querySiteTimes(Integer id, String day, String halfName, String siteName, Integer targetAudience) throws Exception { |
| | | |
| | | System.out.println("=======date======"+day); |
| | | |
| | | System.out.println("=======date======" + day); |
| | | List<String> strings = new ArrayList<>(); |
| | | |
| | | // List<SiteBooking> siteBookings = siteClient.listBooks(id); |
| | | List<SiteBooking> siteBookings = iSiteBookingService.list(new QueryWrapper<SiteBooking>().eq("siteId", id).eq("nextName",siteName).like("times",day)); |
| | | if (siteName==null|| siteName.equals("")){ |
| | | siteBookings = iSiteBookingService.list(new QueryWrapper<SiteBooking>().eq("siteId", id).like("times",day)); |
| | | List<SiteBooking> siteBookings = iSiteBookingService.list(new QueryWrapper<SiteBooking>().eq("siteId", id).ne("status", 5).eq("nextName", siteName).like("times", day)); |
| | | |
| | | if (siteName == null || siteName.equals("")) { |
| | | siteBookings = iSiteBookingService.list(new QueryWrapper<SiteBooking>().eq("siteId", id).ne("status", 5).like("times", day)); |
| | | } |
| | | |
| | | |
| | | System.out.println("=======siteBookings======"+siteBookings); |
| | | System.out.println("=======已预约列表======" + siteBookings); |
| | | for (SiteBooking siteBooking : siteBookings) { |
| | | |
| | | |
| | |
| | | if (siteBooking.getIsHalf() == 2) { |
| | | for (String s : split) { |
| | | String convertedValue = s.substring(11); |
| | | strings.add(convertedValue); |
| | | strings.add(convertedValue + (siteBooking.getTargetAudience() != null ? "," + siteBooking.getTargetAudience() : ",1")); |
| | | } |
| | | }else { |
| | | if (halfName==null){ |
| | | } else { |
| | | if (halfName == null) { |
| | | for (String s : split) { |
| | | String convertedValue = s.substring(11); |
| | | strings.add(convertedValue); |
| | | strings.add(convertedValue + (siteBooking.getTargetAudience() != null ? "," + siteBooking.getTargetAudience() : ",1")); |
| | | } |
| | | } |
| | | |
| | | if (siteBooking.getHalfName().equals(halfName)){ |
| | | if (siteBooking.getHalfName().equals(halfName)) { |
| | | for (String s : split) { |
| | | String convertedValue = s.substring(11); |
| | | strings.add(convertedValue); |
| | | strings.add(convertedValue + (siteBooking.getTargetAudience() != null ? "," + siteBooking.getTargetAudience() : ",1")); |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | | System.out.println("======strings======="+strings); |
| | | System.out.println("======已经预约时间段=======" + strings); |
| | | |
| | | |
| | | Site site = siteService.getById(id); |
| | | List<QuerySiteTimes> timeRanges = new ArrayList<>(); |
| | | day = day.split(";")[0].split(" ")[0]; |
| | | LocalDate date = LocalDate.parse(day); |
| | | DayOfWeek dayOfWeek = date.getDayOfWeek(); |
| | | // 通过日期 确定周X 查询设置的可以约时间段和金额 封装基础时间段数据 |
| | | LambdaQueryWrapper<TSitePrice> tSitePriceLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getSiteId, id); |
| | | tSitePriceLambdaQueryWrapper.orderByAsc(TSitePrice::getStartTime); |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getTargetAudience, targetAudience); |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getDayOfWeek, dayOfWeek.getValue()); |
| | | if (StringUtils.hasLength(halfName)) { |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getFieldType, 2); |
| | | } else { |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getFieldType, 1); |
| | | } |
| | | List<TSitePrice> sitePrice = sitePriceService.list(tSitePriceLambdaQueryWrapper); |
| | | |
| | | SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm"); |
| | | |
| | | Site site = siteService.getById(id); |
| | | System.out.println("================"+site); |
| | | String appointmentStartTime = site.getAppointmentStartTime(); |
| | | String appointmentEndTime = site.getAppointmentEndTime(); |
| | | |
| | | String currentTime = appointmentStartTime; |
| | | while (currentTime.compareTo(appointmentEndTime) < 0) { |
| | | String nextTime=null; |
| | | if("智慧场地".equals(site.getTypeName())){ |
| | | nextTime=getNextTimeOne(currentTime); |
| | | }else { |
| | | nextTime= getNextTime(currentTime); |
| | | for (TSitePrice tSitePrice : sitePrice) { |
| | | QuerySiteTimes querySiteTimes = new QuerySiteTimes(); |
| | | querySiteTimes.setTime(tSitePrice.getStartTime().substring(0, tSitePrice.getStartTime().length() - 3) + "-" + tSitePrice.getEndTime().substring(0, tSitePrice.getEndTime().length() - 3)); |
| | | querySiteTimes.setSelectable(1); |
| | | querySiteTimes.setSelectCount(0); |
| | | querySiteTimes.setSelectMaxCount(site.getWalkinCapacity()); |
| | | querySiteTimes.setIsReserve(0); |
| | | querySiteTimes.setCashPrice(tSitePrice.getCashPrice()); |
| | | querySiteTimes.setCoinPrice(tSitePrice.getCoinPrice()); |
| | | String temp = tSitePrice.getStartTime().substring(0, tSitePrice.getStartTime().length() - 3) + "-" + tSitePrice.getEndTime().substring(0, tSitePrice.getEndTime().length() - 3); |
| | | String timePriceStart = day + " " + tSitePrice.getStartTime().substring(0, tSitePrice.getStartTime().length() - 3); |
| | | String timePriceEnd = day + " " + tSitePrice.getEndTime().substring(0, tSitePrice.getEndTime().length() - 3); |
| | | Date now = new Date(); |
| | | Date start = simpleDateFormat1.parse(timePriceStart); |
| | | Date end = simpleDateFormat1.parse(timePriceEnd); |
| | | // 已经预约了 判断是散客模式还是订场模式 |
| | | Integer flag = 0; |
| | | // 散客预约人数 |
| | | Integer count = 0; |
| | | for (String time : strings) { |
| | | // 先判断时间是否和预约时间有交集 |
| | | String s = time.split(",")[1]; |
| | | String timeRange = time.split(",")[0]; |
| | | String[] split = timeRange.split("-"); |
| | | String bookingStart = day + " " + split[0]; |
| | | String bookingEnd = day + " " + split[1]; |
| | | if (!isTimePeriodsIntersect(timePriceStart, timePriceEnd, bookingStart, bookingEnd)) { |
| | | // 不相交 |
| | | } else { |
| | | if (s.equals("1")) { |
| | | // 订场 不可再预约了 |
| | | querySiteTimes.setIsReserve(1); |
| | | querySiteTimes.setSelectable(0); |
| | | flag = 1; |
| | | break; |
| | | } |
| | | count++; |
| | | } |
| | | } |
| | | |
| | | |
| | | String timeRange = currentTime + "-" + nextTime; |
| | | QuerySiteTimes orderDto = new QuerySiteTimes(); |
| | | orderDto.setTime(timeRange); |
| | | |
| | | LocalTime currentTime1 = LocalTime.now(); |
| | | LocalTime targetTime = LocalTime.parse(currentTime); |
| | | |
| | | boolean hasExceeded = currentTime1.isAfter(targetTime); |
| | | // if (hasExceeded){ |
| | | // orderDto.setSelectable(0); |
| | | // } |
| | | if (strings.contains(timeRange)){ |
| | | |
| | | orderDto.setSelectable(0); |
| | | }else { |
| | | |
| | | String stime = day+" "+currentTime; |
| | | String etime = day+" "+nextTime; |
| | | orderDto.setSelectable(1); |
| | | // 查出lock |
| | | List<SiteLock> list = siteLockService.list(new LambdaQueryWrapper<SiteLock>().eq(SiteLock::getSiteId, id)); |
| | | for (SiteLock siteLock : list) { |
| | | boolean stringDateBetween = DateComparisonExample.isStringDateBetween(stime + " - " + etime, siteLock.getStartTime(), siteLock.getEndTime()); |
| | | if(stringDateBetween){ |
| | | orderDto.setSelectable(0); |
| | | if (querySiteTimes.getSelectable() == 1 && end.before(now)) { |
| | | querySiteTimes.setSelectable(0); |
| | | } |
| | | if (end.before(now)) { |
| | | querySiteTimes.setSelectable(0); |
| | | } |
| | | querySiteTimes.setSelectCount(count); |
| | | if (flag == 0 && querySiteTimes.getSelectable() == 1) { |
| | | // 当前时间段还没有预约 |
| | | Integer walkinCapacity = site.getWalkinCapacity(); |
| | | // 计算散客预约人数和最大散客容纳数 |
| | | System.err.println("预约人数" + count); |
| | | System.err.println("最大散客容纳数" + walkinCapacity); |
| | | if (walkinCapacity <= count) { |
| | | if (targetAudience == 1 && walkinCapacity != 0) { |
| | | // 不可预约 |
| | | System.err.println("不可预约 也不能散客"); |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(0); |
| | | } else if (targetAudience == 2) { |
| | | // 不能散客 |
| | | System.err.println("不可预约 也不能散客"); |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(0); |
| | | } else { |
| | | querySiteTimes.setSelectable(1); |
| | | } |
| | | } else { |
| | | if (targetAudience == 2) { |
| | | // 散客只能预约当前时间段 |
| | | SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm"); |
| | | String nowStr = simpleDateFormat.format(now); |
| | | // 判断当前时间有没有在timePriceStart和timePriceEnd之间 |
| | | if (DateComparisonExample.isStringWithinTimeRange(nowStr, simpleDateFormat.parse(timePriceStart), simpleDateFormat.parse(timePriceEnd))) { |
| | | querySiteTimes.setSelectable(1); |
| | | } else { |
| | | querySiteTimes.setSelectable(0); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | } |
| | | // 查出lock |
| | | List<SiteLock> list = siteLockService.list(new LambdaQueryWrapper<SiteLock>().eq(SiteLock::getSiteId, id)); |
| | | for (SiteLock siteLock : list) { |
| | | String stime = day + " " + tSitePrice.getStartTime().substring(0, tSitePrice.getStartTime().length() - 3); |
| | | String etime = day + " " + tSitePrice.getEndTime().substring(0, tSitePrice.getEndTime().length() - 3); |
| | | boolean stringDateBetween = DateComparisonExample.isStringDateBetween(stime + " - " + etime, siteLock.getStartTime(), siteLock.getEndTime()); |
| | | if (stringDateBetween) { |
| | | System.err.println("11111预约开始" + stime + "预约结束" + etime); |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(1); |
| | | } |
| | | if (DateComparisonExample.isStringWithinTimeRange(stime, siteLock.getStartTime(), siteLock.getEndTime())) { |
| | | System.err.println("22222预约开始" + stime + "预约结束" + etime); |
| | | |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(1); |
| | | } |
| | | if (DateComparisonExample.isStringWithinTimeRange(etime, siteLock.getStartTime(), siteLock.getEndTime())) { |
| | | System.err.println("33333预约开始" + stime + "预约结束" + etime); |
| | | |
| | | timeRanges.add(orderDto); |
| | | currentTime = nextTime; |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(1); |
| | | } |
| | | } |
| | | timeRanges.add(querySiteTimes); |
| | | } |
| | | System.out.println("-------------"+timeRanges); |
| | | System.out.println("封装后的基础时间段和价格" + site); |
| | | |
| | | // System.out.println("================" + site); |
| | | // String appointmentStartTime = site.getAppointmentStartTime(); |
| | | // String appointmentEndTime = site.getAppointmentEndTime(); |
| | | // |
| | | // String currentTime = appointmentStartTime; |
| | | // while (currentTime.compareTo(appointmentEndTime) < 0) { |
| | | // String nextTime = null; |
| | | // if ("智慧场地".equals(site.getTypeName())) { |
| | | // nextTime = getNextTimeOne(currentTime); |
| | | // } else { |
| | | // nextTime = getNextTime(currentTime); |
| | | // } |
| | | // |
| | | // |
| | | // String timeRange = currentTime + "-" + nextTime; |
| | | // QuerySiteTimes orderDto = new QuerySiteTimes(); |
| | | // orderDto.setTime(timeRange); |
| | | // |
| | | // LocalTime currentTime1 = LocalTime.now(); |
| | | // LocalTime targetTime = LocalTime.parse(currentTime); |
| | | // |
| | | // boolean hasExceeded = currentTime1.isAfter(targetTime); |
| | | //// if (hasExceeded){ |
| | | //// orderDto.setSelectable(0); |
| | | //// } |
| | | // if (strings.contains(timeRange)) { |
| | | // |
| | | // orderDto.setSelectable(0); |
| | | // } else { |
| | | // |
| | | // String stime = day + " " + currentTime; |
| | | // String etime = day + " " + nextTime; |
| | | // orderDto.setSelectable(1); |
| | | // // 查出lock |
| | | // List<SiteLock> list = siteLockService.list(new LambdaQueryWrapper<SiteLock>().eq(SiteLock::getSiteId, id)); |
| | | // for (SiteLock siteLock : list) { |
| | | // boolean stringDateBetween = DateComparisonExample.isStringDateBetween(stime + " - " + etime, siteLock.getStartTime(), siteLock.getEndTime()); |
| | | // if (stringDateBetween) { |
| | | // orderDto.setSelectable(0); |
| | | // } |
| | | // if (DateComparisonExample.isStringWithinTimeRange(stime, siteLock.getStartTime(), siteLock.getEndTime())) { |
| | | // orderDto.setSelectable(0); |
| | | // } |
| | | // if (DateComparisonExample.isStringWithinTimeRange(etime, siteLock.getStartTime(), siteLock.getEndTime())) { |
| | | // orderDto.setSelectable(0); |
| | | // } |
| | | // |
| | | // } |
| | | // |
| | | // |
| | | // } |
| | | // |
| | | // |
| | | // timeRanges.add(orderDto); |
| | | // currentTime = nextTime; |
| | | // } |
| | | System.out.println("----最后封装的时间段数据------" + timeRanges); |
| | | |
| | | return timeRanges; |
| | | |
| | | |
| | | } |
| | | |
| | | // 用于继续支付 |
| | | public List<QuerySiteTimes> querySiteTimes1(Integer siteBookingId, String day, String halfName, String siteName, Integer targetAudience) throws Exception { |
| | | |
| | | SiteBooking siteBookingServiceById = iSiteBookingService.getById(siteBookingId); |
| | | Integer id = siteBookingServiceById.getSiteId(); |
| | | System.out.println("=======date======" + day); |
| | | List<String> strings = new ArrayList<>(); |
| | | |
| | | List<SiteBooking> siteBookings = iSiteBookingService.list(new QueryWrapper<SiteBooking>() |
| | | .ne("id", siteBookingId).eq("siteId", id).ne("status", 5).eq("nextName", siteName).like("times", day)); |
| | | |
| | | if (siteName == null || siteName.equals("")) { |
| | | siteBookings = iSiteBookingService.list(new QueryWrapper<SiteBooking>().eq("siteId", id).ne("status", 5).like("times", day)); |
| | | } |
| | | |
| | | |
| | | System.out.println("=======已预约列表======" + siteBookings); |
| | | for (SiteBooking siteBooking : siteBookings) { |
| | | |
| | | |
| | | String[] split = siteBooking.getTimes().split(";"); |
| | | |
| | | if (siteBooking.getIsHalf() == 2) { |
| | | for (String s : split) { |
| | | String convertedValue = s.substring(11); |
| | | strings.add(convertedValue + (siteBooking.getTargetAudience() != null ? "," + siteBooking.getTargetAudience() : ",1")); |
| | | } |
| | | } else { |
| | | if (halfName == null) { |
| | | for (String s : split) { |
| | | String convertedValue = s.substring(11); |
| | | strings.add(convertedValue + (siteBooking.getTargetAudience() != null ? "," + siteBooking.getTargetAudience() : ",1")); |
| | | } |
| | | } |
| | | |
| | | if (siteBooking.getHalfName().equals(halfName)) { |
| | | for (String s : split) { |
| | | String convertedValue = s.substring(11); |
| | | strings.add(convertedValue + (siteBooking.getTargetAudience() != null ? "," + siteBooking.getTargetAudience() : ",1")); |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | | System.out.println("======已经预约时间段=======" + strings); |
| | | |
| | | |
| | | Site site = siteService.getById(id); |
| | | List<QuerySiteTimes> timeRanges = new ArrayList<>(); |
| | | day = day.split(";")[0].split(" ")[0]; |
| | | LocalDate date = LocalDate.parse(day); |
| | | DayOfWeek dayOfWeek = date.getDayOfWeek(); |
| | | // 通过日期 确定周X 查询设置的可以约时间段和金额 封装基础时间段数据 |
| | | LambdaQueryWrapper<TSitePrice> tSitePriceLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getSiteId, id); |
| | | tSitePriceLambdaQueryWrapper.orderByAsc(TSitePrice::getStartTime); |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getTargetAudience, targetAudience); |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getDayOfWeek, dayOfWeek.getValue()); |
| | | if (StringUtils.hasLength(halfName)) { |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getFieldType, 2); |
| | | } else { |
| | | tSitePriceLambdaQueryWrapper.eq(TSitePrice::getFieldType, 1); |
| | | } |
| | | List<TSitePrice> sitePrice = sitePriceService.list(tSitePriceLambdaQueryWrapper); |
| | | |
| | | SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm"); |
| | | |
| | | for (TSitePrice tSitePrice : sitePrice) { |
| | | QuerySiteTimes querySiteTimes = new QuerySiteTimes(); |
| | | querySiteTimes.setTime(tSitePrice.getStartTime().substring(0, tSitePrice.getStartTime().length() - 3) + "-" + tSitePrice.getEndTime().substring(0, tSitePrice.getEndTime().length() - 3)); |
| | | querySiteTimes.setSelectable(1); |
| | | querySiteTimes.setSelectCount(0); |
| | | querySiteTimes.setSelectMaxCount(site.getWalkinCapacity()); |
| | | querySiteTimes.setIsReserve(0); |
| | | querySiteTimes.setCashPrice(tSitePrice.getCashPrice()); |
| | | querySiteTimes.setCoinPrice(tSitePrice.getCoinPrice()); |
| | | String temp = tSitePrice.getStartTime().substring(0, tSitePrice.getStartTime().length() - 3) + "-" + tSitePrice.getEndTime().substring(0, tSitePrice.getEndTime().length() - 3); |
| | | String timePriceStart = day + " " + tSitePrice.getStartTime().substring(0, tSitePrice.getStartTime().length() - 3); |
| | | String timePriceEnd = day + " " + tSitePrice.getEndTime().substring(0, tSitePrice.getEndTime().length() - 3); |
| | | Date now = new Date(); |
| | | Date start = simpleDateFormat1.parse(timePriceStart); |
| | | Date end = simpleDateFormat1.parse(timePriceEnd); |
| | | // 已经预约了 判断是散客模式还是订场模式 |
| | | Integer flag = 0; |
| | | // 散客预约人数 |
| | | Integer count = 0; |
| | | for (String time : strings) { |
| | | // 先判断时间是否和预约时间有交集 |
| | | String s = time.split(",")[1]; |
| | | String timeRange = time.split(",")[0]; |
| | | String[] split = timeRange.split("-"); |
| | | String bookingStart = day + " " + split[0]; |
| | | String bookingEnd = day + " " + split[1]; |
| | | if (!isTimePeriodsIntersect(timePriceStart, timePriceEnd, bookingStart, bookingEnd)) { |
| | | // 不相交 |
| | | } else { |
| | | if (s.equals("1")) { |
| | | // 订场 不可再预约了 |
| | | querySiteTimes.setIsReserve(1); |
| | | querySiteTimes.setSelectable(0); |
| | | flag = 1; |
| | | break; |
| | | } |
| | | count++; |
| | | } |
| | | } |
| | | if (querySiteTimes.getSelectable() == 1 && end.before(now)) { |
| | | querySiteTimes.setSelectable(0); |
| | | } |
| | | if (end.before(now)) { |
| | | querySiteTimes.setSelectable(0); |
| | | } |
| | | querySiteTimes.setSelectCount(count); |
| | | if (flag == 0 && querySiteTimes.getSelectable() == 1) { |
| | | // 当前时间段还没有预约 |
| | | Integer walkinCapacity = site.getWalkinCapacity(); |
| | | // 计算散客预约人数和最大散客容纳数 |
| | | System.err.println("预约人数" + count); |
| | | System.err.println("最大散客容纳数" + walkinCapacity); |
| | | if (walkinCapacity <= count) { |
| | | if (targetAudience == 1 && walkinCapacity != 0) { |
| | | // 不可预约 |
| | | System.err.println("不可预约 也不能散客"); |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(0); |
| | | } else if (targetAudience == 2) { |
| | | // 不能散客 |
| | | System.err.println("不可预约 也不能散客"); |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(0); |
| | | } else { |
| | | querySiteTimes.setSelectable(1); |
| | | } |
| | | } else { |
| | | if (targetAudience == 2) { |
| | | // 散客只能预约当前时间段 |
| | | SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm"); |
| | | String nowStr = simpleDateFormat.format(now); |
| | | // 判断当前时间有没有在timePriceStart和timePriceEnd之间 |
| | | if (DateComparisonExample.isStringWithinTimeRange(nowStr, simpleDateFormat.parse(timePriceStart), simpleDateFormat.parse(timePriceEnd))) { |
| | | querySiteTimes.setSelectable(1); |
| | | } else { |
| | | querySiteTimes.setSelectable(0); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | // 查出lock |
| | | List<SiteLock> list = siteLockService.list(new LambdaQueryWrapper<SiteLock>().eq(SiteLock::getSiteId, id)); |
| | | for (SiteLock siteLock : list) { |
| | | String stime = day + " " + tSitePrice.getStartTime().substring(0, tSitePrice.getStartTime().length() - 3); |
| | | String etime = day + " " + tSitePrice.getEndTime().substring(0, tSitePrice.getEndTime().length() - 3); |
| | | boolean stringDateBetween = DateComparisonExample.isStringDateBetween(stime + " - " + etime, siteLock.getStartTime(), siteLock.getEndTime()); |
| | | if (stringDateBetween) { |
| | | System.err.println("11111预约开始" + stime + "预约结束" + etime); |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(1); |
| | | } |
| | | if (DateComparisonExample.isStringWithinTimeRange(stime, siteLock.getStartTime(), siteLock.getEndTime())) { |
| | | System.err.println("22222预约开始" + stime + "预约结束" + etime); |
| | | |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(1); |
| | | } |
| | | if (DateComparisonExample.isStringWithinTimeRange(etime, siteLock.getStartTime(), siteLock.getEndTime())) { |
| | | System.err.println("33333预约开始" + stime + "预约结束" + etime); |
| | | |
| | | querySiteTimes.setSelectable(0); |
| | | querySiteTimes.setIsReserve(1); |
| | | } |
| | | } |
| | | timeRanges.add(querySiteTimes); |
| | | } |
| | | System.out.println("封装后的基础时间段和价格" + site); |
| | | |
| | | // System.out.println("================" + site); |
| | | // String appointmentStartTime = site.getAppointmentStartTime(); |
| | | // String appointmentEndTime = site.getAppointmentEndTime(); |
| | | // |
| | | // String currentTime = appointmentStartTime; |
| | | // while (currentTime.compareTo(appointmentEndTime) < 0) { |
| | | // String nextTime = null; |
| | | // if ("智慧场地".equals(site.getTypeName())) { |
| | | // nextTime = getNextTimeOne(currentTime); |
| | | // } else { |
| | | // nextTime = getNextTime(currentTime); |
| | | // } |
| | | // |
| | | // |
| | | // String timeRange = currentTime + "-" + nextTime; |
| | | // QuerySiteTimes orderDto = new QuerySiteTimes(); |
| | | // orderDto.setTime(timeRange); |
| | | // |
| | | // LocalTime currentTime1 = LocalTime.now(); |
| | | // LocalTime targetTime = LocalTime.parse(currentTime); |
| | | // |
| | | // boolean hasExceeded = currentTime1.isAfter(targetTime); |
| | | //// if (hasExceeded){ |
| | | //// orderDto.setSelectable(0); |
| | | //// } |
| | | // if (strings.contains(timeRange)) { |
| | | // |
| | | // orderDto.setSelectable(0); |
| | | // } else { |
| | | // |
| | | // String stime = day + " " + currentTime; |
| | | // String etime = day + " " + nextTime; |
| | | // orderDto.setSelectable(1); |
| | | // // 查出lock |
| | | // List<SiteLock> list = siteLockService.list(new LambdaQueryWrapper<SiteLock>().eq(SiteLock::getSiteId, id)); |
| | | // for (SiteLock siteLock : list) { |
| | | // boolean stringDateBetween = DateComparisonExample.isStringDateBetween(stime + " - " + etime, siteLock.getStartTime(), siteLock.getEndTime()); |
| | | // if (stringDateBetween) { |
| | | // orderDto.setSelectable(0); |
| | | // } |
| | | // if (DateComparisonExample.isStringWithinTimeRange(stime, siteLock.getStartTime(), siteLock.getEndTime())) { |
| | | // orderDto.setSelectable(0); |
| | | // } |
| | | // if (DateComparisonExample.isStringWithinTimeRange(etime, siteLock.getStartTime(), siteLock.getEndTime())) { |
| | | // orderDto.setSelectable(0); |
| | | // } |
| | | // |
| | | // } |
| | | // |
| | | // |
| | | // } |
| | | // |
| | | // |
| | | // timeRanges.add(orderDto); |
| | | // currentTime = nextTime; |
| | | // } |
| | | System.out.println("----最后封装的时间段数据------" + timeRanges); |
| | | |
| | | return timeRanges; |
| | | |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 判断两个时间段是否有交集 |
| | | * |
| | | * @param start1 第一个时间段开始时间 |
| | | * @param end1 第一个时间段结束时间 |
| | | * @param start2 第二个时间段开始时间 |
| | | * @param end2 第二个时间段结束时间 |
| | | * @return 如果有交集返回true,否则返回false |
| | | */ |
| | | private boolean isTimePeriodsIntersect(String start1, String end1, String start2, String end2) { |
| | | // 首先判断是否有任何形式的重叠(包括端点) |
| | | boolean hasOverlap = start1.compareTo(end2) <= 0 && end1.compareTo(start2) >= 0; |
| | | |
| | | // 判断是否仅仅是端点相接 |
| | | boolean onlyTouching = start1.compareTo(end2) == 0 || end1.compareTo(start2) == 0; |
| | | |
| | | // 有重叠且不是仅仅端点相接才算真正的交集 |
| | | return hasOverlap && !onlyTouching; |
| | | } |
| | | // public static void main(String[] args) { |
| | | // String temp = "09:00-09:30"; |
| | | // List<String> strings = new ArrayList<>(); |
| | | // strings.add("09:00-09:30,1"); |
| | | // List<String> booking = strings.stream().filter(e -> e.split(",")[0].equals(temp)).collect(Collectors.toList()); |
| | | // |
| | | // System.err.println( booking); |
| | | // } |
| | | |
| | | |
| | | public static String getNextTime(String currentTime) { |
| | |
| | | return String.format("%02d:%02d", hour, minute); |
| | | |
| | | } |
| | | |
| | | public static String getNextTimeOne(String currentTime) { |
| | | |
| | | String[] parts = currentTime.split(":"); |
| | |
| | | if (minute == 45) { |
| | | hour++; |
| | | minute = 0; |
| | | } else if (minute == 0){ |
| | | } else if (minute == 0) { |
| | | minute = 15; |
| | | }else if (minute == 15){ |
| | | } else if (minute == 15) { |
| | | minute = 30; |
| | | }else if (minute == 30){ |
| | | } else if (minute == 30) { |
| | | minute = 45; |
| | | } |
| | | |
| | |
| | | |
| | | /** |
| | | * 预约场地 |
| | | * |
| | | * @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(";"); |
| | | // 所选时间段 所需总计金额 |
| | | BigDecimal money = BigDecimal.ZERO; |
| | | Integer playCoin = 0; |
| | | for (String s : split) { |
| | | String day = s.split(" ")[0]; |
| | | String time = s.split(" ")[1]; |
| | | List<QuerySiteTimes> querySiteTimes = querySiteTimes(reservationSite.getId(), day,reservationSite.getHalfName(),reservationSite.getNextName()); |
| | | String bookingStart = day + " " + time.split("-")[0]; |
| | | String bookingEnd = day + " " + time.split("-")[1]; |
| | | List<QuerySiteTimes> querySiteTimes = querySiteTimes(reservationSite.getId(), day, reservationSite.getHalfName(), reservationSite.getNextName(), reservationSite.getTargetAudience()); |
| | | for (QuerySiteTimes querySiteTime : querySiteTimes) { |
| | | if(querySiteTime.getTime().equals(time) && querySiteTime.getSelectable() == 0){ |
| | | return ResultUtil.error("【" + s + "】" + |
| | | "时间段已被使用"); |
| | | String timePriceStart = day + " " + querySiteTime.getTime().split("-")[0]; |
| | | String timePriceEnd = day + " " + querySiteTime.getTime().split("-")[1]; |
| | | if (!isTimePeriodsIntersect(timePriceStart, timePriceEnd, bookingStart, bookingEnd)) { |
| | | // 时间不相交 |
| | | } else if (querySiteTime.getSelectable() == 0) { |
| | | if (querySiteTime.getIsReserve() == 1) { |
| | | return ResultUtil.error("【" + s + "】" + |
| | | "时间段已被使用"); |
| | | } else { |
| | | return ResultUtil.error("【" + s + "】" + |
| | | "时间段散客人数已满"); |
| | | } |
| | | } |
| | | if (querySiteTime.getTime().equals(time)) { |
| | | money = money.add(querySiteTime.getCashPrice()); |
| | | playCoin = playCoin + querySiteTime.getCoinPrice(); |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | String s_time = split[0]; |
| | | String e_time = split[split.length - 1]; |
| | | s_time = s_time.substring(0,s_time.lastIndexOf("-")); |
| | | 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){ |
| | | if(reservationSite.getIsHalf()==2){ |
| | | payMoney = new BigDecimal(site.getPlayPaiCoin()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | }else { |
| | | payMoney = new BigDecimal(site.getPlayPaiCoinOne()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | } |
| | | if(appUser.getPlayPaiCoins().compareTo(payMoney.intValue()) < 0){ |
| | | if (reservationSite.getPayType() == 3) { |
| | | |
| | | return new ResultUtil(3,"玩湃币不足"); |
| | | if (appUser.getPlayPaiCoins().compareTo(playCoin.intValue()) < 0) { |
| | | return new ResultUtil(3, "玩湃币不足"); |
| | | } |
| | | }else{ |
| | | payMoney = new BigDecimal(site.getCashPrice()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | } |
| | | |
| | | //校验优惠券 |
| | | Long couponId = reservationSite.getCouponId(); |
| | | if (couponId!=null && couponId != 0){ |
| | | |
| | | if(null != couponId && reservationSite.getPayType() != 3){ |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(reservationSite.getCouponId(),uid)); |
| | | |
| | | |
| | | if(userCoupon!=null && 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(userCoupon!=null && coupon.getType() == 1){//满减 |
| | | // {"conditionalAmount":50,"deductionAmount":10,"experienceName":""} |
| | | JSONObject jsonObject = JSON.parseObject(coupon.getContent()); |
| | | Double num1 = jsonObject.getDouble("conditionalAmount"); |
| | | Double num2 = jsonObject.getDouble("deductionAmount"); |
| | | if(payMoney.compareTo(num1) <= 0){ |
| | | return ResultUtil.error("该优惠券无法使用"); |
| | | if (couponId != null && couponId != 0) { |
| | | if (null != couponId && reservationSite.getPayType() != 3) { |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(reservationSite.getCouponId(), uid)); |
| | | if (userCoupon == null || userCoupon.getStatus() == null || userCoupon.getStatus() != 1) { |
| | | return ResultUtil.error("优惠券不可用"); |
| | | } |
| | | |
| | | payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num2)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | } |
| | | if(userCoupon!=null && coupon.getType() == 2){//代金券 |
| | | JSONObject jsonObject = JSON.parseObject(coupon.getContent()); |
| | | Double num1 = jsonObject.getDouble("conditionalAmount"); |
| | | if(payMoney.compareTo(num1) <= 0){ |
| | | return ResultUtil.error("该优惠券无法使用"); |
| | | Coupon coupon = couponClient.queryCouponById(userCoupon.getCouponId()); |
| | | long time = coupon.getEndTime().getTime(); |
| | | if (System.currentTimeMillis() >= time) { |
| | | return ResultUtil.error("优惠券已过期"); |
| | | } |
| | | payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num1)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | if (userCoupon != null && coupon.getType() == 1) {//满减 |
| | | JSONObject jsonObject = JSON.parseObject(coupon.getContent()); |
| | | Double num1 = jsonObject.getDouble("conditionalAmount"); |
| | | Double num2 = jsonObject.getDouble("deductionAmount"); |
| | | if (money.compareTo(new BigDecimal(num1)) < 0) { |
| | | return ResultUtil.error("该优惠券无法使用"); |
| | | } |
| | | |
| | | money = money.subtract(new BigDecimal(num2)).max(BigDecimal.ZERO).setScale(2, RoundingMode.HALF_EVEN); |
| | | } |
| | | if (userCoupon != null && coupon.getType() == 2) {//代金券 |
| | | JSONObject jsonObject = JSON.parseObject(coupon.getContent()); |
| | | Double num1 = jsonObject.getDouble("conditionalAmount"); |
| | | if (num1 == null || num1 <= 0) { |
| | | return ResultUtil.error("该优惠券无法使用"); |
| | | } |
| | | money = money.subtract(new BigDecimal(num1)).max(BigDecimal.ZERO).setScale(2, RoundingMode.HALF_EVEN); |
| | | } |
| | | userCoupon.setStatus(2); |
| | | userCouponClient.updateUserCoupon(userCoupon); |
| | | } |
| | | userCoupon.setStatus(2); |
| | | userCouponClient.updateUserCoupon(userCoupon); |
| | | } |
| | | } |
| | | |
| | | |
| | |
| | | siteBooking.setBooker(reservationSite.getBooker()); |
| | | siteBooking.setPhone(reservationSite.getPhone()); |
| | | siteBooking.setPayType(reservationSite.getPayType()); |
| | | siteBooking.setPayMoney(payMoney); |
| | | if (reservationSite.getPayType() == 3) { |
| | | siteBooking.setPayMoney(playCoin.doubleValue()); |
| | | } else { |
| | | siteBooking.setPayMoney(money.setScale(2, RoundingMode.HALF_EVEN).doubleValue()); |
| | | } |
| | | siteBooking.setUserCouponId(reservationSite.getCouponId()); |
| | | siteBooking.setStatus(0); |
| | | siteBooking.setState(1); |
| | | siteBooking.setTargetAudience(reservationSite.getTargetAudience()); |
| | | siteBooking.setInsertTime(new Date()); |
| | | |
| | | // 2.0 |
| | | siteBooking.setMoney(money + "," + playCoin); |
| | | siteBooking.setNextName(reservationSite.getNextName()); |
| | | siteBooking.setIsHalf(reservationSite.getIsHalf()); |
| | | siteBooking.setHalfName(reservationSite.getHalfName()); |
| | | siteBookingService.save(siteBooking); |
| | | |
| | | if(reservationSite.getPayType() == 1){//微信支付 |
| | | return weChatPaymentSite(payMoney, siteBooking); |
| | | if (money.compareTo(BigDecimal.ZERO)==0){ |
| | | siteBooking.setStatus(1); |
| | | siteBooking.setPayMoney(BigDecimal.ZERO.doubleValue()); |
| | | siteBooking.setPayTime(new Date()); |
| | | siteBookingService.updateById(siteBooking); |
| | | consumeCouponAfterSuccessfulPayment(siteBooking); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("siteBooking", siteBooking.getId().toString()); |
| | | map.put("paySuccess", true); |
| | | return ResultUtil.success(map); |
| | | } |
| | | if(reservationSite.getPayType() == 2){//支付宝支付 |
| | | return aliPaymentSite(payMoney, siteBooking); |
| | | if (reservationSite.getPayType() == 1 ) {//微信支付 |
| | | ResultUtil resultUtil = weChatPaymentSite(money.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), siteBooking); |
| | | return resultUtil; |
| | | } |
| | | if(reservationSite.getPayType() == 3){//玩湃币支付 |
| | | if(reservationSite.getIsHalf()==2){ |
| | | return playPaiCoinPaymentSite(appUser, Double.valueOf(site.getPlayPaiCoin()), siteBooking); |
| | | }else { |
| | | return playPaiCoinPaymentSite(appUser, site.getPlayPaiCoinOne(), siteBooking); |
| | | } |
| | | if (reservationSite.getPayType() == 2) {//支付宝支付 |
| | | return aliPaymentSite(money.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), siteBooking); |
| | | } |
| | | if (reservationSite.getPayType() == 3) {//玩湃币支付 |
| | | return playPaiCoinPaymentSite(appUser, playCoin.doubleValue(), siteBooking); |
| | | } |
| | | |
| | | return ResultUtil.success(); |
| | | } |
| | | |
| | | private String smidVx = "2088330203191220";//平台微信商户号 |
| | | |
| | | /** |
| | | * 课程微信支付 |
| | | * |
| | | * @param paymentPrice |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | public ResultUtil weChatPaymentSite(Double paymentPrice, SiteBooking siteBooking) 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(); |
| | | Site byId = siteService.getById(siteBooking.getSiteId()); |
| | | Store store = storeService.getById(byId.getStoreId()); |
| | | if (store.getOperatorId() == null || store.getOperatorId() == 0) { |
| | | // 平台 |
| | | ResultUtil weixinpay = payMoneyUtil.weixinpay("预约场地", id.toString(), code, paymentPrice.toString(), |
| | | "/base/site/weChatPaymentSiteCallback", "APP", ""); |
| | | return appendPaySuccess(weixinpay, false); |
| | | } else { |
| | | String smidVx = operatorUserService.getmerchantNumberByOperatorId(store.getOperatorId()); |
| | | if (!StringUtils.hasLength(smidVx)) { |
| | | return ResultUtil.error("运营商未配置微信商户号,获取支付失败!"); |
| | | } |
| | | return appendPaySuccess(payMoneyUtil.weixinpayV3(smidVx, "预约场地" |
| | | , code, "/base/site/weChatPaymentSiteCallback1", |
| | | paymentPrice.toString(), id.toString()), false); |
| | | } |
| | | return weixinpay; |
| | | |
| | | |
| | | } |
| | | |
| | | private String smid = "2088330203191220";//平台支付宝商户号 |
| | | @Autowired |
| | | private IOperatorUserService operatorUserService; |
| | | @Autowired |
| | | private StoreClient storeClient; |
| | | |
| | | /** |
| | | * 课程支付宝支付 |
| | | * |
| | | * @param paymentPrice |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | public ResultUtil aliPaymentSite(Double paymentPrice, SiteBooking siteBooking) 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(); |
| | | // 判断预约的门店 属于哪个运营商 |
| | | Integer storeId = siteBooking.getStoreId(); |
| | | Store byId = storeService.getById(storeId); |
| | | Integer operatorId = byId.getOperatorId(); |
| | | String smid1 = ""; |
| | | if (operatorId == null) { |
| | | // 平台的门店 |
| | | smid1 = smid; |
| | | } else if (operatorId == 0) { |
| | | smid1 = smid; |
| | | } else { |
| | | smid1 = siteService.getmerchantNumberAliByOperatorId(operatorId); |
| | | |
| | | } |
| | | return alipay; |
| | | ResultUtil alipay = payMoneyUtil.alipay(smid1, "预约场地", "预约场地", id.toString(), code, paymentPrice.toString(), "/base/site/aliPaymentSiteCallback"); |
| | | System.out.println("预约场地----" + alipay.getCode()); |
| | | return appendPaySuccess(alipay, false); |
| | | } |
| | | |
| | | private void extracted(Integer operatorId, BigDecimal coursePackageOrder1, String tradeNo) throws Exception { |
| | | // 分账 |
| | | AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", |
| | | "2021004105665036", |
| | | "MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCi5i9nW/hGLJ3A06cZxTQdviFC7THpdSihoTYGLr9q006hu0V26ecBMY/o4w5bvIX0Ok/yofmZsVcCJpAPvbXL/uqVrIjnRRxXiaeBFThlxoBUTdunvbUSDYfzlEhJr5NvUKI6H6lz2niXlQGx4qy8Hau4ccWit9kM8jwUvsBVQoFgJA+xrjMvooA7YLopQtpOD+UJr5thApTSf1xrnr1W12yolTLEH15JmNV372cqXrYUuqnY0QsaPtxeqJUGAOcGdVLllQ7easEznP8DFBvDdHATcmp2SHNQDUEWN6MCVPbMgY06NQVqAXxqjTAYSVh+6TRu6bofPmpYC3TZB003AgMBAAECggEBAJAcR2+PA3NBYUYHeFrqBRMS8uX8ZR19kjZ7IgoSLTFaQsP9opRylPSPXhrPVBKAE5leRQAHn4MCSlESwHvMfxo7KFjFTFAc6dffZZpipYQUOc9bGampwJh58/3e/pyBgVMG6J23CPf/HJQtNFSkjd/V9+ayb/9l2dUEL3bC0fAZ/dbx8HsxdLw8wn3fLlWLj68hOMqa2deCZe3JdSVsPbeWqkh56FFsMLug0Nd+Ar4TgRl9/jnhXF0JWiD0LmPUYLhboY7EfUBzN4w1iYbDi1P+3zvoOYsiVKAXox9GMhQ2VzOO2UcSTuizSza2e98mGpabl/GpKmCz+RDFjtkX6eECgYEA2MyCij65eO3aGIm3FUe93DULRBYTfX8qJQSJq2WOWA3mmQlEW6L3O2B5/lG2h+8WmN6iLEs9eHpgycGYp7vAqgrANEn16ACVcuyx0scFtrZfZ+kmHMzFfiUWxJjVYk/6YngsGVBLdw6ueM42C8TTP67X9tU5TdVGoGWuqEj4W98CgYEAwFqwprXOch5Pqk/RPbb49r0Ou03K/UbciWnWWKzUhFFNS8MdlQPoDvQZbMwHLeWsa2VhaKITK3x5biLQb3U+0GLOn6lTvEyrEUH+ucREyLgVYTRAvwBPtnvlrzpyxPk2HnslQjju8WrvvLLBMKWUjlTrTOzhaHT21gz3pHMiOakCgYEAhLmfaXdBITGshb054sNLDtdCkGpbgEcrzAHdLps769iGxkYQHXHFngpQZUwtTUcoNGqIKknd1jZFrv7gsD+XkgKG7PwimehRlkwmCX5ilxtLiVgJRzRt6+5U5AMVD90a0tHzXYP0z2yjj73fBJF5KtGl0a10KZxaYrQdm1UhB00CgYBZZgzx/k9rtHC8LAqIj1CYhHejT92G53c6Gkl3vyOqN4sgKhfGmSEySfrDGPRBPZxr8ZtbIPCd5mUdberH0osWGMYFaJI1UsCy7aQwvGpniz7MhZeN7dweaOjwDs8mgtjHQ96mL4XGCDhR0BZ/wIURvZ/6iaGdhbbu9unlsWj3uQKBgQCmZYdsbbZkd3ev6f8rwyvMz+DrCQyYpY44cegBYuJgrZiQnL2fJioeN7ixX0UM48SfwsZEIrzshP/LGAwnc2MdjxKUl4jLN8SEe0NAjXOnz9Zaw740+aOmLpXcLWdP4uM2gIhWsvW1tEkQZCXmm7c9s/RsU8Pmzv+YL3+fSijOzA==", |
| | | "json", "GBK", |
| | | "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmu8n/4yTHWbn7VOrNc9OsLtDL1bEQ8gC1dHkj8Wy5z0mkaOsjJRIG/28ze12M0V8jdCKuuDr5Z1OPKiqf+XO3ypguEh+mYUVMBM/cZodDFQfTY1TKLWjvQCuaqlA+QUTCK6f7T7stsgyQ1o9Jj0rXZDz6PM4QHSTzjrLIBaeqM5WIBvH+fy/X+QG5Utd+/UT0kc0JyvuKhZ65yVUd/C9VcwJJAPliRsAQNrqYterwAJ9zvw9tF11wj9W0XgJ8Ccu4x3gR1vrlLRJJo/OA97RmxPQ+5hSacWQZCUd1dwiBq+YCrKVHGTj14izRHXrLc0yBlRXo7tBOIqcy3IsvKVthQIDAQAB", |
| | | "RSA2"); |
| | | AlipayTradeOrderSettleRequest request = new AlipayTradeOrderSettleRequest(); |
| | | String randomCode = UUIDUtil.getRandomCode(16); |
| | | |
| | | String proportionByOperatorId = operatorUserService.getOne(new QueryWrapper<OperatorUser>() |
| | | .eq("operatorId", operatorId)).getAlipayProportion(); |
| | | // 支付宝分账比例 |
| | | String s1 = proportionByOperatorId.split(",")[1]; |
| | | double i = Double.parseDouble(s1); |
| | | double v = i * 0.01; |
| | | BigDecimal bigDecimal1 = new BigDecimal(String.valueOf(v)); |
| | | // 分账金额 |
| | | BigDecimal bigDecimal2 = coursePackageOrder1.multiply(bigDecimal1).setScale(2, RoundingMode.DOWN); |
| | | request.setBizContent("{" + |
| | | " \"out_request_no\":\"" + randomCode + "\"," + |
| | | " \"trade_no\":\"" + tradeNo + "\"," + |
| | | " \"royalty_parameters\":[" + |
| | | " {" + |
| | | " \"royalty_type\":\"transfer\"," + |
| | | " \"trans_out\":\"" + storeClient.getSMIDByOperatorId(operatorId) + "\"," + |
| | | " \"trans_out_type\":\"userId\"," + |
| | | " \"trans_in_type\":\"userId\"," + |
| | | " \"trans_in\":\"" + smid + "\"," + |
| | | " \"amount\":" + bigDecimal2 + "," + |
| | | " \"desc\":\"平台服务费\"," + |
| | | " \"royalty_scene\":\"平台服务费\"," + |
| | | " }" + |
| | | " ]," + |
| | | " \"extend_params\":{" + |
| | | " \"royalty_finish\":\"true\"" + |
| | | " }," + |
| | | " \"royalty_mode\":\"async\"" + |
| | | "}"); |
| | | AlipayTradeOrderSettleResponse response = alipayClient.execute(request); |
| | | if (response.isSuccess()) { |
| | | System.out.println("调用成功"); |
| | | } else { |
| | | System.out.println("调用失败"); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 玩湃币支付 |
| | | * |
| | | * @param appUser |
| | | * @param paymentPrice |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | public ResultUtil playPaiCoinPaymentSite(AppUser appUser, Double paymentPrice, SiteBooking siteBooking) 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(); |
| | | consumeCouponAfterSuccessfulPayment(siteBooking); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("siteBooking", siteBooking.getId().toString()); |
| | | map.put("paySuccess", true); |
| | | return ResultUtil.success(map); |
| | | } |
| | | |
| | | /** 支付参数生成成功不等于已支付,前端仍需拉起微信或支付宝。 */ |
| | | private ResultUtil appendPaySuccess(ResultUtil paymentResult, boolean paySuccess) { |
| | | JSONObject data = paymentResult.getData() == null ? new JSONObject() |
| | | : JSON.parseObject(JSON.toJSONString(paymentResult.getData())); |
| | | if (data == null) { |
| | | data = new JSONObject(); |
| | | } |
| | | data.put("paySuccess", paySuccess); |
| | | return ResultUtil.getResult(paymentResult.getCode(), paymentResult.getMsg(), data); |
| | | } |
| | | |
| | | /** |
| | | * 场地订单实际支付成功后才核销所选优惠券;避免仅创建待支付订单就提前消耗优惠券。 |
| | | */ |
| | | private void consumeCouponAfterSuccessfulPayment(SiteBooking siteBooking) { |
| | | if (siteBooking.getUserCouponId() == null || siteBooking.getUserCouponId() == 0) { |
| | | return; |
| | | } |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById( |
| | | new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(), siteBooking.getAppUserId())); |
| | | if (userCoupon != null && Integer.valueOf(1).equals(userCoupon.getStatus())) { |
| | | userCoupon.setStatus(2); |
| | | userCouponClient.updateUserCoupon(userCoupon); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 获取我的场地预约 |
| | | * |
| | | * @param uid |
| | | * @param status |
| | | * @param pageNo |
| | |
| | | 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(";"); |
| | | if(site!=null){ |
| | | |
| | | queryMySiteVo.setPlayPaiCoin(site.getPlayPaiCoin() * split.length); |
| | | if (queryMySiteVo.getTargetAudience() == null) { |
| | | queryMySiteVo.setTargetAudience(1); |
| | | } |
| | | SiteBooking siteBooking = siteBookingService.getById(queryMySiteVo.getId()); |
| | | String[] split = siteBooking.getTimes().split(";"); |
| | | // 所选时间段 所需总计金额 |
| | | BigDecimal money = BigDecimal.ZERO; |
| | | Integer playCoin = 0; |
| | | for (String s : split) { |
| | | |
| | | String day = s.split(" ")[0]; |
| | | String time = s.split(" ")[1]; |
| | | String bookingStart = day + " " + time.split("-")[0]; |
| | | String bookingEnd = day + " " + time.split("-")[1]; |
| | | List<QuerySiteTimes> querySiteTimes = querySiteTimes(siteBooking.getId(), day, siteBooking.getHalfName(), siteBooking.getNextName(), siteBooking.getTargetAudience()); |
| | | for (QuerySiteTimes querySiteTime : querySiteTimes) { |
| | | String timePriceStart = day + " " + querySiteTime.getTime().split("-")[0]; |
| | | String timePriceEnd = day + " " + querySiteTime.getTime().split("-")[1]; |
| | | // if (!isTimePeriodsIntersect(timePriceStart, timePriceEnd, bookingStart, bookingEnd)) { |
| | | // // 时间不相交 |
| | | // } else if (querySiteTime.getSelectable() == 0) { |
| | | // if (querySiteTime.getIsReserve() == 1) { |
| | | // return ResultUtil.error("【" + s + "】" + |
| | | // "时间段已被使用"); |
| | | // } else { |
| | | // return ResultUtil.error("【" + s + "】" + |
| | | // "时间段散客人数已满"); |
| | | // } |
| | | // } |
| | | if (querySiteTime.getTime().equals(time)) { |
| | | money = money.add(querySiteTime.getCashPrice()); |
| | | playCoin = playCoin + querySiteTime.getCoinPrice(); |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | queryMySiteVo.setPlayPaiCoin(playCoin); |
| | | } |
| | | return queryMySiteVos; |
| | | } |
| | |
| | | |
| | | /** |
| | | * 取消我的预约场地 |
| | | * |
| | | * @param id |
| | | * @return |
| | | * @throws Exception |
| | |
| | | @Override |
| | | public ResultUtil cancelMySite(Integer uid, Integer id) throws Exception { |
| | | SiteBooking siteBooking = siteBookingService.getById(id); |
| | | |
| | | Site byId = siteService.getById(siteBooking.getSiteId()); |
| | | SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd"); |
| | | Date startTime = siteBooking.getStartTime(); |
| | | if(format.format(new Date()).equals(format.format(startTime))){ |
| | | if (siteBooking.getTargetAudience() == 1 && format.format(new Date()).equals(format.format(startTime)) && siteBooking.getStatus() != 0) { |
| | | return ResultUtil.error("预约当天,不能取消"); |
| | | } |
| | | if(siteBooking.getStatus() == 0){ |
| | | return ResultUtil.error("请先进行支付"); |
| | | if (siteBooking.getTargetAudience() == 2) { |
| | | Date date = new Date(); |
| | | if (siteBooking.getEndTime().before(date)) { |
| | | return ResultUtil.error("已过期,不能取消"); |
| | | } |
| | | } |
| | | if(siteBooking.getStatus() != 1 && siteBooking.getStatus() != 2){ |
| | | if (siteBooking.getStatus() == 0) { |
| | | siteBooking.setStatus(5); |
| | | siteBookingService.updateById(siteBooking); |
| | | AppUser appUser = appUserClient.queryAppUser(siteBooking.getAppUserId()); |
| | | |
| | | if (null != siteBooking.getUserCouponId() && siteBooking.getUserCouponId() != 0) { |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(), appUser.getId())); |
| | | userCoupon.setStatus(1); |
| | | userCouponClient.updateUserCoupon(userCoupon); |
| | | } |
| | | |
| | | return ResultUtil.success(); |
| | | } |
| | | 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); |
| | | Integer storeId = siteBooking.getStoreId(); |
| | | Store store = storeService.getById(storeId); |
| | | |
| | | TBackRecord tBackRecord = new TBackRecord(); |
| | | tBackRecord.setMoney(siteBooking.getPayMoney()); |
| | | tBackRecord.setUserId(siteBooking.getAppUserId()); |
| | | tBackRecord.setTime(new Date()); |
| | | backRecordService.save(tBackRecord); |
| | | if (siteBooking.getPayType() == 1) {//微信支付 |
| | | if (store.getOperatorId() != null && store.getOperatorId() != 0) { |
| | | String smidVx = operatorUserService.getmerchantNumberByOperatorId(store.getOperatorId()); |
| | | if (!StringUtils.hasLength(smidVx)) { |
| | | return ResultUtil.error("运营商未配置微信商户号,获取支付失败!"); |
| | | } |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); |
| | | String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5);// 退款单号 |
| | | // 运营商退款 |
| | | payMoneyUtil.weixinRefundV3(smidVx, code, siteBooking.getPayOrderNo(), siteBooking.getPayMoney().toString(), "/base/site/cancelMySiteCallback1"); |
| | | } else { |
| | | 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 return_code = map.get("return_code"); |
| | | if (!"SUCCESS".equals(return_code)) { |
| | | return ResultUtil.error(map.get("return_msg")); |
| | | } |
| | | siteBooking.setCancelUserId(uid); |
| | | siteBookingService.updateById(siteBooking); |
| | | |
| | | TBackRecord tBackRecord = new TBackRecord(); |
| | | tBackRecord.setMoney(siteBooking.getPayMoney()); |
| | | tBackRecord.setUserId(siteBooking.getAppUserId()); |
| | | tBackRecord.setTime(new Date()); |
| | | backRecordService.save(tBackRecord); |
| | | } |
| | | |
| | | |
| | | } |
| | | if(siteBooking.getPayType() == 2){//支付宝 |
| | | if (siteBooking.getPayType() == 2) {//支付宝 |
| | | Map<String, String> map = payMoneyUtil.aliRefund(siteBooking.getPayOrderNo(), siteBooking.getPayMoney().toString()); |
| | | if(null == map){ |
| | | if (null == map) { |
| | | return ResultUtil.error("取消退款异常"); |
| | | } |
| | | String code = map.get("code"); |
| | | if(!"10000".equals(code)){ |
| | | if (!"10000".equals(code)) { |
| | | return ResultUtil.error(map.get("return_msg")); |
| | | } |
| | | String trade_no = map.get("trade_no"); |
| | |
| | | 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())); |
| | | if (null != siteBooking.getUserCouponId() && siteBooking.getUserCouponId() != 0) { |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(), siteBooking.getAppUserId())); |
| | | userCoupon.setStatus(1); |
| | | userCouponClient.updateUserCoupon(userCoupon); |
| | | } |
| | |
| | | backRecordService.save(tBackRecord); |
| | | } |
| | | |
| | | if(siteBooking.getPayType() == 3){//玩湃币 |
| | | if (siteBooking.getPayType() == 3) {//玩湃币 |
| | | AppUser appUser = appUserClient.queryAppUser(siteBooking.getAppUserId()); |
| | | appUser.setPlayPaiCoins(appUser.getPlayPaiCoins() + siteBooking.getPayMoney().intValue()); |
| | | appUserClient.updateAppUser(appUser); |
| | |
| | | siteBooking.setCancelUserId(uid); |
| | | siteBooking.setCancelTime(new Date()); |
| | | siteBookingService.updateById(siteBooking); |
| | | if(null != siteBooking.getUserCouponId()){ |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),appUser.getId())); |
| | | if (null != siteBooking.getUserCouponId() && siteBooking.getUserCouponId() != 0) { |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(), appUser.getId())); |
| | | userCoupon.setStatus(1); |
| | | userCouponClient.updateUserCoupon(userCoupon); |
| | | } |
| | |
| | | |
| | | /** |
| | | * 继续支付我预约的场地 |
| | | * |
| | | * @param id |
| | | * @param payType |
| | | * @return |
| | |
| | | @Override |
| | | public ResultUtil continuePaymentMySite(Integer uid, Integer id, Integer payType) throws Exception { |
| | | SiteBooking siteBooking = siteBookingService.getById(id); |
| | | if(siteBooking.getStatus() != 0){ |
| | | 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{ |
| | | if(reservationSite.getIsHalf()==2){ |
| | | payMoney = new BigDecimal(site.getCashPrice()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | }else { |
| | | payMoney = new BigDecimal(site.getCashPriceOne()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | // 所选时间段 所需总计金额 |
| | | BigDecimal money = BigDecimal.ZERO; |
| | | Integer playCoin = 0; |
| | | for (String s : split) { |
| | | String day = s.split(" ")[0]; |
| | | String time = s.split(" ")[1]; |
| | | String bookingStart = day + " " + time.split("-")[0]; |
| | | String bookingEnd = day + " " + time.split("-")[1]; |
| | | List<QuerySiteTimes> querySiteTimes = querySiteTimes1(siteBooking.getId(), day, siteBooking.getHalfName(), siteBooking.getNextName(), siteBooking.getTargetAudience()); |
| | | for (QuerySiteTimes querySiteTime : querySiteTimes) { |
| | | String timePriceStart = day + " " + querySiteTime.getTime().split("-")[0]; |
| | | String timePriceEnd = day + " " + querySiteTime.getTime().split("-")[1]; |
| | | if (querySiteTime.getTime().equals(time)) { |
| | | money = money.add(querySiteTime.getCashPrice()); |
| | | playCoin = playCoin + querySiteTime.getCoinPrice(); |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | |
| | | //校验优惠券 |
| | | Long couponId = siteBooking.getUserCouponId(); |
| | | if(null != couponId && payType != 3){ |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),appUser.getId())); |
| | | 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){//满减 |
| | | if (coupon.getType() == 1) {//满减 |
| | | // {"conditionalAmount":50,"deductionAmount":10,"experienceName":""} |
| | | JSONObject jsonObject = JSON.parseObject(coupon.getContent()); |
| | | Double num1 = jsonObject.getDouble("conditionalAmount"); |
| | | Double num2 = jsonObject.getDouble("deductionAmount"); |
| | | payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num2)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | money = money.subtract(new BigDecimal(num2)).setScale(2, RoundingMode.HALF_EVEN); |
| | | } |
| | | if(coupon.getType() == 2){//代金券 |
| | | if (coupon.getType() == 2) {//代金券 |
| | | JSONObject jsonObject = JSON.parseObject(coupon.getContent()); |
| | | Double num1 = jsonObject.getDouble("conditionalAmount"); |
| | | payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num1)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | money = money.subtract(new BigDecimal(num1)).max(BigDecimal.ZERO).setScale(2, RoundingMode.HALF_EVEN); |
| | | } |
| | | 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); |
| | | if (payType == 3) { |
| | | siteBooking.setPayMoney(playCoin.doubleValue()); |
| | | } else { |
| | | siteBooking.setPayMoney(money.doubleValue()); |
| | | } |
| | | siteBookingService.updateById(siteBooking); |
| | | if(payType == 1){//微信支付 |
| | | return weChatPaymentSite(payMoney, siteBooking); |
| | | if (payType == 1) {//微信支付 |
| | | return weChatPaymentSite(money.doubleValue(), siteBooking); |
| | | } |
| | | if(payType == 2){//支付宝支付 |
| | | return aliPaymentSite(payMoney, siteBooking); |
| | | if (payType == 2) {//支付宝支付 |
| | | return aliPaymentSite(money.doubleValue(), siteBooking); |
| | | } |
| | | if(payType == 3){//玩湃币支付 |
| | | return playPaiCoinPaymentSite(appUser, payMoney, siteBooking); |
| | | if (payType == 3) {//玩湃币支付 |
| | | return playPaiCoinPaymentSite(appUser, playCoin.doubleValue(), 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){ |
| | | 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(); |
| | | // 所选时间段 所需总计金额 |
| | | BigDecimal money = BigDecimal.ZERO; |
| | | Integer playCoin = 0; |
| | | for (String s : split) { |
| | | String day = s.split(" ")[0]; |
| | | String time = s.split(" ")[1]; |
| | | String bookingStart = day + " " + time.split("-")[0]; |
| | | String bookingEnd = day + " " + time.split("-")[1]; |
| | | List<QuerySiteTimes> querySiteTimes = querySiteTimes1(siteBooking.getId(), day, siteBooking.getHalfName(), siteBooking.getNextName(), siteBooking.getTargetAudience()); |
| | | for (QuerySiteTimes querySiteTime : querySiteTimes) { |
| | | String timePriceStart = day + " " + querySiteTime.getTime().split("-")[0]; |
| | | String timePriceEnd = day + " " + querySiteTime.getTime().split("-")[1]; |
| | | if (querySiteTime.getTime().equals(time)) { |
| | | money = money.add(querySiteTime.getCashPrice()); |
| | | playCoin = playCoin + querySiteTime.getCoinPrice(); |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | |
| | | //校验优惠券 |
| | | Long couponId = siteBooking.getUserCouponId(); |
| | | if(null != couponId){ |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),siteBooking.getAppUserId())); |
| | | if (null != couponId && couponId != 0) { |
| | | UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(), siteBooking.getAppUserId())); |
| | | Coupon coupon = couponClient.queryCouponById(userCoupon.getCouponId()); |
| | | if(coupon.getType() == 1){//满减 |
| | | if (coupon.getType() == 1) {//满减 |
| | | // {"conditionalAmount":50,"deductionAmount":10,"experienceName":""} |
| | | JSONObject jsonObject = JSON.parseObject(coupon.getContent()); |
| | | Double num1 = jsonObject.getDouble("conditionalAmount"); |
| | | Double num2 = jsonObject.getDouble("deductionAmount"); |
| | | payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num2)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | money = money.subtract(new BigDecimal(num2)).setScale(2, RoundingMode.HALF_EVEN); |
| | | } |
| | | if(coupon.getType() == 2){//代金券 |
| | | if (coupon.getType() == 2) {//代金券 |
| | | JSONObject jsonObject = JSON.parseObject(coupon.getContent()); |
| | | Double num1 = jsonObject.getDouble("conditionalAmount"); |
| | | payMoney = new BigDecimal(payMoney).subtract(new BigDecimal(num1)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); |
| | | money = money.subtract(new BigDecimal(num1)).max(BigDecimal.ZERO).setScale(2, RoundingMode.HALF_EVEN); |
| | | } |
| | | } |
| | | map.put("cash", payMoney); |
| | | switch (siteBooking.getPayType()) { |
| | | case 1: |
| | | map.put("cash", money.doubleValue()); |
| | | break; |
| | | case 2: |
| | | map.put("cash", money.doubleValue()); |
| | | break; |
| | | case 3: |
| | | map.put("cash", playCoin.doubleValue()); |
| | | } |
| | | return ResultUtil.success(map); |
| | | } |
| | | |
| | |
| | | |
| | | List<Integer> siteIds = vo.getSiteIds(); |
| | | Integer type = vo.getType(); |
| | | return siteMapper.changeState(siteIds,type); |
| | | return siteMapper.changeState(siteIds, type); |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public String getSMIDByOperatorId(Integer id) { |
| | | return siteMapper.getSMIDByOperatorId(id); |
| | | } |
| | | |
| | | @Override |
| | | public String getmerchantNumberByOperatorId(Integer id) { |
| | | return siteMapper.getmerchantNumberByOperatorId(id); |
| | | } |
| | | |
| | | @Override |
| | | public String getmerchantNumberAliByOperatorId(Integer id) { |
| | | return siteMapper.getmerchantNumberAliByOperatorId(id); |
| | | } |
| | | } |