BJ_ZTEITS-Developers / parking-cloud-yudao

Commit 9d262e8e7fd8f7bc731683f9f905b4047ab9505f

Authored by xiaqing
1 parent db1f4430

新增两个APP端接口 

1.获取用户个人签到信息
2.用户签到接接口
Inline Side-by-side
Showing 10 changed files with 245 additions and 16 deletions
yudao-module-member/yudao-module-member-api/src/main/java/cn/iocoder/yudao/module/member/enums/ErrorCodeConstants.java
  View file @9d262e8
... ... @@ -32,6 +32,6 @@ public interface ErrorCodeConstants {
32 32  
33 33 ErrorCode RECORD_NOT_EXISTS = new ErrorCode( 1004005005, "用户积分记录不存在");
34 34  
35   - ErrorCode SIGN_IN_RECORD_NOT_EXISTS = new ErrorCode(1004005006, "用户签到积分不存在");
  35 + ErrorCode SIGN_IN_RECORD_EXISTS = new ErrorCode(1004005006, "用户重复签到");
36 36  
37 37 }
... ...
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/controller/app/signin/AppMemberSignInController.java 0 → 100644
  View file @9d262e8
  1 +package cn.iocoder.yudao.module.member.controller.app.signin;
  2 +
  3 +import cn.iocoder.yudao.framework.common.pojo.CommonResult;
  4 +import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
  5 +import cn.iocoder.yudao.module.member.convert.signin.MemberSignInRecordConvert;
  6 +import cn.iocoder.yudao.module.member.dal.dataobject.signin.MemberSignInRecordDO;
  7 +import cn.iocoder.yudao.module.member.service.signin.MemberSignInRecordService;
  8 +import io.swagger.v3.oas.annotations.Operation;
  9 +import io.swagger.v3.oas.annotations.tags.Tag;
  10 +import org.springframework.web.bind.annotation.GetMapping;
  11 +import org.springframework.web.bind.annotation.PostMapping;
  12 +import org.springframework.web.bind.annotation.RequestMapping;
  13 +import org.springframework.web.bind.annotation.RestController;
  14 +
  15 +import javax.annotation.Resource;
  16 +
  17 +/**
  18 + * 描述 :用户签到相关信息接口
  19 + * Author :xiaqing
  20 + * Date :2023-09-15 09:02
  21 + */
  22 +@Tag(name = "签到APP - 签到")
  23 +@RestController
  24 +@RequestMapping("/member/signin")
  25 +public class AppMemberSignInController {
  26 +
  27 + @Resource
  28 + MemberSignInRecordService signInRecordService;
  29 +
  30 + /**
  31 + * 描述 :获取个人签到信息
  32 + * Author :xiaqing
  33 + * Date :2023-09-15 12:56:47
  34 + */
  35 +
  36 + @Operation(summary = "个人签到信息")
  37 + @GetMapping("/get-summary")
  38 + public CommonResult getUserSummary(){
  39 + return CommonResult.success(signInRecordService.getUserSummary(SecurityFrameworkUtils.getLoginUserId()));
  40 + }
  41 +
  42 +
  43 + /**
  44 + * 描述 :用户签到
  45 + * Author :xiaqing
  46 + * Date :2023-09-15 09:20:58
  47 + */
  48 + @Operation(summary = "会员签到")
  49 + @PostMapping("/create")
  50 + public CommonResult create(){
  51 + MemberSignInRecordDO recordDO = signInRecordService.create(SecurityFrameworkUtils.getLoginUserId());
  52 + return CommonResult.success(MemberSignInRecordConvert.INSTANCE.coverRecordToAppRecordVo(recordDO));
  53 + }
  54 +
  55 +}
