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);
        this.syncData(request);
    }

    @Override
    @Transactional
    public void syncByPhone(String phone) {
        CrmDaogouBindListRequest request = new CrmDaogouBindListRequest();
        request.setPage(0);
        request.setPageSize(100);
        request.setTiming(Constants.ZERO+"");
        request.setKeyWords(phone);
        this.syncData(request);
    }

    public void syncData(CrmDaogouBindListRequest request){
        boolean hasMore = true;
        int currentNum = 0;
        Date cdate = new Date();
        List<CRMDaogouBindListResponse> allList = new ArrayList<>();
        while (hasMore){
            try {
                request.setPage(request.getPage()+1);
                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;
                }else{
                    allList.addAll(response.getData());
                    currentNum += response.getTotal();
                }
                if(currentNum >= response.getTotal()){
                    hasMore = false;
                }
            }catch (Exception e){
                hasMore = false;
            }
        }
        dealSyncDataBiz(cdate,allList);
    }

    private void dealSyncDataBiz(Date date,List<CRMDaogouBindListResponse> list) {
        if(list ==null && list.size()==0){
            return;
        }
        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;
            }
        }
    }
}