修改mq消息转换失败的问题

performance-web/src/main/java/com/clx/performance/listener/SaveOrderGoodsAdjustmentPriceListener.java

 package com.clx.performance.listener;
 
-import cn.hutool.json.JSONUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.TypeReference;
+import com.clx.performance.common.MqWrapper;
 import com.clx.performance.constant.RabbitKeyConstants;
 import com.clx.performance.model.OrderGoodsAdjustmentPrice;
 import com.clx.performance.service.OrderGoodsAdjustmentPriceService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
 
@@ -21,9 +24,11 @@ public class SaveOrderGoodsAdjustmentPriceListener {
 
 
     @RabbitListener(queues = RabbitKeyConstants.SAVE_ORDER_GOODS_ADJUSTMENT_PRICE_QUEUE)
-    public void onMessage(String message) {
+    public void onMessage(Message message) {
         log.info("监听到保存货单挂单运费调整记录,消息内容{}", message);
-        OrderGoodsAdjustmentPrice data = JSONUtil.toBean(message, OrderGoodsAdjustmentPrice.class);
+        OrderGoodsAdjustmentPrice data = JSON.parseObject(new String(message.getBody()),
+                new TypeReference<MqWrapper<OrderGoodsAdjustmentPrice>>() {
+                }).getData();
         orderGoodsAdjustmentPriceService.saveOrderGoodsAdjustmentPrice(data);
     }
 }