课程购买钱包流水记录

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/controller/wallet/PayWalletController.java

@@ -2,6 +2,7 @@ package com.mmc.iuav.user.controller.wallet;
 
 import com.mmc.iuav.response.ResultBody;
 import com.mmc.iuav.user.controller.BaseController;
+import com.mmc.iuav.user.entity.wallet.CurriculumOrderLogVO;
 import com.mmc.iuav.user.entity.wallet.UserBillingDetailVO;
 import com.mmc.iuav.user.model.dto.wallet.PayWalletDTO;
 import com.mmc.iuav.user.model.qo.wallet.WalletFlowQO;
@@ -94,4 +95,11 @@ public class PayWalletController extends BaseController {
     public ResultBody payUavWallet(@RequestBody PayUavWalletVO payUavWalletVO) {
         return payWalletService.payUavWallet(payUavWalletVO);
     }
+
+    @ApiOperation(value = "feign——课程订单钱包流水记录")
+    @ApiResponses({@ApiResponse(code = 200, message = "OK", response = ResultBody.class)})
+    @PostMapping("feignCurriculumOrderLog")
+    public ResultBody payUavWallet2(HttpServletRequest request,@RequestBody CurriculumOrderLogVO param) {
+        return payWalletService.feignCurriculumOrderLog(this.getUserLoginInfoFromRedis(request).getUserAccountId(),param);
+    }
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/entity/wallet/CurriculumOrderLogVO.java

+package com.mmc.iuav.user.entity.wallet;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+
+/**
+ * @author Admin
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class CurriculumOrderLogVO {
+    private Integer userAccountId;
+    @ApiModelProperty(value = "云享金消耗金额")
+    private BigDecimal  cashAmtPaid;
+    @ApiModelProperty(value = "佣金消耗金额")
+    private BigDecimal salaryAmtPaid;
+    @ApiModelProperty(value = "订单编号")
+    private String orderNo;
+
+    public PayLogDO buildPayLog() {
+        return PayLogDO.builder().userAccountId(this.userAccountId)
+                .cashAmtPaid(this.cashAmtPaid)
+                .salaryAmtPaid(this.salaryAmtPaid)
+                .payNo(this.orderNo)
+                .build();
+    }
+}
\ No newline at end of file

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/entity/wallet/PayLogDO.java

 package com.mmc.iuav.user.entity.wallet;
 
 import lombok.AllArgsConstructor;
+import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
@@ -17,6 +18,7 @@ import java.util.Date;
 @Data
 @AllArgsConstructor
 @NoArgsConstructor
+@Builder
 public class PayLogDO implements Serializable {
     private static final long serialVersionUID = 752682324297846133L;
 

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/wallet/PayWalletService.java

 package com.mmc.iuav.user.service.wallet;
 
 import com.mmc.iuav.response.ResultBody;
+import com.mmc.iuav.user.entity.wallet.CurriculumOrderLogVO;
 import com.mmc.iuav.user.model.qo.wallet.WalletFlowQO;
 import com.mmc.iuav.user.model.vo.wallet.PayUavWalletVO;
 import com.mmc.iuav.user.model.vo.wallet.TopUpOrderVO;
@@ -26,5 +27,12 @@ public interface PayWalletService {
 
     ResultBody payUavWallet(PayUavWalletVO payUavWalletVO);
 
+    /**
+     * 保存用户购买课程消耗的云享金和佣金的金额流水
+     * @param param
+     * @return {@link ResultBody}
+     */
+    ResultBody feignCurriculumOrderLog(Integer userId, CurriculumOrderLogVO param);
+
     ResultBody optimizeWalletFlow(WalletFlowVO walletFlowVO);
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/wallet/impl/PayWalletServiceImpl.java

@@ -8,10 +8,7 @@ import com.mmc.iuav.user.dao.UserServiceDao;
 import com.mmc.iuav.user.dao.wallet.PayWalletDao;
 import com.mmc.iuav.user.entity.UserAccountDO;
 import com.mmc.iuav.user.entity.XzWithdrawalApplyDO;
-import com.mmc.iuav.user.entity.wallet.PayLogDO;
-import com.mmc.iuav.user.entity.wallet.PayWalletDO;
-import com.mmc.iuav.user.entity.wallet.UserBillingDetailVO;
-import com.mmc.iuav.user.entity.wallet.WithdrawalLogDO;
+import com.mmc.iuav.user.entity.wallet.*;
 import com.mmc.iuav.user.enums.PayMethodEnums;
 import com.mmc.iuav.user.model.dto.wallet.PayWalletDTO;
 import com.mmc.iuav.user.model.qo.wallet.WalletFlowQO;
@@ -37,6 +34,7 @@ import java.util.stream.Collectors;
  */
 @Service
 @Slf4j
+@Transactional(rollbackFor = Exception.class)
 public class PayWalletServiceImpl implements PayWalletService {
     @Resource
     PayWalletDao payWalletDao;
@@ -629,6 +627,47 @@ public class PayWalletServiceImpl implements PayWalletService {
         }
     }
 
+    /**
+     * 保存用户购买课程消耗的云享金和佣金的金额流水
+     *
+     * @param param
+     * @return {@link ResultBody}
+     */
+    @Override
+    public ResultBody feignCurriculumOrderLog(Integer userId, CurriculumOrderLogVO param) {
+
+        PayWalletDO payWalletByUser = payWalletDao.getPayWalletByUser(param.getUserAccountId());
+        //需要扣除的云享金
+        BigDecimal cashAmtPaid = param.getCashAmtPaid();
+        //需要扣除的佣金
+        BigDecimal salaryAmtPaid = param.getSalaryAmtPaid();
+        // 这是扣钱的接口 如果小于0表示加钱 不行
+        if(cashAmtPaid.compareTo(BigDecimal.ZERO) < 0 || salaryAmtPaid.compareTo(BigDecimal.ZERO) < 0){
+            return ResultBody.error("需要扣除的金额不能为负");
+        }
+        //扣除完后云享金
+        BigDecimal cashAmt = payWalletByUser.getCashAmt().subtract(cashAmtPaid);
+        //扣除完后佣金余额
+        BigDecimal salaryAmt = payWalletByUser.getSalaryAmt().subtract(salaryAmtPaid);
+        if(cashAmt.compareTo(BigDecimal.ZERO) >= 0){
+            payWalletByUser.setCashAmt(cashAmt);
+        }else {
+            return ResultBody.error("云享金不足");
+        }
+        if(salaryAmt.compareTo(BigDecimal.ZERO) >= 0){
+            payWalletByUser.setSalaryAmt(salaryAmt);
+        }else {
+            return ResultBody.error("佣金不足");
+        }
+        payWalletDao.updatePayWallet(payWalletByUser);
+
+        PayLogDO payLogDO = param.buildPayLog();
+        payLogDO.setOperateUser(userId);
+        payLogDO.setPayMethod(1400);
+        payWalletDao.insertPayLogDO(payLogDO);
+        return ResultBody.success();
+    }
+
     private ResultBody handleLeaseOrderRefund(PayUavWalletVO payUavWalletVO, PayWalletDO userWalletInfo, PayLogDO payLogDO, PayWalletDO payWalletDO) {
         payLogDO.setCashAmtPaid(payUavWalletVO.getCashAmount());
         payLogDO.setSalaryAmtPaid(payUavWalletVO.getSalaryAmount());