4 e c c c  c c          c  c  c *  . . . * * * * *  c     J       c    c J  ! "# "$% P &' "(  ) *+ , - ". "/ c0 12345 ^6 7 89: ;<=logLorg/slf4j/Logger; ebUserService2Lcom/bcxin/sync/service/tuoluojiang/EbUserService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebAdminInfoService7Lcom/bcxin/sync/service/tuoluojiang/EbAdminInfoService;ebFrameAssistService9Lcom/bcxin/sync/service/tuoluojiang/EbFrameAssistService;ebAttendanceGroupMemberServiceCLcom/bcxin/sync/service/tuoluojiang/EbAttendanceGroupMemberService;ebAttendanceGroupService=Lcom/bcxin/sync/service/tuoluojiang/EbAttendanceGroupService;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;ebAdminService3Lcom/bcxin/sync/service/tuoluojiang/EbAdminService;ebEnterpriseRoleService()VCodeLineNumberTableLocalVariableTablethis;Lcom/bcxin/sync/consumer/AttendanceSitePersonKakfaConsumer;$bcxDataSyncAttendanceSitePersonToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VattendanceSiteBaseInfo>Lcom/bcxin/sync/entity/tenant/TlkAttendanceSiteBaseInfoEntity; outEmployee2Lcom/bcxin/sync/dtos/response/BcxEmployeeResponse; ebUserEntity0Lcom/bcxin/sync/entity/tuoluojiang/EbUserEntity; employeeIdLjava/lang/String;oaAndAttendanceRoleIdLjava/lang/Long; ebAdminEntity1Lcom/bcxin/sync/entity/tuoluojiang/EbAdminEntity;employeeResponseListLjava/util/List; adminEntityadminInfoEntity5Lcom/bcxin/sync/entity/tuoluojiang/EbAdminInfoEntity;groupId itemAttTypeadminIdentidopenAndEffectiveZeLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment; attSitePersonCLcom/bcxin/sync/dtos/kafka/message/AttendanceSitePersonSyncMessage;LocalVariableTypeTableDLjava/util/List;XLorg/apache/kafka/clients/consumer/ConsumerRecord; StackMapTable:>?@ABCD4MethodParameters Signature(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V4Lorg/springframework/kafka/annotation/KafkaListener;id4bcx_data_sync_listener_attendance_site_person_to_tljtopicsAbaibaodunflow.binlog-cdc.topic.v2.tlk_attendance_site_person_info+bcx_data_sync_attendance_site_person_to_tlj SourceFile&AttendanceSitePersonKakfaConsumer.java*Lorg/springframework/stereotype/Component; E FG fgDkafka监听tlk_attendance_site_person_info表，数据转化为：{}H IJK LM z{@ NOP QR STU VW tuX YZI组织id：{}，有开通陀螺匠，所以需要同步驻勤人员信息 rs [O\ ]Z |}^ _`com/bcxin/sync/service/tenant/TlkAttendanceSiteBaseInfoServicegetById*(Ljava/io/Serializable;)Ljava/lang/Object;getIdgetItemAttendanceSiteName getItemAttendanceSiteFullAddressgetItemAttendanceSiteLongitude()Ljava/math/BigDecimal;getItemAttendanceSiteLatitudegetItemPerformRangegetItemPrincipalgetItemAttTypeattendanceGroupCreate(Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/math/BigDecimal;Ljava/math/BigDecimal;Ljava/math/BigDecimal;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Long;&(Ljava/lang/String;)Ljava/lang/String; getEmployeeId1com/bcxin/sync/service/tuoluojiang/EbAdminServicegetIdByEmployeeId4(Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long;'com/bcxin/sync/common/utils/CommonUtilsisLinBao(Ljava/lang/String;)Zjava/util/Collections singletonList$(Ljava/lang/Object;)Ljava/util/List;java/lang/IntegervalueOf(I)Ljava/lang/Integer;4com/bcxin/sync/service/tenant/TenantEmployeesService'getEmployeeResponseListByEmployeeIdList5(Ljava/util/List;Ljava/lang/Integer;)Ljava/util/List;(cn/hutool/core/collection/CollectionUtil isNotEmpty(Ljava/util/Collection;)Zget(I)Ljava/lang/Object; getUserId0com/bcxin/sync/service/tuoluojiang/EbUserServicegetUserByUserIdD(Ljava/lang/String;)Lcom/bcxin/sync/entity/tuoluojiang/EbUserEntity;append-(Ljava/lang/String;)Ljava/lang/StringBuilder;toStringgetCredentialNumber 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;userJoin(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;)VsetAdminOtherInfo(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;()Ljava/lang/Long;getType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypeCREATE.Lcom/bcxin/sync/common/emus/DataOperationType;getReportingTime()Ljava/util/Date;getPushAttendance()Ljava/lang/Integer;intValueAcom/bcxin/sync/service/tuoluojiang/EbAttendanceGroupMemberServiceaddMemberExclude3(Ljava/lang/Long;Ljava/lang/Long;Ljava/lang/Long;)V addMember(Ljava/lang/Long;Ljava/lang/Long;Ljava/lang/Long;Ljava/lang/Integer;Z)Lcom/bcxin/sync/entity/tuoluojiang/EbAttendanceGroupMemberEntity;getUid5com/bcxin/sync/service/tuoluojiang/EbAdminInfoServicegetByUserIdAndEntidY(Ljava/lang/String;Ljava/lang/Long;)Lcom/bcxin/sync/entity/tuoluojiang/EbAdminInfoEntity;3com/bcxin/sync/entity/tuoluojiang/EbAdminInfoEntitysetType(Ljava/lang/Integer;)Vcn/hutool/core/date/DateUtilformatDateTime$(Ljava/util/Date;)Ljava/lang/String; setWorkTime(Ljava/lang/String;)V updateById(Ljava/lang/Object;)ZDELETE deleteMemberF(Ljava/lang/Long;Ljava/lang/Long;Ljava/lang/Long;Ljava/lang/Integer;)VdeleteMemberExclude(Ljava/util/List;)V getIsPart setQuitTime7com/bcxin/sync/service/tuoluojiang/EbFrameAssistServiceframeAssistDelete#(Ljava/lang/Long;Ljava/lang/Long;)V getMessageerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!ce fghijklmjknojkpqjkrsjktujkvwjkxyjkz{jk|}jk~jk/*% ! \+N-*- 6 * - :-*-:F*-:*:*-:*- !:"#-*$- %&':  ( )*: *+ ,-: .Y/ ,010-02:  43 *+ , 4 5 6 7 89*:;: *- , <*   5&&=: >:z-?@A@B-"-C-DF-DE;*FG*F&HW*IJ: *K LM:  1 NE% &O PYQRS*K TW*F&HW-?@U@V-*F&W"z*F%X*IJ: *K LM:  K YE? NE3 &O PYQRZ*K TW*[ >\]-:_`a,b?B^"HBCE&F+G8H=IKJXK]LmMzNOPQMSTUVWXYZ[\.]3^?_O`Yaa_dcodghinopqstuvx$y4zE|N}]~gj .1?BDU[m3  . o>   $C 43 ] M Xr8&D\\\W \  H Hp B js[ss! cd#j