package com.ruoyi.web.controller.api;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.basic.PageInfo;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.core.domain.entity.TDept;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.system.dto.SetDeptDTO;
import com.ruoyi.system.model.OaApproval;
import com.ruoyi.system.model.OaNotifationUser;
import com.ruoyi.system.model.OaNotification;
import com.ruoyi.system.query.ApprovalListQuery;
import com.ruoyi.system.query.NotificationListQuery;
import com.ruoyi.system.service.*;
import com.ruoyi.system.vo.system.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.BeanUtils;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.sql.Array;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * <p>
 * 通知表 前端控制器
 * </p>
 *
 * @author WuGuanFengYue
 * @since 2025-09-15
 */
@RestController
@Api("消息通知")
@RequestMapping("/oa-notification")
public class OaNotificationController {
    @Resource
    private OaNotificationService oaNotificationService;
    @Resource
    private OaNotifationUserService oaNotifationUserService;
    @Resource
    private TDeptService deptService;
    @Resource
    private ISysUserService sysUserService;

    /**
     * 获取部门树列表
     */
    @ApiOperation("消息通知分页列表")
    @PostMapping("/pageList")
    public R<PageInfo<NotificationVO>> pageList(@RequestBody NotificationListQuery query) {
        return R.ok(oaNotificationService.pageList(query));
    }

    @ApiOperation(value = "删除消息通知")
    @Log(title = "删除消息通知", businessType = BusinessType.DELETE)

    @DeleteMapping(value = "/delete")
    public R delete(@RequestParam String ids) {
        List<String> notificationIds = Arrays.asList(ids.split(","));
        // 删除后 将已发送的消息通知一并删除
        oaNotificationService.removeBatchByIds(notificationIds);
        oaNotifationUserService.remove(new LambdaQueryWrapper<OaNotifationUser>()
                .in(OaNotifationUser::getNotificationId,notificationIds));
        return R.ok();
    }
    @Log(title = "消息通知-新增消息", businessType = BusinessType.INSERT)
    @ApiOperation(value = "新增消息")
    @PostMapping(value = "/add")
    public R<Boolean> add( @RequestBody OaNotification dto) {
        oaNotificationService.save(dto);
        ArrayList<OaNotifationUser> oaNotifationUsers = new ArrayList<>();
        // 发送消息通知
        if (dto.getType()){
            // 指定人员发送
            Arrays.asList(dto.getUserIds().split(","))
                    .forEach(userId -> {
                        OaNotifationUser oaNotifationUser = new OaNotifationUser();
                        oaNotifationUser.setUserId(Integer.parseInt(userId));
                        oaNotifationUser.setNotificationId(dto.getId());
                        oaNotifationUsers.add(oaNotifationUser);
                    });
        }else{
            // 所有人发送
            List<SysUser> sysUsers = sysUserService.selectAllList();
            sysUsers.forEach(sysUser -> {
                OaNotifationUser oaNotifationUser = new OaNotifationUser();
                oaNotifationUser.setUserId(sysUser.getUserId().intValue());
                oaNotifationUser.setNotificationId(dto.getId());
                oaNotifationUsers.add(oaNotifationUser);
            });
        }
        oaNotifationUserService.saveBatch(oaNotifationUsers);
        return R.ok();
    }
    @ApiOperation(value = "消息通知详情")
    @GetMapping(value = "/detail")
    public R<NotificationDetailVO> detail(String id) {
        NotificationDetailVO notificationDetailVO = new NotificationDetailVO();
        OaNotification oaNotification = oaNotificationService.getById(id);
        BeanUtils.copyProperties(oaNotification, notificationDetailVO);
        StringBuilder deptName = new StringBuilder();
        List<TDept> tDepts = deptService.list();
        List<SysUser> sysUsers = sysUserService.selectAllList();
        List<OaNotifationUser> notifationUsers = oaNotifationUserService.lambdaQuery().eq(OaNotifationUser::getNotificationId, id)
                .list();
        Map<Integer, String> deptMap = tDepts.stream().collect(Collectors.toMap(TDept::getId, TDept::getDeptName));
        Map<Long, SysUser> userMap = sysUsers.stream().collect(Collectors.toMap(SysUser::getUserId, e->e));
        if (oaNotification.getType()){
            for (String deptId : oaNotification.getDeptIds().split(",")) {
                String orDefault = deptMap.getOrDefault(Integer.parseInt(deptId), "");
                deptName.append(orDefault).append(",");
            }
            notificationDetailVO.setDeptName(deptName.substring(0,deptName.length()-1));
            List<NotificationDeptUserDetailVO> notificationUserVOS = new ArrayList<>();
            List<Long> userIds = notifationUsers.stream().map(e -> e.getUserId().longValue()).collect(Collectors.toList());
            if (!userIds.isEmpty()){
                Map<String, List<SysUser>> deptUserList = sysUsers.stream().filter(e -> userIds.contains(e.getUserId()))
                        .collect(Collectors.groupingBy(SysUser::getDeptId));
                // 遍历这个map
                for (Map.Entry<String, List<SysUser>> entry : deptUserList.entrySet()) {
                    List<SysUser> users = entry.getValue();
                    String deptId = entry.getKey();
                    NotificationDeptUserDetailVO notificationDeptUserDetailVO = new NotificationDeptUserDetailVO();
                    notificationDeptUserDetailVO.setDeptName(deptMap.getOrDefault(Integer.parseInt(deptId), ""));
                    notificationDeptUserDetailVO.setUsers(users);
                    // 查询部门下的员工数是否和users一致
                    long count = sysUsers.stream().filter(e -> e.getDeptId().equals(deptId)).count();
                    if (count==users.size()){
                        notificationDeptUserDetailVO.setIsAll(true);
                    }else{
                        notificationDeptUserDetailVO.setIsAll(false);
                    }
                    notificationUserVOS.add(notificationDeptUserDetailVO);
                }
            }
            notificationDetailVO.setNotificationDeptUserDetailVOList(notificationUserVOS);

        }else{

            notificationDetailVO.setDeptName("全部人员");
        }
        List<NotificationUserDetailVO> notificationUserDetailVOS = new ArrayList<>();

        for (OaNotifationUser notifationUser : notifationUsers) {
            NotificationUserDetailVO notificationUserDetailVO = new NotificationUserDetailVO();
            BeanUtils.copyProperties(notifationUser, notificationUserDetailVO);
            SysUser sysUser = userMap.get(notifationUser.getUserId().longValue());
            if (sysUser==null){
                continue;
            }
            notificationUserDetailVO.setDeptName(deptMap.getOrDefault(Integer.parseInt(sysUser.getDeptId()), ""));
            notificationUserDetailVO.setNickName(sysUser.getNickName());
            notificationUserDetailVO.setPhonenumber(sysUser.getPhonenumber());
            notificationUserDetailVO.setPosition(sysUser.getPosition());
            notificationUserDetailVOS.add(notificationUserDetailVO);
        }

        notificationDetailVO.setNotificationUserDetailVOS(notificationUserDetailVOS);
        return R.ok();
    }
}