package com.data.Comm;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.List;
|
import com.base.Com;
|
import com.data.Afe_Inverter_Contorl;
|
import com.data.Afe_Inverter_RT;
|
import com.data.Afe_Inverter_State;
|
import com.data.Afe_Rectifier_State;
|
import com.data.Motor_inf;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
public class AFE_Inverter_SocketClient_Thread_SQL {
|
|
/**
|
* ¼ÓÔØAFE±äƵÆ÷É豸ÐÅÏ¢
|
* @param pool
|
* @param motors
|
*/
|
public static void loadDeviceData(MysqlConnPool pool,List<Motor_inf> motors) {
|
String sql_str = " SELECT * FROM " + Sql_Mysql.Tb_MW_Motor_inf + " WHERE sys_id = 100002";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str);
|
while(res.next()) {
|
Motor_inf motor = new Motor_inf(res.getInt("dev_id"));
|
motor.setDev_ip(res.getString("dev_ip"));
|
motor.setDev_name(res.getString("dev_name"));
|
motor.setSys_id(res.getInt("sys_id"));
|
motor.setSys_name(res.getString("sys_name"));
|
motor.setNote(res.getString("note"));
|
motors.add(motor);
|
}
|
} catch (SQLException e) {
|
sql.logger.error(e.toString(),e);
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
sql.logger.error(e.toString(),e);
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ²åÈë»ò¸üбäƵÆ÷ÐÅÏ¢
|
* @param pool
|
* @param stdata
|
*/
|
public static void insertOrUpdateTb_AFE_Inverter_RT(MysqlConnPool pool,Afe_Inverter_RT rtdata) {
|
String sql_str_sel = " select dev_id from " + Sql_Mysql.Tb_AFE_Inverter_RT + " where dev_id = " + rtdata.getDev_id();
|
String sql_str_ins = " insert into " + Sql_Mysql.Tb_AFE_Inverter_RT + "(dev_id) values("+rtdata.getDev_id()+")";
|
String sql_str_upd = " update " + Sql_Mysql.Tb_AFE_Inverter_RT + ""
|
+ " SET record_time = '" + Com.getDateTimeFormat(rtdata.getRecord_time(), Com.DTF_YMDhms)
|
+ "',rectifier_run= " + rtdata.getRectifier_run()
|
+ ",inverter_run= " + rtdata.getInverter_run()
|
+ ",report_alm= " + rtdata.getReport_alm()
|
+ ",report_fault= " + rtdata.getReport_fault()
|
+ ",motor_speed= " + rtdata.getMotor_speed()
|
+ ",output_power= " + rtdata.getOutput_power()
|
+ ",output_curr= " + rtdata.getOutput_curr()
|
+ ",output_vol= " + rtdata.getOutput_vol()
|
+ ",model_tmp = "+ rtdata.getModel_tmp()
|
+ " Where dev_id = " + rtdata.getDev_id();
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(res.next()) {
|
sql.sqlMysqlExecute(sql_str_upd);
|
}else {
|
sql.sqlMysqlExecute(sql_str_ins);
|
}
|
} catch (Exception e) {
|
sql.logger.error(e.toString(),e);
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
sql.logger.error(e.toString(),e);
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ²éѯ¿ØÖÆÐÅÏ¢
|
* @param pool
|
* @param control
|
*/
|
public static void queryAFE_Inverter_Control_Table(MysqlConnPool pool,Afe_Inverter_Contorl control) {
|
String sql_str = " SELECT * FROM " + Sql_Mysql.Tb_AFE_Inverter_Control + " WHERE dev_id = " + control.getDev_id();
|
ResultSet res = null;
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
res = sql.sqlMysqlQuery(sql_str);
|
if(res.next()) {
|
control.setOp_cmd(res.getInt("op_cmd")); //'¿ØÖÆÃüÁî',
|
control.setRectifier_start(res.getInt("rectifier_start")); //'ÕûÁ÷Æô¶¯',
|
control.setRectifier_stop(res.getInt("rectifier_stop")); //'ÕûÁ÷Í£Ö¹',
|
control.setInverter_start(res.getInt("inverter_start")); //'Äæ±äÆô¶¯',
|
control.setInverter_stop(res.getInt("inverter_stop")); //'Äæ±äÍ£Ö¹',
|
control.setSpeed_torque_change(res.getInt("speed_torque_change")); //'ËÙ¶È/ת¾Øģʽ',
|
control.setReset(res.getInt("reset")); //'¸´Î»',
|
control.setTorque_set(res.getFloat("torque_set")); //'ת¾Ø¸ø¶¨',
|
control.setSpeed_set(res.getFloat("speed_set")); //'Ëٶȸø¶¨',
|
control.setPositive_speed_limit(res.getFloat("positive_speed_limit")); //'ÕýÏòתËÙÏÞ·ù',
|
control.setReverse_speed_limit(res.getFloat("reverse_speed_limit")); //'·´ÏòתËÙÏÞ·ù',
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
sql.logger.error(e.toString(),e);
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
|
/**
|
* ²åÈë»ò¸üÐÂÕûÁ÷½Ó¿Ú
|
* @param pool
|
* @param state
|
*/
|
public static void insertOrupdateAfe_Rectifier_State_Table(MysqlConnPool pool,Afe_Rectifier_State state) {
|
String sql_str_sel = " select dev_id from " + Sql_Mysql.Afe_Rectifier_State_Table + " where dev_id = " + state.getDev_id();
|
String sql_str_ins = " insert into " + Sql_Mysql.Afe_Rectifier_State_Table + "(dev_id) values("+state.getDev_id()+")";
|
String sql_str_upd = " update " + Sql_Mysql.Afe_Rectifier_State_Table + ""
|
+ " SET record_time = '" + Com.getDateTimeFormat(state.getRecord_time(), Com.DTF_YMDhms)
|
+ "',rectifier_start = " + state.getRectifier_start()
|
+ ",rectifier_stop = " + state.getRectifier_stop()
|
+ ",inverter_start = " + state.getInverter_start()
|
+ ",inverter_stop = " + state.getInverter_stop()
|
+ ",speed_torque_change = " + state.getSpeed_torque_change()
|
+ ",reset = " + state.getReset()
|
+ ",rectifier_run = " + state.getRectifier_run()
|
+ ",inverter_run = " + state.getInverter_run()
|
+ ",report_alm = " + state.getReport_alm()
|
+ ",report_fault = "+ state.getReport_fault()
|
+ " Where dev_id = " + state.getDev_id();
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(res.next()) {
|
sql.sqlMysqlExecute(sql_str_upd);
|
}else {
|
sql.sqlMysqlExecute(sql_str_ins);
|
}
|
} catch (Exception e) {
|
sql.logger.error(e.toString(),e);
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
sql.logger.error(e.toString(),e);
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ²åÈë»ò¸üÐÂÄæ±ä½Ó¿Ú
|
* @param pool
|
* @param state
|
*/
|
public static void insertOrupdateAfe_Inverter_State(MysqlConnPool pool,Afe_Inverter_State state) {
|
String sql_str_sel = " select dev_id from " + Sql_Mysql.Afe_Inverter_State_Table + " where dev_id = " + state.getDev_id();
|
String sql_str_ins = " insert into " + Sql_Mysql.Afe_Inverter_State_Table + "(dev_id) values("+state.getDev_id()+")";
|
String sql_str_upd = " update " + Sql_Mysql.Afe_Inverter_State_Table + ""
|
+ " SET record_time = '" + Com.getDateTimeFormat(state.getRecord_time(), Com.DTF_YMDhms)
|
+ "',torque_set = " + state.getTorque_set()
|
+ ",speed_set = " + state.getSpeed_set()
|
+ ",positive_speed_limit = " + state.getPositive_speed_limit()
|
+ ",reverse_speed_limit = " + state.getReverse_speed_limit()
|
+ ",motor_speed = " + state.getMotor_speed()
|
+ ",output_power = " + state.getOutput_power()
|
+ ",output_curr = " + state.getOutput_curr()
|
+ ",output_vol = " + state.getOutput_vol()
|
+ ",model_tmp = " + state.getModel_tmp()
|
+ " Where dev_id = " + state.getDev_id();
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
res = sql.sqlMysqlQuery(sql_str_sel);
|
if(res.next()) {
|
sql.sqlMysqlExecute(sql_str_upd);
|
}else {
|
sql.sqlMysqlExecute(sql_str_ins);
|
}
|
} catch (Exception e) {
|
sql.logger.error(e.toString(),e);
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
sql.logger.error(e.toString(),e);
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
}
|
