4 /q rs -tu vw xy z {| }~ - { - -  - { { -   x -   ( x  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;rbacPermitOptionUserService;Lcom/bcxin/sync/service/tenant/RbacPermitOptionUserService;tenantOrganizationsService:Lcom/bcxin/sync/service/tenant/TenantOrganizationsService;()VCodeLineNumberTableLocalVariableTablethis;Lcom/bcxin/sync/consumer/RbacPermitOptionUserKafkaConsumer;$bcxDataSyncRbacPermitOptionUserToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V existPermitZadminIdLjava/lang/Long;entidopenAndEffectiveleveLjava/lang/Integer;eLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;rbacPermitOptionUserCLcom/bcxin/sync/dtos/kafka/message/RbacPermitOptionUserSyncMessage;LocalVariableTypeTableXLorg/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_user_to_tljtopics1obpm2.binlog-cdc.topic.v2.rbac_permit_option_usergroupId,bcx_data_sync_rbac_permit_option_user_to_tlj SourceFile&RbacPermitOptionUserKafkaConsumer.java*Lorg/springframework/stereotype/Component; @A 01?  67 C组织id：{}，有开通陀螺匠，所以需要同步权限信息 <=  23 $com/bcxin/sync/common/CommonConstantattendance_manager A组织id：{}，职员id：{}，新增考勤管理员权限信息 89  A组织id：{}，职员id：{}，删除考勤管理员权限信息 F组织id：{}，没开通陀螺匠，所以不需要同步权限信息权限{},是不需要同步的java/lang/Exception3kafka监听rbac_permit_option_user表，异常：{}  A9com/bcxin/sync/consumer/RbacPermitOptionUserKafkaConsumer java/lang/Object0org/apache/kafka/clients/consumer/ConsumerRecord0org/springframework/kafka/support/AcknowledgmentAcom/bcxin/sync/dtos/kafka/message/RbacPermitOptionUserSyncMessagejava/lang/Integerjava/lang/Long,com/bcxin/sync/common/utils/KafkaMessageUtil)transferKafkaRbacPermitOptionUser2Messagew(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/RbacPermitOptionUserSyncMessage;com/alibaba/fastjson/JSONObject toJSONString&(Ljava/lang/Object;)Ljava/lang/String;org/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)VNEED_SYNC_PERMIT_CODESLjava/util/List; getOptionCode()Ljava/lang/String;java/util/Listcontains(Ljava/lang/Object;)ZgetOrganizationId#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;getTenantEmployeeIdgetPermitOptionId()Ljava/lang/Long;9com/bcxin/sync/service/tenant/RbacPermitOptionUserService isExistPermit%(Ljava/lang/String;Ljava/lang/Long;)Z1com/bcxin/sync/service/tuoluojiang/EbAdminServicegetIdByEmployeeId4(Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long;java/lang/Stringequals9(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;)VattendanceWhitelistDelete&(Ljava/lang/Long;Ljava/lang/Integer;)V getMessageerror acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!-/01234567458945:;45<=45>?45@AB/*CD EFGHB B+N--  -* - 6*- :*- :- *--6*-:c3-R- - *!"#.-"$- - *!"%&- '-:)*+,,%((Cv./1"203C4P5^6k7p8~:;<=?@AEFGLMOP%T(R*S;UAVDf tIJeKLkMLCNJPOP*QRBEFBSTBUV=WXY BSZ[. \]^_`aa*  Bbc SUde4fgshi[sjkslmAB! -.Cno4p