3 Commits

Author SHA1 Message Date
Xiang
4f07b22919 perf:场地日志 2026-03-25 10:51:20 +08:00
xiang
1634565e92 feat: 江南体育中心用户管理 2026-03-24 20:55:06 +08:00
Xiang
65114aca14 perf:新增页面查询的请求响应数据结构 2026-03-24 17:21:14 +08:00
19 changed files with 490 additions and 0 deletions

20
api/pom.xml Normal file
View File

@@ -0,0 +1,20 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.xiang.app</groupId>
<artifactId>xservice-cornucopia</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>api</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>

View File

@@ -0,0 +1,39 @@
package com.xiang.app.module.jntyzx.pojo.req;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
@Data
public class UserAddReq {
/**
* 用户名称
*/
@NotBlank(message = "用户名称不能为空")
private String name;
/**
* token
*/
@NotBlank(message = "token不能为空")
private String token;
/**
* wx openId
*/
@NotBlank(message = "openId不能为空")
private String openId;
/**
* 会员卡号
*/
@NotBlank(message = "会员卡号不能为空")
private String memberCardNo;
/**
* 状态 0:禁用 1:启用
*/
@NotNull(message = "用户状态不能为空")
private Integer status;
}

View File

@@ -0,0 +1,41 @@
package com.xiang.app.module.jntyzx.pojo.req;
import lombok.Data;
/**
* @Author: xiang
* @Date: 2026-03-24 16:40
*/
@Data
public class UserQueryReq {
/**
* 用户名称
*/
private String name;
/**
* wx openId
*/
private String openId;
/**
* 会员卡号
*/
private String memberCardNo;
/**
* 状态 0:禁用 1:启用
*/
private Integer status;
/**
* 是否可以下单 0:否 1:是
*/
private Integer isOrder;
/**
* 是否封禁 0:否 1:是
*/
private Integer isRestriction;
}

View File

@@ -0,0 +1,22 @@
package com.xiang.app.module.jntyzx.pojo.req;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
@Data
public class UserStatusUpdateReq {
/**
* 用户名称
*/
@NotBlank(message = "用户名称不能为空")
private String username;
/**
* status
*/
@NotNull(message = "状态不能为空")
private Integer status;
}

View File

@@ -0,0 +1,21 @@
package com.xiang.app.module.jntyzx.pojo.req;
import lombok.Data;
import javax.validation.constraints.NotBlank;
@Data
public class UserTokenUpdateReq {
/**
* 用户名称
*/
@NotBlank(message = "用户名称不能为空")
private String username;
/**
* token
*/
@NotBlank(message = "token不能为空")
private String token;
}

View File

@@ -0,0 +1,11 @@
package com.xiang.app.module.jntyzx.pojo.req;
import lombok.Data;
import javax.validation.constraints.NotBlank;
@Data
public class UsernameReq {
@NotBlank(message = "用户名称不能为空")
private String username;
}

View File

@@ -0,0 +1,64 @@
package com.xiang.app.module.jntyzx.pojo.resp;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
/**
* @Author: xiang
* @Date: 2026-03-24 16:40
*/
@Data
public class JtUserVo {
private Long userId;
/**
* 用户名称
*/
private String name;
/**
* token
*/
private String token;
/**
* wx:openId
*/
private String openId;
/**
* 账号状态:
* 状态(0:禁用 1:启用)
*/
private Integer status;
/**
* 修改时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd Hh:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd Hh:mm:ss")
private LocalDateTime updateTime;
/**
* 江南体育中心会员卡号
*/
private String memberCardNo;
/**
* 是否可以下单
*/
private Boolean isOrder;
/**
* 是否封禁
*/
private Boolean isRestriction;
/**
* 封禁结束时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd Hh:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd Hh:mm:ss")
private LocalDateTime restrictionDeadline;
/**
* 封禁缘由
*/
private String restrictionDesc;
}

View File

