API接口文档代码提交

src/main/java/com/glxp/api/controller/trace/TraceOrderController.java

@@ -3,11 +3,13 @@ package com.glxp.api.controller.trace;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSON;
 import com.github.pagehelper.PageInfo;
 import com.glxp.api.annotation.AuthRuleAnnotation;
 import com.glxp.api.common.enums.ResultEnum;
 import com.glxp.api.common.res.BaseResponse;
 import com.glxp.api.common.util.ResultVOUtils;
+import com.glxp.api.config.rabbit.TopicRabbitConfig;
 import com.glxp.api.controller.BaseController;
 import com.glxp.api.entity.basic.UdiEntity;
 import com.glxp.api.entity.sup.UserCompanyEntity;
@@ -25,7 +27,9 @@ import com.glxp.api.service.trace.TraceTaskNoticeService;
 import com.glxp.api.util.udi.FilterUdiUtils;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.BeanUtils;
 import org.springframework.validation.BindingResult;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -43,10 +47,13 @@ import java.util.List;
 @ApiIgnore
 @RestController
 @Slf4j
+@RequiredArgsConstructor
 public class TraceOrderController extends BaseController {
 
     @Resource
     TraceOrderService traceOrderService;
+    @Resource
+    private final RabbitTemplate rabbitTemplate;
 
     @ApiOperation(value = "查询追溯单据列表",response = TraceOrderResponse.class)
     @AuthRuleAnnotation("")

src/main/java/com/glxp/api/controller/trace/UdiTraceController.java

@@ -17,10 +17,7 @@ import com.glxp.api.entity.basic.UdiEntity;
 import com.glxp.api.entity.sup.UserCompanyEntity;
 import com.glxp.api.entity.trace.*;
 import com.glxp.api.req.basic.FilterUdiRelRequest;
-import com.glxp.api.req.trace.TraceManuDetailRequest;
+import com.glxp.api.req.trace.*;
-import com.glxp.api.req.trace.TraceManuOrderUploadRequest;
-import com.glxp.api.req.trace.TraceOrderUploadRequest;
-import com.glxp.api.req.trace.TraceRecordRequest;
 import com.glxp.api.res.basic.BasicUdiRelResponse;
 import com.glxp.api.res.trace.TraceSearchReponse;
 import com.glxp.api.service.basic.BasicUdiRelService;
@@ -87,14 +84,24 @@ public class UdiTraceController extends BaseController {
     @Resource
     private final RabbitTemplate rabbitTemplate;
 
-    @GetMapping("/udi/trace/source/sendUDI")
+    @PostMapping("/udi/trace/source/message")
-    public BaseResponse sendUdi(@RequestBody TraceRecordRequest traceRecordRequest) {
+    public BaseResponse sendMessage(@RequestBody MqTraceMessage mqTraceMessage) {
-        String messageJson = JSON.toJSONString(traceRecordRequest);
+        String messageJson = JSON.toJSONString(mqTraceMessage);
         System.out.println(messageJson);
         rabbitTemplate.convertAndSend("trace.topic.exchange", TopicRabbitConfig.common, messageJson);
         return ResultVOUtils.success("发送成功");
     }
 
+    @PostMapping("/udi/trace/source/task")
+    public BaseResponse sendTask(@RequestBody MqTaskDelayMessage mqTaskDelayMessage) {
+        String messageJson = JSON.toJSONString(mqTaskDelayMessage);
+        System.out.println(messageJson);
+        rabbitTemplate.convertAndSend(TopicRabbitConfig.TRACE_DELAY_EXCHANGE, TopicRabbitConfig.delaytrace, mqTaskDelayMessage);
+        return ResultVOUtils.success("发送成功");
+    }
+
+
+
     /**
      * 源头追溯查询
      *