package com.doumee.service.business.impl;
|
|
import com.doumee.biz.zbom.ZbomCRMService;
|
import com.doumee.biz.zbom.model.crm.CRMConstants;
|
import com.doumee.biz.zbom.model.crm.CrmDaogouBindListRequest;
|
import com.doumee.biz.zbom.model.crm.response.CRMBaseResponse;
|
import com.doumee.biz.zbom.model.crm.response.CRMDaogouBindListResponse;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.CustomerUserMapper;
|
import com.doumee.dao.business.MemberMapper;
|
import com.doumee.dao.business.UsersMapper;
|
import com.doumee.dao.business.model.CustomerUser;
|
import com.doumee.dao.business.model.Member;
|
import com.doumee.dao.business.model.Users;
|
import com.doumee.service.business.CustomerUserService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 客户导购关联表Service实现
|
* @author 江蹄蹄
|
* @date 2024/07/15 10:21
|
*/
|
@Service
|
public class CustomerUserServiceImpl implements CustomerUserService {
|
|
@Autowired
|
private CustomerUserMapper customerUserMapper;
|
@Autowired
|
private MemberMapper memberMapper;
|
@Autowired
|
private UsersMapper usersMapper;
|
@Autowired
|
private ZbomCRMService zbomCRMService;
|
|
@Override
|
public Long create(CustomerUser customerUser) {
|
customerUserMapper.insert(customerUser);
|
return customerUser.getId();
|
}
|
|
@Override
|
public void deleteById(Long id) {
|
customerUserMapper.deleteById(id);
|
}
|
|
@Override
|
public void delete(CustomerUser customerUser) {
|
UpdateWrapper<CustomerUser> deleteWrapper = new UpdateWrapper<>(customerUser);
|
customerUserMapper.delete(deleteWrapper);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<Long> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
customerUserMapper.deleteBatchIds(ids);
|
}
|
|
@Override
|
public void updateById(CustomerUser customerUser) {
|
customerUserMapper.updateById(customerUser);
|
}
|
|
@Override
|
public void updateByIdInBatch(List<CustomerUser> customerUsers) {
|
if (CollectionUtils.isEmpty(customerUsers)) {
|
return;
|
}
|
for (CustomerUser customerUser: customerUsers) {
|
this.updateById(customerUser);
|
}
|
}
|
|
@Override
|
public CustomerUser findById(Long id) {
|
return customerUserMapper.selectById(id);
|
}
|
|
@Override
|
public CustomerUser findOne(CustomerUser customerUser) {
|
QueryWrapper<CustomerUser> wrapper = new QueryWrapper<>(customerUser);
|
return customerUserMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<CustomerUser> findList(CustomerUser customerUser) {
|
QueryWrapper<CustomerUser> wrapper = new QueryWrapper<>(customerUser);
|
return customerUserMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<CustomerUser> findPage(PageWrap<CustomerUser> pageWrap) {
|
IPage<CustomerUser> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
QueryWrapper<CustomerUser> queryWrapper = new QueryWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
if (pageWrap.getModel().getId() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getId, pageWrap.getModel().getId());
|
}
|
if (pageWrap.getModel().getIsdeleted() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getIsdeleted, pageWrap.getModel().getIsdeleted());
|
}
|
if (pageWrap.getModel().getCreateDate() != null) {
|
queryWrapper.lambda().ge(CustomerUser::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
|
queryWrapper.lambda().le(CustomerUser::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
|
}
|
if (pageWrap.getModel().getCreator() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getCreator, pageWrap.getModel().getCreator());
|
}
|
if (pageWrap.getModel().getEditDate() != null) {
|
queryWrapper.lambda().ge(CustomerUser::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
|
queryWrapper.lambda().le(CustomerUser::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
|
}
|
if (pageWrap.getModel().getEditor() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getEditor, pageWrap.getModel().getEditor());
|
}
|
if (pageWrap.getModel().getPhone() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getPhone, pageWrap.getModel().getPhone());
|
}
|
if (pageWrap.getModel().getInfo() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getInfo, pageWrap.getModel().getInfo());
|
}
|
if (pageWrap.getModel().getUserId() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getUserId, pageWrap.getModel().getUserId());
|
}
|
if (pageWrap.getModel().getIamUserId() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getIamUserId, pageWrap.getModel().getIamUserId());
|
}
|
if (pageWrap.getModel().getMemberId() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getMemberId, pageWrap.getModel().getMemberId());
|
}
|
if (pageWrap.getModel().getName() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getName, pageWrap.getModel().getName());
|
}
|
if (pageWrap.getModel().getOrgName() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getOrgName, pageWrap.getModel().getOrgName());
|
}
|
if (pageWrap.getModel().getUsername() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getUsername, pageWrap.getModel().getUsername());
|
}
|
if (pageWrap.getModel().getProductCodeName() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getProductCodeName, pageWrap.getModel().getProductCodeName());
|
}
|
if (pageWrap.getModel().getAddr() != null) {
|
queryWrapper.lambda().eq(CustomerUser::getAddr, pageWrap.getModel().getAddr());
|
}
|
for(PageWrap.SortData sortData: pageWrap.getSorts()) {
|
if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
|
queryWrapper.orderByDesc(sortData.getProperty());
|
} else {
|
queryWrapper.orderByAsc(sortData.getProperty());
|
}
|
}
|
return PageData.from(customerUserMapper.selectPage(page, queryWrapper));
|
}
|
|
@Override
|
public long count(CustomerUser customerUser) {
|
QueryWrapper<CustomerUser> wrapper = new QueryWrapper<>(customerUser);
|
return customerUserMapper.selectCount(wrapper);
|
}
|
@Override
|
@Transactional
|
public void syncYesterday(String date) {
|
CrmDaogouBindListRequest request = new CrmDaogouBindListRequest();
|
request.setPage(0);
|
request.setPageSize(100);
|
request.setTiming(Constants.ONE+"");
|
request.setCreationDate(date);
|
boolean hasMore = true;
|
int currentNum = 0;
|
Date cdate = new Date();
|
while (hasMore){
|
try {
|
request.setPage(request.getPage()+1);
|
currentNum += currentNum;
|
CRMBaseResponse<List<CRMDaogouBindListResponse>> response = zbomCRMService.getDaogouBindList(request);
|
if(response==null
|
|| !StringUtils.equals(response.getCode(), CRMConstants.CODE_SUCCESS)
|
|| response.getData() ==null
|
|| response.getData().size() ==0){
|
hasMore = false;
|
}
|
if(currentNum >= response.getTotal()){
|
hasMore = false;
|
}
|
dealSyncDataBiz(cdate,response.getData());
|
}catch (Exception e){
|
hasMore = false;
|
}
|
}
|
}
|
|
private void dealSyncDataBiz(Date date,List<CRMDaogouBindListResponse> list) {
|
List<CustomerUser> addList = new ArrayList<>();
|
List<String> phoneList = new ArrayList<>();
|
for(CRMDaogouBindListResponse data : list){
|
if(StringUtils.isBlank(data.getCustomerPhone())){
|
continue;
|
}
|
Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda()
|
.eq(Member::getPhone,data.getCustomerPhone() )
|
.eq(Member::getIsdeleted,Constants.ZERO)
|
.last("limit 1" ));
|
Users user = usersMapper.selectOne(new QueryWrapper<Users>().lambda()
|
.eq(Users::getIamId,data.getUserId() )
|
.last("limit 1" ));
|
if(member == null){
|
continue;
|
}
|
phoneList.add(data.getCustomerPhone());
|
|
CustomerUser model = new CustomerUser();
|
model.setCreateDate(date);
|
model.setIsdeleted(Constants.ZERO);
|
model.setEditDate(date);
|
model.setName(data.getDgName());
|
model.setPhone(data.getDgPhone());
|
model.setOrgName(data.getOrgName());
|
model.setCustomerName(data.getCustomerName());
|
model.setCustomerPhone(data.getCustomerPhone());
|
model.setUsername(data.getUserName());
|
model.setSource(Constants.ONE);
|
model.setZtStatus(Constants.ONE);
|
model.setZtInfo("crm同步");
|
model.setIamUserId(data.getUserId());
|
model.setUserId(user== null?null:user.getId());
|
model.setCreationDate(data.getCreationDate());
|
addList.add(model);
|
}
|
if(phoneList.size()>0){
|
/**
|
* 删除老得数据
|
*/
|
customerUserMapper.update(null,new UpdateWrapper<CustomerUser>().lambda()
|
.in(CustomerUser::getPhone,phoneList)
|
.eq(CustomerUser::getZtStatus,Constants.ONE)
|
.eq(CustomerUser::getIsdeleted,Constants.ZERO)
|
.set(CustomerUser::getIsdeleted,Constants.ONE)
|
);
|
}
|
if(addList .size() >0){
|
int temp = 0;
|
while(temp < addList.size()){
|
int index;
|
if(temp + 500 <= addList.size()){
|
index = temp+500;
|
}else{
|
index = addList.size();
|
}
|
customerUserMapper.insert(addList.subList(temp,index));
|
temp = index;
|
}
|
}
|
}
|
}
|
