4 b ` ` `  ` `  R      ` `  `        )   `   `     `   ! " #$%& ' `( )*+ `, -./0 -1 R28 9: ;<=8 ;? 9@A `B CD88 9H `I JK L K NM NOPQR STUlogLorg/slf4j/Logger; ebUserService2Lcom/bcxin/sync/service/tuoluojiang/EbUserService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebAdminService3Lcom/bcxin/sync/service/tuoluojiang/EbAdminService;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;ebEnterpriseRoleService()VCodeLineNumberTableLocalVariableTablethis/Lcom/bcxin/sync/consumer/EmployeeKafkaConsumer;bcxDataSyncEmployeeToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VemployeeResponseListLjava/util/List; ebUserEntity0Lcom/bcxin/sync/entity/tuoluojiang/EbUserEntity;oaAndAttendanceRoleIdLjava/lang/Long;%departmentEmployeeRelationsEntityListentidopenAndEffectiveZeLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;employee7Lcom/bcxin/sync/dtos/kafka/message/EmployeeSyncMessage;LocalVariableTypeTableDLjava/util/List;XLjava/util/List;XLorg/apache/kafka/clients/consumer/ConsumerRecord; StackMapTableRVWXYAZ MethodParameters Signature(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V4Lorg/springframework/kafka/annotation/KafkaListener;id-bcx_data_sync_listener_tenant_employee_to_tljtopics*obpm2.binlog-cdc.topic.v2.tenant_employeesgroupIdbcx_data_sync_employee_to_tljbcxDataSyncEmployeeToRbacroleIdleveLjava/lang/Integer;[.bcx_data_sync_listener_tenant_employee_to_rbacbcx_data_sync_employee_to_rbacbcxDataSyncEmployeeToJvsemployeeResponse2Lcom/bcxin/sync/dtos/response/BcxEmployeeResponse; sysUserInfo-Lcom/bcxin/sync/entity/jvs/SysUserInfoEntity;employeeDepartmentMapLjava/util/Map;departmentIdListdepartmentResponseListdeptMap sysTenant+Lcom/bcxin/sync/entity/jvs/SysTenantEntity;{Ljava/util/Map;>;$Ljava/util/List;FLjava/util/List;5Ljava/util/Map;\/-bcx_data_sync_listener_tenant_employee_to_jvsbcx_data_sync_employee_to_jvs SourceFileEmployeeKafkaConsumer.java*Lorg/springframework/stereotype/Component; ] ^_ cdF同步陀螺匠，kafka监听tenant-employee表，数据转化为：{}` abc de X fgh ij klm no klp qrU同步陀螺匠，组织id：{}，有开通陀螺匠，所以需要同步职员信息 wx sgt uvw xy ef zg{ |}[同步陀螺匠，职员id：{}，还未同步过陀螺匠，所以需要同步用户信息 ~0com/bcxin/sync/dtos/response/BcxEmployeeResponse g g g g g  mn  yz  ij  [  [同步陀螺匠，组织id：{}，没有开通陀螺匠，所以不需要同步职员信息java/lang/Exception=同步陀螺匠，kafka监听tenant-employee表，异常：{} g W A同步rbac，kafka监听tenant-employee表，数据转化为：{} op  lc同步rbac，组织id：{}，有开通高级版，所以需要同步职员信息到rbac基础角色 {| r   }~    i同步rbac，组织id：{}，没有开通高级版，所以不需要同步职员信息到rbac基础角色8同步rbac，kafka监听tenant-employee表，异常：{}@同步JVS，kafka监听tenant-employee表，数据转化为：{} j uv F同步JVS，组织id：{}，有开JVS，所以需要同步职员信息 qr +com/bcxin/sync/entity/jvs/SysUserInfoEntityO同步JVS，职员id：{}，还未同步过JVS，所以需要同步用户信息  BootstrapMethods    java/util/Map  java/util/List    st\ g  ~ O同步JVS，组织id：{}，没有开通JVS，所以不需要同步职员信息7同步JVS，kafka监听tenant-employee表，异常：{}-com/bcxin/sync/consumer/EmployeeKafkaConsumer java/lang/Object0org/apache/kafka/clients/consumer/ConsumerRecord0org/springframework/kafka/support/Acknowledgment5com/bcxin/sync/dtos/kafka/message/EmployeeSyncMessagejava/lang/Long.com/bcxin/sync/entity/tuoluojiang/EbUserEntityjava/lang/Integer)com/bcxin/sync/entity/jvs/SysTenantEntity,com/bcxin/sync/common/utils/KafkaMessageUtil#transferKafkaEmployeeRecord2Messagek(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/EmployeeSyncMessage;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)Z6com/bcxin/sync/service/tuoluojiang/EbEnterpriseService getIdByOrgId$(Ljava/lang/String;)Ljava/lang/Long; getEmployeeIdjava/util/Collections singletonList$(Ljava/lang/Object;)Ljava/util/List;4com/bcxin/sync/service/tenant/TenantEmployeesService'getEmployeeResponseListByEmployeeIdList5(Ljava/util/List;Ljava/lang/Integer;)Ljava/util/List; getUserId0com/bcxin/sync/service/tuoluojiang/EbUserServicegetUserByUserIdD(Ljava/lang/String;)Lcom/bcxin/sync/entity/tuoluojiang/EbUserEntity;get(I)Ljava/lang/Object;getCredentialNumber getCardPhoto getHeadPhotogetEmployeeName getTelephone userCreateo(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V:com/bcxin/sync/service/tuoluojiang/EbEnterpriseRoleServicecreateGetOaAndAttendanceRole"(Ljava/lang/Long;)Ljava/lang/Long;Fcom/bcxin/sync/service/tenant/TenantDepartmentEmployeeRelationsServicegetListByEmployeeIdList"(Ljava/util/List;)Ljava/util/List;1com/bcxin/sync/service/tuoluojiang/EbAdminServiceuserJoin(Ljava/lang/String;Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Lcom/bcxin/sync/dtos/kafka/message/EmployeeSyncMessage;Lcom/bcxin/sync/dtos/kafka/message/ExternalMemberSyncMessage;)VgetAfterIsDomainAdmin()Ljava/lang/Integer;valueOf(I)Ljava/lang/Integer;setAdminOtherInfo(Ljava/lang/String;Ljava/lang/Long;Ljava/lang/String;Lcom/bcxin/sync/dtos/kafka/message/EmployeeSyncMessage;Ljava/lang/Integer;Ljava/lang/Integer;)Lcom/bcxin/sync/entity/tuoluojiang/EbAdminEntity; getMessageerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V acknowledge8com/bcxin/sync/service/tenant/TenantOrganizationsServicegetLevelByOrgId'(Ljava/lang/String;)Ljava/lang/Integer;intValue3com/bcxin/sync/service/tenant/RbacCustomRoleServicegetPTYGRoleIdByOrganizationId getOpType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypeCREATE.Lcom/bcxin/sync/common/emus/DataOperationType;7com/bcxin/sync/service/tenant/RbacCustomRoleUserService createAndSave7(Ljava/lang/String;Ljava/lang/Long;Ljava/lang/String;)VgetBeforeStatus-()Lcom/bcxin/sync/common/emus/EmployedStatus;)com/bcxin/sync/common/emus/EmployedStatusgetAfterStatusdeleteByRoleIdAndEmployeeId%(Ljava/lang/Long;Ljava/lang/String;)VJVS+com/bcxin/sync/service/jvs/SysTenantServicegetById?(Ljava/lang/String;)Lcom/bcxin/sync/entity/jvs/SysTenantEntity;-com/bcxin/sync/service/jvs/SysUserInfoService*(Ljava/io/Serializable;)Ljava/lang/Object;createw(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/bcxin/sync/entity/jvs/SysUserInfoEntity;stream()Ljava/util/stream/Stream; &(Ljava/lang/Object;)Ljava/lang/Object; Z(Lcom/bcxin/sync/entity/tenant/TenantDepartmentEmployeeRelationsEntity;)Ljava/lang/String;apply()Ljava/util/function/Function;java/util/stream/Collectors groupingBy;(Ljava/util/function/Function;)Ljava/util/stream/Collector;java/util/stream/Streamcollect0(Ljava/util/stream/Collector;)Ljava/lang/Object; map8(Ljava/util/function/Function;)Ljava/util/stream/Stream;toList()Ljava/util/stream/Collector;6com/bcxin/sync/service/tenant/TenantDepartmentsService)getDepartmentResponseListByOrganizationId4(Ljava/lang/String;Ljava/util/List;)Ljava/util/List; KH(Lcom/bcxin/sync/dtos/response/BcxDepartmentResponse;)Ljava/lang/String; toMapX(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;getId getHiredDate()Ljava/util/Date;/com/bcxin/sync/service/jvs/SysUserTenantService(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Date;Ljava/util/List;Ljava/util/Map;Lcom/bcxin/sync/dtos/kafka/message/EmployeeSyncMessage;)Vorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;  g g"java/lang/invoke/LambdaMetafactory metafactoryLookup 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;Dcom/bcxin/sync/entity/tenant/TenantDepartmentEmployeeRelationsEntitygetDepartmentId2com/bcxin/sync/dtos/response/BcxDepartmentResponsegetDepartmentName%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles!`bcdefghijghklghmnghopghqrghstghuvghwxghyzgh{|gh}~ghghgh/*,  X+N--'*- 6* - :-*-:*-:b-*-* :*!-": *#--- -$*#---%&'W(-:*+,,-;>)vOPRS*T/U<VAXOY`Zm[r\]^_]abcfg&f*i-j;o>m@nQpWqp `mN> <*@XXXS `> X+X B gs[ss+N.--*/-0:12-*3-4:-5676*8--9N-:;-<;*8-=)-:;-<;*8--9>-:?+,,-)Rxy{|$}-~;HXlHHo$ l$% B gs[ssG +N@--Q*-A 6+*B-C:D-*-::*E-FG:,H-*E-IW*!-":  JKLMN:  JOPQMR: *S- T:  JUVWMN: *XY--Z [\R -]^-:_+,,-eh)z*/<AO`m}2CQTWehj{`m} b S 5 <*;j}H` b S 5 ?  B gs[ss! `a*g 3*456745>745EF45GF