diff --git a/cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java b/cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java index f52b394..7e45094 100644 --- a/cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java +++ b/cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java @@ -27,7 +27,7 @@ public interface DataValueClient { * @return */ @PostMapping("/DataValue/findTableValue") - public Result findTableValue(@RequestParam("basicId") Long basicId,@RequestParam("sql") String sql); + public Result>> findTableValue(@RequestParam("basicId") Long basicId,@RequestParam("sql") String sql); /** * 根据sql查询数据条数 diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java index 72408d5..df75d41 100644 --- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java @@ -247,12 +247,13 @@ public class TaskServiceImpl extends ServiceImpl implement String limitSelect = sql + limit; log.info("执行查询语句为{}", limitSelect); log.info(databaseId); - Result tableValue = dataValueClient.findTableValue(databaseId, limitSelect); - List> data = (List>) tableValue.getData(); + Result>> tableValue = dataValueClient.findTableValue(databaseId, limitSelect); + List> data = tableValue.getData(); log.info("远程调用完毕,调用数量{}",data.size()); for (List datum : data) { + log.info(datum.toString()); for (DataValue dataValue : datum) { - log.info(datum.toString()); + log.info(dataValue.toString()); String key = dataValue.getKey(); log.info("传来的值的键为{}",key); String newKey = newAndOldMap.get(key);