From c6cb57f307b0c62a05cac78cfd828c313f10e611 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期二, 15 四月 2025 10:58:25 +0800
Subject: [PATCH] 1、卧式理片笼新增任务逻辑 2、入参时间加入时区

---
 hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/hollow/service/impl/HollowGlassOutRelationInfoServiceImpl.java |  118 ++++++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 97 insertions(+), 21 deletions(-)

diff --git a/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/hollow/service/impl/HollowGlassOutRelationInfoServiceImpl.java b/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/hollow/service/impl/HollowGlassOutRelationInfoServiceImpl.java
index 5099eb5..14d0ff2 100644
--- a/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/hollow/service/impl/HollowGlassOutRelationInfoServiceImpl.java
+++ b/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/hollow/service/impl/HollowGlassOutRelationInfoServiceImpl.java
@@ -1,8 +1,10 @@
 package com.mes.hollow.service.impl;
 
 import cn.hutool.core.collection.CollectionUtil;
+import cn.smallbun.screw.core.util.StringUtils;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.mes.common.config.Const;
 import com.mes.glassinfo.entity.GlassInfo;
@@ -12,6 +14,7 @@
 import com.mes.hollow.entity.HollowFormulaDetails;
 import com.mes.hollow.entity.HollowGlassOutRelationInfo;
 import com.mes.hollow.entity.dto.*;
+import com.mes.hollow.entity.request.HollowHistoryTaskRequest;
 import com.mes.hollow.entity.request.HollowTaskRequest;
 import com.mes.hollow.mapper.HollowGlassOutRelationInfoMapper;
 import com.mes.hollow.service.HollowBigStorageCageDetailsService;
@@ -20,6 +23,8 @@
 import com.mes.hollow.service.HollowGlassRelationInfoService;
 import com.mes.hollowqueue.entity.HollowGlassQueueInfo;
 import com.mes.hollowqueue.service.HollowGlassQueueInfoService;
+import com.mes.largenscreen.entity.PieChartVO;
+import com.mes.tools.DateUtil;
 import com.mes.utils.Blank;
 import com.mes.utils.RedisUtil;
 import freemarker.template.Configuration;
@@ -28,6 +33,7 @@
 import freemarker.template.Version;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -59,6 +65,12 @@
 
     @Resource
     RedisUtil redisUtil;
+
+    @Value("${mes.glassGap}")
+    private Integer glassGap;
+
+    @Value("${mes.carWidth}")
+    private Integer carWidth;
 
     private static final int ID_RATIO = 10;
 
@@ -119,6 +131,7 @@
         return this.update(new LambdaUpdateWrapper<HollowGlassOutRelationInfo>()
                 .set(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_START)
                 .eq(HollowGlassOutRelationInfo::getFlowCardId, flowCardId)
+                .ne(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_SUCCESS)
                 .eq(HollowGlassOutRelationInfo::getCell, cell));
     }
 
@@ -128,6 +141,7 @@
         return this.update(new LambdaUpdateWrapper<HollowGlassOutRelationInfo>()
                 .set(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_PAUSE)
                 .eq(HollowGlassOutRelationInfo::getFlowCardId, flowCardId)
+                .ne(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_SUCCESS)
                 .eq(HollowGlassOutRelationInfo::getCell, cell));
     }
 
@@ -200,14 +214,16 @@
 
         //璁剧疆鏂囦欢绗竴灞傚垪琛ㄦ暟鎹�
         //鏆傛椂鐢熸垚绗煎唴鎵�鏈夌殑鐜荤拑淇℃伅锛堝凡閰嶅鍜屾湭閰嶅鐨勶級
-//        List<HollowGlassRelationInfo> hollowGlassRelationInfos = hollowGlassRelationInfoService.list(new LambdaQueryWrapper<HollowGlassRelationInfo>()
-//                .eq(HollowGlassRelationInfo::getFlowCardId, flowCardId).orderByAsc(HollowGlassRelationInfo::getHollowSequence));
         List<HollowBigStorageCageDetails> hollowGlassRelationInfos = hollowBigStorageCageDetailsService.queryPairGlassList(flowCardId, relationInfo.getTotalLayer(), relationInfo.getTotalPairQuantity(), isOut);
