4 ([ \] &^_ `a bc de fg dhi [j k dl m &n op &q rs rtu [ v dw x fy z { &| }~ b ! b  logLorg/slf4j/Logger;rbacCustomRoleService5Lcom/bcxin/sync/service/tenant/RbacCustomRoleService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;organizationOpenService9Lcom/bcxin/sync/service/datasync/OrganizationOpenService; redisCache#Lcom/bcxin/sync/service/RedisCache;()VCodeLineNumberTableLocalVariableTablethis:Lcom/bcxin/sync/consumer/TenantOrganizationsKafkaConsumer;bcxDataSyncTenantOrganizationsg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VkeyLjava/lang/String;request5Lcom/bcxin/sync/dtos/request/OrganizationOpenRequest;eLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment; organizationsBLcom/bcxin/sync/dtos/kafka/message/TenantOrganizationsSyncMessage;LocalVariableTypeTableXLorg/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_tenant_organizationstopics.obpm2.binlog-cdc.topic.v2.tenant_organizationsgroupId"bcx_data_sync_tenant_organizations SourceFile%TenantOrganizationsKafkaConsumer.java(Lorg/springframework/stereotype/Service; 34 )*9kafka监听tenant-organizations表，数据转化为：{}    java/lang/StringBuilderdata-sync:org:level: 12 +, 3com/bcxin/sync/dtos/request/OrganizationOpenRequest /0 ;组织不是高级版，无需初始化<普通员工>角色 java/lang/Exception0kafka监听tenant-organizations表，异常：{}  48com/bcxin/sync/consumer/TenantOrganizationsKafkaConsumer java/lang/Object@com/bcxin/sync/dtos/kafka/message/TenantOrganizationsSyncMessage,com/bcxin/sync/common/utils/KafkaMessageUtil(transferKafkaOrganizationsRecord2Messagev(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/TenantOrganizationsSyncMessage;com/alibaba/fastjson/JSONObject toJSONString&(Ljava/lang/Object;)Ljava/lang/String;org/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)VgetBeforeLevel()Ljava/lang/Integer;java/lang/IntegerintValue()I getAfterLevelappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;getOrganizationId()Ljava/lang/String;toString!com/bcxin/sync/service/RedisCache deleteObject(Ljava/lang/String;)Z3com/bcxin/sync/service/tenant/RbacCustomRoleServiceinitRole(Ljava/lang/String;)VinitUserPermitsetOrganizationId getAfterNamesetOrganizationNamevalueOf(I)Ljava/lang/Integer; setOpenType(Ljava/lang/Integer;)V setOpenDay7com/bcxin/sync/service/datasync/OrganizationOpenService openThird8(Lcom/bcxin/sync/dtos/request/OrganizationOpenRequest;)V 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;!&()*+,-./0-.12-.345/*67 89:;5+N----- - v Y  - :*W*-*-Y:--*  :"#$,%!6Z%&()**;-S.]0h2s4|56789:;?=>@A7HSX<=|/>?@A89BCDEFGH BIJK BLM BDNO-PQsRS[sTUsVW45! &'6XY-Z