zy-wcs.git - Gitblit

			@@ -12,7 +12,6 @@
			import com.zy.asrs.domain.enums.WorkNoType;
			import com.zy.asrs.domain.param.CrnOperatorParam;
			import com.zy.asrs.entity.*;
			import com.zy.asrs.entity.param.Result;
			import com.zy.asrs.entity.param.StorageEscalationParam;
			import com.zy.asrs.entity.param.TaskOverToWms;
			import com.zy.asrs.mapper.BasCrnErrorMapper;
			@@ -302,81 +301,56 @@
			} else {
			staProtocol = staProtocol.clone();
			}
			Short workNo = staProtocol.getWorkNo();
			Short stano = staProtocol.getStaNo();
			//led
			LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed());

			// 尺寸检测异常
			boolean back = false;
			String errMsg = "";
			if (staProtocol.isFrontErr()) {
			errMsg = "前超限";
			back = true;
			}
			if (!back && staProtocol.isBackErr()) {
			errMsg = "后超限";
			back = true;
			}
			if (!back && staProtocol.isHighErr()) {
			errMsg = "高超限";
			back = true;
			}
			if (!back && staProtocol.isLeftErr()) {
			errMsg = "左超限";
			back = true;
			}
			if (!back && staProtocol.isRightErr()) {
			errMsg = "右超限";
			back = true;
			}
			if (!back && staProtocol.isWeightErr()) {
			errMsg = "超重";
			back = true;
			}
			// if (!back && staProtocol.isBarcodeErr()) {
			// errMsg = "扫码失败";
			// back = true;
			// }
			// 判断是否满足入库条件
			if (staProtocol.isAutoing() && staProtocol.isLoading()
			&& staProtocol.isInEnable()
			&& workNo >= 9990
			&& staProtocol.isPakMk()) {
			if (back) {
			// led 异常显示
			if (ledThread != null) {
			String errorMsg = errMsg;
			MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
			}
			}
			if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isPakMk() && staProtocol.getWorkNo() == 0) {

			TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().orderBy("create_time"));
			TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("wrk_sts",1).orderBy("create_time"));
			if (taskWrk != null) {
			HashMap<String, Object> hashMap = new HashMap<>();
			hashMap.put("TaskNo", taskWrk.getTaskNo());
			//开始上报,任务开始时，WCS回调WMS
			String response = new HttpHandler.Builder()
			.setUri(wmsUrl)
			.setPath(taskStatusFeedbackPath)
			.setJson(JSON.toJSONString(hashMap))
			.build()
			.doPost();
			JSONObject jsonObject1 = JSON.parseObject(response);
			Boolean bool = false;
			if (jsonObject1.get("ReturnStatus").equals(0)) {
			taskWrk.setStatus(2);//派发任务
			bool = true;
			taskWrkService.updateById(taskWrk);
			log.info("下发输送线任务：taskWrk:" + JSON.toJSONString(taskWrk));
			staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue());
			staProtocol.setStaNo(staProtocol.getSiteId().shortValue());
			boolean offer = false;
			try {
			offer = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
			} catch (Exception e) {
			log.error("下发输送线任务失败：异常:" + e);
			log.error("下发输送线任务失败：异常:offer:" + offer);
			}
			apiLogService.save("wcs开始入库任务上报wms"
			, wmsUrl + TaskExecCallback
			, null
			, "127.0.0.1"
			, JSON.toJSONString(hashMap)
			, response
			, bool
			);
			if (offer) {
			log.info("下发输送线任务成功：taskWrk:" + JSON.toJSONString(taskWrk));
			taskWrk.setStatus(1);
			taskWrk.setWrkSts(2);
			taskWrkService.updateById(taskWrk);

			HashMap<String, Object> hashMap = new HashMap<>();
			hashMap.put("TaskNo", taskWrk.getTaskNo());
			//开始上报,任务开始时，WCS回调WMS
			String response = new HttpHandler.Builder()
			.setUri(wmsUrl)
			.setPath(taskStatusFeedbackPath)
			.setJson(JSON.toJSONString(hashMap))
			.build()
			.doPost();
			JSONObject jsonObject1 = JSON.parseObject(response);
			Boolean bool = false;
			if (jsonObject1.get("ReturnStatus").equals(0)) {
			taskWrk.setStatus(2);//派发任务
			bool = true;
			taskWrkService.updateById(taskWrk);
			}
			apiLogService.save("wcs开始入库任务上报wms"
			, wmsUrl + TaskExecCallback
			, null
			, "127.0.0.1"
			, JSON.toJSONString(hashMap)
			, response
			, bool
			);
			} else {
			log.error("下发输送线任务失败：taskWrk:" + JSON.toJSONString(taskWrk));
			// log.error("下发输送线任务失败：异常信息:"+JSON.toJSONString(r));
			}
			}
			}
			}
			@@ -388,172 +362,172 @@
			}
			}

			//拣料回库
			public synchronized void PickingAndReturningToTheWarehouse() throws IOException, InterruptedException {
			try {
			// 根据输送线plc遍历
			for (DevpSlave devp : slaveProperties.getDevp()) {
			// 遍历入库口
			for (DevpSlave.Sta inSta : devp.getPickSta()) {
			StorageEscalationParam storageEscalationParam = new StorageEscalationParam();
			// 获取入库站信息
			DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
			StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
			if (staProtocol == null) {
			continue;
			} else {
			staProtocol = staProtocol.clone();
			}
			Short workNo = staProtocol.getWorkNo();
			//led
			LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed());

			// 判断是否满足入库条件
			if (staProtocol.isAutoing() && staProtocol.isLoading()
			&& staProtocol.isInEnable()
			&& staProtocol.isPakMk()) {
			// 获取条码扫描仪信息
			String BoxNo = "";
			//站点拣料回库任务是会有一条
			TaskWrk taskWrkk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("start_point", staProtocol.getSiteId()));
			if (!Cools.isEmpty(taskWrkk)) {
			continue;
			}
			if (!staProtocol.isEmptyMk() && staProtocol.getWorkNo() < 9990) {

			TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("wrk_no", workNo));

			if (!Cools.isEmpty(taskWrk1)) {
			BoxNo = taskWrk1.getBarcode();
			} else {
			TaskWrkLog taskWrkLog = taskWrkLogService.selectOne(new EntityWrapper<TaskWrkLog>().eq("wrk_no", workNo).orderBy("modi_time", false));
			if (taskWrkLog != null) {
			BoxNo = taskWrkLog.getBarcode();
			}
			}
			}
			log.info("组托入库={}", storageEscalationParam);
			storageEscalationParam.setBoxNo(BoxNo);
			//是否满板 1满板 0空板
			storageEscalationParam.setStaType(staProtocol.isEmptyMk() ? 0 : 1);
			//库位类型 1高库位 0低库位
			storageEscalationParam.setLocType(staProtocol.isHigh() ? 1 : 0);
			storageEscalationParam.setTerminalNo(staProtocol.getSiteId());
			String response = "";
			Boolean success = false;
			try {
			response = new HttpHandler.Builder()
			.setUri(wmsUrl)
			.setPath(inboundTaskApplyPath)
			.setJson(JSON.toJSONString(storageEscalationParam))
			.build()
			.doPost();
			JSONObject jsonObject = JSON.parseObject(response);

			if (!Cools.isEmpty(response) && !Cools.isEmpty(jsonObject.get("ReturnStatus")) && jsonObject.get("ReturnStatus").equals(0) && !Cools.isEmpty(jsonObject.get("Result").toString())) {
			Result result = JSON.parseObject(jsonObject.get("Result").toString(), Result.class);

			// 创新一个入库工作档
			TaskWrk taskWrk = taskWrkService.selectByTaskNo(result.getTaskNo());
			if (Cools.isEmpty(taskWrk)) {
			taskWrk = createTask1(result, BoxNo, staProtocol.getSiteId());
			if (Cools.isEmpty(taskWrk)) {
			log.error("库位异常，库位号：={}", taskWrk.getOriginTargetPoint());
			} else {
			taskWrkService.insert(taskWrk);
			StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
			.eq("crn_no", taskWrk.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId()));
			staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue());
			staProtocol.setStaNo(staDesc.getCrnStn().shortValue());
			MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
			HashMap<String, Object> hashMap = new HashMap<>();
			hashMap.put("TaskNo", taskWrk.getTaskNo());
			try {
			//开始上报,任务开始时，WCS回调WMS
			response = new HttpHandler.Builder()
			.setUri(wmsUrl)
			.setPath(taskStatusFeedbackPath)
			.setJson(JSON.toJSONString(hashMap))
			.build()
			.doPost();
			JSONObject jsonObject1 = JSON.parseObject(response);
			Boolean bool = false;
			if (jsonObject1.get("ReturnStatus").equals(0)) {
			taskWrk.setStatus(2);//派发任务
			bool = true;
			taskWrkService.updateById(taskWrk);
			}
			apiLogService.save("wcs开始入库任务上报wms"
			, wmsUrl + TaskExecCallback
			, null
			, "127.0.0.1"
			, JSON.toJSONString(hashMap)
			, response
			, bool
			);
			} catch (Exception e) {

			}
			}
			} else {
			// led 异常显示
			if (ledThread != null) {
			String errorMsg = "任务已存在！！！！";
			MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
			}
			staProtocol.setWorkNo((short) 9991);
			staProtocol.setStaNo(inSta.getBackSta().shortValue());
			devpThread.setPakMk(staProtocol.getSiteId(), false);
			MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
			}

			} else {
			// led 异常显示
			if (ledThread != null) {
			String errorMsg = jsonObject.getString("ErrorMessage");
			MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
			}
			staProtocol.setWorkNo((short) 9991);
			staProtocol.setStaNo(inSta.getBackSta().shortValue());
			devpThread.setPakMk(staProtocol.getSiteId(), false);
			MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
			}

			} catch (Exception e) {
			log.error("请求入库调用接口失败");
			log.error("异常信息打印：" + e);
			try {
			BasDevp basDevp = basDevpService.selectById(inSta.getStaNo());
			if (Cools.isEmpty(basDevp)) {
			log.error("站点号异常" + inSta.getStaNo());
			} else if (basDevp.getStaErr() != 0) {
			basDevp.setStaErr(2);
			basDevpService.updateById(basDevp);
			}
			} catch (Exception e1) {
			// 退回
			log.error("扫码检测程序异常" + inSta.getStaNo() + "异常信息" + e1);
			}
			} finally {
			apiLogService.save("wms请求入库货位接口"
			, wmsUrl + inboundTaskApplyPath
			, null
			, "127.0.0.1"
			, JSON.toJSONString(storageEscalationParam)
			, response
			, success
			);
			}
			log.info("入库请求参数=" + JSON.toJSONString(BoxNo));
			log.info("入库请求返回参数=" + JSON.toJSONString(response));
			}
			}
			}
			} catch (Exception e) {
			log.error("generateStoreWrkFile e", e);
			TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
			}
			}
			// //拣料回库
			// public synchronized void PickingAndReturningToTheWarehouse() throws IOException, InterruptedException {
			// try {
			// // 根据输送线plc遍历
			// for (DevpSlave devp : slaveProperties.getDevp()) {
			// // 遍历入库口
			// for (DevpSlave.Sta inSta : devp.getPickSta()) {
			// StorageEscalationParam storageEscalationParam = new StorageEscalationParam();
			// // 获取入库站信息
			// DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
			// StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
			// if (staProtocol == null) {
			// continue;
			// } else {
			// staProtocol = staProtocol.clone();
			// }
			// Short workNo = staProtocol.getWorkNo();
			// //led
			// LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed());
			//
			// // 判断是否满足入库条件
			// if (staProtocol.isAutoing() && staProtocol.isLoading()
			// && staProtocol.isInEnable()
			// && staProtocol.isPakMk()) {
			// // 获取条码扫描仪信息
			// String BoxNo = "";
			// //站点拣料回库任务是会有一条
			// TaskWrk taskWrkk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("start_point", staProtocol.getSiteId()));
			// if (!Cools.isEmpty(taskWrkk)) {
			// continue;
			// }
			// if (!staProtocol.isEmptyMk() && staProtocol.getWorkNo() < 9990) {
			//
			// TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("wrk_no", workNo));
			//
			// if (!Cools.isEmpty(taskWrk1)) {
			// BoxNo = taskWrk1.getBarcode();
			// } else {
			// TaskWrkLog taskWrkLog = taskWrkLogService.selectOne(new EntityWrapper<TaskWrkLog>().eq("wrk_no", workNo).orderBy("modi_time", false));
			// if (taskWrkLog != null) {
			// BoxNo = taskWrkLog.getBarcode();
			// }
			// }
			// }
			// log.info("组托入库={}", storageEscalationParam);
			// storageEscalationParam.setBoxNo(BoxNo);
			// //是否满板 1满板 0空板
			// storageEscalationParam.setStaType(staProtocol.isEmptyMk() ? 0 : 1);
			// //库位类型 1高库位 0低库位
			// storageEscalationParam.setLocType(staProtocol.isHigh() ? 1 : 0);
			// storageEscalationParam.setTerminalNo(staProtocol.getSiteId());
			// String response = "";
			// Boolean success = false;
			// try {
			// response = new HttpHandler.Builder()
			// .setUri(wmsUrl)
			// .setPath(inboundTaskApplyPath)
			// .setJson(JSON.toJSONString(storageEscalationParam))
			// .build()
			// .doPost();
			// JSONObject jsonObject = JSON.parseObject(response);
			//
			// if (!Cools.isEmpty(response) && !Cools.isEmpty(jsonObject.get("ReturnStatus")) && jsonObject.get("ReturnStatus").equals(0) && !Cools.isEmpty(jsonObject.get("Result").toString())) {
			// Result result = JSON.parseObject(jsonObject.get("Result").toString(), Result.class);
			//
			// // 创新一个入库工作档
			// TaskWrk taskWrk = taskWrkService.selectByTaskNo(result.getTaskNo());
			// if (Cools.isEmpty(taskWrk)) {
			// taskWrk = createTask1(result, BoxNo, staProtocol.getSiteId());
			// if (Cools.isEmpty(taskWrk)) {
			// log.error("库位异常，库位号：={}", taskWrk.getOriginTargetPoint());
			// } else {
			// taskWrkService.insert(taskWrk);
			// StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
			// .eq("crn_no", taskWrk.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId()));
			// staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue());
			// staProtocol.setStaNo(staDesc.getCrnStn().shortValue());
			// MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
			// HashMap<String, Object> hashMap = new HashMap<>();
			// hashMap.put("TaskNo", taskWrk.getTaskNo());
			// try {
			// //开始上报,任务开始时，WCS回调WMS
			// response = new HttpHandler.Builder()
			// .setUri(wmsUrl)
			// .setPath(taskStatusFeedbackPath)
			// .setJson(JSON.toJSONString(hashMap))
			// .build()
			// .doPost();
			// JSONObject jsonObject1 = JSON.parseObject(response);
			// Boolean bool = false;
			// if (jsonObject1.get("ReturnStatus").equals(0)) {
			// taskWrk.setStatus(2);//派发任务
			// bool = true;
			// taskWrkService.updateById(taskWrk);
			// }
			// apiLogService.save("wcs开始入库任务上报wms"
			// , wmsUrl + TaskExecCallback
			// , null
			// , "127.0.0.1"
			// , JSON.toJSONString(hashMap)
			// , response
			// , bool
			// );
			// } catch (Exception e) {
			//
			// }
			// }
			// } else {
			// // led 异常显示
			// if (ledThread != null) {
			// String errorMsg = "任务已存在！！！！";
			// MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
			// }
			// staProtocol.setWorkNo((short) 9991);
			// staProtocol.setStaNo(inSta.getBackSta().shortValue());
			// devpThread.setPakMk(staProtocol.getSiteId(), false);
			// MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
			// }
			//
			// } else {
			// // led 异常显示
			// if (ledThread != null) {
			// String errorMsg = jsonObject.getString("ErrorMessage");
			// MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
			// }
			// staProtocol.setWorkNo((short) 9991);
			// staProtocol.setStaNo(inSta.getBackSta().shortValue());
			// devpThread.setPakMk(staProtocol.getSiteId(), false);
			// MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
			// }
			//
			// } catch (Exception e) {
			// log.error("请求入库调用接口失败");
			// log.error("异常信息打印：" + e);
			// try {
			// BasDevp basDevp = basDevpService.selectById(inSta.getStaNo());
			// if (Cools.isEmpty(basDevp)) {
			// log.error("站点号异常" + inSta.getStaNo());
			// } else if (basDevp.getStaErr() != 0) {
			// basDevp.setStaErr(2);
			// basDevpService.updateById(basDevp);
			// }
			// } catch (Exception e1) {
			// // 退回
			// log.error("扫码检测程序异常" + inSta.getStaNo() + "异常信息" + e1);
			// }
			// } finally {
			// apiLogService.save("wms请求入库货位接口"
			// , wmsUrl + inboundTaskApplyPath
			// , null
			// , "127.0.0.1"
			// , JSON.toJSONString(storageEscalationParam)
			// , response
			// , success
			// );
			// }
			// log.info("入库请求参数=" + JSON.toJSONString(BoxNo));
			// log.info("入库请求返回参数=" + JSON.toJSONString(response));
			// }
			// }
			// }
			// } catch (Exception e) {
			// log.error("generateStoreWrkFile e", e);
			// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
			// }
			// }

			public synchronized void generateStoreWrkFile() throws IOException, InterruptedException {
			try {
			@@ -853,28 +827,27 @@
			if (taskWrk == null) {
			continue;
			}
			// log.info("下发输送线任务：taskWrk:" + JSON.toJSONString(taskWrk));
			//// R r = siteController.siteDetlUpdate(Integer.valueOf(taskWrk.getTargetPoint()), taskWrk.getWrkNo().shortValue(), (short) 0, "Y", false, false);
			// staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue());
			// staProtocol.setStaNo(staDesc.getStnNo().shortValue());
			// boolean offer = false;
			// try {
			// offer = MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol));
			// } catch (Exception e) {
			// log.error("下发输送线任务失败：异常:" + e);
			// log.error("下发输送线任务失败：异常:offer:" + offer);
			// }
			log.info("下发输送线任务：taskWrk:" + JSON.toJSONString(taskWrk));
			// R r = siteController.siteDetlUpdate(Integer.valueOf(taskWrk.getTargetPoint()), taskWrk.getWrkNo().shortValue(), (short) 0, "Y", false, false);
			staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue());
			staProtocol.setStaNo(staDesc.getStnNo().shortValue());
			boolean offer = false;
			try {
			offer = MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol));
			} catch (Exception e) {
			log.error("下发输送线任务失败：异常:" + e);
			log.error("下发输送线任务失败：异常:offer:" + offer);
			}
			// JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(r));
			// if (offer) {
			// log.info("下发输送线任务成功：taskWrk:" + JSON.toJSONString(taskWrk));
			if (offer) {
			log.info("下发输送线任务成功：taskWrk:" + JSON.toJSONString(taskWrk));
			taskWrk.setStatus(5);
			taskWrk.setWrkSts(14);
			taskWrkService.updateById(taskWrk);

			// } else {
			// log.error("下发输送线任务失败：taskWrk:" + JSON.toJSONString(taskWrk));
			//// log.error("下发输送线任务失败：异常信息:"+JSON.toJSONString(r));
			// }
			} else {
			log.error("下发输送线任务失败：taskWrk:" + JSON.toJSONString(taskWrk));
			// log.error("下发输送线任务失败：异常信息:"+JSON.toJSONString(r));
			}
			}
			} catch (Exception e) {
			log.error("出库到出库站异常:异常信息：" + e);
			@@ -1705,31 +1678,31 @@
			return response;
			}

			private TaskWrk createTask1(Result result, String barcode, Integer staNo) {
			String locNo = Utils.Fusion(result.getRow(), result.getFloor(), result.getColumn());

			Date now = new Date();
			TaskWrk taskWrk = new TaskWrk();
			int workNo1 = commonService.getWorkNo(WorkNoType.PAKIN.type);//获取入库工作号
			taskWrk.setTaskNo(result.getTaskNo());//任务号
			taskWrk.setWrkNo(workNo1);
			taskWrk.setStatus(TaskStatusType.RECEIVE.id);//任务状态：接收
			taskWrk.setCreateTime(now);
			taskWrk.setIoType(1);//任务类型入库
			taskWrk.setIoPri(13);//优先级
			taskWrk.setBarcode(barcode);//条码
			taskWrk.setTargetPoint(locNo);
			taskWrk.setStartPoint(staNo + "");
			taskWrk.setCrnNo(Integer.valueOf(result.getAlley()));//堆垛机号

			if (taskWrk.getIoType() == 1) {
			taskWrk.setWrkSts(2);
			if (!Cools.isEmpty(taskWrk.getTargetPoint())) {
			taskWrk.setOriginTargetPoint(taskWrk.getTargetPoint());
			}
			}
			return taskWrk;
			}
			// private TaskWrk createTask1(Result result, String barcode, Integer staNo) {
			// String locNo = Utils.Fusion(result.getRow(), result.getFloor(), result.getColumn());
			//
			// Date now = new Date();
			// TaskWrk taskWrk = new TaskWrk();
			// int workNo1 = commonService.getWorkNo(WorkNoType.PAKIN.type);//获取入库工作号
			// taskWrk.setTaskNo(result.getTaskNo());//任务号
			// taskWrk.setWrkNo(workNo1);
			// taskWrk.setStatus(TaskStatusType.RECEIVE.id);//任务状态：接收
			// taskWrk.setCreateTime(now);
			// taskWrk.setIoType(1);//任务类型入库
			// taskWrk.setIoPri(13);//优先级
			// taskWrk.setBarcode(barcode);//条码
			// taskWrk.setTargetPoint(locNo);
			// taskWrk.setStartPoint(staNo + "");
			// taskWrk.setCrnNo(Integer.valueOf(result.getAlley()));//堆垛机号
			//
			// if (taskWrk.getIoType() == 1) {
			// taskWrk.setWrkSts(2);
			// if (!Cools.isEmpty(taskWrk.getTargetPoint())) {
			// taskWrk.setOriginTargetPoint(taskWrk.getTargetPoint());
			// }
			// }
			// return taskWrk;
			// }

			private TaskWrk createTask(GetWmsDto dto, String barcode) {
			String wcsLocNo = dto.getLocNo();
			@@ -1813,4 +1786,85 @@
			// log.info(""+mark+" - 0"+" - 执行完成：其他 ===>> LED显示器复位，显示默认信息");
			}


			/**
			* 入出库模式切换函数
			*/
			public synchronized void ioConvert() {
			try {
			// 根据输送线plc遍历
			for (DevpSlave devp : slaveProperties.getDevp()) {
			if (devp.getId() == 2) {
			continue;
			}
			SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
			for (DevpSlave.Sta inSta : devp.getInSta()) {
			TaskWrk taskWrk = taskWrkService.selectByTargetPoint(inSta.getBackSta() + "");
			switch (inSta.getBackSta()) {
			case 101:
			if (taskWrk != null) {
			if (devpThread.ioModeOf1F1 != IoModeType.PAKOUT_MODE) {
			// 出库切换中
			devpThread.ioModeOf1F1 = IoModeType.PAKOUT_BOOTING;
			TaskWrk pakin = taskWrkService.selectByStartPoint(inSta.getStaNo() + "");
			if (pakin == null && !devpThread.getStation().get(inSta.getStaNo()).isLoading()
			&& !devpThread.getStation().get(inSta.getBackSta()).isLoading()
			&& devpThread.getStation().get(inSta.getBackSta()).getWorkNo() == 0) {
			// 出库模式
			devpThread.ioModeOf1F1 = IoModeType.PAKOUT_MODE;
			}
			}
			} else {
			// 入库模式
			devpThread.ioModeOf1F1 = IoModeType.PAKIN_MODE;
			}
			break;
			default:
			break;
			}
			}
			}
			} catch (Exception e) {
			e.printStackTrace();
			}
			}


			/**
			* 跑库程序
			*/
			// public void debug(String sts, Long modiUser, Integer loc_type1) {
			// if (!enable) {
			// return;
			// }
			// List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>());
			// if (basCrnps.isEmpty()) {
			// return;
			// }
			// for (BasCrnp basCrnp : basCrnps) {
			// if (!basCrnp.getInEnable().equals("N") \|\| !basCrnp.getOutEnable().equals("Y")) {
			// continue;
			// }
			// List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("crn_no", basCrnp.getCrnNo()).eq("io_type", 11));
			// if (Cools.isEmpty(wrkMasts) \|\| wrkMasts.isEmpty()) {
			// int i = locMastService.selectCount(new EntityWrapper<LocMast>().eq("loc_sts", sts).eq("loc_type1", loc_type1).ne("modi_user", modiUser));
			// LocMast locMastStart = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", sts).eq("loc_type1", loc_type1).ne("modi_user", modiUser));
			// if (locMastStart == null \|\| i > 1) {
			// continue;
			// }
			// List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>()
			// .eq("loc_sts", "O")
			// .eq("crn_no", basCrnp.getCrnNo())
			// .eq("loc_type1", locMastStart.getLocType1())
			// .ne("modi_user", 77));
			// if (Cools.isEmpty(locMasts)) {
			// continue;
			// }
			// Random random = new Random();
			// LocMast locMastEnd = locMasts.get(random.nextInt(locMasts.size()));
			// locMove(locMastStart, locMastEnd, Long.parseLong(basCrnp.getCrnNo().toString()));
			// }
			// }
			// }

			}