Merge branch 'pt' of https://dd.tall.wiki/gitea/ccsens_wiki/ccsenscloud into pt

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);

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<CarRecordMessageDto> params) throws Exception {
+        recordService.disposeMessage(params.getParam());
+        return JsonResponse.newInstance().ok("测试");
+    }
+
 }