From c0f6294b0be6789fddd652f89f820fcf6d5526cf Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期四, 06 七月 2023 17:32:39 +0800
Subject: [PATCH] 合并代码

---
 cloud-server-course/src/main/java/com/dsh/course/controller/CourseController.java |   88 +++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 87 insertions(+), 1 deletions(-)

diff --git a/cloud-server-course/src/main/java/com/dsh/course/controller/CourseController.java b/cloud-server-course/src/main/java/com/dsh/course/controller/CourseController.java
index 0400ac4..ab2011c 100644
--- a/cloud-server-course/src/main/java/com/dsh/course/controller/CourseController.java
+++ b/cloud-server-course/src/main/java/com/dsh/course/controller/CourseController.java
@@ -3,12 +3,15 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.dsh.course.entity.TCourse;
+import com.dsh.course.entity.TCoursePackagePayment;
 import com.dsh.course.entity.TCoursePackageType;
 import com.dsh.course.feignclient.model.ExerciseVideo;
 import com.dsh.course.model.*;
+import com.dsh.course.service.TCoursePackagePaymentService;
 import com.dsh.course.service.TCoursePackageService;
 import com.dsh.course.service.TCoursePackageTypeService;
 import com.dsh.course.service.TCourseService;
+import com.dsh.course.util.PayMoneyUtil;
 import com.dsh.course.util.ResultUtil;
 import com.dsh.course.util.TokenUtil;
 import io.swagger.annotations.Api;
@@ -21,8 +24,12 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.PrintWriter;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 
 @Api
 @CrossOrigin
@@ -43,6 +50,12 @@
 
     @Autowired
     private TCoursePackageTypeService coursePackageTypeService;
+
+    @Autowired
+    private PayMoneyUtil payMoneyUtil;
+
+    @Autowired
+    private TCoursePackagePaymentService coursePackagePaymentService;
 
 
 
@@ -142,7 +155,12 @@
 
 
 
-
+    @ResponseBody
+    @PostMapping("/api/course/paymentCourse")
+    @ApiOperation(value = "支付课程", tags = {"APP-课程列表"})
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
+    })
     public ResultUtil paymentCourse(@RequestBody PaymentCourseVo paymentCourseVo){
         try {
             Integer uid = tokenUtil.getUserIdFormRedis();
@@ -156,4 +174,72 @@
         }
     }
 
+
+    /**
+     * 购买课程微信支付回调
+     * @param request
+     * @param response
+     */
+    @ResponseBody
+    @PostMapping("/base/course/weChatPaymentCourseCallback")
+    public void weChatPaymentCourseCallback(HttpServletRequest request, HttpServletResponse response){
+        try {
+            Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
+            if(null != map){
+                String code = map.get("out_trade_no");
+                String transaction_id = map.get("transaction_id");
+                String result = map.get("result");
+
+                List<TCoursePackagePayment> list = coursePackagePaymentService.list(new QueryWrapper<TCoursePackagePayment>().eq("state", 1).eq("code", code).eq("payType", 1));
+                TCoursePackagePayment one = list.get(0);
+                if(one.getPayStatus() == 1){
+                    for (TCoursePackagePayment coursePackagePayment : list) {
+                        coursePackagePayment.setPayStatus(2);
+                        coursePackagePayment.setOrderNumber(transaction_id);
+                    }
+                    coursePackagePaymentService.updateBatchById(list);
+                }
+                PrintWriter out = response.getWriter();
+                out.write(result);
+                out.flush();
+                out.close();
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+    }
+
+
+    /**
+     * 购买课程支付宝回调
+     * @param request
+     * @param response
+     */
+    @ResponseBody
+    @PostMapping("/base/course/aliPaymentCourseCallback")
+    public void aliPaymentCourseCallback(HttpServletRequest request, HttpServletResponse response){
+        try {
+            Map<String, String> map = payMoneyUtil.alipayCallback(request);
+            if(null != map){
+                String code = map.get("out_trade_no");
+                String trade_no = map.get("trade_no");
+
+                List<TCoursePackagePayment> list = coursePackagePaymentService.list(new QueryWrapper<TCoursePackagePayment>().eq("state", 1).eq("code", code).eq("payType", 2));
+                TCoursePackagePayment one = list.get(0);
+                if(one.getPayStatus() == 1){
+                    for (TCoursePackagePayment coursePackagePayment : list) {
+                        coursePackagePayment.setPayStatus(2);
+                        coursePackagePayment.setOrderNumber(trade_no);
+                    }
+                    coursePackagePaymentService.updateBatchById(list);
+                }
+                PrintWriter out = response.getWriter();
+                out.write("success");
+                out.flush();
+                out.close();
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+    }
 }

--
Gitblit v1.7.1