统一不处理

src/main/java/com/usky/dxtop/service/listener/CartGetMqListener.java

@@ -29,7 +29,7 @@ public class CartGetMqListener {
         try {
             //消息类型
             String s = new String(message.getBody(), StandardCharsets.UTF_8);
-            msgLogService.consumerSuccess(s,msgLog -> log.info("处理完成"));
+            msgLogService.consumerSuccess(s,msgLog -> {});
         } catch (Exception e) {
             log.info("charge_trans_produce"+"异常信息：" + e.getMessage());
             throw new CustomException(e.getMessage());

src/main/java/com/usky/dxtop/service/listener/FaceMqListener.java

@@ -24,7 +24,7 @@ public class FaceMqListener {
     public void dealDeclareMessage(Message message) {
         try {
             String s = new String(message.getBody(), StandardCharsets.UTF_8);
-            msgLogService.consumerSuccess(s,msgLog -> log.info("处理完成"));
+            msgLogService.consumerSuccess(s,msgLog -> {});
         } catch (Exception e) {
             log.info("charge_trans_produce"+"异常信息：" + e.getMessage());
         } finally {

src/main/java/com/usky/dxtop/service/listener/GroupMqListener.java

@@ -24,7 +24,7 @@ public class GroupMqListener {
     public void dealDeclareMessage(Message message) {
         try {
             String s = new String(message.getBody(), StandardCharsets.UTF_8);
-            msgLogService.consumerSuccess(s,msgLog -> log.info("处理完成"));
+            msgLogService.consumerSuccess(s,msgLog -> {});
         } catch (Exception e) {
             log.info("charge_trans_produce"+"异常信息：" + e.getMessage());
         } finally {

src/main/java/com/usky/dxtop/service/listener/PersonMqListener.java

@@ -24,7 +24,7 @@ public class PersonMqListener {
     public void dealDeclareMessage(Message message) {
         try {
             String s = new String(message.getBody(), StandardCharsets.UTF_8);
-            msgLogService.consumerSuccess(s,msgLog -> log.info("处理完成"));
+            msgLogService.consumerSuccess(s,msgLog -> {});
         } catch (Exception e) {
             log.info("charge_trans_produce"+"异常信息：" + e.getMessage());
         } finally {