初次修改

Administrator

2021-08-07 e64eded3dcffb628171ea5c28b830dd291956d02

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
package com.dev_fbs9600.data; 
 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.util.Date; 
 
import com.battmonitor.base.Com; 
import com.battmonitor.sql.MysqlConnPool; 
import com.battmonitor.sql.Sql_Mysql; 
 
public class FBS9600_State_SQL { 
    /***********************************************************************************/ 
    public static void updateFbs9600State_ByID(MysqlConnPool con_pool, FBS9600_State state_9600) 
    { 
        String sql_str_base = Sql_Mysql.FBS9100State_Table 
                        + " SET " 
                        + " dev_ip = '" + state_9600.ip_addr + "', " 
                        + " record_datetime=" 
                        + "'" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "'," 
                        + " dev_workstate = " + state_9600.getWorkState() + ", " 
                        + " dev_commcount = " + state_9600.com_count + ", " 
                        + " dev_errcommcount = " + state_9600.com_err_count + "  " 
                        + " WHERE dev_id = " + state_9600.dev_id; 
        String sql_str_replace = "UPDATE  " + sql_str_base; 
        //System.out.println(sql_str_replace); 
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn()); 
        try { 
            sql.sqlMysqlExecute(sql_str_replace); 
        } catch (SQLException e) { 
            // TODO Auto-generated catch block 
            //e.printStackTrace(); 
        } finally { 
            sql.close_con(); 
        } 
    } 
    /***********************************************************************************/ 
    /***********************************************************************************/ 
    public static void queryFbs9600UsrCmd_ByID(MysqlConnPool con_pool, FBS9600_State fbs9600_stat) 
    { 
        String sql_str = "SELECT op_cmd FROM " + Sql_Mysql.FBS9100State_Table 
                         + " WHERE dev_id=" + fbs9600_stat.dev_id; 
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn()); 
        ResultSet res = sql.sqlMysqlQuery(sql_str); 
        try { 
            if(res.next()) { 
                int cmd = res.getInt("op_cmd"); 
                 
                if(FBS9600_State.UsrCmdNull == fbs9600_stat.getFBS9600Cmd()) { 
                    fbs9600_stat.setFBS9600CmdAckFromDev(false); 
                    fbs9600_stat.setFBS9600Cmd(cmd); 
                } 
            } 
        } catch (SQLException e) { 
            // TODO Auto-generated catch block 
            //e.printStackTrace(); 
        } finally { 
            sql.close_con(); 
        } 
    } 
    /***********************************************************************************/ 
    /***********************************************************************************/ 
    public static void updateFbs9600UsrCmdAck_ByID(MysqlConnPool con_pool, FBS9600_State fbs9600_state) 
    { 
        if((FBS9600_State.UsrCmdNull != fbs9600_state.getFBS9600Cmd())  
                && (true == fbs9600_state.getFBS9600CmdAckFromDev())) 
        { 
            String sql_str_base = Sql_Mysql.FBS9100State_Table  
                                + " SET " 
                                + " op_cmd = " + FBS9600_State.UsrCmdNull + "  " 
                                + " WHERE dev_id = " + fbs9600_state.dev_id; 
            String sql_str_replace = "UPDATE " + sql_str_base; 
            //System.out.println(sql_str_replace); 
            Sql_Mysql sql = new Sql_Mysql(con_pool.getConn()); 
            try { 
                sql.sqlMysqlExecute(sql_str_replace); 
            } catch (SQLException e) { 
            // TODO Auto-generated catch block 
            //e.printStackTrace(); 
            } finally { 
                sql.close_con(); 
            } 
             
            fbs9600_state.setFBS9600Cmd(FBS9600_State.UsrCmdNull); 
            fbs9600_state.setFBS9600CmdAckFromDev(false); 
        } 
    } 
    /***********************************************************************************/ 
    /***********************************************************************************/ 
    public static void update_JSB_LCD_UsrCmdAck_ByID(MysqlConnPool con_pool, FBS9600_State fbs9600_state) 
    { 
        String sql_str_base = Sql_Mysql.FBS9100State_Table  
                + " SET " 
                + " op_cmd = " + fbs9600_state.getFBS9600Cmd() + "  " 
                + " WHERE dev_id = " + fbs9600_state.dev_id; 
        String sql_str_replace = "UPDATE " + sql_str_base; 
        //System.out.println(sql_str_replace); 
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn()); 
        try { 
            sql.sqlMysqlExecute(sql_str_replace); 
        } catch (SQLException e) { 
        // TODO Auto-generated catch block 
        //e.printStackTrace(); 
        } finally { 
        sql.close_con(); 
        } 
    } 
    /***********************************************************************************/ 
    /***********************************************************************************/ 
    public static void replaceFbs9600Inf_ByID(MysqlConnPool con_pool, FBS9600_State fbs9600_state) 
    { 
        String sql_str_base = Sql_Mysql.FBS9100State_Table  
                + " SET " 
                + " op_cmd = " + FBS9600_State.UsrCmdNull + ",  " 
                + " dev_version = '" + String.format("V%1.3f", fbs9600_state.dev_ver) + "',  " 
                + " dev_id = " + fbs9600_state.dev_id; 
        String sql_str_replace = "REPLACE INTO " + sql_str_base; 
        //System.out.println(sql_str_replace); 
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn()); 
        try { 
        sql.sqlMysqlExecute(sql_str_replace); 
        } catch (SQLException e) { 
        // TODO Auto-generated catch block 
        //e.printStackTrace(); 
        } finally { 
        sql.close_con(); 
        } 
         
        fbs9600_state.setFBS9600Cmd(FBS9600_State.UsrCmdNull); 
        fbs9600_state.setFBS9600CmdAckFromDev(false); 
    } 
    /***********************************************************************************/ 
}