package com.qianwen.smartman.modules.sync.service.impl;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;

import org.jetbrains.annotations.NotNull;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.DefaultTransactionDefinition;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.aliyun.dingtalkcontact_1_0.models.GetUserHeaders;
import com.aliyun.dingtalkcontact_1_0.models.GetUserResponseBody;
import com.aliyun.dingtalkoauth2_1_0.Client;
import com.aliyun.teaopenapi.models.Config;
import com.aliyun.teautil.models.RuntimeOptions;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.dingtalk.api.DefaultDingTalkClient;
import com.dingtalk.api.request.OapiAuthScopesRequest;
import com.dingtalk.api.request.OapiRoleListRequest;
import com.dingtalk.api.request.OapiRoleSimplelistRequest;
import com.dingtalk.api.request.OapiSnsGetuserinfoBycodeRequest;
import com.dingtalk.api.request.OapiUserGetbyunionidRequest;
import com.dingtalk.api.request.OapiV2DepartmentGetRequest;
import com.dingtalk.api.request.OapiV2DepartmentListsubRequest;
import com.dingtalk.api.request.OapiV2UserGetRequest;
import com.dingtalk.api.request.OapiV2UserListRequest;
import com.dingtalk.api.response.OapiAuthScopesResponse;
import com.dingtalk.api.response.OapiRoleListResponse;
import com.dingtalk.api.response.OapiRoleSimplelistResponse;
import com.dingtalk.api.response.OapiSnsGetuserinfoBycodeResponse;
import com.dingtalk.api.response.OapiUserGetbyunionidResponse;
import com.dingtalk.api.response.OapiV2DepartmentGetResponse;
import com.dingtalk.api.response.OapiV2DepartmentListsubResponse;
import com.dingtalk.api.response.OapiV2UserGetResponse;
import com.dingtalk.api.response.OapiV2UserListResponse;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.core.tool.utils.StringUtil;
import com.qianwen.smartman.common.constant.CommonConstant;
import com.qianwen.smartman.common.constant.CommonGroupConstant;
import com.qianwen.smartman.common.enums.CommonGroupTypeEnum;
import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.smartman.modules.cps.entity.CommonGroup;
import com.qianwen.smartman.modules.cps.entity.CommonGroupOfItem;
import com.qianwen.smartman.modules.cps.entity.Employee;
import com.qianwen.smartman.modules.cps.entity.EmployeePost;
import com.qianwen.smartman.modules.cps.mapper.CommonGroupMapper;
import com.qianwen.smartman.modules.cps.service.ICommonGroupOfItemService;
import com.qianwen.smartman.modules.cps.service.ICommonGroupService;
import com.qianwen.smartman.modules.cps.service.IEmployeePostService;
import com.qianwen.smartman.modules.cps.service.IEmployeeService;
import com.qianwen.smartman.modules.sync.constant.DingConstant;
import com.qianwen.smartman.modules.sync.constant.OuterAppConfigConstant;
import com.qianwen.smartman.modules.sync.constant.QyWechatConstant;
import com.qianwen.smartman.modules.sync.entity.DingOriDept;
import com.qianwen.smartman.modules.sync.entity.DingOriUser;
import com.qianwen.smartman.modules.sync.entity.OuterAppConfig;
import com.qianwen.smartman.modules.sync.service.IDingEventService;
import com.qianwen.smartman.modules.sync.service.IDingSyncService;
import com.qianwen.smartman.modules.sync.service.IOuterAppConfigService;
import com.qianwen.smartman.modules.sync.vo.SyncResultVO;
import com.qianwen.smartman.modules.system.entity.Post;
import com.qianwen.smartman.modules.system.entity.UserOauth;
import com.qianwen.smartman.modules.system.mapper.PostMapper;
import com.qianwen.smartman.modules.system.service.IParamService;
import com.qianwen.smartman.modules.system.service.IPostService;
import com.qianwen.smartman.modules.system.service.IUserOauthService;
import com.taobao.api.TaobaoRequest;

import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;

