diff --git a/src/main/java/com/peanut/common/utils/BaiduVoicesUtils.java b/src/main/java/com/peanut/common/utils/BaiduVoicesUtils.java index 00617b5d..49ff33e6 100644 --- a/src/main/java/com/peanut/common/utils/BaiduVoicesUtils.java +++ b/src/main/java/com/peanut/common/utils/BaiduVoicesUtils.java @@ -21,35 +21,8 @@ public class BaiduVoicesUtils { // 填写申请百度语音申请的appkey 申请地址：百度AI开放平台 private final static String appKey = "WOKN473V1o1gL8WMsAkfJZIY"; private final static String secretKey = "CpgbKdB9aZu2esnq5lMdqRZG37Jn3a76"; - //http://aipe-speech.bj.bcebos.com/text_to_speech/2024-12-06/6752c65ee615a10001435c06/speech/0.null?authorization=bce-auth-v1%2FALTAKjI91nE52nvtDNRgFlUCVz%2F2024-12-06T09%3A41%3A51Z%2F259200%2F%2F08aed96bc0e5808a83c1a80ee3a925866a2a7ac5b017e29670fe7951f713bbf6 - - public static void main(String[] arg){ - try { - System.out.println(new Date().getTime()); -// File audioFile = new File("F:\\111.wav");// 创建一个文件对象 -// AudioFileFormat fileFormat = AudioSystem.getAudioFileFormat(audioFile);// 获音频文件格式 -// float sampleRate = fileFormat.getFormat().getSampleRate(); -// int samplesizeInBits = fileFormat.getFormat().getSampleSizeInBits(); -// int aaa = fileFormat.getByteLength(); -// System.out.println("sampleRate: " + sampleRate); -// System.out.println("samplesizeInBits: " + samplesizeInBits); -// System.out.println("aaa: " + aaa); - String text = "天地之道者 ，理也 ； 万物之始者 ， 气也 ； 气之聚散者 ， 象也； 物之终始者 ，数也 。为 医者尤需明理 ，理不明则法不清 ， 法不清则 方药无凭 。 医之理者 ，病理也 ， 然欲明病理 ，先知生理 ，故太湖无 中医基础理论课程而有生理 、病理 。生之理者 ，《 内经》 所谓人事 也 ，至于天人之学 ， 尚需于太湖国学院求之 。经谓精光之论 ， 大圣"; -// shortText("补充一点，桂枝的主要有效成分是挥发油，大概占桂枝 重量的0.7%左右，不到1%。桂枝挥发油有一个特点，它由呼 吸道排出，对呼吸道炎症有明显的抗炎、祛痰、止咳作用，所 以在麻黄汤里，桂枝既增强了麻黄的发汗作用，又增强了杏仁 的化痰止咳平喘作用。"); -// System.out.println(JacobUtil.toVoice(text)); - -// MP3File file = new MP3File("F:/a.mp3"); -// MP3AudioHeader audioHeader = (MP3AudioHeader)file.getAudioHeader(); -// int intLen = audioHeader.getTrackLength(); -// System.out.println(intLen); - - System.out.println(new Date().getTime()); - }catch (Exception e) { - e.printStackTrace(); - } - } - + //语音合并 public static String mergeVoices(List urls){ try { File outFile = File.createTempFile(UUID.randomUUID().toString(),".mp3",new File("..\\")); diff --git a/src/main/java/com/peanut/common/utils/JacobUtil.java b/src/main/java/com/peanut/common/utils/JacobUtil.java index 12361186..831ccca9 100644 --- a/src/main/java/com/peanut/common/utils/JacobUtil.java +++ b/src/main/java/com/peanut/common/utils/JacobUtil.java @@ -28,35 +28,24 @@ import java.util.UUID; //文字转语音离线工具，windows平台 public class JacobUtil { - public static String toVoice(String text) { + public static void toVoice(String text,File file) { try { + //生成wav音频文件 直接生成MP3文件，获取不到文件头，转换一下才可以 File wavFile = File.createTempFile(UUID.randomUUID().toString(),".wav",new File("..\\")); text(wavFile.getAbsolutePath(),text,100,0); + //wav转mp3文件 byte[] bytes = encodeToMp3(wavFile); - File file = File.createTempFile(UUID.randomUUID().toString(),".mp3",new File("..\\")); FileCopyUtils.copy(bytes,file); - - String fileUrl = uploadFile(file,".mp3"); - if (StringUtils.isNotBlank(fileUrl)){ - MP3File mp3File = new MP3File(file); - MP3AudioHeader audioHeader = (MP3AudioHeader)mp3File.getAudioHeader(); - double intLen = audioHeader.getPreciseTrackLength(); - BigDecimal bd = new BigDecimal(intLen); - bd = bd.setScale(4, BigDecimal.ROUND_HALF_UP); - file.delete(); - fileUrl+=","+bd.toString(); - } - file.delete(); - return fileUrl; + wavFile.delete(); }catch (Exception e) { e.printStackTrace(); - return ""; } } + + //wav转mp3工具，在项目resources-lib下有jar包 public static byte[] encodeToMp3(File wavFile) throws Exception { InputStream wavTestFileInputStream = new BufferedInputStream(new FileInputStream(wavFile)); AudioInputStream audioInputStream = AudioSystem.getAudioInputStream(wavTestFileInputStream); - // LameEncoder encoder = new LameEncoder(audioInputStream.getFormat(), 256, MPEGMode.STEREO, Lame.QUALITY_HIGHEST, false); LameEncoder encoder = new LameEncoder(audioInputStream.getFormat(), 128, MPEGMode.STEREO, Lame.QUALITY_HIGHEST, false); ByteArrayOutputStream mp3 = new ByteArrayOutputStream(); byte[] inputBuffer = new byte[encoder.getPCMBufferSize()]; @@ -70,27 +59,6 @@ public class JacobUtil { encoder.close(); return mp3.toByteArray(); } - public static String uploadFile(File file, String fileName) { - String endpoint = ConstantPropertiesUtils.END_POIND; - String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID; - String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET; - String bucketName = ConstantPropertiesUtils.BUCKET_NAME; - try { - OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); - String uuid = UUID.randomUUID().toString().replaceAll("-", ""); - fileName = uuid + fileName; - String datePath = new DateTime().toString("yyyy/MM/dd"); - fileName = datePath + "/" + fileName; - ossClient.putObject(bucketName, fileName, file); - ossClient.shutdown(); - String url = "https://" + bucketName + "." + endpoint + "/" + fileName; - return url; - } catch (Exception e) { - e.printStackTrace(); - return null; - } - } - public static boolean text(String path, String text, int volume, int speed) { try { diff --git a/src/main/java/com/peanut/modules/book/controller/BookChapterContentController.java b/src/main/java/com/peanut/modules/book/controller/BookChapterContentController.java index d29bd253..e39e8a5a 100644 --- a/src/main/java/com/peanut/modules/book/controller/BookChapterContentController.java +++ b/src/main/java/com/peanut/modules/book/controller/BookChapterContentController.java @@ -56,22 +56,17 @@ public class BookChapterContentController { private ShopProductBookService shopProductBookService; - //章节内容单句转成音频 + //某一内容转成音频 @RequestMapping("/contentToVoices") public R contentToVoices(@RequestBody Map params){ - //调用百度语音合成 API -// String voices = BaiduVoicesUtils.shortText(params.get("content").toString()); - String voices = JacobUtil.toVoice(params.get("content").toString()); - if (StringUtils.isEmpty(voices)) { - return R.error("语音上传失败"); - } - return R.ok().put("voices", voices); + bookChapterContentService.contentToVoices(params.get("bookChapterContentId").toString()); + return R.ok(); } - //按一句话转成短音频 + //书籍下所有内容转成音频 @RequestMapping("/bookToShortVoices") public R bookToShortVoices(@RequestBody Map params){ - ExecutorService service = Executors.newFixedThreadPool(5); + ExecutorService service = Executors.newFixedThreadPool(10); List list = bookChapterContentService.list(new LambdaQueryWrapper() .eq(BookChapterContentEntity::getBookId,params.get("bookId"))); for (BookChapterContentEntity bcc:list){ @@ -79,20 +74,7 @@ public class BookChapterContentController { service.execute(new Runnable() { @Override public void run() { - try { - //调用百度语音合成 API -// String voices = BaiduVoicesUtils.shortText(bcc.getContent()); - String voices = JacobUtil.toVoice(bcc.getContent()); - if (voices.contains(",")){ - bcc.setVoices(voices.split(",")[0]); - bcc.setVoicesSize(voices.split(",")[1]); - }else { - bcc.setVoices(voices); - } - bookChapterContentService.updateById(bcc); - }catch (Exception e) { - e.printStackTrace(); - } + bookChapterContentService.contentToVoices(bcc.getId()+""); } }); } @@ -100,7 +82,7 @@ public class BookChapterContentController { return R.ok(); } - //章节下所有音频合并成一个音频 + //某一章节下所有音频合并成一个音频 @RequestMapping("/mergeVoices") public R mergeVoices(@RequestBody Map params){ List bccs = bookChapterContentService.list(new LambdaQueryWrapper() @@ -123,7 +105,7 @@ public class BookChapterContentController { } } - //所有章节合并音频 + //所有章节合并各自音频 @RequestMapping("/mergeVoicesByBookId") @Transactional public R mergeVoicesByBookId(@RequestBody Map params){ @@ -131,25 +113,27 @@ public class BookChapterContentController { List bcs = bookChapterService.list(new LambdaQueryWrapper() .eq(BookChapterEntity::getBookId,params.get("bookId")) .orderByAsc(BookChapterEntity::getNumber)); + ExecutorService service = Executors.newFixedThreadPool(10); for (BookChapterEntity bc:bcs) { - List bccs = bookChapterContentService.list(new LambdaQueryWrapper() - .eq(BookChapterContentEntity::getBookChatperId,bc.getId()) - .orderByAsc(BookChapterContentEntity::getNumber)); - List list = new ArrayList<>(); - for (BookChapterContentEntity bcc : bccs) { - if (!StringUtils.isEmpty(bcc.getVoices())){ - list.add(bcc.getVoices()); + service.execute(new Runnable() { + @Override + public void run() { + List bccs = bookChapterContentService.list(new LambdaQueryWrapper() + .eq(BookChapterContentEntity::getBookChatperId,bc.getId()) + .orderByAsc(BookChapterContentEntity::getNumber)); + List list = new ArrayList<>(); + for (BookChapterContentEntity bcc : bccs) { + if (!StringUtils.isEmpty(bcc.getVoices())){ + list.add(bcc.getVoices()); + } + } + String url = BaiduVoicesUtils.mergeVoices(list); + bc.setVoices(url); + bookChapterService.updateById(bc); } - } - String url = BaiduVoicesUtils.mergeVoices(list); - if (!StringUtils.isEmpty(url)){ - bc.setVoices(url); - bookChapterService.updateById(bc); - }else { - sb.append(bc.getChapter()+"-"+bc.getContent()+"错误"); - } + }); } - return R.ok().put("info",sb.toString()); + return R.ok(); } //按章节转成长音频 diff --git a/src/main/java/com/peanut/modules/book/service/BookChapterContentService.java b/src/main/java/com/peanut/modules/book/service/BookChapterContentService.java index 1aa351a6..bdf0e90a 100644 --- a/src/main/java/com/peanut/modules/book/service/BookChapterContentService.java +++ b/src/main/java/com/peanut/modules/book/service/BookChapterContentService.java @@ -15,6 +15,8 @@ import java.util.Map; */ public interface BookChapterContentService extends IService { + void contentToVoices(String bccId); + PageUtils queryPage(Map params); void getBookVoices(Integer id); diff --git a/src/main/java/com/peanut/modules/book/service/impl/BookChapterContentServiceImpl.java b/src/main/java/com/peanut/modules/book/service/impl/BookChapterContentServiceImpl.java index fec53b8d..45388d7a 100644 --- a/src/main/java/com/peanut/modules/book/service/impl/BookChapterContentServiceImpl.java +++ b/src/main/java/com/peanut/modules/book/service/impl/BookChapterContentServiceImpl.java @@ -1,20 +1,30 @@ package com.peanut.modules.book.service.impl; import com.peanut.common.utils.FileDownloadUtil; +import com.peanut.common.utils.JacobUtil; import com.peanut.modules.common.entity.BookChapterEntity; import com.peanut.modules.common.entity.BookEntity; import com.peanut.modules.book.service.BookChapterService; import com.peanut.modules.book.service.BookService; +import com.peanut.modules.oss.service.OssService; import com.spire.doc.Document; import com.spire.doc.Section; import com.spire.doc.documents.Paragraph; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; +import org.jaudiotagger.audio.mp3.MP3AudioHeader; +import org.jaudiotagger.audio.mp3.MP3File; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; + +import java.io.ByteArrayInputStream; +import java.io.File; import java.io.InputStream; +import java.math.BigDecimal; import java.text.BreakIterator; import java.util.List; import java.util.Map; +import java.util.UUID; + import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -32,6 +42,44 @@ public class BookChapterContentServiceImpl extends ServiceImpl params) { diff --git a/src/main/java/com/peanut/modules/oss/service/OssService.java b/src/main/java/com/peanut/modules/oss/service/OssService.java index 7e61208c..5c225e86 100644 --- a/src/main/java/com/peanut/modules/oss/service/OssService.java +++ b/src/main/java/com/peanut/modules/oss/service/OssService.java @@ -3,12 +3,19 @@ package com.peanut.modules.oss.service; import com.peanut.common.utils.R; import org.springframework.web.multipart.MultipartFile; +import java.io.File; +import java.io.InputStream; + public interface OssService { //上传头像到oss String uploadFileAvatar(MultipartFile file); String uploadFileSchedule(MultipartFile file,String uid); + String uploadFile(File file); + + String uploadFile(InputStream inputStream, String fileName); + String uploadHtml(String html,String name); R getSchedule(String uid); diff --git a/src/main/java/com/peanut/modules/oss/service/impl/OssServiceImpl.java b/src/main/java/com/peanut/modules/oss/service/impl/OssServiceImpl.java index c116e123..13433f9d 100644 --- a/src/main/java/com/peanut/modules/oss/service/impl/OssServiceImpl.java +++ b/src/main/java/com/peanut/modules/oss/service/impl/OssServiceImpl.java @@ -15,6 +15,7 @@ import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import java.io.ByteArrayInputStream; +import java.io.File; import java.io.InputStream; import java.util.UUID; @@ -76,6 +77,49 @@ public class OssServiceImpl implements OssService { } } + public String uploadFile(File file) { + String endpoint = ConstantPropertiesUtils.END_POIND; + String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID; + String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET; + String bucketName = ConstantPropertiesUtils.BUCKET_NAME; + try { + OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); + String uuid = UUID.randomUUID().toString().replaceAll("-", ""); + String fileName = file.getName(); + fileName = uuid + fileName; + String datePath = new DateTime().toString("yyyy/MM/dd"); + fileName = datePath + "/" + fileName; + ossClient.putObject(bucketName, fileName, file); + ossClient.shutdown(); + String url = "https://" + bucketName + "." + endpoint + "/" + fileName; + return url; + } catch (Exception e) { + e.printStackTrace(); + return null; + } + } + + public String uploadFile(InputStream inputStream, String fileName) { + String endpoint = ConstantPropertiesUtils.END_POIND; + String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID; + String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET; + String bucketName = ConstantPropertiesUtils.BUCKET_NAME; + try { + OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); + String uuid = UUID.randomUUID().toString().replaceAll("-", ""); + fileName = uuid + fileName; + String datePath = new DateTime().toString("yyyy/MM/dd"); + fileName = datePath + "/" + fileName; + ossClient.putObject(bucketName, fileName, inputStream); + ossClient.shutdown(); + String url = "https://" + bucketName + "." + endpoint + "/" + fileName; + return url; + } catch (Exception e) { + e.printStackTrace(); + return null; + } + } + @Override public String uploadHtml(String html, String name) { // 工具类获取值