... ...
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/controller/app/signin/vo/AppMemberSignInRecordRespVO.java 0 → 100644
  View file @9d262e8
  1 +package cn.iocoder.yudao.module.member.controller.app.signin.vo;
  2 +
  3 +import io.swagger.v3.oas.annotations.media.Schema;
  4 +import lombok.Data;
  5 +
  6 +import java.time.LocalDateTime;
  7 +
  8 +@Schema(description = "用户签到积分 Response VO")
  9 +@Data
  10 +public class AppMemberSignInRecordRespVO {
  11 +
  12 + @Schema(description = "第几天签到", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
  13 + private Integer day;
  14 +
  15 + @Schema(description = "签到的分数", requiredMode = Schema.RequiredMode.REQUIRED, example = "10")
  16 + private Integer point;
  17 +
  18 + @Schema(description = "签到时间", requiredMode = Schema.RequiredMode.REQUIRED)
  19 + private LocalDateTime createTime;
  20 +
  21 +}
... ...
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/controller/app/signin/vo/AppMemberSignInSummaryRespVO.java 0 → 100644
  View file @9d262e8
  1 +package cn.iocoder.yudao.module.member.controller.app.signin.vo;
  2 +
  3 +import io.swagger.v3.oas.annotations.media.Schema;
  4 +import lombok.Data;
  5 +
  6 +import java.time.LocalDateTime;
  7 +
  8 +@Schema(description = "用户签到统计信息 Response VO")
  9 +@Data
  10 +public class AppMemberSignInSummaryRespVO {
  11 +
  12 + @Schema(description = "持续签到天数", requiredMode = Schema.RequiredMode.REQUIRED, example = "5")
  13 + private Integer continuousDay;
  14 +
  15 + @Schema(description = "总签到天数", requiredMode = Schema.RequiredMode.REQUIRED, example = "10")
  16 + private Integer totalDay;
  17 +
  18 + @Schema(description = "当天是否签到", requiredMode = Schema.RequiredMode.REQUIRED,example = "true")
  19 + private Boolean todaySignIn ;
  20 +
  21 +}
... ...
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/convert/signin/MemberSignInRecordConvert.java
  View file @9d262e8
... ... @@ -4,6 +4,7 @@ import cn.iocoder.yudao.framework.common.pojo.PageResult;
4 4 import cn.iocoder.yudao.framework.common.util.collection.MapUtils;
5 5 import cn.iocoder.yudao.module.member.api.user.dto.MemberUserRespDTO;
6 6 import cn.iocoder.yudao.module.member.controller.admin.signin.vo.record.MemberSignInRecordRespVO;
  7 +import cn.iocoder.yudao.module.member.controller.app.signin.vo.AppMemberSignInRecordRespVO;
7 8 import cn.iocoder.yudao.module.member.dal.dataobject.signin.MemberSignInRecordDO;
8 9 import org.mapstruct.Mapper;
9 10 import org.mapstruct.factory.Mappers;
... ... @@ -33,4 +34,6 @@ public interface MemberSignInRecordConvert {
33 34 }
34 35 PageResult<MemberSignInRecordRespVO> convertPage(PageResult<MemberSignInRecordDO> pageResult);
35 36  
  37 + AppMemberSignInRecordRespVO coverRecordToAppRecordVo(MemberSignInRecordDO memberSignInRecordDO);
  38 +
36 39 }
... ...
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/dal/mysql/signin/MemberSignInConfigMapper.java
  View file @9d262e8
