4 1p qr /st uv wx /y z{ |} |~  /  z ~  / z z  z   w  | /  /   logLorg/slf4j/Logger;ebFrameService3Lcom/bcxin/sync/service/tuoluojiang/EbFrameService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;sysDeptService+Lcom/bcxin/sync/service/jvs/SysDeptService;sysTenantService-Lcom/bcxin/sync/service/jvs/SysTenantService;organizationOpenService9Lcom/bcxin/sync/service/datasync/OrganizationOpenService;()VCodeLineNumberTableLocalVariableTablethis1Lcom/bcxin/sync/consumer/DepartmentKafkaConsumer;bcxDataSyncDeptToTljg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)VpidLjava/lang/Long;entidopenAndEffectiveZeLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment; department9Lcom/bcxin/sync/dtos/kafka/message/DepartmentSyncMessage;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_tenant_department_to_tljtopics,obpm2.binlog-cdc.topic.v2.tenant_departmentsgroupIdbcx_data_sync_dept_to_tljbcxDataSyncDeptToJvs sysTenant+Lcom/bcxin/sync/entity/jvs/SysTenantEntity;/bcx_data_sync_listener_tenant_department_to_jvsbcx_data_sync_dept_to_jvs SourceFileDepartmentKafkaConsumer.java*Lorg/springframework/stereotype/Component; @A 23H同步陀螺匠，kafka监听tenant-department表，数据转化为：{}  >?   89 U同步陀螺匠，组织id：{}，有开通陀螺匠，所以需要同步部门信息  .同步陀螺匠，组织id：{}，删除部门 45  7同步陀螺匠，组织id：{}，新增或修改部门  X同步陀螺匠，组织id：{}，没开通陀螺匠，所以不需要同步部门信息java/lang/Exception?同步陀螺匠，kafka监听tenant-department表，异常：{}  AB同步JVS，kafka监听tenant-department表，数据转化为：{} <= I同步JVS，组织id：{}，有开通JVS，所以需要同步部门信息(同步JVS，组织id：{}，删除部门 :; 1同步JVS，组织id：{}，新增或修改部门 L同步JVS，组织id：{}，没开通JVS，所以不需要同步部门信息9同步JVS，kafka监听tenant-department表，异常：{}/com/bcxin/sync/consumer/DepartmentKafkaConsumer java/lang/Object7com/bcxin/sync/dtos/kafka/message/DepartmentSyncMessagejava/lang/Long)com/bcxin/sync/entity/jvs/SysTenantEntity,com/bcxin/sync/common/utils/KafkaMessageUtiltransferKafkaDeptRecord2Messagem(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/DepartmentSyncMessage;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;getType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypeDELETE.Lcom/bcxin/sync/common/emus/DataOperationType;getDepartmentIdgetAfterDepartmentName1com/bcxin/sync/service/tuoluojiang/EbFrameService frameDelete'(Ljava/lang/String;Ljava/lang/String;)VgetAfterParentId$org/apache/commons/lang3/StringUtils isNotBlank(Ljava/lang/CharSequence;)ZgetIdByDepartmentId frameCreateV(Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long; getMessageerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V0org/springframework/kafka/support/Acknowledgment acknowledgeJVS+com/bcxin/sync/service/jvs/SysTenantServicegetById?(Ljava/lang/String;)Lcom/bcxin/sync/entity/jvs/SysTenantEntity;)com/bcxin/sync/service/jvs/SysDeptServicedeletegetIdcreate\(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;org/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!/12345678967:;67<=67>?67@AB/*CD EFGHB+N-*- 6* - :}--#-*--?-:-*-:*--W-: ,!CZ-.0&1+283=5K6[8i9{;<=>@CDHFGIJDR+IJ8KJ&LMNOEFPQRSTUV PWX{YZ'Z B[\ PR]^6_`sab[scdsefHB+N"-*-# 6}*$-%:h&--#'-*(--)**-*(+---,W--:. ,!CNPQS&T+U8V=XKY[[i\{^_bcgefhiDH8jgh&LMNOEFPQRSTUV PWX{Yi& B[\ PR]^6_`sjb[scdsklAB! /0Cmn6o