fix: 数据导入

als-modules/agile-assurance/src/main/java/org/eco/als/controller/DataImportController.java

@@ -0,0 +1,100 @@
+package org.eco.als.controller;
+
+import cn.dev33.satoken.annotation.SaCheckPermission;
+import jakarta.annotation.Resource;
+import lombok.RequiredArgsConstructor;
+import org.eco.als.domain.bo.DataImportBo;
+import org.eco.als.domain.vo.DataImportVo;
+import org.eco.als.service.IDataImportService;
+import org.eco.common.core.core.domain.CommonResult;
+import org.eco.common.core.core.page.PageResult;
+import org.eco.common.log.annotation.Log;
+import org.eco.common.log.enums.BusinessType;
+import org.eco.common.web.annotation.RepeatSubmit;
+import org.eco.common.web.core.BaseController;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 数据导入信息Controller
+ *
+ * @author wgk
+ * @date 2024-07-22
+ */
+@Validated
+@RequiredArgsConstructor
+@RestController
+@RequestMapping("/als/dataImport")
+public class DataImportController extends BaseController {
+    @Resource
+    private IDataImportService dataImportService;
+
+    /**
+     * 查询数据导入信息列表
+     */
+    @SaCheckPermission("als:dataImport:list")
+    @GetMapping("/list")
+    public CommonResult<PageResult<DataImportVo>> list(DataImportBo dataImportBo) {
+        return CommonResult.success(dataImportService.selectPage(dataImportBo));
+    }
+
+    /**
+     * 获取数据导入信息详细信息
+     */
+    @SaCheckPermission("als:dataImport:query")
+    @GetMapping(value = "/{id}")
+    public CommonResult<DataImportVo> getInfo(@PathVariable Long id) {
+        return CommonResult.success(dataImportService.selectById(id));
+    }
+
+    /**
+     * 新增数据导入信息
+     */
+    @SaCheckPermission("als:dataImport:add")
+    @Log(title = "数据导入信息", businessType = BusinessType.INSERT)
+    @RepeatSubmit()
+    @PostMapping
+    public CommonResult<Void> add(@Validated @RequestBody DataImportBo dataImportBo) {
+        boolean inserted = dataImportService.insert(dataImportBo);
+        if (!inserted) {
+            return CommonResult.fail("新增数据导入信息记录失败！");
+        }
+        return CommonResult.success();
+    }
+
+    /**
+     * 修改数据导入信息
+     */
+    @SaCheckPermission("als:dataImport:edit")
+    @Log(title = "数据导入信息", businessType = BusinessType.UPDATE)
+    @RepeatSubmit()
+    @PutMapping
+    public CommonResult<Void> edit(@Validated @RequestBody DataImportBo dataImportBo) {
+        boolean updated = dataImportService.update(dataImportBo);
+        if (!updated) {
+            return CommonResult.fail("修改数据导入信息记录失败!");
+        }
+        return CommonResult.success();
+    }
+
+    /**
+     * 删除数据导入信息
+     */
+    @SaCheckPermission("als:dataImport:remove")
+    @Log(title = "数据导入信息", businessType = BusinessType.DELETE)
+    @DeleteMapping("/{ids}")
+    public CommonResult<Void> remove(@PathVariable Long[] ids) {
+        boolean deleted = dataImportService.deleteByIds(ids);
+        if (!deleted) {
+            return CommonResult.fail("删除数据导入信息记录失败!");
+        }
+        return CommonResult.success();
+    }
+}

als-modules/agile-assurance/src/main/java/org/eco/als/domain/DataImport.java

@@ -0,0 +1,69 @@
+package org.eco.als.domain;
+
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.eco.common.orm.core.domain.BaseEntity;
+
+import java.io.Serial;
+import java.util.Date;
+
+/**
+ * 数据导入信息对象 als_data_import_t
+ *
+ * @author wgk
+ * @date 2024-07-22
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(value = "als_data_import_t")
+public class DataImport extends BaseEntity {
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 唯一编号
+     */
+    @Id
+    private Long id;
+
+    /**
+     * 文件编号
+     */
+    private Long ossId;
+
+    /**
+     * 数据源
+     */
+    private String source;
+
+    /**
+     * 架次号
+     */
+    private String sortieNo;
+
+    /**
+     * 机号
+     */
+    private String aircraftNo;
+
+    /**
+     * 飞行日期
+     */
+    private Date flightDate;
+
+    /**
+     * 状态（1正常）
+     */
+    private String status;
+
+    /**
+     * 删除标识（1删除 0未删除）
+     */
+    @Column(isLogicDelete = true)
+    private Integer delFlag;
+
+
+}

