新增：

1.是否有正在执行的导入任务

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

@@ -12,9 +12,7 @@ import com.epmet.dto.form.ImportTaskCommonFormDTO;
 import com.epmet.dto.result.ImportTaskCommonResultDTO;
 import com.epmet.service.ImportTaskService;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 @RequestMapping("import-task")
@@ -70,4 +68,15 @@ public class ImportTaskController {
         return new Result();
     }
 
+    /**
+     * 检查是否有正在执行的任务
+     * @param bizType 业务类型
+     * @return
+     */
+    @GetMapping("processing-check")
+    public Result processingTaskCheck(@RequestParam("biz_type") String bizType) {
+        Boolean r = importTaskService.processingTaskCheck(bizType);
+        return new Result().ok(r);
+    }
+
 }

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

@@ -44,4 +44,11 @@ public interface ImportTaskService {
      * @return
      */
     PageData<ImportTaskCommonResultDTO> page(ImportTaskCommonFormDTO param);
+
+    /**
+     * 检查是否有正在执行的任务
+     * @param bizType
+     * @return
+     */
+    Boolean processingTaskCheck(String bizType);
 }

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

@@ -108,4 +108,13 @@ public class ImportTaskServiceImpl implements ImportTaskService {
         });
         return new PageData<>(list,page.getTotal());
     }
+
+    @Override
+    public Boolean processingTaskCheck(String bizType) {
+        LambdaQueryWrapper<ImportTaskEntity> query = new LambdaQueryWrapper<>();
+        query.eq(ImportTaskEntity::getBizType, bizType);
+        query.eq(ImportTaskEntity::getProcessStatus, ImportTaskConstants.PROCESS_STATUS_PROCESSING);
+
+        return importRecordDao.selectCount(query) > 0;
+    }
 }