1 1 package cn.iocoder.yudao.module.member.dal.mysql.signin;
2 2  
3 3 import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
4   -import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
5 4 import cn.iocoder.yudao.module.member.dal.dataobject.signin.MemberSignInConfigDO;
6   -import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
7 5 import org.apache.ibatis.annotations.Mapper;
8 6  
9   -import java.util.List;
10   -
11 7 /**
12 8 * 积分签到规则 Mapper
13 9 *
... ...
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/dal/mysql/signin/MemberSignInRecordMapper.java
  View file @9d262e8
... ... @@ -7,6 +7,7 @@ import cn.iocoder.yudao.module.member.controller.admin.signin.vo.record.MemberSi
7 7 import cn.iocoder.yudao.module.member.dal.dataobject.signin.MemberSignInRecordDO;
8 8 import org.apache.ibatis.annotations.Mapper;
9 9  
  10 +import java.util.List;
10 11 import java.util.Set;
11 12  
12 13 /**
... ... @@ -25,4 +26,12 @@ public interface MemberSignInRecordMapper extends BaseMapperX&lt;MemberSignInRecord
25 26 .orderByDesc(MemberSignInRecordDO::getId));
26 27 }
27 28  
  29 +
  30 + //获取用户的签到记录列表信息,根据签到时间倒序
  31 + default List<MemberSignInRecordDO> selectListByUserId(Long userId){
  32 + return selectList(new LambdaQueryWrapperX <MemberSignInRecordDO>()
  33 + .eq(MemberSignInRecordDO::getUserId, userId)
  34 + .orderByDesc(MemberSignInRecordDO::getCreateTime));
  35 + }
  36 +
28 37 }
... ...
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/signin/MemberSignInRecordService.java
  View file @9d262e8
... ... @@ -2,6 +2,8 @@ package cn.iocoder.yudao.module.member.service.signin;
2 2  
3 3 import cn.iocoder.yudao.framework.common.pojo.PageResult;
4 4 import cn.iocoder.yudao.module.member.controller.admin.signin.vo.record.MemberSignInRecordPageReqVO;
  5 +import cn.iocoder.yudao.module.member.controller.app.signin.vo.AppMemberSignInRecordRespVO;
  6 +import cn.iocoder.yudao.module.member.controller.app.signin.vo.AppMemberSignInSummaryRespVO;
5 7 import cn.iocoder.yudao.module.member.dal.dataobject.signin.MemberSignInRecordDO;
6 8  
7 9 /**
... ... @@ -19,4 +21,18 @@ public interface MemberSignInRecordService {
19 21 */
20 22 PageResult<MemberSignInRecordDO> getSignInRecordPage(MemberSignInRecordPageReqVO pageReqVO);
21 23  
  24 +
  25 + MemberSignInRecordDO create(Long userId);
  26 +
  27 + /**
  28 + *
  29 + *功能描述: 根据用户id获取个人签到信息
  30 + * @param userId
  31 + * @return
  32 + * @author xiaqing
  33 + * @date 2023-09-15 14:21:01
  34 + */
  35 + AppMemberSignInSummaryRespVO getUserSummary(Long userId);
  36 +
  37 +
22 38 }
... ...
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/signin/MemberSignInRecordServiceImpl.java
  View file @9d262e8
1 1 package cn.iocoder.yudao.module.member.service.signin;
2 2  
3 3 import cn.iocoder.yudao.framework.common.pojo.PageResult;
  4 +import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
4 5 import cn.iocoder.yudao.module.member.api.user.MemberUserApi;
5 6 import cn.iocoder.yudao.module.member.api.user.dto.MemberUserRespDTO;
6 7 import cn.iocoder.yudao.module.member.controller.admin.signin.vo.record.MemberSignInRecordPageReqVO;
  8 +import cn.iocoder.yudao.module.member.controller.app.signin.vo.AppMemberSignInSummaryRespVO;
  9 +import cn.iocoder.yudao.module.member.dal.dataobject.signin.MemberSignInConfigDO;
7 10 import cn.iocoder.yudao.module.member.dal.dataobject.signin.MemberSignInRecordDO;
  11 +import cn.iocoder.yudao.module.member.dal.mysql.signin.MemberSignInConfigMapper;
8 12 import cn.iocoder.yudao.module.member.dal.mysql.signin.MemberSignInRecordMapper;
  13 +import cn.iocoder.yudao.module.member.enums.ErrorCodeConstants;
9 14 import org.apache.commons.lang3.StringUtils;
10 15 import org.springframework.stereotype.Service;
11 16 import org.springframework.util.CollectionUtils;
12 17 import org.springframework.validation.annotation.Validated;
13 18  
14 19 import javax.annotation.Resource;
  20 +import java.time.LocalDate;
  21 +import java.time.temporal.ChronoUnit;
15 22 import java.util.List;
16 23 import java.util.Set;
17 24  
  25 +import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
