From a3f45b92f2e226028cf5c964b24160a3d71e476c Mon Sep 17 00:00:00 2001
From: Kris <2893855659@qq.com>
Date: Mon, 27 Oct 2025 10:31:37 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90feat=E3=80=91=20=E8=B0=83=E6=95=B4bigo?=
 =?UTF-8?q?bject=E4=B8=8B=E8=BD=BD=E6=96=87=E4=BB=B6=E5=A4=A7=E5=B0=8F?=
 =?UTF-8?q?=E4=B8=BA20MB=E5=8D=95=E4=B8=AA=E6=96=87=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../datadump/service/impl/CommonBatchServiceImpl.java       | 2 +-
 .../com/celnet/datadump/service/impl/CommonServiceImpl.java | 4 +++-
 .../celnet/datadump/service/impl/OrgConfigServiceImpl.java  | 6 ++++--
 3 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/celnet/datadump/service/impl/CommonBatchServiceImpl.java b/src/main/java/com/celnet/datadump/service/impl/CommonBatchServiceImpl.java
index b58dd27..d016d9e 100644
--- a/src/main/java/com/celnet/datadump/service/impl/CommonBatchServiceImpl.java
+++ b/src/main/java/com/celnet/datadump/service/impl/CommonBatchServiceImpl.java
@@ -234,7 +234,7 @@ public class CommonBatchServiceImpl implements CommonBatchService {
 
             // 使用确定性命名策略，避免使用随机时间戳
             String fileName = Const.SERVER_FILE_PATH + "/" + api+ "/" + DateFormatUtils.format(new Date(), "yyyyMMddHHmmss");
-            final long maxFileSize = 50 * 1024 * 1024; // 50MB
+            final long maxFileSize = 20 * 1024 * 1024; // 20MB
 
             int fileIndex = 0;
             Path currentFilePath = Paths.get(fileName + "_" + fileIndex + ".csv");
diff --git a/src/main/java/com/celnet/datadump/service/impl/CommonServiceImpl.java b/src/main/java/com/celnet/datadump/service/impl/CommonServiceImpl.java
index 5f35133..d1e5d7b 100644
--- a/src/main/java/com/celnet/datadump/service/impl/CommonServiceImpl.java
+++ b/src/main/java/com/celnet/datadump/service/impl/CommonServiceImpl.java
@@ -1183,7 +1183,8 @@ public class CommonServiceImpl implements CommonService {
                 dataObjectService.saveOrUpdate(update);
             }
         }catch (Exception e){
-            EmailUtil.send("DataDump ERROR", e.getMessage());
+            log.info("创建表失败" , e);
+            throw new RuntimeException(e);
         }
     }
 
@@ -1601,6 +1602,7 @@ public class CommonServiceImpl implements CommonService {
             try {
                 checkApi(api, true);
             }catch (Exception e){
+                log.info("创建表结构异常！",e);
                 String message = e.getMessage();
                 String format = String.format("创建表结构 error, api name: %s, \nparam: %s, \ncause:\n%s",  api, com.alibaba.fastjson2.JSON.toJSONString(param, DataDumpParam.getFilter()), message);
                 EmailUtil.send("DataDump ERROR", format);
diff --git a/src/main/java/com/celnet/datadump/service/impl/OrgConfigServiceImpl.java b/src/main/java/com/celnet/datadump/service/impl/OrgConfigServiceImpl.java
index d9e76a4..999e725 100644
--- a/src/main/java/com/celnet/datadump/service/impl/OrgConfigServiceImpl.java
+++ b/src/main/java/com/celnet/datadump/service/impl/OrgConfigServiceImpl.java
@@ -14,6 +14,7 @@ import com.celnet.datadump.util.EmailUtil;
 import com.sforce.soap.partner.PartnerConnection;
 import com.sforce.ws.ConnectionException;
 import com.sforce.ws.ConnectorConfig;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -28,6 +29,7 @@ import static com.celnet.datadump.global.SystemConfigCode.EXECUTOR_SIZE;
 /**
  * org配置表 服务实现类
  */
+@Slf4j
 @Service
 public class OrgConfigServiceImpl extends ServiceImpl<OrgConfigMapper, OrgConfig> implements OrgConfigService {
 
@@ -78,7 +80,7 @@ public class OrgConfigServiceImpl extends ServiceImpl<OrgConfigMapper, OrgConfig
             String message = "源ORG连接配置错误！,\n地址：" + sourceOrgUrl + "\n错误信息：\n" + e.getMessage() ;;
             String format = String.format("ORG连接异常！, \ncause:\n%s", message);
             EmailUtil.send("DataDump ERROR", format);
-            log.error("exception message", e);
+            log.info("exception message", e);
             flag = false;
         }
 
@@ -117,7 +119,7 @@ public class OrgConfigServiceImpl extends ServiceImpl<OrgConfigMapper, OrgConfig
             String message = "目标ORG连接配置错误！,\n地址：" + targetOrgUrl + "\n错误信息：\n" + e.getMessage() ;
             String format = String.format("ORG连接异常！, \ncause:\n%s", message);
             EmailUtil.send("DataDump ERROR", format);
-            log.error("exception message", e);
+            log.info("exception message", e);
             flag = false;
         }