package com.ruoyi.approve.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.approve.bean.dto.LogReportDto;
import com.ruoyi.approve.mapper.LogReportMapper;
import com.ruoyi.approve.pojo.LogReport;
import com.ruoyi.approve.service.LogReportService;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.project.system.domain.SysUser;
import com.ruoyi.project.system.mapper.SysUserMapper;
import com.ruoyi.project.system.service.ISysNoticeService;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

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

/**
 * <p>
 * 日志表 服务实现类
 * </p>
 *
 * @author 芯导软件（江苏）有限公司
 * @since 2026-05-08 01:51:13
 */
@Service
@RequiredArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class LogReportServiceImpl extends ServiceImpl<LogReportMapper, LogReport> implements LogReportService {

    private final LogReportMapper sysLogReportMapper;
    private final ISysNoticeService sysNoticeService;
    private final SysUserMapper sysUserMapper;

    @Override
    public IPage<LogReportDto> listPage(Page page, LogReportDto sysLogReport) {
        Long userId = SecurityUtils.getUserId();
        IPage<LogReportDto> logReportDtoIPage = sysLogReportMapper.listPage(page, sysLogReport, userId);
        logReportDtoIPage.getRecords().forEach(sysLogReportDto -> {
            String ccUsers = sysLogReportDto.getCcUsers();
            if (StringUtils.isBlank(ccUsers)) {
                return;
            }
            List<Long> userIdList = Arrays.stream(ccUsers.split(","))
                    .filter(StringUtils::isNotBlank)  // 过滤空字符串
                    .map(String::trim)                 // 去除空格
                    .map(Long::parseLong)              // 转换为 Long
                    .collect(Collectors.toList());     // 收集为 List
            sysLogReportDto.setCcUserIds(userIdList);
            if (!userIdList.isEmpty()) {
                List<SysUser> users = sysUserMapper.selectUsersByIds(userIdList);
                String userNames = users.stream()
                        .filter(Objects::nonNull)
                        .map(SysUser::getNickName)
                        .filter(StringUtils::isNotBlank)
                        .collect(Collectors.joining(","));

                // 如果所有用户都没有昵称，设置为空字符串
                sysLogReportDto.setCcUserName(StringUtils.isNotBlank(userNames) ? userNames : "");
            } else {
                sysLogReportDto.setCcUserName("");
            }
        });
        return logReportDtoIPage;
    }

    @Override
    public Boolean add(LogReportDto sysLogReport) {
        if (ObjectUtils.isEmpty(sysLogReport.getCcUserIds())) {
            throw new RuntimeException("请选择抄送人");
        }
        String collect = sysLogReport.getCcUserIds().stream()
                .map(String::valueOf)           // Long → String
                .collect(Collectors.joining(","));// 拼接为 "1,2,3"
        sysLogReport.setCcUsers(collect);
        sysLogReport.setPushStatus(1);
        this.save(sysLogReport);
        if (ObjectUtils.isNotEmpty(sysLogReport.getCcUserIds())) {
            pushLogReport(sysLogReport);
        }
        return true;
    }

    @Override
    public Boolean updateSysLogReportDto(LogReportDto sysLogReport) {
        if (ObjectUtils.isEmpty(sysLogReport.getCcUserIds())) {
            throw new RuntimeException("请选择抄送人");
        }
        String collect = sysLogReport.getCcUserIds().stream()
                .map(String::valueOf)           // Long → String
                .collect(Collectors.joining(","));// 拼接为 "1,2,3"
        sysLogReport.setCcUsers(collect);
        sysLogReport.setPushStatus(1);
        if (ObjectUtils.isNotEmpty(sysLogReport.getCcUserIds())) {
            pushLogReport(sysLogReport);
        }
        return this.updateById(sysLogReport);
    }

    @Override
    public void pushLogReport(LogReportDto sysLogReportDto) {
        LogReport byId = this.getById(sysLogReportDto.getId());
        sysNoticeService.simpleNoticeByUser(byId.getTitle(), byId.getContent(), sysLogReportDto.getCcUserIds(), "/collaborativeApproval/journal");

    }
}