4 )` ab 'cd ef gh ij kl 'm in op oq rs 't uvw ix yq yz{ '| i} i~  i  '  " g  logLorg/slf4j/Logger;tenantDepartmentsService8Lcom/bcxin/sync/service/tenant/TenantDepartmentsService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebFrameService3Lcom/bcxin/sync/service/tuoluojiang/EbFrameService;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;organizationOpenService9Lcom/bcxin/sync/service/datasync/OrganizationOpenService;()VCodeLineNumberTableLocalVariableTablethis4Lcom/bcxin/sync/consumer/ExternalGroupKafkaConsumer;bcxDataSyncExternalGroupsToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VpidLjava/lang/Long;entidopenAndEffectiveZeLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;group; StackMapTableMethodParameters Signature(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V4Lorg/springframework/kafka/annotation/KafkaListener;id-bcx_data_sync_listener_external_groups_to_tljtopics)obpm2.binlog-cdc.topic.v2.external_groupsgroupId$bcx_data_sync_external_groups_to_tlj SourceFileExternalGroupKafkaConsumer.java(Lorg/springframework/stereotype/Service; 67 *+4kafka监听external_groups表，数据转化为：{}    45   23 C组织id：{}，有开通陀螺匠，所以需要同步分组信息  组织id：{}，删除分组 01  %组织id：{}，新增或修改分组  ,-  F组织id：{}，没开通陀螺匠，所以不需要同步分组信息java/lang/Exception+kafka监听external_groups表，异常：{}  72com/bcxin/sync/consumer/ExternalGroupKafkaConsumer java/lang/Object:com/bcxin/sync/dtos/kafka/message/ExternalGroupSyncMessagejava/lang/Long,com/bcxin/sync/common/utils/KafkaMessageUtil transferKafkaGroupRecord2Messagep(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/ExternalGroupSyncMessage;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;getType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypeDELETE.Lcom/bcxin/sync/common/emus/DataOperationType; getGroupIdgetAfterGroupName1com/bcxin/sync/service/tuoluojiang/EbFrameService frameDelete'(Ljava/lang/String;Ljava/lang/String;)VgetAfterParentId$org/apache/commons/lang3/StringUtils isNotBlank(Ljava/lang/CharSequence;)ZgetIdByDepartmentId6com/bcxin/sync/service/tenant/TenantDepartmentsServicegetRootDeptByOrganizationIdJ(Ljava/lang/String;)Lcom/bcxin/sync/entity/tenant/TenantDepartmentsEntity;4com/bcxin/sync/entity/tenant/TenantDepartmentsEntitygetId frameCreateV(Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long; getMessageerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V0org/springframework/kafka/support/Acknowledgment acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!')*+,-./01./23./45./678/*9: ;<=>8 +N--* - 6*- :- -#- *--Y- :-*-:**- :*-- W!- :#$%,&"9b*+-.0/50B1G3U4e6s79:;<>@CDIGHJK:RE?@BA@0BCDE ;< FG HIJKL  FMNOP*P BQR FHST.UVsWX[sYZs[\78! '(9]^._