|  |  | 
 |  |  | import com.core.common.R; | 
 |  |  | import com.core.exception.CoolException; | 
 |  |  | import com.zy.asrs.entity.*; | 
 |  |  | import com.zy.asrs.entity.param.EmptyPlateOutParam; | 
 |  |  | import com.zy.asrs.service.*; | 
 |  |  | import com.zy.common.CodeRes; | 
 |  |  | import com.zy.common.model.LocTypeDto; | 
 |  |  | 
 |  |  | import org.springframework.transaction.annotation.Transactional; | 
 |  |  | import org.springframework.web.bind.annotation.*; | 
 |  |  |  | 
 |  |  | import java.util.ArrayList; | 
 |  |  | import java.util.Date; | 
 |  |  | import java.util.List; | 
 |  |  | import java.util.stream.Collectors; | 
 |  |  | 
 |  |  |     private  LocDetlService locDetlService; | 
 |  |  |     @Autowired | 
 |  |  |     private RowLastnoService rowLastnoService; | 
 |  |  |     @Autowired | 
 |  |  |     private WorkService workService; | 
 |  |  |     @Autowired | 
 |  |  |     private BasCrnpService basCrnpService; | 
 |  |  |  | 
 |  |  |     @PostMapping("/pakin/loc/v1") | 
 |  |  |     @ResponseBody | 
 |  |  | 
 |  |  |                 return R.parse(CodeRes.NO_COMB_700); | 
 |  |  |             } | 
 |  |  |             int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet",param.getBarcode())); | 
 |  |  |             int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet",param.getBarcode())); | 
 |  |  |             int countWrk = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("barcode",param.getBarcode()) | 
 |  |  |                     .le("io_type",100)); | 
 |  |  |  | 
 |  |  |             if (countLoc > 0 || countWrk > 0) { | 
 |  |  |                 return R.error(CodeRes.EXIST_500); | 
 |  |  |             } | 
 |  |  | 
 |  |  |         BasDevp sourceStaNo = basDevpService.checkSiteStatus(12, true); | 
 |  |  |  | 
 |  |  |         // 检索库位 | 
 |  |  |         StartupDto dto = commonService.getLocNo(rowLastnoService.selectNextWhsType(), 10, 15, null, locTypeDto,0); | 
 |  |  |         StartupDto dto = commonService.getLocNo(rowLastnoService.selectNextWhsType(), 10, 12, null, locTypeDto,0); | 
 |  |  |         Date now = new Date(); | 
 |  |  |         // 生成工作档 | 
 |  |  |         WrkMast wrkMast = new WrkMast(); | 
 |  |  | 
 |  |  |         return wrkMastService.insert(wrkMast) ? R.ok("自动空托入库成功,工作号:"+wrkMast.getWrkNo()) : R.error("生成自动空托入库失败"); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @PostMapping("auto/emptyOut/v1") | 
 |  |  |     @ResponseBody | 
 |  |  |     public R autoEmptyOut(){ | 
 |  |  |         LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>() | 
 |  |  |                 .eq("loc_sts", "D")); | 
 |  |  |         if (Cools.isEmpty(locMast)) { | 
 |  |  |             return R.error("库存没有空板"); | 
 |  |  |         } | 
 |  |  |         EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam(); | 
 |  |  |         emptyPlateOutParam.setOutSite(12); | 
 |  |  |         emptyPlateOutParam.setLocNos(new ArrayList<String>(){{add(locMast.getLocNo()+"");}}); | 
 |  |  |         WrkMast wrkMast = workService.emptyPlateOut(emptyPlateOutParam); | 
 |  |  |         return R.ok(!Cools.isEmpty(wrkMast)? R.ok("自动空托出库成功,工作号:" + wrkMast.getWrkNo()) : R.error("生成自动空托出库失败")); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 全板入库 | 
 |  |  |      */ | 
 |  |  | 
 |  |  |         BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true); | 
 |  |  |         // 检索库位 | 
 |  |  |         List<String> matNos = waitPakins.stream().map(WaitPakin::getMatnr).distinct().collect(Collectors.toList()); | 
 |  |  |         StartupDto dto = commonService.getLocNo(1, 1, devpNo, matNos, locTypeDto,0); | 
 |  |  |         int rowCount = rowLastnoService.selectCount(null); | 
 |  |  |         Integer integer = 2; | 
 |  |  |         for (int i = 1; i <= rowCount; i++) { | 
 |  |  |             integer = rowLastnoService.selectNextWhsType(); | 
 |  |  |             BasCrnp crn_no = basCrnpService.selectOne(new EntityWrapper<BasCrnp>() | 
 |  |  |                     .eq("crn_no", integer)); | 
 |  |  |             if (crn_no.getInEnable().equals("Y") && crn_no.getCrnSts() == 3){ | 
 |  |  |                 break; | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         StartupDto dto = commonService.getLocNo(integer, 1, devpNo, matNos, locTypeDto,0); | 
 |  |  |         int workNo = dto.getWorkNo(); | 
 |  |  |         Date now = new Date(); | 
 |  |  |         // 生成工作档 | 
 |  |  | 
 |  |  |         } | 
 |  |  |         // 生成工作档明细 | 
 |  |  |         waitPakins.forEach(waitPakin -> { | 
 |  |  |             String uuid = String.valueOf(System.currentTimeMillis()); | 
 |  |  |             WrkDetl wrkDetl = new WrkDetl(); | 
 |  |  |             wrkDetl.sync(waitPakin); | 
 |  |  |             wrkDetl.setWrkNo(wrkMast.getWrkNo()); | 
 |  |  |             wrkDetl.setIoTime(wrkMast.getIoTime()); | 
 |  |  |             wrkDetl.setAppeTime(now); | 
 |  |  |             wrkDetl.setModiTime(now); | 
 |  |  |             wrkDetl.setUuid(uuid); | 
 |  |  |             wrkDetl.setWeight(waitPakin.getWeight()); | 
 |  |  |             wrkDetl.setOwner(waitPakin.getOwner()); | 
 |  |  |             wrkDetl.setPayment(waitPakin.getPayment()); | 
 |  |  |             if (!wrkDetlService.insert(wrkDetl)) { | 
 |  |  |                 throw new CoolException("保存工作明细失败"); | 
 |  |  |             } | 
 |  |  | 
 |  |  |     public StartupDto emptyPlateIn(Integer devpNo, LocTypeDto locTypeDto, String barcode) { | 
 |  |  |         // 源站点状态检测 | 
 |  |  |         BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true); | 
 |  |  |         int rowCount = rowLastnoService.selectCount(null); | 
 |  |  |         Integer integer = 2; | 
 |  |  |         for (int i = 1; i <= rowCount; i++) { | 
 |  |  |             integer = rowLastnoService.selectNextWhsType(); | 
 |  |  |             BasCrnp crn_no = basCrnpService.selectOne(new EntityWrapper<BasCrnp>() | 
 |  |  |                     .eq("crn_no", integer)); | 
 |  |  |             if (crn_no.getInEnable().equals("Y") | 
 |  |  |                     && crn_no.getCrnSts() == 3){ | 
 |  |  |                 break; | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         // 检索库位 | 
 |  |  |         StartupDto dto = commonService.getLocNo(1, 10, devpNo, null, locTypeDto,0); | 
 |  |  |         StartupDto dto = commonService.getLocNo(integer, 10, devpNo, null, locTypeDto,0); | 
 |  |  |         int workNo = dto.getWorkNo(); | 
 |  |  |         // 生成工作档 | 
 |  |  |         WrkMast wrkMast = new WrkMast(); |