4 2o pq 0rs tu vw 0x yz {| {} ~ 0  y  o y }   0 y y y y y y y y   + v  logLorg/slf4j/Logger;ebAttendanceGroupService=Lcom/bcxin/sync/service/tuoluojiang/EbAttendanceGroupService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;organizationOpenService9Lcom/bcxin/sync/service/datasync/OrganizationOpenService;()VCodeLineNumberTableLocalVariableTablethis5Lcom/bcxin/sync/consumer/AttendanceSiteKafkaConsumer;bcxDataSyncAttendanceSiteToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VendDateLcn/hutool/core/date/DateTime;nowLjava/util/Date;entidLjava/lang/Long;openAndEffectiveZeLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;attSite=Lcom/bcxin/sync/dtos/kafka/message/AttendanceSiteSyncMessage;LocalVariableTypeTableXLorg/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_attendance_site_to_tljtopics?baibaodunflow.binlog-cdc.topic.v2.tlk_attendance_site_base_infogroupId$bcx_data_sync_attendance_site_to_tlj SourceFile AttendanceSiteKafkaConsumer.java*Lorg/springframework/stereotype/Component; => 34Bkafka监听tlk_attendance_site_base_info表，数据转化为：{}  ;<   9: F组织id：{}，有开通陀螺匠，所以需要同步驻勤点信息  java/util/Date  %组织id：{}，新增驻勤点信息 @组织id：{}，新增驻勤点信息，驻勤点在有效期内 56  (组织id：{}，修改了驻勤点信息C组织id：{}，修改了驻勤点信息，驻勤点在有效期内F组织id：{}，修改了驻勤点信息，驻勤点过期了，删除 1组织id：{}，删除了驻勤点信息，删除I组织id：{}，没开通陀螺匠，所以不需要同步驻勤点信息java/lang/Exception9kafka监听tlk_attendance_site_base_info表，异常：{}  >3com/bcxin/sync/consumer/AttendanceSiteKafkaConsumer java/lang/Object0org/apache/kafka/clients/consumer/ConsumerRecord0org/springframework/kafka/support/Acknowledgment;com/bcxin/sync/dtos/kafka/message/AttendanceSiteSyncMessagejava/lang/Longcn/hutool/core/date/DateTime,com/bcxin/sync/common/utils/KafkaMessageUtil"transferKafkaAttSiteRecord2Messageq(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/AttendanceSiteSyncMessage;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;getAfterEndDate()Ljava/util/Date;cn/hutool/core/date/DateUtil offsetDay1(Ljava/util/Date;I)Lcn/hutool/core/date/DateTime;getType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypeCREATE.Lcom/bcxin/sync/common/emus/DataOperationType;after(Ljava/util/Date;)ZgetAttendanceSiteIdgetAfterAttSiteNamegetAfterFullAddressgetAfterLongitude()Ljava/math/BigDecimal;getAfterLatitudegetAfterPerformRangegetAfterPrincipal getAttType;com/bcxin/sync/service/tuoluojiang/EbAttendanceGroupServiceattendanceGroupCreate(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;UPDATEjava/util/Collections singletonList$(Ljava/lang/Object;)Ljava/util/List;attendanceGroupDelete(Ljava/util/List;)V getMessageerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!023456789:78;<78=>?/*@A BCDE? +N--`*- 6:* - :%--:Y:-V-ܲ-*------- -!"W-#u$->%-*------- -!"W>&-*-'()-*-'(*-:,-.,/tw+@%*+-.*//0<1A2O3Y4b5r6789:;9=>?@A BC!A(E6FGIUJcMfNtSwQyRTUA\ Y FGbHI<'JK*JLMyNOBCPQRSTUV PWX/YZ[\]^_b B`a PRbc7desfg[shisjk>?! 01@lm7n