48 5 C C  C  C            E  C  '    -  - - *  C   >  a EN  L logLorg/slf4j/Logger;ebEnterpriseService8Lcom/bcxin/sync/service/tuoluojiang/EbEnterpriseService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;ebAdminService3Lcom/bcxin/sync/service/tuoluojiang/EbAdminService;mcNoticeService/Lcom/bcxin/sync/service/tenant/McNoticeService;NEED_SYNC_NOTICE_CATE_IDLjava/util/List; Signature"Ljava/util/List;SUBJECT_TYPE_APP_CODELjava/util/Map;3Ljava/util/Map;()VCodeLineNumberTableLocalVariableTablethis@Lcom/bcxin/sync/consumer/EbEnterpriseMessageNoticeKakfaConsumer;(bcxDataSyncEbEnterpriseMessageNoticeToV5g(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V adminEntity1Lcom/bcxin/sync/entity/tuoluojiang/EbAdminEntity;enterpriseEntity6Lcom/bcxin/sync/entity/tuoluojiang/EbEnterpriseEntity;mcNoticeEntity-Lcom/bcxin/sync/entity/tenant/McNoticeEntity; linkParamsDto2Lcom/bcxin/sync/dtos/tenant/McNoticeLinkParamsDto; contentDto/Lcom/bcxin/sync/dtos/tenant/McNoticeContentDto;summaryLjava/lang/String;eLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;noticeHLcom/bcxin/sync/dtos/kafka/message/EbEnterpriseMessageNoticeSyncMessage;LocalVariableTypeTableXLorg/apache/kafka/clients/consumer/ConsumerRecord; StackMapTableMethodParameters(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;)V4Lorg/springframework/kafka/annotation/KafkaListener;id9bcx_data_sync_listener_eb_enterprise_message_notice_to_v5topics SourceFile+EbEnterpriseMessageNoticeKakfaConsumer.java(Lorg/springframework/stereotype/Service; bc QRAkafka监听eb_enterprise_message_notice表，数据转化为：{}    [\ 2陀螺匠有新增消息通知，消息类型：{} WX  /com/bcxin/sync/entity/tuoluojiang/EbAdminEntity ST 4com/bcxin/sync/entity/tuoluojiang/EbEnterpriseEntity+com/bcxin/sync/entity/tenant/McNoticeEntity                0com/bcxin/sync/dtos/tenant/McNoticeLinkParamsDto _` java/lang/String b  -com/bcxin/sync/dtos/tenant/McNoticeContentDto    ! b" # Q%sjava/lang/Object $ % &' ( YZ) *其他类型消息不同步  java/lang/Exception8kafka监听eb_enterprise_message_notice表，异常：{} +,- .c>com/bcxin/sync/consumer/EbEnterpriseMessageNoticeKakfaConsumer/ 01java/lang/Long  23 45java/util/HashMap__yXF3gCR1rLDkGP9l3Vm 67__nxvdMJ82R9ZsXae3UGLFcom/bcxin/sync/dtos/kafka/message/EbEnterpriseMessageNoticeSyncMessage,com/bcxin/sync/common/utils/KafkaMessageUtil4transferKafkaEbEnterpriseMessageNoticeRecord2Message|(Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lcom/bcxin/sync/dtos/kafka/message/EbEnterpriseMessageNoticeSyncMessage;com/alibaba/fastjson/JSONObject toJSONString&(Ljava/lang/Object;)Ljava/lang/String;org/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)VgetType0()Lcom/bcxin/sync/common/emus/DataOperationType;,com/bcxin/sync/common/emus/DataOperationTypegetCode()ICREATE.Lcom/bcxin/sync/common/emus/DataOperationType; getCateId()Ljava/lang/Long;java/util/Listcontains(Ljava/lang/Object;)Z getCateName()Ljava/lang/String; getAdminId1com/bcxin/sync/service/tuoluojiang/EbAdminServicegetById*(Ljava/io/Serializable;)Ljava/lang/Object;getEntid6com/bcxin/sync/service/tuoluojiang/EbEnterpriseServicejava/util/UUID randomUUID()Ljava/util/UUID;toStringsetId(Ljava/lang/String;)Vjava/lang/IntegervalueOf(I)Ljava/lang/Integer; setIsRead(Ljava/lang/Integer;)V getUniqued setToUserId getCreatedAt()Ljava/util/Date; setCreateTime(Ljava/util/Date;)V setDomainId setModuleintValuesetSubjectType java/util/Mapget&(Ljava/lang/Object;)Ljava/lang/Object; setLinkParamsgetUidgetNamegetTitle getMessage(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Date;)V setContent()Ljava/lang/Integer; getContentformat9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; setSummary-com/bcxin/sync/service/tenant/McNoticeServicesaveerror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V0org/springframework/kafka/support/Acknowledgment acknowledgeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;(J)Ljava/lang/Long;"cn/hutool/core/collection/ListUtilof%([Ljava/lang/Object;)Ljava/util/List;put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;!C5QRSTUVWXUVYZUV[\]^_`]abcd/*e#f ghijd s+N-- ,- % -  -*-:*:Y:- !"#-$- %&'Y(- )*+:,-Y./"- %--0-1- 2:345Y6SY7S8:  9*:;W <=:?@A,BVY>e"78:$;.<9=G>W?hAqB|CDEFGHJKMNOPR'S3R8T?VIWLXV\YZ[[l]r^fp Wklhmnqopwqr6st8uv [wxsghsyzs{|n}~ syL B y{]Us[sscd}QCDEYFHSYIHSK LYM((FHNOW(IHPOWe!,$-./?0P1U