From af212f68a20cfd2549a37093a7850b5a99f1a2ea Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期六, 21 九月 2024 09:39:19 +0800
Subject: [PATCH] 逻辑调整

---
 src/main/java/com/zy/asrs/controller/BasDevpController.java |   50 ++++++++++++++++++++++++++++++++++----------------
 1 files changed, 34 insertions(+), 16 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/BasDevpController.java b/src/main/java/com/zy/asrs/controller/BasDevpController.java
index 5182bc4..fe6324e 100644
--- a/src/main/java/com/zy/asrs/controller/BasDevpController.java
+++ b/src/main/java/com/zy/asrs/controller/BasDevpController.java
@@ -7,6 +7,7 @@
 import com.baomidou.mybatisplus.plugins.Page;
 import com.zy.asrs.entity.BasDevp;
 import com.zy.asrs.entity.param.BasDevpInitParam;
+import com.zy.asrs.mapper.BasDevpMapper;
 import com.zy.asrs.service.BasDevpService;
 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,29 +28,43 @@
 
     @Autowired
     private BasDevpService basDevpService;
+    @Autowired
+    private SqlSessionFactory sqlSessionFactory;
 
     @RequestMapping(value = "/basDevp/init/auth")
     @ManagerAuth(memo = "鍒濆鍖栫珯鐐�")
     public R init(BasDevpInitParam param) {
         List<BasDevp> list = new ArrayList<>();
-        for (int devNo = param.getStartDev() ; devNo<=param.getEndDev() ; devNo++){
-            BasDevp basDevp = basDevpService.selectById(devNo);
-            if (Cools.isEmpty(basDevp)){
-                BasDevp basDevp1 = new BasDevp();
-                basDevp1.setDevNo(devNo);
-                basDevp1.setInEnable("Y");
-                basDevp1.setOutEnable("Y");
-                basDevp1.setAutoing("Y");
-                basDevp1.setLoading("Y");
-                basDevp1.setCanining("Y");
-                basDevp1.setCanouting("Y");
-                basDevp1.setModiUser(getUserId());
-                basDevp1.setModiTime(new Date());
-                list.add(basDevp1);
+        SqlSession sqlSession = null;
+        try {
+            sqlSession = sqlSessionFactory.openSession(ExecutorType.SIMPLE,false);
+            BasDevpMapper sessionMapper = sqlSession.getMapper(BasDevpMapper.class);
+            for (int devNo = param.getStartDev() ; devNo<=param.getEndDev() ; devNo++){
+                BasDevp basDevp = basDevpService.selectById(devNo);
+                if (Cools.isEmpty(basDevp)){
+                    BasDevp basDevp1 = new BasDevp();
+                    basDevp1.setDevNo(devNo);
+                    basDevp1.setInEnable("Y");
+                    basDevp1.setOutEnable("Y");
+                    basDevp1.setAutoing("Y");
+                    basDevp1.setLoading("Y");
+                    basDevp1.setCanining("Y");
+                    basDevp1.setCanouting("Y");
+                    basDevp1.setModiUser(getUserId());
+                    basDevp1.setModiTime(new Date());
+                    sessionMapper.insert(basDevp1);
+//                list.add(basDevp1);
+                }
             }
+            sqlSession.commit();
+             sqlSession.clearCache();
+        }catch (Exception e) {
+            return R.error(e.getMessage());
+        }finally {
+            sqlSession.close();
+            return R.ok("鍒濆鍖栨垚鍔�");
         }
-        basDevpService.insertBatch(list);
-        return R.ok("鍒濆鍖栨垚鍔�");
+
     }
 
     @RequestMapping(value = "/basDevp/{id}/auth")

--
Gitblit v1.9.1