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