-        Map<Integer, List<HollowBigStorageCageDetails>> listMap = hollowGlassRelationInfos.stream().collect(Collectors.groupingBy(HollowBigStorageCageDetails::getHollowSequence));
-
+        Map<Integer, List<HollowBigStorageCageDetails>> listMap = hollowGlassRelationInfos.stream()
+                .collect(Collectors.groupingBy(HollowBigStorageCageDetails::getHollowSequence,
+                        Collectors.collectingAndThen(Collectors.toList(),
+                                list -> list.stream().sorted(Comparator.comparing(HollowBigStorageCageDetails::getLayer)).collect(Collectors.toList()))));
+        Map<Integer, List<HollowBigStorageCageDetails>> sortListMap = new TreeMap<>();
+        sortListMap.putAll(listMap);
         //璁剧疆闂撮殧鏉挎暟鎹叡鎵�鏈夐厤瀵圭幓鐠冧娇鐢�
         List<LisecHollowGlassAndFrameDetails> glassAndFrameList = new ArrayList<>();
-        listMap.forEach((e, v) -> {
+        sortListMap.forEach((e, v) -> {
             LisecHollowGlassAndFrameDetails glassAndFrame = new LisecHollowGlassAndFrameDetails();
             List<LisecHollowGlassDetails> glassList = new ArrayList<>();
             List<LisecHollowFrameDetails> frameList = new ArrayList<>();
@@ -269,8 +285,6 @@
             glassAndFrameList.add(glassAndFrame);
         });
         details.setGlassAndFrameList(glassAndFrameList);
-
-
         Configuration cfg = new Configuration(new Version("2.3.29"));
         cfg.setClassForTemplateLoading(HollowBigStorageCageController.class, "/templates/");
         // 鍒涘缓Calculator瀹炰緥
@@ -297,6 +311,23 @@
             e.printStackTrace();
         }
         return "success";
+    }
+
+    @Override
+    public Page<HollowGlassOutRelationInfo> queryHollowHistoryTask(HollowHistoryTaskRequest request) {
+        Page<HollowGlassOutRelationInfo> page = new Page<>(request.getPageNo(), request.getPageSize());
+        if (null == request.getBeginDate()) {
+            request.setBeginDate(DateUtil.getBeginDate());
+            request.setEndDate(DateUtil.getEndDate());
+        }
+        LambdaQueryWrapper<HollowGlassOutRelationInfo> wrapper = new LambdaQueryWrapper<HollowGlassOutRelationInfo>()
+                .eq(HollowGlassOutRelationInfo::getCell, request.getCell())
+                .like(StringUtils.isNotBlank(request.getFlowCardId()), HollowGlassOutRelationInfo::getFlowCardId, request.getFlowCardId())
+                .in(CollectionUtil.isNotEmpty(request.getIsForceList()), HollowGlassOutRelationInfo::getIsForce, request.getIsForceList())
+                .in(CollectionUtil.isNotEmpty(request.getStateList()), HollowGlassOutRelationInfo::getState, request.getStateList())
+                .between(HollowGlassOutRelationInfo::getCreateTime, request.getBeginDate(), request.getEndDate())
+                .orderByDesc(HollowGlassOutRelationInfo::getCreateTime);
+        return this.page(page, wrapper);
     }
 
 
@@ -328,20 +359,49 @@
                 .queryOutGlassList(request.getFlowCardId(), request.getCell());
         int isPairCount = glassInfo.getTotalLayer() * request.getTotalPairQuantity();
         List<HollowGlassQueueInfo> hollowQueues = new ArrayList<>();
