From 7662a7fac0a3047e2e9a03eefee7d81ab5695522 Mon Sep 17 00:00:00 2001 From: zy_Java <654600784@qq.com> Date: Mon, 14 Dec 2020 17:16:07 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=98=9F=E5=88=97=E6=B3=A8?= =?UTF-8?q?=E5=86=8C=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ccsens/util/config/RabbitMQConfig.java | 5 +++++ .../ccsens/wisdomcar/api/DebugController.java | 19 +++++++++++++++++++ 2 files changed, 24 insertions(+) diff --git a/util/src/main/java/com/ccsens/util/config/RabbitMQConfig.java b/util/src/main/java/com/ccsens/util/config/RabbitMQConfig.java index 0b07bcf1..68cd4d7d 100644 --- a/util/src/main/java/com/ccsens/util/config/RabbitMQConfig.java +++ b/util/src/main/java/com/ccsens/util/config/RabbitMQConfig.java @@ -53,6 +53,11 @@ public class RabbitMQConfig { return new Queue(GAME_SCORE); } + @Bean + public Queue wisdom_car(){ + return new Queue(WISDOM_CAR); + } + // @Bean // public Queue queueGame(){ // return new Queue(GAME_MQ_A); diff --git a/wisdomcar/src/main/java/com/ccsens/wisdomcar/api/DebugController.java b/wisdomcar/src/main/java/com/ccsens/wisdomcar/api/DebugController.java index 846d1f23..5d91ffc6 100644 --- a/wisdomcar/src/main/java/com/ccsens/wisdomcar/api/DebugController.java +++ b/wisdomcar/src/main/java/com/ccsens/wisdomcar/api/DebugController.java @@ -1,14 +1,22 @@ package com.ccsens.wisdomcar.api; import com.ccsens.util.JsonResponse; +import com.ccsens.util.bean.dto.QueryDto; +import com.ccsens.wisdomcar.bean.dto.Message.CarRecordMessageDto; +import com.ccsens.wisdomcar.bean.dto.StatisticsDto; +import com.ccsens.wisdomcar.service.IRecordService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiParam; import lombok.extern.slf4j.Slf4j; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; +import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; @Api(tags = "DEBUG" , description = "DebugController | ") @@ -16,6 +24,8 @@ import javax.servlet.http.HttpServletRequest; @RequestMapping("/debug") @Slf4j public class DebugController { + @Resource + private IRecordService recordService; @ApiOperation(value = "/测试",notes = "") @ApiImplicitParams({ @@ -26,4 +36,13 @@ public class DebugController { return JsonResponse.newInstance().ok("测试"); } + @ApiOperation(value = "/测试消息接收存放",notes = "") + @ApiImplicitParams({ + }) + @RequestMapping(value="/record",method = RequestMethod.POST,produces = {"application/json;charset=UTF-8"}) + public JsonResponse record(@ApiParam @Validated @RequestBody QueryDto params) throws Exception { + recordService.disposeMessage(params.getParam()); + return JsonResponse.newInstance().ok("测试"); + } + }