package com.dev.idce8kw;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
|
import com.base.Com;
|
import com.dev.fbs9100.FBS9100_ComBase;
|
import com.dev.fbs9100.FBS9100_StatAndParam;
|
import com.dev.fbs9100.FBS9100_VCData;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
|
public class IDCE8KWSocketClientThread_SQL {
|
|
|
/**
|
* ¸ù¾Ý Ö¸¶¨¶ÔÏóµÄÉ豸idÐÞ¸Ätb_fbs9100_setparam±íÖÐÖ¸¶¨É豸µÄÐÅÏ¢
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void updateFbs9100SetParamBydev_id(MysqlConnPool con_pool, IDCE_SystemState sysState)
|
{
|
IDCE_DischargeParam param = sysState.param;
|
if(param != null)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SetParam_Table
|
+ " SET "
|
+ "dev_id=" + param.dev_id + ", "
|
+ "op_cmd=" + MyModBusCom.CMD_GetDischargeParmAck + ", "
|
+ "TestCmd=" + 0 + ", "
|
+ "DisCurr=" + param.disCurr + ", "
|
+ "DisTime=" + param.disTimeLong + ", "
|
+ "GroupVol_LOW=" + param.disAbortVol + ", "
|
|
+ "HourRate=" + param.chaTimeLong + ", "
|
+ "DCVolHighLimit=" + param.chaAbortVol + ", "
|
+ "ChargeCurrSet=" + param.chaCurr;
|
//String sql_str_update = "UPDATE " + sql_str_base;
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//System.out.println(sql_str_replace);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
//e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
|
param.op_cmd = MyModBusCom.CMD_NULL;
|
}
|
}
|
|
/**
|
* ¸ù¾Ýtb_fbs9100_setparam±í¸üÐÂal_paramÊý×é
|
* @param con_pool
|
* @param al_param
|
*/
|
public static void queryFbs9100SetParamBydev_id(MysqlConnPool con_pool, IDCE_SystemState sysState)
|
{
|
IDCE_DischargeParam param = sysState.param;
|
String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetParam_Table + " where dev_id = " + sysState.dev_id;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
ResultSet res = sql.sqlMysqlQuery(sql_str);
|
try {
|
if(res.next())
|
{
|
if(null != param) {
|
//param.m_FBS_DiscParam.op_cmd = res.getInt("op_cmd");
|
param.op_cmd = res.getInt("op_cmd");
|
param.test_cmd = res.getInt("TestCmd");
|
param.dev_id = res.getInt("dev_id");
|
|
param.chaCurr = res.getFloat("ChargeCurrSet"); //³äµçµçÁ÷
|
param.chaAbortVol = res.getFloat("DCVolHighLimit"); //³äµç½ØÖ¹µçѹ
|
param.chaTimeLong = res.getInt("HourRate"); //³äµçʱ³¤
|
|
param.disCurr = res.getFloat("DisCurr"); //·ÅµçµçÁ÷
|
param.disAbortVol = res.getFloat("GroupVol_LOW"); //·Åµç½ØÖ¹µçѹ
|
param.disTimeLong = res.getInt("DisTime"); //·Åµçʱ³¤
|
}
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ¸ù¾ÝÖ¸¶¨µÄÉ豸id Ð޸ıí tb_fbs9100_setparam ÖеÄop_cmdÖµ
|
*/
|
public static void updateFbs9100SetParamCmdBydev_id(MysqlConnPool con_pool, IDCE_DischargeParam param)
|
{
|
if((param.op_cmd == MyModBusCom.CMD_StartTestACK) //Æô¶¯·Åµç³É¹¦
|
|| (param.op_cmd == MyModBusCom.CMD_StopTestACK) //Æô¶¯³äµç³É¹¦
|
|| (param.op_cmd == MyModBusCom.CMD_SetDischargeParmAck) //ÉèÖòÎÊý³É¹¦
|
|| (param.op_cmd == MyModBusCom.CMD_GetDischargeParmAck) //ÉèÖòÎÊý³É¹¦
|
)
|
{
|
String sql_str_base = Sql_Mysql.FBS9100SetParam_Table + " SET "
|
+ "dev_id=" + param.dev_id + ", "
|
+ "op_cmd=" + param.op_cmd + ", "
|
+ "TestCmd=" + param.test_cmd
|
+ " WHERE dev_id ="+param.dev_id;
|
String sql_str_update = "UPDATE " + sql_str_base;
|
//String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
sql.sqlMysqlExecute(sql_str_update);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
param.op_cmd = MyModBusCom.CMD_NULL;
|
}
|
}
|
|
|
/**
|
* ¸ù¾ÝÉ豸id¸üРtb_fbs9100_state ±í
|
* @param con_pool
|
* @param v_data
|
* @param dev_id
|
*/
|
public static void updateFbs9100StateByDev_Id(MysqlConnPool con_pool, IDCE_SystemState sysState)
|
{
|
if(sysState == null) {
|
return;
|
}
|
String sql_str_base = Sql_Mysql.FBS9100State_Table
|
+ " SET "
|
+ "dev_id=" + sysState.dev_id + ", "
|
+ "dev_ip='" + sysState.dev_ip + "', "
|
+ "dev_version='" + "', "
|
+ "record_datetime="
|
+ "'" + Com.getDateTimeFormat(sysState.record_time, Com.DTF_YMDhms) + "',"
|
+ "dev_testgroupnum=" + 0 + ", "
|
+ "dev_workstate=" + sysState.workState + ", "
|
+ "dev_alarmstate=" + sysState.stopReason + ", "
|
+ "dev_captest_onlinevol=" + sysState.onlinevol + ", "
|
+ "dev_captest_groupvol=" + sysState.groupvol + ", "
|
+ "dev_captest_curr=" + sysState.testCurr + ", "
|
+ "dev_captest_cap=" + sysState.cap_ah + ", "
|
+ "dev_commcount=" + sysState.commCount + ", "
|
+ "dev_errcommcount=" + sysState.errCount ;
|
|
//String sql_str_update = "UPDATE " + sql_str_tb + sql_str_base + " WHERE dev_id=" + dev_id;
|
String sql_str_replace = "REPLACE INTO " + sql_str_base;
|
|
Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
|
try {
|
//System.out.println(sql_str);
|
sql.sqlMysqlExecute(sql_str_replace);
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
//e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
}
|
