package com.qxgmat.service.extend; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.nuliji.tools.Tools; import com.nuliji.tools.Transform; import com.nuliji.tools.exception.ParameterException; import com.qxgmat.data.constants.enums.ServiceKey; import com.qxgmat.data.constants.enums.ServiceVipKey; import com.qxgmat.data.constants.enums.module.CourseModule; import com.qxgmat.data.constants.enums.module.ProductType; import com.qxgmat.data.constants.enums.trade.PayChannel; import com.qxgmat.data.constants.enums.trade.PayMethod; import com.qxgmat.data.constants.enums.trade.PayModule; import com.qxgmat.data.constants.enums.trade.RecordSource; import com.qxgmat.data.dao.entity.*; import com.qxgmat.service.UserServiceService; import com.qxgmat.service.UsersService; import com.qxgmat.service.annotation.*; import com.qxgmat.service.inline.*; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; @Service public class OrderFlowService { @Resource private ToolsService toolsService; @Resource private CourseService courseService; @Resource private CourseExtendService courseExtendService; @Resource private CoursePackageService coursePackageService; @Resource private CourseDataService courseDataService; @Resource private UserCourseService userCourseService; @Resource private UserServiceService userServiceService; @Resource private UserOrderService userOrderService; @Resource private UserOrderCheckoutService userOrderCheckoutService; @Resource private UserOrderRecordService userOrderRecordService; @Resource private UsersService usersService; @Resource private ExaminationService examinationService; @Resource private MessageExtendService messageExtendService; @Resource private TextbookService textbookService; private TradeService tradeService; @Resource private void registerTrade(TradeService tradeService) { this.tradeService = tradeService; this.tradeService.register(PayModule.ORDER, (obj)->{ Pay pay = (Pay)obj; Integer userId = pay.getUserId(); Integer orderId = pay.getModuleExtend(); return this.payed(orderId, userId, pay.getId(), pay.getPayTime(), PayMethod.FromChannel(PayChannel.ValueOf(pay.getChannel())), pay.getTransactionNo()); }); } private Map initCheckoutCallback = new HashMap<>(); private Map removeCheckoutCallback = new HashMap<>(); private Map initOrderCallback = new HashMap<>(); private Map initRecordCallback = new HashMap<>(); private Map useRecordCallback = new HashMap<>(); private Map stopRecordCallback = new HashMap<>(); public OrderFlowService(){ initCheckoutCallback.put(ProductType.COURSE, ((checkout, userOrderCheckoutList) -> { // 判断课程是否已经存在 UserOrderCheckout tmp=null; for(UserOrderCheckout in: userOrderCheckoutList){ if (!in.getProductType().equals(ProductType.COURSE.key)) continue; if (in.getProductId().equals(checkout.getProductId())){ tmp = in; break; } } Course mainCourse = courseService.get(checkout.getProductId()); // 判断是否是1v1课程 if (mainCourse.getCourseModule().equals(CourseModule.VS.key)){ if (tmp != null){ // 累加课时 checkout.setId(tmp.getId()); checkout.setNumber(tmp.getNumber() + checkout.getNumber()); } checkout.setOriginMoney(mainCourse.getPrice().multiply(BigDecimal.valueOf(checkout.getNumber()))); int percent = toolsService.computeVsMoney(checkout); checkout.setMoney(checkout.getOriginMoney().multiply(BigDecimal.valueOf(percent)).divide(BigDecimal.valueOf(100), BigDecimal.ROUND_HALF_UP)); return checkout; }else{ // 课程已添加，无需添加 if(tmp != null){ return null; } } // 填充金额 checkout.setMoney(mainCourse.getPrice()); checkout.setOriginMoney(mainCourse.getPrice()); // 先加入列表，统一处理 userOrderCheckoutList.add(checkout); // 判断是否符合套餐情况: 剩余的独立课程 List courseCheckout = userOrderCheckoutList.stream().filter((in)-> in.getProductType().equals(ProductType.COURSE.key) && in.getParentId() == 0).collect(Collectors.toList()); Collection courseIds = Transform.getIds(courseCheckout, UserOrderCheckout.class, "productId"); CoursePackage coursePackage = coursePackageService.combineCourse(courseIds); if(coursePackage != null){ List courseList = courseService.select(coursePackage.getCourseIds()); BigDecimal originMoney = BigDecimal.valueOf(0); for(Course course : courseList){ originMoney = originMoney.add(course.getPrice()); } // 加入套餐 UserOrderCheckout packageCheckout = UserOrderCheckout.builder() .productType(ProductType.COURSE_PACKAGE.key) .productId(coursePackage.getId()) .money(coursePackage.getPrice()) .originMoney(originMoney) .build(); packageCheckout = userOrderCheckoutService.add(packageCheckout); // 绑定所属 List ids = Arrays.stream(coursePackage.getCourseIds()).collect(Collectors.toList()); for(UserOrderCheckout c:courseCheckout){ if (ids.contains(c.getProductId())){ if (c.getId() !=null && c.getId() > 0){ userOrderCheckoutService.edit(UserOrderCheckout.builder() .id(c.getId()) .parentId(packageCheckout.getId()) .build()); }else{ c.setParentId(packageCheckout.getId()); userOrderCheckoutService.add(c); } } } return null; } // 正常添加 return checkout; })); initCheckoutCallback.put(ProductType.COURSE_PACKAGE, ((checkout, userOrderCheckoutList)->{ for(UserOrderCheckout in: userOrderCheckoutList){ if (!in.getProductType().equals(ProductType.COURSE_PACKAGE.key)) continue; if (in.getProductId().equals(checkout.getProductId())) return null; } CoursePackage coursePackage = coursePackageService.get(checkout.getProductId()); List courseList = courseService.select(coursePackage.getCourseIds()); Map courseMap = new HashMap<>(); for(Course course : courseList){ courseMap.put(course.getId(), course); } BigDecimal originMoney = BigDecimal.valueOf(0); for(Course course : courseList){ originMoney = originMoney.add(course.getPrice()); } checkout.setMoney(coursePackage.getPrice()); checkout.setOriginMoney(originMoney); checkout = userOrderCheckoutService.add(checkout); // 转移课程包含的独立课程 List ids = Arrays.stream(coursePackage.getCourseIds()).collect(Collectors.toList()); List courseCheckout = userOrderCheckoutList.stream().filter((in)-> in.getProductType().equals(ProductType.COURSE.key) && in.getParentId() == 0).collect(Collectors.toList()); for(UserOrderCheckout in : courseCheckout){ if (ids.contains(in.getProductId())){ // 转移该购物车记录 userOrderCheckoutService.edit(UserOrderCheckout.builder() .id(in.getId()) .parentId(checkout.getId()) .build()); ids.remove(in.getProductId()); } } // 添加还未添加的课程记录 for(Integer id : ids){ Course course = courseMap.get(id); userOrderCheckoutService.add(UserOrderCheckout.builder() .parentId(checkout.getId()) .productType(ProductType.COURSE.key) .productId(id) .money(course.getPrice()) .originMoney(course.getPrice()) .build()); } return null; })); initCheckoutCallback.put(ProductType.DATA, ((checkout, userOrderCheckoutList)->{ for(UserOrderCheckout in: userOrderCheckoutList){ if (!in.getProductType().equals(ProductType.DATA.key)) continue; if (in.getProductId().equals(checkout.getProductId())) return null; } CourseData courseData = courseDataService.get(checkout.getProductId()); checkout.setMoney(courseData.getPrice()); checkout.setOriginMoney(courseData.getPrice()); return checkout; })); initCheckoutCallback.put(ProductType.SERVICE, ((checkout, userOrderCheckoutList)->{ for(UserOrderCheckout in: userOrderCheckoutList){ if (!in.getProductType().equals(ProductType.SERVICE.key)) continue; if (in.getService().equals(checkout.getService())){ checkout.setId(in.getId()); break; } } BigDecimal money = BigDecimal.valueOf(toolsService.getServicePrice(checkout.getService(), checkout.getParam())); checkout.setOriginMoney(money); ServiceKey serviceKey = ServiceKey.ValueOf(checkout.getService()); if (serviceKey == ServiceKey.TEXTBOOK){ // 是否存在半价机经券 User user = usersService.get(checkout.getId()); checkout.setMoney(user.getTextbookHalf() > 0 ? money.divide(BigDecimal.valueOf(2), BigDecimal.ROUND_HALF_UP):money); }else{ checkout.setMoney(money); } return checkout; })); removeCheckoutCallback.put(ProductType.COURSE, ((checkout, userOrderCheckoutList)->{ // 子项目不允许参数，则无需处理 })); removeCheckoutCallback.put(ProductType.COURSE_PACKAGE, ((checkout, userOrderCheckoutList)->{ // 删除对应子项目 })); removeCheckoutCallback.put(ProductType.DATA, ((checkout, userOrderCheckoutList)->{ // miss })); removeCheckoutCallback.put(ProductType.SERVICE, ((checkout, userOrderCheckoutList)->{ // miss })); initOrderCallback.put(ProductType.SERVICE, ((order, userOrderCheckoutList) -> { // 累计金额 BigDecimal money = order.getMoney(); BigDecimal originMoney = order.getOriginMoney(); for(UserOrderCheckout checkout:userOrderCheckoutList){ ServiceKey serviceKey = ServiceKey.ValueOf(checkout.getService()); if (serviceKey == ServiceKey.TEXTBOOK){ // 是否存在半价机经券 if (!checkout.getMoney().equals(checkout.getOriginMoney())){ JSONObject info = new JSONObject(); info.put("originMoney", originMoney); info.put("money", money); info.put("key", "half"); JSONObject promote = order.getPromote(); promote.put("textbook", info); } } money = money.add(checkout.getMoney()); originMoney = originMoney.add(checkout.getMoney()); } order.setMoney(money); order.setOriginMoney(originMoney); })); initOrderCallback.put(ProductType.DATA, ((order, userOrderCheckoutList) -> { // 累计金额 BigDecimal money = order.getMoney(); BigDecimal originMoney = order.getOriginMoney(); for(UserOrderCheckout checkout:userOrderCheckoutList){ money = money.add(checkout.getMoney()); originMoney = originMoney.add(checkout.getMoney()); } order.setMoney(money); order.setOriginMoney(originMoney); })); initOrderCallback.put(ProductType.COURSE, ((order, userOrderCheckoutList) -> { BigDecimal money = order.getMoney(); BigDecimal originMoney = order.getOriginMoney(); Integer vsNumber = 0; // 独立课程信息: 排除套餐内的 List courseCheckout = userOrderCheckoutList.stream().filter((checkout)-> checkout.getProductType().equals(ProductType.COURSE.key) && checkout.getParentId() == 0).collect(Collectors.toList()); Collection courseIds = Transform.getIds(courseCheckout, UserOrderCheckout.class, "productId"); List courseList = courseService.select(courseIds); Map courseMap = new HashMap<>(); for(Course course : courseList){ courseMap.put(course.getId(), course); } BigDecimal courseMoney = BigDecimal.valueOf(0); // 视频课程优惠 List videoCheckout = courseCheckout.stream().filter((checkout)-> courseMap.get(checkout.getProductId()).getCourseModule().equals(CourseModule.VIDEO.key)).collect(Collectors.toList()); BigDecimal videoMoney = BigDecimal.valueOf(0); for(UserOrderCheckout checkout : videoCheckout){ videoMoney = videoMoney.add(checkout.getMoney()); } int percent = toolsService.computeVideoMoney(courseCheckout); if (percent < 100){ BigDecimal promoteVideoMoney = videoMoney.multiply(BigDecimal.valueOf(percent)).divide(BigDecimal.valueOf(100), BigDecimal.ROUND_HALF_UP); courseMoney = courseMoney.add(promoteVideoMoney); money = money.add(promoteVideoMoney); // 添加视频优惠记录 JSONObject info = new JSONObject(); info.put("originMoney", videoMoney); info.put("money", promoteVideoMoney); info.put("message", toolsService.videoMoneyMessage()); JSONObject promote = order.getPromote(); promote.put("video", info); }else{ courseMoney = courseMoney.add(videoMoney); money = money.add(videoMoney); } originMoney = originMoney.add(videoMoney); // 1v1课程优惠: 添加时计算 List vsCheckout = courseCheckout.stream().filter((checkout)-> courseMap.get(checkout.getProductId()).getCourseModule().equals(CourseModule.VS.key)).collect(Collectors.toList()); for(UserOrderCheckout checkout: vsCheckout){ courseMoney = courseMoney.add(checkout.getMoney()); money = money.add(checkout.getMoney()); originMoney = originMoney.add(checkout.getMoney()); vsNumber += checkout.getNumber(); } // 套餐费用: 添加时计算 List packageCheckout = userOrderCheckoutList.stream().filter((checkout)-> checkout.getProductType().equals(ProductType.COURSE_PACKAGE.key)).collect(Collectors.toList()); for(UserOrderCheckout checkout : packageCheckout){ courseMoney = courseMoney.add(checkout.getMoney()); money = money.add(checkout.getMoney()); originMoney = originMoney.add(checkout.getMoney()); // 套餐优惠记录 - 不参与总价，单独展示逻辑 } // 满金额处理 // 回复时长 JSONObject askInfo = toolsService.getAskTime(courseMoney); if(askInfo != null) order.setAskTime(askInfo.getIntValue("hour") * 3600); // 1v1辅导 JSONObject vsInfo = toolsService.getVsNumber(courseMoney); // 满课时处理 Boolean coach = toolsService.getCoach(vsNumber); JSONArray gift = order.getGift(); if (askInfo!=null && askInfo.getIntValue("money") > 0){ // 因为存在默认最低值，金额超过限额，才写入赠送 JSONObject info = new JSONObject(); info.put("key", "ask"); info.put("money", askInfo.getIntValue("money")); info.put("hour", askInfo.getIntValue("hour")); info.put("message", toolsService.askTimeMessage().replace("{}", askInfo.getInteger("hour").toString())); gift.add(info); } if (vsInfo != null){ JSONObject info = new JSONObject(); info.put("key", "vs"); info.put("money", vsInfo.getIntValue("money")); info.put("number", vsInfo.getIntValue("number")); info.put("message", toolsService.vsRecordMessage().replace("{}", vsInfo.getInteger("number").toString())); gift.add(info); } if(coach){ JSONObject info = new JSONObject(); info.put("key", "coach"); info.put("message", toolsService.coachMessage()); gift.add(info); } order.setMoney(money); order.setOriginMoney(originMoney); // 课程金额进行开票处理 order.setInvoiceMoney(courseMoney); })); initRecordCallback.put(ProductType.COURSE, ((order, record) -> { Course course = courseService.get(record.getProductId()); // 记录销售数量 courseService.accumulation(course.getId(), 0, record.getParentId() ==0 ? 1:0, record.getParentId() != 0 ? 1:0); CourseModule courseModule = CourseModule.ValueOf(course.getCourseModule()); // 小班课程不会存在记录，在线视频和1v1授课都有有效期 Date startTime = new Date(); Date endTime = Tools.addDate(startTime, courseModule.expireDay); record.setStartTime(startTime); record.setEndTime(endTime); // 绑定订单的回复时长 record.setAskTime(order.getAskTime()); // 计算vs课程编号 if (courseModule == CourseModule.VS){ Integer no = userOrderRecordService.maxVsNo(order.getUserId()); record.setVsNo(no+1); } return record; })); initRecordCallback.put(ProductType.COURSE_PACKAGE, ((order, record)->{ // 资料无需开启，也没有有效期 record.setIsUsed(1); Date time = new Date(); record.setUseTime(time); // 处理套餐赠送 CoursePackage coursePackage = coursePackageService.get(record.getProductId()); // 记录销售数量 coursePackageService.accumulation(coursePackage.getId(), 1); InitRecord callback = initRecordCallback.get(ProductType.SERVICE); JSONObject gift = coursePackage.getGift(); Integer qxCat = gift.getInteger(ServiceKey.QX_CAT.key); if (qxCat != null && qxCat > 0){ // 添加cat UserOrderRecord giftRecord = UserOrderRecord.builder() .orderId(order.getId()) .userId(order.getUserId()) .productType(ProductType.SERVICE.key) .service(ServiceKey.QX_CAT.key) .source(RecordSource.GIFT_COURSE.key) .build(); callback.callback(order, giftRecord); userOrderRecordService.add(giftRecord); } Integer textbook = gift.getInteger(ServiceKey.TEXTBOOK.key); if (textbook != null && textbook > 0){ // 添加text UserOrderRecord giftRecord = UserOrderRecord.builder() .orderId(order.getId()) .userId(order.getUserId()) .productType(ProductType.SERVICE.key) .service(ServiceKey.TEXTBOOK.key) .source(RecordSource.GIFT_COURSE.key) .build(); callback.callback(order, giftRecord); userOrderRecordService.add(giftRecord); } String vip = gift.getString(ServiceKey.VIP.key); ServiceVipKey vipKey = ServiceVipKey.ValueOf(vip); if (vipKey != null){ // 添加vip，并开通 UserOrderRecord giftRecord = UserOrderRecord.builder() .orderId(order.getId()) .userId(order.getUserId()) .productType(ProductType.SERVICE.key) .service(ServiceKey.VIP.key) .param(vipKey.key) .source(RecordSource.GIFT_COURSE.key) .build(); callback.callback(order, giftRecord); userOrderRecordService.add(giftRecord); } return record; })); initRecordCallback.put(ProductType.DATA, ((order, record)->{ // 资料无需开启，也没有有效期 record.setIsUsed(1); Date time = new Date(); record.setUseTime(time); // 记录销售数量 courseDataService.accumulation(record.getProductId(), 1, 0); return record; })); initRecordCallback.put(ProductType.SERVICE, ((order, record)->{ if(record.getService().equals(ServiceKey.VIP.key)){ // VIP直接开通 record = useRecordCallback.get(ProductType.SERVICE).callback(record); }else{ ServiceKey serviceKey = ServiceKey.ValueOf(record.getService()); Date startTime = new Date(); Date endTime = Tools.addMonth(startTime, serviceKey.expireDay); record.setStartTime(startTime); record.setEndTime(endTime); // 如果使用半价优惠券，则扣除 if (serviceKey == ServiceKey.TEXTBOOK){ User user = usersService.get(record.getUserId()); if (user.getTextbookHalf() == 0) { // todo 支付存在问题 } usersService.edit(User.builder().id(user.getId()).textbookHalf(user.getTextbookHalf() - 1).build()); } } return record; })); useRecordCallback.put(ProductType.COURSE, (record->{ record.setIsUsed(1); Date time = new Date(); record.setUseTime(time); Course course = courseService.get(record.getProductId()); Integer expireDay = 0; if (course.getCourseModule().equals(CourseModule.ONLINE.key)){ // 小班课程，无需更新有效时间 return record; }else if (course.getCourseModule().equals(CourseModule.VS.key)){ // 根据课时数进行计算 expireDay = courseExtendService.computeExpire(record.getNumber(), course); }else{ // 根据设置进行计算 expireDay = courseExtendService.computeExpire(course); } Date startTime = time; Date endTime = Tools.addDate(startTime, expireDay); UserCourse userCourse = userCourseService.getCourseBase(record.getUserId(), record.getProductId()); if(userCourse == null){ userCourse = UserCourse.builder() .userId(record.getUserId()) .courseId(course.getId()) .recordId(record.getId()) .startTime(startTime) .expireTime(endTime) .build(); userCourse = userCourseService.add(userCourse); }else{ if (userCourse.getExpireTime().before(time)){ // 已到期 - 续期 userCourse.setStartTime(startTime); userCourse.setExpireTime(endTime); userCourse.setRecordId(record.getId()); }else{ // 未到期 - 报错 throw new ParameterException("已开通当前课程"); } userCourse = userCourseService.edit(userCourse); } record.setUseStartTime(startTime); record.setUseEndTime(endTime); return record; })); useRecordCallback.put(ProductType.COURSE_PACKAGE, (record->{ // miss throw new ParameterException("套餐无需开通"); })); useRecordCallback.put(ProductType.DATA, (record->{ // miss throw new ParameterException("资料无需开通"); })); useRecordCallback.put(ProductType.SERVICE, (record->{ record.setIsUsed(1); Date time = new Date(); record.setUseTime(time); ServiceKey serviceKey = ServiceKey.ValueOf(record.getService()); Integer expireDay = serviceKey.useExpireDay; if(serviceKey == ServiceKey.VIP){ ServiceVipKey vipKey = ServiceVipKey.ValueOf(record.getParam()); expireDay = vipKey.useExpireDay; } Date startTime = time; Date endTime = null; if(expireDay > 0){ // 设置结束有效期 endTime = Tools.addDate(startTime, expireDay); } UserService userService = userServiceService.getServiceBase(record.getUserId(), serviceKey); if (userService == null){ userService = UserService.builder() .userId(record.getUserId()) .isSubscribe(record.getIsSubscribe()) .isReset(0) .startTime(startTime) .expireTime(endTime) .build(); userService = userServiceService.add(userService); }else{ if (serviceKey == ServiceKey.QX_CAT){ // cat逻辑独立 if (userService.getExpireTime().after(time)){ // 有效期内 if (userService.getIsReset() == 0) throw new ParameterException("已开通当前服务"); // 第二次还未做完 if (userService.getIsReset() == 1 && examinationService.isFinishCat(record.getUserId())) throw new ParameterException("已开通当前服务"); } // 重置 userService.setIsReset(0); examinationService.resetCat(record.getUserId(), true); }else if (userService.getExpireTime() != null && userService.getExpireTime().before(time)){ // 已到期 - 续期 userService.setStartTime(startTime); userService.setExpireTime(endTime); }else{ // 未到期 - 延长有效期 startTime = userService.getExpireTime(); if (expireDay > 0){ endTime = Tools.addDate(userService.getExpireTime(), expireDay); userService.setExpireTime(endTime); } } userService.setIsSubscribe(record.getIsSubscribe()); userService = userServiceService.edit(userService); } if (serviceKey == ServiceKey.TEXTBOOK){ // 自动报名: 使用机经的后10天所在月份 textbookService.enroll(record.getUserId(), Tools.addDate(new Date(), 10)); } record.setUseStartTime(startTime); record.setUseEndTime(endTime); return record; })); stopRecordCallback.put(ProductType.COURSE, (record->{ record.setIsUsed(1); Date time = new Date(); record.setUseTime(time); Course course = courseService.get(record.getProductId()); Integer expireDay = 0; if (course.getCourseModule().equals(CourseModule.VS.key)){ // 根据课时数进行计算 expireDay = courseExtendService.computeExpire(record.getNumber(), course); }else{ // 根据设置进行计算 } Date startTime = time; Date endTime = Tools.addDate(startTime, expireDay); UserCourse userCourse = userCourseService.getCourseBase(record.getUserId(), record.getProductId()); if(userCourse == null){ userCourse = UserCourse.builder() .userId(record.getUserId()) .recordId(record.getId()) .startTime(startTime) .expireTime(endTime) .build(); userCourse = userCourseService.add(userCourse); }else{ if (userCourse.getExpireTime().before(time)){ // 已到期 - 续期 userCourse.setStartTime(startTime); userCourse.setExpireTime(endTime); userCourse.setRecordId(record.getId()); }else{ // 未到期 - 报错 throw new ParameterException("已开通当前课程"); } userCourse = userCourseService.edit(userCourse); } record.setUseStartTime(startTime); record.setUseEndTime(endTime); return record; })); stopRecordCallback.put(ProductType.COURSE_PACKAGE, (record->{ // miss throw new ParameterException("套餐无需停用"); })); stopRecordCallback.put(ProductType.DATA, (record->{ // 停用后无法查看 record.setIsStop(1); return record; })); stopRecordCallback.put(ProductType.SERVICE, (record->{ record.setIsUsed(1); Date time = new Date(); record.setUseTime(time); ServiceKey serviceKey = ServiceKey.ValueOf(record.getService()); Integer expireDay = serviceKey.useExpireDay; if(serviceKey == ServiceKey.VIP){ ServiceVipKey vipKey = ServiceVipKey.ValueOf(record.getParam()); expireDay = vipKey.useExpireDay; } Date startTime = time; Date endTime = Tools.addDate(startTime, expireDay); UserService userService = userServiceService.getServiceBase(record.getUserId(), serviceKey); if (userService == null){ userService = UserService.builder() .userId(record.getUserId()) .isSubscribe(record.getIsSubscribe()) .startTime(startTime) .expireTime(endTime) .build(); userService = userServiceService.add(userService); }else{ if (userService.getExpireTime().before(time)){ // 已到期 - 续期 userService.setStartTime(startTime); userService.setExpireTime(endTime); }else{ if (serviceKey == ServiceKey.QX_CAT){ // 未到期 - 报错 throw new ParameterException("已开通当前服务"); } // 未到期 - 延长有效期 startTime = userService.getExpireTime(); endTime = Tools.addDate(userService.getExpireTime(), expireDay); userService.setExpireTime(endTime); } userService.setIsSubscribe(record.getIsSubscribe()); userService = userServiceService.edit(userService); } record.setUseStartTime(startTime); record.setUseEndTime(endTime); return record; })); } /** * 完成订单支付 * @param orderId * @param userId * @param payTime * @param payMethod * @return */ @Transactional public boolean payed(Integer orderId, Integer userId, Long payId, Date payTime, PayMethod payMethod, String transactionNo){ UserOrder userOrder = userOrderService.get(orderId); if (userOrder == null) return false; if (userOrder.getPayStatus() > 0) return false; userOrder = userOrderService.edit(UserOrder.builder() .id(userOrder.getId()) .payId(payId) .payMethod(payMethod.key) .payTime(payTime) .transactionNo(transactionNo) .payStatus(1) .build()); // 转换购物车记录为购买记录 List checkoutList = userOrderCheckoutService.allByUser(userId, orderId); List pList = checkoutList.stream().filter((checkout)-> checkout.getParentId() == 0).collect(Collectors.toList()); List cList = checkoutList.stream().filter((checkout)-> checkout.getParentId() > 0).collect(Collectors.toList()); Map pMap = new HashMap<>(); for(UserOrderCheckout checkout : pList){ UserOrderRecord record = Transform.convert(checkout, UserOrderRecord.class); record.setSource(RecordSource.FromPayModule(payMethod).key); InitRecord callback = initRecordCallback.get(ProductType.ValueOf(record.getProductType())); callback.callback(userOrder, record); record = userOrderRecordService.add(record); // 建立新旧id关系 pMap.put(checkout.getId(), record.getId()); } for(UserOrderCheckout checkout : cList){ UserOrderRecord record = Transform.convert(checkout, UserOrderRecord.class); // 记录parentid record.setParentId(pMap.get(checkout.getParentId())); record.setSource(RecordSource.FromPayModule(payMethod).key); InitRecord callback = initRecordCallback.get(ProductType.ValueOf(record.getProductType())); callback.callback(userOrder, record); userOrderRecordService.add(record); } JSONArray gift = userOrder.getGift(); if (gift != null){ for(Object infoO : gift){ JSONObject info = (JSONObject)infoO; if(info.get("key").equals("vs")){ // 添加赠送课时 Integer courseId = info.getInteger("courseId"); if(courseId != null){ UserOrderRecord record = UserOrderRecord.builder() .orderId(userOrder.getId()) .userId(userOrder.getUserId()) .productType(ProductType.COURSE.key) .productId(courseId) .number(info.getIntValue("number")) .source(RecordSource.GIFT_COURSE.key) .build(); InitRecord callback = initRecordCallback.get(ProductType.ValueOf(record.getProductType())); callback.callback(userOrder, record); userOrderRecordService.add(record); } } } } userOrderCheckoutService.deleteByUser(userId, orderId); // 累加用户支付信息 usersService.accumulation(userOrder.getUserId(), userOrder.getMoney()); // 发送通知 User user = usersService.get(userId); messageExtendService.sendPayed(user, userOrder); return true; } /** * 添加购物车 * @param userId * @param checkout * @return */ @Transactional public int addCheckout(Integer userId, UserOrderCheckout checkout){ List list = userOrderCheckoutService.allByUser(userId, 0); InitCheckout callback = initCheckoutCallback.get(ProductType.ValueOf(checkout.getProductType())); checkout = callback.callback(checkout, list); if (checkout == null){ // 无需操作 }else if(checkout.getId() > 0){ userOrderCheckoutService.edit(checkout); }else{ userOrderCheckoutService.add(checkout); } // 计算购物车数量 return userOrderCheckoutService.allByUser(userId, 0).size(); } /** * 删除购物车 * @param checkoutId * @param userId * @return */ @Transactional public int removeCheckout(Integer checkoutId, Integer userId){ UserOrderCheckout in = userOrderCheckoutService.get(checkoutId); if (in == null){ throw new ParameterException("记录不存在"); } if (!in.getUserId().equals(userId)){ throw new ParameterException("记录不存在"); } if (in.getParentId() != null && in.getParentId() > 0){ // 如果能删除子项目，要处理删除父项目，转移其他子项目 throw new ParameterException("套餐内，不允许单独删除"); } userOrderCheckoutService.delete(checkoutId); List list = userOrderCheckoutService.allByUser(userId, 0); // 删除子项目 for(UserOrderCheckout checkout: list){ if (checkout.getParentId()==null || checkout.getParentId() == 0) continue; if (checkout.getParentId().equals(in.getId())){ userOrderCheckoutService.delete(checkout.getId()); } } RemoveCheckout callback = removeCheckoutCallback.get(ProductType.ValueOf(in.getProductType())); callback.callback(in, list); // 计算购物车数量 return userOrderCheckoutService.allByUser(userId, 0).size(); } /** * 根据购物车生成对应订单信息 * @param list * @return */ public UserOrder preOrderWithCheckout(Integer userId, List list){ UserOrder order = UserOrder.builder() .userId(userId) .originMoney(BigDecimal.valueOf(0)) .money(BigDecimal.valueOf(0)) .build(); // 记录订单优惠 JSONObject promote = new JSONObject(); order.setPromote(promote); // 记录订单类型 JSONArray productTypes = new JSONArray(); order.setProductTypes(productTypes); // 记录赠品信息 JSONArray gift = new JSONArray(); order.setGift(gift); InitOrder callback; // 课程: 并包含套餐 List courseCheckout = list.stream().filter((checkout)-> checkout.getProductType().equals(ProductType.COURSE.key) || checkout.getProductType().equals(ProductType.COURSE_PACKAGE.key)).collect(Collectors.toList()); callback = initOrderCallback.get(ProductType.COURSE); callback.callback(order, courseCheckout); if(courseCheckout.size() > 0){ productTypes.add(ProductType.COURSE.key); } // 资料 List dataCheckout = list.stream().filter((checkout)-> checkout.getProductType().equals(ProductType.DATA.key)).collect(Collectors.toList()); callback = initOrderCallback.get(ProductType.DATA); callback.callback(order, courseCheckout); if (dataCheckout.size() > 0){ productTypes.add(ProductType.DATA.key); } // 服务 List serviceCheckout = list.stream().filter((checkout)-> checkout.getProductType().equals(ProductType.SERVICE.key)).collect(Collectors.toList()); callback = initOrderCallback.get(ProductType.SERVICE); callback.callback(order, courseCheckout); if(serviceCheckout.size() > 0){ productTypes.add(ProductType.SERVICE.key); } return order; } /** * 支付购物车 * @param userId * @return */ @Transactional public UserOrder makeOrder(Integer userId, Integer courseId){ List list = userOrderCheckoutService.allByUser(userId, 0); UserOrder order = preOrderWithCheckout(userId, list); // 保存课程赠送选择: 付款后添加 JSONArray gift = order.getGift(); for(Object infoO:gift){ JSONObject info = (JSONObject)infoO; if(info.getString("key").equals("vs")){ info.put("courseId", courseId); } } order = userOrderService.add(order); // 转移购物车信息 userOrderCheckoutService.changeByUser(userId, 0, UserOrderCheckout.builder().orderId(order.getId()).build()); return order; } /** * 立即购买 * @param userId * @param checkout * @return */ @Transactional public UserOrder makeOrderWithSpeed(Integer userId, UserOrderCheckout checkout){ List list = new ArrayList(){{add(checkout);}}; UserOrder order = preOrderWithCheckout(userId, list); order.setIsSpeed(1); order = userOrderService.add(order); checkout.setOrderId(order.getId()); userOrderCheckoutService.add(checkout); return order; } /** * 后台直接添加记录 * @param record * @return */ @Transactional public UserOrderRecord addRecord(UserOrderRecord record){ InitRecord callback = initRecordCallback.get(ProductType.ValueOf(record.getProductType())); // 虚拟order callback.callback(UserOrder.builder().build(), record); return userOrderRecordService.add(record); } /** * 开通记录 * @param userId * @param recordId * @return */ @Transactional public UserOrderRecord useRecord(Integer userId, Integer recordId){ UserOrderRecord in = userOrderRecordService.get(recordId); if (in == null){ throw new ParameterException("记录不存在"); } if (!in.getUserId().equals(userId)){ throw new ParameterException("记录不存在"); } UseRecord callback = useRecordCallback.get(ProductType.ValueOf(in.getProductType())); callback.callback(in); return in; } public void stopRecord(Integer recordId){ UserOrderRecord in = userOrderRecordService.get(recordId); if (in == null){ throw new ParameterException("记录不存在"); } if (in.getIsStop()> 0){ throw new ParameterException("已停用"); } UseRecord callback = useRecordCallback.get(ProductType.ValueOf(in.getProductType())); callback.callback(in); } /** * 给用户邀请奖励： 7天vip * @param userId */ public void giveInvite(Integer userId){ UserOrderRecord record = UserOrderRecord.builder() .userId(userId) .service(ServiceKey.VIP.key) .param(ServiceVipKey.DAY7.key) .source(RecordSource.INVITE.key) .build(); // 虚拟order record = initRecordCallback.get(ProductType.SERVICE).callback(UserOrder.builder().build(), record); userOrderRecordService.add(record); } /** * 给用户备考奖励： 7天vip * @param userId */ public void givePrepare(Integer userId){ UserOrderRecord record = UserOrderRecord.builder() .userId(userId) .service(ServiceKey.VIP.key) .param(ServiceVipKey.DAY7.key) .source(RecordSource.PREPARE.key) .build(); // 虚拟order record = initRecordCallback.get(ProductType.SERVICE).callback(UserOrder.builder().build(), record); userOrderRecordService.add(record); } /** * 给用户实名认证奖励: 180天vip * @param userId */ public void giveReal(Integer userId){ UserOrderRecord record = UserOrderRecord.builder() .userId(userId) .service(ServiceKey.VIP.key) .param(ServiceVipKey.MONTH3.key) .source(RecordSource.REAL.key) .build(); // 虚拟order record = initRecordCallback.get(ProductType.SERVICE).callback(UserOrder.builder().build(), record); userOrderRecordService.add(record); } }