From f5ca8f01cf6b8256a25e8c6838d805fe3fca43fc Mon Sep 17 00:00:00 2001 From: liujie <liujie> Date: 星期一, 07 八月 2023 11:34:21 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java | 275 +++++++++++++++++++++++++++++++++++------------------- 1 files changed, 179 insertions(+), 96 deletions(-) diff --git a/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java b/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java index 96b94e1..ce4fdc1 100644 --- a/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java +++ b/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java @@ -10,14 +10,18 @@ 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.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; @@ -30,22 +34,25 @@ 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; @@ -92,6 +99,10 @@ @Resource private ImgConfigClient icfgClient; + + @Resource + private VideoOfCourseListClient voclClient; + @Resource private VipPaymentMapper vipPaymentMapper; @@ -119,11 +130,14 @@ @Resource private CoursePackageConfigClient cpconClient; - @Autowired + @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)){ @@ -142,38 +156,28 @@ 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(); @@ -192,36 +196,34 @@ * @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学时"); + courses.add(couList); + } + courseVenue.setCourses(courses); + courseVenues.add(courseVenue); } - return weekedCourses; + return courseVenues; } @@ -486,20 +488,22 @@ 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"); Date monthStart = null; @@ -511,41 +515,66 @@ monthStart = DateTimeHelper.getCurrentMouthStart(); monthEnd = DateTimeHelper.getCurrentMouthEnd(); } + + BillingDataRequestVo requestVo = new BillingDataRequestVo(); + requestVo.setMonthStart(monthStart); + requestVo.setMonthEnd(monthEnd); + requestVo.setAppUserId(appUserId); // 1.赛事报名 - List<PaymentCompetition> allCompetitionPayRecord = deducClient.getAllCompetitionPayRecord(appUserId); + List<PaymentCompetition> allCompetitionPayRecord = deducClient.getAllCompetitionPayRecord(requestVo); if (allCompetitionPayRecord.size() > 0 ){ for (PaymentCompetition paymentCompetition : allCompetitionPayRecord) { - BillingDetailsVo.ConsumeDetail consumeDetail = new BillingDetailsVo.ConsumeDetail(); + ConsumeDetail consumeDetail = new ConsumeDetail(); consumeDetail.setConsumeName(RechargeRecordEnum.EVENT_REGISTRATION.getMsg()); consumeDetail.setConsumeTime(simpleDateFormat.format(paymentCompetition.getInsertTime())); consumeDetail.setConsumeAmount("-" + paymentCompetition.getAmount()); details.add(consumeDetail); + consumeDetail.setType(1); } } // 2.取消赛事报名 - List<PaymentCompetition> cancelOrderOfUserPayRecord = deducClient.getCancelOrderOfUserPayRecord(appUserId); + List<PaymentCompetition> cancelOrderOfUserPayRecord = deducClient.getCancelOrderOfUserPayRecord(requestVo); if (cancelOrderOfUserPayRecord.size() > 0 ){ for (PaymentCompetition paymentCompetition : cancelOrderOfUserPayRecord) { - BillingDetailsVo.ConsumeDetail consumeDetail = new BillingDetailsVo.ConsumeDetail(); + ConsumeDetail consumeDetail = new ConsumeDetail(); consumeDetail.setConsumeName(RechargeRecordEnum.CANCEL_EVENT_REGISTRATION.getMsg()); consumeDetail.setConsumeTime(simpleDateFormat.format(paymentCompetition.getInsertTime())); consumeDetail.setConsumeAmount("+" + paymentCompetition.getAmount()); + consumeDetail.setType(1); details.add(consumeDetail); } } // 3.课包购买 - List<TCoursePackagePayment> amountPayRecord = paymentClient.getAmountPayRecord(appUserId); + List<TCoursePackagePayment> amountPayRecord = paymentClient.getAmountPayRecord(requestVo); if (amountPayRecord.size() > 0 ){ for (TCoursePackagePayment coursePackagePayment : amountPayRecord) { - BillingDetailsVo.ConsumeDetail consumeDetail = new BillingDetailsVo.ConsumeDetail(); + ConsumeDetail consumeDetail = new ConsumeDetail(); consumeDetail.setConsumeName(RechargeRecordEnum.COURSE_PACKAGE_PURCHASE.getMsg()); consumeDetail.setConsumeTime(simpleDateFormat.format(coursePackagePayment.getInsertTime())); consumeDetail.setConsumeAmount("-" + coursePackagePayment.getCashPayment()); + consumeDetail.setType(2); details.add(consumeDetail); } } // 4.场地预约 - // TODO: 2023/7/14 账单的场地预约查询 + List<SiteBooking> allSiteBookingList = stClient.getAllSiteBookingList(requestVo); + if (allSiteBookingList.size() > 0){ + for (SiteBooking booking : allSiteBookingList) { + ConsumeDetail consumeDetail = new ConsumeDetail(); + if (booking.getStatus() != 5){ + consumeDetail.setConsumeName(RechargeRecordEnum.VENUE_RESERVATION.getMsg()); + consumeDetail.setConsumeAmount("-" + booking.getPayMoney()); + consumeDetail.setConsumeTime(simpleDateFormat.format(booking.getPayTime())); + consumeDetail.setType(2); + }else { + consumeDetail.setConsumeName(RechargeRecordEnum.CANCEL_VENUE_RESERVATION.getMsg()); + consumeDetail.setConsumeAmount("+" + booking.getPayMoney()); + consumeDetail.setConsumeTime(simpleDateFormat.format(booking.getCancelTime())); + consumeDetail.setType(1); + } + details.add(consumeDetail); + } + } // 5.智慧球场 // 6.年度会员 @@ -555,10 +584,11 @@ .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); } } @@ -569,16 +599,39 @@ .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 @@ -595,14 +648,16 @@ 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); } @@ -611,14 +666,8 @@ } @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()); @@ -626,7 +675,7 @@ List<PointsMerchandise> vicinityGoods = mcClient.getVicinityGoods(commodityRequest); if (vicinityGoods.size() > 0) { for (PointsMerchandise vicinityGood : vicinityGoods) { - PointMallDetailsResponse.Goods commodity = new PointMallDetailsResponse.Goods(); + Goods commodity = new Goods(); switch (vicinityGood.getType()) { case 1: commodity.setGoodId(vicinityGood.getId()); @@ -683,7 +732,7 @@ 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()); @@ -701,26 +750,34 @@ } } 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; @@ -728,12 +785,22 @@ } 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; + Pageable pageable = PageRequest.of(request.getPageNum() - 1, request.getPageSize()); + Page<Goods> page = getPage(goods, pageable); + return page.getContent(); + } + + // 对数据进行分页处理的方法 + 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 @@ -1112,4 +1179,20 @@ } + @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; + } + + } -- Gitblit v1.7.1