wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3581: 返回幂等信息

Browse Source
This commit is contained in:
yanglin 2025-02-24 18:27:54 +08:00
parent a620402863
commit 826f91e847
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/PersonResignHandler.java
View File

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