package cn.iocoder.yudao.module.crm.service.customer;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.crm.controller.admin.customer.vo.progress.CrmCustomerProgressSaveReqVO;
import cn.iocoder.yudao.module.crm.dal.dataobject.customer.CrmCustomerDO;
import cn.iocoder.yudao.module.crm.dal.dataobject.customer.CrmCustomerProgressDO;
import cn.iocoder.yudao.module.crm.dal.mysql.customer.CrmCustomerProgressMapper;
import cn.iocoder.yudao.module.crm.enums.common.CrmBizTypeEnum;
import cn.iocoder.yudao.module.crm.enums.permission.CrmPermissionLevelEnum;
import cn.iocoder.yudao.module.crm.framework.permission.core.annotations.CrmPermission;
import cn.iocoder.yudao.module.crm.service.permission.CrmPermissionService;
import cn.iocoder.yudao.module.crm.util.CrmPermissionUtils;
import jakarta.annotation.Resource;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;

import java.util.Collection;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId;
import static cn.iocoder.yudao.module.crm.enums.ErrorCodeConstants.CRM_PERMISSION_DENIED;
import static cn.iocoder.yudao.module.crm.enums.ErrorCodeConstants.CUSTOMER_PROGRESS_NOT_EXISTS;

/**
 * CRM 客户洽谈进度 Service 实现类
 *
 * @author 超级管理员
 */
@Service
@Validated
public class CrmCustomerProgressServiceImpl implements CrmCustomerProgressService {

    @Resource
    private CrmCustomerProgressMapper customerProgressMapper;

    @Resource
    @Lazy
    private CrmPermissionService permissionService;

    @Resource
    private CrmCustomerService customerService;

    @Override
    @CrmPermission(bizType = CrmBizTypeEnum.CRM_CUSTOMER, bizId = "#createReqVO.customerId",
            level = CrmPermissionLevelEnum.WRITE)
    public Long createProgress(CrmCustomerProgressSaveReqVO createReqVO) {
        CrmCustomerProgressDO progress = BeanUtils.toBean(createReqVO, CrmCustomerProgressDO.class);
        customerProgressMapper.insert(progress);
        return progress.getId();
    }

    @Override
    public void updateProgress(CrmCustomerProgressSaveReqVO updateReqVO) {
        // 1. 校验存在
        CrmCustomerProgressDO oldProgress = validateProgressExists(updateReqVO.getId());
        // 2. 校验权限：洽谈进度跟随客户，客户写权限即可修改
        validateCustomerWritePermission(oldProgress.getCustomerId());
        // 3. 更新（客户编号不允许修改）
        CrmCustomerProgressDO updateObj = BeanUtils.toBean(updateReqVO, CrmCustomerProgressDO.class);
        updateObj.setCustomerId(oldProgress.getCustomerId());
        customerProgressMapper.updateById(updateObj);
    }

    @Override
    public void deleteProgress(Long id) {
        // 1. 校验存在
        CrmCustomerProgressDO progress = validateProgressExists(id);
        // 2. 校验权限
        validateCustomerWritePermission(progress.getCustomerId());
        // 3. 删除
        customerProgressMapper.deleteById(id);
    }

    @Override
    @CrmPermission(bizType = CrmBizTypeEnum.CRM_CUSTOMER, bizId = "#customerId",
            level = CrmPermissionLevelEnum.READ)
    public List<CrmCustomerProgressDO> getProgressListByCustomerId(Long customerId) {
        return customerProgressMapper.selectListByCustomerId(customerId);
    }

    @Override
    public Map<Long, CrmCustomerProgressDO> getLatestProgressMap(Collection<Long> customerIds) {
        List<CrmCustomerProgressDO> list = customerProgressMapper.selectListByCustomerIds(customerIds);
        if (CollUtil.isEmpty(list)) {
            return new LinkedHashMap<>();
        }
        // 已按洽谈时间倒序，同一客户保留第一条即最新
        Map<Long, CrmCustomerProgressDO> result = new LinkedHashMap<>();
        for (CrmCustomerProgressDO progress : list) {
            result.putIfAbsent(progress.getCustomerId(), progress);
        }
        return result;
    }

    /**
     * 异常提示里用的客户名称：解析失败时回退为 ID，避免异常分支再抛二次异常
     */
    private String getCustomerDisplayName(Long customerId) {
        try {
            CrmCustomerDO customer = customerService.getCustomer(customerId);
            return customer != null && StrUtil.isNotBlank(customer.getName())
                    ? customer.getName() : "ID=" + customerId;
        } catch (Exception ex) {
            return "ID=" + customerId;
        }
    }

    private CrmCustomerProgressDO validateProgressExists(Long id) {
        CrmCustomerProgressDO progress = customerProgressMapper.selectById(id);
        if (progress == null) {
            throw exception(CUSTOMER_PROGRESS_NOT_EXISTS);
        }
        return progress;
    }

    private void validateCustomerWritePermission(Long customerId) {
        // 超管 / CRM 管理员与 @CrmPermission 切面保持一致，直接放行
        if (CrmPermissionUtils.isCrmAdmin()) {
            return;
        }
        if (!permissionService.hasPermission(CrmBizTypeEnum.CRM_CUSTOMER.getType(), customerId,
                getLoginUserId(), CrmPermissionLevelEnum.WRITE)) {
            throw new ServiceException(CRM_PERMISSION_DENIED.getCode(),
                    "没有权限修改/删除客户[" + getCustomerDisplayName(customerId)
                            + "]的洽谈进度：您不是该客户的负责人或团队成员。请让客户负责人在客户详情「团队成员」中把您加入，"
                            + "或切换到该客户负责人账号后重试。");
        }
    }

}