1

src/main/java/com/fdkankan/pay/service/impl/OrderServiceImpl.java

@@ -82,7 +82,9 @@ public class OrderServiceImpl extends ServiceImpl<IOrderMapper, Order> implement
         order.setPayTime(new Date());
         order.setUpdateTime(new Date());
         this.updateById(order);
-        Map<String, Object> map = BeanUtil.beanToMap(order);
-        rabbitMqProducer.sendByWorkQueue(CacheUtil.orderPayResultQueue,map);
+        if(payFlag){
+            Map<String, Object> map = BeanUtil.beanToMap(order);
+            rabbitMqProducer.sendByWorkQueue(CacheUtil.orderPayResultQueue,map);
+        }
     }
 }