18 26 import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
19 27  
20 28 /**
... ... @@ -28,16 +36,62 @@ public class MemberSignInRecordServiceImpl implements MemberSignInRecordService
28 36  
29 37 @Resource
30 38 private MemberSignInRecordMapper signInRecordMapper;
31   -
  39 + @Resource
  40 + private MemberSignInConfigMapper signInConfigMapper;
32 41 @Resource
33 42 private MemberUserApi memberUserApi;
34 43  
  44 +
35 45 @Override
36   - public PageResult<MemberSignInRecordDO> getSignInRecordPage(MemberSignInRecordPageReqVO pageReqVO) {
  46 + public AppMemberSignInSummaryRespVO getUserSummary(Long userId) {
  47 + AppMemberSignInSummaryRespVO vo = new AppMemberSignInSummaryRespVO();
  48 + vo.setTotalDay(0);
  49 + vo.setContinuousDay(0);
  50 + vo.setTodaySignIn(false);
  51 + //获取用户签到的记录，按照天数倒序获取
  52 + List <MemberSignInRecordDO> signInRecordDOList = signInRecordMapper.selectListByUserId(userId);
  53 + if(!CollectionUtils.isEmpty(signInRecordDOList)){
  54 + //设置总签到天数
  55 + vo.setTotalDay(signInRecordDOList.size());
  56 + //判断当天是否有签到复用校验方法
  57 + try {
  58 + validSignDay(signInRecordDOList.get(0));
  59 + vo.setTodaySignIn(false);
  60 + }catch (Exception e){
  61 + vo.setTodaySignIn(true);
  62 + }
  63 + //如果当天签到了则说明连续签到天数有意义，否则直接用默认值0
  64 + if(vo.getTodaySignIn()){
  65 + //下方计算连续签到从2天开始，此处直接设置一天连续签到
  66 + vo.setContinuousDay(1);
  67 + //判断连续签到天数
  68 + for (int i = 1; i < signInRecordDOList.size(); i++) {
  69 + //前一天减1等于当前天数则说明连续，继续循环
  70 + LocalDate cur = signInRecordDOList.get(i).getCreateTime().toLocalDate();
  71 + LocalDate pre = signInRecordDOList.get(i-1).getCreateTime().toLocalDate();
  72 + if(1==daysBetween(cur,pre)){
  73 + vo.setContinuousDay(i+1);
  74 + }else{
  75 + break;
  76 + }
  77 + }
  78 + }
  79 +
  80 +
  81 + }
  82 + return vo;
  83 + }
  84 +
  85 + private long daysBetween(LocalDate date1,LocalDate date2){
  86 + return ChronoUnit.DAYS.between(date1, date2);
  87 + }
  88 +
  89 + @Override
  90 + public PageResult <MemberSignInRecordDO> getSignInRecordPage(MemberSignInRecordPageReqVO pageReqVO) {
37 91 // 根据用户昵称查询出用户ids
38   - Set<Long> userIds = null;
  92 + Set <Long> userIds = null;
39 93 if (StringUtils.isNotBlank(pageReqVO.getNickname())) {
40   - List<MemberUserRespDTO> users = memberUserApi.getUserListByNickname(pageReqVO.getNickname());
  94 + List <MemberUserRespDTO> users = memberUserApi.getUserListByNickname(pageReqVO.getNickname());
41 95 // 如果查询用户结果为空直接返回无需继续查询
42 96 if (CollectionUtils.isEmpty(users)) {
43 97 return PageResult.empty();
... ... @@ -47,4 +101,58 @@ public class MemberSignInRecordServiceImpl implements MemberSignInRecordService
47 101 return signInRecordMapper.selectPage(pageReqVO, userIds);
48 102 }
49 103  
  104 + @Override
  105 + public MemberSignInRecordDO create(Long userId) {
  106 + //获取当前用户签到的最大天数
  107 + MemberSignInRecordDO maxSignDay = signInRecordMapper.selectOne(new LambdaQueryWrapperX <MemberSignInRecordDO>()
  108 + .eq(MemberSignInRecordDO::getUserId, userId)
  109 + .orderByDesc(MemberSignInRecordDO::getDay)
  110 + .last("limit 1"));
  111 + //判断是否重复签到
  112 + validSignDay(maxSignDay);
  113 +
  114 + /**1.查询出当前签到的天数**/
  115 + MemberSignInRecordDO sign = new MemberSignInRecordDO();
  116 + sign.setUserId(userId);
  117 + //设置签到初始化天数
  118 + sign.setDay(1);
  119 + //设置签到分数默认为0
  120 + sign.setPoint(0);
  121 + //如果不为空则修改当前签到对应的天数
  122 + if (maxSignDay != null) {
  123 + sign.setDay(maxSignDay.getDay() + 1);
  124 + }
  125 + /**2.获取签到对应的分数**/
  126 + //获取所有的签到规则，按照天数排序，只获取启用的
  127 + List <MemberSignInConfigDO> configDOList = signInConfigMapper.selectList(new LambdaQueryWrapperX <MemberSignInConfigDO>()
  128 + .eq(MemberSignInConfigDO::getEnable, 1)
  129 + .orderByAsc(MemberSignInConfigDO::getDay));
  130 + //如果签到的天数大于最大启用的规则天数，直接给最大签到的分数
  131 + MemberSignInConfigDO lastConfig = configDOList.get(configDOList.size() - 1);
  132 + if (sign.getDay() > lastConfig.getDay()) {
  133 + sign.setPoint(lastConfig.getPoint());
  134 + } else {
  135 + configDOList.forEach(el -> {
  136 + //循环匹配对应天数，设置对应分数
  137 + if (el.getDay() == sign.getDay()) {
  138 + sign.setPoint(el.getPoint());
  139 + }
  140 +
  141 + });
  142 + }
  143 +
  144 + //3.插入当前签到获取的分数
  145 + signInRecordMapper.insert(sign);
  146 + //4.返回给用户
  147 + return sign;
  148 + }
  149 +
  150 + void validSignDay(MemberSignInRecordDO signInRecordDO) {
  151 + if (signInRecordDO == null)
  152 + return;
  153 + LocalDate today = LocalDate.now();
  154 + if (today.equals(signInRecordDO.getCreateTime().toLocalDate())) {
  155 + throw exception(ErrorCodeConstants.SIGN_IN_RECORD_EXISTS);
  156 + }
  157 + }
