package com.mes.job.opccallback;

import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.kangaroohy.milo.runner.subscription.SubscriptionCallback;
import com.mes.common.config.Const;
import com.mes.edgglasstask.service.EdgGlassTaskInfoService;
import com.mes.edgstoragecage.entity.EdgStorageCage;
import com.mes.edgstoragecage.entity.EdgStorageCageDetails;
import com.mes.edgstoragecage.service.EdgStorageCageDetailsService;
import com.mes.edgstoragecage.service.EdgStorageCageService;
import com.mes.glassinfo.entity.GlassInfo;
import com.mes.glassinfo.service.GlassInfoService;
import com.mes.opctask.entity.EdgStorageDeviceTask;
import com.mes.opctask.entity.EdgStorageDeviceTaskHistory;
import com.mes.opctask.service.EdgStorageDeviceTaskHistoryService;
import com.mes.opctask.service.EdgStorageDeviceTaskService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

/**
 * @Author : zhoush
 * @Date: 2024/10/10 14:13
 * @Description:
 */
@Service
@Slf4j
public class CacheGlassStartCallback implements SubscriptionCallback {

    private static final String EDG_STORAGE_DEVICE_ONE_TASK = "edg_storage_device_one_task";

    private static final String EDG_STORAGE_DEVICE_TWO_TASK = "edg_storage_device_two_task";

    @Resource
    EdgStorageDeviceTaskService edgStorageDeviceTaskService;
    @Resource
    GlassInfoService glassInfoService;
    @Resource
    EdgStorageCageDetailsService edgStorageCageDetailsService;
    @Resource
    EdgStorageCageService edgStorageCageService;
    @Resource
    EdgStorageDeviceTaskHistoryService edgStorageDeviceTaskHistoryService;

    @Resource
    EdgGlassTaskInfoService edgGlassTaskInfoService;

    @Value("${mes.glassGap}")
    private int glassGap;
    @Value("${mes.threshold}")
    private int threshold;
    @Value("${mes.cellLength}")
    private int cellLength;

    private Date startDate;

    @Override
    public void onSubscribe(String identifier, Object value) {

//        log.info("当前正在执行的任务为{}", value);
//        String tableName = identifier.contains("edg_storage_device_one_task") ? EDG_STORAGE_DEVICE_ONE_TASK : EDG_STORAGE_DEVICE_TWO_TASK;
//        int device = tableName.equals("edg_storage_device_one_task") ? 1 : 2;
//        EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(tableName);
//        try {
//            if (task == null) {
//                log.info("任务表基础数据录入失败，请检查数据是否录入成功");
//                return;
//            }
//            if (task.getTaskState() == 2) {
//                //防止出片任务且笼前有玻璃的情况，将进片id置空，即出片仅考虑笼内的玻璃
//                task.setGlassIdIn("");
//            }
//            int request = Integer.parseInt("" + value);
//            log.info("开始执行任务，任务请信息为{}", task);
//            if (request == 0) {
//                log.info("未收到任务请求，结束本次任务");
//            } else if (request == 1) {
//                //进片任务
//                log.info("进片任务：进片玻璃id为：{}", task.getGlassIdIn());
//                intoTask(task, tableName, device);
//            } else if (request == 2) {
//                //出片任务
//                outTask(task, tableName, device);
//            } else if (request == 3) {
//                //直通任务
//                if (!outTask(task, tableName, device)) {
//                    intoTask(task, tableName, device);
//                }
//            } else if (request == 4) {
//                log.info("将启动子改为0");
//                task.setTaskRunning(Const.GLASS_CACHE_TYPE_RUNNING);
//                edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
//            } else {
//                finishTask(task, tableName);
//            }
//        } catch (Exception e) {
//            log.info("执行任务过程中发生异常，任务字{}，{}", task.getTaskState(), e.getMessage());
//            log.info("将启动子改为0");
//            task.setTaskState(Const.GLASS_CACHE_TYPE_EMPTY);
//            edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
//        }
    }

