数据源类型

cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/SourceController.java

@@ -21,7 +21,6 @@ public class SourceController extends BaseController {
     @Autowired
     private SourceService sourceService;
 
-
     //列表
     @RequiresPermissions("etl:info:list")
     @GetMapping("/list")
@@ -62,6 +61,26 @@ public class SourceController extends BaseController {
         return toAjax(sourceService.insertBasicConfigInfo(sourceReq));
     }
 
+    //批量删除
+    @RequiresPermissions("etl:info:deleteIds")
+    @DeleteMapping("{ids}")
+    public Integer delete(@PathVariable("ids") String ids) {
+        return sourceService.deleteByIds(ids);
+    }
+
+    /**
+     * 修改
+     */
+//    @RequiresPermissions("etl:info:updata")
+//    @PostMapping
+//    public Result update(@RequestBody Source sourceReq) {
+//
+//        return toAjax(sourceService.updataSource(sourceReq));
+//    }
+
+
+
+
 
 
 

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/SourceService.java

@@ -13,4 +13,8 @@ public interface SourceService extends IService<Source> {
 
     int insertBasicConfigInfo(Source sourceReq);
 
+    Integer deleteByIds(String ids);
+
+//    int updataSource(Source sourceReq);
+
 }

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java

@@ -35,4 +35,19 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
         return insert;
     }
 
+    @Override
+    public Integer deleteByIds(String ids) {
+        LambdaQueryWrapper<Source> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.in(Source::getId, ids);
+        int delete = sourceMapper.delete(lambdaQueryWrapper);
+        return delete;
+    }
+
+//    @Override
+//    public int updataSource(Source sourceReq) {
+//        LambdaQueryWrapper<Source> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+//        int update = sourceMapper.update(lambdaQueryWrapper);
+//        return update;
+//    }
+
 }