修改消息队列查询

jyzb-biz/src/main/java/com/junmp/jyzb/rabbitmq/CabinetLogReceiver.java

@@ -41,7 +41,8 @@ public class CabinetLogReceiver {
         logRecordDTO.setLogType(LogTypeEnum.OPT_LOG.getCode());
         logRecordDTO.setHttpMethod("RabbitMQ");
         logRecordDTO.setLogContent("CabinetLogsRecord");
-        logRecordDTO.setRequestResult(msg);
+        logRecordDTO.setRequestParams(msg);
+        logRecordDTO.setRequestUrl("queues = \"CabinetLogsRecord\"");
         try {
             // 手动确认消息
             channel.basicAck(deliveryTag, false);

jyzb-biz/src/main/java/com/junmp/jyzb/rabbitmq/OutInLogsByCabinetReceiver.java

@@ -39,7 +39,8 @@ public class OutInLogsByCabinetReceiver {
         logRecordDTO.setLogType(LogTypeEnum.OPT_LOG.getCode());
         logRecordDTO.setHttpMethod("RabbitMQ");
         logRecordDTO.setLogContent("CabinetLogsRecord");
-        logRecordDTO.setRequestResult(msg);
+        logRecordDTO.setRequestParams(msg);
+        logRecordDTO.setRequestUrl("queues = \"CabinetLogsRecord\"");
         try {
             System.out.println("msg = " + msg);
 

jyzb-biz/src/main/java/com/junmp/jyzb/rabbitmq/OutInLogsReceiver.java

@@ -40,7 +40,8 @@ public class OutInLogsReceiver {
         logRecordDTO.setLogType(LogTypeEnum.OPT_LOG.getCode());
         logRecordDTO.setHttpMethod("RabbitMQ");
         logRecordDTO.setLogContent("OrderResult");
-        logRecordDTO.setRequestResult(msg);
+        logRecordDTO.setRequestParams(msg);
+        logRecordDTO.setRequestUrl("queues = \"11111\"");
         try {
             System.out.println("msg = " + msg);
             // 创建日志对象