Commit 0beec712 authored by wanghao's avatar wanghao

1 写时间后 立马 读一次 判断是否写入成功

parent 59b5b63e
......@@ -166,16 +166,14 @@ public class AgingStageOneProcessJob implements Job {
// 5. 写入自检让设备开始自检,跟 上面的状态没关系
writeSelfCheckStatus(master, deviceId, binding);
binding.setWriteTimeStatus("1");
// 6. 更新数据库
palletDeviceBindingMapper.updatePalletDeviceBinding(binding);
log.debug("设备{}处理完成: ip={}, port={}, status={}", deviceId, ip, port, result[1]);
log.info("设备{}处理完成: ip={}, port={}, status={}", deviceId, ip, port, result[1]);
return true;
} catch (Exception e) {
log.error("设备{}处理异常: ip={}, port={}", deviceId, ip, port, e);
log.info("设备{}处理异常: ip={}, port={}", deviceId, ip, port, e);
if(binding == null) {
binding = palletDeviceBindingMapper.selectByTrayIdAndIndex(ip, deviceId);
}
......@@ -259,6 +257,7 @@ public class AgingStageOneProcessJob implements Job {
binding.setRecordDate(String.valueOf(day));
binding.setRecordHour(String.valueOf(hour));
binding.setRecordMinute(String.valueOf(minute));
binding.setWriteTimeStatus("1");
log.debug("设备{}时间写入成功", deviceId);
} else {
log.info("设备{}时间写入失败: year={}, month={}, day={}, hour={}, minute={}",deviceId,ints[4], ints[5], ints[6], ints[7], ints[8]);
......
......@@ -375,15 +375,18 @@ public class AgingStageThreeProcessJob implements Job {
binding.setRecordDate(String.valueOf(day));
binding.setRecordHour(String.valueOf(hour));
binding.setRecordMinute(String.valueOf(minute));
log.debug("设备{}时间写入成功", deviceId);
binding.setWriteTimeStatus("1");
binding.setRunTimeStatus("1");
log.info("设备{}时间写入成功", deviceId);
} else {
log.info("设备{}时间写入失败: year={}, month={}, day={}, hour={}, minute={}",deviceId,ints[4], ints[5], ints[6], ints[7], ints[8]);
binding.setWriteTimeStatus("0");
binding.setRunTimeStatus("0");
recordAlarmByBinding(binding, "设备时间写入失败");
}
} else {
binding.setRunTimeStatus("0");
log.error("设备{}时间更新失败", deviceId);
log.info("设备{}时间更新失败", deviceId);
recordAlarmByBinding(binding, "设备时间更新失败");
}
// 2. 如果时间状态为1,则更新 时间运行状态 为异常 状态
......@@ -393,7 +396,7 @@ public class AgingStageThreeProcessJob implements Job {
} // 3. 写时间状态 异常状态;不管
} catch (Exception e) {
binding.setRunTimeStatus("0");
log.error("设备{}时间更新异常", deviceId, e);
log.info("设备{}时间更新异常", deviceId, e);
recordAlarmByBinding(binding, "设备时间更新异常: " + e.getMessage());
}
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment