From 3bdaddaeadd94ec83ffb89b2dd2812a0b1ee0ed0 Mon Sep 17 00:00:00 2001
From: chuzhongzai <chuzhongzai@hotmail.com>
Date: Fri, 29 Aug 2025 16:15:59 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E5=88=9D=E5=A7=8B=E5=8C=96?=
 =?UTF-8?q?=E9=A1=BA=E5=BA=8F,=E9=81=BF=E5=85=8D=E9=87=8D=E8=BF=9E?=
 =?UTF-8?q?=E6=97=B6=E6=9C=89=E6=9C=AA=E5=AE=8C=E6=88=90=E7=9A=84=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E5=AF=BC=E8=87=B4=E5=88=9D=E5=A7=8B=E5=8C=96=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5;=E4=BF=AE=E5=A4=8D=E5=8F=91=E9=80=81=E6=9C=AA?=
 =?UTF-8?q?=E5=AE=8C=E6=88=90=E4=BB=BB=E5=8A=A1=E6=97=B6=E4=B8=8D=E5=B8=A6?=
 =?UTF-8?q?=E5=90=8D=E5=AD=97=E7=9A=84bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/lion/lionwebsite/Service/RemoteService.java  | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/lion/lionwebsite/Service/RemoteService.java b/src/main/java/com/lion/lionwebsite/Service/RemoteService.java
index c22b86b..30ddaa5 100644
--- a/src/main/java/com/lion/lionwebsite/Service/RemoteService.java
+++ b/src/main/java/com/lion/lionwebsite/Service/RemoteService.java
@@ -19,6 +19,7 @@ import org.springframework.stereotype.Service;
 
 import java.io.IOException;
 import java.net.*;
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -87,10 +88,11 @@ public class RemoteService {
             if(pushService != null)
                 pushService.storageNodeOnline();
 
-            //子节点上线时，发送未完成的任务
-            resetUndone();
             channel = channelFuture.channel();
             channel.writeAndFlush(new IdentityMessage("lionwebsite"));
+
+            //子节点上线时，发送未完成的任务
+            resetUndone();
             return true;
         }catch (Exception e){
             e.printStackTrace();
@@ -110,6 +112,7 @@ public class RemoteService {
         Gallery[] galleries = galleryMapper.selectUnDoneGalleries();
         if(galleries != null && galleries.length != 0) {
             log.info("发送未下载完成图片至节点,{}本", galleries.length);
+            log.info("{}", Arrays.toString(galleries));
             for (Gallery gallery : galleries)
                 addGalleryToQueue(gallery);
         }
@@ -118,6 +121,7 @@ public class RemoteService {
     public byte addGalleryToQueue(Gallery gallery){
         GalleryTask galleryTask = new GalleryTask();
         galleryTask.setGid(gallery.getGid());
+        galleryTask.setName(gallery.getName());
 
         DownloadPostMessage dpm = new DownloadPostMessage();
         dpm.messageId = atomicInteger.getAndIncrement();