diff --git a/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/PersonResignHandler.java b/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/PersonResignHandler.java index e3cb7c8a..37c96b79 100644 --- a/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/PersonResignHandler.java +++ b/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/PersonResignHandler.java @@ -15,7 +15,6 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.InitializingBean; import org.springframework.stereotype.Component; -import org.springframework.transaction.support.TransactionTemplate; import java.util.Collections; @@ -32,14 +31,13 @@ public class PersonResignHandler implements EventHandler, InitializingBean { private final OrgManager orgManager; private final EssOrgDao essOrgDao; private final EssPersonDao essPersonDao; - private final TransactionTemplate transactionTemplate; @Override public void onEvent(Event event, EventConsumer.Context context) { OrgUserStatusChangedEvent message = event.normalizedData(OrgUserStatusChangedEvent.class); log.info("receive node user event: {}", JSON.toJSONString(message)); if (message.getStatusCode() == 6) - transactionTemplate.executeWithoutResult(unused -> trySetPersonResigned(message)); + trySetPersonResigned(message); else log.info("ignore node user event: {}", JSON.toJSONString(message)); }