From ff8ae23da4205f072c823ea2a5e095386c6672db Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@63.com>
Date: 星期四, 23 九月 2021 10:58:45 +0800
Subject: [PATCH] 1

---
 src/main/java/com/zy/common/service/erp/ErpSqlServer.java |   15 ++++++++++-----
 1 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/zy/common/service/erp/ErpSqlServer.java b/src/main/java/com/zy/common/service/erp/ErpSqlServer.java
index 2ebe41f..7f0610d 100644
--- a/src/main/java/com/zy/common/service/erp/ErpSqlServer.java
+++ b/src/main/java/com/zy/common/service/erp/ErpSqlServer.java
@@ -2,6 +2,7 @@
 
 import com.core.common.Cools;
 import com.zy.common.properties.ErpDbProperties;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -19,6 +20,7 @@
  * 绠�鍗曟寔涔呭眰妗嗘灦
  * Created by vincent on 2020/11/26
  */
+@Slf4j
 @Service
 public class ErpSqlServer {
 
@@ -66,13 +68,13 @@
     /*****************************************************************************/
 
 
-    private synchronized List<Map<String, Object>> executeQuery(String sql) {
+    private List<Map<String, Object>> executeQuery(String sql) {
         try {
             Connection conn = getConn();
             pstm = conn.prepareStatement(sql);
             rs = pstm.executeQuery();
-            List<Map<String, Object>> maps = convertList(rs);
-            return deepClone(maps);
+//            List<Map<String, Object>> maps = convertList(rs);
+            return convertList(rs);
         } catch (Exception e) {
             e.printStackTrace();
             return null;
@@ -88,6 +90,8 @@
             return pstm.executeUpdate();
         } catch (Exception e) {
             e.printStackTrace();
+            log.error("鏇存柊ERP涓棿琛ㄥけ璐�===>>" + sql);
+            log.error("鏇存柊ERP涓棿琛ㄥけ璐�===>>" + e);
             return 0;
         } finally {
             release();
@@ -108,12 +112,13 @@
         return list;
     }
 
-    private Connection getConn() {
-        if (null == this.conn) {
+    public synchronized Connection getConn() throws SQLException {
+        if (null == this.conn || this.conn.isClosed()) {
             try {
                 Class.forName(erpDbProperties.getDriver_class_name()).newInstance();
                 this.conn = DriverManager.getConnection(erpDbProperties.getUr(), erpDbProperties.getUsername(), erpDbProperties.getPassword());
             } catch (Exception e) {
+                log.error("鑾峰彇ERP鏁版嵁搴撹繛鎺ュけ璐�");
                 e.printStackTrace();
                 throw new RuntimeException("鑾峰彇ERP鏁版嵁搴撹繛鎺ュけ璐�");
             }

--
Gitblit v1.9.1