package com.cloud.attendance.service.impl;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.cloud.attendance.service.TokenService;
import com.cloud.attendance.service.UserService;
import com.cloud.attendance.utils.EnumStr;
import com.cloud.common.utils.RestTemplateUtil;
import com.cloud.model.sys.LoginAppUser;
import com.google.common.collect.Lists;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.stream.Stream;

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private EnumStr enumStr;
    @Autowired
    private TokenService tokenService;

    //    BbEmployee/feign/findEmpById
    @Override
    public Map<String, Object> findEmpById(String personId, Integer orgId) {
// 调用 人员模块
        String userHOSTNAME = enumStr.getUserHOSTNAME();
        int userHTTP_port = enumStr.getUserHTTP_PORT();
        String userQueryPerIdUrl = EnumStr.findEmpByIdUrl;
        String queryUrl = "http://"+userHOSTNAME+":"+userHTTP_port+userQueryPerIdUrl;

        JSONObject dataBaseParams = new JSONObject();
        dataBaseParams.put("id",personId);
        dataBaseParams.put("orgId",orgId);
        String resp = RestTemplateUtil.post(queryUrl,
                dataBaseParams, MediaType.APPLICATION_FORM_URLENCODED, false);
        Map map = JSONObject.parseObject(resp, Map.class);
        if (map != null){
            if ("200".equals(map.get("type"))){  //  学生类型
                map.put("phone",null);         // 手机号 处理为空
            }else if ("100".equals(map.get("type"))){
                map.put("no",null);             //  学号处理为空
            }
        }else {
            map = new HashMap();  //  防止  后面调用数据为空
        }
        return map;
    }
    // /BbEmployee/list