    private boolean intoTask(EdgStorageDeviceTask task, String tableName, int deviceId) {
//        //获取玻璃的基本信息
//        GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, task.getGlassIdIn()));
//        if (null == glassInfo) {
//            log.info("进片玻璃信息不存在，玻璃id:{}", task.getGlassIdIn());
//            return Boolean.FALSE;
//        }
//        //获取当前进片玻璃id和进片格子  相同尺寸可以放下的格子
//        EdgStorageCage edgStorageCage = edgStorageCageService.getEdgStorageCageBySize(deviceId, glassInfo.getWidth(), glassInfo.getHeight(), task.getCurrentCell());
//        if (edgStorageCage == null) {
//            log.info("相同尺寸可以放下的格子未找到，格子id:{}", task.getCurrentCell());
////            SELECT * from edg_storage_cage where device_id = 1 and remain_width > 1000 order by abs(slot - 10)
//            List<EdgStorageCage> storageCageList = edgStorageCageService.list(new LambdaQueryWrapper<EdgStorageCage>()
//                    .eq(EdgStorageCage::getDeviceId, deviceId)
//                    .eq(EdgStorageCage::getEnableState, Const.SLOT_ON)
//                    .ge(EdgStorageCage::getRemainWidth, Math.max(glassInfo.getWidth(), glassInfo.getHeight())).last("order by abs(slot - " + task.getCurrentCell() + ")"));
////            //直通任务
////            if (flag && CollectionUtil.isNotEmpty(emptyList)) {
////                return emptyList.get(0);
////            }
//            if (CollectionUtil.isEmpty(storageCageList) || storageCageList.size() == 1) {
//                log.info("没有多余的空格子");
//                return Boolean.FALSE;
//            }
//            edgStorageCage = storageCageList.get(0);
//        }
//        log.info("4、将玻璃信息插入卧式理片笼,当前玻璃信息:{}", glassInfo);
//        EdgStorageCageDetails details = new EdgStorageCageDetails();
//        BeanUtils.copyProperties(glassInfo, details);
//        details.setState(Const.GLASS_STATE_IN);
//        details.setSlot(edgStorageCage.getSlot());
//        details.setDeviceId(edgStorageCage.getDeviceId());
//        edgStorageCageDetailsService.save(details);
//
//        //更新任务信息
//        task.setStartCell(edgStorageCage.getSlot());
//        task.setTaskRunning(Const.GLASS_CACHE_TYPE_IN);
//        edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
//        saveHistoryTask(task);
        return Boolean.TRUE;
    }

