添加paddle 工具

pom.xml

@@ -54,22 +54,15 @@
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>5.8.26</version>
+        </dependency>
     </dependencies>
 
     <build>
         <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <configuration>
-                    <annotationProcessorPaths>
-                        <path>
-                            <groupId>org.projectlombok</groupId>
-                            <artifactId>lombok</artifactId>
-                        </path>
-                    </annotationProcessorPaths>
-                </configuration>
-            </plugin>
             <plugin>
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-maven-plugin</artifactId>

src/main/java/com/supervision/dto/paddlespeech/req/AsrReqDTO.java

@@ -0,0 +1,21 @@
+package com.supervision.dto.paddlespeech.req;
+
+import lombok.Data;
+
+@Data
+public class AsrReqDTO {
+
+    private final String audio;
+
+    private final String audio_format = "wav";
+
+    private final Integer sample_rate = 16000;
+
+    private final String lang = "zh_cn";
+
+    private final Integer punc = 0;
+
+    public AsrReqDTO(String audio) {
+        this.audio = audio;
+    }
+}

src/main/java/com/supervision/dto/paddlespeech/req/TtsReqDTO.java

@@ -0,0 +1,23 @@
+package com.supervision.dto.paddlespeech.req;
+
+import lombok.Data;
+
+@Data
+public class TtsReqDTO {
+
+    private final String text;
+
+    private final Integer spk_id = 0;
+
+    private final Double speed = 1.0;
+
+    private final Double volume = 1.0;
+
+    private final Integer sample_rate = 16000;
+
+    private final String save_path = "./tts.wav";
+
+    public TtsReqDTO(String text) {
+        this.text = text;
+    }
+}

src/main/java/com/supervision/dto/paddlespeech/res/AsrResultDTO.java

@@ -0,0 +1,10 @@
+package com.supervision.dto.paddlespeech.res;
+
+import lombok.Data;
+
+@Data
+public class AsrResultDTO {
+
+    private String transcription;
+
+}

src/main/java/com/supervision/dto/paddlespeech/res/PaddleSpeechResDTO.java

@@ -0,0 +1,15 @@
+package com.supervision.dto.paddlespeech.res;
+
+import lombok.Data;
+
+@Data
+public class PaddleSpeechResDTO<T> {
+
+    private Boolean success;
+
+    private Integer code;
+
+    private Object message;
+
+    private T result;
+}

src/main/java/com/supervision/dto/paddlespeech/res/TtsResultDTO.java

@@ -0,0 +1,26 @@
+package com.supervision.dto.paddlespeech.res;
+
+import lombok.Data;
+
+@Data
+public class TtsResultDTO {
+
+    private String lang;
+
+    private String spk_id;
+
+    private String speed;
+
+    private String volume;
+
+    private String sample_rate;
+
+    private String duration;
+
+    private String save_path;
+
+    /**
+     * 语音的base64编码
+     */
+    private String audio;
+}

src/main/java/com/supervision/exception/BusinessException.java

