package com.gkhy.safePlatform.account.rpc.test;
import com.gkhy.safePlatform.account.model.dto.resp.DepRespDTO;
import com.gkhy.safePlatform.account.service.DepartmentService;
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
import com.gkhy.safePlatform.commons.exception.AusinessException;
import com.gkhy.safePlatform.commons.exception.BusinessException;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.MenuMetaRPCRespDTO;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.ProjectRPCRespDTO;


import com.gkhy.safePlatform.account.model.dto.req.LoginReqDTO;
import com.gkhy.safePlatform.account.model.dto.resp.MenuRespDTO;
import com.gkhy.safePlatform.account.model.dto.resp.UserLoginRespDTO;
import com.gkhy.safePlatform.account.entity.user.PermissionInfo;
import com.gkhy.safePlatform.account.entity.user.RoleInfo;
import com.gkhy.safePlatform.account.entity.user.UserInfo;
import com.gkhy.safePlatform.account.rpc.apimodel.AccountAuthService;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.*;
import com.gkhy.safePlatform.account.service.AuthService;
import com.gkhy.safePlatform.commons.enums.ResultCodes;
import com.gkhy.safePlatform.commons.vo.ResultVO;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;

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

@DubboService
public class AccountAuthServiceProvider implements AccountAuthService {

    @Autowired
    private AuthService authService;
    @Autowired
    private DepartmentService departmentService;

    @Override
    public String sayName(String id) {
        return "rpc call "+id+" test";
    }



    @Override
    public  ResultVO<List<String>> getUserPermissionByUserId (Long userId) {
        try {
            List<String> codes = new ArrayList<>();
            List<PermissionInfo> permissionInfos = authService.getUserPermissionByUserId(userId);
            if (permissionInfos.size() > 0) {
                codes = permissionInfos.stream().map(PermissionInfo::getCode).collect(Collectors.toList());
            }
            return new ResultVO<>(ResultCodes.OK, codes);
        } catch (AusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (BusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            ResultVO resultVO = new ResultVO<>();
            resultVO.setCode(ResultCodes.SERVER_ERROR);
            return resultVO;
        }
    }


    @Override
    public ResultVO<String> getUserRoleCodeByUserId(Long userId) {
        try {
            RoleInfo roleInfo = authService.getUserRoleByUserId(userId);
            return new ResultVO<>(ResultCodes.OK, roleInfo.getCode());
        } catch (AusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (BusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            ResultVO resultVO = new ResultVO<>();
            resultVO.setCode(ResultCodes.SERVER_ERROR);
            return resultVO;
        }
    }


    @Override
    public ResultVO<UserRPCRespDTO> getUserById(Long userId) {
        try {
            // 用户
            UserInfo userInfo = authService.getUserByUserId(userId);
            UserRPCRespDTO userReqDTO = new UserRPCRespDTO();
            BeanUtils.copyProperties(userInfo, userReqDTO);
            // 用户部门
            if (userInfo.getDepId() != null) {
                DepRespDTO dep = departmentService.getEnableDepartmentInfoByDepId(userId, userInfo.getDepId());
                if (dep != null) {
                    UserDepRPCRespDTO userDepRPCRespDTO = new UserDepRPCRespDTO();
                    BeanUtils.copyProperties(dep, userDepRPCRespDTO);
                    userReqDTO.setDepartment(userDepRPCRespDTO);
                }
            }
            userReqDTO.setEnterprise(new UserEnterpriseRPCRespDTO());
            return new ResultVO<>(ResultCodes.OK, userReqDTO);
        } catch (AusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (BusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            ResultVO resultVO = new ResultVO<>();
            resultVO.setCode(ResultCodes.SERVER_ERROR);
            return resultVO;
        }


    }

    @Override
    public ResultVO<UserLoginRPCRespDTO> authLogin(String username, String password) {
        ResultVO<UserLoginRPCRespDTO> result = new ResultVO<>(ResultCodes.OK);
        LoginReqDTO loginReqDTO = new LoginReqDTO();
        loginReqDTO.setUsername(username);
        loginReqDTO.setPassword(password);

        try {
            UserLoginRespDTO userOnlineRespDTO = authService.authLogin(loginReqDTO);
            UserLoginRPCRespDTO userLoginRespDTO = new UserLoginRPCRespDTO();
            BeanUtils.copyProperties(userOnlineRespDTO,userLoginRespDTO);
            result.setData(userLoginRespDTO);
        } catch (AusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (BusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (Exception e) {
            result.setCode(ResultCodes.SERVER_ERROR);
        }

        return result;
    }

    @Override
    public ResultVO<List<MenuRPCRespDTO>> getMenu(ContextCacheUser currentUser, Long projectId) {
        ResultVO<List<MenuRPCRespDTO>> result = new ResultVO<>(ResultCodes.OK);
        try {
            List<MenuRespDTO> sources = authService.getUserMenuTreeByUserIdAndProjectId(currentUser, projectId);
            // 重新赋值一遍
            result.setData(this.convertTORPCModel(sources));
        } catch (AusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (BusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (Exception e) {
            result.setCode(ResultCodes.SERVER_ERROR.getCode());
            result.setMsg(ResultCodes.SERVER_ERROR.getDesc());
        }

        return result;
    }







    private List<MenuRPCRespDTO> convertTORPCModel(List<MenuRespDTO> sources) {
        List<MenuRPCRespDTO> targets = new ArrayList<>();
        for (MenuRespDTO source : sources) {
            MenuRPCRespDTO target = new MenuRPCRespDTO();
            target.setId(source.getId());
            target.setName(source.getName());
            target.setPath(source.getPath());
            target.setPriority(source.getPriority());
            target.setDescription(source.getDescription());
            target.setParentId(source.getParentId());
            target.setRedirect(source.getRedirect());
            target.setComponent(source.getComponent());
            target.setStatus(source.getStatus());
            target.setChildren(new ArrayList<>());
            target.setPublic(source.getPublic());
            target.setMenuSuperior(source.getMenuSuperior());


        // meta
        MenuMetaRPCRespDTO meta;
        if (source.getMeta() != null) {
            meta = new MenuMetaRPCRespDTO();
            meta.setIsAffix(source.getMeta().getIsAffix());
            meta.setIsHide(source.getMeta().getIsHide());
            meta.setIcon(source.getMeta().getIcon());
            meta.setIsIframe(source.getMeta().getIsIframe());
            meta.setIsKeepAlive(source.getMeta().getIsKeepAlive());
            meta.setIsLink(source.getMeta().getIsLink());
            meta.setRoles(source.getMeta().getRoles());
            meta.setTitle(source.getMeta().getTitle());
            target.setMeta(meta);
        }

        // project
        if (source.getProject() != null) {
            ProjectRPCRespDTO project = new ProjectRPCRespDTO();
            project.setProjectCode(source.getProject().getProjectCode());
            project.setProjectId(source.getProject().getProjectId());
            project.setProjectName(source.getProject().getProjectName());
            project.setStatus(source.getProject().getStatus());
            target.setProject(project);
            target.setProjectId(source.getProject().getProjectId());
        }


        if (source.getChildren() != null && source.getChildren().size() > 0) {
            List<MenuRPCRespDTO> children = this.convertTORPCModel(source.getChildren());
            target.setChildren(children);
        }


            targets.add(target);
        }
        return targets;
    }

}