玩湃
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
nickchange
2023-11-25 cf28c25d1a8e360ab328c5435d289c5cb9b414c1 
 cloud-server-course/src/main/java/com/dsh/course/controller/CoursePackagePaymentController.java


@@ -21,6 +21,7 @@


import com.dsh.course.feignclient.other.StoreClient;


import com.dsh.course.feignclient.other.model.Store;


import com.dsh.course.mapper.CoursePackageSchedulingMapper;


import com.dsh.course.mapper.TCoursePackageMapper;


import com.dsh.course.model.*;


import com.dsh.course.model.dto.DiscountJsonDto;


import com.dsh.course.model.vo.CourseDetailRequest;


@@ -28,6 +29,7 @@


import com.dsh.course.model.vo.request.*;


import com.dsh.course.model.vo.response.*;


import com.dsh.course.service.*;


import com.dsh.course.service.impl.CoursePackageOrderStudentServiceImpl;


import com.dsh.course.util.*;


import com.fasterxml.jackson.core.JsonProcessingException;


import com.fasterxml.jackson.databind.ObjectMapper;


@@ -585,6 +587,8 @@


        }


    }




    @Autowired


    private ICoursePackageOrderStudentService orderStudentService;




    /**


     * 课程名称列表


@@ -592,12 +596,12 @@


    @PostMapping("/base/coursePack/sessionNames")


    public List<StuSessionDetailsVo> getStuSessionList(@RequestBody CourseDetailRequest request) {


        List<StuSessionDetailsVo> detailsVos = new ArrayList<>();


        List<TCoursePackagePayment> byUserId = packagePaymentService.list(new QueryWrapper<TCoursePackagePayment>()


        List<CoursePackageOrderStudent> byUserId = orderStudentService.list(new QueryWrapper<CoursePackageOrderStudent>()


                .between("insertTime", request.getStartTime(), request.getEndTime())


                .eq("appUserId", request.getAppUserId())


                .eq("studentId", request.getStuId()));


        if (byUserId.size() > 0) {


            List<Integer> collect = byUserId.stream().map(TCoursePackagePayment::getCoursePackageId).collect(Collectors.toList());


            List<Integer> collect = byUserId.stream().map(CoursePackageOrderStudent::getCoursePackageId).collect(Collectors.toList());


            List<TCoursePackage> list = tcpService.list(new QueryWrapper<TCoursePackage>()


                    .in("id", collect));




@@ -670,22 +674,23 @@




    @PostMapping("/base/coursePack/getRecord")


    public List<PurchaseRecordVo> getRecord(@RequestBody RecordTimeRequest recordTimeRequest) {


        List<TCoursePackagePayment> list = new ArrayList<>();


        List<CoursePackageOrderStudent> list = new ArrayList<>();


        Integer[] changes = {1, 0};


        if (recordTimeRequest.getType() == null) {


            list = coursePackagePaymentService.list(new QueryWrapper<TCoursePackagePayment>().eq("studentId", recordTimeRequest.getStuId()).eq("coursePackageId", recordTimeRequest.getLessionId()).orderByDesc("insertTime"));


            list = coursePackageOrderStudentService.list(new QueryWrapper<CoursePackageOrderStudent>().eq("studentId", recordTimeRequest.getStuId()).eq("coursePackageId", recordTimeRequest.getLessionId()).orderByDesc("insertTime"));


        } else {




            list = coursePackagePaymentService.list(new QueryWrapper<TCoursePackagePayment>().eq("studentId", recordTimeRequest.getStuId()).eq("coursePackageId", recordTimeRequest.getLessionId()).orderByDesc("insertTime"));




            list = coursePackageOrderStudentService.list(new QueryWrapper<CoursePackageOrderStudent>().eq("studentId", recordTimeRequest.getStuId()).eq("coursePackageId", recordTimeRequest.getLessionId()).orderByDesc("insertTime"));


        }


        List<Long> ids = new ArrayList<>();


        for (TCoursePackagePayment coursePackagePayment : list) {


            ids.add(coursePackagePayment.getId());


        }


        List<Integer> appUserIds = list.stream().map(CoursePackageOrderStudent::getAppUserId).collect(Collectors.toList());


        List<CoursePackageOrderStudent> list1 = coursePackageOrderStudentService.list(new QueryWrapper<CoursePackageOrderStudent>()


                .in("appUserId", appUserIds)


                .eq("coursePackageId", recordTimeRequest.getLessionId())


                .eq("state", 1)


        );


        List<Long> collect = list1.stream().map(CoursePackageOrderStudent::getId).collect(Collectors.toList());






        QueryWrapper<CourseCounsum> in = new QueryWrapper<CourseCounsum>().in("paymentId", ids).in("changeType", changes);


        QueryWrapper<CourseCounsum> in = new QueryWrapper<CourseCounsum>().in("paymentId", collect).in("changeType", changes);




        if (recordTimeRequest.getType() != null) {


            if (recordTimeRequest.getType() == 2) {


@@ -1255,8 +1260,8 @@


    @PostMapping("/coursePackagePayment/queryResidueClassHourById")


    public Integer queryResidueClassHourById(@RequestBody Long id) {


        try {


            TCoursePackagePayment list = packagePaymentService.getById(id);


            return list.getLaveClassHours();


            CoursePackageOrderStudent coursePackageOrderStudent = coursePackageOrderStudentService.getById(id);


            return coursePackageOrderStudent.getLaveClassHours();


        } catch (Exception e) {


            e.printStackTrace();


            return 0;


@@ -1293,128 +1298,162 @@


    public void paymentDeductionClassHour(@RequestBody PaymentDeductionClassHour paymentDeductionClassHour) {


        try {


            // 2.0 用id进行查询


            TCoursePackagePayment coursePackagePayment = packagePaymentService.getOne(new QueryWrapper<TCoursePackagePayment>().eq("id", paymentDeductionClassHour.getCourseId()).eq("payStatus", 2)


                    .eq("status", 1).eq("state", 1).gt("laveClassHours", 0));


            Integer classHour = paymentDeductionClassHour.getClassHour();


//            TCoursePackagePayment coursePackagePayment = packagePaymentService.getOne(new QueryWrapper<TCoursePackagePayment>().eq("id", paymentDeductionClassHour.getCourseId()).eq("payStatus", 2)


//                    .eq("status", 1).eq("state", 1).gt("laveClassHours", 0));


//            Integer classHour = paymentDeductionClassHour.getClassHour();


//            for (TCoursePackagePayment coursePackagePayment : list) {


            if (coursePackagePayment.getLaveClassHours().compareTo(classHour) >= 0) {


                coursePackagePayment.setLaveClassHours(coursePackagePayment.getLaveClassHours() - classHour);


                coursePackagePayment.setAppUserId(null);


                packagePaymentService.updateById(coursePackagePayment);




                CourseCounsum courseCounsum = new CourseCounsum();


                courseCounsum.setPaymentId(coursePackagePayment.getId());


                courseCounsum.setChangeType(0);


                courseCounsum.setNum(classHour);


                courseCounsum.setInsertTime(new Date());


                courseCounsum.setReason("报名赛事");


                courseCounsumService.save(courseCounsum);






                List<CoursePackageStudent> studentCourse = coursePackageStudentService.list(new QueryWrapper<CoursePackageStudent>().eq("studentId", coursePackagePayment.getStudentId()).eq("coursePackageId", coursePackagePayment.getCoursePackageId()));


                List<Long> collect = studentCourse.stream().map(CoursePackageStudent::getCoursePackageSchedulingId).collect(Collectors.toList());


                coursePackageSchedulingService.remove(new QueryWrapper<CoursePackageScheduling>().in("id", collect));


                coursePackageStudentService.remove(new QueryWrapper<CoursePackageStudent>().eq("studentId", paymentDeductionClassHour.getId()).eq("coursePackageId", coursePackagePayment.getCoursePackageId()));




            CoursePackageOrderStudent coursePackageOrderStudent = coursePackageOrderStudentService.getById(paymentDeductionClassHour.getCourseId());


//            if (paymentDeductionClassHour.getClassHour() > coursePackageOrderStudent.getLaveClassHours()) {


//                return ResultUtil.error("当前课包课时数不足");


//            }


            TCoursePackage coursePackage = coursePackageService.getById(coursePackageOrderStudent.getCoursePackageId());


            coursePackageOrderStudent.setLaveClassHours(coursePackageOrderStudent.getLaveClassHours() - paymentDeductionClassHour.getClassHour());


            coursePackageOrderStudentService.updateById(coursePackageOrderStudent);


            //判断剩余课时是否已经全部进行排课，如果排课需要删除已经排好的记录


            List<CoursePackageScheduling> list1 = coursePackageSchedulingService.list(new QueryWrapper<CoursePackageScheduling>()


                    .eq("studentId", coursePackageOrderStudent.getStudentId()).eq("status", 1)


                    .eq("type", 1).orderByDesc("classDate"));


            //已经排课但没有使用的课时数量


            int number = list1.size() * coursePackage.getNeedNum();


            Integer laveClassHours1 = coursePackageOrderStudent.getLaveClassHours();


            //需要删除多余的排课记录


            if(number > laveClassHours1){


                int n = number - laveClassHours1;


                for (int i = 0; i < n; i++) {


                    CoursePackageScheduling coursePackageScheduling = list1.get(i);


                    coursePackageSchedulingService.getBaseMapper().deleteById(coursePackageScheduling.getId());




                TCoursePackage tCoursePackage = packageService.getById(coursePackagePayment.getCoursePackageId());


                String classWeeks = tCoursePackage.getClassWeeks();


                List<Integer> week = week(classWeeks);




                TCoursePackagePayment pay = packagePaymentService.getOne(new QueryWrapper<TCoursePackagePayment>().eq("coursePackageId", coursePackagePayment.getCoursePackageId()).eq("studentId", coursePackagePayment.getStudentId()));




                Date today = new Date();


                Calendar calendar = Calendar.getInstance();


                calendar.add(Calendar.DATE, -1);


                today = calendar.getTime();






                Integer laveClassHours = pay.getLaveClassHours();


                Integer codeTime = tCoursePackage.getCodeTime();


                Integer can = laveClassHours / codeTime;




                int count = 0;


                String[] split = tCoursePackage.getClassStartTime().split(",");


                String[] split1 = tCoursePackage.getClassEndTime().split(",");


                SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");


                SimpleDateFormat format1 = new SimpleDateFormat("yyyy-MM-dd HH:mm");




                Date[] dates = generateDateArray(14, today);


                for (Date date : dates) {


                    if (count == can) {


                        break;


                    }


                    int wei = cn.hutool.core.date.DateUtil.dayOfWeek(date);


                    if (week.contains(wei)) {


                        for (int i1 = 0; i1 < split.length; i1++) {


                            if (count == can) {


                                break;


                            }


                            CoursePackageScheduling coursePackageScheduling = new CoursePackageScheduling();


                            coursePackageScheduling.setCoursePackageId(tCoursePackage.getId());


                            Date parse = format1.parse(format.format(date) + " " + split[i1]);


                            Date parse1 = format1.parse(format.format(date) + " " + split1[i1]);


                            coursePackageScheduling.setClassDate(parse);


                            coursePackageScheduling.setEndDate(parse1);


                            coursePackageScheduling.setStatus(1);


                            coursePackageSchedulingService.save(coursePackageScheduling);


                            CoursePackageStudent student1 = new CoursePackageStudent();


                            student1.setAppUserId(pay.getAppUserId());


                            student1.setStudentId(pay.getStudentId());


                            student1.setCoursePackageId(pay.getCoursePackageId());


                            student1.setCoursePackagePaymentId(pay.getId());


                            student1.setCoursePackageSchedulingId(coursePackageScheduling.getId());


                            student1.setSignInOrNot(1);


                            student1.setReservationStatus(1);


                            student1.setInsertTime(new Date());


                            studentService.save(student1);


                            count++;


                        }


                    }


                }






                // 2.0 少于3课时 推送


                if (coursePackagePayment.getLaveClassHours() <= 3) {


                    Integer appUserId = coursePackagePayment.getAppUserId();




                    //调用推送


                    HttpHeaders headers = new HttpHeaders();


                    // 以表单的方式提交


                    headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);


                    String s1 = appUserId + "_" + "Three";


                    //定时修改排课状态


                    String s = internalRestTemplate.getForObject("http://mb-cloud-gateway/netty/sendMsgToClient?id=" + s1, String.class);


                    JSONObject jsonObject1 = JSON.parseObject(s, JSONObject.class);


                    if (jsonObject1.getIntValue("code") != 200) {


                        System.err.println(jsonObject1.getString("msg"));


                    coursePackageStudentService.getBaseMapper().delete(new QueryWrapper<CoursePackageStudent>()


                            .eq("coursePackageSchedulingId", coursePackageScheduling.getId()));


                    }


                }




                CancelledClasses cancelledClasses = new CancelledClasses();


                cancelledClasses.setType(2);


                cancelledClasses.setVoucher(paymentDeductionClassHour.getCode());


                cancelledClasses.setCoursePackageId(coursePackagePayment.getCoursePackageId());


                cancelledClasses.setCoursePackagePaymentId(coursePackagePayment.getId());


                cancelledClasses.setCancelledClassesNumber(classHour);


                cancelledClasses.setInsertTime(new Date());


                cancelledClassesService.save(cancelledClasses);




            } else {


                CancelledClasses cancelledClasses = new CancelledClasses();


                cancelledClasses.setType(2);


                cancelledClasses.setVoucher(paymentDeductionClassHour.getCode());


                cancelledClasses.setCoursePackageId(coursePackagePayment.getCoursePackageId());


                cancelledClasses.setCoursePackagePaymentId(coursePackagePayment.getId());


                cancelledClasses.setCancelledClassesNumber(coursePackagePayment.getLaveClassHours());


                cancelledClasses.setInsertTime(new Date());


                cancelledClassesService.save(cancelledClasses);




                coursePackagePayment.setLaveClassHours(0);


                packagePaymentService.updateById(coursePackagePayment);




                classHour -= cancelledClasses.getCancelledClassesNumber();


            }






//            if (coursePackagePayment.getLaveClassHours().compareTo(classHour) >= 0) {


//                coursePackagePayment.setLaveClassHours(coursePackagePayment.getLaveClassHours() - classHour);


//                coursePackagePayment.setAppUserId(null);


//                packagePaymentService.updateById(coursePackagePayment);


//


//                CourseCounsum courseCounsum = new CourseCounsum();


//                courseCounsum.setPaymentId(coursePackagePayment.getId());


//                courseCounsum.setChangeType(0);


//                courseCounsum.setNum(classHour);


//                courseCounsum.setInsertTime(new Date());


//                courseCounsum.setReason("报名赛事");


//                courseCounsumService.save(courseCounsum);


//


//


//                List<CoursePackageStudent> studentCourse = coursePackageStudentService.list(new QueryWrapper<CoursePackageStudent>().eq("studentId", coursePackagePayment.getStudentId()).eq("coursePackageId", coursePackagePayment.getCoursePackageId()));


//                List<Long> collect = studentCourse.stream().map(CoursePackageStudent::getCoursePackageSchedulingId).collect(Collectors.toList());


//                coursePackageSchedulingService.remove(new QueryWrapper<CoursePackageScheduling>().in("id", collect));


//                coursePackageStudentService.remove(new QueryWrapper<CoursePackageStudent>().eq("studentId", paymentDeductionClassHour.getId()).eq("coursePackageId", coursePackagePayment.getCoursePackageId()));


//


//


//                TCoursePackage tCoursePackage = packageService.getById(coursePackagePayment.getCoursePackageId());


//                String classWeeks = tCoursePackage.getClassWeeks();


//                List<Integer> week = week(classWeeks);


//


//                TCoursePackagePayment pay = packagePaymentService.getOne(new QueryWrapper<TCoursePackagePayment>().eq("coursePackageId", coursePackagePayment.getCoursePackageId()).eq("studentId", coursePackagePayment.getStudentId()));


//


//                Date today = new Date();


//                Calendar calendar = Calendar.getInstance();


//                calendar.add(Calendar.DATE, -1);


//                today = calendar.getTime();


//


//


//                Integer laveClassHours = pay.getLaveClassHours();


//                Integer codeTime = tCoursePackage.getCodeTime();


//                Integer can = laveClassHours / codeTime;


//


//                int count = 0;


//                String[] split = tCoursePackage.getClassStartTime().split(",");


//                String[] split1 = tCoursePackage.getClassEndTime().split(",");


//                SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");


//                SimpleDateFormat format1 = new SimpleDateFormat("yyyy-MM-dd HH:mm");


//


//                Date[] dates = generateDateArray(14, today);


//                for (Date date : dates) {


//                    if (count == can) {


//                        break;


//                    }


//                    int wei = cn.hutool.core.date.DateUtil.dayOfWeek(date);


//                    if (week.contains(wei)) {


//                        for (int i1 = 0; i1 < split.length; i1++) {


//                            if (count == can) {


//                                break;


//                            }


//                            CoursePackageScheduling coursePackageScheduling = new CoursePackageScheduling();


//                            coursePackageScheduling.setCoursePackageId(tCoursePackage.getId());


//                            Date parse = format1.parse(format.format(date) + " " + split[i1]);


//                            Date parse1 = format1.parse(format.format(date) + " " + split1[i1]);


//                            coursePackageScheduling.setClassDate(parse);


//                            coursePackageScheduling.setEndDate(parse1);


//                            coursePackageScheduling.setStatus(1);


//                            coursePackageSchedulingService.save(coursePackageScheduling);


//                            CoursePackageStudent student1 = new CoursePackageStudent();


//                            student1.setAppUserId(pay.getAppUserId());


//                            student1.setStudentId(pay.getStudentId());


//                            student1.setCoursePackageId(pay.getCoursePackageId());


//                            student1.setCoursePackagePaymentId(pay.getId());


//                            student1.setCoursePackageSchedulingId(coursePackageScheduling.getId());


//                            student1.setSignInOrNot(1);


//                            student1.setReservationStatus(1);


//                            student1.setInsertTime(new Date());


//                            studentService.save(student1);


//                            count++;


//                        }


//                    }


//                }


//


//


//                // 2.0 少于3课时 推送


//                if (coursePackagePayment.getLaveClassHours() <= 3) {


//                    Integer appUserId = coursePackagePayment.getAppUserId();


//


//                    //调用推送


//                    HttpHeaders headers = new HttpHeaders();


//                    // 以表单的方式提交


//                    headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);


//                    String s1 = appUserId + "_" + "Three";


//                    //定时修改排课状态


//                    String s = internalRestTemplate.getForObject("http://mb-cloud-gateway/netty/sendMsgToClient?id=" + s1, String.class);


//                    JSONObject jsonObject1 = JSON.parseObject(s, JSONObject.class);


//                    if (jsonObject1.getIntValue("code") != 200) {


//                        System.err.println(jsonObject1.getString("msg"));


//                    }


//                }


//


//                CancelledClasses cancelledClasses = new CancelledClasses();


//                cancelledClasses.setType(2);


//                cancelledClasses.setVoucher(paymentDeductionClassHour.getCode());


//                cancelledClasses.setCoursePackageId(coursePackagePayment.getCoursePackageId());


//                cancelledClasses.setCoursePackagePaymentId(coursePackagePayment.getId());


//                cancelledClasses.setCancelledClassesNumber(classHour);


//                cancelledClasses.setInsertTime(new Date());


//                cancelledClassesService.save(cancelledClasses);


//


//            } else {


//                CancelledClasses cancelledClasses = new CancelledClasses();


//                cancelledClasses.setType(2);


//                cancelledClasses.setVoucher(paymentDeductionClassHour.getCode());


//                cancelledClasses.setCoursePackageId(coursePackagePayment.getCoursePackageId());


//                cancelledClasses.setCoursePackagePaymentId(coursePackagePayment.getId());


//                cancelledClasses.setCancelledClassesNumber(coursePackagePayment.getLaveClassHours());


//                cancelledClasses.setInsertTime(new Date());


//                cancelledClassesService.save(cancelledClasses);


//


//                coursePackagePayment.setLaveClassHours(0);


//                packagePaymentService.updateById(coursePackagePayment);


//


//                classHour -= cancelledClasses.getCancelledClassesNumber();


//            }


//                }






@@ -1478,6 +1517,8 @@


    }






    @Resource


    private TCoursePackageMapper tcpmapper;


    /**


     * 找出符合门店的课包


     *


@@ -1499,21 +1540,42 @@


        for (String s2 : split1) {


            storeIds.add(Integer.valueOf(s2));


        }


        List<TCoursePackagePayment> list = packagePaymentService.list(new LambdaQueryWrapper<TCoursePackagePayment>().eq(TCoursePackagePayment::getAppUserId, integer).ge(TCoursePackagePayment::getLaveClassHours, 0).eq(TCoursePackagePayment::getStatus, 1).eq(TCoursePackagePayment::getState, 1));


        for (TCoursePackagePayment tCoursePackagePayment : list) {


            Integer coursePackageId = tCoursePackagePayment.getCoursePackageId();


            TCoursePackage byId = tcpService.getById(coursePackageId);


            if (byId.getType() == 3) {


//        List<TCoursePackagePayment> list = packagePaymentService.list(new LambdaQueryWrapper<TCoursePackagePayment>().eq(TCoursePackagePayment::getAppUserId, integer).ge(TCoursePackagePayment::getLaveClassHours, 0).eq(TCoursePackagePayment::getStatus, 1).eq(TCoursePackagePayment::getState, 1));


//        for (TCoursePackagePayment tCoursePackagePayment : list) {


//            Integer coursePackageId = tCoursePackagePayment.getCoursePackageId();


//            TCoursePackage byId = tcpService.getById(coursePackageId);


//            if (byId.getType() == 3) {


//                continue;


//            }


//            if (storeIds.contains(byId.getStoreId())) {


//                PayCourseRes payCourseRes = new PayCourseRes();


//                payCourseRes.setCourseNum(tCoursePackagePayment.getLaveClassHours());


//                payCourseRes.setId(tCoursePackagePayment.getId());


//                payCourseRes.setName(byId.getName());


//                objects.add(payCourseRes);


//            }


//        }








        List<CoursePackageOrderStudent> tCoursePackagePayments = coursePackageOrderStudentService.list(new LambdaQueryWrapper<CoursePackageOrderStudent>().eq(CoursePackageOrderStudent::getAppUserId, integer));


//        ArrayList<PayCourseRes> payCourseRes = new ArrayList<>();


        for (CoursePackageOrderStudent tCoursePackagePayment : tCoursePackagePayments) {


            TCoursePackage tCoursePackage = tcpmapper.selectById(tCoursePackagePayment.getCoursePackageId());


            if (tCoursePackage.getType() != 1) {


                continue;


            }


            if (storeIds.contains(byId.getStoreId())) {


            if (storeIds.contains(tCoursePackage.getStoreId())) {


                PayCourseRes payCourseRes = new PayCourseRes();


                payCourseRes.setCourseNum(tCoursePackagePayment.getLaveClassHours());


                payCourseRes.setId(tCoursePackagePayment.getId());


                payCourseRes.setName(byId.getName());


                payCourseRes.setName(tCoursePackage.getName());


                objects.add(payCourseRes);




            }


        }






        return objects;


    }




@@ -1880,7 +1942,7 @@


    @PostMapping("/base/coursePack/obtainStudentClassDetails")


    public List<RecordAppoint> obtainStudentClassDetailsData(@RequestBody WeeksOfCourseRest stuId) {


//        try {


        return packagePaymentService.obtainStuClassDetails(stuId.getStuId(), stuId.getAppUserId(), stuId.getPageNum());


        return coursePackageOrderStudentService.obtainStuClassDetails(stuId.getStuId(), stuId.getAppUserId(), stuId.getPageNum());


//        }catch (Exception e){


//            e.printStackTrace();


//            throw new RuntimeException();