From 1096218c1f00bd9e9b2c2ff05e9df5c531c4d328 Mon Sep 17 00:00:00 2001
From: tian <11429339@qq.com>
Date: Sat, 25 Jul 2026 12:53:59 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BA=BA=E8=84=B8=E5=BA=93=E9=87=8D?=
 =?UTF-8?q?=E8=BD=BD=E7=A7=BB=E5=88=B0syncResourceToDevice=E5=86=85?=
 =?UTF-8?q?=E9=83=A8=EF=BC=8C=E4=B8=8E=E6=96=87=E4=BB=B6=E4=BC=A0=E8=BE=93?=
 =?UTF-8?q?=E7=BB=91=E5=AE=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/service/task.go | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/internal/service/task.go b/internal/service/task.go
index 6e21c52..2273803 100644
--- a/internal/service/task.go
+++ b/internal/service/task.go
@@ -426,12 +426,6 @@ func (s *TaskService) executeOnDevice(task *models.Task, did string) {
             s.updateDeviceStatus(task.ID, did, models.TaskFailed, 0, err.Error())
             return
         }
-        // Auto-reload face gallery after sync
-        if payload, ok := task.Payload.(map[string]any); ok {
-            if name, ok := payload["resource_name"].(string); ok && name == "face_gallery" {
-                s.agent.Do("POST", dev.IP, dev.AgentPort, "/v1/face-gallery/reload", nil)
-            }
-        }
         s.updateDeviceStatus(task.ID, did, models.TaskSuccess, 1.0, "")
         s.appendAuditLog(task, did, models.TaskSuccess, "")
 
@@ -561,6 +555,10 @@ func (s *TaskService) syncResourceToDevice(task *models.Task, dev *models.Device
         if code >= 400 {
             return fmt.Errorf("agent error: %d %s", code, strings.TrimSpace(string(resp)))
         }
+        // Auto-reload after syncing face_gallery
+        if item.ResourceType == "face_gallery" {
+            _, _, _ = s.agent.Do("POST", dev.IP, dev.AgentPort, "/v1/face-gallery/reload", nil)
+        }
     }
     return nil
 }