als-modules/agile-assurance/src/main/java/org/eco/als/domain/bo/DataImportBo.java

@@ -0,0 +1,63 @@
+package org.eco.als.domain.bo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.github.linpeilie.annotations.AutoMapper;
+import jakarta.validation.constraints.NotBlank;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.eco.als.domain.DataImport;
+import org.eco.common.orm.core.domain.BaseEntity;
+
+import java.util.Date;
+
+/**
+ * 数据导入信息业务对象 als_data_import_t
+ *
+ * @author wgk
+ * @date 2024-07-22
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = DataImport.class, reverseConvertGenerate = false)
+public class DataImportBo extends BaseEntity {
+    /**
+     * 唯一编号
+     */
+    private Long id;
+
+    /**
+     * 文件编号
+     */
+    private Long ossId;
+
+    /**
+     * 数据源
+     */
+    @NotBlank(message = "数据源不能为空")
+    private String source;
+
+    /**
+     * 架次号
+     */
+    @NotBlank(message = "架次号不能为空")
+    private String sortieNo;
+
+    /**
+     * 机号
+     */
+    @NotBlank(message = "机号不能为空")
+    private String aircraftNo;
+
+    /**
+     * 飞行日期
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date flightDate;
+
+    /**
+     * 状态（1正常）
+     */
+    private String status;
+
+
+}

als-modules/agile-assurance/src/main/java/org/eco/als/domain/vo/DataImportImportVo.java

@@ -0,0 +1,74 @@
+package org.eco.als.domain.vo;
+
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.eco.common.excel.annotation.ExcelDictFormat;
+import org.eco.common.excel.convert.ExcelDictConvert;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 数据导入信息导入视图对象 als_data_import_t
+ *
+ * @author wgk
+ * @date 2024-07-22
+ */
+
+@Data
+@NoArgsConstructor
+@ExcelIgnoreUnannotated
+public class DataImportImportVo implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+
+    /**
+     * 文件编号
+     */
+    @ExcelProperty(value = "文件编号")
+    private Long ossId;
+
+    /**
+     * 数据源
+     */
+    @ExcelProperty(value = "数据源", converter = ExcelDictConvert.class)
+    @ExcelDictFormat(dictType = "common_type")
+    private String source;
+
+    /**
+     * 架次号
+     */
+    @ExcelProperty(value = "架次号")
+    private String sortieNo;
+
+    /**
+     * 机号
+     */
+    @ExcelProperty(value = "机号")
+    private String aircraftNo;
+
+    /**
+     * 飞行日期
+     */
+    @ExcelProperty(value = "飞行日期")
+    private Date flightDate;
+
+    /**
+     * 状态（1正常）
+     */
+    @ExcelProperty(value = "状态", converter = ExcelDictConvert.class)
+    @ExcelDictFormat(dictType = "common_type")
+    private String status;
+
+    /**
+     * 删除标识（1删除 0未删除）
+     */
+    private Integer delFlag;
+
+
+}

als-modules/agile-assurance/src/main/java/org/eco/als/domain/vo/DataImportVo.java

