diff --git a/src/main/java/xuan/common/ApiResponse.java b/src/main/java/xuan/common/ApiResponse.java new file mode 100644 index 0000000..97ff91f --- /dev/null +++ b/src/main/java/xuan/common/ApiResponse.java @@ -0,0 +1,53 @@ +package xuan.common; + +public class ApiResponse { + + private boolean success; + private T data; + private String error; + private Integer code; + private Long timestamp; + + public ApiResponse() { + this.timestamp = System.currentTimeMillis(); + } + + public ApiResponse(boolean success, T data, String error, Integer code, Long timestamp) { + this.success = success; + this.data = data; + this.error = error; + this.code = code; + this.timestamp = timestamp; + } + + public static ApiResponse success(T data) { + return new ApiResponse<>(true, data, null, 200, System.currentTimeMillis()); + } + + public static ApiResponse success(String message) { + return new ApiResponse<>(true, null, message, 200, System.currentTimeMillis()); + } + + public static ApiResponse error(String message) { + return new ApiResponse<>(false, null, message, 500, System.currentTimeMillis()); + } + + public static ApiResponse error(String message, Integer code) { + return new ApiResponse<>(false, null, message, code, System.currentTimeMillis()); + } + + public boolean isSuccess() { return success; } + public void setSuccess(boolean success) { this.success = success; } + + public T getData() { return data; } + public void setData(T data) { this.data = data; } + + public String getError() { return error; } + public void setError(String error) { this.error = error; } + + public Integer getCode() { return code; } + public void setCode(Integer code) { this.code = code; } + + public Long getTimestamp() { return timestamp; } + public void setTimestamp(Long timestamp) { this.timestamp = timestamp; } +} diff --git a/src/main/java/xuan/dto/UpdateCoinsRequest.java b/src/main/java/xuan/dto/UpdateCoinsRequest.java new file mode 100644 index 0000000..6fca556 --- /dev/null +++ b/src/main/java/xuan/dto/UpdateCoinsRequest.java @@ -0,0 +1,21 @@ +package xuan.dto; + +import javax.validation.constraints.Min; +import javax.validation.constraints.NotBlank; +import javax.validation.constraints.NotNull; + +public class UpdateCoinsRequest { + + @NotBlank(message = "userId不能为空") + private String userId; + + @NotNull(message = "coins不能为空") + @Min(value = 0, message = "金币数不能小于0") + private Integer coins; + + public String getUserId() { return userId; } + public void setUserId(String userId) { this.userId = userId; } + + public Integer getCoins() { return coins; } + public void setCoins(Integer coins) { this.coins = coins; } +} diff --git a/src/main/java/xuan/dto/UpdatePhoneRequest.java b/src/main/java/xuan/dto/UpdatePhoneRequest.java new file mode 100644 index 0000000..79bdc69 --- /dev/null +++ b/src/main/java/xuan/dto/UpdatePhoneRequest.java @@ -0,0 +1,20 @@ +package xuan.dto; + +import javax.validation.constraints.NotBlank; +import javax.validation.constraints.Pattern; + +public class UpdatePhoneRequest { + + @NotBlank(message = "userId不能为空") + private String userId; + + @NotBlank(message = "手机号不能为空") + @Pattern(regexp = "^1[3-9]\\d{9}$", message = "手机号格式不正确") + private String phone; + + public String getUserId() { return userId; } + public void setUserId(String userId) { this.userId = userId; } + + public String getPhone() { return phone; } + public void setPhone(String phone) { this.phone = phone; } +} diff --git a/src/main/java/xuan/dto/UpdateVipRequest.java b/src/main/java/xuan/dto/UpdateVipRequest.java new file mode 100644 index 0000000..6ae2ced --- /dev/null +++ b/src/main/java/xuan/dto/UpdateVipRequest.java @@ -0,0 +1,23 @@ +package xuan.dto; + +import javax.validation.constraints.Max; +import javax.validation.constraints.Min; +import javax.validation.constraints.NotBlank; +import javax.validation.constraints.NotNull; + +public class UpdateVipRequest { + + @NotBlank(message = "userId不能为空") + private String userId; + + @NotNull(message = "vipLevel不能为空") + @Min(value = 0, message = "VIP等级不能小于0") + @Max(value = 10, message = "VIP等级不能大于10") + private Integer vipLevel; + + public String getUserId() { return userId; } + public void setUserId(String userId) { this.userId = userId; } + + public Integer getVipLevel() { return vipLevel; } + public void setVipLevel(Integer vipLevel) { this.vipLevel = vipLevel; } +} diff --git a/src/main/java/xuan/exception/GlobalExceptionHandler.java b/src/main/java/xuan/exception/GlobalExceptionHandler.java new file mode 100644 index 0000000..ff2f9a3 --- /dev/null +++ b/src/main/java/xuan/exception/GlobalExceptionHandler.java @@ -0,0 +1,62 @@ +package xuan.exception; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.http.HttpStatus; +import org.springframework.http.ResponseEntity; +import org.springframework.validation.FieldError; +import org.springframework.web.bind.MethodArgumentNotValidException; +import org.springframework.web.bind.annotation.ExceptionHandler; +import org.springframework.web.bind.annotation.RestControllerAdvice; +import xuan.common.ApiResponse; + +import javax.validation.ConstraintViolation; +import javax.validation.ConstraintViolationException; +import java.util.stream.Collectors; + +@RestControllerAdvice +public class GlobalExceptionHandler { + + private static final Logger logger = LoggerFactory.getLogger(GlobalExceptionHandler.class); + + @ExceptionHandler(Exception.class) + public ResponseEntity> handleException(Exception e) { + logger.error("系统异常", e); + return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR) + .body(ApiResponse.error("系统繁忙,请稍后重试")); + } + + @ExceptionHandler(MethodArgumentNotValidException.class) + public ResponseEntity> handleValidation(MethodArgumentNotValidException e) { + String message = e.getBindingResult().getFieldErrors().stream() + .map(FieldError::getDefaultMessage) + .collect(Collectors.joining(", ")); + logger.warn("参数验证失败: {}", message); + return ResponseEntity.badRequest() + .body(ApiResponse.error(message, 400)); + } + + @ExceptionHandler(ConstraintViolationException.class) + public ResponseEntity> handleConstraintViolation(ConstraintViolationException e) { + String message = e.getConstraintViolations().stream() + .map(ConstraintViolation::getMessage) + .collect(Collectors.joining(", ")); + logger.warn("参数验证失败: {}", message); + return ResponseEntity.badRequest() + .body(ApiResponse.error(message, 400)); + } + + @ExceptionHandler(IllegalArgumentException.class) + public ResponseEntity> handleIllegalArgument(IllegalArgumentException e) { + logger.warn("参数错误: {}", e.getMessage()); + return ResponseEntity.badRequest() + .body(ApiResponse.error(e.getMessage(), 400)); + } + + @ExceptionHandler(RuntimeException.class) + public ResponseEntity> handleRuntimeException(RuntimeException e) { + logger.error("运行时异常", e); + return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR) + .body(ApiResponse.error("操作失败,请稍后重试")); + } +} diff --git a/src/main/java/xuan/service/UserInfoService.java b/src/main/java/xuan/service/UserInfoService.java index 2f53ce5..f667861 100644 --- a/src/main/java/xuan/service/UserInfoService.java +++ b/src/main/java/xuan/service/UserInfoService.java @@ -54,6 +54,33 @@ public class UserInfoService { return null; } + public UserInfo addCoins(String userId, Integer amount) { + if (amount == null || amount <= 0) { + throw new IllegalArgumentException("金币数量必须大于0"); + } + UserInfo user = userInfoRepository.findByUserId(userId); + if (user != null) { + user.setCoins(user.getCoins() + amount); + return userInfoRepository.save(user); + } + return null; + } + + public UserInfo deductCoins(String userId, Integer amount) { + if (amount == null || amount <= 0) { + throw new IllegalArgumentException("金币数量必须大于0"); + } + UserInfo user = userInfoRepository.findByUserId(userId); + if (user != null) { + if (user.getCoins() < amount) { + throw new IllegalArgumentException("金币不足"); + } + user.setCoins(user.getCoins() - amount); + return userInfoRepository.save(user); + } + return null; + } + public UserInfo updatePhone(String userId, String phone) { UserInfo user = userInfoRepository.findByUserId(userId); if (user != null) {