//     "id=选择的部门id/001-总库"  "start-->起始页-->true," "length-->条数--> true"
//    "orgId-->分库orgId--> false, -->String", "groupInformation-->人员姓名 身份证号 学号，手机号，组织机构名称等组合信息",
//             "type-->人员类型-学生 教师 校外", "distributionIds-->集群数组","phone"

    @Override
    public List<String> queryPersonByContent(String contentValue, String gradeValue, String classValue,
                                             String identity, String orgId,Boolean delFlag,List<String> orgIds){
// 调用 人员模块
        String userHOSTNAME = enumStr.getUserHOSTNAME();
        int userHTTP_port = enumStr.getUserHTTP_PORT();
        String userQueryPerIdUrl = EnumStr.queryPersonList;
        String queryUrl = "http://"+userHOSTNAME+":"+userHTTP_port+userQueryPerIdUrl;
        JSONObject dataBaseParams = new JSONObject();
        if (classValue != null){
            dataBaseParams.put("id",classValue);
        }else if (gradeValue != null){
            dataBaseParams.put("id",gradeValue);
        }else {
            LoginAppUser appUser = tokenService.currentUser();
            Long orgId1 = appUser.getOrgId();
            Integer officeId = appUser.getOfficeId();
            dataBaseParams.put("id",officeId);
            if (StringUtils.isBlank(orgId)){
                orgId = orgId1.toString();
            }
        }

        if (orgIds != null && orgIds .size() > 0){
            dataBaseParams.put("orgIds",orgIds);
        }
        dataBaseParams.put("start",0);
        dataBaseParams.put("length",5000);
        dataBaseParams.put("orgId",orgId);
        dataBaseParams.put("delFlag",delFlag);
        dataBaseParams.put("groupInformation",contentValue);
        dataBaseParams.put("type",identity);
        String resp = RestTemplateUtil.post(queryUrl,
                dataBaseParams, MediaType.APPLICATION_JSON_UTF8, false);
        JSONObject map = JSONObject.parseObject(resp);
        Integer total = map.getInteger("total");
        if (total > 5000){
             // 接着查询
        }
        if (map == null){
            map = new JSONObject();  //  防止  后面调用数据为空
        }
        JSONArray data = map.getJSONArray("data");
//        data.parallelStream().map
        List<String> usrIds = Lists.transform(data, jsonObj->((JSONObject)jsonObj).getString("id"));
        return usrIds;
    }

    @Override
    public List queryPersonByContentForAll(String contentValue, String gradeValue,
                                                String classValue, String identity, String orgId){
// 调用 人员模块
        String userHOSTNAME = enumStr.getUserHOSTNAME();
        int userHTTP_port = enumStr.getUserHTTP_PORT();
        String userQueryPerIdUrl = EnumStr.queryPersonList;
        String queryUrl = "http://"+userHOSTNAME+":"+userHTTP_port+userQueryPerIdUrl;
        JSONObject dataBaseParams = new JSONObject();
        if (classValue != null){
            dataBaseParams.put("id",classValue);
        }else if (gradeValue != null){
            dataBaseParams.put("id",gradeValue);
        }else {
            LoginAppUser appUser = tokenService.currentUser();
            Long orgId1 = appUser.getOrgId();
            Integer officeId = appUser.getOfficeId();
            dataBaseParams.put("id",officeId);
            if (StringUtils.isBlank(orgId)){
                orgId = orgId1.toString();
            }
        }
        dataBaseParams.put("start",0);
        dataBaseParams.put("length",5000);
        dataBaseParams.put("orgId",orgId);
        dataBaseParams.put("groupInformation",contentValue);
        dataBaseParams.put("type",identity);
        String resp = RestTemplateUtil.post(queryUrl,
                dataBaseParams, MediaType.APPLICATION_JSON_UTF8, false);
        JSONObject map = JSONObject.parseObject(resp);
        Integer total = map.getInteger("total");
        if (total > 5000){
            // 接着查询
        }
        if (map == null){
            map = new JSONObject();  //  防止  后面调用数据为空
        }
        JSONArray data = map.getJSONArray("data");
        return data;
    }

    // /BbEmployee/queryPersonSimpleInfoById
    @Override
    public Map<String, Object> getPersonInfoById(String perId) {
// 调用 人员模块
        String userHOSTNAME = enumStr.getUserHOSTNAME();
        int userHTTP_port = enumStr.getUserHTTP_PORT();
        String userQueryPerIdUrl = EnumStr.queryPersonSimpleInfoById;
        String queryUrl = "http://"+userHOSTNAME+":"+userHTTP_port+userQueryPerIdUrl;
        JSONObject dataBaseParams = new JSONObject();
        dataBaseParams.put("personId",perId);
        dataBaseParams.put("delFlag",true);
        String resp = RestTemplateUtil.post(queryUrl,
                dataBaseParams, MediaType.APPLICATION_FORM_URLENCODED, false);
        Map map = JSONObject.parseObject(resp, Map.class);
        if (map != null){
            if ("200".equals(map.get("type"))){  //  学生类型
                map.put("phone",null);         // 手机号 处理为空
            }else if ("100".equals(map.get("type"))){
                map.put("no",null);             //  学号处理为空
            }
        }else {
            map = new HashMap();  //  防止  后面调用数据为空
        }
        return map;
    }


    @Override
    public Map<String, JSONObject> queryAllPersonId() {
        // 调用 人员模块
        String userHOSTNAME = enumStr.getUserHOSTNAME();
        int userHTTP_port = enumStr.getUserHTTP_PORT();
        String userQueryPerIdUrl = EnumStr.queryPersonList;
        String queryUrl = "http://"+userHOSTNAME+":"+userHTTP_port+userQueryPerIdUrl;
        JSONObject dataBaseParams = new JSONObject();
        dataBaseParams.put("id","001");
        dataBaseParams.put("start",0);
        dataBaseParams.put("length",5000);
        dataBaseParams.put("orgId",null);
        dataBaseParams.put("groupInformation",null);
        dataBaseParams.put("type",null);
        dataBaseParams.put("delFlag",true);   //  是否查询全部
        String resp = RestTemplateUtil.post(queryUrl,
                dataBaseParams, MediaType.APPLICATION_JSON_UTF8, false);
        JSONObject map = JSONObject.parseObject(resp);
        Integer total = map.getInteger("total");
        if (total > 5000){
            // 接着查询
        }
        if (map == null){
            map = new JSONObject();  //  防止  后面调用数据为空
        }
        JSONArray data = map.getJSONArray("data");
//        data.parallelStream().map
//        List<String> usrIds = Lists.transform(data, jsonObj->((JSONObject)jsonObj).getString("id"));
        Map<String, JSONObject> maps = data.stream().collect(Collectors.toMap(user->((JSONObject)user).getString("id"), user -> (JSONObject) user));
        return maps;
    }

    public JSONArray queryAllPersonList() {
        // 调用 人员模块
        String userHOSTNAME = enumStr.getUserHOSTNAME();
        int userHTTP_port = enumStr.getUserHTTP_PORT();
        String userQueryPerIdUrl = EnumStr.queryPersonList;
        String queryUrl = "http://"+userHOSTNAME+":"+userHTTP_port+userQueryPerIdUrl;
        JSONObject dataBaseParams = new JSONObject();
        dataBaseParams.put("id","001");
        dataBaseParams.put("start",0);
        dataBaseParams.put("length",5000);
        dataBaseParams.put("orgId",null);
        dataBaseParams.put("groupInformation",null);
        dataBaseParams.put("type",null);
        String resp = RestTemplateUtil.post(queryUrl,
                dataBaseParams, MediaType.APPLICATION_JSON_UTF8, false);
        JSONObject map = JSONObject.parseObject(resp);
        Integer total = map.getInteger("total");
        if (total > 5000){
            // 接着查询
        }
        if (map == null){
            map = new JSONObject();  //  防止  后面调用数据为空
        }
        JSONArray data = map.getJSONArray("data");
        return data;
    }

    @Override
    public Map<String, String> queryPersonType() {
        String userHOSTNAME = enumStr.getUserHOSTNAME();
        int userHTTP_port = enumStr.getUserHTTP_PORT();
        String userQueryPerIdUrl = EnumStr.queryPersonList;
        String queryUrl = "http://"+enumStr.getUserHOSTNAME()+":"+enumStr.getUserHTTP_PORT()
                +"/data/api-u/dict/getSysDictByType";  // ?orgId=1&type=PEO_TYPE&module=SYSTEM
// loginData/api-u/dict/getSysDictByType?orgId=1&type=PEO_TYPE&module=SYSTEM
        JSONObject params = new JSONObject();
        params.put("orgId","1");
        params.put("type","PEO_TYPE");
        params.put("module","SYSTEM");
        String s = RestTemplateUtil.get(queryUrl, params, true);
        JSONObject resp = JSONObject.parseObject(s);
        Map<String, String> personType = new HashMap<>();
        if ("0".equals(resp.getString("code"))){
            JSONArray data = resp.getJSONArray("data");
            if (data!=null &&data.size()>0){
                personType = data.parallelStream().collect(Collectors.toMap(
                        perType -> ((JSONObject) perType).getString("value"),
                        perType -> ((JSONObject) perType).getString("lable")));
            }
        }else {
            throw new RuntimeException(resp.getString("message"));
        }
        return personType;
    }
}