| | |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import com.zy.acs.common.utils.News; |
| | | |
| | | import java.util.concurrent.TimeoutException; |
| | | |
| | |
| | | public BaseResult<?> executeAgvActionCmd(AgvAction agvAction) { |
| | | |
| | | // todo 1: 记录日志 2:发送任务 3:同步响应 |
| | | // log.info(JSON.toJSONString(agvAction)); |
| | | // News.info(JSON.toJSONString(agvAction)); |
| | | |
| | | String serialNo = agvAction.getSerialNo(); |
| | | |
| | |
| | | public BaseResult<?> executeAgvCommand(AgvCommand agvCommand) { |
| | | |
| | | // todo 1: 记录日志 2:发送任务 3:同步响应 |
| | | log.info(JSON.toJSONString(agvCommand)); |
| | | News.info(JSON.toJSONString(agvCommand)); |
| | | |
| | | String serialNo = agvCommand.getSerialNo(); |
| | | |
| | |
| | | return BaseResult.error(); |
| | | } |
| | | } catch (TimeoutException e){ |
| | | log.error("AgvCmdService.requestProcess", e); |
| | | News.error("AgvCmdService.requestProcess", e); |
| | | return BaseResult.error(); |
| | | } |
| | | } |
| | |
| | | return messageBody; |
| | | } |
| | | try{ |
| | | Thread.sleep(15); |
| | | Thread.sleep(10); |
| | | }catch(Exception ex){ |
| | | ex.printStackTrace(); |
| | | } |
| | |
| | | throw new TimeoutException(); |
| | | } |
| | | |
| | | } |
| | | } |