From f6fe09539d37e44b199d6c1d09798088209d6d72 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期三, 24 七月 2024 19:34:02 +0800
Subject: [PATCH] 玩湃门店数据权限修改 收入管理增加世界杯记录

---
 cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackagePaymentServiceImpl.java |   38 +++++++++++++++++++++++++++++---------
 1 files changed, 29 insertions(+), 9 deletions(-)

diff --git a/cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackagePaymentServiceImpl.java b/cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackagePaymentServiceImpl.java
index e93dcad..4a0b2a2 100644
--- a/cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackagePaymentServiceImpl.java
+++ b/cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackagePaymentServiceImpl.java
@@ -6,7 +6,11 @@
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.alipay.api.AlipayApiException;
+import com.alipay.api.AlipayClient;
+import com.alipay.api.DefaultAlipayClient;
 import com.alipay.api.domain.Person;
+import com.alipay.api.request.AlipayTradeOrderSettleRequest;
+import com.alipay.api.response.AlipayTradeOrderSettleResponse;
 import com.alipay.api.response.AlipayTradeQueryResponse;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -16,10 +20,7 @@
 import com.dsh.course.entity.*;
 import com.dsh.course.entity.TAppUser;
 import com.dsh.course.entity.dto.StudentQeryDto;
-import com.dsh.course.feignclient.account.AppUserClient;
-import com.dsh.course.feignclient.account.CoachClient;
-import com.dsh.course.feignclient.account.StudentClient;
-import com.dsh.course.feignclient.account.UserIntegralChangesClient;
+import com.dsh.course.feignclient.account.*;
 import com.dsh.course.feignclient.account.model.*;
 import com.dsh.course.feignclient.activity.BenefitVideoClient;
 import com.dsh.course.feignclient.activity.CouponClient;
@@ -50,6 +51,7 @@
 import javax.annotation.Resource;
 import javax.persistence.criteria.CriteriaBuilder;
 import java.math.BigDecimal;
+import java.math.BigInteger;
 import java.math.MathContext;
 import java.math.RoundingMode;
 import java.text.ParseException;
@@ -124,6 +126,14 @@
     @Resource
     private UserIntegralChangesClient userIntegralChangesClient;
 
+    @Resource
+    private StudentHonorClient studentHonorClient;
+
+
+
+
+
+
 
     @Override
     public List<CoursePackagePaymentVO> listAll(CoursePackagePaymentQuery query) {
@@ -167,7 +177,7 @@
         if(null != appUserIds){
             status.in("appUserId", appUserIds);
         }
-        List<Map<String, Object>> maps = this.baseMapper.getStudentTotal(appUserIds, studentQeryDto.getStart(), studentQeryDto.getEnd());
+        List<Map<String, Object>> maps = this.baseMapper.getStudentTotal(appUserIds, studentQeryDto.getStart(), studentQeryDto.getEnd(),studentQeryDto.getCoursePackageIds());
         List<Map<String, Object>> list = new ArrayList<>();
         for (Map<String, Object> objectMap : maps) {
             if(null == objectMap.get("studentId")){
@@ -361,6 +371,7 @@
                 .eq("coursePackageId", detailsRequest.getCoursePackageId())
                 .eq("courseId", detailsRequest.getVideoId())
         );
+        //完成学习
         if (null != userVideoDetails && userVideoDetails.getState() == 1 && detailsRequest.getIsOver() == 1) {
             userVideoDetails.setState(2);
             userVideoDetails.setUpdateTime(new Date());
@@ -371,11 +382,19 @@
             AppUser appUser = appuClient.queryAppUser(coursePackageScheduling.getAppUserId());
             appUser.setIntegral((null == appUser.getIntegral() ? 0 : appUser.getIntegral()) + (null == coursePackageScheduling.getIntegral() ? 0 : coursePackageScheduling.getIntegral()));
             appuClient.updateAppUser(appUser);
+            //保存用户积分变动记录
             SaveUserIntegralChangesVo vo = new SaveUserIntegralChangesVo();
             vo.setAppUserId(coursePackageScheduling.getAppUserId());
             vo.setIntegral(coursePackageScheduling.getIntegral());
             vo.setType(4);
             userIntegralChangesClient.saveUserIntegralChanges(vo);
+            //添加勋章数据
+            Integer number = uvdmapper.selectCount(new QueryWrapper<UserVideoDetails>().eq("appUserId", appUserId).eq("state", 2));
+            StudentHonor studentHonor = new StudentHonor();
+            studentHonor.setAppUserId(appUserId);
+            studentHonor.setHonorType(4);
+            studentHonor.setNumber(number);
+            studentHonorClient.saveStudentHonor(studentHonor);
             return "SUCCESS";
         }
         return "ERROR";
@@ -829,6 +848,7 @@
             newPayment.setPayType(request.getPayType());
             newPayment.setState(1);
             newPayment.setInsertTime(new Date());
+            newPayment.setOrderType(1);
             coursePackageOrderService.save(newPayment);
             code = newPayment.getCode();
         }
@@ -917,7 +937,7 @@
                                 Map<String, String> data1 = resultUtil.getData();
                                 String s = data1.get("trade_state");
                                 String transaction_id = data1.get("transaction_id");
-                                if ("REFUND".equals(s) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) {
+                                if ("REFUND".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) {
                                     //有待支付的订单,这里不处理
 //                                    coursePackageOrder1.setState(3);
 //                                    coursePackageOrderService.updateById(coursePackageOrder1);
@@ -937,7 +957,7 @@
                                     coursePackageService.addCoursePackageOrderStudent(coursePackageOrder1.getId(), coursePackagePaymentConfig);
                                     break;
                                 }
-                                if ("USERPAYING".equals(s)) {
+                                if ("USERPAYING".equals(s) || "NOTPAY".equals(s)) {
                                     num++;
                                 }
                             }
@@ -1181,7 +1201,7 @@
     }
 
     public List<Integer> getIds(Integer siteId) {
-        HttpRequest httpRequest = HttpRequest.get("https://try.daowepark.com/v7/user_api/general/get_space_area?space_id=" + siteId);
+        HttpRequest httpRequest = HttpRequest.get("https://port.daowepark.com/v7/user_api/general/get_space_area?space_id=" + siteId);
         HttpResponse execute = httpRequest.execute();
         String body = execute.body();
         JSONObject jsonObject = JSONObject.parseObject(body);
@@ -1211,7 +1231,7 @@
         coursePackageOrderService.updateById(coursePackageOrder1);
 
         CoursePackagePaymentConfig coursePackagePaymentConfig = coursePackagePaymentConfigService.getOne(new QueryWrapper<CoursePackagePaymentConfig>()
-                .eq("coursePackageId", coursePackageOrder1.getId())
+                .eq("coursePackageId", coursePackageOrder1.getCoursePackageId())
                 .eq("classHours", coursePackageOrder1.getClassHours())
         );
         coursePackageService.addCoursePackageOrderStudent(coursePackageOrder1.getId(), coursePackagePaymentConfig);

--
Gitblit v1.7.1