From 1bb91fea213a129dd71295bdef58dcbbd2ea6a7b Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期四, 18 四月 2024 11:48:44 +0800
Subject: [PATCH] 修改部分实体类id为Long类型防止溢出

---
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageServiceImpl.java |  139 ++++++++++++++++++++++++++++------------------
 1 files changed, 84 insertions(+), 55 deletions(-)

diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageServiceImpl.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageServiceImpl.java
index 00f8430..6956b36 100644
--- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageServiceImpl.java
+++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageServiceImpl.java
@@ -1,6 +1,7 @@
 package com.mes.bigstorage.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.mes.bigstorage.entity.BigStorageCage;
@@ -9,7 +10,10 @@
 import com.mes.bigstorage.mapper.BigStorageCageMapper;
 import com.mes.bigstorage.service.BigStorageCageService;
 import com.mes.glassinfo.entity.GlassInfo;
+import com.mes.temperingglass.entity.TemperingGlassInfo;
+import com.mes.temperingglass.service.TemperingGlassInfoService;
 import lombok.extern.slf4j.Slf4j;
+import com.mes.glassinfo.entity.GlassInfo;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 
@@ -31,94 +35,119 @@
 @Service
 @Slf4j
 public class BigStorageCageServiceImpl extends ServiceImpl<BigStorageCageMapper, BigStorageCage> implements BigStorageCageService {
+    @Resource
+    private BigStorageCageMapper bigStorageCageMapper;
 
     @Resource
     private BigStorageCageDetailsMapper bigStorageCageDetailsMapper;
 
+    @Resource
+    private TemperingGlassInfoService temperingGlassInfoService;
+
     @Override
     public BigStorageCageDetails feedGlass(GlassInfo glassInfo, BigStorageCageDetails bigStorageCageDetails) {
 
-        //1銆佹煡璇㈢悊鐗囩鍐呯幓鐠冪墖搴忕瓑浜庡綋鍓嶇幓鐠冪墖搴�-1鐨勭幓鐠�
+        log.info("1銆佹煡璇㈢悊鐗囩鍐呯墖搴�+1绛変簬褰撳墠鐜荤拑鐗囧簭鐨勭幓鐠�");
         LambdaQueryWrapper<BigStorageCageDetails> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(BigStorageCageDetails::getTemperingLayoutId, glassInfo.getTemperingLayoutId())
                 .eq(BigStorageCageDetails::getTemperingFeedSequence, glassInfo.getTemperingFeedSequence() + 1);
+        BigStorageCageDetails layoutSlotInfo;
+        layoutSlotInfo= bigStorageCageDetailsMapper.selectOne(wrapper);
 
-        BigStorageCageDetails layoutSlotInfo = bigStorageCageDetailsMapper.selectOne(wrapper);
         BeanUtils.copyProperties(glassInfo, bigStorageCageDetails);
-        bigStorageCageDetails.setSlot(layoutSlotInfo.getSlot());
 
-        //2銆佹湁绗﹀悎鏉′欢鐨勬牸瀛愭椿鐗囧簭涓�1鏃�
-        log.info("鏈夌鍚堟潯浠剁殑鏍煎瓙娲荤墖搴忎负1鏃�");
+        log.info("2銆佹煡璇㈢悊鐗囩鍐呯墖搴�+1绛変簬褰撳墠鐜荤拑鐗囧簭鐨勭幓鐠冪殑缁撴灉涓嶄负绌烘椂");
         if (layoutSlotInfo.getSlot() != null) {
             bigStorageCageDetails.setSlot(layoutSlotInfo.getSlot());
         } else {
-            //鑾峰彇涓嶅埌鏃讹細
-//            LambdaQueryWrapper<BigStorageCageDetails> BigStorageCageDetailslambdaQueryWrapper = new LambdaQueryWrapper<>();
-//            BigStorageCageDetailslambdaQueryWrapper
-//                    .select(BigStorageCageDetails::getTemperingLayoutId)
-//                    .groupBy(BigStorageCageDetails::getTemperingLayoutId);
-//            List<Map<String, Object>> temperingLayoutIdList= bigStorageCageDetailsMapper.selectMaps(BigStorageCageDetailslambdaQueryWrapper);
-//            for (Map<String, Object> map : temperingLayoutIdList) {
-//                for (Map.Entry<String, Object> entry : map.entrySet()) {
-//                    String prefix = entry.getKey().substring(0, entry.getKey().indexOf('-'));
-//                    String suffix = entry.getKey().substring(entry.getKey().indexOf('-') + 1);
-//                    if(suffix.equals(entry.getValue())){
-//
-//                    }
-//                }
-//            }
+            log.info("3銆佹煡璇㈢悊鐗囩鍐呯墖搴�+1绛変簬褰撳墠鐜荤拑鐗囧簭鐨勭幓鐠冪殑缁撴灉涓虹┖鏃惰幏鍙栧綋鍓嶇幓鐠冪増鍥緄d鏄惁瀛樺湪鐞嗙墖绗煎唴");
+            LambdaQueryWrapper<BigStorageCageDetails> BigStorageCageDetailslambdaQueryWrapper = new LambdaQueryWrapper<>();
+            BigStorageCageDetailslambdaQueryWrapper
+                    .select(BigStorageCageDetails::getTemperingLayoutId);
+            layoutSlotInfo = bigStorageCageDetailsMapper.selectOne(BigStorageCageDetailslambdaQueryWrapper);
 
+            if(layoutSlotInfo != null){
+                log.info("4銆佽幏鍙栫瀛愬唴閫傚悎鐨勬牸瀛�");
+                BigStorageCage bigStorageCage=bigStorageCageSlot(layoutSlotInfo.getDeviceId());
+                bigStorageCageDetails.setSlot(bigStorageCage.getSlot());
+            }else{
+                log.info("5銆佽幏鍙栨瘡涓瀛愮増鍥緄d鐨勪釜鏁�");
+                QueryWrapper<BigStorageCageDetails> queryWrapper = new QueryWrapper<>();
+                queryWrapper.select("a.device_id", "COUNT(DISTINCT b.tempering_layout_id) AS layoutCount")
+                        .groupBy("a.device_id")
+                        .apply("LEFT JOIN (SELECT device_id, tempering_layout_id FROM big_storage_cage_details) b ON a.device_id = b.device_id AND a.slot = b.slot")
+                        .orderByAsc("layoutCount")
+                        .orderByAsc("a.device_id");
+                List<Map<String, Object>> BigStorageCageDetailsCount= bigStorageCageDetailsMapper.selectMaps(queryWrapper);
 
-            //鑾峰彇鍙繘鐗囨牸瀛愪俊鎭�
-//            BigStorageCageDetails EmptySlotInfo = bigStorageCageMapper.selectEmptyFeedSlot();
-//            if (EmptySlotInfo != null) {
-//                bigStorageCageDetails.setSlot(EmptySlotInfo.getSlot());
-//            } else {
-//                //鑾峰彇鍏朵粬绗兼牸瀛�-
-//                BigStorageCageDetails OtherSlotInfo = bigStorageCageMapper.selectOtherFeedSlot();
-//                bigStorageCageDetails.setSlot(OtherSlotInfo.getSlot());
-//            }
-            //灏嗙幓鐠冧俊鎭斁鍏ヨ鏍煎瓙
-
+                log.info("5銆佹煡璇㈢瀛愬唴鏄惁鏈夊悎閫傜殑鏍煎瓙");
+                for (Map<String, Object> map : BigStorageCageDetailsCount) {
+                    for (Map.Entry<String, Object> entry : map.entrySet()) {
+                        int deviceId = Integer.parseInt(entry.getKey());
+                        BigStorageCage bigStorageCage=bigStorageCageSlot(deviceId);
+                        if(bigStorageCage!=null){
+                            bigStorageCageDetails.setSlot(bigStorageCage.getSlot());
+                        }
+                    }
+                }
+            }
         }
+        log.info("6銆佸綋鎵惧埌鍚堥�傜殑鏍煎瓙鏃舵坊鍔犵幓鐠冨埌绗煎瓙琛�");
         if (bigStorageCageDetails.getSlot() != null) {
+            bigStorageCageDetails.setState(0);
             bigStorageCageDetailsMapper.insert(bigStorageCageDetails);
-            updateRemainWidth(bigStorageCageDetails.getSlot());
+            updateRemainWidth(bigStorageCageDetails.getSlot()) ;
         }
         return bigStorageCageDetails;
     }
 
+    //鑾峰彇绗煎瓙鍐呯殑绌烘牸瀛�
+    private BigStorageCage bigStorageCageSlot(Integer deviceId) {
+        LambdaQueryWrapper<BigStorageCage> bigStorageCageWrapper=new LambdaQueryWrapper<>();
+                bigStorageCageWrapper
+                        .eq(BigStorageCage::getRemainWidth,"5000")
+                        .eq(BigStorageCage::getEnableState,"0")
+                        .eq(BigStorageCage::getDeviceId,deviceId)
+                        .orderByAsc(BigStorageCage::getSlot)
+                        .last("LIMIT 1");
+                return bigStorageCageMapper.selectOne(bigStorageCageWrapper);
+    }
+
+
     @Override
     public boolean outGlass() {
-//        // 1銆佹煡璇㈤挗鍖栧皬鐗囦换鍔¤〃鏄惁鏈夊緟鍑虹幓鐠�
-//        List<TemperingGlassInfo> temperingGlassInfoList = temperingGlassInfoService.SelectTemperingGlassInfo();
-//        //娌℃湁鍙嚭鐨勭幓鐠冩椂
-//        if (temperingGlassInfoList != null) {
-//            //鏌ヨ鏄惁鏈夊皬鐗囧叏閮ㄥ埌榻愮殑閽㈠寲鐗堝浘
-//        } else {
-//            //缁х画褰撳墠閽㈠寲鐗堝浘鐨勪换鍔�
-//        }
-        LambdaQueryWrapper<BigStorageCageDetails> bigStorageCageDetailslambdaQueryWrapper = new LambdaQueryWrapper<>();
-        bigStorageCageDetailslambdaQueryWrapper
-                .select(BigStorageCageDetails::getTemperingLayoutId)
-                .groupBy(BigStorageCageDetails::getTemperingLayoutId);
-        List<Map<String, Object>> temperingLayoutIdList = bigStorageCageDetailsMapper.selectMaps(bigStorageCageDetailslambdaQueryWrapper);
-        for (Map<String, Object> map : temperingLayoutIdList) {
-            for (Map.Entry<String, Object> entry : map.entrySet()) {
-                String prefix = entry.getKey().substring(0, entry.getKey().indexOf('-'));
-                String suffix = entry.getKey().substring(entry.getKey().indexOf('-') + 1);
-                if (suffix.equals(entry.getValue())) {
+        List<TemperingGlassInfo> temperingGlassInfoList = temperingGlassInfoService.list();
+        log.info("1銆佹煡璇㈤挗鍖栧皬鐗囦换鍔¤〃鏄惁鏈夊緟鍑虹幓鐠�"+temperingGlassInfoList.size());
 
+        if(temperingGlassInfoList!=null){
+            temperingGlassInfoService.addOutTask(temperingGlassInfoList);
+            log.info("2銆佹坊鍔犱换鍔″埌浠诲姟琛�");
+            return true;
+        }else{
+            log.info("3銆佹病鏈夊彲鍑虹殑鐜荤拑鏃惰幏鍙栨槸鍚︽湁灏忕墖鍒伴綈鐨勭増鍥�");
+            LambdaQueryWrapper<BigStorageCageDetails> bigStorageCageDetailslambdaQueryWrapper = new LambdaQueryWrapper<>();
+            bigStorageCageDetailslambdaQueryWrapper
+                    .select(BigStorageCageDetails::getTemperingLayoutId)
+                    .groupBy(BigStorageCageDetails::getTemperingLayoutId);
+            List<Map<String, Object>> temperingLayoutIdList = bigStorageCageDetailsMapper.selectMaps(bigStorageCageDetailslambdaQueryWrapper);
+            for (Map<String, Object> map : temperingLayoutIdList) {
+                for (Map.Entry<String, Object> entry : map.entrySet()) {
+                    String layoutId = entry.getKey().substring(0, entry.getKey().indexOf('-'));
+                    String layoutNum = entry.getKey().substring(entry.getKey().indexOf('-') + 1);
+                    if (layoutNum.equals(entry.getValue())) {
+                        //4銆佹坊鍔犳閽㈠寲鐗堝浘id鎵�鏈夊皬鐗囧皬鐗囧埌閽㈠寲灏忕墖琛�
+                        return false;
+                    }
                 }
             }
         }
-        return true;
+        return false;
     }
 
-    //淇敼鏍煎瓙鍓╀綑瀹藉害
+    //璁$畻鏍煎瓙鍓╀綑瀹藉害
     @Override
     public void updateRemainWidth(int slot) {
-        //鑾峰彇璇ユ牸瀛愬唴鐜荤拑淇℃伅
+        log.info("鑾峰彇璇ユ牸瀛愬唴鐜荤拑淇℃伅锛岃绠楁牸瀛愬墿浣欏搴�");
         Integer width = 5000;
         List<BigStorageCageDetails> bigStorageCageDetailsList = Collections.singletonList(bigStorageCageDetailsMapper.selectById(slot));
         for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList
@@ -130,13 +159,13 @@
         bigStorageCage.setRemainWidth(width);
         UpdateWrapper<BigStorageCage> bigStorageCageWrapper = new UpdateWrapper<>();
         bigStorageCageWrapper.eq("remain_width", width);
-        baseMapper.update(bigStorageCage, bigStorageCageWrapper);
+        bigStorageCageMapper.update(bigStorageCage, bigStorageCageWrapper);
     }
 
     @Override
     public List<BigStorageCage> querybigStorageCageDetail() {
         //1銆佽幏鍙栧ぇ鐞嗙墖绗间俊鎭�
-        List<BigStorageCage> bigStorageCages = baseMapper.selectList(null);
+        List<BigStorageCage> bigStorageCages = bigStorageCageMapper.selectList(null);
         log.info("1銆佽幏鍙栧ぇ鐞嗙墖绗间俊鎭畬鎴愶紝鑾峰彇鍒扮殑鏁版嵁{}", bigStorageCages.size());
         //2鑾峰彇鐞嗙墖绗兼墍鏈変俊鎭�
         List<BigStorageCageDetails> bigStorageCageDetailsList = bigStorageCageDetailsMapper.selectList(null);

--
Gitblit v1.8.0