| | |
|---|
| | | import com.zy.common.model.StartupDto; |
|---|
| | | import com.zy.common.properties.SlaveProperties; |
|---|
| | | import com.zy.common.web.param.SearchLocParam; |
|---|
| | | import com.zy.system.entity.Config; |
|---|
| | | import com.zy.system.service.ConfigService; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private LocMastMapper locMastMapper; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private ConfigService configService; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 生成工作号 |
|---|
| | |
|---|
| | | |
|---|
| | | // 入空桶库 |
|---|
| | | if (staDescId == 1 && locArea == 2) { |
|---|
| | | Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "emptyBucketInCacheCount").eq("status", 1)); |
|---|
| | | if (config != null && !Cools.isEmpty(config.getValue())) { // 限制入空桶库输送线缓存任务数，避免堵塞 |
|---|
| | | int value = Integer.parseInt(config.getValue()); |
|---|
| | | List<BasDevp> basDevps = basDevpService.selectList(new EntityWrapper<BasDevp>().in("dev_no", 1044, 1045, 1046, 1047, 1048, 1049, 1050).ne("wrk_no", 0)); |
|---|
| | | long count = basDevps.stream().map(BasDevp::getWrkNo).distinct().count(); |
|---|
| | | log.info("入空桶库输送线缓存任务数:{}",count); |
|---|
| | | if(count >= value) { |
|---|
| | | log.error("-----入空桶库输送线缓存任务数：{}，超配置缓存数：{}----",count,value); |
|---|
| | | throw new CoolException("入空桶库输送线缓存任务数："+count+"，超配置缓存数：" + value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | List<WrkMast> wrkMastList = wrkMastMapper.selectLastInEmptyLoc(); // 前面入空桶库的任务(未执行堆垛机入库) |
|---|
| | | |
|---|
| | | if (wrkMastList.size() == 0) { |
|---|
| | |
|---|
| | | |
|---|
| | | // 入成品库摆放规则 判断可用堆垛机自动-无报警 按层列排顺序从下往上，从前往后排 先深库位在浅库位 最上面一层只能放208L桶(剩余库位达到一个阈值208L就先从最上面开始放，下面留给其他货物-后续优化) |
|---|
| | | |
|---|
| | | List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>().eq("crn_sts", 3).eq("crn_err", 0).in("crn_no",1,2,3)); |
|---|
| | | List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>().eq("crn_sts", 3).eq("crn_err", 0).in("crn_no",1,2,3) |
|---|
| | | .eq("in_enable","Y")); |
|---|
| | | if (basCrnps.size() == 0) { |
|---|
| | | log.error("入库请求库位失败，没有联机堆垛机或堆垛机异常"); |
|---|
| | | throw new CoolException("入库请求库位失败，没有联机堆垛机或堆垛机异常"); |
|---|
| | |
|---|
| | | basCrnpList.add(basCrnp); |
|---|
| | | } |
|---|
| | | |
|---|
| | | basCrnpList = basCrnpList.stream().sorted(Comparator.comparing(BasCrnp::getWrkNo)).collect(Collectors.toList()); |
|---|
| | | basCrnpList = basCrnpList.stream().sorted(Comparator.comparing(BasCrnp::getWrkNo).thenComparing(BasCrnp::getCrnNo,((o1, o2) -> { |
|---|
| | | // 定义 2 → 3 → 1 的优先级 |
|---|
| | | int order1 = getCustomOrder(o1); |
|---|
| | | int order2 = getCustomOrder(o2); |
|---|
| | | return Integer.compare(order1, order2); |
|---|
| | | }))).collect(Collectors.toList()); |
|---|
| | | |
|---|
| | | // 入库桶型 |
|---|
| | | String model = findLocNoAttributeVo.getModel(); |
|---|
| | |
|---|
| | | return startupDto; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 辅助方法：定义 crn_no 的排序优先级 |
|---|
| | | private static int getCustomOrder(Integer crnNo) { |
|---|
| | | switch (crnNo) { |
|---|
| | | case 2: return 1; // 2 排第一 |
|---|
| | | case 3: return 2; // 3 排第二 |
|---|
| | | case 1: return 3; // 1 排第三 |
|---|
| | | default: return 4; // 其他值排最后（如果有） |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Transactional(propagation = Propagation.REQUIRED) |
|---|
| | | public StartupDto getLocNo(SearchLocParam param, Integer staNo) { |
|---|
| | | |
|---|
