hby100japp功能,语音音量增加

fys-admin/src/main/java/com/fuyuanshen/app/service/AudioProcessService.java

@@ -14,6 +14,7 @@ import com.fuyuanshen.equipment.utils.AlibabaTTSUtil;
 import com.fuyuanshen.equipment.utils.AudioProcessUtil;
 import com.fuyuanshen.equipment.utils.FileHashUtil;
 import com.fuyuanshen.equipment.utils.Mp3Duration;
+import com.fuyuanshen.global.mqtt.utils.FfmpegVolumeUtil;
 import com.fuyuanshen.system.domain.vo.SysOssVo;
 import com.fuyuanshen.system.service.ISysOssService;
 import lombok.RequiredArgsConstructor;
@@ -195,6 +196,7 @@ public class AudioProcessService {
             fos.write(data);
         }
 
+
         return file.getAbsolutePath();
     }
 
@@ -450,6 +452,7 @@ public class AudioProcessService {
         String accessKeySecret = "2F3sdoBJ08bYvJcuDgSkLnJwGXsvYH";
         String appKey = "lbGuq5K5bEH4uxmT";
         String savedPath = null;
+        String savedMp3VolumePath = null;
         try {
             // 使用HTTP方式调用
             HttpTtsClient httpClient = new HttpTtsClient(accessKeyId, accessKeySecret, appKey);
@@ -457,26 +460,31 @@ public class AudioProcessService {
             byte[] mp3Data = httpClient.synthesizeTextToMp3(text,fileSuffix);
 //            byte[] mp3Data = alibabaTTSUtil.synthesizeTextToMp3(text);
 
-            SysOssVo upload = ossService.upload(mp3Data, generateRandomFileName(fileSuffix));
+
+            AppBusinessFileBo appBusinessFileBo = new AppBusinessFileBo();
+
+            savedPath = saveByteArrayToFile(mp3Data, generateRandomFileName(fileSuffix));
+
+            Integer mp3Duration = getMp3Duration2(savedPath);
+            appBusinessFileBo.setDuration(mp3Duration);
+
+            String directory = System.getProperty("java.io.tmpdir"); // 使用系统临时目录
+            File file = new File(directory, generateRandomFileName(fileSuffix));
+            savedMp3VolumePath = file.getAbsolutePath();
+            FfmpegVolumeUtil.increaseMp3Volume(savedPath, savedMp3VolumePath, 12);
+
+            String fileHash = fileHashUtil.getFileHash(file,"SHA-256");
+            SysOssVo upload = ossService.updateHash(file, fileHash);
 
             // 强制将HTTP替换为HTTPS
             if (upload.getUrl() != null && upload.getUrl().startsWith("http://")) {
                 upload.setUrl(upload.getUrl().replaceFirst("^http://", "https://"));
             }
 
-
-            AppBusinessFileBo appBusinessFileBo = new AppBusinessFileBo();
             appBusinessFileBo.setFileId(upload.getOssId());
             appBusinessFileBo.setBusinessId(deviceId);
             appBusinessFileBo.setFileType(3L);
             appBusinessFileBo.setCreateBy(AppLoginHelper.getUserId());
-            savedPath = saveByteArrayToFile(mp3Data, generateRandomFileName(fileSuffix));
-            if (savedPath != null) {
-                log.info("MP3文件已保存: {}", savedPath);
-                Integer mp3Duration = Mp3Duration.getMp3Duration(savedPath);
-                log.info("MP3文件时长: {} 秒", mp3Duration);
-                appBusinessFileBo.setDuration(mp3Duration);
-            }
             appBusinessFileService.insertByBo(appBusinessFileBo);
             if (upload != null) {
                 return upload.getUrl();
@@ -488,10 +496,23 @@ public class AudioProcessService {
             if(savedPath != null){
                 deleteTempFile(new File(savedPath));
             }
+            if(savedMp3VolumePath != null){
+                deleteTempFile(new File(savedMp3VolumePath));
+            }
         }
         return null;
     }
 
+    private Integer getMp3Duration2(String savedPath) {
+        if (savedPath != null) {
+            log.info("MP3文件已保存: {}", savedPath);
+            Integer mp3Duration = Mp3Duration.getMp3Duration(savedPath);
+            log.info("MP3文件时长: {} 秒", mp3Duration);
+            return  mp3Duration;
+        }
+        return 0;
+    }
+
     private static final Random random = new Random();
     private static final DateTimeFormatter formatter =
             DateTimeFormatter.ofPattern("yyyyMMddHHmmss");

fys-admin/src/main/java/com/fuyuanshen/global/mqtt/utils/FfmpegVolumeUtil.java

@@ -0,0 +1,81 @@
+package com.fuyuanshen.global.mqtt.utils;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+
+public class FfmpegVolumeUtil {
+
+    /**
+     * 使用FFmpeg增加MP3文件的音量
+     *
+     * @param inputFilePath  输入MP3文件路径
+     * @param outputFilePath 输出MP3文件路径
+     * @param volumeGain     音量增益（例如：1.5表示增加50%音量，2.0表示翻倍）
+     */
+    public static void increaseMp3Volume(String inputFilePath, String outputFilePath, int volumeGain) {
+        boolean ffmpegAvailable = isFfmpegAvailable();
+        if (!ffmpegAvailable) {
+            System.err.println("FFmpeg未安装或未找到！请安装FFmpeg并确保在系统路径中。");
+            return;
+        }
+        Process process = null;
+        try {
+            // 构建FFmpeg命令
+            String command = String.format(
+                    "ffmpeg -i \"%s\" -af \"volume=%sdB\" \"%s\"",
+                    inputFilePath,
+                    volumeGain,
+                    outputFilePath
+            );
+
+            System.out.println("执行命令: " + command);
+
+            // 执行FFmpeg命令
+            process = Runtime.getRuntime().exec(command);
+
+            // 读取命令执行结果
+            BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
+            String line;
+            while ((line = reader.readLine()) != null) {
+                System.out.println(line);
+            }
+
+            // 等待命令执行完成
+            int exitCode = process.waitFor();
+            if (exitCode == 0) {
+                System.out.println("音量调整成功！输出文件：" + outputFilePath);
+            } else {
+                System.err.println("FFmpeg命令执行失败，退出码：" + exitCode);
+            }
+        } catch (IOException | InterruptedException e) {
+            e.printStackTrace();
+        } finally {
+            if (process != null) {
+                process.destroy();
+            }
+        }
+    }
+
+    public static void main(String[] args) {
+
+        // 示例用法
+        String inputPath = "D:\\http_output9.mp3";
+        String outputPath = "D:\\output17.mp3";
+        int volumeGain = 12;
+
+        increaseMp3Volume(inputPath, outputPath, volumeGain);
+    }
+
+    private static boolean isFfmpegAvailable() {
+        try {
+            Process process = Runtime.getRuntime().exec("ffmpeg -version");
+            int exitCode = process.waitFor();
+            return exitCode == 0;
+        } catch (Exception e) {
+            return false;
+        }
+    }
+
+}
+

fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/utils/FileHashUtil.java

@@ -4,6 +4,8 @@ import org.apache.commons.codec.digest.DigestUtils;
 import org.springframework.stereotype.Component;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.io.File;
+import java.io.FileInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.security.MessageDigest;
@@ -67,4 +69,32 @@ public class FileHashUtil {
             throw new IllegalStateException("算法 " + ALGORITHM + " 不可用", e);
         }
     }
+
+    /**
+     * 获取文件的哈希值
+     * // 或者使用特定算法
+     * String md5Hash = getFileHash(audioFile, "MD5");
+     * String sha256Hash = getFileHash(audioFile, "SHA-256");
+     * @param file       文件
+     * @param algorithm  哈希算法
+     * @return 文件的哈希值
+     * @throws Exception 获取文件哈希值时发生的异常
+     */
+    public String getFileHash(File file, String algorithm) throws Exception {
+        MessageDigest md = MessageDigest.getInstance(algorithm);
+        try (FileInputStream fis = new FileInputStream(file)) {
+            byte[] buffer = new byte[8192];
+            int bytesRead;
+            while ((bytesRead = fis.read(buffer)) != -1) {
+                md.update(buffer, 0, bytesRead);
+            }
+        }
+        byte[] hashBytes = md.digest();
+        StringBuilder sb = new StringBuilder();
+        for (byte b : hashBytes) {
+            sb.append(String.format("%02x", b));
+        }
+        return sb.toString();
+    }
+
 }

fys-modules/fys-system/src/main/java/com/fuyuanshen/system/service/ISysOssService.java

@@ -68,6 +68,13 @@ public interface ISysOssService {
      */
     SysOssVo updateHash(MultipartFile file, String hash);
 
+    /**
+     * 更新文件 hash 值
+     *
+     * @param file 文件对象
+     * @return 匹配的 SysOssVo 列表
+     */
+    SysOssVo updateHash(File file, String hash);
     /**
      * 上传 MultipartFile 到对象存储服务，并保存文件信息到数据库
      *

fys-modules/fys-system/src/main/java/com/fuyuanshen/system/service/impl/SysOssServiceImpl.java

@@ -226,6 +226,22 @@ public class SysOssServiceImpl implements ISysOssService, OssService {
         return buildResultEntity(originalfileName, suffix, storage.getConfigKey(), uploadResult, hash);
     }
 
+    @Override
+    public SysOssVo updateHash(File file, String hash) {
+        // 2. 先根据 hash 查库（秒传）
+        SysOssVo exist = baseMapper.selectByHash(hash);
+        if (exist != null) {
+            return exist;
+        }
+
+        String originalfileName = file.getName();
+        String suffix = StringUtils.substring(originalfileName, originalfileName.lastIndexOf("."), originalfileName.length());
+        OssClient storage = OssFactory.instance();
+        UploadResult uploadResult = storage.uploadSuffix(file, suffix);
+        // 保存文件信息
+        return buildResultEntity(originalfileName, suffix, storage.getConfigKey(), uploadResult, hash);
+    }
+
 
     /**
      * 上传 MultipartFile 到对象存储服务，并保存文件信息到数据库