package com.thread.devs;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Date;

import com.base.Com;
import com.mode.Motor_State;
import com.sql.MysqlConnPool;
import com.sql.Sql_Mysql;

public class Manage_Simul_Motor_Thread_SQL {

	public static void insertOrUpdateMotor_State_Table(MysqlConnPool pool,Motor_State state) {
		String sql_str = " SELECT device_id FROM "+Sql_Mysql.Tb_Motor_State_Table+" WHERE device_id = " + state.device_id;
		String sql_str_ins = " INSERT INTO " + Sql_Mysql.Tb_Motor_State_Table +
				"(device_id,record_time,motor_curr,motor_power,motor_speed,motor_vol,motor_out_tmp,motor_into_tmp,motor_torque,motor_state) " + 
				"VALUES("+state.device_id+",'"+Com.getDateTimeFormat(state.record_time, Com.DTF_YMDhms)+"',"+state.motor_curr+","+state.motor_power+","+state.motor_speed+","+state.motor_vol+","+state.motor_out_tmp+","+state.motor_into_tmp+","+state.motor_torque+","+state.motor_state+")";
		String sql_str_upd = "UPDATE " + Sql_Mysql.Tb_Motor_State_Table +
				" SET device_id="+state.device_id+""
				+ ",record_time = '"+Com.getDateTimeFormat(state.record_time, Com.DTF_YMDhms)
				+ "',motor_curr="+state.motor_curr
				+ ",motor_power="+state.motor_power
				+ ",motor_speed="+state.motor_speed
				+ ",motor_vol="+state.motor_vol
				+ ",motor_out_tmp="+state.motor_out_tmp
				+ ",motor_into_tmp="+state.motor_into_tmp
				+ ",motor_torque="+state.motor_torque
				+ ",motor_state=" + state.motor_state+
				" WHERE device_id = " + state.device_id;
		ResultSet res = null;
		Sql_Mysql sql = new Sql_Mysql(pool.getConn());
		try {
			res = sql.sqlMysqlQuery(sql_str);
			if(res.next()) {
				sql.sqlMysqlExecute(sql_str_upd);
			}else {
				sql.sqlMysqlExecute(sql_str_ins);
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if(null != res) {
				try {
					res.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			sql.close_con();
		}
	}
	
	/**
	 * 	¸üеç»úʵʱ״̬
	 * @param pool
	 * @param state
	 */
	public static void updateMotor_State_Table(MysqlConnPool pool,Motor_State state) {
		String sql_str_upd = "UPDATE " + Sql_Mysql.Tb_Motor_State_Table +
				" SET device_id="+state.device_id+""
				+ ",record_time = '"+Com.getDateTimeFormat(state.record_time, Com.DTF_YMDhms)
				+ "',motor_curr="+state.motor_curr
				+ ",motor_power="+state.motor_power
				+ ",motor_speed="+state.motor_speed
				+ ",motor_vol="+state.motor_vol
				+ ",motor_out_tmp="+state.motor_out_tmp
				+ ",motor_into_tmp="+state.motor_into_tmp
				+ ",motor_torque="+state.motor_torque
				+ ",motor_state=" + state.motor_state+
				" WHERE device_id = " + state.device_id;
		Sql_Mysql sql = new Sql_Mysql(pool.getConn());
		try {
			//System.out.println(sql_str_upd);
			sql.sqlMysqlExecute(sql_str_upd);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			sql.close_con();
		}
	}
	
	/**
	 * 
	 * @param pool
	 * @param state
	 * @param time
	 */
	public static void createTb_Motor_State_RealData_Table(MysqlConnPool pool,int device_id,Date time) {
		String sql_str = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.Tb_Motor_State_RealData_Table+device_id+"_"+Com.getDateTimeFormat(time, Com.DTF_Y_M_D)+" (" + 
				"  `num` bigint(20) NOT NULL AUTO_INCREMENT," + 
				"  `device_id` int(11) NOT NULL DEFAULT '100001' COMMENT 'É豸id'," + 
				"  `record_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '¼Ç¼ʱ¼ä'," + 
				"  `motor_curr` float NOT NULL DEFAULT '0' COMMENT 'µç»úµçÁ÷'," + 
				"  `motor_power` float NOT NULL DEFAULT '0' COMMENT 'µç»ú¹¦ÂÊ'," + 
				"  `motor_speed` float NOT NULL DEFAULT '0' COMMENT 'µç»úתËÙ'," + 
				"  `motor_vol` float NOT NULL DEFAULT '0' COMMENT 'µç»úµçѹ'," + 
				"  `motor_out_tmp` float NOT NULL DEFAULT '0' COMMENT 'µç»ú³ö¿ÚζÈ'," + 
				"  `motor_into_tmp` float NOT NULL DEFAULT '0' COMMENT 'µç»ú½ø¿ÚζÈ'," + 
				"  `motor_torque` float NOT NULL DEFAULT '0' COMMENT 'µç»úת¾Ø'," + 
				"  `motor_state` int(11) NOT NULL DEFAULT '0' COMMENT 'µç»ú״̬'," + 
				"  PRIMARY KEY (`num`)" + 
				") ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;";
		Sql_Mysql sql = new Sql_Mysql(pool.getConn());
		try {
			sql.sqlMysqlExecute(sql_str);
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			sql.close_con();
		}
	}
	
	/**
	 * 	²åÈëÀúʷʵʱÊý¾Ý
	 * @param pool
	 * @param state
	 */
	public static void insertMotor_State_RealData_Table(MysqlConnPool pool,Motor_State state) {
		String sql_str_ins = " INSERT INTO " + Sql_Mysql.Tb_Motor_State_RealData_Table+state.device_id+"_"+Com.getDateTimeFormat(state.record_time, Com.DTF_Y_M_D) +
				"(device_id,record_time,motor_curr,motor_power,motor_speed,motor_vol,motor_out_tmp,motor_into_tmp,motor_torque,motor_state) " + 
				"VALUES("+state.device_id+",'"+Com.getDateTimeFormat(state.record_time, Com.DTF_YMDhms)+"',"+state.motor_curr+","+state.motor_power+","+state.motor_speed+","+state.motor_vol+","+state.motor_out_tmp+","+state.motor_into_tmp+","+state.motor_torque+","+state.motor_state+")";
		Sql_Mysql sql = new Sql_Mysql(pool.getConn());
		try {
			sql.sqlMysqlExecute(sql_str_ins);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			sql.close_con();
		}
	}
}