link-wechat-master.zip

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.base.Joiner; import com.google.common.collect.Lists; import com.linkwechat.common.annotation.SynchRecord; import com.linkwechat.common.constant.Constants; import com.linkwechat.common.constant.HttpStatus; import com.linkwechat.common.constant.SynchRecordConstants; import com.linkwechat.common.constant.WeConstans; 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.*; import com.linkwechat.common.exception.wecom.WeComException; import com.linkwechat.common.utils.DateUtils; 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.tag.vo.WeTagVo; 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.UnionidToExternalUserIdQuery; import com.linkwechat.domain.wecom.query.customer.WeBatchCustomerQuery; import com.linkwechat.domain.wecom.query.customer.WeCustomerQuery; import com.linkwechat.domain.wecom.query.customer.tag.WeMarkTagQuery; import com.linkwechat.domain.wecom.query.customer.transfer.WeTransferCustomerQuery; import com.linkwechat.domain.wecom.vo.customer.UnionidToExternalUserIdVo; import com.linkwechat.domain.wecom.vo.customer.WeBatchCustomerDetailVo; import com.linkwechat.domain.wecom.vo.customer.WeCustomerDetailVo; import com.linkwechat.domain.wecom.vo.customer.WeFollowUserListVo; 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.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.linkwechat.common.utils.SecurityUtils; 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 private IWeGroupService iWeGroupService; @Autowired private RabbitMQSettingConfig rabbitMQSettingConfig; @Autowired private RabbitTemplate rabbitTemplate; @Autowired private IWeMessagePushService iWeMessagePushService; @Autowired private IWeCustomerSeasService iWeCustomerSeasService; @Autowired private IWeCustomerInfoExpandService iWeCustomerInfoExpandService; @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 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.noRepeatCountCustomer(weCustomersQuery); } @Override @SynchRecord(synchType = SynchRecordConstants.SYNCH_CUSTOMER) public void synchWeCustomer() { LoginUser loginUser = SecurityUtils.getLoginUser(); rabbitTemplate.convertAndSend(rabbitMQSettingConfig.getWeSyncEx(), rabbitMQSettingConfig.getWeCustomerRk(), JSONObject.toJSONString(loginUser)); } @Override @Async public void synchWeCustomerHandler(String msg) { LoginUser loginUser = JSONObject.parseObject(msg, LoginUser.class); SecurityContextHolder.setCorpId(loginUser.getCorpId()); SecurityContextHolder.setUserName(loginUser.getUserName()); SecurityContextHolder.setUserId(String.valueOf(loginUser.getSysUser().getUserId())); SecurityContextHolder.setUserType(loginUser.getUserType()); WeFollowUserListVo followUserList = qwCustomerClient.getFollowUserList(new WeBaseQuery()).getData(); if (null != followUserList && CollectionUtil.isNotEmpty(followUserList.getFollowUser())) { this.synchWeCustomerByAddIds(followUserList.getFollowUser()); } } /** * 通过跟进人id同步客户 * @param followUserIds * @return */ @Override public void synchWeCustomerByAddIds(List<String> followUserIds){ if(CollectionUtil.isNotEmpty(followUserIds)){ List<List<String>> partition = Lists.part