hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

家族消息的处理增加事务

Browse Source
This commit is contained in:
tianfeng 2025-12-23 18:31:37 +08:00
parent 65d5a6fbfc
commit 203cd537c3
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/family/ApplyJoinFamilyExe.java
View File

@ -28,6 +28,7 @@ import java.util.concurrent.TimeUnit;
import com.red.circle.other.inner.model.dto.user.UserProfileDTO; import com.red.circle.other.inner.model.dto.user.UserProfileDTO;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
/** /**
* <p> * <p>
@ -46,7 +47,7 @@ public class ApplyJoinFamilyExe {
private final FamilyMessageService familyMessageService; private final FamilyMessageService familyMessageService;
private final FamilyMemberInfoService familyMemberInfoService; private final FamilyMemberInfoService familyMemberInfoService;
@Transactional(rollbackFor = Exception.class)
public void execute(ApplyJoinFamilyCmd cmd) { public void execute(ApplyJoinFamilyCmd cmd) {
String string = redisService.getString(FamilyKeys.USER_LEAVE.getKey()); String string = redisService.getString(FamilyKeys.USER_LEAVE.getKey());
ResponseAssert.isNull(FamilyErrorCode.USER_RECENT_LEAVE, string); ResponseAssert.isNull(FamilyErrorCode.USER_RECENT_LEAVE, string);

2
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/family/FamilyMessageHandleExe.java
View File

@ -26,6 +26,7 @@ import java.util.Objects;
import java.util.Optional; import java.util.Optional;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
/** /**
* <p> * <p>
@ -44,6 +45,7 @@ public class FamilyMessageHandleExe {
private final FamilyMessageService familyMessageService; private final FamilyMessageService familyMessageService;
private final FamilyMemberInfoService familyMemberInfoService; private final FamilyMemberInfoService familyMemberInfoService;
@Transactional(rollbackFor = Exception.class)
public void execute(FamilyMessageHandleCmd cmd) { public void execute(FamilyMessageHandleCmd cmd) {
isExistFamily(cmd); isExistFamily(cmd);