diff --git a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/TempController.java b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/TempController.java index f71768001..d54ef45e5 100644 --- a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/TempController.java +++ b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/TempController.java @@ -25,6 +25,7 @@ import com.jsowell.pile.vo.web.PileStationVO; import com.jsowell.service.OrderService; import com.jsowell.service.TempService; import org.apache.commons.collections4.CollectionUtils; +import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -65,6 +66,9 @@ public class TempController extends BaseController { @Autowired private OrderService orderService; + @Autowired + private RabbitTemplate rabbitTemplate; + @Autowired private SettleOrderReportService settleOrderReportService; @@ -583,4 +587,13 @@ public class TempController extends BaseController { } return response; } + + /** + * 测试RabbitMQ + */ + @PostMapping("/testRabbitMQ") + public RestApiResponse testRabbitMQ(@RequestBody TestRabbitMQDTO dto) { + rabbitTemplate.convertAndSend(dto.getExchange(), dto.getRoutingKey(), dto.getData()); + return new RestApiResponse<>(); + } } diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/service/rabbitmq/PileRabbitListener.java b/jsowell-netty/src/main/java/com/jsowell/netty/service/rabbitmq/PileRabbitListener.java index 1f740c58b..971ec438f 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/service/rabbitmq/PileRabbitListener.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/service/rabbitmq/PileRabbitListener.java @@ -44,6 +44,9 @@ import java.util.Objects; import java.util.concurrent.CompletableFuture; import java.util.concurrent.TimeUnit; +/** + * 监听RabbitMQ消息 充电桩 + */ @Slf4j @Service public class PileRabbitListener { diff --git a/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java b/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java index 5759e14e2..6cfcfdff8 100644 --- a/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java +++ b/jsowell-pile/src/main/java/com/jsowell/mq/OrderRabbitListener.java @@ -10,6 +10,9 @@ import org.springframework.stereotype.Service; import java.io.IOException; +/** + * 监听RabbitMQ消息 订单 + */ @Slf4j @Service public class OrderRabbitListener { diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/dto/TestRabbitMQDTO.java b/jsowell-pile/src/main/java/com/jsowell/pile/dto/TestRabbitMQDTO.java new file mode 100644 index 000000000..77b91712a --- /dev/null +++ b/jsowell-pile/src/main/java/com/jsowell/pile/dto/TestRabbitMQDTO.java @@ -0,0 +1,10 @@ +package com.jsowell.pile.dto; + +import lombok.Data; + +@Data +public class TestRabbitMQDTO { + private String exchange; + private String routingKey; + private String data; +}