社区feed流

src/main/java/com/rj/service/DifyWorkflowService.java

@@ -44,6 +44,9 @@ public class DifyWorkflowService {
     @Value("${dify.api.portrait-3in1-token}")// 客户画像 app-Tpz9ByHyj5X6QCNpPX53QoBt
     private String portraitAllInToken;
 
+    @Value("${dify.api.ai-feed-token}")
+    private String aiFeedToken; // AI-Feed流（社区优质内容评估）
+
     private final RestTemplate restTemplate;
 
     @Autowired
@@ -200,6 +203,62 @@ public class DifyWorkflowService {
         }
     }
 
+    /**
+     * 调用 AI-Feed 流（社区Feed流优质内容）工作流
+     * 期望 inputs 参数包含：targetContent、targetId、targetType
+     */
+    public DifyWorkflowResponse callAiFeedWorkflow(DifyWorkflowRequest request) {
+        try {
+            String url = difyBaseUrl + workflowEndpoint;
+
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(MediaType.APPLICATION_JSON);
+            headers.set("Authorization", "Bearer " + aiFeedToken);
+
+            Map<String, Object> requestBody = new HashMap<>();
+            requestBody.put("inputs", request.getInputs());
+            requestBody.put("response_mode", "blocking");
+            requestBody.put("user", request.getUserId());
+
+            HttpEntity<Map<String, Object>> entity = new HttpEntity<>(requestBody, headers);
+
+            log.info("调用AI-Feed Dify工作流API: {}", url);
+            log.info("AI-Feed请求参数: {}", JSON.toJSONString(requestBody));
+
+            ResponseEntity<String> response = restTemplate.exchange(
+                url,
+                HttpMethod.POST,
+                entity,
+                String.class
+            );
+
+            log.info("AI-Feed Dify工作流响应状态: {}", response.getStatusCode());
+            log.info("AI-Feed Dify工作流响应内容: {}", response.getBody());
+
+            if (response.getStatusCode() == HttpStatus.OK) {
+                JSONObject responseJson = JSON.parseObject(response.getBody());
+                // AI-Feed 暂不做入库，直接返回
+                DifyWorkflowResponse result = new DifyWorkflowResponse();
+                if (responseJson.containsKey("data")) {
+                    JSONObject data = responseJson.getJSONObject("data");
+                    result.setWorkflowRunId(data.getString("workflow_run_id"));
+                    result.setTaskId(data.getString("task_id"));
+                    result.setData(data);
+                }
+                if (responseJson.containsKey("metadata")) {
+                    result.setMetadata(responseJson.getJSONObject("metadata"));
+                }
+                return result;
+            } else {
+                throw new RuntimeException("AI-Feed Dify工作流调用失败，状态码: " + response.getStatusCode());
+            }
+
+        } catch (Exception e) {
+            log.error("调用AI-Feed Dify工作流异常", e);
+            throw new RuntimeException("调用AI-Feed Dify工作流异常: " + e.getMessage(), e);
+        }
+    }
+
     /**
      * 解析工作流响应并保存数据
      */