| | |
|---|
| | | // log.info(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), slave.getId())); |
|---|
| | | } |
|---|
| | | // log.warn(JSON.toJSONString(shuttleProtocol));//输出小车状态 |
|---|
| | | |
|---|
| | | if (System.currentTimeMillis() - shuttleProtocol.getDeviceDataLog() > 1000 * 5) { |
|---|
| | | //采集时间超过5s，保存一次数据记录 |
|---|
| | | //保存数据记录 |
|---|
| | | DeviceDataLogService deviceDataLogService = SpringUtils.getBean(DeviceDataLogService.class); |
|---|
| | | DeviceDataLog deviceDataLog = new DeviceDataLog(); |
|---|
| | | deviceDataLog.setOriginData(JSON.toJSONString(jsonObject)); |
|---|
| | | deviceDataLog.setWcsData(JSON.toJSONString(shuttleProtocol)); |
|---|
| | | deviceDataLog.setType("shuttle"); |
|---|
| | | deviceDataLog.setDeviceNo(shuttleProtocol.getShuttleNo().intValue()); |
|---|
| | | deviceDataLog.setCreateTime(new Date()); |
|---|
| | | deviceDataLogService.insert(deviceDataLog); |
|---|
| | | |
|---|
| | | //更新采集时间 |
|---|
| | | shuttleProtocol.setDeviceDataLog(System.currentTimeMillis()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | |
|---|
| | | if (result == null) { |
|---|
| | | return false;//请求失败 |
|---|
| | | } |
|---|
| | | |
|---|
| | | shuttleProtocol.setSendTime(System.currentTimeMillis());//指令下发时间 |
|---|
| | | |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | |
|---|
