| | |
| | | import com.ruoyi.common.security.service.TokenService; |
| | | import com.ruoyi.common.security.utils.SecurityUtils; |
| | | import com.ruoyi.management.api.feignClient.ManagementClient; |
| | | import com.ruoyi.management.api.model.TFeedback; |
| | | import com.ruoyi.management.api.model.TPage; |
| | | import com.ruoyi.management.api.model.TUseGuide; |
| | | import com.ruoyi.management.api.model.TVipSet; |
| | | import com.ruoyi.management.api.model.*; |
| | | import com.ruoyi.management.api.query.UseGuideQuery; |
| | | import com.ruoyi.study.domain.TUser; |
| | | import com.ruoyi.study.domain.TUserShare; |
| | | import com.ruoyi.study.domain.TVipOrder; |
| | | import com.ruoyi.study.dto.AppUserQuery; |
| | | import com.ruoyi.study.dto.UserInfoQuery; |
| | | import com.ruoyi.study.request.RegisterPhoneRequest; |
| | | import com.ruoyi.study.service.ITUserService; |
| | | import com.ruoyi.study.service.ITUserShareService; |
| | | import com.ruoyi.study.service.IVipOrderService; |
| | | import com.ruoyi.study.utils.PayMoneyUtil; |
| | | import com.ruoyi.study.utils.UUIDUtil; |
| | |
| | | private TokenService tokenService; |
| | | @Resource |
| | | private RedisService redisService; |
| | | @Resource |
| | | private ITUserShareService userShareService; |
| | | |
| | | @PostMapping("/vipInfo") |
| | | @ApiOperation(value = "会员中心-获取会员说明、当前登录用户是否为会员、会员购买规格", tags = {"家长端-个人中心"}) |
| | |
| | | List<TPage> data = managementClient.getPage1().getData(); |
| | | for (TPage datum : data) { |
| | | if (datum.getType() == 4) { |
| | | return AjaxResult.success(datum); |
| | | return AjaxResult.success(datum.getImg()); |
| | | } |
| | | } |
| | | return AjaxResult.success(); |
| | | } |
| | | |
| | | @PostMapping("/parentPage") |
| | | @ApiOperation(value = "平板", tags = {"家长端-启动页"}) |
| | | public AjaxResult<String> parentPage() { |
| | | List<TPage> data = managementClient.getPage1().getData(); |
| | | for (TPage datum : data) { |
| | | if (datum.getType() == 3) { |
| | | return AjaxResult.success(datum.getImg()); |
| | | } |
| | | } |
| | | return AjaxResult.success(); |
| | | } |
| | | |
| | | @PostMapping("/parentPage1") |
| | | @ApiOperation(value = "手机", tags = {"家长端-启动页"}) |
| | | public AjaxResult<String> parentPage1() { |
| | | List<TPage> data = managementClient.getPage1().getData(); |
| | | for (TPage datum : data) { |
| | | if (datum.getType() == 2) { |
| | | return AjaxResult.success(datum.getImg()); |
| | | } |
| | | } |
| | | return AjaxResult.success(); |
| | | } |
| | | |
| | | @PostMapping("/getProtocol") |
| | | @ApiOperation(value = "获取协议", tags = {"家长端-协议"}) |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(value = "类型 1用户 2隐私 3注销", name = "type", dataType = "string", required = true), |
| | | }) |
| | | public AjaxResult<String> getProtocol(Integer type) { |
| | | String data = managementClient.agreement1(type).getData(); |
| | | return AjaxResult.success(data); |
| | | } |
| | | |
| | | @PostMapping("/useGuide") |
| | |
| | | return AjaxResult.error("登录失败,您的账号已被冻结!"); |
| | | } |
| | | } else { |
| | | // todo 验证码校验 |
| | | tUser1 = getUser(phone); |
| | | userService.save(tUser1); |
| | | // 手机验证码校验 |
| | | Object redisPhoneCode = redisService.getCacheObject(RedisConstants.PHONE_CODE + phone); |
| | | if (null == redisPhoneCode) { |
| | | return AjaxResult.error("登录失败,手机验证码已过期!"); |
| | | } else { |
| | | // redis 验证码的value 为 code:时间戳 |
| | | String rCodeAndTime = String.valueOf(redisPhoneCode); |
| | | String rCode = rCodeAndTime.split(":")[0]; |
| | | if (!rCode.equalsIgnoreCase(phoneCode)) { |
| | | return AjaxResult.error("登录失败,手机验证码输入有误!"); |
| | | } else { |
| | | tUser1 = getUser(phone); |
| | | userService.save(tUser1); |
| | | } |
| | | } |
| | | } |
| | | LoginUserParent loginUserParent = new LoginUserParent(); |
| | | loginUserParent.setName(tUser1.getName()); |
| | |
| | | */ |
| | | @GetMapping("/sendPhoneCode") |
| | | @ApiOperation(value = "发送手机验证码", tags = {"家长端/学习端-发送手机验证码"}) |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(value = "手机号", name = "phone", dataType = "string", required = true), |
| | | }) |
| | | public AjaxResult sendPhoneCode(@RequestParam String phone) { |
| | | return userService.phoneCode(phone) ? AjaxResult.success() : AjaxResult.error(); |
| | | } |
| | | |
| | | /** |
| | | * 分享图片、标题及可获积分数 |
| | | */ |
| | | @GetMapping("/shareInfo") |
| | | @ApiOperation(value = "微信分享信息", tags = {"微信分享信息"}) |
| | | public AjaxResult shareInfo() { |
| | | // 分享信息 |
| | | TSysSet data = managementClient.shareInfo().getData(); |
| | | Integer userid = tokenService.getLoginUserStudy().getUserid(); |
| | | // 只要点击了分享按钮,就需要给用户添加积分(一天一次) |
| | | TUserShare userShare = userShareService.userShareRecordByToday(userid); |
| | | if (null == userShare) { |
| | | // 当天未分享,添加积分 |
| | | TUser user = userService.getById(userid); |
| | | int integral = Integer.parseInt(data.getIntegralShare()); |
| | | user.setIntegral(user.getIntegral() + integral); |
| | | userService.updateById(user); |
| | | // 添加分享记录 |
| | | TUserShare record = new TUserShare(); |
| | | record.setIntegral(integral); |
| | | record.setUserId(userid); |
| | | userShareService.save(record); |
| | | } |
| | | return AjaxResult.success(); |
| | | } |
| | | |
| | | /** |
| | | * 获取用户信息 |
| | | * |
| | | * @return 用户信息 |
| | | */ |
| | | @GetMapping("/userInfo") |
| | | @ApiOperation(value = "用户详情", tags = {"用户详情"}) |
| | | public R<TUser> userInfo() { |
| | | return R.ok(userService.lambdaQuery().eq(TUser::getId,tokenService.getLoginUserStudy().getUserid()).one()); |
| | | } |
| | | |
| | | @PostMapping("/deleteUser") |
| | |
| | | userService.saveOrUpdate(byId); |
| | | return AjaxResult.success("修改成功"); |
| | | } |
| | | |
| | | @ResponseBody |
| | | @PostMapping("/base/wxRefund") |
| | | public void cancelMySiteCallback(HttpServletRequest request, HttpServletResponse response) { |
| | | try { |
| | | Map<String, String> map = payMoneyUtil.wxRefundCallback(request); |
| | | if (null != map) { |
| | | String code = map.get("out_refund_no"); |
| | | String refund_id = map.get("refund_id"); |
| | | String result = map.get("result"); |
| | | TVipOrder one = vipOrderService.getOne(new QueryWrapper<TVipOrder>() |
| | | .eq("outTradeNo", code) |
| | | .eq("payState", 3)); |
| | | one.setBackTime(new Date()); |
| | | vipOrderService.updateById(one); |
| | | Integer userId = one.getUserId(); |
| | | TUser byId1 = userService.getById(userId); |
| | | // 判断用户是不是第一次充值 |
| | | List<TVipOrder> list = vipOrderService.list(new QueryWrapper<TVipOrder>() |
| | | .eq("userId", userId) |
| | | .eq("payState", 2) |
| | | .orderByDesc("createTime")); |
| | | int size = list.size(); |
| | | if (size == 0) { |
| | | // 证明这是用户第一次充值会员 将首次充值会员时间和会员到期时间清空 |
| | | byId1.setVipEndTime(null); |
| | | byId1.setVipPayTime(null); |
| | | userService.updateById(byId1); |
| | | } else { |
| | | // 最近的一次充值会员时间 |
| | | TVipOrder tVipOrder = list.get(0); |
| | | // 将会员到期时间回退到上一次 |
| | | byId1.setVipEndTime(tVipOrder.getTime()); |
| | | userService.updateById(byId1); |
| | | } |
| | | |
| | | PrintWriter out = response.getWriter(); |
| | | out.write(result); |
| | | out.flush(); |
| | | out.close(); |
| | | } |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | @PostMapping("/vipBack/{id}") |
| | | @ApiOperation(value = "会员退款", tags = {"管理后台-会员退款"}) |
| | | public R vipBack(@PathVariable("id") Integer id) throws AlipayApiException { |
| | |
| | | String transactionId = byId.getTransactionId(); |
| | | // 内部订单号 |
| | | String outTradeNo = byId.getOutTradeNo(); |
| | | switch (byId.getPayType()){ |
| | | switch (byId.getPayType()) { |
| | | case 1: |
| | | // 微信退款 |
| | | // 微信退款 |
| | | Map<String, String> stringStringMap = payMoneyUtil.wxRefund(transactionId, outTradeNo, byId.getMoney().toString(), byId.getMoney().toString(), "/base/wxRefund"); |
| | | if (stringStringMap.get("code").equals("SUCCESS")){ |
| | | byId.setPayState(3); |
| | | byId.setBackTime(new Date()); |
| | | vipOrderService.updateById(byId); |
| | | // 用户的vip剩余时间减少 |
| | | Calendar calendar = Calendar.getInstance(); |
| | | calendar.setTime(new Date()); |
| | | calendar.add(Calendar.MONTH, -byId.getCount()); |
| | | Date dateAfterOneMonth = calendar.getTime(); |
| | | Integer userId = byId.getUserId(); |
| | | TUser byId1 = userService.getById(userId); |
| | | // 判断用户是不是第一次充值 |
| | | List<TVipOrder> list = vipOrderService.list(new QueryWrapper<TVipOrder>() |
| | | .eq("userId", userId) |
| | | .eq("payState", 2) |
| | | .orderByDesc("createTime")); |
| | | int size = list.size(); |
| | | if (size == 0) { |
| | | // 证明这是用户第一次充值会员 将首次充值会员时间和会员到期时间清空 |
| | | byId1.setVipEndTime(null); |
| | | byId1.setVipPayTime(null); |
| | | userService.updateById(byId1); |
| | | } else { |
| | | // 最近的一次充值会员时间 |
| | | TVipOrder tVipOrder = list.get(0); |
| | | // 将会员到期时间回退到上一次 |
| | | byId1.setVipEndTime(tVipOrder.getTime()); |
| | | userService.updateById(byId1); |
| | | } |
| | | |
| | | return R.ok(); |
| | | }else{ |
| | | return R.fail(stringStringMap.get("msg")); |
| | | if (null == stringStringMap) { |
| | | return R.fail("取消退款异常"); |
| | | } |
| | | String result_code = stringStringMap.get("result_code"); |
| | | if (!"SUCCESS".equals(result_code)) { |
| | |
| | | vipOrderService.updateById(byId); |
| | | case 2: |
| | | // 支付宝退款 |
| | | Map<String, String> stringStringMap1 = payMoneyUtil.aliRefund(transactionId,byId.getMoney().toString()); |
| | | Map<String, String> stringStringMap1 = payMoneyUtil.aliRefund(transactionId, byId.getMoney().toString()); |
| | | if (null == stringStringMap1) { |
| | | return R.fail("取消退款异常"); |
| | | } |
| | |
| | | if (!"10000".equals(code)) { |
| | | return R.fail(stringStringMap1.get("return_msg")); |
| | | } |
| | | byId.setPayState(3); |
| | | byId.setBackTime(new Date()); |
| | | vipOrderService.updateById(byId); |
| | | // 用户的vip剩余时间减少 |
| | | Calendar calendar = Calendar.getInstance(); |
| | | calendar.setTime(new Date()); |
| | | calendar.add(Calendar.MONTH, -byId.getCount()); |
| | | Date dateAfterOneMonth = calendar.getTime(); |
| | | Integer userId = byId.getUserId(); |
| | | TUser byId1 = userService.getById(userId); |
| | | // 判断用户是不是第一次充值 |
| | | List<TVipOrder> list = vipOrderService.list(new QueryWrapper<TVipOrder>() |
| | | .eq("userId", userId) |
| | | .eq("payState", 2) |
| | | .orderByDesc("createTime")); |
| | | int size = list.size(); |
| | | if (size == 0) { |
| | | // 证明这是用户第一次充值会员 将首次充值会员时间和会员到期时间清空 |
| | | byId1.setVipEndTime(null); |
| | | byId1.setVipPayTime(null); |
| | | userService.updateById(byId1); |
| | | } else { |
| | | // 最近的一次充值会员时间 |
| | | TVipOrder tVipOrder = list.get(0); |
| | | // 将会员到期时间回退到上一次 |
| | | byId1.setVipEndTime(tVipOrder.getTime()); |
| | | userService.updateById(byId1); |
| | | } |
| | | return R.ok(); |
| | | byId.setPayState(3); |
| | | byId.setBackTime(new Date()); |
| | | vipOrderService.updateById(byId); |
| | | // 用户的vip剩余时间减少 |
| | | Calendar calendar = Calendar.getInstance(); |
| | | calendar.setTime(new Date()); |
| | | calendar.add(Calendar.MONTH, -byId.getCount()); |
| | | Date dateAfterOneMonth = calendar.getTime(); |
| | | Integer userId = byId.getUserId(); |
| | | TUser byId1 = userService.getById(userId); |
| | | // 判断用户是不是第一次充值 |
| | | List<TVipOrder> list = vipOrderService.list(new QueryWrapper<TVipOrder>() |
| | | .eq("userId", userId) |
| | | .eq("payState", 2) |
| | | .orderByDesc("createTime")); |
| | | int size = list.size(); |
| | | if (size == 0) { |
| | | // 证明这是用户第一次充值会员 将首次充值会员时间和会员到期时间清空 |
| | | byId1.setVipEndTime(null); |
| | | byId1.setVipPayTime(null); |
| | | userService.updateById(byId1); |
| | | } else { |
| | | return R.fail(stringStringMap1.get("msg")); |
| | | // 最近的一次充值会员时间 |
| | | TVipOrder tVipOrder = list.get(0); |
| | | // 将会员到期时间回退到上一次 |
| | | byId1.setVipEndTime(tVipOrder.getTime()); |
| | | userService.updateById(byId1); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | return R.ok(); |
| | | } |