package com.nova.sankuai.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nova.sankuai.domain.dto.LoanMarketConfigDto;
import com.nova.sankuai.domain.dto.LoanSupermarketPageDto;
import com.nova.sankuai.domain.dto.LoanSupermarketVisitDto;
import com.nova.sankuai.domain.entity.ChannelInfo;
import com.nova.sankuai.domain.entity.Customer;
import com.nova.sankuai.domain.entity.CustomerUser;
import com.nova.sankuai.domain.entity.LoanSupermarket;
import com.nova.sankuai.domain.vo.LoanMarketHotLinkVo;
import com.nova.sankuai.domain.vo.LoanSupermarketVo;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.mapper.ChannelInfoMapper;
import com.nova.sankuai.infra.mapper.CustomerMapper;
import com.nova.sankuai.infra.mapper.CustomerUserMapper;
import com.nova.sankuai.infra.mapper.LoanSupermarketMapper;
import com.nova.sankuai.infra.utils.PageRequest;
import com.nova.sankuai.infra.utils.PageUtil;
import com.nova.sankuai.security.UserDetail;
import com.nova.sankuai.service.*;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Objects;

/**
 * @author weikangdi
 */
@Service
@AllArgsConstructor
public class LoanSupermarketServiceImpl extends ServiceImpl<LoanSupermarketMapper, LoanSupermarket> implements ILoanSupermarketService {

    private final LoanSupermarketMapper supermarketMapper;

    private final PageUtil pageUtil;

    private final IChannelLogService channelLogService;

    private final IChannelSupermarketService channelSupermarketService;

    private final IH5ChannelLoanMarketService h5ChannelLoanMarketService;

    private final ChannelInfoMapper channelInfoMapper;

    private final CustomerMapper customerMapper;

    private final CustomerUserMapper customerUserMapper;

    private final IChannelInfoService channelInfoService;


    @Override
    public IPage<LoanSupermarketVo> pageModel(PageRequest pageRequest, LoanSupermarketPageDto pageDto) {
        IPage<LoanSupermarketVo> page = supermarketMapper.pageModel(pageUtil.getPage(pageRequest), pageDto);
        return page;
    }

    @Override
    public void addVisitRecord(LoanSupermarketVisitDto visitDto) {
        channelLogService.createSupermarketLog(visitDto.getId(), visitDto.getSource(), visitDto.getCustomerId());
    }

