From df040e45d65d728f6465508dfdda8f4acfacc789 Mon Sep 17 00:00:00 2001
From: TangCheng <tangchengmail@163.com>
Date: 星期五, 18 四月 2025 14:41:46 +0800
Subject: [PATCH] 支持定时任务跑js
---
JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/scheduledTasks/checkForTicketStatusChanges.java | 35 ++++++++++++++++++++++++++---------
JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/javaai/jsonflow/node/SMTJsonFlowNodeScript.java | 1 -
2 files changed, 26 insertions(+), 10 deletions(-)
diff --git a/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/javaai/jsonflow/node/SMTJsonFlowNodeScript.java b/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/javaai/jsonflow/node/SMTJsonFlowNodeScript.java
index 2754218..a25e177 100644
--- a/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/javaai/jsonflow/node/SMTJsonFlowNodeScript.java
+++ b/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/javaai/jsonflow/node/SMTJsonFlowNodeScript.java
@@ -338,7 +338,6 @@
private int executeSQL(SMTDatabase db, String sql, NativeObject nvParams) throws Exception
{
List<Object> sqlParams = new ArrayList<>();
- List<NativeObject> listRecs = new ArrayList<>();
try
{
// 瑙ｆ瀽鍑哄師濮媠ql
diff --git a/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/scheduledTasks/checkForTicketStatusChanges.java b/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/scheduledTasks/checkForTicketStatusChanges.java
index dced21c..7e5dc5b 100644
--- a/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/scheduledTasks/checkForTicketStatusChanges.java
+++ b/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/scheduledTasks/checkForTicketStatusChanges.java
@@ -1,8 +1,13 @@
package com.smtaiserver.smtaiserver.scheduledTasks;
import com.smtaiserver.smtaiserver.core.SMTAIServerApp;
+import com.smtaiserver.smtaiserver.core.SMTAIServerRequest;
import com.smtaiserver.smtaiserver.database.SMTDatabase;
+import com.smtaiserver.smtaiserver.javaai.llm.core.SMTLLMConnect;
+import com.smtaiserver.smtaiserver.javaai.qwen.agent.SMTQwenAgent;
import com.smtaiserver.smtaiserver.web.SMTWebSocketHandler;
+import com.smtservlet.util.Json;
+
import java.util.Calendar;
import java.util.Date;
import lombok.extern.log4j.Log4j2;
@@ -24,10 +29,9 @@
public class checkForTicketStatusChanges {
private static final Logger _logger = LogManager.getLogger(checkForTicketStatusChanges.class);
- @Autowired private SMTWebSocketHandler webSocketHandler;
-
+
@Scheduled(cron = "0/10 * * * * ?") // 涓�绉掍竴娆�
- public void checkForTicketStatusChanges() throws Exception {
+ public void execCheckForTicketStatusChanges() throws Exception {
_logger.info("start checkForTicketStatusChanges task");
SMTDatabase db = SMTAIServerApp.getApp().allocDatabase();
Date date = new Date();
@@ -37,15 +41,28 @@
Date time = cal.getTime();
try {
- SMTDatabase.DBRecords dbRecords =
- db.querySQL(
+ SMTDatabase.DBRecords dbRecords =
+ db.querySQL(
"select order_id from work_order_list where is_notify =? and status_update_time > ?",
new Object[] {"N", time});
- _logger.info("鏌ヨ鍒扮殑鏁伴噺锛歿}", dbRecords.getRowCount());
- for (SMTDatabase.DBRecord rec : dbRecords.getRecords()) {
-// SMTJavaAIControl.
- }
+ _logger.info("鏌ヨ鍒扮殑鏁伴噺锛歿}", dbRecords.getRowCount());
+ for (SMTDatabase.DBRecord rec : dbRecords.getRecords())
+ {
+ String agentId = "create_work_order";
+
+ Json jsonArgs = Json.object("question", "", "order_id", "aaaaa");
+
+ SMTQwenAgent agent = SMTAIServerApp.getApp().getQwenAgentManager().getAgentById(agentId);
+ if(agent == null)
+ throw new Exception("can't find agent : " + agentId);
+ SMTLLMConnect llm = SMTAIServerApp.getApp().allocLLMConnect(null);
+
+
+ SMTAIServerRequest _tranReq = new SMTAIServerRequest();
+ agent.callAgents("/", jsonArgs, llm, "", _tranReq );
+
+ }
} catch (Exception e) {
_logger.error("checkForTicketStatusChanges error", e);
--
Gitblit v1.9.3