Commit dcab49bb78077b12e9d6d9ebb38151711fb9a858

Authored by cherishsince
2 parents 9949a06c d4cfcd0a

Merge remote-tracking branch 'origin/master-jdk21-ai' into master-jdk21-ai

Showing 20 changed files with 125 additions and 165 deletions
yudao-module-ai/yudao-module-ai-api/src/main/java/cn/iocoder/yudao/module/ai/enums/music/AiMusicGenerateEnum.java renamed to yudao-module-ai/yudao-module-ai-api/src/main/java/cn/iocoder/yudao/module/ai/enums/music/AiMusicGenerateModeEnum.java
@@ -3,7 +3,6 @@ package cn.iocoder.yudao.module.ai.enums.music; @@ -3,7 +3,6 @@ package cn.iocoder.yudao.module.ai.enums.music;
3 import lombok.AllArgsConstructor; 3 import lombok.AllArgsConstructor;
4 import lombok.Getter; 4 import lombok.Getter;
5 5
6 -// TODO @xiaoxin:这个也叫 AiMusicGenerateModeEnum 吧。虽然长,但是和项目统一一点。  
7 /** 6 /**
8 * AI 音乐状态的枚举 7 * AI 音乐状态的枚举
9 * 8 *
@@ -11,27 +10,18 @@ import lombok.Getter; @@ -11,27 +10,18 @@ import lombok.Getter;
11 */ 10 */
12 @AllArgsConstructor 11 @AllArgsConstructor
13 @Getter 12 @Getter
14 -public enum AiMusicGenerateEnum { 13 +public enum AiMusicGenerateModeEnum {
15 14
16 - LYRIC("1", "歌词模式"),  
17 - DESCRIPTION("2", "描述模式"); 15 + LYRIC(1, "歌词模式"),
  16 + DESCRIPTION(2, "描述模式");
18 17
19 /** 18 /**
20 * 模式 19 * 模式
21 */ 20 */
22 - private final String mode; 21 + private final Integer mode;
23 /** 22 /**
24 * 模式名 23 * 模式名
25 */ 24 */
26 private final String name; 25 private final String name;
27 26
28 - public static AiMusicGenerateEnum valueOfMode(String mode) {  
29 - for (AiMusicGenerateEnum modeEnum : AiMusicGenerateEnum.values()) {  
30 - if (modeEnum.getMode().equals(mode)) {  
31 - return modeEnum;  
32 - }  
33 - }  
34 - throw new IllegalArgumentException("未知模式: " + mode);  
35 - }  
36 -  
37 } 27 }
yudao-module-ai/yudao-module-ai-api/src/main/java/cn/iocoder/yudao/module/ai/enums/music/AiMusicStatusEnum.java
@@ -12,14 +12,13 @@ import lombok.Getter; @@ -12,14 +12,13 @@ import lombok.Getter;
12 @Getter 12 @Getter
13 public enum AiMusicStatusEnum { 13 public enum AiMusicStatusEnum {
14 14
15 - // @xin 文档中无失败这个返回值 TODO @xin:用 Integer 哈。另外个枚举类也是  
16 - STREAMING("10", "进行中"),  
17 - COMPLETE("20", "完成"); 15 + IN_PROGRESS(10, "进行中"),
  16 + SUCCESS(20, "已完成");
18 17
19 /** 18 /**
20 * 状态 19 * 状态
21 */ 20 */
22 - private final String status; 21 + private final Integer status;
23 22
24 /** 23 /**
25 * 状态名 24 * 状态名
yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/controller/admin/music/AiImageController.http 0 → 100644
  1 +### 生成音乐:Suno +
  2 +POST {{baseUrl}}/ai/music/generate
  3 +Content-Type: application/json
  4 +Authorization: {{token}}
  5 +
  6 +{
  7 + "platform": "Suno",
  8 + "generateMode": 1,
  9 + "prompt": "来一首快乐的歌曲",
  10 + "modelVersion": "chirp-v3.5",
  11 + "tags": ["Happy"],
  12 + "title": "Happy Song"
  13 +}
0 \ No newline at end of file 14 \ No newline at end of file
yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/controller/admin/music/AiMusicController.java
@@ -15,6 +15,7 @@ import org.springframework.web.bind.annotation.RestController; @@ -15,6 +15,7 @@ import org.springframework.web.bind.annotation.RestController;
15 import java.util.List; 15 import java.util.List;
16 16
17 import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success; 17 import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
  18 +import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId;
18 19
19 @Tag(name = "管理后台 - AI 音乐") 20 @Tag(name = "管理后台 - AI 音乐")
20 @RestController 21 @RestController
@@ -27,7 +28,7 @@ public class AiMusicController { @@ -27,7 +28,7 @@ public class AiMusicController {
27 @PostMapping("/generate") 28 @PostMapping("/generate")
28 @Operation(summary = "音乐生成") 29 @Operation(summary = "音乐生成")
29 public CommonResult<List<Long>> generateMusic(@RequestBody @Valid AiSunoGenerateReqVO reqVO) { 30 public CommonResult<List<Long>> generateMusic(@RequestBody @Valid AiSunoGenerateReqVO reqVO) {
30 - return success(musicService.generateMusic(reqVO)); 31 + return success(musicService.generateMusic(getLoginUserId(), reqVO));
31 } 32 }
32 33
33 } 34 }
yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/controller/admin/music/vo/AiSunoGenerateReqVO.java
@@ -2,36 +2,37 @@ package cn.iocoder.yudao.module.ai.controller.admin.music.vo; @@ -2,36 +2,37 @@ package cn.iocoder.yudao.module.ai.controller.admin.music.vo;
2 2
3 import io.swagger.v3.oas.annotations.media.Schema; 3 import io.swagger.v3.oas.annotations.media.Schema;
4 import jakarta.validation.constraints.NotBlank; 4 import jakarta.validation.constraints.NotBlank;
  5 +import jakarta.validation.constraints.NotNull;
5 import lombok.Data; 6 import lombok.Data;
6 7
7 import java.util.List; 8 import java.util.List;
8 9
9 -@Schema(description = "管理后台 - 音乐生成 Request VO") 10 +@Schema(description = "管理后台 - AI 音乐生成 Request VO")
10 @Data 11 @Data
11 public class AiSunoGenerateReqVO { 12 public class AiSunoGenerateReqVO {
12 13
13 - // TODO @xin:每个参数,必要的是否必填校验  
14 - @Schema(description = "用于生成音乐音频的提示", example = "创作一首带有轻松吉他旋律的流行歌曲,[verse] 描述夏日海滩的宁静,[chorus] 节奏加快,表达对自由的向往。") 14 + @Schema(description = "平台", requiredMode = Schema.RequiredMode.REQUIRED, example = "Suno")
  15 + @NotBlank(message = "平台不能为空")
  16 + private String platform; // 参见 AiPlatformEnum 枚举
  17 +
  18 + @Schema(description = "生成模式", requiredMode = Schema.RequiredMode.REQUIRED, example = "2")
  19 + @NotNull(message = "生成模式不能为空")
  20 + private Integer generateMode; // 参见 AiMusicGenerateModeEnum 枚举
  21 +
  22 + @Schema(description = "用于生成音乐音频的提示", requiredMode = Schema.RequiredMode.REQUIRED,
  23 + example = "创作一首带有轻松吉他旋律的流行歌曲,[verse] 描述夏日海滩的宁静,[chorus] 节奏加快,表达对自由的向往。")
15 private String prompt; 24 private String prompt;
16 25
17 - @Schema(description = "是否纯音乐", example = "true") 26 + @Schema(description = "是否纯音乐", requiredMode = Schema.RequiredMode.NOT_REQUIRED, example = "true")
18 private Boolean makeInstrumental; 27 private Boolean makeInstrumental;
19 28
20 - @Schema(description = "模型版本, 默认 chirp-v3.5", example = "chirp-v3.5") 29 + @Schema(description = "模型版本", requiredMode = Schema.RequiredMode.NOT_REQUIRED, example = "chirp-v3.5")
21 private String modelVersion; // 参见 AiModelEnum 枚举 30 private String modelVersion; // 参见 AiModelEnum 枚举
22 31
23 - @Schema(description = "音乐风格", example = "[\"pop\",\"jazz\",\"punk\"]") 32 + @Schema(description = "音乐风格", requiredMode = Schema.RequiredMode.NOT_REQUIRED, example = "[\"pop\",\"jazz\",\"punk\"]")
24 private List<String> tags; 33 private List<String> tags;
25 34
26 - @Schema(description = "音乐/歌曲名称", example = "夜空中最亮的星") 35 + @Schema(description = "音乐/歌曲名称", requiredMode = Schema.RequiredMode.NOT_REQUIRED, example = "夜空中最亮的星")
27 private String title; 36 private String title;
28 37
29 - @Schema(description = "平台", requiredMode = Schema.RequiredMode.REQUIRED, example = "Suno")  
30 - @NotBlank(message = "平台不能为空")  
31 - private String platform; // 参见 AiPlatformEnum 枚举  
32 -  
33 - @Schema(description = "生成模式", requiredMode = Schema.RequiredMode.REQUIRED, example = "2")  
34 - @NotBlank(message = "生成模式不能为空")  
35 - private String generateMode; // 参见 AiMusicGenerateEnum 枚举  
36 -  
37 } 38 }
38 \ No newline at end of file 39 \ No newline at end of file
yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/dal/dataobject/music/AiMusicDO.java
1 package cn.iocoder.yudao.module.ai.dal.dataobject.music; 1 package cn.iocoder.yudao.module.ai.dal.dataobject.music;
2 2
  3 +import cn.iocoder.yudao.framework.ai.core.enums.AiPlatformEnum;
3 import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO; 4 import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
  5 +import cn.iocoder.yudao.module.ai.enums.music.AiMusicGenerateModeEnum;
4 import cn.iocoder.yudao.module.ai.enums.music.AiMusicStatusEnum; 6 import cn.iocoder.yudao.module.ai.enums.music.AiMusicStatusEnum;
5 import com.baomidou.mybatisplus.annotation.IdType; 7 import com.baomidou.mybatisplus.annotation.IdType;
6 import com.baomidou.mybatisplus.annotation.TableField; 8 import com.baomidou.mybatisplus.annotation.TableField;
@@ -39,20 +41,18 @@ public class AiMusicDO extends BaseDO { @@ -39,20 +41,18 @@ public class AiMusicDO extends BaseDO {
39 private String title; 41 private String title;
40 42
41 /** 43 /**
42 - * 图片地址  
43 - */  
44 - private String imageUrl;  
45 -  
46 - /**  
47 * 歌词 44 * 歌词
48 */ 45 */
49 private String lyric; 46 private String lyric;
50 47
51 /** 48 /**
  49 + * 图片地址
  50 + */
  51 + private String imageUrl;
  52 + /**
52 * 音频地址 53 * 音频地址
53 */ 54 */
54 private String audioUrl; 55 private String audioUrl;
55 -  
56 /** 56 /**
57 * 视频地址 57 * 视频地址
58 */ 58 */
@@ -63,7 +63,14 @@ public class AiMusicDO extends BaseDO { @@ -63,7 +63,14 @@ public class AiMusicDO extends BaseDO {
63 * <p> 63 * <p>
64 * 枚举 {@link AiMusicStatusEnum} 64 * 枚举 {@link AiMusicStatusEnum}
65 */ 65 */
66 - private String status; 66 + private Integer status;
  67 +
  68 + /**
  69 + * 生成模式
  70 + *
  71 + * 枚举 {@link AiMusicGenerateModeEnum}
  72 + */
  73 + private Integer generateMode;
67 74
68 /** 75 /**
69 * 描述词 76 * 描述词
@@ -75,28 +82,17 @@ public class AiMusicDO extends BaseDO { @@ -75,28 +82,17 @@ public class AiMusicDO extends BaseDO {
75 private String prompt; 82 private String prompt;
76 83
77 /** 84 /**
78 - * 生成模式  
79 - */  
80 - private String generateMode;  
81 -  
82 - /**  
83 * 平台 85 * 平台
84 * <p> 86 * <p>
85 - * 枚举 {@link cn.iocoder.yudao.framework.ai.core.enums.AiPlatformEnum} 87 + * 枚举 {@link AiPlatformEnum}
86 */ 88 */
87 private String platform; 89 private String platform;
88 -  
89 /** 90 /**
90 * 模型 91 * 模型
91 */ 92 */
92 private String model; 93 private String model;
93 94
94 /** 95 /**
95 - * 错误信息  
96 - */  
97 - private String errorMessage;  
98 -  
99 - /**  
100 * 音乐风格标签 96 * 音乐风格标签
101 */ 97 */
102 @TableField(typeHandler = JacksonTypeHandler.class) 98 @TableField(typeHandler = JacksonTypeHandler.class)
@@ -107,4 +103,9 @@ public class AiMusicDO extends BaseDO { @@ -107,4 +103,9 @@ public class AiMusicDO extends BaseDO {
107 */ 103 */
108 private String taskId; 104 private String taskId;
109 105
  106 + /**
  107 + * 错误信息
  108 + */
  109 + private String errorMessage;
  110 +
110 } 111 }
yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/dal/mysql/music/AiMusicMapper.java
@@ -4,10 +4,18 @@ import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX; @@ -4,10 +4,18 @@ import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
4 import cn.iocoder.yudao.module.ai.dal.dataobject.music.AiMusicDO; 4 import cn.iocoder.yudao.module.ai.dal.dataobject.music.AiMusicDO;
5 import org.apache.ibatis.annotations.Mapper; 5 import org.apache.ibatis.annotations.Mapper;
6 6
  7 +import java.util.List;
  8 +
7 /** 9 /**
8 * AI 音乐 Mapper 10 * AI 音乐 Mapper
9 - * @author xiaoxin 11 + *
  12 + * @author xiaoxin
10 */ 13 */
11 @Mapper 14 @Mapper
12 public interface AiMusicMapper extends BaseMapperX<AiMusicDO> { 15 public interface AiMusicMapper extends BaseMapperX<AiMusicDO> {
  16 +
  17 + default List<AiMusicDO> selectListByStatus(Integer status) {
  18 + return selectList(AiMusicDO::getStatus, status);
  19 + }
  20 +
13 } 21 }
yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/job/sun/AiSunoSyncJob.java renamed to yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/job/music/AiSunoSyncJob.java
1 -package cn.iocoder.yudao.module.ai.job.sun; 1 +package cn.iocoder.yudao.module.ai.job.music;
2 2
3 import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler; 3 import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler;
4 import cn.iocoder.yudao.module.ai.service.music.AiMusicService; 4 import cn.iocoder.yudao.module.ai.service.music.AiMusicService;
yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/service/music/AiMusicService.java
1 package cn.iocoder.yudao.module.ai.service.music; 1 package cn.iocoder.yudao.module.ai.service.music;
2 2
3 import cn.iocoder.yudao.module.ai.controller.admin.music.vo.AiSunoGenerateReqVO; 3 import cn.iocoder.yudao.module.ai.controller.admin.music.vo.AiSunoGenerateReqVO;
4 -import cn.iocoder.yudao.module.ai.dal.dataobject.music.AiMusicDO;  
5 4
6 import java.util.List; 5 import java.util.List;
7 6
@@ -15,17 +14,11 @@ public interface AiMusicService { @@ -15,17 +14,11 @@ public interface AiMusicService {
15 /** 14 /**
16 * 音乐生成 15 * 音乐生成
17 * 16 *
  17 + * @param userId 用户编号
18 * @param reqVO 请求参数 18 * @param reqVO 请求参数
19 * @return 生成的音乐ID 19 * @return 生成的音乐ID
20 */ 20 */
21 - List<Long> generateMusic(AiSunoGenerateReqVO reqVO);  
22 -  
23 - /**  
24 - * 获取未完成状态的任务  
25 - *  
26 - * @return 未完成任务列表  
27 - */  
28 - List<AiMusicDO> getUnCompletedTask(); 21 + List<Long> generateMusic(Long userId, AiSunoGenerateReqVO reqVO);
29 22
30 /** 23 /**
31 * 同步音乐任务 24 * 同步音乐任务
@@ -34,12 +27,4 @@ public interface AiMusicService { @@ -34,12 +27,4 @@ public interface AiMusicService {
34 */ 27 */
35 Integer syncMusic(); 28 Integer syncMusic();
36 29
37 - /**  
38 - * 批量更新音乐信息  
39 - *  
40 - * @param musicDOS 音乐信息  
41 - * @return 是否成功  
42 - */  
43 - Boolean updateBatch(List<AiMusicDO> musicDOS);  
44 -  
45 } 30 }
yudao-module-ai/yudao-module-ai-biz/src/main/java/cn/iocoder/yudao/module/ai/service/music/AiMusicServiceImpl.java
@@ -4,21 +4,19 @@ import cn.hutool.core.collection.CollUtil; @@ -4,21 +4,19 @@ import cn.hutool.core.collection.CollUtil;
4 import cn.hutool.core.text.StrPool; 4 import cn.hutool.core.text.StrPool;
5 import cn.hutool.core.util.StrUtil; 5 import cn.hutool.core.util.StrUtil;
6 import cn.iocoder.yudao.framework.ai.core.model.suno.api.SunoApi; 6 import cn.iocoder.yudao.framework.ai.core.model.suno.api.SunoApi;
7 -import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;  
8 import cn.iocoder.yudao.module.ai.controller.admin.music.vo.AiSunoGenerateReqVO; 7 import cn.iocoder.yudao.module.ai.controller.admin.music.vo.AiSunoGenerateReqVO;
9 import cn.iocoder.yudao.module.ai.dal.dataobject.music.AiMusicDO; 8 import cn.iocoder.yudao.module.ai.dal.dataobject.music.AiMusicDO;
10 import cn.iocoder.yudao.module.ai.dal.mysql.music.AiMusicMapper; 9 import cn.iocoder.yudao.module.ai.dal.mysql.music.AiMusicMapper;
11 -import cn.iocoder.yudao.module.ai.enums.music.AiMusicGenerateEnum; 10 +import cn.iocoder.yudao.module.ai.enums.music.AiMusicGenerateModeEnum;
12 import cn.iocoder.yudao.module.ai.enums.music.AiMusicStatusEnum; 11 import cn.iocoder.yudao.module.ai.enums.music.AiMusicStatusEnum;
13 -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;  
14 import jakarta.annotation.Resource; 12 import jakarta.annotation.Resource;
15 import lombok.extern.slf4j.Slf4j; 13 import lombok.extern.slf4j.Slf4j;
16 import org.springframework.stereotype.Service; 14 import org.springframework.stereotype.Service;
17 15
18 import java.util.*; 16 import java.util.*;
19 -import java.util.stream.Collectors;  
20 17
21 -import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId; 18 +import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
  19 +import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
22 20
23 /** 21 /**
24 * AI 音乐 Service 实现类 22 * AI 音乐 Service 实现类
@@ -36,112 +34,70 @@ public class AiMusicServiceImpl implements AiMusicService { @@ -36,112 +34,70 @@ public class AiMusicServiceImpl implements AiMusicService {
36 private AiMusicMapper musicMapper; 34 private AiMusicMapper musicMapper;
37 35
38 @Override 36 @Override
39 - public List<Long> generateMusic(AiSunoGenerateReqVO reqVO) { 37 + public List<Long> generateMusic(Long userId, AiSunoGenerateReqVO reqVO) {
  38 + // 1. 调用 Suno 生成音乐
40 List<SunoApi.MusicData> musicDataList; 39 List<SunoApi.MusicData> musicDataList;
41 - if (Objects.equals(AiMusicGenerateEnum.LYRIC.getMode(), reqVO.getGenerateMode())) { 40 + if (Objects.equals(AiMusicGenerateModeEnum.LYRIC.getMode(), reqVO.getGenerateMode())) {
42 // 1.1 歌词模式 41 // 1.1 歌词模式
43 - SunoApi.MusicGenerateRequest sunoReq = new SunoApi.MusicGenerateRequest( 42 + SunoApi.MusicGenerateRequest generateRequest = new SunoApi.MusicGenerateRequest(
44 reqVO.getPrompt(), reqVO.getModelVersion(), CollUtil.join(reqVO.getTags(), StrPool.COMMA), reqVO.getTitle()); 43 reqVO.getPrompt(), reqVO.getModelVersion(), CollUtil.join(reqVO.getTags(), StrPool.COMMA), reqVO.getTitle());
45 - musicDataList = sunoApi.customGenerate(sunoReq);  
46 - } else if (Objects.equals(AiMusicGenerateEnum.DESCRIPTION.getMode(), reqVO.getGenerateMode())) { 44 + musicDataList = sunoApi.customGenerate(generateRequest);
  45 + } else if (Objects.equals(AiMusicGenerateModeEnum.DESCRIPTION.getMode(), reqVO.getGenerateMode())) {
47 // 1.2 描述模式 46 // 1.2 描述模式
48 - SunoApi.MusicGenerateRequest sunoReq = new SunoApi.MusicGenerateRequest( 47 + SunoApi.MusicGenerateRequest generateRequest = new SunoApi.MusicGenerateRequest(
49 reqVO.getPrompt(), reqVO.getModelVersion(), reqVO.getMakeInstrumental()); 48 reqVO.getPrompt(), reqVO.getModelVersion(), reqVO.getMakeInstrumental());
50 - musicDataList = sunoApi.generate(sunoReq); 49 + musicDataList = sunoApi.generate(generateRequest);
51 } else { 50 } else {
52 - // TODO @xin:不用 log error,直接抛异常,吧 reqVO 呆进去,有全局处理的哈  
53 - log.error("未知的生成模式:{}", reqVO.getGenerateMode());  
54 - throw new IllegalArgumentException("未知的生成模式"); 51 + throw new IllegalArgumentException(StrUtil.format("未知生成模式({})", reqVO));
55 } 52 }
56 53
57 // 2. 插入数据库 54 // 2. 插入数据库
58 - // TODO @xin:因为 insertMusicData 复用的比较少,所以不用愁单独的方法,直接写在这里就好啦  
59 - return insertMusicData(musicDataList, reqVO.getGenerateMode(), reqVO.getPlatform());  
60 - }  
61 -  
62 - // TODO @xin:1)service 里面,不要直接查询 db;2)不要用 ne,用 STREAMING 哈  
63 - @Override  
64 - public List<AiMusicDO> getUnCompletedTask() {  
65 - return musicMapper.selectList(new LambdaQueryWrapper<AiMusicDO>().ne(AiMusicDO::getStatus, AiMusicStatusEnum.COMPLETE.getStatus())); 55 + if (CollUtil.isEmpty(musicDataList)) {
  56 + return Collections.emptyList();
  57 + }
  58 + List<AiMusicDO> musicList = buildMusicDOList(musicDataList);
  59 + musicList.forEach(music -> music.setUserId(userId).setPlatform(music.getPlatform()).setGenerateMode(reqVO.getGenerateMode()));
  60 + musicMapper.insertBatch(musicList);
  61 + return convertList(musicList, AiMusicDO::getId);
66 } 62 }
67 63
68 @Override 64 @Override
69 public Integer syncMusic() { 65 public Integer syncMusic() {
70 - List<AiMusicDO> unCompletedTask = this.getUnCompletedTask();  
71 - if (CollUtil.isEmpty(unCompletedTask)) {  
72 - // TODO @xin:这里不用打,反正 Job 也打了  
73 - log.info("Suno 无进行中任务需要更新!"); 66 + List<AiMusicDO> streamingTask = musicMapper.selectListByStatus(AiMusicStatusEnum.IN_PROGRESS.getStatus());
  67 + if (CollUtil.isEmpty(streamingTask)) {
74 return 0; 68 return 0;
75 } 69 }
76 - log.info("[syncMusic][Suno 开始同步, 共 ({}) 个任务]", unCompletedTask.size()); 70 + log.info("[syncMusic][Suno 开始同步, 共 ({}) 个任务]", streamingTask.size());
  71 +
77 // GET 请求,为避免参数过长,分批次处理 72 // GET 请求,为避免参数过长,分批次处理
78 - // TODO @xin:建议批量更大一些。  
79 - CollUtil.split(unCompletedTask, 4).forEach(chunk -> {  
80 - // TODO @xin:可以使用 CollectionUtils 里的 map 转换  
81 - Map<String, Long> taskIdMap = CollUtil.toMap(chunk, new HashMap<>(), AiMusicDO::getTaskId, AiMusicDO::getId); 73 + CollUtil.split(streamingTask, 36).forEach(chunkList -> {
  74 + Map<String, Long> taskIdMap = convertMap(chunkList, AiMusicDO::getTaskId, AiMusicDO::getId);
82 List<SunoApi.MusicData> musicTaskList = sunoApi.getMusicList(new ArrayList<>(taskIdMap.keySet())); 75 List<SunoApi.MusicData> musicTaskList = sunoApi.getMusicList(new ArrayList<>(taskIdMap.keySet()));
83 - // TODO @xin:查询不到,直接 return;这样真正逻辑的 85 - 87 就不用多一层括号  
84 - if (CollUtil.isNotEmpty(musicTaskList)) {  
85 - List<AiMusicDO> aiMusicDOS = buildMusicDOList(musicTaskList);  
86 - //回填id  
87 - aiMusicDOS.forEach(aiMusicDO -> aiMusicDO.setId(taskIdMap.get(aiMusicDO.getTaskId())));  
88 - this.updateBatch(aiMusicDOS);  
89 - } else { 76 + if (CollUtil.isEmpty(musicTaskList)) {
90 log.warn("Suno 任务同步失败, 任务ID: [{}]", taskIdMap.keySet()); 77 log.warn("Suno 任务同步失败, 任务ID: [{}]", taskIdMap.keySet());
  78 + return;
91 } 79 }
  80 + // 更新进度
  81 + List<AiMusicDO> updateMusicList = buildMusicDOList(musicTaskList);
  82 + updateMusicList.forEach(music -> music.setId(taskIdMap.get(music.getTaskId())));
  83 + musicMapper.updateBatch(updateMusicList);
92 }); 84 });
93 - return unCompletedTask.size();  
94 - }  
95 -  
96 - // TODO @xin:这个方法,看着不用啦  
97 - @Override  
98 - public Boolean updateBatch(List<AiMusicDO> musicDOS) {  
99 - return musicMapper.updateBatch(musicDOS);  
100 - }  
101 -  
102 - /**  
103 - * 新增音乐数据并提交 suno任务  
104 - *  
105 - * @param musicDataList 音乐数据列表  
106 - * @return 音乐id集合  
107 - */  
108 - private List<Long> insertMusicData(List<SunoApi.MusicData> musicDataList, String generateMode, String platform) {  
109 - if (CollUtil.isEmpty(musicDataList)) {  
110 - return Collections.emptyList();  
111 - }  
112 - List<AiMusicDO> aiMusicDOList = buildMusicDOList(musicDataList).stream()  
113 - .map(musicDO -> musicDO.setUserId(getLoginUserId())  
114 - .setGenerateMode(generateMode)  
115 - .setPlatform(platform))  
116 - .toList();  
117 - musicMapper.insertBatch(aiMusicDOList);  
118 - // TODO @xin:用 CollectionUtils 简化操作  
119 - return aiMusicDOList.stream()  
120 - .map(AiMusicDO::getId)  
121 - .collect(Collectors.toList()); 85 + return streamingTask.size();
122 } 86 }
123 87
124 /** 88 /**
125 * 构建 AiMusicDO 集合 89 * 构建 AiMusicDO 集合
126 * 90 *
127 - * @param musicTaskList suno 音乐任务列表 91 + * @param musicList suno 音乐任务列表
128 * @return AiMusicDO 集合 92 * @return AiMusicDO 集合
129 */ 93 */
130 - private static List<AiMusicDO> buildMusicDOList(List<SunoApi.MusicData> musicTaskList) {  
131 - // TODO @xin:想通的变量,放在同一行,避免过长。  
132 - return CollectionUtils.convertList(musicTaskList, musicData -> new AiMusicDO()  
133 - .setTaskId(musicData.id())  
134 - .setPrompt(musicData.prompt())  
135 - .setGptDescriptionPrompt(musicData.gptDescriptionPrompt())  
136 - .setAudioUrl(musicData.audioUrl())  
137 - .setVideoUrl(musicData.videoUrl())  
138 - .setImageUrl(musicData.imageUrl())  
139 - .setLyric(musicData.lyric())  
140 - .setTitle(musicData.title())  
141 - .setStatus(Objects.equals("complete", musicData.status()) ? AiMusicStatusEnum.COMPLETE.getStatus() : AiMusicStatusEnum.STREAMING.getStatus())  
142 - .setModel(musicData.modelName())  
143 - // TODO @xin:可以用 hutool 的 StrUtil 的 split 之类的  
144 - .setTags(StrUtil.isNotBlank(musicData.tags()) ? List.of(musicData.tags().split(StrPool.COMMA)) : null));  
145 - } 94 + private static List<AiMusicDO> buildMusicDOList(List<SunoApi.MusicData> musicList) {
  95 + return convertList(musicList, musicData -> new AiMusicDO()
  96 + .setTaskId(musicData.id()).setModel(musicData.modelName())
  97 + .setPrompt(musicData.prompt()).setGptDescriptionPrompt(musicData.gptDescriptionPrompt())
  98 + .setAudioUrl(musicData.audioUrl()).setVideoUrl(musicData.videoUrl()).setImageUrl(musicData.imageUrl())
  99 + .setTitle(musicData.title()).setLyric(musicData.lyric()).setTags(StrUtil.split(musicData.tags(), StrPool.COMMA))
  100 + .setStatus(Objects.equals("complete", musicData.status()) ? AiMusicStatusEnum.SUCCESS.getStatus() : AiMusicStatusEnum.IN_PROGRESS.getStatus()));
146 101
  102 + }
147 } 103 }
yudao-module-ai/yudao-spring-boot-starter-ai/src/main/java/cn/iocoder/yudao/framework/ai/config/YudaoAiAutoConfiguration.java
@@ -63,7 +63,7 @@ public class YudaoAiAutoConfiguration { @@ -63,7 +63,7 @@ public class YudaoAiAutoConfiguration {
63 YudaoAiProperties.QianWenProperties qianWenProperties = yudaoAiProperties.getQianwen(); 63 YudaoAiProperties.QianWenProperties qianWenProperties = yudaoAiProperties.getQianwen();
64 // 转换配置 64 // 转换配置
65 QianWenOptions qianWenOptions = new QianWenOptions(); 65 QianWenOptions qianWenOptions = new QianWenOptions();
66 - qianWenOptions.setModel(qianWenProperties.getModel().getModel()); 66 +// qianWenOptions.setModel(qianWenProperties.getModel().getModel()); TODO @fan:这里报错了
67 qianWenOptions.setTemperature(qianWenProperties.getTemperature()); 67 qianWenOptions.setTemperature(qianWenProperties.getTemperature());
68 // qianWenOptions.setTopK(qianWenProperties.getTopK()); TODO 芋艿:后续弄 68 // qianWenOptions.setTopK(qianWenProperties.getTopK()); TODO 芋艿:后续弄
69 qianWenOptions.setTopP(qianWenProperties.getTopP()); 69 qianWenOptions.setTopP(qianWenProperties.getTopP());
yudao-module-ai/yudao-spring-boot-starter-ai/src/main/java/cn/iocoder/yudao/framework/ai/core/model/suno/api/SunoApi.java
@@ -19,7 +19,7 @@ import java.util.function.Predicate; @@ -19,7 +19,7 @@ import java.util.function.Predicate;
19 19
20 /** 20 /**
21 * Suno API 21 * Suno API
22 - * 22 + * <p>
23 * 对接 Suno Proxy:<a href="https://github.com/gcui-art/suno-api">suno-api</a> 23 * 对接 Suno Proxy:<a href="https://github.com/gcui-art/suno-api">suno-api</a>
24 * 24 *
25 * @author xiaoxin 25 * @author xiaoxin
yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/chat/QianWenChatClientTests.java
@@ -24,6 +24,7 @@ import java.util.List; @@ -24,6 +24,7 @@ import java.util.List;
24 import java.util.Scanner; 24 import java.util.Scanner;
25 import java.util.function.Consumer; 25 import java.util.function.Consumer;
26 26
  27 +// TODO 芋艿:整理单测
27 /** 28 /**
28 * author: fansili 29 * author: fansili
29 * time: 2024/3/13 21:37 30 * time: 2024/3/13 21:37
yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/chat/XingHuoChatClientMainTests.java
@@ -18,6 +18,7 @@ import java.security.NoSuchAlgorithmException; @@ -18,6 +18,7 @@ import java.security.NoSuchAlgorithmException;
18 import java.text.SimpleDateFormat; 18 import java.text.SimpleDateFormat;
19 import java.util.*; 19 import java.util.*;
20 20
  21 +// TODO 芋艿:整理单测
21 /** 22 /**
22 * author: fansili 23 * author: fansili
23 * time: 2024/3/13 20:47 24 * time: 2024/3/13 20:47
yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/chat/XingHuoChatClientTests.java
@@ -18,6 +18,7 @@ import java.util.List; @@ -18,6 +18,7 @@ import java.util.List;
18 import java.util.Scanner; 18 import java.util.Scanner;
19 import java.util.function.Consumer; 19 import java.util.function.Consumer;
20 20
  21 +// TODO 芋艿:整理单测
21 /** 22 /**
22 * 讯飞星火 tests 23 * 讯飞星火 tests
23 * <p> 24 * <p>
yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/chat/XingHuoOkHttpTests.java
@@ -17,6 +17,7 @@ import java.security.NoSuchAlgorithmException; @@ -17,6 +17,7 @@ import java.security.NoSuchAlgorithmException;
17 import java.text.SimpleDateFormat; 17 import java.text.SimpleDateFormat;
18 import java.util.*; 18 import java.util.*;
19 19
  20 +// TODO 芋艿:整理单测
20 /** 21 /**
21 * 讯飞星火 tests 22 * 讯飞星火 tests
22 * <p> 23 * <p>
yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/chat/YiYanChatTests.java
@@ -17,6 +17,7 @@ import java.util.ArrayList; @@ -17,6 +17,7 @@ import java.util.ArrayList;
17 import java.util.List; 17 import java.util.List;
18 import java.util.Scanner; 18 import java.util.Scanner;
19 19
  20 +// TODO 芋艿:整理单测
20 /** 21 /**
21 * chat 文心一言 22 * chat 文心一言
22 * <p> 23 * <p>
yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/openai/OpenAiImageClientTests.java renamed to yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/image/OpenAiImageClientTests.java
1 -package cn.iocoder.yudao.framework.ai.openai; 1 +package cn.iocoder.yudao.framework.ai.image;
2 2
3 import org.springframework.ai.image.ImagePrompt; 3 import org.springframework.ai.image.ImagePrompt;
4 import org.springframework.ai.image.ImageResponse; 4 import org.springframework.ai.image.ImageResponse;
@@ -15,6 +15,7 @@ import java.io.IOException; @@ -15,6 +15,7 @@ import java.io.IOException;
15 import java.util.Base64; 15 import java.util.Base64;
16 import java.util.Scanner; 16 import java.util.Scanner;
17 17
  18 +// TODO 芋艿:整理单测
18 /** 19 /**
19 * author: fansili 20 * author: fansili
20 * time: 2024/3/17 10:40 21 * time: 2024/3/17 10:40
yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/suno/SunoTests.java renamed to yudao-module-ai/yudao-spring-boot-starter-ai/src/test/java/cn/iocoder/yudao/framework/ai/music/SunoTests.java
1 -package cn.iocoder.yudao.framework.ai.suno; 1 +package cn.iocoder.yudao.framework.ai.music;
2 2
3 import cn.iocoder.yudao.framework.ai.core.model.suno.api.SunoApi; 3 import cn.iocoder.yudao.framework.ai.core.model.suno.api.SunoApi;
4 import org.junit.Before; 4 import org.junit.Before;
@@ -6,24 +6,24 @@ import org.junit.Test; @@ -6,24 +6,24 @@ import org.junit.Test;
6 6
7 import java.util.List; 7 import java.util.List;
8 8
  9 +// TODO 芋艿:整理单测
9 /** 10 /**
10 * @Author xiaoxin 11 * @Author xiaoxin
11 * @Date 2024/5/27 12 * @Date 2024/5/27
12 */ 13 */
13 public class SunoTests { 14 public class SunoTests {
14 15
15 - SunoApi sunoApi; 16 + private SunoApi sunoApi;
16 17
17 @Before 18 @Before
18 public void setup() { 19 public void setup() {
19 - String url = "https://suno-imrqwwui8-status2xxs-projects.vercel.app"; 20 + String url = "https://suno-om0w1cy6e-status2xxs-projects.vercel.app";
20 this.sunoApi = new SunoApi(url); 21 this.sunoApi = new SunoApi(url);
21 } 22 }
22 23
23 @Test 24 @Test
24 public void selectById() { 25 public void selectById() {
25 System.out.println(sunoApi.getMusicList(List.of("d460ddda-7c87-4f34-b751-419b08a590ca,ff90ea66-49cd-4fd2-b44c-44267dfd5551"))); 26 System.out.println(sunoApi.getMusicList(List.of("d460ddda-7c87-4f34-b751-419b08a590ca,ff90ea66-49cd-4fd2-b44c-44267dfd5551")));
26 -  
27 } 27 }
28 28
29 @Test 29 @Test
yudao-server/src/main/resources/application.yaml
@@ -201,7 +201,7 @@ yudao.ai: @@ -201,7 +201,7 @@ yudao.ai:
201 notify-url: http://java.nat300.top/admin-api/ai/image/midjourney/notify 201 notify-url: http://java.nat300.top/admin-api/ai/image/midjourney/notify
202 suno: 202 suno:
203 enable: true 203 enable: true
204 - base-url: https://suno-imrqwwui8-status2xxs-projects.vercel.app 204 + base-url: https://suno-om0w1cy6e-status2xxs-projects.vercel.app
205 205
206 --- #################### 芋道相关配置 #################### 206 --- #################### 芋道相关配置 ####################
207 207