package com.highdatas.mdm.util;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.highdatas.mdm.entity.TRole;
import com.highdatas.mdm.entity.TUser;
import com.highdatas.mdm.entity.TUserGroup;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import java.util.*;

@ConfigurationProperties(prefix = "user")
@Component
@Slf4j
public class UserRoleClient {

    @Value("${user.url}")
    String url;

    String prefix ;
    @Autowired
    RedisClient redisClient;

    public UserRoleClient() {
        this.prefix = "/api/datacvg/";
    }

    public TUser getTUserById(String userId) {
        Object redisValObj = redisClient.getRedisValObj(RedisClient.getRealRedisKey(userId));
        if (redisValObj != null) {
            JSONObject object = (JSONObject) redisValObj;
            TUser user = JSONObject.parseObject(object.toJSONString(), TUser.class);
            return user;
        }
        String url = this.url + prefix + "user/selectUser";
        Map<String, String> params = new LinkedHashMap<>();
        params.put("userId",userId);
        String s = HttpUtils.HttpRestClient(url, HttpMethod.POST, params, MediaType.APPLICATION_JSON);
        log.info(s);
        JSONObject result = (JSONObject) JSON.parse(s);
        String sucess = result.getString(Constant.Success);
        if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
            return null;
        }else {
            JSONObject data = result.getJSONObject(Constant.Data);
            data = data.getJSONObject(Constant.userDO);
            TUser user = JSON.toJavaObject(data, TUser.class);
            if (user == null){
                return null;
            }
            redisClient.putRedisValObj(RedisClient.getRealRedisKey(userId), user);
            return user;
        }
    }

    public TRole getRoleByRoleId(String roleId) {
        Object redisValObj = redisClient.getRedisValObj(RedisClient.getRealRedisKey(roleId));
        if (redisValObj != null) {
            JSONObject object = (JSONObject) redisValObj;
            TRole user = JSONObject.parseObject(object.toJSONString(), TRole.class);
            return user;
        }
        try {
            String url =  this.url + prefix + "role/selectRole";
            Map<String, String> params = new LinkedHashMap<>();
            params.put("roleId", roleId);
            String s = HttpUtils.HttpRestClient(url, HttpMethod.POST, params, MediaType.APPLICATION_JSON);
            JSONObject result = (JSONObject) JSON.parse(s);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return null;
            }else {
                JSONObject data = result.getJSONObject(Constant.Data);
                TRole role = JSON.toJavaObject(data, TRole.class);
                if (role == null){
                    return null;
                }
                redisClient.putRedisValObj(RedisClient.getRealRedisKey(roleId), role);
                return role;
            }
        }catch (Exception e){
            e.printStackTrace();
            return null;
        }

    }

    public  List<TUserGroup> getUserGroupByUserId(String userId) {

        String key = RedisClient.getRealRedisKey(userId + "-getUserGroupByUserId");
        List<Object> redisList = redisClient.getRedisList(key);
        if (redisList != null && !redisList.isEmpty()) {
            List<TUserGroup> result = new ArrayList<>();
            for (Object o : redisList) {
                JSONObject object = (JSONObject) o;
                TUserGroup menu = JSONObject.parseObject(object.toJSONString(), TUserGroup.class);
                result.add(menu);
            }
            return result;
        }

        String url =  this.url + prefix + "group/userGroupInfo";
        Map<String, Object> params = new LinkedHashMap<>();
        params.put("userId",userId);
        String urlParamsByMap = HttpUtils.getUrlParamsByMap(params);
        String s = HttpUtils.HttpRestClient(url, HttpMethod.POST, null,urlParamsByMap, MediaType.APPLICATION_JSON);
        JSONObject result = (JSONObject) JSON.parse(s);
        String sucess = result.getString(Constant.Success);
        if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
            return null;
        }else {
            JSONArray groupArray = result.getJSONArray(Constant.Data);
            List<TUserGroup> tUserGroups = JSONArray.parseArray(groupArray.toJSONString(), TUserGroup.class);
            if (tUserGroups == null || tUserGroups.isEmpty()) {
                return null;
            }
            redisClient.putRedisList(key, (tUserGroups));
            return tUserGroups;
        }
    }

    public  List<TRole> getTRoleListByUserId(String userId) {

        String key = RedisClient.getRealRedisKey(userId + "-getTRoleListByUserId");
        List<Object> redisList = redisClient.getRedisList(key);
        if (redisList != null && !redisList.isEmpty()) {
            List<TRole> result = new ArrayList<>();
            for (Object o : redisList) {
                JSONObject object = (JSONObject) o;
                TRole menu = JSONObject.parseObject(object.toJSONString(), TRole.class);
                result.add(menu);
            }
            return result;
        }
        String url =  this.url + prefix + "userRole/selectUserRoleList";
        Map<String, String> params = new LinkedHashMap<>();
        params.put("userId",userId);
        String s = HttpUtils.HttpRestClient(url, HttpMethod.POST, params, MediaType.APPLICATION_JSON);
        JSONObject result = (JSONObject) JSON.parse(s);
        String sucess = result.getString(Constant.Success);
        if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
            return null;
        }else {
            JSONArray groupArray = result.getJSONArray(Constant.Data);
            List<TRole> tRoles = JSONArray.parseArray(groupArray.toJSONString(), TRole.class);
            if (tRoles == null || tRoles.isEmpty()) {
                return null;
            }
            redisClient.putRedisList(key, tRoles);
            return tRoles;
        }
    }

    public List<TRole> getRoleListByGroupId(String groupId) {
        String key = RedisClient.getRealRedisKey(groupId + "-getTRoleListByUserId");
        List<Object> redisList = redisClient.getRedisList(key);
        if (redisList != null && !redisList.isEmpty()) {
            List<TRole> result = new ArrayList<>();
            for (Object o : redisList) {
                JSONObject object = (JSONObject) o;
                TRole menu = JSONObject.parseObject(object.toJSONString(), TRole.class);
                result.add(menu);
            }
            return result;
        }
        try {
            String url =  this.url + prefix + "group/groupRoleInfo";
            Map<String, Object> params = new LinkedHashMap<>();
            params.put("groupId", groupId);
            String urlParamsByMap = HttpUtils.getUrlParamsByMap(params);
            String s = HttpUtils.HttpRestClient(url, HttpMethod.POST, null,urlParamsByMap, MediaType.APPLICATION_JSON);
            JSONObject result = (JSONObject) JSON.parse(s);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return null;
            }else {
                JSONArray data = result.getJSONArray(Constant.Data);
                List<TRole> role = JSONArray.parseArray(data.toJSONString(), TRole.class);
                if (role == null || role.isEmpty()){
                    return null;
                }
                redisClient.putRedisList(key, role);
                return role;
            }
        }catch (Exception e){
            e.printStackTrace();
            return null;
        }

    }

    public boolean addRoleByUser(String userId, List<String> roleIds, String userName) {
        try {
            String url =  this.url + prefix + "userRole/addRoleUser";
            Map<String, Object> params = new LinkedHashMap<>();
            params.put("userId", userId);
            params.put("listRoleId", roleIds);
            params.put("createUser", userId);
            String s = HttpUtils.HttpRestClientByObjectParams(url, HttpMethod.POST, params, null, null,MediaType.APPLICATION_JSON);
            JSONObject result = (JSONObject) JSON.parse(s);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return false;
            }else {
                boolean added = result.getBoolean(Constant.Data);
                return added;
            }
        }catch (Exception e){
            e.printStackTrace();
            return false;
        }
    }

    public boolean deleteRoleByUser(String userId, List<String> roleIds) {
        try {
            String url =  this.url + prefix + "userRole/deleteRoleUsers";
            Map<String, Object> params = new LinkedHashMap<>();
            params.put("userId", userId);
            params.put("listRoleId", roleIds);
            String s = HttpUtils.HttpRestClientByObjectParams(url, HttpMethod.POST, params, null, null,MediaType.APPLICATION_JSON);
            JSONObject result = (JSONObject) JSON.parse(s);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return false;
            }else {
                boolean added = result.getBoolean(Constant.Data);
                return added;
            }
        }catch (Exception e){
            e.printStackTrace();
            return false;
        }

    }

    public boolean addRoleByGroupId(String userId, List<String> roleIds, String groupId) {
        try {
            String url =  this.url + prefix + "group/addGroupRole";
            HashMap<String, String> headerMap = new HashMap<>();
            headerMap.put("userId", userId);

            Map<String, Object> params = new LinkedHashMap<>();
            params.put("groupId", groupId);
            params.put("roleIdList", roleIds);
            String s = HttpUtils.HttpRestClientByObjectParams(url, HttpMethod.POST, params, null,headerMap,MediaType.APPLICATION_JSON);
            JSONObject result = (JSONObject) JSON.parse(s);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return false;
            }
            return true;
        }catch (Exception e){
            e.printStackTrace();
            return false;
        }
    }

    public List<TUser> listUserRoleGroup() {
        try {
            String url =  this.url + prefix + "user/listUserRoleGroup";
            String s = HttpUtils.HttpRestClientByObjectParams(url, HttpMethod.POST, null, null,null,MediaType.APPLICATION_JSON);
            JSONObject result = (JSONObject) JSON.parse(s);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return null;
            }
            JSONArray jsonArray = result.getJSONArray(Constant.Data);
            List<TUser> tUsers = JSONObject.parseArray(jsonArray.toJSONString(), TUser.class);
            return tUsers;
        }catch (Exception e){
            e.printStackTrace();
            return null;
        }
    }


    public boolean deleteRoleByGroupId(List<String> roleIds, String groupId) {
        try {
            String url =  this.url + prefix + "group/delGroupRole";
            Map<String, Object> params = new LinkedHashMap<>();
            params.put("groupId", groupId);
            params.put("roleIdList", roleIds);
            String s = HttpUtils.HttpRestClientByObjectParams(url, HttpMethod.POST, params, null,null,MediaType.APPLICATION_JSON);
            JSONObject result = (JSONObject) JSON.parse(s);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return false;
            }
            return true;
        }catch (Exception e){
            e.printStackTrace();
            return false;
        }
    }

    public List<String> getUserListByRole(String roleId) {
        String key = RedisClient.getRealRedisKey(roleId + "-getUserListByRole");
        List<Object> redisList = redisClient.getRedisList(key);
        if (redisList != null && !redisList.isEmpty()) {
            List<String> result = new ArrayList<>();
            for (Object o : redisList) {
                result.add(o.toString());
            }
            return result;
        }
        try {
            String url =  this.url + prefix + "userRole/selectUserMap";
            Map<String, Object> params = new LinkedHashMap<>();
            params.put("roleId", roleId);
            String s = HttpUtils.HttpRestClientByObjectParams(url, HttpMethod.POST, params, null,null,MediaType.APPLICATION_JSON);
            JSONObject result = (JSONObject) JSON.parse(s);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return null;
            }
            List<String> array = result.getObject(Constant.Data, List.class);

            redisClient.putRedisList(key,array);
            return array;
        }catch (Exception e){
            e.printStackTrace();
            return null;
        }
    }
}