zy-wcs.git - Gitblit

			@@ -4,6 +4,7 @@
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.mapper.EntityWrapper;
			import com.core.common.Cools;
			import com.core.common.SpringUtils;
			import com.core.exception.CoolException;
			import com.zy.asrs.controller.CrnController;
			import com.zy.asrs.domain.enums.TaskStatusType;
			@@ -106,6 +107,7 @@
			private TaskWrkLogServiceImpl taskWrkLogService;
			@Autowired
			private BasPlcerrorLogServiceImpl basPlcerrorLogService;
			public Long currentTimeMilliConnectCrnAuto= 0L;

			public void generateStoreWrkFile() {
			try {
			@@ -721,26 +723,61 @@
			log.error("{}号堆垛机尚未在数据库进行维护！", crn.getId());
			continue;
			}

			if (crnProtocol.getLaneNo()!=0 && (crnProtocol.getBay()!=1 \|\| crnProtocol.getLevel()!=1)){
			if (crnProtocol.modeType == CrnModeType.AUTO && crnProtocol.statusType == CrnStatusType.IDLE && crnProtocol.getTaskNo() != 0) {
			if (System.currentTimeMillis()-currentTimeMilliConnectCrnAuto<10006010){
			continue;
			}
			if (crnProtocol.modeType == CrnModeType.AUTO && crnProtocol.statusType == CrnStatusType.IDLE && crnProtocol.getLoaded().equals((short)0) && crnProtocol.getLaneNo()!=0 && crnProtocol.getTaskNo() == 0 ) {
			if (crnProtocol.getBay()!=1 \|\| crnProtocol.getLevel()!=1){
			//获取工作档
			List<TaskWrk> taskWrks = taskWrkMapper.selectByLaneNo(crnProtocol.getLaneNo());
			if (!taskWrks.isEmpty()) {
			continue;
			}
			List<TaskWrkLog> taskWrkLogs = taskWrkLogService.selectList(new EntityWrapper<TaskWrkLog>().eq("CRN_NO",crnProtocol.getLaneNo()).orderBy("COMPLETE_TIME",true));
			if (taskWrkLogs.isEmpty()) {
			CrnCommand command = new CrnCommand();
			if (!MessageQueue.offer(SlaveType.Crn, crnProtocol.getCrnNo(), new Task(4, command))) {
			log.error("堆垛机自动回源点失败，堆垛机号={}", crnProtocol.getCrnNo());
			if (!taskWrkLogs.isEmpty()) {
			TaskWrkLog taskWrkLog = taskWrkLogs.get(0);
			Date completeTime = taskWrkLog.getCompleteTime();
			if (completeTime==null){
			completeTime = taskWrkLog.getCancelTime();
			if (completeTime==null){
			completeTime = taskWrkLog.getModiTime();
			}
			}
			long differenceInSeconds = TimeCalculatorUtils.differenceInMilliseconds(completeTime, new Date());
			if (differenceInSeconds <= 60101000) {
			return;
			}
			}
			// long differenceInSeconds = TimeCalculatorUtils.differenceInMilliseconds(taskWrkLogs.get(0).getCompleteTime(), new Date());
			// if (differenceInSeconds <= 1000) {
			// return;
			// }
			// 命令下发区 --------------------------------------------------------------------------
			CrnCommand crnCommand = new CrnCommand();
			crnCommand.setCrnNo(crnProtocol.getCrnNo()); // 堆垛机编号
			crnCommand.setCrnNo(crnProtocol.getLaneNo()); // 堆垛机巷道编号
			crnCommand.setTaskNo((short)999); // 工作号
			crnCommand.setAckFinish((short) 0); // 任务完成确认位
			crnCommand.setTaskMode(CrnTaskModeType.GO_ORIGIN); // 任务模式: 库位移转
			crnCommand.setSourcePosX((short) 0); // 源库位排
			crnCommand.setSourcePosY((short) 0); // 源库位列
			crnCommand.setSourcePosZ((short) 0); // 源库位层
			int row = crnProtocol.getLaneNo() * 2;
			crnCommand.setDestinationPosX((short) row); // 目标库位排
			crnCommand.setDestinationPosY((short) 1); // 目标库位层
			crnCommand.setDestinationPosZ((short) 1); // 目标库位列
			if (!MessageQueue.offer(SlaveType.Crn, crnProtocol.getCrnNo(), new Task(2, crnCommand))) {
			log.error("堆垛机自动回源点失败，堆垛机号={}", crnProtocol.getCrnNo());

			if (System.currentTimeMillis()-currentTimeMilliConnectCrnAuto>10006010){
			try{
			DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
			deviceErrorService.addDeviceError("CrnErr", crnProtocol.getCrnNo(), "堆垛机自动回源点失败");
			} catch (Exception e2){
			}
			if (currentTimeMilliConnectCrnAuto == 0){
			currentTimeMilliConnectCrnAuto = System.currentTimeMillis()-10006010-1;
			} else {
			currentTimeMilliConnectCrnAuto = System.currentTimeMillis();
			}
			}
			}
			}
			}
			} catch (Exception e){
			@@ -1415,8 +1452,8 @@
			null, // 结束时间
			taskWrk.getWrkSts().longValue(), // 工作状态
			taskWrk.getIoType(), // 入出库类型
			crn.getId(), // 堆垛机
			null, // plc
			taskWrk.getCrnNo(), // 巷道号
			crn.getId(), // 堆垛机号
			taskWrk.getTargetPoint(), // 目标库位
			0, // 目标站
			0, // 源站
			@@ -1971,6 +2008,11 @@
			boolean itSmall = new TrackRangeUtils().IsItSmall(rgvSlave);
			if (basDevpPositions.isEmpty()) {
			log.error("获取所有站点信息异常");
			try{
			DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
			deviceErrorService.addDeviceError("rgvErr", rgvSlave.getId(), "指令生成：获取所有站点信息异常");
			} catch (Exception e2){
			}
			continue;
			}
			List<TaskWrk> taskWrkList = new ArrayList<>();
			@@ -2287,6 +2329,11 @@
			}
			} catch (Exception e) {
			log.error("任务生成失败===》异常信息：{}", e.getMessage());
			try{
			DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
			deviceErrorService.addDeviceError("rgvErr", rgvSlave.getId(), "指令生成失败");
			} catch (Exception e2){
			}
			}
			}
			}
			@@ -2386,6 +2433,11 @@
			log.error("任务生成失败issued1===》异常信息：{}", e.getMessage());
			RgvErrCache.updateRgvErr(rgvSlave.getId(),rgvStn.getStaNo()+"站点任务生成失败issued1");

			try{
			DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
			deviceErrorService.addDeviceError("rgvErr", rgvSlave.getId(), "任务生成失败issued1");
			} catch (Exception e2){
			}
			return false;
			}

			@@ -2404,6 +2456,12 @@
			} catch (Exception e) {
			log.error("任务生成失败issued2===》异常信息：{}", e.getMessage());
			RgvErrCache.updateRgvErr(rgvSlave.getId(),rgvStn.getStaNo()+"站点任务生成失败issued2");

			try{
			DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
			deviceErrorService.addDeviceError("rgvErr", rgvSlave.getId(), "站点任务生成失败issued2");
			} catch (Exception e2){
			}
			}
			return true;
			}