package cn.iocoder.yudao.module.crm.service.contact;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.collection.ListUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.extra.spring.SpringUtil;
|
import cn.iocoder.yudao.framework.common.exception.ServiceException;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.crm.controller.admin.contact.vo.CrmContactBusinessReqVO;
|
import cn.iocoder.yudao.module.crm.controller.admin.contact.vo.CrmContactImportExcelVO;
|
import cn.iocoder.yudao.module.crm.controller.admin.contact.vo.CrmContactImportReqVO;
|
import cn.iocoder.yudao.module.crm.controller.admin.contact.vo.CrmContactImportRespVO;
|
import cn.iocoder.yudao.module.crm.controller.admin.contact.vo.CrmContactPageReqVO;
|
import cn.iocoder.yudao.module.crm.controller.admin.contact.vo.CrmContactSaveReqVO;
|
import cn.iocoder.yudao.module.crm.controller.admin.contact.vo.CrmContactTransferReqVO;
|
import cn.iocoder.yudao.module.crm.dal.dataobject.contact.CrmContactBusinessDO;
|
import cn.iocoder.yudao.module.crm.dal.dataobject.contact.CrmContactDO;
|
import cn.iocoder.yudao.module.crm.dal.dataobject.customer.CrmCustomerDO;
|
import cn.iocoder.yudao.module.crm.dal.mysql.contact.CrmContactMapper;
|
import cn.iocoder.yudao.module.crm.dal.mysql.customer.CrmCustomerMapper;
|
import cn.iocoder.yudao.module.crm.enums.common.CrmBizTypeEnum;
|
import cn.iocoder.yudao.module.crm.enums.permission.CrmPermissionLevelEnum;
|
import cn.iocoder.yudao.module.crm.framework.permission.core.annotations.CrmPermission;
|
import cn.iocoder.yudao.module.crm.service.business.CrmBusinessService;
|
import cn.iocoder.yudao.module.crm.service.contract.CrmContractService;
|
import cn.iocoder.yudao.module.crm.service.customer.CrmCustomerService;
|
import cn.iocoder.yudao.module.crm.service.permission.CrmPermissionService;
|
import cn.iocoder.yudao.module.crm.service.permission.bo.CrmPermissionCreateReqBO;
|
import cn.iocoder.yudao.module.crm.service.permission.bo.CrmPermissionTransferReqBO;
|
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
|
import com.mzt.logapi.context.LogRecordContext;
|
import com.mzt.logapi.service.impl.DiffParseFunction;
|
import com.mzt.logapi.starter.annotation.LogRecord;
|
import jakarta.annotation.Resource;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.Collection;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.iocoder.yudao.framework.common.pojo.PageParam.PAGE_SIZE_NONE;
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.filterList;
|
import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId;
|
import static cn.iocoder.yudao.module.crm.enums.ErrorCodeConstants.*;
|
import static cn.iocoder.yudao.module.crm.enums.LogRecordConstants.*;
|
import static java.util.Collections.singletonList;
|
|
/**
|
* CRM 联系人 Service 实现类
|
*
|
* @author 超级管理员
|
*/
|
@Service
|
@Validated
|
public class CrmContactServiceImpl implements CrmContactService {
|
|
@Resource
|
private CrmContactMapper contactMapper;
|
|
@Resource
|
private CrmCustomerService customerService;
|
@Resource
|
private CrmCustomerMapper customerMapper;
|
@Resource
|
private CrmPermissionService permissionService;
|
@Resource
|
@Lazy
|
private CrmContractService contractService;
|
@Resource
|
private CrmContactBusinessService contactBusinessService;
|
@Resource
|
private CrmBusinessService businessService;
|
|
@Resource
|
private AdminUserApi adminUserApi;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@LogRecord(type = CRM_CONTACT_TYPE, subType = CRM_CONTACT_CREATE_SUB_TYPE, bizNo = "{{#contact.id}}",
|
success = CRM_CONTACT_CREATE_SUCCESS)
|
public Long createContact(CrmContactSaveReqVO createReqVO, Long userId) {
|
createReqVO.setId(null);
|
// 1. 校验关联数据
|
validateRelationDataExists(createReqVO);
|
|
// 2. 插入联系人
|
CrmContactDO contact = BeanUtils.toBean(createReqVO, CrmContactDO.class);
|
contactMapper.insert(contact);
|
|
// 3. 创建数据权限
|
permissionService.createPermission(new CrmPermissionCreateReqBO().setUserId(userId)
|
.setBizType(CrmBizTypeEnum.CRM_CONTACT.getType()).setBizId(contact.getId())
|
.setLevel(CrmPermissionLevelEnum.OWNER.getLevel()));
|
// 3.1 客户负责人自动拥有该联系人的读写权限
|
permissionService.createPermissionForCustomerOwner(CrmBizTypeEnum.CRM_CONTACT.getType(),
|
contact.getId(), contact.getCustomerId(), userId);
|
|
// 4. 如果有关联商机，则需要创建关联
|
if (createReqVO.getBusinessId() != null) {
|
contactBusinessService.createContactBusinessList(new CrmContactBusinessReqVO()
|
.setContactId(contact.getId()).setBusinessIds(singletonList(createReqVO.getBusinessId())));
|
}
|
|
// 5. 记录操作日志
|
LogRecordContext.putVariable("contact", contact);
|
return contact.getId();
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@LogRecord(type = CRM_CONTACT_TYPE, subType = CRM_CONTACT_UPDATE_SUB_TYPE, bizNo = "{{#updateReqVO.id}}",
|
success = CRM_CONTACT_UPDATE_SUCCESS)
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CONTACT, bizId = "#updateReqVO.id", level = CrmPermissionLevelEnum.WRITE)
|
public void updateContact(CrmContactSaveReqVO updateReqVO) {
|
// 1.1 校验存在
|
CrmContactDO oldContact = validateContactExists(updateReqVO.getId());
|
// 1.2 校验关联数据
|
validateRelationDataExists(updateReqVO);
|
|
// 2. 更新联系人
|
CrmContactDO updateObj = BeanUtils.toBean(updateReqVO, CrmContactDO.class);
|
contactMapper.updateById(updateObj);
|
|
// 3. 记录操作日志
|
updateReqVO.setOwnerUserId(oldContact.getOwnerUserId()); // 避免操作日志出现“删除负责人”的情况
|
LogRecordContext.putVariable(DiffParseFunction.OLD_OBJECT, BeanUtils.toBean(oldContact, CrmContactSaveReqVO.class));
|
LogRecordContext.putVariable("contactName", oldContact.getName());
|
}
|
|
/**
|
* 校验关联的数据都存在
|
*
|
* @param saveReqVO 新增/修改请求 VO
|
*/
|
private void validateRelationDataExists(CrmContactSaveReqVO saveReqVO) {
|
// 1. 校验客户
|
if (saveReqVO.getCustomerId() != null && customerService.getCustomer(saveReqVO.getCustomerId()) == null) {
|
customerService.validateCustomer(saveReqVO.getCustomerId());
|
}
|
// 2. 校验负责人
|
if (saveReqVO.getOwnerUserId() != null) {
|
adminUserApi.validateUser(saveReqVO.getOwnerUserId());
|
}
|
// 3. 直属上级
|
if (saveReqVO.getParentId() != null) {
|
validateContactExists(saveReqVO.getParentId());
|
}
|
// 4. 如果有关联商机，则需要校验存在
|
if (saveReqVO.getBusinessId() != null && businessService.getBusiness(saveReqVO.getBusinessId()) == null) {
|
throw exception(BUSINESS_NOT_EXISTS);
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@LogRecord(type = CRM_CONTACT_TYPE, subType = CRM_CONTACT_DELETE_SUB_TYPE, bizNo = "{{#id}}",
|
success = CRM_CONTACT_DELETE_SUCCESS)
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CONTACT, bizId = "#id", level = CrmPermissionLevelEnum.OWNER)
|
public void deleteContact(Long id) {
|
// 1.1 校验存在
|
CrmContactDO contact = validateContactExists(id);
|
// 1.2 校验是否关联合同
|
if (contractService.getContractCountByContactId(id) > 0) {
|
throw exception(CONTACT_DELETE_FAIL_CONTRACT_LINK_EXISTS);
|
}
|
|
// 2. 删除联系人
|
contactMapper.deleteById(id);
|
|
// 4.1 删除商机关联
|
contactBusinessService.deleteContactBusinessByContactId(id);
|
// 4.2 删除数据权限
|
permissionService.deletePermission(CrmBizTypeEnum.CRM_CONTACT.getType(), id);
|
|
// 记录操作日志上下文
|
LogRecordContext.putVariable("contactName", contact.getName());
|
}
|
|
private CrmContactDO validateContactExists(Long id) {
|
CrmContactDO contact = contactMapper.selectById(id);
|
if (contact == null) {
|
throw exception(CONTACT_NOT_EXISTS);
|
}
|
return contact;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@LogRecord(type = CRM_CONTACT_TYPE, subType = CRM_CONTACT_TRANSFER_SUB_TYPE, bizNo = "{{#reqVO.id}}",
|
success = CRM_CONTACT_TRANSFER_SUCCESS)
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CONTACT, bizId = "#reqVO.id", level = CrmPermissionLevelEnum.OWNER)
|
public void transferContact(CrmContactTransferReqVO reqVO, Long userId) {
|
// 1 校验联系人是否存在
|
CrmContactDO contact = validateContactExists(reqVO.getId());
|
|
// 2.1 数据权限转移
|
permissionService.transferPermission(new CrmPermissionTransferReqBO(userId, CrmBizTypeEnum.CRM_CONTACT.getType(),
|
reqVO.getId(), reqVO.getNewOwnerUserId(), reqVO.getOldOwnerPermissionLevel()));
|
// 2.2 设置新的负责人
|
contactMapper.updateById(new CrmContactDO().setId(reqVO.getId()).setOwnerUserId(reqVO.getNewOwnerUserId()));
|
|
// 3. 记录转移日志
|
LogRecordContext.putVariable("contact", contact);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CUSTOMER, bizId = "#customerId", level = CrmPermissionLevelEnum.OWNER)
|
public void updateOwnerUserIdByCustomerId(Long customerId, Long ownerUserId) {
|
// 1. 校验存在
|
List<CrmContactDO> contacts = contactMapper.selectListByCustomerId(customerId);
|
if (CollUtil.isEmpty(contacts)) {
|
return;
|
}
|
int count = contactMapper.updateOwnerUserIdByCustomerId(customerId, ownerUserId);
|
if (count == 0) {
|
throw exception(CONTACT_UPDATE_OWNER_USER_FAIL);
|
}
|
|
// 2. 记录操作日志
|
for (CrmContactDO contact : contacts) {
|
receiveContactLog(contact, ownerUserId);
|
}
|
}
|
|
@LogRecord(type = CRM_CONTACT_TYPE, subType = CRM_CONTACT_UPDATE_OWNER_USER_SUB_TYPE, bizNo = "{{#contact.id}}",
|
success = CRM_CONTACT_UPDATE_OWNER_USER_SUCCESS)
|
public void receiveContactLog(CrmContactDO contact, Long ownerUserId) {
|
// 记录操作日志上下文
|
LogRecordContext.putVariable("contact", contact);
|
LogRecordContext.putVariable("ownerUserId", ownerUserId);
|
}
|
|
@Override
|
@LogRecord(type = CRM_CONTACT_TYPE, subType = CRM_CONTACT_FOLLOW_UP_SUB_TYPE, bizNo = "{{#id}}",
|
success = CRM_CONTACT_FOLLOW_UP_SUCCESS)
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CONTACT, bizId = "#id", level = CrmPermissionLevelEnum.WRITE)
|
public void updateContactFollowUp(Long id, LocalDateTime contactNextTime, String contactLastContent) {
|
// 1. 校验存在
|
CrmContactDO contact = validateContactExists(id);
|
|
// 2. 更新联系人的跟进信息
|
contactMapper.updateById(new CrmContactDO().setId(id).setContactNextTime(contactNextTime)
|
.setContactLastTime(LocalDateTime.now()).setContactLastContent(contactLastContent));
|
|
// 3. 记录操作日志上下文
|
LogRecordContext.putVariable("contactName", contact.getName());
|
}
|
|
@Override
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CONTACT, bizId = "#ids", level = CrmPermissionLevelEnum.WRITE)
|
public void updateContactContactNextTime(Collection<Long> ids, LocalDateTime contactNextTime) {
|
contactMapper.updateBatch(convertList(ids, id -> new CrmContactDO().setId(id).setContactNextTime(contactNextTime)));
|
}
|
|
//======================= 查询相关 =======================
|
|
@Override
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CONTACT, bizId = "#id", level = CrmPermissionLevelEnum.READ)
|
public CrmContactDO getContact(Long id) {
|
return contactMapper.selectById(id);
|
}
|
|
@Override
|
public void validateContact(Long id) {
|
validateContactExists(id);
|
}
|
|
@Override
|
public List<CrmContactDO> getContactList(Collection<Long> ids) {
|
if (CollUtil.isEmpty(ids)) {
|
return ListUtil.empty();
|
}
|
return contactMapper.selectByIds(ids);
|
}
|
|
@Override
|
public List<CrmContactDO> getContactList(Long userId) {
|
CrmContactPageReqVO reqVO = new CrmContactPageReqVO();
|
reqVO.setPageSize(PAGE_SIZE_NONE); // 不分页
|
return contactMapper.selectPage(reqVO, userId).getList();
|
}
|
|
@Override
|
public PageResult<CrmContactDO> getContactPage(CrmContactPageReqVO pageReqVO, Long userId) {
|
return contactMapper.selectPage(pageReqVO, userId);
|
}
|
|
@Override
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CUSTOMER, bizId = "#pageVO.customerId", level = CrmPermissionLevelEnum.READ)
|
public PageResult<CrmContactDO> getContactPageByCustomerId(CrmContactPageReqVO pageVO) {
|
return contactMapper.selectPageByCustomerId(pageVO);
|
}
|
|
@Override
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_BUSINESS, bizId = "#pageVO.businessId", level = CrmPermissionLevelEnum.READ)
|
public PageResult<CrmContactDO> getContactPageByBusinessId(CrmContactPageReqVO pageVO) {
|
List<CrmContactBusinessDO> contactBusinessList = contactBusinessService.getContactBusinessListByBusinessId(pageVO.getBusinessId());
|
if (CollUtil.isEmpty(contactBusinessList)) {
|
return PageResult.empty();
|
}
|
return contactMapper.selectPageByBusinessId(pageVO, convertSet(contactBusinessList, CrmContactBusinessDO::getContactId));
|
}
|
|
@Override
|
public Long getContactCountByCustomerId(Long customerId) {
|
return contactMapper.selectCount(CrmContactDO::getCustomerId, customerId);
|
}
|
|
@Override
|
public List<CrmContactDO> getContactListByCustomerIdOwnerUserId(Long customerId, Long ownerUserId) {
|
return contactMapper.selectListByCustomerIdOwnerUserId(customerId, ownerUserId);
|
}
|
|
@Override
|
@CrmPermission(bizType = CrmBizTypeEnum.CRM_CUSTOMER, bizId = "#customerId", level = CrmPermissionLevelEnum.READ)
|
public List<CrmContactDO> getContactListByCustomerId(Long customerId) {
|
return contactMapper.selectListByCustomerId(customerId);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CrmContactImportRespVO importContactList(List<CrmContactImportExcelVO> importContacts,
|
CrmContactImportReqVO importReqVO) {
|
// 1. 校验非空
|
importContacts = filterList(importContacts, item -> StrUtil.isNotBlank(item.getName()));
|
if (CollUtil.isEmpty(importContacts)) {
|
throw exception(CONTACT_IMPORT_LIST_IS_EMPTY);
|
}
|
// 2. 校验负责人（为空则默认当前操作人）
|
Long ownerUserId = importReqVO.getOwnerUserId() != null ? importReqVO.getOwnerUserId() : getLoginUserId();
|
adminUserApi.validateUser(ownerUserId);
|
|
// 3. 逐条处理
|
CrmContactImportRespVO respVO = CrmContactImportRespVO.builder()
|
.createContactNames(new ArrayList<>())
|
.updateContactNames(new ArrayList<>())
|
.failureContactNames(new LinkedHashMap<>())
|
.build();
|
importContacts.forEach(importContact -> {
|
try {
|
// 3.1 解析客户
|
CrmCustomerDO customer = StrUtil.isBlank(importContact.getCustomerName()) ? null
|
: customerMapper.selectByCustomerName(importContact.getCustomerName());
|
if (customer == null) {
|
throw exception(CONTACT_IMPORT_CUSTOMER_NOT_EXISTS, importContact.getCustomerName());
|
}
|
// 3.2 判断是否存在
|
CrmContactDO existContact = contactMapper.selectByNameAndCustomerId(
|
importContact.getName(), customer.getId());
|
if (existContact == null) {
|
// 3.2.1 新增
|
CrmContactDO contact = BeanUtils.toBean(importContact, CrmContactDO.class)
|
.setCustomerId(customer.getId()).setOwnerUserId(ownerUserId);
|
contactMapper.insert(contact);
|
// 创建数据权限
|
permissionService.createPermission(new CrmPermissionCreateReqBO()
|
.setBizType(CrmBizTypeEnum.CRM_CONTACT.getType()).setBizId(contact.getId())
|
.setUserId(ownerUserId).setLevel(CrmPermissionLevelEnum.OWNER.getLevel()));
|
// 客户负责人自动拥有该联系人的读写权限
|
permissionService.createPermissionForCustomerOwner(CrmBizTypeEnum.CRM_CONTACT.getType(),
|
contact.getId(), customer.getId(), ownerUserId);
|
respVO.getCreateContactNames().add(importContact.getName());
|
// 记录操作日志
|
getSelf().importContactLog(contact, false);
|
return;
|
}
|
// 3.2.2 已存在，判断是否允许更新
|
if (!importReqVO.getUpdateSupport()) {
|
respVO.getFailureContactNames().put(importContact.getName(),
|
StrUtil.format(CONTACT_NAME_EXISTS.getMsg(), importContact.getName()));
|
return;
|
}
|
CrmContactDO updateContact = BeanUtils.toBean(importContact, CrmContactDO.class)
|
.setId(existContact.getId()).setCustomerId(customer.getId());
|
contactMapper.updateById(updateContact);
|
respVO.getUpdateContactNames().add(importContact.getName());
|
// 记录操作日志
|
getSelf().importContactLog(updateContact, true);
|
} catch (ServiceException ex) {
|
respVO.getFailureContactNames().put(importContact.getName(), ex.getMessage());
|
}
|
});
|
return respVO;
|
}
|
|
/**
|
* 记录导入联系人时的操作日志
|
*
|
* @param contact 联系人信息
|
* @param isUpdate 是否更新；true - 更新，false - 新增
|
*/
|
@LogRecord(type = CRM_CONTACT_TYPE, subType = CRM_CONTACT_IMPORT_SUB_TYPE, bizNo = "{{#contact.id}}",
|
success = CRM_CONTACT_IMPORT_SUCCESS)
|
public void importContactLog(CrmContactDO contact, boolean isUpdate) {
|
LogRecordContext.putVariable("contact", contact);
|
LogRecordContext.putVariable("isUpdate", isUpdate);
|
}
|
|
/**
|
* 获得自身的代理对象，解决 AOP 生效问题
|
*
|
* @return 自己
|
*/
|
private CrmContactServiceImpl getSelf() {
|
return SpringUtil.getBean(getClass());
|
}
|
|
}
|
