4 (i jk &lm no pq &r st uv &w xy xz {| &} ~ s z & s & s s &  ! p  logLorg/slf4j/Logger;ebFrameService3Lcom/bcxin/sync/service/tuoluojiang/EbFrameService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebFrameAssistService9Lcom/bcxin/sync/service/tuoluojiang/EbFrameAssistService;ebAdminService3Lcom/bcxin/sync/service/tuoluojiang/EbAdminService;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;tenantDepartmentsService8Lcom/bcxin/sync/service/tenant/TenantDepartmentsService;organizationOpenService9Lcom/bcxin/sync/service/datasync/OrganizationOpenService;()VCodeLineNumberTableLocalVariableTablethisHLcom/bcxin/sync/consumer/TenantDepartmentEmployeeRelationsKafkaConsumer;1bcxDataSyncTenantDepartmentEmployeeRelationsToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VadminIdLjava/lang/Long;entidorganizationIdLjava/lang/String;openAndEffectiveZeLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment; relationsPLcom/bcxin/sync/dtos/kafka/message/TenantDepartmentEmployeeRelationsSyncMessage;LocalVariableTypeTableXLorg/apache/kafka/clients/consumer/ConsumerRecord; StackMapTableMethodParameters Signature(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V4Lorg/springframework/kafka/annotation/KafkaListener;idBbcx_data_sync_listener_tenant_department_employee_relations_to_tljtopics>obpm2.binlog-cdc.topic.v2.tenant_department_employee_relationsgroupId9bcx_data_sync_tenant_department_employee_relations_to_tlj SourceFile3TenantDepartmentEmployeeRelationsKafkaConsumer.java(Lorg/springframework/stereotype/Service; 9: )*Ikafka监听tenant-department-employee-relations表，数据转化为：{}  56  78  34 O组织id：{}，有开通陀螺匠，所以需要同步职员部门变更信息  /0  12   +, U组织id：{}，没有开通陀螺匠，所以不需要同步职员部门变更信息java/lang/Exception@kafka监听tenant-department-employee-relations表，异常：{}  :Fcom/bcxin/sync/consumer/TenantDepartmentEmployeeRelationsKafkaConsumer java/lang/Object0org/apache/kafka/clients/consumer/ConsumerRecord0org/springframework/kafka/support/AcknowledgmentNcom/bcxin/sync/dtos/kafka/message/TenantDepartmentEmployeeRelationsSyncMessagejava/lang/Stringjava/lang/Long,com/bcxin/sync/common/utils/KafkaMessageUtilGtransferKafkaTenantDepartmentEmployeeRelationsSyncMessageRecord2Message(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/TenantDepartmentEmployeeRelationsSyncMessage;com/alibaba/fastjson/JSONObject toJSONString&(Ljava/lang/Object;)Ljava/lang/String;org/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)VgetAfterDeptId()Ljava/lang/String;6com/bcxin/sync/service/tenant/TenantDepartmentsServicegetOrgIdByDepartmentId&(Ljava/lang/String;)Ljava/lang/String;#com/bcxin/sync/common/emus/OpenTypeTLJ%Lcom/bcxin/sync/common/emus/OpenType;getCode()I7com/bcxin/sync/service/datasync/OrganizationOpenServiceisOpenAndEffective(Ljava/lang/String;I)Z6com/bcxin/sync/service/tuoluojiang/EbEnterpriseService getIdByOrgId$(Ljava/lang/String;)Ljava/lang/Long; getOpType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypeDELETE.Lcom/bcxin/sync/common/emus/DataOperationType;getId7com/bcxin/sync/service/tuoluojiang/EbFrameAssistServiceframeAssistDelete(Ljava/lang/String;)V getEmployeeId1com/bcxin/sync/service/tuoluojiang/EbAdminServicegetIdByEmployeeId4(Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long;getAfterLeaderType()Ljava/lang/Integer;java/lang/IntegervalueOf(I)Ljava/lang/Integer;frameAssistCreatem(Ljava/lang/Long;Ljava/lang/String;Ljava/lang/Long;Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/String;)VintValue1com/bcxin/sync/service/tuoluojiang/EbFrameServiceupdateFrameUser%(Ljava/lang/String;Ljava/lang/Long;)V getMessageerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!&()*+,-./0-.12-.34-.56-.78-.9:;/*<= >?@A;+N-*- :*  6*:{-*-Q*-:=*-----*- :"#$,%!<b./1 21364A5F7R8b9p;<=>=?AFGKIJLM=\ ?BCA}DC EF1GHIJ>?KLMNOPQ KRS(pTUVWXYM BZ[ KM\]-^_s`a[sbcsde:;! &'<fg-h