From 1ac555ce49a45e2c7fc015dbb16b104840788c21 Mon Sep 17 00:00:00 2001
From: chengf <2156125618@qq.com>
Date: 星期一, 18 八月 2025 11:51:42 +0800
Subject: [PATCH] 费用导入修复2025/08/15
---
service-job/src/main/java/com/java110/job/importData/ImportDataExecutor.java | 16 +++++++++++++++-
1 files changed, 15 insertions(+), 1 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/importData/ImportDataExecutor.java b/service-job/src/main/java/com/java110/job/importData/ImportDataExecutor.java
index 9bd43a2..c02451e 100644
--- a/service-job/src/main/java/com/java110/job/importData/ImportDataExecutor.java
+++ b/service-job/src/main/java/com/java110/job/importData/ImportDataExecutor.java
@@ -6,9 +6,11 @@
import com.java110.dto.log.AssetImportLogDto;
import com.java110.intf.common.IAssetImportLogDetailInnerServiceSMO;
import com.java110.intf.common.IAssetImportLogInnerServiceSMO;
+import com.java110.po.log.AssetImportLogDetailPo;
import com.java110.po.log.AssetImportLogPo;
import com.java110.utils.factory.ApplicationContextFactory;
import com.java110.utils.util.Assert;
+import com.java110.utils.util.ExceptionUtil;
import org.slf4j.Logger;
import java.util.List;
@@ -135,8 +137,10 @@
try {
importDataAdaptImpl.importData(assetImportLogDetailDtos);
- } catch (Throwable e) {
+ } catch (Exception e) {
e.printStackTrace();
+ updateImportLogDetailState(assetImportLogDetailDto.getDetailId(), e);
+// throw new IllegalArgumentException(e);
}
}
@@ -157,4 +161,14 @@
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);
+ }
}
--
Gitblit v1.8.0