cloud-server-account/src/main/java/com/dsh/account/controller/ClassDetailsController.java
@@ -360,6 +360,10 @@ Double bim = weight/squareHeight; TStudent tStudent = new TStudent(); tStudent.setId(stu.getStuId()); tStudent.setBirthday(format.parse(stu.getBirthday())); tStudent.setHeadImg(stu.getHeadImg()); @@ -370,6 +374,14 @@ tStudent.setName(stu.getName()); tStudent.setIdCard(stu.getIdCard()); tStudent.setBmi(bim); if(ToolUtil.isNotEmpty(tStudent.getName()) && ToolUtil.isNotEmpty(tStudent.getIdCard())){ Boolean aBoolean = JuHeUtil.idcardAuthentication(tStudent.getIdCard(), tStudent.getName()); if(!aBoolean){ return ResultUtil.error("身份证和姓名不匹配"); } } return ResultUtil.success(istuService.updateById(tStudent)); // return ResultUtil.success(istuService.commitEditStudentInfo(stu,userIdFormRedis)); cloud-server-account/src/main/java/com/dsh/account/controller/ExploreWPController.java
@@ -119,7 +119,7 @@ }) public ResultUtil<List<StoreDetailList>> getStoreListCon(Integer space,String cityCode,String latitude,String longitude,String search){ // try { return ResultUtil.success(tsService.queryStoreList(space,cityCode,"104.05349525280955","30.588087670753833",search)); return ResultUtil.success(tsService.queryStoreList(space,cityCode,longitude,latitude,search)); // }catch (Exception e){ // return ResultUtil.runErr(); // } cloud-server-activity/src/main/java/com/dsh/activity/controller/UserCouponController.java
@@ -178,8 +178,28 @@ return null; } } @ResponseBody @PostMapping("/userCoupon/queryUserCouponById1") public UserCoupon queryUserCouponById1(@RequestBody Long id){ try { UserCoupon userCoupon = userCouponService.getOne(new LambdaQueryWrapper<UserCoupon>().eq(UserCoupon::getId,id)); return userCoupon; }catch (Exception e){ e.printStackTrace(); return null; } } @Autowired private ICouponService couponService; @PostMapping("/userCoupon/edit") public void edit(@RequestBody UserCoupon userCoupon) { userCoupon.setUserId(null); userCouponService.updateById(userCoupon); } @PostMapping("/userCoupon/sendUserCoupon") public void sendUserCoupon(@RequestBody SendCouponReq sendCouponReq){ try { cloud-server-activity/src/main/java/com/dsh/activity/entity/Coupon.java
@@ -159,6 +159,7 @@ @TableField("cityManagerId") private Integer cityManagerId; @Override protected Serializable pkVal() { return this.id; cloud-server-competition/src/main/java/com/dsh/competition/mapper/CompetitionMapper.java
@@ -41,5 +41,5 @@ Integer counts(@Param("id")Long id); void deleteTenMinutes(); void deleteTenMinutes(@Param("pays") List<Long> pays); } cloud-server-competition/src/main/java/com/dsh/competition/service/impl/CompetitionServiceImpl.java
@@ -31,6 +31,7 @@ import com.dsh.competition.service.IPaymentCompetitionService; import com.dsh.competition.service.UserCompetitionService; import com.dsh.competition.util.*; import org.checkerframework.checker.units.qual.A; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -227,6 +228,7 @@ AppUser appUser = appUserClient.queryAppUser(uid); String[] split = paymentCompetitionVo.getIds().split(";"); Competition competition = this.getById(paymentCompetitionVo.getId()); int competitionId = userCompetitionService.count(new QueryWrapper<UserCompetition>().eq("competitionId", paymentCompetitionVo.getId())); if ((competitionId+split.length)>competition.getApplicantsNumber()){ return ResultUtil.error("报名人数超过最大限制"); @@ -557,11 +559,25 @@ /** * 定时任务修改赛事状态 */ @Override public void taskSetStatus() { this.baseMapper.taskSetStatusStart(); this.baseMapper.taskSetStatusEnd(); this.baseMapper.deleteTenMinutes(); Date currentTime = new Date(); Calendar calendar = Calendar.getInstance(); calendar.setTime(currentTime); calendar.add(Calendar.MINUTE, -10); Date tenMinutesAgo = calendar.getTime(); List<PaymentCompetition> payStatus = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>().eq("payStatus", 1).le("insertTime", tenMinutesAgo)); List<Long> pays = new ArrayList<>(); for (PaymentCompetition status : payStatus) { pays.add(status.getId()); } if (!pays.isEmpty()) { this.baseMapper.deleteTenMinutes(pays); } } @Override cloud-server-competition/src/main/resources/mapper/CompetitionMapper.xml
@@ -3,9 +3,12 @@ <mapper namespace="com.dsh.competition.mapper.CompetitionMapper"> <delete id="deleteTenMinutes"> delete from t_payment_competition WHERE payStatus = 1 AND DATE_ADD(insertTime, INTERVAL 10 MINUTE) <= NOW() delete from t_user_competition where paymentCompetitionId in <foreach collection="pays" item="pay" separator="," open="(" close=")"> #{pay} </foreach> </delete> @@ -41,7 +44,7 @@ FROM t_competition a WHERE a.auditStatus = 2 a.auditStatus = 2 and a.status != 4 AND a.state = 1 <if test="null != cityCode and '' != cityCode"> and a.cityCode = #{cityCode} cloud-server-course/src/main/java/com/dsh/course/controller/CourseController.java
@@ -175,7 +175,7 @@ @ApiImplicitParam(value = "纬度", name = "lat", dataType = "string", required = false), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) public ResultUtil<CoursePackageInfo> queryCourseInfo(Integer id, String lon, String lat){ public ResultUtil<CoursePackageInfo> queryCourseInfo(Integer id, String lon, String lat,Long payId){ try { Integer uid = tokenUtil.getUserIdFormRedis(); if(null == uid){ @@ -198,7 +198,7 @@ @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) public ResultUtil paymentCourse(PaymentCourseVo paymentCourseVo){ public synchronized ResultUtil paymentCourse(PaymentCourseVo paymentCourseVo){ try { Integer uid = tokenUtil.getUserIdFormRedis(); if(null == uid){ cloud-server-course/src/main/java/com/dsh/course/controller/CoursePackagePaymentController.java
@@ -1054,9 +1054,11 @@ @ApiOperation(value = "已报名课程详情", tags = {"APP-开始上课"}) @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."), @ApiImplicitParam(value = "经度", name = "lon", dataType = "string", required = false), @ApiImplicitParam(value = "纬度", name = "lat", dataType = "string", required = false), @ApiImplicitParam(name = "coursePayId" ,value = "课包记录id",dataType = "long"), }) public ResultUtil<CourseDetailsResponse> getRegisteredData(Long coursePayId){ public ResultUtil<CourseDetailsResponse> getRegisteredData(Long coursePayId, String lon, String lat){ try { Integer appUserId = tokenUtil.getUserIdFormRedis(); if(null == appUserId){ @@ -2183,7 +2185,7 @@ List<CoursePackageStudent> list5 = cspsService.list(new QueryWrapper<CoursePackageStudent>().eq("studentId", courseDetailReq.getStuId()).eq("coursePackageId",tCoursePackage.getId())); if(list5.size()>0){ if(list5.size()>0&&list4.size()>0){ Integer signInOrNot = list4.get(0).getSignInOrNot(); detailsListVo.setType(1); cloud-server-course/src/main/java/com/dsh/course/feignclient/activity/UserCouponClient.java
@@ -4,6 +4,7 @@ import com.dsh.course.feignclient.activity.model.UserCoupon; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; /** * @author zhibing.pu @@ -18,7 +19,7 @@ * @param id * @return */ @PostMapping("/userCoupon/queryUserCouponById") @PostMapping("/userCoupon/queryUserCouponById1") UserCoupon queryUserCouponById(Long id); /** @@ -27,4 +28,6 @@ */ @PostMapping("/userCoupon/sendUserCoupon") void sendUserCoupon(SendCouponReq sendCouponReq); @PostMapping("/userCoupon/edit") void edit(@RequestBody UserCoupon userCoupon); } cloud-server-course/src/main/java/com/dsh/course/mapper/TCoursePackagePaymentMapper.java
@@ -67,6 +67,7 @@ List<Integer> getStudentIds(@Param("id")Long payId,@Param("classId")Integer classId,@Param("appId")Integer appId); boolean updateHoursById(@Param("id") Long id, @Param("i") int i); boolean updateHoursById1(@Param("id") Long id, @Param("i") int i); void updateBytime(@Param("coursePackagePayment") TCoursePackagePayment coursePackagePayment); cloud-server-course/src/main/java/com/dsh/course/model/vo/request/CourseWithDetailsRequest.java
@@ -13,4 +13,7 @@ @ApiModelProperty(value = "课包id") private Integer coursePackageId; @ApiModelProperty(value = "排课id") private Long scId; } cloud-server-course/src/main/java/com/dsh/course/model/vo/response/AppUserVideoResponse.java
@@ -34,4 +34,7 @@ @ApiModelProperty(value = "课程视频") private String courseVideo; @ApiModelProperty(value = "排课id") private Long scId; } cloud-server-course/src/main/java/com/dsh/course/model/vo/response/CourseDetailsResponse.java
@@ -56,5 +56,12 @@ @ApiModelProperty("课时套餐") private List<CoursePackagePaymentConfigVo> list; @ApiModelProperty("门店地址") private String storeAddress; @ApiModelProperty("门店名称") private String storeName; @ApiModelProperty("距离") private Double distance; } cloud-server-course/src/main/java/com/dsh/course/service/ICoursePackageSchedulingService.java
@@ -37,4 +37,6 @@ void taskSetStatus(); List<AppUserVideoResponse> queryAll(List<Long> longs); void cancel(); } cloud-server-course/src/main/java/com/dsh/course/service/impl/CoursePackageSchedulingServiceImpl.java
@@ -3,23 +3,23 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.dsh.course.controller.CoursePackagePaymentController; import com.dsh.course.entity.CoursePackageScheduling; import com.dsh.course.entity.CoursePackageStudent; import com.dsh.course.entity.TCoursePackage; import com.dsh.course.entity.TCoursePackagePayment; import com.dsh.course.mapper.CoursePackageSchedulingMapper; import com.dsh.course.model.QueryCoursePackageSchedulingList; import com.dsh.course.model.vo.response.AppUserVideoResponse; import com.dsh.course.service.CoursePackageStudentService; import com.dsh.course.service.ICoursePackageSchedulingService; import com.dsh.course.service.TCoursePackagePaymentService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; import java.util.List; import java.util.Map; import java.util.*; /** * @author zhibing.pu @@ -104,6 +104,38 @@ } @Autowired private TCoursePackagePaymentService packagePaymentService; /** * 定时修改状态 */ @Override public void cancel() { new Thread(new Runnable() { @Override public void run() { List<TCoursePackagePayment> list = packagePaymentService.list(); Date now = new Date(); List<Long> pays = new ArrayList<>(); for (TCoursePackagePayment coursePackagePayment : list) { if (now.before(coursePackagePayment.getUseTime())){ pays.add(coursePackagePayment.getId()); } } List<CoursePackageStudent> coursePackagePaymentId = coursePackageStudentService.list(new QueryWrapper<CoursePackageStudent>().in("coursePackagePaymentId", pays)); List<Long> scs = new ArrayList<>(); for (CoursePackageStudent coursePackageStudent : coursePackagePaymentId) { scs.add(coursePackageStudent.getCoursePackageSchedulingId()); } coursePackageStudentService.remove(new QueryWrapper<CoursePackageStudent>().in("coursePackagePaymentId", pays)); coursePackageSchedulingMapper.delete(new QueryWrapper<CoursePackageScheduling>().in("id",scs)); } }).start(); } /** * 定时修改状态 */ cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackageDiscountServiceImpl.java
@@ -76,13 +76,13 @@ for (TCoursePackageDiscount tCoursePackageDiscount : tCoursePackageDiscounts) { TCoursePackage coursePackage = tcpMapper.selectById(tCoursePackageDiscount.getCoursePackageId()); // 判断预约人数是否已满 Integer maxSubscribeNumber = coursePackage.getMaxSubscribeNumber(); Integer integer = tcppMapper.selectCount(new QueryWrapper<TCoursePackagePayment>() .eq("appUserId",appUserId ) .eq("status",1)); if (integer >= maxSubscribeNumber){ continue; } // Integer maxSubscribeNumber = coursePackage.getMaxSubscribeNumber(); // Integer integer = tcppMapper.selectCount(new QueryWrapper<TCoursePackagePayment>() // .eq("appUserId",appUserId ) // .eq("status",1)); // if (integer >= maxSubscribeNumber){ // continue; // } try { JSONArray jsonArray = JSON.parseArray(tCoursePackageDiscount.getContent()); JSONObject jsonObject = jsonArray.getJSONObject(0); cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackagePaymentServiceImpl.java
@@ -328,13 +328,16 @@ // BenefitsVideos videosWithIds = bfvoClient.getVideosWithIds(detailsRequest.getVideoId()); TCourse byId = courseService.getById(detailsRequest.getVideoId()); TCoursePackage coursePackage = tcpmapper.selectById(detailsRequest.getCoursePackageId()); CoursePackageScheduling byId1 = new CoursePackageScheduling(); if (detailsRequest.getScId()!=null){ byId1 = coursePackageSchedulingService.getById(detailsRequest.getScId()); } if (null != coursePackage){ response.setCoursePackageId(coursePackage.getId()); response.setVideoId(byId.getId()); response.setVideoURL(byId.getCourseVideo()); response.setVideoName(coursePackage.getName()); // response.setIntegral(byId.getIntegral()); UserVideoDetails userVideoDetails = uvdmapper.selectOne(new QueryWrapper<UserVideoDetails>() .eq("appUserId",appUserId ) .eq("coursePackageId",coursePackage.getId()) @@ -349,6 +352,10 @@ response.setSynopsis(byId.getIntroduce()); response.setDetailedDiagram(byId.getIntroductionDrawing()); response.setCover(byId.getCoverDrawing()); if (byId1.getIntegral()!=null) { response.setIntegral(String.valueOf(byId1.getIntegral())); } } return response; @@ -482,6 +489,18 @@ if (coursePackage.getType()==2) { response.setTime(new SimpleDateFormat("yyyy.MM.dd").format(coursePackage.getStartTime()) + "-" + new SimpleDateFormat("yyyy.MM.dd").format(coursePackage.getEndTime())); } // Store store = storeClient.queryStoreById(coursePackage.getStoreId()); // response.setStoreName(store.getName()); // response.setStoreCoverDrawing(store.getCoverDrawing()); // response.setStoreAddress(store.getAddress()); // response.setLon(store.getLon()); // response.setLat(store.getLat()); // if(ToolUtil.isNotEmpty(lon) && ToolUtil.isNotEmpty(lat)){ // Map<String, Double> distance = GeodesyUtil.getDistance(lon + "," + lat, store.getLon() + "," + store.getLat()); // double wgs84 = new BigDecimal(distance.get("WGS84")).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); // response.setDistance(wgs84); // } response.setCoursePackageId(tCoursePackagePayment.getCoursePackageId()); @@ -1361,6 +1380,9 @@ @Autowired private CoursePackageStudentService coursePackageStudentService; @Autowired private CourseCounsumService courseCounsumService; @Override @Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRES_NEW) public ResultUtil payCourse(PayCourseReq req,Integer userId) throws ParseException { @@ -1513,14 +1535,24 @@ // 2.0 TCourseInfoRecord tCourseInfoRecord = new TCourseInfoRecord(); tCourseInfoRecord.setUserId(userId); tCourseInfoRecord.setCourseId(req.getCourseId()); tCourseInfoRecord.setName("体验购课"); tCourseInfoRecord.setNum(req.getNum()); tCourseInfoRecord.setTime(new Date()); tCourseInfoRecord.setType(2); appuClient.addCourseInfoRecord(tCourseInfoRecord); // TCourseInfoRecord tCourseInfoRecord = new TCourseInfoRecord(); // tCourseInfoRecord.setUserId(userId); // tCourseInfoRecord.setCourseId(req.getCourseId()); // tCourseInfoRecord.setName("体验购课"); // tCourseInfoRecord.setNum(req.getNum()); // tCourseInfoRecord.setTime(new Date()); // tCourseInfoRecord.setType(2); // appuClient.addCourseInfoRecord(tCourseInfoRecord); CourseCounsum courseCounsum = new CourseCounsum(); courseCounsum.setPaymentId(tCoursePackagePayment.getId()); courseCounsum.setChangeType(0); courseCounsum.setNum(req.getNum()); courseCounsum.setInsertTime(new Date()); courseCounsum.setReason("体验购课"); courseCounsum.setAppUserId(userId); courseCounsumService.save(courseCounsum); if(tCoursePackagePayment.getLaveClassHours()<=3){ @@ -1555,7 +1587,7 @@ @Override public boolean updateHoursById(TCoursePackagePayment byId, int i) { return this.baseMapper.updateHoursById(byId.getId(),i); return this.baseMapper.updateHoursById1(byId.getId(),i); } cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackageServiceImpl.java
@@ -298,12 +298,14 @@ double originalPrice1 = coursePackageListVo.getOriginalPrice(); double paymentPrice1 = coursePackageListVo.getPaymentPrice(); double minPrice = Math.min(vipPrice1, Math.min(originalPrice1, paymentPrice1)); double maxPrice = Math.max(vipPrice1, Math.max(originalPrice1, paymentPrice1)); coursePackageListVo.setPaymentPrice(minPrice); coursePackageListVo.setOriginalPrice(maxPrice); System.out.println("Minimum price: " + minPrice); System.out.println("Maximum price: " + maxPrice); // double minPrice = Math.min(vipPrice1, Math.min(originalPrice1, paymentPrice1)); // double maxPrice = Math.max(vipPrice1, Math.max(originalPrice1, paymentPrice1)); // coursePackageListVo.setPaymentPrice(minPrice); // coursePackageListVo.setOriginalPrice(maxPrice); // System.out.println("Minimum price: " + minPrice); // } // else{ // List<TCoursePackageDiscount> list2 = coursePackageDiscountService.list(new QueryWrapper<TCoursePackageDiscount>().eq("coursePackagePaymentConfigId", coursePackagePaymentConfig.getId()) @@ -318,6 +320,20 @@ // coursePackageListVo.setPaymentPrice(vipPrice); // coursePackageListVo.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); // } if (coursePackageListVo.getPaymentPrice()<coursePackageListVo.getVipPrice()){ coursePackageListVo.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); // coursePackageListVo.setVipPrice(null); } if(appUser.getIsVip() == 1) { if (coursePackageListVo.getVipPrice() < coursePackageListVo.getPaymentPrice()) { coursePackageListVo.setPaymentPrice(coursePackageListVo.getVipPrice()); } }else { coursePackageListVo.setVipPrice(null); } Map<String, Double> distance = GeodesyUtil.getDistance(coursePackageList.getLon() + "," + coursePackageList.getLat(), store.getLon() + "," + store.getLat()); coursePackageListVo.setDistance(distance.get("WGS84") / 1000); @@ -637,7 +653,7 @@ // coursePackagePaymentConfigVo.setPayType(coursePackage.getPayType()); //会员显示原价和支付价(会员价)。非会员显示会员价和支付价(最低) if(appUser.getIsVip() == 0){//非会员 // if(appUser.getIsVip() == 0){//非会员 List<TCoursePackageDiscount> list2 = coursePackageDiscountService.list(new QueryWrapper<TCoursePackageDiscount>().eq("coursePackagePaymentConfigId", coursePackagePaymentConfig.getId()) .eq("type", 1).eq("auditStatus", 2)); Double vipPrice = coursePackagePaymentConfig.getCashPayment(); @@ -728,42 +744,50 @@ TCoursePackageDiscount discount = coursePackageDiscountService.getOne(new QueryWrapper<TCoursePackageDiscount>().eq("coursePackagePaymentConfigId", coursePackagePaymentConfig.getId()) .eq("type", 2).eq("auditStatus", 2)); // TCoursePackageDiscount discount = coursePackageDiscountService.getOne(new QueryWrapper<TCoursePackageDiscount>().eq("coursePackagePaymentConfigId", coursePackagePaymentConfig.getId()) // .eq("type", 2).eq("auditStatus", 2)); // // // //这里是续课优惠 // Double continuingMember = JSON.parseObject(discount.getContent()).getDouble("continuingUser"); // Double vipcontinuingMember = JSON.parseObject(discount.getContent()).getDouble("continuingMember"); // // // if (coursePackagePaymentConfigVo.getPaymentPrice()>continuingMember){ // coursePackagePaymentConfigVo.setPaymentPrice(continuingMember); // } // if (coursePackagePaymentConfigVo.getVipPrice()>vipcontinuingMember){ // coursePackagePaymentConfigVo.setVipPrice(vipcontinuingMember); // } if(appUser.getIsVip() == 1) { if (coursePackagePaymentConfigVo.getVipPrice()<coursePackagePaymentConfigVo.getPaymentPrice()){ coursePackagePaymentConfigVo.setPaymentPrice(coursePackagePaymentConfigVo.getVipPrice()); } } //这里是续课优惠 Double continuingMember = JSON.parseObject(discount.getContent()).getDouble("continuingUser"); Double vipcontinuingMember = JSON.parseObject(discount.getContent()).getDouble("continuingMember"); if (coursePackagePaymentConfigVo.getPaymentPrice()>continuingMember){ coursePackagePaymentConfigVo.setPaymentPrice(continuingMember); } if (coursePackagePaymentConfigVo.getVipPrice()>vipcontinuingMember){ coursePackagePaymentConfigVo.setVipPrice(vipcontinuingMember); } if (coursePackagePaymentConfigVo.getPaymentPrice()<coursePackagePaymentConfigVo.getVipPrice()){ if (coursePackagePaymentConfigVo.getPaymentPrice()<coursePackagePaymentConfigVo.getVipPrice()){ coursePackagePaymentConfigVo.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); coursePackagePaymentConfigVo.setVipPrice(null); } } else{ List<TCoursePackageDiscount> list2 = coursePackageDiscountService.list(new QueryWrapper<TCoursePackageDiscount>().eq("coursePackagePaymentConfigId", coursePackagePaymentConfig.getId()) .eq("type", 1).eq("auditStatus", 2)); Double vipPrice = coursePackagePaymentConfig.getCashPayment(); for (TCoursePackageDiscount coursePackageDiscount : list2) { Double num1 = JSON.parseObject(coursePackageDiscount.getContent()).getDouble("discountMember"); if(vipPrice.compareTo(num1) > 0){ vipPrice = num1; } } coursePackagePaymentConfigVo.setPaymentPrice(vipPrice); coursePackagePaymentConfigVo.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); } // } // else{ // List<TCoursePackageDiscount> list2 = coursePackageDiscountService.list(new QueryWrapper<TCoursePackageDiscount>().eq("coursePackagePaymentConfigId", coursePackagePaymentConfig.getId()) // .eq("type", 1).eq("auditStatus", 2)); // Double vipPrice = coursePackagePaymentConfig.getCashPayment(); // for (TCoursePackageDiscount coursePackageDiscount : list2) { // Double num1 = JSON.parseObject(coursePackageDiscount.getContent()).getDouble("discountMember"); // if(vipPrice.compareTo(num1) > 0){ // vipPrice = num1; // } // } // coursePackagePaymentConfigVo.setPaymentPrice(vipPrice); // coursePackagePaymentConfigVo.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); // } list.add(coursePackagePaymentConfigVo); }); coursePackageInfo.setList(list); @@ -872,6 +896,9 @@ } price = new BigDecimal(price).subtract(new BigDecimal(num1)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); } userCoupon.setStatus(2); userCouponClient.edit(userCoupon); } if(paymentCourseVo.getPayType() == 1){//微信支付 @@ -1126,11 +1153,13 @@ // coursePackagePaymentServiceOne.setPlayPaiCoin(coursePackagePaymentServiceOne.getPlayPaiCoin()+paymentPrice.intValue()); // coursePackagePaymentServiceOne.setTotalClassHours(coursePackagePaymentServiceOne.getTotalClassHours()+coursePackagePaymentConfig.getClassHours()); // coursePackagePaymentServiceOne.setLaveClassHours(coursePackagePaymentServiceOne.getLaveClassHours()+coursePackagePaymentConfig.getClassHours()); // coursePackagePaymentServiceOne.setCode(code); coursePackagePaymentServiceOne.setCode(code); // // coursePackagePaymentServiceOne.setAppUserId(null); coursePackagePaymentServiceOne.setPayStatus(2); coursePackagePaymentServiceOne.setSalesName("续课"); coursePackagePaymentServiceOne.setAppUserId(null); // coursePackagePaymentServiceOne.setPayStatus(2); // coursePackagePaymentService.updateById(coursePackagePaymentServiceOne); coursePackagePaymentService.updateById(coursePackagePaymentServiceOne); // // Integer sId = null; // Student student = studentClient.queryDefaultStudent(uid); @@ -1165,6 +1194,8 @@ @Override public void run() { try { Thread.sleep(1000); int num = 1; int wait = 0; while (num <= 10){ @@ -1173,10 +1204,11 @@ Thread.sleep(wait); List<TCoursePackagePayment> list = coursePackagePaymentService.list(new QueryWrapper<TCoursePackagePayment>().eq("state", 1).eq("code", code).eq("payType", 2)); TCoursePackagePayment one = list.get(0); AlipayTradeQueryResponse alipayTradeQueryResponse = payMoneyUtil.queryALIOrder(code); if(one.getPayStatus() == 2){ break; } AlipayTradeQueryResponse alipayTradeQueryResponse = payMoneyUtil.queryALIOrder(code); if( one.getPayStatus() == 1){ /** * WAIT_BUYER_PAY(交易创建,等待买家付款)、 @@ -1188,7 +1220,13 @@ String tradeNo = alipayTradeQueryResponse.getTradeNo(); if("TRADE_CLOSED".equals(s) || "TRADE_FINISHED".equals(s) || num == 10){ for (TCoursePackagePayment coursePackagePayment : list) { for (TCoursePackagePayment coursePackagePayment : list) { if (coursePackagePayment.getStudentName()!=null){ if (coursePackagePayment.getStudentName().equals("续课")){ coursePackagePayment.setPayStatus(2); } } coursePackagePayment.setStatus(3); } coursePackagePaymentService.updateBatchById(list); @@ -1632,7 +1670,7 @@ if (count == can) { break; } int wei = DateUtil.dayOfWeek(date); int wei = DateUtil.dayOfWeek(date)-1; if (week.contains(wei)) { for (int i1 = 0; i1 < split.length; i1++) { if (count == can) { cloud-server-course/src/main/java/com/dsh/course/util/TaskUtil.java
@@ -93,9 +93,10 @@ /** * 零时任务 */ // @Scheduled(cron = "0 0 0 * * *") // public void zeroTask(){ // //定时添加排课数据 @Scheduled(cron = "0 0 0 * * *") public void zeroTask(){ //定时添加排课数据 // coursePackageSchedulingService.taskAddData(); // } coursePackageSchedulingService.cancel(); } } cloud-server-course/src/main/resources/mapper/CoursePackageSchedulingMapper.xml
@@ -31,7 +31,7 @@ </select> <select id="queryAll" resultType="com.dsh.course.model.vo.response.AppUserVideoResponse"> SELECT cs.courseId as videoId,cs.coursePackageId as coursePackageId,tc.coverDrawing as coverImage,tc.name as videoName,tc.introduce as synopsis,cs.integral,tc.courseVideo as courseVideo,cp.name as packageName SELECT cs.courseId as videoId,cs.coursePackageId as coursePackageId,tc.coverDrawing as coverImage,tc.name as videoName,tc.introduce as synopsis,cs.integral,tc.courseVideo as courseVideo,cp.name as packageName,cs.id as scId FROM t_course_package_scheduling cs LEFT JOIN t_course tc ON cs.courseId = tc.id left join t_course_package cp on cs.coursePackageId = cp.id cloud-server-course/src/main/resources/mapper/TCoursePackagePaymentMapper.xml
@@ -31,7 +31,10 @@ where id = #{id} </update> <update id="updateHoursById"> update t_course_package_payment set totalClassHours =totalClassHours +#{i},classHours =classHours+#{i},laveClassHours =laveClassHours+#{i} where id =#{id} update t_course_package_payment set classHours =classHours+#{i},laveClassHours =laveClassHours+#{i} where id =#{id} </update> <update id="updateHoursById1"> update t_course_package_payment set totalClassHours = totalClassHours+#{i},classHours =classHours+#{i},laveClassHours =laveClassHours+#{i} where id =#{id} </update> <select id="queryCountNumber" resultType="int"> cloud-server-other/src/main/java/com/dsh/other/controller/StoreController.java
@@ -224,6 +224,7 @@ // detailList.setStoreDistance(l); detailList.setStoreTime(store.getStartTime() + "-" + store.getEndTime()); detailList.setStoreInfo(store.getIntroduce()); detailList.setStoreDistance(Long.valueOf(distanceTOKilometer.lastIndexOf("."))); detailLists.add(detailList); } } cloud-server-other/src/main/java/com/dsh/other/model/QueryMySiteVo.java
@@ -37,4 +37,6 @@ private Long insertTime; @ApiModelProperty("支付方式2玩湃币,其他rmb") private Integer payType; @ApiModelProperty("1是半场,2 不是") private Integer isHalf; } cloud-server-other/src/main/java/com/dsh/other/service/impl/SiteServiceImpl.java
@@ -634,7 +634,11 @@ Site site = this.getById(siteBooking.getSiteId()); String[] split = siteBooking.getTimes().split(";"); if(site!=null){ queryMySiteVo.setPlayPaiCoin(site.getPlayPaiCoin() * split.length); if (queryMySiteVo.getIsHalf()==1) { queryMySiteVo.setPlayPaiCoin(site.getPlayPaiCoin() * split.length); }else { queryMySiteVo.setPlayPaiCoin((int) (site.getPlayPaiCoinOne() * split.length)); } } } return queryMySiteVos; @@ -852,7 +856,7 @@ //校验优惠券 Long couponId = siteBooking.getUserCouponId(); if(null != couponId){ if(null != couponId&&couponId!=0){ UserCoupon userCoupon = userCouponClient.queryUserCouponById(new QueryUserCouponByIdAndUserId(siteBooking.getUserCouponId(),siteBooking.getAppUserId())); Coupon coupon = couponClient.queryCouponById(userCoupon.getCouponId()); if(coupon.getType() == 1){//满减 cloud-server-other/src/main/resources/mapper/SiteMapper.xml
@@ -60,6 +60,7 @@ c.lat as storeLat, a.payMoney as payMoney, a.payType as payType, a.isHalf as isHalf, CONCAT(DATE_FORMAT(a.startTime, '%Y-%m-%d %H:%i'), '-', DATE_FORMAT(a.endTime, '%H:%i')) as appointment, a.`status`, UNIX_TIMESTAMP(a.insertTime) * 1000 as insertTime