feat(websocket): 实现 websocket广播功能

qfrjava

2025-04-18 fc3cf8628d46b02a7c86c865889954fa6edb6c9a

 JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/scheduledTasks/checkForTicketStatusChanges.java

@@ -2,11 +2,13 @@

import com.smtaiserver.smtaiserver.core.SMTAIServerApp;
import com.smtaiserver.smtaiserver.database.SMTDatabase;
import com.smtaiserver.smtaiserver.web.SMTWebSocketHandler;
import java.util.Calendar;
import java.util.Date;
import lombok.extern.log4j.Log4j2;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@@ -20,10 +22,11 @@
@Log4j2
@Component
public class checkForTicketStatusChanges {
  private static Logger _logger = LogManager.getLogger(checkForTicketStatusChanges.class);
  private static final Logger _logger = LogManager.getLogger(checkForTicketStatusChanges.class);

  // 一秒一次
  @Scheduled(cron = "0/1 * * * * ?")
  @Autowired private SMTWebSocketHandler webSocketHandler;

  @Scheduled(cron = "0/10 * * * * ?") // 一秒一次
  public void checkForTicketStatusChanges() throws Exception {
    _logger.info("start checkForTicketStatusChanges task");
    SMTDatabase db = SMTAIServerApp.getApp().allocDatabase();
@@ -32,13 +35,17 @@
    cal.setTime(date);
    cal.add(Calendar.MINUTE, -5);
    Date time = cal.getTime();

    try {
      SMTDatabase.DBRecords dbRecords =
          db.querySQL(
              "select * from work_order_list where is_notify =? and  status_update_time > ?",
              "select order_id from work_order_list where is_notify =? and  status_update_time > ?",
              new Object[] {"N", time});
      _logger.info("查询到的数量：{}",dbRecords.getRowCount());
      dbRecords.getRecords().forEach(record -> {});

      _logger.info("查询到的数量：{}", dbRecords.getRowCount());
        for (SMTDatabase.DBRecord rec : dbRecords.getRecords()) {
//          SMTJavaAIControl.
        }

    } catch (Exception e) {
      _logger.error("checkForTicketStatusChanges error", e);