package jnpf.base.controller;
|
|
import cn.dev33.satoken.annotation.SaCheckPermission;
|
import cn.dev33.satoken.annotation.SaMode;
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import com.dingtalk.api.response.OapiV2DepartmentListsubResponse;
|
import com.dingtalk.api.response.OapiV2UserListResponse;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.Parameters;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import jakarta.validation.Valid;
|
import jnpf.base.ActionResult;
|
import jnpf.base.SynThirdInfoApi;
|
import jnpf.base.SysConfigApi;
|
import jnpf.base.UserInfo;
|
import jnpf.base.entity.SuperBaseEntity;
|
import jnpf.base.entity.SynThirdInfoEntity;
|
import jnpf.base.entity.SysConfigEntity;
|
import jnpf.base.model.synthirdinfo.*;
|
import jnpf.base.service.SynThirdDingTalkService;
|
import jnpf.base.service.SynThirdInfoService;
|
import jnpf.base.service.SynThirdQyService;
|
import jnpf.base.util.SynDingTalkUtil;
|
import jnpf.base.util.SynQyWebChatUtil;
|
import jnpf.base.vo.PaginationVO;
|
import jnpf.config.ConfigValueUtil;
|
import jnpf.constant.MsgCode;
|
import jnpf.database.util.TenantDataSourceUtil;
|
import jnpf.exception.DataException;
|
import jnpf.exception.WxErrorException;
|
import jnpf.message.SentMessageApi;
|
import jnpf.message.model.SynThirdInfoVo;
|
import jnpf.message.uitl.SynThirdConsts;
|
import jnpf.model.SocialsSysConfig;
|
import jnpf.permission.OrganizeApi;
|
import jnpf.permission.UserApi;
|
import jnpf.permission.entity.OrganizeEntity;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.permission.model.*;
|
import jnpf.permission.model.organize.OrganizeListVO;
|
import jnpf.permission.model.organize.OrganizeModel;
|
import jnpf.util.*;
|
import jnpf.util.treeutil.SumTree;
|
import jnpf.util.treeutil.newtreeutil.TreeDotUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.text.ParseException;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
import static jnpf.constant.JnpfConst.*;
|
|
/**
|
* 第三方工具的公司-部门-用户同步表模型
|
*
|
* @版本： V3.1.0
|
* @版权： 引迈信息技术有限公司（https://www.jnpfsoft.com）
|
* @作者： JNPF开发平台组
|
* @日期： 2021/4/25 9:30
|
*/
|
@Tag(name = "第三方信息同步", description = "SynThirdInfo")
|
@RestController
|
@RequestMapping("/SynThirdInfo")
|
@Slf4j
|
public class SynThirdInfoController extends SuperController<SynThirdInfoService, SynThirdInfoEntity> implements SynThirdInfoApi {
|
|
|
@Autowired
|
private SynThirdInfoService synThirdInfoService;
|
@Autowired
|
private SynThirdQyService synThirdQyService;
|
@Autowired
|
private SynThirdDingTalkService synThirdDingTalkService;
|
@Autowired
|
private OrganizeApi organizeApi;
|
@Autowired
|
private UserApi userApi;
|
@Autowired
|
private ConfigValueUtil configValueUtil;
|
@Autowired
|
private RedisUtil redisUtil;
|
@Autowired
|
private SentMessageApi sentMessageApi;
|
@Autowired
|
private CacheKeyUtil cacheKeyUtil;
|
@Autowired
|
private SysConfigApi sysConfigApi;
|
|
|
/**
|
* 新增同步表信息
|
*
|
* @param synThirdInfoCrForm 同步信息模型
|
* @return
|
*/
|
@Operation(summary = "新增同步表信息")
|
@Parameters({
|
@Parameter(name = "synThirdInfoCrForm", description = "同步信息模型", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@PostMapping
|
@Transactional
|
public ActionResult create(@RequestBody @Valid SynThirdInfoCrForm synThirdInfoCrForm) throws DataException {
|
UserInfo userInfo = UserProvider.getUser();
|
SynThirdInfoEntity entity = JsonUtil.getJsonToBean(synThirdInfoCrForm, SynThirdInfoEntity.class);
|
entity.setCreatorUserId(userInfo.getUserId());
|
entity.setCreatorTime(DateUtil.getNowDate());
|
entity.setId(RandomUtil.uuId());
|
synThirdInfoService.create(entity);
|
return ActionResult.success(MsgCode.SU001.get());
|
}
|
|
/**
|
* 获取同步表信息
|
*
|
* @param id 主键
|
* @return
|
*/
|
@Operation(summary = "获取同步表信息")
|
@Parameters({
|
@Parameter(name = "id", description = "主键", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/{id}")
|
public SynThirdInfoEntity getInfo(@PathVariable("id") String id) {
|
SynThirdInfoEntity entity = synThirdInfoService.getInfo(id);
|
return entity;
|
}
|
|
/**
|
* 获取指定类型的同步对象
|
*
|
* @param thirdType 1:企业微信 2:钉钉
|
* @param dataType 1:公司 2:部门 3：用户
|
* @param id dataType对应的对象ID
|
* @return
|
*/
|
@Override
|
@NoDataSourceBind
|
@GetMapping("/getInfoBySysObjId/{thirdType}/{dataType}/{id}")
|
public SynThirdInfoEntity getInfoBySysObjId(@PathVariable("thirdType") String thirdType, @PathVariable("dataType") String dataType, @PathVariable("id") String id, @RequestParam("tenantId") String tenantId) {
|
if (configValueUtil.isMultiTenancy()) {
|
TenantDataSourceUtil.switchTenant(tenantId);
|
}
|
SynThirdInfoEntity entity = synThirdInfoService.getInfoBySysObjId(thirdType, dataType, id);
|
return entity;
|
}
|
|
|
/**
|
* 更新同步表信息
|
*
|
* @param id 主键
|
* @param synThirdInfoUpForm 同步模型
|
* @return
|
*/
|
@Operation(summary = "更新同步表信息")
|
@Parameters({
|
@Parameter(name = "id", description = "主键", required = true),
|
@Parameter(name = "synThirdInfoUpForm", description = "同步模型", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@PutMapping("/{id}")
|
@Transactional
|
public ActionResult update(@PathVariable("id") String id, @RequestBody @Valid SynThirdInfoUpForm synThirdInfoUpForm) throws DataException {
|
SynThirdInfoEntity entity = synThirdInfoService.getInfo(id);
|
UserInfo userInfo = UserProvider.getUser();
|
if (entity != null) {
|
SynThirdInfoEntity entityUpd = JsonUtil.getJsonToBean(synThirdInfoUpForm, SynThirdInfoEntity.class);
|
entityUpd.setCreatorUserId(entity.getCreatorUserId());
|
entityUpd.setCreatorTime(entity.getCreatorTime());
|
entityUpd.setLastModifyUserId(userInfo.getUserId());
|
entityUpd.setLastModifyTime(DateUtil.getNowDate());
|
synThirdInfoService.update(id, entityUpd);
|
|
return ActionResult.success(MsgCode.SU004.get());
|
} else {
|
return ActionResult.fail(MsgCode.FA002.get());
|
}
|
}
|
|
|
/**
|
* 删除同步表信息
|
*
|
* @param id
|
* @return
|
*/
|
@Operation(summary = "删除同步表信息")
|
@Parameters({
|
@Parameter(name = "id", description = "主键", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@DeleteMapping("/{id}")
|
@Transactional
|
public ActionResult delete(@PathVariable("id") String id) {
|
SynThirdInfoEntity entity = synThirdInfoService.getInfo(id);
|
if (entity != null) {
|
synThirdInfoService.delete(entity);
|
}
|
return ActionResult.success(MsgCode.SU003.get());
|
}
|
|
|
/**
|
* 获取第三方(如：企业微信、钉钉)的组织与用户同步统计信息
|
*
|
* @param thirdType 第三方类型(1:企业微信;2:钉钉)
|
* @return
|
*/
|
@Operation(summary = "获取第三方(如：企业微信、钉钉)的组织与用户同步统计信息")
|
@Parameters({
|
@Parameter(name = "thirdType", description = "第三方类型(1:企业微信;2:钉钉)", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/getSynThirdTotal/{thirdType}")
|
public ActionResult<List<SynThirdTotal>> getSynThirdTotal(@PathVariable("thirdType") String thirdType) {
|
List<SynThirdTotal> synTotalList = new ArrayList<>();
|
synTotalList.add(synThirdInfoService.getSynTotal(thirdType, SynThirdConsts.DATA_TYPE_ORG));
|
synTotalList.add(synThirdInfoService.getSynTotal(thirdType, SynThirdConsts.DATA_TYPE_USER));
|
return ActionResult.success(synTotalList);
|
}
|
|
/**
|
* 获取第三方(如：企业微信、钉钉)的组织或用户同步统计信息
|
*
|
* @param thirdType 第三方类型(1:企业微信;2:钉钉)
|
* @param dataType 数据类型(1:组织(公司与部门);2:用户)
|
* @return
|
*/
|
@Operation(summary = "获取第三方(如：企业微信、钉钉)的组织或用户同步统计信息")
|
@Parameters({
|
@Parameter(name = "thirdType", description = "第三方类型(1:企业微信;2:钉钉)", required = true),
|
@Parameter(name = "dataType", description = "数据类型(1:组织(公司与部门);2:用户)", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/getSynThirdTotal/{thirdType}/{dataType}")
|
public SynThirdTotal getSynThirdTotal(@PathVariable("thirdType") String thirdType, @PathVariable("dataType") String dataType) {
|
SynThirdTotal synThirdTotal = synThirdInfoService.getSynTotal(thirdType, dataType);
|
return synThirdTotal;
|
}
|
|
|
|
private Boolean saveConfig(String departmentId, String dingDepartment, String department) {
|
if (StringUtil.isNotEmpty(departmentId) && !departmentId.equals(dingDepartment)) {
|
List<SysConfigEntity> list = sysConfigApi.getList(department);
|
|
if (CollectionUtil.isEmpty(list)) {
|
SysConfigEntity sysConfigEntity = new SysConfigEntity();
|
sysConfigEntity.setCategory(SOCIALS_CONFIG);
|
sysConfigEntity.setFkey(department);
|
sysConfigEntity.setValue(departmentId);
|
sysConfigApi.create(sysConfigEntity);
|
|
}else {
|
SysConfigEntity configEntity = list.get(0);
|
configEntity.setValue(departmentId);
|
sysConfigApi.updateById(configEntity);
|
}
|
String cacheKey = cacheKeyUtil.getSocialsConfig();
|
redisUtil.remove(cacheKey);
|
return true;
|
}
|
return false;
|
}
|
|
/**
|
* 本地所有组织信息(包含公司和部门)同步到企业微信
|
* 不带第三方错误定位判断的功能代码,只获取调用接口的返回信息 20210604
|
*
|
* @param type 类型
|
* @return ignore
|
* @throws WxErrorException ignore
|
*/
|
@Operation(summary = "本地所有组织信息(包含公司和部门)同步到企业微信")
|
@Parameters({
|
@Parameter(name = "type", description = "类型", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/synAllOrganizeSysToQy")
|
public ActionResult synAllOrganizeSysToQy(@RequestParam("type") String type
|
, @RequestParam("departmentId") String departmentId) throws WxErrorException {
|
if (StringUtils.isEmpty(departmentId)) {
|
return ActionResult.fail(MsgCode.FA057.get());
|
}
|
SocialsSysConfig config = sysConfigApi.getSocialsConfig();
|
String qyhDepartment = config.getQyhDepartment();
|
Boolean isDepartChange = saveConfig(departmentId, qyhDepartment, QYH_DEPARTMENT);
|
if (isDepartChange){
|
qyhDepartment=departmentId;
|
}
|
if ("1".equals(type)) {
|
//类型为1走企业微信组织信息同步到本地
|
return this.synAllOrganizeQyToSys(qyhDepartment);
|
}
|
|
JSONObject retMsg = new JSONObject();
|
String corpId = config.getQyhCorpId();
|
// 向企业微信插入数据需要另外token（凭证密钥）
|
String corpSecret = config.getQyhAgentSecret();
|
|
if (StringUtil.isEmpty(qyhDepartment)) {
|
return ActionResult.fail("同步组织配置未保存");
|
}
|
String access_token = "";
|
try {
|
// 获取Token值
|
JSONObject tokenObject = SynQyWebChatUtil.getAccessToken(corpId, corpSecret);
|
if (!tokenObject.getBoolean("code")) {
|
return ActionResult.fail(MsgCode.SYS025.get());
|
}
|
access_token = tokenObject.getString("access_token");
|
// 获取同步表、部门表的信息
|
List<SynThirdInfoEntity> synThirdInfoList = synThirdInfoService.getList(SynThirdConsts.THIRD_TYPE_QY, SynThirdConsts.DATA_TYPE_ORG);
|
List<OrganizeEntity> organizeEntitiesBind = synThirdInfoService.getOrganizeEntitiesBind(qyhDepartment);
|
List<String> collect = organizeEntitiesBind.stream()
|
.map(SuperBaseEntity.SuperIBaseEntity::getId)
|
.distinct()
|
.collect(Collectors.toList());
|
List<SynThirdInfoEntity> collected = synThirdInfoList.stream()
|
.filter(t -> !collect.contains(t.getSysObjId()))
|
.collect(Collectors.toList());
|
synThirdInfoList.removeAll(collected);
|
// 根据公司表、同步表进行比较，决定执行创建、还是更新
|
for (OrganizeEntity organizeEntity : organizeEntitiesBind) {
|
if (synThirdInfoList.stream().anyMatch(t -> t.getSysObjId().equals(organizeEntity.getId()))) {
|
// 执行更新功能,token取应用密钥
|
retMsg = synThirdQyService.updateDepartmentSysToQy(true, organizeEntity, access_token);
|
} else {
|
// 执行创建功能,token取应用密钥
|
retMsg = synThirdQyService.createDepartmentSysToQy(true, organizeEntity, access_token);
|
}
|
}
|
} catch (Exception e) {
|
ActionResult.fail(e.toString());
|
}
|
//获取结果
|
SynThirdTotal synThirdTotal = synThirdInfoService.getSynTotal(SynThirdConsts.THIRD_TYPE_QY, SynThirdConsts.DATA_TYPE_ORG);
|
return ActionResult.success(synThirdTotal);
|
}
|
|
|
/**
|
* 本地所有用户信息同步到企业微信
|
* 不带第三方错误定位判断的功能代码,只获取调用接口的返回信息 20210604
|
*
|
* @param type 类型
|
* @return ignore
|
* @throws WxErrorException ignore
|
*/
|
@Operation(summary = "本地所有用户信息同步到企业微信")
|
@Parameters({
|
@Parameter(name = "type", description = "类型", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/synAllUserSysToQy")
|
public ActionResult synAllUserSysToQy(@RequestParam("type") String type) throws WxErrorException {
|
if ("1".equals(type)) {
|
//类型为1走企业微信用户同步到本地
|
return this.synAllUserQyToSys();
|
}
|
JSONObject retMsg = new JSONObject();
|
SocialsSysConfig config = sysConfigApi.getSocialsConfig();
|
|
String corpToken = "";
|
|
try {
|
String corpId = config.getQyhCorpId();
|
// 向企业微信插入数据需要另外token（凭证密钥）
|
String corpSecret = config.getQyhCorpSecret();
|
// 获取Token值
|
JSONObject tokenObject = SynQyWebChatUtil.getAccessToken(corpId, corpSecret);
|
if (!tokenObject.getBoolean("code")) {
|
return ActionResult.fail(MsgCode.SYS025.get());
|
}
|
corpToken = tokenObject.getString("access_token");
|
|
// 获取同步表、用户表的信息
|
List<SynThirdInfoEntity> synThirdInfoList = synThirdInfoService
|
.getList(SynThirdConsts.THIRD_TYPE_QY, SynThirdConsts.DATA_TYPE_USER);
|
List<OrganizeEntity> organizeEntitiesBind = synThirdInfoService
|
.getOrganizeEntitiesBind(config.getQyhDepartment());
|
List<UserEntity> userEntities = userApi.getListByOrgIds(organizeEntitiesBind.stream()
|
.map(SuperBaseEntity.SuperIBaseEntity::getId).collect(Collectors.toList()));
|
|
|
// 根据公司表、同步表进行比较，决定执行创建、还是更新
|
String needToken=this.getAgentAccessToken();
|
for (UserEntity userEntity : userEntities) {
|
if (synThirdInfoList.stream().noneMatch(t -> t.getSysObjId().equals(userEntity.getId()))) {
|
// 执行创建功能
|
retMsg = synThirdQyService.createUserSysToQy(true, userEntity, needToken);
|
} else {
|
// 执行更新功能
|
retMsg = synThirdQyService.updateUserSysToQy(true, userEntity, needToken,corpToken);
|
}
|
}
|
} catch (Exception e) {
|
ActionResult.fail(e.toString());
|
}
|
|
//获取结果
|
SynThirdTotal synThirdTotal = synThirdInfoService.getSynTotal(SynThirdConsts.THIRD_TYPE_QY, SynThirdConsts.DATA_TYPE_USER);
|
return ActionResult.success(synThirdTotal);
|
}
|
private String getAgentAccessToken() {
|
SocialsSysConfig socialsConfig = sysConfigApi.getSocialsConfig();
|
String corpId = socialsConfig.getQyhCorpId();
|
String corpSecret = socialsConfig.getQyhAgentSecret();
|
JSONObject tokenObject = SynQyWebChatUtil.getAccessToken(corpId, corpSecret);
|
return tokenObject.getString("access_token");
|
}
|
|
/**
|
* 本地所有组织信息(包含公司和部门)同步到钉钉
|
* 不带第三方错误定位判断的功能代码 20210604
|
*
|
* @param type 类型
|
* @return ignore
|
*/
|
@Operation(summary = "本地所有组织信息(包含公司和部门)同步到钉钉")
|
@Parameters({
|
@Parameter(name = "type", description = "类型", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/synAllOrganizeSysToDing")
|
public ActionResult synAllOrganizeSysToDing(@RequestParam("type") String type
|
,@RequestParam("departmentId") String departmentId) {
|
if (StringUtils.isEmpty(departmentId)) {
|
return ActionResult.fail(MsgCode.FA057.get());
|
}
|
SocialsSysConfig config = sysConfigApi.getSocialsConfig();
|
String dingDepartment = config.getDingDepartment();
|
Boolean isDepartChange = saveConfig(departmentId, dingDepartment, DING_DEPARTMENT);
|
if (isDepartChange){
|
dingDepartment=departmentId;
|
}
|
if ("1".equals(type)) {
|
//类型为1走钉钉组织部门信息同步到本地
|
return this.synAllOrganizeDingToSys(dingDepartment);
|
}
|
JSONObject retMsg = new JSONObject();
|
//获取配置
|
|
String corpId = config.getDingSynAppKey();
|
String corpSecret = config.getDingSynAppSecret();
|
|
if (StringUtil.isEmpty(dingDepartment)) {
|
return ActionResult.fail("同步组织配置未保存");
|
}
|
// 获取Token值
|
JSONObject tokenObject = SynDingTalkUtil.getAccessToken(corpId, corpSecret);
|
if (!tokenObject.getBoolean("code")) {
|
return ActionResult.fail(MsgCode.SYS053.get());
|
}
|
String access_token = tokenObject.getString("access_token");
|
//获取绑定部门的下级有序组织
|
List<OrganizeEntity> listByOrder = synThirdInfoService.getOrganizeEntitiesBind(dingDepartment);
|
|
try {
|
|
List<SynThirdInfoEntity> synThirdInfoList = synThirdInfoService.getList(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_ORG);
|
List<String> collect = listByOrder.stream()
|
.map(SuperBaseEntity.SuperIBaseEntity::getId)
|
.distinct()
|
.collect(Collectors.toList());
|
//筛选同步表有，但是公司表没有的数据
|
List<SynThirdInfoEntity> collected = synThirdInfoList.stream()
|
.filter(t -> !collect.contains(t.getSysObjId()))
|
.collect(Collectors.toList());
|
if (CollectionUtil.isNotEmpty(collected)) {
|
for (SynThirdInfoEntity synThirdInfoEntity : collected) {
|
//如果系统中组织不存在同步表，那将钉钉上的数据也删除
|
retMsg = synThirdDingTalkService.deleteDepartmentSysToDing(true, synThirdInfoEntity.getId(), access_token);
|
}
|
}
|
synThirdInfoList.removeAll(collected);
|
|
|
// 根据公司表、同步表进行比较，决定执行创建、还是更新
|
for (OrganizeEntity organizeEntity : listByOrder) {
|
if (synThirdInfoList.stream().anyMatch(t -> t.getSysObjId().equals(organizeEntity.getId()))) {
|
// 执行更新功能
|
retMsg = synThirdDingTalkService.updateDepartmentSysToDing(true, organizeEntity, access_token);
|
} else {
|
// 执行创建功能
|
retMsg = synThirdDingTalkService.createDepartmentSysToDing(true, organizeEntity, access_token);
|
}
|
}
|
} catch (Exception e) {
|
ActionResult.fail(e.toString());
|
}
|
|
//获取结果
|
SynThirdTotal synThirdTotal = synThirdInfoService.getSynTotal(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_ORG);
|
return ActionResult.success(synThirdTotal);
|
}
|
|
|
/**
|
* 本地所有用户信息同步到钉钉
|
* 不带第三方错误定位判断的功能代码 20210604
|
*
|
* @param type 类型
|
* @return ignore
|
*/
|
@Operation(summary = "本地所有用户信息同步到钉钉")
|
@Parameters({
|
@Parameter(name = "type", description = "类型", required = true)
|
})
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/synAllUserSysToDing")
|
public ActionResult synAllUserSysToDing(@RequestParam("type") String type) throws ParseException {
|
if ("1".equals(type)) {
|
//类型为1走钉钉用户信息同步到本地
|
return this.synAllUserDingToSys();
|
}
|
JSONObject retMsg = new JSONObject();
|
SocialsSysConfig config = sysConfigApi.getSocialsConfig();
|
String corpId = config.getDingSynAppKey();
|
String corpSecret = config.getDingSynAppSecret();
|
String dingDepartment = config.getDingDepartment();
|
|
try {
|
// 获取Token值
|
JSONObject tokenObject = SynDingTalkUtil.getAccessToken(corpId, corpSecret);
|
if (!tokenObject.getBoolean("code")) {
|
return ActionResult.success(MsgCode.SYS053.get());
|
}
|
String access_token = tokenObject.getString("access_token");
|
// 获取同步表、用户表的信息
|
List<SynThirdInfoEntity> synThirdInfoList = synThirdInfoService.getList(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_USER);
|
List<OrganizeEntity> organizeEntitiesBind = synThirdInfoService.getOrganizeEntitiesBind(dingDepartment);
|
|
List<UserEntity> userEntities = userApi.getListByOrgIds(organizeEntitiesBind.stream()
|
.map(SuperBaseEntity.SuperIBaseEntity::getId).collect(Collectors.toList()));
|
// 根据同步表、公司表进行比较，判断不存的执行删除
|
for (SynThirdInfoEntity synThirdInfoEntity : synThirdInfoList) {
|
if (userEntities.stream().noneMatch(t -> t.getId().equals(synThirdInfoEntity.getSysObjId()))) {
|
// 执行删除操作
|
retMsg = synThirdDingTalkService.deleteUserSysToDing(true, synThirdInfoEntity.getSysObjId(), access_token);
|
}
|
}
|
// ||synThirdInfoList.stream()
|
// .filter(t->t.getSysObjId().equals(userEntity.getId()))
|
// .collect(Collectors.toList())
|
// .get(0).getDescription().contains("40103")
|
// 根据公司表、同步表进行比较，决定执行创建、还是更新
|
for (UserEntity userEntity : userEntities) {
|
if (synThirdInfoList.stream()
|
.noneMatch(t -> t.getSysObjId().equals(userEntity.getId()))
|
) {
|
// 执行创建功能
|
retMsg = synThirdDingTalkService.createUserSysToDing(true, userEntity, access_token);
|
} else {
|
// 执行更新功能
|
retMsg = synThirdDingTalkService.updateUserSysToDing(true, userEntity, access_token);
|
}
|
}
|
} catch (Exception e) {
|
ActionResult.fail(e.toString());
|
}
|
|
//获取结果
|
SynThirdTotal synThirdTotal = synThirdInfoService.getSynTotal(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_USER);
|
return ActionResult.success(synThirdTotal);
|
}
|
|
//==================================钉钉的公司-部门-用户批量同步到本系统20220330==================================
|
|
/**
|
* 钉钉所有组织信息(包含公司和部门)同步到本系统
|
* 不带第三方错误定位判断的功能代码 20220330
|
*
|
* @return ignore
|
*/
|
@Operation(summary = "钉钉所有组织信息(包含公司和部门)同步到本系统")
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/synAllOrganizeDingToSys")
|
public ActionResult synAllOrganizeDingToSys(@RequestParam("departmentId") String departmentId) {
|
// 设置redis的key
|
String synDing = "";
|
UserInfo userInfo = UserProvider.getUser();
|
if (configValueUtil.isMultiTenancy()) {
|
synDing = userInfo.getTenantId() + "_" + userInfo.getUserId() + "_synAllOrganizeDingToSys";
|
} else {
|
synDing = userInfo.getUserId() + "_synAllOrganizeDingToSys";
|
}
|
// 如果redis中存在key说明同步正在进行
|
if (redisUtil.exists(synDing)) {
|
return ActionResult.fail(MsgCode.SYS026.get());
|
}
|
SocialsSysConfig config = sysConfigApi.getSocialsConfig();
|
if (StringUtil.isEmpty(departmentId)) {
|
return ActionResult.fail("同步组织配置未保存");
|
}
|
OrganizeEntity info = organizeApi.getInfoById(departmentId);
|
if (info == null) {
|
return ActionResult.fail("同步组织数据不存在");
|
}
|
// 获取Token值
|
JSONObject tokenObject = SynDingTalkUtil.getAccessToken(config.getDingSynAppKey(), config.getDingSynAppSecret());
|
if (!tokenObject.getBoolean("code")) {
|
return ActionResult.fail(MsgCode.SYS053.get());
|
}
|
|
// 异步执行
|
String finalSynDing = synDing;
|
ThreadPoolExecutorUtil.getExecutor().execute(() -> {
|
String userId = userInfo.getUserId();
|
String messText = "同步完成";
|
try {
|
redisUtil.insert(finalSynDing, "true");
|
|
List<OapiV2DepartmentListsubResponse.DeptBaseResponse> DingDeptList = new ArrayList<>();
|
|
String access_token = tokenObject.getString("access_token");
|
// 获取钉钉上的部门列表
|
JSONObject retMsg = SynDingTalkUtil.getDepartmentList(SynThirdConsts.DING_ROOT_DEPT_ID, access_token);
|
if (!retMsg.getBoolean("code")) {
|
throw new DataException(retMsg.getString("msg"));
|
}
|
DingDeptList = (List<OapiV2DepartmentListsubResponse.DeptBaseResponse>) retMsg.get("department");
|
List<DingTalkDeptModel> dingDeptListVo = JsonUtil.getJsonToList(DingDeptList, DingTalkDeptModel.class);
|
List<DingTalkDeptModel> DingDeptAllList = new ArrayList<>(dingDeptListVo);
|
|
Map<String, DingTalkDeptModel> deptModelMap = DingDeptAllList.stream().collect(Collectors.toMap(t -> String.valueOf(t.getDeptId()), dept -> dept));
|
// 部门进行树结构化,固化上下层级序列化
|
List<OrganizeModel> organizeModelList = DingDeptAllList.stream().map(t -> {
|
OrganizeModel model = JsonUtil.getJsonToBean(t, OrganizeModel.class);
|
model.setFullName(t.getName());
|
model.setCategory(t.getSourceIdentifier());
|
model.setParentId(t.getParentId() + "");
|
model.setDeptId(t.getDeptId() + "");
|
model.setId(t.getDeptId() + "");
|
model.setParentId(t.getParentId() + "");
|
return model;
|
}).collect(Collectors.toList());
|
List<SumTree<OrganizeModel>> trees = TreeDotUtils.convertListToTreeDot(organizeModelList);
|
List<OrganizeListVO> listVO = JsonUtil.getJsonToList(trees, OrganizeListVO.class);
|
|
// 转化成为按上下层级顺序排序的列表数据
|
List<DingTalkDeptModel> listByOrder = new ArrayList<>();
|
for (OrganizeListVO organizeVo : listVO) {
|
DingTalkDeptModel entity = deptModelMap.get(organizeVo.getId());
|
listByOrder.add(entity);
|
SynDingTalkUtil.getOrganizeTreeToList(organizeVo, deptModelMap, listByOrder);
|
}
|
|
// 钉钉没有最高级得先插入一条最高级
|
synThirdInfoService.initBaseDept(SynThirdConsts.DING_ROOT_DEPT_ID, access_token, SynThirdConsts.THIRD_TYPE_DING);
|
// 获取同步表的信息
|
List<SynThirdInfoEntity> synThirdInfoList = synThirdInfoService.getListByDepartment(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_ORG,departmentId);
|
// List<SynThirdInfoEntity> synThirdInfoListAll = synThirdInfoService.getList(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_ORG);
|
// // 根据同步表、公司表进行比较，判断不存的执行删除
|
// synThirdInfoListAll.removeAll(synThirdInfoList);
|
// for (SynThirdInfoEntity synThirdInfoEntity : synThirdInfoListAll) {
|
// synThirdInfoService.delete(synThirdInfoEntity);
|
// }
|
|
// // 删除后需要重新获取数据
|
// synThirdInfoList = synThirdInfoService.getList(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_ORG);
|
List<String> sysDeptIds = synThirdInfoList.stream().map(SynThirdInfoEntity::getThirdObjId).collect(Collectors.toList());
|
|
// 根据公司表、同步表进行比较，决定执行创建、还是更新
|
for (DingTalkDeptModel dingDeptEntity : listByOrder) {
|
if (sysDeptIds.contains(String.valueOf(dingDeptEntity.getDeptId()))) {
|
// 执行本地更新功能
|
synThirdDingTalkService.updateDepartmentDingToSys(true, dingDeptEntity, access_token);
|
} else {
|
// 执行本的创建功能
|
synThirdDingTalkService.createDepartmentDingToSys(true, dingDeptEntity, access_token);
|
}
|
}
|
} catch (Exception e) {
|
messText = e.getMessage();
|
log.error("{}，钉钉所有组织信息同步到本系统失败：{}", finalSynDing, e.getMessage());
|
} finally {
|
redisUtil.remove(finalSynDing);
|
redisUtil.remove(cacheKeyUtil.getOrganizeList());
|
List<String> toUserId = new ArrayList<>(1);
|
toUserId.add(userId);
|
sentMessageApi.sentMessage(toUserId, "钉钉所有组织信息同步到本系统", null, 3, 1, userInfo);
|
}
|
});
|
return ActionResult.success(MsgCode.SYS026.get());
|
}
|
|
|
/**
|
* 钉钉所有用户信息同步到本系统
|
* 不带第三方错误定位判断的功能代码 20210604
|
*
|
* @return ignore
|
*/
|
@Operation(summary = "钉钉所有用户信息同步到本系统")
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/synAllUserDingToSys")
|
@Transactional
|
public ActionResult synAllUserDingToSys() {
|
SocialsSysConfig socialsConfig = sysConfigApi.getSocialsConfig();
|
String dingDepartment = socialsConfig.getDingDepartment();
|
// 设置redis的key
|
String synDing = "";
|
UserInfo userInfo = UserProvider.getUser();
|
if (configValueUtil.isMultiTenancy()) {
|
synDing = userInfo.getTenantId() + "_" + userInfo.getUserId() + "_synAllUserDingToSys";
|
} else {
|
synDing = userInfo.getUserId() + "_synAllUserDingToSys";
|
}
|
// 如果redis中存在key说明同步正在进行
|
if (redisUtil.exists(synDing)) {
|
return ActionResult.fail(MsgCode.SYS026.get());
|
}
|
// 获取已同步的部门信息
|
List<SynThirdInfoEntity> synThirdOrgList = synThirdInfoService.getListByDepartment(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_ORG,dingDepartment);
|
List<String> dingDeptIdList = new ArrayList<>();
|
if (CollectionUtil.isNotEmpty(synThirdOrgList)) {
|
dingDeptIdList = synThirdOrgList.stream().map(SynThirdInfoEntity::getThirdObjId)
|
.filter(StringUtils::isNotBlank)
|
.distinct().collect(Collectors.toList());
|
} else {
|
return ActionResult.fail(MsgCode.SYS028.get());
|
}
|
|
// 获取Token值
|
SocialsSysConfig config = sysConfigApi.getSocialsConfig();
|
JSONObject tokenObject = SynDingTalkUtil.getAccessToken(config.getDingSynAppKey(), config.getDingSynAppSecret());
|
if (!tokenObject.getBoolean("code")) {
|
return ActionResult.fail(MsgCode.SYS053.get());
|
}
|
// 异步执行
|
List<String> finalDingDeptIdList = dingDeptIdList;
|
String finalSynDing = synDing;
|
ThreadPoolExecutorUtil.getExecutor().execute(() -> {
|
String userId = userInfo.getUserId();
|
|
try {
|
redisUtil.insert(finalSynDing, "true");
|
List<OapiV2UserListResponse.ListUserResponse> dingUserList = new ArrayList<>();
|
String access_token = tokenObject.getString("access_token");
|
|
// 获取钉钉的用户列表
|
JSONObject retMsg = SynDingTalkUtil.getUserDingList(finalDingDeptIdList, access_token);
|
|
dingUserList = (List<OapiV2UserListResponse.ListUserResponse>) retMsg.get("userlist");
|
|
// 获取同步表、用户表的信息
|
List<SynThirdInfoEntity> synThirdInfoList = synThirdInfoService.syncThirdInfoByType(SynThirdConsts.THIRD_TYPE_DING, SynThirdConsts.DATA_TYPE_USER, SynThirdConsts.THIRD_TYPE_DING);
|
// 根据公司表、同步表进行比较，决定执行创建、还是更新
|
for (OapiV2UserListResponse.ListUserResponse dingUserModel : dingUserList) {
|
if (synThirdInfoList.stream().noneMatch(t -> t.getThirdObjId().equals(dingUserModel.getUserid()))) {
|
// 执行创建功能
|
synThirdDingTalkService.createUserDingToSys(true, dingUserModel, access_token);
|
} else {
|
// 执行更新功能
|
synThirdDingTalkService.updateUserDingToSystem(true, dingUserModel);
|
}
|
}
|
} catch (Exception e) {
|
log.error("{}，钉钉所有用户信息同步到本系统失败：{}", finalSynDing, e.getMessage());
|
} finally {
|
redisUtil.remove(finalSynDing);
|
List<String> toUserId = new ArrayList<>(1);
|
toUserId.add(userId);
|
sentMessageApi.sentMessage(toUserId, "钉钉所有用户信息同步到本系统", null, 3, 1,userInfo );
|
}
|
});
|
return ActionResult.success(MsgCode.SYS026.get());
|
}
|
|
//==================================企业微信的公司-部门-用户批量同步到本系统20220609==================================
|
|
@Operation(summary = "解除同步")
|
@SaCheckPermission(value = {"sysConfig.parameter", "integrationCenter.dingTalk"}, mode = SaMode.OR)
|
@GetMapping("/clearAllSyn")
|
@Transactional
|
public ActionResult clearAllSyn(String type) {
|
synThirdInfoService.clearAllSyn(Integer.valueOf(type));
|
return ActionResult.success(MsgCode.SU005.get());
|
}
|
@Operation(summary = "同步成功或失败数")
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/getHandleNum")
|
public ActionResult getHandleNum(PaginationSynThirdInfo pagination) {
|
List<SynThirdInfoVo> synThirdInfoList = synThirdInfoService
|
.getListJoin(pagination);
|
synThirdInfoList=synThirdInfoList.stream()
|
.filter(t->t.getLastModifyTime()!=null)
|
.collect(Collectors.toList());
|
PaginationVO paginationVO = JsonUtil.getJsonToBean(pagination, PaginationVO.class);
|
return ActionResult.page(synThirdInfoList, paginationVO);
|
}
|
/**
|
* 企业微信所有组织信息(包含公司和部门)同步到本系统
|
*
|
* @return ignore
|
*/
|
@Operation(summary = "企业微信所有组织信息(包含公司和部门)同步到本系统")
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/synAllOrganizeQyToSys")
|
public ActionResult synAllOrganizeQyToSys(@RequestParam(value = "departmentId") String departmentId) {
|
// 设置redis的key
|
String synDing = "";
|
UserInfo userInfo = UserProvider.getUser();
|
if (configValueUtil.isMultiTenancy()) {
|
synDing = userInfo.getTenantId() + "_" + userInfo.getUserId() + "_synAllOrganizeQyToSys";
|
} else {
|
synDing = userInfo.getUserId() + "_synAllOrganizeQyToSys";
|
}
|
// 如果redis中存在key说明同步正在进行
|
if (redisUtil.exists(synDing)) {
|
return ActionResult.fail(MsgCode.SYS026.get());
|
}
|
SocialsSysConfig config = sysConfigApi.getSocialsConfig();
|
if (StringUtil.isEmpty(departmentId)) {
|
return ActionResult.fail("同步组织配置未保存");
|
}
|
OrganizeEntity info = organizeApi.getInfoById(departmentId);
|
if (info == null) {
|
return ActionResult.fail("同步组织数据不存在");
|
}
|
// 获取Token值
|
JSONObject tokenObject = SynQyWebChatUtil.getAccessToken(config.getQyhCorpId(), config.getQyhCorpSecret());
|
if (!tokenObject.getBoolean("code")) {
|
return ActionResult.fail(MsgCode.SYS025.get());
|
}
|
|
// 异步执行
|
String finalSynDing = synDing;
|
ThreadPoolExecutorUtil.getExecutor().execute(() -> {
|
String userId = userInfo.getUserId();
|
try {
|
redisUtil.insert(finalSynDing, "true");
|
String access_token = tokenObject.getString("access_token");
|
|
List<QyWebChatDeptModel> QyDeptAllList = new ArrayList<>();
|
|
// 获取同步表的信息
|
List<SynThirdInfoEntity> synThirdInfoList = synThirdInfoService
|
.getListByDepartment(SynThirdConsts.THIRD_TYPE_QY
|
, SynThirdConsts.DATA_TYPE_ORG
|
, config.getQyhDepartment());
|
// 获取企业微信上的根目录部门(本系统的组织)
|
String departId = SynThirdConsts.QY_ROOT_DEPT_ID;
|
|
// 获取企业微信上的部门列表,需要通讯录密钥
|
JSONObject retMsg = SynQyWebChatUtil.getDepartmentList(departId, access_token);
|
QyDeptAllList = JsonUtil.getJsonToList(retMsg.get("department").toString(), QyWebChatDeptModel.class);
|
|
Map<String, QyWebChatDeptModel> deptModelMap = QyDeptAllList.stream().collect(Collectors.toMap(t -> String.valueOf(t.getId()), dept -> dept));
|
// 部门进行树结构化,固化上下层级序列化
|
List<OrganizeModel> organizeModelList = QyDeptAllList.stream().map(t -> {
|
OrganizeModel model = JsonUtil.getJsonToBean(t, OrganizeModel.class);
|
model.setFullName(t.getName());
|
model.setParentId(t.getParentid() + "");
|
return model;
|
}).collect(Collectors.toList());
|
List<SumTree<OrganizeModel>> trees = TreeDotUtils.convertListToTreeDot(organizeModelList);
|
List<OrganizeListVO> listVO = JsonUtil.getJsonToList(trees, OrganizeListVO.class);
|
|
// 转化成为按上下层级顺序排序的列表数据
|
List<QyWebChatDeptModel> listByOrder = new ArrayList<>();
|
for (OrganizeListVO organizeVo : listVO) {
|
QyWebChatDeptModel entity = deptModelMap.get(organizeVo.getId());
|
listByOrder.add(entity);
|
SynQyWebChatUtil.getOrganizeTreeToList(organizeVo, deptModelMap, listByOrder);
|
}
|
List<OrganizeEntity> organizeEntitiesBind = synThirdInfoService.getOrganizeEntitiesBind(departmentId);
|
List<String> collect = organizeEntitiesBind.stream()
|
.map(SuperBaseEntity.SuperIBaseEntity::getId)
|
.distinct()
|
.collect(Collectors.toList());
|
List<SynThirdInfoEntity> list = synThirdInfoService.getList(SynThirdConsts.THIRD_TYPE_QY, SynThirdConsts.DATA_TYPE_ORG);
|
List<SynThirdInfoEntity> synThirdInfoEntities = list.stream()
|
.filter(t -> !collect.contains(t.getSysObjId()))
|
.distinct()
|
.collect(Collectors.toList());
|
//如果不存在在最高组织下，就删除
|
if (CollectionUtil.isNotEmpty(synThirdInfoEntities)) {
|
synThirdInfoService.removeBatchByIds(synThirdInfoEntities);
|
}
|
// 根据公司表、同步表进行比较，决定执行创建、还是更新
|
for (QyWebChatDeptModel qyWebChatDeptModel : listByOrder) {
|
if (synThirdInfoList.stream().anyMatch(t -> t.getThirdObjId().equals(String.valueOf(qyWebChatDeptModel.getId())))) {
|
// 执行本地更新功能
|
synThirdQyService.updateDepartmentQyToSys(true, qyWebChatDeptModel, access_token);
|
} else {
|
// 执行本的创建功能
|
synThirdQyService.createDepartmentQyToSys(true, qyWebChatDeptModel, access_token);
|
}
|
}
|
} catch (Exception e) {
|
log.error(finalSynDing + "，企业微信所有组织信息同步到本系统失败：" + e.getMessage());
|
} finally {
|
redisUtil.remove(finalSynDing);
|
redisUtil.remove(cacheKeyUtil.getOrganizeList());
|
List<String> toUserId = new ArrayList<>(1);
|
toUserId.add(userId);
|
sentMessageApi.sentMessage(toUserId, "企业微信所有组织信息同步到本系统", null,3 , 1, userInfo);
|
redisUtil.remove(cacheKeyUtil.getOrganizeInfoList());
|
}
|
});
|
return ActionResult.success(MsgCode.SYS026.get());
|
}
|
|
|
/**
|
* 企业微信所有用户信息同步到本系统
|
*
|
* @return ignore
|
*/
|
@Operation(summary = "企业微信所有用户信息同步到本系统")
|
@SaCheckPermission("sysConfig.parameter")
|
@GetMapping("/synAllUserQyToSys")
|
@Transactional
|
public ActionResult synAllUserQyToSys() {
|
SocialsSysConfig socialsConfig = sysConfigApi.getSocialsConfig();
|
String qyhDepartment = socialsConfig.getQyhDepartment();
|
// 设置redis的key
|
String synDing = "";
|
UserInfo userInfo = UserProvider.getUser();
|
if (configValueUtil.isMultiTenancy()) {
|
synDing = userInfo.getTenantId() + "_" + userInfo.getUserId() + "_synAllUserQyToSys";
|
} else {
|
synDing = userInfo.getUserId() + "_synAllUserQyToSys";
|
}
|
// 如果redis中存在key说明同步正在进行
|
if (redisUtil.exists(synDing)) {
|
return ActionResult.fail(MsgCode.SYS026.get());
|
}
|
// 获取已同步的部门信息
|
List<SynThirdInfoEntity> synThirdOrgList = synThirdInfoService.getListByDepartment(SynThirdConsts.THIRD_TYPE_QY, SynThirdConsts.DATA_TYPE_ORG,qyhDepartment);
|
List<String> dingDeptIdList = new ArrayList<>();
|
if (CollectionUtil.isNotEmpty(synThirdOrgList)) {
|
dingDeptIdList = synThirdOrgList
|
.stream()
|
.map(SynThirdInfoEntity::getThirdObjId)
|
.filter(StringUtils::isNotBlank)
|
.distinct().collect(Collectors.toList());
|
} else {
|
return ActionResult.fail(MsgCode.SYS027.get());
|
}
|
|
// 获取Token值
|
SocialsSysConfig config = sysConfigApi.getSocialsConfig();
|
JSONObject tokenObject = SynQyWebChatUtil.getAccessToken(config.getQyhCorpId(), config.getQyhCorpSecret());
|
if (!tokenObject.getBoolean("code")) {
|
return ActionResult.fail(MsgCode.SYS025.get());
|
}
|
// 异步执行
|
String finalSynDing = synDing;
|
ThreadPoolExecutorUtil.getExecutor().execute(() -> {
|
String userId = userInfo.getUserId();
|
try {
|
redisUtil.insert(finalSynDing, "true");
|
List<OapiV2UserListResponse.ListUserResponse> dingUserList = new ArrayList<>();
|
List<QyWebChatUserModel> qyUserAllList = new ArrayList<>();
|
String access_token = tokenObject.getString("access_token");
|
|
// 获取企业微信的用户列表
|
JSONObject retMsg = SynQyWebChatUtil.getUserList("1", "1", access_token);
|
qyUserAllList = JsonUtil.getJsonToList(retMsg.get("userlist"), QyWebChatUserModel.class);
|
// 得到企业微信信息
|
List<SynThirdInfoEntity> synThirdInfoEntityList = synThirdInfoService
|
.syncThirdInfoByType(SynThirdConsts.THIRD_TYPE_QY, SynThirdConsts.DATA_TYPE_USER, SynThirdConsts.THIRD_TYPE_QY);
|
// 根据公司表、同步表进行比较，决定执行创建、还是更新
|
for (QyWebChatUserModel qyWebChatUserModel : qyUserAllList) {
|
if (synThirdInfoEntityList.stream().noneMatch(t -> t.getThirdObjId().equals(qyWebChatUserModel.getUserid()))) {
|
// 执行创建功能
|
synThirdQyService.createUserQyToSys(true, qyWebChatUserModel, access_token);
|
} else {
|
// 执行更新功能
|
synThirdQyService.updateUserQyToSystem(true, qyWebChatUserModel, access_token);
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("{}，企业微信所有用户信息同步到本系统失败：{}", finalSynDing, e.getMessage());
|
} finally {
|
redisUtil.remove(finalSynDing);
|
List<String> toUserId = new ArrayList<>(1);
|
toUserId.add(userId);
|
sentMessageApi.sentMessage(toUserId, "企业微信所有用户信息同步到本系统", null,3 , 1,userInfo );
|
}
|
});
|
return ActionResult.success(MsgCode.SYS026.get());
|
}
|
|
/**
|
* 新建用户后同步用户到企业微信
|
*
|
* @param synThirdQyModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/createUserSysToQy")
|
public void createUserSysToQy(@RequestBody SynThirdQyModel synThirdQyModel) {
|
try {
|
if (synThirdQyModel.getUserEntity()!=null) {
|
synThirdQyService.createUserSysToQy(synThirdQyModel.getIsBatch()
|
, synThirdQyModel.getUserEntity(), synThirdQyModel.getAccessToken()
|
,synThirdQyModel.getOrgIds());
|
}else {
|
synThirdQyService.createUserSysToQy(synThirdQyModel.getIsBatch()
|
, synThirdQyModel.getUserEntities(), synThirdQyModel.getAccessToken()
|
,synThirdQyModel.getPositionId());
|
}
|
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 新建用户后同步用户到钉钉
|
*
|
* @param synThirdQyModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/createUserSysToDing")
|
public void createUserSysToDing(@RequestBody SynThirdQyModel synThirdQyModel) {
|
try {
|
if (synThirdQyModel.getUserEntity()!=null) {
|
synThirdDingTalkService.createUserSysToDing(synThirdQyModel.getIsBatch()
|
, synThirdQyModel.getUserEntity(), synThirdQyModel.getAccessToken()
|
,synThirdQyModel.getOrgIds());
|
}else {
|
synThirdDingTalkService.createUserSysToDing(synThirdQyModel.getIsBatch()
|
, synThirdQyModel.getUserEntities(), synThirdQyModel.getAccessToken()
|
,synThirdQyModel.getPositionId());
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 修改用户后同步用户到企业微信
|
*
|
* @param synThirdQyModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/updateUserSysToQy")
|
public void updateUserSysToQy(@RequestBody SynThirdQyModel synThirdQyModel) {
|
try {
|
if (synThirdQyModel.getSingle() != null) {
|
synThirdQyService.updateUserSysToQy(synThirdQyModel.getIsBatch()
|
, synThirdQyModel.getUserEntity(), synThirdQyModel.getAccessToken(),synThirdQyModel.getSingle());
|
}else {
|
synThirdQyService.updateUserSysToQy(synThirdQyModel.getIsBatch(), synThirdQyModel.getUserEntity()
|
, synThirdQyModel.getAccessToken(),"");
|
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 修改用户后同步用户到钉钉
|
*
|
* @param synThirdQyModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/updateUserSysToDing")
|
public void updateUserSysToDing(@RequestBody SynThirdQyModel synThirdQyModel) {
|
try {
|
if (synThirdQyModel.getSingle() != null) {
|
synThirdDingTalkService.updateUserSysToDing(synThirdQyModel.getIsBatch()
|
, synThirdQyModel.getUserEntity(), synThirdQyModel.getAccessToken(),synThirdQyModel.getSingle());
|
}else {
|
synThirdDingTalkService.updateUserSysToDing(synThirdQyModel.getIsBatch(), synThirdQyModel.getUserEntity()
|
, synThirdQyModel.getAccessToken());
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 删除用户后同步用户到企业微信
|
*
|
* @param sysThirdDeleteModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/deleteUserSysToQy")
|
public void deleteUserSysToQy(@RequestBody SysThirdDeleteModel sysThirdDeleteModel) {
|
try {
|
if (StringUtil.isEmpty(sysThirdDeleteModel.getUserId())
|
&&CollectionUtil.isNotEmpty(sysThirdDeleteModel.getUserIds())) {
|
synThirdQyService.deleteUserSysToQy(sysThirdDeleteModel.getIsBatch(),
|
sysThirdDeleteModel.getUserIds(),sysThirdDeleteModel.getAccessToken(),"");
|
}
|
synThirdQyService.deleteUserSysToQy(sysThirdDeleteModel.getIsBatch(), sysThirdDeleteModel.getUserId(), sysThirdDeleteModel.getAccessToken());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 删除用户后同步用户到钉钉
|
*
|
* @param sysThirdDeleteModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/deleteUserSysToDing")
|
public void deleteUserSysToDing(@RequestBody SysThirdDeleteModel sysThirdDeleteModel) {
|
try {
|
if (StringUtil.isEmpty(sysThirdDeleteModel.getUserId())
|
&&CollectionUtil.isNotEmpty(sysThirdDeleteModel.getUserIds())) {
|
synThirdDingTalkService.deleteUserSysToDing(sysThirdDeleteModel.getIsBatch(),
|
sysThirdDeleteModel.getUserIds(),sysThirdDeleteModel.getAccessToken(),"");
|
}else {
|
synThirdDingTalkService.deleteUserSysToDing(sysThirdDeleteModel.getIsBatch()
|
, sysThirdDeleteModel.getUserId(), sysThirdDeleteModel.getAccessToken());
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 新建组织或部门后同步用户到企业微信
|
*
|
* @param synOrganizeModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/createDepartmentSysToQy")
|
public void createDepartmentSysToQy(@RequestBody SynOrganizeModel synOrganizeModel) {
|
try {
|
synThirdQyService.createDepartmentSysToQy(synOrganizeModel.getIsBatch(), synOrganizeModel.getDeptEntity(), synOrganizeModel.getAccessToken());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 新建组织或部门后同步用户到钉钉
|
*
|
* @param synOrganizeModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/createDepartmentSysToDing")
|
public void createDepartmentSysToDing(@RequestBody SynOrganizeModel synOrganizeModel) {
|
try {
|
synThirdDingTalkService.createDepartmentSysToDing(synOrganizeModel.getIsBatch(), synOrganizeModel.getDeptEntity(), synOrganizeModel.getAccessToken());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 修改组织或部门后同步用户到企业微信
|
*
|
* @param synOrganizeModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/updateDepartmentSysToQy")
|
public void updateDepartmentSysToQy(@RequestBody SynOrganizeModel synOrganizeModel) {
|
try {
|
synThirdQyService.updateDepartmentSysToQy(synOrganizeModel.getIsBatch(), synOrganizeModel.getDeptEntity(), synOrganizeModel.getAccessToken());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 修改组织或部门后同步用户到钉钉
|
*
|
* @param synOrganizeModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/updateDepartmentSysToDing")
|
public void updateDepartmentSysToDing(@RequestBody SynOrganizeModel synOrganizeModel) {
|
try {
|
synThirdDingTalkService.updateDepartmentSysToDing(synOrganizeModel.getIsBatch(), synOrganizeModel.getDeptEntity(), synOrganizeModel.getAccessToken());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 删除组织或部门后同步用户到企业微信
|
*
|
* @param synOrganizeDeleteModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/deleteDepartmentSysToQy")
|
public void deleteDepartmentSysToQy(@RequestBody SynOrganizeDeleteModel synOrganizeDeleteModel) {
|
try {
|
synThirdQyService.deleteDepartmentSysToQy(synOrganizeDeleteModel.getIsBatch(), synOrganizeDeleteModel.getOrganizeId(), synOrganizeDeleteModel.getAccessToken());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 删除组织或部门后同步用户到钉钉
|
*
|
* @param synOrganizeDeleteModel
|
* @return
|
*/
|
@Override
|
@PostMapping("/deleteDepartmentSysToDing")
|
public void deleteDepartmentSysToDing(@RequestBody SynOrganizeDeleteModel synOrganizeDeleteModel) {
|
try {
|
synThirdDingTalkService.deleteDepartmentSysToDing(synOrganizeDeleteModel.getIsBatch()
|
, synOrganizeDeleteModel.getOrganizeId(), synOrganizeDeleteModel.getAccessToken());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
@GetMapping("/getListByObjIds")
|
public List<SynThirdInfoEntity> getListByObjIds(SynThirdModel model) {
|
QueryWrapper<SynThirdInfoEntity> wrapper = new QueryWrapper<>();
|
wrapper.lambda().in(SynThirdInfoEntity::getThirdObjId, model.getIds());
|
wrapper.lambda().eq(SynThirdInfoEntity::getThirdType, model.getThirdType());
|
wrapper.lambda().eq(SynThirdInfoEntity::getDataType, Integer.valueOf(SynThirdConsts.DATA_TYPE_ORG));
|
return synThirdInfoService.getBaseMapper().selectList(wrapper);
|
}
|
|
@Override
|
@PostMapping("/unifyDepartmentSysToQyList")
|
public void unifyDepartmentSysToQy(@RequestBody SynThirdUnifyModel synThirdUnifyModel) throws WxErrorException {
|
synThirdQyService.unifyDepartmentSysToQy(synThirdUnifyModel.isBatch()
|
,synThirdUnifyModel.getOrganizeEntities(),synThirdUnifyModel.getAccessToken()
|
,synThirdUnifyModel.getCategory());
|
}
|
|
@Override
|
@PostMapping("/unifyDepartmentSysToDingList")
|
public void unifyDepartmentSysToDing(@RequestBody SynThirdUnifyModel synThirdUnifyModel) {
|
synThirdDingTalkService.unifyDepartmentSysToDing(synThirdUnifyModel.isBatch()
|
,synThirdUnifyModel.getOrganizeEntities(),synThirdUnifyModel.getAccessToken()
|
,synThirdUnifyModel.getCategory());
|
}
|
|
}
|
