|  |  | 
 |  |  | 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.entity.param.EmptyPlateOutParam; | 
 |  |  | import com.zy.asrs.service.*; | 
 |  |  | import com.zy.asrs.task.AbstractHandler; | 
 |  |  | import com.zy.asrs.task.core.ReturnT; | 
 |  |  | import com.zy.asrs.utils.Utils; | 
 |  |  | import com.zy.common.model.enums.WorkNoType; | 
 |  |  | import com.zy.common.service.CommonService; | 
 |  |  | import lombok.extern.slf4j.Slf4j; | 
 |  |  | 
 |  |  |     private StaDescService staDescService; | 
 |  |  |     @Autowired | 
 |  |  |     private BasCrnpService basCrnpService; | 
 |  |  |     @Autowired | 
 |  |  |     private WorkService workService; | 
 |  |  |  | 
 |  |  |     public ReturnT<String> start() { | 
 |  |  |     public ReturnT<String>  start(Integer staNo,Integer count) { | 
 |  |  |         try { | 
 |  |  |             if (!Cools.isEmpty(wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("io_type", 110).eq("sta_no", 213)))){ | 
 |  |  | //            if (!Cools.isEmpty(wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("io_type", 110).eq("sta_no", staNo)))){ | 
 |  |  | //                return null; | 
 |  |  | //            } | 
 |  |  |             int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 110).eq("sta_no", staNo)); | 
 |  |  |             if (wrkCount>count){ | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |             // 获取工作号 | 
 |  |  | 
 |  |  |             crns.add(4); | 
 |  |  |             crns.add(5); | 
 |  |  |             crns.add(6); | 
 |  |  |             crns.add(7); | 
 |  |  |             boolean sign = true; | 
 |  |  |             for (Integer crnNo : crns){ | 
 |  |  |                 BasCrnp basCrnp = basCrnpService.selectById(crnNo); | 
 |  |  |                 if (basCrnp.getCrnSts()!=3 || !basCrnp.getOutEnable().equals("Y")){ | 
 |  |  |                     continue; | 
 |  |  |                 } | 
 |  |  |                 sign = true; | 
 |  |  |                 // 获取库位 | 
 |  |  |                 LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts","D").eq("crn_no",crnNo)); | 
 |  |  | 
 |  |  |                     // 获取源站 | 
 |  |  |                     Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>() | 
 |  |  |                             .eq("type_no", 110) | 
 |  |  |                             .eq("stn_no", 213) | 
 |  |  |                             .eq("stn_no", staNo) | 
 |  |  |                             .eq("crn_no", locMast.getCrnNo()); | 
 |  |  |                     StaDesc staDesc = staDescService.selectOne(wrapper); | 
 |  |  |                     Integer sourceStaNo = staDesc.getCrnStn(); | 
 |  |  | 
 |  |  |                         wrkMast.setIoType(110); // 入出库状态: 110.空板出库 | 
 |  |  |                         wrkMast.setIoPri(10D); | 
 |  |  |                         wrkMast.setSourceStaNo(sourceStaNo); // 源站 | 
 |  |  |                         wrkMast.setStaNo(213); // 目标站 | 
 |  |  |                         wrkMast.setStaNo(staNo); // 目标站 | 
 |  |  |                         wrkMast.setCrnNo(locMast.getCrnNo()); | 
 |  |  |                         wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位 | 
 |  |  |                         wrkMast.setFullPlt("N"); // 满板:Y | 
 |  |  | 
 |  |  |         } | 
 |  |  |         return SUCCESS; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public ReturnT<String>  startYx(Integer staNo,Integer count) { | 
 |  |  |         try { | 
 |  |  | //            if (!Cools.isEmpty(wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("io_type", 110).eq("sta_no", staNo)))){ | 
 |  |  | //                return null; | 
 |  |  | //            } | 
 |  |  |             int wrkCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 110).eq("sta_no", staNo)); | 
 |  |  |             if (wrkCount>count){ | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |             ArrayList<Integer> crns =new ArrayList<>(); | 
 |  |  |             crns.add(1); | 
 |  |  |             crns.add(2); | 
 |  |  |             crns.add(3); | 
 |  |  |             crns.add(4); | 
 |  |  |             crns.add(5); | 
 |  |  |             crns.add(6); | 
 |  |  |             crns.add(7); | 
 |  |  |             boolean sign = true; | 
 |  |  |             for (Integer crnNo : crns){ | 
 |  |  |                 // 检测路径 | 
 |  |  |                 Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>() | 
 |  |  |                         .eq("type_no", 110) | 
 |  |  |                         .eq("stn_no", staNo) | 
 |  |  |                         .eq("crn_no", crnNo); | 
 |  |  |                 StaDesc staDesc = staDescService.selectOne(wrapper); | 
 |  |  |                 if (Cools.isEmpty(staDesc)){ | 
 |  |  |                     continue; | 
 |  |  |                 } | 
 |  |  |                 BasCrnp basCrnp = basCrnpService.selectById(crnNo); | 
 |  |  |                 if (basCrnp.getCrnSts()!=3 || !basCrnp.getOutEnable().equals("Y")){ | 
 |  |  |                     continue; | 
 |  |  |                 } | 
 |  |  |                 // 获取库位 | 
 |  |  |                 List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "D").eq("crn_no", crnNo)); | 
 |  |  |                 for (LocMast locMastS : locMasts){ | 
 |  |  |                     List<String> locNoList = new ArrayList<>(); | 
 |  |  |                     sign = true; | 
 |  |  |  | 
 |  |  |                     if (Cools.isEmpty(locMastS)) { | 
 |  |  | //                    throw new CoolException("库中无空板!!!"); | 
 |  |  |                         log.error(crnNo+"号堆垛机无空板!"); | 
 |  |  |                         sign=false; | 
 |  |  |                         break; | 
 |  |  |                     } | 
 |  |  |                     if (sign && !locMastS.getLocSts().equals("D")){ | 
 |  |  | //                    throw new CoolException("所选库位存在状态不为D的库位,库位号:"+locMast.getLocNo()+" 、当前状态:"+locMast.getLocSts()+"-"+locMast.getLocSts$()); | 
 |  |  |                         log.error(crnNo+"号堆垛机"+"所选库位存在状态不为D的库位,库位号:"+locMastS.getLocNo()+" 、当前状态:"+locMastS.getLocSts()+"-"+locMastS.getLocSts$()); | 
 |  |  |                         sign=false; | 
 |  |  |                     } | 
 |  |  |                     locNoList.add(locMastS.getLocNo()); | 
 |  |  |  | 
 |  |  |                     //小料箱伴生出库 | 
 |  |  |                     if (sign && Utils.getRow(locMastS.getLocNo())<=8){ | 
 |  |  |                         String locNoOther = staNoOther(locMastS.getLocNo()); | 
 |  |  |                         LocMast locMastOther = locMastService.selectById(locNoOther); | 
 |  |  |                         if (locMastOther.getLocSts().equals("D") || locMastOther.getLocSts().equals("F") ||  locMastOther.getLocSts().equals("R")){ | 
 |  |  |                             if (locMastOther.getLocSts().equals("D")){ | 
 |  |  |                                 locNoList.add(locNoOther); | 
 |  |  |                             } | 
 |  |  |                         }else { | 
 |  |  |                             sign=false; | 
 |  |  |                         } | 
 |  |  |                     }else if (sign && Utils.getRow(locMastS.getLocNo())>=21 && Utils.getRow(locMastS.getLocNo())<=27){ | 
 |  |  |                         String locNoOther = staNoOther(locMastS.getLocNo()); | 
 |  |  |                         LocMast locMastOther = locMastService.selectById(locNoOther); | 
 |  |  |                         if (locMastOther.getLocSts().equals("D") || locMastOther.getLocSts().equals("F") ||  locMastOther.getLocSts().equals("R")){ | 
 |  |  |                             if (locMastOther.getLocSts().equals("D")){ | 
 |  |  |                                 locNoList.add(locNoOther); | 
 |  |  |                             } | 
 |  |  |                         }else { | 
 |  |  |                             sign=false; | 
 |  |  |                         } | 
 |  |  |                     } | 
 |  |  |                     if (sign) { | 
 |  |  |                         EmptyPlateOutParam param = new EmptyPlateOutParam(); | 
 |  |  |                         param.setOutSite(staNo); | 
 |  |  |                         param.setLocNos(locNoList); | 
 |  |  |                         try{ | 
 |  |  |                             workService.emptyPlateOut(param, 9999L); | 
 |  |  |                         }catch (Exception e){ | 
 |  |  |                             log.error("二楼小料箱自动补空板失败!!异常原因:"+e); | 
 |  |  |                         } | 
 |  |  |                         return SUCCESS; | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |             if (!sign){ | 
 |  |  |                 log.error("未查到可出库的空板!!!"); | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |         }catch (Exception e){ | 
 |  |  |             log.error("异常!!!"+e); | 
 |  |  |             return null; | 
 |  |  |         } | 
 |  |  |         return SUCCESS; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public String staNoOther(String locNo){ | 
 |  |  |         int row = Utils.getRow(locNo); | 
 |  |  |         if (row<=8){ | 
 |  |  |             if (row%4==0 || row%4==1){ | 
 |  |  |                 return getDeepLoc2(locNo,row); | 
 |  |  |             }else { | 
 |  |  |                 return getDeepLoc(locNo,row); | 
 |  |  |             } | 
 |  |  |         }else if (row>=21 && row<=27){ | 
 |  |  |             if (row==21 || row==24 || row==27){ | 
 |  |  |                 return getDeepLoc2(locNo,row); | 
 |  |  |             }else { | 
 |  |  |                 return locNo; | 
 |  |  |             } | 
 |  |  |         }else { | 
 |  |  |             return locNo; | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 获取 深库位对应的浅库位号 | 
 |  |  |      */ | 
 |  |  |     public static String getDeepLoc2(String shallowLoc,int row) { | 
 |  |  |         if (row == 1 || row == 5 || row==21) { | 
 |  |  |             return Utils.zerofill(String.valueOf(row+1), 2) + shallowLoc.substring(2); | 
 |  |  |         } else if (row == 4 || row == 8 || row == 24 || row == 27) { | 
 |  |  |             return Utils.zerofill(String.valueOf(row-1), 2) + shallowLoc.substring(2); | 
 |  |  |         }else { | 
 |  |  |             return null; | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 获取 浅库位对应的深库位号 | 
 |  |  |      */ | 
 |  |  |     public static String getDeepLoc(String shallowLoc,int row) { | 
 |  |  |         if (row == 2 || row == 6) { | 
 |  |  |             return Utils.zerofill(String.valueOf(row-1), 2) + shallowLoc.substring(2); | 
 |  |  |         } else if (row == 3 || row == 7) { | 
 |  |  |             return Utils.zerofill(String.valueOf(row+1), 2) + shallowLoc.substring(2); | 
 |  |  |         }else { | 
 |  |  |             return shallowLoc; | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  | } |