增加同步设备状态任务

‘liusuyi’

2023-10-08 b9c9cfff20129a4cb787b752c900da2d7fe7c4eb

 ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java

@@ -10,6 +10,11 @@

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
import java.sql.*;


@@ -18,18 +23,21 @@
public class ReadAccessDatabase {

    public static void main(String[] args) {
        Boolean aBoolean = IsConnectTcpServer("127.0.0.1", 1200, 100);
        String message = aBoolean ? "success" : "fail";
        log.info(message);

        // 多个数据库文件路径
        String[] dbPaths = {
                "D:\\Workspaces\\ard\\安瑞达工作资料\\mdb\\道路中心线.mdb"
//                "D:\\Workspaces\\ard\\安瑞达工作资料\\mdb\\防风林-灌木.mdb",
                // 添加更多的数据库文件路径
        };

        // 遍历每个数据库文件
        for (String dbPath : dbPaths) {
            readDataFromAccessDatabase(dbPath);
        }
//        String[] dbPaths = {
//                "D:\\Workspaces\\ard\\安瑞达工作资料\\mdb\\道路中心线.mdb"
////                "D:\\Workspaces\\ard\\安瑞达工作资料\\mdb\\防风林-灌木.mdb",
//                // 添加更多的数据库文件路径
//        };
//
//        // 遍历每个数据库文件
//        for (String dbPath : dbPaths) {
//            readDataFromAccessDatabase(dbPath);
//        }
    }

    public static void readDataFromAccessDatabase(String dbPath) {
@@ -86,6 +94,17 @@
        }
    }

    public static Boolean IsConnectTcpServer(String ip,Integer port,Integer timeOut) {
        try {
            Socket socket = new Socket();
            socket.connect(new InetSocketAddress(ip, port), timeOut);
            socket.close();
           return true;
        } catch (IOException e) {
           // log.error(e.getMessage());
            return false;
        }
    }

}