    private boolean outTask(EdgStorageDeviceTask task, String tableName, int deviceId) {
//        EdgStorageCageDetails edgStorageCageDetails = null;
//        //笼内是版图相差是否超过阈值
//        boolean flag = queryMaxMinDiff(threshold);
//        if (flag) {
//            EdgStorageCageDetails minEdgDetails = edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>()
//                    .inSql(EdgStorageCageDetails::getSlot, "select slot from edg_storage_cage where enable_state = " + Const.SLOT_ON)
//                    .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN)
//                    .eq(EdgStorageCageDetails::getDeviceId, deviceId)
//                    .orderByAsc(EdgStorageCageDetails::getTemperingLayoutId)
//                    .orderBy(Boolean.TRUE, Boolean.TRUE, EdgStorageCageDetails::getTemperingFeedSequence)
//                    .last("limit 1"));
////            select * from edg_storage_cage_details where width = 551 and height = 1151 and id in (select min(id ) from edg_storage_cage_details where state = 100 group by slot )
//            edgStorageCageDetails = edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>()
//                    .eq(EdgStorageCageDetails::getWidth, minEdgDetails.getWidth())
//                    .eq(EdgStorageCageDetails::getHeight, minEdgDetails.getHeight())
//                    .eq(EdgStorageCageDetails::getDeviceId, deviceId)
//                    .inSql(EdgStorageCageDetails::getId, "select min(id) from edg_storage_cage_details where state = 100 group by slot ")
//                    .last("order by abs(slot - " + task.getCurrentCell() + ")  asc limit 1")
//            );
//            //给直通任务
//            if (null == edgStorageCageDetails && StringUtils.isNotBlank(task.getGlassIdIn())) {
//                GlassInfo glassInInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>()
//                        .eq(GlassInfo::getGlassId, task.getGlassIdIn())
//                        .eq(GlassInfo::getWidth, minEdgDetails.getWidth())
//                        .eq(GlassInfo::getHeight, minEdgDetails.getHeight()));
//                if (null != glassInInfo) {
//                    edgStorageCageDetails = new EdgStorageCageDetails();
//                    BeanUtils.copyProperties(glassInInfo, edgStorageCageDetails);
//                }
//            }
//            if (null == edgStorageCageDetails) {
//                edgStorageCageDetails = edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>()
//                        .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN)
//                        .eq(EdgStorageCageDetails::getDeviceId, deviceId)
//                        .eq(EdgStorageCageDetails::getSlot, minEdgDetails.getSlot())
//                        .orderByAsc(EdgStorageCageDetails::getId)
//                        .last("limit 1")
//                );
//            }
//        }
//        if (null == edgStorageCageDetails) {
//            //        获取上次任务
////        获取历史表中上次任务最后一片尺寸
//            EdgStorageDeviceTaskHistory edgeData = edgStorageDeviceTaskHistoryService.getOne(new LambdaQueryWrapper<EdgStorageDeviceTaskHistory>()
//                    .eq(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_SUCCESS)
//                    .in(EdgStorageDeviceTaskHistory::getTaskType, Const.GLASS_CACHE_TYPE_OUT, Const.GLASS_CACHE_TYPE_THROUGH)
//                    .orderByDesc(EdgStorageDeviceTaskHistory::getId).last("limit 1"));
//            if (null != edgeData) {
//                GlassInfo glassOutInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, edgeData.getGlassIdOut()));
//                //笼内的玻璃的尺寸是否和上一次任务一致
//                edgStorageCageDetails = edgStorageCageDetailsService.queryEdgStorageDetailsBySize(deviceId, task.getCurrentCell(), glassOutInfo.getWidth(), glassOutInfo.getHeight());
//                if (null == edgStorageCageDetails && StringUtils.isNotBlank(task.getGlassIdIn())) {
//                    GlassInfo glassInInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>()
//                            .eq(GlassInfo::getGlassId, task.getGlassIdIn())
//                            .eq(GlassInfo::getWidth, glassOutInfo.getWidth())
//                            .eq(GlassInfo::getHeight, glassOutInfo.getHeight()));
//                    if (null != glassInInfo) {
//                        edgStorageCageDetails = new EdgStorageCageDetails();
//                        BeanUtils.copyProperties(glassInInfo, edgStorageCageDetails);
//                    }
//                }
//            }
//        }
//        if (null == edgStorageCageDetails) {
//            edgStorageCageDetails = edgStorageCageDetailsService.queryEdgStorageDetailsBySize(deviceId, task.getCurrentCell(), 0, 0);
//        }
//        if (edgStorageCageDetails == null && StringUtils.isNotBlank(task.getGlassIdIn())) {
//            //和上次任务不存在相同尺寸
//            GlassInfo glassInInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, task.getGlassIdIn()));
//            edgStorageCageDetails = new EdgStorageCageDetails();
//            BeanUtils.copyProperties(glassInInfo, edgStorageCageDetails);
//        }
//        if (edgStorageCageDetails == null) {
//            //和上次任务不存在相同尺寸
//            log.info("笼内没有玻璃了");
//            return Boolean.FALSE;
//        }
//        int taskType = Const.GLASS_CACHE_TYPE_OUT;
//        String glassId = edgStorageCageDetails.getGlassId();
//        if (glassId.equals(task.getGlassIdIn())) {
//            if (3 != task.getTaskState()) {
//                return Boolean.FALSE;
//            }
//            log.info("5、直通任务,将玻璃信息插入卧式理片笼,当前玻璃信息:{}", edgStorageCageDetails);
//            //玻璃信息替换
//            String glassIdChange = queryAndChangeGlass(glassId);
//            //处理在卧理内的玻璃信息：笼内的数据处理
//            queryEdgAndChangeGlass(edgStorageCageDetails.getGlassId(), glassIdChange);
//            if (StringUtils.isNotBlank(glassIdChange)) {
//                edgStorageCageDetails = new EdgStorageCageDetails();
//                GlassInfo one = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId));
//                BeanUtils.copyProperties(one, edgStorageCageDetails);
//            }
//            EdgStorageCage storageCage = edgStorageCageService.getOne(new LambdaQueryWrapper<EdgStorageCage>()
//                    .eq(EdgStorageCage::getDeviceId, deviceId)
//                    .eq(EdgStorageCage::getEnableState, Const.SLOT_ON)
//                    .ge(EdgStorageCage::getRemainWidth, cellLength)
//                    .last("order by abs(slot - " + task.getCurrentCell() + ") limit 1"));
//            Assert.isTrue(null != storageCage, "格子已满,无法执行直通任务");
//            log.info("3、查询卧式理片笼里面的空格:{}", storageCage);
//            edgStorageCageDetails.setSlot(storageCage.getSlot());
//            edgStorageCageDetails.setDeviceId(storageCage.getDeviceId());
//            edgStorageCageDetails.setState(Const.GLASS_STATE_OUT);
//            edgStorageCageDetailsService.save(edgStorageCageDetails);
//            taskType = Const.GLASS_CACHE_TYPE_THROUGH;
//        } else {
//            log.info("5、非直通任务,将玻璃信息插入卧式理片笼,当前玻璃信息:{}", edgStorageCageDetails);
//            if (!edgStorageCageDetails.getSlot().equals(task.getCurrentCell())) {
//                EdgStorageCageDetails currentGlass = edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>()
//                        .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN)
//                        .eq(EdgStorageCageDetails::getDeviceId, deviceId)
//                        .eq(EdgStorageCageDetails::getSlot, task.getCurrentCell()).eq(EdgStorageCageDetails::getWidth, edgStorageCageDetails.getWidth())
//                        .eq(EdgStorageCageDetails::getHeight, edgStorageCageDetails.getHeight()).eq(EdgStorageCageDetails::getThickness, edgStorageCageDetails.getThickness())
//                        .orderByAsc(EdgStorageCageDetails::getId).last("limit 1")
//                );
//                if (null != currentGlass) {
//                    edgStorageCageDetails = currentGlass;
//                }
//            }
//            //玻璃信息替换
//            String glassIdChange = queryAndChangeGlass(edgStorageCageDetails.getGlassId());
//            //处理在卧理内的玻璃信息：笼内的数据处理
//            queryEdgAndChangeGlass(edgStorageCageDetails.getGlassId(), glassIdChange);
//            LambdaUpdateWrapper<EdgStorageCageDetails> wrapper = new LambdaUpdateWrapper<>();
//            wrapper.eq(EdgStorageCageDetails::getGlassId, edgStorageCageDetails.getGlassId()).set(EdgStorageCageDetails::getState, Const.GLASS_STATE_OUT);
//            edgStorageCageDetailsService.update(wrapper);
//            log.info("5、更新出片玻璃的状态为{}", Const.GLASS_STATE_OUT);
//        }
//        //生成出片任务
//        task.setGlassIdOut(edgStorageCageDetails.getGlassId());
//        task.setStartCell(edgStorageCageDetails.getSlot());
//        task.setTaskRunning(taskType);
//
//        edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
//        saveHistoryTask(task);
//        //更新详情表任务出片中
//        edgStorageCageDetailsService.update(new LambdaUpdateWrapper<EdgStorageCageDetails>()
//                .set(EdgStorageCageDetails::getState, Const.GLASS_STATE_OUT)
//                .eq(EdgStorageCageDetails::getGlassId, edgStorageCageDetails.getGlassId()));
//        //磨边对列表新增一条数据
//        EdgGlassTaskQueueInfo edgInfo = new EdgGlassTaskQueueInfo();
//        BeanUtils.copyProperties(task, edgInfo);
//        edgInfo.setCreateTime(new Date());
//        edgInfo.setWidth((int) edgStorageCageDetails.getWidth());
//        edgInfo.setHeight((int) edgStorageCageDetails.getWidth());
//        edgInfo.setThickness((int) edgStorageCageDetails.getWidth());
//        edgInfo.setState(Const.GLASS_STATE_NEW);
//        edgGlassTaskQueueInfoService.save(edgInfo);
        return Boolean.TRUE;
    }

