修改：

1.导入任务记录-创建接口-新增originFileName 原始文件名参数

epmet-module/epmet-common-service/common-service-client/src/main/java/com/epmet/dto/form/ImportTaskCommonFormDTO.java

@@ -10,6 +10,12 @@ public class ImportTaskCommonFormDTO {
     public interface Create {}
     public interface Finish {}
 
+    /**
+     * 原始文件名
+     */
+    @NotBlank(message = "原始文件名必填", groups = { Create.class })
+    private String originFileName;
+
     /**
      * 操作者ID
      */

epmet-module/epmet-common-service/common-service-server/src/main/java/com/epmet/controller/ImportTaskController.java

@@ -31,8 +31,9 @@ public class ImportTaskController {
         ValidatorUtils.validateEntity(input, ImportTaskCommonFormDTO.Create.class);
         String operatorId = input.getOperatorId();
         String bizType = input.getBizType();
+        String originFileName = input.getOriginFileName();
 
-        String taskId = importTaskService.createProcessTask(operatorId, bizType);
+        String taskId = importTaskService.createProcessTask(operatorId, bizType, originFileName);
         ImportTaskCommonResultDTO ro = new ImportTaskCommonResultDTO(taskId);
         return new Result().ok(ro);
     }

epmet-module/epmet-common-service/common-service-server/src/main/java/com/epmet/entity/ImportTaskEntity.java

@@ -20,6 +20,16 @@ public class ImportTaskEntity extends BaseEpmetEntity {
 
 	private static final long serialVersionUID = 1L;
 
+	/**
+	 * 客户ID
+	 */
+	private String customerId;
+
+	/**
+	 * 原始文件名
+	 */
+	private String originFileName;
+
     /**
      * 业务类型。resi:居民；楼栋:building；房屋:house。依次补充
      */

epmet-module/epmet-common-service/common-service-server/src/main/java/com/epmet/service/ImportTaskService.java

@@ -21,8 +21,9 @@ public interface ImportTaskService {
      * 创建处理任务
      * @param operatorId
      * @param bizType
+     * @param originFileName 原始文件名
      */
-    String createProcessTask(String operatorId, String bizType);
+    String createProcessTask(String operatorId, String bizType, String originFileName);
 
     /**
      * 结束导入

epmet-module/epmet-common-service/common-service-server/src/main/java/com/epmet/service/impl/ImportTaskServiceImpl.java

@@ -3,6 +3,7 @@ package com.epmet.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.epmet.commons.tools.exception.EpmetErrorCode;
 import com.epmet.commons.tools.exception.EpmetException;
+import com.epmet.commons.tools.security.user.LoginUserUtil;
 import com.epmet.constants.ImportTaskConstants;
 import com.epmet.dao.ImportTaskDao;
 import com.epmet.entity.ImportTaskEntity;
@@ -24,6 +25,9 @@ public class ImportTaskServiceImpl implements ImportTaskService {
     @Autowired
     private ImportTaskDao importRecordDao;
 
+    @Autowired
+    private LoginUserUtil loginUserUtil;
+
 //    /**
 //     * 该用户，该业务类型，是否有正在处理的导入任务
 //     * @param operatorId 操作者ID
@@ -56,7 +60,7 @@ public class ImportTaskServiceImpl implements ImportTaskService {
     }
 
     @Override
-    public String createProcessTask(String operatorId, String bizType) {
+    public String createProcessTask(String operatorId, String bizType, String originFileName) {
         if (existsProcessingTask(operatorId, bizType)) {
             throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),
                     "已存在执行中的导入任务，请等待执行完成。",
@@ -67,7 +71,9 @@ public class ImportTaskServiceImpl implements ImportTaskService {
         importRecord.setProcessStatus(ImportTaskConstants.PROCESS_STATUS_PROCESSING);
         importRecord.setOperatorId(operatorId);
         importRecord.setBizType(bizType);
+        importRecord.setCustomerId(loginUserUtil.getLoginUserCustomerId());
         importRecord.setStartTime(new Date());
+        importRecord.setOriginFileName(originFileName);
 
         importRecordDao.insert(importRecord);
         return importRecord.getId();

epmet-module/epmet-common-service/common-service-server/src/main/resources/mapper/ImportTaskDao.xml

@@ -5,6 +5,7 @@
 
     <resultMap type="com.epmet.entity.ImportTaskEntity" id="importRecordMap">
         <result property="id" column="ID"/>
+        <result property="originFileName" column="ORIGIN_FILE_NAME"/>
         <result property="bizType" column="BIZ_TYPE"/>
         <result property="processStatus" column="PROCESS_STATUS"/>
         <result property="operatorId" column="OPERATOR_ID"/>