@@ -0,0 +1,97 @@
+package org.eco.als.domain.vo;
+
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.eco.common.mapper.annotation.FieldMapper;
+import com.eco.common.mapper.constant.MapperConstant;
+import com.mybatisflex.annotation.Id;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.eco.als.domain.DataImport;
+import org.eco.common.excel.annotation.ExcelDictFormat;
+import org.eco.common.excel.convert.ExcelDictConvert;
+import org.eco.common.orm.core.domain.BaseEntity;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 数据导入信息视图对象 als_data_import_t
+ *
+ * @author wgk
+ * @date 2024-07-22
+ */
+@Data
+@ExcelIgnoreUnannotated
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = DataImport.class)
+public class DataImportVo extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 唯一编号
+     */
+    @Id
+    private Long id;
+
+    /**
+     * 文件编号
+     */
+    @ExcelProperty(value = "文件编号")
+    private Long ossId;
+
+    /**
+     * 数据源
+     */
+    @ExcelProperty(value = "数据源", converter = ExcelDictConvert.class)
+    @ExcelDictFormat(dictType = "common_type")
+    private String source;
+
+    /**
+     * 架次号
+     */
+    @ExcelProperty(value = "架次号")
+    private String sortieNo;
+
+    /**
+     * 机号
+     */
+    @ExcelProperty(value = "机号")
+    private String aircraftNo;
+
+    /**
+     * 飞行日期
+     */
+    @ExcelProperty(value = "飞行日期")
+    private Date flightDate;
+
+    /**
+     * 状态（1正常）
+     */
+    @ExcelProperty(value = "状态", converter = ExcelDictConvert.class)
+    @ExcelDictFormat(dictType = "common_type")
+    private String status;
+
+    /**
+     * 删除标识（1删除 0未删除）
+     */
+    private Integer delFlag;
+
+
+    /**
+     * 创建人名称
+     */
+    @FieldMapper(type = MapperConstant.USER_ID_TO_NAME, mapper = "createBy")
+    private String createByName;
+
+    /**
+     * 创建人名称
+     */
+    @FieldMapper(type = MapperConstant.USER_ID_TO_NAME, mapper = "updateBy")
+    private String updateByName;
+
+}

als-modules/agile-assurance/src/main/java/org/eco/als/listener/DataImportImportListener.java

@@ -0,0 +1,126 @@
+package org.eco.als.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 lombok.extern.slf4j.Slf4j;
+import org.eco.als.domain.bo.DataImportBo;
+import org.eco.als.domain.vo.DataImportImportVo;
+import org.eco.als.domain.vo.DataImportVo;
+import org.eco.als.service.IDataImportService;
+import org.eco.common.core.core.domain.model.LoginUser;
+import org.eco.common.core.utils.SpringUtils;
+import org.eco.common.core.utils.ValidatorUtils;
+import org.eco.common.excel.core.ExcelListener;
+import org.eco.common.excel.core.ExcelResult;
+import org.eco.common.excel.entity.ExcelResultRes;
+
+import java.util.List;
+
+/**
+ * 数据导入信息自定义导入
+ *
+ * @author wgk
+ */
+@Slf4j
+public class DataImportImportListener extends AnalysisEventListener<DataImportImportVo> implements ExcelListener<DataImportImportVo> {
+    private final IDataImportService dataImportService;
+
+    private final Boolean isUpdateSupport;
+    private final LoginUser loginUser;
+    private int successNum = 0;
+    private int failureNum = 0;
+    private final StringBuilder successMsg = new StringBuilder();
+    private final StringBuilder failureMsg = new StringBuilder();
+
+    public DataImportImportListener(Boolean isUpdateSupport, LoginUser loginUser) {
+        this.dataImportService = SpringUtils.getBean(IDataImportService.class);
+        this.isUpdateSupport = isUpdateSupport;
+        this.loginUser = loginUser;
+    }
+
+    @Override
+    public void invoke(DataImportImportVo dataImportVo, AnalysisContext context) {
+        try {
+
+            DataImportBo dataImportBo = BeanUtil.toBean(dataImportVo, DataImportBo.class);
+            DataImportVo dataImportVo1 = null;
+
+            //dataImportVo1 = dataImportService.selectBySomefield(dataImportVo.getSomefield());
+            if (ObjectUtil.isNull(dataImportVo1)) {
+                //不存在就新增
+                setBo(dataImportBo);
+                ValidatorUtils.validate(dataImportBo);
+                boolean inserted = dataImportService.insert(dataImportBo);
+
+                if (inserted) {
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、数据导入信息 记录导入成功");
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>").append(failureNum).append("、数据导入信息 记录导入失败");
+                }
+            } else if (isUpdateSupport) {
+                //存在就更新
+                dataImportBo.setId(dataImportVo1.getId());//主键
+                dataImportBo.setVersion(dataImportVo1.getVersion());
+                boolean updated = dataImportService.update(dataImportBo);
+                if (updated) {
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、数据导入信息 记录更新成功");
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>").append(failureNum).append("、数据导入信息 记录更新失败");
+                }
+            }
+        } catch (Exception e) {
+            failureNum++;
+            String msg = "<br/>" + failureNum + "、数据导入信息 记录导入失败：" ;
+            failureMsg.append(msg).append(e.getMessage());
+            log.error(msg, e);
+        }
+    }
+
+    private void setBo(DataImportBo dataImportBo) {
+        dataImportBo.setVersion(0);
+        dataImportBo.setCreateBy(loginUser.getUserId());
+        dataImportBo.setUpdateBy(loginUser.getUserId());
+        dataImportBo.setTenantId(loginUser.getTenantId());
+    }
+
+    @Override
+    public void doAfterAllAnalysed(AnalysisContext context) {
+        log.info("解析完成");
+    }
+
+    @Override
+    public ExcelResult<DataImportImportVo> getExcelResult() {
+        return new ExcelResult<>() {
+
+            @Override
+            public ExcelResultRes getAnalysis() {
+                if (failureNum > 0 && successNum == 0) {
+                    failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据没有成功导入，错误如下：");
+                    return ExcelResultRes.builder().logInfo(failureMsg.toString()).status("0").build();
+                } else if (failureNum > 0 && successNum > 0) {
+                    failureMsg.insert(0, "很抱歉，部分导入失败！共 " + failureNum + " 条数据没有成功导入，错误如下：");
+                    return ExcelResultRes.builder().logInfo(failureMsg.toString()).status("2").build();
+                } else {
+                    successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
+                    return ExcelResultRes.builder().logInfo(successMsg.toString()).status("1").build();
+                }
+            }
+
+            @Override
+            public List<DataImportImportVo> getList() {
+                return null;
+            }
+
+            @Override
+            public List<String> getErrorList() {
+                return null;
+            }
+        };
+    }
+}

