Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加自动补招数据外部接口

Browse Source
This commit is contained in:
hzj
2025-07-30 10:03:55 +08:00
parent 9c14d8c49b
commit 317c734d89
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java
View File

@@ -82,7 +82,7 @@ public class DataRecallController extends BaseController {
//暂态补招 //暂态补招
RecallMessage.RecallDTO recallDTO = new RecallMessage.RecallDTO(); RecallMessage.RecallDTO recallDTO = new RecallMessage.RecallDTO();
//不设置dataType暂态稳态全部补招 //不设置dataType暂态稳态全部补招
// recallDTO2.setDataType("1"); recallDTO.setDataType("");
recallDTO.setMonitorId(Stream.of(temp).collect(Collectors.toList())); recallDTO.setMonitorId(Stream.of(temp).collect(Collectors.toList()));
String eventTime = formatInterval(param.getReCallStartTime(),param.getReCallEndTime()); String eventTime = formatInterval(param.getReCallStartTime(),param.getReCallEndTime());
recallDTO.setTimeInterval(Stream.of(eventTime).collect(Collectors.toList())); recallDTO.setTimeInterval(Stream.of(eventTime).collect(Collectors.toList()));
@@ -99,6 +99,7 @@ public class DataRecallController extends BaseController {
message.setData(v); message.setData(v);
String guid = IdUtil.simpleUUID(); String guid = IdUtil.simpleUUID();
message.setGuid(guid); message.setGuid(guid);
produceFeignClient.recall(message); produceFeignClient.recall(message);
guidList.add(guid); guidList.add(guid);
}); });