From 3b8684cff12189f2e8388b2c2309379a830b93c3 Mon Sep 17 00:00:00 2001
From: 秦芳睿 <1425609123@qq.com>
Date: 星期二, 22 四月 2025 09:45:45 +0800
Subject: [PATCH] Merge branch 'master' of http://47.103.154.90:83/r/WI/Service.V1.0
---
JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/scheduledTasks/checkForTicketStatusChanges.java | 146 ++++++++++++++++++++++++++----------------------
1 files changed, 80 insertions(+), 66 deletions(-)
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 fcd9bab..d0ed99f 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
@@ -6,6 +6,8 @@
import com.smtaiserver.smtaiserver.javaai.llm.core.SMTLLMConnect;
import com.smtaiserver.smtaiserver.javaai.qwen.agent.SMTQwenAgent;
import com.smtservlet.util.Json;
+import com.smtservlet.util.SMTJsonWriter;
+
import java.util.Calendar;
import java.util.Date;
import lombok.extern.log4j.Log4j2;
@@ -34,38 +36,45 @@
@Scheduled(cron = "0/10 * * * * ?")
public void execCheckForTicketStatusChangesByOrdersTaken() throws Exception {
_logger.info("start checkForTicketStatusChanges task");
- SMTDatabase db = SMTAIServerApp.getApp().allocDatabase();
- Date date = new Date();
- Calendar cal = Calendar.getInstance();
- cal.setTime(date);
- cal.add(Calendar.MINUTE, -5);
- Date time = cal.getTime();
-
- try {
- SMTDatabase.DBRecords dbRecords =
- db.querySQL(
- "select order_id from work_order_list where is_notify =? and status_update_time > ? and stepstatus =1",
- new Object[] {"N", time});
-
- _logger.info("鏌ヨ鍒扮姸鎬佷负宸叉帴鍗曠殑宸ュ崟鐨勬暟閲忥細{}", dbRecords.getRowCount());
- for (SMTDatabase.DBRecord rec : dbRecords.getRecords()) {
- String agentId =
- (String)
- SMTAIServerApp.getApp()
- .getGlobalConfig(
- "work_order.workflow_agent_re", "status_changes_received_order");
-
- Json jsonArgs = Json.object("question", "", "order_id", rec.getString("order_id"));
-
- 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) {
+
+ try
+ {
+ Date date = new Date();
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(date);
+ cal.add(Calendar.MINUTE, -5);
+ Date time = cal.getTime();
+
+ _logger.info("aaaaaaaaaaaaaa : " + SMTAIServerApp.getApp().getSystemDatasourceUsgae());
+
+ try(SMTDatabase db = SMTAIServerApp.getApp().allocDatabase())
+ {
+ SMTDatabase.DBRecords dbRecords =
+ db.querySQL(
+ "select order_id from work_order_list where is_notify =? and status_update_time > ? and stepstatus =1",
+ new Object[] {"N", time});
+
+ _logger.info("鏌ヨ鍒扮姸鎬佷负宸叉帴鍗曠殑宸ュ崟鐨勬暟閲忥細{}", dbRecords.getRowCount());
+ for (SMTDatabase.DBRecord rec : dbRecords.getRecords()) {
+ String agentId =
+ (String)
+ SMTAIServerApp.getApp()
+ .getGlobalConfig(
+ "work_order.workflow_agent_re", "status_changes_received_order");
+
+ Json jsonArgs = Json.object("question", "", "order_id", rec.getString("order_id"));
+
+ 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);
+ }
+ }
+ _logger.info("bbbbbbbbbbbbbbbbbbb : " + SMTAIServerApp.getApp().getSystemDatasourceUsgae());
+ }
+ catch (Exception e) {
_logger.error("checkForTicketStatusChanges error", e);
}
}
@@ -77,39 +86,44 @@
*/
@Scheduled(cron = "0/10 * * * * ?")
public void execCheckForTicketStatusChangesByFinish() throws Exception {
- _logger.info("start checkForTicketStatusChanges task");
- SMTDatabase db = SMTAIServerApp.getApp().allocDatabase();
- Date date = new Date();
- Calendar cal = Calendar.getInstance();
- cal.setTime(date);
- cal.add(Calendar.MINUTE, -5);
- Date time = cal.getTime();
-
- try {
- SMTDatabase.DBRecords dbRecords =
- db.querySQL(
- "select order_id from work_order_list where is_notify =? and status_update_time > ? and stepstatus =4",
- new Object[] {"N", time});
-
- _logger.info("鏌ヨ鍒扮姸鎬佷负宸插畬鎴愮殑宸ュ崟鐨勬暟閲忥細{}", dbRecords.getRowCount());
- for (SMTDatabase.DBRecord rec : dbRecords.getRecords()) {
- String agentId =
- (String)
- SMTAIServerApp.getApp()
- .getGlobalConfig(
- "work_order.workflow_agent_finish", "status_changes_received_order");
- Json jsonArgs = Json.object("question", "", "order_id", rec.getString("order_id"));
-
- 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);
- }
+ _logger.info("start checkForTicketStatusChanges task");
+ try
+ {
+ Date date = new Date();
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(date);
+ cal.add(Calendar.MINUTE, -5);
+ Date time = cal.getTime();
+
+ try(SMTDatabase db = SMTAIServerApp.getApp().allocDatabase())
+ {
+ SMTDatabase.DBRecords dbRecords =
+ db.querySQL(
+ "select order_id from work_order_list where is_notify =? and status_update_time > ? and stepstatus =4",
+ new Object[] {"N", time});
+
+ _logger.info("鏌ヨ鍒扮姸鎬佷负宸插畬鎴愮殑宸ュ崟鐨勬暟閲忥細{}", dbRecords.getRowCount());
+ for (SMTDatabase.DBRecord rec : dbRecords.getRecords()) {
+ String agentId =
+ (String)
+ SMTAIServerApp.getApp()
+ .getGlobalConfig(
+ "work_order.workflow_agent_finish", "status_changes_received_order");
+ Json jsonArgs = Json.object("question", "", "order_id", rec.getString("order_id"));
+
+ 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