修改mq的配置

joying-admin/src/main/java/com/fzm/admin/listener/CopyrightLister.java

@@ -130,7 +130,7 @@ public class CopyrightLister {
     }
 
     public static void main(String[] args) {
-        String param = "{\"charset\":\"utf-8\",\"biz_content\":\"{\\\"serial_code\\\":\\\"21122777035\\\"}\",\"sign\":\"0447d87137e87ab5533821688d70da2c\",\"version\":\"1.0\",\"app_id\":\"289391457858\",\"sign_type\":\"md5\",\"timestamp\":\"2021-12-27 14:51:00\"}";
+        String param = " {\"charset\":\"utf-8\",\"biz_content\":\"{\\\"serial_code\\\":\\\"21123030879\\\"}\",\"sign\":\"db432c9e6bc9d16a1e051f093d58ee33\",\"version\":\"1.0\",\"app_id\":\"289391457858\",\"sign_type\":\"md5\",\"timestamp\":\"2021-12-30 16:00:21\"}";
         String response = HttpUtil.post("https://p.yareiot.com/ccct/api/copyright/query", param, 10000);
         System.out.println(response);
     }

joying-admin/src/main/resources/application-dev.yml

@@ -53,12 +53,7 @@ spring:
     password: admin
     listener:
       simple:
-        retry:
-          enabled: true
-          max-attempts: 5
-          initial-interval: 1000
-          multiplier: 2
-          stateless: true
+        acknowledge-mode: auto #acknowledge-mode: none，关闭ack；manual，手动ack；auto：自动ack
 swagger:
   title: 乐映影视后台管理系统
   description: 乐映影视后台管理系统RESTFUL API

joying-admin/src/main/resources/application-local.yml

@@ -54,12 +54,7 @@ spring:
     password: admin
     listener:
       simple:
-        retry:
-          enabled: true
-          max-attempts: 5
-          initial-interval: 1000
-          multiplier: 2
-          stateless: true
+        acknowledge-mode: auto #acknowledge-mode: none，关闭ack；manual，手动ack；auto：自动ack
 swagger:
   title: 乐映影视乐映影视后台管理系统
   description: 乐映影视后台管理系统RESTFUL API

joying-admin/src/main/resources/application-nj.yml

@@ -54,12 +54,7 @@ spring:
     password: guest
     listener:
       simple:
-        retry:
-          enabled: true
-          max-attempts: 5
-          initial-interval: 1000
-          multiplier: 2
-          stateless: true
+        acknowledge-mode: auto #acknowledge-mode: none，关闭ack；manual，手动ack；auto：自动ack
 swagger:
   title: 乐映影视后台管理系统
   description: 乐映影视后台管理系统RESTFUL API

joying-admin/src/main/resources/application-test.yml

@@ -53,12 +53,7 @@ spring:
     password: admin
     listener:
       simple:
-        retry:
-          enabled: true
-          max-attempts: 5
-          initial-interval: 1000
-          multiplier: 2
-          stateless: true
+        acknowledge-mode: auto #acknowledge-mode: none，关闭ack；manual，手动ack；auto：自动ack
 swagger:
   title: 乐映影视乐映影视后台管理系统
   description: 乐映影视后台管理系统RESTFUL API

joying-admin/src/main/resources/application.yml

 spring:
   profiles:
-    active: local
+    active: nj
   application:
     name: ly-admin
 

joying-common/src/main/java/com/fzm/common/service/impl/CopyrightApplyServiceImpl.java

@@ -30,6 +30,7 @@ import com.github.pagehelper.PageInfo;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.dao.DuplicateKeyException;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -110,7 +111,12 @@ public class CopyrightApplyServiceImpl extends ServiceImpl<CopyrightApplyMapper,
         copyrightApply.setRegisterState(CopyrightApplyState.TO_BE_REVIEWED.getCode());
         copyrightApply.setUserId(user.getId());
         copyrightApply.setApplyTime(new Date());
+        try {
             save(copyrightApply);
+        } catch (DuplicateKeyException e) {
+            throw GlobalException.newException(ResultCode.FAILED, "当前存证已提交过版权申请, 请勿重复提交");
+        }
+
         // 保存附件
         ArrayList<CopyrightFile> files = new ArrayList<>();
         for (CopyrightDTO.File file : copyrightDTO.getFiles()) {