first

whyclxw

2024-04-17 b49b5bd7da878564a91ea09ec1a3a63404a21694

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
package main;
 
import java.sql.Connection;
import java.util.ArrayList;
import java.util.Date;
import java.util.TimeZone;
 
import com.mysql_param.Mysql_database_param;
import com.table.alarm.AlarmDaoFactory;
import com.table.alarm.Alarm_thread;
import com.table.badbatt.BadBatt_thread2;
import com.table.badbatt.BadBatt_thread;
import com.table_sql.MySqlPool;
 
public class MainTable {
    private static MySqlPool mpool;
    private static Connection conn;
    //´´½¨Âäºóµ¥Ìå±í
    public static    void createbadbatt(MySqlPool m_ConnPool){
        //´´½¨Êý¾Ý±í
        String createbadbatt_monSql="CREATE TABLE IF NOT EXISTS web_site.tb_badbatt_mon "
                + "("
                + "`num` int(11) NOT NULL AUTO_INCREMENT,"
                + "`battgroupid` int NOT NULL DEFAULT '0',"
                + " `mon_num` int NOT NULL DEFAULT '0',"
                + "`record_num` int NOT NULL DEFAULT '0',"
                + "`test_starttime` datetime NOT NULL DEFAULT '1982-01-01 00:00:00',"
                + "`group_vol` float NOT NULL DEFAULT '0',"
                + "`test_curr` float NOT NULL DEFAULT '0',"
                + "`mon_vol` float NOT NULL DEFAULT '0',"
                + "`real_cap` float NOT NULL DEFAULT '0',"
                + "`stdcap` float NOT NULL DEFAULT '0',"
                + "`note` varchar(64) COLLATE utf8_unicode_ci NOT NULL DEFAULT ' ',"
                + "PRIMARY KEY (`num`),"
                + "KEY `index_num` (`battgroupid`)"
                + ")";
        ArrayList<String> sql_str=new ArrayList();
        sql_str.add(createbadbatt_monSql);
        boolean bl=MySqlPool.makeManualCommit(m_ConnPool.getConn(), sql_str);
    }
    //Âäºóµ¥Ìå·þÎñÆô¶¯,Çå¿ÕÂäºóµ¥Ìå±íÖÐÊý¾ÝÖØÐÂÆô¶¯
    private static void deletebadbatt(MySqlPool m_ConnPool) {
        //ɾ³ýÊý¾Ý±í
        String deletebadbatt_monSql="DELETE FROM web_site.tb_badbatt_mon WHERE num>0 ";//truncate table ....
        ArrayList<String> sql_str=new ArrayList();
        sql_str.add(deletebadbatt_monSql);
        boolean bl=MySqlPool.makeManualCommit(m_ConnPool.getConn(), sql_str);    
    }
    //Âäºóµ¥Ìå·þÎñÆô¶¯,½«¹ØÓÚÈÝÁ¿¸æ¾¯µÄʵʱÊý¾Ý¸ÄΪÀúÊ·
    private static void updatealarmcap(MySqlPool m_ConnPool) {
        String updatealarmcapSql="update db_alarm.tb_battalarm_data set alm_cleared_type=1 where alm_id in("+AlarmDaoFactory.Alarm_CapAlarm+","+AlarmDaoFactory.Alarm_CapChange+") and alm_cleared_type=0";//truncate table ....
        ArrayList<String> sql_str=new ArrayList();
        sql_str.add(updatealarmcapSql);
        boolean bl=MySqlPool.makeManualCommit(m_ConnPool.getConn(), sql_str);    
    }
    //·þÎñÆô¶¯£¬¼Ç¼·þÎñÆô¶¯µÄ³õʼʱ¼ä
    public static void serverstartSql(Date nowdate,String serverName,String version,MySqlPool m_ConnPool_){
        String sql=" update  "+Mysql_database_param.web_site+Mysql_database_param.tb_Process_survey+" "
                +" set Process_starttime='"+BadBatt_thread.sdf.format(nowdate)
                +"',ProcessVersion='"+version
                +"' where ServerName='"+serverName+"'";
        Connection conn=m_ConnPool_.getConn();
        //System.out.println(sql);
        boolean bl=m_ConnPool_.sqlMysqlUpdate(conn, sql);
    }
    public static void main(String[] args) {
        TimeZone.setDefault(TimeZone.getTimeZone("GMT+8"));
        mpool=new MySqlPool();
        try {
            Thread.sleep(30*1000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        //·þÎñÆô¶¯£¬Èç¹ûûÓÐÂäºóµ¥Ìå±íÔò´´½¨Âäºóµ¥Ìå±í
        System.out.println("tb_badbatt_mon±íн¨!");
        createbadbatt(mpool);
        //Âäºóµ¥Ìå·þÎñÆô¶¯ºó,Çå¿ÕÂäºóµ¥Ìå±íÖÐÊý¾ÝÖØÐÂÆô¶¯
        System.out.println("tb_badbatt_mon±íÖØÆôÈ¥³ý¾ÍÊý¾Ý!");
        deletebadbatt(mpool);
        //Âäºóµ¥Ìå·þÎñÆô¶¯,½«¹ØÓÚÈÝÁ¿¸æ¾¯µÄʵʱÊý¾Ý¸ÄΪÀúÊ·
        System.out.println("Âäºóµ¥Ìå·þÎñÆô¶¯,ÈÝÁ¿¸æ¾¯µÄʵʱÊý¾Ý¸ÄΪÀúÊ·!");
        updatealarmcap(mpool);
        //·þÎñÆô¶¯£¬¼Ç¼·þÎñÆô¶¯µÄ³õʼʱ¼ä
        System.out.println("·þÎñÆô¶¯£¬¼Ç¼·þÎñÆô¶¯µÄ³õʼʱ¼ä!");
        serverstartSql(new Date(), Mysql_database_param.BMS_FBSDEV_BADBATT,Mysql_database_param.VERSION, mpool);
        //alarm_threadÏß³ÌÆô¶¯
        Alarm_thread alarm_t=new Alarm_thread(mpool);
        alarm_t.start();
        //badbatt_threadÏß³ÌÆô¶¯
        BadBatt_thread bd_t=new BadBatt_thread(mpool);
        bd_t.start();
    }
}