From 7e654f0bdb591ef8e7a67a4e9fc20f65fa6dd571 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期三, 17 四月 2024 20:43:02 +0800
Subject: [PATCH] 优化代码

---
 service-job/src/main/java/com/java110/job/databus/DatabusDataExecutor.java |   11 ++++++++++-
 1 files changed, 10 insertions(+), 1 deletions(-)

diff --git a/service-job/src/main/java/com/java110/job/databus/DatabusDataExecutor.java b/service-job/src/main/java/com/java110/job/databus/DatabusDataExecutor.java
index 4e4226e..5239a3e 100644
--- a/service-job/src/main/java/com/java110/job/databus/DatabusDataExecutor.java
+++ b/service-job/src/main/java/com/java110/job/databus/DatabusDataExecutor.java
@@ -1,11 +1,15 @@
 package com.java110.job.databus;
 
+import com.java110.core.factory.GenerateCodeFactory;
 import com.java110.core.log.LoggerFactory;
 import com.java110.dto.data.DatabusQueueDataDto;
+import com.java110.dto.log.LogSystemErrorDto;
 import com.java110.job.adapt.IDatabusAdapt;
 import com.java110.job.importData.ImportDataQueue;
+import com.java110.po.log.LogSystemErrorPo;
 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.concurrent.*;
@@ -70,7 +74,12 @@
         FutureTask<String> futureTask = new FutureTask<>(new Callable<String>() {
             @Override
             public String call() throws Exception {
-                databusAdaptImpl.execute(databusQueueDataDto.getBusiness(), databusQueueDataDto.getBusinesses());
+                try {
+                    databusAdaptImpl.execute(databusQueueDataDto.getBusiness(), databusQueueDataDto.getBusinesses());
+                }catch (Exception e){
+                    e.printStackTrace();
+                    log.error("鎵цdatabus澶辫触", e);
+                }
                 return "";
             }
         });

--
Gitblit v1.8.0