    private boolean finishTask(EdgStorageDeviceTask task, String tableName) {
//        log.info("当前任务信息为：{}", task);
//        if (task.getTaskState() <= 4) {
//            log.info("有正在执行的任务，结束");
//            return Boolean.FALSE;
//        }
//        Integer cell = task.getStartCell();
//        Integer state = task.getTaskState();
//        task.setTaskRunning(Const.GLASS_CACHE_TYPE_EMPTY);
//        task.setGlassIdOut("");
//        task.setStartCell(0);
//        edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
//        edgStorageDeviceTaskHistoryService.update(new LambdaUpdateWrapper<EdgStorageDeviceTaskHistory>()
//                .eq(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_NEW)
//                .set(EdgStorageDeviceTaskHistory::getTaskState,
//                        Const.GLASS_CACHE_TYPE_FINISH.equals(state) ? Const.RAW_GLASS_TASK_SUCCESS : Const.RAW_GLASS_TASK_FAILURE)
//        );
//        int device = tableName.equals("edg_storage_device_one_task") ? 1 : 2;
//        updateCellRemainWidth(cell, device);
        return Boolean.TRUE;
    }

    /**
     * 查询玻璃并进行交换
     *
     * @param glassId
     * @return
     */
    public String queryAndChangeGlass(String glassId) {
//        GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId));
////                .inSql(GlassInfo::getEngineerId, "select engineer_id from engineering where state = 1"));
//        Assert.isFalse(null == glassInfo, "玻璃信息不存在");        //按照玻璃尺寸
//        LambdaQueryWrapper<GlassInfo> queryWrapper = new LambdaQueryWrapper<GlassInfo>()
//                .eq(GlassInfo::getWidth, glassInfo.getWidth())
//                .eq(GlassInfo::getHeight, glassInfo.getHeight())
//                .eq(GlassInfo::getThickness, glassInfo.getThickness())
//                .eq(GlassInfo::getFilmsid, glassInfo.getFilmsid())
//                .eq(GlassInfo::getFlowCardId, glassInfo.getFlowCardId())
//                .eq(GlassInfo::getTotalLayer, glassInfo.getTotalLayer())
//                .eq(GlassInfo::getLayer, glassInfo.getLayer())
//                .eq(GlassInfo::getEngineerId, glassInfo.getEngineerId())
//                .notInSql(GlassInfo::getGlassId, "select distinct glass_id from edg_storage_cage_details " +
//                        "where engineer_id = '" + glassInfo.getEngineerId() + "' and width = " + glassInfo.getWidth() + " and height = " + glassInfo.getHeight()
//                        + " and state != 100")
//                .orderByAsc(GlassInfo::getTemperingLayoutId)
//                .orderBy(Boolean.TRUE, Boolean.TRUE, GlassInfo::getTemperingFeedSequence)
//                .last("Limit 1");
//        GlassInfo swapGlassInfo = glassInfoService.getOne(queryWrapper);
//        if (swapGlassInfo != null && !glassInfo.getGlassId().equals(swapGlassInfo.getGlassId())) {
//            String swapGlassId = swapGlassInfo.getGlassId();
//            log.info("将玻璃{}和玻璃{}，信息互换,进玻璃 {}", glassInfo, swapGlassInfo, swapGlassInfo);
//            swapGlassInfo.setGlassId(glassId);
//            glassInfo.setGlassId(swapGlassId);
//            glassInfoService.updateById(swapGlassInfo);
//            glassInfoService.updateById(glassInfo);
//            return swapGlassId;
//        }
        return "";
    }


