增加 直播课购买回调

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/CourseGroupService.java

@@ -107,7 +107,7 @@ public interface CourseGroupService extends IService<CourseGroup> {
     /**
      * 直播详情 直播课学生到课状态
      *
-     * @param page 分页信息
+     * @param page  分页信息
      * @param query 查询条件
      * @return
      */
@@ -129,5 +129,10 @@ public interface CourseGroupService extends IService<CourseGroup> {
      *                   <p> - courseGroup   直播课程组信息
      */
     void buyLiveCourseAfter(UserOrderDetailVo afterParam);
+
+    /**
+     * 学生购买直播课程-成功-回调
+     */
+    void buyLiveCourseSuccess(UserOrderDetailVo orderParam);
 }
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/CourseGroupServiceImpl.java

@@ -525,6 +525,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
     @Transactional(rollbackFor = Exception.class)
     @Override
     public HttpResponseResult<OrderCreateRes> buyLiveCourse(OrderReq.OrderReqInfo orderReqInfo) {
+        log.info("学生购买直播课程组,请求参数:{}", JSON.toJSONString(orderReqInfo));
         Map<String, Object> param = WrapperUtil.toMap(orderReqInfo.getBizContent());
         Long groupId = WrapperUtil.toLong(param, "groupId", "课程组id不能为空！");
         Long studentId = orderReqInfo.getUserId();
@@ -577,6 +578,7 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
     @Transactional(rollbackFor = Exception.class)
     @Override
     public void buyLiveCourseAfter(UserOrderDetailVo afterParam) {
+        log.info("学生购买直播课程组 after ,请求参数:{}", JSON.toJSONString(afterParam));
         Map<String, Object> param = WrapperUtil.toMap(afterParam.getBizParam());
         String orderNo = afterParam.getOrderNo();
         Long studentId = (Long) param.get("studentId");
@@ -607,7 +609,10 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
      * 学生购买直播课程-成功-回调
      */
     @Transactional(rollbackFor = Exception.class)
-    public void buyLiveCourseSuccess(String orderNo) {
+    @Override
+    public void buyLiveCourseSuccess( UserOrderDetailVo orderParam) {
+        log.info("学生购买直播课程-成功-回调,请求参数:{}", JSON.toJSONString(orderParam));
+        String orderNo = orderParam.getOrderNo();
         //更新课程组的购买人数+1
         CourseScheduleStudentPayment studentPayment = courseScheduleStudentPaymentService.getOne(Wrappers.<CourseScheduleStudentPayment>lambdaQuery()
                 .eq(CourseScheduleStudentPayment::getOrderNo, orderNo)

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/UserOrderServiceImpl.java

@@ -83,7 +83,8 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
         /**********订单完成后******************/
         //vip开通缴费
         orderSuccess.put(GoodTypeEnum.VIP, vipCardService::orderSuccess);
-
+        //直播课程购买
+        orderSuccess.put(GoodTypeEnum.LIVE, courseGroupService::buyLiveCourseSuccess);
 
         /**********订单取消后******************/
         //orderCancel.put();