als-modules/agile-assurance/src/main/java/org/eco/als/mapper/DataImportMapper.java

@@ -0,0 +1,16 @@
+package org.eco.als.mapper;
+
+import com.mybatisflex.core.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.eco.als.domain.DataImport;
+
+/**
+ * 数据导入信息Mapper接口
+ *
+ * @author wgk
+ * @date 2024-07-22
+ */
+@Mapper
+public interface DataImportMapper extends BaseMapper<DataImport> {
+
+}

als-modules/agile-assurance/src/main/java/org/eco/als/service/IDataImportService.java

@@ -0,0 +1,97 @@
+package org.eco.als.service;
+
+import org.eco.als.domain.DataImport;
+import org.eco.als.domain.bo.DataImportBo;
+import org.eco.als.domain.vo.DataImportVo;
+import org.eco.common.core.core.domain.model.LoginUser;
+import org.eco.common.core.core.page.PageResult;
+import org.eco.common.orm.core.service.IBaseService;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+
+/**
+ * 数据导入信息Service接口
+ *
+ * @author wgk
+ * @date 2024-07-22
+ */
+public interface IDataImportService extends IBaseService<DataImport> {
+    /**
+     * 查询数据导入信息
+     *
+     * @param id 数据导入信息主键
+     * @return 数据导入信息
+     */
+    DataImportVo selectById(Long id);
+
+    /**
+     * 查询数据导入信息列表
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 数据导入信息集合
+     */
+    List<DataImportVo> selectList(DataImportBo dataImportBo);
+
+    /**
+     * 分页查询数据导入信息列表
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 分页数据导入信息集合
+     */
+    PageResult<DataImportVo> selectPage(DataImportBo dataImportBo);
+
+    /**
+     * 新增数据导入信息
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    boolean insert(DataImportBo dataImportBo);
+
+    /**
+     * 新增数据导入信息，前台提供主键值，一般用于导入的场合
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    boolean insertWithPk(DataImportBo dataImportBo);
+
+    /**
+     * 修改数据导入信息
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 结果:true 更新成功，false 更新失败
+     */
+    boolean update(DataImportBo dataImportBo);
+
+    /**
+     * 批量删除数据导入信息
+     *
+     * @param ids 需要删除的数据导入信息主键集合
+     * @return 结果:true 删除成功，false 删除失败
+     */
+    boolean deleteByIds(Long[] ids);
+
+    /**
+     * 异步导入
+     *
+     * @param file          导入的文件
+     * @param updateSupport 是否覆盖
+     * @param user          用户上下文信息
+     */
+    @Async
+    void asyncImportData(MultipartFile file, boolean updateSupport, LoginUser user);
+
+    /**
+     * asyncExport 异步导出
+     *
+     * @param listVo    数据列表
+     * @param sheetName 文件名称
+     * @param user      上下文
+     */
+    @Async
+    void asyncExport(List<DataImportVo> listVo, String sheetName, LoginUser user);
+
+}

