diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/build.gradle b/maxkey-synchronizers/maxkey-synchronizer-feishu/build.gradle new file mode 100644 index 00000000..de15554f --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/build.gradle @@ -0,0 +1,14 @@ +description = "maxkey-synchronizer-feishu" + +apply plugin: 'java' + +dependencies { + //local jars + implementation fileTree(dir: '../maxkey-lib/*/', include: '*.jar') + + implementation project(":maxkey-common") + implementation project(":maxkey-core") + implementation project(":maxkey-persistence") + implementation project(":maxkey-synchronizers:maxkey-synchronizer") + +} \ No newline at end of file diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuAccessTokenService.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuAccessTokenService.java new file mode 100644 index 00000000..0b699b32 --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuAccessTokenService.java @@ -0,0 +1,90 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +package org.maxkey.synchronizer.feishu; + +import java.util.HashMap; +import java.util.Map; + +import org.maxkey.synchronizer.entity.AccessToken; +import org.maxkey.util.JsonUtils; +import org.maxkey.web.HttpRequestAdapter; +import org.maxkey.web.HttpRequestAdapter.MediaType; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class FeishuAccessTokenService { + final static Logger _logger = LoggerFactory.getLogger(FeishuAccessTokenService.class); + + String appId; + + String appSecret; + + public static String TOKEN_URL="https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal"; + + + public FeishuAccessTokenService() {} + + + public FeishuAccessTokenService(String appId, String appSecret) { + super(); + this.appId = appId; + this.appSecret = appSecret; + } + + + public String requestToken() { + HttpRequestAdapter request =new HttpRequestAdapter(MediaType.JSON); + Map parameterMap = new HashMap(); + parameterMap.put("app_id", appId); + parameterMap.put("app_secret", appSecret); + String responseBody = request.post(TOKEN_URL, parameterMap,null); + + AccessToken accessToken = JsonUtils.gson2Object(responseBody, AccessToken.class); + _logger.debug("accessToken " + accessToken); + if(accessToken.getErrcode()== 0){ + return accessToken.getTenant_access_token(); + } + return ""; + } + + + public String getAppId() { + return appId; + } + + + public void setAppId(String appId) { + this.appId = appId; + } + + + public String getAppSecret() { + return appSecret; + } + + + public void setAppSecret(String appSecret) { + this.appSecret = appSecret; + } + + + public static void main(String[] args) { + + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuOrganizationService.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuOrganizationService.java new file mode 100644 index 00000000..c0532cb6 --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuOrganizationService.java @@ -0,0 +1,106 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +package org.maxkey.synchronizer.feishu; + +import java.util.HashMap; +import java.util.NoSuchElementException; +import java.util.concurrent.LinkedBlockingQueue; + +import org.maxkey.constants.ConstsStatus; +import org.maxkey.entity.Organizations; +import org.maxkey.synchronizer.AbstractSynchronizerService; +import org.maxkey.synchronizer.ISynchronizerService; +import org.maxkey.synchronizer.feishu.entity.FeishuDepts; +import org.maxkey.synchronizer.feishu.entity.FeishuDeptsResponse; +import org.maxkey.util.AuthorizationHeaderUtils; +import org.maxkey.util.JsonUtils; +import org.maxkey.web.HttpRequestAdapter; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Service; + +@Service +public class FeishuOrganizationService extends AbstractSynchronizerService implements ISynchronizerService{ + final static Logger _logger = LoggerFactory.getLogger(FeishuOrganizationService.class); + + String access_token; + + static String DEPTS_URL="https://open.feishu.cn/open-apis/contact/v3/departments/%s/children?page_size=50"; + + public void sync() { + _logger.info("Sync Organizations ..."); + + LinkedBlockingQueue deptsQueue = new LinkedBlockingQueue(); + deptsQueue.add("0"); + HashMap deptMap = new HashMap(); + try { + while(deptsQueue.element() != null) { + FeishuDeptsResponse rsp = requestDepartmentList(access_token,deptsQueue.poll()); + + for(FeishuDepts dept : rsp.getData().getItems()) { + _logger.info("dept : " + dept.getDepartment_id()+" "+ dept.getName()+" "+ dept.getParent_department_id()); + deptsQueue.add(dept.getDepartment_id()); + deptMap.put(dept.getDepartment_id(), dept); + Organizations organization = buildOrganization(dept,deptMap.get(dept.getParent_department_id())); + organizationsService.saveOrUpdate(organization); + _logger.info("Organizations : " + organization); + } + } + } catch (NoSuchElementException e) { + _logger.debug("Sync Department successful ."); + } + + } + + public FeishuDeptsResponse requestDepartmentList(String access_token,String deptId) { + HttpRequestAdapter request =new HttpRequestAdapter(); + HashMap headers =new HashMap(); + headers.put("Authorization", AuthorizationHeaderUtils.createBearer(access_token)); + String responseBody = request.get(String.format(DEPTS_URL, deptId),headers); + FeishuDeptsResponse deptsResponse =JsonUtils.gson2Object(responseBody, FeishuDeptsResponse.class); + + _logger.info("response : " + responseBody); + + return deptsResponse; + } + + public Organizations buildOrganization(FeishuDepts dept,FeishuDepts parentDept) { + Organizations org = new Organizations(); + org.setId(dept.getDepartment_id()+""); + org.setName(dept.getName()); + if(parentDept == null) { + org.setParentId("1"); + }else { + org.setParentId(dept.getParent_department_id()+""); + } + org.setSortIndex(Integer.parseInt(dept.getOrder())); + org.setInstId(this.synchronizer.getInstId()); + org.setStatus(ConstsStatus.ACTIVE); + org.setDescription("Feishu"); + return org; + } + + public String getAccess_token() { + return access_token; + } + + public void setAccess_token(String access_token) { + this.access_token = access_token; + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuSynchronizerService.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuSynchronizerService.java new file mode 100644 index 00000000..1235b50a --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuSynchronizerService.java @@ -0,0 +1,75 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +package org.maxkey.synchronizer.feishu; + +import org.maxkey.entity.Synchronizers; +import org.maxkey.synchronizer.ISynchronizerService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +@Service +public class FeishuSynchronizerService implements ISynchronizerService{ + final static Logger _logger = LoggerFactory.getLogger(FeishuSynchronizerService.class); + Synchronizers synchronizer; + + @Autowired + FeishuUsersService feishuUsersService; + + @Autowired + FeishuOrganizationService feishuOrganizationService; + + + FeishuAccessTokenService feishuAccessTokenService = new FeishuAccessTokenService(); + + public FeishuSynchronizerService() { + super(); + } + + public void sync() throws Exception { + _logger.info("Sync ..."); + feishuAccessTokenService.setAppId(synchronizer.getPrincipal()); + feishuAccessTokenService.setAppSecret(synchronizer.getCredentials()); + String access_token=feishuAccessTokenService.requestToken(); + + feishuOrganizationService.setSynchronizer(synchronizer); + feishuOrganizationService.setAccess_token(access_token); + feishuOrganizationService.sync(); + + feishuUsersService.setSynchronizer(synchronizer); + feishuUsersService.setAccess_token(access_token); + //feishuUsersService.sync(); + } + + + public void setFeishuUsersService(FeishuUsersService feishuUsersService) { + this.feishuUsersService = feishuUsersService; + } + + public void setFeishuOrganizationService(FeishuOrganizationService feishuOrganizationService) { + this.feishuOrganizationService = feishuOrganizationService; + } + + @Override + public void setSynchronizer(Synchronizers synchronizer) { + this.synchronizer = synchronizer; + + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuUsersService.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuUsersService.java new file mode 100644 index 00000000..5e9d31b7 --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/FeishuUsersService.java @@ -0,0 +1,108 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +package org.maxkey.synchronizer.feishu; + +import java.sql.Types; +import java.util.HashMap; +import java.util.List; + +import org.maxkey.constants.ConstsStatus; +import org.maxkey.entity.Organizations; +import org.maxkey.entity.UserInfo; +import org.maxkey.synchronizer.AbstractSynchronizerService; +import org.maxkey.synchronizer.ISynchronizerService; +import org.maxkey.synchronizer.feishu.entity.FeishuUsers; +import org.maxkey.synchronizer.feishu.entity.FeishuUsersResponse; +import org.maxkey.util.AuthorizationHeaderUtils; +import org.maxkey.util.JsonUtils; +import org.maxkey.web.HttpRequestAdapter; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Service; + +@Service +public class FeishuUsersService extends AbstractSynchronizerService implements ISynchronizerService{ + final static Logger _logger = LoggerFactory.getLogger(FeishuUsersService.class); + + String access_token; + + static String USERS_URL="https://open.feishu.cn/open-apis/contact/v3/users/find_by_department"; + + public void sync() { + _logger.info("Sync Users..."); + try { + List organizations = + organizationsService.find("instid = ?", + new Object[] { this.synchronizer.getInstId() }, + new int[] { Types.VARCHAR}); + for(Organizations dept : organizations) { + HttpRequestAdapter request =new HttpRequestAdapter(); + HashMap headers =new HashMap(); + headers.put("Authorization", AuthorizationHeaderUtils.createBearer(access_token)); + String responseBody = request.get(String.format(USERS_URL, access_token,dept.getId()),headers); + FeishuUsersResponse usersResponse =JsonUtils.gson2Object(responseBody, FeishuUsersResponse.class); + _logger.info("response : " + responseBody); + + for(FeishuUsers user : usersResponse.getData().getItems()) { + UserInfo userInfo = buildUserInfo(user); + _logger.info("userInfo : " + userInfo); + userInfo.setPassword(userInfo.getUsername() + "Maxkey@888"); + userInfoService.saveOrUpdate(userInfo); + } + } + + } catch (Exception e) { + e.printStackTrace(); + } + + } + + public void postSync(UserInfo userInfo) { + + } + + public UserInfo buildUserInfo(FeishuUsers user) { + UserInfo userInfo = new UserInfo(); + userInfo.setUsername(user.getUser_id());//账号 + userInfo.setNickName(user.getNickname());//名字 + userInfo.setDisplayName(user.getName());//名字 + + userInfo.setMobile(user.getMobile());//手机 + userInfo.setEmail(user.getEmail()); + userInfo.setGender(user.getGender()); + + userInfo.setEmployeeNumber(user.getEmployee_no()); + userInfo.setWorkPhoneNumber(user.getMobile());//工作电话 + userInfo.setDepartmentId(user.getDepartment_ids()[0]+""); + userInfo.setJobTitle(user.getJob_title());//职务 + userInfo.setWorkAddressFormatted(user.getWork_station());//工作地点 + + //激活状态: 1=已激活，2=已禁用，4=未激活，5=退出企业。 + if(user.getStatus().isIs_activated() ) { + userInfo.setStatus(ConstsStatus.ACTIVE); + }else { + userInfo.setStatus(ConstsStatus.INACTIVE); + } + userInfo.setInstId(this.synchronizer.getInstId()); + return userInfo; + } + + public void setAccess_token(String access_token) { + this.access_token = access_token; + } +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptStatus.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptStatus.java new file mode 100644 index 00000000..feb1640c --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptStatus.java @@ -0,0 +1,44 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.maxkey.synchronizer.feishu.entity; + +public class FeishuDeptStatus { + boolean is_deleted; + + public FeishuDeptStatus() { + super(); + + } + + public boolean isIs_deleted() { + return is_deleted; + } + + public void setIs_deleted(boolean is_deleted) { + this.is_deleted = is_deleted; + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuDeptStatus [is_deleted="); + builder.append(is_deleted); + builder.append("]"); + return builder.toString(); + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDepts.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDepts.java new file mode 100644 index 00000000..2aad38d4 --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDepts.java @@ -0,0 +1,167 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +package org.maxkey.synchronizer.feishu.entity; + +public class FeishuDepts { + + String department_id; + String parent_department_id; + String open_department_id; + String name; + FeishuI18nName i18n_name; + String leader_user_id; + String chat_id; + String order; + int member_count; + FeishuDeptStatus status; + String is_deleted; + String create_group_chat; + + public FeishuDepts() { + super(); + } + + public String getDepartment_id() { + return department_id; + } + + public void setDepartment_id(String department_id) { + this.department_id = department_id; + } + + public String getParent_department_id() { + return parent_department_id; + } + + public void setParent_department_id(String parent_department_id) { + this.parent_department_id = parent_department_id; + } + + public String getOpen_department_id() { + return open_department_id; + } + + public void setOpen_department_id(String open_department_id) { + this.open_department_id = open_department_id; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public FeishuI18nName getI18n_name() { + return i18n_name; + } + + public void setI18n_name(FeishuI18nName i18n_name) { + this.i18n_name = i18n_name; + } + + public String getLeader_user_id() { + return leader_user_id; + } + + public void setLeader_user_id(String leader_user_id) { + this.leader_user_id = leader_user_id; + } + + public String getChat_id() { + return chat_id; + } + + public void setChat_id(String chat_id) { + this.chat_id = chat_id; + } + + public String getOrder() { + return order; + } + + public void setOrder(String order) { + this.order = order; + } + + public int getMember_count() { + return member_count; + } + + public void setMember_count(int member_count) { + this.member_count = member_count; + } + + public FeishuDeptStatus getStatus() { + return status; + } + + public void setStatus(FeishuDeptStatus status) { + this.status = status; + } + + public String getIs_deleted() { + return is_deleted; + } + + public void setIs_deleted(String is_deleted) { + this.is_deleted = is_deleted; + } + + public String getCreate_group_chat() { + return create_group_chat; + } + + public void setCreate_group_chat(String create_group_chat) { + this.create_group_chat = create_group_chat; + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuDepts [department_id="); + builder.append(department_id); + builder.append(", parent_department_id="); + builder.append(parent_department_id); + builder.append(", open_department_id="); + builder.append(open_department_id); + builder.append(", name="); + builder.append(name); + builder.append(", i18n_name="); + builder.append(i18n_name); + builder.append(", leader_user_id="); + builder.append(leader_user_id); + builder.append(", chat_id="); + builder.append(chat_id); + builder.append(", order="); + builder.append(order); + builder.append(", member_count="); + builder.append(member_count); + builder.append(", status="); + builder.append(status); + builder.append(", is_deleted="); + builder.append(is_deleted); + builder.append(", create_group_chat="); + builder.append(create_group_chat); + builder.append("]"); + return builder.toString(); + } + + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptsData.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptsData.java new file mode 100644 index 00000000..fd838c7e --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptsData.java @@ -0,0 +1,70 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.maxkey.synchronizer.feishu.entity; + +import java.util.ArrayList; + +import org.maxkey.synchronizer.entity.ResponseData; + +public class FeishuDeptsData extends ResponseData { + + boolean has_more; + String page_token; + ArrayList items; + + public boolean isHas_more() { + return has_more; + } + + public void setHas_more(boolean has_more) { + this.has_more = has_more; + } + + public String getPage_token() { + return page_token; + } + + public void setPage_token(String page_token) { + this.page_token = page_token; + } + + public ArrayList getItems() { + return items; + } + + public void setItems(ArrayList items) { + this.items = items; + } + + public FeishuDeptsData() { + super(); + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuDeptsResponse [has_more="); + builder.append(has_more); + builder.append(", page_token="); + builder.append(page_token); + builder.append(", items="); + builder.append(items); + builder.append("]"); + return builder.toString(); + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptsResponse.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptsResponse.java new file mode 100644 index 00000000..d7b5f718 --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuDeptsResponse.java @@ -0,0 +1,50 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.maxkey.synchronizer.feishu.entity; + +import org.maxkey.synchronizer.entity.ResponseData; + +public class FeishuDeptsResponse extends ResponseData { + + FeishuDeptsData data; + + + public FeishuDeptsResponse() { + super(); + } + + + public FeishuDeptsData getData() { + return data; + } + + + public void setData(FeishuDeptsData data) { + this.data = data; + } + + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuDeptsResponse [data="); + builder.append(data); + builder.append("]"); + return builder.toString(); + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuI18nName.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuI18nName.java new file mode 100644 index 00000000..2a1dc718 --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuI18nName.java @@ -0,0 +1,66 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.maxkey.synchronizer.feishu.entity; + +public class FeishuI18nName { + + String zh_cn; + String ja_jp; + String en_us; + + public FeishuI18nName() { + super(); + } + + public String getZh_cn() { + return zh_cn; + } + + public void setZh_cn(String zh_cn) { + this.zh_cn = zh_cn; + } + + public String getJa_jp() { + return ja_jp; + } + + public void setJa_jp(String ja_jp) { + this.ja_jp = ja_jp; + } + + public String getEn_us() { + return en_us; + } + + public void setEn_us(String en_us) { + this.en_us = en_us; + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuI18nName [zh_cn="); + builder.append(zh_cn); + builder.append(", ja_jp="); + builder.append(ja_jp); + builder.append(", en_us="); + builder.append(en_us); + builder.append("]"); + return builder.toString(); + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUserStatus.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUserStatus.java new file mode 100644 index 00000000..3a903fa0 --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUserStatus.java @@ -0,0 +1,87 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.maxkey.synchronizer.feishu.entity; + +public class FeishuUserStatus { + boolean is_frozen; + boolean is_resigned; + boolean is_activated; + boolean is_exited; + boolean is_unjoin; + + public FeishuUserStatus() { + super(); + } + + public boolean isIs_frozen() { + return is_frozen; + } + + public void setIs_frozen(boolean is_frozen) { + this.is_frozen = is_frozen; + } + + public boolean isIs_resigned() { + return is_resigned; + } + + public void setIs_resigned(boolean is_resigned) { + this.is_resigned = is_resigned; + } + + public boolean isIs_activated() { + return is_activated; + } + + public void setIs_activated(boolean is_activated) { + this.is_activated = is_activated; + } + + public boolean isIs_exited() { + return is_exited; + } + + public void setIs_exited(boolean is_exited) { + this.is_exited = is_exited; + } + + public boolean isIs_unjoin() { + return is_unjoin; + } + + public void setIs_unjoin(boolean is_unjoin) { + this.is_unjoin = is_unjoin; + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuUserStatus [is_frozen="); + builder.append(is_frozen); + builder.append(", is_resigned="); + builder.append(is_resigned); + builder.append(", is_activated="); + builder.append(is_activated); + builder.append(", is_exited="); + builder.append(is_exited); + builder.append(", is_unjoin="); + builder.append(is_unjoin); + builder.append("]"); + return builder.toString(); + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsers.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsers.java new file mode 100644 index 00000000..08907e1d --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsers.java @@ -0,0 +1,309 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +package org.maxkey.synchronizer.feishu.entity; + +import java.util.Arrays; + +public class FeishuUsers { + + String union_id; + String user_id; + String open_id; + String name; + String en_name; + String nickname; + String email; + String mobile; + boolean mobile_visible; + int gender; + String avatar_key; + FeishuUserStatus status; + String []department_ids; + String leader_user_id; + String city; + String country; + String work_station; + int join_time; + String is_tenant_manager; + String employee_no; + long employee_type; + + String enterprise_email; + String job_title; + String is_frozen; + + public class ExtAttrs { + + String type; + String name; + String text; + + } + + public String getUnion_id() { + return union_id; + } + + public void setUnion_id(String union_id) { + this.union_id = union_id; + } + + public String getUser_id() { + return user_id; + } + + public void setUser_id(String user_id) { + this.user_id = user_id; + } + + public String getOpen_id() { + return open_id; + } + + public void setOpen_id(String open_id) { + this.open_id = open_id; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getEn_name() { + return en_name; + } + + public void setEn_name(String en_name) { + this.en_name = en_name; + } + + public String getNickname() { + return nickname; + } + + public void setNickname(String nickname) { + this.nickname = nickname; + } + + public String getEmail() { + return email; + } + + public void setEmail(String email) { + this.email = email; + } + + public String getMobile() { + return mobile; + } + + public void setMobile(String mobile) { + this.mobile = mobile; + } + + public boolean isMobile_visible() { + return mobile_visible; + } + + public void setMobile_visible(boolean mobile_visible) { + this.mobile_visible = mobile_visible; + } + + public int getGender() { + return gender; + } + + public void setGender(int gender) { + this.gender = gender; + } + + public String getAvatar_key() { + return avatar_key; + } + + public void setAvatar_key(String avatar_key) { + this.avatar_key = avatar_key; + } + + public FeishuUserStatus getStatus() { + return status; + } + + public void setStatus(FeishuUserStatus status) { + this.status = status; + } + + public String[] getDepartment_ids() { + return department_ids; + } + + public void setDepartment_ids(String[] department_ids) { + this.department_ids = department_ids; + } + + public String getLeader_user_id() { + return leader_user_id; + } + + public void setLeader_user_id(String leader_user_id) { + this.leader_user_id = leader_user_id; + } + + public String getCity() { + return city; + } + + public void setCity(String city) { + this.city = city; + } + + public String getCountry() { + return country; + } + + public void setCountry(String country) { + this.country = country; + } + + public String getWork_station() { + return work_station; + } + + public void setWork_station(String work_station) { + this.work_station = work_station; + } + + public int getJoin_time() { + return join_time; + } + + public void setJoin_time(int join_time) { + this.join_time = join_time; + } + + public String getIs_tenant_manager() { + return is_tenant_manager; + } + + public void setIs_tenant_manager(String is_tenant_manager) { + this.is_tenant_manager = is_tenant_manager; + } + + public String getEmployee_no() { + return employee_no; + } + + public void setEmployee_no(String employee_no) { + this.employee_no = employee_no; + } + + public long getEmployee_type() { + return employee_type; + } + + public void setEmployee_type(long employee_type) { + this.employee_type = employee_type; + } + + public String getEnterprise_email() { + return enterprise_email; + } + + public void setEnterprise_email(String enterprise_email) { + this.enterprise_email = enterprise_email; + } + + public String getJob_title() { + return job_title; + } + + public void setJob_title(String job_title) { + this.job_title = job_title; + } + + public String getIs_frozen() { + return is_frozen; + } + + public void setIs_frozen(String is_frozen) { + this.is_frozen = is_frozen; + } + + public FeishuUsers() { + super(); + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuUsers [union_id="); + builder.append(union_id); + builder.append(", user_id="); + builder.append(user_id); + builder.append(", open_id="); + builder.append(open_id); + builder.append(", name="); + builder.append(name); + builder.append(", en_name="); + builder.append(en_name); + builder.append(", nickname="); + builder.append(nickname); + builder.append(", email="); + builder.append(email); + builder.append(", mobile="); + builder.append(mobile); + builder.append(", mobile_visible="); + builder.append(mobile_visible); + builder.append(", gender="); + builder.append(gender); + builder.append(", avatar_key="); + builder.append(avatar_key); + builder.append(", status="); + builder.append(status); + builder.append(", department_ids="); + builder.append(Arrays.toString(department_ids)); + builder.append(", leader_user_id="); + builder.append(leader_user_id); + builder.append(", city="); + builder.append(city); + builder.append(", country="); + builder.append(country); + builder.append(", work_station="); + builder.append(work_station); + builder.append(", join_time="); + builder.append(join_time); + builder.append(", is_tenant_manager="); + builder.append(is_tenant_manager); + builder.append(", employee_no="); + builder.append(employee_no); + builder.append(", employee_type="); + builder.append(employee_type); + builder.append(", enterprise_email="); + builder.append(enterprise_email); + builder.append(", job_title="); + builder.append(job_title); + builder.append(", is_frozen="); + builder.append(is_frozen); + builder.append("]"); + return builder.toString(); + } + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsersData.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsersData.java new file mode 100644 index 00000000..219cb80b --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsersData.java @@ -0,0 +1,79 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +package org.maxkey.synchronizer.feishu.entity; + +import java.util.ArrayList; + +public class FeishuUsersData { + boolean has_more; + String page_token; + + ArrayListitems; + + + public FeishuUsersData() { + super(); + } + + + public boolean isHas_more() { + return has_more; + } + + + public void setHas_more(boolean has_more) { + this.has_more = has_more; + } + + + public String getPage_token() { + return page_token; + } + + + public void setPage_token(String page_token) { + this.page_token = page_token; + } + + + public ArrayList getItems() { + return items; + } + + + public void setItems(ArrayList items) { + this.items = items; + } + + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuUsersData [has_more="); + builder.append(has_more); + builder.append(", page_token="); + builder.append(page_token); + builder.append(", items="); + builder.append(items); + builder.append("]"); + return builder.toString(); + } + + + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsersResponse.java b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsersResponse.java new file mode 100644 index 00000000..fcf6aa15 --- /dev/null +++ b/maxkey-synchronizers/maxkey-synchronizer-feishu/src/main/java/org/maxkey/synchronizer/feishu/entity/FeishuUsersResponse.java @@ -0,0 +1,49 @@ +/* + * Copyright [2022] [MaxKey of copyright http://www.maxkey.top] + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + +package org.maxkey.synchronizer.feishu.entity; + +import org.maxkey.synchronizer.entity.ResponseData; + +public class FeishuUsersResponse extends ResponseData{ + + FeishuUsersData data; + + public FeishuUsersResponse() { + super(); + } + + public FeishuUsersData getData() { + return data; + } + + public void setData(FeishuUsersData data) { + this.data = data; + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("FeishuUsersResponse [data="); + builder.append(data); + builder.append("]"); + return builder.toString(); + } + + + +} diff --git a/maxkey-synchronizers/maxkey-synchronizer/src/main/java/org/maxkey/synchronizer/entity/AccessToken.java b/maxkey-synchronizers/maxkey-synchronizer/src/main/java/org/maxkey/synchronizer/entity/AccessToken.java index 5251babe..ea368fc1 100644 --- a/maxkey-synchronizers/maxkey-synchronizer/src/main/java/org/maxkey/synchronizer/entity/AccessToken.java +++ b/maxkey-synchronizers/maxkey-synchronizer/src/main/java/org/maxkey/synchronizer/entity/AccessToken.java @@ -22,6 +22,8 @@ public class AccessToken { int errcode; String errmsg; String access_token; + //feishu access_token + String tenant_access_token; String expires_in; public AccessToken() { @@ -52,6 +54,14 @@ public class AccessToken { this.access_token = access_token; } + public String getTenant_access_token() { + return tenant_access_token; + } + + public void setTenant_access_token(String tenant_access_token) { + this.tenant_access_token = tenant_access_token; + } + public String getExpires_in() { return expires_in; } diff --git a/maxkey-synchronizers/maxkey-synchronizer/src/main/java/org/maxkey/synchronizer/entity/ResponseData.java b/maxkey-synchronizers/maxkey-synchronizer/src/main/java/org/maxkey/synchronizer/entity/ResponseData.java index 9b9fbc5c..5b224be6 100644 --- a/maxkey-synchronizers/maxkey-synchronizer/src/main/java/org/maxkey/synchronizer/entity/ResponseData.java +++ b/maxkey-synchronizers/maxkey-synchronizer/src/main/java/org/maxkey/synchronizer/entity/ResponseData.java @@ -20,7 +20,10 @@ package org.maxkey.synchronizer.entity; public class ResponseData { protected long errcode; + protected long code; + protected String errmsg; + protected String msg; public long getErrcode() { return errcode; @@ -34,6 +37,20 @@ public class ResponseData { public void setErrmsg(String errmsg) { this.errmsg = errmsg; } + + + public long getCode() { + return code; + } + public void setCode(long code) { + this.code = code; + } + public String getMsg() { + return msg; + } + public void setMsg(String msg) { + this.msg = msg; + } public ResponseData() { super(); } diff --git a/maxkey-webs/maxkey-web-mgt/build.gradle b/maxkey-webs/maxkey-web-mgt/build.gradle index 00bd7920..46c2342d 100644 --- a/maxkey-webs/maxkey-web-mgt/build.gradle +++ b/maxkey-webs/maxkey-web-mgt/build.gradle @@ -22,6 +22,7 @@ dependencies { //synchronizers implementation project(":maxkey-synchronizers:maxkey-synchronizer") implementation project(":maxkey-synchronizers:maxkey-synchronizer-activedirectory") + implementation project(":maxkey-synchronizers:maxkey-synchronizer-feishu") implementation project(":maxkey-synchronizers:maxkey-synchronizer-ldap") implementation project(":maxkey-synchronizers:maxkey-synchronizer-workweixin") implementation project(":maxkey-synchronizers:maxkey-synchronizer-dingtalk") diff --git a/maxkey-webs/maxkey-web-mgt/config/build_docker.gradle b/maxkey-webs/maxkey-web-mgt/config/build_docker.gradle index 48375f9c..e68de729 100644 --- a/maxkey-webs/maxkey-web-mgt/config/build_docker.gradle +++ b/maxkey-webs/maxkey-web-mgt/config/build_docker.gradle @@ -57,6 +57,7 @@ dependencies { //synchronizers implementation project(":maxkey-synchronizers:maxkey-synchronizer") implementation project(":maxkey-synchronizers:maxkey-synchronizer-activedirectory") + implementation project(":maxkey-synchronizers:maxkey-synchronizer-feishu") implementation project(":maxkey-synchronizers:maxkey-synchronizer-ldap") implementation project(":maxkey-synchronizers:maxkey-synchronizer-workweixin") implementation project(":maxkey-synchronizers:maxkey-synchronizer-dingtalk") diff --git a/maxkey-webs/maxkey-web-mgt/config/build_jar.gradle b/maxkey-webs/maxkey-web-mgt/config/build_jar.gradle index 903619f2..dd927221 100644 --- a/maxkey-webs/maxkey-web-mgt/config/build_jar.gradle +++ b/maxkey-webs/maxkey-web-mgt/config/build_jar.gradle @@ -58,6 +58,7 @@ dependencies { //synchronizers implementation project(":maxkey-synchronizers:maxkey-synchronizer") implementation project(":maxkey-synchronizers:maxkey-synchronizer-activedirectory") + implementation project(":maxkey-synchronizers:maxkey-synchronizer-feishu") implementation project(":maxkey-synchronizers:maxkey-synchronizer-ldap") implementation project(":maxkey-synchronizers:maxkey-synchronizer-workweixin") implementation project(":maxkey-synchronizers:maxkey-synchronizer-dingtalk") diff --git a/maxkey-webs/maxkey-web-mgt/config/build_standard.gradle b/maxkey-webs/maxkey-web-mgt/config/build_standard.gradle index 69e6118a..ab664031 100644 --- a/maxkey-webs/maxkey-web-mgt/config/build_standard.gradle +++ b/maxkey-webs/maxkey-web-mgt/config/build_standard.gradle @@ -22,6 +22,7 @@ dependencies { //synchronizers implementation project(":maxkey-synchronizers:maxkey-synchronizer") implementation project(":maxkey-synchronizers:maxkey-synchronizer-activedirectory") + implementation project(":maxkey-synchronizers:maxkey-synchronizer-feishu") implementation project(":maxkey-synchronizers:maxkey-synchronizer-ldap") implementation project(":maxkey-synchronizers:maxkey-synchronizer-workweixin") implementation project(":maxkey-synchronizers:maxkey-synchronizer-dingtalk") diff --git a/settings.gradle b/settings.gradle index e80cc61d..a65e8096 100644 --- a/settings.gradle +++ b/settings.gradle @@ -37,6 +37,7 @@ include ( 'maxkey-synchronizers:maxkey-synchronizer', 'maxkey-synchronizers:maxkey-synchronizer-reorgdept', 'maxkey-synchronizers:maxkey-synchronizer-activedirectory', + 'maxkey-synchronizers:maxkey-synchronizer-feishu', 'maxkey-synchronizers:maxkey-synchronizer-ldap', 'maxkey-synchronizers:maxkey-synchronizer-dingtalk', 'maxkey-synchronizers:maxkey-synchronizer-workweixin',