支持定时任务跑js

TangCheng

2025-04-18 df040e45d65d728f6465508dfdda8f4acfacc789

支持定时任务跑js

 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

            {

                // 解析出原始sql


 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);