From d64f4958d0647c21016e39e59184f30f8f07b1e3 Mon Sep 17 00:00:00 2001
From: zhuangtianxiang <2913129173@qq.com>
Date: Tue, 6 May 2025 12:39:30 +0800
Subject: [PATCH] =?UTF-8?q?feat(dify):=20=E6=B7=BB=E5=8A=A0=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=E5=88=97=E8=A1=A8=E6=9F=A5=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dify/controller/V1WorkflowController.java     | 15 ++++++++++++++-
 .../dify/modules/dify/entity/WorkflowData.java    |  5 ++---
 .../service/Impl/DifyWorkflowServiceImpl.java     |  1 +
 3 files changed, 17 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zsc/edu/dify/modules/dify/controller/V1WorkflowController.java b/src/main/java/com/zsc/edu/dify/modules/dify/controller/V1WorkflowController.java
index 76b43c4..c26c6c6 100644
--- a/src/main/java/com/zsc/edu/dify/modules/dify/controller/V1WorkflowController.java
+++ b/src/main/java/com/zsc/edu/dify/modules/dify/controller/V1WorkflowController.java
@@ -1,5 +1,6 @@
 package com.zsc.edu.dify.modules.dify.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.zsc.edu.dify.modules.dify.entity.WorkflowData;
 import com.zsc.edu.dify.modules.dify.repo.AppEntityRepository;
 import com.zsc.edu.dify.modules.dify.service.DifyWorkflowService;
@@ -13,6 +14,8 @@ import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
 import reactor.core.publisher.Flux;
 
+import java.util.List;
+
 @RestController
 @RequestMapping("/api/v1/workflow")
 public class V1WorkflowController {
@@ -20,7 +23,6 @@ public class V1WorkflowController {
     @Resource
     private DifyWorkflow difyWorkflow;
 
-
     @Resource
     private AppEntityRepository appEntityRepository;
 
@@ -90,4 +92,15 @@ public class V1WorkflowController {
         final DifyPageResult<WorkflowLogs> logs = difyWorkflow.logs(request);
         return logs;
     }
+
+    /**
+     * 日志列表
+     * @param appId
+     * @return
+     */
+    @GetMapping("/list/{appId}")
+    @PreAuthorize("hasAuthority('dify:workflow:query')")
+    public List<WorkflowData> list(@PathVariable String appId){
+        return difyWorkflowService.list(new QueryWrapper<WorkflowData>().eq("app_id",appId));
+    }
 }
diff --git a/src/main/java/com/zsc/edu/dify/modules/dify/entity/WorkflowData.java b/src/main/java/com/zsc/edu/dify/modules/dify/entity/WorkflowData.java
index 7cb76cd..cfebc62 100644
--- a/src/main/java/com/zsc/edu/dify/modules/dify/entity/WorkflowData.java
+++ b/src/main/java/com/zsc/edu/dify/modules/dify/entity/WorkflowData.java
@@ -4,13 +4,10 @@ import com.baomidou.mybatisplus.annotation.FieldFill;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
-import com.zsc.edu.dify.framework.json.JsonbTypeHandler;
 import lombok.Data;
-import lombok.EqualsAndHashCode;
 import lombok.Getter;
 import lombok.Setter;
 
-import java.util.Map;
 
 @Getter
 @Setter
@@ -26,4 +23,6 @@ public class WorkflowData {
 
     @TableField(value = "user_id", fill = FieldFill.INSERT)
     private Long userId;
+
+    private String appId;
 }
diff --git a/src/main/java/com/zsc/edu/dify/modules/dify/service/Impl/DifyWorkflowServiceImpl.java b/src/main/java/com/zsc/edu/dify/modules/dify/service/Impl/DifyWorkflowServiceImpl.java
index 1e371f2..d070834 100644
--- a/src/main/java/com/zsc/edu/dify/modules/dify/service/Impl/DifyWorkflowServiceImpl.java
+++ b/src/main/java/com/zsc/edu/dify/modules/dify/service/Impl/DifyWorkflowServiceImpl.java
@@ -27,6 +27,7 @@ public class DifyWorkflowServiceImpl extends ServiceImpl<WorkflowRepository, Wor
         String apiKey = appEntityRepository.selectApiKey(appId);
         request.setApiKey(apiKey);
         WorkflowData  workflowData =mapper.toEntity(difyWorkflow.runWorkflow(request));
+        workflowData.setAppId(appId);
         baseMapper.insert(workflowData);
         return workflowData;
     }