| | |
| | | import com.core.common.SpringUtils; |
| | | import com.zy.asrs.entity.DeviceConfig; |
| | | import com.zy.asrs.entity.DeviceDataLog; |
| | | import com.zy.asrs.entity.BasStationOpt; |
| | | import com.zy.asrs.service.BasStationOptService; |
| | | import com.zy.common.utils.RedisUtil; |
| | | import com.zy.core.network.ZyStationConnectDriver; |
| | | import com.zy.core.cache.MessageQueue; |
| | |
| | | |
| | | @Override |
| | | public CommandResponse sendCommand(StationCommand command) { |
| | | CommandResponse commandResponse = zyStationConnectDriver.sendCommand(command); |
| | | CommandResponse commandResponse = null; |
| | | try { |
| | | commandResponse = zyStationConnectDriver.sendCommand(command); |
| | | return commandResponse; |
| | | } finally { |
| | | BasStationOptService optService = SpringUtils.getBean(BasStationOptService.class); |
| | | List<ZyStationStatusEntity> statusListEntity = zyStationConnectDriver.getStatus(); |
| | | ZyStationStatusEntity matched = null; |
| | | if (statusListEntity != null) { |
| | | for (ZyStationStatusEntity e : statusListEntity) { |
| | | if (e.getStationId() != null && e.getStationId().equals(command.getStationId())) { |
| | | matched = e; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | BasStationOpt basStationOpt = new BasStationOpt( |
| | | command.getTaskNo(), |
| | | command.getStationId(), |
| | | new Date(), |
| | | "MOVE", |
| | | command.getStationId(), |
| | | command.getTargetStaNo(), |
| | | null, |
| | | null, |
| | | null, |
| | | JSON.toJSONString(command), |
| | | JSON.toJSONString(matched), |
| | | 1, |
| | | JSON.toJSONString(commandResponse) |
| | | ); |
| | | if (optService != null) { |
| | | optService.insert(basStationOpt); |
| | | } |
| | | } |
| | | } |
| | | |
| | | @Override |