| | |
| | | import com.dsh.account.feignclient.activity.UserConponClient; |
| | | import com.dsh.account.feignclient.activity.model.*; |
| | | import com.dsh.account.feignclient.competition.DeductionCompetitionsClient; |
| | | import com.dsh.account.feignclient.competition.model.BillingDataRequestVo; |
| | | import com.dsh.account.feignclient.competition.model.PaymentCompetition; |
| | | import com.dsh.account.feignclient.course.CoursePackageClient; |
| | | import com.dsh.account.feignclient.course.CoursePackageConfigClient; |
| | | import com.dsh.account.feignclient.course.CoursePaymentClient; |
| | | import com.dsh.account.feignclient.course.VideoOfCourseListClient; |
| | | import com.dsh.account.feignclient.course.model.*; |
| | | import com.dsh.account.feignclient.other.ImgConfigClient; |
| | | import com.dsh.account.feignclient.other.RechargeConfigClient; |
| | | import com.dsh.account.feignclient.other.SiteClient; |
| | | import com.dsh.account.feignclient.other.StoreClient; |
| | | import com.dsh.account.feignclient.other.model.*; |
| | | import com.dsh.account.feignclient.other.model.SiteBooking; |
| | | import com.dsh.account.feignclient.other.model.Store; |
| | | import com.dsh.account.feignclient.other.model.StoreDetailOfCourse; |
| | | import com.dsh.account.feignclient.other.model.TImgConfig; |
| | | import com.dsh.account.mapper.*; |
| | | import com.dsh.account.model.AddAppUserVo; |
| | | import com.dsh.account.model.JoinPlayPaiVo; |
| | | import com.dsh.account.model.LoginSMSCodeVo; |
| | | import com.dsh.account.model.LoginWeChatVo; |
| | | import com.dsh.account.model.*; |
| | | import com.dsh.account.model.dto.Coupon; |
| | | import com.dsh.account.model.vo.classDetails.CourseVenue; |
| | | import com.dsh.account.model.vo.classDetails.ExerciseVideo; |
| | | import com.dsh.account.model.vo.classDetails.RegisteredCourse; |
| | | import com.dsh.account.model.vo.classDetails.WeekedCourse; |
| | | import com.dsh.account.model.vo.classDetails.classInsVo.ClassInfoVo; |
| | | import com.dsh.account.model.vo.userBenefitDetail.*; |
| | | import com.dsh.account.service.TAppUserService; |
| | | import com.dsh.account.util.*; |
| | | import com.dsh.account.util.akeylogin.Md5Util; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.domain.Page; |
| | | import org.springframework.data.domain.PageImpl; |
| | | import org.springframework.data.domain.PageRequest; |
| | | import org.springframework.data.domain.Pageable; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.StringUtils; |
| | | import org.springframework.web.bind.annotation.RequestBody; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.annotation.Resource; |
| | | import javax.servlet.http.HttpServletRequest; |
| | | import java.io.IOException; |
| | | import java.math.BigDecimal; |
| | | import java.text.ParseException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | |
| | | @Resource |
| | | private ImgConfigClient icfgClient; |
| | | |
| | | |
| | | @Resource |
| | | private VideoOfCourseListClient voclClient; |
| | | |
| | | @Resource |
| | | private VipPaymentMapper vipPaymentMapper; |
| | | |
| | |
| | | @Resource |
| | | private MerChandiseStoreClient mcsClient; |
| | | |
| | | @Resource |
| | | private CoursePackageConfigClient cpconClient; |
| | | |
| | | @Resource |
| | | private PayMoneyUtil payMoneyUtil; |
| | | |
| | | @Resource |
| | | private SiteClient stClient; |
| | | |
| | | @Override |
| | | public ClassInfoVo queryUserOfStus(Integer id,String latitude,String longitude) { |
| | | public ClassInfoVo queryUserOfStus(Integer id) { |
| | | TAppUser tAppUser = this.baseMapper.selectById(id); |
| | | ClassInfoVo classInfoVo = new ClassInfoVo(); |
| | | if (ToolUtil.isNotEmpty(tAppUser)){ |
| | |
| | | classInfoVo.setHeight(tStudent.getHeight()); |
| | | classInfoVo.setWeight(tStudent.getWeight()); |
| | | classInfoVo.setBmi(tStudent.getBmi()); |
| | | classInfoVo.setBodyStatus(BMIBodyUtil.getBodyStatus(tStudent.getBmi())); |
| | | |
| | | List<RegisteredCourse> courseList = new ArrayList<>(); |
| | | // 总学时数 |
| | | int total = 0; |
| | | // 已扣数 |
| | | int deduct = 0; |
| | | // 剩余数 |
| | | int remain = 0; |
| | | List<StuCourseResp> stuCoursePayment = paymentClient.getStuCoursePayment(); |
| | | List<StuCourseResp> stuCoursePayment = paymentClient.getStuCoursePayment(tStudent.getId()); |
| | | List<Integer> coursePackIds = new ArrayList<>(); |
| | | if (stuCoursePayment.size() > 0){ |
| | | coursePackIds = stuCoursePayment.stream().map(StuCourseResp::getCourseId).collect(Collectors.toList()); |
| | | for (StuCourseResp tCoursePackagePayment : stuCoursePayment) { |
| | | RegisteredCourse course = new RegisteredCourse(); |
| | | course.setCourseId(tCoursePackagePayment.getCourseId()); |
| | | course.setCourseName(tCoursePackagePayment.getCourseName()); |
| | | total = total + (ToolUtil.isEmpty(tCoursePackagePayment.getTotalCourseNums()) ? 0 : tCoursePackagePayment.getTotalCourseNums()); |
| | | deduct = deduct + (ToolUtil.isEmpty(tCoursePackagePayment.getDeductionNums()) ? 0 : tCoursePackagePayment.getDeductionNums()); |
| | | remain = remain + (ToolUtil.isEmpty(tCoursePackagePayment.getResidueNums())? 0 : tCoursePackagePayment.getResidueNums()); |
| | | course.setTotalNums(ToolUtil.isEmpty(tCoursePackagePayment.getTotalCourseNums()) ? 0 : tCoursePackagePayment.getTotalCourseNums()); |
| | | course.setDeductedNums(ToolUtil.isEmpty(tCoursePackagePayment.getDeductionNums()) ? 0 : tCoursePackagePayment.getDeductionNums()); |
| | | course.setRemainingNums(ToolUtil.isEmpty(tCoursePackagePayment.getResidueNums())? 0 : tCoursePackagePayment.getResidueNums()); |
| | | course.setPeriodOfValidity(tCoursePackagePayment.getPeriodOfValidity()); |
| | | courseList.add(course); |
| | | } |
| | | } |
| | | classInfoVo.setCourseList(courseList); |
| | | |
| | | classInfoVo.setTotalNums(total); |
| | | classInfoVo.setDeductedNums(deduct); |
| | | classInfoVo.setRemainingNums(remain); |
| | | |
| | | List<CourseOfStoreVo> storeOfCourses = paymentClient.getStoreOfCourses(); |
| | | classInfoVo.setWeekCourseList(dealDatas(storeOfCourses,longitude,latitude)); |
| | | |
| | | List<ExerciseVideo> videos = new ArrayList<>(); |
| | | |
| | | classInfoVo.setExerciseVideoList(videos); |
| | | List<ExerciseVideo> stuCourseOfVideoList = voclClient.getStuCourseOfVideoList(coursePackIds); |
| | | System.out.println(stuCourseOfVideoList); |
| | | classInfoVo.setExerciseVideoList(stuCourseOfVideoList); |
| | | }else { |
| | | classInfoVo.setIsThere(2); |
| | | List<TImgConfig> tImgConfigs = configClient.getNoneStuImgs(); |
| | |
| | | * @param latitude |
| | | * @return |
| | | */ |
| | | public List<WeekedCourse> dealDatas(List<CourseOfStoreVo> storeOfCourses,String longitude ,@RequestBody String latitude){ |
| | | List<WeekedCourse> weekedCourses = new ArrayList<>(); |
| | | for (int i = 1; i < 8; i++) { |
| | | WeekedCourse weekedCourse = new WeekedCourse(); |
| | | List<CourseVenue> courseVenues = new ArrayList<>(); |
| | | Map<Integer, List<CourseOfStoreVo>> map = storeOfCourses.stream().collect(Collectors.groupingBy(CourseOfStoreVo::getStoreId)); |
| | | for (Map.Entry<Integer, List<CourseOfStoreVo>> integerListEntry : map.entrySet()) { |
| | | List<CourseOfStoreVo> value = integerListEntry.getValue(); |
| | | CourseVenue courseVenue = new CourseVenue(); |
| | | courseVenue.setStoreId(value.get(0).getStoreId()); |
| | | courseVenue.setAreaName(value.get(0).getStoreName()); |
| | | public List<CourseVenue> dealDatas(List<CourseOfStoreVo> storeOfCourses, String longitude , String latitude){ |
| | | List<CourseVenue> courseVenues = new ArrayList<>(); |
| | | Map<Integer, List<CourseOfStoreVo>> map = storeOfCourses.stream().collect(Collectors.groupingBy(CourseOfStoreVo::getStoreId)); |
| | | for (Map.Entry<Integer, List<CourseOfStoreVo>> integerListEntry : map.entrySet()) { |
| | | Integer storeId = integerListEntry.getKey(); |
| | | List<CourseOfStoreVo> value = integerListEntry.getValue(); |
| | | CourseVenue courseVenue = new CourseVenue(); |
| | | courseVenue.setStoreId(storeId); |
| | | courseVenue.setAreaName(value.get(0).getCourseName()); |
| | | if (ToolUtil.isEmpty(longitude) && ToolUtil.isEmpty(latitude)){ |
| | | courseVenue.setSiteDistance(0+""); |
| | | }else { |
| | | courseVenue.setSiteDistance(LonlatUtils.distance(Double.parseDouble(longitude), Double.parseDouble(latitude), |
| | | Double.parseDouble(value.get(0).getLon()), Double.parseDouble(value.get(0).getLat())) + ""); |
| | | |
| | | List<CourseVenue.CouList> courses = new ArrayList<>(); |
| | | for (CourseOfStoreVo courseOfStoreVo : value) { |
| | | CourseVenue.CouList couList = new CourseVenue.CouList(); |
| | | couList.setCourseID(courseOfStoreVo.getCourseId()); |
| | | couList.setCourseName(courseOfStoreVo.getCourseName()); |
| | | couList.setTimeStr(courseOfStoreVo.getClassStartTime() + "-" + courseOfStoreVo.getClassEndTime()); |
| | | couList.setDetail(""); |
| | | courses.add(couList); |
| | | } |
| | | courseVenue.setCourses(courses); |
| | | courseVenues.add(courseVenue); |
| | | } |
| | | weekedCourse.setDetails(courseVenues); |
| | | weekedCourses.add(weekedCourse); |
| | | List<CourseVenue.CouList> courses = new ArrayList<>(); |
| | | for (CourseOfStoreVo courseOfStoreVo : value) { |
| | | CourseVenue.CouList couList = new CourseVenue.CouList(); |
| | | couList.setCourseID(courseOfStoreVo.getCourseId()); |
| | | couList.setCourseName(courseOfStoreVo.getCourseName()); |
| | | couList.setTimeStr(courseOfStoreVo.getClassStartTime() + "-" + courseOfStoreVo.getClassEndTime()); |
| | | couList.setDetail("¥" + courseOfStoreVo.getCoursePrice() + "/会员扣2学时"); |
| | | couList.setStatus(courseOfStoreVo.getStatus()); |
| | | courses.add(couList); |
| | | } |
| | | courseVenue.setCourses(courses); |
| | | courseVenues.add(courseVenue); |
| | | } |
| | | return weekedCourses; |
| | | return courseVenues; |
| | | } |
| | | |
| | | |
| | |
| | | TAppUser appUser = this.getById(appUserId); |
| | | benefirVo.setUserHeadImg(appUser.getHeadImg()); |
| | | benefirVo.setUserName(appUser.getName()); |
| | | benefirVo.setWpCoin(ToolUtil.isEmpty(appUser.getPlayPaiCoins()) ? 0 : appUser.getPlayPaiCoins()); |
| | | benefirVo.setUserIntegral(ToolUtil.isEmpty(appUser.getIntegral()) ? 0 : appUser.getIntegral()); |
| | | if (appUser.getIsVip() == 1){ |
| | | benefirVo.setIsMember("年度会员"); |
| | | }else { |
| | | benefirVo.setIsMember("普通用户"); |
| | | } |
| | | benefirVo.setCommodities(mcClient.getConvertibleGoods()); |
| | | List<IntegralCommodity> convertibleGoods = mcClient.getConvertibleGoods(); |
| | | benefirVo.setCommodities(convertibleGoods); |
| | | benefirVo.setImage(icfgClient.getImageConfig()); |
| | | return benefirVo; |
| | | } |
| | | |
| | | @Override |
| | | public BillingDetailsVo queryUserBillingDetails(String yearMonth, Integer recordId, Integer appUserId) { |
| | | BillingDetailsVo vo = new BillingDetailsVo(); |
| | | List<BillingDetailsVo.ConsumeDetail> details = new ArrayList<>(); |
| | | public List<ConsumeDetail> queryUserBillingDetails(String yearMonth, Integer recordId, Integer appUserId) { |
| | | List<ConsumeDetail> details = new ArrayList<>(); |
| | | |
| | | SimpleDateFormat simpleDateFormat = new SimpleDateFormat("MM-dd HH:mm"); |
| | | SimpleDateFormat result = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date monthStart = null; |
| | | Date monthEnd = null; |
| | | if (StringUtils.hasText(yearMonth)) { |
| | |
| | | monthStart = DateTimeHelper.getCurrentMouthStart(); |
| | | monthEnd = DateTimeHelper.getCurrentMouthEnd(); |
| | | } |
| | | |
| | | BillingDataRequestVo requestVo = new BillingDataRequestVo(); |
| | | requestVo.setMonthStart(result.format(monthStart)); |
| | | requestVo.setMonthEnd(result.format(monthEnd)); |
| | | requestVo.setAppUserId(appUserId); |
| | | // 1.赛事报名 |
| | | List<PaymentCompetition> allCompetitionPayRecord = deducClient.getAllCompetitionPayRecord(appUserId); |
| | | if (allCompetitionPayRecord.size() > 0 ){ |
| | | for (PaymentCompetition paymentCompetition : allCompetitionPayRecord) { |
| | | BillingDetailsVo.ConsumeDetail consumeDetail = new BillingDetailsVo.ConsumeDetail(); |
| | | BillingRequestVo allCompetitionPayRecord = deducClient.getAllCompetitionPayRecord(requestVo); |
| | | if (ToolUtil.isNotEmpty(allCompetitionPayRecord.getRequests())){ |
| | | for (BillingRequest paymentCompetition : allCompetitionPayRecord.getRequests()) { |
| | | ConsumeDetail consumeDetail = new ConsumeDetail(); |
| | | consumeDetail.setConsumeName(RechargeRecordEnum.EVENT_REGISTRATION.getMsg()); |
| | | consumeDetail.setConsumeTime(simpleDateFormat.format(paymentCompetition.getInsertTime())); |
| | | consumeDetail.setConsumeTime(paymentCompetition.getTime()); |
| | | consumeDetail.setConsumeAmount("-" + paymentCompetition.getAmount()); |
| | | details.add(consumeDetail); |
| | | consumeDetail.setType(1); |
| | | } |
| | | } |
| | | // 2.取消赛事报名 |
| | | List<PaymentCompetition> cancelOrderOfUserPayRecord = deducClient.getCancelOrderOfUserPayRecord(appUserId); |
| | | if (cancelOrderOfUserPayRecord.size() > 0 ){ |
| | | for (PaymentCompetition paymentCompetition : cancelOrderOfUserPayRecord) { |
| | | BillingDetailsVo.ConsumeDetail consumeDetail = new BillingDetailsVo.ConsumeDetail(); |
| | | BillingRequestVo cancelOrderOfUserPayRecord = deducClient.getCancelOrderOfUserPayRecord(requestVo); |
| | | if (ToolUtil.isNotEmpty(cancelOrderOfUserPayRecord.getRequests())){ |
| | | for (BillingRequest paymentCompetition : cancelOrderOfUserPayRecord.getRequests()) { |
| | | ConsumeDetail consumeDetail = new ConsumeDetail(); |
| | | consumeDetail.setConsumeName(RechargeRecordEnum.CANCEL_EVENT_REGISTRATION.getMsg()); |
| | | consumeDetail.setConsumeTime(simpleDateFormat.format(paymentCompetition.getInsertTime())); |
| | | consumeDetail.setConsumeTime(paymentCompetition.getTime()); |
| | | consumeDetail.setConsumeAmount("+" + paymentCompetition.getAmount()); |
| | | consumeDetail.setType(1); |
| | | details.add(consumeDetail); |
| | | } |
| | | } |
| | | // 3.课包购买 |
| | | List<TCoursePackagePayment> amountPayRecord = paymentClient.getAmountPayRecord(appUserId); |
| | | if (amountPayRecord.size() > 0 ){ |
| | | for (TCoursePackagePayment coursePackagePayment : amountPayRecord) { |
| | | BillingDetailsVo.ConsumeDetail consumeDetail = new BillingDetailsVo.ConsumeDetail(); |
| | | BillingRequestVo amountPayRecord = paymentClient.getAmountPayRecord(requestVo); |
| | | if (ToolUtil.isNotEmpty(amountPayRecord.getRequests())){ |
| | | for (BillingRequest coursePackagePayment : amountPayRecord.getRequests()) { |
| | | ConsumeDetail consumeDetail = new ConsumeDetail(); |
| | | consumeDetail.setConsumeName(RechargeRecordEnum.COURSE_PACKAGE_PURCHASE.getMsg()); |
| | | consumeDetail.setConsumeTime(simpleDateFormat.format(coursePackagePayment.getInsertTime())); |
| | | consumeDetail.setConsumeAmount("-" + coursePackagePayment.getCashPayment()); |
| | | consumeDetail.setConsumeTime(coursePackagePayment.getTime()); |
| | | consumeDetail.setConsumeAmount("-" + coursePackagePayment.getAmount()); |
| | | consumeDetail.setType(2); |
| | | details.add(consumeDetail); |
| | | } |
| | | } |
| | | // 4.场地预约 |
| | | RequestOfTypeVo allSiteBookingList = stClient.getAllSiteBookingList(requestVo); |
| | | if (ToolUtil.isNotEmpty(allSiteBookingList.getRequest())){ |
| | | for (BillingRequestOfType booking : allSiteBookingList.getRequest()) { |
| | | ConsumeDetail consumeDetail = new ConsumeDetail(); |
| | | if (booking.getStatus() != 5){ |
| | | consumeDetail.setConsumeName(RechargeRecordEnum.VENUE_RESERVATION.getMsg()); |
| | | consumeDetail.setConsumeAmount("-" + booking.getAmount()); |
| | | consumeDetail.setConsumeTime(booking.getTime()); |
| | | consumeDetail.setType(2); |
| | | }else { |
| | | consumeDetail.setConsumeName(RechargeRecordEnum.CANCEL_VENUE_RESERVATION.getMsg()); |
| | | consumeDetail.setConsumeAmount("+" + booking.getAmount()); |
| | | consumeDetail.setConsumeTime(booking.getTime()); |
| | | consumeDetail.setType(1); |
| | | } |
| | | details.add(consumeDetail); |
| | | } |
| | | } |
| | | |
| | | // 5.智慧球场 |
| | | // 6.年度会员 |
| | | List<VipPayment> vipPayments = vipPaymentMapper.selectList(new QueryWrapper<VipPayment>() |
| | |
| | | .between("insertTime", monthStart, monthEnd)); |
| | | if (vipPayments.size() > 0) { |
| | | for (VipPayment vipPayment : vipPayments) { |
| | | BillingDetailsVo.ConsumeDetail consumeDetail = new BillingDetailsVo.ConsumeDetail(); |
| | | ConsumeDetail consumeDetail = new ConsumeDetail(); |
| | | consumeDetail.setConsumeName(RechargeRecordEnum.ANNUAL_MEMBERSHIP.getMsg()); |
| | | consumeDetail.setConsumeTime(simpleDateFormat.format(vipPayment.getInsertTime())); |
| | | consumeDetail.setConsumeAmount("-" + vipPayment.getAmount()); |
| | | consumeDetail.setType(2); |
| | | details.add(consumeDetail); |
| | | } |
| | | } |
| | |
| | | .between("insertTime", monthStart, monthEnd)); |
| | | if (rechargeRecords.size() > 0) { |
| | | for (RechargeRecords rechargeRecord : rechargeRecords) { |
| | | BillingDetailsVo.ConsumeDetail consumeDetail = new BillingDetailsVo.ConsumeDetail(); |
| | | ConsumeDetail consumeDetail = new ConsumeDetail(); |
| | | consumeDetail.setConsumeName(RechargeRecordEnum.RECHARGE.getMsg() + ":" + rechargeRecord.getPlayPaiCoins()); |
| | | consumeDetail.setConsumeTime(simpleDateFormat.format(rechargeRecord.getInsertTime())); |
| | | consumeDetail.setConsumeAmount("-" + rechargeRecord.getAmount()); |
| | | consumeDetail.setType(2); |
| | | details.add(consumeDetail); |
| | | } |
| | | } |
| | | if (details.size() > 0 ){ |
| | | Collections.sort(details, new Comparator<ConsumeDetail>() { |
| | | @Override |
| | | public int compare(ConsumeDetail record1, ConsumeDetail record2) { |
| | | SimpleDateFormat dateFormat = new SimpleDateFormat("MM-dd HH:mm"); |
| | | Date date1 = null; |
| | | Date date2 = null; |
| | | try { |
| | | date1 = dateFormat.parse(record1.getConsumeTime()); |
| | | date2 = dateFormat.parse(record2.getConsumeTime()); |
| | | } catch (ParseException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | // 倒序排序 |
| | | return date2.compareTo(date1); |
| | | } |
| | | }); |
| | | |
| | | vo.setDetails(details); |
| | | return vo; |
| | | if (ToolUtil.isNotEmpty(recordId)){ |
| | | details = details.stream() |
| | | .filter(response -> Objects.equals(response.getType(), recordId)) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | } |
| | | return details; |
| | | } |
| | | |
| | | @Override |
| | |
| | | List<RechargeCentVo> centVos = new ArrayList<>(); |
| | | TAppUser tAppUser = this.baseMapper.selectById(appUserId); |
| | | List<Map<String, Object>> rechargeConfig = reconMapper.getRechargeConfig(); |
| | | System.out.println(rechargeConfig); |
| | | if (rechargeConfig.size() > 0 ){ |
| | | for (Map<String, Object> stringObjectMap : rechargeConfig) { |
| | | RechargeCentVo vo = new RechargeCentVo(); |
| | | vo.setAmount("¥ "+stringObjectMap.get("money")); |
| | | Double money = (Double) stringObjectMap.get("money"); |
| | | vo.setAmount(BigDecimal.valueOf(money) ); |
| | | if (tAppUser.getIsVip() == 1){ |
| | | vo.setWpGold(stringObjectMap.get("MemberCoins")+"币"); |
| | | vo.setWpGold((Integer) stringObjectMap.get("MemberCoins")); |
| | | }else { |
| | | vo.setWpGold(stringObjectMap.get("usersCoins")+"币"); |
| | | vo.setWpGold((Integer) stringObjectMap.get("usersCoins")); |
| | | } |
| | | centVos.add(vo); |
| | | } |
| | |
| | | } |
| | | |
| | | @Override |
| | | public PointMallDetailsResponse queryAppUserIntegral(MallRequest request, Integer userIdFormRedis) { |
| | | PointMallDetailsResponse detailsResponse = new PointMallDetailsResponse(); |
| | | List<PointMallDetailsResponse.Goods> goods = new ArrayList<>(); |
| | | |
| | | TAppUser tAppUser = this.baseMapper.selectById(userIdFormRedis); |
| | | detailsResponse.setName(tAppUser.getName()); |
| | | detailsResponse.setIntegral(tAppUser.getIntegral()); |
| | | detailsResponse.setHeadImg(tAppUser.getHeadImg()); |
| | | public List<Goods> queryAppUserIntegral(MallRequest request ) { |
| | | List<Goods> goods = new ArrayList<>(); |
| | | |
| | | CommodityRequest commodityRequest = new CommodityRequest(); |
| | | commodityRequest.setLon(request.getLon()); |
| | | commodityRequest.setLat(request.getLat()); |
| | | List<PointsMerchandise> vicinityGoods = mcClient.getVicinityGoods(commodityRequest); |
| | | if (vicinityGoods.size() > 0) { |
| | | for (PointsMerchandise vicinityGood : vicinityGoods) { |
| | | PointMallDetailsResponse.Goods commodity = new PointMallDetailsResponse.Goods(); |
| | | PointMerchandiseVo vicinityGoods = mcClient.getVicinityGoods(commodityRequest); |
| | | if (ToolUtil.isNotEmpty(vicinityGoods.getMerchandises())) { |
| | | for (PointsMerchandise vicinityGood : vicinityGoods.getMerchandises()) { |
| | | Goods commodity = new Goods(); |
| | | switch (vicinityGood.getType()) { |
| | | case 1: |
| | | commodity.setGoodId(vicinityGood.getId()); |
| | |
| | | List<Coupon> allCoupons = ucponClient.getAllCoupons(commodityRequest); |
| | | if (allCoupons.size() > 0) { |
| | | for (Coupon allCoupon : allCoupons) { |
| | | PointMallDetailsResponse.Goods commodity = new PointMallDetailsResponse.Goods(); |
| | | Goods commodity = new Goods(); |
| | | commodity.setGoodId(allCoupon.getId()); |
| | | commodity.setGoodName(allCoupon.getName()); |
| | | commodity.setCondition(allCoupon.getRedemptionMethod()); |
| | |
| | | } |
| | | } |
| | | if (StringUtils.hasText(request.getSearch())){ |
| | | goods = goods.stream() |
| | | .filter(merchandise -> merchandise.getGoodName().contains(request.getSearch())) |
| | | .collect(Collectors.toList()); |
| | | if (goods.size() > 0 ){ |
| | | goods = goods.stream() |
| | | .filter(merchandise -> merchandise.getGoodName().contains(request.getSearch())) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | } |
| | | if (null != request.getRank()){ |
| | | switch (request.getRank()){ |
| | | case 1: |
| | | goods = goods.stream() |
| | | .sorted(Comparator.comparing(PointMallDetailsResponse.Goods::getIntegral).reversed()) |
| | | .collect(Collectors.toList()); |
| | | if (goods.size() > 0 ){ |
| | | goods = goods.stream() |
| | | .sorted(Comparator.comparing(Goods::getIntegral).reversed()) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | break; |
| | | case 2: |
| | | goods = goods.stream() |
| | | .sorted(Comparator.comparing(PointMallDetailsResponse.Goods::getIntegral)) |
| | | .collect(Collectors.toList()); |
| | | if (goods.size() > 0 ){ |
| | | goods = goods.stream() |
| | | .sorted(Comparator.comparing(Goods::getIntegral)) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | break; |
| | | case 3: |
| | | goods = goods.stream() |
| | | .sorted(Comparator.comparing(PointMallDetailsResponse.Goods::getNums).reversed()) |
| | | .collect(Collectors.toList()); |
| | | if (goods.size() > 0 ){ |
| | | goods = goods.stream() |
| | | .sorted(Comparator.comparing(Goods::getNums).reversed()) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | break; |
| | | default: |
| | | break; |
| | |
| | | |
| | | } |
| | | if (null != request.getGoodsType()){ |
| | | goods = goods.stream() |
| | | .filter(merchandise -> merchandise.getGoodsType().equals(request.getGoodsType())) |
| | | .collect(Collectors.toList()); |
| | | if (goods.size() > 0 ){ |
| | | goods = goods.stream() |
| | | .filter(merchandise -> merchandise.getGoodsType().equals(request.getGoodsType())) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | } |
| | | detailsResponse.setGoods(goods); |
| | | return detailsResponse; |
| | | |
| | | //当前第几页 |
| | | int pageNo = request.getPageNum(); |
| | | //一页五条 |
| | | int size = request.getPageSize(); |
| | | |
| | | //分页 |
| | | goods = goods.stream().skip((pageNo - 1) * size).limit(size). |
| | | collect(Collectors.toList()); |
| | | return goods; |
| | | } |
| | | |
| | | @Override |
| | | public ResultUtil uploadAppUserHeadImg(Integer appUserId, MultipartFile file, HttpServletRequest request) { |
| | | try { |
| | | String filePath = OssUploadUtil.ossUpload(request,file); |
| | | TAppUser tAppUser = this.baseMapper.selectById(appUserId); |
| | | tAppUser.setHeadImg(filePath); |
| | | this.baseMapper.updateById(tAppUser); |
| | | } catch (IOException e) { |
| | | ResultUtil.error("头像上传失败!"); |
| | | } |
| | | |
| | | return ResultUtil.success(); |
| | | // 对数据进行分页处理的方法 |
| | | private static Page<Goods> getPage(List<Goods> dataList, Pageable pageable) { |
| | | int start = (int) pageable.getOffset(); |
| | | int end = Math.min((start + pageable.getPageSize()), dataList.size()); |
| | | return new PageImpl<>(dataList.subList(start, end), pageable, dataList.size()); |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | |
| | | @Override |
| | | public ResultUtil productRedemptionOperation(Integer userIdFormRedis, Integer goodId, Integer goodsType,Integer nums,Integer exchangeType,Integer payType) { |
| | | PointsMerchandise merchandise = mcClient.selectPointsMerchandiseById(goodId); |
| | | public ResultUtil productRedemptionOperation(Integer userIdFormRedis, GoodsExchangeVo exchangeType) { |
| | | System.out.println("exchangeType:--->"); |
| | | System.out.println(exchangeType); |
| | | |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); |
| | | String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5); |
| | | for (int i = 0; i < nums; i++) { |
| | | PointsMerchandise merchandise = mcClient.selectPointsMerchandiseById(exchangeType.getGoodId()); |
| | | if (ToolUtil.isEmpty(merchandise)){ |
| | | return ResultUtil.error("商品不存在"); |
| | | } |
| | | TAppUser tAppUser = this.baseMapper.selectById(userIdFormRedis); |
| | | if (ToolUtil.isEmpty(tAppUser)){ |
| | | return ResultUtil.error("用户不存在"); |
| | | } |
| | | // todo 积分商品明细 查询是否超出限领数量 |
| | | switch (exchangeType.getGoodsType()){ |
| | | case 1: |
| | | |
| | | break; |
| | | case 2: |
| | | |
| | | break; |
| | | case 3: |
| | | |
| | | break; |
| | | case 4: |
| | | |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | int goodsNums = 0; |
| | | if (ToolUtil.isEmpty(exchangeType.getNums())){ |
| | | goodsNums = 1; |
| | | }else { |
| | | goodsNums = exchangeType.getNums(); |
| | | } |
| | | for (int i = 0; i < goodsNums; i++) { |
| | | // 新增积分商品兑换记录 |
| | | UserPointsMerchandise pointsMerchandise = new UserPointsMerchandise(); |
| | | pointsMerchandise.setPointsMerchandiseId(goodId); |
| | | pointsMerchandise.setPointsMerchandiseId(exchangeType.getGoodId()); |
| | | pointsMerchandise.setUserId(userIdFormRedis); |
| | | pointsMerchandise.setStatus(1); |
| | | if (merchandise.getUseScope() == 3){ |
| | | if (exchangeType.getGoodsType() == 2){ |
| | | CoursePackage coursePackage = cpageClient.queryCoursePackageById(merchandise.getCoursePackageId()); |
| | | pointsMerchandise.setStoreId(coursePackage.getStoreId()); |
| | | }else { |
| | | pointsMerchandise.setStoreId(exchangeType.getStoreId()); |
| | | } |
| | | } |
| | | pointsMerchandise.setCode(code); |
| | | mcClient.saveDetailsUserPointMercase(pointsMerchandise); |
| | | } |
| | | |
| | | // 扣减积分 |
| | | TAppUser tAppUser = this.baseMapper.selectById(userIdFormRedis); |
| | | |
| | | |
| | | // 积分变更记录 |
| | | UserIntegralChanges userIntegralChanges = new UserIntegralChanges(); |
| | | userIntegralChanges.setAppUserId(userIdFormRedis); |
| | | userIntegralChanges.setOldIntegral(tAppUser.getIntegral()); |
| | | userIntegralChanges.setType(2); |
| | | tAppUser.setIntegral(null == tAppUser.getIntegral() ? merchandise.getIntegral() : tAppUser.getIntegral() +merchandise.getIntegral()); |
| | | userIntegralChanges.setNewIntegral(tAppUser.getIntegral()); |
| | | userIntegralChanges.setInsertTime(new Date()); |
| | | uicMapper.insert(userIntegralChanges); |
| | | |
| | | this.baseMapper.updateById(tAppUser); |
| | | // 现金支付 |
| | | if (exchangeType == 1){ |
| | | // 积分兑换 |
| | | switch (goodsType){ |
| | | case 2: |
| | | for (int i = 0; i < nums; i++) { |
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
| | | // packagePayment.setAppUserId(); |
| | | // TODO: 2023/7/14 |
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
| | | switch (exchangeType.getExchangeType()){ |
| | | // 积分 |
| | | case 1: |
| | | boolean b = dealAppUserIntegral(userIdFormRedis,tAppUser,merchandise.getIntegral()); |
| | | if (b){ |
| | | switch (exchangeType.getGoodsType()){ |
| | | case 2: |
| | | Integer stuNums = 0; |
| | | if (ToolUtil.isNotEmpty(exchangeType.getStuIds())){ |
| | | stuNums = exchangeType.getStuIds().size(); |
| | | }else { |
| | | stuNums = 1; |
| | | } |
| | | for (int i = 0; i < stuNums; i++) { |
| | | List<CoursePackagePaymentConfig> courseConfigList = cpconClient.getCourseConfigList(merchandise.getCoursePackageId()); |
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
| | | packagePayment.setAppUserId(userIdFormRedis); |
| | | packagePayment.setStudentId(exchangeType.getStuIds().get(i)); |
| | | packagePayment.setCoursePackageId(merchandise.getCoursePackageId()); |
| | | for (CoursePackagePaymentConfig coursePackagePaymentConfig : courseConfigList) { |
| | | if (Objects.equals(coursePackagePaymentConfig.getId(), merchandise.getCoursePackageConfigId())) { |
| | | packagePayment.setClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setTotalClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setLaveClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); |
| | | break; |
| | | } |
| | | } |
| | | packagePayment.setPlayPaiCoin(merchandise.getIntegral()); |
| | | packagePayment.setAbsencesNumber(0); |
| | | packagePayment.setPayUserType(1); |
| | | packagePayment.setPayStatus(2); |
| | | packagePayment.setPayUserId(userIdFormRedis); |
| | | packagePayment.setStatus(1); |
| | | packagePayment.setState(1); |
| | | packagePayment.setInsertTime(new Date()); |
| | | packagePayment.setCode(code); |
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
| | | } |
| | | break; |
| | | case 4: |
| | | for (int i = 0; i < goodsNums; i++) { |
| | | UserCoupon coupon = new UserCoupon(); |
| | | coupon.setCouponId(exchangeType.getGoodId()); |
| | | coupon.setUserId(userIdFormRedis); |
| | | coupon.setStatus(1); |
| | | coupon.setInsertTime(new Date()); |
| | | ucponClient.insertToAppuserCoupon(coupon); |
| | | } |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | break; |
| | | case 4: |
| | | for (int i = 0; i < nums; i++) { |
| | | UserCoupon coupon = new UserCoupon(); |
| | | coupon.setCouponId(goodId); |
| | | coupon.setUserId(userIdFormRedis); |
| | | coupon.setStatus(1); |
| | | coupon.setInsertTime(new Date()); |
| | | ucponClient.insertToAppuserCoupon(coupon); |
| | | }else { |
| | | return ResultUtil.error("用户积分不足!"); |
| | | } |
| | | break; |
| | | case 2: |
| | | // 积分+现金 |
| | | boolean dealt = dealAppUserIntegral(userIdFormRedis,tAppUser,merchandise.getIntegral()); |
| | | if (dealt){ |
| | | switch (exchangeType.getGoodsType()){ |
| | | // 1实物 2课包 3门票 4优惠券 |
| | | case 2: |
| | | Integer stuNums = 0; |
| | | if (ToolUtil.isNotEmpty(exchangeType.getStuIds())){ |
| | | stuNums = exchangeType.getStuIds().size(); |
| | | }else { |
| | | stuNums = 1; |
| | | } |
| | | for (int i = 0; i < stuNums; i++) { |
| | | List<CoursePackagePaymentConfig> courseConfigList = cpconClient.getCourseConfigList(merchandise.getCoursePackageId()); |
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
| | | packagePayment.setAppUserId(userIdFormRedis); |
| | | packagePayment.setStudentId(exchangeType.getStuIds().get(i)); |
| | | packagePayment.setCoursePackageId(merchandise.getCoursePackageId()); |
| | | for (CoursePackagePaymentConfig coursePackagePaymentConfig : courseConfigList) { |
| | | if (Objects.equals(coursePackagePaymentConfig.getId(), merchandise.getCoursePackageConfigId())) { |
| | | packagePayment.setClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setTotalClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setLaveClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); |
| | | break; |
| | | } |
| | | } |
| | | packagePayment.setPlayPaiCoin(merchandise.getIntegral()); |
| | | packagePayment.setAbsencesNumber(0); |
| | | packagePayment.setPayUserType(1); |
| | | packagePayment.setPayStatus(1); |
| | | packagePayment.setPayUserId(userIdFormRedis); |
| | | packagePayment.setStatus(1); |
| | | packagePayment.setState(1); |
| | | packagePayment.setInsertTime(new Date()); |
| | | packagePayment.setCode(code); |
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
| | | } |
| | | break; |
| | | case 4: |
| | | for (int i = 0; i < goodsNums; i++) { |
| | | UserCoupon coupon = new UserCoupon(); |
| | | coupon.setCouponId(exchangeType.getGoodId()); |
| | | coupon.setUserId(userIdFormRedis); |
| | | coupon.setStatus(1); |
| | | coupon.setInsertTime(new Date()); |
| | | ucponClient.insertToAppuserCoupon(coupon); |
| | | } |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | }else { |
| | | switch (payType){ |
| | | case 1: |
| | | return WechatPayment(merchandise.getCash(),code); |
| | | case 2: |
| | | return AlipayPayment(merchandise.getCash(),code); |
| | | default: |
| | | break; |
| | | } |
| | | }else { |
| | | return ResultUtil.error("用户积分不足!"); |
| | | } |
| | | switch (exchangeType.getPayType()) { |
| | | case 1: |
| | | try { |
| | | if (merchandise.getType() == 2) { |
| | | return WechatPayment(merchandise.getCash().multiply(new BigDecimal(exchangeType.getStuIds().size())), code); |
| | | } else { |
| | | return WechatPayment(merchandise.getCash().multiply(new BigDecimal(goodsNums)), code); |
| | | } |
| | | } catch (Exception e) { |
| | | return ResultUtil.runErr(); |
| | | } |
| | | case 2: |
| | | if (merchandise.getType() == 2) { |
| | | return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(exchangeType.getStuIds().size())), code); |
| | | } else { |
| | | return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(goodsNums)), code); |
| | | } |
| | | default: |
| | | break; |
| | | } |
| | | break; |
| | | case 3: |
| | | // 现金 |
| | | switch (exchangeType.getGoodsType()){ |
| | | case 2: |
| | | Integer stuNums = 0; |
| | | if (ToolUtil.isNotEmpty(exchangeType.getStuIds())){ |
| | | stuNums = exchangeType.getStuIds().size(); |
| | | }else { |
| | | stuNums = 1; |
| | | } |
| | | for (int i = 0; i < stuNums; i++) { |
| | | List<CoursePackagePaymentConfig> courseConfigList = cpconClient.getCourseConfigList(merchandise.getCoursePackageId()); |
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
| | | packagePayment.setAppUserId(userIdFormRedis); |
| | | packagePayment.setStudentId(exchangeType.getStuIds().get(i)); |
| | | packagePayment.setCoursePackageId(merchandise.getCoursePackageId()); |
| | | for (CoursePackagePaymentConfig coursePackagePaymentConfig : courseConfigList) { |
| | | if (Objects.equals(coursePackagePaymentConfig.getId(), merchandise.getCoursePackageConfigId())) { |
| | | packagePayment.setClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setTotalClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setLaveClassHours(coursePackagePaymentConfig.getClassHours()); |
| | | packagePayment.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); |
| | | break; |
| | | } |
| | | } |
| | | packagePayment.setCashPayment(merchandise.getCash()); |
| | | packagePayment.setAbsencesNumber(0); |
| | | packagePayment.setPayUserType(1); |
| | | packagePayment.setPayStatus(1); |
| | | packagePayment.setPayUserId(userIdFormRedis); |
| | | packagePayment.setStatus(1); |
| | | packagePayment.setState(1); |
| | | packagePayment.setInsertTime(new Date()); |
| | | packagePayment.setCode(code); |
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
| | | } |
| | | break; |
| | | case 4: |
| | | for (int i = 0; i < goodsNums; i++) { |
| | | UserCoupon coupon = new UserCoupon(); |
| | | coupon.setCouponId(exchangeType.getGoodId()); |
| | | coupon.setUserId(userIdFormRedis); |
| | | coupon.setStatus(1); |
| | | coupon.setInsertTime(new Date()); |
| | | ucponClient.insertToAppuserCoupon(coupon); |
| | | } |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | switch (exchangeType.getPayType()) { |
| | | case 1: |
| | | try { |
| | | if (merchandise.getType() == 2) { |
| | | return WechatPayment(merchandise.getCash().multiply(new BigDecimal(exchangeType.getStuIds().size())), code); |
| | | } else { |
| | | return WechatPayment(merchandise.getCash().multiply(new BigDecimal(goodsNums)), code); |
| | | } |
| | | } catch (Exception e) { |
| | | return ResultUtil.runErr(); |
| | | } |
| | | case 2: |
| | | if (merchandise.getType() == 2) { |
| | | return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(exchangeType.getStuIds().size())), code); |
| | | } else { |
| | | return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(goodsNums)), code); |
| | | } |
| | | default: |
| | | break; |
| | | } |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | |
| | | return null; |
| | | return ResultUtil.success(); |
| | | } |
| | | |
| | | public boolean dealAppUserIntegral(Integer appUserId,TAppUser appUser,Integer points){ |
| | | try { |
| | | if (ToolUtil.isEmpty(appUser.getIntegral()) || (ToolUtil.isNotEmpty(appUser.getIntegral()) && appUser.getIntegral() < points)){ |
| | | return false; |
| | | } |
| | | // 积分变更记录 |
| | | UserIntegralChanges userIntegralChanges = new UserIntegralChanges(); |
| | | userIntegralChanges.setAppUserId(appUserId); |
| | | userIntegralChanges.setOldIntegral(appUser.getIntegral()); |
| | | userIntegralChanges.setType(2); |
| | | appUser.setIntegral(null == appUser.getIntegral() ? points : appUser.getIntegral() - points); |
| | | userIntegralChanges.setNewIntegral(appUser.getIntegral()); |
| | | userIntegralChanges.setInsertTime(new Date()); |
| | | uicMapper.insert(userIntegralChanges); |
| | | |
| | | this.baseMapper.updateById(appUser); |
| | | return true; |
| | | }catch (Exception e){ |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | private ResultUtil AlipayPayment(BigDecimal cash, String code) { |
| | | |
| | | return ResultUtil.success(); |
| | | ResultUtil alipay = payMoneyUtil.alipay("课包续费", "", "", code, cash.toString(), |
| | | "/base/pointMer/exchangeGoodPaymentAliCallback"); |
| | | 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); |
| | | List<UserPointsMerchandise> userPointsMerchandises = mcClient.queryUserPointMerchaseByCode(code); |
| | | if(userPointsMerchandises.get(0).getPayStatus() == 2){ |
| | | break; |
| | | } |
| | | ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryALIOrder(code); |
| | | if(resultUtil.getCode() == 200 && userPointsMerchandises.get(0).getPayStatus() == 1){ |
| | | /** |
| | | * 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){ |
| | | // coursePackagePayment.setState(3); |
| | | // couPayClient.delPaymentCoursePackage(coursePackagePayment.getId()); |
| | | // break; |
| | | // } |
| | | if("TRADE_SUCCESS".equals(s)){ |
| | | for (UserPointsMerchandise userPointsMerchandise : userPointsMerchandises) { |
| | | userPointsMerchandise.setPayStatus(2); |
| | | userPointsMerchandise.setOrderNumber(tradeNo); |
| | | userPointsMerchandise.setPayType(2); |
| | | mcClient.updateDetailsUserPointMercase(userPointsMerchandise); |
| | | } |
| | | break; |
| | | } |
| | | if("WAIT_BUYER_PAY".equals(s)){ |
| | | num++; |
| | | } |
| | | } |
| | | } |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | }).start(); |
| | | } |
| | | return alipay; |
| | | } |
| | | |
| | | private ResultUtil WechatPayment(BigDecimal cash, String code) { |
| | | |
| | | return ResultUtil.success(); |
| | | private ResultUtil WechatPayment(BigDecimal cash, String code) throws Exception { |
| | | ResultUtil weixinpay = payMoneyUtil.weixinpay("课包", "", code, cash.toString(), |
| | | "/base/pointMer/exchangeGoodPaymentWeChatCallback", "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); |
| | | List<UserPointsMerchandise> userPointsMerchandises = mcClient.queryUserPointMerchaseByCode(code); |
| | | if(userPointsMerchandises.get(0).getPayStatus() == 2){ |
| | | break; |
| | | } |
| | | ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(code, ""); |
| | | if(resultUtil.getCode() == 200 && userPointsMerchandises.get(0).getPayStatus() == 1){ |
| | | /** |
| | | * 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){ |
| | | // coursePackagePayment.setState(3); |
| | | // couPayClient.delPaymentCoursePackage(coursePackagePayment.getId()); |
| | | // break; |
| | | // } |
| | | if("SUCCESS".equals(s)){ |
| | | for (UserPointsMerchandise userPointsMerchandise : userPointsMerchandises) { |
| | | userPointsMerchandise.setPayStatus(2); |
| | | userPointsMerchandise.setOrderNumber(transaction_id); |
| | | userPointsMerchandise.setPayType(1); |
| | | mcClient.updateDetailsUserPointMercase(userPointsMerchandise); |
| | | } |
| | | break; |
| | | } |
| | | if("USERPAYING".equals(s)){ |
| | | num++; |
| | | } |
| | | } |
| | | } |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | }).start(); |
| | | } |
| | | return weixinpay; |
| | | } |
| | | |
| | | @Override |
| | |
| | | if (userPointsMerchandises.size() > 1){ |
| | | for (int i = 0; i < userPointsMerchandises.size(); i++) { |
| | | userPointsMerchandises.get(i).setOrderNumber(orderNumber+ "-" + (i+1)); |
| | | userPointsMerchandises.get(i).setPayType(payType); |
| | | userPointsMerchandises.get(i).setPayStatus(2); |
| | | mcClient.updateDetailsUserPointMercase(userPointsMerchandises.get(i)); |
| | | |
| | | Integer pointsMerchandiseId = userPointsMerchandises.get(i).getPointsMerchandiseId(); |
| | | PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerchandiseId); |
| | | switch (pointsMerchandise.getType()){ |
| | | case 2: |
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
| | | |
| | | // packagePayment.setAppUserId(); |
| | | |
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
| | | List<TCoursePackagePayment> coursePackagePaymentOfCode = paymentClient.getCoursePackagePaymentOfCode(code); |
| | | for (TCoursePackagePayment coursePackagePayment : coursePackagePaymentOfCode) { |
| | | coursePackagePayment.setPayStatus(2); |
| | | coursePackagePayment.setPayType(payType); |
| | | coursePackagePayment.setOrderNumber(orderNumber); |
| | | coursePackagePayment.setCashPayment(pointsMerchandise.getCash()); |
| | | paymentClient.updatePaymentCoursePackage(coursePackagePayment); |
| | | } |
| | | break; |
| | | case 4: |
| | | UserCoupon coupon = new UserCoupon(); |
| | |
| | | } |
| | | }else { |
| | | userPointsMerchandises.get(0).setOrderNumber(orderNumber); |
| | | userPointsMerchandises.get(0).setPayType(payType); |
| | | userPointsMerchandises.get(0).setPayStatus(2); |
| | | mcClient.updateDetailsUserPointMercase(userPointsMerchandises.get(0)); |
| | | |
| | | Integer pointsMerchandiseId = userPointsMerchandises.get(0).getPointsMerchandiseId(); |
| | | PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerchandiseId); |
| | | switch (pointsMerchandise.getType()){ |
| | | case 2: |
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
| | | List<TCoursePackagePayment> coursePackagePaymentOfCode = paymentClient.getCoursePackagePaymentOfCode(code); |
| | | |
| | | // packagePayment.setAppUserId(); |
| | | |
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
| | | TCoursePackagePayment packagePayment =coursePackagePaymentOfCode.get(0); |
| | | packagePayment.setPayStatus(2); |
| | | packagePayment.setPayType(payType); |
| | | packagePayment.setOrderNumber(orderNumber); |
| | | packagePayment.setCashPayment(pointsMerchandise.getCash()); |
| | | paymentClient.updatePaymentCoursePackage(packagePayment); |
| | | break; |
| | | case 4: |
| | | UserCoupon coupon = new UserCoupon(); |
| | |
| | | List<StoreResponse> responses = new ArrayList<>(); |
| | | if (goodsType == 4){ |
| | | List<Integer> couponStoreIds = ucponClient.getCouponStoreIds(pointsMerId); |
| | | for (Integer couponStoreId : couponStoreIds) { |
| | | StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(couponStoreId); |
| | | if(ToolUtil.isNotEmpty(courseOfStore)){ |
| | | StoreResponse response = new StoreResponse(); |
| | | response.setStoreId(couponStoreId); |
| | | response.setStoreName(courseOfStore.getStoreName()); |
| | | responses.add(response); |
| | | if (couponStoreIds.size() > 0 ){ |
| | | for (Integer couponStoreId : couponStoreIds) { |
| | | StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(couponStoreId); |
| | | if(ToolUtil.isNotEmpty(courseOfStore)){ |
| | | StoreResponse response = new StoreResponse(); |
| | | response.setStoreId(couponStoreId); |
| | | response.setStoreName(courseOfStore.getStoreName()); |
| | | responses.add(response); |
| | | } |
| | | } |
| | | } |
| | | |
| | | }else { |
| | | List<Integer> integers = mcsClient.queryPointMerStoreIds(pointsMerId); |
| | | for (Integer integer : integers) { |
| | | StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(integer); |
| | | if(ToolUtil.isNotEmpty(courseOfStore)){ |
| | | StoreResponse response = new StoreResponse(); |
| | | response.setStoreId(integer); |
| | | response.setStoreName(courseOfStore.getStoreName()); |
| | | responses.add(response); |
| | | if (integers.size() > 0 ){ |
| | | for (Integer integer : integers) { |
| | | StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(integer); |
| | | if(ToolUtil.isNotEmpty(courseOfStore)){ |
| | | StoreResponse response = new StoreResponse(); |
| | | response.setStoreId(integer); |
| | | response.setStoreName(courseOfStore.getStoreName()); |
| | | responses.add(response); |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public List<CourseVenue> queryWeekOfCourseDetails(Integer appUserId ,Integer stuId, String time,String longitude,String latitude) { |
| | | List<CourseVenue> courseVenues = new ArrayList<>(); |
| | | WeeksOfCourseRest weeksOfCourseRest = new WeeksOfCourseRest(); |
| | | weeksOfCourseRest.setTime(time); |
| | | weeksOfCourseRest.setStuId(stuId); |
| | | weeksOfCourseRest.setAppUserId(appUserId); |
| | | List<CourseOfStoreVo> storeOfCourses = paymentClient.getStoreOfCourses(weeksOfCourseRest); |
| | | System.out.println(storeOfCourses); |
| | | if (storeOfCourses.size() > 0 ){ |
| | | courseVenues = dealDatas(storeOfCourses,longitude,latitude); |
| | | } |
| | | return courseVenues; |
| | | } |
| | | |
| | | |
| | | } |