zy-asrs-master.git

			@@ -53,31 +53,113 @@

			Set<String> exist = new HashSet<>();

			//标记库位
			HashMap<String,Integer> hm = new HashMap<>();

			for (OrderDetl orderDetl : orderDetls) {
			double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getQty()).orElse(0.0D);
			if (issued <= 0.0D) { continue; }
			List<LocDetl> locDetls = locDetlService.queryStock(orderDetl.getMatnr(), orderDetl.getBatch(), hostId);
			for (LocDetl locDetl : locDetls) {
			// if (!Cools.isEmpty(locDetl.getMemo())){
			// continue;
			// }
			if (issued > 0) {
			LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
			issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued);
			List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), issued >= locDetl.getAnfme() ? 101 : 103, hostId);
			locDto.setStaNos(staNos);
			locDtos.add(locDto);
			exist.add(locDetl.getLocNo());
			// 剩余待出数量递减
			issued = issued - locDetl.getAnfme();
			} else {
			break;
			double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getWorkQty()).orElse(0.0D);
			if (issued <= 0.0D) {
			continue;
			}
			if(!Cools.isEmpty(hm)){
			for(HashMap.Entry<String,Integer> entry:hm.entrySet()){
			List<LocDetl> locDetls = locDetlService.list(new LambdaQueryWrapper<LocDetl>()
			.eq(LocDetl::getHostId, hostId)
			.eq(LocDetl::getLocNo, entry.getKey())
			.eq(LocDetl::getMatnr, orderDetl.getMatnr()));
			for (LocDetl locDetl : locDetls) {
			List<LocDetl> locMats = locDetlService.list(new LambdaQueryWrapper<LocDetl>()
			.eq(LocDetl::getLocNo, locDetl.getLocNo())
			.eq(LocDetl::getHostId, hostId));
			if (issued > 0) {
			LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
			issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued);
			List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), ((issued >= locDetl.getAnfme()) && (locMats.size() == 1)) ? 101 : 103, hostId);
			locDto.setStaNos(staNos);
			locDtos.add(locDto);
			exist.add(locDetl.getLocNo());
			// 剩余待出数量递减
			issued = issued - locDetl.getAnfme();
			hm.put(locDetl.getLocNo(), 1);
			} else {
			break;
			}
			}
			}
			if (issued >0){
			List<LocDetl> locDetls = locDetlService.queryStock(orderDetl.getMatnr(), orderDetl.getBatch(), hostId);
			for (LocDetl locDetl : locDetls) {
			for (HashMap.Entry<String,Integer> entry:hm.entrySet()){
			if(locDetl.getLocNo().equals(entry.getKey())){
			continue;
			}
			}
			List<LocDetl> locMats = locDetlService.list(new LambdaQueryWrapper<LocDetl>()
			.eq(LocDetl::getLocNo, locDetl.getLocNo())
			.eq(LocDetl::getHostId, hostId));
			if (issued > 0) {
			LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
			issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued);
			List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), ((issued >= locDetl.getAnfme()) && (locMats.size() == 1)) ? 101 : 103, hostId);
			locDto.setStaNos(staNos);
			locDtos.add(locDto);
			exist.add(locDetl.getLocNo());
			// 剩余待出数量递减
			issued = issued - locDetl.getAnfme();
			hm.put(locDetl.getLocNo(), 1);
			} else {
			break;
			}
			}
			}
			}else{
			List<LocDetl> locDetls = locDetlService.queryStock(orderDetl.getMatnr(), orderDetl.getBatch(), hostId);
			for (LocDetl locDetl : locDetls) {
			List<LocDetl> locMats = locDetlService.list(new LambdaQueryWrapper<LocDetl>()
			.eq(LocDetl::getLocNo, locDetl.getLocNo())
			.eq(LocDetl::getHostId, hostId));
			if (issued > 0) {
			LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
			issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued);
			List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), ((issued >= locDetl.getAnfme()) && (locMats.size() == 1)) ? 101 : 103, hostId);
			locDto.setStaNos(staNos);
			locDtos.add(locDto);
			exist.add(locDetl.getLocNo());
			// 剩余待出数量递减
			issued = issued - locDetl.getAnfme();
			hm.put(locDetl.getLocNo(), 1);
			} else {
			break;
			}
			}
			}

			if (issued > 0) {
			LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued);
			locDto.setLack(Boolean.TRUE);
			locDtos.add(locDto);
			List<LocDetl> locDetls1 = locDetlService.list(new LambdaQueryWrapper<LocDetl>()
			.eq(LocDetl::getMatnr, orderDetl.getMatnr()).eq(LocDetl::getHostId, hostId));
			boolean boo = false;
			if (Cools.isEmpty(locDetls1)) {
			LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued);
			locDto.setLack(Boolean.TRUE);
			locDtos.add(locDto);
			} else {
			for (LocDetl locDetl : locDetls1
			) {
			String locNo = locDetl.getLocNo().substring(1, 2);
			if (Integer.valueOf(locNo) > 4) {
			boo = true;
			LocDto locDto = new LocDto("在平库", orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued);
			locDto.setLack(Boolean.TRUE);
			locDtos.add(locDto);
			break;
			}
			}
			if (!boo) {
			LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued);
			locDto.setLack(Boolean.TRUE);
			locDtos.add(locDto);
			}
			}
			}
			}
			return R.ok().add(locDtos);
			@@ -106,7 +188,9 @@
			// 订单预校验 ===>> 1.订单状态； 2.订单带出数量
			List<OrderDto> orderDtos = new ArrayList<>();
			for (LocDto locDto : locDtos) {
			if (Cools.isEmpty(locDto.getOrderNo())) { continue; }
			if (Cools.isEmpty(locDto.getOrderNo())) {
			continue;
			}
			OrderDto orderDto = new OrderDto(locDto.getOrderNo(), locDto.getMatnr(), locDto.getAnfme());
			if (OrderDto.has(orderDtos, orderDto)) {
			OrderDto dto = OrderDto.find(orderDtos, orderDto);
			@@ -121,7 +205,15 @@
			if (order.getSettle() > 2) {
			return R.error(orderDto.getOrderNo() + "订单已失效，请及时刷新页面");
			}
			OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), orderDto.getMatnr(), null,getHostId());
			OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), orderDto.getMatnr(), null, getHostId());
			if(Cools.isEmpty(orderDetl)){
			return R.error("没有找到订单明细");
			}
			int oerderDetlCount = orderDetlService.count(new LambdaQueryWrapper<OrderDetl>()
			.eq(OrderDetl::getOrderId,order.getId()).eq(OrderDetl::getMatnr,orderDto.getMatnr()).eq(OrderDetl::getHostId,getHostId()));
			if(oerderDetlCount>1){
			return R.error("同一订单不允许有相同物料");
			}
			if (orderDetl.getAnfme() - orderDetl.getQty() < orderDto.getAnfme()) {
			return R.ok(orderDto.getOrderNo() + "订单已作业，请及时刷新页面");
			}
			@@ -130,12 +222,17 @@
			List<TaskDto> taskDtos = new ArrayList<>();
			// 根据（库位 & 出库站）分组；理想状态：一组为一次出库任务
			for (LocDto locDto : locDtos) {
			if (locDto.isLack()) { continue; }
			if (locDto.isLack()) {
			continue;
			}
			//2022-08-04 Add，防止前端页面提取库位信息后，在其他地方对该库位生成了出库任务(库位状态非F状态)
			LocMast locMast = locMastService.getOne(new LambdaQueryWrapper<LocMast>()
			.eq(LocMast::getLocNo, locDto.getLocNo())
			.eq(LocMast::getHostId, hostId));
			if(!Cools.isEmpty(locMast) && !locMast.getLocSts().equals("F")){
			if (locMast.getWhsType() != 0) {
			continue;
			}
			if (!Cools.isEmpty(locMast) && !locMast.getLocSts().equals("F")) {
			return R.error("库位号非在库状态，请重新选择出库库位===>>" + locDto.getLocNo());
			}

			@@ -153,7 +250,7 @@
			BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo(), false, hostId);
			workService.stockOut(staNo.getDevNo(), taskDto, getUserId(), hostId);
			}
			return R.ok();
			return R.ok("立体仓库生成出库任务成功，平库请使用PDA进行出库！！！");
			}

			}