vertoryao/dify-proxy-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(dify): 添加日志列表查接口

Browse Source
This commit is contained in:
zhuangtianxiang 2025-05-06 12:39:30 +08:00
parent 4cd46e7b77
commit d64f4958d0
3 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/com/zsc/edu/dify/modules/dify/controller/V1WorkflowController.java
View File

@ -1,5 +1,6 @@
package com.zsc.edu.dify.modules.dify.controller; 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.entity.WorkflowData;
import com.zsc.edu.dify.modules.dify.repo.AppEntityRepository; import com.zsc.edu.dify.modules.dify.repo.AppEntityRepository;
import com.zsc.edu.dify.modules.dify.service.DifyWorkflowService; 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 org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
import java.util.List;
@RestController @RestController
@RequestMapping("/api/v1/workflow") @RequestMapping("/api/v1/workflow")
public class V1WorkflowController { public class V1WorkflowController {
@ -20,7 +23,6 @@ public class V1WorkflowController {
@Resource @Resource
private DifyWorkflow difyWorkflow; private DifyWorkflow difyWorkflow;
@Resource @Resource
private AppEntityRepository appEntityRepository; private AppEntityRepository appEntityRepository;
@ -90,4 +92,15 @@ public class V1WorkflowController {
final DifyPageResult<WorkflowLogs> logs = difyWorkflow.logs(request); final DifyPageResult<WorkflowLogs> logs = difyWorkflow.logs(request);
return logs; 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));
}
} }

5
src/main/java/com/zsc/edu/dify/modules/dify/entity/WorkflowData.java
View File

@ -4,13 +4,10 @@ import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.zsc.edu.dify.framework.json.JsonbTypeHandler;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import java.util.Map;
@Getter @Getter
@Setter @Setter
@ -26,4 +23,6 @@ public class WorkflowData {
@TableField(value = "user_id", fill = FieldFill.INSERT) @TableField(value = "user_id", fill = FieldFill.INSERT)
private Long userId; private Long userId;
private String appId;
} }

1
src/main/java/com/zsc/edu/dify/modules/dify/service/Impl/DifyWorkflowServiceImpl.java
View File

@ -27,6 +27,7 @@ public class DifyWorkflowServiceImpl extends ServiceImpl<WorkflowRepository, Wor
String apiKey = appEntityRepository.selectApiKey(appId); String apiKey = appEntityRepository.selectApiKey(appId);
request.setApiKey(apiKey); request.setApiKey(apiKey);
WorkflowData workflowData =mapper.toEntity(difyWorkflow.runWorkflow(request)); WorkflowData workflowData =mapper.toEntity(difyWorkflow.runWorkflow(request));
workflowData.setAppId(appId);
baseMapper.insert(workflowData); baseMapper.insert(workflowData);
return workflowData; return workflowData;
} }