-        loop:
-        for (HollowBigStorageCageDetails queue : hollowBigStorageCageDetailsList) {
-            HollowGlassQueueInfo queueInfo = new HollowGlassQueueInfo();
-            BeanUtils.copyProperties(queue, queueInfo);
-            queueInfo.setRelationId(info.getId());
-            queueInfo.setState(Const.TEMPERING_NEW);
-            queueInfo.setCell(request.getCell());
-            queueInfo.setCreateTime(new Date());
-            queueInfo.setUpdateTime(new Date());
-            hollowQueues.add(queueInfo);
-            if (queue.getIsPair() == 1) {
-                isPairCount -= 1;
-                if (isPairCount == 0) {
-                    break loop;
+
+        if (930 == request.getCell()) {
+            Map<Integer, List<HollowBigStorageCageDetails>> listMap = hollowBigStorageCageDetailsList.stream()
+                    .collect(Collectors.groupingBy(HollowBigStorageCageDetails::getHollowSequence));
+            Map<Integer, List<HollowBigStorageCageDetails>> sortListMap = new TreeMap<>();
+            sortListMap.putAll(listMap);
+            for (Map.Entry<Integer, List<HollowBigStorageCageDetails>> entry : sortListMap.entrySet()) {
+                //鍒涘缓闃熷垪鎺ユ敹涓嶆弧瓒虫垚瀵规儏鍐典笅锛氫竴瀵圭幓鐠冨垎鍑犳涓婅溅鐨勬搴忛棶棰�
+                List<HollowGlassQueueInfo> tempList = new ArrayList<>();
+                //鍏堝皢鐜荤拑鎸夌収姝e父椤哄簭鎺掑垪锛岃绠椾竴杞︽渶澶氭斁鍑犲潡锛岀畻濂藉潡鏁颁箣鍚庡皢涓�杞︾殑鐜荤拑鎸夌収鍊掑簭瀛樺偍
+                List<HollowBigStorageCageDetails> reverse = CollectionUtil.reverse(entry.getValue());
+                int remainWidth = carWidth;
+                for (HollowBigStorageCageDetails item : reverse) {
+                    remainWidth = remainWidth - (int) Math.max(item.getWidth(), item.getHeight());
+                    if (remainWidth < 0) {
+                        hollowQueues.addAll(CollectionUtil.reverse(tempList));
+                        tempList = new ArrayList<>();
+                        remainWidth = carWidth - (int) Math.max(item.getWidth(), item.getHeight());
+                    }
+                    HollowGlassQueueInfo queueInfo = HollowBDetailToQueue(item, info.getId(), request.getCell());
+                    tempList.add(queueInfo);
+                    remainWidth = remainWidth - glassGap;
+                }
+                hollowQueues.addAll(CollectionUtil.reverse(tempList));
+                HollowBigStorageCageDetails cageDetails = entry.getValue().get(0);
+                if (cageDetails.getIsPair() == 1) {
+                    isPairCount = isPairCount - cageDetails.getTotalLayer();
+                    if (isPairCount == 0) {
+                        break;
+                    }
+                }
+            }
+
+        } else {
+            loop:
+            for (HollowBigStorageCageDetails item : hollowBigStorageCageDetailsList) {
+                HollowGlassQueueInfo queueInfo = HollowBDetailToQueue(item, info.getId(), request.getCell());
+                hollowQueues.add(queueInfo);
+                if (item.getIsPair() == 1) {
+                    isPairCount = isPairCount - 1;
+                    if (isPairCount == 0) {
+                        break loop;
+                    }
                 }
             }
         }
@@ -355,5 +415,21 @@
         }
         return info;
     }
+
+    private HollowGlassQueueInfo HollowBDetailToQueue(HollowBigStorageCageDetails details, Long taskId, int targetCell) {
+        HollowGlassQueueInfo queueInfo = new HollowGlassQueueInfo();
+        BeanUtils.copyProperties(details, queueInfo);
+        queueInfo.setRelationId(taskId);
+        queueInfo.setState(Const.TEMPERING_NEW);
+        queueInfo.setCell(targetCell);
+        queueInfo.setCreateTime(new Date());
+        queueInfo.setUpdateTime(new Date());
+        return queueInfo;
+    }
+
+    @Override
+    public List<PieChartVO> queryPieChart(){
+        return baseMapper.queryPieChart();
+    }
 }
 

--
Gitblit v1.8.0