| | |
| | | stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, basStation.getDeviceNo()); |
| | | if (stationThread != null) { |
| | | Map<Integer, StationProtocol> statusMap = stationThread.getStatusMap(); |
| | | StationProtocol stationProtocol = statusMap.get(basStation.getStationId()); |
| | | if (stationProtocol != null && wrkNo.equals(stationProtocol.getTaskNo())) { |
| | | StationProtocol stationProtocol = statusMap == null ? null : statusMap.get(basStation.getStationId()); |
| | | boolean arrived = stationProtocol != null && wrkNo.equals(stationProtocol.getTaskNo()); |
| | | if (arrived || stationThread.hasRecentArrival(basStation.getStationId(), wrkNo)) { |
| | | complete = true; |
| | | if (!arrived) { |
| | | News.info("输送站点出库到达判定使用最近到站补偿,工作号={},目标站={}", wrkNo, targetStaNo); |
| | | } |
| | | } |
| | | } |
| | | } |