4 .p qr ,st uv wx ,y z{ |} |~  , ,  , z  , z z ~  w ,   ' w  logLorg/slf4j/Logger;ebAdminService3Lcom/bcxin/sync/service/tuoluojiang/EbAdminService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;ebAttendanceWhitelistServiceALcom/bcxin/sync/service/tuoluojiang/EbAttendanceWhitelistService;organizationOpenService9Lcom/bcxin/sync/service/datasync/OrganizationOpenService;rbacPermitOptionRoleService;Lcom/bcxin/sync/service/tenant/RbacPermitOptionRoleService;tenantOrganizationsService:Lcom/bcxin/sync/service/tenant/TenantOrganizationsService;()VCodeLineNumberTableLocalVariableTablethis9Lcom/bcxin/sync/consumer/RbacCustomRoleUserKafkaConsumer;"bcxDataSyncRbacCustomRoleUserToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VadminIdLjava/lang/Long;isRoleContainsOptionCodeZentidopenAndEffectiveleveLjava/lang/Integer;eLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;rbacCustomRoleUserALcom/bcxin/sync/dtos/kafka/message/RbacCustomRoleUserSyncMessage;LocalVariableTypeTableXLorg/apache/kafka/clients/consumer/ConsumerRecord; StackMapTableMethodParameters Signature(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V4Lorg/springframework/kafka/annotation/KafkaListener;id3bcx_data_sync_listener_rbac_custom_role_user_to_tljtopics/obpm2.binlog-cdc.topic.v2.rbac_custom_role_usergroupId*bcx_data_sync_rbac_custom_role_user_to_tlj SourceFile$RbacCustomRoleUserKafkaConsumer.java*Lorg/springframework/stereotype/Component; ?@ /0:kafka监听rbac_custom_role_user表，数据转化为：{}  9:   =>  56 C组织id：{}，有开通陀螺匠，所以需要同步权限信息 ;<   J角色：{},是需要同步的 12   A组织id：{}，职员id：{}，新增考勤管理员权限信息 78  A组织id：{}，职员id：{}，删除考勤管理员权限信息 !角色：{},是不需要同步的[组织id：{}，没开通陀螺匠或没开通高级版，所以不需要同步权限信息java/lang/Exception1kafka监听rbac_custom_role_user表，异常：{}  @7com/bcxin/sync/consumer/RbacCustomRoleUserKafkaConsumer java/lang/Object0org/apache/kafka/clients/consumer/ConsumerRecord0org/springframework/kafka/support/Acknowledgment?com/bcxin/sync/dtos/kafka/message/RbacCustomRoleUserSyncMessagejava/lang/Integerjava/lang/Long,com/bcxin/sync/common/utils/KafkaMessageUtil'transferKafkaRbacCustomRoleUser2Messageu(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/RbacCustomRoleUserSyncMessage;com/alibaba/fastjson/JSONObject toJSONString&(Ljava/lang/Object;)Ljava/lang/String;org/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)VgetOrganizationId()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)Z8com/bcxin/sync/service/tenant/TenantOrganizationsServicegetLevelByOrgId'(Ljava/lang/String;)Ljava/lang/Integer;intValue6com/bcxin/sync/service/tuoluojiang/EbEnterpriseService getIdByOrgId$(Ljava/lang/String;)Ljava/lang/Long; getRbacRoleId()Ljava/lang/Long;$com/bcxin/sync/common/CommonConstantNEED_SYNC_PERMIT_CODESLjava/util/List;9com/bcxin/sync/service/tenant/RbacPermitOptionRoleService#(Ljava/lang/Long;Ljava/util/List;)ZgetTenantEmployeeId1com/bcxin/sync/service/tuoluojiang/EbAdminServicegetIdByEmployeeId4(Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long;getType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypeCREATE.Lcom/bcxin/sync/common/emus/DataOperationType;9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)VvalueOf(I)Ljava/lang/Integer;?com/bcxin/sync/service/tuoluojiang/EbAttendanceWhitelistServiceattendanceWhitelistCreate6(Ljava/lang/Long;Ljava/lang/Long;Ljava/lang/Integer;)VDELETEattendanceWhitelistDelete&(Ljava/lang/Long;Ljava/lang/Integer;)V getMessageerror acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!,./01234563478349:34;<34=>34?@A/*BC DEFGA{ ?+N-*- 6* - :*-:-*-6-*-:7-'--* !72-""#--* $%-&-:()*,+"%'Bn/02&334A5N6S7a8q9v:;<?@BEFIJMN"R%P'Q8S>TCf mHIqJKNLI&MK3NO'PQ?DE?RS?TU:VWX ?RYZ0 [\]^_``3  Bab RTcd3efsgh[sijskl@A! ,-Bmn3o