杭州利来项目
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
wu
2024-12-23 164cb74e2c471321caf9c4870de846cf08ca5f6c 
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java


@@ -2,10 +2,12 @@




import cn.hutool.core.lang.Assert;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;


import com.github.yulichang.base.MPJBaseServiceImpl;


import com.github.yulichang.toolkit.JoinWrappers;


import com.github.yulichang.wrapper.MPJLambdaWrapper;


import com.mes.base.entity.BigStorageCageBaseInfo;


import com.mes.bigstorage.entity.BigStorageCage;


import com.mes.bigstorage.entity.BigStorageCageDetails;


import com.mes.bigstorage.entity.BigStorageDTO;


@@ -19,6 +21,7 @@


import com.mes.bigstoragetask.entity.UpdateBigStorageCageDTO;


import com.mes.bigstoragetask.mapper.BigStorageCageFeedTaskMapper;


import com.mes.bigstoragetask.mapper.BigStorageCageOutTaskMapper;


import com.mes.bigstoragetask.service.BigStorageCageOutTaskService;


import com.mes.common.config.Const;


import com.mes.damage.entity.Damage;


import com.mes.damage.service.DamageService;


@@ -36,10 +39,7 @@


import org.springframework.stereotype.Service;




import javax.annotation.Resource;


import java.util.ArrayList;


import java.util.Iterator;


import java.util.List;


import java.util.Map;


import java.util.*;


import java.util.stream.Collectors;




/**


@@ -78,6 +78,10 @@


    private DamageService damageService;


    @Resource


    private RedisUtil redisUtil;


    @Resource


    private BigStorageCageOutTaskService bigStorageCageOutTaskService;


    @Resource


    private BigStorageCageDetailsService bigStorageCageDetailsService;




    @Value("${mes.minCount}")


    private int minCount;


@@ -467,4 +471,60 @@


    public void appointEngineerId(String engineerId) {


        redisUtil.setCacheObject("temperingengineerId", engineerId);


    }




    @Override


    public long scheduleTime() {


        //执行内部调度任务


        List<TemperingLayoutDTO> temperingOccupySlotList = bigStorageCageDetailsService.queryTemperingOccupySlot();


        List<BigStorageCageOutTask> bigStorageCageOutTasks = new ArrayList<>();


        if (CollectionUtils.isNotEmpty(temperingOccupySlotList)) {


            for (TemperingLayoutDTO temperingOccupySlot : temperingOccupySlotList) {


                List<GlassInfo> glassInfos = glassInfoService.list(


                        new LambdaQueryWrapper<GlassInfo>()


                                .eq(GlassInfo::getEngineerId, temperingOccupySlot.getEngineerId())


                                .eq(GlassInfo::getTemperingLayoutId, temperingOccupySlot.getTemperingLayoutId())


                                .notInSql(GlassInfo::getGlassId, "select glass_id from damage where type=8 and engineer_id='"


                                        + temperingOccupySlot.getEngineerId() + "' and tempering_layout_id = '" + temperingOccupySlot.getTemperingLayoutId() + "'")


                                .orderBy(Boolean.TRUE, sequenceOrder, GlassInfo::getTemperingFeedSequence)


                );


                Map<Integer, List<GlassInfo>> listMap = glassInfos.stream().collect(Collectors.groupingBy(item -> item.getTargetSlot()));


                for (Map.Entry<Integer, List<GlassInfo>> entry : listMap.entrySet()) {


                    List<GlassInfo> valueList = entry.getValue();


                    List<String> glassIds = valueList.stream().map(GlassInfo::getGlassId).collect(Collectors.toList());


                    List<BigStorageCageDetails> bigStorageCageDetailsList = bigStorageCageDetailsService.list(


                            new LambdaQueryWrapper<BigStorageCageDetails>()


                                    .in(BigStorageCageDetails::getGlassId, glassIds)


                                    .eq(BigStorageCageDetails::getState, Const.GLASS_STATE_IN)


                                    .orderBy(Boolean.TRUE, sequenceOrder, BigStorageCageDetails::getTemperingFeedSequence)


                    );


                    //当一格玻璃都到齐时


                    if (bigStorageCageDetailsList.size() == valueList.size()) {


                        long distinctSlotCount = bigStorageCageDetailsList.stream()


                                .map(BigStorageCageDetails::getSlot)


                                .distinct()


                                .count();


                        //当玻璃不在同一格时


                        if (distinctSlotCount > 1) {


                            BigStorageCageDetails maxSequenceDetail = bigStorageCageDetailsList.stream()


                                    .max(Comparator.comparingInt(BigStorageCageDetails::getTemperingFeedSequence))


                                    .orElse(null);  // 如果没有元素，返回 null


                            int maxSlot = maxSequenceDetail.getSlot();


                            int serialNumber = 1;


                            for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList


                            ) {


                                if (bigStorageCageDetails.getSlot() != maxSlot) {


                                    bigStorageCageOutTasks.add(new BigStorageCageOutTask(bigStorageCageDetails.getGlassId(), bigStorageCageDetails.getSlot(), maxSlot,


                                            bigStorageCageDetails.getWidth() * 10, bigStorageCageDetails.getHeight() * 10, 1, serialNumber++, Const.BIG_STORAGE_OUT_NEW, new Date()));


                                }


                            }


                        }


                    }


                }


            }


        }


        long startSlotCount = bigStorageCageOutTasks.stream().map(BigStorageCageOutTask::getStartSlot).distinct().count();


        long endSlotCount = bigStorageCageOutTasks.stream().map(BigStorageCageOutTask::getEndSlot).distinct().count();


        long time = (startSlotCount * 10 + endSlotCount * 20) / 60;


        return time;


    }


}