package com.ruoyi.basic.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.basic.dto.CustomerReturnVisitDto;
import com.ruoyi.basic.mapper.CustomerReturnVisitMapper;
import com.ruoyi.basic.pojo.CustomerReturnVisit;
import com.ruoyi.basic.service.CustomerReturnVisitService;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.time.LocalDateTime;
import java.util.List;

/**
 * <br>
 * 客户回访提醒接口实现类
 * </br>
 *
 * @author deslrey
 * @version 1.0
 * @since 2026/03/04 17:58
 */
@Service
public class CustomerReturnVisitServiceImpl extends ServiceImpl<CustomerReturnVisitMapper, CustomerReturnVisit> implements CustomerReturnVisitService {

    @Autowired
    private ReturnVisitReminderService returnVisitReminderService;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public int saveOrUpdateReturnVisit(CustomerReturnVisit customerReturnVisit) {
        validateReturnVisit(customerReturnVisit);
        Long currentUserId = SecurityUtils.getUserId();
        Long currentTenantId = SecurityUtils.getLoginUser().getTenantId();
        if (customerReturnVisit.getId() != null) {
            CustomerReturnVisit existing = baseMapper.selectById(customerReturnVisit.getId());
            if (existing == null) {
                throw new ServiceException("回访提醒不存在");
            }
            if (!existing.getTenantId().equals(currentTenantId)) {
                throw new ServiceException("无权限修改此回访提醒");
            }
            customerReturnVisit.setUpdateUser(currentUserId);
            customerReturnVisit.setUpdateTime(LocalDateTime.now());
            int result = baseMapper.updateById(customerReturnVisit);

            //  根据提醒开关来判断队列信息新增或取消
            if (customerReturnVisit.getIsEnabled() == 1) {
                returnVisitReminderService.scheduleReminder(customerReturnVisit.getId());
            } else {
                returnVisitReminderService.cancelReminder(customerReturnVisit.getId());
            }
            return result;
        } else {
            customerReturnVisit.setCreateUser(currentUserId);
            customerReturnVisit.setCreateTime(LocalDateTime.now());
            customerReturnVisit.setTenantId(currentTenantId);
            int result = baseMapper.insert(customerReturnVisit);

            if (customerReturnVisit.getIsEnabled() == 1) {
                returnVisitReminderService.scheduleReminder(customerReturnVisit.getId());
            }
            return result;
        }
    }

    @Override
    public CustomerReturnVisitDto getByCustomerId(Integer customerId) {
        if (customerId == null) {
            throw new ServiceException("客户ID不能为空");
        }
        LambdaQueryWrapper<CustomerReturnVisit> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(CustomerReturnVisit::getCustomerId, customerId);
        CustomerReturnVisit returnVisit = baseMapper.selectOne(queryWrapper);

        if (returnVisit == null) {
            return null;
        }

        CustomerReturnVisitDto dto = new CustomerReturnVisitDto();
        BeanUtils.copyProperties(returnVisit, dto);
        return dto;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void deleteByCustomerId(Long customerId) {
        if (customerId == null) {
            throw new ServiceException("客户ID不能为空");
        }
        LambdaQueryWrapper<CustomerReturnVisit> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(CustomerReturnVisit::getCustomerId, customerId);
        List<CustomerReturnVisit> returnVisits = baseMapper.selectList(queryWrapper);

        for (CustomerReturnVisit returnVisit : returnVisits) {
            returnVisitReminderService.cancelReminder(returnVisit.getId());
        }
        baseMapper.delete(queryWrapper);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void markAsRead(Long id) {
        if (id == null) {
            throw new ServiceException("回访提醒ID不能为空");
        }
        CustomerReturnVisit returnVisit = baseMapper.selectById(id);
        if (returnVisit == null) {
            throw new ServiceException("回访提醒不存在");
        }

        CustomerReturnVisit updateObj = new CustomerReturnVisit();
        updateObj.setId(id);
        updateObj.setIsCompleted(1);
        baseMapper.updateById(updateObj);
    }

    private void validateReturnVisit(CustomerReturnVisit returnVisit) {
        if (returnVisit == null) {
            throw new ServiceException("回访提醒数据不能为空");
        }
        if (returnVisit.getCustomerId() == null) {
            throw new ServiceException("客户ID不能为空");
        }
        if (returnVisit.getReminderTime() == null) {
            throw new ServiceException("提醒时间不能为空");
        }
        if (returnVisit.getIsEnabled() != null && returnVisit.getIsEnabled() == 1) {
            if (returnVisit.getReminderTime().isBefore(LocalDateTime.now())) {
                throw new ServiceException("提醒时间不能早于当前时间");
            }
        }
    }
}