From 035ecbe3a3540011f29a8f2287aead232749aaad Mon Sep 17 00:00:00 2001
From: zc <zc@123>
Date: 星期六, 19 四月 2025 10:38:25 +0800
Subject: [PATCH] qw

---
 src/main/java/com/zy/asrs/controller/StaDescController.java |   20 +++++++++-----------
 1 files changed, 9 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/StaDescController.java b/src/main/java/com/zy/asrs/controller/StaDescController.java
index 3a6ac32..ee0c3ed 100644
--- a/src/main/java/com/zy/asrs/controller/StaDescController.java
+++ b/src/main/java/com/zy/asrs/controller/StaDescController.java
@@ -37,6 +37,7 @@
     @RequestMapping(value = "/staDesc/init/auth")
     @ManagerAuth(memo = "鍒濆鍖栫珯鐐硅矾寰�")
     public R init(StaDescInitParam param) {
+        SqlSession sqlSession = null;
         try{
             if (param.getTypeDesc()==1){
                 staDescService.delete(new EntityWrapper<>());
@@ -44,7 +45,7 @@
             String[] startStaList = param.getStartStaList().split(";");
             String[] endStaList = param.getEndStaList().split(";");
             List<StaDesc> staDescList = new ArrayList<>();
-            SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
+            sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
             StaDescMapper sqlSessionMapper = sqlSession.getMapper(StaDescMapper.class);
             for (String startSta : startStaList){
                 for (String endSta : endStaList){
@@ -66,22 +67,19 @@
                         staDesc.setModiTime(new Date());
                         staDesc.setAppeUser(getUserId());
                         staDesc.setAppeTime(new Date());
-//                        staDescList.add(staDesc);
                         sqlSessionMapper.insert(staDesc);
-
+//                        staDescList.add(staDesc);
                     }
                 }
             }
-            try{
-                sqlSession.commit();
-                sqlSession.close();
-            }catch (Exception e){
-                log.error("鍒濆鍖栫珯鐐硅矾寰勫紓甯�===>sql寮傚父锛歿}",e.getMessage());
-            }
+            sqlSession.flushStatements();
+            sqlSession.clearCache();
+
 //            staDescService.insertBatch(staDescList);
         }catch (Exception e){
-            log.error("鍒濆鍖栫珯鐐硅矾寰勫紓甯革細{}",e.getMessage());
-            return R.error("鍒濆鍖栫珯鐐硅矾寰勫紓甯革細"+e.getMessage());
+            return R.error(e.getMessage());
+        }finally {
+            sqlSession.close();
         }
 
         return R.ok("ok1").add("ok2");

--
Gitblit v1.9.1