导入测试

chengf

2026-03-18 56931dc90c4e070d279a0cbf5822af010c481812

 service-job/src/main/java/com/java110/job/importData/ImportDataExecutor.java

@@ -141,10 +141,8 @@

            try {
                importDataAdaptImpl.importData(assetImportLogDetailDtos);
            } catch (Exception e) {
            } catch (Throwable e) {
                e.printStackTrace();
                updateImportLogDetailState(assetImportLogDetailDto.getDetailId(), e);
                throw new IllegalArgumentException(e);
            }
        }

@@ -165,15 +163,5 @@
        executorService.execute(new ImportDataExecutor(true));
        log.debug("初始化导入队列完成");

    }

    protected void updateImportLogDetailState(String detailId, Exception e) {
        String state = AssetImportLogDetailDto.STATE_FAIL_IMPORT;
        String message = ExceptionUtil.getStackTrace(e);
        AssetImportLogDetailPo tmpAssetImportOwnerRoomPo = new AssetImportLogDetailPo();
        tmpAssetImportOwnerRoomPo.setDetailId(detailId);
        tmpAssetImportOwnerRoomPo.setState(state);
        tmpAssetImportOwnerRoomPo.setMessage(message);
        assetImportLogDetailInnerServiceSMOImpl.updateAssetImportLogDetail(tmpAssetImportOwnerRoomPo);
    }
}