package cc.mrbird.febs.ai.service.impl;
|
|
import cc.mrbird.febs.ai.entity.AiCompany;
|
import cc.mrbird.febs.ai.entity.AiCompanyMemberApply;
|
import cc.mrbird.febs.ai.entity.AiKnowledgeFile;
|
import cc.mrbird.febs.ai.entity.AiMember;
|
import cc.mrbird.febs.ai.mapper.AiCompanyMapper;
|
import cc.mrbird.febs.ai.mapper.AiCompanyMemberApplyMapper;
|
import cc.mrbird.febs.ai.service.AiCompanyMemberApplyService;
|
import cc.mrbird.febs.ai.service.AiMemberService;
|
import cc.mrbird.febs.common.entity.FebsResponse;
|
import cc.mrbird.febs.common.entity.QueryRequest;
|
import cc.mrbird.febs.common.exception.FebsException;
|
import cc.mrbird.febs.common.utils.LoginUserUtil;
|
import cc.mrbird.febs.mall.entity.MallMember;
|
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
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;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class AiCompanyMemberApplyServiceImpl extends ServiceImpl<AiCompanyMemberApplyMapper, AiCompanyMemberApply> implements AiCompanyMemberApplyService {
|
|
private final MallMemberMapper mallMemberMapper;
|
private final AiMemberService aiMemberService;
|
private final AiCompanyMapper aiCompanyMapper;
|
|
@Override
|
public IPage<AiCompanyMemberApply> listInPage(AiCompanyMemberApply dto, QueryRequest request) {
|
|
Page<AiCompanyMemberApply> page = new Page<>(request.getPageNum(), request.getPageSize());
|
LambdaQueryWrapper<AiCompanyMemberApply> query = Wrappers.lambdaQuery(AiCompanyMemberApply.class);
|
if (StrUtil.isNotEmpty(dto.getCompanyId())){
|
AiCompany aiCompany = aiCompanyMapper.selectById(dto.getCompanyId());
|
query.eq(AiCompanyMemberApply::getCompanyCode, aiCompany.getCode());
|
}
|
query.orderByDesc(AiCompanyMemberApply::getCreatedTime);
|
Page<AiCompanyMemberApply> pages = this.baseMapper.selectPage(page, query);
|
List<AiCompanyMemberApply> records = pages.getRecords();
|
if(CollUtil.isNotEmpty(records)){
|
//获取records的全部memberId
|
List<String> memberIds = records.stream().map(AiCompanyMemberApply::getMemberId).collect(Collectors.toList());
|
|
List<MallMember> mallMembers = mallMemberMapper.selectList(
|
Wrappers.lambdaQuery(MallMember.class)
|
.select(MallMember::getMemberUuid, MallMember::getName, MallMember::getRealName)
|
.in(MallMember::getMemberUuid, memberIds)
|
);
|
if (CollUtil.isNotEmpty(mallMembers)){
|
records.forEach(record -> {
|
MallMember mallMember = mallMembers.stream().filter(m -> m.getMemberUuid().equals(record.getMemberId())).findFirst().orElse(null);
|
if (mallMember != null){
|
record.setName(mallMember.getName());
|
record.setRealName(mallMember.getRealName());
|
}
|
});
|
}
|
}
|
|
return pages;
|
}
|
|
@Override
|
public FebsResponse agree(AiCompanyMemberApply dto) {
|
String id = dto.getId();
|
AiCompanyMemberApply aiCompanyMemberApply = this.getById(id);
|
if (ObjectUtil.isEmpty(aiCompanyMemberApply)){
|
throw new RuntimeException("申请不存在");
|
}
|
if (0 != aiCompanyMemberApply.getState()){
|
throw new RuntimeException("申请已处理");
|
}
|
String companyCode = aiCompanyMemberApply.getCompanyCode();
|
AiCompany aiCompany = aiCompanyMapper.selectOne(
|
Wrappers.lambdaQuery(AiCompany.class)
|
.eq(AiCompany::getCode, companyCode)
|
.last("limit 1")
|
);
|
|
if (ObjectUtil.isEmpty(aiCompany)){
|
throw new FebsException("公司编码不存在");
|
}
|
|
String memberUuid = aiCompanyMemberApply.getMemberId();
|
String companyId = aiCompany.getId();
|
|
mallMemberMapper.update(null,
|
Wrappers.lambdaUpdate(MallMember.class)
|
.set(MallMember::getCompanyId, companyId)
|
.eq(MallMember::getMemberUuid, memberUuid)
|
);
|
|
aiMemberService.update(null,
|
Wrappers.lambdaUpdate(AiMember.class)
|
.set(AiMember::getCompanyId, companyId)
|
.eq(AiMember::getId, memberUuid)
|
);
|
return new FebsResponse().success();
|
}
|
|
@Override
|
public FebsResponse disagree(AiCompanyMemberApply dto) {
|
String id = dto.getId();
|
AiCompanyMemberApply aiCompanyMemberApply = this.getById(id);
|
if (ObjectUtil.isEmpty(aiCompanyMemberApply)){
|
throw new RuntimeException("申请不存在");
|
}
|
if (0 != aiCompanyMemberApply.getState()){
|
throw new RuntimeException("申请已处理");
|
}
|
this.update(null,
|
Wrappers.lambdaUpdate(AiCompanyMemberApply.class)
|
.set(AiCompanyMemberApply::getState, 3)
|
.eq(AiCompanyMemberApply::getId, id)
|
);
|
return new FebsResponse().success();
|
}
|
|
@Override
|
public FebsResponse unbind(AiCompanyMemberApply dto) {
|
String id = dto.getId();
|
AiCompanyMemberApply aiCompanyMemberApply = this.getById(id);
|
if (ObjectUtil.isEmpty(aiCompanyMemberApply)){
|
throw new RuntimeException("申请不存在");
|
}
|
if (0 != aiCompanyMemberApply.getState()){
|
throw new RuntimeException("申请已处理");
|
}
|
String companyCode = aiCompanyMemberApply.getCompanyCode();
|
AiCompany aiCompany = aiCompanyMapper.selectOne(
|
Wrappers.lambdaQuery(AiCompany.class)
|
.eq(AiCompany::getCode, companyCode)
|
.last("limit 1")
|
);
|
|
if (ObjectUtil.isEmpty(aiCompany)){
|
throw new FebsException("公司编码不存在");
|
}
|
|
String memberUuid = aiCompanyMemberApply.getMemberId();
|
String companyId = aiCompany.getId();
|
|
mallMemberMapper.update(null,
|
Wrappers.lambdaUpdate(MallMember.class)
|
.set(MallMember::getCompanyId, null)
|
.eq(MallMember::getMemberUuid, memberUuid)
|
);
|
|
aiMemberService.update(null,
|
Wrappers.lambdaUpdate(AiMember.class)
|
.set(AiMember::getCompanyId, null)
|
.eq(AiMember::getId, memberUuid)
|
);
|
return new FebsResponse().success();
|
}
|
|
}
|