als-modules/agile-assurance/src/main/java/org/eco/als/service/impl/DataImportServiceImpl.java

@@ -0,0 +1,203 @@
+package org.eco.als.service.impl;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.mybatisflex.core.paginate.Page;
+import com.mybatisflex.core.query.QueryWrapper;
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.eco.als.domain.DataImport;
+import org.eco.als.domain.bo.DataImportBo;
+import org.eco.als.domain.vo.DataImportImportVo;
+import org.eco.als.domain.vo.DataImportVo;
+import org.eco.als.listener.DataImportImportListener;
+import org.eco.als.mapper.DataImportMapper;
+import org.eco.als.service.IDataImportService;
+import org.eco.common.core.core.domain.model.LoginUser;
+import org.eco.common.core.core.page.PageResult;
+import org.eco.common.core.utils.MapstructUtils;
+import org.eco.common.core.utils.bean.BeanUtils;
+import org.eco.common.excel.entity.ExcelResultRes;
+import org.eco.common.excel.service.IExcelService;
+import org.eco.common.orm.core.page.PageQuery;
+import org.eco.common.orm.core.service.impl.BaseServiceImpl;
+import org.eco.system.domain.bo.ImportExportBo;
+import org.eco.system.service.IImportExportService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.List;
+
+import static org.eco.als.domain.table.DataImportTableDef.DATA_IMPORT;
+
+/**
+ * 数据导入信息Service业务层处理
+ *
+ * @author wgk
+ * @date 2024-07-22
+ */
+@Service
+@Slf4j
+public class DataImportServiceImpl extends BaseServiceImpl<DataImportMapper, DataImport> implements IDataImportService {
+    @Resource
+    private DataImportMapper dataImportMapper;
+
+    @Resource
+    private IExcelService excelService;
+
+    @Resource
+    private IImportExportService importExportService;
+
+    @Override
+    public QueryWrapper query() {
+        return super.query().from(DATA_IMPORT);
+    }
+
+    private QueryWrapper buildQueryWrapper(DataImportBo dataImportBo) {
+        QueryWrapper queryWrapper = super.buildBaseQueryWrapper();
+        queryWrapper.and(DATA_IMPORT.OSS_ID.eq
+            (dataImportBo.getOssId()));
+        queryWrapper.and(DATA_IMPORT.SOURCE.eq
+            (dataImportBo.getSource()));
+        queryWrapper.and(DATA_IMPORT.SORTIE_NO.eq
+            (dataImportBo.getSortieNo()));
+        queryWrapper.and(DATA_IMPORT.AIRCRAFT_NO.eq
+            (dataImportBo.getAircraftNo()));
+        queryWrapper.and(DATA_IMPORT.FLIGHT_DATE.eq
+            (dataImportBo.getFlightDate()));
+        queryWrapper.and(DATA_IMPORT.STATUS.eq
+            (dataImportBo.getStatus()));
+
+        return queryWrapper;
+    }
+
+    /**
+     * 查询数据导入信息
+     *
+     * @param id 数据导入信息主键
+     * @return 数据导入信息
+     */
+    @Override
+    public DataImportVo selectById(Long id) {
+        return this.getOneAs(query().where(DATA_IMPORT.ID.eq(id)), DataImportVo.class);
+
+    }
+
+
+    /**
+     * 查询数据导入信息列表
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 数据导入信息集合
+     */
+    @Override
+    public List<DataImportVo> selectList(DataImportBo dataImportBo) {
+        QueryWrapper queryWrapper = buildQueryWrapper(dataImportBo);
+        return this.listAs(queryWrapper, DataImportVo.class);
+    }
+
+    /**
+     * 分页查询数据导入信息列表
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 分页数据导入信息集合
+     */
+    @Override
+    public PageResult<DataImportVo> selectPage(DataImportBo dataImportBo) {
+        QueryWrapper queryWrapper = buildQueryWrapper(dataImportBo);
+        Page<DataImportVo> page = this.pageAs(PageQuery.build(), queryWrapper, DataImportVo.class);
+        return PageResult.build(page);
+    }
+
+    /**
+     * 新增数据导入信息
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    @Override
+    public boolean insert(DataImportBo dataImportBo) {
+        DataImport dataImport = MapstructUtils.convert(dataImportBo, DataImport.class);
+
+        return this.save(dataImport);//使用全局配置的雪花算法主键生成器生成ID值
+    }
+
+    /**
+     * 新增数据导入信息，前台提供主键值，一般用于导入的场合
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 结果:true 操作成功，false 操作失败
+     */
+    @Override
+    public boolean insertWithPk(DataImportBo dataImportBo) {
+        DataImport dataImport = MapstructUtils.convert(dataImportBo, DataImport.class);
+
+
+        return dataImportMapper.insertWithPk(dataImport) > 0;//前台传来主键值
+    }
+
+    /**
+     * 修改数据导入信息
+     *
+     * @param dataImportBo 数据导入信息Bo
+     * @return 结果:true 更新成功，false 更新失败
+     */
+    @Override
+    public boolean update(DataImportBo dataImportBo) {
+        DataImport dataImport = MapstructUtils.convert(dataImportBo, DataImport.class);
+        if (ObjectUtil.isNotNull(dataImport) && ObjectUtil.isNotNull(dataImport.getId())) {
+            return this.updateById(dataImport);
+        }
+        return false;
+    }
+
+    @Override
+    public void asyncImportData(MultipartFile file, boolean updateSupport, LoginUser loginUser) {
+        ExcelResultRes result;
+        try {
+            String name = file.getOriginalFilename();
+            result = excelService.importExcel(file.getInputStream(), name, DataImportImportVo.class, new DataImportImportListener(updateSupport, loginUser));
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+        ImportExportBo bo = getImportExportBo(result, loginUser, "0");
+        boolean flag = importExportService.insert(bo);
+        if (flag) {
+            log.info("异步导入日志写入成功");
+        }
+    }
+
+    @Override
+    public void asyncExport(List<DataImportVo> listVo, String sheetName, LoginUser loginUser) {
+        ExcelResultRes result = excelService.exportExcel(listVo, sheetName, DataImportVo.class);
+        ImportExportBo bo = getImportExportBo(result, loginUser, "1");
+        boolean flag = importExportService.insert(bo);
+        if (flag) {
+            log.info("异步导出日志写入成功");
+        }
+    }
+
+    private static ImportExportBo getImportExportBo(ExcelResultRes result, LoginUser loginUser, String type) {
+        ImportExportBo bo = new ImportExportBo();
+        BeanUtils.copyProperties(result, bo);
+        bo.setUpdateBy(loginUser.getUserId());
+        bo.setCreateBy(loginUser.getUserId());
+        bo.setType(type);
+        return bo;
+    }
+
+    /**
+     * 批量删除数据导入信息
+     *
+     * @param ids 需要删除的数据导入信息主键集合
+     * @return 结果:true 删除成功，false 删除失败
+     */
+    @Transactional
+    @Override
+    public boolean deleteByIds(Long[] ids) {
+        return this.removeByIds(Arrays.asList(ids));
+    }
+
+}

als-modules/agile-assurance/src/main/resources/mapper/als/DataImportMapper.xml

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