caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add transactional

Browse Source
This commit is contained in:
paulGao 2022-07-27 12:06:47 +08:00
parent 99479e722a
commit a2a923809e
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java
View File

@ -180,6 +180,7 @@ public class MemberServiceImpl extends ServiceImpl<MemberMapper, Member> impleme
} }
@Override @Override
@Transactional
public Token autoRegister(ConnectAuthUser authUser) { public Token autoRegister(ConnectAuthUser authUser) {
if (CharSequenceUtil.isEmpty(authUser.getNickname())) { if (CharSequenceUtil.isEmpty(authUser.getNickname())) {
@ -223,6 +224,7 @@ public class MemberServiceImpl extends ServiceImpl<MemberMapper, Member> impleme
} }
@Override @Override
@Transactional
public Token mobilePhoneLogin(String mobilePhone) { public Token mobilePhoneLogin(String mobilePhone) {
QueryWrapper<Member> queryWrapper = new QueryWrapper<>(); QueryWrapper<Member> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("mobile", mobilePhone); queryWrapper.eq("mobile", mobilePhone);
@ -241,7 +243,8 @@ public class MemberServiceImpl extends ServiceImpl<MemberMapper, Member> impleme
* *
* @param member * @param member
*/ */
private void registerHandler(Member member) { @Transactional
public void registerHandler(Member member) {
member.setId(SnowFlake.getIdStr()); member.setId(SnowFlake.getIdStr());
//保存会员 //保存会员
this.save(member); this.save(member);
@ -338,6 +341,7 @@ public class MemberServiceImpl extends ServiceImpl<MemberMapper, Member> impleme
} }
@Override @Override
@Transactional
public Token register(String userName, String password, String mobilePhone) { public Token register(String userName, String password, String mobilePhone) {
//检测会员信息 //检测会员信息
checkMember(userName, mobilePhone); checkMember(userName, mobilePhone);
@ -382,6 +386,7 @@ public class MemberServiceImpl extends ServiceImpl<MemberMapper, Member> impleme
} }
@Override @Override
@Transactional
public Member addMember(MemberAddDTO memberAddDTO) { public Member addMember(MemberAddDTO memberAddDTO) {
//检测会员信息 //检测会员信息
@ -458,7 +463,7 @@ public class MemberServiceImpl extends ServiceImpl<MemberMapper, Member> impleme
memberPointMessage.setType(type); memberPointMessage.setType(type);
memberPointMessage.setMemberId(memberId); memberPointMessage.setMemberId(memberId);
// 发送会员注册信息 // 发送会员注册信息
applicationEventPublisher.publishEvent(new TransactionCommitSendMQEvent("new member register", rocketmqCustomProperties.getMemberTopic(), MemberTagsEnum.MEMBER_REGISTER.name(), member)); applicationEventPublisher.publishEvent(new TransactionCommitSendMQEvent("update member point", rocketmqCustomProperties.getMemberTopic(), MemberTagsEnum.MEMBER_POINT_CHANGE.name(), memberPointMessage));
return true; return true;
} }
return false; return false;