From f980e7dfcd093aeaff061061f31fb71294f9e618 Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期六, 04 一月 2025 11:31:48 +0800 Subject: [PATCH] #并板加入自由项 --- src/main/java/com/zy/asrs/controller/StaDescController.java | 61 ++++++++++++++++++++++++++++++ 1 files changed, 61 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/StaDescController.java b/src/main/java/com/zy/asrs/controller/StaDescController.java index 8d85caf..ee0c3ed 100644 --- a/src/main/java/com/zy/asrs/controller/StaDescController.java +++ b/src/main/java/com/zy/asrs/controller/StaDescController.java @@ -6,6 +6,8 @@ import com.baomidou.mybatisplus.mapper.Wrapper; 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; @@ -13,6 +15,11 @@ 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.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -21,8 +28,62 @@ @RestController public class StaDescController extends BaseController { + private static final Logger log = LoggerFactory.getLogger(StaDescController.class); @Autowired private StaDescService staDescService; + @Autowired + private SqlSessionFactory sqlSessionFactory; + + @RequestMapping(value = "/staDesc/init/auth") + @ManagerAuth(memo = "鍒濆鍖栫珯鐐硅矾寰�") + public R init(StaDescInitParam param) { + SqlSession sqlSession = null; + try{ + if (param.getTypeDesc()==1){ + staDescService.delete(new EntityWrapper<>()); + } + String[] startStaList = param.getStartStaList().split(";"); + String[] endStaList = param.getEndStaList().split(";"); + List<StaDesc> staDescList = new ArrayList<>(); + sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false); + StaDescMapper sqlSessionMapper = sqlSession.getMapper(StaDescMapper.class); + for (String startSta : startStaList){ + for (String endSta : endStaList){ + for (Integer type:param.getType()){ + int sameRes = staDescService.selectCount(new EntityWrapper<StaDesc>() + .eq("type_no", type) + .eq("stn_no", Integer.parseInt(startSta)) + .eq("crn_no", param.getCrnNo()) + .eq("crn_stn", Integer.parseInt(endSta))); + if (sameRes > 0) { + continue; + } + StaDesc staDesc = new StaDesc(); + staDesc.setCrnNo(param.getCrnNo()); + staDesc.setTypeNo(type); + staDesc.setStnNo(Integer.parseInt(startSta)); + staDesc.setCrnStn(Integer.parseInt(endSta)); + staDesc.setModiUser(getUserId()); + staDesc.setModiTime(new Date()); + staDesc.setAppeUser(getUserId()); + staDesc.setAppeTime(new Date()); + sqlSessionMapper.insert(staDesc); +// staDescList.add(staDesc); + } + } + } + sqlSession.flushStatements(); + sqlSession.clearCache(); + +// staDescService.insertBatch(staDescList); + }catch (Exception e){ + return R.error(e.getMessage()); + }finally { + sqlSession.close(); + } + + return R.ok("ok1").add("ok2"); + } @RequestMapping(value = "/staDesc/{id}/auth") @ManagerAuth -- Gitblit v1.9.1