From 73db5fb7f98e13e37ff5f43ec8977fb1f0cfcb9b Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期四, 25 七月 2024 12:34:34 +0800
Subject: [PATCH] 大理片:修改进片逻辑,卧转立启动,详情表中新增一条状态为0的玻璃信息,进片任务完成后将状态改为100 下片:下片异常问题解决

---
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java |  175 +++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 142 insertions(+), 33 deletions(-)

diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java
index 27c9878..01b49c4 100644
--- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java
+++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java
@@ -2,6 +2,7 @@
 
 import cn.hutool.core.lang.Assert;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.github.yulichang.base.MPJBaseServiceImpl;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
 import com.mes.bigstorage.entity.BigStorageCage;
@@ -17,6 +18,8 @@
 import com.mes.bigstoragetask.mapper.BigStorageCageFeedTaskMapper;
 import com.mes.bigstoragetask.mapper.BigStorageCageOutTaskMapper;
 import com.mes.common.config.Const;
+import com.mes.damage.entity.Damage;
+import com.mes.damage.service.DamageService;
 import com.mes.glassinfo.entity.GlassInfo;
 import com.mes.glassinfo.mapper.GlassInfoMapper;
 import com.mes.temperingglass.entity.TemperingGlassInfo;
@@ -27,6 +30,7 @@
 
 import javax.annotation.Resource;
 import java.util.ArrayList;
+import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -53,49 +57,66 @@
     @Resource
     private GlassInfoMapper glassInfoMapper;
 
+    @Resource
+    private DamageService damageService;
+
     @Value("${mes.minCount}")
     private int minCount;
-
-    @Value("${mes.carWidth}")
-    private Integer carWidth;
 
     @Value("${mes.slotWidth}")
     private Integer slotWidth;
 
-    @Value("${mes.carMaxSize}")
-    private Integer carMaxSize;
-
-    @Value("${mes.galssGap}")
-    private Integer galssGap;
+    @Value("${mes.glassGap}")
+    private Integer glassGap;
 
     /**
      * 鏌ヨ杩�/鍑虹墖浠诲姟
      */
     @Override
     public List<BigStorageCageDetails> selectTask(int taskType) {
-
         if (taskType == 1) {
             //杩涚墖浠诲姟鏁版嵁
             LambdaQueryWrapper<BigStorageCageDetails> feedWrapper = new LambdaQueryWrapper<>();
-            feedWrapper.eq(BigStorageCageDetails::getState, Const.BIG_STORAGE_IN);
+            feedWrapper.eq(BigStorageCageDetails::getState, Const.GLASS_STATE_IN);
             List<BigStorageCageDetails> bigStorageCageDetailsList = baseMapper.selectList(feedWrapper);
 
             LambdaQueryWrapper<BigStorageCageFeedTask> feedTaskWrapper = new LambdaQueryWrapper<>();
-            feedTaskWrapper.lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT);
+            feedTaskWrapper
+                    .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
+                    .isNotNull(BigStorageCageFeedTask::getTargetSlot);
             List<BigStorageCageFeedTask> bigStorageCageFeedTaskList = bigStorageCageFeedTaskMapper.selectList(feedTaskWrapper);
 
             Map<String, BigStorageCageFeedTask> listMap = bigStorageCageFeedTaskList.stream()
                     .collect(Collectors.toMap(BigStorageCageFeedTask::getGlassId, task -> task));
-
-            for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList) {
+            Iterator<BigStorageCageDetails> iterator = bigStorageCageDetailsList.iterator();
+            while (iterator.hasNext()) {
+                BigStorageCageDetails bigStorageCageDetails = iterator.next();
                 BigStorageCageFeedTask bigStorageCageFeedTask = listMap.get(bigStorageCageDetails.getGlassId());
                 bigStorageCageDetails.setBigStorageCageFeedTask(bigStorageCageFeedTask);
+                if (bigStorageCageDetails.getBigStorageCageFeedTask() == null) {
+                    iterator.remove();
+                }
+            }
+            LambdaQueryWrapper<BigStorageCageFeedTask> feedTaskNoTargetWrapper = new LambdaQueryWrapper<>();
+            feedTaskNoTargetWrapper
+                    .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
+                    .isNull(BigStorageCageFeedTask::getTargetSlot);
+            List<BigStorageCageFeedTask> bigStorageCageFeedTaskNoTargetList = bigStorageCageFeedTaskMapper.selectList(feedTaskNoTargetWrapper);
+            for (BigStorageCageFeedTask bigStorageCageFeedTask : bigStorageCageFeedTaskNoTargetList
+            ) {
+                BigStorageCageDetails bigStorageCageDetails = new BigStorageCageDetails();
+                LambdaQueryWrapper<GlassInfo> glassInfoWrapper = new LambdaQueryWrapper<>();
+                glassInfoWrapper.eq(GlassInfo::getGlassId, bigStorageCageFeedTask.getGlassId());
+                GlassInfo glassInfo = glassInfoMapper.selectOne(glassInfoWrapper);
+                BeanUtils.copyProperties(glassInfo, bigStorageCageDetails);
+                bigStorageCageDetails.setBigStorageCageFeedTask(bigStorageCageFeedTask);
+                bigStorageCageDetailsList.add(bigStorageCageDetails);
             }
             return bigStorageCageDetailsList;
         } else {
             //鍑虹墖浠诲姟鏁版嵁
             LambdaQueryWrapper<BigStorageCageDetails> outWrapper = new LambdaQueryWrapper<>();
-            outWrapper.eq(BigStorageCageDetails::getState, Const.BIG_STORAGE_OUT);
+            outWrapper.eq(BigStorageCageDetails::getState, Const.GLASS_STATE_IN);
             List<BigStorageCageDetails> bigStorageCageDetailsList = baseMapper.selectList(outWrapper);
 
             LambdaQueryWrapper<BigStorageCageOutTask> outTaskWrapper = new LambdaQueryWrapper<>();
@@ -107,6 +128,15 @@
             for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList) {
                 BigStorageCageOutTask bigStorageCageOutTask = listMap.get(bigStorageCageDetails.getGlassId());
                 bigStorageCageDetails.setBigStorageCageOutTask(bigStorageCageOutTask);
+            }
+            Iterator<BigStorageCageDetails> iterator = bigStorageCageDetailsList.iterator();
+            while (iterator.hasNext()) {
+                BigStorageCageDetails bigStorageCageDetails = iterator.next();
+                BigStorageCageOutTask bigStorageCageOutTask = listMap.get(bigStorageCageDetails.getGlassId());
+                bigStorageCageDetails.setBigStorageCageOutTask(bigStorageCageOutTask);
+                if (bigStorageCageDetails.getBigStorageCageOutTask() == null) {
+                    iterator.remove();
+                }
             }
             return bigStorageCageDetailsList;
         }
