48 ? = =     =  =      $    =   =  logLorg/slf4j/Logger; ebUserService2Lcom/bcxin/sync/service/tuoluojiang/EbUserService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;sysUserInfoService/Lcom/bcxin/sync/service/jvs/SysUserInfoService;tenantEmployeesService6Lcom/bcxin/sync/service/tenant/TenantEmployeesService;organizationOpenService9Lcom/bcxin/sync/service/datasync/OrganizationOpenService; tUserService+Lcom/bcxin/sync/service/yehuo/TUserService;()VCodeLineNumberTableLocalVariableTablethis2Lcom/bcxin/sync/consumer/TenantUsersKafkaConsumer;bcxDataSyncTenantUsersToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V orgIdListLjava/util/List;openAndEffectiveZemployeeResponseListeLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;user9Lcom/bcxin/sync/dtos/kafka/message/TenantUserSyncMessage;LocalVariableTypeTable$Ljava/util/List;DLjava/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;id*bcx_data_sync_listener_tenant_users_to_tljtopics&obpm2.binlog-cdc.topic.v2.tenant_usersgroupId!bcx_data_sync_tenant_users_to_tljbcxDataSyncTenantUsersToJvs*bcx_data_sync_listener_tenant_users_to_jvs!bcx_data_sync_tenant_users_to_jvsbcxDataSyncTenantUsersToYehuo,bcx_data_sync_listener_tenant_users_to_yehuo#bcx_data_sync_tenant_users_to_yehuo SourceFileTenantUsersKafkaConsumer.java*Lorg/springframework/stereotype/Component; NO @AC同步陀螺匠，kafka监听tenant-users表，数据转化为：{}  HI     /同步陀螺匠，有职员信息，数量：{} BootstrapMethods    java/util/List JK     ^同步陀螺匠，组织id列表：{}中，有开通陀螺匠，所以需要同步用户信息 BC   0com/bcxin/sync/dtos/response/BcxEmployeeResponse      g同步陀螺匠，组织id列表：{}中，都没有开通陀螺匠，所以不需要同步用户信息java/lang/Exception:同步陀螺匠，kafka监听tenant-users表，异常：{}   O4同步JVS，kafka监听tenant-users表，数据：{} =同步JVS，kafka监听tenant-users表，数据转化为：{})同步JVS，有职员信息，数量：{} R同步JVS，组织id列表：{}中，有开通JVS，所以需要同步用户信息 FG [同步JVS，组织id列表：{}中，都没有开通JVS，所以不需要同步用户信息4同步JVS，kafka监听tenant-users表，异常：{}7同步野火，kafka监听tenant-users表，数据：{}@同步野火，kafka监听tenant-users表，数据转化为：{}  !" #$-同步野火，有新建用户，需要同步 % LM& '7同步野火，kafka监听tenant-users表，异常：{}0com/bcxin/sync/consumer/TenantUsersKafkaConsumer( )*java/lang/Object0org/apache/kafka/clients/consumer/ConsumerRecord0org/springframework/kafka/support/Acknowledgment7com/bcxin/sync/dtos/kafka/message/TenantUserSyncMessage,com/bcxin/sync/common/utils/KafkaMessageUtiltransferKafkaUserRecord2Messagem(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/TenantUserSyncMessage;com/alibaba/fastjson/JSONObject toJSONString&(Ljava/lang/Object;)Ljava/lang/String;org/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)V getUserId()Ljava/lang/String;java/util/Collections singletonList$(Ljava/lang/Object;)Ljava/util/List;java/lang/IntegervalueOf(I)Ljava/lang/Integer;4com/bcxin/sync/service/tenant/TenantEmployeesService#getEmployeeResponseListByUserIdList5(Ljava/util/List;Ljava/lang/Integer;)Ljava/util/List;(cn/hutool/core/collection/CollectionUtil isNotEmpty(Ljava/util/Collection;)Zsize()Istream()Ljava/util/stream/Stream; +,&(Ljava/lang/Object;)Ljava/lang/Object; -F(Lcom/bcxin/sync/dtos/response/BcxEmployeeResponse;)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;#com/bcxin/sync/common/emus/OpenTypeTLJ%Lcom/bcxin/sync/common/emus/OpenType;getCode7com/bcxin/sync/service/datasync/OrganizationOpenServiceisOpenAndEffective(Ljava/util/List;I)Zget(I)Ljava/lang/Object;getCredentialNumber getCardPhoto getHeadPhoto getAfterNamegetAfterTelephone0com/bcxin/sync/service/tuoluojiang/EbUserService userCreateo(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V getMessageerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V acknowledgevalue()Ljava/lang/Object;JVS-com/bcxin/sync/service/jvs/SysUserInfoServicecreatew(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/bcxin/sync/entity/jvs/SysUserInfoEntity; getOpType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypeCREATE.Lcom/bcxin/sync/common/emus/DataOperationType;(Ljava/lang/String;)V)com/bcxin/sync/service/yehuo/TUserService9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Vorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;. /3 4"java/lang/invoke/LambdaMetafactory metafactory6Lookup 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;getOrganizationId7%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles!=?@ABCDEFGDEHIDEJKDELMDENOP/*Q R STUVP +N--*-  :   :*6R*-- -!"#:%&',($QR1245+637G8e9v:{<=>?=AGEFHIRRetWXvcYZ+[X\]ST^_`abcd etWe+[f^gh$ijklmmBno ^`pqDrsstu[svwsxyVP)+*+N+-*-  : , :*-67.*/-- -!0W1:2&',(!$QFOPQ!S2T:UNVlW}XZ[]b`acdRRlYWX}HYZ2[X\]ST^_`abcd lYWe2[f^gh$ijklmmBno ^`pqDrsszu[svws{|VPo3+*+N4--0-5676 89*:-- -!;:<&',(!RU$Q. jkl!n5p?qRuUsWthvnwR4W\]oSTo^_o`a\bcd o^gh RlBno ^`pqDrss}u[svws~OP! =>QD2 051