zy-wcs.git - Gitblit

			@@ -29,6 +29,7 @@
			import com.zy.core.enums.*;
			import com.zy.core.model.CrnSlave;
			import com.zy.core.model.DevpSlave;
			import com.zy.core.model.LedSlave;
			import com.zy.core.model.Task;
			import com.zy.core.model.command.CommandPackage;
			import com.zy.core.model.command.CrnCommand;
			@@ -36,6 +37,7 @@
			import com.zy.core.model.protocol.StaProtocol;
			import com.zy.core.properties.SlaveProperties;
			import com.zy.core.thread.BarcodeThread;
			import com.zy.core.thread.LedThread;
			import com.zy.core.thread.SiemensDevpThread;
			import com.zy.system.entity.Config;
			import com.zy.system.service.ConfigService;
			@@ -113,13 +115,15 @@
			private CrnController crnController;
			@Autowired
			private SiteController siteController;
			@Autowired
			private TaskWrkLogService taskWrkLogService;

			/**
			* 堆垛机演示 ===>> 库位移转
			*/
			public synchronized void crnDemoOfLocMove1() {
			try {
			List <BasCrnp> basCrnps =basCrnpService.selectList(new EntityWrapper<BasCrnp>());
			List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>());
			for (BasCrnp crn : basCrnps) {
			if (!crn.getEmpIn().equals("1")) {
			continue;
			@@ -131,7 +135,7 @@
			if (crnProtocol == null) {
			continue;
			}
			TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("crn_no",crn.getCrnNo()).eq("io_type",3));
			TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("crn_no", crn.getCrnNo()).eq("io_type", 3));
			if (taskWrk1 != null) {
			continue;
			}
			@@ -141,7 +145,7 @@

			LocMast sourceLoc = locMastService.queryDemoSourceLoc(crn.getCrnNo());

			LocMast loc = locMastService.queryDemoLoc(crn.getCrnNo(),sourceLoc.getLocType1());
			LocMast loc = locMastService.queryDemoLoc(crn.getCrnNo(), sourceLoc.getLocType1());
			if (null == sourceLoc \|\| null == loc) {
			continue;
			}
			@@ -152,7 +156,7 @@
			// 保存工作档
			TaskWrk taskWrk = new TaskWrk();
			taskWrk.setWrkNo(workNo);
			taskWrk.setTaskNo(workNo+"");//任务号
			taskWrk.setTaskNo(workNo + "");//任务号
			taskWrk.setWrkSts(11); // 工作状态：11.生成出库ID
			taskWrk.setIoType(3); // 入出库状态： 3.库格移载
			taskWrk.setIoPri(13);
			@@ -164,7 +168,7 @@
			int res = taskWrkMapper.insert(taskWrk);
			if (res == 0) {
			throw new CoolException("保存工作档失败");
			}else {
			} else {
			loc.setCtnKind(1);
			locMastService.updateById(loc);
			}
			@@ -341,33 +345,36 @@
			&& staProtocol.isPakMk()) {
			// 获取条码扫描仪信息
			BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, inSta.getBarcode());
			if (barcodeThread == null) {
			continue;
			}
			String BoxNo = barcodeThread.getBarcode();
			TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("barcode", BoxNo));
			if (!Cools.isEmpty(taskWrk1)) {
			log.info("托盘码：" + BoxNo + "任务档存在");
			if (taskWrk1.getIoType() == 1 && taskWrk1.getStartPoint().equals(staProtocol.getSiteId().toString())) {
			StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
			.eq("crn_no", taskWrk1.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId()));
			if (Cools.isEmpty(staDesc)) {
			return;
			} else {
			continue;
			String BoxNo = "";
			if (barcodeThread != null) {
			BoxNo = barcodeThread.getBarcode();
			TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("barcode", BoxNo));
			if (!Cools.isEmpty(taskWrk1)) {
			log.info("托盘码：" + BoxNo + "任务档存在");
			if (taskWrk1.getIoType() == 1 && taskWrk1.getStartPoint().equals(staProtocol.getSiteId().toString())) {
			StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
			.eq("crn_no", taskWrk1.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId()));
			if (Cools.isEmpty(staDesc)) {
			return;
			} else {
			continue;
			}
			}
			}
			if (back) {
			storageEscalationParam.setWCSStatus(1);
			storageEscalationParam.setWCSErrorMessage(storageEscalationParam.getWCSErrorMessage() + errMsg);
			}
			}
			if (back) {
			storageEscalationParam.setWCSStatus(1);
			storageEscalationParam.setWCSErrorMessage(storageEscalationParam.getWCSErrorMessage() + errMsg);
			}
			log.info("组托入库={}", storageEscalationParam);


			storageEscalationParam.setBoxNo(BoxNo);
			//是否满板 1满板 0空板
			storageEscalationParam.setStaType(staProtocol.isEmptyMk()? 0:1);
			storageEscalationParam.setStaType(staProtocol.isEmptyMk() ? 0 : 1);
			//库位类型 1高库位 0低库位
			storageEscalationParam.setLocType(staProtocol.isHigh()? 1:0);
			storageEscalationParam.setLocType(staProtocol.isHigh() ? 1 : 0);
			storageEscalationParam.setTerminalNo(staProtocol.getSiteId());
			log.info("组托入库={}", storageEscalationParam);
			String response = "";
			Boolean success = false;
			try {
			@@ -389,7 +396,7 @@
			// 创新一个入库工作档
			TaskWrk taskWrk = taskWrkService.selectByTaskNo(result.getTaskNo());
			if (Cools.isEmpty(taskWrk)) {
			taskWrk = createTask1(result, BoxNo);
			taskWrk = createTask1(result, BoxNo,staProtocol.getSiteId());
			if (Cools.isEmpty(taskWrk)) {
			log.error("库位异常，库位号：={}", taskWrk.getOriginTargetPoint());
			} else {
			@@ -442,6 +449,160 @@
			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();
			// 判断是否满足入库条件
			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 {
			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 {
			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);
			@@ -782,7 +943,7 @@
			staProtocol.setStaNo(staDesc.getStnNo().shortValue());
			boolean offer = false;
			try {
			offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
			offer = MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol));
			} catch (Exception e) {
			log.error("下发输送线任务失败：异常:" + e);
			log.error("下发输送线任务失败：异常:offer:" + offer);
			@@ -968,18 +1129,9 @@

			LocMast locMast = locMastService.selectByLocNo(taskWrk.getStartPoint());
			//判断其库位是否为深库位，如果为深库位找其浅库位是都有货
			if (locMast.getRow1() == 1 \|\| locMast.getRow1() == 5) {
			if (locMast.getRow1() == 8 \|\| locMast.getRow1() == 5) {
			LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>()
			.eq("row1", (locMast.getRow1() + 1))
			.eq("bay1", locMast.getBay1())
			.eq("lev1", locMast.getLev1()).eq("loc_sts", "F"));
			if (!Cools.isEmpty(locMast1)) {
			log.info(locMast.getLocNo() + "出深库位，浅库位有货");
			continue;
			}
			} else if (locMast.getRow1() == 4 \|\| locMast.getRow1() == 8) {
			LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>()
			.eq("row1", (locMast.getRow1() - 1))
			.eq("bay1", locMast.getBay1())
			.eq("lev1", locMast.getLev1()).eq("loc_sts", "F"));
			if (!Cools.isEmpty(locMast1)) {
			@@ -1013,11 +1165,11 @@
			if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) \|\| crnProtocol.getTaskNo() != 0) {
			break;
			}
			int storeCount = basDevpService.getStoreCount();
			if (storeCount >= maxCount) {
			log.error("输送线暂存数达到上限{}", storeCount);
			break;
			}
			// int storeCount = basDevpService.getStoreCount();
			// if (storeCount >= maxCount) {
			// log.error("输送线暂存数达到上限{}", storeCount);
			// break;
			// }


			// 已经存在吊车执行任务时，则过滤
			@@ -1627,9 +1779,8 @@
			return response;
			}

			private TaskWrk createTask1(Result result, String barcode) {
			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();
			@@ -1638,18 +1789,13 @@
			taskWrk.setWrkNo(workNo1);
			taskWrk.setStatus(TaskStatusType.RECEIVE.id);//任务状态：接收
			taskWrk.setCreateTime(now);
			taskWrk.setIoType(1);//任务类型
			taskWrk.setIoType(1);//任务类型入库
			taskWrk.setIoPri(13);//优先级
			taskWrk.setBarcode(barcode);//条码
			LocMast locMast = locMastService.selectByLocNo(locNo);
			taskWrk.setCrnNo(locMast.getCrnNo());
			taskWrk.setTargetPoint(locNo);
			taskWrk.setStartPoint("116");
			if (result.getAlley().equals("1")) {
			taskWrk.setCrnNo(1);
			} else {
			taskWrk.setCrnNo(2);
			}
			taskWrk.setStartPoint(staNo+"");
			taskWrk.setCrnNo(Integer.valueOf(result.getAlley()));//堆垛机号

			if (taskWrk.getIoType() == 1) {
			taskWrk.setWrkSts(2);
			if (!Cools.isEmpty(taskWrk.getTargetPoint())) {
			@@ -1701,4 +1847,43 @@
			return taskWrk;
			}

			//----------------------------------------------------------电视机显示处理----------------------------------------
			/**
			* 其他 ===>> LED显示器复位，显示默认信息
			*/
			public synchronized void ledReset(Integer mark) {

			// log.info(""+mark+" - 0"+" - 开始执行:其他 ===>> LED显示器复位，显示默认信息");
			for (LedSlave led : slaveProperties.getLed()) {

			// 获取输送线plc线程
			DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, led.getDevpPlcId());
			// 命令集合
			boolean reset = true;
			for (Integer staNo : led.getStaArr()) {
			// 获取叉车站点
			StaProtocol staProtocol = devpThread.getStation().get(staNo);
			if (staProtocol == null) {
			continue;
			}
			if (staProtocol.getWorkNo() != 0 && staProtocol.isLoading()) {
			reset = false;
			break;
			}
			}
			// 获取led线程
			LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, led.getId());
			// led显示默认内容
			if (reset && !ledThread.isLedMk()) {
			ledThread.setLedMk(true);
			if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(4, new ArrayList<>()))) {
			log.error(""+mark+" - 1"+" - {}号LED命令下发失败！！！[ip：{}] [port：{}]", led.getId(), led.getIp(), led.getPort());
			} else {

			}
			}
			}
			// log.info(""+mark+" - 0"+" - 执行完成：其他 ===>> LED显示器复位，显示默认信息");
			}

			}