@@ -137,7 +167,7 @@
         for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList
         ) {
             if (bigStorageCageDetails.getBigStorageCageFeedTask().getTaskState() == 0) {
-                carWidth = carWidth - bigStorageCageDetails.getWidth() - galssGap;
+                carWidth = carWidth - bigStorageCageDetails.getWidth() - glassGap;
             }
         }
         return carWidth;
@@ -172,11 +202,20 @@
             }
             temperingGlassInfoMapper.updateById(temperingGlassInfo);
         }
-        bigStorageCageDetails.setState(Const.BIG_STORAGE_OUTSIDE);
+        if (status == 0) {
+            bigStorageCageDetails.setState(Const.GLASS_STATE_DAMAGE);
+        } else {
+            bigStorageCageDetails.setState(Const.GLASS_STATE_TAKE);
+        }
         baseMapper.updateById(bigStorageCageDetails);
         bigStorageCageService.updateRemainWidth(bigStorageCageDetails.getSlot());
         //todo:鎻掑叆鐮存崯鏁版嵁
-
+        Damage damage = new Damage();
+        damage.setGlassId(bigStorageCageDetails.getGlassId());
+        damage.setWorkingProcedure("鍐峰姞宸�");
+        damage.setRemark("澶х悊鐗囩鐮存崯");
+        damage.setStatus(2);
+        damageService.insertDamage(damage);
     }
 
     //鏌ヨ鐜荤拑淇℃伅
@@ -188,17 +227,21 @@
         BigStorageCageDetails bigStorageCageDetails = new BigStorageCageDetails();
         if (glassInfo != null) {
             BeanUtils.copyProperties(glassInfo, bigStorageCageDetails);
-            bigStorageCageDetails.setState(0);
-            bigStorageCageDetails.setGap(galssGap);
+            bigStorageCageDetails.setState(1);
+            bigStorageCageDetails.setGap(glassGap);
+            List<BigStorageCageDetails> bigStorageCageDetailsList = new ArrayList<>();
+            bigStorageCageDetailsList.add(bigStorageCageDetails);
+            return bigStorageCageDetailsList;
+        } else {
+            return null;
         }
