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 logs = difyWorkflow.logs(request); return logs; } + + /** + * 日志列表 + * @param appId + * @return + */ + @GetMapping("/list/{appId}") + @PreAuthorize("hasAuthority('dify:workflow:query')") + public List list(@PathVariable String appId){ + return difyWorkflowService.list(new QueryWrapper().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