package com.nanjing.water.service.cache;

import com.nanjing.water.common.enums.EYesOrNo;
import com.nanjing.water.common.util.LocalDateTimeUtil;
import com.nanjing.water.common.util.SerializeUtil;
import com.nanjing.water.common.util.StringUtil;
import com.nanjing.water.entity.enums.EMenuType;
import com.nanjing.water.entity.enums.EOperation;
import com.nanjing.water.entity.enums.EState;
import com.nanjing.water.repository.impl.AdminPermissionMapperImpl;
import com.nanjing.water.repository.po.AdminMenuPO;
import com.nanjing.water.repository.po.AdminPermissionPO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.function.Function;

@Service
public class AdminPermissionService {
    @Autowired
    private AdminPermissionMapperImpl dao;

    @Autowired
    private StringRedisTemplate redisTemplate;

    /**
     * 获取所有权限(缓存)
     */
    public List<AdminPermissionPO> listAllWithCache() {
        try {
            if (redisTemplate.hasKey("adminPermissionCache")) {
                String json = redisTemplate.opsForValue().get("adminPermissionCache");
                if (StringUtil.isNotNullOrEmpty(json)) {
                    return SerializeUtil.toListObject(json, AdminPermissionPO.class);
                }
            }
        } catch (Exception e) {
            //
        }
        List<AdminPermissionPO> list = dao.getList();
        redisTemplate.opsForValue().set("adminPermissionCache", SerializeUtil.toJson(list));
        return list;
    }

    // 删除权限缓存
    public void removeListAllCache() {
        redisTemplate.delete("adminPermissionCache");
    }

    /**
     * 获取用户拥有的权限(缓存)
     */
    public List<AdminPermissionPO> listUserAllWithCache(Long id, List<Long> listRoleId, Function<List<Long>, List<AdminPermissionPO>> funcGetUserPermission) {
        try {
            if (redisTemplate.hasKey("userMenusCache")) {
                Object json = redisTemplate.opsForHash().get("userPermissionCache", id);
                if (Objects.nonNull(json)) {
                    return SerializeUtil.toListObject(json.toString(), AdminPermissionPO.class);
                }
            }
        } catch (Exception e) {
            //
        }
        List<AdminPermissionPO> list = funcGetUserPermission.apply(listRoleId);
        redisTemplate.opsForHash().put("userPermissionCache", id, list);
        return list;
    }
    // 删除指定用户拥有的权限缓存
    public void removeUserCache(Long id) {
        redisTemplate.opsForHash().delete("userPermissionCache", id);
    }
    // 删除所有用户拥有的权限缓存
    public void removeAllUserCache() {
        redisTemplate.delete("userPermissionCache");
    }

    /**
     * 给菜单添加默认权限
     * @param menu 菜单信息
     */
    public void createDefaultPermission(AdminMenuPO menu) {
        if (!Objects.equals(menu.getType(), EMenuType.PAGE.getValue())) {
            return;
        }
        Long now = LocalDateTimeUtil.nowTimeStamp();
        List<AdminPermissionPO> list = new ArrayList<>();

        AdminPermissionPO item1 = new AdminPermissionPO();
        item1.setSn(menu.getUrl().replaceAll("/", "") + "." + EOperation.LIST.getValue());
        item1.setMenuId(menu.getId());
        item1.setMenuUrl(menu.getUrl());
        item1.setName(menu.getName() + "." + EOperation.LIST.getDesc());
        item1.setIcon("");
        item1.setType(EOperation.LIST.getValue());
        item1.setStatus(EState.NORMAL.getValue());
        item1.setCreateTime(now);
        item1.setIsDelete(EYesOrNo.NO.getValue());
        list.add(item1);

        AdminPermissionPO item2 = new AdminPermissionPO();
        item2.setSn(menu.getUrl().replaceAll("/", "") + "." + EOperation.ADD.getValue());
        item2.setMenuId(menu.getId());
        item2.setMenuUrl(menu.getUrl());
        item2.setName(menu.getName() + "." + EOperation.ADD.getDesc());
        item2.setIcon("");
        item2.setType(EOperation.ADD.getValue());
        item2.setStatus(EState.NORMAL.getValue());
        item2.setCreateTime(now);
        item2.setIsDelete(EYesOrNo.NO.getValue());
        list.add(item2);

        AdminPermissionPO item3 = new AdminPermissionPO();
        item3.setSn(menu.getUrl().replaceAll("/", "") + "." + EOperation.UPDATE.getValue());
        item3.setMenuId(menu.getId());
        item3.setMenuUrl(menu.getUrl());
        item3.setName(menu.getName() + "." + EOperation.UPDATE.getDesc());
        item3.setIcon("");
        item3.setType(EOperation.UPDATE.getValue());
        item3.setStatus(EState.NORMAL.getValue());
        item3.setCreateTime(now);
        item3.setIsDelete(EYesOrNo.NO.getValue());
        list.add(item3);

        AdminPermissionPO item4 = new AdminPermissionPO();
        item4.setSn(menu.getUrl().replaceAll("/", "") + "." + EOperation.DETAIL.getValue());
        item4.setMenuId(menu.getId());
        item4.setMenuUrl(menu.getUrl());
        item4.setName(menu.getName() + "." + EOperation.DETAIL.getDesc());
        item4.setIcon("");
        item4.setType(EOperation.DETAIL.getValue());
        item4.setStatus(EState.NORMAL.getValue());
        item4.setCreateTime(now);
        item4.setIsDelete(EYesOrNo.NO.getValue());
        list.add(item4);

        dao.insert(list);
    }
}