fix: 删除冗余代码

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

@@ -1,119 +0,0 @@
-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/AlgorithmConfigImportListener.java

@@ -1,119 +0,0 @@
-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.AlgorithmConfigBo;
-import com.taais.biz.domain.vo.AlgorithmConfigImportVo;
-import com.taais.biz.domain.vo.AlgorithmConfigVo;
-import com.taais.biz.service.IAlgorithmConfigService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 算法配置自定义导入
- *
- * @author 0
- */
-@Slf4j
-public class AlgorithmConfigImportListener extends AnalysisEventListener<AlgorithmConfigImportVo> implements ExcelListener<AlgorithmConfigImportVo> {
-    private final IAlgorithmConfigService algorithmConfigService;
-
-    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 AlgorithmConfigImportListener(Boolean isUpdateSupport) {
-        this.algorithmConfigService = SpringUtils.getBean(IAlgorithmConfigService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(AlgorithmConfigImportVo algorithmConfigVo, AnalysisContext context) {
-        try {
-
-            AlgorithmConfigBo algorithmConfigBo = BeanUtil.toBean(algorithmConfigVo, AlgorithmConfigBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            AlgorithmConfigVo algorithmConfigVo1 = null;
-
-            //algorithmConfigVo1 = algorithmConfigService.selectBySomefield(algorithmConfigVo.getSomefield());
-            if (ObjectUtil.isNull(algorithmConfigVo1)) {
-                //不存在就新增
-                algorithmConfigBo.setVersion(0);
-                ValidatorUtils.validate(algorithmConfigBo);
-                boolean inserted = algorithmConfigService.insert(algorithmConfigBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、算法配置 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、算法配置 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                algorithmConfigBo.setId(algorithmConfigVo1.getId());//主键
-                algorithmConfigBo.setVersion(algorithmConfigVo1.getVersion());
-                boolean updated = algorithmConfigService.update(algorithmConfigBo);
-                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<AlgorithmConfigImportVo> 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<AlgorithmConfigImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.AlgorithmConfigTrackBo;
-import com.taais.biz.domain.vo.AlgorithmConfigTrackImportVo;
-import com.taais.biz.domain.vo.AlgorithmConfigTrackVo;
-import com.taais.biz.service.IAlgorithmConfigTrackService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 算法配置自定义导入
- *
- * @author wangkang
- */
-@Slf4j
-public class AlgorithmConfigTrackImportListener extends AnalysisEventListener<AlgorithmConfigTrackImportVo> implements ExcelListener<AlgorithmConfigTrackImportVo> {
-    private final IAlgorithmConfigTrackService algorithmConfigTrackService;
-
-    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 AlgorithmConfigTrackImportListener(Boolean isUpdateSupport) {
-        this.algorithmConfigTrackService = SpringUtils.getBean(IAlgorithmConfigTrackService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(AlgorithmConfigTrackImportVo algorithmConfigTrackVo, AnalysisContext context) {
-        try {
-
-            AlgorithmConfigTrackBo algorithmConfigTrackBo = BeanUtil.toBean(algorithmConfigTrackVo, AlgorithmConfigTrackBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            AlgorithmConfigTrackVo algorithmConfigTrackVo1 = null;
-
-            //algorithmConfigTrackVo1 = algorithmConfigTrackService.selectBySomefield(algorithmConfigTrackVo.getSomefield());
-            if (ObjectUtil.isNull(algorithmConfigTrackVo1)) {
-                //不存在就新增
-                algorithmConfigTrackBo.setVersion(0);
-                ValidatorUtils.validate(algorithmConfigTrackBo);
-                boolean inserted = algorithmConfigTrackService.insert(algorithmConfigTrackBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、算法配置 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、算法配置 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                algorithmConfigTrackBo.setId(algorithmConfigTrackVo1.getId());//主键
-                algorithmConfigTrackBo.setVersion(algorithmConfigTrackVo1.getVersion());
-                boolean updated = algorithmConfigTrackService.update(algorithmConfigTrackBo);
-                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<AlgorithmConfigTrackImportVo> 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<AlgorithmConfigTrackImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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

@@ -1,119 +0,0 @@
-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/listener/AlgorithmModelImportListener.java

@@ -1,119 +0,0 @@
-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.AlgorithmModelBo;
-import com.taais.biz.domain.vo.AlgorithmModelImportVo;
-import com.taais.biz.domain.vo.AlgorithmModelVo;
-import com.taais.biz.service.IAlgorithmModelService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 算法模型配置自定义导入
- *
- * @author 0
- */
-@Slf4j
-public class AlgorithmModelImportListener extends AnalysisEventListener<AlgorithmModelImportVo> implements ExcelListener<AlgorithmModelImportVo> {
-    private final IAlgorithmModelService algorithmModelService;
-
-    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 AlgorithmModelImportListener(Boolean isUpdateSupport) {
-        this.algorithmModelService = SpringUtils.getBean(IAlgorithmModelService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(AlgorithmModelImportVo algorithmModelVo, AnalysisContext context) {
-        try {
-
-            AlgorithmModelBo algorithmModelBo = BeanUtil.toBean(algorithmModelVo, AlgorithmModelBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            AlgorithmModelVo algorithmModelVo1 = null;
-
-            //algorithmModelVo1 = algorithmModelService.selectBySomefield(algorithmModelVo.getSomefield());
-            if (ObjectUtil.isNull(algorithmModelVo1)) {
-                //不存在就新增
-                algorithmModelBo.setVersion(0);
-                ValidatorUtils.validate(algorithmModelBo);
-                boolean inserted = algorithmModelService.insert(algorithmModelBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、算法模型配置 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、算法模型配置 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                algorithmModelBo.setId(algorithmModelVo1.getId());//主键
-                algorithmModelBo.setVersion(algorithmModelVo1.getVersion());
-                boolean updated = algorithmModelService.update(algorithmModelBo);
-                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<AlgorithmModelImportVo> 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<AlgorithmModelImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,120 +0,0 @@
-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.core.domain.CommonResult;
-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.AlgorithmModelTrackBo;
-import com.taais.biz.domain.vo.AlgorithmModelTrackImportVo;
-import com.taais.biz.domain.vo.AlgorithmModelTrackVo;
-import com.taais.biz.service.IAlgorithmModelTrackService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 算法模型配置自定义导入
- *
- * @author wangkang
- */
-@Slf4j
-public class AlgorithmModelTrackImportListener extends AnalysisEventListener<AlgorithmModelTrackImportVo> implements ExcelListener<AlgorithmModelTrackImportVo> {
-    private final IAlgorithmModelTrackService algorithmModelTrackService;
-
-    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 AlgorithmModelTrackImportListener(Boolean isUpdateSupport) {
-        this.algorithmModelTrackService = SpringUtils.getBean(IAlgorithmModelTrackService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(AlgorithmModelTrackImportVo algorithmModelTrackVo, AnalysisContext context) {
-        try {
-
-            AlgorithmModelTrackBo algorithmModelTrackBo = BeanUtil.toBean(algorithmModelTrackVo, AlgorithmModelTrackBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            AlgorithmModelTrackVo algorithmModelTrackVo1 = null;
-
-            //algorithmModelTrackVo1 = algorithmModelTrackService.selectBySomefield(algorithmModelTrackVo.getSomefield());
-            if (ObjectUtil.isNull(algorithmModelTrackVo1)) {
-                //不存在就新增
-                algorithmModelTrackBo.setVersion(0);
-                ValidatorUtils.validate(algorithmModelTrackBo);
-                CommonResult<String> result = algorithmModelTrackService.insert(algorithmModelTrackBo);
-
-                if (result.getCode() == CommonResult.SUCCESS) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、算法模型配置 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、算法模型配置 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                algorithmModelTrackBo.setId(algorithmModelTrackVo1.getId());//主键
-                algorithmModelTrackBo.setVersion(algorithmModelTrackVo1.getVersion());
-                boolean updated = algorithmModelTrackService.update(algorithmModelTrackBo);
-                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<AlgorithmModelTrackImportVo> 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<AlgorithmModelTrackImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.AlgorithmSubtaskDetailBo;
-import com.taais.biz.domain.vo.AlgorithmSubtaskDetailImportVo;
-import com.taais.biz.domain.vo.AlgorithmSubtaskDetailVo;
-import com.taais.biz.service.IAlgorithmSubtaskDetailService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 算法子任务详情自定义导入
- *
- * @author 0
- */
-@Slf4j
-public class AlgorithmSubtaskDetailImportListener extends AnalysisEventListener<AlgorithmSubtaskDetailImportVo> implements ExcelListener<AlgorithmSubtaskDetailImportVo> {
-    private final IAlgorithmSubtaskDetailService algorithmSubtaskDetailService;
-
-    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 AlgorithmSubtaskDetailImportListener(Boolean isUpdateSupport) {
-        this.algorithmSubtaskDetailService = SpringUtils.getBean(IAlgorithmSubtaskDetailService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(AlgorithmSubtaskDetailImportVo algorithmSubtaskDetailVo, AnalysisContext context) {
-        try {
-
-            AlgorithmSubtaskDetailBo algorithmSubtaskDetailBo = BeanUtil.toBean(algorithmSubtaskDetailVo, AlgorithmSubtaskDetailBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            AlgorithmSubtaskDetailVo algorithmSubtaskDetailVo1 = null;
-
-            //algorithmSubtaskDetailVo1 = algorithmSubtaskDetailService.selectBySomefield(algorithmSubtaskDetailVo.getSomefield());
-            if (ObjectUtil.isNull(algorithmSubtaskDetailVo1)) {
-                //不存在就新增
-                algorithmSubtaskDetailBo.setVersion(0);
-                ValidatorUtils.validate(algorithmSubtaskDetailBo);
-                boolean inserted = algorithmSubtaskDetailService.insert(algorithmSubtaskDetailBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、算法子任务详情 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、算法子任务详情 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                algorithmSubtaskDetailBo.setId(algorithmSubtaskDetailVo1.getId());//主键
-                algorithmSubtaskDetailBo.setVersion(algorithmSubtaskDetailVo1.getVersion());
-                boolean updated = algorithmSubtaskDetailService.update(algorithmSubtaskDetailBo);
-                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<AlgorithmSubtaskDetailImportVo> 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<AlgorithmSubtaskDetailImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.AlgorithmSubtaskBo;
-import com.taais.biz.domain.vo.AlgorithmSubtaskImportVo;
-import com.taais.biz.domain.vo.AlgorithmSubtaskVo;
-import com.taais.biz.service.IAlgorithmSubtaskService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 算法子任务自定义导入
- *
- * @author Allen
- */
-@Slf4j
-public class AlgorithmSubtaskImportListener extends AnalysisEventListener<AlgorithmSubtaskImportVo> implements ExcelListener<AlgorithmSubtaskImportVo> {
-    private final IAlgorithmSubtaskService algorithmSubtaskService;
-
-    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 AlgorithmSubtaskImportListener(Boolean isUpdateSupport) {
-        this.algorithmSubtaskService = SpringUtils.getBean(IAlgorithmSubtaskService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(AlgorithmSubtaskImportVo algorithmSubtaskVo, AnalysisContext context) {
-        try {
-
-            AlgorithmSubtaskBo algorithmSubtaskBo = BeanUtil.toBean(algorithmSubtaskVo, AlgorithmSubtaskBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            AlgorithmSubtaskVo algorithmSubtaskVo1 = null;
-
-            //algorithmSubtaskVo1 = algorithmSubtaskService.selectBySomefield(algorithmSubtaskVo.getSomefield());
-            if (ObjectUtil.isNull(algorithmSubtaskVo1)) {
-                //不存在就新增
-                algorithmSubtaskBo.setVersion(0);
-                ValidatorUtils.validate(algorithmSubtaskBo);
-                boolean inserted = algorithmSubtaskService.insert(algorithmSubtaskBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、算法子任务 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、算法子任务 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                algorithmSubtaskBo.setId(algorithmSubtaskVo1.getId());//主键
-                algorithmSubtaskBo.setVersion(algorithmSubtaskVo1.getVersion());
-                boolean updated = algorithmSubtaskService.update(algorithmSubtaskBo);
-                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<AlgorithmSubtaskImportVo> 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<AlgorithmSubtaskImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.AlgorithmTaskConfigurationBo;
-import com.taais.biz.domain.vo.AlgorithmTaskConfigurationImportVo;
-import com.taais.biz.domain.vo.AlgorithmTaskConfigurationVo;
-import com.taais.biz.service.IAlgorithmTaskConfigurationService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 算法任务自定义导入
- *
- * @author 0
- */
-@Slf4j
-public class AlgorithmTaskConfigurationImportListener extends AnalysisEventListener<AlgorithmTaskConfigurationImportVo> implements ExcelListener<AlgorithmTaskConfigurationImportVo> {
-    private final IAlgorithmTaskConfigurationService algorithmTaskConfigurationService;
-
-    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 AlgorithmTaskConfigurationImportListener(Boolean isUpdateSupport) {
-        this.algorithmTaskConfigurationService = SpringUtils.getBean(IAlgorithmTaskConfigurationService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(AlgorithmTaskConfigurationImportVo algorithmTaskConfigurationVo, AnalysisContext context) {
-        try {
-
-            AlgorithmTaskConfigurationBo algorithmTaskConfigurationBo = BeanUtil.toBean(algorithmTaskConfigurationVo, AlgorithmTaskConfigurationBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            AlgorithmTaskConfigurationVo algorithmTaskConfigurationVo1 = null;
-
-            //algorithmTaskConfigurationVo1 = algorithmTaskConfigurationService.selectBySomefield(algorithmTaskConfigurationVo.getSomefield());
-            if (ObjectUtil.isNull(algorithmTaskConfigurationVo1)) {
-                //不存在就新增
-                algorithmTaskConfigurationBo.setVersion(0);
-                ValidatorUtils.validate(algorithmTaskConfigurationBo);
-                boolean inserted = algorithmTaskConfigurationService.insert(algorithmTaskConfigurationBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、算法任务 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、算法任务 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                algorithmTaskConfigurationBo.setId(algorithmTaskConfigurationVo1.getId());//主键
-                algorithmTaskConfigurationBo.setVersion(algorithmTaskConfigurationVo1.getVersion());
-                boolean updated = algorithmTaskConfigurationService.update(algorithmTaskConfigurationBo);
-                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<AlgorithmTaskConfigurationImportVo> 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<AlgorithmTaskConfigurationImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.AlgorithmTaskBo;
-import com.taais.biz.domain.vo.AlgorithmTaskImportVo;
-import com.taais.biz.domain.vo.AlgorithmTaskVo;
-import com.taais.biz.service.IAlgorithmTaskService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 算法任务自定义导入
- *
- * @author 0
- */
-@Slf4j
-public class AlgorithmTaskImportListener extends AnalysisEventListener<AlgorithmTaskImportVo> implements ExcelListener<AlgorithmTaskImportVo> {
-    private final IAlgorithmTaskService algorithmTaskService;
-
-    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 AlgorithmTaskImportListener(Boolean isUpdateSupport) {
-        this.algorithmTaskService = SpringUtils.getBean(IAlgorithmTaskService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(AlgorithmTaskImportVo algorithmTaskVo, AnalysisContext context) {
-        try {
-
-            AlgorithmTaskBo algorithmTaskBo = BeanUtil.toBean(algorithmTaskVo, AlgorithmTaskBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            AlgorithmTaskVo algorithmTaskVo1 = null;
-
-            //algorithmTaskVo1 = algorithmTaskService.selectBySomefield(algorithmTaskVo.getSomefield());
-            if (ObjectUtil.isNull(algorithmTaskVo1)) {
-                //不存在就新增
-                algorithmTaskBo.setVersion(0);
-                ValidatorUtils.validate(algorithmTaskBo);
-                boolean inserted = algorithmTaskService.insert(algorithmTaskBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、算法任务 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、算法任务 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                algorithmTaskBo.setId(algorithmTaskVo1.getId());//主键
-                algorithmTaskBo.setVersion(algorithmTaskVo1.getVersion());
-                boolean updated = algorithmTaskService.update(algorithmTaskBo);
-                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<AlgorithmTaskImportVo> 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<AlgorithmTaskImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.DataSeqBo;
-import com.taais.biz.domain.vo.DataSeqImportVo;
-import com.taais.biz.domain.vo.DataSeqVo;
-import com.taais.biz.service.IDataSeqService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 数据管理自定义导入
- *
- * @author wangkang
- */
-@Slf4j
-public class DataSeqImportListener extends AnalysisEventListener<DataSeqImportVo> implements ExcelListener<DataSeqImportVo> {
-    private final IDataSeqService dataSeqService;
-
-    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 DataSeqImportListener(Boolean isUpdateSupport) {
-        this.dataSeqService = SpringUtils.getBean(IDataSeqService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(DataSeqImportVo dataSeqVo, AnalysisContext context) {
-        try {
-
-            DataSeqBo dataSeqBo = BeanUtil.toBean(dataSeqVo, DataSeqBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            DataSeqVo dataSeqVo1 = null;
-
-            //dataSeqVo1 = dataSeqService.selectBySomefield(dataSeqVo.getSomefield());
-            if (ObjectUtil.isNull(dataSeqVo1)) {
-                //不存在就新增
-                dataSeqBo.setVersion(0);
-                ValidatorUtils.validate(dataSeqBo);
-                boolean inserted = dataSeqService.insert(dataSeqBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、数据管理 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、数据管理 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                dataSeqBo.setId(dataSeqVo1.getId());//主键
-                dataSeqBo.setVersion(dataSeqVo1.getVersion());
-                boolean updated = dataSeqService.update(dataSeqBo);
-                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<DataSeqImportVo> 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<DataSeqImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.biz.domain.bo.ObjectTraceMergeBo;
-import com.taais.biz.domain.vo.ObjectTraceMergeImportVo;
-import com.taais.biz.domain.vo.ObjectTraceMergeVo;
-import com.taais.biz.service.IObjectTraceMergeService;
-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 lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 多物体融合轨迹识别自定义导入
- *
- * @author km
- */
-@Slf4j
-public class ObjectTraceMergeImportListener extends AnalysisEventListener<ObjectTraceMergeImportVo> implements ExcelListener<ObjectTraceMergeImportVo> {
-    private final IObjectTraceMergeService objectTraceMergeService;
-
-    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 ObjectTraceMergeImportListener(Boolean isUpdateSupport) {
-        this.objectTraceMergeService = SpringUtils.getBean(IObjectTraceMergeService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(ObjectTraceMergeImportVo objectTraceMergeVo, AnalysisContext context) {
-        try {
-
-            ObjectTraceMergeBo objectTraceMergeBo = BeanUtil.toBean(objectTraceMergeVo, ObjectTraceMergeBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            ObjectTraceMergeVo objectTraceMergeVo1 = null;
-
-            //objectTraceMergeVo1 = objectTraceMergeService.selectBySomefield(objectTraceMergeVo.getSomefield());
-            if (ObjectUtil.isNull(objectTraceMergeVo1)) {
-                //不存在就新增
-                objectTraceMergeBo.setVersion(0);
-                ValidatorUtils.validate(objectTraceMergeBo);
-                boolean inserted = objectTraceMergeService.insert(objectTraceMergeBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、多物体融合轨迹识别 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、多物体融合轨迹识别 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                objectTraceMergeBo.setId(objectTraceMergeVo1.getId());//主键
-                objectTraceMergeBo.setVersion(objectTraceMergeVo1.getVersion());
-                boolean updated = objectTraceMergeService.update(objectTraceMergeBo);
-                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<ObjectTraceMergeImportVo> 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<ObjectTraceMergeImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.TargetDetectionBo;
-import com.taais.biz.domain.vo.TargetDetectionImportVo;
-import com.taais.biz.domain.vo.TargetDetectionVo;
-import com.taais.biz.service.ITargetDetectionService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 目标检测自定义导入
- *
- * @author wangkang
- */
-@Slf4j
-public class TargetDetectionImportListener extends AnalysisEventListener<TargetDetectionImportVo> implements ExcelListener<TargetDetectionImportVo> {
-    private final ITargetDetectionService targetDetectionService;
-
-    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 TargetDetectionImportListener(Boolean isUpdateSupport) {
-        this.targetDetectionService = SpringUtils.getBean(ITargetDetectionService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(TargetDetectionImportVo targetDetectionVo, AnalysisContext context) {
-        try {
-
-            TargetDetectionBo targetDetectionBo = BeanUtil.toBean(targetDetectionVo, TargetDetectionBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            TargetDetectionVo targetDetectionVo1 = null;
-
-            //targetDetectionVo1 = targetDetectionService.selectBySomefield(targetDetectionVo.getSomefield());
-            if (ObjectUtil.isNull(targetDetectionVo1)) {
-                //不存在就新增
-                targetDetectionBo.setVersion(0);
-                ValidatorUtils.validate(targetDetectionBo);
-                boolean inserted = targetDetectionService.insert(targetDetectionBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、目标检测 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、目标检测 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                targetDetectionBo.setId(targetDetectionVo1.getId());//主键
-                targetDetectionBo.setVersion(targetDetectionVo1.getVersion());
-                boolean updated = targetDetectionService.update(targetDetectionBo);
-                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<TargetDetectionImportVo> 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<TargetDetectionImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.TargetIdentificationSubtaskDetailsBo;
-import com.taais.biz.domain.vo.TargetIdentificationSubtaskDetailsImportVo;
-import com.taais.biz.domain.vo.TargetIdentificationSubtaskDetailsVo;
-import com.taais.biz.service.ITargetIdentificationSubtaskDetailsService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 目标识别子任务自定义导入
- *
- * @author 0
- */
-@Slf4j
-public class TargetIdentificationSubtaskDetailsImportListener extends AnalysisEventListener<TargetIdentificationSubtaskDetailsImportVo> implements ExcelListener<TargetIdentificationSubtaskDetailsImportVo> {
-    private final ITargetIdentificationSubtaskDetailsService targetIdentificationSubtaskDetailsService;
-
-    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 TargetIdentificationSubtaskDetailsImportListener(Boolean isUpdateSupport) {
-        this.targetIdentificationSubtaskDetailsService = SpringUtils.getBean(ITargetIdentificationSubtaskDetailsService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(TargetIdentificationSubtaskDetailsImportVo targetIdentificationSubtaskDetailsVo, AnalysisContext context) {
-        try {
-
-            TargetIdentificationSubtaskDetailsBo targetIdentificationSubtaskDetailsBo = BeanUtil.toBean(targetIdentificationSubtaskDetailsVo, TargetIdentificationSubtaskDetailsBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            TargetIdentificationSubtaskDetailsVo targetIdentificationSubtaskDetailsVo1 = null;
-
-            //targetIdentificationSubtaskDetailsVo1 = targetIdentificationSubtaskDetailsService.selectBySomefield(targetIdentificationSubtaskDetailsVo.getSomefield());
-            if (ObjectUtil.isNull(targetIdentificationSubtaskDetailsVo1)) {
-                //不存在就新增
-                targetIdentificationSubtaskDetailsBo.setVersion(0);
-                ValidatorUtils.validate(targetIdentificationSubtaskDetailsBo);
-                boolean inserted = targetIdentificationSubtaskDetailsService.insert(targetIdentificationSubtaskDetailsBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、目标识别子任务 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、目标识别子任务 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                targetIdentificationSubtaskDetailsBo.setId(targetIdentificationSubtaskDetailsVo1.getId());//主键
-                targetIdentificationSubtaskDetailsBo.setVersion(targetIdentificationSubtaskDetailsVo1.getVersion());
-                boolean updated = targetIdentificationSubtaskDetailsService.update(targetIdentificationSubtaskDetailsBo);
-                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<TargetIdentificationSubtaskDetailsImportVo> 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<TargetIdentificationSubtaskDetailsImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.TargetIdentificationSubtaskBo;
-import com.taais.biz.domain.vo.TargetIdentificationSubtaskImportVo;
-import com.taais.biz.domain.vo.TargetIdentificationSubtaskVo;
-import com.taais.biz.service.ITargetIdentificationSubtaskService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 目标识别子任务自定义导入
- *
- * @author Allen
- */
-@Slf4j
-public class TargetIdentificationSubtaskImportListener extends AnalysisEventListener<TargetIdentificationSubtaskImportVo> implements ExcelListener<TargetIdentificationSubtaskImportVo> {
-    private final ITargetIdentificationSubtaskService targetIdentificationSubtaskService;
-
-    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 TargetIdentificationSubtaskImportListener(Boolean isUpdateSupport) {
-        this.targetIdentificationSubtaskService = SpringUtils.getBean(ITargetIdentificationSubtaskService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(TargetIdentificationSubtaskImportVo targetIdentificationSubtaskVo, AnalysisContext context) {
-        try {
-
-            TargetIdentificationSubtaskBo targetIdentificationSubtaskBo = BeanUtil.toBean(targetIdentificationSubtaskVo, TargetIdentificationSubtaskBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            TargetIdentificationSubtaskVo targetIdentificationSubtaskVo1 = null;
-
-            //targetIdentificationSubtaskVo1 = targetIdentificationSubtaskService.selectBySomefield(targetIdentificationSubtaskVo.getSomefield());
-            if (ObjectUtil.isNull(targetIdentificationSubtaskVo1)) {
-                //不存在就新增
-                targetIdentificationSubtaskBo.setVersion(0);
-                ValidatorUtils.validate(targetIdentificationSubtaskBo);
-                boolean inserted = targetIdentificationSubtaskService.insert(targetIdentificationSubtaskBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、目标识别子任务 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、目标识别子任务 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                targetIdentificationSubtaskBo.setId(targetIdentificationSubtaskVo1.getId());//主键
-                targetIdentificationSubtaskBo.setVersion(targetIdentificationSubtaskVo1.getVersion());
-                boolean updated = targetIdentificationSubtaskService.update(targetIdentificationSubtaskBo);
-                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<TargetIdentificationSubtaskImportVo> 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<TargetIdentificationSubtaskImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.TargetIdentificationTaskBo;
-import com.taais.biz.domain.vo.TargetIdentificationTaskImportVo;
-import com.taais.biz.domain.vo.TargetIdentificationTaskVo;
-import com.taais.biz.service.ITargetIdentificationTaskService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 目标识别任务自定义导入
- *
- * @author km
- */
-@Slf4j
-public class TargetIdentificationTaskImportListener extends AnalysisEventListener<TargetIdentificationTaskImportVo> implements ExcelListener<TargetIdentificationTaskImportVo> {
-    private final ITargetIdentificationTaskService targetIdentificationTaskService;
-
-    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 TargetIdentificationTaskImportListener(Boolean isUpdateSupport) {
-        this.targetIdentificationTaskService = SpringUtils.getBean(ITargetIdentificationTaskService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(TargetIdentificationTaskImportVo targetIdentificationTaskVo, AnalysisContext context) {
-        try {
-
-            TargetIdentificationTaskBo targetIdentificationTaskBo = BeanUtil.toBean(targetIdentificationTaskVo, TargetIdentificationTaskBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            TargetIdentificationTaskVo targetIdentificationTaskVo1 = null;
-
-            //targetIdentificationTaskVo1 = targetIdentificationTaskService.selectBySomefield(targetIdentificationTaskVo.getSomefield());
-            if (ObjectUtil.isNull(targetIdentificationTaskVo1)) {
-                //不存在就新增
-                targetIdentificationTaskBo.setVersion(0);
-                ValidatorUtils.validate(targetIdentificationTaskBo);
-                boolean inserted = targetIdentificationTaskService.insert(targetIdentificationTaskBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、目标识别任务 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、目标识别任务 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                targetIdentificationTaskBo.setId(targetIdentificationTaskVo1.getId());//主键
-                targetIdentificationTaskBo.setVersion(targetIdentificationTaskVo1.getVersion());
-                boolean updated = targetIdentificationTaskService.update(targetIdentificationTaskBo);
-                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<TargetIdentificationTaskImportVo> 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<TargetIdentificationTaskImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.biz.domain.bo.ToInfraredBo;
-import com.taais.biz.domain.vo.ToInfraredImportVo;
-import com.taais.biz.domain.vo.ToInfraredVo;
-import com.taais.biz.service.IToInfraredService;
-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 lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 可见光转红外自定义导入
- *
- * @author 0
- */
-@Slf4j
-public class ToInfraredImportListener extends AnalysisEventListener<ToInfraredImportVo> implements ExcelListener<ToInfraredImportVo> {
-    private final IToInfraredService toInfraredService;
-
-    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 ToInfraredImportListener(Boolean isUpdateSupport) {
-        this.toInfraredService = SpringUtils.getBean(IToInfraredService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(ToInfraredImportVo toInfraredVo, AnalysisContext context) {
-        try {
-
-            ToInfraredBo toInfraredBo = BeanUtil.toBean(toInfraredVo, ToInfraredBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            ToInfraredVo toInfraredVo1 = null;
-
-            //toInfraredVo1 = toInfraredService.selectBySomefield(toInfraredVo.getSomefield());
-            if (ObjectUtil.isNull(toInfraredVo1)) {
-                //不存在就新增
-                toInfraredBo.setVersion(0);
-                ValidatorUtils.validate(toInfraredBo);
-                boolean inserted = toInfraredService.insert(toInfraredBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、可见光转红外 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、可见光转红外 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                toInfraredBo.setId(toInfraredVo1.getId());//主键
-                toInfraredBo.setVersion(toInfraredVo1.getVersion());
-                boolean updated = toInfraredService.update(toInfraredBo);
-                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<ToInfraredImportVo> 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<ToInfraredImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.TrackSequenceBo;
-import com.taais.biz.domain.vo.TrackSequenceImportVo;
-import com.taais.biz.domain.vo.TrackSequenceVo;
-import com.taais.biz.service.ITrackSequenceService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 注视轨迹序列自定义导入
- *
- * @author wangkang
- */
-@Slf4j
-public class TrackSequenceImportListener extends AnalysisEventListener<TrackSequenceImportVo> implements ExcelListener<TrackSequenceImportVo> {
-    private final ITrackSequenceService trackSequenceService;
-
-    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 TrackSequenceImportListener(Boolean isUpdateSupport) {
-        this.trackSequenceService = SpringUtils.getBean(ITrackSequenceService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(TrackSequenceImportVo trackSequenceVo, AnalysisContext context) {
-        try {
-
-            TrackSequenceBo trackSequenceBo = BeanUtil.toBean(trackSequenceVo, TrackSequenceBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            TrackSequenceVo trackSequenceVo1 = null;
-
-            //trackSequenceVo1 = trackSequenceService.selectBySomefield(trackSequenceVo.getSomefield());
-            if (ObjectUtil.isNull(trackSequenceVo1)) {
-                //不存在就新增
-                trackSequenceBo.setVersion(0);
-                ValidatorUtils.validate(trackSequenceBo);
-                boolean inserted = trackSequenceService.insert(trackSequenceBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、注视轨迹序列 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、注视轨迹序列 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                trackSequenceBo.setId(trackSequenceVo1.getId());//主键
-                trackSequenceBo.setVersion(trackSequenceVo1.getVersion());
-                boolean updated = trackSequenceService.update(trackSequenceBo);
-                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<TrackSequenceImportVo> 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<TrackSequenceImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.biz.domain.bo.Video2imageBo;
-import com.taais.biz.domain.vo.Video2imageImportVo;
-import com.taais.biz.domain.vo.Video2imageVo;
-import com.taais.biz.service.IVideo2imageService;
-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 lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 视频转图片自定义导入
- *
- * @author km
- */
-@Slf4j
-public class Video2imageImportListener extends AnalysisEventListener<Video2imageImportVo> implements ExcelListener<Video2imageImportVo> {
-    private final IVideo2imageService video2imageService;
-
-    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 Video2imageImportListener(Boolean isUpdateSupport) {
-        this.video2imageService = SpringUtils.getBean(IVideo2imageService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(Video2imageImportVo video2imageVo, AnalysisContext context) {
-        try {
-
-            Video2imageBo video2imageBo = BeanUtil.toBean(video2imageVo, Video2imageBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            Video2imageVo video2imageVo1 = null;
-
-            //video2imageVo1 = video2imageService.selectBySomefield(video2imageVo.getSomefield());
-            if (ObjectUtil.isNull(video2imageVo1)) {
-                //不存在就新增
-                video2imageBo.setVersion(0);
-                ValidatorUtils.validate(video2imageBo);
-                boolean inserted = video2imageService.insert(video2imageBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、视频转图片 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、视频转图片 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                video2imageBo.setId(video2imageVo1.getId());//主键
-                video2imageBo.setVersion(video2imageVo1.getVersion());
-                boolean updated = video2imageService.update(video2imageBo);
-                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<Video2imageImportVo> 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<Video2imageImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}

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

@@ -1,119 +0,0 @@
-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.VideoStableBo;
-import com.taais.biz.domain.vo.VideoStableImportVo;
-import com.taais.biz.domain.vo.VideoStableVo;
-import com.taais.biz.service.IVideoStableService;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-/**
- * 视频去抖动自定义导入
- *
- * @author 0
- */
-@Slf4j
-public class VideoStableImportListener extends AnalysisEventListener<VideoStableImportVo> implements ExcelListener<VideoStableImportVo> {
-    private final IVideoStableService videoStableService;
-
-    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 VideoStableImportListener(Boolean isUpdateSupport) {
-        this.videoStableService = SpringUtils.getBean(IVideoStableService.class);
-        this.isUpdateSupport = isUpdateSupport;
-    }
-
-    @Override
-    public void invoke(VideoStableImportVo videoStableVo, AnalysisContext context) {
-        try {
-
-            VideoStableBo videoStableBo = BeanUtil.toBean(videoStableVo, VideoStableBo.class);
-
-            //TODO:根据某个字段，查询数据库表中是否存在记录，不存在就新增，存在就更新
-            VideoStableVo videoStableVo1 = null;
-
-            //videoStableVo1 = videoStableService.selectBySomefield(videoStableVo.getSomefield());
-            if (ObjectUtil.isNull(videoStableVo1)) {
-                //不存在就新增
-                videoStableBo.setVersion(0);
-                ValidatorUtils.validate(videoStableBo);
-                boolean inserted = videoStableService.insert(videoStableBo);
-
-                if (inserted) {
-                    successNum++;
-                    successMsg.append("<br/>").append(successNum).append("、视频去抖动 记录导入成功");
-                    return;
-                } else {
-                    failureNum++;
-                    failureMsg.append("<br/>").append(failureNum).append("、视频去抖动 记录导入失败");
-                    return;
-                }
-            } else if (isUpdateSupport) {
-                //存在就更新
-                videoStableBo.setId(videoStableVo1.getId());//主键
-                videoStableBo.setVersion(videoStableVo1.getVersion());
-                boolean updated = videoStableService.update(videoStableBo);
-                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<VideoStableImportVo> 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<VideoStableImportVo> getList() {
-                return null;
-            }
-
-            @Override
-            public List<String> getErrorList() {
-                return null;
-            }
-        };
-    }
-}