-        List<BigStorageCageDetails> bigStorageCageDetailsList = new ArrayList<>();
-        bigStorageCageDetailsList.add(bigStorageCageDetails);
-        return bigStorageCageDetailsList;
+
     }
 
     //鐞嗙墖绗艰鎯呮坊鍔�
     @Override
     public void insertBigStorageCageDetails(BigStorageCageDetails bigStorageCageDetails) {
+        bigStorageCageDetails.setState(100);
         baseMapper.insert(bigStorageCageDetails);
         bigStorageCageService.updateRemainWidth(bigStorageCageDetails.getSlot());
     }
@@ -206,20 +249,20 @@
     //鐞嗙墖绗艰鎯呭畬鎴�
     @Override
     public void finishBigStorageCageDetails(BigStorageCageDetails bigStorageCageDetails) {
-        if (bigStorageCageDetails.getBigStorageCageFeedTask() != null) {
-            bigStorageCageDetails.setState(Const.BIG_STORAGE_INSIDE);
-            baseMapper.updateById(bigStorageCageDetails);
-        } else {
-            bigStorageCageDetails.setState(Const.BIG_STORAGE_OUTSIDE);
-            baseMapper.updateById(bigStorageCageDetails);
-            bigStorageCageService.updateRemainWidth(bigStorageCageDetails.getSlot());
-        }
+//        if (bigStorageCageDetails.getBigStorageCageFeedTask() != null) {
+//            bigStorageCageDetails.setState(Const.BIG_STORAGE_INSIDE);
+//            baseMapper.updateById(bigStorageCageDetails);
+//        } else {
+//            bigStorageCageDetails.setState(Const.BIG_STORAGE_OUTSIDE);
+//            baseMapper.updateById(bigStorageCageDetails);
+//            bigStorageCageService.updateRemainWidth(bigStorageCageDetails.getSlot());
+//        }
     }
 
     //鎵嬪姩鍑虹墖
     @Override
     public void outBigStorageCageDetails(BigStorageCageDetails bigStorageCageDetails) {
-        bigStorageCageDetails.setState(4);
+        bigStorageCageDetails.setState(Const.GLASS_STATE_ARTIFICIAL);
         baseMapper.updateById(bigStorageCageDetails);
     }
 
@@ -231,7 +274,7 @@
                 .leftJoin(BigStorageCageDetails.class, BigStorageCageDetails::getSlot, BigStorageCage::getSlot)
                 .eq(BigStorageCage::getEnableState, Const.SLOT_ON)
                 .eq(BigStorageCageDetails::getTemperingLayoutId, glassInfo.getTemperingLayoutId())
-                .gt(BigStorageCage::getRemainWidth, glassInfo.getWidth())
+                .gt(BigStorageCage::getRemainWidth, Math.max(glassInfo.getWidth(), glassInfo.getHeight()))
                 .last("limit 1");
         if (glassInfo.getTemperingLayoutId() == 0) {
             wrapper.eq(BigStorageCageDetails::getWidth, glassInfo.getWidth()).eq(BigStorageCageDetails::getHeight, glassInfo.getHeight());
@@ -243,6 +286,7 @@
             bigStorageDTO = new BigStorageDTO();
             bigStorageDTO.setWidth(bigStorageCage.getRemainWidth());
             bigStorageDTO.setSlot(bigStorageCage.getSlot());
+            bigStorageDTO.setDeviceId(bigStorageCage.getDeviceId());
             return bigStorageDTO;
         }
         bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>()
@@ -255,21 +299,42 @@
             bigStorageDTO = new BigStorageDTO();
             bigStorageDTO.setWidth(bigStorageCage.getRemainWidth());
             bigStorageDTO.setSlot(bigStorageCage.getSlot());
