From b3463bb2d880f381241a7f178b5514e2b09de051 Mon Sep 17 00:00:00 2001
From: anthonywj <yewenjie20@vip.qq.com>
Date: Sun, 25 Jun 2023 11:38:22 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E6=9F=A5=E8=AF=A2=E4=BF=AE?=
=?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../controller/trace/UdiTraceController.java | 17 +++++++++++++----
1 file changed, 13 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/glxp/api/controller/trace/UdiTraceController.java b/src/main/java/com/glxp/api/controller/trace/UdiTraceController.java
index 58b2251..a995633 100644
--- a/src/main/java/com/glxp/api/controller/trace/UdiTraceController.java
+++ b/src/main/java/com/glxp/api/controller/trace/UdiTraceController.java
@@ -89,6 +89,15 @@ public class UdiTraceController extends BaseController {
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("发送成功");
+ }
+
+
/**
* 源头追溯查询
*
@@ -186,8 +195,8 @@ public class UdiTraceController extends BaseController {
udiTraceService.createSourceTraceTask(traceProductDetailEntity, userCompanyEntity.getId());
}
- List<TraceOrderEntity> traceOrderEntities = traceOrderService.findByProductIdFk(traceRecordLogEntity.getTraceProductIdFk());
- return ResultVOUtils.success(traceOrderEntities);
+// List<TraceOrderEntity> traceOrderEntities = traceOrderService.findByProductIdFk(traceRecordLogEntity.getTraceProductIdFk());
+ return ResultVOUtils.success(traceRecordLogEntity.getRecordCode());
}
/**
@@ -277,8 +286,8 @@ public class UdiTraceController extends BaseController {
traceProductDetailEntity = udiTraceService.createTracerProductByBatchNo(traceRecordRequest, 2, 2, basicUdiRelResponse);
udiTraceService.createCheckTraceTask(traceProductDetailEntity, userCompanyEntity.getId());
}
- List<TraceOrderEntity> traceOrderEntities = traceOrderService.findByProductIdFk(traceRecordLogEntity.getTraceProductIdFk());
- return ResultVOUtils.success(traceOrderEntities);
+// List<TraceOrderEntity> traceOrderEntities = traceOrderService.findByProductIdFk(traceRecordLogEntity.getTraceProductIdFk());
+ return ResultVOUtils.success(traceRecordLogEntity.getRecordCode());
}