    /**
     * 查询卧式理片玻璃并进行交换
     *
     * @param glassId
     * @return
     */
    public void queryEdgAndChangeGlass(String glassId, String swapGlassId) {
        if (StringUtils.isBlank(swapGlassId)) {
            log.info("当前出笼玻璃不存在需要替换的玻璃");
            return;
        }
        //获取待出笼的玻璃
        EdgStorageCageDetails glassInfo = edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>()
                .eq(EdgStorageCageDetails::getGlassId, glassId).eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN));
//        获取待出笼的玻璃需要替换的玻璃信息
        EdgStorageCageDetails swapGlassDetailInfo = edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>()
                .eq(EdgStorageCageDetails::getGlassId, swapGlassId).eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN));

//      玻璃小片表中玻璃已经替换，更新卧理笼内现有的准备出笼的玻璃信息，
        if (null == swapGlassDetailInfo) {
            GlassInfo glassInfoBase = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>()
                    .eq(GlassInfo::getGlassId, glassId));
            //需要替换的玻璃为存进卧理，仅需更新当前需要出笼的玻璃信息即可
            edgStorageCageDetailsService.update(new LambdaUpdateWrapper<EdgStorageCageDetails>()
                    .eq(EdgStorageCageDetails::getGlassId, glassId)
                    .set(EdgStorageCageDetails::getTemperingLayoutId, glassInfoBase.getTemperingLayoutId())
                    .set(EdgStorageCageDetails::getTemperingFeedSequence, glassInfoBase.getTemperingFeedSequence()));
        } else {
            //需要替换的玻璃都在卧理内，按照玻璃id对调玻璃信息：对调玻璃id即可
            edgStorageCageDetailsService.update(new LambdaUpdateWrapper<EdgStorageCageDetails>()
                    .eq(EdgStorageCageDetails::getId, glassInfo.getId())
                    .set(EdgStorageCageDetails::getTemperingLayoutId, swapGlassDetailInfo.getTemperingLayoutId())
                    .set(EdgStorageCageDetails::getTemperingFeedSequence, swapGlassDetailInfo.getTemperingFeedSequence())
            );
            edgStorageCageDetailsService.update(new LambdaUpdateWrapper<EdgStorageCageDetails>()
                    .eq(EdgStorageCageDetails::getId, swapGlassDetailInfo.getId())
                    .set(EdgStorageCageDetails::getTemperingLayoutId, glassInfo.getTemperingLayoutId())
                    .set(EdgStorageCageDetails::getTemperingFeedSequence, glassInfo.getTemperingFeedSequence())
            );
        }
    }

    /**
     * 获取详情表内最大最小版图id的差值，判断是否出最小版图玻璃
     *
     * @return
     */
    public boolean queryMaxMinDiff(int threshold) {
        //获取笼子内最大版图id和最小版图id插值，判断是否大于阈值，大于阈值直接出最小版图玻璃
        QueryWrapper<EdgStorageCageDetails> queryWrapper = new QueryWrapper<>();
        queryWrapper.select("max(tempering_layout_id)-min(tempering_layout_id) as diff")
                .eq("state", Const.GLASS_STATE_IN)
                .inSql("slot", "select slot from edg_storage_cage where enable_state = " + Const.SLOT_ON);
        List<Object> list = edgStorageCageDetailsService.listObjs(queryWrapper);
        //获取笼内玻璃版图差值是否大于阈值
        if (CollectionUtil.isNotEmpty(list)) {
            Long diff = (Long) list.get(0);
            return diff > threshold;
        } else {
            return Boolean.FALSE;
        }
    }

    public boolean saveHistoryTask(EdgStorageDeviceTask task) {
        EdgStorageDeviceTaskHistory taskHistory = new EdgStorageDeviceTaskHistory();
        BeanUtils.copyProperties(task, taskHistory);
        taskHistory.setTaskType(task.getTaskRunning());
        taskHistory.setCreateTime(new Date());
        taskHistory.setTaskState(Const.RAW_GLASS_TASK_NEW);
        edgStorageDeviceTaskHistoryService.save(taskHistory);
        return Boolean.TRUE;
    }

    private boolean updateCellRemainWidth(int slot, int device) {
        List<EdgStorageCageDetails> list = edgStorageCageDetailsService.list(new LambdaQueryWrapper<EdgStorageCageDetails>().eq(EdgStorageCageDetails::getSlot, slot)
                .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN));
        int remainWidth = cellLength;
        if (CollectionUtil.isNotEmpty(list)) {
            int widthTotal = (int) list.stream().map(e -> Math.max(e.getWidth(), e.getHeight()) + glassGap).mapToDouble(Double::intValue).sum();
            remainWidth = cellLength - widthTotal >= 0 ? cellLength - widthTotal : 0;
        }
        edgStorageCageService.update(new LambdaUpdateWrapper<EdgStorageCage>().
                set(EdgStorageCage::getRemainWidth, remainWidth).eq(EdgStorageCage::getSlot, slot).eq(EdgStorageCage::getDeviceId, device));
        return Boolean.TRUE;
    }
}