+            bigStorageDTO.setDeviceId(bigStorageCage.getDeviceId());
+            return bigStorageDTO;
+        }
+
+        //鑾峰彇鐜荤拑鐨勫帤搴︼細閲嶆柊閫夌瀛愰渶瑕佹寜鐓х瀛愬彲鏀剧幓鐠冨帤搴﹁繘琛岄�夋嫨
+        bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>()
+                .eq(BigStorageCage::getRemainWidth, slotWidth)
+                .eq(BigStorageCage::getEnableState, Const.SLOT_ON)
+                .notInSql(BigStorageCage::getDeviceId,
+                        "select distinct device_id from big_storage_cage_details where state in (100,102,103)")
+                .ge(BigStorageCage::getMaxThickness, glassInfo.getThickness())
+                .orderByAsc(BigStorageCage::getDeviceId)
+                .last("limit 1"));
+        if (null != bigStorageCage) {
+            bigStorageDTO = new BigStorageDTO();
+            bigStorageDTO.setWidth(bigStorageCage.getRemainWidth());
+            bigStorageDTO.setSlot(bigStorageCage.getSlot());
+            bigStorageDTO.setDeviceId(bigStorageCage.getDeviceId());
             return bigStorageDTO;
         }
         bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>()
                 .eq(BigStorageCage::getRemainWidth, slotWidth)
                 .eq(BigStorageCage::getEnableState, Const.SLOT_ON)
+                .ge(BigStorageCage::getMaxThickness, glassInfo.getThickness())
+                .orderByAsc(BigStorageCage::getDeviceId)
                 .last("limit 1"));
         Assert.isTrue(null != bigStorageCage, "娌℃湁绌轰綑鐨勭瀛愬瓨鏀剧幓鐠�");
         bigStorageDTO = new BigStorageDTO();
         bigStorageDTO.setWidth(bigStorageCage.getRemainWidth());
         bigStorageDTO.setSlot(bigStorageCage.getSlot());
+        bigStorageDTO.setDeviceId(bigStorageCage.getDeviceId());
         return bigStorageDTO;
     }
 
     @Override
-    public TemperingLayoutDTO temperingIsAll() {
+    public List<TemperingLayoutDTO> temperingIsAll() {
         return baseMapper.temperingIsAll();
     }
 
@@ -283,4 +348,48 @@
     public List<SlotSequenceDTO> queryGlassMaxAndMin(String engineerId, Integer temperingLayoutId) {
         return baseMapper.queryGlassMaxAndMin(engineerId, temperingLayoutId);
     }
+
+    @Override
+    public boolean TemperingGlass(String temperingLayoutId, String engineerId) {
+        LambdaQueryWrapper<TemperingGlassInfo> temperingGlassInfoLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        temperingGlassInfoLambdaQueryWrapper
+                .eq(TemperingGlassInfo::getState,Const.TEMPERING_NEW);
+        List<TemperingGlassInfo> temperingGlassInfoList=temperingGlassInfoMapper.selectList(temperingGlassInfoLambdaQueryWrapper);
+
+        if(temperingGlassInfoList.size()==0){
+            LambdaQueryWrapper<BigStorageCageDetails> wrapper =new LambdaQueryWrapper<>();
+            wrapper.eq(BigStorageCageDetails::getTemperingLayoutId,temperingLayoutId)
+                    .eq(BigStorageCageDetails::getEngineerId,engineerId)
+                    .in(BigStorageCageDetails::getState,Const.GLASS_STATE_IN,Const.GLASS_STATE_ARTIFICIAL);
+            List<BigStorageCageDetails> bigStorageCageDetailsList=baseMapper.selectList(wrapper);
+
+            for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList
+            ) {
+                TemperingGlassInfo temperingGlassInfo = new TemperingGlassInfo();
+                LambdaQueryWrapper<GlassInfo> glassInfoLambdaQueryWrapper = new LambdaQueryWrapper<>();
+                glassInfoLambdaQueryWrapper.eq(GlassInfo::getGlassId, bigStorageCageDetails.getGlassId());
+                GlassInfo glassInfo = glassInfoMapper.selectOne(glassInfoLambdaQueryWrapper);
+
+                BeanUtils.copyProperties(glassInfo, temperingGlassInfo);
+                temperingGlassInfo.setAngle((int) glassInfo.getAngle());
+                temperingGlassInfo.setState(Const.TEMPERING_NEW);
+                temperingGlassInfo.setSlot(bigStorageCageDetails.getSlot());
+                temperingGlassInfoMapper.insert(temperingGlassInfo);
+            }
+            return true;
+        } else {
+            return false;
+        }
+
+
+    }
+
+    @Override
+    public List<Map<String, Object>> selectTemperingGlass(){
+        QueryWrapper<BigStorageCageDetails> wrapper = new QueryWrapper<>();
+        wrapper.select("engineer_id,tempering_layout_id,count(*) as count")
+                .groupBy("engineer_id,tempering_layout_id");
+        List<Map<String, Object>> TemperingGlass = baseMapper.selectMaps(wrapper);
+        return TemperingGlass;
+    }
 }

--
Gitblit v1.8.0