etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

更换数组

master
Cui YongXing 2024-09-05 19:18:51 +08:00
parent 40875894c4
commit b291c1d095
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java
View File

@ -18,7 +18,7 @@ import java.util.List;
@FeignClient(name = "cloud-etl-datasources", fallbackFactory = DatasourceFeignFactory.class) @FeignClient(name = "cloud-etl-datasources", fallbackFactory = DatasourceFeignFactory.class)
public interface DatasourceFeign { public interface DatasourceFeign {
@PostMapping("/findTableValueToArray") @PostMapping("/dataValue/findTableValueToArray")
public Result<DataValue[][]> findTableValueToArray(@RequestParam("basicId") Long basicId,@RequestParam("sql") String sql); public Result<DataValue[][]> findTableValueToArray(@RequestParam("basicId") Long basicId,@RequestParam("sql") String sql);
@PostMapping("/dataValue/findTableValue") @PostMapping("/dataValue/findTableValue")
@ -29,7 +29,7 @@ public interface DatasourceFeign {
public Result addProduct(@RequestParam("basicId") Long basicId, public Result addProduct(@RequestParam("basicId") Long basicId,
@RequestParam("tableId") Long tableId, @RequestParam("tableId") Long tableId,
@RequestBody List<List<DataValue>> listList); @RequestBody List<List<DataValue>> listList);
@PostMapping("/addProduct") @PostMapping("/product/addProduct")
public Result addProduct(@RequestParam("basicId") Long basicId, @RequestParam("tableId") Long tableId, @RequestBody DataValue[][] listList); public Result addProduct(@RequestParam("basicId") Long basicId, @RequestParam("tableId") Long tableId, @RequestBody DataValue[][] listList);
@PostMapping("/dataValue/findCount") @PostMapping("/dataValue/findCount")

5
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -307,6 +307,8 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
dataValue.setKey(newKey); dataValue.setKey(newKey);
} }
} }
Result result = datasourceFeign.addProduct(newBasicId, tableId, data);
log.info(result);
// for (List<DataValue> dataValues : tableValue) { // for (List<DataValue> dataValues : tableValue) {
// for (DataValue dataValue : dataValues) { // for (DataValue dataValue : dataValues) {
// String key = dataValue.getKey(); // String key = dataValue.getKey();
@ -314,8 +316,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
// dataValue.setKey(newKey); // dataValue.setKey(newKey);
// } // }
// } // }
Result result = datasourceFeign.addProduct(newBasicId, tableId, data);
log.info(result);
} }