From cbca62b053eb3dc3cc7754aa0062aaf1e04e2cb4 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期四, 22 二月 2024 16:53:36 +0800
Subject: [PATCH] 新增加接口

---
 cloud-server-course/src/main/java/com/dsh/course/controller/CancelSourceController.java |   37 +++++++++++++++++++++----------------
 1 files changed, 21 insertions(+), 16 deletions(-)

diff --git a/cloud-server-course/src/main/java/com/dsh/course/controller/CancelSourceController.java b/cloud-server-course/src/main/java/com/dsh/course/controller/CancelSourceController.java
index e6e427f..9ed7373 100644
--- a/cloud-server-course/src/main/java/com/dsh/course/controller/CancelSourceController.java
+++ b/cloud-server-course/src/main/java/com/dsh/course/controller/CancelSourceController.java
@@ -7,6 +7,7 @@
 import com.dsh.course.feignclient.model.GetStuSessionList;
 import com.dsh.course.feignclient.model.PurchaseRecordVo;
 import com.dsh.course.service.CancelledClassesService;
+import com.dsh.course.service.CourseCounsumService;
 import com.dsh.course.service.TCoursePackagePaymentService;
 import io.swagger.annotations.Api;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,7 +24,6 @@
 @RequestMapping("")
 public class CancelSourceController {
 
-
     @Autowired
     private CancelledClassesService caceService;
 
@@ -36,27 +36,32 @@
 
     /**
      * 获取课包对应的消费记录
+     *
      * @param sessionList
      * @return
      */
     @PostMapping("/base/cancelSource/cancelList")
-    public List<PurchaseRecordVo> getCancelCourseList(@RequestBody GetStuSessionList sessionList){
+    public List<PurchaseRecordVo> getCancelCourseList(@RequestBody GetStuSessionList sessionList) {
         List<PurchaseRecordVo> purchaseRecordVos = new ArrayList<>();
+        List<TCoursePackagePayment> tCoursePackagePayments = tcppService.list(new QueryWrapper<TCoursePackagePayment>()
+                .between("insertTime", sessionList.getStartTime(), sessionList.getEndTime())
+                .eq("appUserId", sessionList.getAppUserId())
+                .eq("studentId", sessionList.getStuId()));
+        if (tCoursePackagePayments.size() > 0) {
+            List<Long> coursePackageIds = tCoursePackagePayments.stream().map(TCoursePackagePayment::getId).collect(Collectors.toList());
 
-        List<TCoursePackagePayment> tCoursePackagePayments = tcppService.queryAllCoursePackage(sessionList.getStartTime(),sessionList.getEndTime(),null,sessionList.getStuId(), sessionList.getAppUserId());
-        List<Long> coursePackageIds = tCoursePackagePayments.stream().map(TCoursePackagePayment::getId).collect(Collectors.toList());
-
-        List<CancelledClasses> list = caceService.list(new QueryWrapper<CancelledClasses>()
-                .in("coursePackageId", coursePackageIds)
-                .between("insertTime",sessionList.getStartTime(),sessionList.getEndTime()));
-        if (list.size() > 0){
-            list.forEach( canse -> {
-                PurchaseRecordVo purchaseRecordVo = new PurchaseRecordVo();
-                purchaseRecordVo.setPurchaseTime(format.format(canse.getInsertTime()));
-                purchaseRecordVo.setPurchaseType("");
-                purchaseRecordVo.setPurchaseAmount("-"+canse.getCancelledClassesNumber());
-                purchaseRecordVos.add(purchaseRecordVo);
-            });
+            List<CancelledClasses> list = caceService.list(new QueryWrapper<CancelledClasses>()
+                    .in("coursePackageId", coursePackageIds)
+                    .between("insertTime", sessionList.getStartTime(), sessionList.getEndTime()));
+            if (list.size() > 0) {
+                list.forEach(canse -> {
+                    PurchaseRecordVo purchaseRecordVo = new PurchaseRecordVo();
+                    purchaseRecordVo.setPurchaseTime(format.format(canse.getInsertTime()));
+                    purchaseRecordVo.setPurchaseType("");
+                    purchaseRecordVo.setPurchaseAmount("-" + canse.getCancelledClassesNumber());
+                    purchaseRecordVos.add(purchaseRecordVo);
+                });
+            }
         }
         return purchaseRecordVos;
     }

--
Gitblit v1.7.1