@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/sync/service/impl/DingSyncServiceImpl.class */
public class DingSyncServiceImpl implements IDingSyncService {
    private static final Logger log = LoggerFactory.getLogger(DingSyncServiceImpl.class);
    private final IUserOauthService userOauthService;
    private final IEmployeeService employeeService;
    private final IPostService postService;
    private final ICommonGroupService groupService;
    private final CommonGroupMapper commonGroupMapper;
    private final IDingEventService dingEventService;
    private final ICommonGroupOfItemService commonGroupOfItemService;
    private Map<String, Set<String>> userPostRelationMap;
    private final DataSourceTransactionManager dataSourceTransactionManager;
    private final PostMapper postMapper;
    private final IOuterAppConfigService outerAppConfigService;
    private final IParamService paramService;
    private final IEmployeePostService employeePostService;


    public DingSyncServiceImpl(final IUserOauthService userOauthService, final IEmployeeService employeeService, final IPostService postService, final ICommonGroupService groupService, final CommonGroupMapper commonGroupMapper, final IDingEventService dingEventService, final ICommonGroupOfItemService commonGroupOfItemService, final Map<String, Set<String>> userPostRelationMap, final DataSourceTransactionManager dataSourceTransactionManager, final PostMapper postMapper, final IOuterAppConfigService outerAppConfigService, final IParamService paramService, final IEmployeePostService employeePostService) {
        this.userOauthService = userOauthService;
        this.employeeService = employeeService;
        this.postService = postService;
        this.groupService = groupService;
        this.commonGroupMapper = commonGroupMapper;
        this.dingEventService = dingEventService;
        this.commonGroupOfItemService = commonGroupOfItemService;
        this.userPostRelationMap = userPostRelationMap;
        this.dataSourceTransactionManager = dataSourceTransactionManager;
        this.postMapper = postMapper;
        this.outerAppConfigService = outerAppConfigService;
        this.paramService = paramService;
        this.employeePostService = employeePostService;
    }