@@ -17,6 +17,7 @@
<modules> <modules>
<module>xservice-server</module> <module>xservice-server</module>
<module>xservice-core</module> <module>xservice-core</module>
<module>api</module>
</modules> </modules>
<properties> <properties>

View File

@@ -17,4 +17,11 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties> </properties>
<dependencies>
<dependency>
<groupId>com.xiang.app</groupId>
<artifactId>api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
</project> </project>

View File

@@ -0,0 +1,32 @@
package com.xiang.app.modules.jntyzx.converts;
import com.xiang.app.module.jntyzx.pojo.resp.JtUserVo;
import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO;
import org.mapstruct.Mapper;
import org.mapstruct.Mapping;
import org.mapstruct.Named;
import org.mapstruct.factory.Mappers;
import java.util.List;
import java.util.Objects;
@Mapper(componentModel = "spring")
public interface UserConverter {
UserConverter INSTANCE = Mappers.getMapper(UserConverter.class);
@Mapping(source = "id", target = "userId")
@Mapping(source = "isOrder", target = "isOrder", qualifiedByName = "isOrder")
@Mapping(source = "isRestriction", target = "isRestriction", qualifiedByName = "isRestrict")
JtUserVo convert(UserTokenInfoDO userTokenInfoDO);
List<JtUserVo> convert(List<UserTokenInfoDO> userTokenInfoDOs);
@Named("isOrder")
default Boolean isOrder(Integer value) {
return Objects.nonNull(value) && Objects.equals(value, 1);
}
@Named("isRestrict")
default Boolean isRestrict(Integer value) {
return Objects.nonNull(value) && Objects.equals(value, 0);
}
}

View File

@@ -54,4 +54,6 @@ public class UserTokenInfoDO {
*/ */
@TableField("is_restriction") @TableField("is_restriction")
private Integer isRestriction; private Integer isRestriction;
private LocalDateTime updateTime;
} }

View File

@@ -3,7 +3,11 @@ package com.xiang.app.modules.jntyzx.manage;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.xiang.app.modules.jntyzx.entity.pojo.UserRestrictionInfo; import com.xiang.app.modules.jntyzx.entity.pojo.UserRestrictionInfo;
import java.util.List;
public interface IUserRestrictionManage extends IService<UserRestrictionInfo> { public interface IUserRestrictionManage extends IService<UserRestrictionInfo> {
UserRestrictionInfo queryByUserId(Long userId); UserRestrictionInfo queryByUserId(Long userId);
List<UserRestrictionInfo> queryByIdList(List<Long> idList);
} }

View File

@@ -1,6 +1,8 @@
package com.xiang.app.modules.jntyzx.manage; package com.xiang.app.modules.jntyzx.manage;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.xiang.app.module.jntyzx.pojo.req.UserQueryReq;
import com.xiang.app.module.jntyzx.pojo.resp.JtUserVo;
import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO; import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO;
import java.util.List; import java.util.List;
@@ -15,4 +17,5 @@ public interface IUserTokenInfoManage extends IService<UserTokenInfoDO> {
List<UserTokenInfoDO> listCanOrder(); List<UserTokenInfoDO> listCanOrder();
List<UserTokenInfoDO> queryByList(UserQueryReq req);
} }

View File

@@ -7,6 +7,8 @@ import com.xiang.app.modules.jntyzx.entity.pojo.UserRestrictionInfo;
import com.xiang.app.modules.jntyzx.mapper.JntyzxUserRestrictionInfoMapper; import com.xiang.app.modules.jntyzx.mapper.JntyzxUserRestrictionInfoMapper;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.List;
@Service @Service
public class UserRestrictionManageImpl extends ServiceImpl<JntyzxUserRestrictionInfoMapper, UserRestrictionInfo> implements IUserRestrictionManage { public class UserRestrictionManageImpl extends ServiceImpl<JntyzxUserRestrictionInfoMapper, UserRestrictionInfo> implements IUserRestrictionManage {
@Override @Override
@@ -15,4 +17,11 @@ public class UserRestrictionManageImpl extends ServiceImpl<JntyzxUserRestriction
lambdaQueryWrapper.eq(UserRestrictionInfo::getUserId, userId); lambdaQueryWrapper.eq(UserRestrictionInfo::getUserId, userId);
return baseMapper.selectOne(lambdaQueryWrapper); return baseMapper.selectOne(lambdaQueryWrapper);
} }
@Override
public List<UserRestrictionInfo> queryByIdList(List<Long> idList) {
LambdaQueryWrapper<UserRestrictionInfo> lambdaQueryWrapper = Wrappers.lambdaQuery();
lambdaQueryWrapper.in(UserRestrictionInfo::getUserId, idList);
return baseMapper.selectList(lambdaQueryWrapper);
}
} }

