mq map实体

src/main/java/com/fdkankan/pay/controller/TestController.java

@@ -1,7 +1,9 @@
 package com.fdkankan.pay.controller;
 import java.math.BigDecimal;
 import java.util.Date;
+import java.util.Map;
 
+import cn.hutool.core.bean.BeanUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.pay.common.ResultData;
 import com.fdkankan.pay.entity.Order;
@@ -26,7 +28,8 @@ public class TestController {
         order.setServeName("test-pay");
         order.setOrderType("test-pay");
         order.setOrderMoney(new BigDecimal("0.01"));
-        rabbitMqProducer.sendByWorkQueue(CacheUtil.orderDownQueue,JSONObject.toJSONString(order));
+        Map<String, Object> map = BeanUtil.beanToMap(order);
+        rabbitMqProducer.sendByWorkQueue(CacheUtil.orderDownQueue,map);
         return ResultData.ok();
     }
 }

src/main/java/com/fdkankan/pay/mq/consumer/OrderDownConsumer.java

@@ -1,5 +1,6 @@
 package com.fdkankan.pay.mq.consumer;
 
+import cn.hutool.core.bean.BeanUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.pay.entity.MqLog;
 import com.fdkankan.pay.entity.Order;
@@ -21,6 +22,8 @@ import org.springframework.stereotype.Component;
 import sun.rmi.runtime.Log;
 
 import java.nio.charset.StandardCharsets;
+import java.util.HashMap;
+import java.util.Map;
 
 @Slf4j
 @Component
@@ -54,7 +57,8 @@ public class OrderDownConsumer {
             mqLog.setStatus(2);
         }else {
             mqLog.setStatus(1);
-            rabbitMqProducer.sendByWorkQueue(orderPayResultQueue, JSONObject.toJSONString(order));
+            Map<String, Object> map = BeanUtil.beanToMap(order);
+            rabbitMqProducer.sendByWorkQueue(orderPayResultQueue, map);
         }
         mqLog.setUpdateTime(null);
         mqLogService.updateById(mqLog);