From 383cee5937b1f10e800ca30743a78a96c34d5123 Mon Sep 17 00:00:00 2001
From: zhangherong <571457620@qq.com>
Date: 星期四, 14 八月 2025 22:21:28 +0800
Subject: [PATCH] art: 生产订单同步任务，同时插入物料基本信息
---
src/main/java/org/jeecg/config/sap/SapRfcConnectionManager.java | 39 +++++++++++++++------------------------
1 files changed, 15 insertions(+), 24 deletions(-)
diff --git a/src/main/java/org/jeecg/config/sap/SapRfcConnectionManager.java b/src/main/java/org/jeecg/config/sap/SapRfcConnectionManager.java
index e120d4f..876add9 100644
--- a/src/main/java/org/jeecg/config/sap/SapRfcConnectionManager.java
+++ b/src/main/java/org/jeecg/config/sap/SapRfcConnectionManager.java
@@ -1,8 +1,12 @@
package org.jeecg.config.sap;
-import com.sap.conn.jco.*;
+import com.sap.conn.jco.JCoDestination;
+import com.sap.conn.jco.JCoDestinationManager;
+import com.sap.conn.jco.JCoException;
import com.sap.conn.jco.ext.DestinationDataProvider;
import com.sap.conn.jco.ext.Environment;
+import lombok.Getter;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
@@ -10,6 +14,8 @@
import java.util.Properties;
@Component
+@Slf4j
+@Getter
public class SapRfcConnectionManager {
@Value("${sap.rfc.destination}")
@@ -33,10 +39,13 @@
@Value("${sap.rfc.lang}")
private String lang;
- private String poolSize = "5";
+ @Value("${sap.rfc.poolSize}")
+ private String poolSize;
- private String idleTimeout = "10000";
+ @Value("${sap.rfc.expirationTime}")
+ private String expirationTime;
+ @Value("${sap.rfc.peekLimit}")
private String peekLimit = "10";
private JCoDestination destination;
@@ -46,7 +55,7 @@
* @throws JCoException
*/
@PostConstruct
- public void init() throws JCoException {
+ public void init() throws Exception {
Properties connectProperties = new Properties();
connectProperties.setProperty(DestinationDataProvider.JCO_ASHOST, ashost);
connectProperties.setProperty(DestinationDataProvider.JCO_SYSNR, sysnr);
@@ -56,33 +65,15 @@
connectProperties.setProperty(DestinationDataProvider.JCO_LANG, lang);
connectProperties.setProperty(DestinationDataProvider.JCO_PEAK_LIMIT, peekLimit);
connectProperties.setProperty(DestinationDataProvider.JCO_POOL_CAPACITY, poolSize);
- connectProperties.setProperty(DestinationDataProvider.JCO_EXPIRATION_TIME, idleTimeout);
+ connectProperties.setProperty(DestinationDataProvider.JCO_EXPIRATION_TIME, expirationTime);
// 鍒涘缓鍔ㄦ�佺洰鐨勫湴锛堥伩鍏嶄緷璧� SM59 閰嶇疆锛�
- CustomDestinationDataProvider provider = new CustomDestinationDataProvider();
- provider.addDestination(destinationName, connectProperties);
+ CustomDestinationDataProvider provider = new CustomDestinationDataProvider(destinationName, connectProperties);
// 璁剧疆鍏ㄥ眬鐩殑鍦版彁渚涜��
Environment.registerDestinationDataProvider(provider);
// 鑾峰彇鐩殑鍦�
this.destination = JCoDestinationManager.getDestination(destinationName);
- }
-
- /**
- *
- * @return
- */
- public JCoDestination getDestination() {
- return destination;
- }
-
- /**
- *
- */
- public void destroy() {
- if (destination != null) {
-// destination;
- }
}
}
\ No newline at end of file
--
Gitblit v1.9.3