package com.mzl.flower.service.customer;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.mzl.flower.config.security.SecurityUtils;
import com.mzl.flower.dto.response.customer.CustomerTjDTO;
import com.mzl.flower.dto.response.customer.InviteDTO;
import com.mzl.flower.dto.response.customer.InviteRewardDTO;
import com.mzl.flower.entity.customer.BrowseHistory;
import com.mzl.flower.entity.customer.Collect;
import com.mzl.flower.entity.customer.Follow;
import com.mzl.flower.mapper.customer.BrowseHistoryMapper;
import com.mzl.flower.mapper.customer.CollectMapper;
import com.mzl.flower.mapper.customer.CustomerMapper;
import com.mzl.flower.mapper.customer.FollowMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Collections;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;

@Service
@Transactional
@Slf4j
public class CustomerCenterService {

    private final FollowMapper followMapper;
    private final CollectMapper collectMapper;
    private final BrowseHistoryMapper browseHistoryMapper;
    private final CustomerMapper customerMapper;

    public CustomerCenterService(FollowMapper followMapper, CollectMapper collectMapper, BrowseHistoryMapper browseHistoryMapper, CustomerMapper customerMapper) {
        this.followMapper = followMapper;
        this.collectMapper = collectMapper;
        this.browseHistoryMapper = browseHistoryMapper;
        this.customerMapper = customerMapper;
    }


    public CustomerTjDTO customerCenterTj(String userId) {
        CustomerTjDTO dto = new CustomerTjDTO();
        dto.setFollowNum(followMapper.selectCount(new LambdaQueryWrapper<Follow>().eq(Follow::getUserId, userId)));
        dto.setCollectNum(collectMapper.selectCount(new LambdaQueryWrapper<Collect>().eq(Collect::getUserId, userId)));
        dto.setBrowseNum(browseHistoryMapper.selectCount(new LambdaQueryWrapper<BrowseHistory>().eq(BrowseHistory::getUserId, userId)));
        return dto;
    }

    //获取所有的邀请记录和当前登陆人的邀请记录
    public InviteRewardDTO customerReward() {
        InviteRewardDTO rewardto = new InviteRewardDTO();
        List<InviteDTO> reward = customerMapper.getReward();
        List<InviteDTO> myreward = customerMapper.getMyReward(SecurityUtils.getUserId());
        List<InviteDTO> processedReward = reward.stream()
                .filter(Objects::nonNull)
                .peek(dto -> {
                    dto.setUserId(maskAll(dto.getUserId()));
                    dto.setUserName(maskMiddle(dto.getUserName(), 4));
                }).collect(Collectors.toList());

        rewardto.setSuccessInvite(processedReward);
        List<InviteDTO> processedMyReward = myreward.stream()
                .filter(Objects::nonNull)
                .peek(dto -> {
                    dto.setUserId(maskAll(dto.getUserId()));
                    dto.setUserName(maskMiddle(dto.getUserName(), 4));
                }).collect(Collectors.toList());
        rewardto.setMyInvite(processedMyReward);
        return rewardto;
    }


    // 全部字符替换为*
    private String maskAll(String input) {
        if (input == null || input.isEmpty()) {
            return input;
        }
        return input.replaceAll(".", "*");
    }

    // 中间部分替换（最多maxStars个*）
    private String maskMiddle(String input, int maxStars) {
        if (input == null || input.length() <= 2) {
            return input == null ? null : "*"; // 1-2个字符直接返回*
        }

        int length = input.length();
        int stars = Math.min(maxStars, length - 2); // 最多maxStars个*

        String starsStr = String.join("", Collections.nCopies(stars, "*"));
        return input.charAt(0) + starsStr + input.charAt(length - 1);
    }
}