    @Override
    public List<LoanSupermarket> getSupermarketList() {
        List<LoanSupermarket> result = supermarketMapper.getSupermarketList();
        return result;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void addLoanSupermarket(LoanSupermarket supermarket) {
        supermarket.setCreationDate(new Date());
        save(supermarket);
        channelSupermarketService.saveBySupermarket(supermarket);
        h5ChannelLoanMarketService.saveBySupermarket(supermarket);
    }


    @Override
    public void edit(LoanSupermarket supermarket) {
        LoanSupermarket loanSupermarketDb = getById(supermarket.getId());
        if (loanSupermarketDb == null) {
            throw new CommonException("该贷款超市不存在");
        }
        loanSupermarketDb.setName(supermarket.getName());
        loanSupermarketDb.setScopeStart(supermarket.getScopeStart());
        loanSupermarketDb.setScopeEnd(supermarket.getScopeEnd());
        loanSupermarketDb.setMonthlyInterestRate(supermarket.getMonthlyInterestRate());
        loanSupermarketDb.setDateStart(supermarket.getDateStart());
        loanSupermarketDb.setDateEnd(supermarket.getDateEnd());
        loanSupermarketDb.setHotFlag(supermarket.getHotFlag());
        loanSupermarketDb.setImageUrl(supermarket.getImageUrl());
        loanSupermarketDb.setLinkUrl(supermarket.getLinkUrl());
        loanSupermarketDb.setDescription(supermarket.getDescription());
        loanSupermarketDb.setSerialNumber(supermarket.getSerialNumber());
        updateById(loanSupermarketDb);
    }

    @Override
    public void editChannelConfig(LoanMarketConfigDto configDto) {
        LoanSupermarket loanSupermarketDb = getById(configDto.getId());
        if (loanSupermarketDb == null) {
            throw new CommonException("该贷款超市不存在");
        }
        BeanUtils.copyProperties(configDto, loanSupermarketDb);
        updateById(loanSupermarketDb);
        channelSupermarketService.editByLoanMarket(loanSupermarketDb);
        h5ChannelLoanMarketService.editByLoanMarket(loanSupermarketDb);
    }

    @Override
    public List<LoanMarketHotLinkVo> getLoanMarketHotLinkList() {
        List<LoanMarketHotLinkVo> result = supermarketMapper.getLoanMarketHotLinkList();
        return result;
    }

    @Override
    public boolean checkLoanMarketHotLinkRely(Long loanMarketId) {
        LoanSupermarket supermarket = getById(loanMarketId);
        if (supermarket == null) {
            throw new CommonException("该贷款超市不存在");
        }
        Integer count = channelInfoMapper.checkLoanMarketHotLinkRely(loanMarketId);
        if (count > 0) {
            return true;
        }
        return false;
    }

    @Override
    public void delete(Long id) {
        LoanSupermarket loanSupermarket = getById(id);
        if (loanSupermarket == null) {
            throw new CommonException("该贷款超市不存在");
        }
        removeById(id);
        channelInfoMapper.update(null, Wrappers.<ChannelInfo>lambdaUpdate()
                .set(ChannelInfo::getLoanMarketHotLinkSwitch, 0)
                .set(ChannelInfo::getLoanMarketHotLinkId, null)
                .eq(ChannelInfo::getLoanMarketHotLinkId, loanSupermarket.getId()));
    }

    @Override
    public List<LoanSupermarket> getSecondSupermarket() {
        List<LoanSupermarket> loanSupermarketList = list(new LambdaQueryWrapper<LoanSupermarket>()
                .eq(LoanSupermarket::getDeleteFlag, 0)
                .eq(LoanSupermarket::getEnableFlag, 1)
                .orderByAsc(LoanSupermarket::getSerialNumber));
        List<LoanSupermarket> loanSupermarkets = new ArrayList<>();
        if (loanSupermarketList != null && !loanSupermarketList.isEmpty()) {
            if (loanSupermarketList.size() > 2) {
                loanSupermarkets.add(loanSupermarketList.get(1));
            } else {
                loanSupermarkets.add(loanSupermarketList.get(0));
            }
        } else {
            loanSupermarkets.add(new LoanSupermarket());
        }
        return loanSupermarkets;
    }

    @Override
    public List<LoanSupermarket> getVipMode() {
        return list(new LambdaQueryWrapper<LoanSupermarket>()
                .eq(LoanSupermarket::getDeleteFlag, 0)
                .eq(LoanSupermarket::getEnableFlag, 1)
                .eq(LoanSupermarket::getIsOpenVipMode, 1)
                .orderByAsc(LoanSupermarket::getSerialNumber));
    }

    @Override
    public List<LoanSupermarketVo> getMyMoney(UserDetail userDetail) {
        Customer customer = customerMapper.getLatestCustomerRecord(userDetail.getPhone());
        CustomerUser user = customerUserMapper.selectOne(Wrappers.lambdaQuery(CustomerUser.class).eq(CustomerUser::getPhone, userDetail.getPhone()));
        ChannelInfo channelInfo = channelInfoService.lambdaQuery().eq(ChannelInfo::getCode, user.getSourceChannel()).eq(ChannelInfo::getType, ChannelInfo.TYPE_IMPORT).one();
        return baseMapper.findMyMoney(channelInfo.getId());
    }

    @Override
    public LoanSupermarketVo getWaitApproval(UserDetail userDetail) {
        LoanSupermarket supermarket = lambdaQuery().eq(LoanSupermarket::getWaitApproval, 1).orderByDesc(LoanSupermarket::getSerialNumber).last("LIMIT 1").one();
        if (Objects.nonNull(supermarket)) {
            LoanSupermarketVo vo = new LoanSupermarketVo();
            BeanUtils.copyProperties(supermarket, vo);
            return vo;
        }
        return null;
    }
}