From 6c19eb74b11c6cbf475d43496b90cdee2a28d8b7 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期一, 11 十一月 2024 18:46:00 +0800
Subject: [PATCH] 代码提交
---
xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/controller/client/ClientOrderController.java | 305 +++++++++++++++++++++++++++++++++-----------------
1 files changed, 199 insertions(+), 106 deletions(-)
diff --git a/xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/controller/client/ClientOrderController.java b/xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/controller/client/ClientOrderController.java
index 850c99f..d0c9d06 100644
--- a/xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/controller/client/ClientOrderController.java
+++ b/xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/controller/client/ClientOrderController.java
@@ -96,6 +96,7 @@
@GetMapping("/getMeditationIsBuy/{id}/{meditationId}")
public R<Integer> getMeditationIsBuy(@PathVariable("id")Long id,@PathVariable("meditationId")Long meditationId) {
List<Order> list = orderService.lambdaQuery().eq(Order::getBusinessId, meditationId)
+ .eq(Order::getAppUserId, id)
.eq(Order::getOrderFrom, 1)
.eq(Order::getPaymentStatus, 2)
.ne(Order::getRefundStatus, 3).list();
@@ -168,16 +169,32 @@
if (loginUser==null){
return R.tokenError("登录失效");
}
- Page<Order> page = orderService.lambdaQuery()
- .eq(Order::getAppUserId, userId)
+ List<OrderCourseVO> res = new ArrayList<>();
+ List<Order> page = orderService.lambdaQuery()
.eq(Order::getOrderFrom, state)
.ne(Order::getPaymentStatus, 3)
- .orderByDesc(BaseModel::getCreateTime).page(new Page<>(pageCurr, pageSize));
+ .orderByDesc(BaseModel::getCreateTime).list();
+ List<Order> list = orderService.lambdaQuery().eq(Order::getGiveUserId, userId).list();
+ for (Order order : page) {
+ OrderCourseVO orderCourseVO = new OrderCourseVO();
+ orderCourseVO.setId(order.getId());
+ orderCourseVO.setOrderFrom(order.getOrderFrom());
+ orderCourseVO.setBusinessId(order.getBusinessId());
+ if (order.getAppUserId().equals(userId) && order.getGiveUserId() == null){
+ BeanUtils.copyProperties(order, orderCourseVO);
+ orderCourseVO.setBusinessId(order.getBusinessId());
+ res.add(orderCourseVO);
+ }
+ if (order.getGiveUserId()!=null&&order.getGiveUserId().equals(userId)){
+ BeanUtils.copyProperties(order, orderCourseVO);
+ orderCourseVO.setBusinessId(order.getBusinessId());
+ res.add(orderCourseVO);
- PageDTO<OrderCourseVO> res = PageDTO.of(page, OrderCourseVO.class);
- List<OrderCourseVO> list = res.getList();
- ArrayList<OrderCourseVO> orderCourseVOS = new ArrayList<>();
- for (OrderCourseVO orderCourseVO : res.getList()) {
+ }
+
+ }
+ List<OrderCourseVO> res1 = new ArrayList<>();
+ for (OrderCourseVO orderCourseVO : res) {
switch (orderCourseVO.getOrderFrom()){
case 1:
Meditation data1 = remoteMeditationService.getMeditationById(orderCourseVO.getBusinessId()).getData();
@@ -189,11 +206,14 @@
orderCourseVO.setIosPrice(data1.getIosPrice());
orderCourseVO.setCount(data1.getRealLearnedNum()+data1.getVirtualLearnedNum());
orderCourseVO.setChargeType(data1.getChargeType());
+ orderCourseVO.setCoverDescription(data1.getCoverDescription());
+ res1.add(orderCourseVO);
break;
case 2:
OrderCourseVO data = remoteCourseService.getCourseByIdAny(orderCourseVO).getData();
if (data==null)continue;
BeanUtils.copyProperties(data, orderCourseVO);
+ Course data4 = remoteCourseService.getCourseById(data.getBusinessId()).getData();
List<CourseChapter> data2 = remoteCourseService.getChapterByCourseId(orderCourseVO.getBusinessId() + "").getData();
int temp = 0 ;
for (CourseChapter courseChapter : data2) {
@@ -201,11 +221,38 @@
}
Integer data3 = remoteCourseService.getCountByCourseId(orderCourseVO.getBusinessId() + "").getData();
orderCourseVO.setCount(data3+temp);
+ if (data4!=null){
+ orderCourseVO.setCourseTitle(data4.getCourseTitle());
+ orderCourseVO.setCoverUrl(data4.getCoverUrl());
+ orderCourseVO.setBusinessId(data4.getId());
+ }
+ res1.add(orderCourseVO);
break;
}
-
}
- return R.ok(res.getList());
+ List<OrderCourseVO> testing = testing(res1.size(), pageCurr, pageSize, res1);
+ return R.ok(testing);
+ }
+ public static List<OrderCourseVO> testing(long total, long current, long size, List<OrderCourseVO> str){
+ List<OrderCourseVO> result = new ArrayList<>();
+ //获取初始化分页结构
+ Page<OrderCourseVO> page = new Page<>(current - 1, size, total);
+ //获取集合下标初始值
+ long startIndex = (current - 1) * size;
+ //获取集合下标结束值
+ long endInddex = 0;
+ if(startIndex + page.getCurrent() >= total || size > total){
+ endInddex = total;
+ }else {
+ endInddex = Math.min(startIndex + page.getSize(), total);
+ }
+ //如果输入的开始查询下标大于集合大小，则查询为空值
+ if(startIndex > total){
+ result = Collections.emptyList();
+ }else{
+ result = str.subList((int)startIndex,(int)endInddex);
+ }
+ return result;
}
/**
* 根据邀请用户ids 查询对应佣金
@@ -297,13 +344,15 @@
@ApiImplicitParam(name = "vipType", value = "订单类型为会员时 必传 会员类型 1月度 2季度 3年度", dataType = "Integer", required = false),
})
public R placeOrderApple(
- @RequestParam(value = "targetId") Long targetId,
+ @RequestParam(value = "targetId", required = false) Long targetId,
@RequestParam(value = "orderFrom") Integer orderFrom,
@RequestParam(value = "receiverId", required = false) Long receiverId,
- @RequestParam(value = "balanceFlag") Integer balanceFlag,
- @RequestParam(value = "amount") BigDecimal amount,
- @RequestParam(value = "vipType") Integer vipType,
- @RequestParam(value = "transactionIdentifier")String transactionIdentifier) throws Exception {
+ @RequestParam(value = "balanceFlag", required = false) Integer balanceFlag,
+ @RequestParam(value = "payType") Integer payType,
+ @RequestParam(value = "amount", required = false) BigDecimal amount,
+ @RequestParam(value = "vipType", required = false) Integer vipType,
+ @RequestParam(value = "transactionIdentifier")String transactionIdentifier)
+ throws Exception {
return R.ok(orderService.placeOrderApple(targetId, orderFrom, receiverId,
@@ -374,6 +423,11 @@
order.setRealPayAmount(data.getIosPrice());
break;
}
+ if (receiverId!=null){
+ remoteAppUserService.addNotice(receiverId + "", data.getId() + "",
+ userId + "", order.getTotalAmount() + "");
+ }
+
break;
}
@@ -421,34 +475,38 @@
AppUser data = remoteAppUserService.getAppUserById(order.getAppUserId() + "").getData();
BigDecimal realPayAmount = order.getRealPayAmount();
if (data.getInviteUserId()!=null) {
- if (order.getOrderFrom() == 1 || order.getOrderFrom() == 2) {
- // 分佣给上级 先远程查询分佣比例
- CommissionRule data1 = sysUserClient.getCommission().getData();
- if (data1 != null) {
- if (data1.getProportion() != null) {
- BigDecimal bigDecimal = realPayAmount.multiply(data1.getProportion())
- .setScale(2, BigDecimal.ROUND_HALF_DOWN);
- // 上级获取的分佣金额
- AppUser appUserById = remoteAppUserService.getAppUserById(data.getInviteUserId() + "").getData();
- // 更新用户余额
- remoteAppUserService.updateAppUser(
- AppUserDTO.builder().balance(
- appUserById.getBalance().add(bigDecimal))
- .build(), SecurityConstants.INNER);
- // 新增分佣流水明细
- AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
- appUserWalletRecord.setAppUserId(data.getInviteUserId());
- appUserWalletRecord.setChangeType(1);
- appUserWalletRecord.setReason("分佣收益");
- appUserWalletRecord.setAmount(bigDecimal);
- appUserWalletRecord.setChildAppUserId(order.getAppUserId());
- appUserWalletRecord.setOrderId(order.getId());
- remoteAppUserService.addBalanceRecord(appUserWalletRecord);
- order.setCommissionAmount(bigDecimal);
- order.setCommissionId(data.getInviteUserId());
- orderService.updateById(order);
- }
- }
+ if (order.getOrderFrom() == 1 || order.getOrderFrom() == 2 || order.getOrderFrom() == 3) {
+// // 查询实际支付价格 不包含余额抵扣价格
+// OrderPaymentRecord one1 = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, order.getId())
+// .one();
+// // 分佣给上级 先远程查询分佣比例
+// CommissionRule data1 = sysUserClient.getCommission().getData();
+// if (data1 != null) {
+// if (data1.getProportion() != null) {
+//
+// BigDecimal bigDecimal = one1.getPayAmount().multiply(data1.getProportion()).divide(new BigDecimal("100"))
+// .setScale(2, BigDecimal.ROUND_HALF_DOWN);
+// // 上级获取的分佣金额
+// AppUser appUserById = remoteAppUserService.getAppUserById(data.getInviteUserId() + "").getData();
+// // 更新用户余额
+// remoteAppUserService.updateAppUser(
+// AppUserDTO.builder().balance(
+// appUserById.getBalance().add(bigDecimal))
+// .build(), SecurityConstants.INNER);
+// // 新增分佣流水明细
+// AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
+// appUserWalletRecord.setAppUserId(data.getInviteUserId());
+// appUserWalletRecord.setChangeType(1);
+// appUserWalletRecord.setReason("分佣收益");
+// appUserWalletRecord.setAmount(bigDecimal);
+// appUserWalletRecord.setChildAppUserId(order.getAppUserId());
+// appUserWalletRecord.setOrderId(order.getId());
+// remoteAppUserService.addBalanceRecord(appUserWalletRecord);
+// order.setCommissionAmount(bigDecimal);
+// order.setCommissionId(data.getInviteUserId());
+// orderService.updateById(order);
+// }
+// }
}
}
return R.ok();
@@ -488,6 +546,9 @@
// 支付金额
String string3 = jsonObject1.getString("pay_fee");
Order one = orderService.lambdaQuery().eq(Order::getBizOrderNo, string).one();
+ if (one.getPaymentStatus()==2){
+ return;
+ }
one.setPaymentStatus(2);
one.setPaymentTime(LocalDateTime.now());
OrderPaymentRecord one2 = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, one.getId())
@@ -500,21 +561,31 @@
BigDecimal realPayAmount = one.getRealPayAmount();
// 判断订单所属用户是否有上级 是否需要做分佣处理
AppUser data = remoteAppUserService.getAppUserById(one.getAppUserId() + "").getData();
+ if (one.getGiveUserId()!=null){
+ remoteAppUserService.addNotice(one.getGiveUserId() + "", one.getBusinessId() + "",
+ one.getAppUserId() + "", one.getTotalAmount() + "");
+ }
+
if (data.getInviteUserId()!=null) {
- if (one.getOrderFrom() == 1 || one.getOrderFrom() == 2) {
- // 分佣给上级 先远程查询分佣比例
+
+ if (one.getOrderFrom() == 1 || one.getOrderFrom() == 2 || one.getOrderFrom() == 3) {
+ // 查询实际支付价格 不包含余额抵扣价格
+ OrderPaymentRecord one1 = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, one.getId())
+ .ne(OrderPaymentRecord::getPaymentType, 4).one();
+ // 分佣给上级 先远程查询分佣比例
CommissionRule data1 = sysUserClient.getCommission().getData();
if (data1 != null) {
if (data1.getProportion() != null) {
- BigDecimal bigDecimal = realPayAmount.multiply(data1.getProportion())
+
+ BigDecimal bigDecimal = one1.getPayAmount().multiply(data1.getProportion()).divide(new BigDecimal("100"))
.setScale(2, BigDecimal.ROUND_HALF_DOWN);
// 上级获取的分佣金额
AppUser appUserById = remoteAppUserService.getAppUserById(data.getInviteUserId() + "").getData();
// 更新用户余额
- remoteAppUserService.updateAppUser(
- AppUserDTO.builder().balance(
- appUserById.getBalance().add(bigDecimal))
- .build(), SecurityConstants.INNER);
+// remoteAppUserService.updateAppUser(
+// AppUserDTO.builder().balance(
+// appUserById.getBalance().add(bigDecimal))
+// .build(), SecurityConstants.INNER);
// 新增分佣流水明细
AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
appUserWalletRecord.setAppUserId(data.getInviteUserId());
@@ -672,6 +743,9 @@
.eq(OrderPaymentRecord::getPayOrderNo, string).ne(OrderPaymentRecord::getPaymentStatus, 2).one();
if (two!=null){
Order one = orderService.getById(two.getOrderId());
+ if (one.getPaymentStatus()==2){
+ return;
+ }
one.setPaymentStatus(2);
one.setPaymentTime(LocalDateTime.now());
OrderPaymentRecord one2 = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, one.getId())
@@ -683,33 +757,45 @@
// 实际支付金额
BigDecimal realPayAmount = one.getRealPayAmount();
// 判断订单所属用户是否有上级 是否需要做分佣处理
- AppUser data3 = remoteAppUserService.getAppUserById(one.getAppUserId() + "").getData();
- if (data3.getInviteUserId()!=null){
- // 分佣给上级 先远程查询分佣比例
- CommissionRule data1 = sysUserClient.getCommission().getData();
- if (data1!=null){
- if (data1.getProportion()!=null){
- BigDecimal bigDecimal = realPayAmount.multiply(data1.getProportion())
- .setScale(2, BigDecimal.ROUND_HALF_DOWN);
- // 上级获取的分佣金额
- AppUser appUserById = remoteAppUserService.getAppUserById(data3.getInviteUserId() + "").getData();
- // 更新用户余额
- remoteAppUserService.updateAppUser(
- AppUserDTO.builder().balance(
- appUserById.getBalance().add(bigDecimal))
- .build(), SecurityConstants.INNER);
- // 新增分佣流水明细
- AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
- appUserWalletRecord.setAppUserId(data3.getInviteUserId());
- appUserWalletRecord.setChangeType(1);
- appUserWalletRecord.setReason("分佣收益");
- appUserWalletRecord.setAmount(bigDecimal);
- appUserWalletRecord.setChildAppUserId(one.getAppUserId());
- appUserWalletRecord.setOrderId(one.getId());
- remoteAppUserService.addBalanceRecord(appUserWalletRecord);
- one.setCommissionAmount(bigDecimal);
- one.setCommissionId(data3.getInviteUserId());
- orderService.updateById(one);
+ AppUser data9 = remoteAppUserService.getAppUserById(one.getAppUserId() + "").getData();
+ if (one.getGiveUserId()!=null){
+ remoteAppUserService.addNotice(one.getGiveUserId() + "", one.getBusinessId() + "",
+ one.getAppUserId() + "", one.getTotalAmount() + "");
+ }
+
+ if (data9.getInviteUserId()!=null) {
+
+ if (one.getOrderFrom() == 1 || one.getOrderFrom() == 2 || one.getOrderFrom() == 3) {
+ // 查询实际支付价格 不包含余额抵扣价格
+ OrderPaymentRecord one1 = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, one.getId())
+ .ne(OrderPaymentRecord::getPaymentType, 4).one();
+ // 分佣给上级 先远程查询分佣比例
+ CommissionRule data1 = sysUserClient.getCommission().getData();
+ if (data1 != null) {
+ if (data1.getProportion() != null) {
+
+ BigDecimal bigDecimal = one1.getPayAmount().multiply(data1.getProportion()).divide(new BigDecimal("100"))
+ .setScale(2, BigDecimal.ROUND_HALF_DOWN);
+ // 上级获取的分佣金额
+ AppUser appUserById = remoteAppUserService.getAppUserById(data9.getInviteUserId() + "").getData();
+ // 更新用户余额
+// remoteAppUserService.updateAppUser(
+// AppUserDTO.builder().balance(
+// appUserById.getBalance().add(bigDecimal))
+// .build(), SecurityConstants.INNER);
+ // 新增分佣流水明细
+ AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
+ appUserWalletRecord.setAppUserId(data9.getInviteUserId());
+ appUserWalletRecord.setChangeType(1);
+ appUserWalletRecord.setReason("分佣收益");
+ appUserWalletRecord.setAmount(bigDecimal);
+ appUserWalletRecord.setChildAppUserId(one.getAppUserId());
+ appUserWalletRecord.setOrderId(one.getId());
+ remoteAppUserService.addBalanceRecord(appUserWalletRecord);
+ one.setCommissionAmount(bigDecimal);
+ one.setCommissionId(data9.getInviteUserId());
+ orderService.updateById(one);
+ }
}
}
}
@@ -718,7 +804,7 @@
OrderPaymentRecord one1 = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, one.getId())
.eq(OrderPaymentRecord::getPaymentType, 4).one();
AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
- appUserWalletRecord.setAppUserId(data3.getInviteUserId());
+ appUserWalletRecord.setAppUserId(data9.getInviteUserId());
String reason=null;
switch (one.getOrderFrom()){
case 1:
@@ -743,35 +829,6 @@
// 会员
reason = "购买【"+one.getBuyContent()+"】";
appUserWalletRecord.setChangeType(2);
- if (data3.getInviteUserId()!=null){
- // 分佣给上级 先远程查询分佣比例
- CommissionRule data4 = sysUserClient.getCommission().getData();
- if (data4!=null){
- if (data4.getProportion()!=null){
- BigDecimal bigDecimal = realPayAmount.multiply(data4.getProportion())
- .setScale(2, BigDecimal.ROUND_HALF_DOWN);
- // 上级获取的分佣金额
- AppUser appUserById = remoteAppUserService.getAppUserById(data3.getInviteUserId() + "").getData();
- // 更新用户余额
- remoteAppUserService.updateAppUser(
- AppUserDTO.builder().balance(
- appUserById.getBalance().add(bigDecimal))
- .build(), SecurityConstants.INNER);
- // 新增分佣流水明细
- AppUserWalletRecord appUserWalletRecord1 = new AppUserWalletRecord();
- appUserWalletRecord1.setAppUserId(data3.getInviteUserId());
- appUserWalletRecord1.setChangeType(1);
- appUserWalletRecord1.setReason("分佣收益");
- appUserWalletRecord1.setAmount(bigDecimal);
- appUserWalletRecord1.setChildAppUserId(one.getAppUserId());
- appUserWalletRecord1.setOrderId(one.getId());
- remoteAppUserService.addBalanceRecord(appUserWalletRecord1);
- one.setCommissionAmount(bigDecimal);
- one.setCommissionId(data3.getInviteUserId());
- orderService.updateById(one);
- }
- }
- }
break;
case 4:
// 充值
@@ -784,6 +841,41 @@
appUserWalletRecord.setChildAppUserId(one.getAppUserId());
appUserWalletRecord.setOrderId(one.getId());
remoteAppUserService.addBalanceRecord(appUserWalletRecord);
+ }else{
+ switch (one.getOrderFrom()){
+ case 2:
+ Course data2 = remoteCourseService.getCourseById(one.getBusinessId()).getData();
+ // 增加用户与课程的关系表
+ if (one.getGiveUserId()!=null){
+ remoteAppUserService.addAppUserCourse(one.getBusinessId(),one.getGiveUserId(),one.getId(),1);
+ }else{
+ // 自己购买
+ remoteAppUserService.addAppUserCourse(one.getBusinessId(),one.getAppUserId(),one.getId(),2);
+ }
+ break;
+ case 3:
+ // 会员
+ if (one.getBuyContent().contains("月")){
+
+ remoteAppUserService.addVipExpireTime(one.getAppUserId(),1);
+ }else if (one.getBuyContent().contains("季")){
+ remoteAppUserService.addVipExpireTime(one.getAppUserId(),2);
+ }else if (one.getBuyContent().contains("年")){
+ remoteAppUserService.addVipExpireTime(one.getAppUserId(),3);
+ }
+ break;
+ case 4:
+ remoteAppUserService.addBalance(one.getAppUserId(),one.getRealPayAmount());
+ AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
+ appUserWalletRecord.setAppUserId(one.getAppUserId());
+ appUserWalletRecord.setChangeType(1);
+ appUserWalletRecord.setReason("充值");
+ appUserWalletRecord.setAmount(one.getRealPayAmount());
+ appUserWalletRecord.setChildAppUserId(one.getAppUserId());
+ appUserWalletRecord.setOrderId(one.getId());
+ remoteAppUserService.addBalanceRecord(appUserWalletRecord);
+ break;
+ }
}
PrintWriter out = response.getWriter();
out.write("succeeded");
@@ -901,6 +993,7 @@
.eq(OrderPaymentRecord::getPaymentStatus, 2).one();
if (two==null){
one.setRemark("余额支付");
+ one.setBalance(one.getTotalAmount());
}else{
switch (two.getPaymentType()){
case 1:
--
Gitblit v1.7.1