4 1x yz /{| }~  / /  / /        /  /  *   logLorg/slf4j/Logger; ebUserService2Lcom/bcxin/sync/service/tuoluojiang/EbUserService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebAdminService3Lcom/bcxin/sync/service/tuoluojiang/EbAdminService;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;ebEnterpriseRoleService()VCodeLineNumberTableLocalVariableTablethis5Lcom/bcxin/sync/consumer/ExternalMemberKafkaConsumer;bcxDataSyncExternalMembersToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VemployeeResponseListLjava/util/List; ebUserEntity0Lcom/bcxin/sync/entity/tuoluojiang/EbUserEntity;oaAndAttendanceRoleIdLjava/lang/Long;%departmentEmployeeRelationsEntityListentidopenAndEffectiveZeLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;member=Lcom/bcxin/sync/dtos/kafka/message/ExternalMemberSyncMessage;LocalVariableTypeTableDLjava/util/List;XLjava/util/List;XLorg/apache/kafka/clients/consumer/ConsumerRecord; StackMapTableMethodParameters Signature(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V4Lorg/springframework/kafka/annotation/KafkaListener;id.bcx_data_sync_listener_external_members_to_tljtopics*obpm2.binlog-cdc.topic.v2.external_membersgroupId%bcx_data_sync_external_members_to_tlj SourceFile ExternalMemberKafkaConsumer.java(Lorg/springframework/stereotype/Service; BC 235kafka监听external_members表，数据转化为：{}    @A   :; I组织id：{}，有开通陀螺匠，所以需要同步分组成员信息 >?   45  O分组成员id：{}，还未同步过陀螺匠，所以需要同步用户信息 0com/bcxin/sync/dtos/response/BcxEmployeeResponse <= 89 O组织id：{}，没有开通陀螺匠，所以不需要同步分组成员信息java/lang/Exception+kafka监听tenant-employee表，异常：{}  C3com/bcxin/sync/consumer/ExternalMemberKafkaConsumer java/lang/Object0org/apache/kafka/clients/consumer/ConsumerRecord0org/springframework/kafka/support/Acknowledgment;com/bcxin/sync/dtos/kafka/message/ExternalMemberSyncMessagejava/lang/Longjava/util/List.com/bcxin/sync/entity/tuoluojiang/EbUserEntity,com/bcxin/sync/common/utils/KafkaMessageUtil!transferKafkaMemberRecord2Messageq(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/ExternalMemberSyncMessage;com/alibaba/fastjson/JSONObject toJSONString&(Ljava/lang/Object;)Ljava/lang/String;org/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)VgetReferenceType()Ljava/lang/Integer;java/lang/IntegerintValue()IgetReferenceNumber()Ljava/lang/String;#com/bcxin/sync/common/emus/OpenTypeTLJ%Lcom/bcxin/sync/common/emus/OpenType;getCode7com/bcxin/sync/service/datasync/OrganizationOpenServiceisOpenAndEffective(Ljava/lang/String;I)Z6com/bcxin/sync/service/tuoluojiang/EbEnterpriseService getIdByOrgId$(Ljava/lang/String;)Ljava/lang/Long; getMemberIdjava/util/Collections singletonList$(Ljava/lang/Object;)Ljava/util/List;4com/bcxin/sync/service/tenant/TenantEmployeesService'getEmployeeResponseListByEmployeeIdList5(Ljava/util/List;Ljava/lang/Integer;)Ljava/util/List; getUserId0com/bcxin/sync/service/tuoluojiang/EbUserServicegetUserByUserIdD(Ljava/lang/String;)Lcom/bcxin/sync/entity/tuoluojiang/EbUserEntity;get(I)Ljava/lang/Object;getCredentialNumber getCardPhoto getHeadPhotogetEmployeeName getTelephone userCreateo(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V:com/bcxin/sync/service/tuoluojiang/EbEnterpriseRoleServicecreateGetOaAndAttendanceRole"(Ljava/lang/Long;)Ljava/lang/Long;getGroupMemberRelationList()Ljava/util/List;1com/bcxin/sync/service/tuoluojiang/EbAdminServiceuserJoin(Ljava/lang/String;Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Lcom/bcxin/sync/dtos/kafka/message/EmployeeSyncMessage;Lcom/bcxin/sync/dtos/kafka/message/ExternalMemberSyncMessage;)VgetAfterIsDomainAdminvalueOf(I)Ljava/lang/Integer;setAdminOtherInfo(Ljava/lang/String;Ljava/lang/Long;Ljava/lang/String;Lcom/bcxin/sync/dtos/kafka/message/EmployeeSyncMessage;Ljava/lang/Integer;Ljava/lang/Integer;)Lcom/bcxin/sync/entity/tuoluojiang/EbAdminEntity; getMessageerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!/12345678967:;67<=67>?67@A67BCD/*E F GHIJD b+N--1-'* - 6*- :- *-:*-:b-*- *!":#: *$- -- -%*$--&'(W)- :+,-,.EH*Ev346!74899F:K<Y=j>w?|@ABCAEFGJK0J4M7NESHQJR[TaUFp jKLwMNNOP>QL FRP4STJUVbGHbWXbYZ][\] jK^>Q_ bW`a+bcdefghX Bij WYkl6mnsop[sqrsstCD! /0Euv6w