4U                               *      5         3      E  E K E    E    :              h j  j j        ! " # $ % & ' ( ) * +, -.  /  0 1 2 34 5 6 78 9 : ;<= >? @ AB  C 31 DE F G H I J K L M N OP QR 3S TUV  C W X 3Y Z [ \ ] `a bc d ef g h i jklx m nopq rstu hv wxyz InnerClasseslogLorg/slf4j/Logger;bpmCallLogManager7Lcom/artfess/bpm/persistence/manager/BpmCallLogManager;RuntimeVisibleAnnotationsLjavax/annotation/Resource;demensionManager)Lcom/artfess/uc/manager/DemensionManager; orgManager#Lcom/artfess/uc/manager/OrgManager; userManager$Lcom/artfess/uc/manager/UserManager; roleManager$Lcom/artfess/uc/manager/RoleManager;userRoleManager(Lcom/artfess/uc/manager/UserRoleManager;pwdStrategyManager+Lcom/artfess/uc/manager/PwdStrategyManager;orgUserService'Lcom/artfess/uc/manager/OrgUserManager;SYS_CODELjava/lang/String; ConstantValue()VCodeLineNumberTableLocalVariableTablethis$Lcom/artfess/uc/kafka/KafkaConsumer; consumeOrgy(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;Ljava/lang/String;)V objectMapper-Lcom/fasterxml/jackson/databind/ObjectMapper;rootNode)Lcom/fasterxml/jackson/databind/JsonNode;msgTypepuuiddataNodeorgDto Lcom/artfess/uc/dto/OrgKafkaDTO;orgVo!Lcom/artfess/uc/params/org/OrgVo;typeEnum"Lcom/artfess/uc/enums/MsgTypeEnum;eLjava/lang/Exception;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;ack2Lorg/springframework/kafka/support/Acknowledgment;topicmsgLjava/lang/Object;callLog.Lcom/artfess/bpm/persistence/model/BpmCallLog;LocalVariableTypeTable6Lorg/apache/kafka/clients/consumer/ConsumerRecord<**>; StackMapTableyt{|s}.~ Signature}(Lorg/apache/kafka/clients/consumer/ConsumerRecord<**>;Lorg/springframework/kafka/support/Acknowledgment;Ljava/lang/String;)V4Lorg/springframework/kafka/annotation/KafkaListener;idorgListenerContainertopicsbasic-org-infogroupIdconsumer-xcjy-user autoStartupfalse"RuntimeVisibleParameterAnnotations9Lorg/springframework/messaging/handler/annotation/Header;valuekafka_receivedTopic consumeUseruserLcom/artfess/uc/model/User;jsonStruserDto!Lcom/artfess/uc/dto/UserKafkaDTO;userVo#Lcom/artfess/uc/params/user/UserVo;BuserListenerContainerbasic-user-info consumeRole zsRoleCodes[Ljava/lang/String; roleCodesuserRoleLcom/artfess/uc/model/UserRole;userRoleRelationDto(Lcom/artfess/uc/dto/UserRoleRelationDTO;roleLcom/artfess/uc/model/Role; userRoleListLjava/util/List;dto$Lcom/artfess/uc/dto/UserRoleItemDTO;userRoleRelationDtoList1Ljava/util/List;:Ljava/util/List;roleListenerContainerbasic-userrole-infopreHandleKafkaMsg(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lorg/springframework/kafka/support/Acknowledgment;Ljava/lang/String;)Ljava/lang/Object;(Lorg/apache/kafka/clients/consumer/ConsumerRecord<**>;Lorg/springframework/kafka/support/Acknowledgment;Ljava/lang/String;)Ljava/lang/Object; buildCallLog(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/artfess/bpm/persistence/model/BpmCallLog;msgStrsubjectdesc buildOrgVoC(Lcom/artfess/uc/dto/OrgKafkaDTO;)Lcom/artfess/uc/params/org/OrgVo;defaultDemension Lcom/artfess/uc/model/Demension;demId buildUserF(Lcom/artfess/uc/dto/UserKafkaDTO;)Lcom/artfess/uc/params/user/UserVo;pwdaccount Exceptions setAddUserOrg6(Ljava/lang/String;Lcom/artfess/uc/dto/UserKafkaDTO;)V orgUserVo%Lcom/artfess/uc/params/org/OrgUserVo; orgInfoDto#Lcom/artfess/uc/dto/UserOrgInfoDTO; userKafkaDtoUV updateUserOrgG(Lcom/artfess/uc/params/user/UserVo;Lcom/artfess/uc/dto/UserKafkaDTO;)V existingOrgsexistingOrgCodesLjava/util/Set; orgInfoList,Ljava/util/List;#Ljava/util/Set;5Ljava/util/List;cdeleteUserUnboundOrg(Ljava/lang/String;)VrelIdmapLjava/util/Map;userId queryWrapper=Lcom/baomidou/mybatisplus/core/conditions/query/QueryWrapper;list5Ljava/util/Map;]Lcom/baomidou/mybatisplus/core/conditions/query/QueryWrapper;GLjava/util/List;>;fllambda$consumeRole$11(I)[Ljava/lang/String;x$0Ilambda$consumeRole$10;(Ljava/util/List;Lcom/artfess/uc/dto/UserRoleRelationDTO;)V SourceFileKafkaConsumer.javaHLorg/springframework/boot/autoconfigure/condition/ConditionalOnProperty;namespring.kafka.enable havingValuetruematchIfMissing*Lorg/springframework/stereotype/Component; PQ,com/artfess/bpm/persistence/model/BpmCallLog+com/fasterxml/jackson/databind/ObjectMapper  }  { 组织同步消息kafka消费组织同步消息 STdata com/artfess/uc/dto/OrgKafkaDTO  XY~ java/lang/RuntimeExceptionjava/lang/StringBuilder不支持的消息类型:  w           | java/lang/Exception  w Kafka 消费异常：{}  用户同步消息kafka消费用户同步消息com/artfess/uc/dto/UserKafkaDTO ^_"java/lang/IllegalArgumentException    lm    cd    Kafka 消费用户异常：{}"com/artfess/uc/dto/UserRoleItemDTO   角色同步消息 java/util/ArrayList BootstrapMethods      根据手机号: 未找到对应的用户！   y   ybry    根据角色Code: !未找到对应的角色信息！   &com/artfess/uc/dto/UserRoleRelationDTO com/artfess/uc/model/UserRole w w 3构建角色关联用户失败，用户无法匹配    Kafka 消费角色异常：{}%Kafka 监听主题:{},消费内容:{} * Kafka 消息为空，topic:{}  w  w w w w w  com/artfess/uc/params/org/OrgVo w  w    wogndept  w      0 w1 w w!com/artfess/uc/params/user/UserVo w w ^1[3-9]\d{9}$  w w      !w " #$% & ' !com/artfess/uc/dto/UserOrgInfoDTO#com/artfess/uc/params/org/OrgUserVo ( )w * + ,- ./ 01234 56 78 java/util/Set vw 9;com/baomidou/mybatisplus/core/conditions/query/QueryWrapperUSER_ID_ :; < => java/util/Map ? ID_id_ @java/lang/String"com/artfess/uc/kafka/KafkaConsumerXCJY AB CDjava/lang/Object$com/artfess/uc/kafka/KafkaConsumer$10org/apache/kafka/clients/consumer/ConsumerRecord0org/springframework/kafka/support/Acknowledgment'com/fasterxml/jackson/databind/JsonNode com/artfess/uc/enums/MsgTypeEnumjava/lang/Throwablejava/util/Listcom/artfess/uc/model/Usercom/artfess/uc/model/Rolejava/util/Iteratorcom/artfess/uc/model/DemensiontoString()Ljava/lang/String;readTree=(Ljava/lang/String;)Lcom/fasterxml/jackson/databind/JsonNode;pathasTextget treeToValueJ(Lcom/fasterxml/jackson/core/TreeNode;Ljava/lang/Class;)Ljava/lang/Object;fromCode6(Ljava/lang/String;)Lcom/artfess/uc/enums/MsgTypeEnum;append-(Ljava/lang/String;)Ljava/lang/StringBuilder;+$SwitchMap$com$artfess$uc$enums$MsgTypeEnum[Iordinal()I!com/artfess/uc/manager/OrgManageraddOrgH(Lcom/artfess/uc/params/org/OrgVo;)Lcom/artfess/base/model/CommonResult; updateOrggetCode deleteOrg9(Ljava/lang/String;)Lcom/artfess/base/model/CommonResult;java/lang/IntegervalueOf(I)Ljava/lang/Integer; setIsSuccess(Ljava/lang/Integer;)V5com/artfess/bpm/persistence/manager/BpmCallLogManagersave(Ljava/lang/Object;)Z acknowledge getMessage setParamsorg/slf4j/Loggererror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Vcom/alibaba/fastjson/JSONtoJSON&(Ljava/lang/Object;)Ljava/lang/Object;getId"com/artfess/uc/manager/UserManager updateUser&(Lcom/artfess/uc/params/user/UserVo;)V setStatusaddUser@(Lcom/artfess/uc/params/user/UserVo;)Lcom/artfess/uc/model/User; getAccount getUserCode getByAccount/(Ljava/lang/String;)Lcom/artfess/uc/model/User;com/artfess/base/util/BeanUtils isNotEmptydeleteUserByIds readValue7(Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object;getType()Ljava/lang/Integer;&(Ljava/lang/Object;)Ljava/lang/String;getDescgetValue()Ljava/util/List; EF(Ljava/lang/Object;)V G+(Lcom/artfess/uc/dto/UserRoleRelationDTO;)Vaccept/(Ljava/util/List;)Ljava/util/function/Consumer;forEach (Ljava/util/function/Consumer;)V/org/apache/commons/collections4/CollectionUtilsisEmpty(Ljava/util/Collection;)ZintValuegetKeyjava/util/ObjectsisNullstream()Ljava/util/stream/Stream; hH<(Lcom/artfess/uc/dto/UserRoleRelationDTO;)Ljava/lang/String;apply()Ljava/util/function/Function;java/util/stream/Stream8(Ljava/util/function/Function;)Ljava/util/stream/Stream;(I)Ljava/lang/Object; I"()Ljava/util/function/IntFunction;toArray5(Ljava/util/function/IntFunction;)[Ljava/lang/Object;java/util/ArrayscopyOf)([Ljava/lang/Object;I)[Ljava/lang/Object;&com/artfess/uc/manager/UserRoleManager saveUserRole((Ljava/lang/String;[Ljava/lang/String;)V"com/artfess/uc/manager/RoleManagergetRole/(Ljava/lang/String;)Lcom/artfess/uc/model/Role;iterator()Ljava/util/Iterator;hasNext()Znext()Ljava/lang/Object;getPhone setRoleId setUserIdaddjava/time/LocalDateTimenow()Ljava/time/LocalDateTime;removeByRoleId.(Ljava/lang/String;Ljava/time/LocalDateTime;)V saveBatch-(Ljava/lang/Object;)Ljava/lang/StringBuilder;infowarn'(Ljava/lang/String;Ljava/lang/Object;)VsetUrl setCallTime(Ljava/time/LocalDateTime;)V setSubjectsetDesc setResponse setEventType setTaskId'com/artfess/uc/manager/DemensionManagergetDefaultDemension"()Lcom/artfess/uc/model/Demension;setDemIdsetCodegetNamesetName setOrgKindgetSortjava/lang/Long(J)Ljava/lang/Long; setOrderNo(Ljava/lang/Long;)V getParentCode com/artfess/base/util/StringUtil(Ljava/lang/String;)Z setParentIdsetGrade setParentCode setAccount setFullnamematches setMobilesetId getStatus getUserType setUserType getPassword setPassword)com/artfess/uc/manager/PwdStrategyManager getDefault$()Lcom/artfess/uc/model/PwdStrategy; com/artfess/uc/model/PwdStrategy getInitPwdgetOrgInfoDtos getOrgCode setOrgCode getDeptCodeequals setIsMaster(I)V addOrgUserL(Lcom/artfess/uc/params/org/OrgUserVo;)Lcom/artfess/base/model/CommonResult;getOrgsByAccount$(Ljava/lang/String;)Ljava/util/List; J.(Lcom/artfess/uc/model/Org;)Ljava/lang/String;java/util/stream/CollectorstoSet()Ljava/util/stream/Collector;collect0(Ljava/util/stream/Collector;)Ljava/lang/Object;containseq8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;%com/artfess/uc/manager/OrgUserManagerlistMapsD(Lcom/baomidou/mybatisplus/core/conditions/Wrapper;)Ljava/util/List;$org/springframework/util/ObjectUtils delOrgUser getModuleCodeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;K LO  P Q"java/lang/invoke/LambdaMetafactory metafactorySLookup(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; getRoleCodecom/artfess/uc/model/OrgT%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles! /*+ b*+,-:Y:Y:: : : *+  ::  : * : :  YY .L+:*  !W@*  "W1*  #$WYY%&*'(W,)U:+,%&-.+/*'(W,):*'(W,)2*m2Xmmom%J KLNP!R-S9TEV\YeZs]{`abdfgijlmorz){/|2s4u>vGwXzd{j|mz{{}!-9E e s {  4$ |  m   _ $z s!"[s#$s%&s'()*s+,*+,-:Y:0:Y: :*+ 12:: Y:   33: * 4: :  5YY6 .]s 7*8 9*  : %;*8 <W* = >_*8 9*  :I*8 ?@:A1*8BCW5YY6%&*'(W,)U:+,%&-D+/*'(W,):*'(W,)j*j, "0<OXaow~+3Eajv|+-."H/0:<.X a o01 w23 ~ $      ` 45$")z s6"[s7$s%&s'()*s+8 *+,-:Y:0:Y:EFE:*+ GHIJ:KYL: M NO P%&*'(W,)GQ*8R@:  S'YYTRU VWXYZ[:   `\[:   ]S*^ _ `GQ*aRb:  S'YYcRdKYL:  e:  fQ gh: *8 i@:S*jYk: lmBn oW P Yp*^ lqr*^ sW"5YYGt6%&*'(W,)U:+,%&-u+/*'(W,):*'(W,)F*1F*1Fl8 "+9U^ow "1AImv ( 1=CF H R [lx~s-. '9:  ;: <=/-.?>? A@A vBC "/+9DE^FC H$      vBG ^FH q IJGKIGLJMTz sN"[sO$s%&s'()*s+PQ3-v+ +wx+w:-y-z,) !"(#.$0&43333   30RST;Y:+{q|}~,-& 5 6789%:+;1<8=R;;;U;;;V;W 2  XYe*M,NY:-++++Q++Q+ +>H IKLM'N0PNRUShUsX}YZ\^4 Z[\;I]] ^_YM*8+?@N,+?,++? ,+?-A&,-B,-;,-,-,%*:,,>hijk&l2m:oApIqQrYsdulvzwy4z`D1z-3la. :5K)b*cdL,j,eN-fT-g:Y:+,  * W(YN-+-,-* -WB (17APY_kqy~>1:ef(Cghyefai1MDjk$b*lm[ * +=N-P-VX:,:q*+7e:fSg:Y:+=,* WF,8*+7Y:+=,* Wb!&39AIhqz\ q8efhAgh$ef23i1nC3op9qC nr3os9qtfJ;uJMF 54JuJMjkk 54JuJMjkkBb*vwrYM,+W*,N-l-e:fZg:ǹ:ə8ʹ:ə˹:* W:"@KS^fqvH^*  K=x @Hyz{|}q~C @Hy|q~ *JMFb* /Ͱ  Z+ж *+oW FC>?! θѳ-*[ssZMRN*^_