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.framework.web.service.TokenService;
import com.ruoyi.system.model.OaNotification;
import com.ruoyi.system.model.OaNotificationUser;
import com.ruoyi.system.query.NotificationListQuery;
import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.system.service.OaNotifationUserService;
import com.ruoyi.system.service.OaNotificationService;
import com.ruoyi.system.service.TDeptService;
import com.ruoyi.system.vo.system.NotificationDeptUserDetailVO;
import com.ruoyi.system.vo.system.NotificationDetailVO;
import com.ruoyi.system.vo.system.NotificationUserDetailVO;
import com.ruoyi.system.vo.system.NotificationVO;
import io.swagger.annotations.ApiOperation;
import jdk.nashorn.internal.parser.Token;
import org.springframework.beans.BeanUtils;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
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
@RequestMapping("/oa-notifation-user")
public class OaNotifationUserController {
    @Resource
    private OaNotificationService oaNotificationService;
    @Resource
    private OaNotifationUserService oaNotifationUserService;
    @Resource
    private TDeptService deptService;
    @Resource
    private ISysUserService sysUserService;
    @Resource
    private TokenService tokenService;

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


    @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<OaNotificationUser> notifationUsers = oaNotifationUserService.lambdaQuery().eq(OaNotificationUser::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(",");
//            }
//            if (deptName.length() > 0){
//                notificationDetailVO.setDeptName(deptName.substring(0,deptName.length()-1));
//            }else {
//                notificationDetailVO.setDeptName("");
//            }
//            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 (OaNotificationUser 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(notificationDetailVO);
    }
}