From ea69776780f0d7e0bb006517b7bb5543b0797c34 Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期日, 27 四月 2025 08:42:48 +0800
Subject: [PATCH] #盘点上报

---
 src/main/java/com/zy/asrs/controller/BasDevpController.java |   51 +++++++++++++++++++++++++++++++++++----------------
 1 files changed, 35 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..d69797b 100644
--- a/src/main/java/com/zy/asrs/controller/BasDevpController.java
+++ b/src/main/java/com/zy/asrs/controller/BasDevpController.java
@@ -5,8 +5,10 @@
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.mapper.Wrapper;
 import com.baomidou.mybatisplus.plugins.Page;
+import com.core.exception.CoolException;
 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 +16,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 +29,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.flushStatements();
+            sqlSession.clearCache();
+        }catch (Exception e) {
+            throw new CoolException(e.getMessage());
+        }finally {
+            sqlSession.close();
+            return R.ok("鍒濆鍖栨垚鍔�");
         }
-        basDevpService.insertBatch(list);
-        return R.ok("鍒濆鍖栨垚鍔�");
+
     }
 
     @RequestMapping(value = "/basDevp/{id}/auth")

--
Gitblit v1.9.1