|
|
@@ -311,7 +311,7 @@ public class DeviceEventListener extends AbstractEventListener { //
|
|
|
scheduledTaskManager.addTask(opcdasubscribe.getName(), opcdasubscribe.getDelay(), opcdasubscribe.getPeriod(), TimeUnit.SECONDS, () -> {
|
|
|
if ("prod".equals(activeProfiles)) {
|
|
|
log.info("HDC subscribe available");
|
|
|
- // hdService.subscribeAvailable();
|
|
|
+ hdService.subscribeAvailable();
|
|
|
} else if ("test".equals(activeProfiles)) {
|
|
|
log.info("DA subscribe available");
|
|
|
opcuaService.subscribeAvailable();
|
|
|
@@ -2312,13 +2312,13 @@ public class DeviceEventListener extends AbstractEventListener { //
|
|
|
StringBuilder speedValues = new StringBuilder();
|
|
|
for (int i = 1; i < warnData.size(); i++) {
|
|
|
if (i > 1) speedValues.append("、");
|
|
|
- speedValues.append(String.format("%.2f", warnData.get(i)));
|
|
|
+ speedValues.append(String.format("%st/min", warnData.get(i)));
|
|
|
}
|
|
|
|
|
|
log.info("触发流速偏高预警");
|
|
|
PushData.send2Warn(mAudioMap.get(ExceptionTypeEnum.NEED_CLOSURE.getCode()));
|
|
|
saveException(ExceptionTypeEnum.NEED_CLOSURE,
|
|
|
- String.format("铁水流速连续%d次偏高:%st/min、%st/min、%st/min，高于%st/min,建议将当前铁口堵口",
|
|
|
+ String.format("铁水流速连续%d次偏高:%s，高于%st/min,建议将当前铁口堵口",
|
|
|
StandardConstans.WARN_COUNT, speedValues.toString(), stdSpeedMax));
|
|
|
//推送预警列表
|
|
|
getExceptionList();
|
wangxiaofei