zy-wcs.git - Gitblit

			@@ -1,6 +1,7 @@
			package com.zy.asrs.service.impl;

			import com.alibaba.fastjson.JSON;
			import com.alibaba.fastjson.JSONArray;
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.mapper.EntityWrapper;
			import com.baomidou.mybatisplus.mapper.Wrapper;
			@@ -36,6 +37,8 @@

			import java.util.*;
			import java.util.stream.Collectors;

			import static com.zy.asrs.utils.Utils.isJson;

			/**
			* 立体仓库WCS系统主流程业务
			@@ -718,6 +721,9 @@
			continue;
			}

			staProtocol.setStaNo(dto.getSourceStaNo().shortValue());//写入目标站
			MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));

			} else if (code == 500){
			News.error("请求接口失败！！！url：{}；request：{}；response：{}", wmsUrl + "/rpc/pakin/loc/v1", JSON.toJSONString(param), response);
			}
			@@ -1274,6 +1280,25 @@
			}

			if (wrkMast.getShuttleNo() == null) {//没有绑定小车，进行调度
			//强制预留一台小车给入库任务
			int lev = Utils.getLev(wrkMast.getSourceLocNo());
			//获取当前楼层有几台可用小车
			int shuttleCount = shuttleDispatchUtils.getShuttleCountByLev(lev);
			if (shuttleCount >= 2) {//只有可用小车数量大于2，才进行入库任务预留小车
			int shuttleWrkInObligateCount = 1;//预留小车数量
			Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "shuttleWrkInObligateCount").eq("status", 1));
			if (config != null) {
			shuttleWrkInObligateCount = Integer.parseInt(config.getValue());
			}
			//可用出库小车数量(给入库任务预留一台车)
			int useShuttleCount = shuttleCount - shuttleWrkInObligateCount;
			//查询楼层已分配车辆的出库任务数量
			List<WrkMast> wrkMasts = wrkMastService.selectShuttleOutWrkByLev(lev);
			if (wrkMasts.size() >= useShuttleCount) {
			News.info("{}任务，当前楼层可用小车{}台，出库任务已分配{}台，系统等待中。", wrkMast.getWrkNo(), useShuttleCount, wrkMasts.size());
			return false;
			}
			}
			boolean result = shuttleDispatchUtils.dispatchShuttle(wrkMast.getWrkNo(), wrkMast.getSourceLocNo());//调度小车到货物所在库位进行取货
			News.info("{}任务，调度小车{}系统等待中。", wrkMast.getWrkNo(), result ? "成功" : "失败");
			return false;
			@@ -2824,51 +2849,15 @@
			ledCommand.setLocNo(wrkMast.getLocNo());
			ledCommand.setStaNo(wrkMast.getStaNo());
			if (wrkMast.getIoType() != 110 && wrkMast.getIoType() != 10) {
			//for (WrkDetl wrkDetl : wrkDetls) {
			// LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("zpallet", wrkDetl.getZpallet()).eq("matnr", wrkDetl.getMatnr()));
			//
			// locDetls.forEach(locDetl1 -> {
			// //工作档中存在该物料则跳过
			// String suppCode = "";
			//
			// if (wrkDetl.getMatnr().equals(locDetl1.getMatnr())) {
			// Double anfme = 0D;
			// if (locDetl != null) {
			// anfme = locDetl.getAnfme();
			// }
			// if (wrkDetl.getSuppCode() != null) {
			// suppCode = wrkDetl.getSuppCode();
			// }
			// ledCommand.getMatDtos()
			// .add(new MatDto(wrkDetl.getMatnr()
			// , wrkDetl.getMaktx()
			// , wrkDetl.getAnfme()
			// , (wrkDetl.getAnfme()-anfme)
			// , wrkDetl.getSpecs()
			// , suppCode));
			// } else {
			// if (locDetl1.getSuppCode() != null) {
			// suppCode = locDetl1.getSuppCode();
			// }
			// ledCommand.getMatDtos()
			// .add(new MatDto(locDetl1.getMatnr()
			// , locDetl1.getMaktx()
			// , 0D
			// , locDetl1.getAnfme()
			// , locDetl1.getSpecs()
			// , suppCode));
			// }
			// });
			// //LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("zpallet", wrkDetl.getZpallet()).eq("matnr", wrkDetl.getMatnr()));
			//}
			List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getSourceLocNo()));
			locDetls.forEach(locDetl -> {
			Wrapper<WrkDetl> wrapper = new EntityWrapper<WrkDetl>().eq("matnr", locDetl.getMatnr()).eq("wrk_no",wrkMast.getWrkNo());
			Utils.wapperSetCondition(wrapper,"batch",locDetl.getBatch());
			Utils.wapperSetCondition(wrapper,"three_code",locDetl.getThreeCode());
			Utils.wapperSetCondition(wrapper,"dead_time",locDetl.getDeadTime());
			Utils.wapperSetCondition(wrapper,"supp_code",locDetl.getSuppCode());//料箱码
			Wrapper<WrkDetl> wrapper = new EntityWrapper<WrkDetl>().eq("matnr", locDetl.getMatnr()).eq("wrk_no", wrkMast.getWrkNo());
			Utils.wapperSetCondition(wrapper, "batch", locDetl.getBatch());
			Utils.wapperSetCondition(wrapper, "three_code", locDetl.getThreeCode());
			Utils.wapperSetCondition(wrapper, "dead_time", locDetl.getDeadTime());
			Utils.wapperSetCondition(wrapper, "supp_code", locDetl.getSuppCode());//料箱码
			WrkDetl detl = wrkDetlService.selectOne(wrapper);

			if (Cools.isEmpty(detl)) {
			String suppCode = "";
			if (locDetl.getSuppCode() != null) {
			@@ -2877,13 +2866,32 @@
			ledCommand.getMatDtos().add(new MatDto(locDetl.getMatnr(), locDetl.getMaktx(), 0D, locDetl.getAnfme(), locDetl.getSpecs(), suppCode));
			} else {
			String suppCode = "";
			String orderNo = detl.getOrderNo();
			if (detl.getSuppCode() != null) {
			suppCode = detl.getSuppCode();
			}
			ledCommand.getMatDtos().add(new MatDto(detl.getMatnr(), detl.getMaktx(), detl.getAnfme(), (locDetl.getAnfme() - detl.getAnfme()), detl.getSpecs(), suppCode));
			if (isJson(orderNo)) {
			JSONArray orders = JSON.parseArray(orderNo);
			for (Object order : orders) {
			JSONObject order1 = (JSONObject) order;
			ledCommand.getMatDtos().add(new MatDto(detl.getMatnr(), detl.getMaktx(), (Double) order1.get("anfme"), (locDetl.getAnfme() - detl.getAnfme()), detl.getSpecs(), suppCode,(String) order1.get("orderNo")));
			}
			} else {
			ledCommand.getMatDtos().add(new MatDto(detl.getMatnr(), detl.getMaktx(), detl.getAnfme(), (locDetl.getAnfme() - detl.getAnfme()), detl.getSpecs(), suppCode,detl.getOrderNo()));
			}


			}
			});

			if (locDetls.isEmpty()) {
			List<WrkDetl> wrkDetls = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
			wrkDetls.forEach(wrkDetl -> {
			ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(), wrkDetl.getAnfme(), wrkDetl.getSpecs(), wrkDetl.getSuppCode()));
			});
			}
			}

			commands.add(ledCommand);
			}
			Set<Integer> workNos = wrkMasts.stream().map(WrkMast::getWrkNo).collect(Collectors.toSet());