添加日志

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/IcNeighborHoodServiceImpl.java

@@ -22,6 +22,7 @@ import cn.afterturn.easypoi.excel.entity.ExportParams;
 import com.alibaba.excel.EasyExcel;
 import com.alibaba.excel.ExcelReader;
 import com.alibaba.excel.read.metadata.ReadSheet;
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -41,7 +42,6 @@ import com.epmet.commons.tools.redis.common.bean.GridInfoCache;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.constant.CustomerGridConstant;
-import com.epmet.constant.ImportErrorMsgConstants;
 import com.epmet.constants.ImportTaskConstants;
 import com.epmet.dao.CustomerGridDao;
 import com.epmet.dao.IcBuildingDao;
@@ -50,7 +50,6 @@ import com.epmet.dao.IcPropertyManagementDao;
 import com.epmet.dto.*;
 import com.epmet.dto.form.ImportInfoFormDTO;
 import com.epmet.dto.form.ImportTaskCommonFormDTO;
-import com.epmet.dto.result.ImportResultDTO;
 import com.epmet.dto.result.ImportTaskCommonResultDTO;
 import com.epmet.dto.result.InfoByNamesResultDTO;
 import com.epmet.dto.result.UploadImgResultDTO;
@@ -62,7 +61,6 @@ import com.epmet.model.ImportNeighborHoodInfoListener;
 import com.epmet.model.NeighborHoodInfoModel;
 import com.epmet.redis.IcHouseRedis;
 import com.epmet.service.*;
-import com.epmet.util.ExcelPoiUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.ListUtils;
@@ -73,8 +71,6 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.http.entity.ContentType;
 import org.apache.poi.ss.usermodel.Workbook;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Async;
-import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
@@ -85,6 +81,7 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.util.*;
+import java.util.concurrent.ExecutorService;
 import java.util.stream.Collectors;
 
 /**
@@ -117,6 +114,8 @@ public class IcNeighborHoodServiceImpl extends BaseServiceImpl<IcNeighborHoodDao
     private EpmetCommonServiceOpenFeignClient epmetCommonServiceOpenFeignClient;
     @Autowired
     private OssFeignClient ossFeignClient;
+    @Autowired
+    private ExecutorService executorService;
 
     @Override
     public PageData<IcNeighborHoodDTO> page(Map<String, Object> params) {
@@ -232,35 +231,42 @@ public class IcNeighborHoodServiceImpl extends BaseServiceImpl<IcNeighborHoodDao
      * @date 2022/2/12 11:11 上午
      */
     @Override
-    @Async
+    public Result neighborhoodImport(ImportInfoFormDTO formDTO, MultipartFile file,Result<ImportTaskCommonResultDTO> importTask) {
-    public Result neighborhoodImport(ImportInfoFormDTO formDTO, MultipartFile file,Result<ImportTaskCommonResultDTO> importTask) throws IOException {
+        log.info("neighborhoodImport start=====");
-//        importNeighbor(formDTO,file,importTask);
+        executorService.submit(() -> {
-        ExcelReader excelReader = null;
+            //        importNeighbor(formDTO,file,importTask);
-        try {
+            log.info("neighborhoodImport thread start=====");
-            InputStream inputStream = null;
+            ExcelReader excelReader = null;
             try {
-                inputStream = file.getInputStream();
+                InputStream inputStream = null;
-            } catch (IOException e) {
+                try {
-                return new Result<String>().error("读取文件失败");
+                    inputStream = file.getInputStream();
-            }
+                } catch (IOException e) {
+                    throw new EpmetException("读取文件失败");
+                }
 
-            excelReader = EasyExcel.read(inputStream).build();
+                excelReader = EasyExcel.read(inputStream).build();
-            // 这里为了简单 所以注册了 同样的head 和Listener 自己使用功能必须不同的Listener
+                // 这里为了简单 所以注册了 同样的head 和Listener 自己使用功能必须不同的Listener
-            ReadSheet readSheet = EasyExcel.readSheet(0).head(NeighborHoodInfoModel.class)
+                ReadSheet readSheet = EasyExcel.readSheet(0).head(NeighborHoodInfoModel.class)
-                    .registerReadListener(new ImportNeighborHoodInfoListener(formDTO,icHouseRedis,icBuildingDao,this,propertyManagementDao,epmetCommonServiceOpenFeignClient,importTask.getData().getTaskId()))
+                        .registerReadListener(new ImportNeighborHoodInfoListener(formDTO,icHouseRedis,icBuildingDao,this,propertyManagementDao,epmetCommonServiceOpenFeignClient,importTask.getData().getTaskId()))
-                    .build();
+                        .build();
-            excelReader.read(readSheet);
+                log.info("neighborhoodImport build readSheet num:{}",readSheet.getSheetNo());
-        } catch (Exception e){
+                excelReader.read(readSheet);
-            ImportTaskCommonFormDTO input = new ImportTaskCommonFormDTO();
+            } catch (Exception e){
-            input.setOperatorId(formDTO.getUserId());
+                log.error("neighborhoodImport import exception", e);
-            input.setTaskId(importTask.getData().getTaskId());
+                ImportTaskCommonFormDTO input = new ImportTaskCommonFormDTO();
-            input.setProcessStatus(ImportTaskConstants.PROCESS_STATUS_FINISHED_FAIL);
+                input.setOperatorId(formDTO.getUserId());
-            epmetCommonServiceOpenFeignClient.finishImportTask(input);
+                input.setTaskId(importTask.getData().getTaskId());
-        } finally {
+                input.setProcessStatus(ImportTaskConstants.PROCESS_STATUS_FINISHED_FAIL);
-            if (excelReader != null) {
+                Result result = epmetCommonServiceOpenFeignClient.finishImportTask(input);
-                excelReader.finish();
+                log.info("neighborhoodImport finishImportTask result:{}", JSON.toJSONString(result));
+            } finally {
+                if (excelReader != null) {
+                    excelReader.finish();
+                }
             }
-        }
+            log.info("neighborhoodImport thread end=====");
+        });
 
         return new Result<>();
     }