    @Override // org.springblade.modules.sync.service.IDingSyncService
    public SyncResultVO syncImmediately() {
    	
    	OuterAppConfig dingAppConfig = this.outerAppConfigService.getAppConfig(OuterAppConfigConstant.DING);
        String appKey = dingAppConfig.getDingAppKey();
        String appSecret = dingAppConfig.getDingAppSecret();
        DefaultTransactionDefinition transDefinition = new DefaultTransactionDefinition();
        
    	List<Post> posts = new ArrayList<>();
        List<DingOriDept> oriGroups = new ArrayList<>();
        List<DingOriUser> oriUsers = new ArrayList<>();
        
        
        
        TransactionStatus transStatus = this.dataSourceTransactionManager.getTransaction(transDefinition);
        SyncResultVO syncResultVO = new SyncResultVO();
        try {
            getRoles(appKey, appSecret, posts, syncResultVO);
            
            List<Long> permissionGroups = getPermissionGroup(appKey, appSecret, syncResultVO);
            if (Func.isEmpty(permissionGroups)) {
                syncResultVO.setGroupResult(false);
                syncResultVO.setUserReason("未获取到权限范围内的组织机构！");
            }
            for (Long permissionGroup : permissionGroups) {
                SyncEmployee(permissionGroup, appKey, appSecret, oriUsers, syncResultVO);
                recursionGetGroup(permissionGroup, appKey, appSecret, oriGroups, oriUsers, syncResultVO, permissionGroups);
            }
           
            if (!syncResultVO.getGroupResult().booleanValue() || !syncResultVO.getPostResult().booleanValue() || !syncResultVO.getUserResult().booleanValue()) {
                this.userPostRelationMap.clear();
                return syncResultVO;
            }
            List<Employee> employees = new ArrayList<>();
            List<EmployeePost> employeePosts = new ArrayList<>();
            List<UserOauth> userOauths = new ArrayList<>();
            List<CommonGroupOfItem> commonGroupOfItems = new ArrayList<>();
            List<Employee> updateEmployees = new ArrayList<>();
            Boolean flag = true;
            try {
                this.postMapper.removePost();
                this.postService.saveBatch(posts);
            } catch (Exception e2) {
                flag = false;
                syncResultVO.setPostResult(false);
                syncResultVO.setPostReason("同步钉钉角色数据库部分报错:" + e2.toString());
            }
            try {
                this.commonGroupMapper.removeOrg();
                insertGroups(permissionGroups, oriGroups, appKey, appSecret);
            } catch (Exception e3) {
                flag = false;
                syncResultVO.setGroupResult(false);
                syncResultVO.setGroupReason("同步钉钉部门数据库部分报错:" + e3.toString());
            }
            try {
                this.userOauthService.remove(Wrappers.lambdaQuery());
                this.commonGroupMapper.removeOrgContact();
                this.employeePostService.remove(Wrappers.lambdaQuery());
                handleAuthAndEmployee(oriUsers, employees, userOauths, commonGroupOfItems, employeePosts, updateEmployees);
                this.employeeService.remove(Wrappers.<Employee>lambdaQuery().notIn(Func.isNotEmpty(updateEmployees), Employee::getId, updateEmployees.stream().map(Employee::getId).collect(Collectors.toList())));
                /*
                this.employeeService.remove(Wrappers.lambdaQuery().notIn(Func.isNotEmpty(updateEmployees), (v0) -> {
                    return v0.getId();
                }, (Collection) updateEmployees.stream().map((v0) -> {
                    return v0.getId();
                }).collect(Collectors.toList())));*/
                this.employeeService.saveBatch(employees);
                this.employeeService.updateBatchById(updateEmployees);
                this.userOauthService.saveOrUpdateBatch(userOauths);
                this.commonGroupOfItemService.saveBatch(commonGroupOfItems);
                if (Func.isNotEmpty(employeePosts)) {
                    this.employeePostService.saveBatch(employeePosts);
                }
            } catch (Exception e4) {
                flag = false;
                syncResultVO.setUserResult(false);
                syncResultVO.setUserReason("同步钉钉员工数据库部分报错:" + e4.toString());
            }
            if (syncResultVO.getGroupResult().booleanValue() && syncResultVO.getPostResult().booleanValue() && syncResultVO.getUserResult().booleanValue()) {
            	this.outerAppConfigService.update(Wrappers.<OuterAppConfig>lambdaUpdate().eq(OuterAppConfig::getAppType, OuterAppConfigConstant.DING)
            			.set(OuterAppConfig::getLastSyncTime, new Date())); 
            	/*
                this.outerAppConfigService.update((Wrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().eq((v0) -> {
                    return v0.getAppType();
                }, OuterAppConfigConstant.DING)).set((v0) -> {
                    return v0.getLastSyncTime();
                }, new Date()));*/
            }
            if (flag.booleanValue()) {
                this.dataSourceTransactionManager.commit(transStatus);
            } else {
                this.dataSourceTransactionManager.rollback(transStatus);
            }
            this.userPostRelationMap.clear();
            return syncResultVO;
        } catch (Exception th) {
        	log.error("同步钉钉通讯录异常，异常信息为：", th);
        	this.dataSourceTransactionManager.rollback(transStatus);
            
            //throw th;
        }finally {
        	this.userPostRelationMap.clear();
        }
        
        return syncResultVO;
    }

