zy-wcs.git - Gitblit

			@@ -470,8 +470,9 @@
			if (wrkMastMapper.setSteEmpty(wrkMast.getWrkNo()) == 0) {
			throw new CoolException(wrkMast.getWrkNo() + "更新工作档数据状态失败");
			}
			LocMast locMast = null;
			// 修改源库位状态 O.空库位
			LocMast locMast = locMastService.selectById(sourceLocNo);
			locMast = locMastService.selectById(sourceLocNo);
			locMast.setLocSts("O");
			locMast.setModiTime(new Date());
			if (!locMastService.updateById(locMast)) {
			@@ -534,6 +535,70 @@
			}
			}

			}
			}

			/**
			* 盘点货物抵达盘点目标站 wrkMast.sourceLoc P ===>> O
			*/
			public void pickWrkCompleteStaNo0() {
			for (DevpSlave devp : slaveProperties.getDevp()) {
			// 遍历拣料入库口
			for (DevpSlave.Sta pickSta : devp.getPickOutSta()) {
			// 获取拣料入库站信息
			DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
			StaProtocol staProtocol = devpThread.getStation().get(pickSta.getStaNo());
			if (staProtocol == null) {
			continue;
			} else {
			staProtocol = staProtocol.clone();
			}
			if (staProtocol.getWorkNo() > 0) {
			// WrkMast wrkMast = wrkMastMapper.selectPick17(pickSta.getStaNo(), staProtocol.getWorkNo().intValue());
			// if (Cools.isEmpty(wrkMast)) {
			// log.error("{}站拣料、并板、盘点检索任务失败！任务号：{}", pickSta.getStaNo(), staProtocol.getWorkNo());
			// } else {
			// // 修改源库位状态 O.空库位
			// LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo());
			// if (locMast.getLocSts().equals("P")) {
			// locMast.setLocSts("O");
			// locMast.setModiTime(new Date());
			// if (!locMastService.updateById(locMast)) {
			// throw new CoolException(wrkMast.getWrkNo() + "修改源库位状态 O.空库位");
			// }
			// }
			// // 修改工作档
			// wrkMast.setIoPri(13D);
			// if (wrkMastMapper.updateById(wrkMast) == 0) {
			// log.error("更新工作档的优先级失败！！！ [工作号:{}]", wrkMast.getWrkNo());
			// }
			// }
			}

			}
			}
			}

			/**
			* 盘点货物抵达盘点目标站 wrkMast.sourceLoc P ===>> O
			*/
			public void pickWrkCompleteStaNo() {
			List<WrkMast> wrkMasts = wrkMastMapper.selectPick17(null, null);
			for (WrkMast wrkMast : wrkMasts) {
			// 修改源库位状态 O.空库位
			LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo());
			if (locMast.getLocSts().equals("P")) {
			locMast.setLocSts("O");
			locMast.setModiTime(new Date());
			if (!locMastService.updateById(locMast)) {
			throw new CoolException(wrkMast.getWrkNo() + "修改源库位状态 O.空库位");
			}
			}
			// 修改工作档
			wrkMast.setIoPri(13D);
			if (wrkMastMapper.updateById(wrkMast) == 0) {
			log.error("更新工作档的优先级失败！！！ [工作号:{}]", wrkMast.getWrkNo());
			}
			}
			}

			@@ -1264,6 +1329,11 @@
			SteThread steThread = queryIdleCar(wrkMast);
			if (steThread != null) {
			if (null == wrkMastMapper.selectPakout(slave.getId(), steNo)) {
			// 标记移库当前流程
			wrkMast.setMk("O");
			if (wrkMastMapper.updateById(wrkMast) == 0) {
			log.error("标记移库当前流程 I 失败！！，工作号={}", wrkMast.getWrkNo());
			}
			// 让小车等待搬运待续
			this.letCarBeReady(wrkMast, steThread.getSlave().getId(), wrkMast.getSourceLocNo());
			}
			@@ -1287,43 +1357,53 @@
			return;
			}

			//查找库位
			boolean flag = false;
			String[] deeplocs = Utils.getDeepLocs(wrkMast.getSourceLocNo());
			if(!Cools.isEmpty(deeplocs)){
			for(String deepLocNo : deeplocs) {
			LocMast deepLoc = locMastService.selectById(deepLocNo);
			if (wrkMast.getWrkSts() == 17) {
			//查找库位
			boolean flag = false;
			String[] deeplocs = Utils.getDeepLocs(wrkMast.getSourceLocNo());
			if(!Cools.isEmpty(deeplocs)){
			for(String deepLocNo : deeplocs) {
			LocMast deepLoc = locMastService.selectById(deepLocNo);
			// WrkMast waitWrkMast = wrkMastMapper.selectByLocNo(deepLocNo);
			if(deepLoc != null && !deepLoc.getLocSts().equals("F") && deepLoc.getLocSts().equals("D") && deepLoc.getLocSts().equals("O")){
			flag = true;
			break;
			}
			if(deepLoc != null && deepLoc.getLocSts().equals("O")){
			//修改移库工作档
			wrkMast.setSourceLocNo(wrkMast.getLocNo());
			wrkMast.setIoPri((double)9999);
			wrkMast.setWrkSts(2L);
			wrkMast.setLocNo(deepLocNo);
			wrkMast.setSteNo(null);
			wrkMast.setModiTime(new Date());
			if (wrkMastMapper.updateById(wrkMast) == 0) {
			log.error("修改工作档状态 11.生成出库ID => 12.吊车出库中失败！！，工作号={}", wrkMast.getWrkNo());
			if(deepLoc != null && !deepLoc.getLocSts().equals("F") && deepLoc.getLocSts().equals("D") && deepLoc.getLocSts().equals("O")){
			flag = true;
			break;
			}

			if(deepLoc.getLocSts().equals("O")){
			deepLoc.setLocSts("S"); // S.入库预约
			deepLoc.setModiTime(new Date());
			if (!locMastService.updateById(deepLoc)) {
			log.error("双深库位 --- 更新目标库位状态失败！待移转浅库位：" + deepLoc.getLocNo());
			throw new CoolException("更新移库回库目标库位状态失败");
			if(deepLoc != null && deepLoc.getLocSts().equals("O")){
			//修改移库工作档
			wrkMast.setSourceLocNo(wrkMast.getLocNo());
			wrkMast.setIoPri((double)9999);
			wrkMast.setWrkSts(2L);
			wrkMast.setLocNo(deepLocNo);
			wrkMast.setSteNo(null);
			wrkMast.setModiTime(new Date());
			if (wrkMastMapper.updateById(wrkMast) == 0) {
			log.error("修改工作档状态 11.生成出库ID => 12.吊车出库中失败！！，工作号={}", wrkMast.getWrkNo());
			}

			if(deepLoc.getLocSts().equals("O")){
			deepLoc.setLocSts("S"); // S.入库预约
			deepLoc.setModiTime(new Date());
			if (!locMastService.updateById(deepLoc)) {
			log.error("双深库位 --- 更新目标库位状态失败！待移转浅库位：" + deepLoc.getLocNo());
			throw new CoolException("更新移库回库目标库位状态失败");
			}
			}
			LocMast sourceLoc = locMastService.selectById(wrkMast.getSourceLocNo());
			// if(sourceLoc.getLocSts().equals("F")){
			sourceLoc.setLocSts("R"); // R.出库预约
			sourceLoc.setModiTime(new Date());
			if (!locMastService.updateById(sourceLoc)) {
			throw new CoolException("更新移库回库目标库位状态失败");
			}
			// }
			break;
			}
			break;
			}
			}
			}
			if(flag){
			return;
			if(flag){
			return;
			}
			}

			// 获取源库位信息
			@@ -1426,6 +1506,11 @@
			if (steThread != null) {
			// 没有其他任务
			if (null == wrkMastMapper.selectPakin(slave.getId(), steNo)) {
			// 标记移库当前流程
			wrkMast.setMk("I");
			if (wrkMastMapper.updateById(wrkMast) == 0) {
			log.error("标记移库当前流程 I 失败！！，工作号={}", wrkMast.getWrkNo());
			}
			// 让小车等待搬运待续
			this.letCarBeReady(wrkMast, steThread.getSlave().getId(), wrkMast.getLocNo());
			}
			@@ -2325,134 +2410,140 @@
			}
			// 入库 ===>> 迁出小车完成
			}
			// if (wrkMast.getWrkSts() == 16) {
			// Date now = new Date();
			//// if (locMastService.isOutMost(wrkMast.getLocNo())) {
			//// // 16.吊车出库中 ==> 9.入库完成
			//// wrkMast.setWrkSts(9L);
			//// wrkMast.setCrnEndTime(now);
			//// } else {
			//// // 16.吊车出库中 ==> 9.入库完成
			//// wrkMast.setWrkSts(9L);
			//// }
			if (wrkMast.getWrkSts() == 16) {
			Date now = new Date();
			// if (locMastService.isOutMost(wrkMast.getLocNo())) {
			// wrkMast.setWrkSts(17L);
			// }
			// wrkMast.setModiTime(now);
			// // 修改成功后复位堆垛机
			// if (wrkMastMapper.updateById(wrkMast) > 0) {
			// // 堆垛机复位
			// crnThread.setResetFlag(true);
			// } else {
			// log.error("修改工作档状态 16.吊车出库中失败！！，工作号={}", wrkMast.getWrkNo());
			// }
			// } else if (wrkMast.getWrkSts() == 4) {
			// // 4.迁入小车 ==> 6.小车待入
			// wrkMast.setWrkSts(6L);
			// Date now = new Date();
			// wrkMast.setCrnEndTime(now);
			// wrkMast.setModiTime(now);
			// // 修改成功后复位堆垛机
			// if (wrkMastMapper.updateById(wrkMast) > 0) {
			// // 堆垛机复位
			// crnThread.setResetFlag(true);
			// // 穿梭车重新定位排列层
			// SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, wrkMast.getSteNo());
			// if (!steThread.confirmPos()) {
			// log.error("{}号穿梭车重新定位失败！作业工作档任务号：{}", wrkMast.getSteNo(), wrkMast.getWrkNo());
			// }
			// // 穿梭车去待机位
			// BasSte basSte = basSteService.selectById(wrkMast.getSteNo());
			// SteCommand steCommand = new SteCommand();
			// steCommand.setSteNo(wrkMast.getSteNo()); // 穿梭车编号
			// steCommand.setTaskNo(9999); // 工作号
			// steCommand.setTaskMode(SteTaskModeType.findWaiting(basSte.getRow())); // 任务模式: 去近点等待堆垛机叉取
			//// steCommand.setRow(Utils.getGroupRow(steProtocol.getRow().intValue()).shortValue());
			//// steCommand.setBay(steProtocol.getBay());
			//// steCommand.setLev(steProtocol.getLev());
			// if (!MessageQueue.offer(SlaveType.Ste, wrkMast.getSteNo(), new Task(2, steCommand))) {
			// log.error("穿梭车待机位命令下发失败，穿梭车号={}，任务数据={}", wrkMast.getSteNo(), JSON.toJSON(steCommand));
			// }
			// } else {
			// log.error("修改工作档状态 4.迁入小车 => 6.小车待入失败！！，工作号={}", wrkMast.getWrkNo());
			// }
			// // 入库 ===>> 迁出小车完成
			// } else if (wrkMast.getWrkSts() == 7){
			// // 判断是否需要小车入库
			// if (locMastService.isOutMost(wrkMast.getLocNo())) {
			// // ==> 9.入库完成
			// // 16.吊车出库中 ==> 9.入库完成
			// wrkMast.setWrkSts(9L);
			// Date now = new Date();
			// wrkMast.setCrnEndTime(now);
			// wrkMast.setModiTime(now);
			// // 修改成功后复位堆垛机
			// if (wrkMastMapper.updateById(wrkMast) > 0) {
			// // 堆垛机复位
			// crnThread.setResetFlag(true);
			// } else {
			// log.error("修改工作档状态 7.吊车入库中 => 9.入库完成失败！！，工作号={}", wrkMast.getWrkNo());
			// }
			// } else {
			// // 给穿梭车下发命令
			// Integer steNo = wrkMast.getSteNo();
			// SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, steNo);
			// SteProtocol steProtocol = steThread.getSteProtocol();
			// if (steProtocol == null) { continue; }
			// if (steProtocol.isIdle()) {
			// // 命令下发区 --------------------------------------------------------------------------
			// SteCommand steCommand = new SteCommand();
			// steCommand.setSteNo(steNo); // 穿梭车编号
			// steCommand.setTaskNo(wrkMast.getWrkNo()); // 工作号
			// steCommand.setTaskMode(SteTaskModeType.findInByLoc(wrkMast.getLocNo())); // 任务模式: 搬入库
			// if (!MessageQueue.offer(SlaveType.Ste, steNo, new Task(2, steCommand))) {
			// log.error("穿梭车命令下发失败，穿梭车号={}，任务数据={}", steNo, JSON.toJSON(steCommand));
			// } else {
			// // 修改工作档状态 7.吊车入库中 => 8.小车搬入库
			// wrkMast.setWrkSts(8L);
			// Date now = new Date();
			// wrkMast.setCrnEndTime(now);
			// wrkMast.setModiTime(now);
			// if (wrkMastMapper.updateById(wrkMast) > 0) {
			// // 堆垛机复位
			// crnThread.setResetFlag(true);
			// } else {
			// log.error("修改工作档状态 7.吊车入库中 => 8.小车搬入库失败！！，工作号={}", wrkMast.getWrkNo());
			// }
			// }
			// // 16.吊车出库中 ==> 9.入库完成
			// wrkMast.setWrkSts(9L);
			// }
			if (locMastService.isOutMost(wrkMast.getLocNo())) {
			wrkMast.setWrkSts(17L);
			// LocMast locMast = locMastService.selectById(wrkMast.getLocNo());
			// locMast.setLocSts("F");
			// locMast.setModiTime(new Date());
			// if (!locMastService.updateById(locMast)) {
			// log.error("");
			// }
			// }
			// } else if (wrkMast.getWrkSts() == 13) {
			// // 给穿梭车下发命令
			// Integer steNo = wrkMast.getSteNo();
			// SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, steNo);
			// SteProtocol steProtocol = steThread.getSteProtocol();
			// if (steProtocol == null) { continue; }
			// // 穿梭车重新定位排列层
			// if (!steThread.confirmPos()) {
			// log.error("{}号穿梭车重新定位失败！作业工作档任务号：{}", wrkMast.getSteNo(), wrkMast.getWrkNo());
			// }
			// // 命令下发区 --------------------------------------------------------------------------
			// SteCommand steCommand = new SteCommand();
			// steCommand.setSteNo(steNo); // 穿梭车编号
			// steCommand.setTaskNo(wrkMast.getWrkNo()); // 工作号
			// steCommand.setTaskMode(SteTaskModeType.findOutByLoc(wrkMast.getSourceLocNo())); // 任务模式: 搬出库
			// if (!MessageQueue.offer(SlaveType.Ste, steNo, new Task(2, steCommand))) {
			// log.error("穿梭车命令下发失败，穿梭车号={}，任务数据={}", steNo, JSON.toJSON(steCommand));
			// } else {
			// // 13.迁入小车 ==> 14.小车搬出库
			// wrkMast.setWrkSts(14L);
			// Date now = new Date();
			// wrkMast.setCrnEndTime(now);
			// wrkMast.setModiTime(now);
			// // 修改成功后复位堆垛机
			// if (wrkMastMapper.updateById(wrkMast) > 0) {
			// // 堆垛机复位
			// crnThread.setResetFlag(true);
			// } else {
			// log.error("修改工作档状态 13.迁入小车 ==> 14.小车搬出库失败！！，工作号={}", wrkMast.getWrkNo());
			// }
			// }
			// }
			}
			wrkMast.setModiTime(now);
			// 修改成功后复位堆垛机
			if (wrkMastMapper.updateById(wrkMast) > 0) {
			// 堆垛机复位
			crnThread.setResetFlag(true);
			} else {
			log.error("修改工作档状态 16.吊车出库中失败！！，工作号={}", wrkMast.getWrkNo());
			}
			} else if (wrkMast.getWrkSts() == 4) {
			// 4.迁入小车 ==> 6.小车待入
			wrkMast.setWrkSts(6L);
			Date now = new Date();
			wrkMast.setCrnEndTime(now);
			wrkMast.setModiTime(now);
			// 修改成功后复位堆垛机
			if (wrkMastMapper.updateById(wrkMast) > 0) {
			// 堆垛机复位
			crnThread.setResetFlag(true);
			// 穿梭车重新定位排列层
			SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, wrkMast.getSteNo());
			if (!steThread.confirmPos()) {
			log.error("{}号穿梭车重新定位失败！作业工作档任务号：{}", wrkMast.getSteNo(), wrkMast.getWrkNo());
			}
			// 穿梭车去待机位
			BasSte basSte = basSteService.selectById(wrkMast.getSteNo());
			SteCommand steCommand = new SteCommand();
			steCommand.setSteNo(wrkMast.getSteNo()); // 穿梭车编号
			steCommand.setTaskNo(9999); // 工作号
			steCommand.setTaskMode(SteTaskModeType.findWaiting(basSte.getRow())); // 任务模式: 去近点等待堆垛机叉取
			// steCommand.setRow(Utils.getGroupRow(steProtocol.getRow().intValue()).shortValue());
			// steCommand.setBay(steProtocol.getBay());
			// steCommand.setLev(steProtocol.getLev());
			if (!MessageQueue.offer(SlaveType.Ste, wrkMast.getSteNo(), new Task(2, steCommand))) {
			log.error("穿梭车待机位命令下发失败，穿梭车号={}，任务数据={}", wrkMast.getSteNo(), JSON.toJSON(steCommand));
			}
			} else {
			log.error("修改工作档状态 4.迁入小车 => 6.小车待入失败！！，工作号={}", wrkMast.getWrkNo());
			}
			// 入库 ===>> 迁出小车完成
			} else if (wrkMast.getWrkSts() == 7){
			// 判断是否需要小车入库
			if (locMastService.isOutMost(wrkMast.getLocNo())) {
			// ==> 9.入库完成
			wrkMast.setWrkSts(9L);
			Date now = new Date();
			wrkMast.setCrnEndTime(now);
			wrkMast.setModiTime(now);
			// 修改成功后复位堆垛机
			if (wrkMastMapper.updateById(wrkMast) > 0) {
			// 堆垛机复位
			crnThread.setResetFlag(true);
			} else {
			log.error("修改工作档状态 7.吊车入库中 => 9.入库完成失败！！，工作号={}", wrkMast.getWrkNo());
			}
			} else {
			// 给穿梭车下发命令
			Integer steNo = wrkMast.getSteNo();
			SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, steNo);
			SteProtocol steProtocol = steThread.getSteProtocol();
			if (steProtocol == null) { continue; }
			if (steProtocol.isIdle()) {
			// 命令下发区 --------------------------------------------------------------------------
			SteCommand steCommand = new SteCommand();
			steCommand.setSteNo(steNo); // 穿梭车编号
			steCommand.setTaskNo(wrkMast.getWrkNo()); // 工作号
			steCommand.setTaskMode(SteTaskModeType.findInByLoc(wrkMast.getLocNo())); // 任务模式: 搬入库
			if (!MessageQueue.offer(SlaveType.Ste, steNo, new Task(2, steCommand))) {
			log.error("穿梭车命令下发失败，穿梭车号={}，任务数据={}", steNo, JSON.toJSON(steCommand));
			} else {
			// 修改工作档状态 7.吊车入库中 => 8.小车搬入库
			wrkMast.setWrkSts(8L);
			Date now = new Date();
			wrkMast.setCrnEndTime(now);
			wrkMast.setModiTime(now);
			if (wrkMastMapper.updateById(wrkMast) > 0) {
			// 堆垛机复位
			crnThread.setResetFlag(true);
			} else {
			log.error("修改工作档状态 7.吊车入库中 => 8.小车搬入库失败！！，工作号={}", wrkMast.getWrkNo());
			}
			}
			}
			}
			} else if (wrkMast.getWrkSts() == 13) {
			// 给穿梭车下发命令
			Integer steNo = wrkMast.getSteNo();
			SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, steNo);
			SteProtocol steProtocol = steThread.getSteProtocol();
			if (steProtocol == null) { continue; }
			// 穿梭车重新定位排列层
			if (!steThread.confirmPos()) {
			log.error("{}号穿梭车重新定位失败！作业工作档任务号：{}", wrkMast.getSteNo(), wrkMast.getWrkNo());
			}
			// 命令下发区 --------------------------------------------------------------------------
			SteCommand steCommand = new SteCommand();
			steCommand.setSteNo(steNo); // 穿梭车编号
			steCommand.setTaskNo(wrkMast.getWrkNo()); // 工作号
			steCommand.setTaskMode(SteTaskModeType.findOutByLoc(wrkMast.getSourceLocNo())); // 任务模式: 搬出库
			if (!MessageQueue.offer(SlaveType.Ste, steNo, new Task(2, steCommand))) {
			log.error("穿梭车命令下发失败，穿梭车号={}，任务数据={}", steNo, JSON.toJSON(steCommand));
			} else {
			// 13.迁入小车 ==> 14.小车搬出库
			wrkMast.setWrkSts(14L);
			Date now = new Date();
			wrkMast.setCrnEndTime(now);
			wrkMast.setModiTime(now);
			// 修改成功后复位堆垛机
			if (wrkMastMapper.updateById(wrkMast) > 0) {
			// 堆垛机复位
			crnThread.setResetFlag(true);
			} else {
			log.error("修改工作档状态 13.迁入小车 ==> 14.小车搬出库失败！！，工作号={}", wrkMast.getWrkNo());
			}
			}
			}
			}
			}
			}
			@@ -2544,23 +2635,23 @@
			// 修改工作档状态 11.生成出库ID => 12.小车待搬
			wrkMast.setWrkSts(12L);
			} else {
			// if (Cools.isEmpty(wrkMast.getMk())) {
			// log.error("移库工作档没有流程标记！！，工作号={}", wrkMast.getWrkNo());
			// } else {
			// if (wrkMast.getMk().equals("I")) {
			// String locNo = wrkMast.getLocNo();
			// if (Utils.getGroupRow(locNo).equals(Utils.getGroupRow(steProtocol.getRow().intValue())) && steProtocol.getBay() == Utils.getBay(locNo) && steProtocol.getLev() == Utils.getLev(locNo)) {
			// // 修改工作档状态 11.生成出库ID => 6.小车待入
			// wrkMast.setWrkSts(6L);
			// } else {
			// // 修改工作档状态 11.生成出库ID => 3.小车待搬
			// wrkMast.setWrkSts(3L);
			// }
			// } else if (wrkMast.getMk().equals("O")) {
			// // 修改工作档状态 11.生成出库ID => 12.小车待搬
			// wrkMast.setWrkSts(12L);
			// }
			// }
			if (Cools.isEmpty(wrkMast.getMk())) {
			log.error("移库工作档没有流程标记！！，工作号={}", wrkMast.getWrkNo());
			} else {
			if (wrkMast.getMk().equals("I")) {
			String locNo = wrkMast.getLocNo();
			if (Utils.getGroupRow(locNo).equals(Utils.getGroupRow(steProtocol.getRow().intValue())) && steProtocol.getBay() == Utils.getBay(locNo) && steProtocol.getLev() == Utils.getLev(locNo)) {
			// 修改工作档状态 11.生成出库ID => 6.小车待入
			wrkMast.setWrkSts(6L);
			} else {
			// 修改工作档状态 11.生成出库ID => 3.小车待搬
			wrkMast.setWrkSts(3L);
			}
			} else if (wrkMast.getMk().equals("O")) {
			// 修改工作档状态 11.生成出库ID => 12.小车待搬
			wrkMast.setWrkSts(12L);
			}
			}
			}
			wrkMast.setModiTime(now);
			if (wrkMastMapper.updateById(wrkMast) == 0) {