|
@@ -421,9 +421,9 @@ public class DeviceEventListener extends AbstractEventListener { //
|
|
|
taskExecutor.submit(() -> operate());
|
|
|
|
|
|
//实时数据
|
|
|
- taskExecutor.submit(() -> {
|
|
|
+// taskExecutor.submit(() -> {
|
|
|
setRealtimeDataAndStatus(opcData);
|
|
|
- });
|
|
|
+// });
|
|
|
|
|
|
}
|
|
|
|
|
@@ -1628,12 +1628,21 @@ public class DeviceEventListener extends AbstractEventListener { //
|
|
|
|
|
|
log.info(" 💾 【数据保存】");
|
|
|
log.info(" ├─ 保存出铁记录...");
|
|
|
- ironDataService.saveOrUpdate(mTIronData);
|
|
|
- opcData.setIronDataId(mTIronData.getId());
|
|
|
- opcDataService.save(opcData);
|
|
|
- log.info(" └─ 保存完成");
|
|
|
+ try {
|
|
|
+ ironDataService.saveOrUpdate(mTIronData);
|
|
|
+ log.info(" ├─ 出铁记录保存成功,ID: {}", mTIronData.getId());
|
|
|
+ opcData.setIronDataId(mTIronData.getId());
|
|
|
+ log.info(" ├─ 设置OPC数据关联ID: {}", mTIronData.getId());
|
|
|
+ opcDataService.save(opcData);
|
|
|
+ log.info(" └─ OPC数据保存成功");
|
|
|
+ log.info(" └─ 保存完成");
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ log.error(" ❌ 保存出铁记录失败: {}", e.getMessage(), e);
|
|
|
+ }finally {
|
|
|
+ mTIronData = null;
|
|
|
+ }
|
|
|
|
|
|
- mTIronData = null;
|
|
|
} else {
|
|
|
log.info(" ⚠️ 无出铁记录需要保存 (mTIronData为null)");
|
|
|
}
|