电机随机数据提交

Administrator

2021-03-25 578faecf2a59d3062c96aed307b6df80c87a315d

电机随机数据提交

 Demo_Manage_Simul/src/com/mode/Motor_State.java

@@ -4,7 +4,7 @@


public class Motor_State {

    public int device_id;// '设备id',

    public Date record_time;//'记录时间',

    public Date record_time = new Date();//'记录时间',

    public float motor_curr = 99.6f;//'电机电流',

    public float motor_power = 50;//'电机功率',

    public float motor_speed = 0;//'电机转速',


 Demo_Manage_Simul/src/com/thread/devs/Manage_Simul_Motor_Thread.java

@@ -20,12 +20,12 @@
    

    @Override

    public void run() {

		
        Manage_Simul_Motor_Thread_SQL.insertOrUpdateMotor_State_Table(pool, state);

        while(true) {

            try {

                createRandomData(state);

                

				
                Manage_Simul_Motor_Thread_SQL.updateMotor_State_Table(pool, state);

                

                Thread.sleep(1000);

            } catch (InterruptedException e) {


 Demo_Manage_Simul/src/com/thread/devs/Manage_Simul_Motor_Thread_SQL.java

@@ -1,17 +1,77 @@
package com.thread.devs;



import java.sql.ResultSet;

import java.sql.SQLException;



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 insertMotor_State_Table(MysqlConnPool pool,Motor_State state) {

    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+",'"+state.record_time+"',"+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+")";

		
                "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();

        }

    }

    

	
    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();

        }

    }

}