@@ -0,0 +1,76 @@
+/*
+ * 文 件 名:  CustomException
+ * 版    权:
+ * 描    述:  <描述>
+ * 修 改 人:  RedName
+ * 修改时间:  2022/8/5
+ * 跟踪单号:  <跟踪单号>
+ * 修改单号:  <修改单号>
+ * 修改内容:  <修改内容>
+ */
+package com.supervision.exception;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatus;
+
+/**
+ * <功能详细描述>
+ * 自定义异常
+ *
+ * @author ljt
+ * @version [版本号, 2022/8/5]
+ * @see [相关类/方法]
+ * @since [产品/模块版本]
+ */
+@Slf4j
+public class BusinessException extends RuntimeException {
+    /**
+     * 异常编码
+     */
+    private final Integer code;
+
+    /**
+     * 异常信息
+     */
+    private final String message;
+
+    public BusinessException(Throwable cause) {
+        super(cause);
+        this.code = HttpStatus.INTERNAL_SERVER_ERROR.value();
+        this.message = null;
+
+    }
+
+    public BusinessException(Throwable cause, String message) {
+        super(cause);
+        this.code = HttpStatus.INTERNAL_SERVER_ERROR.value();
+        this.message = message;
+
+    }
+
+    public BusinessException(String message) {
+        this.code = HttpStatus.INTERNAL_SERVER_ERROR.value();
+        this.message = message;
+    }
+
+    public BusinessException(String message, Integer code) {
+        this.message = message;
+        this.code = code;
+    }
+
+    public BusinessException(String message, Throwable e) {
+        super(message, e);
+        log.error(message, e);
+        this.code = HttpStatus.INTERNAL_SERVER_ERROR.value();
+        this.message = message;
+    }
+
+    @Override
+    public String getMessage() {
+        return message;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+}

src/main/java/com/supervision/util/AsrUtil.java

@@ -0,0 +1,46 @@
+package com.supervision.util;
+
+import cn.hutool.core.codec.Base64;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.http.HttpUtil;
+import cn.hutool.json.JSONUtil;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.supervision.dto.paddlespeech.req.AsrReqDTO;
+import com.supervision.dto.paddlespeech.res.AsrResultDTO;
+import com.supervision.dto.paddlespeech.res.PaddleSpeechResDTO;
+import com.supervision.exception.BusinessException;
+import org.springframework.core.env.Environment;
+
+public class AsrUtil {
+
+    private static final String ASR_URL = SpringBeanUtil.getBean(Environment.class).getProperty("paddle-speech.asr");
+
+    private static final ObjectMapper objectMapper = new ObjectMapper();
+
+    /**
+     * 语音转文字
+     */
+    public static String asrTransformByBytes(byte[] bytes) {
+        // 首先编码为base64编码
+        String encode = Base64.encode(bytes);
+        return asrTransformByBytes(encode);
+    }
+
+    public static String asrTransformByBytes(String voiceBase64){
+        // 这里调用Python的接口,将文字转换为语音
+        String post = HttpUtil.post(ASR_URL, JSONUtil.toJsonStr(new AsrReqDTO(voiceBase64)));
+        try {
+            PaddleSpeechResDTO<AsrResultDTO> response = objectMapper.readValue(post, new TypeReference<PaddleSpeechResDTO<AsrResultDTO>>() {
+            });
+            if (!response.getSuccess() || ObjectUtil.isEmpty(response.getResult())) {
+                throw new BusinessException("语音转换文字失败");
+            }
+            return response.getResult().getTranscription();
+
+        } catch (Exception e) {
+            throw new BusinessException("语音转换文字失败");
+        }
+
+    }
+}

src/main/java/com/supervision/util/SpringBeanUtil.java

@@ -0,0 +1,127 @@
+package com.supervision.util;
+
+import cn.hutool.core.util.ArrayUtil;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/***
+ * @author ljt
+ * @since 2020/8/4 17:37
+ *
+ */
+@Component
+@Lazy(false)
+public class SpringBeanUtil implements ApplicationContextAware {
+
+	private static ApplicationContext applicationContext;
+
+	/**
+	 * 获取applicationContext
+	 *
+	 * @return ApplicationContext
+	 */
+	public static ApplicationContext getApplicationContext() {
+		return applicationContext;
+	}
+
+	@Override
+	public void setApplicationContext(ApplicationContext applicationContext) {
+		SpringBeanUtil.applicationContext = applicationContext;
+	}
+
+	//通过name获取 Bean.
+
+	/**
+	 * 通过name获取 Bean
+	 *
+	 * @param <T>  Bean类型
+	 * @param name Bean名称
+	 * @return Bean
+	 */
+	@SuppressWarnings("unchecked")
+	public static <T> T getBean(String name) {
+		return (T) applicationContext.getBean(name);
+	}
+
+	/**
+	 * 通过class获取Bean
+	 *
+	 * @param <T>   Bean类型
+	 * @param clazz Bean类
+	 * @return Bean对象
+	 */
+	public static <T> T getBean(Class<T> clazz) {
+		return applicationContext.getBean(clazz);
+	}
+
+	/**
+	 * 通过name,以及Clazz返回指定的Bean
+	 *
+	 * @param <T>   bean类型
+	 * @param name  Bean名称
+	 * @param clazz bean类型
+	 * @return Bean对象
+	 */
+	public static <T> T getBean(String name, Class<T> clazz) {
+		return applicationContext.getBean(name, clazz);
+	}
+
+	/**
+	 * 获取指定类型对应的所有Bean，包括子类
+	 *
+	 * @param <T>  Bean类型
+	 * @param type 类、接口，null表示获取所有bean
+	 * @return 类型对应的bean，key是bean注册的name，value是Bean
+	 * @since 5.3.3
+	 */
+	public static <T> Map<String, T> getBeansOfType(Class<T> type) {
+		return applicationContext.getBeansOfType(type);
+	}
+
+	/**
+	 * 获取指定类型对应的Bean名称，包括子类
+	 *
+	 * @param type 类、接口，null表示获取所有bean名称
+	 * @return bean名称
+	 * @since 5.3.3
+	 */
+	public static String[] getBeanNamesForType(Class<?> type) {
+		return applicationContext.getBeanNamesForType(type);
+	}
+
+	/**
+	 * 获取配置文件配置项的值
+	 *
+	 * @param key 配置项key
+	 * @return 属性值
+	 * @since 5.3.3
+	 */
+	public static String getProperty(String key) {
+		return applicationContext.getEnvironment().getProperty(key);
+	}
+
+	/**
+	 * 获取当前的环境配置，无配置返回null
+	 *
+	 * @return 当前的环境配置
+	 * @since 5.3.3
+	 */
+	public static String[] getActiveProfiles() {
+		return applicationContext.getEnvironment().getActiveProfiles();
+	}
+
+	/**
+	 * 获取当前的环境配置，当有多个环境配置时，只获取第一个
+	 *
+	 * @return 当前的环境配置
+	 * @since 5.3.3
+	 */
+	public static String getActiveProfile() {
+		final String[] activeProfiles = getActiveProfiles();
+		return ArrayUtil.isNotEmpty(activeProfiles) ? activeProfiles[0] : null;
+	}
+}

src/main/java/com/supervision/util/TtsUtil.java

@@ -0,0 +1,35 @@
+package com.supervision.util;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.http.HttpUtil;
+import cn.hutool.json.JSONUtil;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.supervision.dto.paddlespeech.req.TtsReqDTO;
+import com.supervision.dto.paddlespeech.res.PaddleSpeechResDTO;
+import com.supervision.dto.paddlespeech.res.TtsResultDTO;
+import com.supervision.exception.BusinessException;
+import org.springframework.core.env.Environment;
+
+public class TtsUtil {
+
+    private static final String TTS_URL = SpringBeanUtil.getBean(Environment.class).getProperty("paddle-speech.tts");
+
+    private static final ObjectMapper objectMapper = new ObjectMapper();
+
+    public static TtsResultDTO ttsTransform(String str) {
+        // 构建
+        String post = HttpUtil.post(TTS_URL, JSONUtil.toJsonStr(new TtsReqDTO(str)));
+        try {
+            PaddleSpeechResDTO<TtsResultDTO> response = objectMapper.readValue(post, new TypeReference<PaddleSpeechResDTO<TtsResultDTO>>() {
+            });
+            if (!response.getSuccess() || ObjectUtil.isEmpty(response.getResult())) {
+                throw new BusinessException("文字转换语音失败");
+            }
+            return response.getResult();
+        } catch (Exception e) {
+            throw new BusinessException("语音转换文字失败", e);
+        }
+
+    }
+}

src/test/java/com/supervision/SpeechDemoServiceApplicationTests.java

@@ -1,6 +1,12 @@
 package com.supervision;
 
+import cn.hutool.json.JSONUtil;
+import com.supervision.dto.paddlespeech.res.TtsResultDTO;
+import com.supervision.util.AsrUtil;
+import com.supervision.util.TtsUtil;
 import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.test.context.SpringBootTest;
 
 @SpringBootTest
@@ -10,4 +16,21 @@ class SpeechDemoServiceApplicationTests {
     void contextLoads() {
     }
 
+
+    @Test
+    void testTtsTransform() {
+        TtsResultDTO ttsResultDTO = TtsUtil.ttsTransform("你好，我是小爱同学");
+        System.out.println(JSONUtil.toJsonStr(ttsResultDTO));
+
+    }
+
+    @Value("${paddle-speech.text:xx}")
+    private String voiceBase64;
+    @Test
+    void testAsrTransform2() {
+
+        String text = AsrUtil.asrTransformByBytes(voiceBase64);
+        System.out.println(text);
+
+    }
 }