    private List<Long> getPermissionGroup(String appKey, String appSecret, SyncResultVO syncResultVO) {
        try {
            DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/auth/scopes");
            OapiAuthScopesRequest req = new OapiAuthScopesRequest();
            req.setHttpMethod("GET");
            OapiAuthScopesResponse rsp = defaultDingTalkClient.execute(req, this.dingEventService.getDingAccessToken(appKey, appSecret));
            JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
            if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
                JSONObject authInfo = jsonObject.getJSONObject("auth_org_scopes");
                JSONArray deptArray = authInfo.getJSONArray("authed_dept");
                return deptArray.toJavaList(Long.class);
            }
            syncResultVO.setUserResult(false);
            syncResultVO.setUserReason("获取权限下部门报错，结果为：" + jsonObject + "---------参数为：" + req);
            return null;
        } catch (Exception e) {
            syncResultVO.setGroupResult(false);
            syncResultVO.setUserReason("获取权限下部门报错:" + e.toString());
            return null;
        }
    }

    @Override // org.springblade.modules.sync.service.IDingSyncService
    @Transactional
    public Boolean scanCodeBind(String code, String state) {
        OuterAppConfig outerAppConfig = this.outerAppConfigService.getAppConfig(OuterAppConfigConstant.DING);
        String appKey = outerAppConfig.getDingAppKey();
        String appSecret = outerAppConfig.getDingAppSecret();
        JSONObject userObject = null;
        try {
            String userId = getUserIdByCode(code, appKey, appSecret);
            if (Func.isNotEmpty(userId)) {
                userObject = getDetailByUserId(userId, appKey, appSecret);
            }
            if (Func.isNotEmpty(userId) && Func.isNotEmpty(userObject)) {
            	UserOauth userOauth = this.userOauthService.getOne(Wrappers.<UserOauth>lambdaQuery().eq(UserOauth::getUuid, userId), false);
            	/*
                UserOauth userOauth = (UserOauth) this.userOauthService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
                    return v0.getUuid();
                }, userId), false);*/
                if (Func.isEmpty(userOauth)) {
                    throw new ServiceException(MessageUtils.message("sys.outer.user.not.exist", new Object[0]));
                }
                if (Func.isEmpty(userOauth.getUserId())) {
                    relationScanUser(userObject, userOauth, state);
                    this.userOauthService.updateById(userOauth);
                    return true;
                }
                throw new ServiceException(MessageUtils.message("cps.employee.already.bind", new Object[0]));
            }
            throw new ServiceException(MessageUtils.message("sys.outer.user.not.exist", new Object[0]));
        } catch (Exception e) {
            log.error("扫码绑定员工异常，异常信息为：", e);
            return false;
        }
    }

    @Override // org.springblade.modules.sync.service.IDingSyncService
    public Boolean unbind(Long id, String source) {
    	UserOauth userOauth = this.userOauthService.getOne(Wrappers.<UserOauth>lambdaQuery().eq(UserOauth::getUserId, id).eq(UserOauth::getSource, source));
    	/*
        UserOauth userOauth = (UserOauth) this.userOauthService.getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getUserId();
        }, id)).eq((v0) -> {
            return v0.getSource();
        }, source));*/
        if (Func.isEmpty(userOauth)) {
            throw new ServiceException(MessageUtils.message("cps.employee.not.band", new Object[0]));
        }
        
        return Boolean.valueOf(this.userOauthService.update(Wrappers.<UserOauth>lambdaUpdate()
        		.set(UserOauth::getUserId, null).eq(UserOauth::getUserId, id).eq(UserOauth::getSource, source)));
        /*
        return Boolean.valueOf(this.userOauthService.update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().set((v0) -> {
            return v0.getUserId();
        }, (Object) null)).eq((v0) -> {
            return v0.getUserId();
        }, id)).eq((v0) -> {
            return v0.getSource();
        }, source)));*/
    }

    @Override // org.springblade.modules.sync.service.IDingSyncService
    public String getDingUserId(String code) {
        try {
            OuterAppConfig outerAppConfig = this.outerAppConfigService.getAppConfig(OuterAppConfigConstant.DING);
            String appKey = outerAppConfig.getDingAppKey();
            String appSecret = outerAppConfig.getDingAppSecret();
            String userId = getUserIdByCode(code, appKey, appSecret);
            return userId;
        } catch (Exception e) {
            log.error("获取钉钉userId异常，异常信息为:", e);
            return null;
        }
    }

    private String getUserIdByCode(String code, String appKey, String appSecret) throws Exception {
        DefaultDingTalkClient client2 = new DefaultDingTalkClient("https://oapi.dingtalk.com/sns/getuserinfo_bycode");
        OapiSnsGetuserinfoBycodeRequest reqBycodeRequest = new OapiSnsGetuserinfoBycodeRequest();
        reqBycodeRequest.setTmpAuthCode(code);
        OapiSnsGetuserinfoBycodeResponse bycodeResponse = client2.execute(reqBycodeRequest, appKey, appSecret);
        if (Func.isEmpty(bycodeResponse) || Func.isEmpty(bycodeResponse.getUserInfo())) {
            return null;
        }
        String unionid = bycodeResponse.getUserInfo().getUnionid();
        DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/user/getbyunionid");
        OapiUserGetbyunionidRequest reqGetbyunionidRequest = new OapiUserGetbyunionidRequest();
        reqGetbyunionidRequest.setUnionid(unionid);
        OapiUserGetbyunionidResponse oapiUserGetbyunionidResponse = defaultDingTalkClient.execute(reqGetbyunionidRequest, this.dingEventService.getDingAccessToken(appKey, appSecret));
        if (Func.isEmpty(oapiUserGetbyunionidResponse) || Func.isEmpty(oapiUserGetbyunionidResponse.getResult()) || Func.isEmpty(oapiUserGetbyunionidResponse.getResult().getUserid())) {
            return null;
        }
        String userid = oapiUserGetbyunionidResponse.getResult().getUserid();
        return userid;
    }

    private void relationScanUser(JSONObject userObject, UserOauth userOauth, String state) {
        Employee employee = (Employee) this.employeeService.getById(state);
        if (Func.isNotEmpty(employee)) {
            if (!employee.getTel().equals(userObject.getString("mobile"))) {
                throw new ServiceException(MessageUtils.message("cps.employee.not.current.scan.user", new Object[0]));
            }
            userOauth.setUserId(employee.getId());
            return;
        }
        throw new ServiceException(MessageUtils.message("cps.employee.not.exist.by.mobile", new Object[0]));
    }

    private JSONObject getDetailByUserId(String userId, String appKey, String appSecret) throws Exception {
        DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
        OapiV2UserGetRequest reqDetail = new OapiV2UserGetRequest();
        reqDetail.setUserid(userId);
        OapiV2UserGetResponse rspDetail = defaultDingTalkClient.execute(reqDetail, this.dingEventService.getDingAccessToken(appKey, appSecret));
        JSONObject jsonObject = JSONObject.parseObject(rspDetail.getBody());
        if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
            return jsonObject.getJSONObject("result");
        }
        return null;
    }

    private String getUserIdByUnionId(GetUserResponseBody userBody, String appKey, String appSecret) throws Exception {
        DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/user/getbyunionid");
        OapiUserGetbyunionidRequest req = new OapiUserGetbyunionidRequest();
        req.setUnionid(userBody.getUnionId());
        OapiUserGetbyunionidResponse rsp = defaultDingTalkClient.execute(req, this.dingEventService.getDingAccessToken(appKey, appSecret));
        if (Func.isEmpty(rsp) || Func.isEmpty(rsp.getBody())) {
            return null;
        }
        JSONObject userObject = JSONObject.parseObject(rsp.getBody()).getJSONObject("result");
        if (Func.isEmpty(userObject)) {
            return null;
        }
        return userObject.getString("userid");
    }

    private void handleAuthAndEmployee(List<DingOriUser> oriUsers, List<Employee> employees, List<UserOauth> userOauths, List<CommonGroupOfItem> commonGroupOfItems, List<EmployeePost> employeePosts, List<Employee> updateEmployees) {
        if (Func.isNotEmpty(oriUsers)) {
            String pinValue = this.paramService.getValue("employee.default.pin");
            List<Employee> dbEmployees = this.employeeService.list();
            
            
            Map<String, Employee> employeeMap = dbEmployees.parallelStream().filter(o -> {
                return Func.isNotEmpty(o.getTel());
            }).collect(Collectors.toMap((v0) -> {
                return v0.getTel();
            }, e -> {
                return e;
            }, (k1, k2) -> {
                return k1;
            }));
            Snowflake snowflake = IdUtil.createSnowflake(1L, 1L);
            Set<String> distinctUser = new HashSet<>();
            oriUsers.forEach(oriUser -> {
                if (!distinctUser.contains(oriUser.getUserid())) {
                    distinctUser.add(oriUser.getUserid());
                    Employee employee = handleEmployee(oriUser, employees, commonGroupOfItems, employeePosts, snowflake, pinValue, employeeMap, updateEmployees);
                    UserOauth userOauth = packageUserOauth(employee, oriUser);
                    userOauths.add(userOauth);
                }
            });
        }
    }

    @NotNull
    private Employee handleEmployee(DingOriUser oriUser, List<Employee> employees, List<CommonGroupOfItem> commonGroupOfItems, List<EmployeePost> employeePosts, Snowflake snowflake, String pin, Map<String, Employee> employeeMap, List<Employee> updateEmployees) {
        Employee employee = packageEmployee(oriUser, snowflake, pin, employeeMap);
        if (Func.isEmpty(employee.getTenantId())) {
            employees.add(employee);
        } else {
            updateEmployees.add(employee);
        }
        packageRelation(oriUser, employee, commonGroupOfItems, employeePosts);
        return employee;
    }

    private void packageRelation(DingOriUser oriUser, Employee employee, List<CommonGroupOfItem> commonGroupOfItems, List<EmployeePost> employeePosts) {
        if (this.userPostRelationMap.containsKey(oriUser.getUserid())) {
            employee.setPostId(StringUtil.join(this.userPostRelationMap.get(oriUser.getUserid()), ","));
            for (String postId : this.userPostRelationMap.get(oriUser.getUserid())) {
                EmployeePost employeePost = new EmployeePost();
                employeePost.setEmployeeId(employee.getId());
                employeePost.setPostId(Long.valueOf(postId));
                employeePosts.add(employeePost);
            }
        }
        commonGroupOfItems.add(CommonGroupOfItem.builder().groupId(Long.valueOf(oriUser.getDept_id_list().get(0).equals(1L) ? 3L : Long.valueOf(String.valueOf(oriUser.getDept_id_list().get(0))).longValue())).itemId(employee.getId()).groupType(CommonGroupTypeEnum.ORGANIZATION.getName()).groupCategory(CommonGroupConstant.DEFAULT_CATEGORY).build());
    }

    @NotNull
    private UserOauth packageUserOauth(Employee employee, DingOriUser dingOriUser) {
        UserOauth userOauth = new UserOauth();
        userOauth.setEmail(employee.getEmail());
        userOauth.setUserId(employee.getId());
        userOauth.setUsername(employee.getName());
        userOauth.setSource(DingConstant.DING_AUTH_KEY);
        userOauth.setUuid(dingOriUser.getUserid());
        userOauth.setAvatar(employee.getAvatar());
        return userOauth;
    }

    @NotNull
    private Employee packageEmployee(DingOriUser oriUser, Snowflake snowflake, String pin, Map<String, Employee> employeeMap) {
        Employee employee = new Employee();
        employee.setName(oriUser.getName());
        employee.setPinCode(pin);
        employee.setTel(oriUser.getMobile());
        if (Func.isNotEmpty(oriUser.getEmail())) {
            employee.setEmail(oriUser.getEmail());
        }
        if (Func.isNotEmpty(oriUser.getHired_date())) {
            employee.setHireDate(new Date(oriUser.getHired_date().longValue()));
        }
        if (Func.isNotEmpty(oriUser.getJob_number())) {
            employee.setJobNumber(oriUser.getJob_number());
        }
        if (Func.isNotEmpty(oriUser.getAvatar())) {
            employee.setAvatar(oriUser.getAvatar());
        }
        employee.setStatus(CommonConstant.ENABLE);
        employee.setOrganizationId(oriUser.getDept_id_list().get(0).equals(1L) ? "3" : String.valueOf(oriUser.getDept_id_list().get(0)));
        if (employeeMap.containsKey(oriUser.getMobile())) {
            Employee oriEmp = employeeMap.get(oriUser.getMobile());
            employee.setPinCode(oriEmp.getPinCode());
            employee.setUserId(oriEmp.getUserId());
            employee.setJobNumber(oriEmp.getJobNumber());
            employee.setId(oriEmp.getId());
            employee.setTenantId(oriEmp.getTenantId());
            employee.setCreateUser(oriEmp.getCreateUser());
            employee.setCreateDept(oriEmp.getCreateDept());
        } else {
            employee.setId(Long.valueOf(snowflake.nextId()));
        }
        return employee;
    }

    private void insertGroups(List<Long> permissionGroups, List<DingOriDept> oriGroups, String appKey, String appSecret) throws Exception {
        for (Long permissionGroup : permissionGroups) {
            DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/get");
            OapiV2DepartmentGetRequest req = new OapiV2DepartmentGetRequest();
            req.setDeptId(permissionGroup);
            OapiV2DepartmentGetResponse rsp = defaultDingTalkClient.execute(req, this.dingEventService.getDingAccessToken(appKey, appSecret));
            JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
            if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
                JSONObject resultMap = jsonObject.getJSONObject("result");
                this.groupService.insert(CommonGroup.builder().groupCategory(1).groupType(DingConstant.GROUPTYPE).parentId(Long.valueOf(permissionGroup.equals(1L) ? 0L : Long.valueOf(String.valueOf(resultMap.get("parent_id"))).longValue())).name(String.valueOf(resultMap.get("name"))).status(1).id(Long.valueOf(permissionGroup.equals(1L) ? 3L : permissionGroup.longValue())).build());
            }
        }
        if (Func.isNotEmpty(oriGroups)) {
            oriGroups.forEach(oriGroup -> {
                this.groupService.insert(CommonGroup.builder().groupCategory(1).groupType(DingConstant.GROUPTYPE).parentId(Long.valueOf(oriGroup.getParent_id().equals(1L) ? 3L : oriGroup.getParent_id().longValue())).name(oriGroup.getName()).status(1).id(oriGroup.getDept_id()).build());
            });
        }
    }

    private void getRoles(String appKey, String appSecret, List<Post> postList, SyncResultVO syncResultVO) {
        try {
          DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/role/list");
          OapiRoleListRequest req = new OapiRoleListRequest();
          req.setSize(DingConstant.ROLE_SIZE);
          req.setOffset(DingConstant.START_OFFSET);
          while (true) {
            OapiRoleListResponse rsp = (OapiRoleListResponse)defaultDingTalkClient.execute((TaobaoRequest)req, this.dingEventService.getDingAccessToken(appKey, appSecret));
            JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
            if (jsonObject.getInteger("errcode").equals(DingConstant.SUCCESS)) {
              Map<String, Object> resultMap = (Map<String, Object>)jsonObject.get("result");
              List<Map<String, Object>> resultList = (List<Map<String, Object>>)resultMap.get("list");
              if (Func.isNotEmpty(resultList))
                for (Map<String, Object> roleGroupMap : resultList) {
                  List<Map<String, Object>> roleList = (List<Map<String, Object>>)roleGroupMap.get("roles");
                  if (Func.isNotEmpty(roleList))
                    for (Map<String, Object> role : roleList) {
                      Post post = new Post();
                      post.setPostCode(String.valueOf(role.get("id")));
                      post.setId(Long.valueOf(String.valueOf(role.get("id"))));
                      post.setPostName(String.valueOf(role.get("name")));
                      post.setStatus(CommonConstant.ENABLE);
                      postList.add(post);
                      getRoleContainsUser(post.getPostCode(), appKey, appSecret);
                    }  
                }  
              if (((Boolean)resultMap.get("hasMore")).booleanValue()) {
                req.setOffset(Long.valueOf(req.getOffset().longValue() + DingConstant.ROLE_SIZE.longValue()));
                continue;
              } 
              break;
            } 
            syncResultVO.setPostResult(Boolean.valueOf(false));
            syncResultVO.setPostReason("同步钉钉角色异常，结果为：" + jsonObject + "---------参数为：" + req);
            break;
          } 
        } catch (Exception e) {
          syncResultVO.setPostResult(Boolean.valueOf(false));
          syncResultVO.setPostReason("同步钉钉角色报错:" + e.toString());
        } 
      }

    private void getRoleContainsUser(String postCode, String appKey, String appSecret) throws Exception {
        DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/role/simplelist");
        OapiRoleSimplelistRequest req = new OapiRoleSimplelistRequest();
        req.setRoleId(Long.valueOf(postCode));
        req.setOffset(DingConstant.START_OFFSET);
        req.setSize(DingConstant.SIZE);
        while (true) {
            OapiRoleSimplelistResponse rsp = defaultDingTalkClient.execute(req, this.dingEventService.getDingAccessToken(appKey, appSecret));
            JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
            if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
                Map<String, Object> resultMap = (Map) jsonObject.get("result");
                List<Map<String, Object>> resultList = (List) resultMap.get("list");
                if (Func.isNotEmpty(resultList)) {
                    resultList.forEach(userMap -> {
                        if (this.userPostRelationMap.containsKey(String.valueOf(userMap.get("userid")))) {
                            Set<String> userRoleList = this.userPostRelationMap.get(String.valueOf(userMap.get("userid")));
                            userRoleList.add(postCode);
                            this.userPostRelationMap.put(String.valueOf(userMap.get("userid")), userRoleList);
                            return;
                        }
                        Set<String> userRoleList2 = new HashSet<>();
                        userRoleList2.add(postCode);
                        this.userPostRelationMap.put(String.valueOf(userMap.get("userid")), userRoleList2);
                    });
                }
                if (((Boolean) resultMap.get("hasMore")).booleanValue()) {
                    req.setOffset(Long.valueOf(req.getOffset().longValue() + DingConstant.SIZE.longValue()));
                } else {
                    return;
                }
            } else {
                log.error("同步钉钉用户异常，结果为：" + jsonObject + "---------参数为：" + req.toString());
                return;
            }
        }
    }

    private void recursionGetGroup(Long deptId, String appKey, String appSecret, List<DingOriDept> oriGroups, List<DingOriUser> oriUsers, SyncResultVO syncResultVO, List<Long> permissionGroups) {
        try {
            DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/listsub");
            OapiV2DepartmentListsubRequest req = new OapiV2DepartmentListsubRequest();
            req.setDeptId(Long.valueOf(deptId.equals(3L) ? 1L : deptId.longValue()));
            OapiV2DepartmentListsubResponse rsp = defaultDingTalkClient.execute(req, this.dingEventService.getDingAccessToken(appKey, appSecret));
            JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
            if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
                List<DingOriDept> resultList = jsonObject.getJSONArray("result").toJavaList(DingOriDept.class);
                if (Func.isNotEmpty(resultList)) {
                    resultList.forEach(dept -> {
                        Long childDeptId = dept.getDept_id();
                        if (!permissionGroups.contains(childDeptId)) {
                            try {
                                oriGroups.add(dept);
                            } catch (Exception e) {
                                log.error("同步钉钉部门入库时异常，部门为：" + dept);
                            }
                            SyncEmployee(childDeptId, appKey, appSecret, oriUsers, syncResultVO);
                            recursionGetGroup(childDeptId, appKey, appSecret, oriGroups, oriUsers, syncResultVO, permissionGroups);
                        }
                    });
                }
            } else {
                syncResultVO.setGroupResult(false);
                syncResultVO.setGroupReason("同步钉钉部门异常，结果为：" + jsonObject + "---------参数为：" + req.toString());
            }
        } catch (Exception e) {
            syncResultVO.setGroupResult(false);
            syncResultVO.setGroupReason("同步钉钉部门报错:" + e.toString());
        }
    }

    private void SyncEmployee(Long deptId, String appKey, String appSecret, List<DingOriUser> oriUsers, SyncResultVO syncResultVO) {
        try {
          DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/list");
          OapiV2UserListRequest req = new OapiV2UserListRequest();
          req.setSize(DingConstant.SIZE);
          req.setDeptId(Long.valueOf(deptId.equals(Long.valueOf(3L)) ? 1L : deptId.longValue()));
          req.setCursor(DingConstant.START_OFFSET);
          while (true) {
            OapiV2UserListResponse rsp = (OapiV2UserListResponse)defaultDingTalkClient.execute((TaobaoRequest)req, this.dingEventService.getDingAccessToken(appKey, appSecret));
            JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
            if (jsonObject.getInteger("errcode").equals(DingConstant.SUCCESS)) {
              JSONObject resultMap = jsonObject.getJSONObject("result");
              List<DingOriUser> resultList = resultMap.getJSONArray("list").toJavaList(DingOriUser.class);
              if (Func.isNotEmpty(resultList))
                resultList.forEach(userMap -> oriUsers.add(userMap)); 
              if (((Boolean)resultMap.get("has_more")).booleanValue()) {
                req.setCursor(Long.valueOf(String.valueOf(resultMap.get("next_cursor"))));
                continue;
              } 
              break;
            } 
            syncResultVO.setUserResult(Boolean.valueOf(false));
            syncResultVO.setUserReason("同步钉钉用户异常，结果为：" + jsonObject + "---------参数为：" + req);
            break;
          } 
        } catch (Exception e) {
          syncResultVO.setUserResult(Boolean.valueOf(false));
          syncResultVO.setUserReason("同步钉钉用户报错:" + e.toString());
        } 
      }

    public static Client authClient() throws Exception {
        Config config = new Config();
        config.protocol = "https";
        config.regionId = "central";
        return new Client(config);
    }

    public static com.aliyun.dingtalkcontact_1_0.Client contactClient() throws Exception {
        Config config = new Config();
        config.protocol = "https";
        config.regionId = "central";
        return new com.aliyun.dingtalkcontact_1_0.Client(config);
    }

    public GetUserResponseBody getUserinfo(String accessToken) throws Exception {
        com.aliyun.dingtalkcontact_1_0.Client client = contactClient();
        GetUserHeaders getUserHeaders = new GetUserHeaders();
        getUserHeaders.xAcsDingtalkAccessToken = accessToken;
        GetUserResponseBody responseBody = client.getUserWithOptions("me", getUserHeaders, new RuntimeOptions()).getBody();
        return responseBody;
    }
}