From b01f752252eaadd1fa31eda6a9ad43146660b721 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期四, 03 四月 2025 23:42:57 +0800
Subject: [PATCH] bug修改
---
xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/service/impl/OrderServiceImpl.java | 765 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 762 insertions(+), 3 deletions(-)
diff --git a/xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/service/impl/OrderServiceImpl.java b/xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/service/impl/OrderServiceImpl.java
index 2877c44..4a87d8c 100644
--- a/xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/service/impl/OrderServiceImpl.java
+++ b/xinquan-modules/xinquan-order/src/main/java/com/xinquan/order/service/impl/OrderServiceImpl.java
@@ -1,10 +1,46 @@
package com.xinquan.order.service.impl;
-import com.xinquan.order.domain.Order;
-import com.xinquan.order.mapper.OrderMapper;
-import com.xinquan.order.service.OrderService;
+import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xinquan.common.core.constant.SecurityConstants;
+import com.xinquan.common.core.enums.ChargeTypeEnum;
+import com.xinquan.common.core.enums.DisabledEnum;
+import com.xinquan.common.core.enums.PaymentStatusEnum;
+import com.xinquan.common.core.enums.PaymentTypeEnum;
+import com.xinquan.common.core.exception.ServiceException;
+import com.xinquan.common.core.utils.ip.IpUtils;
+import com.xinquan.common.security.service.TokenService;
+import com.xinquan.course.api.domain.Course;
+import com.xinquan.course.api.feign.RemoteCourseService;
+import com.xinquan.meditation.api.domain.Meditation;
+import com.xinquan.meditation.api.feign.RemoteMeditationService;
+import com.xinquan.order.api.domain.Order;
+import com.xinquan.order.domain.OrderPaymentRecord;
+import com.xinquan.order.domain.vo.ClientPlaceOrderVO;
+import com.xinquan.order.mapper.OrderMapper;
+import com.xinquan.order.service.OrderPaymentRecordService;
+import com.xinquan.order.service.OrderService;
+import com.xinquan.common.core.utils.JuHeFuUtil;
+import com.xinquan.order.utils.MD5Generator;
+import com.xinquan.order.utils.OrderUtil;
+import com.xinquan.system.api.domain.AppUser;
+import com.xinquan.system.api.domain.AppUserWalletRecord;
+import com.xinquan.system.api.model.LoginUser;
+import com.xinquan.user.api.domain.dto.AppUserDTO;
+import com.xinquan.user.api.feign.RemoteAppUserService;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.time.LocalDateTime;
+import java.util.List;
+
+import lombok.Data;
+import lombok.RequiredArgsConstructor;
+import org.jetbrains.annotations.NotNull;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
/**
* <p>
@@ -15,6 +51,729 @@
* @since 2024-08-21
*/
@Service
+@RequiredArgsConstructor
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {
+ @Resource
+ private RemoteMeditationService remoteMeditationService;
+ @Resource
+ private RemoteCourseService remoteCourseService;
+ @Resource
+ private RemoteAppUserService remoteAppUserService;
+ @Resource
+ private OrderPaymentRecordService orderPaymentRecordService;
+ @Autowired
+ private TokenService tokenService;
+ /**
+ * 创建待支付订单
+ *
+ * @param targetId 目标id
+ * @param orderFrom 订单来源 1=冥想音频 2=课程
+ * @param receiverId 被赠送课程APP用户id
+ * @param balanceFlag 是否使用余额抵扣 1=是 2=否
+ * @param payType 支付方式 1=微信 2=支付宝
+ * @return 下单返回数据视图对象
+ * @see com.xinquan.order.domain.vo.ClientPlaceOrderVO
+ */
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public ClientPlaceOrderVO placeOrder(Long targetId, Integer orderFrom, Long receiverId, Long orderId,
+ Integer balanceFlag, Integer payType,BigDecimal amount,Integer vipType,Integer type) throws Exception {
+ // 获取当前登录用户id
+ LoginUser loginUser = tokenService.getLoginUser();
+ if (loginUser==null){
+ return new ClientPlaceOrderVO();
+ }
+ Long userId = loginUser.getUserid();
+ if (amount!=null){
+ amount = amount.setScale(2, RoundingMode.HALF_DOWN);
+ }
+ // 获取用户信息
+ AppUser appUser = getAppUserById(userId);
+ ClientPlaceOrderVO clientPlaceOrderVO = new ClientPlaceOrderVO();
+ Order order = new Order();
+ order.setPayType(payType);
+ AppUser data = remoteAppUserService.getAppUserById(userId + "").getData();
+
+ // 购买冥想音频
+ if (orderFrom == 1) {
+ Meditation meditation = remoteMeditationService.getMeditationById(targetId,
+ SecurityConstants.INNER).getData();
+ String meditationTitle = meditation.getMeditationTitle();
+ String detailDescription = "购买疗愈音频";
+ String wxOpenId = appUser.getWxOpenId();
+ // 创建订单
+ String orderNo = OrderUtil.getOrderNoForPrefix("MX");
+ if (orderId==null){
+ order.setPayType(payType);
+ order.setOrderFrom(orderFrom);
+ order.setBizOrderNo(orderNo);
+ order.setBusinessId(meditation.getId());
+ order.setAppUserId(userId);
+ order.setRealPayAmount(type==null?meditation.getGeneralPrice():meditation.getIosPrice());
+ order.setTotalAmount(type==null?meditation.getGeneralPrice():meditation.getIosPrice());
+ order.setPayType(payType);
+ order.setBuyContent("购买疗愈【"+meditationTitle+"】");
+ order.setGiveUserId(receiverId);
+ this.save(order);
+ }else{
+ order = this.getById(orderId);
+ order.setBizOrderNo(orderNo);
+ order.setBuyContent("购买疗愈【"+meditationTitle+"】");
+ this.updateById(order);
+ }
+
+ Long orderId9 = order.getId();
+ clientPlaceOrderVO.setOrderNo(orderNo);
+ clientPlaceOrderVO.setId(orderId9);
+
+ // 如果冥想音频价格设定为单独收费，且需要使用余额抵扣
+ if (data.getBalance().compareTo(new BigDecimal("0")) > 0 && balanceFlag.equals(1) && meditation.getChargeType().equals(ChargeTypeEnum.SEPARATE_CHARGE.getCode())) {
+ BigDecimal needPayAmount = handleBalancePayment(appUser,
+ type==null?meditation.getGeneralPrice():meditation.getIosPrice(),
+ orderId9);
+ if (needPayAmount.compareTo(BigDecimal.ZERO) <= 0) {
+ clientPlaceOrderVO.setZeroFlag(DisabledEnum.YES.getCode());
+ // 抵扣后金额为0 为余额支付
+ order.setPayType(4);
+ order.setBuyContent("购买疗愈【"+meditationTitle+"】");
+ this.updateById(order);
+ return clientPlaceOrderVO;
+ }
+ if (payType==1){
+ // 微信+余额
+ order.setPayType(5);
+ }else if (payType == 2){
+ // 支付宝+余额
+ order.setPayType(6);
+ }
+ order.setBuyContent("购买疗愈【"+meditationTitle+"】");
+ this.updateById(order);
+ // 创建支付订单
+ createPayment(payType, orderNo, needPayAmount, meditationTitle, "购买疗愈",
+ wxOpenId, orderId9, clientPlaceOrderVO);
+ } else {
+ // 创建支付订单
+ createPayment(payType, orderNo, type==null?order.getRealPayAmount():order.getRealPayAmount(), meditationTitle,
+ "购买疗愈", wxOpenId, orderId9, clientPlaceOrderVO);
+ }
+ }
+ else if (orderFrom == 2){
+ // 购买课程
+ Course course = remoteCourseService.getCourseById(targetId).getData();
+ String courseTitle = course.getCourseTitle();
+ String wxOpenId = appUser.getWxOpenId();
+ String description = "购买课程";
+
+ // 创建订单
+ String orderNo = OrderUtil.getOrderNoForPrefix("KC");
+ if (orderId==null){
+ order.setOrderFrom(orderFrom);
+ order.setBizOrderNo(orderNo);
+ order.setGiveUserId(receiverId);
+ order.setBusinessId(course.getId());
+
+ order.setAppUserId(userId);
+ order.setBuyContent("购买课程【"+courseTitle+"】");
+ order.setRealPayAmount(type==null?course.getGeneralPrice():course.getIosPrice());
+ order.setTotalAmount(type==null?course.getGeneralPrice():course.getIosPrice());
+ this.save(order);
+ }else{
+ order = this.getById(orderId);
+ order.setBuyContent("购买课程【"+courseTitle+"】");
+ order.setBizOrderNo(orderNo);
+ this.updateById(order);
+
+ }
+ Long orderId8 = order.getId();
+ clientPlaceOrderVO.setOrderNo(orderNo);
+ clientPlaceOrderVO.setId(orderId8);
+
+ if (data.getBalance().compareTo(new BigDecimal("0")) > 0 && balanceFlag.equals(1) && course.getChargeType()
+ .equals(ChargeTypeEnum.SEPARATE_CHARGE.getCode())) {
+ BigDecimal needPayAmount = handleBalancePayment(appUser, type==null?course.getGeneralPrice():course.getIosPrice(),
+ orderId8);
+
+ if (needPayAmount.compareTo(BigDecimal.ZERO) <= 0) {
+ clientPlaceOrderVO.setZeroFlag(DisabledEnum.YES.getCode());
+ // 抵扣后金额为0 为余额支付
+ order.setPayType(4);
+ order.setBuyContent("购买课程【"+courseTitle+"】");
+
+ this.updateById(order);
+ return clientPlaceOrderVO;
+ }
+ if (payType==1){
+ // 微信+余额
+ order.setPayType(5);
+ }else if (payType == 2){
+ // 支付宝+余额
+ order.setPayType(6);
+ }
+ order.setBuyContent("购买课程【"+courseTitle+"】");
+
+ this.updateById(order);
+ // 创建支付订单
+ createPayment(payType, orderNo, needPayAmount, courseTitle, "购买课程",
+ wxOpenId, orderId8, clientPlaceOrderVO);
+ } else {
+ // 创建支付订单
+ createPayment(payType, orderNo, order.getRealPayAmount(), courseTitle,
+ "购买课程", wxOpenId, orderId8, clientPlaceOrderVO);
+ }
+ }
+ else if (orderFrom == 3){
+ String wxOpenId = appUser.getWxOpenId();
+ // 创建订单
+ String orderNo = OrderUtil.getOrderNoForPrefix("HY");
+ order.setOrderFrom(orderFrom);
+ order.setBizOrderNo(orderNo);
+ order.setAppUserId(userId);
+ order.setTotalAmount(amount);
+ order.setPayType(payType);
+ order.setRealPayAmount(amount);
+ String vipType1 ="";
+ switch (vipType){
+ case 1:
+ vipType1="月会员";
+ break;
+ case 2:
+ vipType1="季会员";
+ break;
+ case 3:
+ vipType1="年会员";
+ break;
+ }
+ order.setBuyContent(vipType1);
+ this.save(order);
+ Long orderId7 = order.getId();
+ clientPlaceOrderVO.setOrderNo(orderNo);
+ clientPlaceOrderVO.setId(orderId7);
+ // 创建支付订单
+ createPayment(payType, orderNo, amount, "购买会员",
+ vipType1, wxOpenId, orderId7, clientPlaceOrderVO);
+
+ }else {
+ // 充值
+ String wxOpenId = appUser.getWxOpenId();
+ // 创建订单
+ String orderNo = OrderUtil.getOrderNoForPrefix("CZ");
+ order.setOrderFrom(orderFrom);
+ order.setBizOrderNo(orderNo);
+ order.setAppUserId(userId);
+ order.setTotalAmount(amount);
+ order.setRealPayAmount(amount);
+ order.setPayType(payType);
+ order.setBuyContent("充值");
+ this.save(order);
+ Long orderId6 = order.getId();
+ clientPlaceOrderVO.setOrderNo(orderNo);
+ clientPlaceOrderVO.setId(orderId6);
+ // 创建支付订单
+ createPayment(payType, orderNo, amount, "充值余额",
+ "充值余额", wxOpenId, orderId6, clientPlaceOrderVO);
+ }
+ return clientPlaceOrderVO;
+ }
+
+ /**
+ * 处理余额抵扣
+ *
+ * @param appUser app用户
+ * @param generalPrice 通用价格
+ * @param orderId 订单号
+ * @return 需要支付的金额
+ */
+ @NotNull
+ private BigDecimal handleBalancePayment(AppUser appUser, BigDecimal generalPrice,
+ Long orderId) {
+ if (appUser.getBalance().compareTo(BigDecimal.ZERO) < 0) {
+ throw new ServiceException("用户可用余额不足，请重新选择支付方案");
+ }
+ Order one = this.lambdaQuery().eq(Order::getId, orderId).one();
+
+ // 如果余额大于通用价格 则实际支付价格为0
+ if (appUser.getBalance().compareTo(one.getRealPayAmount())>=0){
+ // 更新用户余额
+// remoteAppUserService.updateAppUser(
+// AppUserDTO.builder().balance(
+// appUser.getBalance().subtract(one.getRealPayAmount()))
+// .build(), SecurityConstants.INNER);
+ OrderPaymentRecord balancePaymentRecord = new OrderPaymentRecord();
+ balancePaymentRecord.setOrderId(orderId);
+ balancePaymentRecord.setPayAmount(one.getRealPayAmount());
+ balancePaymentRecord.setPaymentType(PaymentTypeEnum.BALANCE_PAY.getCode());
+ balancePaymentRecord.setPaymentStatus(PaymentStatusEnum.COMPLETED.getCode());
+ List<OrderPaymentRecord> list = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, orderId)
+ .eq(OrderPaymentRecord::getPaymentType, 4).list();
+ if (list.isEmpty()){
+ orderPaymentRecordService.save(balancePaymentRecord);
+ }
+
+ return new BigDecimal("0");
+ }else {
+ // 更新用户余额
+// remoteAppUserService.updateAppUser(
+// AppUserDTO.builder().balance(
+// one.getRealPayAmount().subtract(appUser.getBalance()))
+// .build(), SecurityConstants.INNER);
+
+ OrderPaymentRecord balancePaymentRecord = new OrderPaymentRecord();
+ balancePaymentRecord.setOrderId(orderId);
+ balancePaymentRecord.setPaymentType(PaymentTypeEnum.BALANCE_PAY.getCode());
+ balancePaymentRecord.setPaymentStatus(PaymentStatusEnum.COMPLETED.getCode());
+ balancePaymentRecord.setPayAmount(appUser.getBalance());
+ List<OrderPaymentRecord> list = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, orderId)
+ .eq(OrderPaymentRecord::getPaymentType, 4).list();
+ if (list.isEmpty()){
+ orderPaymentRecordService.save(balancePaymentRecord);
+ }
+ // 计算除去余额还需支付的金额
+ return one.getRealPayAmount()
+ .subtract(appUser.getBalance());
+ }
+
+ }
+
+ /**
+ * 获取登录用户信息
+ *
+ * @param userId APP用户id
+ * @return AppUser
+ */
+ private AppUser getAppUserById(Long userId) {
+ return remoteAppUserService.getAppUserById(userId+"").getData();
+ }
+
+ /**
+ * 创建支付订单
+ *
+ * @param payType 支付方式 1=微信 2=支付宝
+ * @param orderNo 订单编号
+ * @param needPayAmount 支付金额
+ * @param goodsTitle 商品标题
+ * @param goodsDesc 商品描述
+ * @param wxOpenId 微信openId
+ * @param orderId 订单id
+ * @param clientPlaceOrderVO 下单返回数据视图对象
+ * @throws Exception
+ */
+ private void createPayment(Integer payType, String orderNo, BigDecimal needPayAmount,
+ String goodsTitle, String goodsDesc, String wxOpenId, Long orderId,
+ ClientPlaceOrderVO clientPlaceOrderVO) throws Exception {
+ if (payType == 1){
+ // 微信托管支付
+ // 截取前42个字符 商品描述信息，微信小程序和微信公众号该字段，最大长度 42 个字符
+ // 调用第三方支付获取支付信息
+ JSONObject payInfo = JuHeFuUtil.createPayment1(orderNo, payType,
+ needPayAmount.toString(), goodsTitle, goodsDesc,
+ IpUtils.getIpAddr(), wxOpenId,
+ "https://xq.xqzhihui.com/api/order/client/order/order/base/callback"
+// "https://xq.xqzhihui.com/api/order/client/order/order/base/callback"
+ );
+ // 第三方支付记录
+ OrderPaymentRecord paymentRecord = new OrderPaymentRecord();
+ paymentRecord.setOrderId(orderId);
+ Order byId = this.getById(orderId);
+ this.updateById(byId);
+ clientPlaceOrderVO.setPayAmt(payInfo.getString("pay_amt"));
+ clientPlaceOrderVO.setPath(payInfo.getJSONObject("expend").getString("path"));
+ clientPlaceOrderVO.setPayInfo(payInfo.getJSONObject("expend").getString("pay_info"));
+ clientPlaceOrderVO.setOrgId(payInfo.getJSONObject("expend").getString("orgId"));
+ clientPlaceOrderVO.setAppId(payInfo.getJSONObject("expend").getString("appId"));
+ paymentRecord.setPaymentType(PaymentTypeEnum.WECHAT_PAY.getCode());
+ paymentRecord.setPayOrderNo(payInfo.getString("id"));
+ clientPlaceOrderVO.setOrderId(payInfo.getString("id"));
+ paymentRecord.setPaymentStatus(PaymentStatusEnum.TO_BE_PAID.getCode());
+ paymentRecord.setPayAmount(needPayAmount);
+ OrderPaymentRecord list = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, orderId)
+ .ne(OrderPaymentRecord::getPaymentType, 4).one();
+ if (list==null){
+ orderPaymentRecordService.save(paymentRecord);
+ }else{
+ list.setPayOrderNo(payInfo.getString("id"));
+ orderPaymentRecordService.updateById(list);
+ }
+ // 设置订单是否需要支付标识
+ clientPlaceOrderVO.setZeroFlag(DisabledEnum.NO.getCode());
+ }else{
+ // 调用第三方支付获取支付信息
+ JSONObject payInfo = JuHeFuUtil.createPayment(orderNo, payType,
+ needPayAmount.toString(), goodsTitle, goodsDesc,
+ IpUtils.getIpAddr(), wxOpenId,
+ "https://xq.xqzhihui.com/api/order/client/order/order/base/callback"
+// "https://xq.xqzhihui.com/api/order/client/order/order/base/callback"
+
+ );
+ // 第三方支付记录
+ OrderPaymentRecord paymentRecord = new OrderPaymentRecord();
+ paymentRecord.setOrderId(orderId);
+ paymentRecord.setPayAmount(needPayAmount);
+ Order byId = this.getById(orderId);
+ this.updateById(byId);
+ JSONObject expend = payInfo.getJSONObject("expend");
+ String string = expend.getString("qrcode_url");
+ clientPlaceOrderVO.setQrcodeUrl(string);
+ paymentRecord.setPaymentType(PaymentTypeEnum.ALI_PAY.getCode());
+ paymentRecord.setPaymentStatus(PaymentStatusEnum.TO_BE_PAID.getCode());
+ paymentRecord.setPayOrderNo(payInfo.getString("id"));
+ OrderPaymentRecord list = orderPaymentRecordService.lambdaQuery().eq(OrderPaymentRecord::getOrderId, orderId)
+ .ne(OrderPaymentRecord::getPaymentType, 4).one();
+ if (list==null){
+ orderPaymentRecordService.save(paymentRecord);
+ }else{
+ list.setPayOrderNo(payInfo.getString("id"));
+ orderPaymentRecordService.updateById(list);
+ }
+ clientPlaceOrderVO.setPayAmt(payInfo.getString("pay_amt"));
+ clientPlaceOrderVO.setOrderId(payInfo.getString("id"));
+ // 设置订单是否需要支付标识
+ clientPlaceOrderVO.setZeroFlag(DisabledEnum.NO.getCode());
+ }
+
+ }
+
+ /**
+ * 根据类型获取已完成的订单列表
+ *
+ * @param userId 用户id
+ * @param orderFrom 订单来源
+ * @return
+ */
+ @Override
+ public List<Order> getOrderListByType(Long userId, Integer orderFrom) {
+ return this.lambdaQuery().eq(Order::getAppUserId, userId).eq(Order::getOrderFrom, orderFrom)
+ .eq(Order::getPaymentStatus, PaymentStatusEnum.COMPLETED.getCode()).list();
+ }
+
+ @Override
+ public String placeOrderApple(Long targetId, Integer orderFrom,
+ Long receiverId, Integer balanceFlag,
+ BigDecimal amount, Integer vipType, String transactionIdentifier
+ ,String originTransactionIdentifier,String receipt) {
+// String s = MD5Generator.generateMD5(receipt);
+
+ // 获取当前登录用户id
+ Long userId = tokenService.getLoginUser().getUserid();
+ // 获取用户信息
+ AppUser appUser = getAppUserById(userId);
+ ClientPlaceOrderVO clientPlaceOrderVO = new ClientPlaceOrderVO();
+ Order order = new Order();
+ // 购买冥想音频
+ if (orderFrom == 1) {
+ Meditation meditation = remoteMeditationService.getMeditationById(targetId,
+ SecurityConstants.INNER).getData();
+ // 创建订单
+ String orderNo = OrderUtil.getOrderNoForPrefix("MX");
+ order.setOrderFrom(orderFrom);
+ order.setBizOrderNo(orderNo);
+ order.setBusinessId(meditation.getId());
+ order.setAppUserId(userId);
+ order.setTotalAmount(meditation.getIosPrice());
+ order.setPayType(3);
+ order.setBuyContent("购买疗愈");
+ this.save(order);
+ Long orderId = order.getId();
+ clientPlaceOrderVO.setOrderNo(orderNo);
+ clientPlaceOrderVO.setId(orderId);
+ // 如果冥想音频价格设定为单独收费，且需要使用余额抵扣
+ if (balanceFlag.equals(1) && meditation.getChargeType().equals(ChargeTypeEnum.SEPARATE_CHARGE.getCode())) {
+ BigDecimal needPayAmount = handleBalancePayment(appUser,
+ meditation.getIosPrice(),
+ orderId);
+ if (needPayAmount.compareTo(BigDecimal.ZERO) <= 0) {
+ clientPlaceOrderVO.setZeroFlag(DisabledEnum.YES.getCode());
+ // 抵扣后金额为0 为余额支付
+ order.setPayType(4);
+ order.setRealPayAmount(meditation.getIosPrice());
+ this.updateById(order);
+ return order.getId().toString();
+ }else{
+ order.setPayType(7);
+ this.updateById(order);
+ // 创建支付订单
+ OrderPaymentRecord paymentRecord = new OrderPaymentRecord();
+ paymentRecord.setPayAmount(meditation.getIosPrice());
+ paymentRecord.setPayOrderNo(transactionIdentifier);
+ paymentRecord.setOrderId(orderId);
+ paymentRecord.setPaymentType(PaymentTypeEnum.IOS_PAY.getCode());
+ paymentRecord.setPaymentStatus(PaymentStatusEnum.TO_BE_PAID.getCode());
+// paymentRecord.setReceipt(s);
+ orderPaymentRecordService.save(paymentRecord);
+ }
+
+ } else {
+ order.setPayType(3);
+ this.updateById(order);
+ // 纯内购支付
+ OrderPaymentRecord paymentRecord = new OrderPaymentRecord();
+ paymentRecord.setPayAmount(meditation.getIosPrice());
+ paymentRecord.setPayOrderNo(transactionIdentifier);
+ paymentRecord.setOrderId(orderId);
+ paymentRecord.setPaymentType(PaymentTypeEnum.IOS_PAY.getCode());
+ paymentRecord.setPaymentStatus(PaymentStatusEnum.TO_BE_PAID.getCode());
+// paymentRecord.setReceipt(s);
+
+ orderPaymentRecordService.save(paymentRecord);
+ }
+ }
+ else if (orderFrom == 2){
+ // 购买课程
+ Course course = remoteCourseService.getCourseById(targetId).getData();
+ // 创建订单
+ String orderNo = OrderUtil.getOrderNoForPrefix("KC");
+ order.setOrderFrom(orderFrom);
+ order.setBuyContent("购买课程");
+ order.setBizOrderNo(orderNo);
+ order.setPayOrderNo(transactionIdentifier);
+ order.setGiveUserId(receiverId);
+ order.setBusinessId(course.getId());
+ order.setAppUserId(userId);
+ order.setTotalAmount(course.getIosPrice());
+ this.save(order);
+ Long orderId = order.getId();
+ clientPlaceOrderVO.setOrderNo(orderNo);
+ clientPlaceOrderVO.setId(orderId);
+ if (balanceFlag.equals(1) && course.getChargeType()
+ .equals(ChargeTypeEnum.SEPARATE_CHARGE.getCode())) {
+ BigDecimal needPayAmount = handleBalancePayment(appUser, course.getGeneralPrice(),
+ orderId);
+ if (needPayAmount.compareTo(BigDecimal.ZERO) <= 0) {
+ clientPlaceOrderVO.setZeroFlag(DisabledEnum.YES.getCode());
+ // 抵扣后金额为0 为余额支付
+ order.setPayType(4);
+ order.setRealPayAmount(course.getGeneralPrice());
+ this.updateById(order);
+ return order.getId()+"";
+ }else{
+ order.setPayType(7);
+ this.updateById(order);
+ // 创建支付订单
+ OrderPaymentRecord paymentRecord = new OrderPaymentRecord();
+ paymentRecord.setPayAmount(course.getIosPrice());
+ paymentRecord.setPayOrderNo(transactionIdentifier);
+ paymentRecord.setOrderId(orderId);
+ paymentRecord.setPaymentType(PaymentTypeEnum.IOS_PAY.getCode());
+ paymentRecord.setPaymentStatus(PaymentStatusEnum.TO_BE_PAID.getCode());
+// paymentRecord.setReceipt(s);
+
+ orderPaymentRecordService.save(paymentRecord);
+ }
+ } else {
+ order.setPayType(3);
+ this.updateById(order);
+ // 创建支付订单
+ OrderPaymentRecord paymentRecord = new OrderPaymentRecord();
+ paymentRecord.setPayAmount(course.getIosPrice());
+ paymentRecord.setPayOrderNo(transactionIdentifier);
+ paymentRecord.setOrderId(orderId);
+ paymentRecord.setPaymentType(PaymentTypeEnum.IOS_PAY.getCode());
+ paymentRecord.setPaymentStatus(PaymentStatusEnum.TO_BE_PAID.getCode());
+// paymentRecord.setReceipt(s);
+
+ orderPaymentRecordService.save(paymentRecord);
+ }
+ }
+ else if (orderFrom == 3){
+ // 创建订单
+ String orderNo = OrderUtil.getOrderNoForPrefix("HY");
+ order.setOrderFrom(orderFrom);
+ order.setBizOrderNo(orderNo);
+ order.setAppUserId(userId);
+ order.setTotalAmount(amount);
+ order.setRealPayAmount(amount);
+ String vipType1 ="";
+ switch (vipType){
+ case 1:
+ vipType1="月会员";
+ break;
+ case 2:
+ vipType1="季会员";
+ break;
+ case 3:
+ vipType1="年会员";
+ break;
+ }
+ order.setBuyContent(vipType1);
+ this.save(order);
+ Long orderId = order.getId();
+ order.setPayType(3);
+ this.updateById(order);
+ // 创建支付订单
+ OrderPaymentRecord paymentRecord = new OrderPaymentRecord();
+ paymentRecord.setPayAmount(amount);
+ paymentRecord.setPayOrderNo(transactionIdentifier);
+ paymentRecord.setOrderId(orderId);
+ paymentRecord.setPaymentType(PaymentTypeEnum.IOS_PAY.getCode());
+ paymentRecord.setPaymentStatus(PaymentStatusEnum.TO_BE_PAID.getCode());
+// paymentRecord.setReceipt(s);
+
+ orderPaymentRecordService.save(paymentRecord);
+ }else {
+ // 充值
+ String wxOpenId = appUser.getWxOpenId();
+ // 创建订单
+ String orderNo = OrderUtil.getOrderNoForPrefix("CZ");
+ order.setOrderFrom(orderFrom);
+ order.setBizOrderNo(orderNo);
+ order.setAppUserId(userId);
+ order.setTotalAmount(amount);
+ order.setRealPayAmount(amount);
+ order.setBuyContent("充值");
+ this.save(order);
+ Long orderId = order.getId();
+ order.setPayType(3);
+ this.updateById(order);
+ // 创建支付订单
+ OrderPaymentRecord paymentRecord = new OrderPaymentRecord();
+ paymentRecord.setPayAmount(amount);
+ paymentRecord.setPayOrderNo(transactionIdentifier);
+ paymentRecord.setOrderId(orderId);
+ paymentRecord.setPaymentType(PaymentTypeEnum.IOS_PAY.getCode());
+ paymentRecord.setPaymentStatus(PaymentStatusEnum.TO_BE_PAID.getCode());
+// paymentRecord.setReceipt(s);
+ orderPaymentRecordService.save(paymentRecord);
+ }
+ return order.getId()+"";
+ }
+
+
+
+ @Override
+ public String refund(Long uid) throws Exception {
+ Order byId = this.getById(uid);
+ OrderPaymentRecord two = orderPaymentRecordService.lambdaQuery()
+ .eq(OrderPaymentRecord::getPaymentType,4)
+ .eq(OrderPaymentRecord::getOrderId, uid)
+ .one();
+ if (byId.getPayType() == 4){
+ // 纯余额支付 直接退还余额
+ // 回退余额记录
+ AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
+ appUserWalletRecord.setAppUserId(byId.getAppUserId());
+ appUserWalletRecord.setChangeType(1);
+ appUserWalletRecord.setReason("后台退款");
+ appUserWalletRecord.setOrderId(byId.getId());
+ appUserWalletRecord.setAmount(two.getPayAmount());
+ remoteAppUserService.addBalanceRecord(appUserWalletRecord);
+ remoteAppUserService.addBalance(byId.getAppUserId(),two.getPayAmount());
+ byId.setRefundStatus(3);
+ byId.setRefundRemark("后台退款");
+ byId.setRefundTime(LocalDateTime.now());
+ byId.setPaymentStatus(3);
+ byId.setCancelTime(LocalDateTime.now());
+ two.setPaymentStatus(3);
+
+ this.updateById(byId);
+ orderPaymentRecordService.updateById(two);
+ switch (byId.getOrderFrom()){
+ case 1:
+ // 冥想订单 删除
+ break;
+ case 2:
+ // 删除用户与课程的关系表
+ remoteAppUserService.deleteAppUserCourse(byId.getBusinessId(),byId.getAppUserId());
+ break;
+ case 3:
+ // 会员订单 将用户会员到期时间回退
+ if (byId.getBuyContent().contains("月")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),1);
+ }else if (byId.getBuyContent().contains("季")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),2);
+ }else if (byId.getBuyContent().contains("年")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),3);
+ }
+ break;
+ }
+ return "success";
+ }else if (byId.getPayType() == 5 || byId.getPayType() == 6 || byId.getPayType() == 7){
+ OrderPaymentRecord one = orderPaymentRecordService.lambdaQuery()
+ .eq(OrderPaymentRecord::getOrderId, uid)
+ .ne(OrderPaymentRecord::getPaymentType, 4)
+ .ne(OrderPaymentRecord::getPaymentType, 3)
+ .one();
+ JSONObject refund = JuHeFuUtil.refund(one.getPayOrderNo(), byId.getBizOrderNo());
+ if (refund.getString("error_msg")!=null){
+ return refund.getString("error_msg");
+ }
+ // 回退余额记录
+ AppUserWalletRecord appUserWalletRecord = new AppUserWalletRecord();
+ appUserWalletRecord.setAppUserId(byId.getAppUserId());
+ appUserWalletRecord.setChangeType(1);
+ appUserWalletRecord.setReason("后台退款");
+ appUserWalletRecord.setOrderId(byId.getId());
+ appUserWalletRecord.setAmount(two.getPayAmount());
+ remoteAppUserService.addBalanceRecord(appUserWalletRecord);
+ remoteAppUserService.addBalance(byId.getAppUserId(),two.getPayAmount());
+ byId.setRefundStatus(3);
+ byId.setRefundRemark("后台退款");
+ byId.setRefundTime(LocalDateTime.now());
+ byId.setPaymentStatus(3);
+ byId.setCancelTime(LocalDateTime.now());
+ two.setPaymentStatus(3);
+ this.updateById(byId);
+ orderPaymentRecordService.updateById(two);
+
+ switch (byId.getOrderFrom()){
+ case 1:
+ // 冥想订单 删除
+ break;
+ case 2:
+ // 删除用户与课程的关系表
+ remoteAppUserService.deleteAppUserCourse(byId.getBusinessId(),byId.getAppUserId());
+ break;
+ case 3:
+ // 会员订单 将用户会员到期时间回退
+ if (byId.getBuyContent().contains("月")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),1);
+ }else if (byId.getBuyContent().contains("季")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),2);
+ }else if (byId.getBuyContent().contains("年")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),3);
+ }
+ break;
+ }
+ return "success";
+ }
+ OrderPaymentRecord one = orderPaymentRecordService.lambdaQuery()
+ .eq(OrderPaymentRecord::getOrderId, uid)
+ .ne(OrderPaymentRecord::getPaymentType, 4)
+ .ne(OrderPaymentRecord::getPaymentType, 3)
+ .one();
+ JSONObject refund = JuHeFuUtil.refund(one.getPayOrderNo(), byId.getBizOrderNo());
+ if (refund.getString("error_msg")!=null){
+ return refund.getString("error_msg");
+ }
+ one.setPaymentStatus(3);
+
+ orderPaymentRecordService.updateById(one);
+ String string = refund.getString("payment_id");
+ if (string!=null){
+ byId.setRefundCode(string);
+ }
+ byId.setRefundTime(LocalDateTime.now());
+ byId.setRefundStatus(3);
+ byId.setRefundRemark("后台退款");
+ this.updateById(byId);
+ switch (byId.getOrderFrom()){
+ case 1:
+ // 冥想订单 删除
+ break;
+ case 2:
+ // 删除用户与课程的关系表
+ remoteAppUserService.deleteAppUserCourse(byId.getBusinessId(),byId.getAppUserId());
+ break;
+ case 3:
+ // 会员订单 将用户会员到期时间回退
+ if (byId.getBuyContent().contains("月")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),1);
+ }else if (byId.getBuyContent().contains("季")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),2);
+ }else if (byId.getBuyContent().contains("年")){
+ remoteAppUserService.subVipExpireTime(byId.getAppUserId(),3);
+ }
+ break;
+ }
+ return "success";
+ }
}
--
Gitblit v1.7.1