From 5962461d86cb6f1986e220ff36f18e6328e4b74d Mon Sep 17 00:00:00 2001 From: puzvv <1@> Date: Tue, 30 Dec 2025 19:44:05 +0800 Subject: [PATCH] =?UTF-8?q?=E9=85=8D=E7=BD=AE=E4=BA=86=E9=98=BF=E9=87=8Cos?= =?UTF-8?q?s=E5=AD=98=E5=82=A8=E6=A1=B6=E8=BF=9E=E6=8E=A5=EF=BC=8C?= =?UTF-8?q?=E5=AE=9E=E7=8E=B0=E4=BA=86=E6=96=87=E4=BB=B6=E4=B8=8A=E4=BC=A0?= =?UTF-8?q?=E5=8A=9F=E8=83=BD=EF=BC=8C=E7=8E=B0=E5=9C=A8=E5=89=8D=E7=AB=AF?= =?UTF-8?q?=E8=83=BD=E5=A4=9F=E6=AD=A3=E5=B8=B8=E4=B8=8A=E4=BC=A0=E5=9B=BE?= =?UTF-8?q?=E7=89=87=E5=88=B0oss=E5=B9=B6=E6=98=BE=E7=A4=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 6 +- .../Common/Utils/OSSUtil.java | 78 +++++ .../ai_spring_example/Controllers/Admin.java | 282 ------------------ .../ai_spring_example/Controllers/Auth.java | 87 ------ .../ai_spring_example/Controllers/Course.java | 193 ------------ .../Controllers/UploadController.java | 38 +++ .../Service/Impl/ProductServiceImpl.java | 12 +- src/main/resources/application.yaml | 10 +- 8 files changed, 137 insertions(+), 569 deletions(-) create mode 100644 src/main/java/icu/sunway/ai_spring_example/Common/Utils/OSSUtil.java delete mode 100644 src/main/java/icu/sunway/ai_spring_example/Controllers/Admin.java delete mode 100644 src/main/java/icu/sunway/ai_spring_example/Controllers/Auth.java delete mode 100644 src/main/java/icu/sunway/ai_spring_example/Controllers/Course.java create mode 100644 src/main/java/icu/sunway/ai_spring_example/Controllers/UploadController.java diff --git a/pom.xml b/pom.xml index a6fb3a7..dbb6027 100644 --- a/pom.xml +++ b/pom.xml @@ -61,7 +61,11 @@ org.springframework.boot spring-boot-starter-data-redis - + + com.aliyun.oss + aliyun-sdk-oss + 3.17.4 + org.projectlombok diff --git a/src/main/java/icu/sunway/ai_spring_example/Common/Utils/OSSUtil.java b/src/main/java/icu/sunway/ai_spring_example/Common/Utils/OSSUtil.java new file mode 100644 index 0000000..2300aa6 --- /dev/null +++ b/src/main/java/icu/sunway/ai_spring_example/Common/Utils/OSSUtil.java @@ -0,0 +1,78 @@ +package icu.sunway.ai_spring_example.Common.Utils; + +import com.aliyun.oss.OSS; +import com.aliyun.oss.OSSClientBuilder; +import com.aliyun.oss.model.PutObjectRequest; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Component; + +import java.io.InputStream; +import java.net.URL; +import java.time.LocalDate; +import java.util.Date; +import java.util.UUID; + +@Component +public class OSSUtil { + + @Value("${aliyun.oss.endpoint}") + private String endpoint; + @Value("${aliyun.oss.accessKeyId}") + private String accessKeyId; + @Value("${aliyun.oss.accessKeySecret}") + private String accessKeySecret; + @Value("${aliyun.oss.bucketName}") + private String bucketName; + @Value("${aliyun.oss.urlPrefix}") + private String urlPrefix; + + /** + * 生成预签名上传 URL（前端直传） + */ + public String generatePresignedUrl(String fileName) { + OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); + + String key = "images/" + LocalDate.now() + "/" + UUID.randomUUID() + getFileExtension(fileName); + Date expiration = new Date(System.currentTimeMillis() + 30 * 60 * 1000); // 30分钟过期 + + URL url = ossClient.generatePresignedUrl(bucketName, key, expiration); + ossClient.shutdown(); + + return url.toString(); + } + + /** + * 获取文件访问 URL + */ + public String getFileUrl(String fileName) { + String key = "images/" + LocalDate.now() + "/" + UUID.randomUUID() + getFileExtension(fileName); + return urlPrefix + key; + } + + /** + * 后端直接上传文件到 OSS + */ + public String uploadFile(String originalFilename, InputStream inputStream) { + OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); + + String key = "images/" + LocalDate.now() + "/" + UUID.randomUUID() + getFileExtension(originalFilename); + + try { + PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, key, inputStream); + ossClient.putObject(putObjectRequest); + return urlPrefix + key; + } finally { + ossClient.shutdown(); + } + } + + /** + * 获取文件扩展名 + */ + private String getFileExtension(String fileName) { + if (fileName == null || !fileName.contains(".")) { + return ""; + } + return fileName.substring(fileName.lastIndexOf(".")); + } +} \ No newline at end of file diff --git a/src/main/java/icu/sunway/ai_spring_example/Controllers/Admin.java b/src/main/java/icu/sunway/ai_spring_example/Controllers/Admin.java deleted file mode 100644 index 057b0da..0000000 --- a/src/main/java/icu/sunway/ai_spring_example/Controllers/Admin.java +++ /dev/null @@ -1,282 +0,0 @@ -package icu.sunway.ai_spring_example.Controllers; - -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import org.springframework.web.bind.annotation.DeleteMapping; -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.PutMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; - -import icu.sunway.ai_spring_example.Common.Response.ResponseEntity; - -/** - * 用户管理后台接口 - * 提供用户管理相关的功能 - */ -@RestController -public class Admin { - - /** - * 获取用户列表 - * - * @param params 查询参数，包含page、size、username、status等字段 - * @return 用户列表数据 - */ - @GetMapping("/admin/users") - public ResponseEntity getUserList(@RequestParam Map params) { - // 从Map中获取查询参数 - Integer page = Integer.valueOf((String) params.getOrDefault("page", "1")); - Integer size = Integer.valueOf((String) params.getOrDefault("size", "10")); - String username = (String) params.get("username"); - Integer status = params.get("status") != null ? Integer.valueOf((String) params.get("status")) : null; - - // TODO: 实现查询逻辑 - // 1. 根据条件查询用户列表 - // 2. 处理分页 - - // 模拟返回用户列表 - List> userList = List.of( - Map.of("id", 1, "username", "admin", "email", "admin@example.com", "status", 1, "role", "admin", - "createTime", "2023-01-01 10:00:00"), - Map.of("id", 2, "username", "user1", "email", "user1@example.com", "status", 1, "role", "user", - "createTime", "2023-01-02 10:00:00")); - - Map responseData = new HashMap<>(); - responseData.put("list", userList); - responseData.put("total", 2); - responseData.put("page", page); - responseData.put("size", size); - - return ResponseEntity.success("获取用户列表成功", responseData); - } - - /** - * 获取用户详情 - * - * @param userId 用户ID - * @return 用户详细信息 - */ - @GetMapping("/admin/users/{userId}") - public ResponseEntity getUserDetail(@PathVariable Long userId) { - // 参数验证 - if (userId == null) { - return ResponseEntity.error(400, "用户ID不能为空"); - } - - // TODO: 实现查询逻辑 - // 1. 根据用户ID查询用户信息 - // 2. 构建响应数据 - - // 模拟返回用户详情 - Map userInfo = Map.of( - "id", userId, "username", "admin", "email", "admin@example.com", "status", 1, - "role", "admin", "createTime", "2023-01-01 10:00:00", "updateTime", "2023-01-02 10:00:00"); - - return ResponseEntity.success("获取用户详情成功", userInfo); - } - - /** - * 创建新用户 - * - * @param userMap 用户信息，包含username、password、email、role等字段 - * @return 创建结果 - */ - @PostMapping("/admin/users") - public ResponseEntity createUser(@RequestBody Map userMap) { - // 从Map中获取用户信息 - String username = (String) userMap.get("username"); - String password = (String) userMap.get("password"); - String email = (String) userMap.get("email"); - String role = (String) userMap.get("role"); - Integer status = (Integer) userMap.get("status"); - - // 参数验证 - if (username == null || username.isEmpty()) { - return ResponseEntity.error(400, "用户名不能为空"); - } - if (password == null || password.isEmpty()) { - return ResponseEntity.error(400, "密码不能为空"); - } - if (email == null || email.isEmpty()) { - return ResponseEntity.error(400, "邮箱不能为空"); - } - if (role == null || role.isEmpty()) { - return ResponseEntity.error(400, "角色不能为空"); - } - - // TODO: 实现创建逻辑 - // 1. 检查用户名是否已存在 - // 2. 检查邮箱是否已存在 - // 3. 密码加密 - // 4. 保存用户信息 - - // 模拟创建成功 - Map responseData = new HashMap<>(); - responseData.put("id", 3); - responseData.put("username", username); - responseData.put("email", email); - - return ResponseEntity.success("创建用户成功", responseData); - } - - /** - * 更新用户信息 - * - * @param userId 用户ID - * @param userMap 用户更新信息 - * @return 更新结果 - */ - @PutMapping("/admin/users/{userId}") - public ResponseEntity updateUser(@PathVariable Long userId, @RequestBody Map userMap) { - // 参数验证 - if (userId == null) { - return ResponseEntity.error(400, "用户ID不能为空"); - } - - // 从Map中获取更新信息 - String email = (String) userMap.get("email"); - String role = (String) userMap.get("role"); - Integer status = (Integer) userMap.get("status"); - - // TODO: 实现更新逻辑 - // 1. 检查用户是否存在 - // 2. 更新用户信息 - - // 模拟更新成功 - Map responseData = new HashMap<>(); - responseData.put("id", userId); - responseData.put("email", email); - responseData.put("role", role); - responseData.put("status", status); - - return ResponseEntity.success("更新用户信息成功", responseData); - } - - /** - * 删除用户 - * - * @param userId 用户ID - * @return 删除结果 - */ - @DeleteMapping("/admin/users/{userId}") - public ResponseEntity deleteUser(@PathVariable Long userId) { - // 参数验证 - if (userId == null) { - return ResponseEntity.error(400, "用户ID不能为空"); - } - - // TODO: 实现删除逻辑 - // 1. 检查用户是否存在 - // 2. 删除用户信息 - - // 模拟删除成功 - return ResponseEntity.success("删除用户成功"); - } - - /** - * 修改用户密码 - * - * @param userId 用户ID - * @param passwordMap 密码信息，包含oldPassword和newPassword字段 - * @return 修改结果 - */ - @PutMapping("/admin/users/{userId}/password") - public ResponseEntity changeUserPassword(@PathVariable Long userId, - @RequestBody Map passwordMap) { - // 参数验证 - if (userId == null) { - return ResponseEntity.error(400, "用户ID不能为空"); - } - - // 从Map中获取密码信息 - String oldPassword = (String) passwordMap.get("oldPassword"); - String newPassword = (String) passwordMap.get("newPassword"); - - // 参数验证 - if (oldPassword == null || oldPassword.isEmpty()) { - return ResponseEntity.error(400, "旧密码不能为空"); - } - if (newPassword == null || newPassword.isEmpty()) { - return ResponseEntity.error(400, "新密码不能为空"); - } - - // TODO: 实现修改密码逻辑 - // 1. 检查用户是否存在 - // 2. 验证旧密码 - // 3. 更新新密码 - - // 模拟修改密码成功 - return ResponseEntity.success("修改密码成功"); - } - - /** - * 更新用户状态 - * - * @param userId 用户ID - * @param statusMap 状态信息，包含status字段 - * @return 更新结果 - */ - @PutMapping("/admin/users/{userId}/status") - public ResponseEntity updateUserStatus(@PathVariable Long userId, @RequestBody Map statusMap) { - // 参数验证 - if (userId == null) { - return ResponseEntity.error(400, "用户ID不能为空"); - } - - // 从Map中获取状态信息 - Integer status = (Integer) statusMap.get("status"); - - // 参数验证 - if (status == null) { - return ResponseEntity.error(400, "状态不能为空"); - } - if (status != 0 && status != 1) { - return ResponseEntity.error(400, "状态值只能是0或1"); - } - - // TODO: 实现更新状态逻辑 - // 1. 检查用户是否存在 - // 2. 更新用户状态 - - // 模拟更新状态成功 - Map responseData = new HashMap<>(); - responseData.put("id", userId); - responseData.put("status", status); - - return ResponseEntity.success("更新用户状态成功", responseData); - } - - /** - * 批量删除用户 - * - * @param deleteMap 批量删除信息，包含ids字段 - * @return 删除结果 - */ - @DeleteMapping("/admin/users/batch") - public ResponseEntity batchDeleteUsers(@RequestBody Map deleteMap) { - // 从Map中获取删除信息 - List userIds = (List) deleteMap.get("ids"); - - // 参数验证 - if (userIds == null || userIds.isEmpty()) { - return ResponseEntity.error(400, "用户ID列表不能为空"); - } - - // TODO: 实现批量删除逻辑 - // 1. 检查用户是否存在 - // 2. 批量删除用户 - - // 模拟批量删除成功 - Map responseData = new HashMap<>(); - responseData.put("deletedCount", userIds.size()); - responseData.put("deletedIds", userIds); - - return ResponseEntity.success("批量删除用户成功", responseData); - } -} \ No newline at end of file diff --git a/src/main/java/icu/sunway/ai_spring_example/Controllers/Auth.java b/src/main/java/icu/sunway/ai_spring_example/Controllers/Auth.java deleted file mode 100644 index 62826a4..0000000 --- a/src/main/java/icu/sunway/ai_spring_example/Controllers/Auth.java +++ /dev/null @@ -1,87 +0,0 @@ -package icu.sunway.ai_spring_example.Controllers; - -import java.util.HashMap; -import java.util.Map; - -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RestController; - -import icu.sunway.ai_spring_example.Common.Response.ResponseEntity; - -/** - * 认证控制器 - * 提供登录和注册接口 - */ -@RestController -public class Auth { - - /** - * 登录接口 - * - * @param loginMap 登录请求参数，包含username和password字段 - * @return 登录成功返回 JWT 令牌，失败返回错误信息 - */ - @PostMapping("/login") - public ResponseEntity login(@RequestBody Map loginMap) { - // 从Map中获取登录参数 - String username = (String) loginMap.get("username"); - String password = (String) loginMap.get("password"); - - // 参数验证 - if (username == null || username.isEmpty() || password == null || password.isEmpty()) { - return ResponseEntity.error(400, "用户名和密码不能为空"); - } - - // TODO: 实现实际的登录逻辑 - // 1. 根据用户名查询用户 - // 2. 验证密码 - // 3. 生成JWT令牌 - - // 模拟登录成功 - Map responseData = new HashMap<>(); - responseData.put("token", "mock-jwt-token-123456"); - responseData.put("username", username); - responseData.put("role", "user"); - - return ResponseEntity.success("登录成功", responseData); - } - - /** - * 注册接口 - * - * @param registerMap 注册请求参数，包含username、password、email等字段 - * @return 注册成功返回成功信息，失败返回错误信息 - */ - @PostMapping("/register") - public ResponseEntity register(@RequestBody Map registerMap) { - // 从Map中获取注册参数 - String username = (String) registerMap.get("username"); - String password = (String) registerMap.get("password"); - String email = (String) registerMap.get("email"); - - // 参数验证 - if (username == null || username.isEmpty()) { - return ResponseEntity.error(400, "用户名不能为空"); - } - if (password == null || password.isEmpty()) { - return ResponseEntity.error(400, "密码不能为空"); - } - if (email == null || email.isEmpty()) { - return ResponseEntity.error(400, "邮箱不能为空"); - } - - // TODO: 实现实际的注册逻辑 - // 1. 检查用户名是否已存在 - // 2. 检查邮箱是否已存在 - // 3. 密码加密 - // 4. 保存用户信息 - - // 模拟注册成功 - Map responseData = new HashMap<>(); - responseData.put("username", username); - responseData.put("email", email); - - return ResponseEntity.success("注册成功", responseData); - } -} \ No newline at end of file diff --git a/src/main/java/icu/sunway/ai_spring_example/Controllers/Course.java b/src/main/java/icu/sunway/ai_spring_example/Controllers/Course.java deleted file mode 100644 index dfbf458..0000000 --- a/src/main/java/icu/sunway/ai_spring_example/Controllers/Course.java +++ /dev/null @@ -1,193 +0,0 @@ -package icu.sunway.ai_spring_example.Controllers; - -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import org.springframework.web.bind.annotation.DeleteMapping; -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.RequestParam; -import org.springframework.web.bind.annotation.RestController; - -import icu.sunway.ai_spring_example.Common.Response.ResponseEntity; - -/** - * 课程控制器 - * 提供课程展示和报名相关的功能 - */ -@RestController -public class Course { - - /** - * 获取课程列表 - * - * @param params 查询参数，包含page、size、name、category、status等字段 - * @return 课程列表数据 - */ - @GetMapping("/courses") - public ResponseEntity getCourseList(@RequestParam Map params) { - // 从Map中获取查询参数 - Integer page = Integer.valueOf((String) params.getOrDefault("page", "1")); - Integer size = Integer.valueOf((String) params.getOrDefault("size", "10")); - String name = (String) params.get("name"); - String category = (String) params.get("category"); - Integer status = params.get("status") != null ? Integer.valueOf((String) params.get("status")) : null; - - // TODO: 实现查询逻辑 - // 1. 根据条件查询课程列表 - // 2. 处理分页 - - // 模拟返回课程列表 - List> courseList = List.of( - Map.of("id", 1, "name", "Java基础课程", "category", "编程", "teacher", "张老师", "price", 99.00, "students", 150, - "status", 1, "description", "Java入门到精通课程"), - Map.of("id", 2, "name", "Python数据分析", "category", "数据科学", "teacher", "李老师", "price", 199.00, "students", - 80, "status", 1, "description", "Python数据分析实战课程")); - - Map responseData = new HashMap<>(); - responseData.put("list", courseList); - responseData.put("total", 2); - responseData.put("page", page); - responseData.put("size", size); - - return ResponseEntity.success("获取课程列表成功", responseData); - } - - /** - * 获取课程详情 - * - * @param courseId 课程ID - * @return 课程详细信息 - */ - @GetMapping("/courses/{courseId}") - public ResponseEntity getCourseDetail(@PathVariable Long courseId) { - // 参数验证 - if (courseId == null) { - return ResponseEntity.error(400, "课程ID不能为空"); - } - - // TODO: 实现查询逻辑 - // 1. 根据课程ID查询课程信息 - // 2. 查询课程章节、评价等关联信息 - - // 模拟返回课程详情 - Map courseInfo = Map.of( - "id", courseId, "name", "Java基础课程", "category", "编程", "teacher", "张老师", "price", 99.00, - "students", 150, "status", 1, "description", "Java入门到精通课程", - "chapters", List.of( - Map.of("id", 1, "name", "Java简介", "duration", "30分钟"), - Map.of("id", 2, "name", "变量与数据类型", "duration", "45分钟")), - "ratings", Map.of("avg", 4.8, "count", 50)); - - return ResponseEntity.success("获取课程详情成功", courseInfo); - } - - /** - * 课程报名 - * - * @param enrollMap 报名信息，包含courseId、userId等字段 - * @return 报名结果 - */ - @PostMapping("/courses/enroll") - public ResponseEntity enrollCourse(@RequestBody Map enrollMap) { - // 从Map中获取报名信息 - Long courseId = (Long) enrollMap.get("courseId"); - Long userId = (Long) enrollMap.get("userId"); - - // 参数验证 - if (courseId == null) { - return ResponseEntity.error(400, "课程ID不能为空"); - } - if (userId == null) { - return ResponseEntity.error(400, "用户ID不能为空"); - } - - // TODO: 实现报名逻辑 - // 1. 检查课程是否存在且可报名 - // 2. 检查用户是否已报名该课程 - // 3. 记录报名信息 - // 4. 更新课程报名人数 - - // 模拟报名成功 - Map responseData = new HashMap<>(); - responseData.put("courseId", courseId); - responseData.put("userId", userId); - responseData.put("enrollTime", "2023-05-20 10:00:00"); - - return ResponseEntity.success("课程报名成功", responseData); - } - - /** - * 获取用户报名的课程列表 - * - * @param params 查询参数，包含userId、page、size等字段 - * @return 用户报名的课程列表 - */ - @GetMapping("/user/courses") - public ResponseEntity getUserCourses(@RequestParam Map params) { - // 从Map中获取查询参数 - Long userId = Long.valueOf((String) params.get("userId")); - Integer page = Integer.valueOf((String) params.getOrDefault("page", "1")); - Integer size = Integer.valueOf((String) params.getOrDefault("size", "10")); - - // 参数验证 - if (userId == null) { - return ResponseEntity.error(400, "用户ID不能为空"); - } - - // TODO: 实现查询逻辑 - // 1. 根据用户ID查询已报名课程 - // 2. 处理分页 - - // 模拟返回用户报名的课程列表 - List> userCourseList = List.of( - Map.of("id", 1, "courseId", 1, "courseName", "Java基础课程", "teacher", "张老师", "enrollTime", - "2023-05-20 10:00:00", "status", "learning"), - Map.of("id", 2, "courseId", 2, "courseName", "Python数据分析", "teacher", "李老师", "enrollTime", - "2023-05-15 14:30:00", "status", "completed")); - - Map responseData = new HashMap<>(); - responseData.put("list", userCourseList); - responseData.put("total", 2); - responseData.put("page", page); - responseData.put("size", size); - - return ResponseEntity.success("获取用户课程列表成功", responseData); - } - - /** - * 取消课程报名 - * - * @param courseId 课程ID - * @param params 参数，包含userId字段 - * @return 取消报名结果 - */ - @DeleteMapping("/courses/{courseId}/enroll") - public ResponseEntity cancelEnroll(@PathVariable Long courseId, @RequestParam Map params) { - // 从Map中获取用户ID - Long userId = Long.valueOf((String) params.get("userId")); - - // 参数验证 - if (courseId == null) { - return ResponseEntity.error(400, "课程ID不能为空"); - } - if (userId == null) { - return ResponseEntity.error(400, "用户ID不能为空"); - } - - // TODO: 实现取消报名逻辑 - // 1. 检查报名记录是否存在 - // 2. 删除报名记录 - // 3. 更新课程报名人数 - - // 模拟取消报名成功 - Map responseData = new HashMap<>(); - responseData.put("courseId", courseId); - responseData.put("userId", userId); - - return ResponseEntity.success("取消课程报名成功", responseData); - } -} diff --git a/src/main/java/icu/sunway/ai_spring_example/Controllers/UploadController.java b/src/main/java/icu/sunway/ai_spring_example/Controllers/UploadController.java new file mode 100644 index 0000000..c25d308 --- /dev/null +++ b/src/main/java/icu/sunway/ai_spring_example/Controllers/UploadController.java @@ -0,0 +1,38 @@ +package icu.sunway.ai_spring_example.Controllers; + +import icu.sunway.ai_spring_example.Common.Exception.BusinessException; +import icu.sunway.ai_spring_example.Common.Response.ResponseEntity; +import icu.sunway.ai_spring_example.Common.Utils.OSSUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; + +import java.io.IOException; +import java.util.Map; + +@RestController +@RequestMapping("/api/upload") +public class UploadController { + + @Autowired + private OSSUtil ossUtil; + + // 方式1：生成预签名 URL 给前端直传 + @GetMapping("/presigned-url") + public ResponseEntity getPresignedUrl(@RequestParam String fileName) { + String presignedUrl = ossUtil.generatePresignedUrl(fileName); + String fileUrl = ossUtil.getFileUrl(fileName); + return ResponseEntity.success(Map.of("uploadUrl", presignedUrl, "fileUrl", fileUrl)); + } + + // 方式2：后端接收文件并上传 + @PostMapping("/file") + public ResponseEntity uploadFile(@RequestParam("file") MultipartFile file) { + try { + String fileUrl = ossUtil.uploadFile(file.getOriginalFilename(), file.getInputStream()); + return ResponseEntity.success(Map.of("msg", "上传成功", "fileUrl", fileUrl)); + } catch (IOException e) { + return ResponseEntity.error("文件上传失败"); + } + } +} \ No newline at end of file diff --git a/src/main/java/icu/sunway/ai_spring_example/Service/Impl/ProductServiceImpl.java b/src/main/java/icu/sunway/ai_spring_example/Service/Impl/ProductServiceImpl.java index 071dd2a..ccfd26a 100644 --- a/src/main/java/icu/sunway/ai_spring_example/Service/Impl/ProductServiceImpl.java +++ b/src/main/java/icu/sunway/ai_spring_example/Service/Impl/ProductServiceImpl.java @@ -105,11 +105,13 @@ public class ProductServiceImpl extends ServiceImpl impl // 4. 重新插入新规格 List skuList = new ArrayList<>(); - for (ProductSkuDTO skuDTO : productDTO.getSkuList()) { - ProductSku sku = new ProductSku(); - BeanUtils.copyProperties(skuDTO, sku); - sku.setProductId(product.getId()); - skuList.add(sku); + if(productDTO.getSkuList() != null){ + for (ProductSkuDTO skuDTO : productDTO.getSkuList()) { + ProductSku sku = new ProductSku(); + BeanUtils.copyProperties(skuDTO, sku); + sku.setProductId(product.getId()); + skuList.add(sku); + } } if (!skuList.isEmpty()) { productSkuMapper.batchInsert(skuList); diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml index 3d09c6b..a394889 100644 --- a/src/main/resources/application.yaml +++ b/src/main/resources/application.yaml @@ -35,4 +35,12 @@ zhiwei: # 设置jwt过期时间 user-ttl: 7200000 # 设置前端传递过来的令牌名称 - user-token-name: token \ No newline at end of file + user-token-name: token + +aliyun: + oss: + endpoint: oss-cn-hangzhou.aliyuncs.com + accessKeyId: LTAI5tEajTmhB2RCHuUwo3QW + accessKeySecret: G1x7ZoS8PkjjRNtoPMoLaJz5T6VGep + bucketName: puzv + urlPrefix: https://puzv.oss-cn-hangzhou.aliyuncs.com/ \ No newline at end of file