From 0d164f40d878c50dc799b0c80fae950816507d80 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 03 六月 2024 17:01:05 +0800
Subject: [PATCH] #xgm辅料库初始化

---
 src/main/java/com/zy/asrs/controller/StaDescController.java |   17 ++++++++++++++---
 1 files changed, 14 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/StaDescController.java b/src/main/java/com/zy/asrs/controller/StaDescController.java
index e6030da..bf01105 100644
--- a/src/main/java/com/zy/asrs/controller/StaDescController.java
+++ b/src/main/java/com/zy/asrs/controller/StaDescController.java
@@ -7,6 +7,7 @@
 import com.baomidou.mybatisplus.plugins.Page;
 import com.zy.asrs.entity.StaDesc;
 import com.zy.asrs.entity.param.StaDescInitParam;
+import com.zy.asrs.mapper.StaDescMapper;
 import com.zy.asrs.service.StaDescService;
 import com.zy.common.web.BaseController;
 import com.core.annotations.ManagerAuth;
@@ -14,6 +15,9 @@
 import com.core.common.Cools;
 import com.core.common.DateUtils;
 import com.core.common.R;
+import org.apache.ibatis.session.ExecutorType;
+import org.apache.ibatis.session.SqlSession;
+import org.apache.ibatis.session.SqlSessionFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -24,6 +28,8 @@
 
     @Autowired
     private StaDescService staDescService;
+    @Autowired
+    private SqlSessionFactory sqlSessionFactory;
 
     @RequestMapping(value = "/staDesc/init/auth")
     @ManagerAuth(memo = "鍒濆鍖栫珯鐐硅矾寰�")
@@ -35,6 +41,8 @@
             String[] startStaList = param.getStartStaList().split(";");
             String[] endStaList = param.getEndStaList().split(";");
             List<StaDesc> staDescList = new ArrayList<>();
+            SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH);
+            StaDescMapper sqlSessionMapper = sqlSession.getMapper(StaDescMapper.class);
             for (String startSta : startStaList){
                 for (String endSta : endStaList){
                     for (Integer type:param.getType()){
@@ -55,13 +63,16 @@
                         staDesc.setModiTime(new Date());
                         staDesc.setAppeUser(getUserId());
                         staDesc.setAppeTime(new Date());
-                        staDescList.add(staDesc);
+                        sqlSessionMapper.insert(staDesc);
+//                        staDescList.add(staDesc);
                     }
                 }
             }
-            staDescService.insertBatch(staDescList);
+            sqlSession.commit();
+            sqlSession.close();
+//            staDescService.insertBatch(staDescList);
         }catch (Exception e){
-            return R.error();
+            return R.error(e.getMessage());
         }
 
         return R.ok("ok1").add("ok2");

--
Gitblit v1.9.1