package com.ruoyi.utils.data;
|
|
import com.ruoyi.alarmpoints.well.domain.RTU_DATA_YJ_8;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.sql.Connection;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.sql.Statement;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@Slf4j(topic = "orcl")
|
public class Query {
|
static Connection conn = null;
|
static Statement st = null;
|
static ResultSet rs = null;
|
|
public static List<RTU_DATA_YJ_8> getRTUDataYJ8(String wellId) {
|
List<RTU_DATA_YJ_8> dataBridgeList = new ArrayList<>();
|
try {
|
//1、获取连接对象
|
conn = Conn.getGc().getCon();
|
//2、创建statement类对象，用来执行SQL语句
|
st = conn.createStatement();
|
//3、创建sql查询语句
|
StringBuilder sbd = new StringBuilder();
|
String sql = "select * from RTU_DATA_YJ_8 where 1=1 ";
|
sbd.append(sql);
|
if (wellId != null) {
|
sbd.append(" and JH ='" + wellId+"'");
|
}
|
//4、执行sql语句并且换回一个查询的结果集
|
rs = st.executeQuery(sbd.toString());
|
while (rs.next()) { //循环遍历结果集
|
RTU_DATA_YJ_8 rtu_data_yj_8 = new RTU_DATA_YJ_8();
|
rtu_data_yj_8.setJH(rs.getString("JH"));
|
rtu_data_yj_8.setRQ(rs.getDate("RQ"));
|
rtu_data_yj_8.setMAT(rs.getInt("MAT"));
|
rtu_data_yj_8.setTGP(rs.getInt("TGP"));
|
rtu_data_yj_8.setCPV(rs.getInt("CPV"));
|
rtu_data_yj_8.setADL(rs.getInt("ADL"));
|
rtu_data_yj_8.setADY(rs.getInt("ADY"));
|
rtu_data_yj_8.setBDL(rs.getInt("BDL"));
|
rtu_data_yj_8.setBDL(rs.getInt("BDL"));
|
rtu_data_yj_8.setCDL(rs.getInt("CDL"));
|
rtu_data_yj_8.setCDY(rs.getInt("CDY"));
|
rtu_data_yj_8.setUCV(rs.getInt("UCV"));
|
rtu_data_yj_8.setDCV(rs.getInt("DCV"));
|
rtu_data_yj_8.setSLV(rs.getInt("SLV"));
|
rtu_data_yj_8.setCHC(rs.getInt("CHC"));
|
rtu_data_yj_8.setBPV(rs.getInt("BPV"));
|
rtu_data_yj_8.setZWG(rs.getInt("ZWG"));
|
rtu_data_yj_8.setZYG(rs.getInt("ZYG"));
|
rtu_data_yj_8.setGYS(rs.getInt("GYS"));
|
rtu_data_yj_8.setUWL(rs.getInt("UWL"));
|
rtu_data_yj_8.setDWL(rs.getInt("DWL"));
|
rtu_data_yj_8.setTIME(rs.getString("TIME"));
|
rtu_data_yj_8.setLRSJ(rs.getDate("LRSJ"));
|
rtu_data_yj_8.setXT(rs.getInt("XT"));
|
rtu_data_yj_8.setSCSJ(rs.getInt("SCSJ"));
|
rtu_data_yj_8.setSCSL(rs.getInt("SCSL"));
|
rtu_data_yj_8.setMLV(rs.getInt("MLV"));
|
rtu_data_yj_8.setDLV(rs.getInt("DLV"));
|
rtu_data_yj_8.setDLV(rs.getInt("DLV"));
|
rtu_data_yj_8.setXY(rs.getInt("XY"));
|
rtu_data_yj_8.setNJU(rs.getInt("NJU"));
|
rtu_data_yj_8.setZHS(rs.getInt("ZHS"));
|
dataBridgeList.add(rtu_data_yj_8);
|
}
|
conn.close();
|
return dataBridgeList;
|
} catch (Exception e) {
|
log.error("设备运行状态查询异常:" + e.getMessage());
|
return dataBridgeList;
|
}
|
}
|
}
|
