From 317c734d89a8d84a1a2a8b809bca85f8a4efe9a2 Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Wed, 30 Jul 2025 10:03:55 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=87=AA=E5=8A=A8=E8=A1=A5?= =?UTF-8?q?=E6=8B=9B=E6=95=B0=E6=8D=AE=E5=A4=96=E9=83=A8=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/njcn/dataProcess/controller/DataRecallController.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java index 2956e0e..aab325d 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java @@ -82,7 +82,7 @@ public class DataRecallController extends BaseController { //暂态补招 RecallMessage.RecallDTO recallDTO = new RecallMessage.RecallDTO(); //不设置dataType暂态稳态全部补招 -// recallDTO2.setDataType("1"); + recallDTO.setDataType(""); recallDTO.setMonitorId(Stream.of(temp).collect(Collectors.toList())); String eventTime = formatInterval(param.getReCallStartTime(),param.getReCallEndTime()); recallDTO.setTimeInterval(Stream.of(eventTime).collect(Collectors.toList())); @@ -99,6 +99,7 @@ public class DataRecallController extends BaseController { message.setData(v); String guid = IdUtil.simpleUUID(); message.setGuid(guid); + produceFeignClient.recall(message); guidList.add(guid); });