4L > < ) # < < <  < < < #  #   ( < (   7  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;rbacCustomRoleUserService9Lcom/bcxin/sync/service/tenant/RbacCustomRoleUserService;rbacPermitOptionRoleService;Lcom/bcxin/sync/service/tenant/RbacPermitOptionRoleService;tenantOrganizationsService:Lcom/bcxin/sync/service/tenant/TenantOrganizationsService;()VCodeLineNumberTableLocalVariableTablethis;Lcom/bcxin/sync/consumer/RbacPermitOptionRoleKafkaConsumer;$bcxDataSyncRbacPermitOptionRoleToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)Vadmin1Lcom/bcxin/sync/entity/tuoluojiang/EbAdminEntity;adminEntityListLjava/util/List; existPermitZroleUserEntityListentidLjava/lang/Long;openAndEffectiveleveLjava/lang/Integer;eLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;rbacPermitOptionRoleCLcom/bcxin/sync/dtos/kafka/message/RbacPermitOptionRoleSyncMessage;LocalVariableTypeTableCLjava/util/List;ILjava/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;id5bcx_data_sync_listener_rbac_permit_option_role_to_tljtopics1obpm2.binlog-cdc.topic.v2.rbac_permit_option_rolegroupId,bcx_data_sync_rbac_permit_option_role_to_tlj SourceFile&RbacPermitOptionRoleKafkaConsumer.java*Lorg/springframework/stereotype/Component; QR ?@&(Ljava/lang/Object;)Ljava/lang/Object; ?@K(Lcom/bcxin/sync/entity/tenant/RbacCustomRoleUserEntity;)Ljava/lang/String;apply()Ljava/util/function/Function;java/util/stream/Streammap8(Ljava/util/function/Function;)Ljava/util/stream/Stream;java/util/stream/CollectorstoList()Ljava/util/stream/Collector;collect0(Ljava/util/stream/Collector;)Ljava/lang/Object;1com/bcxin/sync/service/tuoluojiang/EbAdminServicegetListByEmployeeIdList2(Ljava/util/List;Ljava/lang/Long;)Ljava/util/List;iterator()Ljava/util/Iterator;hasNext()Znext()Ljava/lang/Object;java/lang/Stringequals getUniqued9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)VgetIdvalueOf(I)Ljava/lang/Integer;?com/bcxin/sync/service/tuoluojiang/EbAttendanceWhitelistServiceattendanceWhitelistCreate6(Ljava/lang/Long;Ljava/lang/Long;Ljava/lang/Integer;)VattendanceWhitelistDelete&(Ljava/lang/Long;Ljava/lang/Integer;)V getMessageerror acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;A BFG H"java/lang/invoke/LambdaMetafactory metafactoryJLookup InnerClasses(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;5com/bcxin/sync/entity/tenant/RbacCustomRoleUserEntitygetTenantEmployeeIdK%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles!<>?@ABCDEFCDGHCDIJCDKLCDMNCDOPCDQRS/*T!U VWXYS9 +N-- R -* - 6*- :*- :- *--6*-:* !"#$:   %:  &z '(: 7*-+Z,-  -.*/ 0122*-+&3-  -.*/ 0145- 6-:89:,;7T!679":0;C<P=^>k?p@~BDEFGHIKLM+Q7RJSZV]Z`[n]q^b`acdUz hZ[ \] ^_`]kabC+c_PdefgVWhijklmn \o `phqrQ stuvwxyyzN{.stuvw  B|} hj~Cs[ssRS! <=T CE CID