package com.zy.common.service; import com.alibaba.fastjson.JSON; 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.*; import com.zy.asrs.service.*; import com.zy.asrs.utils.Utils; import com.zy.common.entity.Parameter; import com.zy.common.model.LocTypeDto; import com.zy.common.model.StartupDto; import com.zy.common.properties.SlaveProperties; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.List; /** * 货架核心功能 * Created by vincent on 2020/6/11 */ @Slf4j @Service public class CommonService { @Autowired private WrkMastService wrkMastService; @Autowired private WrkLastnoService wrkLastnoService; @Autowired private RowLastnoService rowLastnoService; @Autowired private BasCrnpService basCrnpService; @Autowired private StaDescService staDescService; @Autowired private BasDevpService basDevpService; @Autowired private LocMastService locMastService; @Autowired private LocDetlService locDetlService; @Autowired private SlaveProperties slaveProperties; @Value("${channel.channelMax}") private Integer channelMax; @Value("${channel.equipmentCount}") private Integer equipmentCount; /** * 生成工作号 * * @param wrkMk 0:入库 1 - 3000 ; 1:拣料/并板/盘点 3001 - 6000 ; 2: 出库 6001 -9000 ; 3:其他 9001 -9999 * @return workNo(工作号) */ public int getWorkNo(Integer wrkMk) { WrkLastno wrkLastno = wrkLastnoService.selectById(wrkMk); if (Cools.isEmpty(wrkLastno)) { throw new CoolException("数据异常，请联系管理员"); } int workNo = wrkLastno.getWrkNo(); int sNo = wrkLastno.getSNo(); int eNo = wrkLastno.getENo(); workNo = workNo >= eNo ? sNo : workNo + 1; while (true) { WrkMast wrkMast = wrkMastService.selectById(workNo); if (null != wrkMast) { workNo = workNo >= eNo ? sNo : workNo + 1; } else { break; } } // 修改序号记录 if (workNo > 0) { wrkLastno.setWrkNo(workNo); wrkLastnoService.updateById(wrkLastno); } // 检验 if (workNo == 0) { throw new CoolException("生成工作号失败，请联系管理员"); } else { if (wrkMastService.selectById(workNo) != null) { throw new CoolException("生成工作号" + workNo + "在工作档中已存在"); } } return workNo; } /** * 检索库位号 * * @param whsType 类型 1:双深式货架 * @param staDescId 路径工作类型 * @param sourceStaNo 源站 * @param matNos 商品编号集合 * @return locNo 检索到的库位号 */ @Transactional public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List matNos, LocTypeDto locTypeDto, int times) { whsType = 1; locTypeDto.setLocType1((short) 1); StartupDto startupDto = new StartupDto(); RowLastno rowLastno = rowLastnoService.selectById(whsType); if (Cools.isEmpty(rowLastno)) { throw new CoolException("数据异常，请联系管理员"); } // ===============>>>> 开始执行 int curRow = rowLastno.getCurrentRow(); int sRow = rowLastno.getsRow(); int eRow = rowLastno.geteRow(); int crn_qty = rowLastno.getCrnQty(); int rowCount = eRow - sRow; // 目标堆垛机号 int crnNo = crn_qty; // 目标库位 LocMast locMast = null; if (crnNo == 0) { throw new CoolException("没有可用的堆垛机"); } // 获取目标站 Wrapper wrapper = new EntityWrapper() .eq("type_no", staDescId) .eq("stn_no", sourceStaNo) .eq("crn_no", crnNo); StaDesc staDesc = staDescService.selectOne(wrapper); if (Cools.isEmpty(staDesc)) { log.error("type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, crnNo); throw new CoolException("入库路径不存在"); } BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn()); if (!staNo.getAutoing().equals("Y")) { throw new CoolException("目标站" + staDesc.getCrnStn() + "不可用"); } // 更新库位排号 rowLastno.setCurrentRow(curRow); rowLastnoService.updateById(rowLastno); if (crnNo==1){ LocMast locMast1 = locMastService.selectOne(new EntityWrapper() .eq("loc_sts", "F") .eq("loc_type1", (short) 3));//待测库位 LocMast locMast2 = locMastService.selectOne(new EntityWrapper() .eq("loc_sts", "O") .eq("loc_type1", (short) 1));//测试库位 if (!Cools.isEmpty(locMast1)||Cools.isEmpty(locMast2)){ List locMasts=locMastService.selectList(new EntityWrapper() .eq("loc_sts", "O").eq("loc_type1", (short) 3) .orderBy("row1",false).orderBy("bay1",true)); if(!Cools.isEmpty(locMasts)){ locMast = locMasts.get(0); }else{ throw new CoolException("没有待测库位无法入库！！！"); } } } // 靠近摆放规则 --- 空托 if (staDescId == 10) { List locMasts = locMastService.selectList(new EntityWrapper().eq("loc_sts", "D").ge("row1", sRow).le("row1", eRow)); if (locMasts.size() > 0) { for (LocMast loc : locMasts) { if (Utils.isShallowLoc(slaveProperties, loc.getLocNo())) { continue; } String shallowLocNo = Utils.getShallowLoc(slaveProperties, loc.getLocNo()); // 检测目标库位是否为空库位 LocMast shallowLoc = locMastService.selectById(shallowLocNo); if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) { if (shallowLoc.getLocType1() locMastList3 = locMastService.selectList(new EntityWrapper() .eq("loc_sts", "O") .eq("row1",3) .notIn("loc_type1",1)); if (!Cools.isEmpty(locMastList3)) { locMast = locMastList3.get(0); }else { List locMastList1 = locMastService.selectList(new EntityWrapper() .eq("loc_sts", "O") .eq("row1",1) .notIn("loc_type1",1)); if (!Cools.isEmpty(locMastList1)) { locMast = locMastList1.get(0); } } } } if (Cools.isEmpty(locMast)){ locMast = locMastService.queryFreeLocMast(1, locTypeDto.getLocType1()); // // 开始查找库位 ==============================> // int ruleId = Integer.parseInt(Parameter.get().getFindLocRule()); // if (whsType != 1) { // locMast = locMastService.queryFreeLocMast(curRow, locTypeDto.getLocType1()); // } else if (ruleId == 1) { //按测试设备排序，优先排满单台设备 // locMast = locMastService.queryFreeLocMast1(curRow, locTypeDto.getLocType1(), channelMax + 1); // } else if (ruleId == 2) { //按通道排序，均匀分配每台设备 // Short locType2 = getLocType2Small(curRow, locTypeDto.getLocType1()); // locMast = locMastService.queryFreeLocMast2(curRow, locTypeDto.getLocType1(), locType2); // } else { //默认规则 // locMast = locMastService.queryFreeLocMast(curRow, locTypeDto.getLocType1()); // } } if (Cools.isEmpty(locMast)) { throw new CoolException("没有空库位"); } String locNo = locMast.getLocNo(); // 生成工作号 int workNo = getWorkNo(0); // 返回dto startupDto.setWorkNo(workNo); startupDto.setCrnNo(crnNo); startupDto.setSourceStaNo(sourceStaNo); startupDto.setStaNo(staNo.getDevNo()); startupDto.setLocNo(locNo); return startupDto; } public Short getLocType2Small(Integer curRow, short locType1) { Integer OCount = locMastService.queryFreeLocMastCount(curRow, locType1, (short) 1); short locType2 = 1; for (int i = 2; i < equipmentCount + 1; i++) { Integer integer = locMastService.queryFreeLocMastCount(curRow, locType1, (short) i); if (OCount < integer) { OCount = integer; locType2 = (short) i; } } return locType2; } }