package com.qianwen.smartman.modules.sync.service.impl;
|
|
import java.time.Duration;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.dingtalk.api.DefaultDingTalkClient;
|
import com.dingtalk.api.request.OapiGettokenRequest;
|
import com.dingtalk.api.request.OapiRoleGetroleRequest;
|
import com.dingtalk.api.request.OapiV2DepartmentGetRequest;
|
import com.dingtalk.api.request.OapiV2UserGetRequest;
|
import com.dingtalk.api.response.OapiGettokenResponse;
|
import com.dingtalk.api.response.OapiRoleGetroleResponse;
|
import com.dingtalk.api.response.OapiV2DepartmentGetResponse;
|
import com.dingtalk.api.response.OapiV2UserGetResponse;
|
import com.qianwen.core.redis.cache.BladeRedis;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.common.constant.CommonConstant;
|
import com.qianwen.smartman.common.constant.CommonGroupConstant;
|
import com.qianwen.smartman.common.constant.DncConstant;
|
import com.qianwen.smartman.common.enums.CommonGroupTypeEnum;
|
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.QyWechatConstant;
|
import com.qianwen.smartman.modules.sync.entity.DingUserInnerRole;
|
import com.qianwen.smartman.modules.sync.entity.OuterAppConfig;
|
import com.qianwen.smartman.modules.sync.enums.DingEventEnum;
|
import com.qianwen.smartman.modules.sync.service.IDingEventService;
|
import com.qianwen.smartman.modules.sync.util.DingCallbackCrypto;
|
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 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/DingEventServiceImpl.class */
|
public class DingEventServiceImpl implements IDingEventService {
|
private static final Logger log = LoggerFactory.getLogger(DingEventServiceImpl.class);
|
private final IUserOauthService userOauthService;
|
private final IEmployeeService employeeService;
|
private final ICommonGroupService groupService;
|
private final CommonGroupMapper commonGroupMapper;
|
private final BladeRedis bladeRedis;
|
private final IEmployeePostService employeePostService;
|
private final ICommonGroupOfItemService commonGroupOfItemService;
|
private final IPostService postService;
|
private final PostMapper postMapper;
|
private final IParamService paramService;
|
|
|
public DingEventServiceImpl(final IUserOauthService userOauthService, final IEmployeeService employeeService, final ICommonGroupService groupService, final CommonGroupMapper commonGroupMapper, final BladeRedis bladeRedis, final IEmployeePostService employeePostService, final ICommonGroupOfItemService commonGroupOfItemService, final IPostService postService, final PostMapper postMapper, final IParamService paramService) {
|
this.userOauthService = userOauthService;
|
this.employeeService = employeeService;
|
this.groupService = groupService;
|
this.commonGroupMapper = commonGroupMapper;
|
this.bladeRedis = bladeRedis;
|
this.employeePostService = employeePostService;
|
this.commonGroupOfItemService = commonGroupOfItemService;
|
this.postService = postService;
|
this.postMapper = postMapper;
|
this.paramService = paramService;
|
}
|
|
@Override // org.springblade.modules.sync.service.IDingEventService
|
@Async
|
@Transactional
|
public void handleEvent(DingCallbackCrypto callbackCrypto, String decryptMsg, OuterAppConfig outerAppConfig) {
|
JSONObject eventJson = JSON.parseObject(decryptMsg);
|
String eventType = eventJson.getString("EventType");
|
String appKey = outerAppConfig.getDingAppKey();
|
String appSecret = outerAppConfig.getDingAppSecret();
|
|
switch (DingEventEnum.getValue(eventType)) {
|
case CHECK_URL:
|
log.info("测试回调url的正确性");
|
break;
|
case USER_ADD_ORG:
|
userAdd(eventJson, appKey, appSecret);
|
break;
|
case USER_MODIFY_ORG:
|
userModify(eventJson, appKey, appSecret);
|
break;
|
case USER_LEAVE_ORG:
|
userLeave(eventJson);
|
break;
|
case ORG_DEPT_CREATE:
|
deptCreate(eventJson, appKey, appSecret);
|
break;
|
case ORG_DEPT_MODIFY:
|
deptModify(eventJson, appKey, appSecret);
|
break;
|
case ORG_DEPT_REMOVE:
|
deptRemove(eventJson);
|
break;
|
case LABEL_USER_CHANGE:
|
labelUserChange(eventJson, appKey, appSecret);
|
break;
|
case LABEL_CONF_ADD:
|
labelAdd(eventJson, appKey, appSecret);
|
break;
|
case LABEL_CONF_DEL:
|
lableDel(eventJson);
|
break;
|
case LABEL_CONF_MODIFY:
|
lableModify(eventJson, appKey, appSecret);
|
break;
|
}
|
/*
|
switch (AnonymousClass1.$SwitchMap$org$springblade$modules$sync$enums$DingEventEnum[DingEventEnum.getValue(eventType).ordinal()]) {
|
case 1:
|
log.info("测试回调url的正确性");
|
return;
|
case 2:
|
userAdd(eventJson, appKey, appSecret);
|
return;
|
case 3:
|
userModify(eventJson, appKey, appSecret);
|
return;
|
case 4:
|
userLeave(eventJson);
|
return;
|
case RegionCache.VILLAGE_LEVEL // 5
|
deptCreate(eventJson, appKey, appSecret);
|
return;
|
case 6:
|
deptModify(eventJson, appKey, appSecret);
|
return;
|
case 7:
|
deptRemove(eventJson);
|
return;
|
case 8:
|
labelUserChange(eventJson, appKey, appSecret);
|
return;
|
case 9:
|
labelAdd(eventJson, appKey, appSecret);
|
return;
|
case 10:
|
lableDel(eventJson);
|
return;
|
case 11:
|
lableModify(eventJson, appKey, appSecret);
|
return;
|
default:
|
return;
|
}*/
|
}
|
|
|
@Override // org.springblade.modules.sync.service.IDingEventService
|
public void addNewEmployee(JSONObject userObject, UserOauth userOauth, Snowflake snowflake) {
|
Employee newEmployee = new Employee();
|
String pinValue = this.paramService.getValue("employee.default.pin");
|
newEmployee.setPinCode(pinValue);
|
newEmployee.setId(Long.valueOf(snowflake.nextId()));
|
newEmployee.setName(userObject.getString("name"));
|
newEmployee.setCode(IdUtil.randomUUID());
|
newEmployee.setEmail(userObject.getString("email"));
|
newEmployee.setTel(userObject.getString("mobile"));
|
if (Func.isNotEmpty(userObject.get("hired_date"))) {
|
newEmployee.setHireDate(new Date(userObject.getLong("hired_date").longValue()));
|
}
|
newEmployee.setJobNumber(userObject.getString("job_number"));
|
newEmployee.setStatus(CommonConstant.ENABLE);
|
newEmployee.setAvatar(userObject.getString("avatar"));
|
newEmployee.setOrganizationId("1".equals(String.valueOf(userObject.getJSONArray("dept_id_list").get(0))) ? "3" : String.valueOf(userObject.getJSONArray("dept_id_list").get(0)));
|
JSONArray roleList = userObject.getJSONArray("role_list");
|
List<EmployeePost> employeePosts = new ArrayList<>();
|
if (Func.isNotEmpty(roleList)) {
|
List<DingUserInnerRole> innerRoles = roleList.toJavaList(DingUserInnerRole.class);
|
String postStr = (String) innerRoles.stream().map(o -> {
|
return String.valueOf(o.getId());
|
}).collect(Collectors.joining(","));
|
newEmployee.setPostId(postStr);
|
for (DingUserInnerRole role : innerRoles) {
|
EmployeePost employeePost = new EmployeePost();
|
employeePost.setEmployeeId(newEmployee.getId());
|
employeePost.setPostId(role.getId());
|
employeePosts.add(employeePost);
|
}
|
this.employeePostService.saveBatch(employeePosts);
|
}
|
this.commonGroupOfItemService.save(CommonGroupOfItem.builder().groupId(Long.valueOf(newEmployee.getOrganizationId())).itemId(newEmployee.getId()).groupType(CommonGroupTypeEnum.ORGANIZATION.getName()).groupCategory(CommonGroupConstant.DEFAULT_CATEGORY).build());
|
this.employeeService.save(newEmployee);
|
userOauth.setUserId(newEmployee.getId());
|
}
|
|
private void userAdd(JSONObject eventJson, String appKey, String appSecret) {
|
try {
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
|
OapiV2UserGetRequest req = new OapiV2UserGetRequest();
|
List<String> userIdList = eventJson.getJSONArray("UserId").toJavaList(String.class);
|
Snowflake snowflake = IdUtil.createSnowflake(1L, 1L);
|
for (String id : userIdList) {
|
req.setUserid(id);
|
OapiV2UserGetResponse rsp = defaultDingTalkClient.execute(req, getDingAccessToken(appKey, appSecret));
|
JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
|
if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
|
JSONObject userObject = jsonObject.getJSONObject("result");
|
UserOauth newAuth = new UserOauth();
|
newAuth.setUuid(id);
|
newAuth.setUsername(userObject.getString("name"));
|
newAuth.setAvatar(userObject.getString("avatar"));
|
newAuth.setSource(DingConstant.DING_AUTH_KEY);
|
Employee employee = this.employeeService.getOne(Wrappers.<Employee>lambdaQuery().eq(Employee::getTel, userObject.getString("mobile")), false);
|
/*
|
Employee employee = (Employee) this.employeeService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getTel();
|
}, userObject.getString("mobile")), false);*/
|
if (Func.isNotEmpty(employee)) {
|
updateEmployee(userObject, employee);
|
newAuth.setUserId(employee.getId());
|
} else {
|
addNewEmployee(userObject, newAuth, snowflake);
|
}
|
this.userOauthService.save(newAuth);
|
}
|
}
|
} catch (Exception e) {
|
log.error("通讯录用户增加异常，异常信息为:", e);
|
}
|
}
|
|
private void userModify(JSONObject eventJson, String appKey, String appSecret) {
|
try {
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
|
OapiV2UserGetRequest req = new OapiV2UserGetRequest();
|
List<String> userIdList = eventJson.getJSONArray("UserId").toJavaList(String.class);
|
for (String id : userIdList) {
|
req.setUserid(id);
|
OapiV2UserGetResponse rsp = defaultDingTalkClient.execute(req, getDingAccessToken(appKey, appSecret));
|
JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
|
if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
|
JSONObject userObject = jsonObject.getJSONObject("result");
|
UserOauth userOauth = this.userOauthService.getOne(Wrappers.<UserOauth>lambdaQuery().eq(UserOauth::getUuid, id), false);
|
/*
|
UserOauth userOauth = (UserOauth) this.userOauthService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getUuid();
|
}, id), false);*/
|
Employee employee = this.employeeService.getOne(Wrappers.<Employee>lambdaQuery().eq(Employee::getTel, userObject.getString("mobile")), false);
|
/*
|
Employee employee = (Employee) this.employeeService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getTel();
|
}, userObject.getString("mobile")), false);*/
|
userOauth.setUsername(userObject.getString("name"));
|
userOauth.setAvatar(userObject.getString("avatar"));
|
this.userOauthService.updateById(userOauth);
|
updateEmployee(userObject, employee);
|
}
|
}
|
} catch (Exception e) {
|
log.error("通讯录用户更改，异常信息为:", e);
|
}
|
}
|
|
private void updateEmployee(JSONObject userObject, Employee employee) {
|
if (Func.isEmpty(employee.getPinCode())) {
|
String pinValue = this.paramService.getValue("employee.default.pin");
|
employee.setPinCode(pinValue);
|
}
|
employee.setName(userObject.getString("name"));
|
if (Func.isNotEmpty(userObject.getString("email"))) {
|
employee.setEmail(userObject.getString("email"));
|
}
|
if (Func.isNotEmpty(userObject.get("hired_date"))) {
|
employee.setHireDate(new Date(userObject.getLong("hired_date").longValue()));
|
}
|
if (Func.isNotEmpty(userObject.getString("job_number"))) {
|
employee.setJobNumber(userObject.getString("job_number"));
|
}
|
if (Func.isNotEmpty(userObject.getString("avatar"))) {
|
employee.setAvatar(userObject.getString("avatar"));
|
}
|
employee.setStatus(CommonConstant.ENABLE);
|
employee.setOrganizationId("1".equals(String.valueOf(userObject.getJSONArray("dept_id_list").get(0))) ? "3" : String.valueOf(userObject.getJSONArray("dept_id_list").get(0)));
|
JSONArray roleList = userObject.getJSONArray("role_list");
|
List<EmployeePost> employeePosts = new ArrayList<>();
|
if (Func.isNotEmpty(roleList)) {
|
List<DingUserInnerRole> innerRoles = roleList.toJavaList(DingUserInnerRole.class);
|
String postStr = (String) innerRoles.stream().map(o -> {
|
return String.valueOf(o.getId());
|
}).collect(Collectors.joining(","));
|
employee.setPostId(postStr);
|
for (DingUserInnerRole role : innerRoles) {
|
EmployeePost employeePost = new EmployeePost();
|
employeePost.setEmployeeId(employee.getId());
|
employeePost.setPostId(role.getId());
|
employeePosts.add(employeePost);
|
}
|
this.employeePostService.remove(Wrappers.<EmployeePost>lambdaQuery().eq(EmployeePost::getEmployeeId, employee.getId()));
|
/*
|
this.employeePostService.remove((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getEmployeeId();
|
}, employee.getId()));*/
|
this.employeePostService.saveBatch(employeePosts);
|
}
|
this.commonGroupOfItemService.remove(Wrappers.<CommonGroupOfItem>lambdaQuery().eq(CommonGroupOfItem::getItemId, employee.getId())
|
.eq(CommonGroupOfItem::getGroupType, CommonGroupTypeEnum.ORGANIZATION.getName()));
|
/*
|
this.commonGroupOfItemService.remove((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getItemId();
|
}, employee.getId())).eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.ORGANIZATION.getName()));*/
|
this.commonGroupOfItemService.save(CommonGroupOfItem.builder().groupId(Long.valueOf(employee.getOrganizationId())).itemId(employee.getId()).groupType(CommonGroupTypeEnum.ORGANIZATION.getName()).groupCategory(CommonGroupConstant.DEFAULT_CATEGORY).build());
|
this.employeeService.updateById(employee);
|
}
|
|
private void userLeave(JSONObject eventJson) {
|
try {
|
List<String> userIdList = eventJson.getJSONArray("UserId").toJavaList(String.class);
|
List<UserOauth> userOauths = this.userOauthService.list(Wrappers.<UserOauth>lambdaQuery().in(UserOauth::getUuid, userIdList));
|
/*
|
List<UserOauth> userOauths = this.userOauthService.list((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getUuid();
|
}, userIdList));*/
|
List<Long> empIds = userOauths.stream().map((v0) -> {
|
return v0.getUserId();
|
}).collect(Collectors.toList());
|
|
this.userOauthService.remove(Wrappers.<UserOauth>lambdaQuery().in(UserOauth::getUuid, userIdList));
|
/*
|
this.userOauthService.remove(Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getUuid();
|
}, userIdList));*/
|
this.employeeService.remove(Wrappers.<Employee>lambdaQuery().in(Employee::getId, empIds));
|
/*
|
this.employeeService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getId();
|
}, empIds));*/
|
this.employeePostService.remove(Wrappers.<EmployeePost>lambdaQuery().in(EmployeePost::getEmployeeId, empIds));
|
/*
|
this.employeePostService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getEmployeeId();
|
}, empIds));*/
|
|
this.commonGroupOfItemService.remove(Wrappers.<CommonGroupOfItem>lambdaQuery()
|
.in(CommonGroupOfItem::getItemId, empIds)
|
.eq(CommonGroupOfItem::getGroupType, CommonGroupTypeEnum.ORGANIZATION.getName()));
|
/*
|
this.commonGroupOfItemService.remove((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getItemId();
|
}, empIds)).eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.ORGANIZATION.getName()));*/
|
} catch (Exception e) {
|
log.error("通讯录用户离职，异常信息为:", e);
|
}
|
}
|
|
private void deptCreate(JSONObject eventJson, String appKey, String appSecret) {
|
try {
|
List<String> deptIds = eventJson.getJSONArray("DeptId").toJavaList(String.class);
|
for (String deptId : deptIds) {
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/get");
|
OapiV2DepartmentGetRequest req = new OapiV2DepartmentGetRequest();
|
req.setDeptId(Long.valueOf(deptId));
|
OapiV2DepartmentGetResponse rsp = defaultDingTalkClient.execute(req, getDingAccessToken(appKey, appSecret));
|
JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
|
if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
|
Map<String, Object> deptMap = (Map) jsonObject.get("result");
|
Long parentId = Long.valueOf(String.valueOf(deptMap.get("parent_id")));
|
this.groupService.insert(CommonGroup.builder().groupCategory(1).groupType(DingConstant.GROUPTYPE).parentId(Long.valueOf(parentId.equals(1L) ? 3L : parentId.longValue())).name(String.valueOf(deptMap.get("name"))).status(1).id(Long.valueOf(deptId)).build());
|
}
|
}
|
} catch (Exception e) {
|
log.error("通讯录企业部门创建，异常信息为:", e);
|
}
|
}
|
|
public static void main(String[] args) {
|
JSONObject jsonObject = JSONObject.parseObject("{\"errcode\":0,\"role\":{\"groupId\":2907093702,\"name\":\"角色222\"},\"errmsg\":\"ok\",\"request_id\":\"16mni2qt143fv\"}");
|
Map<String, Object> roleMap = (Map) jsonObject.get("role");
|
System.out.println(roleMap.get("groupId"));
|
}
|
|
private void deptModify(JSONObject eventJson, String appKey, String appSecret) {
|
try {
|
List<String> deptIds = eventJson.getJSONArray("DeptId").toJavaList(String.class);
|
this.commonGroupMapper.removeOrgByIds(deptIds);
|
this.commonGroupOfItemService.remove(Wrappers.<CommonGroupOfItem>lambdaQuery().in(CommonGroupOfItem::getGroupId, deptIds).eq(CommonGroupOfItem::getGroupType, CommonGroupTypeEnum.ORGANIZATION.getName()));
|
/*
|
this.commonGroupOfItemService.remove((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getGroupId();
|
}, deptIds)).eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.ORGANIZATION.getName()));*/
|
for (String deptId : deptIds) {
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/get");
|
OapiV2DepartmentGetRequest req = new OapiV2DepartmentGetRequest();
|
req.setDeptId(Long.valueOf(deptId));
|
OapiV2DepartmentGetResponse rsp = defaultDingTalkClient.execute(req, getDingAccessToken(appKey, appSecret));
|
JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
|
if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
|
Map<String, Object> deptMap = (Map) jsonObject.get("result");
|
Long parentId = Long.valueOf(String.valueOf(deptMap.get("parent_id")));
|
this.groupService.insert(CommonGroup.builder().groupCategory(1).groupType(DingConstant.GROUPTYPE).parentId(Long.valueOf(parentId.equals(1L) ? 3L : parentId.longValue())).name(String.valueOf(deptMap.get("name"))).status(1).id(Long.valueOf(deptId)).build());
|
}
|
}
|
} catch (Exception e) {
|
log.error("通讯录企业部门创建，异常信息为:", e);
|
}
|
}
|
|
private void deptRemove(JSONObject eventJson) {
|
try {
|
List<String> deptIds = eventJson.getJSONArray("DeptId").toJavaList(String.class);
|
this.commonGroupMapper.removeOrgByIds(deptIds);
|
this.commonGroupOfItemService.remove(Wrappers.<CommonGroupOfItem>lambdaQuery().in(CommonGroupOfItem::getGroupId, deptIds)
|
.eq(CommonGroupOfItem::getGroupType, CommonGroupTypeEnum.ORGANIZATION.getName()));
|
/*
|
this.commonGroupOfItemService.remove((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getGroupId();
|
}, deptIds)).eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.ORGANIZATION.getName()));*/
|
} catch (Exception e) {
|
log.error("通讯录用户离职，异常信息为:", e);
|
}
|
}
|
|
private void labelUserChange(JSONObject eventJson, String appKey, String appSecret) {
|
try {
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
|
OapiV2UserGetRequest req = new OapiV2UserGetRequest();
|
List<String> userIdList = eventJson.getJSONArray("UserIdList").toJavaList(String.class);
|
List<Employee> employeesUpdate = new ArrayList<>();
|
List<EmployeePost> employeePostsNew = new ArrayList<>();
|
for (String id : userIdList) {
|
req.setUserid(id);
|
OapiV2UserGetResponse rsp = defaultDingTalkClient.execute(req, getDingAccessToken(appKey, appSecret));
|
JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
|
if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
|
JSONObject userObject = jsonObject.getJSONObject("result");
|
Employee employee = (Employee)this.employeeService.getOne(Wrappers.<Employee>lambdaQuery().eq(Employee::getTel, userObject.getString("mobile")), false);
|
/*
|
Employee employee = (Employee) this.employeeService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getTel();
|
}, userObject.getString("mobile")), false);*/
|
JSONArray roleList = userObject.getJSONArray("role_list");
|
if (Func.isNotEmpty(roleList)) {
|
List<DingUserInnerRole> innerRoles = roleList.toJavaList(DingUserInnerRole.class);
|
String postStr = (String) innerRoles.stream().map(o -> {
|
return String.valueOf(o.getId());
|
}).collect(Collectors.joining(","));
|
employee.setPostId(postStr);
|
employeesUpdate.add(employee);
|
for (DingUserInnerRole role : innerRoles) {
|
EmployeePost employeePost = new EmployeePost();
|
employeePost.setEmployeeId(employee.getId());
|
employeePost.setPostId(role.getId());
|
employeePostsNew.add(employeePost);
|
}
|
}
|
}
|
}
|
this.employeePostService.remove(Wrappers.<EmployeePost>lambdaQuery().in(EmployeePost::getEmployeeId, userIdList));
|
/*
|
this.employeePostService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getEmployeeId();
|
}, userIdList));*/
|
if (Func.isNotEmpty(employeesUpdate)) {
|
this.employeeService.updateBatchById(employeesUpdate);
|
}
|
if (Func.isNotEmpty(employeePostsNew)) {
|
this.employeePostService.saveBatch(employeePostsNew);
|
}
|
} catch (Exception e) {
|
log.error("员工角色信息发生变更，异常信息为:", e);
|
}
|
}
|
|
private void labelAdd(JSONObject eventJson, String appKey, String appSecret) {
|
try {
|
List<String> roleIds = eventJson.getJSONArray("LabelIdList").toJavaList(String.class);
|
List<Post> postList = new ArrayList<>();
|
for (String roleId : roleIds) {
|
getRoleDetail(roleId, postList, appKey, appSecret);
|
}
|
this.postService.saveBatch(postList);
|
} catch (Exception e) {
|
log.error("增加角色或者角色组，异常信息为:", e);
|
}
|
}
|
|
private void lableModify(JSONObject eventJson, String appKey, String appSecret) {
|
try {
|
List<String> roleIds = eventJson.getJSONArray("LabelIdList").toJavaList(String.class);
|
List<Post> postList = new ArrayList<>();
|
for (String roleId : roleIds) {
|
getRoleDetail(roleId, postList, appKey, appSecret);
|
}
|
this.postService.updateBatchById(postList);
|
} catch (Exception e) {
|
log.error("修改角色或者角色组，异常信息为:", e);
|
}
|
}
|
|
private void getRoleDetail(String roleId, List<Post> postList, String appKey, String appSecret) throws Exception {
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/role/getrole");
|
OapiRoleGetroleRequest req = new OapiRoleGetroleRequest();
|
req.setRoleId(Long.valueOf(roleId));
|
OapiRoleGetroleResponse rsp = defaultDingTalkClient.execute(req, getDingAccessToken(appKey, appSecret));
|
JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
|
if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS) && Func.isNotEmpty(jsonObject.get("role"))) {
|
Map<String, Object> roleMap = (Map) jsonObject.get("role");
|
if (!DncConstant.DNC_DEFAULT_PARENT_ID.equals(String.valueOf(roleMap.get("groupId")))) {
|
Post post = new Post();
|
post.setPostCode(roleId);
|
post.setId(Long.valueOf(roleId));
|
post.setPostName(String.valueOf(roleMap.get("name")));
|
post.setStatus(CommonConstant.ENABLE);
|
postList.add(post);
|
}
|
}
|
}
|
|
private void lableDel(JSONObject eventJson) {
|
try {
|
List<String> roleIds = eventJson.getJSONArray("LabelIdList").toJavaList(String.class);
|
this.postMapper.removePostByIds(roleIds);
|
this.employeePostService.remove(Wrappers.<EmployeePost>lambdaQuery().in(EmployeePost::getPostId, roleIds));
|
/*
|
this.employeePostService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getPostId();
|
}, roleIds));*/
|
} catch (Exception e) {
|
log.error("删除角色或者角色组，异常信息为:", e);
|
}
|
}
|
|
@Override // org.springblade.modules.sync.service.IDingEventService
|
public String getDingAccessToken(String appKey, String appSecret) throws Exception {
|
String cacheToken = (String) this.bladeRedis.get(DingConstant.DING_ACCESSTOKEN_REDIS_CACHE);
|
if (Func.isNotEmpty(cacheToken)) {
|
return cacheToken;
|
}
|
DefaultDingTalkClient defaultDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
|
OapiGettokenRequest req = new OapiGettokenRequest();
|
req.setAppkey(appKey);
|
req.setAppsecret(appSecret);
|
req.setHttpMethod("GET");
|
OapiGettokenResponse rsp = defaultDingTalkClient.execute(req);
|
JSONObject jsonObject = JSONObject.parseObject(rsp.getBody());
|
if (jsonObject.getInteger(QyWechatConstant.ERROR_CODE_KEY).equals(DingConstant.SUCCESS)) {
|
this.bladeRedis.setEx(DingConstant.DING_ACCESSTOKEN_REDIS_CACHE, String.valueOf(jsonObject.get("access_token")), Duration.ofHours(2L));
|
return String.valueOf(jsonObject.get("access_token"));
|
}
|
log.error("获取钉钉应用accessToken异常，结果为：" + jsonObject);
|
return null;
|
}
|
}
|
