package com.gkhy.exam.institutionalaccess.service.serviceImpl;

import com.alibaba.fastjson2.JSONArray;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gkhy.exam.institutionalaccess.entity.ThSubjectType;
import com.gkhy.exam.institutionalaccess.mapper.ThSubjectTypeMapper;
import com.gkhy.exam.institutionalaccess.model.vo.ThSubjectTypeVO;
import com.gkhy.exam.institutionalaccess.service.ThSubjectTypeService;
import com.ruoyi.common.constant.CacheConstants;
import com.ruoyi.common.core.domain.entity.SysDictData;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.spring.SpringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

/**
 * @author zf
 * @email 1603559716@qq.com
 * @date 2024/8/6 15:09
 * @description ThSubjectTypeServiceImpl
 */
@Service("ThSubjectTypeService")
public class ThSubjectTypeServiceImpl extends ServiceImpl<ThSubjectTypeMapper, ThSubjectType> implements ThSubjectTypeService {
    @Autowired
    private RedisCache redisCache;
    @Override
    public void subjectTypeCache() {
        List<ThSubjectType> thSubjectTypes = baseMapper.selectList(new LambdaQueryWrapper<>());
        redisCache.setCacheObject(CacheConstants.THREE_SUBJECT_TYPE, thSubjectTypes);
    }

    @Override
    public List<ThSubjectType> getSubjectTypeList() {
        JSONArray arrayCache = SpringUtils.getBean(RedisCache.class).getCacheObject(CacheConstants.THREE_SUBJECT_TYPE);
        if (StringUtils.isNotNull(arrayCache))
        {
            return arrayCache.toList(ThSubjectType.class);
        }else {
            return baseMapper.selectList(new LambdaQueryWrapper<>());

        }

    }

    @Override
    public List<ThSubjectTypeVO> getTree() {
        List<ThSubjectType> subjectTypeList = getSubjectTypeList();
        List<ThSubjectTypeVO> children = getChildren(subjectTypeList, "0");

        return children;
    }
    private List<ThSubjectTypeVO> getChildren(List<ThSubjectType> thSubjectTypes, String parentCode){

        List<ThSubjectTypeVO> thSubjectTypeVOList = new ArrayList<>();
        List<ThSubjectType> selectList =  thSubjectTypes
                .stream()
                .filter(thSubjectType -> thSubjectType.getParentCode().equals(parentCode))
                .collect(Collectors.toList());
        for (ThSubjectType thSubjectType : selectList) {
            ThSubjectTypeVO thSubjectTypeVO = new ThSubjectTypeVO();
            thSubjectTypeVO.setId(thSubjectType.getId());
            thSubjectTypeVO.setName(thSubjectType.getName());
            thSubjectTypeVO.setCode(thSubjectType.getCode());
            thSubjectTypeVO.setParentCode(thSubjectType.getParentCode());
            //获取孩子节点
            thSubjectTypeVO.setChildren(getChildren(thSubjectTypes, thSubjectType.getCode()));
            thSubjectTypeVOList.add(thSubjectTypeVO);
        }
        return thSubjectTypeVOList;
    }



}