Compare commits
36 Commits
feature-Ki
...
feature-in
| Author | SHA1 | Date | |
|---|---|---|---|
| a4faa11036 | |||
| 290db24bc4 | |||
| 31b0dffd68 | |||
| 31fd23afa8 | |||
| d8d46ab089 | |||
|
|
c83d86ad1a | ||
|
|
b12128fad6 | ||
|
|
212668ae1c | ||
|
|
a648ecad2a | ||
|
|
b8ec4a434d | ||
|
|
3bc00334ea | ||
| eb2b0cb999 | |||
| 30db5ad706 | |||
|
|
5151ccfacc | ||
|
|
ab2bde0517 | ||
|
|
c9cb410819 | ||
|
|
07a6b86d7d | ||
|
|
1cf9ba0aa9 | ||
|
|
6a68fefbd4 | ||
|
|
da66c3b048 | ||
|
|
a9730a8414 | ||
|
|
0da6cde202 | ||
|
|
59838e1f5b | ||
|
|
7601fbb3c0 | ||
|
|
170ce83fe1 | ||
|
|
aa16c30d57 | ||
|
|
8fdbad8bd5 | ||
|
|
a9598ba795 | ||
|
|
439b6789fa | ||
|
|
9c7afc4470 | ||
|
|
e92cd31c27 | ||
|
|
bd12c599b0 | ||
|
|
b5a15a3f01 | ||
|
|
039443dc0f | ||
| ae0cca5437 | |||
| c329eaef79 |
6
pom.xml
6
pom.xml
@@ -88,6 +88,12 @@
|
|||||||
<artifactId>spring-boot-starter-aop</artifactId>
|
<artifactId>spring-boot-starter-aop</artifactId>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- WebSocket 起步依赖 -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.springframework.boot</groupId>
|
||||||
|
<artifactId>spring-boot-starter-websocket</artifactId>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
<!-- 阿里云相关依赖 -->
|
<!-- 阿里云相关依赖 -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.aliyun.oss</groupId>
|
<groupId>com.aliyun.oss</groupId>
|
||||||
|
|||||||
@@ -4,11 +4,32 @@ import org.mybatis.spring.annotation.MapperScan;
|
|||||||
import org.springframework.boot.SpringApplication;
|
import org.springframework.boot.SpringApplication;
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||||
|
|
||||||
|
import java.io.BufferedReader;
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.io.InputStream;
|
||||||
|
import java.io.InputStreamReader;
|
||||||
|
|
||||||
@MapperScan("com.bao.dating.mapper")
|
@MapperScan("com.bao.dating.mapper")
|
||||||
@SpringBootApplication
|
@SpringBootApplication
|
||||||
public class DatingApplication {
|
public class DatingApplication {
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
SpringApplication.run(DatingApplication.class, args);
|
SpringApplication.run(DatingApplication.class, args);
|
||||||
|
// 读取并打印 ciallo.txt 文件内容
|
||||||
|
printCialloFile();
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
/**
|
||||||
|
* 读取并打印 ciallo.txt 文件内容
|
||||||
|
*/
|
||||||
|
private static void printCialloFile() {
|
||||||
|
try (InputStream inputStream = DatingApplication.class.getClassLoader().getResourceAsStream("ciallo.txt");
|
||||||
|
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) {
|
||||||
|
String line;
|
||||||
|
while ((line = reader.readLine()) != null) {
|
||||||
|
System.out.println(line);
|
||||||
|
}
|
||||||
|
} catch (IOException e) {
|
||||||
|
System.err.println("读取 ciallo.txt 文件时发生错误: " + e.getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,16 +0,0 @@
|
|||||||
package com.bao.dating.common;
|
|
||||||
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
/**
|
|
||||||
* 动态表
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
public class Post {
|
|
||||||
private Long post_id; // 动态ID
|
|
||||||
private String content; // 动态内容
|
|
||||||
private Long user_id; // 发布人ID
|
|
||||||
private LocalDateTime created_at; // 创建时间
|
|
||||||
}
|
|
||||||
@@ -75,6 +75,8 @@ public class SmsUtil {
|
|||||||
.setTemplateCode(templateCode != null ? templateCode : this.templateCode)
|
.setTemplateCode(templateCode != null ? templateCode : this.templateCode)
|
||||||
.setTemplateParam(templateParam);
|
.setTemplateParam(templateParam);
|
||||||
|
|
||||||
|
log.error("TemplateParam 实际值 = {}", templateParam);
|
||||||
|
|
||||||
SendSmsResponse response = client.sendSms(sendSmsRequest);
|
SendSmsResponse response = client.sendSms(sendSmsRequest);
|
||||||
|
|
||||||
if ("OK".equals(response.getBody().getCode())) {
|
if ("OK".equals(response.getBody().getCode())) {
|
||||||
@@ -145,6 +147,7 @@ public class SmsUtil {
|
|||||||
jsonBuilder.append("}");
|
jsonBuilder.append("}");
|
||||||
return sendSms(phoneNumber, templateCode, jsonBuilder.toString());
|
return sendSms(phoneNumber, templateCode, jsonBuilder.toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -29,7 +29,8 @@ public class WebConfig implements WebMvcConfigurer {
|
|||||||
.addPathPatterns("/**")
|
.addPathPatterns("/**")
|
||||||
// 忽略的接口
|
// 忽略的接口
|
||||||
.excludePathPatterns(
|
.excludePathPatterns(
|
||||||
"/user/login"
|
"/user/login",
|
||||||
|
"/user/sendCode"
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ import com.bao.dating.common.ResultCode;
|
|||||||
import com.bao.dating.context.UserContext;
|
import com.bao.dating.context.UserContext;
|
||||||
import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
|
import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
|
||||||
import com.bao.dating.pojo.dto.UserLoginDTO;
|
import com.bao.dating.pojo.dto.UserLoginDTO;
|
||||||
|
import com.bao.dating.pojo.entity.User;
|
||||||
import com.bao.dating.pojo.vo.UserInfoVO;
|
import com.bao.dating.pojo.vo.UserInfoVO;
|
||||||
import com.bao.dating.pojo.vo.UserLoginVO;
|
import com.bao.dating.pojo.vo.UserLoginVO;
|
||||||
import com.bao.dating.service.UserService;
|
import com.bao.dating.service.UserService;
|
||||||
@@ -14,7 +15,9 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|||||||
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.bind.annotation.*;
|
||||||
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartFile;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletRequest;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 用户接口
|
* 用户接口
|
||||||
@@ -65,7 +68,6 @@ public class UserController {
|
|||||||
* @param file 头像文件
|
* @param file 头像文件
|
||||||
* @return 上传后的文件URL列表
|
* @return 上传后的文件URL列表
|
||||||
*/
|
*/
|
||||||
@Log
|
|
||||||
@PostMapping(value = "/info/uploadAvatar", consumes = "multipart/form-data")
|
@PostMapping(value = "/info/uploadAvatar", consumes = "multipart/form-data")
|
||||||
public Result<String> uploadAvatar(@RequestParam("file") MultipartFile file) {
|
public Result<String> uploadAvatar(@RequestParam("file") MultipartFile file) {
|
||||||
String fileUrl = userService.uploadAvatar(file);
|
String fileUrl = userService.uploadAvatar(file);
|
||||||
@@ -77,7 +79,6 @@ public class UserController {
|
|||||||
* @param file 背景文件
|
* @param file 背景文件
|
||||||
* @return 上传后的文件URL列表
|
* @return 上传后的文件URL列表
|
||||||
*/
|
*/
|
||||||
@Log
|
|
||||||
@PostMapping(value = "/info/uploadBackground", consumes = "multipart/form-data")
|
@PostMapping(value = "/info/uploadBackground", consumes = "multipart/form-data")
|
||||||
public Result<String> uploadBackground(@RequestParam("file") MultipartFile file) {
|
public Result<String> uploadBackground(@RequestParam("file") MultipartFile file) {
|
||||||
String fileUrl = userService.uploadBackground(file);
|
String fileUrl = userService.uploadBackground(file);
|
||||||
@@ -89,7 +90,6 @@ public class UserController {
|
|||||||
* @param userInfoUpdateDTO 用户信息更新参数
|
* @param userInfoUpdateDTO 用户信息更新参数
|
||||||
* @return 更新后的用户信息
|
* @return 更新后的用户信息
|
||||||
*/
|
*/
|
||||||
@Log
|
|
||||||
@PostMapping("/info/update")
|
@PostMapping("/info/update")
|
||||||
public Result<UserInfoVO> userInfoUpdate(@RequestBody UserInfoUpdateDTO userInfoUpdateDTO) {
|
public Result<UserInfoVO> userInfoUpdate(@RequestBody UserInfoUpdateDTO userInfoUpdateDTO) {
|
||||||
Long userId = UserContext.getUserId();
|
Long userId = UserContext.getUserId();
|
||||||
@@ -97,4 +97,71 @@ public class UserController {
|
|||||||
UserInfoVO userInfoVO =userService.updateUserInfo(userInfoUpdateDTO);
|
UserInfoVO userInfoVO =userService.updateUserInfo(userInfoUpdateDTO);
|
||||||
return Result.success(ResultCode.SUCCESS, "用户信息更新成功", userInfoVO);
|
return Result.success(ResultCode.SUCCESS, "用户信息更新成功", userInfoVO);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PostMapping("/sendCode")
|
||||||
|
public Result sendCode(@RequestBody Map<String, String> body) {
|
||||||
|
String phone = body.get("phone");
|
||||||
|
userService.sendSmsCode(phone);
|
||||||
|
return Result.success(ResultCode.SUCCESS, "验证码发送成功");
|
||||||
|
}
|
||||||
|
|
||||||
|
@PostMapping("/loginByCode")
|
||||||
|
public Result loginByCode(@RequestBody Map<String, String> body){
|
||||||
|
boolean ok = userService.verifyCode(body.get("phone"), body.get("code"));
|
||||||
|
return ok ? Result.success(ResultCode.SUCCESS, "登录成功") : Result.error(ResultCode.SYSTEM_ERROR, "登录失败");
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 登录
|
||||||
|
* @param body 登录参数
|
||||||
|
*/
|
||||||
|
@PostMapping("/loginPhone")
|
||||||
|
public Result<?> loginPhone(@RequestBody Map<String, String> body) {
|
||||||
|
String phone = body.get("phone");
|
||||||
|
String code = body.get("code");
|
||||||
|
|
||||||
|
//校验验证码
|
||||||
|
boolean verify = userService.verifyCode(phone, code);
|
||||||
|
if (!verify){
|
||||||
|
return Result.error(ResultCode.SYSTEM_ERROR, "验证码错误或已过期");
|
||||||
|
}
|
||||||
|
//登录
|
||||||
|
UserLoginVO vo = userService.loginByPhone(phone);
|
||||||
|
return Result.success(ResultCode.SUCCESS, "登录成功", vo);
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/nearby")
|
||||||
|
public Result<List<UserInfoVO>> nearby(@RequestParam(defaultValue = "5") double distance){
|
||||||
|
// 获取当前线程的用户 ID
|
||||||
|
Long userId = UserContext.getUserId();
|
||||||
|
if (userId == null) {
|
||||||
|
return Result.error(ResultCode.SYSTEM_ERROR, "用户未登录");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 通过 UserID 获取当前用户的经纬度信息
|
||||||
|
UserInfoVO currentUser = userService.getUserInfo(userId);
|
||||||
|
if (currentUser == null) {
|
||||||
|
return Result.error(ResultCode.SYSTEM_ERROR, "用户信息获取失败");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获取当前用户的经纬度
|
||||||
|
Double latitude = currentUser.getLatitude();
|
||||||
|
Double longitude = currentUser.getLongitude();
|
||||||
|
|
||||||
|
// 检查经纬度是否为空
|
||||||
|
if (latitude == null || longitude == null) {
|
||||||
|
return Result.error(ResultCode.SYSTEM_ERROR, "用户经纬度信息未完善");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 这里可以添加默认值,比如如果 latitude 或 longitude 为 null,则设置为某个默认值(例如 0)
|
||||||
|
latitude = (latitude != null) ? latitude : 0.0;
|
||||||
|
longitude = (longitude != null) ? longitude : 0.0;
|
||||||
|
|
||||||
|
// 查询附近用户
|
||||||
|
List<UserInfoVO> nearbyUsers = userService.findNearbyUsers(latitude, longitude, distance);
|
||||||
|
|
||||||
|
// 返回成功结果
|
||||||
|
return Result.success(ResultCode.SUCCESS, "查询成功", nearbyUsers);
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -5,18 +5,18 @@ import com.bao.dating.pojo.entity.Comments;
|
|||||||
import org.apache.ibatis.annotations.*;
|
import org.apache.ibatis.annotations.*;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
@Mapper
|
||||||
public interface CommentsMapper {
|
public interface CommentsMapper {
|
||||||
// 添加评论
|
// 添加评论
|
||||||
@Insert("INSERT INTO comments(content, user_id, post_id, created_at) VALUES(#{content}, #{user_id}, #{post_id}, #{created_at})")
|
@Insert("INSERT INTO dating.comments(content, user_id, post_id, created_at) VALUES(#{content}, #{user_id}, #{post_id}, #{created_at})")
|
||||||
int addComment(Comments comments);
|
int addComment(Comments comments);
|
||||||
|
|
||||||
// 删除评论
|
// 删除评论
|
||||||
@Delete("DELETE FROM comments WHERE user_id = #{user_id}")
|
@Delete("DELETE FROM dating.comments WHERE user_id = #{user_id}")
|
||||||
int deleteComments(@Param("user_id") Long user_id);
|
int deleteComments(@Param("user_id") Long user_id);
|
||||||
|
|
||||||
// 根据动态ID查询评论列表
|
// 根据动态ID查询评论列表
|
||||||
@Select("SELECT * FROM comments WHERE post_id = #{post_id} ORDER BY created_at DESC")
|
@Select("SELECT * FROM dating.comments WHERE post_id = #{post_id} ORDER BY created_at DESC")
|
||||||
List<Comments> getCommentsByPostId(@Param("post_id") Long post_id);
|
List<Comments> getCommentsByPostId(@Param("post_id") Long post_id);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ import org.apache.ibatis.annotations.Param;
|
|||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
@Mapper
|
@Mapper
|
||||||
public interface PostFavoriteMapper {
|
public interface PostFavoriteMapper {
|
||||||
//查询当前已收藏所有用户
|
//查询当前已收藏所有用户
|
||||||
List<Long> selectUserIDByPostID(@Param("postId") Long postId);
|
List<Long> selectUserIDByPostID(@Param("postId") Long postId);
|
||||||
int addPostFavorite(PostFavorite postFavorite);
|
int addPostFavorite(PostFavorite postFavorite);
|
||||||
|
|||||||
@@ -2,7 +2,11 @@ package com.bao.dating.mapper;
|
|||||||
|
|
||||||
import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
|
import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
|
||||||
import com.bao.dating.pojo.entity.User;
|
import com.bao.dating.pojo.entity.User;
|
||||||
|
import com.bao.dating.pojo.vo.UserInfoVO;
|
||||||
import org.apache.ibatis.annotations.Mapper;
|
import org.apache.ibatis.annotations.Mapper;
|
||||||
|
import org.apache.ibatis.annotations.Param;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 用户Mapper
|
* 用户Mapper
|
||||||
@@ -33,4 +37,15 @@ public interface UserMapper {
|
|||||||
*/
|
*/
|
||||||
void updateUserInfoByUserId(UserInfoUpdateDTO userInfoUpdateDTO);
|
void updateUserInfoByUserId(UserInfoUpdateDTO userInfoUpdateDTO);
|
||||||
|
|
||||||
|
User selectByPhone(@Param("phone") String phone);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 根据经纬度范围查询用户
|
||||||
|
* @param minLat 最小纬度
|
||||||
|
* @param maxLat 最大纬度
|
||||||
|
* @param minLng 最小经度
|
||||||
|
* @param maxLng 最大经度
|
||||||
|
* @return 用户列表
|
||||||
|
*/
|
||||||
|
List<UserInfoVO> findByLatLngRange(@Param("minLat") double minLat, @Param("maxLat") double maxLat, @Param("minLng") double minLng, @Param("maxLng") double maxLng);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -43,4 +43,8 @@ public class User implements Serializable {
|
|||||||
private String userEmail;
|
private String userEmail;
|
||||||
|
|
||||||
private String userPhone;
|
private String userPhone;
|
||||||
|
|
||||||
|
private Double latitude; // 纬度
|
||||||
|
|
||||||
|
private Double longitude; // 经度
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -24,4 +24,6 @@ public class UserInfoVO implements Serializable {
|
|||||||
private String signature;
|
private String signature;
|
||||||
private LocalDateTime updatedAt;
|
private LocalDateTime updatedAt;
|
||||||
private LocalDateTime createdAt;
|
private LocalDateTime createdAt;
|
||||||
|
private Double latitude;
|
||||||
|
private Double longitude;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,10 +2,13 @@ package com.bao.dating.service;
|
|||||||
|
|
||||||
import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
|
import com.bao.dating.pojo.dto.UserInfoUpdateDTO;
|
||||||
import com.bao.dating.pojo.dto.UserLoginDTO;
|
import com.bao.dating.pojo.dto.UserLoginDTO;
|
||||||
|
import com.bao.dating.pojo.entity.User;
|
||||||
import com.bao.dating.pojo.vo.UserInfoVO;
|
import com.bao.dating.pojo.vo.UserInfoVO;
|
||||||
import com.bao.dating.pojo.vo.UserLoginVO;
|
import com.bao.dating.pojo.vo.UserLoginVO;
|
||||||
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartFile;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 用户服务接口
|
* 用户服务接口
|
||||||
* @author KilLze
|
* @author KilLze
|
||||||
@@ -52,4 +55,19 @@ public interface UserService {
|
|||||||
* @return 更新后的用户信息
|
* @return 更新后的用户信息
|
||||||
*/
|
*/
|
||||||
UserInfoVO updateUserInfo(UserInfoUpdateDTO userInfoUpdateDTO);
|
UserInfoVO updateUserInfo(UserInfoUpdateDTO userInfoUpdateDTO);
|
||||||
|
|
||||||
|
void sendSmsCode(String phone);
|
||||||
|
|
||||||
|
boolean verifyCode(String phone, String code);
|
||||||
|
|
||||||
|
UserLoginVO loginByPhone(String phone);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取指定经纬度范围内的用户
|
||||||
|
* @param lat 用户纬度
|
||||||
|
* @param lng 用户经度
|
||||||
|
* @param radiusKm 半径 km
|
||||||
|
* @return 用户列表
|
||||||
|
*/
|
||||||
|
List<UserInfoVO> findNearbyUsers(double lat,double lng,double radiusKm);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ package com.bao.dating.service.impl;
|
|||||||
import com.bao.dating.common.aliyun.AliOssUtil;
|
import com.bao.dating.common.aliyun.AliOssUtil;
|
||||||
import com.bao.dating.common.aliyun.GreenImageScan;
|
import com.bao.dating.common.aliyun.GreenImageScan;
|
||||||
import com.bao.dating.common.aliyun.GreenTextScan;
|
import com.bao.dating.common.aliyun.GreenTextScan;
|
||||||
|
import com.bao.dating.common.aliyun.SmsUtil;
|
||||||
import com.bao.dating.common.result.AliOssResult;
|
import com.bao.dating.common.result.AliOssResult;
|
||||||
import com.bao.dating.common.result.GreenAuditResult;
|
import com.bao.dating.common.result.GreenAuditResult;
|
||||||
import com.bao.dating.config.RedisConfig;
|
import com.bao.dating.config.RedisConfig;
|
||||||
@@ -14,6 +15,8 @@ import com.bao.dating.pojo.entity.User;
|
|||||||
import com.bao.dating.pojo.vo.UserInfoVO;
|
import com.bao.dating.pojo.vo.UserInfoVO;
|
||||||
import com.bao.dating.pojo.vo.UserLoginVO;
|
import com.bao.dating.pojo.vo.UserLoginVO;
|
||||||
import com.bao.dating.service.UserService;
|
import com.bao.dating.service.UserService;
|
||||||
|
import com.bao.dating.util.*;
|
||||||
|
import com.bao.dating.util.CodeUtil;
|
||||||
import com.bao.dating.util.FileUtil;
|
import com.bao.dating.util.FileUtil;
|
||||||
import com.bao.dating.util.JwtUtil;
|
import com.bao.dating.util.JwtUtil;
|
||||||
import com.bao.dating.util.MD5Util;
|
import com.bao.dating.util.MD5Util;
|
||||||
@@ -21,6 +24,7 @@ import io.jsonwebtoken.Claims;
|
|||||||
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.BeanUtils;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.data.redis.core.RedisTemplate;
|
||||||
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartFile;
|
||||||
|
|
||||||
@@ -37,6 +41,10 @@ import java.util.concurrent.TimeUnit;
|
|||||||
@Service
|
@Service
|
||||||
public class UserServiceImpl implements UserService {
|
public class UserServiceImpl implements UserService {
|
||||||
|
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private SmsUtil smsUtil;
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private AliOssUtil ossUtil;
|
private AliOssUtil ossUtil;
|
||||||
|
|
||||||
@@ -52,6 +60,9 @@ public class UserServiceImpl implements UserService {
|
|||||||
@Autowired
|
@Autowired
|
||||||
private UserMapper userMapper;
|
private UserMapper userMapper;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private StringRedisTemplate stringRedisTemplate;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 用户登录
|
* 用户登录
|
||||||
*
|
*
|
||||||
@@ -311,4 +322,85 @@ public class UserServiceImpl implements UserService {
|
|||||||
BeanUtils.copyProperties(updatedUser, userInfoVO);
|
BeanUtils.copyProperties(updatedUser, userInfoVO);
|
||||||
return userInfoVO;
|
return userInfoVO;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 发送短信验证码
|
||||||
|
@Override
|
||||||
|
public void sendSmsCode(String phone) {
|
||||||
|
//防刷:60 秒内只能发一次
|
||||||
|
String key = "sms:code:" + phone;
|
||||||
|
Boolean exists = stringRedisTemplate.hasKey(key);
|
||||||
|
if (Boolean.TRUE.equals(exists)){
|
||||||
|
throw new RuntimeException("请勿频繁发送验证码");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 生成验证码
|
||||||
|
String code = CodeUtil.generateCode();
|
||||||
|
// 发送短信
|
||||||
|
smsUtil.sendVerificationCode(phone, code);
|
||||||
|
//存 Redis(5分钟过期)
|
||||||
|
stringRedisTemplate.opsForValue()
|
||||||
|
.set(key,code, 5, TimeUnit.MINUTES);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 校验验证码
|
||||||
|
@Override
|
||||||
|
public boolean verifyCode(String phone, String code) {
|
||||||
|
|
||||||
|
String key = "sms:code:" + phone;
|
||||||
|
String realCode = stringRedisTemplate.opsForValue().get(key);
|
||||||
|
//过期,未发送
|
||||||
|
if (realCode ==null){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
//不匹配
|
||||||
|
if (!realCode.equals(code)){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
// 校验成功,删除验证码(一次性)
|
||||||
|
stringRedisTemplate.delete(key);
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public UserLoginVO loginByPhone(String phone) {
|
||||||
|
//根据手机号查询用户
|
||||||
|
User user = userMapper.selectByPhone(phone);
|
||||||
|
//创建token
|
||||||
|
String token = JwtUtil.generateToken(user.getUserId().toString());
|
||||||
|
//封装返回结果
|
||||||
|
UserLoginVO VO = new UserLoginVO();
|
||||||
|
VO.setUserId(user.getUserId());
|
||||||
|
VO.setToken(token);
|
||||||
|
return VO;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public List<UserInfoVO> findNearbyUsers(double lat, double lng, double radiusKm) {
|
||||||
|
//先用经纬度范围筛选(矩形框,提高性能)
|
||||||
|
double delta = radiusKm / 111.0; // 1° ≈ 111km
|
||||||
|
double minLat = lat - delta;// 最小纬度
|
||||||
|
double maxLat = lat + delta;// 最大纬度
|
||||||
|
double minLng = lng - delta;// 最小经度
|
||||||
|
double maxLng = lng + delta;// 最大经度
|
||||||
|
|
||||||
|
// 打印经纬度范围
|
||||||
|
System.out.println("Min Latitude: " + minLat + ", Max Latitude: " + maxLat);
|
||||||
|
System.out.println("Min Longitude: " + minLng + ", Max Longitude: " + maxLng);
|
||||||
|
|
||||||
|
List<UserInfoVO> byLatLngRange = userMapper.findByLatLngRange(minLat, maxLat, minLng, maxLng);
|
||||||
|
|
||||||
|
//精确计算距离,筛选在半径内的用户
|
||||||
|
List<UserInfoVO> result = new ArrayList<>();
|
||||||
|
for (UserInfoVO u:byLatLngRange){
|
||||||
|
// 检查用户是否有经纬度信息
|
||||||
|
if (u.getLatitude() != null && u.getLongitude() != null) {
|
||||||
|
double distance = DistanceUtil.calculate(lat, lng, u.getLatitude(), u.getLongitude());
|
||||||
|
if (distance <= radiusKm){
|
||||||
|
result.add(u);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
12
src/main/java/com/bao/dating/util/CodeUtil.java
Normal file
12
src/main/java/com/bao/dating/util/CodeUtil.java
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
package com.bao.dating.util;
|
||||||
|
|
||||||
|
import java.util.Random;
|
||||||
|
|
||||||
|
public class CodeUtil {
|
||||||
|
// 生成6位数字验证码
|
||||||
|
public static String generateCode() {
|
||||||
|
Random random = new Random();
|
||||||
|
int code=100000+random.nextInt(900000);
|
||||||
|
return String.valueOf(code);
|
||||||
|
}
|
||||||
|
}
|
||||||
29
src/main/java/com/bao/dating/util/DistanceUtil.java
Normal file
29
src/main/java/com/bao/dating/util/DistanceUtil.java
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
package com.bao.dating.util;
|
||||||
|
|
||||||
|
//Haversine 公式(标准写法)
|
||||||
|
|
||||||
|
public class DistanceUtil {
|
||||||
|
private static final double EARTH_RADIUS = 6371.0; // 地球半径 km
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 计算两点之间距离(单位:km)
|
||||||
|
*/
|
||||||
|
public static double calculate(
|
||||||
|
double lat1, double lon1,
|
||||||
|
double lat2, double lon2) {
|
||||||
|
|
||||||
|
double dLat = Math.toRadians(lat2 - lat1);
|
||||||
|
double dLon = Math.toRadians(lon2 - lon1);
|
||||||
|
|
||||||
|
lat1 = Math.toRadians(lat1);
|
||||||
|
lat2 = Math.toRadians(lat2);
|
||||||
|
|
||||||
|
double a = Math.sin(dLat / 2) * Math.sin(dLat / 2)
|
||||||
|
+ Math.cos(lat1) * Math.cos(lat2)
|
||||||
|
* Math.sin(dLon / 2) * Math.sin(dLon / 2);
|
||||||
|
|
||||||
|
double c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a));
|
||||||
|
|
||||||
|
return EARTH_RADIUS * c;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -9,7 +9,7 @@ import java.security.NoSuchAlgorithmException;
|
|||||||
* @author KilLze
|
* @author KilLze
|
||||||
*/
|
*/
|
||||||
public class MD5Util {
|
public class MD5Util {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 对字符串进行MD5加密
|
* 对字符串进行MD5加密
|
||||||
* @param input 待加密的字符串
|
* @param input 待加密的字符串
|
||||||
@@ -19,7 +19,7 @@ public class MD5Util {
|
|||||||
if (input == null || input.isEmpty()) {
|
if (input == null || input.isEmpty()) {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
MessageDigest md = MessageDigest.getInstance("MD5");
|
MessageDigest md = MessageDigest.getInstance("MD5");
|
||||||
byte[] digest = md.digest(input.getBytes());
|
byte[] digest = md.digest(input.getBytes());
|
||||||
@@ -28,7 +28,7 @@ public class MD5Util {
|
|||||||
throw new RuntimeException("MD5算法不可用", e);
|
throw new RuntimeException("MD5算法不可用", e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 对字符串进行MD5加密(带盐值)
|
* 对字符串进行MD5加密(带盐值)
|
||||||
* @param input 待加密的字符串
|
* @param input 待加密的字符串
|
||||||
@@ -44,7 +44,7 @@ public class MD5Util {
|
|||||||
}
|
}
|
||||||
return encrypt(input + salt);
|
return encrypt(input + salt);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 验证字符串与MD5值是否匹配
|
* 验证字符串与MD5值是否匹配
|
||||||
* @param input 原始字符串
|
* @param input 原始字符串
|
||||||
@@ -57,7 +57,7 @@ public class MD5Util {
|
|||||||
}
|
}
|
||||||
return encrypt(input).equalsIgnoreCase(md5Hash);
|
return encrypt(input).equalsIgnoreCase(md5Hash);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 验证字符串与MD5值是否匹配(带盐值)
|
* 验证字符串与MD5值是否匹配(带盐值)
|
||||||
* @param input 原始字符串
|
* @param input 原始字符串
|
||||||
@@ -74,7 +74,7 @@ public class MD5Util {
|
|||||||
}
|
}
|
||||||
return encryptWithSalt(input, salt).equalsIgnoreCase(md5Hash);
|
return encryptWithSalt(input, salt).equalsIgnoreCase(md5Hash);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 将字节数组转换为十六进制字符串
|
* 将字节数组转换为十六进制字符串
|
||||||
* @param bytes 字节数组
|
* @param bytes 字节数组
|
||||||
@@ -88,6 +88,3 @@ public class MD5Util {
|
|||||||
return sb.toString();
|
return sb.toString();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
9
src/main/resources/ciallo.txt
Normal file
9
src/main/resources/ciallo.txt
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
|
||||||
|
▄▄▄▄ ██ ▄▄▄▄ ▄▄▄▄ ▄▄ ▄▄
|
||||||
|
██▀▀▀▀█ ▀▀ ▀▀██ ▀▀██ ██ ▄▄ ██
|
||||||
|
██▀ ████ ▄█████▄ ██ ██ ▄████▄ ▄▄▄ ▄█▀ ▄█▀ ██ █▄ ▄▄▄█ ▀█▄ ▄▄▄▄
|
||||||
|
██ ██ ▀ ▄▄▄██ ██ ██ ██▀ ▀██ ▀ ▀▀▄▄ ▄ ██ ▄█▀ ██ ██ ██ ▄▄█▀▀▀ ██ █▀▀ ▀█▄ █▄
|
||||||
|
██▄ ██ ▄██▀▀▀██ ██ ██ ██ ██ ▀▀▀ ██ ▄█▄▄▄▄▄ ▀▀ ██ ██ ██ ▀▀█▄▄▄ ██ █▀ █ ▀▀████▀
|
||||||
|
██▄▄▄▄█ ▄▄▄██▄▄▄ ██▄▄▄███ ██▄▄▄ ██▄▄▄ ▀██▄▄██▀ ▀█▄ ▀▀▀▀▀▀▀▀ ██▄██▄██ ▀▀▀█ ▄█▀ █▀▀█
|
||||||
|
▀▀▀▀ ▀▀▀▀▀▀▀▀ ▀▀▀▀ ▀▀ ▀▀▀▀ ▀▀▀▀ ▀▀▀▀ ██ ▀▀▀ ▀▀▀ ██
|
||||||
|
▀▀ ▀▀
|
||||||
@@ -28,6 +28,8 @@
|
|||||||
<result property="signature" column="signature"/>
|
<result property="signature" column="signature"/>
|
||||||
<result property="createdAt" column="created_at"/>
|
<result property="createdAt" column="created_at"/>
|
||||||
<result property="updatedAt" column="updated_at"/>
|
<result property="updatedAt" column="updated_at"/>
|
||||||
|
<result property="latitude" column="user_latitude"/>
|
||||||
|
<result property="longitude" column="user_longitude"/>
|
||||||
</resultMap>
|
</resultMap>
|
||||||
<select id="selectByUserId" resultMap="UserResultMap">
|
<select id="selectByUserId" resultMap="UserResultMap">
|
||||||
SELECT
|
SELECT
|
||||||
@@ -41,8 +43,10 @@
|
|||||||
hobbies,
|
hobbies,
|
||||||
signature,
|
signature,
|
||||||
created_at,
|
created_at,
|
||||||
updated_at
|
updated_at,
|
||||||
FROM user WHERE user_id = #{userId}
|
user_latitude,
|
||||||
|
user_longitude
|
||||||
|
FROM dating.user WHERE user_id = #{userId}
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<!--根据ID更新动态-->
|
<!--根据ID更新动态-->
|
||||||
@@ -74,4 +78,41 @@
|
|||||||
</set>
|
</set>
|
||||||
WHERE user_id = #{userId}
|
WHERE user_id = #{userId}
|
||||||
</update>
|
</update>
|
||||||
|
|
||||||
|
<select id="selectByPhone" resultType="com.bao.dating.pojo.entity.User">
|
||||||
|
select * from dating.user where user_phone =#{phone}
|
||||||
|
</select>
|
||||||
|
<resultMap id="UserInfoVOResultMap" type="com.bao.dating.pojo.vo.UserInfoVO">
|
||||||
|
<id property="userId" column="user_id"/>
|
||||||
|
<result property="userName" column="user_name"/>
|
||||||
|
<result property="nickname" column="nickname"/>
|
||||||
|
<result property="avatarUrl" column="avatar_url"/>
|
||||||
|
<result property="backgroundUrl" column="background_url"/>
|
||||||
|
<result property="gender" column="gender"/>
|
||||||
|
<result property="birthday" column="birthday"/>
|
||||||
|
<result property="hobbies" column="hobbies" typeHandler="com.bao.dating.handler.ListToJsonTypeHandler"/>
|
||||||
|
<result property="signature" column="signature"/>
|
||||||
|
<result property="createdAt" column="created_at"/>
|
||||||
|
<result property="updatedAt" column="updated_at"/>
|
||||||
|
<result property="latitude" column="user_latitude"/>
|
||||||
|
<result property="longitude" column="user_longitude"/>
|
||||||
|
</resultMap>
|
||||||
|
|
||||||
|
<select id="findByLatLngRange" resultMap="UserInfoVOResultMap">
|
||||||
|
SELECT
|
||||||
|
user_id,
|
||||||
|
user_name,
|
||||||
|
nickname,
|
||||||
|
avatar_url,
|
||||||
|
background_url,
|
||||||
|
gender,
|
||||||
|
birthday,
|
||||||
|
hobbies,
|
||||||
|
signature,
|
||||||
|
created_at,
|
||||||
|
updated_at,
|
||||||
|
user_latitude,
|
||||||
|
user_longitude
|
||||||
|
FROM user WHERE user_latitude BETWEEN #{minLat} AND #{maxLat} AND user_longitude BETWEEN #{minLng} AND #{maxLng}
|
||||||
|
</select>
|
||||||
</mapper>
|
</mapper>
|
||||||
Reference in New Issue
Block a user