dev

taais-modules/taais-biz/src/main/java/com/taais/biz/controller/AlgorithmBizProcessController.java

@@ -0,0 +1,109 @@
+package com.taais.biz.controller;
+
+import java.util.List;
+
+import lombok.RequiredArgsConstructor;
+import jakarta.servlet.http.HttpServletResponse;
+import cn.dev33.satoken.annotation.SaCheckPermission;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.validation.annotation.Validated;
+import com.taais.common.core.core.domain.CommonResult;
+import com.taais.common.excel.utils.ExcelUtil;
+import com.taais.common.log.annotation.Log;
+import com.taais.common.log.enums.BusinessType;
+import com.taais.common.web.annotation.RepeatSubmit;
+import com.taais.common.web.core.BaseController;
+import jakarta.annotation.Resource;
+import com.taais.biz.domain.vo.AlgorithmBizProcessVo;
+import com.taais.biz.domain.bo.AlgorithmBizProcessBo;
+import com.taais.biz.service.IAlgorithmBizProcessService;
+
+import com.taais.common.core.core.page.PageResult;
+
+/**
+ * 算法业务处理Controller
+ *
+ * @author 0
+ * 2024-06-14
+ */
+@Validated
+@RequiredArgsConstructor
+@RestController
+@RequestMapping("/task/bizProcess")
+public class AlgorithmBizProcessController extends BaseController {
+    @Resource
+    private IAlgorithmBizProcessService algorithmBizProcessService;
+
+    /**
+     * 查询算法业务处理列表
+     */
+    @SaCheckPermission("task:bizProcess:list")
+    @GetMapping("/list")
+    public CommonResult<PageResult<AlgorithmBizProcessVo>> list(AlgorithmBizProcessBo algorithmBizProcessBo) {
+        return CommonResult.success(algorithmBizProcessService.selectPage(algorithmBizProcessBo));
+    }
+
+    /**
+     * 导出算法业务处理列表
+     */
+    @SaCheckPermission("task:bizProcess:export")
+    @Log(title = "算法业务处理", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, AlgorithmBizProcessBo algorithmBizProcessBo) {
+        List<AlgorithmBizProcessVo> list = algorithmBizProcessService.selectList(algorithmBizProcessBo);
+        ExcelUtil.exportExcel(list, "算法业务处理", AlgorithmBizProcessVo.class, response);
+    }
+
+    /**
+     * 获取算法业务处理详细信息
+     */
+    @SaCheckPermission("task:bizProcess:query")
+    @GetMapping(value = "/{id}")
+    public CommonResult<AlgorithmBizProcessVo> getInfo(@PathVariable Long id) {
+        return CommonResult.success(algorithmBizProcessService.selectById(id));
+    }
+
+    /**
+     * 新增算法业务处理
+     */
+    @SaCheckPermission("task:bizProcess:add")
+    @Log(title = "算法业务处理", businessType = BusinessType.INSERT)
+    @RepeatSubmit()
+    @PostMapping
+    public CommonResult<Void> add(@Validated @RequestBody AlgorithmBizProcessBo algorithmBizProcessBo) {
+        boolean inserted = algorithmBizProcessService.insert(algorithmBizProcessBo);
+        if (!inserted) {
+            return CommonResult.fail("新增算法业务处理记录失败！");
+        }
+        return CommonResult.success();
+    }
+
+    /**
+     * 修改算法业务处理
+     */
+    @SaCheckPermission("task:bizProcess:edit")
+    @Log(title = "算法业务处理", businessType = BusinessType.UPDATE)
+    @RepeatSubmit()
+    @PutMapping
+    public CommonResult<Void> edit(@Validated @RequestBody AlgorithmBizProcessBo algorithmBizProcessBo) {
+        Boolean updated = algorithmBizProcessService.update(algorithmBizProcessBo);
+        if (!updated) {
+            return CommonResult.fail("修改算法业务处理记录失败!");
+        }
+        return CommonResult.success();
+    }
+
+    /**
+     * 删除算法业务处理
+     */
+    @SaCheckPermission("task:bizProcess:remove")
+    @Log(title = "算法业务处理", businessType = BusinessType.DELETE)
+    @DeleteMapping("/{ids}")
+    public CommonResult<Void> remove(@PathVariable Long[] ids) {
+        boolean deleted = algorithmBizProcessService.deleteByIds(ids);
+        if (!deleted) {
+            return CommonResult.fail("删除算法业务处理记录失败!");
+        }
+        return CommonResult.success();
+    }
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/controller/AlgorithmDataProcessController.java

@@ -0,0 +1,109 @@
+package com.taais.biz.controller;
+
+import java.util.List;
+
+import lombok.RequiredArgsConstructor;
+import jakarta.servlet.http.HttpServletResponse;
+import cn.dev33.satoken.annotation.SaCheckPermission;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.validation.annotation.Validated;
+import com.taais.common.core.core.domain.CommonResult;
+import com.taais.common.excel.utils.ExcelUtil;
+import com.taais.common.log.annotation.Log;
+import com.taais.common.log.enums.BusinessType;
+import com.taais.common.web.annotation.RepeatSubmit;
+import com.taais.common.web.core.BaseController;
+import jakarta.annotation.Resource;
+import com.taais.biz.domain.vo.AlgorithmDataProcessVo;
+import com.taais.biz.domain.bo.AlgorithmDataProcessBo;
+import com.taais.biz.service.IAlgorithmDataProcessService;
+
+import com.taais.common.core.core.page.PageResult;
+
+/**
+ * 算法数据处理Controller
+ *
+ * @author 0
+ * 2024-06-14
+ */
+@Validated
+@RequiredArgsConstructor
+@RestController
+@RequestMapping("/task/dataProcess")
+public class AlgorithmDataProcessController extends BaseController {
+    @Resource
+    private IAlgorithmDataProcessService algorithmDataProcessService;
+
+    /**
+     * 查询算法数据处理列表
+     */
+    @SaCheckPermission("task:dataProcess:list")
+    @GetMapping("/list")
+    public CommonResult<PageResult<AlgorithmDataProcessVo>> list(AlgorithmDataProcessBo algorithmDataProcessBo) {
+        return CommonResult.success(algorithmDataProcessService.selectPage(algorithmDataProcessBo));
+    }
+
+    /**
+     * 导出算法数据处理列表
+     */
+    @SaCheckPermission("task:dataProcess:export")
+    @Log(title = "算法数据处理", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, AlgorithmDataProcessBo algorithmDataProcessBo) {
+        List<AlgorithmDataProcessVo> list = algorithmDataProcessService.selectList(algorithmDataProcessBo);
+        ExcelUtil.exportExcel(list, "算法数据处理", AlgorithmDataProcessVo.class, response);
+    }
+
+    /**
+     * 获取算法数据处理详细信息
+     */
+    @SaCheckPermission("task:dataProcess:query")
+    @GetMapping(value = "/{id}")
+    public CommonResult<AlgorithmDataProcessVo> getInfo(@PathVariable Long id) {
+        return CommonResult.success(algorithmDataProcessService.selectById(id));
+    }
+
+    /**
+     * 新增算法数据处理
+     */
+    @SaCheckPermission("task:dataProcess:add")
+    @Log(title = "算法数据处理", businessType = BusinessType.INSERT)
+    @RepeatSubmit()
+    @PostMapping
+    public CommonResult<Void> add(@Validated @RequestBody AlgorithmDataProcessBo algorithmDataProcessBo) {
+        boolean inserted = algorithmDataProcessService.insert(algorithmDataProcessBo);
+        if (!inserted) {
+            return CommonResult.fail("新增算法数据处理记录失败！");
+        }
+        return CommonResult.success();
+    }
+
+    /**
+     * 修改算法数据处理
+     */
+    @SaCheckPermission("task:dataProcess:edit")
+    @Log(title = "算法数据处理", businessType = BusinessType.UPDATE)
+    @RepeatSubmit()
+    @PutMapping
+    public CommonResult<Void> edit(@Validated @RequestBody AlgorithmDataProcessBo algorithmDataProcessBo) {
+        Boolean updated = algorithmDataProcessService.update(algorithmDataProcessBo);
+        if (!updated) {
+            return CommonResult.fail("修改算法数据处理记录失败!");
+        }
+        return CommonResult.success();
+    }
+
+    /**
+     * 删除算法数据处理
+     */
+    @SaCheckPermission("task:dataProcess:remove")
+    @Log(title = "算法数据处理", businessType = BusinessType.DELETE)
+    @DeleteMapping("/{ids}")
+    public CommonResult<Void> remove(@PathVariable Long[] ids) {
+        boolean deleted = algorithmDataProcessService.deleteByIds(ids);
+        if (!deleted) {
+            return CommonResult.fail("删除算法数据处理记录失败!");
+        }
+        return CommonResult.success();
+    }
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/controller/AlgorithmDataSetController.java

@@ -0,0 +1,109 @@
+package com.taais.biz.controller;
+
+import java.util.List;
+
+import lombok.RequiredArgsConstructor;
+import jakarta.servlet.http.HttpServletResponse;
+import cn.dev33.satoken.annotation.SaCheckPermission;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.validation.annotation.Validated;
+import com.taais.common.core.core.domain.CommonResult;
+import com.taais.common.excel.utils.ExcelUtil;
+import com.taais.common.log.annotation.Log;
+import com.taais.common.log.enums.BusinessType;
+import com.taais.common.web.annotation.RepeatSubmit;
+import com.taais.common.web.core.BaseController;
+import jakarta.annotation.Resource;
+import com.taais.biz.domain.vo.AlgorithmDataSetVo;
+import com.taais.biz.domain.bo.AlgorithmDataSetBo;
+import com.taais.biz.service.IAlgorithmDataSetService;
+
+import com.taais.common.core.core.page.PageResult;
+
+/**
+ * 算法数据集合Controller
+ *
+ * @author km
+ * 2024-06-14
+ */
+@Validated
+@RequiredArgsConstructor
+@RestController
+@RequestMapping("/task/dataSet")
+public class AlgorithmDataSetController extends BaseController {
+    @Resource
+    private IAlgorithmDataSetService algorithmDataSetService;
+
+    /**
+     * 查询算法数据集合列表
+     */
+    @SaCheckPermission("task:dataSet:list")
+    @GetMapping("/list")
+    public CommonResult<PageResult<AlgorithmDataSetVo>> list(AlgorithmDataSetBo algorithmDataSetBo) {
+        return CommonResult.success(algorithmDataSetService.selectPage(algorithmDataSetBo));
+    }
+
+    /**
+     * 导出算法数据集合列表
+     */
+    @SaCheckPermission("task:dataSet:export")
+    @Log(title = "算法数据集合", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, AlgorithmDataSetBo algorithmDataSetBo) {
+        List<AlgorithmDataSetVo> list = algorithmDataSetService.selectList(algorithmDataSetBo);
+        ExcelUtil.exportExcel(list, "算法数据集合", AlgorithmDataSetVo.class, response);
+    }
+
+    /**
+     * 获取算法数据集合详细信息
+     */
+    @SaCheckPermission("task:dataSet:query")
+    @GetMapping(value = "/{id}")
+    public CommonResult<AlgorithmDataSetVo> getInfo(@PathVariable Long id) {
+        return CommonResult.success(algorithmDataSetService.selectById(id));
+    }
+
+    /**
+     * 新增算法数据集合
+     */
+    @SaCheckPermission("task:dataSet:add")
+    @Log(title = "算法数据集合", businessType = BusinessType.INSERT)
+    @RepeatSubmit()
+    @PostMapping
+    public CommonResult<Void> add(@Validated @RequestBody AlgorithmDataSetBo algorithmDataSetBo) {
+        boolean inserted = algorithmDataSetService.insert(algorithmDataSetBo);
+        if (!inserted) {
+            return CommonResult.fail("新增算法数据集合记录失败！");
+        }
+        return CommonResult.success();
+    }
+
+    /**
+     * 修改算法数据集合
+     */
+    @SaCheckPermission("task:dataSet:edit")
+    @Log(title = "算法数据集合", businessType = BusinessType.UPDATE)
+    @RepeatSubmit()
+    @PutMapping
+    public CommonResult<Void> edit(@Validated @RequestBody AlgorithmDataSetBo algorithmDataSetBo) {
+        Boolean updated = algorithmDataSetService.update(algorithmDataSetBo);
+        if (!updated) {
+            return CommonResult.fail("修改算法数据集合记录失败!");
+        }
+        return CommonResult.success();
+    }
+
+    /**
+     * 删除算法数据集合
+     */
+    @SaCheckPermission("task:dataSet:remove")
+    @Log(title = "算法数据集合", businessType = BusinessType.DELETE)
+    @DeleteMapping("/{ids}")
+    public CommonResult<Void> remove(@PathVariable Long[] ids) {
+        boolean deleted = algorithmDataSetService.deleteByIds(ids);
+        if (!deleted) {
+            return CommonResult.fail("删除算法数据集合记录失败!");
+        }
+        return CommonResult.success();
+    }
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/AlgorithmBizProcess.java

@@ -0,0 +1,85 @@
+package com.taais.biz.domain;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法业务处理对象 algorithm_biz_process
+ *
+ * @author 0
+ * 2024-06-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(value = "algorithm_biz_process")
+public class AlgorithmBizProcess extends BaseEntity
+    {
+@Serial
+private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    @Id
+    private Long id;
+
+    /** 子任务id */
+    private Long subTaskId;
+
+    /** 任务名称 */
+    private String name;
+
+    /** 任务类型 */
+    private String type;
+
+    /** 任务状态 */
+    private String status;
+
+    /** 算法 */
+    private Long algorithmId;
+
+    /** 模型 */
+    private Long modelId;
+
+    /** 调用算法时所用的参数 */
+    private String parameters;
+
+    /** 预处理数据路径 */
+    private String preprocessPath;
+
+    /** 结果数据路径 */
+    private String resultPath;
+
+    /** 序号 */
+    private Long index;
+
+    /** 开始时间 */
+    private Date startTime;
+
+    /** 结束时间 */
+    private Date endTime;
+
+    /** 耗时 */
+    private Long costSecond;
+
+    /** 日志 */
+    private String log;
+
+    /** 备注 */
+    private String remarks;
+
+    /** 逻辑删除标志（0代表存在 1代表删除） */
+    @Column(isLogicDelete = true)
+    private Integer delFlag;
+
+    /** 系统 */
+    private String system;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/AlgorithmDataProcess.java

@@ -0,0 +1,82 @@
+package com.taais.biz.domain;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法数据处理对象 algorithm_data_process
+ *
+ * @author 0
+ * 2024-06-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(value = "algorithm_data_process")
+public class AlgorithmDataProcess extends BaseEntity
+    {
+@Serial
+private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    @Id
+    private Long id;
+
+    /** 子任务id */
+    private Long subTaskId;
+
+    /** 任务名称 */
+    private String name;
+
+    /** 任务类型 */
+    private String type;
+
+    /** 任务状态 */
+    private String status;
+
+    /** 算法 */
+    private Long algorithmId;
+
+    /** 调用算法时所用的参数 */
+    private String parameters;
+
+    /** 预处理数据路径 */
+    private String preprocessPath;
+
+    /** 结果数据路径 */
+    private String resultPath;
+
+    /** 开始时间 */
+    private Date startTime;
+
+    /** 序号 */
+    private Long index;
+
+    /** 结束时间 */
+    private Date endTime;
+
+    /** 耗时 */
+    private Long costSecond;
+
+    /** 日志 */
+    private String log;
+
+    /** 备注 */
+    private String remarks;
+
+    /** 逻辑删除标志（0代表存在 1代表删除） */
+    @Column(isLogicDelete = true)
+    private Integer delFlag;
+
+    /** 系统 */
+    private String system;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/AlgorithmDataSet.java

@@ -0,0 +1,76 @@
+package com.taais.biz.domain;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法数据集合对象 algorithm_data_set
+ *
+ * @author km
+ * 2024-06-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(value = "algorithm_data_set")
+public class AlgorithmDataSet extends BaseEntity
+    {
+@Serial
+private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    @Id
+    private Long id;
+
+    /** 子任务id */
+    private Long subTaskId;
+
+    /** 任务名称 */
+    private String name;
+
+    /** 任务类型 */
+    private String type;
+
+    /** 任务状态 */
+    private String status;
+
+    /** 调用算法时所用的参数 */
+    private String parameters;
+
+    /** 结果数据路径 */
+    private String resultPath;
+
+    /** 开始时间 */
+    private Date startTime;
+
+    /** 序号 */
+    private Long index;
+
+    /** 结束时间 */
+    private Date endTime;
+
+    /** 耗时 */
+    private Long costSecond;
+
+    /** 日志 */
+    private String log;
+
+    /** 备注 */
+    private String remarks;
+
+    /** 逻辑删除标志（0代表存在 1代表删除） */
+    @Column(isLogicDelete = true)
+    private Integer delFlag;
+
+    /** 系统 */
+    private String system;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/bo/AlgorithmBizProcessBo.java

@@ -0,0 +1,100 @@
+package com.taais.biz.domain.bo;
+
+import com.taais.biz.domain.AlgorithmBizProcess;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import jakarta.validation.constraints.*;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法业务处理业务对象 algorithm_biz_process
+ *
+ * @author 0
+ * @date 2024-06-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = AlgorithmBizProcess.class, reverseConvertGenerate = false)
+public class AlgorithmBizProcessBo extends BaseEntity{
+    /**
+     * 主键ID
+     */
+    private Long id;
+
+    /**
+     * 子任务id
+     */
+    private Long subTaskId;
+
+    /**
+     * 任务名称
+     */
+    private String name;
+
+    /**
+     * 任务类型
+     */
+    private String type;
+
+    /**
+     * 任务状态
+     */
+    private String status;
+
+    /**
+     * 算法
+     */
+    private Long algorithmId;
+
+    /**
+     * 模型
+     */
+    private Long modelId;
+
+    /**
+     * 调用算法时所用的参数
+     */
+    private String parameters;
+
+    /**
+     * 预处理数据路径
+     */
+    private String preprocessPath;
+
+    /**
+     * 结果数据路径
+     */
+    private String resultPath;
+
+    /**
+     * 序号
+     */
+    private Long index;
+
+    /**
+     * 开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date startTime;
+
+    /**
+     * 结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date endTime;
+
+    /**
+     * 耗时
+     */
+    private Long costSecond;
+
+    /**
+     * 日志
+     */
+    private String log;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/bo/AlgorithmDataProcessBo.java

@@ -0,0 +1,95 @@
+package com.taais.biz.domain.bo;
+
+import com.taais.biz.domain.AlgorithmDataProcess;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import jakarta.validation.constraints.*;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法数据处理业务对象 algorithm_data_process
+ *
+ * @author 0
+ * @date 2024-06-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = AlgorithmDataProcess.class, reverseConvertGenerate = false)
+public class AlgorithmDataProcessBo extends BaseEntity{
+    /**
+     * 主键ID
+     */
+    private Long id;
+
+    /**
+     * 子任务id
+     */
+    private Long subTaskId;
+
+    /**
+     * 任务名称
+     */
+    private String name;
+
+    /**
+     * 任务类型
+     */
+    private String type;
+
+    /**
+     * 任务状态
+     */
+    private String status;
+
+    /**
+     * 算法
+     */
+    private Long algorithmId;
+
+    /**
+     * 调用算法时所用的参数
+     */
+    private String parameters;
+
+    /**
+     * 预处理数据路径
+     */
+    private String preprocessPath;
+
+    /**
+     * 结果数据路径
+     */
+    private String resultPath;
+
+    /**
+     * 开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date startTime;
+
+    /**
+     * 序号
+     */
+    private Long index;
+
+    /**
+     * 结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date endTime;
+
+    /**
+     * 耗时
+     */
+    private Long costSecond;
+
+    /**
+     * 日志
+     */
+    private String log;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/bo/AlgorithmDataSetBo.java

@@ -0,0 +1,85 @@
+package com.taais.biz.domain.bo;
+
+import com.taais.biz.domain.AlgorithmDataSet;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import jakarta.validation.constraints.*;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法数据集合业务对象 algorithm_data_set
+ *
+ * @author km
+ * @date 2024-06-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = AlgorithmDataSet.class, reverseConvertGenerate = false)
+public class AlgorithmDataSetBo extends BaseEntity{
+    /**
+     * 主键ID
+     */
+    private Long id;
+
+    /**
+     * 子任务id
+     */
+    private Long subTaskId;
+
+    /**
+     * 任务名称
+     */
+    private String name;
+
+    /**
+     * 任务类型
+     */
+    private String type;
+
+    /**
+     * 任务状态
+     */
+    private String status;
+
+    /**
+     * 调用算法时所用的参数
+     */
+    private String parameters;
+
+    /**
+     * 结果数据路径
+     */
+    private String resultPath;
+
+    /**
+     * 开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date startTime;
+
+    /**
+     * 序号
+     */
+    private Long index;
+
+    /**
+     * 结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date endTime;
+
+    /**
+     * 耗时
+     */
+    private Long costSecond;
+
+    /**
+     * 日志
+     */
+    private String log;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/dto/task/DataSelectDto.java

@@ -0,0 +1,18 @@
+package com.taais.biz.domain.dto.task;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author allen
+ */
+@Data
+public class DataSelectDto {
+
+    private Boolean conditionSelected;
+
+    private String condition;
+
+    private List<Long> dateSet;
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/dto/task/TaskDto.java

@@ -0,0 +1,13 @@
+package com.taais.biz.domain.dto.task;
+
+import lombok.Data;
+
+/**
+ * @author allen
+ */
+@Data
+public class TaskDto {
+    private Long algorithmId;
+    private Long modelId;
+    private String params;
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/vo/AlgorithmBizProcessImportVo.java

@@ -0,0 +1,98 @@
+package com.taais.biz.domain.vo;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.taais.common.excel.annotation.ExcelDictFormat;
+import com.taais.common.excel.convert.ExcelDictConvert;
+import lombok.Data;
+import java.io.Serial;
+import java.io.Serializable;
+import lombok.NoArgsConstructor;
+
+/**
+ * 算法业务处理导入视图对象 algorithm_biz_process
+ *
+ * @author 0
+ * @date 2024-06-14
+ */
+
+@Data
+@NoArgsConstructor
+public class AlgorithmBizProcessImportVo implements Serializable
+{
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+
+     /** 子任务id */
+    @ExcelProperty(value = "子任务id")
+    private Long subTaskId;
+
+     /** 任务名称 */
+    @ExcelProperty(value = "任务名称")
+    private String name;
+
+     /** 任务类型 */
+    @ExcelProperty(value = "任务类型")
+    private String type;
+
+     /** 任务状态 */
+    @ExcelProperty(value = "任务状态")
+    private String status;
+
+     /** 算法 */
+    @ExcelProperty(value = "算法")
+    private Long algorithmId;
+
+     /** 模型 */
+    @ExcelProperty(value = "模型")
+    private Long modelId;
+
+     /** 调用算法时所用的参数 */
+    @ExcelProperty(value = "调用算法时所用的参数")
+    private String parameters;
+
+     /** 预处理数据路径 */
+    @ExcelProperty(value = "预处理数据路径")
+    private String preprocessPath;
+
+     /** 结果数据路径 */
+    @ExcelProperty(value = "结果数据路径")
+    private String resultPath;
+
+     /** 序号 */
+    @ExcelProperty(value = "序号")
+    private Long index;
+
+     /** 开始时间 */
+    @ExcelProperty(value = "开始时间")
+    private Date startTime;
+
+     /** 结束时间 */
+    @ExcelProperty(value = "结束时间")
+    private Date endTime;
+
+     /** 耗时 */
+    @ExcelProperty(value = "耗时")
+    private Long costSecond;
+
+     /** 日志 */
+    @ExcelProperty(value = "日志")
+    private String log;
+
+     /** 备注 */
+    @ExcelProperty(value = "备注")
+    private String remarks;
+
+     /** 逻辑删除标志（0代表存在 1代表删除） */
+    @ExcelProperty(value = "逻辑删除标志（0代表存在 1代表删除）")
+    private Integer delFlag;
+
+     /** 系统 */
+    @ExcelProperty(value = "系统")
+    private String system;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/vo/AlgorithmBizProcessVo.java

@@ -0,0 +1,106 @@
+package com.taais.biz.domain.vo;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.taais.biz.domain.AlgorithmBizProcess;
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.taais.common.excel.annotation.ExcelDictFormat;
+import com.taais.common.excel.convert.ExcelDictConvert;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import java.io.Serial;
+import java.io.Serializable;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法业务处理视图对象 algorithm_biz_process
+ *
+ * @author 0
+ * @date 2024-06-14
+ */
+@Data
+@ExcelIgnoreUnannotated
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = AlgorithmBizProcess.class)
+public class AlgorithmBizProcessVo extends BaseEntity implements Serializable {
+
+@Serial
+private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    @ExcelProperty(value = "主键ID")
+    private Long id;
+
+    /** 子任务id */
+    @ExcelProperty(value = "子任务id")
+    private Long subTaskId;
+
+    /** 任务名称 */
+    @ExcelProperty(value = "任务名称")
+    private String name;
+
+    /** 任务类型 */
+    @ExcelProperty(value = "任务类型")
+    private String type;
+
+    /** 任务状态 */
+    @ExcelProperty(value = "任务状态")
+    private String status;
+
+    /** 算法 */
+    @ExcelProperty(value = "算法")
+    private Long algorithmId;
+
+    /** 模型 */
+    @ExcelProperty(value = "模型")
+    private Long modelId;
+
+    /** 调用算法时所用的参数 */
+    @ExcelProperty(value = "调用算法时所用的参数")
+    private String parameters;
+
+    /** 预处理数据路径 */
+    @ExcelProperty(value = "预处理数据路径")
+    private String preprocessPath;
+
+    /** 结果数据路径 */
+    @ExcelProperty(value = "结果数据路径")
+    private String resultPath;
+
+    /** 序号 */
+    @ExcelProperty(value = "序号")
+    private Long index;
+
+    /** 开始时间 */
+    @ExcelProperty(value = "开始时间")
+    private Date startTime;
+
+    /** 结束时间 */
+    @ExcelProperty(value = "结束时间")
+    private Date endTime;
+
+    /** 耗时 */
+    @ExcelProperty(value = "耗时")
+    private Long costSecond;
+
+    /** 日志 */
+    @ExcelProperty(value = "日志")
+    private String log;
+
+    /** 备注 */
+    @ExcelProperty(value = "备注")
+    private String remarks;
+
+    /** 逻辑删除标志（0代表存在 1代表删除） */
+    @ExcelProperty(value = "逻辑删除标志（0代表存在 1代表删除）")
+    private Integer delFlag;
+
+    /** 系统 */
+    @ExcelProperty(value = "系统")
+    private String system;
+
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/vo/AlgorithmDataProcessImportVo.java

@@ -0,0 +1,94 @@
+package com.taais.biz.domain.vo;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.taais.common.excel.annotation.ExcelDictFormat;
+import com.taais.common.excel.convert.ExcelDictConvert;
+import lombok.Data;
+import java.io.Serial;
+import java.io.Serializable;
+import lombok.NoArgsConstructor;
+
+/**
+ * 算法数据处理导入视图对象 algorithm_data_process
+ *
+ * @author 0
+ * @date 2024-06-14
+ */
+
+@Data
+@NoArgsConstructor
+public class AlgorithmDataProcessImportVo implements Serializable
+{
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+
+     /** 子任务id */
+    @ExcelProperty(value = "子任务id")
+    private Long subTaskId;
+
+     /** 任务名称 */
+    @ExcelProperty(value = "任务名称")
+    private String name;
+
+     /** 任务类型 */
+    @ExcelProperty(value = "任务类型")
+    private String type;
+
+     /** 任务状态 */
+    @ExcelProperty(value = "任务状态")
+    private String status;
+
+     /** 算法 */
+    @ExcelProperty(value = "算法")
+    private Long algorithmId;
+
+     /** 调用算法时所用的参数 */
+    @ExcelProperty(value = "调用算法时所用的参数")
+    private String parameters;
+
+     /** 预处理数据路径 */
+    @ExcelProperty(value = "预处理数据路径")
+    private String preprocessPath;
+
+     /** 结果数据路径 */
+    @ExcelProperty(value = "结果数据路径")
+    private String resultPath;
+
+     /** 开始时间 */
+    @ExcelProperty(value = "开始时间")
+    private Date startTime;
+
+     /** 序号 */
+    @ExcelProperty(value = "序号")
+    private Long index;
+
+     /** 结束时间 */
+    @ExcelProperty(value = "结束时间")
+    private Date endTime;
+
+     /** 耗时 */
+    @ExcelProperty(value = "耗时")
+    private Long costSecond;
+
+     /** 日志 */
+    @ExcelProperty(value = "日志")
+    private String log;
+
+     /** 备注 */
+    @ExcelProperty(value = "备注")
+    private String remarks;
+
+     /** 逻辑删除标志（0代表存在 1代表删除） */
+    @ExcelProperty(value = "逻辑删除标志（0代表存在 1代表删除）")
+    private Integer delFlag;
+
+     /** 系统 */
+    @ExcelProperty(value = "系统")
+    private String system;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/vo/AlgorithmDataProcessVo.java

@@ -0,0 +1,102 @@
+package com.taais.biz.domain.vo;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.taais.biz.domain.AlgorithmDataProcess;
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.taais.common.excel.annotation.ExcelDictFormat;
+import com.taais.common.excel.convert.ExcelDictConvert;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import java.io.Serial;
+import java.io.Serializable;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法数据处理视图对象 algorithm_data_process
+ *
+ * @author 0
+ * @date 2024-06-14
+ */
+@Data
+@ExcelIgnoreUnannotated
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = AlgorithmDataProcess.class)
+public class AlgorithmDataProcessVo extends BaseEntity implements Serializable {
+
+@Serial
+private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    @ExcelProperty(value = "主键ID")
+    private Long id;
+
+    /** 子任务id */
+    @ExcelProperty(value = "子任务id")
+    private Long subTaskId;
+
+    /** 任务名称 */
+    @ExcelProperty(value = "任务名称")
+    private String name;
+
+    /** 任务类型 */
+    @ExcelProperty(value = "任务类型")
+    private String type;
+
+    /** 任务状态 */
+    @ExcelProperty(value = "任务状态")
+    private String status;
+
+    /** 算法 */
+    @ExcelProperty(value = "算法")
+    private Long algorithmId;
+
+    /** 调用算法时所用的参数 */
+    @ExcelProperty(value = "调用算法时所用的参数")
+    private String parameters;
+
+    /** 预处理数据路径 */
+    @ExcelProperty(value = "预处理数据路径")
+    private String preprocessPath;
+
+    /** 结果数据路径 */
+    @ExcelProperty(value = "结果数据路径")
+    private String resultPath;
+
+    /** 开始时间 */
+    @ExcelProperty(value = "开始时间")
+    private Date startTime;
+
+    /** 序号 */
+    @ExcelProperty(value = "序号")
+    private Long index;
+
+    /** 结束时间 */
+    @ExcelProperty(value = "结束时间")
+    private Date endTime;
+
+    /** 耗时 */
+    @ExcelProperty(value = "耗时")
+    private Long costSecond;
+
+    /** 日志 */
+    @ExcelProperty(value = "日志")
+    private String log;
+
+    /** 备注 */
+    @ExcelProperty(value = "备注")
+    private String remarks;
+
+    /** 逻辑删除标志（0代表存在 1代表删除） */
+    @ExcelProperty(value = "逻辑删除标志（0代表存在 1代表删除）")
+    private Integer delFlag;
+
+    /** 系统 */
+    @ExcelProperty(value = "系统")
+    private String system;
+
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/vo/AlgorithmDataSetImportVo.java

@@ -0,0 +1,86 @@
+package com.taais.biz.domain.vo;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.taais.common.excel.annotation.ExcelDictFormat;
+import com.taais.common.excel.convert.ExcelDictConvert;
+import lombok.Data;
+import java.io.Serial;
+import java.io.Serializable;
+import lombok.NoArgsConstructor;
+
+/**
+ * 算法数据集合导入视图对象 algorithm_data_set
+ *
+ * @author km
+ * @date 2024-06-14
+ */
+
+@Data
+@NoArgsConstructor
+public class AlgorithmDataSetImportVo implements Serializable
+{
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+
+     /** 子任务id */
+    @ExcelProperty(value = "子任务id")
+    private Long subTaskId;
+
+     /** 任务名称 */
+    @ExcelProperty(value = "任务名称")
+    private String name;
+
+     /** 任务类型 */
+    @ExcelProperty(value = "任务类型")
+    private String type;
+
+     /** 任务状态 */
+    @ExcelProperty(value = "任务状态")
+    private String status;
+
+     /** 调用算法时所用的参数 */
+    @ExcelProperty(value = "调用算法时所用的参数")
+    private String parameters;
+
+     /** 结果数据路径 */
+    @ExcelProperty(value = "结果数据路径")
+    private String resultPath;
+
+     /** 开始时间 */
+    @ExcelProperty(value = "开始时间")
+    private Date startTime;
+
+     /** 序号 */
+    @ExcelProperty(value = "序号")
+    private Long index;
+
+     /** 结束时间 */
+    @ExcelProperty(value = "结束时间")
+    private Date endTime;
+
+     /** 耗时 */
+    @ExcelProperty(value = "耗时")
+    private Long costSecond;
+
+     /** 日志 */
+    @ExcelProperty(value = "日志")
+    private String log;
+
+     /** 备注 */
+    @ExcelProperty(value = "备注")
+    private String remarks;
+
+     /** 逻辑删除标志（0代表存在 1代表删除） */
+    @ExcelProperty(value = "逻辑删除标志（0代表存在 1代表删除）")
+    private Integer delFlag;
+
+     /** 系统 */
+    @ExcelProperty(value = "系统")
+    private String system;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/vo/AlgorithmDataSetVo.java

@@ -0,0 +1,94 @@
+package com.taais.biz.domain.vo;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.taais.biz.domain.AlgorithmDataSet;
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.taais.common.excel.annotation.ExcelDictFormat;
+import com.taais.common.excel.convert.ExcelDictConvert;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import java.io.Serial;
+import java.io.Serializable;
+import com.taais.common.orm.core.domain.BaseEntity;
+
+/**
+ * 算法数据集合视图对象 algorithm_data_set
+ *
+ * @author km
+ * @date 2024-06-14
+ */
+@Data
+@ExcelIgnoreUnannotated
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = AlgorithmDataSet.class)
+public class AlgorithmDataSetVo extends BaseEntity implements Serializable {
+
+@Serial
+private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    @ExcelProperty(value = "主键ID")
+    private Long id;
+
+    /** 子任务id */
+    @ExcelProperty(value = "子任务id")
+    private Long subTaskId;
+
+    /** 任务名称 */
+    @ExcelProperty(value = "任务名称")
+    private String name;
+
+    /** 任务类型 */
+    @ExcelProperty(value = "任务类型")
+    private String type;
+
+    /** 任务状态 */
+    @ExcelProperty(value = "任务状态")
+    private String status;
+
+    /** 调用算法时所用的参数 */
+    @ExcelProperty(value = "调用算法时所用的参数")
+    private String parameters;
+
+    /** 结果数据路径 */
+    @ExcelProperty(value = "结果数据路径")
+    private String resultPath;
+
+    /** 开始时间 */
+    @ExcelProperty(value = "开始时间")
+    private Date startTime;
+
+    /** 序号 */
+    @ExcelProperty(value = "序号")
+    private Long index;
+
+    /** 结束时间 */
+    @ExcelProperty(value = "结束时间")
+    private Date endTime;
+
+    /** 耗时 */
+    @ExcelProperty(value = "耗时")
+    private Long costSecond;
+
+    /** 日志 */
+    @ExcelProperty(value = "日志")
+    private String log;
+
+    /** 备注 */
+    @ExcelProperty(value = "备注")
+    private String remarks;
+
+    /** 逻辑删除标志（0代表存在 1代表删除） */
+    @ExcelProperty(value = "逻辑删除标志（0代表存在 1代表删除）")
+    private Integer delFlag;
+
+    /** 系统 */
+    @ExcelProperty(value = "系统")
+    private String system;
+
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/vo/DataImportVo.java

@@ -0,0 +1,86 @@
+package com.taais.biz.domain.vo;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.taais.common.excel.annotation.ExcelDictFormat;
+import com.taais.common.excel.convert.ExcelDictConvert;
+import lombok.Data;
+import java.io.Serial;
+import java.io.Serializable;
+import lombok.NoArgsConstructor;
+
+/**
+ * 数据管理导入视图对象 data
+ *
+ * @author km
+ * @date 2024-06-14
+ */
+
+@Data
+@NoArgsConstructor
+public class DataImportVo implements Serializable
+{
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+
+     /** 名称 */
+    @ExcelProperty(value = "名称")
+    private String name;
+
+     /** 数据类型 */
+    @ExcelProperty(value = "数据类型")
+    private String dataType;
+
+     /** 文件类型 */
+    @ExcelProperty(value = "文件类型")
+    private String fileType;
+
+     /** 目标类型 */
+    @ExcelProperty(value = "目标类型")
+    private String objectType;
+
+     /** 目标子类型 */
+    @ExcelProperty(value = "目标子类型")
+    private String objectSubtype;
+
+     /** 批次号 */
+    @ExcelProperty(value = "批次号")
+    private Long batchNum;
+
+     /** 场景 */
+    @ExcelProperty(value = "场景")
+    private String scene;
+
+     /** 数据源 */
+    @ExcelProperty(value = "数据源")
+    private String dataSource;
+
+     /** 采集时间 */
+    @ExcelProperty(value = "采集时间")
+    private Date gatherTime;
+
+     /** 采集地点 */
+    @ExcelProperty(value = "采集地点")
+    private String gatherSpot;
+
+     /** 图片url */
+    @ExcelProperty(value = "图片url")
+    private String url;
+
+     /** 标注url */
+    @ExcelProperty(value = "标注url")
+    private String labelurl;
+
+     /** 扩增方式 */
+    @ExcelProperty(value = "扩增方式")
+    private String increment;
+
+     /** 是否标注 */
+    @ExcelProperty(value = "是否标注")
+    private String labeled;
+
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/listener/AlgorithmBizProcessImportListener.java

@@ -0,0 +1,119 @@
+package com.taais.biz.listener;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.util.ObjectUtil;
+import com.alibaba.excel.context.AnalysisContext;
+import com.alibaba.excel.event.AnalysisEventListener;
+import com.taais.common.core.exception.ServiceException;
+import com.taais.common.core.utils.SpringUtils;
+import com.taais.common.core.utils.ValidatorUtils;
+import com.taais.common.excel.core.ExcelListener;
+import com.taais.common.excel.core.ExcelResult;
+import com.taais.biz.domain.bo.AlgorithmBizProcessBo;
+import com.taais.biz.domain.vo.AlgorithmBizProcessImportVo;
+import com.taais.biz.domain.vo.AlgorithmBizProcessVo;
+import com.taais.biz.service.IAlgorithmBizProcessService;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.List;
+
+/**
+ * 算法业务处理自定义导入
+ *
+ * @author 0
+ */
+@Slf4j
+public class AlgorithmBizProcessImportListener extends AnalysisEventListener<AlgorithmBizProcessImportVo> implements ExcelListener<AlgorithmBizProcessImportVo> {
+    private final IAlgorithmBizProcessService algorithmBizProcessService;
+
+    private final Boolean isUpdateSupport;
+    private int successNum = 0;
+    private int failureNum = 0;
+    private final StringBuilder successMsg = new StringBuilder();
+    private final StringBuilder failureMsg = new StringBuilder();
+
+    public AlgorithmBizProcessImportListener(Boolean isUpdateSupport) {
+        this.algorithmBizProcessService = SpringUtils.getBean(IAlgorithmBizProcessService.class);
+        this.isUpdateSupport = isUpdateSupport;
+    }
+
+    @Override
+    public void invoke(AlgorithmBizProcessImportVo algorithmBizProcessVo, AnalysisContext context) {
+        try {
+
+            AlgorithmBizProcessBo algorithmBizProcessBo = BeanUtil.toBean(algorithmBizProcessVo, AlgorithmBizProcessBo.class);
+
+            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
+            AlgorithmBizProcessVo algorithmBizProcessVo1 = null;
+
+            //algorithmBizProcessVo1 = algorithmBizProcessService.selectBySomefield(algorithmBizProcessVo.getSomefield());
+            if (ObjectUtil.isNull(algorithmBizProcessVo1)) {
+                //不存在就新增
+                algorithmBizProcessBo.setVersion(0);
+                ValidatorUtils.validate(algorithmBizProcessBo);
+                boolean inserted = algorithmBizProcessService.insert(algorithmBizProcessBo);
+
+                if (inserted) {
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、算法业务处理 记录导入成功");
+                    return;
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>").append(failureNum).append("、算法业务处理 记录导入失败");
+                    return;
+                }
+            } else if (isUpdateSupport) {
+                //存在就更新
+                algorithmBizProcessBo.setId(algorithmBizProcessVo1.getId());//主键
+                algorithmBizProcessBo.setVersion(algorithmBizProcessVo1.getVersion());
+                boolean updated = algorithmBizProcessService.update(algorithmBizProcessBo);
+                if (updated) {
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、算法业务处理 记录更新成功");
+                    return;
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>").append(failureNum).append("、算法业务处理 记录更新失败");
+                    return;
+                }
+            }
+        } catch (Exception e) {
+            failureNum++;
+            String msg = "<br/>" + failureNum + "、算法业务处理 记录导入失败：";
+            failureMsg.append(msg).append(e.getMessage());
+            log.error(msg, e);
+        }
+    }
+
+    @Override
+    public void doAfterAllAnalysed(AnalysisContext context) {
+
+    }
+
+    @Override
+    public ExcelResult<AlgorithmBizProcessImportVo> getExcelResult() {
+        return new ExcelResult<>() {
+
+            @Override
+            public String getAnalysis() {
+                if (failureNum > 0) {
+                    failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据没有成功导入，错误如下：");
+                    throw new ServiceException(failureMsg.toString());
+                } else {
+                    successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
+                }
+                return successMsg.toString();
+            }
+
+            @Override
+            public List<AlgorithmBizProcessImportVo> getList() {
+                return null;
+            }
+
+            @Override
+            public List<String> getErrorList() {
+                return null;
+            }
+        };
+    }
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/listener/AlgorithmDataProcessImportListener.java

@@ -0,0 +1,119 @@
+package com.taais.biz.listener;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.util.ObjectUtil;
+import com.alibaba.excel.context.AnalysisContext;
+import com.alibaba.excel.event.AnalysisEventListener;
+import com.taais.common.core.exception.ServiceException;
+import com.taais.common.core.utils.SpringUtils;
+import com.taais.common.core.utils.ValidatorUtils;
+import com.taais.common.excel.core.ExcelListener;
+import com.taais.common.excel.core.ExcelResult;
+import com.taais.biz.domain.bo.AlgorithmDataProcessBo;
+import com.taais.biz.domain.vo.AlgorithmDataProcessImportVo;
+import com.taais.biz.domain.vo.AlgorithmDataProcessVo;
+import com.taais.biz.service.IAlgorithmDataProcessService;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.List;
+
+/**
+ * 算法数据处理自定义导入
+ *
+ * @author 0
+ */
+@Slf4j
+public class AlgorithmDataProcessImportListener extends AnalysisEventListener<AlgorithmDataProcessImportVo> implements ExcelListener<AlgorithmDataProcessImportVo> {
+    private final IAlgorithmDataProcessService algorithmDataProcessService;
+
+    private final Boolean isUpdateSupport;
+    private int successNum = 0;
+    private int failureNum = 0;
+    private final StringBuilder successMsg = new StringBuilder();
+    private final StringBuilder failureMsg = new StringBuilder();
+
+    public AlgorithmDataProcessImportListener(Boolean isUpdateSupport) {
+        this.algorithmDataProcessService = SpringUtils.getBean(IAlgorithmDataProcessService.class);
+        this.isUpdateSupport = isUpdateSupport;
+    }
+
+    @Override
+    public void invoke(AlgorithmDataProcessImportVo algorithmDataProcessVo, AnalysisContext context) {
+        try {
+
+            AlgorithmDataProcessBo algorithmDataProcessBo = BeanUtil.toBean(algorithmDataProcessVo, AlgorithmDataProcessBo.class);
+
+            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
+            AlgorithmDataProcessVo algorithmDataProcessVo1 = null;
+
+            //algorithmDataProcessVo1 = algorithmDataProcessService.selectBySomefield(algorithmDataProcessVo.getSomefield());
+            if (ObjectUtil.isNull(algorithmDataProcessVo1)) {
+                //不存在就新增
+                algorithmDataProcessBo.setVersion(0);
+                ValidatorUtils.validate(algorithmDataProcessBo);
+                boolean inserted = algorithmDataProcessService.insert(algorithmDataProcessBo);
+
+                if (inserted) {
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、算法数据处理 记录导入成功");
+                    return;
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>").append(failureNum).append("、算法数据处理 记录导入失败");
+                    return;
+                }
+            } else if (isUpdateSupport) {
+                //存在就更新
+                algorithmDataProcessBo.setId(algorithmDataProcessVo1.getId());//主键
+                algorithmDataProcessBo.setVersion(algorithmDataProcessVo1.getVersion());
+                boolean updated = algorithmDataProcessService.update(algorithmDataProcessBo);
+                if (updated) {
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、算法数据处理 记录更新成功");
+                    return;
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>").append(failureNum).append("、算法数据处理 记录更新失败");
+                    return;
+                }
+            }
+        } catch (Exception e) {
+            failureNum++;
+            String msg = "<br/>" + failureNum + "、算法数据处理 记录导入失败：";
+            failureMsg.append(msg).append(e.getMessage());
+            log.error(msg, e);
+        }
+    }
+
+    @Override
+    public void doAfterAllAnalysed(AnalysisContext context) {
+
+    }
+
+    @Override
+    public ExcelResult<AlgorithmDataProcessImportVo> getExcelResult() {
+        return new ExcelResult<>() {
+
+            @Override
+            public String getAnalysis() {
+                if (failureNum > 0) {
+                    failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据没有成功导入，错误如下：");
+                    throw new ServiceException(failureMsg.toString());
+                } else {
+                    successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
+                }
+                return successMsg.toString();
+            }
+
+            @Override
+            public List<AlgorithmDataProcessImportVo> getList() {
+                return null;
+            }
+
+            @Override
+            public List<String> getErrorList() {
+                return null;
+            }
+        };
+    }
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/listener/AlgorithmDataSetImportListener.java

@@ -0,0 +1,119 @@
+package com.taais.biz.listener;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.util.ObjectUtil;
+import com.alibaba.excel.context.AnalysisContext;
+import com.alibaba.excel.event.AnalysisEventListener;
+import com.taais.common.core.exception.ServiceException;
+import com.taais.common.core.utils.SpringUtils;
+import com.taais.common.core.utils.ValidatorUtils;
+import com.taais.common.excel.core.ExcelListener;
+import com.taais.common.excel.core.ExcelResult;
+import com.taais.biz.domain.bo.AlgorithmDataSetBo;
+import com.taais.biz.domain.vo.AlgorithmDataSetImportVo;
+import com.taais.biz.domain.vo.AlgorithmDataSetVo;
+import com.taais.biz.service.IAlgorithmDataSetService;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.List;
+
+/**
+ * 算法数据集合自定义导入
+ *
+ * @author km
+ */
+@Slf4j
+public class AlgorithmDataSetImportListener extends AnalysisEventListener<AlgorithmDataSetImportVo> implements ExcelListener<AlgorithmDataSetImportVo> {
+    private final IAlgorithmDataSetService algorithmDataSetService;
+
+    private final Boolean isUpdateSupport;
+    private int successNum = 0;
+    private int failureNum = 0;
+    private final StringBuilder successMsg = new StringBuilder();
+    private final StringBuilder failureMsg = new StringBuilder();
+
+    public AlgorithmDataSetImportListener(Boolean isUpdateSupport) {
+        this.algorithmDataSetService = SpringUtils.getBean(IAlgorithmDataSetService.class);
+        this.isUpdateSupport = isUpdateSupport;
+    }
+
+    @Override
+    public void invoke(AlgorithmDataSetImportVo algorithmDataSetVo, AnalysisContext context) {
+        try {
+
+            AlgorithmDataSetBo algorithmDataSetBo = BeanUtil.toBean(algorithmDataSetVo, AlgorithmDataSetBo.class);
+
+            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
+            AlgorithmDataSetVo algorithmDataSetVo1 = null;
+
+            //algorithmDataSetVo1 = algorithmDataSetService.selectBySomefield(algorithmDataSetVo.getSomefield());
+            if (ObjectUtil.isNull(algorithmDataSetVo1)) {
+                //不存在就新增
+                algorithmDataSetBo.setVersion(0);
+                ValidatorUtils.validate(algorithmDataSetBo);
+                boolean inserted = algorithmDataSetService.insert(algorithmDataSetBo);
+
+                if (inserted) {
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、算法数据集合 记录导入成功");
+                    return;
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>").append(failureNum).append("、算法数据集合 记录导入失败");
+                    return;
+                }
+            } else if (isUpdateSupport) {
+                //存在就更新
+                algorithmDataSetBo.setId(algorithmDataSetVo1.getId());//主键
+                algorithmDataSetBo.setVersion(algorithmDataSetVo1.getVersion());
+                boolean updated = algorithmDataSetService.update(algorithmDataSetBo);
+                if (updated) {
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、算法数据集合 记录更新成功");
+                    return;
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>").append(failureNum).append("、算法数据集合 记录更新失败");
+                    return;
+                }
+            }
+        } catch (Exception e) {
+            failureNum++;
+            String msg = "<br/>" + failureNum + "、算法数据集合 记录导入失败：";
+            failureMsg.append(msg).append(e.getMessage());
+            log.error(msg, e);
+        }
+    }
+
+    @Override
+    public void doAfterAllAnalysed(AnalysisContext context) {
+
+    }
+
+    @Override
+    public ExcelResult<AlgorithmDataSetImportVo> getExcelResult() {
+        return new ExcelResult<>() {
+
+            @Override
+            public String getAnalysis() {
+                if (failureNum > 0) {
+                    failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据没有成功导入，错误如下：");
+                    throw new ServiceException(failureMsg.toString());
+                } else {
+                    successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
+                }
+                return successMsg.toString();
+            }
+
+            @Override
+            public List<AlgorithmDataSetImportVo> getList() {
+                return null;
+            }
+
+            @Override
+            public List<String> getErrorList() {
+                return null;
+            }
+        };
+    }
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/mapper/AlgorithmBizProcessMapper.java

@@ -0,0 +1,16 @@
+package com.taais.biz.mapper;
+
+import com.mybatisflex.core.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import com.taais.biz.domain.AlgorithmBizProcess;
+
+/**
+ * 算法业务处理Mapper接口
+ *
+ * @author 0
+ * 2024-06-14
+ */
+@Mapper
+public interface AlgorithmBizProcessMapper extends BaseMapper<AlgorithmBizProcess> {
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/mapper/AlgorithmDataProcessMapper.java

@@ -0,0 +1,16 @@
+package com.taais.biz.mapper;
+
+import com.mybatisflex.core.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import com.taais.biz.domain.AlgorithmDataProcess;
+
+/**
+ * 算法数据处理Mapper接口
+ *
+ * @author 0
+ * 2024-06-14
+ */
+@Mapper
+public interface AlgorithmDataProcessMapper extends BaseMapper<AlgorithmDataProcess> {
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/mapper/AlgorithmDataSetMapper.java

@@ -0,0 +1,16 @@
+package com.taais.biz.mapper;
+
+import com.mybatisflex.core.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import com.taais.biz.domain.AlgorithmDataSet;
+
+/**
+ * 算法数据集合Mapper接口
+ *
+ * @author km
+ * 2024-06-14
+ */
+@Mapper
+public interface AlgorithmDataSetMapper extends BaseMapper<AlgorithmDataSet> {
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/service/IAlgorithmBizProcessService.java

@@ -0,0 +1,67 @@
+package com.taais.biz.service;
+
+import java.util.List;
+
+import com.taais.biz.domain.AlgorithmBizProcess;
+import com.taais.biz.domain.vo.AlgorithmBizProcessVo;
+import com.taais.biz.domain.bo.AlgorithmBizProcessBo;
+import com.taais.common.orm.core.service.IBaseService;
+import com.taais.common.core.core.page.PageResult;
+
+/**
+ * 算法业务处理Service接口
+ *
+ * @author 0
+ * 2024-06-14
+ */
+public interface IAlgorithmBizProcessService extends IBaseService<AlgorithmBizProcess> {
+    /**
+     * 查询算法业务处理
+     *
+     * @param id 算法业务处理主键
+     * @return 算法业务处理
+     */
+        AlgorithmBizProcessVo selectById(Long id);
+
+    /**
+     * 查询算法业务处理列表
+     *
+     * @param algorithmBizProcessBo 算法业务处理Bo
+     * @return 算法业务处理集合
+     */
+    List<AlgorithmBizProcessVo> selectList(AlgorithmBizProcessBo algorithmBizProcessBo);
+
+    /**
+     * 分页查询算法业务处理列表
+     *
+     * @param algorithmBizProcessBo 算法业务处理Bo
+     * @return 分页算法业务处理集合
+     */
+    PageResult<AlgorithmBizProcessVo> selectPage(AlgorithmBizProcessBo algorithmBizProcessBo);
+
+    /**
+     * 新增算法业务处理
+     *
+     * @param algorithmBizProcessBo 算法业务处理Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    boolean insert(AlgorithmBizProcessBo algorithmBizProcessBo);
+
+    /**
+     * 修改算法业务处理
+     *
+     * @param algorithmBizProcessBo 算法业务处理Bo
+     * @return 结果:true 更新成功，false 更新失败
+     */
+    boolean update(AlgorithmBizProcessBo algorithmBizProcessBo);
+
+    /**
+     * 批量删除算法业务处理
+     *
+     * @param ids 需要删除的算法业务处理主键集合
+     * @return 结果:true 删除成功，false 删除失败
+     */
+    boolean deleteByIds(Long[] ids);
+
+    List<AlgorithmBizProcessVo> getProcessBySubtaskId(Long subtaskId);
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/service/IAlgorithmDataProcessService.java

@@ -0,0 +1,68 @@
+package com.taais.biz.service;
+
+import java.util.List;
+
+import com.taais.biz.domain.AlgorithmDataProcess;
+import com.taais.biz.domain.vo.AlgorithmDataProcessVo;
+import com.taais.biz.domain.bo.AlgorithmDataProcessBo;
+import com.taais.biz.domain.vo.AlgorithmDataSetVo;
+import com.taais.common.orm.core.service.IBaseService;
+import com.taais.common.core.core.page.PageResult;
+
+/**
+ * 算法数据处理Service接口
+ *
+ * @author 0
+ * 2024-06-14
+ */
+public interface IAlgorithmDataProcessService extends IBaseService<AlgorithmDataProcess> {
+    /**
+     * 查询算法数据处理
+     *
+     * @param id 算法数据处理主键
+     * @return 算法数据处理
+     */
+        AlgorithmDataProcessVo selectById(Long id);
+
+    /**
+     * 查询算法数据处理列表
+     *
+     * @param algorithmDataProcessBo 算法数据处理Bo
+     * @return 算法数据处理集合
+     */
+    List<AlgorithmDataProcessVo> selectList(AlgorithmDataProcessBo algorithmDataProcessBo);
+
+    /**
+     * 分页查询算法数据处理列表
+     *
+     * @param algorithmDataProcessBo 算法数据处理Bo
+     * @return 分页算法数据处理集合
+     */
+    PageResult<AlgorithmDataProcessVo> selectPage(AlgorithmDataProcessBo algorithmDataProcessBo);
+
+    /**
+     * 新增算法数据处理
+     *
+     * @param algorithmDataProcessBo 算法数据处理Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    boolean insert(AlgorithmDataProcessBo algorithmDataProcessBo);
+
+    /**
+     * 修改算法数据处理
+     *
+     * @param algorithmDataProcessBo 算法数据处理Bo
+     * @return 结果:true 更新成功，false 更新失败
+     */
+    boolean update(AlgorithmDataProcessBo algorithmDataProcessBo);
+
+    /**
+     * 批量删除算法数据处理
+     *
+     * @param ids 需要删除的算法数据处理主键集合
+     * @return 结果:true 删除成功，false 删除失败
+     */
+    boolean deleteByIds(Long[] ids);
+
+    List<AlgorithmDataProcessVo> getProcessBySubtaskId(Long id);
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/service/IAlgorithmDataSetService.java

@@ -0,0 +1,66 @@
+package com.taais.biz.service;
+
+import java.util.List;
+
+import com.taais.biz.domain.AlgorithmDataSet;
+import com.taais.biz.domain.vo.AlgorithmDataSetVo;
+import com.taais.biz.domain.bo.AlgorithmDataSetBo;
+import com.taais.common.orm.core.service.IBaseService;
+import com.taais.common.core.core.page.PageResult;
+
+/**
+ * 算法数据集合Service接口
+ *
+ * @author km
+ * 2024-06-14
+ */
+public interface IAlgorithmDataSetService extends IBaseService<AlgorithmDataSet> {
+    /**
+     * 查询算法数据集合
+     *
+     * @param id 算法数据集合主键
+     * @return 算法数据集合
+     */
+        AlgorithmDataSetVo selectById(Long id);
+
+    /**
+     * 查询算法数据集合列表
+     *
+     * @param algorithmDataSetBo 算法数据集合Bo
+     * @return 算法数据集合集合
+     */
+    List<AlgorithmDataSetVo> selectList(AlgorithmDataSetBo algorithmDataSetBo);
+
+    /**
+     * 分页查询算法数据集合列表
+     *
+     * @param algorithmDataSetBo 算法数据集合Bo
+     * @return 分页算法数据集合集合
+     */
+    PageResult<AlgorithmDataSetVo> selectPage(AlgorithmDataSetBo algorithmDataSetBo);
+
+    /**
+     * 新增算法数据集合
+     *
+     * @param algorithmDataSetBo 算法数据集合Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    boolean insert(AlgorithmDataSetBo algorithmDataSetBo);
+
+    /**
+     * 修改算法数据集合
+     *
+     * @param algorithmDataSetBo 算法数据集合Bo
+     * @return 结果:true 更新成功，false 更新失败
+     */
+    boolean update(AlgorithmDataSetBo algorithmDataSetBo);
+
+    /**
+     * 批量删除算法数据集合
+     *
+     * @param ids 需要删除的算法数据集合主键集合
+     * @return 结果:true 删除成功，false 删除失败
+     */
+    boolean deleteByIds(Long[] ids);
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/service/impl/AlgorithmBizProcessServiceImpl.java

@@ -0,0 +1,138 @@
+package com.taais.biz.service.impl;
+
+import java.util.Arrays;
+import java.util.List;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.mybatisflex.core.paginate.Page;
+import com.mybatisflex.core.query.QueryWrapper;
+import com.taais.common.core.utils.MapstructUtils;
+import com.taais.common.core.utils.StringUtils;
+import com.taais.common.orm.core.page.PageQuery;
+import com.taais.common.core.core.page.PageResult;
+import com.taais.common.orm.core.service.impl.BaseServiceImpl;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import com.taais.biz.mapper.AlgorithmBizProcessMapper;
+import com.taais.biz.domain.AlgorithmBizProcess;
+import com.taais.biz.domain.bo.AlgorithmBizProcessBo;
+import com.taais.biz.domain.vo.AlgorithmBizProcessVo;
+import com.taais.biz.service.IAlgorithmBizProcessService;
+import static com.taais.biz.domain.table.AlgorithmBizProcessTableDef.ALGORITHM_BIZ_PROCESS;
+
+/**
+ * 算法业务处理Service业务层处理
+ *
+ * @author 0
+ * 2024-06-14
+ */
+@Service
+public class AlgorithmBizProcessServiceImpl extends BaseServiceImpl<AlgorithmBizProcessMapper, AlgorithmBizProcess> implements IAlgorithmBizProcessService {
+    @Resource
+    private AlgorithmBizProcessMapper algorithmBizProcessMapper;
+
+    @Override
+    public QueryWrapper query() {
+        return super.query().from(ALGORITHM_BIZ_PROCESS);
+    }
+
+    private QueryWrapper buildQueryWrapper(AlgorithmBizProcessBo algorithmBizProcessBo) {
+        QueryWrapper queryWrapper = super.buildBaseQueryWrapper();
+        queryWrapper.and(ALGORITHM_BIZ_PROCESS.SUB_TASK_ID.eq
+        (algorithmBizProcessBo.getSubTaskId()));
+        queryWrapper.and(ALGORITHM_BIZ_PROCESS.NAME.like
+        (algorithmBizProcessBo.getName()));
+        queryWrapper.and(ALGORITHM_BIZ_PROCESS.TYPE.eq
+        (algorithmBizProcessBo.getType()));
+        queryWrapper.and(ALGORITHM_BIZ_PROCESS.STATUS.eq
+        (algorithmBizProcessBo.getStatus()));
+
+        return queryWrapper;
+    }
+
+    /**
+     * 查询算法业务处理
+     *
+     * @param id 算法业务处理主键
+     * @return 算法业务处理
+     */
+    @Override
+    public AlgorithmBizProcessVo selectById(Long id) {
+            return this.getOneAs(query().where(ALGORITHM_BIZ_PROCESS.ID.eq(id)), AlgorithmBizProcessVo.class);
+
+    }
+
+    /**
+     * 查询算法业务处理列表
+     *
+     * @param algorithmBizProcessBo 算法业务处理Bo
+     * @return 算法业务处理集合
+     */
+    @Override
+    public List<AlgorithmBizProcessVo> selectList(AlgorithmBizProcessBo algorithmBizProcessBo) {
+        QueryWrapper queryWrapper = buildQueryWrapper(algorithmBizProcessBo);
+            return this.listAs(queryWrapper, AlgorithmBizProcessVo.class);
+    }
+
+    /**
+     * 分页查询算法业务处理列表
+     *
+     * @param algorithmBizProcessBo 算法业务处理Bo
+     * @return 分页算法业务处理集合
+     */
+    @Override
+    public PageResult<AlgorithmBizProcessVo> selectPage(AlgorithmBizProcessBo algorithmBizProcessBo) {
+        QueryWrapper queryWrapper = buildQueryWrapper(algorithmBizProcessBo);
+            Page<AlgorithmBizProcessVo> page = this.pageAs(PageQuery.build(), queryWrapper, AlgorithmBizProcessVo.class);
+        return PageResult.build(page);
+    }
+
+    /**
+     * 新增算法业务处理
+     *
+     * @param algorithmBizProcessBo 算法业务处理Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    @Override
+    public boolean insert(AlgorithmBizProcessBo algorithmBizProcessBo) {
+    AlgorithmBizProcess algorithmBizProcess =MapstructUtils.convert(algorithmBizProcessBo, AlgorithmBizProcess. class);
+
+        return this.save(algorithmBizProcess);//使用全局配置的雪花算法主键生成器生成ID值
+    }
+
+    /**
+     * 修改算法业务处理
+     *
+     * @param algorithmBizProcessBo 算法业务处理Bo
+     * @return 结果:true 更新成功，false 更新失败
+     */
+    @Override
+    public boolean update(AlgorithmBizProcessBo algorithmBizProcessBo) {
+        AlgorithmBizProcess algorithmBizProcess =MapstructUtils.convert(algorithmBizProcessBo, AlgorithmBizProcess. class);
+        if (ObjectUtil.isNotNull(algorithmBizProcess) && ObjectUtil.isNotNull(algorithmBizProcess.getId())){
+            boolean updated = this.updateById(algorithmBizProcess);
+                return updated;
+        }
+        return false;
+    }
+
+    /**
+     * 批量删除算法业务处理
+     *
+     * @param ids 需要删除的算法业务处理主键集合
+     * @return 结果:true 删除成功，false 删除失败
+     */
+    @Transactional
+    @Override
+    public boolean deleteByIds(Long[] ids) {
+        return this.removeByIds(Arrays.asList(ids));
+    }
+
+    @Override
+    public List<AlgorithmBizProcessVo> getProcessBySubtaskId(Long subtaskId) {
+        // todo Allen
+        return null;
+    }
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/service/impl/AlgorithmDataProcessServiceImpl.java

@@ -0,0 +1,138 @@
+package com.taais.biz.service.impl;
+
+import java.util.Arrays;
+import java.util.List;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.mybatisflex.core.paginate.Page;
+import com.mybatisflex.core.query.QueryWrapper;
+import com.taais.common.core.utils.MapstructUtils;
+import com.taais.common.core.utils.StringUtils;
+import com.taais.common.orm.core.page.PageQuery;
+import com.taais.common.core.core.page.PageResult;
+import com.taais.common.orm.core.service.impl.BaseServiceImpl;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import com.taais.biz.mapper.AlgorithmDataProcessMapper;
+import com.taais.biz.domain.AlgorithmDataProcess;
+import com.taais.biz.domain.bo.AlgorithmDataProcessBo;
+import com.taais.biz.domain.vo.AlgorithmDataProcessVo;
+import com.taais.biz.service.IAlgorithmDataProcessService;
+import static com.taais.biz.domain.table.AlgorithmDataProcessTableDef.ALGORITHM_DATA_PROCESS;
+
+/**
+ * 算法数据处理Service业务层处理
+ *
+ * @author 0
+ * 2024-06-14
+ */
+@Service
+public class AlgorithmDataProcessServiceImpl extends BaseServiceImpl<AlgorithmDataProcessMapper, AlgorithmDataProcess> implements IAlgorithmDataProcessService {
+    @Resource
+    private AlgorithmDataProcessMapper algorithmDataProcessMapper;
+
+    @Override
+    public QueryWrapper query() {
+        return super.query().from(ALGORITHM_DATA_PROCESS);
+    }
+
+    private QueryWrapper buildQueryWrapper(AlgorithmDataProcessBo algorithmDataProcessBo) {
+        QueryWrapper queryWrapper = super.buildBaseQueryWrapper();
+        queryWrapper.and(ALGORITHM_DATA_PROCESS.SUB_TASK_ID.eq
+        (algorithmDataProcessBo.getSubTaskId()));
+        queryWrapper.and(ALGORITHM_DATA_PROCESS.NAME.like
+        (algorithmDataProcessBo.getName()));
+        queryWrapper.and(ALGORITHM_DATA_PROCESS.TYPE.eq
+        (algorithmDataProcessBo.getType()));
+        queryWrapper.and(ALGORITHM_DATA_PROCESS.STATUS.eq
+        (algorithmDataProcessBo.getStatus()));
+
+        return queryWrapper;
+    }
+
+    /**
+     * 查询算法数据处理
+     *
+     * @param id 算法数据处理主键
+     * @return 算法数据处理
+     */
+    @Override
+    public AlgorithmDataProcessVo selectById(Long id) {
+            return this.getOneAs(query().where(ALGORITHM_DATA_PROCESS.ID.eq(id)), AlgorithmDataProcessVo.class);
+
+    }
+
+    /**
+     * 查询算法数据处理列表
+     *
+     * @param algorithmDataProcessBo 算法数据处理Bo
+     * @return 算法数据处理集合
+     */
+    @Override
+    public List<AlgorithmDataProcessVo> selectList(AlgorithmDataProcessBo algorithmDataProcessBo) {
+        QueryWrapper queryWrapper = buildQueryWrapper(algorithmDataProcessBo);
+            return this.listAs(queryWrapper, AlgorithmDataProcessVo.class);
+    }
+
+    /**
+     * 分页查询算法数据处理列表
+     *
+     * @param algorithmDataProcessBo 算法数据处理Bo
+     * @return 分页算法数据处理集合
+     */
+    @Override
+    public PageResult<AlgorithmDataProcessVo> selectPage(AlgorithmDataProcessBo algorithmDataProcessBo) {
+        QueryWrapper queryWrapper = buildQueryWrapper(algorithmDataProcessBo);
+            Page<AlgorithmDataProcessVo> page = this.pageAs(PageQuery.build(), queryWrapper, AlgorithmDataProcessVo.class);
+        return PageResult.build(page);
+    }
+
+    /**
+     * 新增算法数据处理
+     *
+     * @param algorithmDataProcessBo 算法数据处理Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    @Override
+    public boolean insert(AlgorithmDataProcessBo algorithmDataProcessBo) {
+    AlgorithmDataProcess algorithmDataProcess =MapstructUtils.convert(algorithmDataProcessBo, AlgorithmDataProcess. class);
+
+        return this.save(algorithmDataProcess);//使用全局配置的雪花算法主键生成器生成ID值
+    }
+
+    /**
+     * 修改算法数据处理
+     *
+     * @param algorithmDataProcessBo 算法数据处理Bo
+     * @return 结果:true 更新成功，false 更新失败
+     */
+    @Override
+    public boolean update(AlgorithmDataProcessBo algorithmDataProcessBo) {
+        AlgorithmDataProcess algorithmDataProcess =MapstructUtils.convert(algorithmDataProcessBo, AlgorithmDataProcess. class);
+        if (ObjectUtil.isNotNull(algorithmDataProcess) && ObjectUtil.isNotNull(algorithmDataProcess.getId())){
+            boolean updated = this.updateById(algorithmDataProcess);
+                return updated;
+        }
+        return false;
+    }
+
+    /**
+     * 批量删除算法数据处理
+     *
+     * @param ids 需要删除的算法数据处理主键集合
+     * @return 结果:true 删除成功，false 删除失败
+     */
+    @Transactional
+    @Override
+    public boolean deleteByIds(Long[] ids) {
+        return this.removeByIds(Arrays.asList(ids));
+    }
+
+    @Override
+    public List<AlgorithmDataProcessVo> getProcessBySubtaskId(Long id) {
+        // todo Allen
+        return null;
+    }
+
+}

taais-modules/taais-biz/src/main/java/com/taais/biz/service/impl/AlgorithmDataSetServiceImpl.java

@@ -0,0 +1,132 @@
+package com.taais.biz.service.impl;
+
+import java.util.Arrays;
+import java.util.List;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.mybatisflex.core.paginate.Page;
+import com.mybatisflex.core.query.QueryWrapper;
+import com.taais.common.core.utils.MapstructUtils;
+import com.taais.common.core.utils.StringUtils;
+import com.taais.common.orm.core.page.PageQuery;
+import com.taais.common.core.core.page.PageResult;
+import com.taais.common.orm.core.service.impl.BaseServiceImpl;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import com.taais.biz.mapper.AlgorithmDataSetMapper;
+import com.taais.biz.domain.AlgorithmDataSet;
+import com.taais.biz.domain.bo.AlgorithmDataSetBo;
+import com.taais.biz.domain.vo.AlgorithmDataSetVo;
+import com.taais.biz.service.IAlgorithmDataSetService;
+import static com.taais.biz.domain.table.AlgorithmDataSetTableDef.ALGORITHM_DATA_SET;
+
+/**
+ * 算法数据集合Service业务层处理
+ *
+ * @author km
+ * 2024-06-14
+ */
+@Service
+public class AlgorithmDataSetServiceImpl extends BaseServiceImpl<AlgorithmDataSetMapper, AlgorithmDataSet> implements IAlgorithmDataSetService {
+    @Resource
+    private AlgorithmDataSetMapper algorithmDataSetMapper;
+
+    @Override
+    public QueryWrapper query() {
+        return super.query().from(ALGORITHM_DATA_SET);
+    }
+
+    private QueryWrapper buildQueryWrapper(AlgorithmDataSetBo algorithmDataSetBo) {
+        QueryWrapper queryWrapper = super.buildBaseQueryWrapper();
+        queryWrapper.and(ALGORITHM_DATA_SET.SUB_TASK_ID.eq
+        (algorithmDataSetBo.getSubTaskId()));
+        queryWrapper.and(ALGORITHM_DATA_SET.NAME.like
+        (algorithmDataSetBo.getName()));
+        queryWrapper.and(ALGORITHM_DATA_SET.TYPE.eq
+        (algorithmDataSetBo.getType()));
+        queryWrapper.and(ALGORITHM_DATA_SET.STATUS.eq
+        (algorithmDataSetBo.getStatus()));
+
+        return queryWrapper;
+    }
+
+    /**
+     * 查询算法数据集合
+     *
+     * @param id 算法数据集合主键
+     * @return 算法数据集合
+     */
+    @Override
+    public AlgorithmDataSetVo selectById(Long id) {
+            return this.getOneAs(query().where(ALGORITHM_DATA_SET.ID.eq(id)), AlgorithmDataSetVo.class);
+
+    }
+
+    /**
+     * 查询算法数据集合列表
+     *
+     * @param algorithmDataSetBo 算法数据集合Bo
+     * @return 算法数据集合集合
+     */
+    @Override
+    public List<AlgorithmDataSetVo> selectList(AlgorithmDataSetBo algorithmDataSetBo) {
+        QueryWrapper queryWrapper = buildQueryWrapper(algorithmDataSetBo);
+            return this.listAs(queryWrapper, AlgorithmDataSetVo.class);
+    }
+
+    /**
+     * 分页查询算法数据集合列表
+     *
+     * @param algorithmDataSetBo 算法数据集合Bo
+     * @return 分页算法数据集合集合
+     */
+    @Override
+    public PageResult<AlgorithmDataSetVo> selectPage(AlgorithmDataSetBo algorithmDataSetBo) {
+        QueryWrapper queryWrapper = buildQueryWrapper(algorithmDataSetBo);
+            Page<AlgorithmDataSetVo> page = this.pageAs(PageQuery.build(), queryWrapper, AlgorithmDataSetVo.class);
+        return PageResult.build(page);
+    }
+
+    /**
+     * 新增算法数据集合
+     *
+     * @param algorithmDataSetBo 算法数据集合Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    @Override
+    public boolean insert(AlgorithmDataSetBo algorithmDataSetBo) {
+    AlgorithmDataSet algorithmDataSet =MapstructUtils.convert(algorithmDataSetBo, AlgorithmDataSet. class);
+
+        return this.save(algorithmDataSet);//使用全局配置的雪花算法主键生成器生成ID值
+    }
+
+    /**
+     * 修改算法数据集合
+     *
+     * @param algorithmDataSetBo 算法数据集合Bo
+     * @return 结果:true 更新成功，false 更新失败
+     */
+    @Override
+    public boolean update(AlgorithmDataSetBo algorithmDataSetBo) {
+        AlgorithmDataSet algorithmDataSet =MapstructUtils.convert(algorithmDataSetBo, AlgorithmDataSet. class);
+        if (ObjectUtil.isNotNull(algorithmDataSet) && ObjectUtil.isNotNull(algorithmDataSet.getId())){
+            boolean updated = this.updateById(algorithmDataSet);
+                return updated;
+        }
+        return false;
+    }
+
+    /**
+     * 批量删除算法数据集合
+     *
+     * @param ids 需要删除的算法数据集合主键集合
+     * @return 结果:true 删除成功，false 删除失败
+     */
+    @Transactional
+    @Override
+    public boolean deleteByIds(Long[] ids) {
+        return this.removeByIds(Arrays.asList(ids));
+    }
+
+}

taais-modules/taais-biz/src/main/resources/mapper/demo/DataMapper.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.taais.biz.mapper.DataMapper">
+
+</mapper>

taais-modules/taais-biz/src/main/resources/mapper/task/AlgorithmBizProcessMapper.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.taais.biz.mapper.AlgorithmBizProcessMapper">
+
+</mapper>

taais-modules/taais-biz/src/main/resources/mapper/task/AlgorithmDataProcessMapper.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.taais.biz.mapper.AlgorithmDataProcessMapper">
+
+</mapper>

taais-modules/taais-biz/src/main/resources/mapper/task/AlgorithmDataSetMapper.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.taais.biz.mapper.AlgorithmDataSetMapper">
+
+</mapper>