50 158 }
... ...
yudao-server/src/main/resources/application-local.yaml
  View file @9d262e8
... ... @@ -44,31 +44,31 @@ spring:
44 44 primary: master
45 45 datasource:
46 46 master:
47   - name: ruoyi-vue-pro
48   - url: jdbc:mysql://127.0.0.1:3306/${spring.datasource.dynamic.datasource.master.name}?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true # MySQL Connector/J 8.X 连接的示例
  47 + name: mall
  48 + url: jdbc:mysql://10.211.55.5:3308/${spring.datasource.dynamic.datasource.slave.name}?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true # MySQL Connector/J 8.X 连接的示例
49 49 # url: jdbc:mysql://127.0.0.1:3306/${spring.datasource.dynamic.datasource.master.name}?useSSL=false&allowPublicKeyRetrieval=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=CTT # MySQL Connector/J 5.X 连接的示例
50 50 # url: jdbc:postgresql://127.0.0.1:5432/${spring.datasource.dynamic.datasource.master.name} # PostgreSQL 连接的示例
51 51 # url: jdbc:oracle:thin:@127.0.0.1:1521:xe # Oracle 连接的示例
52 52 # url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=${spring.datasource.dynamic.datasource.master.name} # SQLServer 连接的示例
53 53 username: root
54   - password: 123456
  54 + password: 1qaz!QAZ
55 55 # username: sa
56 56 # password: JSm:g(*%lU4ZAkz06cd52KqT3)i1?H7W
57 57 slave: # 模拟从库，可根据自己需要修改
58   - name: ruoyi-vue-pro
59   - url: jdbc:mysql://127.0.0.1:3306/${spring.datasource.dynamic.datasource.master.name}?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true # MySQL Connector/J 8.X 连接的示例
  58 + name: mall
  59 + url: jdbc:mysql://10.211.55.5:3308/${spring.datasource.dynamic.datasource.slave.name}?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true # MySQL Connector/J 8.X 连接的示例
60 60 # url: jdbc:mysql://127.0.0.1:3306/${spring.datasource.dynamic.datasource.slave.name}?useSSL=false&allowPublicKeyRetrieval=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=CTT # MySQL Connector/J 5.X 连接的示例
61 61 # url: jdbc:postgresql://127.0.0.1:5432/${spring.datasource.dynamic.datasource.slave.name} # PostgreSQL 连接的示例
62 62 # url: jdbc:oracle:thin:@127.0.0.1:1521:xe # Oracle 连接的示例
63 63 # url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=${spring.datasource.dynamic.datasource.slave.name} # SQLServer 连接的示例
64 64 username: root
65   - password: 123456
  65 + password: 1qaz!QAZ
66 66 # username: sa
67 67 # password: JSm:g(*%lU4ZAkz06cd52KqT3)i1?H7W
68 68  
69 69 # Redis 配置。Redisson 默认的配置足够使用，一般不需要进行调优
70 70 redis:
71   - host: 127.0.0.1 # 地址
  71 + host: 10.211.55.5 # 地址
72 72 port: 6379 # 端口
73 73 database: 0 # 数据库索引
74 74 # password: dev # 密码，建议生产环境开启
... ...