package dell_targets;
import databases.DBConnector;
import targets.DifferentialBaseStation;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class Dell_differentialBaseStation {
    // »ñÈ¡ËùÓлùÕ¾
    public static List<DifferentialBaseStation> getAllBaseStations() throws SQLException {
        List<DifferentialBaseStation> stations = new ArrayList<>();
        ResultSet rs = DBConnector.queryTableData("differential_base_station");
        while (rs.next()) {
            DifferentialBaseStation station = new DifferentialBaseStation();
            station.setId(rs.getInt("id"));
            station.setDeviceNumber(rs.getString("device_number"));
            station.setIpAddress(rs.getString("ip_address"));
            station.setCommunicationPort(rs.getString("communication_port"));
            station.setCoverageDistance(rs.getString("coverage_distance"));
            station.setSendAddress(rs.getString("send_address"));
            station.setSendPort(rs.getString("send_port"));
            station.setXCoordinate(rs.getString("x_coordinate"));
            station.setYCoordinate(rs.getString("y_coordinate"));
            station.setZCoordinate(rs.getString("z_coordinate"));
            station.setLayer(rs.getString("layer"));
            station.setLongitude(rs.getString("longitude"));
            station.setLatitude(rs.getString("latitude"));
            station.setElevation(rs.getString("elevation"));
            station.setVersion(rs.getString("versions")); // ×¢ÒâÊý¾Ý¿â×Ö¶ÎÃûÊÇversions
            station.setDeviceStatus(rs.getString("device_status"));
            station.setAddTime(rs.getString("add_time"));
            station.setLastHeartbeatTime(rs.getString("last_heartbeat_time"));
            station.setIotCardNumber(rs.getString("iot_card_number"));
            station.setCompany(rs.getString("company"));
            stations.add(station);
        }
        return stations;
    }

    // ɾ³ý»ùÕ¾
    public static void deleteBaseStation(String device_number) throws SQLException {
        String sql = "DELETE FROM differential_base_station WHERE device_number = ?";
        DBConnector.executeUpdate(sql, device_number);
    }

    // ÐÂÔö»ùÕ¾
    public static void insertBaseStation(DifferentialBaseStation station) throws SQLException {
        String sql = "INSERT INTO differential_base_station (device_number, ip_address, communication_port, "
        		+ "coverage_distance, send_address, send_port, x_coordinate, y_coordinate, "
        		+ "z_coordinate, layer, longitude, latitude, elevation, versions, "
        		+ "device_status, add_time, last_heartbeat_time, iot_card_number, company) " +
                     "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
        DBConnector.executeUpdate(sql,
            station.getDeviceNumber(),
            station.getIpAddress(),
            station.getCommunicationPort(),
            station.getCoverageDistance(),
            station.getSendAddress(),
            station.getSendPort(),
            station.getXCoordinate(),
            station.getYCoordinate(),
            station.getZCoordinate(),
            station.getLayer(),
            station.getLongitude(),
            station.getLatitude(),
            station.getElevation(),
            station.getVersion(),
            station.getDeviceStatus(),
            station.getAddTime(),
            station.getLastHeartbeatTime(),
            station.getIotCardNumber(),
            station.getCompany());
    }

    // ¸üлùÕ¾
    public static void updateBaseStation(DifferentialBaseStation station) throws SQLException {
        String sql = "UPDATE differential_base_station SET device_number=?, ip_address=?, "
        		+ "communication_port=?, coverage_distance=?, send_address=?, "
        		+ "send_port=?, x_coordinate=?, y_coordinate=?, z_coordinate=?, "
        		+ "layer=?, longitude=?, latitude=?, elevation=?, versions=?, "
        		+ "device_status=?, add_time=?, last_heartbeat_time=?, "
        		+ "iot_card_number=?, company=? WHERE id=?";
        DBConnector.executeUpdate(sql,
            station.getDeviceNumber(),
            station.getIpAddress(),
            station.getCommunicationPort(),
            station.getCoverageDistance(),
            station.getSendAddress(),
            station.getSendPort(),
            station.getXCoordinate(),
            station.getYCoordinate(),
            station.getZCoordinate(),
            station.getLayer(),
            station.getLongitude(),
            station.getLatitude(),
            station.getElevation(),
            station.getVersion(),
            station.getDeviceStatus(),
            station.getAddTime(),
            station.getLastHeartbeatTime(),
            station.getIotCardNumber(),
            station.getCompany(),
            station.getId());
    }
}