From 53e7558400dcacecdce70e39ebfe1727740f9296 Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期六, 25 十一月 2023 17:20:06 +0800 Subject: [PATCH] 重写课包支付和排课逻辑 --- cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java | 715 ++++++++++++++++++++++++++++------------------------------- 1 files changed, 342 insertions(+), 373 deletions(-) diff --git a/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java b/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java index cbb978c..e5a6145 100644 --- a/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java +++ b/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java @@ -176,21 +176,32 @@ private String alipayPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAouYvZ1v4RiydwNOnGcU0Hb4hQu0x6XUooaE2Bi6/atNOobtFdunnATGP6OMOW7yF9DpP8qH5mbFXAiaQD721y/7qlayI50UcV4mngRU4ZcaAVE3bp721Eg2H85RISa+Tb1CiOh+pc9p4l5UBseKsvB2ruHHForfZDPI8FL7AVUKBYCQPsa4zL6KAO2C6KULaTg/lCa+bYQKU0n9ca569VtdsqJUyxB9eSZjVd+9nKl62FLqp2NELGj7cXqiVBgDnBnVS5ZUO3mrBM5z/AxQbw3RwE3JqdkhzUA1BFjejAlT2zIGNOjUFagF8ao0wGElYfuk0bum6Hz5qWAt02QdNNwIDAQAB";//支付宝应用公钥 private String alipay_public_key = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmu8n/4yTHWbn7VOrNc9OsLtDL1bEQ8gC1dHkj8Wy5z0mkaOsjJRIG/28ze12M0V8jdCKuuDr5Z1OPKiqf+XO3ypguEh+mYUVMBM/cZodDFQfTY1TKLWjvQCuaqlA+QUTCK6f7T7stsgyQ1o9Jj0rXZDz6PM4QHSTzjrLIBaeqM5WIBvH+fy/X+QG5Utd+/UT0kc0JyvuKhZ65yVUd/C9VcwJJAPliRsAQNrqYterwAJ9zvw9tF11wj9W0XgJ8Ccu4x3gR1vrlLRJJo/OA97RmxPQ+5hSacWQZCUd1dwiBq+YCrKVHGTj14izRHXrLc0yBlRXo7tBOIqcy3IsvKVthQIDAQAB";//支付宝支付公钥 + @Resource + private UserConponClient userConponClient; + @Autowired + private TAppUserService appUserService; + @Resource + private MerChandiseClient merChandiseClient; + // 对数据进行分页处理的方法 + private static Page<Goods> getPage(List<Goods> dataList, Pageable pageable) { + int start = (int) pageable.getOffset(); + int end = Math.min((start + pageable.getPageSize()), dataList.size()); + return new PageImpl<>(dataList.subList(start, end), pageable, dataList.size()); + } @Override public List<QueryAppUserVO> listAll(QueryAppUser query) { - return appUserMapper.listAll(query); + return appUserMapper.listAll(query); } @Override - public HashMap<String,Object> weeksOfCourseDetailsList(Integer appUserId, Integer stuId, String time, Integer storeId,String lon,String lat) { + public HashMap<String, Object> weeksOfCourseDetailsList(Integer appUserId, Integer stuId, String time, Integer storeId, String lon, String lat) { // 门店id 查出所有课程 - HashMap<String, Object> map = paymentClient.weeksOfCourseDetailsList(new CourseDetailReq(appUserId, stuId, time, storeId,lon,lat)); + HashMap<String, Object> map = paymentClient.weeksOfCourseDetailsList(new CourseDetailReq(appUserId, stuId, time, storeId, lon, lat)); return map; } - @Override public List<SelectDto> getSelects(List<Integer> studentIds) { @@ -199,13 +210,14 @@ @Override public Object changeState(AdvertisementChangeStateDTO dto) { - return appUserMapper.changeState(dto.getIds(),dto.getState()); + return appUserMapper.changeState(dto.getIds(), dto.getState()); } @Override public List<TAppUser> queryAPPUserByNameAndPhone(AppUserByNameAndPhoneDTO dto) { return appUserMapper.queryAPPUserByNameAndPhone(dto); } + @Override public List<YearData> getYearUserCount(UserInfoQueryDTO dto) { return appUserMapper.getYearUserCount(dto); @@ -228,14 +240,17 @@ public WeekData getWeekUserCount4(UserInfoQueryDTO dto) { return appUserMapper.getWeekUserCount4(dto); } + @Override public WeekData getWeekUserCount3(UserInfoQueryDTO dto) { return appUserMapper.getWeekUserCount3(dto); } + @Override public WeekData getWeekUserCount2(UserInfoQueryDTO dto) { return appUserMapper.getWeekUserCount2(dto); } + @Override public WeekData getWeekUserCount1(UserInfoQueryDTO dto) { return appUserMapper.getWeekUserCount1(dto); @@ -244,17 +259,17 @@ @Override public List<DayData> getDayUserCount(UserInfoQueryDTO dto) { List<DayData> dayUserCount = appUserMapper.getDayUserCount(dto); - if(dayUserCount.size()<7){ + if (dayUserCount.size() < 7) { for (int i = 1; i <= 6; i++) { String time = LocalDate.now().minusDays(i).toString(); for (DayData dayData : dayUserCount) { - if(!time.equals(dayData.getDay())){ - dayUserCount.add(new DayData(time,0)); + if (!time.equals(dayData.getDay())) { + dayUserCount.add(new DayData(time, 0)); } } } } - dayUserCount.forEach(dayData->dayData.setDay(dayData.getDay().split("-")[2])); + dayUserCount.forEach(dayData -> dayData.setDay(dayData.getDay().split("-")[2])); return dayUserCount.stream().sorted(Comparator.comparing(DayData::getDay)).collect(Collectors.toList()); } @@ -262,17 +277,14 @@ public List<GroupCityInfoVO> groupCityInfo(UserInfoQueryDTO dto) { return appUserMapper.groupCityInfo(dto); } + @Override - public ClassInfoVo queryUserOfStus(Integer id,Integer uid) { + public ClassInfoVo queryUserOfStus(Integer id, Integer uid) { TAppUser tAppUser = this.baseMapper.selectById(uid); ClassInfoVo classInfoVo = new ClassInfoVo(); -// if (ToolUtil.isNotEmpty(tAppUser)){ - -// - List<TStudent> tStudents = new ArrayList<>(); - if (id!=null) { - tStudents = tsmapper.selectList(new QueryWrapper<TStudent>() + if (id != null) { + tStudents = tsmapper.selectList(new QueryWrapper<TStudent>() .eq("id", id).eq("state", 1)); if (tStudents.size() == 0) { @@ -280,75 +292,72 @@ .eq("appUserId", tAppUser.getId()) .eq("state", 1)); } - }else { - tStudents = tsmapper.selectList(new QueryWrapper<TStudent>() - .eq("appUserId",tAppUser.getId()) - .eq("state",1) - .eq("isDefault",1)); - if (tStudents.isEmpty()){ - tStudents = tsmapper.selectList(new QueryWrapper<TStudent>() - .eq("appUserId",tAppUser.getId()) - .eq("state",1)) - ; - } + } else { + tStudents = tsmapper.selectList(new QueryWrapper<TStudent>() + .eq("appUserId", tAppUser.getId()) + .eq("state", 1) + .eq("isDefault", 1)); + if (tStudents.isEmpty()) { + tStudents = tsmapper.selectList(new QueryWrapper<TStudent>() + .eq("appUserId", tAppUser.getId()) + .eq("state", 1)) + ; + } } - if (tStudents.size() > 0 ){ - TStudent tStudent = tStudents.get(0); - classInfoVo.setStuId(tStudent.getId()); - classInfoVo.setIsThere(1); - classInfoVo.setStuImg(tStudent.getHeadImg()); - classInfoVo.setStuSex(tStudent.getSex()); - classInfoVo.setStuAge(DateUtil.age(tStudent.getBirthday())); - classInfoVo.setStuName(tStudent.getName()); - classInfoVo.setHeight(tStudent.getHeight()); - classInfoVo.setWeight(tStudent.getWeight()); - classInfoVo.setBmi(tStudent.getBmi()); - if (tStudent.getBmi()!=null) { - classInfoVo.setBodyStatus(BMIBodyUtil.getBodyStatus(tStudent.getBmi())); - } - List<RegisteredCourse> courseList = new ArrayList<>(); - List<StuCourseResp> stuCoursePayment = paymentClient.getStuCoursePayment(tStudent.getId()); - List<Integer> coursePackIds = new ArrayList<>(); - if (stuCoursePayment.size() > 0){ - coursePackIds = stuCoursePayment.stream().map(StuCourseResp::getCourseId).collect(Collectors.toList()); - for (StuCourseResp tCoursePackagePayment : stuCoursePayment) { - RegisteredCourse course = new RegisteredCourse(); - course.setId(tCoursePackagePayment.getId()); - course.setCourseId(tCoursePackagePayment.getCourseId()); - course.setCourseName(tCoursePackagePayment.getCourseName()); - course.setTotalNums(ToolUtil.isEmpty(tCoursePackagePayment.getTotalCourseNums()) ? 0 : tCoursePackagePayment.getTotalCourseNums()); - course.setDeductedNums(ToolUtil.isEmpty(tCoursePackagePayment.getDeductionNums()) ? 0 : tCoursePackagePayment.getDeductionNums()); - course.setRemainingNums(ToolUtil.isEmpty(tCoursePackagePayment.getResidueNums())? 0 : tCoursePackagePayment.getResidueNums()); - course.setPeriodOfValidity(tCoursePackagePayment.getPeriodOfValidity()); - course.setIsAble(tCoursePackagePayment.getIsAble()); - course.setCourseType(tCoursePackagePayment.getCourseType()); - courseList.add(course); - } - } - classInfoVo.setCourseList(courseList); -// List<ExerciseVideo> stuCourseOfVideoList = voclClient.getStuCourseOfVideoList(coursePackIds); - List<ExerciseVideo> query = voclClient.query(tStudent.getId()); - classInfoVo.setExerciseVideoList(query); - - }else { - classInfoVo.setIsThere(2); - List<TImgConfig> tImgConfigs = configClient.getNoneStuImgs(); - if (tImgConfigs.size() > 0){ - classInfoVo.setImgs(tImgConfigs.get(0).getContent()); + if (tStudents.size() > 0) { + TStudent tStudent = tStudents.get(0); + classInfoVo.setStuId(tStudent.getId()); + classInfoVo.setIsThere(1); + classInfoVo.setStuImg(tStudent.getHeadImg()); + classInfoVo.setStuSex(tStudent.getSex()); + classInfoVo.setStuAge(DateUtil.age(tStudent.getBirthday())); + classInfoVo.setStuName(tStudent.getName()); + classInfoVo.setHeight(tStudent.getHeight()); + classInfoVo.setWeight(tStudent.getWeight()); + classInfoVo.setBmi(tStudent.getBmi()); + if (tStudent.getBmi() != null) { + classInfoVo.setBodyStatus(BMIBodyUtil.getBodyStatus(tStudent.getBmi())); + } + List<RegisteredCourse> courseList = new ArrayList<>(); + List<StuCourseResp> stuCoursePayment = paymentClient.getStuCoursePayment(tStudent.getId()); + if (stuCoursePayment.size() > 0) { + for (StuCourseResp tCoursePackagePayment : stuCoursePayment) { + RegisteredCourse course = new RegisteredCourse(); + course.setId(tCoursePackagePayment.getId()); + course.setCourseId(tCoursePackagePayment.getCourseId()); + course.setCourseName(tCoursePackagePayment.getCourseName()); + course.setTotalNums(ToolUtil.isEmpty(tCoursePackagePayment.getTotalCourseNums()) ? 0 : tCoursePackagePayment.getTotalCourseNums()); + course.setDeductedNums(ToolUtil.isEmpty(tCoursePackagePayment.getDeductionNums()) ? 0 : tCoursePackagePayment.getDeductionNums()); + course.setRemainingNums(ToolUtil.isEmpty(tCoursePackagePayment.getResidueNums()) ? 0 : tCoursePackagePayment.getResidueNums()); + course.setPeriodOfValidity(tCoursePackagePayment.getPeriodOfValidity()); + course.setIsAble(tCoursePackagePayment.getIsAble()); + course.setCourseType(tCoursePackagePayment.getCourseType()); + courseList.add(course); } } -// } + classInfoVo.setCourseList(courseList); + List<ExerciseVideo> query = voclClient.query(tStudent.getId()); + classInfoVo.setExerciseVideoList(query); + + } else { + classInfoVo.setIsThere(2); + List<TImgConfig> tImgConfigs = configClient.getNoneStuImgs(); + if (tImgConfigs.size() > 0) { + classInfoVo.setImgs(tImgConfigs.get(0).getContent()); + } + } return classInfoVo; } /** * 处理数据 + * * @param storeOfCourses * @param longitude * @param latitude * @return */ - public List<CourseVenue> dealDatas(List<CourseOfStoreVo> storeOfCourses, String longitude , String latitude){ + public List<CourseVenue> dealDatas(List<CourseOfStoreVo> storeOfCourses, String longitude, String latitude) { List<CourseVenue> courseVenues = new ArrayList<>(); Map<Integer, List<CourseOfStoreVo>> map = storeOfCourses.stream().collect(Collectors.groupingBy(CourseOfStoreVo::getStoreId)); for (Map.Entry<Integer, List<CourseOfStoreVo>> integerListEntry : map.entrySet()) { @@ -357,9 +366,9 @@ CourseVenue courseVenue = new CourseVenue(); courseVenue.setStoreId(storeId); courseVenue.setAreaName(value.get(0).getCourseName()); - if (ToolUtil.isEmpty(longitude) && ToolUtil.isEmpty(latitude)){ - courseVenue.setSiteDistance(0+""); - }else { + if (ToolUtil.isEmpty(longitude) && ToolUtil.isEmpty(latitude)) { + courseVenue.setSiteDistance(0 + ""); + } else { courseVenue.setSiteDistance(LonlatUtils.distance(Double.parseDouble(longitude), Double.parseDouble(latitude), Double.parseDouble(value.get(0).getLon()), Double.parseDouble(value.get(0).getLat())) + ""); } @@ -383,28 +392,28 @@ return courseVenues; } - /** * 获取短信验证码 - * @param type 1:登录,2:注册,3:修改密码,4:忘记密码 + * + * @param type 1:登录,2:注册,3:修改密码,4:忘记密码 * @param phone * @return * @throws Exception */ @Override public ResultUtil getSMSCode(Integer type, String phone) throws Exception { - if(type == 2){ + if (type == 2) { TAppUser tAppUser = this.baseMapper.selectOne(new QueryWrapper<TAppUser>().eq("phone", phone).ne("state", 3)); - if(null != tAppUser){ + if (null != tAppUser) { return ResultUtil.error("账号已存在"); } } String numberRandom = UUIDUtil.getNumberRandom(6); String templateCode = ""; - if(type == 1 || type == 2){ + if (type == 1 || type == 2) { templateCode = "SMS_161275250"; } - if(type == 3 || type == 4){ + if (type == 3 || type == 4) { templateCode = "SMS_160960014"; } aLiSendSms.sendSms(phone, templateCode, "{\"code\":\"" + numberRandom + "\"}"); @@ -412,9 +421,9 @@ return ResultUtil.success(); } - /** * 注册用户 + * * @return * @throws Exception */ @@ -423,11 +432,11 @@ TAppUser tAppUser = this.baseMapper.selectOne(new QueryWrapper<TAppUser>() .eq("phone", addAppUserVo.getPhone()) .ne("state", 3)); - if(null != tAppUser){ + if (null != tAppUser) { return ResultUtil.error("账号已存在"); } String value = redisUtil.getValue(addAppUserVo.getPhone()); - if(!"123456".equals(addAppUserVo.getCode()) && (ToolUtil.isEmpty(value) || !value.equals(addAppUserVo.getCode()))){ + if (!"123456".equals(addAppUserVo.getCode()) && (ToolUtil.isEmpty(value) || !value.equals(addAppUserVo.getCode()))) { return ResultUtil.error("验证码无效"); } @@ -440,63 +449,61 @@ tAppUser.setInsertTime(new Date()); // 注册用户 int insert = this.baseMapper.insert(tAppUser); - // 介绍有礼 - if(addAppUserVo.getReferralUserId()!=null || ToolUtil.isNotEmpty(addAppUserVo.getInvitePhone())){ - if(ToolUtil.isEmpty(addAppUserVo.getLat()) || ToolUtil.isEmpty(addAppUserVo.getLon())){ - return ResultUtil.error("请先开启定位", ""); - } - Map<String, String> geocode = gdMapGeocodingUtil.geocode(addAppUserVo.getLon(), addAppUserVo.getLat()); - Integer num=0; - Integer activityId=null; - if(null != geocode){ - String province = geocode.get("province"); - String provinceCode = geocode.get("provinceCode"); - String city = geocode.get("city"); - String cityCode = geocode.get("cityCode"); - // 根据所在市code 查询是否有介绍有礼活动 - IntroduceRewards res = introduceRewardsClient.getGiftList(cityCode); - if (res!=null){ - num = res.getGiveClass(); - activityId = res.getId(); - if(ToolUtil.isNotEmpty(addAppUserVo.getInvitePhone())){ - List<TAppUser> tAppUsers = this.baseMapper.selectList(new LambdaQueryWrapper<TAppUser>() - .eq(TAppUser::getPhone, addAppUserVo.getInvitePhone())); - if(tAppUsers.size()>0){ - addAppUserVo.setReferralUserId(tAppUsers.get(0).getId()); - } + // 介绍有礼 + if (addAppUserVo.getReferralUserId() != null || ToolUtil.isNotEmpty(addAppUserVo.getInvitePhone())) { + if (ToolUtil.isEmpty(addAppUserVo.getLat()) || ToolUtil.isEmpty(addAppUserVo.getLon())) { + return ResultUtil.error("请先开启定位", ""); + } + Map<String, String> geocode = gdMapGeocodingUtil.geocode(addAppUserVo.getLon(), addAppUserVo.getLat()); + Integer num = 0; + Integer activityId = null; + if (null != geocode) { + String province = geocode.get("province"); + String provinceCode = geocode.get("provinceCode"); + String city = geocode.get("city"); + String cityCode = geocode.get("cityCode"); + // 根据所在市code 查询是否有介绍有礼活动 + IntroduceRewards res = introduceRewardsClient.getGiftList(cityCode); + if (res != null) { + num = res.getGiveClass(); + activityId = res.getId(); + if (ToolUtil.isNotEmpty(addAppUserVo.getInvitePhone())) { + List<TAppUser> tAppUsers = this.baseMapper.selectList(new LambdaQueryWrapper<TAppUser>() + .eq(TAppUser::getPhone, addAppUserVo.getInvitePhone())); + if (tAppUsers.size() > 0) { + addAppUserVo.setReferralUserId(tAppUsers.get(0).getId()); } - if (num!=0){ - TAppGift tAppGift = new TAppGift(); - TAppUser phone = appUserService.getOne(new QueryWrapper<TAppUser>() - .eq("phone", addAppUserVo.getInvitePhone())); - if (phone == null){ - return ResultUtil.error("推荐人手机号未注册玩湃会员!"); - }else{ - tAppGift.setUserName(phone.getName()); - tAppGift.setUserPhone(phone.getPhone()); - } - tAppGift.setUserId(addAppUserVo.getReferralUserId()); - tAppGift.setNum(num); - tAppGift.setShareUserId(tAppUser.getId()); - tAppGift.setShareUserName(tAppUser.getPhone()); - tAppGift.setShareUserPhone(tAppUser.getPhone()); - tAppGift.setActivityId(activityId); - tAppGift.setInsertTime(new Date()); - appGiftService.save(tAppGift); + } + if (num != 0) { + TAppGift tAppGift = new TAppGift(); + TAppUser phone = appUserService.getOne(new QueryWrapper<TAppUser>() + .eq("phone", addAppUserVo.getInvitePhone())); + if (phone == null) { + return ResultUtil.error("推荐人手机号未注册玩湃会员!"); + } else { + tAppGift.setUserName(phone.getName()); + tAppGift.setUserPhone(phone.getPhone()); } + tAppGift.setUserId(addAppUserVo.getReferralUserId()); + tAppGift.setNum(num); + tAppGift.setShareUserId(tAppUser.getId()); + tAppGift.setShareUserName(tAppUser.getPhone()); + tAppGift.setShareUserPhone(tAppUser.getPhone()); + tAppGift.setActivityId(activityId); + tAppGift.setInsertTime(new Date()); + appGiftService.save(tAppGift); } } } - - + } return ResultUtil.success(); } - /** * 账号密码登录 + * * @param phone * @param password * @return @@ -505,34 +512,34 @@ @Override public ResultUtil loginPassword(String phone, String password) throws Exception { TAppUser tAppUser = this.baseMapper.selectOne(new QueryWrapper<TAppUser>().eq("phone", phone).ne("state", 3)); - if(null == tAppUser){ + if (null == tAppUser) { return ResultUtil.error("请先注册", ""); } - if(tAppUser.getState() == 2){ + if (tAppUser.getState() == 2) { return ResultUtil.errorCode("您的账号已被冻结", ""); } // password = Md5Util.MD5Encode(password, null); - if(!tAppUser.getPassword().equals(password)){ + if (!tAppUser.getPassword().equals(password)) { return ResultUtil.error("账号密码错误", ""); } String token = getToken(tAppUser); return ResultUtil.success(token); } - /** * 验证码登录 + * * @return * @throws Exception */ @Override public ResultUtil loginSMSCode(LoginSMSCodeVo loginSMSCodeVo) throws Exception { String value = redisUtil.getValue(loginSMSCodeVo.getPhone()); - if(!"123456".equals(loginSMSCodeVo.getCode()) && (ToolUtil.isEmpty(value) || !value.equals(loginSMSCodeVo.getCode()))){ + if (!"123456".equals(loginSMSCodeVo.getCode()) && (ToolUtil.isEmpty(value) || !value.equals(loginSMSCodeVo.getCode()))) { return ResultUtil.error("验证码无效", ""); } TAppUser tAppUser = this.baseMapper.selectOne(new QueryWrapper<TAppUser>().eq("phone", loginSMSCodeVo.getPhone()).ne("state", 3)); - if(null == tAppUser){ + if (null == tAppUser) { tAppUser = new TAppUser(); tAppUser.setCode(UUIDUtil.getNumberRandom(16)); tAppUser.setPhone(loginSMSCodeVo.getPhone()); @@ -541,16 +548,16 @@ tAppUser.setState(1); this.baseMapper.insert(tAppUser); } - if(tAppUser.getState() == 2){ + if (tAppUser.getState() == 2) { return ResultUtil.error("您的账号已被冻结", ""); } String token = getToken(tAppUser); return ResultUtil.success(token); } - /** * 微信登录 + * * @return * @throws Exception */ @@ -558,9 +565,9 @@ public ResultUtil loginWechat(LoginWeChatVo loginWechatVo) throws Exception { TAppUser tAppUser = this.baseMapper.selectOne(new QueryWrapper<TAppUser>().eq("openid", loginWechatVo.getOpenId()).ne("state", 3)); - if(null == tAppUser){ + if (null == tAppUser) { tAppUser = this.baseMapper.selectOne(new QueryWrapper<TAppUser>().eq("phone", loginWechatVo.getPhone()).ne("state", 3)); - if(null == tAppUser){ + if (null == tAppUser) { tAppUser = new TAppUser(); tAppUser.setCode(UUIDUtil.getNumberRandom(16)); tAppUser.setOpenid(loginWechatVo.getOpenId()); @@ -575,14 +582,14 @@ this.baseMapper.insert(tAppUser); } } - if(tAppUser.getState() == 2){ + if (tAppUser.getState() == 2) { return ResultUtil.error("您的账号已被冻结", ""); } - if(ToolUtil.isEmpty(tAppUser.getOpenid())){ + if (ToolUtil.isEmpty(tAppUser.getOpenid())) { tAppUser.setOpenid(loginWechatVo.getOpenId()); } - if(ToolUtil.isEmpty(tAppUser.getPhone())){ + if (ToolUtil.isEmpty(tAppUser.getPhone())) { tAppUser.setPhone(loginWechatVo.getPhone()); } this.updateById(tAppUser); @@ -590,22 +597,22 @@ String token = getToken(tAppUser); HashMap<String, String> map = new HashMap<>(); - map.put("token",token); - if(ToolUtil.isEmpty(tAppUser.getPhone())){ - map.put("isBind","0"); - }else { - map.put("isBind","1"); + map.put("token", token); + if (ToolUtil.isEmpty(tAppUser.getPhone())) { + map.put("isBind", "0"); + } else { + map.put("isBind", "1"); } return ResultUtil.success(map); } - /** * 获取JWT token和存储个人信息 + * * @param appUser * @return */ - private String getToken(TAppUser appUser){ + private String getToken(TAppUser appUser) { String randomKey = jwtTokenUtil.getRandomKey(); String token = jwtTokenUtil.generateToken(appUser.getId().toString(), randomKey); redisUtil.setStrValue(token.substring(token.length() - 32), String.valueOf(appUser.getId()), 7 * 24 * 60 * 60); @@ -614,9 +621,9 @@ return token; } - /** * 修改密码 + * * @param phone * @param code * @param password @@ -626,24 +633,23 @@ @Override public ResultUtil updatePassword(String phone, String code, String password) throws Exception { String value = redisUtil.getValue(phone); - if(!"123456".equals(code) && (ToolUtil.isEmpty(value) || !value.equals(code))){ + if (!"123456".equals(code) && (ToolUtil.isEmpty(value) || !value.equals(code))) { return ResultUtil.error("验证码无效"); } TAppUser tAppUser = this.baseMapper.selectOne(new QueryWrapper<TAppUser>().eq("phone", phone).ne("state", 3)); - if(tAppUser==null){ + if (tAppUser == null) { return ResultUtil.error("该账号未注册", ""); } - if(tAppUser.getState() == 2){ + if (tAppUser.getState() == 2) { return ResultUtil.error("您的账号已被冻结", ""); } - if (tAppUser.getCode()==null){ + if (tAppUser.getCode() == null) { tAppUser.setCode(UUIDUtil.getNumberRandom(16)); } tAppUser.setPassword(password); this.updateById(tAppUser); return ResultUtil.success(); } - /** * 定时任务修改到期会员的状态 @@ -653,9 +659,9 @@ this.baseMapper.membershipEnd(); } - /** * 获取加入玩湃首页数据 + * * @param lon * @param lat * @return @@ -664,9 +670,9 @@ @Override public JoinPlayPaiVo queryJoinPlayPai(Integer uid, String lon, String lat) throws Exception { TAppUser appUser = this.getById(uid); - if(ToolUtil.isEmpty(appUser.getProvince()) && ToolUtil.isNotEmpty(lon)){ + if (ToolUtil.isEmpty(appUser.getProvince()) && ToolUtil.isNotEmpty(lon)) { Map<String, String> geocode = gdMapGeocodingUtil.geocode(lon, lat); - if(null != geocode){ + if (null != geocode) { String province = geocode.get("province"); String provinceCode = geocode.get("provinceCode"); String city = geocode.get("city"); @@ -682,12 +688,12 @@ JoinPlayPaiVo joinPlayPaiVo = new JoinPlayPaiVo(); joinPlayPaiVo.setIsVip(appUser.getIsVip()); - if(ToolUtil.isEmpty(lon) ||ToolUtil.isEmpty(lat)){ + if (ToolUtil.isEmpty(lon) || ToolUtil.isEmpty(lat)) { return joinPlayPaiVo; } Map<String, String> geocode = gdMapGeocodingUtil.geocode(lon, lat); - if(null != geocode){ + if (null != geocode) { String provinceCode = geocode.get("provinceCode"); String cityCode = geocode.get("cityCode"); List<Store> stores = storeClient.queryStoreList(new QueryStoreList(provinceCode, cityCode)); @@ -696,7 +702,7 @@ for (Store store : stores) { Map<String, Double> distance = GeodesyUtil.getDistance(lon + "," + lat, store.getLon() + "," + store.getLat()); Double wgs84 = distance.get("WGS84"); - if(s == null || d>wgs84){ + if (s == null || d > wgs84) { s = store; d = wgs84; } @@ -715,21 +721,21 @@ } @Override - public IndexOfUserBenefirVo queryBenefitDetails(Integer appUserId,String lon,String lat) { + public IndexOfUserBenefirVo queryBenefitDetails(Integer appUserId, String lon, String lat) { IndexOfUserBenefirVo benefirVo = new IndexOfUserBenefirVo(); TAppUser appUser = this.getById(appUserId); - if (appUser.getHeadImg()!=null) { + if (appUser.getHeadImg() != null) { benefirVo.setUserHeadImg(appUser.getHeadImg()); - }else { + } else { benefirVo.setUserHeadImg("https://we-park-life.oss-cn-beijing.aliyuncs.com/img/630864764d3c4e98822ff976a2389559.jpg"); } benefirVo.setUserName(appUser.getName()); benefirVo.setWpCoin(ToolUtil.isEmpty(appUser.getPlayPaiCoins()) ? 0 : appUser.getPlayPaiCoins()); benefirVo.setUserIntegral(ToolUtil.isEmpty(appUser.getIntegral()) ? 0 : appUser.getIntegral()); - if (appUser.getIsVip() == 1){ + if (appUser.getIsVip() == 1) { benefirVo.setIsMember("年度会员"); - }else { + } else { benefirVo.setIsMember("普通用户"); } @@ -743,7 +749,7 @@ } @Override - public List<ConsumeDetail> queryUserBillingDetails(String yearMonth, Integer recordId, Integer appUserId) { + public List<ConsumeDetail> queryUserBillingDetails(String yearMonth, Integer recordId, Integer appUserId) { List<ConsumeDetail> details = new ArrayList<>(); SimpleDateFormat simpleDateFormat = new SimpleDateFormat("MM-dd HH:mm"); @@ -764,7 +770,7 @@ requestVo.setAppUserId(appUserId); // 1.赛事报名 BillingRequestVo allCompetitionPayRecord = deducClient.getAllCompetitionPayRecord(requestVo); - if (ToolUtil.isNotEmpty(allCompetitionPayRecord.getRequests())){ + if (ToolUtil.isNotEmpty(allCompetitionPayRecord.getRequests())) { for (BillingRequest paymentCompetition : allCompetitionPayRecord.getRequests()) { ConsumeDetail consumeDetail = new ConsumeDetail(); consumeDetail.setConsumeName(RechargeRecordEnum.EVENT_REGISTRATION.getMsg()); @@ -776,7 +782,7 @@ } // 2.取消赛事报名 BillingRequestVo cancelOrderOfUserPayRecord = deducClient.getCancelOrderOfUserPayRecord(requestVo); - if (ToolUtil.isNotEmpty(cancelOrderOfUserPayRecord.getRequests())){ + if (ToolUtil.isNotEmpty(cancelOrderOfUserPayRecord.getRequests())) { for (BillingRequest paymentCompetition : cancelOrderOfUserPayRecord.getRequests()) { ConsumeDetail consumeDetail = new ConsumeDetail(); consumeDetail.setConsumeName(RechargeRecordEnum.CANCEL_EVENT_REGISTRATION.getMsg()); @@ -800,7 +806,7 @@ // } //2.0 - List<CourseCounsum> courseCounsums = paymentClient.getConsumes(requestVo); + List<CourseCounsum> courseCounsums = paymentClient.getConsumes(requestVo); for (CourseCounsum courseCounsum : courseCounsums) { ConsumeDetail consumeDetail = new ConsumeDetail(); @@ -808,8 +814,8 @@ consumeDetail.setConsumeName(split[0]); consumeDetail.setConsumeTime(simpleDateFormat.format(courseCounsum.getInsertTime())); // if (courseCounsum.getChangeType()==3){ - consumeDetail.setConsumeAmount("-" + split[1]); - consumeDetail.setType(2); + consumeDetail.setConsumeAmount("-" + split[1]); + consumeDetail.setType(2); // } // // consumeDetail.setConsumeAmount("-" + coursePackagePayment.getAmount()); @@ -820,16 +826,16 @@ // 4.场地预约 RequestOfTypeVo allSiteBookingList = stClient.getAllSiteBookingList(requestVo); - if (ToolUtil.isNotEmpty(allSiteBookingList.getRequest())){ + if (ToolUtil.isNotEmpty(allSiteBookingList.getRequest())) { for (BillingRequestOfType booking : allSiteBookingList.getRequest()) { ConsumeDetail consumeDetail = new ConsumeDetail(); - if (booking.getStatus() != 5){ + if (booking.getStatus() != 5) { consumeDetail.setConsumeName(RechargeRecordEnum.VENUE_RESERVATION.getMsg()); consumeDetail.setConsumeAmount("-" + booking.getAmount()); consumeDetail.setConsumeTime(booking.getTime()); consumeDetail.setType(2); details.add(consumeDetail); - }else { + } else { ConsumeDetail consumeDetail1 = new ConsumeDetail(); consumeDetail1.setConsumeName(RechargeRecordEnum.CANCEL_VENUE_RESERVATION.getMsg()); consumeDetail1.setConsumeAmount("+" + booking.getAmount()); @@ -872,7 +878,7 @@ if (rechargeRecords.size() > 0) { for (RechargeRecords rechargeRecord : rechargeRecords) { ConsumeDetail consumeDetail = new ConsumeDetail(); - consumeDetail.setConsumeName(RechargeRecordEnum.RECHARGE.getMsg() + ":" + rechargeRecord.getPlayPaiCoins()+"币"); + consumeDetail.setConsumeName(RechargeRecordEnum.RECHARGE.getMsg() + ":" + rechargeRecord.getPlayPaiCoins() + "币"); consumeDetail.setConsumeTime(simpleDateFormat.format(rechargeRecord.getInsertTime())); consumeDetail.setConsumeAmount("-" + rechargeRecord.getAmount()); consumeDetail.setType(2); @@ -886,7 +892,7 @@ details.addAll(consumeDetails); - if (details.size() > 0 ){ + if (details.size() > 0) { Collections.sort(details, new Comparator<ConsumeDetail>() { @Override public int compare(ConsumeDetail record1, ConsumeDetail record2) { @@ -904,7 +910,7 @@ } }); - if (ToolUtil.isNotEmpty(recordId)){ + if (ToolUtil.isNotEmpty(recordId)) { details = details.stream() .filter(response -> Objects.equals(response.getType(), recordId)) .collect(Collectors.toList()); @@ -916,7 +922,7 @@ @Override public void cancellation(Integer appUserId) { TAppUser tAppUser = this.baseMapper.selectById(appUserId); - if (null != tAppUser){ + if (null != tAppUser) { tAppUser.setState(3); this.baseMapper.updateById(tAppUser); } @@ -928,14 +934,14 @@ TAppUser tAppUser = this.baseMapper.selectById(appUserId); List<Map<String, Object>> rechargeConfig = reconMapper.getRechargeConfig(); System.out.println(rechargeConfig); - if (rechargeConfig.size() > 0 ){ + if (rechargeConfig.size() > 0) { for (Map<String, Object> stringObjectMap : rechargeConfig) { RechargeCentVo vo = new RechargeCentVo(); Double money = (Double) stringObjectMap.get("money"); - vo.setAmount(BigDecimal.valueOf(money) ); - if (tAppUser.getIsVip() == 1&&tAppUser.getVipEndTime().after(new Date())){ + vo.setAmount(BigDecimal.valueOf(money)); + if (tAppUser.getIsVip() == 1 && tAppUser.getVipEndTime().after(new Date())) { vo.setWpGold((Integer) stringObjectMap.get("MemberCoins")); - }else { + } else { vo.setWpGold((Integer) stringObjectMap.get("usersCoins")); } centVos.add(vo); @@ -945,7 +951,7 @@ } @Override - public List<Goods> queryAppUserIntegral(MallRequest request ) { + public List<Goods> queryAppUserIntegral(MallRequest request) { List<Goods> goods = new ArrayList<>(); CommodityRequest commodityRequest = new CommodityRequest(); @@ -964,7 +970,7 @@ if (vicinityGood.getRedemptionMethod() == 1) { commodity.setIntegral(vicinityGood.getIntegral().intValue()); } else { - commodity.setIntegral(ToolUtil.isEmpty(vicinityGood.getIntegral())?0:vicinityGood.getIntegral()); + commodity.setIntegral(ToolUtil.isEmpty(vicinityGood.getIntegral()) ? 0 : vicinityGood.getIntegral()); commodity.setAmount(vicinityGood.getCash()); } commodity.setBelongsType(vicinityGood.getUserPopulation()); @@ -1004,7 +1010,7 @@ if (vicinityGood.getRedemptionMethod() == 1) { commodity.setIntegral(vicinityGood.getIntegral().intValue()); } else { - commodity.setIntegral(ToolUtil.isEmpty(vicinityGood.getIntegral())?0:vicinityGood.getIntegral()); + commodity.setIntegral(ToolUtil.isEmpty(vicinityGood.getIntegral()) ? 0 : vicinityGood.getIntegral()); commodity.setAmount(vicinityGood.getCash()); } commodity.setBelongsType(vicinityGood.getUserPopulation()); @@ -1030,7 +1036,7 @@ if (allCoupon.getRedemptionMethod() == 1) { commodity.setIntegral(allCoupon.getIntegral().intValue()); } else { - if (allCoupon.getIntegral()!=null) { + if (allCoupon.getIntegral() != null) { commodity.setIntegral(allCoupon.getIntegral().intValue()); } commodity.setAmount(allCoupon.getCash()); @@ -1044,40 +1050,40 @@ } } - if (StringUtils.hasText(request.getSearch())){ - if (goods.size() > 0 ){ + if (StringUtils.hasText(request.getSearch())) { + if (goods.size() > 0) { goods = goods.stream() .filter(merchandise -> merchandise.getGoodName().contains(request.getSearch())) .collect(Collectors.toList()); } } // 2.0 门店筛选 - if (request.getShopId()!=null){ - if (goods.size() > 0 ){ + if (request.getShopId() != null) { + if (goods.size() > 0) { goods = goods.stream() - .filter( merchandise ->(merchandise.getGoodsType() == 1&&merchandise.getUseScope() == 2)||(merchandise.getGoodsType() == 1&&merchandise.getUseScope() == 1)||(merchandise.getGoodsType() == 4&&merchandise.getUseScope() == 2)||(merchandise.getGoodsType() == 4&&merchandise.getUseScope() == 1)||merchandise.getShopIds().contains(request.getShopId())) + .filter(merchandise -> (merchandise.getGoodsType() == 1 && merchandise.getUseScope() == 2) || (merchandise.getGoodsType() == 1 && merchandise.getUseScope() == 1) || (merchandise.getGoodsType() == 4 && merchandise.getUseScope() == 2) || (merchandise.getGoodsType() == 4 && merchandise.getUseScope() == 1) || merchandise.getShopIds().contains(request.getShopId())) .collect(Collectors.toList()); } } - if (null != request.getRank()){ - switch (request.getRank()){ + if (null != request.getRank()) { + switch (request.getRank()) { case 1: - if (goods.size() > 0 ){ + if (goods.size() > 0) { goods = goods.stream() .sorted(Comparator.comparing(Goods::getIntegral).reversed()) .collect(Collectors.toList()); } break; case 2: - if (goods.size() > 0 ){ + if (goods.size() > 0) { goods = goods.stream() .sorted(Comparator.comparing(Goods::getIntegral)) .collect(Collectors.toList()); } break; case 3: - if (goods.size() > 0 ){ + if (goods.size() > 0) { goods = goods.stream() .sorted(Comparator.comparing(Goods::getNums).reversed()) .collect(Collectors.toList()); @@ -1088,8 +1094,8 @@ } } - if (null != request.getGoodsType()){ - if (goods.size() > 0 ){ + if (null != request.getGoodsType()) { + if (goods.size() > 0) { goods = goods.stream() .filter(merchandise -> merchandise.getGoodsType().equals(request.getGoodsType())) .collect(Collectors.toList()); @@ -1107,22 +1113,16 @@ return goods; } - // 对数据进行分页处理的方法 - private static Page<Goods> getPage(List<Goods> dataList, Pageable pageable) { - int start = (int) pageable.getOffset(); - int end = Math.min((start + pageable.getPageSize()), dataList.size()); - return new PageImpl<>(dataList.subList(start, end), pageable, dataList.size()); - } - @Override - public ProductDetailsVo productDetails(Integer goodId, Integer goodsType ) { + public ProductDetailsVo productDetails(Integer goodId, Integer goodsType) { ProductDetailRequest detailsVo = new ProductDetailRequest(); detailsVo.setGoodsType(goodsType); detailsVo.setGoodId(goodId); return mcClient.getGoodDetailsWithId(detailsVo); } + @Override - public ProductDetailsVo goodsDetailsOne(Integer goodId ) { + public ProductDetailsVo goodsDetailsOne(Integer goodId) { return mcClient.getGoodDetailsWithIdOne(goodId); } @@ -1131,55 +1131,55 @@ HashMap<String, String> map = new HashMap<>(); // 1 验证手机号 String value = redisUtil.getValue(dto.getPhone()); - if(!"123456".equals(dto.getCode()) && (ToolUtil.isEmpty(value) || !value.equals(dto.getCode()))){ + if (!"123456".equals(dto.getCode()) && (ToolUtil.isEmpty(value) || !value.equals(dto.getCode()))) { return ResultUtil.error("验证码无效"); } - String token=""; + String token = ""; // 通过openId 找到 - TAppUser tAppUser = appUserMapper.selectOne(new LambdaQueryWrapper<TAppUser>().eq(TAppUser::getOpenid, dto.getOpenId()).eq(TAppUser::getState,1)); + TAppUser tAppUser = appUserMapper.selectOne(new LambdaQueryWrapper<TAppUser>().eq(TAppUser::getOpenid, dto.getOpenId()).eq(TAppUser::getState, 1)); - if(tAppUser==null){ + if (tAppUser == null) { return ResultUtil.error("该账号未注册"); } - if(tAppUser.getState() == 2){ + if (tAppUser.getState() == 2) { return ResultUtil.error("您的账号已被冻结"); } - List<TAppUser> tAppUsers1 = appUserMapper.selectList(new LambdaQueryWrapper<TAppUser>().eq(TAppUser::getPhone, dto.getPhone()).eq(TAppUser::getState,1)); - if(tAppUsers1.size()>0){ + List<TAppUser> tAppUsers1 = appUserMapper.selectList(new LambdaQueryWrapper<TAppUser>().eq(TAppUser::getPhone, dto.getPhone()).eq(TAppUser::getState, 1)); + if (tAppUsers1.size() > 0) { TAppUser tAppUser1 = tAppUsers1.get(0); - if(ToolUtil.isNotEmpty(tAppUser1.getOpenid())){ + if (ToolUtil.isNotEmpty(tAppUser1.getOpenid())) { return ResultUtil.error("该手机号已绑定其他微信"); - }else { + } else { tAppUser1.setOpenid(dto.getOpenId()); appUserMapper.updateById(tAppUser1); appUserMapper.deleteById(tAppUser.getId()); token = getToken(tAppUser1); - map.put("token",token); + map.put("token", token); } - }else { + } else { tAppUser.setPhone(dto.getPhone()); appUserMapper.updateById(tAppUser); - token = getToken(tAppUser); - map.put("token",token); + token = getToken(tAppUser); + map.put("token", token); } // tAppUser.setPhone(dto.getPhone()); - if(ToolUtil.isNotEmpty(dto.getInvitePhone())){ - if(ToolUtil.isEmpty(dto.getLat()) || ToolUtil.isEmpty(dto.getLon())){ + if (ToolUtil.isNotEmpty(dto.getInvitePhone())) { + if (ToolUtil.isEmpty(dto.getLat()) || ToolUtil.isEmpty(dto.getLon())) { return ResultUtil.error("请先开启定位"); } - TAppUser tAppUser1 = appUserMapper.selectOne(new LambdaQueryWrapper<TAppUser>().eq(TAppUser::getPhone, dto.getInvitePhone()).eq(TAppUser::getState,1)); - if(tAppUser1!=null){ + TAppUser tAppUser1 = appUserMapper.selectOne(new LambdaQueryWrapper<TAppUser>().eq(TAppUser::getPhone, dto.getInvitePhone()).eq(TAppUser::getState, 1)); + if (tAppUser1 != null) { Map<String, String> geocode = null; try { geocode = gdMapGeocodingUtil.geocode(dto.getLon(), dto.getLat()); } catch (Exception e) { e.printStackTrace(); } - Integer num=0; - if(null != geocode){ + Integer num = 0; + if (null != geocode) { String province = geocode.get("province"); String provinceCode = geocode.get("provinceCode"); String city = geocode.get("city"); @@ -1187,19 +1187,19 @@ IntroduceRewards giftList = introduceRewardsClient.getGiftList(cityCode); num = giftList.getGiveClass(); } - Integer userId=null; - if(ToolUtil.isNotEmpty(dto.getInvitePhone())){ + Integer userId = null; + if (ToolUtil.isNotEmpty(dto.getInvitePhone())) { List<TAppUser> tAppUsers = this.baseMapper.selectList(new LambdaQueryWrapper<TAppUser>().eq(TAppUser::getPhone, dto.getInvitePhone())); - if(tAppUsers.size()>0){ + if (tAppUsers.size() > 0) { userId = tAppUsers.get(0).getId(); } } - if(userId!=null){ + if (userId != null) { TAppGift one = appGiftService.getOne(new LambdaQueryWrapper<TAppGift>().eq(TAppGift::getUserId, userId)); - if(one!=null){ - one.setNum(one.getNum()+num); + if (one != null) { + one.setNum(one.getNum() + num); appGiftService.updateById(one); - }else { + } else { TAppGift tAppGift = new TAppGift(); tAppGift.setUserId(userId); tAppGift.setNum(num); @@ -1215,12 +1215,12 @@ } @Override - public ResultUtil<String> updateInfo(UpdateInfoDto dto,Integer uid) { + public ResultUtil<String> updateInfo(UpdateInfoDto dto, Integer uid) { TAppUser tAppUser = appUserMapper.selectById(uid); - if(ToolUtil.isNotEmpty(dto.getName())){ + if (ToolUtil.isNotEmpty(dto.getName())) { tAppUser.setName(dto.getName()); } - if(ToolUtil.isNotEmpty(dto.getBirthday())){ + if (ToolUtil.isNotEmpty(dto.getBirthday())) { SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); try { Date parse = format.parse(dto.getBirthday()); @@ -1230,7 +1230,7 @@ } } - if(ToolUtil.isNotEmpty(dto.getGender())){ + if (ToolUtil.isNotEmpty(dto.getGender())) { tAppUser.setGender(dto.getGender()); } appUserMapper.updateById(tAppUser); @@ -1243,33 +1243,33 @@ } @Override - public StuAndStoreResponse queryAppUserDefaultStuAndStore(Integer userIdFormRedis,Integer pointsMerId, String lat, String lon,Integer isCourse) { + public StuAndStoreResponse queryAppUserDefaultStuAndStore(Integer userIdFormRedis, Integer pointsMerId, String lat, String lon, Integer isCourse) { StuAndStoreResponse response = new StuAndStoreResponse(); - if (isCourse == 1){ + if (isCourse == 1) { List<TStudent> tStudents = tsmapper.selectList(new QueryWrapper<TStudent>() - .eq("appUserId",userIdFormRedis) - .eq("state",1) - .eq("isDefault",1)); - if (tStudents.size() > 0 ){ + .eq("appUserId", userIdFormRedis) + .eq("state", 1) + .eq("isDefault", 1)); + if (tStudents.size() > 0) { response.setStuId(tStudents.get(0).getId()); response.setStuName(tStudents.get(0).getName()); response.setStuPhone(tStudents.get(0).getPhone()); response.setStuAge(DateUtil.age(tStudents.get(0).getBirthday())); } return response; - }else { + } else { PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerId); - if (pointsMerchandise.getType() == 4){ + if (pointsMerchandise.getType() == 4) { List<Integer> couponStoreIds = ucponClient.getCouponStoreIds(pointsMerId); StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(couponStoreIds.get(0)); - if(ToolUtil.isNotEmpty(courseOfStore)){ + if (ToolUtil.isNotEmpty(courseOfStore)) { response.setStoreId(couponStoreIds.get(0)); response.setStoreName(courseOfStore.getStoreName()); } - }else { + } else { List<Integer> integers = mcsClient.queryPointMerStoreIds(pointsMerId); StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(integers.get(0)); - if(ToolUtil.isNotEmpty(courseOfStore)){ + if (ToolUtil.isNotEmpty(courseOfStore)) { response.setStoreId(integers.get(0)); response.setStoreName(courseOfStore.getStoreName()); } @@ -1278,43 +1278,31 @@ } } - - - @Resource - private UserConponClient userConponClient; - -@Autowired -private TAppUserService appUserService; - - - - @Override @Transactional public synchronized ResultUtil productRedemptionOperation(Integer userIdFormRedis, GoodsExchangeVo exchangeType) { System.out.println("exchangeType:--->"); - ReturnModel returnModel = new ReturnModel(); Long returnId = null; - //如果是兑换优惠卷 - if (exchangeType.getGoodsType()==4){ + //如果是兑换优惠卷 + if (exchangeType.getGoodsType() == 4) { //查询优惠卷 Coupon coupon = userConponClient.queryCouponById(exchangeType.getGoodId()); //查询该优惠卷的数量够不够 List<Integer> queryIds = new ArrayList<>(); queryIds.add(coupon.getId()); queryIds.add(userIdFormRedis); - Integer counts = userConponClient.queryCounts(queryIds); - if (coupon.getQuantityIssued()-counts == 0){ - return new ResultUtil(0,"当前数量不足"); - } + Integer counts = userConponClient.queryCounts(queryIds); + if (coupon.getQuantityIssued() - counts == 0) { + return new ResultUtil(0, "当前数量不足"); + } //查询该用户是否超出限领数量 - Integer usercounts = userConponClient.queryCounts1(queryIds); + Integer usercounts = userConponClient.queryCounts1(queryIds); - if (usercounts == coupon.getPickUpQuantity()){ - return new ResultUtil<>(0,"限领数量已达最大"); + if (usercounts == coupon.getPickUpQuantity()) { + return new ResultUtil<>(0, "限领数量已达最大"); } // userConponClient.queryCouponById(exchangeType.getGoodId()); UserCoupon userCoupon = new UserCoupon(); @@ -1325,10 +1313,10 @@ userConponClient.insertToAppuserCoupon(userCoupon); //扣积分 TAppUser user = appUserService.getById(userIdFormRedis); - if (user.getIntegral()<coupon.getIntegral().intValue()){ - return new ResultUtil<>(0,"当前用户积分不足"); + if (user.getIntegral() < coupon.getIntegral().intValue()) { + return new ResultUtil<>(0, "当前用户积分不足"); } - user.setIntegral(user.getIntegral()-coupon.getIntegral().intValue()); + user.setIntegral(user.getIntegral() - coupon.getIntegral().intValue()); appUserService.updateById(user); //记录 @@ -1353,8 +1341,6 @@ } - - System.out.println(exchangeType); try { SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); @@ -1362,39 +1348,37 @@ PointsMerchandise merchandise = mcClient.selectPointsMerchandiseById(exchangeType.getGoodId()); - - - if (ToolUtil.isEmpty(merchandise)){ + if (ToolUtil.isEmpty(merchandise)) { return ResultUtil.error("商品不存在"); } TAppUser tAppUser = this.baseMapper.selectById(userIdFormRedis); - if(merchandise.getUserPopulation()==2){ - if(tAppUser.getIsVip()==0){ + if (merchandise.getUserPopulation() == 2) { + if (tAppUser.getIsVip() == 0) { return ResultUtil.error("该商品只能年度会员购买"); } } - if(merchandise.getUserPopulation()==3){ + if (merchandise.getUserPopulation() == 3) { List<TStudent> students = tsmapper.selectList(new LambdaQueryWrapper<TStudent>().eq(TStudent::getAppUserId, userIdFormRedis)); - if(students.size()==0){ + if (students.size() == 0) { return ResultUtil.error("该商品只能已有学员用户购买"); } } - if (ToolUtil.isEmpty(tAppUser)){ + if (ToolUtil.isEmpty(tAppUser)) { return ResultUtil.error("用户不存在"); } int goodsNums = 0; - if (ToolUtil.isEmpty(exchangeType.getNums())){ + if (ToolUtil.isEmpty(exchangeType.getNums())) { goodsNums = 1; - }else { + } else { goodsNums = exchangeType.getNums(); } TAppUser user = appUserService.getById(userIdFormRedis); - if (merchandise.getIntegral()!=null) { + if (merchandise.getIntegral() != null) { if (user.getIntegral() < merchandise.getIntegral().intValue() * goodsNums) { return new ResultUtil<>(0, "当前用户积分不足"); } @@ -1405,15 +1389,13 @@ goodResp.setAppUserId(userIdFormRedis); goodResp.setGoodId(merchandise.getId()); int count = mcClient.queryUserHasGoodsNums(goodResp); - if (ToolUtil.isNotEmpty(count) && count+exchangeType.getNums() > merchandise.getPickUpQuantity()){ + if (ToolUtil.isNotEmpty(count) && count + exchangeType.getNums() > merchandise.getPickUpQuantity()) { return ResultUtil.error("超过限领数量"); } int count1 = mcClient.queryUserHasGoodsNums1(goodResp); - if (ToolUtil.isNotEmpty(count1) && count1 >= merchandise.getQuantityIssued()){ + if (ToolUtil.isNotEmpty(count1) && count1 >= merchandise.getQuantityIssued()) { return ResultUtil.error("超过发放数量"); } - - for (int i = 0; i < goodsNums; i++) { @@ -1421,23 +1403,23 @@ UserPointsMerchandise pointsMerchandise = new UserPointsMerchandise(); pointsMerchandise.setPointsMerchandiseId(exchangeType.getGoodId()); pointsMerchandise.setUserId(userIdFormRedis); - if (exchangeType.getGoodsType()==2){ + if (exchangeType.getGoodsType() == 2) { pointsMerchandise.setStatus(2); pointsMerchandise.setVerificationTime(new Date()); - }else { + } else { pointsMerchandise.setStatus(1); } pointsMerchandise.setState(1); - if (exchangeType.getExchangeType()==1) { + if (exchangeType.getExchangeType() == 1) { pointsMerchandise.setPayStatus(2); - }else { + } else { pointsMerchandise.setPayStatus(1); } - if (merchandise.getUseScope() == 3){ - if (exchangeType.getGoodsType() == 2){ + if (merchandise.getUseScope() == 3) { + if (exchangeType.getGoodsType() == 2) { CoursePackage coursePackage = cpageClient.queryCoursePackageById(merchandise.getCoursePackageId()); pointsMerchandise.setStoreId(coursePackage.getStoreId()); - }else { + } else { pointsMerchandise.setStoreId(exchangeType.getStoreId()); } } @@ -1445,20 +1427,20 @@ returnId = mcClient.saveDetailsUserPointMercase(pointsMerchandise); } - switch (exchangeType.getExchangeType()){ + switch (exchangeType.getExchangeType()) { // 积分 case 1: - boolean b =true; + boolean b = true; for (int i = 0; i < goodsNums; i++) { - b = dealAppUserIntegral(userIdFormRedis,tAppUser,merchandise.getIntegral()); + b = dealAppUserIntegral(userIdFormRedis, tAppUser, merchandise.getIntegral()); } - if (b){ - switch (exchangeType.getGoodsType()){ + if (b) { + switch (exchangeType.getGoodsType()) { case 2: Integer stuNums = 0; - if (ToolUtil.isNotEmpty(exchangeType.getStuIds())){ + if (ToolUtil.isNotEmpty(exchangeType.getStuIds())) { stuNums = exchangeType.getStuIds().size(); - }else { + } else { stuNums = 1; } for (int i = 0; i < stuNums; i++) { @@ -1509,15 +1491,15 @@ default: break; } - }else { + } else { return ResultUtil.error("用户积分不足!"); } break; case 2: // 积分+现金 - boolean dealt =true; + boolean dealt = true; for (int i = 0; i < goodsNums; i++) { - dealt = dealAppUserIntegral(userIdFormRedis,tAppUser,merchandise.getIntegral()); + dealt = dealAppUserIntegral(userIdFormRedis, tAppUser, merchandise.getIntegral()); } switch (exchangeType.getPayType()) { @@ -1533,9 +1515,9 @@ } case 2: if (merchandise.getType() == 2) { - return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(exchangeType.getStuIds().size())), code,returnId); + return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(exchangeType.getStuIds().size())), code, returnId); } else { - return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(goodsNums)), code,returnId); + return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(goodsNums)), code, returnId); } default: break; @@ -1555,9 +1537,9 @@ } case 2: if (merchandise.getType() == 2) { - return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(exchangeType.getStuIds().size())), code,returnId); + return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(exchangeType.getStuIds().size())), code, returnId); } else { - return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(goodsNums)), code,returnId); + return AlipayPayment(merchandise.getCash().multiply(new BigDecimal(goodsNums)), code, returnId); } default: break; @@ -1567,18 +1549,18 @@ break; } - returnModel.setReturnId(returnId); + returnModel.setReturnId(returnId); return ResultUtil.success(returnModel); - }catch (Exception e){ + } catch (Exception e) { e.printStackTrace(); return null; } } - public boolean dealAppUserIntegral(Integer appUserId,TAppUser appUser,Integer points){ + public boolean dealAppUserIntegral(Integer appUserId, TAppUser appUser, Integer points) { try { - if (ToolUtil.isEmpty(appUser.getIntegral()) || (ToolUtil.isNotEmpty(appUser.getIntegral()) && appUser.getIntegral() < points)){ + if (ToolUtil.isEmpty(appUser.getIntegral()) || (ToolUtil.isNotEmpty(appUser.getIntegral()) && appUser.getIntegral() < points)) { return false; } // 积分变更记录 @@ -1594,35 +1576,35 @@ this.baseMapper.updateById(appUser); return true; - }catch (Exception e){ + } catch (Exception e) { return false; } } - private ResultUtil AlipayPayment(BigDecimal cash, String code,Long returnId) { - System.out.println("金额:"+cash); + private ResultUtil AlipayPayment(BigDecimal cash, String code, Long returnId) { + System.out.println("金额:" + cash); ResultUtil alipay = payMoneyUtil.alipay("优惠卷", "优惠卷", String.valueOf(returnId), code, cash.toString(), "/base/pointMer/exchangeGoodPaymentAliCallback"); - if(alipay.getCode() == 200){ + if (alipay.getCode() == 200) { new Thread(new Runnable() { @Override public void run() { try { int num = 1; int wait = 0; - while (num <= 10){ + while (num <= 10) { int min = 5000; wait += (min * num); Thread.sleep(wait); - System.out.println("code:"+code); + System.out.println("code:" + code); List<UserPointsMerchandise> userPointsMerchandises = mcClient.queryUserPointMerchaseByCode(code); - System.out.println("list-----"+userPointsMerchandises); - if(userPointsMerchandises.get(0).getPayStatus() == 2){ + System.out.println("list-----" + userPointsMerchandises); + if (userPointsMerchandises.get(0).getPayStatus() == 2) { break; } // ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryALIOrder(code); AlipayTradeQueryResponse resultUtil = payMoneyUtil.queryALIOrder(code); - if(resultUtil.getCode().equals("10000") && userPointsMerchandises.get(0).getPayStatus() == 1){ + if (resultUtil.getCode().equals("10000") && userPointsMerchandises.get(0).getPayStatus() == 1) { /** * WAIT_BUYER_PAY(交易创建,等待买家付款)、 * TRADE_CLOSED(未付款交易超时关闭,或支付完成后全额退款)、 @@ -1635,9 +1617,9 @@ String tradeNo = resultUtil.getTradeNo(); String tradeStatus = resultUtil.getTradeStatus(); - System.out.println("ssssss"+tradeStatus); + System.out.println("ssssss" + tradeStatus); - if("TRADE_SUCCESS".equals(tradeStatus)){ + if ("TRADE_SUCCESS".equals(tradeStatus)) { for (UserPointsMerchandise userPointsMerchandise : userPointsMerchandises) { userPointsMerchandise.setPayStatus(2); userPointsMerchandise.setOrderNumber(tradeNo); @@ -1646,7 +1628,7 @@ userPointsMerchandise.setUserId(null); mcClient.updateDetailsUserPointMercase(userPointsMerchandise); } - moneyOut(tradeNo,tradeNo); + moneyOut(tradeNo, tradeNo); break; } // if("REFUND".equals(tradeStatus) || "NOTPAY".equals(tradeStatus) || "CLOSED".equals(tradeStatus) || "REVOKED".equals(tradeStatus) || "PAYERROR".equals(tradeStatus) || num == 10){ @@ -1654,12 +1636,12 @@ // break; // } - if("WAIT_BUYER_PAY".equals(tradeStatus)){ + if ("WAIT_BUYER_PAY".equals(tradeStatus)) { num++; } } } - }catch (Exception e){ + } catch (Exception e) { mcClient.deletePaymentRecord(code); e.printStackTrace(); } @@ -1669,13 +1651,7 @@ return alipay; } - - - @Resource - private MerChandiseClient merChandiseClient; - - - public void moneyOut(String outNum,String tradeNo) throws AlipayApiException { + public void moneyOut(String outNum, String tradeNo) throws AlipayApiException { AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", aliAppid, appPrivateKey, "json", "UTF-8", alipay_public_key, "RSA2"); @@ -1698,15 +1674,14 @@ " \"memo\":\"分账给测试商户\"," + " }" + " ]," + - " \"out_request_no\":\""+tradeNo+"\"" + + " \"out_request_no\":\"" + tradeNo + "\"" + "}"); AlipayTradeRoyaltyRelationBindResponse response = alipayClient.execute(request1); - if(response.isSuccess()){ + if (response.isSuccess()) { System.out.println("绑定调用成功"); } else { System.out.println("调用失败"); } - // RoyaltyDetailInfos royaltyDetailInfos1 = new RoyaltyDetailInfos(); @@ -1730,9 +1705,7 @@ // TCoursePackage byId = coursePackageService.getById(one.getCoursePackageId()); - - OperatorUser operatorUser = storeClient.queryByStoreId(storeId); - + OperatorUser operatorUser = storeClient.queryByStoreId(storeId); // Integer paymentCompetitions = competitionsClient.queryByCode(outTradeNo); @@ -1742,8 +1715,6 @@ // stores.add(paymentCompetitions); // stores.add(siteBookings); // OperatorUser operatorUser = siteClient.queryOperator(stores); - - OpenApiRoyaltyDetailInfoPojo op = new OpenApiRoyaltyDetailInfoPojo(); @@ -1761,7 +1732,7 @@ AlipayTradeOrderSettleResponse response1 = alipayClient.execute(request); - if(response1.isSuccess()){ + if (response1.isSuccess()) { System.out.println("调用成功"); } else { System.out.println("调用失败"); @@ -1772,23 +1743,23 @@ private ResultUtil WechatPayment(BigDecimal cash, String code) throws Exception { ResultUtil weixinpay = payMoneyUtil.weixinpay("课包", "", code, cash.toString(), "/base/pointMer/exchangeGoodPaymentWeChatCallback", "APP", ""); - if(weixinpay.getCode() == 200){ + if (weixinpay.getCode() == 200) { new Thread(new Runnable() { @Override public void run() { try { int num = 1; int wait = 0; - while (num <= 10){ + while (num <= 10) { int min = 5000; wait += (min * num); Thread.sleep(wait); List<UserPointsMerchandise> userPointsMerchandises = mcClient.queryUserPointMerchaseByCode(code); - if(userPointsMerchandises.get(0).getPayStatus() == 2){ + if (userPointsMerchandises.get(0).getPayStatus() == 2) { break; } ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(code, ""); - if(resultUtil.getCode() == 200 && userPointsMerchandises.get(0).getPayStatus() == 1){ + if (resultUtil.getCode() == 200 && userPointsMerchandises.get(0).getPayStatus() == 1) { /** * SUCCESS—支付成功, * REFUND—转入退款, @@ -1801,11 +1772,11 @@ 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) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) { mcClient.deletePaymentRecord(code); break; } - if("SUCCESS".equals(s)){ + if ("SUCCESS".equals(s)) { for (UserPointsMerchandise userPointsMerchandise : userPointsMerchandises) { userPointsMerchandise.setPayStatus(2); userPointsMerchandise.setOrderNumber(transaction_id); @@ -1814,12 +1785,12 @@ } break; } - if("USERPAYING".equals(s)){ + if ("USERPAYING".equals(s)) { num++; } } } - }catch (Exception e){ + } catch (Exception e) { e.printStackTrace(); } } @@ -1829,21 +1800,21 @@ } @Override - public ResultUtil exchangeAddPaymentCallback(String code, String orderNumber,Integer payType) { + public ResultUtil exchangeAddPaymentCallback(String code, String orderNumber, Integer payType) { List<UserPointsMerchandise> userPointsMerchandises = mcClient.queryUserPointMerchaseByCode(code); - if(userPointsMerchandises.get(0).getPayStatus() == 2){ + if (userPointsMerchandises.get(0).getPayStatus() == 2) { return ResultUtil.success(); } - if (userPointsMerchandises.size() > 1){ + if (userPointsMerchandises.size() > 1) { for (int i = 0; i < userPointsMerchandises.size(); i++) { - userPointsMerchandises.get(i).setOrderNumber(orderNumber+ "-" + (i+1)); + userPointsMerchandises.get(i).setOrderNumber(orderNumber + "-" + (i + 1)); userPointsMerchandises.get(i).setPayType(payType); userPointsMerchandises.get(i).setPayStatus(2); mcClient.updateDetailsUserPointMercase(userPointsMerchandises.get(i)); Integer pointsMerchandiseId = userPointsMerchandises.get(i).getPointsMerchandiseId(); PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerchandiseId); - switch (pointsMerchandise.getType()){ + switch (pointsMerchandise.getType()) { case 2: List<TCoursePackagePayment> coursePackagePaymentOfCode = paymentClient.getCoursePackagePaymentOfCode(code); for (TCoursePackagePayment coursePackagePayment : coursePackagePaymentOfCode) { @@ -1865,7 +1836,7 @@ break; } } - }else { + } else { userPointsMerchandises.get(0).setOrderNumber(orderNumber); userPointsMerchandises.get(0).setPayType(payType); userPointsMerchandises.get(0).setPayStatus(2); @@ -1873,11 +1844,11 @@ Integer pointsMerchandiseId = userPointsMerchandises.get(0).getPointsMerchandiseId(); PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerchandiseId); - switch (pointsMerchandise.getType()){ + switch (pointsMerchandise.getType()) { case 2: List<TCoursePackagePayment> coursePackagePaymentOfCode = paymentClient.getCoursePackagePaymentOfCode(code); - TCoursePackagePayment packagePayment =coursePackagePaymentOfCode.get(0); + TCoursePackagePayment packagePayment = coursePackagePaymentOfCode.get(0); packagePayment.setPayStatus(2); packagePayment.setPayType(payType); packagePayment.setOrderNumber(orderNumber); @@ -1900,14 +1871,14 @@ } @Override - public List<StoreResponse> queryStoresOfExchange(Integer goodsType,Integer pointsMerId) { + public List<StoreResponse> queryStoresOfExchange(Integer goodsType, Integer pointsMerId) { List<StoreResponse> responses = new ArrayList<>(); - if (goodsType == 4){ + if (goodsType == 4) { List<Integer> couponStoreIds = ucponClient.getCouponStoreIds(pointsMerId); - if (couponStoreIds.size() > 0 ){ + if (couponStoreIds.size() > 0) { for (Integer couponStoreId : couponStoreIds) { StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(couponStoreId); - if(ToolUtil.isNotEmpty(courseOfStore)){ + if (ToolUtil.isNotEmpty(courseOfStore)) { StoreResponse response = new StoreResponse(); response.setStoreId(couponStoreId); response.setStoreName(courseOfStore.getStoreName()); @@ -1916,12 +1887,12 @@ } } - }else { + } else { List<Integer> integers = mcsClient.queryPointMerStoreIds(pointsMerId); - if (integers.size() > 0 ){ + if (integers.size() > 0) { for (Integer integer : integers) { StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(integer); - if(ToolUtil.isNotEmpty(courseOfStore)){ + if (ToolUtil.isNotEmpty(courseOfStore)) { StoreResponse response = new StoreResponse(); response.setStoreId(integer); response.setStoreName(courseOfStore.getStoreName()); @@ -1935,7 +1906,7 @@ @Override - public List<CourseVenue> queryWeekOfCourseDetails(Integer appUserId ,Integer stuId, String time,String longitude,String latitude) { + public List<CourseVenue> queryWeekOfCourseDetails(Integer appUserId, Integer stuId, String time, String longitude, String latitude) { List<CourseVenue> courseVenues = new ArrayList<>(); WeeksOfCourseRest weeksOfCourseRest = new WeeksOfCourseRest(); weeksOfCourseRest.setTime(time); @@ -1943,13 +1914,11 @@ weeksOfCourseRest.setAppUserId(appUserId); List<CourseOfStoreVo> storeOfCourses = paymentClient.getStoreOfCourses(weeksOfCourseRest); System.out.println(storeOfCourses); - if (storeOfCourses.size() > 0 ){ - courseVenues = dealDatas(storeOfCourses,longitude,latitude); + if (storeOfCourses.size() > 0) { + courseVenues = dealDatas(storeOfCourses, longitude, latitude); } return courseVenues; } - - } -- Gitblit v1.7.1