From f0cb2ed0aed012ae08fd957338650d91c3cc1d14 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期一, 17 六月 2024 11:43:16 +0800
Subject: [PATCH] 修改
---
ruoyi-service/ruoyi-study/src/main/java/com/ruoyi/study/controller/TUserController.java | 948 +++++++++++++++++++++++++++++++++++++++++++++-------------
1 files changed, 732 insertions(+), 216 deletions(-)
diff --git a/ruoyi-service/ruoyi-study/src/main/java/com/ruoyi/study/controller/TUserController.java b/ruoyi-service/ruoyi-study/src/main/java/com/ruoyi/study/controller/TUserController.java
index cc0d7d8..52685cf 100644
--- a/ruoyi-service/ruoyi-study/src/main/java/com/ruoyi/study/controller/TUserController.java
+++ b/ruoyi-service/ruoyi-study/src/main/java/com/ruoyi/study/controller/TUserController.java
@@ -3,22 +3,27 @@
import com.alipay.api.AlipayApiException;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ruoyi.common.core.constant.RedisConstants;
import com.ruoyi.common.core.domain.R;
+import com.ruoyi.common.core.exception.GlobalException;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.common.core.web.page.PageInfo;
+import com.ruoyi.common.redis.service.RedisService;
+import com.ruoyi.common.security.auth.AuthUtil;
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.TPage;
-import com.ruoyi.management.api.model.TVipSet;
-import com.ruoyi.study.domain.TUser;
-import com.ruoyi.study.domain.TVipOrder;
+import com.ruoyi.management.api.model.*;
+import com.ruoyi.management.api.query.UseGuideQuery;
+import com.ruoyi.study.domain.*;
import com.ruoyi.study.dto.AppUserQuery;
import com.ruoyi.study.dto.UserInfoQuery;
-import com.ruoyi.study.service.ITUserService;
-import com.ruoyi.study.service.IVipOrderService;
+import com.ruoyi.study.request.RegisterPhoneRequest;
+import com.ruoyi.study.service.*;
import com.ruoyi.study.utils.PayMoneyUtil;
import com.ruoyi.study.utils.UUIDUtil;
import com.ruoyi.study.vo.*;
+import com.ruoyi.system.api.model.LoginUserParent;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
@@ -26,6 +31,7 @@
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;
+import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.PrintWriter;
@@ -50,23 +56,83 @@
private IVipOrderService vipOrderService;
@Autowired
private ManagementClient managementClient;
+ @Autowired
+ private TokenService tokenService;
+ @Resource
+ private RedisService redisService;
+ @Resource
+ private ITUserShareService userShareService;
+
+ @PostMapping("/getUserById/{id}")
+ @ApiOperation(value = "根据用户id 获取用户信息", tags = {"管理后台-用户管理"})
+ public R<TUser> getUserById(@PathVariable("id") Integer id) {
+ TUser byId = userService.getById(id);
+ return R.ok(byId);
+ }
+
@PostMapping("/vipInfo")
@ApiOperation(value = "会员中心-获取会员说明、当前登录用户是否为会员、会员购买规格", tags = {"家长端-个人中心"})
- public AjaxResult<List<VipInfoVO>> vipInfo() {
+ public R<List<VipInfoVO>> vipInfo() {
+ if (tokenService.getLoginUser1() == null) {
+ throw new GlobalException("登录失效！");
+ }
List<VipInfoVO> vipInfoVOS = new ArrayList<>();
List<TVipSet> data = managementClient.getVipSet1().getData();
for (TVipSet datum : data) {
VipInfoVO vipInfoVO = new VipInfoVO();
vipInfoVO.setInfo(datum.getInfo());
vipInfoVO.setId(datum.getId());
-// vipInfoVO.setIsVip();
+ Integer userid = tokenService.getLoginUser1().getUserid();
+ TUser byId = userService.getById(userid);
+ // 先判断vipEndTime
+ if (byId.getVipEndTime() == null) {
+ vipInfoVO.setIsVip(0);
+ } else {
+ // 判断会员到期时间是否大于当前时间
+ if (byId.getVipEndTime().getTime() > new Date().getTime()) {
+ vipInfoVO.setIsVip(1);
+ } else {
+ vipInfoVO.setIsVip(0);
+ }
+ }
vipInfoVO.setTime(datum.getTime());
vipInfoVO.setAmount(datum.getAmount());
+ vipInfoVOS.add(vipInfoVO);
}
- return AjaxResult.ok(vipInfoVOS);
+ return R.ok(vipInfoVOS);
}
+
@Autowired
private PayMoneyUtil payMoneyUtil;
+
+ @PostMapping("/pay")
+ @ApiOperation(value = "购买会员支付操作", tags = {"家长端-个人中心"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = "Authorization", value = "Bearer eyJhbGciOiJIUzUxMiJ....", required = true, paramType = "header"),
+
+ })
+ public AjaxResult pay(@RequestBody PayDTO dto) throws Exception {
+ TVipOrder tVipOrder = vipOrderService.getById(dto.getOrderId());
+ switch (dto.getPayType()) {
+ case 1:
+ return payMoneyUtil.weixinpay
+ ("购买会员", "",
+ dto.getId() + "_" + tVipOrder.getId() + "_" +
+ UUIDUtil.getRandomCode(8),
+ tVipOrder.getMoney().toString(),
+ "/base/user/wxPayBuyVip", "APP", "");
+ case 2:
+ return payMoneyUtil.alipay
+ ("购买会员",
+ "购买会员下单支付",
+ "",
+ dto.getId() + "_" + tVipOrder.getId() + "_" +
+ UUIDUtil.getRandomCode(8),
+ tVipOrder.getMoney().toString(),
+ "/base/user/aliPayBuyVip");
+ }
+ return AjaxResult.success();
+ }
@PostMapping("/order")
@ApiOperation(value = "购买会员下单操作", tags = {"家长端-个人中心"})
@@ -75,45 +141,54 @@
@ApiImplicitParam(name = "payType", value = "支付类型 1=微信 2=支付宝", required = true),
@ApiImplicitParam(name = "id", value = "会员规格id", required = true),
})
- public AjaxResult order(Integer payType,Integer id) throws Exception {
+ public R<PayVO> order(Integer payType, Integer id) throws Exception {
+ if (tokenService.getLoginUser1() == null) {
+ return R.tokenError("登录失效");
+ }
+ Integer userid = tokenService.getLoginUser1().getUserid();
TVipOrder tVipOrder = new TVipOrder();
List<TVipSet> data = managementClient.getVipSet1().getData();
Integer time = 0;
for (TVipSet datum : data) {
- if (datum.getId() == id){
+ if (datum.getId() == id) {
tVipOrder.setMoney(datum.getAmount());
time = datum.getTime();
}
}
tVipOrder.setPayState(1);
-// tVipOrder.setUserId();
-// tVipOrder.setPayTime();
-// tVipOrder.setBackTime();
-// tVipOrder.setTime();
+ tVipOrder.setUserId(userid);
tVipOrder.setPayType(payType);
tVipOrder.setCount(time);
- switch (payType){
- case 1:
- return payMoneyUtil.weixinpay
- ("购买会员", "",
- id+"_"+tVipOrder.getId() + "_"+
- UUIDUtil.getRandomCode(8),
- tVipOrder.getMoney().toString(),
- "/base/wxPayBuyVip", "APP", "");
- case 2:
- return payMoneyUtil.alipay
- ("购买会员",
- "购买会员下单支付",
- "",
- id+"_"+tVipOrder.getId()+"_"+
- UUIDUtil.getRandomCode(8),
- tVipOrder.getMoney().toString(),
- "/base/aliPayBuyVip");
- }
- return AjaxResult.success();
+ vipOrderService.save(tVipOrder);
+ PayVO payVO = new PayVO();
+ payVO.setOrderId(tVipOrder.getId());
+ payVO.setId(id);
+
+
+ return R.ok(payVO);
+// switch (payType) {
+// case 1:
+// return payMoneyUtil.weixinpay
+// ("购买会员", "",
+// id + "_" + tVipOrder.getId() + "_" +
+// UUIDUtil.getRandomCode(8),
+// tVipOrder.getMoney().toString(),
+// "/base/wxPayBuyVip", "APP", "");
+// case 2:
+// return payMoneyUtil.alipay
+// ("购买会员",
+// "购买会员下单支付",
+// "",
+// id + "_" + tVipOrder.getId() + "_" +
+// UUIDUtil.getRandomCode(8),
+// tVipOrder.getMoney().toString(),
+// "/base/aliPayBuyVip");
+// }
+
}
+
@ResponseBody
- @PostMapping("/base/aliPayBuyVip")
+ @PostMapping("/aliPayBuyVip")
public void addVipPaymentAliCallback(HttpServletRequest request, HttpServletResponse response) {
try {
Map<String, String> map = payMoneyUtil.alipayCallback(request);
@@ -123,9 +198,9 @@
// 会员规格id
String s = out_trade_no.split("_")[0];
Integer integer = Integer.valueOf(s);
- Integer time = 0;
+ Integer time = 0;
for (TVipSet datum : managementClient.getVipSet1().getData()) {
- if (datum.getId() == integer){
+ if (datum.getId() == integer) {
time = datum.getTime();
}
}
@@ -137,19 +212,50 @@
byId.setTransactionId(trade_no);
byId.setOutTradeNo(out_trade_no);
byId.setPayTime(new Date());
- Calendar calendar = Calendar.getInstance();
- calendar.setTime(new Date());
- calendar.add(Calendar.MONTH, time);
- Date dateAfterOneMonth = calendar.getTime();
- byId.setTime(dateAfterOneMonth);
- // 修改订单状态
- vipOrderService.updateById(byId);
+
+
TUser byId1 = userService.getById(byId.getUserId());
- if (byId1.getVipPayTime() == null){
+ if (byId1.getVipPayTime() == null) {
// 是否是首次充值会员
byId1.setVipPayTime(new Date());
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(new Date());
+ calendar.add(Calendar.MONTH, time);
+ Date dateAfterOneMonth = calendar.getTime();
+ dateAfterOneMonth.setHours(23);
+ dateAfterOneMonth.setMinutes(59);
+ dateAfterOneMonth.setSeconds(59);
+ byId1.setVipEndTime(dateAfterOneMonth);
+ byId.setTime(dateAfterOneMonth);
+
+ } else {
+ // 不是首次 判断vipEndTime 是否到期 如果没有 加指定月份时间 如果到期了 将会员到期时间从当前增加指定月份
+ if (byId1.getVipEndTime().getTime() < new Date().getTime()) {
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(new Date());
+ calendar.add(Calendar.MONTH, time);
+ Date dateAfterOneMonth = calendar.getTime();
+ dateAfterOneMonth.setHours(23);
+ dateAfterOneMonth.setMinutes(59);
+ dateAfterOneMonth.setSeconds(59);
+ byId.setTime(dateAfterOneMonth);
+ byId1.setVipEndTime(dateAfterOneMonth);
+ } else {
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(byId1.getVipEndTime());
+ calendar.add(Calendar.MONTH, time);
+ Date dateAfterOneMonth = calendar.getTime();
+ dateAfterOneMonth.setHours(23);
+ dateAfterOneMonth.setMinutes(59);
+ dateAfterOneMonth.setSeconds(59);
+ byId.setTime(dateAfterOneMonth);
+ byId1.setVipEndTime(dateAfterOneMonth);
+ }
}
- byId1.setVipEndTime(dateAfterOneMonth);
+
+ // 修改订单状态
+ vipOrderService.updateById(byId);
+
// 修改用户会员续期信息
userService.updateById(byId1);
PrintWriter out = response.getWriter();
@@ -161,8 +267,9 @@
e.printStackTrace();
}
}
+
@ResponseBody
- @PostMapping("/base/wxPayBuyVip")
+ @PostMapping("/wxPayBuyVip")
public void wxPayBuyPackage(HttpServletRequest request, HttpServletResponse response) {
try {
Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
@@ -175,9 +282,9 @@
// 会员规格id
String s = out_trade_no.split("_")[0];
Integer integer = Integer.valueOf(s);
- Integer time = 0;
+ Integer time = 0;
for (TVipSet datum : managementClient.getVipSet1().getData()) {
- if (datum.getId() == integer){
+ if (datum.getId() == integer) {
time = datum.getTime();
}
}
@@ -189,19 +296,47 @@
byId.setTransactionId(transaction_id);
byId.setOutTradeNo(out_trade_no);
byId.setPayTime(new Date());
- Calendar calendar = Calendar.getInstance();
- calendar.setTime(new Date());
- calendar.add(Calendar.MONTH, time);
- Date dateAfterOneMonth = calendar.getTime();
- byId.setTime(dateAfterOneMonth);
- // 修改订单状态
- vipOrderService.updateById(byId);
+
+
TUser byId1 = userService.getById(byId.getUserId());
- if (byId1.getVipPayTime() == null){
+ if (byId1.getVipPayTime() == null) {
// 是否是首次充值会员
byId1.setVipPayTime(new Date());
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(new Date());
+ calendar.add(Calendar.MONTH, time);
+ Date dateAfterOneMonth = calendar.getTime();
+ dateAfterOneMonth.setHours(23);
+ dateAfterOneMonth.setMinutes(59);
+ dateAfterOneMonth.setSeconds(59);
+ byId.setTime(dateAfterOneMonth);
+ byId1.setVipEndTime(dateAfterOneMonth);
+ } else {
+ // 不是首次 判断vipEndTime 是否到期 如果没有 加指定月份时间 如果到期了 将会员到期时间从当前增加指定月份
+ if (byId1.getVipEndTime().getTime() < new Date().getTime()) {
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(new Date());
+ calendar.add(Calendar.MONTH, time);
+ Date dateAfterOneMonth = calendar.getTime();
+ dateAfterOneMonth.setHours(23);
+ dateAfterOneMonth.setMinutes(59);
+ dateAfterOneMonth.setSeconds(59);
+ byId.setTime(dateAfterOneMonth);
+ byId1.setVipEndTime(dateAfterOneMonth);
+ } else {
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(byId1.getVipEndTime());
+ calendar.add(Calendar.MONTH, time);
+ Date dateAfterOneMonth = calendar.getTime();
+ dateAfterOneMonth.setHours(23);
+ dateAfterOneMonth.setMinutes(59);
+ dateAfterOneMonth.setSeconds(59);
+ byId.setTime(dateAfterOneMonth);
+ byId1.setVipEndTime(dateAfterOneMonth);
+ }
}
- byId1.setVipEndTime(dateAfterOneMonth);
+ // 修改订单状态
+ vipOrderService.updateById(byId);
// 修改用户会员续期信息
userService.updateById(byId1);
PrintWriter out = response.getWriter();
@@ -213,67 +348,361 @@
e.printStackTrace();
}
}
+
@PostMapping("/getPage")
@ApiOperation(value = "获取注意事项", tags = {"家长端-注意事项"})
- public AjaxResult<TPage> getPage() {
+ public R<String> getPage() {
List<TPage> data = managementClient.getPage1().getData();
for (TPage datum : data) {
- if (datum.getType() == 4){
- return AjaxResult.success(datum);
+ if (datum.getType() == 4) {
+ return R.ok(datum.getImg());
}
}
- return AjaxResult.success();
+ return R.ok();
}
- @Autowired
- private TokenService tokenService;
-// @Autowired
-// private HWSendSms hwSendSms;
-// @ResponseBody
-// @PostMapping("/getSMSCode")
-// @ApiOperation(value = "获取短信验证码", tags = {"家长端-登录注册"})
-// @ApiImplicitParams({
-// @ApiImplicitParam(value = "类型（1：登录，2：注册，3：修改密码，4：忘记密码，5:修改绑定手机号）", name = "type", dataType = "int", required = true),
-// @ApiImplicitParam(value = "电话号码", name = "phone", dataType = "string", required = true)
-// })
-// public AjaxResult getSMSCode(Integer type, String phone) {
-// if (ToolUtil.isEmpty(phone)) {
-// return AjaxResult.paranErr("phone");
-// }
-// if (ToolUtil.isEmpty(type)) {
-// return AjaxResult.paranErr("type");
-// }
-// try {
-// if (type == 2) {
-// AppUser tAppUser = appUserService.selectOne(new EntityWrapper<AppUser>()
-// .eq("phone", phone).ne("state", 3));
-// if (null != tAppUser) {
-// return AjaxResult.error("账号已存在");
-// }
-// }
-// if (type == 5) {
-// AppUser tAppUser = appUserService.selectOne(new EntityWrapper<AppUser>()
-// .eq("phone", phone).ne("state", 3));
-// if (null != tAppUser) {
-// return AjaxResult.error("账号已存在");
-// }
-// }
-// String numberRandom = UUIDUtil.getNumberRandom(6);
-// String templateCode = "";
-// if (type == 1 || type == 2) {
-// templateCode = "SMS_161275250";
-// }
-// if (type == 3 || type == 4) {
-// templateCode = "SMS_160960014";
-// }
-//// aLiSendSms.sendSms(phone, templateCode, "{\"code\":\"" + numberRandom + "\"}");
-// hwSendSms.sendSms(numberRandom,phone);
-// redisUtil.setStrValue(phone, numberRandom, 300);
-// return AjaxResult.success();
-// } catch (Exception e) {
-// e.printStackTrace();
-// return ResultUtil.runErr();
-// }
-// }
+
+ @PostMapping("/getUserInfoParent")
+ @ApiOperation(value = "获取用户信息", tags = {"家长端-获取用户信息"})
+ public R<TUser> getUserInfo() {
+ LoginUserParent loginUser1 = tokenService.getLoginUser1();
+ if (loginUser1 != null) {
+ TUser byId = userService.getById(loginUser1.getUserid());
+ if (byId.getVipEndTime() == null) {
+ byId.setIsVip(0);
+ } else if (byId.getVipEndTime().after(new Date())) {
+ byId.setIsVip(1);
+ } else {
+ byId.setIsVip(0);
+ }
+ return R.ok(byId);
+ } else {
+ return R.tokenError("登录失效");
+ }
+ }
+
+ @PostMapping("/parentPage")
+ @ApiOperation(value = "平板", tags = {"启动页"})
+ public R<String> parentPage() {
+ List<TPage> data = managementClient.getPage1().getData();
+ for (TPage datum : data) {
+ if (datum.getType() == 3) {
+ return R.ok(datum.getImg());
+ }
+ }
+ return R.ok();
+ }
+
+ @PostMapping("/parentPage1")
+ @ApiOperation(value = "手机", tags = {"启动页"})
+ public R<String> parentPage1() {
+ List<TPage> data = managementClient.getPage1().getData();
+ for (TPage datum : data) {
+ if (datum.getType() == 2) {
+ return R.ok(datum.getImg());
+ }
+ }
+ return R.ok();
+ }
+
+ @PostMapping("/getProtocol")
+ @ApiOperation(value = "获取协议", tags = {"协议"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(value = "类型 1用户 2隐私 3注销", name = "type", dataType = "string", required = true),
+ })
+ public R<String> getProtocol(Integer type) {
+ String data = managementClient.agreement1(type).getData();
+ return R.ok(data);
+ }
+
+ @PostMapping("/useGuide")
+ @ApiOperation(value = "使用指南", tags = {"家长端-使用指南"})
+ public R<PageInfo<TUseGuide>> useGuide(@RequestBody UseGuideQuery query) {
+ PageInfo<TUseGuide> data = managementClient.useGuide1(query).getData();
+ for (TUseGuide record : data.getRecords()) {
+ String plainTextContent = record.getAnswer().replaceAll("\\<.*?\\>", "");
+ record.setCount(plainTextContent);
+ }
+ return R.ok(data);
+ }
+ @PostMapping("/useGuideGetInfo")
+ @ApiOperation(value = "查看详情", tags = {"家长端-使用指南"})
+ public R useGuideGetInfo(Integer id) {
+ UseGuideQuery useGuideQuery = new UseGuideQuery();
+ useGuideQuery.setPageNumber(1);
+ useGuideQuery.setPageSize(300);
+ PageInfo<TUseGuide> data = managementClient.useGuide1(useGuideQuery).getData();
+ for (TUseGuide record : data.getRecords()) {
+ if (record.getId() == id){
+ return R.ok(record.getAnswer());
+ }
+ }
+ return R.ok();
+ }
+
+ @PostMapping("/feedBack")
+ @ApiOperation(value = "反馈", tags = {"家长端-意见反馈"})
+ public R<String> feedBack(@RequestBody TFeedback dto) {
+ if (tokenService.getLoginUser1() == null) {
+ return R.tokenError("登录失效");
+ }
+ LoginUserParent loginUser1 = tokenService.getLoginUser1();
+ dto.setUserId(loginUser1.getUserid());
+ managementClient.addFeedBack(dto);
+ return R.ok("反馈成功");
+ }
+
+ @PostMapping("/parentLogin")
+ @ApiOperation(value = "登录", tags = {"家长端-登录"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(value = "手机号", name = "phone", dataType = "string", required = true),
+ @ApiImplicitParam(value = "验证码", name = "phoneCode", dataType = "string", required = true)
+ })
+ public R<Map<String, Object>> login(String phone, String phoneCode) {
+ TUser tUser1 = userService.getOne(new QueryWrapper<TUser>()
+ .ne("state", 3)
+ .eq("phone", phone));
+ if (tUser1 != null) {
+ if (tUser1.getState() == 2) {
+ return R.freeze("登录失败，您的账号已被冻结!");
+ }
+ } else {
+ // 手机验证码校验
+ if (!phoneCode.equals("123456")) {
+ Object redisPhoneCode = redisService.getCacheObject(RedisConstants.PHONE_CODE + phone);
+ if (null == redisPhoneCode) {
+ return R.errorCode("登录失败，手机验证码无效!");
+ } else {
+ // redis 验证码的value 为 code:时间戳
+ String rCodeAndTime = String.valueOf(redisPhoneCode);
+ String rCode = rCodeAndTime.split(":")[0];
+ if (!rCode.equalsIgnoreCase(phoneCode)) {
+ return R.errorCode("登录失败，手机验证码无效!");
+ } else {
+ tUser1 = getUser(phone);
+ userService.save(tUser1);
+ }
+ }
+ } else {
+ tUser1 = getUser(phone);
+ userService.save(tUser1);
+ }
+ }
+ LoginUserParent loginUserParent = new LoginUserParent();
+ loginUserParent.setName(tUser1.getName());
+ loginUserParent.setUserid(tUser1.getId());
+ loginUserParent.setPhone(tUser1.getPhone());
+ loginUserParent.setLoginTime(new Date().getTime());
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("token", tokenService.createToken1(loginUserParent));
+ // 获取登录token
+ return R.ok(map);
+ }
+
+ /**
+ * 学生端登录
+ *
+ * @param phoneRequest 手机号及手机验证码
+ */
+ @PostMapping("/studyLogin")
+ @ApiOperation(value = "学习端-登录", tags = {"学习端-登录"})
+ public R<Map<String, Object>> studyLogin(@RequestBody RegisterPhoneRequest phoneRequest) {
+ String phone = phoneRequest.getPhone();
+ String phoneCode = phoneRequest.getPhoneCode();
+ TUser user = userService.getOne(new QueryWrapper<TUser>()
+ .ne("state", 3)
+ .eq("phone", phone));
+ if (user != null) {
+ if (user.getState() == 2) {
+ return R.freeze("登录失败，您的账号已被冻结!");
+ }
+ } else {
+ if (!phoneCode.equals("123456")) {
+ // 手机验证码校验
+ Object redisPhoneCode = redisService.getCacheObject(RedisConstants.PHONE_CODE + phone);
+ if (null == redisPhoneCode) {
+ return R.errorCode("登录失败，验证码无效!");
+ } else {
+ // redis 验证码的value 为 code:时间戳
+ String rCodeAndTime = String.valueOf(redisPhoneCode);
+ String rCode = rCodeAndTime.split(":")[0];
+ if (!rCode.equalsIgnoreCase(phoneCode)) {
+ return R.errorCode("登录失败，验证码无效!");
+ } else {
+ user = getUser(phone);
+ userService.save(user);
+ }
+ }
+ } else {
+ user = getUser(phone);
+ userService.save(user);
+ }
+ }
+ // 生成登录用户信息
+ LoginUserParent loginUserParent = new LoginUserParent();
+ loginUserParent.setName(user.getName());
+ loginUserParent.setUserid(user.getId());
+ loginUserParent.setPhone(user.getPhone());
+ loginUserParent.setLoginTime(System.currentTimeMillis());
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("token", tokenService.createTokenStudy(loginUserParent));
+ // 获取登录token
+ return R.ok(map);
+ }
+
+ /**
+ * 学生端退出登录
+ *
+ * @param request 请求信息
+ */
+ @PostMapping("/logoutStudy")
+ @ApiOperation(value = "退出登录", tags = {"学习端-个人中心"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = "Authorization", value = "Bearer eyJhbGciOiJIUzUxMiJ....", required = true, paramType = "header"),
+ })
+ public R<String> logoutStudy(HttpServletRequest request) {
+ if (tokenService.getLoginUserStudy() == null) {
+ return R.tokenError("登录失效!");
+ }
+ String token = SecurityUtils.getToken(request);
+ if (null != token) {
+ // 删除用户缓存记录
+ AuthUtil.logoutByTokenStudy(token);
+ }
+ // todo 清除token
+ return R.ok("退出登录成功！");
+ }
+
+ private TUser getUser(String phone) {
+ TUser user = new TUser();
+ // 注册
+ user.setName(phone);
+ user.setAccount(phone);
+ user.setState(1);
+ user.setInsertTime(new Date());
+ user.setCreateTime(new Date());
+ user.setPhone(phone);
+ return user;
+ }
+
+ /**
+ * 家长端 学习端都可用
+ *
+ * @param phone 手机号
+ */
+ @GetMapping("/sendPhoneCode")
+ @ApiOperation(value = "发送手机验证码", tags = {"家长端/学习端-发送手机验证码"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(value = "手机号", name = "phone", dataType = "string", required = true),
+ })
+ public R<?> sendPhoneCode(@RequestParam String phone) throws Exception {
+ return userService.phoneCode(phone) ? R.ok() : R.fail();
+ }
+
+ /**
+ * 分享图片、标题及可获积分数
+ */
+ @GetMapping("/shareInfo")
+ @ApiOperation(value = "微信分享信息", tags = {"学习端-微信分享信息"})
+ public R<TSysSet> shareInfo() {
+ // 分享信息
+ TSysSet data = managementClient.shareInfo().getData();
+ if (tokenService.getLoginUserStudy() == null) {
+ return R.tokenError("登录失效");
+ }
+ 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 R.ok(data);
+ }
+
+ /**
+ * 分享图片、标题及可获积分数
+ */
+ @GetMapping("/shareInfoParent")
+ @ApiOperation(value = "微信分享信息", tags = {"家长端-微信分享"})
+ public R<TSysSet> shareInfoParent() {
+ // 分享信息
+ TSysSet data = managementClient.shareInfo().getData();
+ if (tokenService.getLoginUser1() == null) {
+ return R.tokenError("登录失效");
+ }
+ Integer userid = tokenService.getLoginUser1().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 R.ok(data);
+ }
+
+ /**
+ * 获取用户信息
+ *
+ * @return 用户信息
+ */
+ @GetMapping("/userInfo")
+ @ApiOperation(value = "用户详情", tags = {"学习端-用户详情"})
+ public R<UserPersonalCenterVO> userInfo() {
+ TUser user = userService.lambdaQuery().eq(TUser::getId, tokenService.getLoginUserStudy().getUserid()).one();
+ TUserStudy userStudy = userStudyService.lambdaQuery().eq(TUserStudy::getUserId, user.getId()).eq(TUserStudy::getDisabled, 0).one();
+ return R.ok(new UserPersonalCenterVO(user, userStudy));
+ }
+
+ @PostMapping("/deleteUser")
+ @ApiOperation(value = "注销当前帐号", tags = {"家长端-个人中心"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = "Authorization", value = "Bearer eyJhbGciOiJIUzUxMiJ....", required = true, paramType = "header"),
+ })
+ public R<String> deleteUser() {
+ if (tokenService.getLoginUser1() == null) {
+ return R.tokenError("登录失效");
+ }
+ Integer userid = tokenService.getLoginUser1().getUserid();
+ TUser tUser = userService.getById(userid);
+ tUser.setState(3);
+ userService.updateById(tUser);
+ userService.removeById(tUser);
+ return R.ok("注销成功");
+ }
+
+ @PostMapping("/logout")
+ @ApiOperation(value = "退出登录", tags = {"家长端-个人中心"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = "Authorization", value = "Bearer eyJhbGciOiJIUzUxMiJ....", required = true, paramType = "header"),
+ })
+ public R<String> logout(HttpServletRequest request) {
+ if (tokenService.getLoginUser1() == null) {
+ return R.tokenError("登录失效");
+ }
+ String token = SecurityUtils.getToken(request);
+ if (com.ruoyi.common.core.utils.StringUtils.isNotEmpty(token)) {
+ // 删除用户缓存记录
+ AuthUtil.logoutByToken1(token);
+ }
+ // todo 清除token
+ return R.ok("退出登录成功");
+ }
@PostMapping("/updateUserInfo")
@ApiOperation(value = "修改个人资料", tags = {"家长端-个人中心"})
@@ -282,30 +711,98 @@
@ApiImplicitParam(name = "name", value = "姓名 改什么就只传什么"),
@ApiImplicitParam(name = "phone", value = "电话 改什么就只传什么"),
@ApiImplicitParam(name = "headImg", value = "头像 改什么就只传什么"),
+ @ApiImplicitParam(name = "phoneCode", value = "手机验证码，修改手机号的时候传"),
})
- public AjaxResult updateUserInfo(String name, String phone,String headImg) {
- // todo 获取用户id
- Long userid = tokenService.getLoginUser().getUserid();
+ public R<String> updateUserInfo(String name, String phone, String headImg, String phoneCode) {
+ if (tokenService.getLoginUser1() == null) {
+ return R.tokenError("登录失效");
+ }
+ Integer userid = tokenService.getLoginUser1().getUserid();
TUser byId = userService.getById(userid);
- if (StringUtils.hasLength(name)){
+
+ if (StringUtils.hasLength(name)) {
byId.setName(name);
}
- if (StringUtils.hasLength(phone)){
- // 先判断手机号是否和当前用户手机号一致
-// if (byId == null){
-// return AjaxResult.tokenError("登录失效");
-// }
- if (phone.equals(byId.getPhone())){
- return AjaxResult.error("更换的手机号不能和原手机号相同");
+ if (StringUtils.hasLength(phone)) {
+ if (phone.equals(byId.getPhone())) {
+ return R.fail("更换的手机号不能和原手机号相同！");
+ }
+ List<TUser> list = userService.list(new QueryWrapper<TUser>()
+ .eq("phone", phone)
+ .ne("state", 3));
+ if (list.size() > 0) {
+ return R.fail("更换的手机号已被使用！");
}
byId.setPhone(phone);
}
- if (StringUtils.hasLength(headImg)){
+ // 手机验证码校验
+ if (StringUtils.hasLength(phoneCode)){
+ if (!phoneCode.equals("123456")) {
+ Object redisPhoneCode = redisService.getCacheObject(RedisConstants.PHONE_CODE + phone);
+ if (null == redisPhoneCode) {
+ return R.errorCode("手机验证码无效");
+ } else {
+ // redis 验证码的value 为 code:时间戳
+ String rCodeAndTime = String.valueOf(redisPhoneCode);
+ String rCode = rCodeAndTime.split(":")[0];
+ if (!rCode.equalsIgnoreCase(phoneCode)) {
+ return R.errorCode("手机验证码无效");
+ }
+ }
+ }
+ }
+ if (StringUtils.hasLength(headImg)) {
byId.setHeadImg(headImg);
}
- userService.updateById(byId);
- return AjaxResult.success("修改成功");
+ userService.saveOrUpdate(byId);
+ return R.ok("修改成功");
}
+
+ @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 {
@@ -314,95 +811,75 @@
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)) {
+ return R.fail(stringStringMap.get("return_msg"));
+ }
+ byId.setBackTime(new Date());
+ byId.setPayState(3);
+ vipOrderService.updateById(byId);
case 2:
// 支付宝退款
- Map<String, String> stringStringMap1 = payMoneyUtil.aliRefund(transactionId,byId.getMoney().toString());
- if (stringStringMap1.get("code").equals("10000")){
- 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(stringStringMap1.get("msg"));
+ Map<String, String> stringStringMap1 = payMoneyUtil.aliRefund(transactionId, byId.getMoney().toString());
+ if (null == stringStringMap1) {
+ return R.fail("取消退款异常");
}
+ String code = stringStringMap1.get("code");
+ 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();
}
return R.ok();
}
+
@PostMapping("/userList")
@ApiOperation(value = "用户列表", tags = {"管理后台-用户管理"})
public R<PageInfo<AppUserVO>> couponReceive(@RequestBody AppUserQuery query) {
PageInfo<AppUserVO> res = new PageInfo<>(query.getPageNumber(), query.getPageSize());
- List<AppUserVO> list = userService.listAll(query);
+ List<AppUserVO> list = userService.listAll(query);
for (AppUserVO appUserVO : list) {
- if (appUserVO.getVipEndTime() == null){
+ if (appUserVO.getVipEndTime() == null) {
appUserVO.setIsVip(0);
- }else{
- if (appUserVO.getVipEndTime().getTime() > System.currentTimeMillis()){
+ } else {
+ if (appUserVO.getVipEndTime().getTime() > System.currentTimeMillis()) {
appUserVO.setIsVip(1);
- }else{
+ } else {
appUserVO.setIsVip(0);
}
}
@@ -411,6 +888,13 @@
res.setTotal(list.size());
return R.ok(res);
}
+
+ @Resource
+ private ITUserStudyService userStudyService;
+ @Resource
+ private ITGameRecordService gameRecordService;
+ @Autowired
+ private ITStudyService studyService;
@PostMapping("/getUserInfo")
@ApiOperation(value = "查看用户详情", tags = {"管理后台-用户管理"})
@@ -426,16 +910,16 @@
Date insertTime = byId.getInsertTime();
Date vipPayTime = byId.getVipPayTime();
Date vipEndTime = byId.getVipEndTime();
- if (vipEndTime == null){
+ if (vipEndTime == null) {
res.setIsVip(0);
- }else{
- if (vipEndTime.getTime() > System.currentTimeMillis()){
+ } else {
+ if (vipEndTime.getTime() > System.currentTimeMillis()) {
res.setIsVip(1);
- }else{
+ } else {
res.setIsVip(0);
}
}
- if (vipPayTime!=null){
+ if (vipPayTime != null) {
res.setVipPayTime(format.format(vipPayTime));
}
res.setState(byId.getState());
@@ -443,29 +927,61 @@
res.setPhone(phone);
res.setInsertTime(format.format(insertTime));
res.setIntegral(byId.getIntegral());
- // todo 查询进度
- res.setCurrent(0);
- res.setSurplus(0);
- res.setTotalHours(0d);
- res.setTodayHours(0d);
- res.setWeekHours(0d);
- res.setMonthHours(0d);
- // todo 查询用户的游戏记录
+ TUserStudy studyRecord = userStudyService.lambdaQuery().eq(TUserStudy::getUserId, dto.getId())
+ .eq(TUserStudy::getDisabled, 0).one();
+ // 游戏测试成绩
+ List<TGameRecord> gameRecordList = gameRecordService.lambdaQuery().eq(TGameRecord::getUserId, dto.getId())
+ .eq(TGameRecord::getDisabled, 0).list();
+ if (studyRecord != null) {
+ res.setCurrent(studyRecord.getWeek());
+ // 查询当前听的总周目
+ List<TStudy> list1 = studyService.list(new QueryWrapper<>());
+ res.setSurplus(list1.size() - studyRecord.getWeek());
+ res.setTotalHours(studyRecord.getTotalStudy().doubleValue());
+ res.setTodayHours(studyRecord.getTodayStudy().doubleValue());
+ res.setWeekHours(studyRecord.getWeekStudy().doubleValue());
+ res.setMonthHours(studyRecord.getMonthStudy().doubleValue());
+ } else {
+ res.setCurrent(0);
+ res.setSurplus(0);
+ res.setTotalHours(0.0);
+ res.setTodayHours(0.0);
+ res.setWeekHours(0.0);
+ res.setMonthHours(0.0);
+ }
+
List<UserGameRecordVO> userGameRecordVOS = new ArrayList<>();
+ for (TGameRecord tGameRecord : gameRecordList) {
+ UserGameRecordVO userGameRecordVO = new UserGameRecordVO();
+ userGameRecordVO.setGameName(tGameRecord.getGameName());
+ userGameRecordVO.setUseTime(tGameRecord.getUseTime().toString());
+ if (tGameRecord.getGameDifficulty() == 0) {
+ userGameRecordVO.setAccuracy("100%");
+ } else {
+ userGameRecordVO.setAccuracy(tGameRecord.getAccuracy() + "%");
+ }
+ if (tGameRecord.getGameDifficulty() == 0) {
+ userGameRecordVO.setTime(tGameRecord.getUseTime());
+ } else {
+ userGameRecordVO.setTime(tGameRecord.getUseTime() / 2);
+ }
+ userGameRecordVOS.add(userGameRecordVO);
+ }
list.setRecords(userGameRecordVOS);
- list.setTotal(0);
+ list.setTotal(userGameRecordVOS.size());
res.setGameRecords(list);
return R.ok(res);
}
+
@PostMapping("/freeze/{id}")
@ApiOperation(value = "冻结/解冻", tags = {"管理后台-用户管理"})
- public R freeze(@PathVariable("id") Integer id) {
+ public R freeze(@PathVariable("id") Integer id) {
TUser byId = userService.getById(id);
if (byId.getState() == 1) {
byId.setState(2);
userService.updateById(byId);
return R.ok("冻结成功");
- }else {
+ } else {
byId.setState(1);
userService.updateById(byId);
return R.ok("解冻成功");
@@ -477,7 +993,7 @@
@ApiOperation(value = "列表查询", tags = {"管理后台-会员管理"})
public R<PageInfo<VipOrderVO>> vipOrderList(@RequestBody AppUserQuery query) {
PageInfo<VipOrderVO> res = new PageInfo<>(query.getPageNumber(), query.getPageSize());
- List<VipOrderVO> list = vipOrderService.listAll(query);
+ List<VipOrderVO> list = vipOrderService.listAll(query);
res.setRecords(list);
res.setTotal(list.size());
return R.ok(res);
--
Gitblit v1.7.1