View File

@@ -1,13 +1,16 @@
package com.xiang.app.modules.jntyzx.manage; package com.xiang.app.modules.jntyzx.manage;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xiang.app.module.jntyzx.pojo.req.UserQueryReq;
import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO; import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO;
import com.xiang.app.modules.jntyzx.mapper.JntyzxUserTokenInfoMapper; import com.xiang.app.modules.jntyzx.mapper.JntyzxUserTokenInfoMapper;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.List; import java.util.List;
import java.util.Objects;
/** /**
* @Author: xiang * @Author: xiang
@@ -27,6 +30,7 @@ public class UserTokenInfoManageImpl extends ServiceImpl<JntyzxUserTokenInfoMapp
LambdaQueryWrapper<UserTokenInfoDO> lambdaQueryWrapper = Wrappers.lambdaQuery(); LambdaQueryWrapper<UserTokenInfoDO> lambdaQueryWrapper = Wrappers.lambdaQuery();
lambdaQueryWrapper.eq(UserTokenInfoDO::getStatus, 1); lambdaQueryWrapper.eq(UserTokenInfoDO::getStatus, 1);
lambdaQueryWrapper.eq(UserTokenInfoDO::getName, name); lambdaQueryWrapper.eq(UserTokenInfoDO::getName, name);
lambdaQueryWrapper.last("limit 1");
return baseMapper.selectOne(lambdaQueryWrapper); return baseMapper.selectOne(lambdaQueryWrapper);
} }
@@ -38,4 +42,28 @@ public class UserTokenInfoManageImpl extends ServiceImpl<JntyzxUserTokenInfoMapp
lambdaQueryWrapper.eq(UserTokenInfoDO::getIsRestriction, 0); lambdaQueryWrapper.eq(UserTokenInfoDO::getIsRestriction, 0);
return baseMapper.selectList(lambdaQueryWrapper); return baseMapper.selectList(lambdaQueryWrapper);
} }
@Override
public List<UserTokenInfoDO> queryByList(UserQueryReq req) {
LambdaQueryWrapper<UserTokenInfoDO> lambdaQueryWrapper = Wrappers.lambdaQuery();
if (StringUtils.isNotBlank(req.getName())) {
lambdaQueryWrapper.like(UserTokenInfoDO::getName, req.getName());
}
if (StringUtils.isNotBlank(req.getOpenId())) {
lambdaQueryWrapper.eq(UserTokenInfoDO::getOpenId, req.getOpenId());
}
if (StringUtils.isNotBlank(req.getMemberCardNo())) {
lambdaQueryWrapper.eq(UserTokenInfoDO::getMemberCardNo, req.getMemberCardNo());
}
if (Objects.nonNull(req.getStatus())) {
lambdaQueryWrapper.eq(UserTokenInfoDO::getStatus, req.getStatus());
}
if (Objects.nonNull(req.getIsRestriction())) {
lambdaQueryWrapper.eq(UserTokenInfoDO::getIsRestriction, req.getIsRestriction());
}
if (Objects.nonNull(req.getIsOrder())) {
lambdaQueryWrapper.eq(UserTokenInfoDO::getIsOrder, req.getIsOrder());
}
return baseMapper.selectList(lambdaQueryWrapper);
}
} }

View File

@@ -1,7 +1,13 @@
package com.xiang.app.modules.jntyzx.service; package com.xiang.app.modules.jntyzx.service;
import com.xiang.app.module.jntyzx.pojo.req.UserAddReq;
import com.xiang.app.module.jntyzx.pojo.req.UserQueryReq;
import com.xiang.app.module.jntyzx.pojo.req.UsernameReq;
import com.xiang.app.module.jntyzx.pojo.resp.JtUserVo;
import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO; import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO;
import javax.validation.Valid;
import javax.validation.constraints.NotNull;
import java.util.List; import java.util.List;
/** /**
@@ -16,4 +22,14 @@ public interface IUserTokenInfoService {
boolean flushSingleToken(String name); boolean flushSingleToken(String name);
boolean flushToken(); boolean flushToken();
boolean updateTokenByName(String name, String token); boolean updateTokenByName(String name, String token);
List<JtUserVo> list(UserQueryReq req);
Boolean updateStatusByUserName(String username, Integer status);
Boolean refreshToken(String username);
Boolean save(UserAddReq req);
JtUserVo info(Long userId);
} }

View File

@@ -1,6 +1,12 @@
package com.xiang.app.modules.jntyzx.service.impl; package com.xiang.app.modules.jntyzx.service.impl;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.xiang.app.common.service.dingtalk.JtDingTalkFactory; import com.xiang.app.common.service.dingtalk.JtDingTalkFactory;
import com.xiang.app.module.jntyzx.pojo.req.UserAddReq;
import com.xiang.app.module.jntyzx.pojo.req.UserQueryReq;
import com.xiang.app.module.jntyzx.pojo.resp.JtUserVo;
import com.xiang.app.modules.jntyzx.converts.UserConverter;
import com.xiang.app.modules.jntyzx.entity.pojo.UserRestrictionInfo; import com.xiang.app.modules.jntyzx.entity.pojo.UserRestrictionInfo;
import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO; import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO;
import com.xiang.app.modules.jntyzx.entity.resp.JntyzxResponse; import com.xiang.app.modules.jntyzx.entity.resp.JntyzxResponse;
@@ -9,6 +15,7 @@ import com.xiang.app.modules.jntyzx.manage.IUserRestrictionManage;
import com.xiang.app.modules.jntyzx.manage.IUserTokenInfoManage; import com.xiang.app.modules.jntyzx.manage.IUserTokenInfoManage;
import com.xiang.app.modules.jntyzx.service.IJntyzxHttpService; import com.xiang.app.modules.jntyzx.service.IJntyzxHttpService;
import com.xiang.app.modules.jntyzx.service.IUserTokenInfoService; import com.xiang.app.modules.jntyzx.service.IUserTokenInfoService;
import com.xiang.xservice.basic.exception.BusinessException;
import com.xiang.xservice.basic.utils.DateUtils; import com.xiang.xservice.basic.utils.DateUtils;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@@ -16,8 +23,12 @@ import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.util.List; import java.util.List;
import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.function.Function;
import java.util.stream.Collectors;
/** /**
* @Author: xiang * @Author: xiang
@@ -32,6 +43,7 @@ public class UserTokenInfoServiceImpl implements IUserTokenInfoService {
private final IJntyzxHttpService jntyzxHttpService; private final IJntyzxHttpService jntyzxHttpService;
private final JtDingTalkFactory jtDingTalkFactory; private final JtDingTalkFactory jtDingTalkFactory;
private final IUserRestrictionManage userRestrictionManage; private final IUserRestrictionManage userRestrictionManage;
private final UserConverter userConverter;
@Override @Override
@@ -108,6 +120,97 @@ public class UserTokenInfoServiceImpl implements IUserTokenInfoService {
return flag; return flag;
} }
@Override
public List<JtUserVo> list(UserQueryReq req) {
List<UserTokenInfoDO> userTokenInfoDOS = userTokenInfoManage.queryByList(req);
if (CollectionUtils.isEmpty(userTokenInfoDOS)) {
return Lists.newArrayList();
}
List<Long> idList = userTokenInfoDOS.stream().map(UserTokenInfoDO::getId).toList();
List<UserRestrictionInfo> userRestrictionInfos = userRestrictionManage.queryByIdList(idList);
Map<Long, UserRestrictionInfo> userRestrictionInfoMap = Maps.newHashMap();
if (CollectionUtils.isNotEmpty(userRestrictionInfos)) {
userRestrictionInfoMap.putAll(
userRestrictionInfos.stream().collect(Collectors.toMap(
UserRestrictionInfo::getUserId, Function.identity(), (a, b) -> a)));
}
List<JtUserVo> jtUserVoList = userConverter.convert(userTokenInfoDOS);
jtUserVoList.forEach(item -> {
if (userRestrictionInfoMap.containsKey(item.getUserId())) {
UserRestrictionInfo userRestrictionInfo = userRestrictionInfoMap.get(item.getUserId());
if (Objects.nonNull(userRestrictionInfo)) {
if (userRestrictionInfo.getRestrictionDeadline().isAfter(LocalDateTime.now())) {
item.setRestrictionDeadline(userRestrictionInfo.getRestrictionDeadline());
item.setRestrictionDesc(userRestrictionInfo.getRestrictionDesc());
}
}
}
});
return jtUserVoList;
}
@Override
public Boolean updateStatusByUserName(String username, Integer status) {
if (StringUtils.isEmpty(username)) {
log.error("用户名为空");
return false;
}
UserTokenInfoDO userTokenInfoDO = userTokenInfoManage.getByName(username);
if (Objects.isNull(userTokenInfoDO)) {
throw new BusinessException("用户不存在!");
}
userTokenInfoDO.setStatus(status);
return userTokenInfoManage.updateById(userTokenInfoDO);
}
@Override
public Boolean refreshToken(String username) {
if (StringUtils.isEmpty(username)) {
log.error("用户名为空");
return false;
}
UserTokenInfoDO userTokenInfoDO = userTokenInfoManage.getByName(username);
if (Objects.isNull(userTokenInfoDO)) {
throw new BusinessException("用户不存在!");
}
return healthDeclaration(userTokenInfoDO);
}
@Override
public Boolean save(UserAddReq req) {
UserTokenInfoDO userTokenInfoDO = userTokenInfoManage.getByName(req.getName());
if (Objects.nonNull(userTokenInfoDO)) {
throw new BusinessException("用户名已存在!");
}
userTokenInfoDO = new UserTokenInfoDO();
userTokenInfoDO.setName(req.getName());
userTokenInfoDO.setToken(req.getToken());
userTokenInfoDO.setOpenId(req.getOpenId());
userTokenInfoDO.setStatus(req.getStatus());
userTokenInfoDO.setIsOrder(1);
userTokenInfoDO.setMemberCardNo(req.getMemberCardNo());
userTokenInfoDO.setIsRestriction(0);
userTokenInfoDO.setUpdateTime(LocalDateTime.now());
return userTokenInfoManage.save(userTokenInfoDO);
}
@Override
public JtUserVo info(Long userId) {
UserTokenInfoDO userTokenInfoDO = userTokenInfoManage.getById(userId);
if (Objects.isNull(userTokenInfoDO)) {
throw new BusinessException("用户不存在!");
}
JtUserVo jtUserVo = userConverter.convert(userTokenInfoDO);
UserRestrictionInfo userRestrictionInfo = userRestrictionManage.queryByUserId(userId);
if (Objects.nonNull(userRestrictionInfo)) {
if (userRestrictionInfo.getRestrictionDeadline().isAfter(LocalDateTime.now())) {
jtUserVo.setRestrictionDeadline(userRestrictionInfo.getRestrictionDeadline());
jtUserVo.setRestrictionDesc(userRestrictionInfo.getRestrictionDesc());
}
}
return jtUserVo;
}
/** /**
* 查询用户信息 * 查询用户信息
* *

View File

@@ -1,5 +1,6 @@
package com.xiang.app.schedule.jntyzx; package com.xiang.app.schedule.jntyzx;
import com.alibaba.fastjson.JSON;
import com.xiang.app.common.service.dingtalk.JtDingTalkFactory; import com.xiang.app.common.service.dingtalk.JtDingTalkFactory;
import com.xiang.app.modules.jntyzx.constants.RedisKeyConstant; import com.xiang.app.modules.jntyzx.constants.RedisKeyConstant;
import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO; import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO;
@@ -57,6 +58,7 @@ public class JtVenueSubscribeTask {
users.parallelStream().forEach(user -> { users.parallelStream().forEach(user -> {
try { try {
List<String> placeNameList = venueInfoMap.keySet().stream().sorted(Comparator.comparing(VenueInfoUtils::sortVenueInfo)).toList(); List<String> placeNameList = venueInfoMap.keySet().stream().sorted(Comparator.comparing(VenueInfoUtils::sortVenueInfo)).toList();
log.info("场地排序后的集合:{}", JSON.toJSONString(placeNameList));
for (String placeName : placeNameList) { for (String placeName : placeNameList) {
List<VenueInfoDO> venueInfoDOList = venueInfoMap.get(placeName); List<VenueInfoDO> venueInfoDOList = venueInfoMap.get(placeName);
for (int i = 0; i < 10; i++) { for (int i = 0; i < 10; i++) {

View File

@@ -0,0 +1,65 @@
package com.xiang.app.server.jntyzx;
import com.xiang.app.module.jntyzx.pojo.req.UserAddReq;
import com.xiang.app.module.jntyzx.pojo.req.UserQueryReq;
import com.xiang.app.module.jntyzx.pojo.req.UserStatusUpdateReq;
import com.xiang.app.module.jntyzx.pojo.req.UserTokenUpdateReq;
import com.xiang.app.module.jntyzx.pojo.req.UsernameReq;
import com.xiang.app.module.jntyzx.pojo.resp.JtUserVo;
import com.xiang.app.modules.jntyzx.service.IUserTokenInfoService;
import com.xiang.xservice.basic.common.resp.Result;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.validation.Valid;
import javax.validation.constraints.NotNull;
import java.util.List;
/**
* 江南体育中心用户管理控制器
*
* @Author: xiang
* @Date: 2026-03-24 16:38
*/
@RestController
@RequestMapping("/private/apps/jntyzx/user")
@RequiredArgsConstructor
public class UserTokenServer {
private final IUserTokenInfoService userTokenInfoService;
@PostMapping("/list")
public Result<List<JtUserVo>> list(@RequestBody @NotNull(message = "请求参数不能为空") @Valid UserQueryReq req) {
return Result.data(userTokenInfoService.list(req));
}
@GetMapping("/info/{id}")
public Result<JtUserVo> info(@PathVariable("id") Long userId) {
return Result.data(userTokenInfoService.info(userId));
}
@PostMapping("/updateToken")
public Result<Boolean> updateToken(@RequestBody @NotNull(message = "请求参数不能为空") @Valid UserTokenUpdateReq req) {
return Result.data(userTokenInfoService.updateTokenByName(req.getUsername(), req.getToken()));
}
@PostMapping("/updateStatus")
public Result<Boolean> updateStatus(@RequestBody @NotNull(message = "请求参数不能为空") @Valid UserStatusUpdateReq req) {
return Result.data(userTokenInfoService.updateStatusByUserName(req.getUsername(), req.getStatus()));
}
@PostMapping("/refreshToken")
public Result<Boolean> refreshToken(@RequestBody @NotNull(message = "请求参数不能为空") @Valid UsernameReq req) {
return Result.data(userTokenInfoService.refreshToken(req.getUsername()));
}
@PostMapping("/add")
public Result<Boolean> addUser(@RequestBody @NotNull(message = "请求参数不能为空") @Valid UserAddReq req) {
return Result.data(userTokenInfoService.save(req));
}
}