4+ G F F F  F  F F       ! ! F         @ fileSyncQueueRepositoryELcom/bcxin/backend/domain/syncs/repositories/FileSyncQueueRepository;appConfigProperty*Lcom/bcxin/backend/core/AppConfigProperty; jsonProvider-Lcom/bcxin/saas/core/components/JsonProvider;(Lcom/bcxin/backend/domain/syncs/repositories/DataSyncQueueLogRepository;Lcom/bcxin/backend/domain/syncs/repositories/FileSyncQueueRepository;Lcom/bcxin/backend/core/AppConfigProperty;Lcom/bcxin/saas/core/components/JsonProvider;)VCodeLineNumberTableLocalVariableTablethis1Lcom/bcxin/backend/tasks/DownloadSyncFileJobTask;dataSyncLogRepositoryHLcom/bcxin/backend/domain/syncs/repositories/DataSyncQueueLogRepository;MethodParametersrunCore()VexLjava/lang/Exception;fileSyncQueueEntity=Lcom/bcxin/runtime/domain/syncs/entities/FileSyncQueueEntity;fileSyncQueueEntitiesLjava/util/Collection;pagedFileSyncQueueEntities&Lorg/springframework/data/domain/Page;LocalVariableTypeTableULjava/util/Collection;eLorg/springframework/data/domain/Page; StackMapTable getTaskName()Ljava/lang/String; downloadFile@(Lcom/bcxin/runtime/domain/syncs/entities/FileSyncQueueEntity;)VdestinationPathLjava/lang/String; inputStreamLjava/io/InputStream;flagZsbLjava/lang/StringBuilder; isSuccesscheckUrlFileExists(Ljava/io/InputStream;)ZeLjava/io/IOException;bytes[B SourceFileDownloadSyncFileJobTask.javaRuntimeVisibleAnnotations*Lorg/springframework/stereotype/Component; NY HI JK LM   "共有%s个data sync log待处理;java/lang/Object    ;com/bcxin/runtime/domain/syncs/entities/FileSyncQueueEntity nojava/lang/Exception  id=%s; msg=%s m m  sync.download.filejava/lang/StringBuilder%DownloadSyncFileJobTask.downloadFile; N准备下载文件资源: %s; m  java/net/URL  }~      m /uploads/lib/ 即将上传到FTP:%s m m m  m   m  n 即将下载到:%s完成文件下载-文件下载失败：图片不存在或者0Kb !"文件下载异常: %s# $% &'java/lang/RuntimeException N () *Yjava/io/IOExceptioninputStream关流异常，{}/com/bcxin/backend/tasks/DownloadSyncFileJobTask$com/bcxin/backend/tasks/TaskAbstractjava/util/Collection$org/springframework/data/domain/Pagejava/util/Iteratorjava/io/InputStreamjava/lang/Stringjava/lang/Throwable(org/springframework/data/domain/PageableofSize-(I)Lorg/springframework/data/domain/Pageable;Ccom/bcxin/backend/domain/syncs/repositories/FileSyncQueueRepository getPendingsR(Lorg/springframework/data/domain/Pageable;)Lorg/springframework/data/domain/Page; getContent()Ljava/util/List;size()Ijava/lang/IntegervalueOf(I)Ljava/lang/Integer;format9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;log(Ljava/lang/String;)Viterator()Ljava/util/Iterator;hasNext()Znext()Ljava/lang/Object;loggerLorg/slf4j/Logger;getIdtoStringorg/slf4j/Loggererror*(Ljava/lang/String;Ljava/lang/Throwable;)VsaveAll&(Ljava/lang/Iterable;)Ljava/util/List;getDownloadUrlappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; openStream()Ljava/io/InputStream;/com/bcxin/backend/domain/configs/FileModeConfig getUseFtp()Ljava/lang/Boolean;java/lang/Boolean booleanValuegetPathindexOf(Ljava/lang/String;)IgetHost getUserName getPasswordgetPort getFilePathcn/hutool/core/util/StrUtilisEmpty(Ljava/lang/CharSequence;)Z%com/bcxin/backend/core/utils/FtpUtils bcxUploadFilea(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;Ljava/io/InputStream;)Z(com/bcxin/backend/core/AppConfigProperty getRootPathconcat&(Ljava/lang/String;)Ljava/lang/String;cn/hutool/http/HttpUtil'(Ljava/lang/String;Ljava/lang/String;)J makeStatus(ZLjava/lang/String;)V+com/bcxin/backend/core/utils/ExceptionUtilsgetStackMessage)(Ljava/lang/Throwable;)Ljava/lang/String;insert.(ILjava/lang/String;)Ljava/lang/StringBuilder;read([B)Iclose!FGHIJKLMNOPw**,*-*Q !"#R4STUVHIJKLMWUHJLXYPpL*dM,L* Y+  S + Z+N-?-:*(: YSYS *+WU[^Q:'()*,1.:/U1[4^2`3568R4`#Z[U.\]ST^_`ab^c`de.Afghifghjk$ lmP-Q<R STnoPWYM>, Y+S W!Y+"#:*$6s%&j+'()^,* Y+'S W+,-.Y/0120 +' 3!Y+"#4>H:*5+'6:+7X,8 YS W,9 W >,: W*,3 ,3;+,3<F:>,= Y>S ?W@Y,3A:,3;+,3<  <><Q#@ A C!D1E9FHHSIhKkLnMqN{OPKQRSTUVWXZ`ab[\].^<`JaSbVcRR$pq1rs9tu'Z[WSTW\] Mvw Kxueeijyz{{{yijyz{{{y{!;ijykh|W\}~Pp=N+-B=6++C:EN6++C:E:++C:E!D2:>ADR26RX\_DRTRQffhijlpru!s#t/l2m3n6p:r>uAsCtOnRpXr\u_satmwRR# *C 3[a pSTprsntueo  iz izkizk iz| iz| Wr