From 640ff18d2d7f4be02ddb7f8f75e899f05545eb98 Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期一, 05 二月 2024 11:56:52 +0800 Subject: [PATCH] 更新bug修改 --- cloud-server-account/src/main/java/com/dsh/account/service/impl/TStudentServiceImpl.java | 209 ++++++++++++++++++++++----------------------------- 1 files changed, 91 insertions(+), 118 deletions(-) diff --git a/cloud-server-account/src/main/java/com/dsh/account/service/impl/TStudentServiceImpl.java b/cloud-server-account/src/main/java/com/dsh/account/service/impl/TStudentServiceImpl.java index 870a43f..6fabab4 100644 --- a/cloud-server-account/src/main/java/com/dsh/account/service/impl/TStudentServiceImpl.java +++ b/cloud-server-account/src/main/java/com/dsh/account/service/impl/TStudentServiceImpl.java @@ -48,6 +48,9 @@ import java.math.RoundingMode; import java.text.ParseException; import java.text.SimpleDateFormat; +import java.time.Instant; +import java.time.LocalDate; +import java.time.ZoneId; import java.util.*; import java.util.stream.Collectors; @@ -101,6 +104,8 @@ @Resource private ParticipantClient participantClient; + @Autowired + private CoursePackageClient coursePackageClient; @Autowired private PayMoneyUtil payMoneyUtil; @@ -163,6 +168,7 @@ saveParticipant.setWeight(student.getWeight()); saveParticipant.setPhone(student.getPhone()); saveParticipant.setIdcard(student.getIdCard()); + participantClient.saveParticipant(saveParticipant); return ResultUtil.success(); } @@ -234,107 +240,7 @@ @Override public List<PurchaseRecordVo> queryDeduRecordDetails(RecordTimeRequest timeRequest, Integer appUserId) { - List<PurchaseRecordVo> purchaseRecordVoList = new ArrayList<>(); - String time = timeRequest.getTime(); - List<PurchaseRecordVo> record1 = sessionNameClient.getRecord(timeRequest); - -// -// Date monthStart = null; -// Date monthEnd = null; -// if (StringUtils.hasText(time)) { -// monthStart = DateTimeHelper.getCurrentIdetMouthStart(time); -// monthEnd = DateTimeHelper.getCurrentIdeaMouthEnd(time); -// } else { -// monthStart = DateTimeHelper.getCurrentMouthStart(); -// monthEnd = DateTimeHelper.getCurrentMouthEnd(); -// } -// -// SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM"); -// Date startTime = DateTimeHelper.getCurrentIdetMouthStart(simpleDateFormat.format(monthStart)); -// Date endTime = DateTimeHelper.getCurrentIdeaMouthEnd(simpleDateFormat.format(monthEnd)); -// GetStuSourseList getStuSourseList = new GetStuSourseList(); -// getStuSourseList.setStartTime(startTime); -// getStuSourseList.setEndTime(endTime); -// getStuSourseList.setAppUserId(appUserId); -// // 报名赛事 -// List<PurchaseRecordVo> stuSourseList = dcttClient.getStuSourseList1(getStuSourseList); -// purchaseRecordVoList.addAll(stuSourseList); -// -// GetStuSessionList sessionList = new GetStuSessionList(); -// sessionList.setStartTime(startTime); -// sessionList.setEndTime(endTime); -// sessionList.setStuId(timeRequest.getStuId()); -// sessionList.setAppUserId(appUserId); -// List<PurchaseRecordVo> cancelCourseList = cancelcClient.getCancelCourseList(sessionList); -// -// purchaseRecordVoList.addAll(cancelCourseList); -// GetStuSessionList getStuSessionList = new GetStuSessionList(); -// getStuSessionList.setStartTime(startTime); -// getStuSessionList.setEndTime(endTime); -// getStuSessionList.setStuId(timeRequest.getStuId()); -// getStuSessionList.setAppUserId(appUserId); -// // 购买课包 -// List<PurchaseRecordVo> purchaseRecordVos = sessionNameClient.queryCourseDetails(getStuSessionList); -// purchaseRecordVoList.addAll(purchaseRecordVos); -// List<TAppUser> tAppUsers = tauMapper.selectList(new QueryWrapper<TAppUser>() -// .eq("referralUserId",appUserId ) -// .between("insertTime",startTime ,endTime)); -// if (ToolUtil.isNotEmpty(tAppUsers)){ -// List<Integer> userIds = tAppUsers.stream().map(TAppUser::getId).collect(Collectors.toList()); -// IntrduceOfUserRequest request = new IntrduceOfUserRequest(); -// request.setStartTime(startTime); -// request.setEndTime(endTime); -// request.setUserIds(userIds); -// // 介绍有礼 -// List<PurchaseRecordVo> purchaseRecordVos1 = idrClient.queryAppUsersofIntroduce(request); -// purchaseRecordVoList.addAll(purchaseRecordVos1); -// } -// -// LambdaQueryWrapper<TCourseInfoRecord> eq = new LambdaQueryWrapper<TCourseInfoRecord>().eq(TCourseInfoRecord::getUserId, appUserId); -// if(timeRequest.getType()!=null){ -// eq.eq(TCourseInfoRecord::getType,timeRequest.getType()); -// } -// if (timeRequest.getLessionId()!=null){ -// eq.eq(TCourseInfoRecord::getCourseId,timeRequest.getLessionId()); -// -// } -// // 2.0其他记录 -// List<TCourseInfoRecord> list = courseInfoRecordService.list(eq); -// List<PurchaseRecordVo> list1=new ArrayList<>(); -// for (TCourseInfoRecord tCourseInfoRecord : list) { -// PurchaseRecordVo purchaseRecordVo = new PurchaseRecordVo(); -// purchaseRecordVo.setPurchaseTime(new SimpleDateFormat("MM-dd HH:mm").format(tCourseInfoRecord.getTime())); -// purchaseRecordVo.setPurchaseType(tCourseInfoRecord.getName()); -// if(tCourseInfoRecord.getType()==1){ -// purchaseRecordVo.setPurchaseAmount("+"+tCourseInfoRecord.getNum()); -// }else { -// purchaseRecordVo.setPurchaseAmount("-"+tCourseInfoRecord.getNum()); -// } -// list1.add(purchaseRecordVo); -// } -// purchaseRecordVoList.addAll(list1); -// -// if (purchaseRecordVoList.size() > 0 ){ -// purchaseRecordVoList = purchaseRecordVoList.stream() -// .filter(record -> { -// String fieldValue = record.getPurchaseAmount(); -// if (ToolUtil.isNotEmpty(timeRequest.getType())){ -// switch (timeRequest.getType()){ -// case 2: -// return fieldValue != null && !fieldValue.isEmpty() && fieldValue.charAt(0) == '-'; -// case 1: -// return fieldValue != null && !fieldValue.isEmpty() && fieldValue.charAt(0) == '+'; -// default: -// break; -// } -// } -// return true; -// }) -// .collect(Collectors.toList()); -// } -// -// purchaseRecordVoList = dealDataOfTime(purchaseRecordVoList); return record1; } @@ -570,9 +476,24 @@ } return weixinpay; } - + private String smid = "2088330203191220";//平台支付宝商户号 public ResultUtil AlipayPayment(String code, BigDecimal amount, Integer hour) { - ResultUtil alipay = payMoneyUtil.alipay("课包续费", "课包续费", "", code, amount.toString(), + TCoursePackagePayment coursePackagePayment = couPayClient.getCoursePackagePaymentByCode(code); + Integer coursePackageId = coursePackagePayment.getCoursePackageId(); + // 判断这个课包是属于哪个运营商的 + CoursePackage coursePackage = coursePackageClient.queryCoursePackageById(coursePackageId); + Integer storeId = coursePackage.getStoreId(); + Store store = storeClient.queryStoreById(storeId); + String smid1= ""; + if (store.getOperatorId()==null){ + // 平台 + smid1 = smid; + }else{ + String smidByOperatorId = storeClient.getSMIDByOperatorId(store.getOperatorId()); + smid1 = smidByOperatorId; + } + + ResultUtil alipay = payMoneyUtil.alipay(smid1,"课包续费", "课包续费", "", code, amount.toString(), "/base/coursePackage/alipayPaymentCallback"); if (alipay.getCode() == 200) { new Thread(new Runnable() { @@ -590,7 +511,6 @@ break; } AlipayTradeQueryResponse resultUtil = payMoneyUtil.queryALIOrder(code); - if (resultUtil.getCode().equals("10000") && coursePackagePayment.getPayStatus() == 1) { /** * WAIT_BUYER_PAY(交易创建,等待买家付款)、 @@ -615,8 +535,20 @@ coursePackagePayment.setLaveClassHours(hour); coursePackagePayment.setOrderNumber(tradeNo); couPayClient.updatePaymentCoursePackage(coursePackagePayment); - - + Integer coursePackageId = coursePackagePayment.getCoursePackageId(); + // 判断这个课包是属于哪个运营商的 + CoursePackage coursePackage = coursePackageClient.queryCoursePackageById(coursePackageId); + Integer storeId = coursePackage.getStoreId(); + Store store = storeClient.queryStoreById(storeId); + String smid1= ""; + if (store.getOperatorId()==null){ + // 平台 + smid1 = smid; + }else{ + String smidByOperatorId = storeClient.getSMIDByOperatorId(store.getOperatorId()); + smid1 = smidByOperatorId; + } + payMoneyUtil.confirm(smid1,code,tradeNo,amount.toString()); break; } if ("WAIT_BUYER_PAY".equals(tradeStatus)) { @@ -703,10 +635,19 @@ .filter(record -> { try { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm"); - String substring = record.getTimeFrame().substring(11); + String substring = record.getTimeFrame().substring(0,16); Date time = sdf.parse(substring); - return !time.before(lastWeekStartDate) && !time.after(lastOfDate); + Instant instant = time.toInstant(); + LocalDate dateToCheck = instant.atZone(ZoneId.systemDefault()).toLocalDate(); + // 获取今天的日期 + LocalDate today = LocalDate.now(); + // 计算一周前的日期 + LocalDate oneWeekAgo = today.minusWeeks(1); + // 计算一周后的日期 + LocalDate oneWeekLater = today.plusWeeks(1); + return dateToCheck.isAfter(oneWeekAgo) && dateToCheck.isBefore(oneWeekLater); } catch (ParseException e) { + e.printStackTrace(); return false; } }) @@ -717,10 +658,20 @@ recordAppoints = recordAppoints.stream() .filter(record -> { try { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - Date time = sdf.parse(record.getTimeFrame().substring(11)); - return !time.before(lastMonthStartDate) && !time.after(lastOfDate); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm"); + String substring = record.getTimeFrame().substring(0,16); + Date time = sdf.parse(substring); + Instant instant = time.toInstant(); + LocalDate dateToCheck = instant.atZone(ZoneId.systemDefault()).toLocalDate(); + // 获取今天的日期 + LocalDate today = LocalDate.now(); + // 计算一周前的日期 + LocalDate oneWeekAgo = today.minusMonths(1); + // 计算一周后的日期 + LocalDate oneWeekLater = today.plusMonths(1); + return dateToCheck.isAfter(oneWeekAgo) && dateToCheck.isBefore(oneWeekLater); } catch (ParseException e) { + e.printStackTrace(); return false; } }) @@ -732,9 +683,19 @@ .filter(record -> { try { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm"); - Date time = sdf.parse(record.getTimeFrame().substring(11)); - return !time.before(lastYearStartDate) && !time.after(lastOfDate); + String substring = record.getTimeFrame().substring(0,16); + Date time = sdf.parse(substring); + Instant instant = time.toInstant(); + LocalDate dateToCheck = instant.atZone(ZoneId.systemDefault()).toLocalDate(); + // 获取今天的日期 + LocalDate today = LocalDate.now(); + // 计算一周前的日期 + LocalDate oneWeekAgo = today.minusYears(1); + // 计算一周后的日期 + LocalDate oneWeekLater = today.plusYears(1); + return dateToCheck.isAfter(oneWeekAgo) && dateToCheck.isBefore(oneWeekLater); } catch (ParseException e) { + e.printStackTrace(); return false; } }) @@ -781,18 +742,16 @@ citycodeResp.setLatitude(longitude); List<StoreDetailList> queryStoreList = storeClient.getQueryStoreList(citycodeResp); if (queryStoreList.size() > 0) { - if (ToolUtil.isEmpty(space) || space == 2) { + if (ToolUtil.isEmpty(space) || space ==1) { + queryStoreList = queryStoreList.stream().sorted(Comparator.comparing(o -> o.getStoreDistance())).collect(Collectors.toList()); + } else { queryStoreList = queryStoreList.stream() .sorted(Comparator.comparing(StoreDetailList::getStoreDistance).reversed()) .collect(Collectors.toList()); - - } else { - queryStoreList = queryStoreList.stream().sorted(Comparator.comparing(o -> o.getStoreDistance())).collect(Collectors.toList()); } if (ToolUtil.isNotEmpty(search)) { queryStoreList = queryStoreList.stream().filter(o -> o.getStoreName().contains(search)).collect(Collectors.toList()); } - } return queryStoreList; } @@ -879,9 +838,23 @@ return this.baseMapper.getGiftSelect(giftSearchDto); } + @Resource + private SiteClient siteClient; + + @Override public List<Map<String, Object>> queryCom(Integer id) { - return this.baseMapper.queryCom(id); + List<Map<String, Object>> maps = this.baseMapper.queryCom(id); + for (Map<String, Object> map : maps) { + Integer coachId = (Integer) map.get("coachId"); + System.err.println("==============XXXXXXXXXXXX"+coachId); + if (coachId!=null) { + User name = siteClient.queryUserName(coachId); + map.put("name",name.getName()); + } + } + + return maps; } -- Gitblit v1.7.1