package cc.mrbird.febs.mall.service.impl;
|
|
import cc.mrbird.febs.mall.entity.MallMember;
|
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
|
import cc.mrbird.febs.mall.service.AsyncService;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class AsyncServiceImpl extends ServiceImpl<MallMemberMapper, MallMember> implements AsyncService {
|
@Override
|
public void updateAllMemberReferrerId() {
|
log.info("异步更新用户信息");
|
List<MallMember> mallMembers = this.baseMapper.selectList(null);
|
if(CollUtil.isEmpty(mallMembers)){
|
return;
|
}
|
for(MallMember mallMember : mallMembers){
|
boolean flag = false;
|
String parentId = mallMember.getReferrerId();
|
if (StrUtil.isBlank(parentId)) {
|
flag = true;
|
}
|
String ids = "";
|
while (!flag) {
|
if (StrUtil.isBlank(ids)) {
|
ids += parentId;
|
} else {
|
ids += ("," + parentId);
|
}
|
MallMember parentMember = this.baseMapper.selectInfoByInviteId(parentId);
|
if (parentMember == null) {
|
break;
|
}
|
parentId = parentMember.getReferrerId();
|
if (StrUtil.isBlank(parentMember.getReferrerId())) {
|
flag = true;
|
}
|
}
|
|
if (StrUtil.isNotBlank(ids)) {
|
mallMember.setReferrerIds(ids);
|
}
|
this.baseMapper.updateById(mallMember);
|
}
|
}
|
}
|
