package com.zy.asrs.task.handler; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.mapper.Wrapper; import com.core.common.Cools; import com.core.exception.CoolException; import com.zy.asrs.entity.BasCrnp; import com.zy.asrs.entity.LocMast; import com.zy.asrs.entity.StaDesc; import com.zy.asrs.entity.WrkMast; import com.zy.asrs.service.BasCrnpService; import com.zy.asrs.service.LocMastService; import com.zy.asrs.service.StaDescService; import com.zy.asrs.service.WrkMastService; import com.zy.asrs.task.AbstractHandler; import com.zy.asrs.task.core.ReturnT; import com.zy.common.model.enums.WorkNoType; import com.zy.common.service.CommonService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.*; /** * Created by Monkey D. Luffy on 2023.07.24 * 徐工汉云..............以下.............上饶江铜.............自动补空板 */ @Slf4j @Service @Transactional public class BareBoardHandler extends AbstractHandler { @Autowired private WrkMastService wrkMastService; @Autowired private LocMastService locMastService; @Autowired private CommonService commonService; @Autowired private StaDescService staDescService; @Autowired private BasCrnpService basCrnpService; public static final List rows1 = new ArrayList() {{ add(1);add(5);add(9);add(13);add(17);add(21); }}; public static final List rows2 = new ArrayList() {{ add(4);add(8);add(12);add(16);add(20);add(24); }}; public ReturnT start(Integer staNo) { try { if (!Cools.isEmpty(wrkMastService.selectOne(new EntityWrapper().eq("io_type", 110).eq("sta_no", staNo)))){ return null; } // 获取工作号 int workNo = commonService.getWorkNo(WorkNoType.PAKOUT.type); ArrayList crns =new ArrayList<>(); crns.add(1); crns.add(2); crns.add(3); crns.add(4); crns.add(5); crns.add(6); ArrayList crnList =new ArrayList<>(); int[] crnCount = new int[6]; for (Integer crnNo : crns){ int crnCountD = locMastService.selectCount(new EntityWrapper().eq("loc_sts", "D").eq("crn_no", crnNo)); crnCount[crnNo-1] = crnCountD; } int[] sortedCrnNos = getSortedCrnNos(crnCount); for (int crnNo : sortedCrnNos){ crnList.add(crnNo); } crnList.add(6); crnList.add(1); crnList.add(4); crnList.add(3); crnList.add(5); crnList.add(2); // List basCrnps = basCrnpService.selectList(new EntityWrapper().eq("crn_sts", 3).eq("out_enable", "Y").eq("wrk_no", 0)); // for (BasCrnp basCrnp : basCrnps){ // crns.add(basCrnp.getCrnNo()); // } boolean sign = true; for (Integer crnNo : crnList){ BasCrnp basCrnp = basCrnpService.selectById(crnNo); if (basCrnp.getCrnSts()!=3 || !basCrnp.getOutEnable().equals("Y")){ continue; } sign = true; // 获取库位 LocMast locMast = locMastService.selectOne(new EntityWrapper().eq("loc_sts","D").eq("crn_no",crnNo)); if (Cools.isEmpty(locMast)) { // throw new CoolException("库中无空板！！！"); sign=false; } if (sign){ if (rows1.contains(locMast.getRow1())){ LocMast locMast1 = locMastService.selectOne(new EntityWrapper().eq("loc_sts", "D").eq("row1", locMast.getRow1() + 1) .eq("bay1", locMast.getBay1()).eq("lev1", locMast.getLev1())); if (!Cools.isEmpty(locMast1)) { locMast = locMast1; } }else if (rows2.contains(locMast.getRow1())){ LocMast locMast1 = locMastService.selectOne(new EntityWrapper().eq("loc_sts", "D").eq("row1", locMast.getRow1() - 1) .eq("bay1", locMast.getBay1()).eq("lev1", locMast.getLev1())); if (!Cools.isEmpty(locMast1)) { locMast = locMast1; } } } if (sign && Cools.isEmpty(locMast)) { // throw new CoolException("库中无空板！！！"); sign=false; } if (sign && !locMast.getLocSts().equals("D")){ // throw new CoolException("所选库位存在状态不为D的库位，库位号："+locMast.getLocNo()+" 、当前状态："+locMast.getLocSts()+"-"+locMast.getLocSts$()); sign=false; } if (sign){ // 获取源站 Wrapper wrapper = new EntityWrapper() .eq("type_no", 110) .eq("stn_no", staNo) .eq("crn_no", locMast.getCrnNo()); StaDesc staDesc = staDescService.selectOne(wrapper); if (Cools.isEmpty(staDesc)) { // throw new CoolException("检索源站失败"); sign = false; } Integer sourceStaNo = null; if (sign){ sourceStaNo = staDesc.getCrnStn(); if (Cools.isEmpty(sourceStaNo)) { // throw new CoolException("检索源站失败"); sign = false; } } if (sign){ Date now = new Date(); // 保存工作档 WrkMast wrkMast = new WrkMast(); wrkMast.setWrkNo(workNo); wrkMast.setIoTime(now); wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID wrkMast.setIoType(110); // 入出库状态： 110.空板出库 wrkMast.setIoPri(99999999D); wrkMast.setSourceStaNo(sourceStaNo); // 源站 wrkMast.setStaNo(staNo); // 目标站 wrkMast.setCrnNo(locMast.getCrnNo()); wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位 wrkMast.setFullPlt("N"); // 满板：Y wrkMast.setPicking("N"); // 拣料 wrkMast.setExitMk("N"); // 退出 wrkMast.setEmptyMk("Y"); // 空板 wrkMast.setLinkMis("N"); wrkMast.setAppeUser(9999L); wrkMast.setAppeTime(now); wrkMast.setModiUser(9999L); wrkMast.setModiTime(now); boolean res = wrkMastService.insert(wrkMast); if (!res) { throw new CoolException("保存工作档失败"); } // 更新库位状态 D.空板 -> R.出库预约 if (locMast.getLocSts().equals("D")){ locMast.setLocSts("R"); locMast.setModiUser(9999L); locMast.setModiTime(now); if (!locMastService.updateById(locMast)) { throw new CoolException("更新库位状态失败"); }else { return SUCCESS; } } } } } if (!sign){ log.error("未查到可出库的空板！！！"); return null; } }catch (Exception e){ log.error("异常！！！"+e); return null; } return SUCCESS; } /** * 根据堆垛机数量从大到小排序，返回排序后的堆垛机号 * * @param crnCount 堆垛机数量数组，索引表示堆垛机号减 1 * @return 排序后的堆垛机号数组 */ public static int[] getSortedCrnNos(int[] crnCount) { // 创建一个列表，存储堆垛机号和对应的值 List> list = new ArrayList<>(); for (int i = 0; i < crnCount.length; i++) { list.add(new AbstractMap.SimpleEntry<>(i + 1, crnCount[i])); // 堆垛机号从 1 开始 } // 根据值从大到小排序 list.sort((entry1, entry2) -> entry2.getValue().compareTo(entry1.getValue())); // 提取排序后的堆垛机号 int[] sortedCrnNos = new int[list.size()]; for (int i = 0; i < list.size(); i++) { sortedCrnNos[i] = list.get(i).getKey(); } return sortedCrnNos; } }