完善测试

src/main/java/com/usky/dxtop/controller/web/TestController.java

@@ -93,9 +93,9 @@ public class TestController {
     @GetMapping("/cartPay")
     public void  cartPay(@RequestParam("id") Long id){
         Map<String,Object> map = new HashMap<>();
-        map.put("seq",id);
+        map.put("seq",id.toString());
         map.put("seq_charge",1111);
-        map.put("code",1);
+        map.put("code","1");
         map.put("msd","成功");
         cart.convertAndSend(ChargeProduceConfig.NAME, ChargeProduceConfig.NAME, map);
     }

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

@@ -11,6 +11,7 @@ import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.nio.charset.StandardCharsets;
 
@@ -24,6 +25,7 @@ public class ChargeMqListener {
 
     @Autowired
     private OrderService orderService;
+    @Transactional(rollbackFor = Exception.class)
     @RabbitListener(queues = ChargeProduceConfig.NAME, containerFactory = ChargeProduceConfig.LISTENER)
     public void dealDeclareMessage(Message message) {
         try {