suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: 修复保存协议不生效问题

This commit is contained in:
zhouhao 2025-05-30 11:27:10 +08:00
parent a809a8c33d
commit 22cdb6862a
1 changed files with 38 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/manager/LocalProtocolSupportManager.java
View File

@ -18,10 +18,7 @@ package org.jetlinks.community.protocol.manager;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.hswebframework.ezorm.rdb.mapping.ReactiveRepository;
import org.hswebframework.web.crud.events.EntityBeforeCreateEvent;
import org.hswebframework.web.crud.events.EntityBeforeDeleteEvent;
import org.hswebframework.web.crud.events.EntityBeforeModifyEvent;
import org.hswebframework.web.crud.events.EntityBeforeSaveEvent;
import org.hswebframework.web.crud.events.*;
import org.hswebframework.web.exception.BusinessException;
import org.hswebframework.web.i18n.LocaleUtils;
import org.jetlinks.core.ProtocolSupport;
@ -104,6 +101,43 @@ public class LocalProtocolSupportManager
);
}
//删除协议前,判断协议是否已被引用。已被引用的协不能删除
@EventListener
public void handleProtocolDelete(EntityDeletedEvent<ProtocolSupportEntity> event) {
event.async(
Flux.fromIterable(event.getEntity())
.doOnNext(entity -> remove(entity.toDefinition()))
);
}
//保存协议前，判断协议是否能正常运行
@EventListener
public void checkProtocol(EntitySavedEvent<ProtocolSupportEntity> event) {
event.async(
Flux.fromIterable(event.getEntity())
.flatMap(entity -> init(entity.toDefinition()))
);
}
//创建协议前，判断协议是否能正常运行
@EventListener
public void checkProtocol(EntityCreatedEvent<ProtocolSupportEntity> event) {
event.async(
Flux.fromIterable(event.getEntity())
.flatMap(entity -> init(entity.toDefinition()))
);
}
//修改协议前，判断协议是否能正常运行
@EventListener
public void checkProtocol(EntityModifyEvent<ProtocolSupportEntity> event) {
event.async(
Flux.fromIterable(event.getAfter())
.flatMap(entity -> checkProtocol(entity.toDefinition()))
);
}
public void remove(ProtocolSupportDefinition definition) {
ProtocolSupport protocol = supports.get(definition.getId());