From 5cf8494a6da08dfcdc5fdb4c5e55aefd8b27d684 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期二, 26 十一月 2024 18:34:28 +0800
Subject: [PATCH] 代码提交
---
xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/controller/client/ClientOrderController.java | 299 ++++++++++++++++++++++++++++++++++++++---------------------
1 files changed, 190 insertions(+), 109 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 cdd565a..5a5e1d1 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
@@ -11,6 +11,7 @@
import com.sun.corba.se.spi.ior.IdentifiableFactory;
import com.xinquan.common.core.constant.SecurityConstants;
import com.xinquan.common.core.domain.R;
+import com.xinquan.common.core.utils.JuHeFuUtil;
import com.xinquan.common.core.utils.page.BeanUtils;
import com.xinquan.common.core.utils.page.CollUtils;
import com.xinquan.common.core.utils.page.PageDTO;
@@ -62,7 +63,7 @@
import java.security.interfaces.ECPublicKey;
import java.time.LocalDateTime;
import java.util.*;
-
+import java.util.stream.Collectors;
/**
@@ -93,6 +94,17 @@
private SysUserClient sysUserClient;
@Autowired
private TokenService tokenService;
+
+ @ResponseBody
+ @PostMapping("/queryPayment")
+ @ApiOperation(value = "查询订单支付状态", tags = "查询订单支付状态")
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = "orderId", value = "订单id", dataType = "String", required = true),
+ })
+ public R<String> queryPayment(@RequestParam(value = "orderId") String orderId) throws Exception {
+ JSONObject jsonObject = JuHeFuUtil.queryPayment(orderId);
+ return R.ok(jsonObject.getString("status"));
+ }
@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)
@@ -118,12 +130,20 @@
if (byId==null){
return R.fail("订单失效");
}
+ if (byId.getGiveUserId()!=null){
+ AppUser data1 = remoteAppUserService.getAppUserById(byId.getGiveUserId() + "").getData();
+ payOrderVO.setPhone(data1.getCellPhone());
+ }
+
+ AppUser data1 = remoteAppUserService.getAppUserById(byId.getAppUserId() + "").getData();
+ payOrderVO.setBalance(data1.getBalance());
payOrderVO.setOrderId(id);
if (byId.getOrderFrom()==1){
Meditation data = remoteMeditationService.getMeditationById(byId.getBusinessId()).getData();
payOrderVO.setTitle(data.getMeditationTitle());
payOrderVO.setOrderFrom(1);
- payOrderVO.setTargetId(data.getId());
+ payOrderVO.setCoverUrl(data.getCoverUrl());
+ payOrderVO.setId(data.getId());
switch (type){
case 1:
payOrderVO.setAmount(data.getGeneralPrice());
@@ -140,7 +160,8 @@
payOrderVO.setTitle(data.getCourseTitle());
payOrderVO.setTutor(data.getTutor());
payOrderVO.setOrderFrom(2);
- payOrderVO.setTargetId(data.getId());
+ payOrderVO.setCoverUrl(data.getCoverUrl());
+ payOrderVO.setId(data.getId());
switch (type){
case 1:
payOrderVO.setAmount(data.getGeneralPrice());
@@ -165,10 +186,10 @@
})
public R<List<OrderCourseVO>> balanceList(Integer state, Integer pageCurr, Integer pageSize) {
LoginUser loginUser = tokenService.getLoginUser();
- Long userId = loginUser.getUserid();
if (loginUser==null){
return R.tokenError("登录失效");
}
+ Long userId = loginUser.getUserid();
List<OrderCourseVO> res = new ArrayList<>();
List<Order> page = orderService.lambdaQuery()
.eq(Order::getOrderFrom, state)
@@ -176,17 +197,24 @@
.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){
- OrderCourseVO orderCourseVO = new OrderCourseVO();
BeanUtils.copyProperties(order, orderCourseVO);
+ orderCourseVO.setBusinessId(order.getBusinessId());
res.add(orderCourseVO);
}
if (order.getGiveUserId()!=null&&order.getGiveUserId().equals(userId)){
- OrderCourseVO orderCourseVO = new OrderCourseVO();
BeanUtils.copyProperties(order, orderCourseVO);
+ orderCourseVO.setBusinessId(order.getBusinessId());
res.add(orderCourseVO);
+
}
+
}
+ List<OrderCourseVO> res1 = new ArrayList<>();
for (OrderCourseVO orderCourseVO : res) {
switch (orderCourseVO.getOrderFrom()){
case 1:
@@ -200,22 +228,40 @@
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 ;
+ int b = 0 ;
for (CourseChapter courseChapter : data2) {
temp+=courseChapter.getVirtualLearnedNum();
+ Long data9 = remoteAppUserService.getCourseChapterHistoryCount(courseChapter.getId()).getData();
+ b+=data9;
}
- Integer data3 = remoteCourseService.getCountByCourseId(orderCourseVO.getBusinessId() + "").getData();
- orderCourseVO.setCount(data3+temp);
+ orderCourseVO.setCount(b+temp);
+ if (data4!=null){
+ orderCourseVO.setCourseTitle(data4.getCourseTitle());
+ orderCourseVO.setCoverUrl(data4.getCoverUrl());
+ orderCourseVO.setBusinessId(data4.getId());
+ }
+ res1.add(orderCourseVO);
break;
}
}
- List<OrderCourseVO> testing = testing(res.size(), pageCurr, pageSize, res);
+ List<OrderCourseVO> orderCourseVOS = new ArrayList<>();
+ List<Long> longs1 = new ArrayList<>();
+ for (OrderCourseVO orderCourseVO : res1) {
+ if (!longs1.contains(orderCourseVO.getBusinessId())){
+ longs1.add(orderCourseVO.getBusinessId());
+ orderCourseVOS.add(orderCourseVO);
+ }
+ }
+ List<OrderCourseVO> testing = testing(orderCourseVOS.size(), pageCurr, pageSize, orderCourseVOS);
return R.ok(testing);
}
public static List<OrderCourseVO> testing(long total, long current, long size, List<OrderCourseVO> str){
@@ -270,10 +316,13 @@
* @return 下单返回数据视图对象
* @see com.xinquan.order.domain.vo.ClientPlaceOrderVO
*/
+
@PostMapping("/placeOrder")
@ApiOperation(value = "创建支付订单", notes = "微信|支付宝")
@ApiImplicitParams({
@ApiImplicitParam(name = "targetId", value = "目标id 订单类型为会员和充值时不传", dataType = "Long", required = false),
+ @ApiImplicitParam(name = "type", value = "类型 用于判断苹果支付还是安卓支付", dataType = "Long", required = false),
+ @ApiImplicitParam(name = "orderId", value = "订单id 待支付时传", dataType = "Long", required = false),
@ApiImplicitParam(name = "orderFrom", value = "订单来源 1=冥想音频 2=课程 3=购买会员 4充值", dataType = "Integer", required = true),
@ApiImplicitParam(name = "receiverId", value = "被赠送课程APP用户id", dataType = "Long", required = false),
@ApiImplicitParam(name = "balanceFlag", value = "是否使用余额抵扣 1=是 2=否", dataType = "Integer", required = false),
@@ -283,18 +332,22 @@
})
public R<ClientPlaceOrderVO> placeOrder(
@RequestParam(value = "targetId", required = false) Long targetId,
+ @RequestParam(value = "type", required = false) Integer type,
+ @RequestParam(value = "orderId", required = false) Long orderId,
@RequestParam(value = "orderFrom") Integer orderFrom,
@RequestParam(value = "receiverId", required = false) Long receiverId,
@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)
+
{
try {
-
+ ClientPlaceOrderVO clientPlaceOrderVO = orderService.placeOrder(targetId, orderFrom, receiverId, orderId,
+ balanceFlag, payType, amount, vipType,type);
+ System.err.println("支付返回参数"+clientPlaceOrderVO);
return R.ok(
- orderService.placeOrder(targetId, orderFrom, receiverId,
- balanceFlag, payType,amount,vipType));
+ clientPlaceOrderVO);
} catch (Exception e) {
throw new RuntimeException(e);
}
@@ -309,11 +362,16 @@
public R refund(@RequestParam(value = "uid") String uid,
@RequestParam(value = "remark") String remark) throws Exception {
Order byId = orderService.getById(uid);
+ String refund = orderService.refund(Long.valueOf(uid));
+ if (refund!=null && (!refund.equals("success"))){
+ return R.fail(refund);
+ }
byId.setRefundStatus(2);
byId.setRefundRemark(remark);
byId.setPaymentStatus(3);
+ byId.setRefundTime(LocalDateTime.now());
orderService.updateById(byId);
- orderService.refund(Long.valueOf(uid));
+
return R.ok();
}
@ResponseBody
@@ -329,13 +387,14 @@
@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 = "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,
@@ -406,6 +465,11 @@
order.setRealPayAmount(data.getIosPrice());
break;
}
+ if (receiverId!=null){
+ remoteAppUserService.addNotice(receiverId + "", data.getId() + "",
+ userId + "", order.getTotalAmount() + "");
+ }
+
break;
}
@@ -414,6 +478,7 @@
case 2:
if (receiverId!=null){
remoteAppUserService.addAppUserCourse(order.getBusinessId(),order.getGiveUserId(),order.getId(),1);
+ remoteAppUserService.addNotice(receiverId+"",order.getBusinessId()+"",order.getAppUserId()+"",order.getTotalAmount()+"");
}else{
// 自己购买
remoteAppUserService.addAppUserCourse(order.getBusinessId(),order.getAppUserId(),order.getId(),2);
@@ -435,20 +500,6 @@
appUserWalletRecord1.setChildAppUserId(order.getAppUserId());
appUserWalletRecord1.setOrderId(order.getId());
remoteAppUserService.addBalanceRecord(appUserWalletRecord1);
- switch (orderFrom){
- case 1:
-
- break;
- case 2:
-
- if (receiverId!=null){
- remoteAppUserService.addAppUserCourse(order.getBusinessId(),order.getGiveUserId(),order.getId(),1);
- }else{
- remoteAppUserService.addAppUserCourse(order.getBusinessId(),userId,order.getId(),1);
- }
- break;
- }
-
// 判断订单所属用户是否有上级 是否需要做分佣处理
AppUser data = remoteAppUserService.getAppUserById(order.getAppUserId() + "").getData();
BigDecimal realPayAmount = order.getRealPayAmount();
@@ -463,7 +514,7 @@
// if (data1.getProportion() != null) {
//
// BigDecimal bigDecimal = one1.getPayAmount().multiply(data1.getProportion()).divide(new BigDecimal("100"))
-// .setScale(2, BigDecimal.ROUND_HALF_DOWN);
+// .setScale(2, BigDecimal.ROUND_DOWN);
// // 上级获取的分佣金额
// AppUser appUserById = remoteAppUserService.getAppUserById(data.getInviteUserId() + "").getData();
// // 更新用户余额
@@ -524,7 +575,7 @@
// 支付金额
String string3 = jsonObject1.getString("pay_fee");
Order one = orderService.lambdaQuery().eq(Order::getBizOrderNo, string).one();
- if (one.getPaymentStatus()==2){
+ if (one.getPaymentStatus()!=1){
return;
}
one.setPaymentStatus(2);
@@ -533,6 +584,7 @@
.ne(OrderPaymentRecord::getPaymentType, 4).one();
if (one2!=null){
one2.setPaymentStatus(2);
+ one2.setPayOrderNo(string2);
orderPaymentRecordService.updateById(one2);
}
// 实际支付金额
@@ -556,7 +608,7 @@
if (data1.getProportion() != null) {
BigDecimal bigDecimal = one1.getPayAmount().multiply(data1.getProportion()).divide(new BigDecimal("100"))
- .setScale(2, BigDecimal.ROUND_HALF_DOWN);
+ .setScale(2, BigDecimal.ROUND_DOWN);
// 上级获取的分佣金额
AppUser appUserById = remoteAppUserService.getAppUserById(data.getInviteUserId() + "").getData();
// 更新用户余额
@@ -585,18 +637,18 @@
OrderPaymentRecord one1 = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, one.getId())
.eq(OrderPaymentRecord::getPaymentType, 4).one();
AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
- appUserWalletRecord.setAppUserId(data.getInviteUserId());
+ appUserWalletRecord.setAppUserId(one.getAppUserId());
String reason=null;
switch (one.getOrderFrom()){
case 1:
Meditation data1 = remoteMeditationService.getMeditationById(one.getBusinessId()).getData();
appUserWalletRecord.setChangeType(2);
- reason = "购买【"+data1.getMeditationTitle()+"】";
+ reason = "购买疗愈【"+data1.getMeditationTitle()+"】";
break;
case 2:
Course data2 = remoteCourseService.getCourseById(one.getBusinessId()).getData();
- reason = "购买【"+data2.getCourseTitle()+"】";
+ reason = "购买课程【"+data2.getCourseTitle()+"】";
appUserWalletRecord.setChangeType(2);
// 增加用户与课程的关系表
if (one.getGiveUserId()!=null){
@@ -608,7 +660,7 @@
break;
case 3:
// 会员
- reason = "购买【"+one.getBuyContent()+"】";
+ reason = "购买会员【"+one.getBuyContent()+"】";
appUserWalletRecord.setChangeType(2);
break;
case 4:
@@ -619,7 +671,6 @@
}
appUserWalletRecord.setReason(reason);
appUserWalletRecord.setAmount(one1.getPayAmount());
- appUserWalletRecord.setChildAppUserId(one.getAppUserId());
appUserWalletRecord.setOrderId(one.getId());
remoteAppUserService.addBalanceRecord(appUserWalletRecord);
}else{
@@ -668,7 +719,7 @@
e.printStackTrace();
}
}
- private static final String AES_KEY = "cb0a181ac97395c6942be19315fc0727";
+ private static final String AES_KEY = "6d548eb01bad44bbbb4a23743e733103";
public static String decrypt(String strToDecrypt) {
try {
SecretKeySpec secretKey = new SecretKeySpec(AES_KEY.getBytes(), "AES");
@@ -721,8 +772,12 @@
.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());
+ orderService.updateById(one);
OrderPaymentRecord one2 = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, one.getId())
.ne(OrderPaymentRecord::getPaymentType, 4).one();
if (one2!=null){
@@ -732,33 +787,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_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);
+ }
}
}
}
@@ -767,18 +834,18 @@
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:
Meditation data1 = remoteMeditationService.getMeditationById(one.getBusinessId()).getData();
appUserWalletRecord.setChangeType(2);
- reason = "购买【"+data1.getMeditationTitle()+"】";
+ reason = "购买疗愈【"+data1.getMeditationTitle()+"】";
break;
case 2:
Course data2 = remoteCourseService.getCourseById(one.getBusinessId()).getData();
- reason = "购买【"+data2.getCourseTitle()+"】";
+ reason = "购买课程【"+data2.getCourseTitle()+"】";
appUserWalletRecord.setChangeType(2);
// 增加用户与课程的关系表
if (one.getGiveUserId()!=null){
@@ -790,37 +857,8 @@
break;
case 3:
// 会员
- reason = "购买【"+one.getBuyContent()+"】";
+ 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())
- .divide(new BigDecimal(100),2, BigDecimal.ROUND_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:
// 充值
@@ -833,6 +871,42 @@
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:
+ System.err.println("进入充值");
+ remoteAppUserService.addBalance(one.getAppUserId(),one.getTotalAmount());
+ AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
+ appUserWalletRecord.setAppUserId(one.getAppUserId());
+ appUserWalletRecord.setChangeType(1);
+ appUserWalletRecord.setReason("充值");
+ appUserWalletRecord.setAmount(one.getTotalAmount());
+ appUserWalletRecord.setChildAppUserId(one.getAppUserId());
+ appUserWalletRecord.setOrderId(one.getId());
+ remoteAppUserService.addBalanceRecord(appUserWalletRecord);
+ break;
+ }
}
PrintWriter out = response.getWriter();
out.write("succeeded");
@@ -947,22 +1021,29 @@
OrderPaymentRecord two = orderPaymentRecordService.lambdaQuery()
.eq(OrderPaymentRecord::getOrderId, orderId)
.ne(OrderPaymentRecord::getPaymentType, 4)
- .eq(OrderPaymentRecord::getPaymentStatus, 2).one();
+ .ne(OrderPaymentRecord::getPaymentStatus, 1).one();
+ OrderPaymentRecord three = orderPaymentRecordService.lambdaQuery()
+ .eq(OrderPaymentRecord::getOrderId, orderId)
+ .eq(OrderPaymentRecord::getPaymentType, 4)
+ .ne(OrderPaymentRecord::getPaymentStatus, 1).one();
if (two==null){
one.setRemark("余额支付");
one.setBalance(one.getTotalAmount());
}else{
- switch (two.getPaymentType()){
- case 1:
- one.setRemark("微信支付");
+ switch (one.getPayType()){
+ case 5:
+ one.setRemark("微信支付+余额");
break;
- case 2:
- one.setRemark("支付宝支付");
+ case 6:
+ one.setRemark("支付宝支付+余额");
break;
- case 3:
- one.setRemark("苹果内购");
+ case 7:
+ one.setRemark("苹果内购+余额");
}
one.setPayOrderNo(two.getPayOrderNo());
+ if (three!=null){
+ one.setBalance(three.getPayAmount());
+ }
}
if (one.getCommissionId()!=null){
switch (one.getOrderFrom()){
--
Gitblit v1.7.1