基于企业微信的开源SCRM系统，前端采用vue3架构，后端采用主流的Java微服务架构，是企业私域流量管理与营销的综合解决方案

package com.linkwechat.service.impl; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.ListUtil; import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.google.common.collect.Lists; import com.linkwechat.common.annotation.SynchRecord; import com.linkwechat.common.constant.*; import com.linkwechat.common.context.SecurityContextHolder; import com.linkwechat.common.core.domain.AjaxResult; import com.linkwechat.common.core.domain.entity.SysUser; import com.linkwechat.common.core.domain.model.LoginUser; import com.linkwechat.common.core.page.PageDomain; import com.linkwechat.common.core.page.TableDataInfo; import com.linkwechat.common.enums.CustomerAddWay; import com.linkwechat.common.enums.MessageNoticeType; import com.linkwechat.common.enums.TrajectorySceneType; import com.linkwechat.common.enums.WeErrorCodeEnum; import com.linkwechat.common.enums.message.MessageTypeEnum; import com.linkwechat.common.enums.*; import com.linkwechat.common.exception.wecom.WeComException; import com.linkwechat.common.utils.DateUtils; import com.linkwechat.common.utils.SecurityUtils; import com.linkwechat.common.utils.SnowFlakeUtil; import com.linkwechat.common.utils.StringUtils; import com.linkwechat.common.utils.bean.BeanUtils; import com.linkwechat.config.rabbitmq.RabbitMQSettingConfig; import com.linkwechat.domain.*; import com.linkwechat.domain.customer.WeBacthMakeCustomerTag; import com.linkwechat.domain.customer.WeMakeCustomerTag; import com.linkwechat.domain.customer.query.WeCustomersQuery; import com.linkwechat.domain.customer.query.WeOnTheJobCustomerQuery; import com.linkwechat.domain.customer.vo.*; import com.linkwechat.domain.groupmsg.query.WeAddGroupMessageQuery; import com.linkwechat.domain.groupmsg.vo.WeGroupMessageExecuteUsertipVo; import com.linkwechat.domain.wecom.entity.customer.WeCustomerFollowInfoEntity; import com.linkwechat.domain.wecom.entity.customer.WeCustomerFollowUserEntity; import com.linkwechat.domain.wecom.query.WeBaseQuery; import com.linkwechat.domain.wecom.query.customer.*; import com.linkwechat.domain.wecom.query.customer.tag.WeMarkTagQuery; import com.linkwechat.domain.wecom.query.customer.transfer.WeTransferCustomerQuery; import com.linkwechat.domain.wecom.vo.WeResultVo; import com.linkwechat.domain.wecom.vo.customer.*; import com.linkwechat.domain.wecom.vo.customer.transfer.WeTransferCustomerVo; import com.linkwechat.fegin.QwCustomerClient; import com.linkwechat.mapper.WeCustomerMapper; import com.linkwechat.service.*; import org.apache.ibatis.annotations.Param; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; @Service public class WeCustomerServiceImpl extends ServiceImpl<WeCustomerMapper, WeCustomer> implements IWeCustomerService { @Autowired private QwCustomerClient qwCustomerClient; @Autowired private IWeFlowerCustomerTagRelService iWeFlowerCustomerTagRelService; @Autowired private IWeTagService iWeTagService; @Autowired private IWeCustomerTrajectoryService iWeCustomerTrajectoryService; @Autowired private IWeAllocateCustomerService iWeAllocateCustomerService; @Autowired @Lazy private IWeGroupService iWeGroupService; @Autowired private RabbitMQSettingConfig rabbitMQSettingConfig; @Autowired private RabbitTemplate rabbitTemplate; @Autowired private IWeMessagePushService iWeMessagePushService; @Autowired private IWeCustomerSeasService iWeCustomerSeasService; @Autowired private IWeCustomerInfoExpandService iWeCustomerInfoExpandService; @Autowired @Lazy private IWeFissionService iWeFissionService; @Resource private IWeMessageNotificationService weMessageNotificationService; @Autowired private IWeCustomerLinkService iWeCustomerLinkService; @Override public List<WeCustomersVo> findWeCustomerList(WeCustomersQuery weCustomersQuery, PageDomain pageDomain) { List<WeCustomersVo> weCustomersVos = new ArrayList<>(); List<String> ids = this.baseMapper.findWeCustomerListIds(weCustomersQuery, pageDomain); if (CollectionUtil.isNotEmpty(ids)) { weCustomersVos = this.baseMapper.findWeCustomerList(ids); } return weCustomersVos; } @Override public List<WeCustomersVo> findWeCustomerInfoFromWechat(List<String> externalUserids) { List<WeCustomersVo> weCustomersVos = new ArrayList<>(); if (CollectionUtil.isNotEmpty(externalUserids)) { List<WeCustomer> weCustomers = this.list(new LambdaQueryWrapper<WeCustomer>() .in(WeCustomer::getExternalUserid, externalUserids)); externalUserids.stream().forEach(k -> { WeCustomersVo weCustomersVo = new WeCustomersVo(); weCustomersVo.setCustomerName("@微信客户"); if (CollectionUtil.isNotEmpty(weCustomers)) { List<WeCustomer> weCustomerss = weCustomers.stream().filter(item -> item.getExternalUserid().equals(k)).collect(Collectors.toList()); if (CollectionUtil.isNotEmpty(weCustomerss)) { weCustomersVo.setCustomerName(weCustomerss.stream().findFirst().get().getCustomerName()); } } weCustomersVo.setExternalUserid(k); weCustomersVos.add(weCustomersVo); }); } return weCustomersVos; } @Override public TableDataInfo<List<WeCustomersVo>> findWeCustomerListByApp(WeCustomersQuery weCustomersQuery, PageDomain pageDomain) { TableDataInfo<List<WeCustomersVo>> tableDataInfo = new TableDataInfo<>(); tableDataInfo.setCode(HttpStatus.SUCCESS); if (weCustomersQuery.getDataScope()) {//这里指的全部数据,是角色的那些数据 tableDataInfo.setRows( this.findWeCustomerList(weCustomersQuery, pageDomain) ); tableDataInfo.setTotal( this.countWeCustomerList(weCustomersQuery) ); } else {//个人数据 weCustomersQuery.setFirstUserId( SecurityUtils.getLoginUser().getSysUser().getWeUserId() ); List<String> customerIds = this.baseMapper.findWeCustomerListIdsByApp(weCustomersQuery, pageDomain); if (CollectionUtil.isNotEmpty(customerIds)) { tableDataInfo.setRows( this.baseMapper.findWeCustomerList(customerIds) ); tableDataInfo.setTotal( this.countWeCustomerListByApp(weCustomersQuery) ); } } List<WeCustomersVo> rows = tableDataInfo.getRows(); if (CollectionUtil.isEmpty(rows)) { tableDataInfo.setRows(new ArrayList<>()); } return tableDataInfo; } @Override public long countWeCustomerList(WeCustomersQuery weCustomersQuery) { return this.baseMapper.countWeCustomerList(weCustomersQuery); } @Override public long countWeCustomerListByApp(WeCustomersQuery weCustomersQuery) { return this.baseMapper.countWeCustomerListByApp(weCustomersQuery); } @Override public long noRepeatCountCustomer(WeCustomersQuery weCustomersQuery) { return this.baseMapper.noR