~whyclj/BattMonitor_DB_Builder.git

parent: b02deabd | 补丁 | 提交 | ignore whitespace

V1.59 edit at date 2023-03-08 1.根据电池信息配置中的数据，将未录入机房总表的机房，录入机房总表 2.根据电源信息配...

Administrator

2023-03-08 e53f7330e82dbf167d2bea4f115687909d960f61

V1.59 edit at date 2023-03-08
	1.根据电池信息配置中的数据，将未录入机房总表的机房，录入机房总表
	2.根据电源信息配置中的数据，将未录入机房总表的机房，录入机房总表
	3.创建菜单配置表 `db_app_sys`.`tb_menu_user`
		CREATE TABLE `tb_menu_user` (
		  `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增长主键',
		  `id` int(11) DEFAULT NULL COMMENT '菜单id',
		  `label` varchar(255) DEFAULT NULL COMMENT '中文名称',
		  `name` varchar(255) DEFAULT NULL COMMENT '名称',
		  `src` varchar(255) DEFAULT NULL COMMENT '路径',
		  `icon` varchar(100) DEFAULT NULL COMMENT '图标',
		  `closable` tinyint(4) DEFAULT NULL COMMENT '是否可关闭',
		  `enableduse` tinyint(4) DEFAULT NULL COMMENT '是否启用',
		  `permitName` varchar(255) DEFAULT NULL COMMENT '权限',
		  `level` tinyint(4) DEFAULT NULL COMMENT '菜单等级',
		  `ord` tinyint(4) DEFAULT NULL COMMENT '排序',
		  `menuId` int(11) DEFAULT NULL COMMENT '上级菜单id',
		  `userId` int(11) DEFAULT NULL COMMENT '用户id',
		  PRIMARY KEY (`num`)
		) ENGINE=InnoDB DEFAULT CHARSET=utf8;

7个文件已修改

	BattMonitor_DB_Builder/bin/com/version_inf/version_inf.txt	42 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	BattMonitor_DB_Builder/config.xml	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	BattMonitor_DB_Builder/src/com/database_util/DB_App_Sys.java	40 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	BattMonitor_DB_Builder/src/com/database_util/DB_battinf.java	245 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java	5 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	BattMonitor_DB_Builder/src/com/version_inf/version_inf.txt	42 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	BattMonitor_DB_Builder/src/main/main_BTS_DB_Builder.java	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史

 BattMonitor_DB_Builder/bin/com/version_inf/version_inf.txt

@@ -1,5 +1,47 @@
蓄电池监控平台建表程序

V1.59 edit at date 2023-03-08
    1.根据电池信息配置中的数据，将未录入机房总表的机房，录入机房总表
    2.根据电源信息配置中的数据，将未录入机房总表的机房，录入机房总表
    3.创建菜单配置表 `db_app_sys`.`tb_menu_user`
        CREATE TABLE `tb_menu_user` (
          `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增长主键',
          `id` int(11) DEFAULT NULL COMMENT '菜单id',
          `label` varchar(255) DEFAULT NULL COMMENT '中文名称',
          `name` varchar(255) DEFAULT NULL COMMENT '名称',
          `src` varchar(255) DEFAULT NULL COMMENT '路径',
          `icon` varchar(100) DEFAULT NULL COMMENT '图标',
          `closable` tinyint(4) DEFAULT NULL COMMENT '是否可关闭',
          `enableduse` tinyint(4) DEFAULT NULL COMMENT '是否启用',
          `permitName` varchar(255) DEFAULT NULL COMMENT '权限',
          `level` tinyint(4) DEFAULT NULL COMMENT '菜单等级',
          `ord` tinyint(4) DEFAULT NULL COMMENT '排序',
          `menuId` int(11) DEFAULT NULL COMMENT '上级菜单id',
          `userId` int(11) DEFAULT NULL COMMENT '用户id',
          PRIMARY KEY (`num`)
        ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

V1.58 edit at date 2023-03-07
    1.新增创建机房总表 
        CREATE TABLE `tb_station_inf` (
          `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
          `stationId` varchar(255) NOT NULL DEFAULT '0' COMMENT '机房Id',
          `stationName1` varchar(255) NOT NULL DEFAULT '' COMMENT 'ʡ',
          `stationName2` varchar(255) NOT NULL DEFAULT '' COMMENT '市',
          `stationName3` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[简写]',
          `stationName4` varchar(255) NOT NULL DEFAULT '' COMMENT '设备名称',
          `stationName5` varchar(255) NOT NULL DEFAULT '' COMMENT '区县',
          `stationName` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[拼接后的]',
          `deviceType` int(11) NOT NULL DEFAULT '0' COMMENT '设备类型',
          `nodeStation` int(11) NOT NULL DEFAULT '0' COMMENT '站点类型[节点站标识:0:不是节点站[默认];1:节点站]',
          `stationType` varchar(255) NOT NULL DEFAULT '' COMMENT '站点电压等级[（35kv/110kv/220kv 字符串类型）]',
          `stationLongitude` double NOT NULL DEFAULT '0' COMMENT '经度',
          `stationLatitude` double NOT NULL DEFAULT '0' COMMENT '纬度',
          `stationAddr` varchar(255) NOT NULL DEFAULT '' COMMENT '机房详细地址',
          PRIMARY KEY (`num`)
        ) ENGINE=InnoDB AUTO_INCREMENT=132 DEFAULT CHARSET=utf8 COMMENT='机房总站表  = 电池信息表 + 电源信息表 ';
		

V1.57 edit at date 2023-03-03
    1.线程监控表中新增web平台监控线程记录，用于监控平台服务的运行状态，保证平台服务不停止
        sql.sqlMysqlExecute(" INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11024', 'WEB_PLATFORM_SERVER',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'WEB_PLATFORM_SERVER', '1', 'v1.100', '蓄电池WEB平台服务', '300');");

 BattMonitor_DB_Builder/config.xml

@@ -2,7 +2,7 @@

<root>
  <mysql_ramdb_recreate_en>false</mysql_ramdb_recreate_en>
  <mysql_server_ip>192.168.10.79</mysql_server_ip>
  <mysql_server_ip>127.0.0.1</mysql_server_ip>
  <!--SOURCE_BATTDATA_TYPE_FBSDEV = 0-->
  <!--SOURCE_BATTDATA_TYPE_SQLSERVER = 1-->
  <!--SOURCE_BATTDATA_TYPE_C_INTERFACE = 2-->

 BattMonitor_DB_Builder/src/com/database_util/DB_App_Sys.java

@@ -49,6 +49,7 @@

        createTb_Menu_Approve_Table(pool, recreate);//创建表tb_menu_approve

        createTb_Menu_User_Table(pool, recreate);//创建表tb_menu_approve

        System.out.println(" db_app_sys init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
    }
@@ -95,6 +96,45 @@
            sql.close_con();
        }
    }
    /**
     * 
     * @Title: createTb_Menu_User_Table
     * @Description: 建表tb_menu_user
     * @param pool
     * @param recreate
     * @author author
     * @date 2021年12月13日
     */
    private static void createTb_Menu_User_Table(MysqlConnPool pool, boolean recreate) {
        String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Tb_Menu_User_Table;
        String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Tb_Menu_User_Table + " (" + 
                "  `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增长主键'," + 
                "  `id` int(11) DEFAULT NULL COMMENT '菜单id'," + 
                "  `label` varchar(255) DEFAULT NULL COMMENT '中文名称'," + 
                "  `name` varchar(255) DEFAULT NULL COMMENT '名称'," + 
                "  `src` varchar(255) DEFAULT NULL COMMENT '路径'," + 
                "  `icon` varchar(100) DEFAULT NULL COMMENT '图标'," + 
                "  `closable` tinyint(4) DEFAULT NULL COMMENT '是否可关闭'," + 
                "  `enableduse` tinyint(4) DEFAULT NULL COMMENT '是否启用'," + 
                "  `permitName` varchar(255) DEFAULT NULL COMMENT '权限'," + 
                "  `level` tinyint(4) DEFAULT NULL COMMENT '菜单等级'," + 
                "  `ord` tinyint(4) DEFAULT NULL COMMENT '排序'," + 
                "  `menuId` int(11) DEFAULT NULL COMMENT '上级菜单id'," + 
                "  `userId` int(11) DEFAULT NULL COMMENT '用户id'," + 
                "  PRIMARY KEY (`num`)" + 
                ") ENGINE=InnoDB DEFAULT CHARSET=utf8;";
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());
        try {
            if(true == recreate) {			
                sql.sqlMysqlExecute(sql_str01);
            }
            sql.sqlMysqlExecute(sql_str02);		
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }

    private static void createTb_Page_Param2_Table(MysqlConnPool pool, boolean recreate) {
        String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Tb_Page_Param2_Table;

 BattMonitor_DB_Builder/src/com/database_util/DB_battinf.java

@@ -23,6 +23,8 @@
        
        createBattInf_Table(pool, recreate);                          //创建电池组信息配置表
        
        createStation_Inf_Table(pool,recreate);                        //创建机房信息总表
		
        createBattinfApply_table(pool, recreate);                    //创建机房安装审批表
        
        createBattinfEx_TABLE(pool, recreate);                        //创建基站信息
@@ -54,6 +56,8 @@
        
        createBattmon_Standardcurve_TABLE(pool,recreate);
        
		

        System.out.println(" db_battinf init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
    }
    
@@ -480,6 +484,13 @@
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(null != res) {
                try {
                    res.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            sql.close_con();
        }
    }
@@ -611,6 +622,50 @@
                //sql.sqlMysqlExecute(sql_str01);
            }
            sql.sqlMysqlExecute(sql_str02);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
	
    /**
     *    创建 `db_battinf`.`tb_station_inf` 表
     * @param pool
     * @param recreate
     */
    public static void createStation_Inf_Table(MysqlConnPool pool, boolean recreate) {
        String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Station_Inf_Table;
        String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Station_Inf_Table + " (" + 
                "  `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键'," + 
                "  `stationId` varchar(255) NOT NULL DEFAULT '0' COMMENT '机房Id'," + 
                "  `stationName1` varchar(255) NOT NULL DEFAULT '' COMMENT 'ʡ'," + 
                "  `stationName2` varchar(255) NOT NULL DEFAULT '' COMMENT '市'," + 
                "  `stationName3` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[简写]'," + 
                "  `stationName4` varchar(255) NOT NULL DEFAULT '' COMMENT '设备名称'," + 
                "  `stationName5` varchar(255) NOT NULL DEFAULT '' COMMENT '区县'," + 
                "  `stationName` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[拼接后的]'," + 
                "  `deviceType` int(11) NOT NULL DEFAULT '0' COMMENT '设备类型'," + 
                "  `nodeStation` int(11) NOT NULL DEFAULT '0' COMMENT '站点类型[节点站标识:0:不是节点站[默认];1:节点站]'," + 
                "  `stationType` varchar(255) NOT NULL DEFAULT '' COMMENT '站点电压等级[（35kv/110kv/220kv 字符串类型）]'," + 
                "  `stationLongitude` double NOT NULL DEFAULT '0' COMMENT '经度'," + 
                "  `stationLatitude` double NOT NULL DEFAULT '0' COMMENT '纬度'," + 
                "  `stationAddr` varchar(255) NOT NULL DEFAULT '' COMMENT '机房详细地址'," + 
                "  PRIMARY KEY (`num`)" + 
                ") ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='机房总站表  = 电池信息表 + 电源信息表 ';";
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());
        try {
            if(true == recreate) {			
                //sql.sqlMysqlExecute(sql_str01);
            }
            sql.sqlMysqlExecute(sql_str02);
			
            //录入已存在的蓄电池机房信息
            initBattStationInfoData(pool);
			
            //录入已存在的电源机房信息
            initPowerStationInfoData(pool);
			
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
@@ -2213,7 +2268,197 @@
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(null != res) {
                try {
                    res.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            sql.close_con();
        }
    }
	
    /**
     * 根据机房信息和电池信息更新电源信息总表
     * @param pool
     */
    public static void initBattStationInfoData(MysqlConnPool pool) {
        String sql_str_sel = " SELECT DISTINCT(StationId),StationName,StationName1,StationName2,StationName3,StationName4,StationName5,NodeStation,StationType " + 
                             " FROM " + Sql_Mysql.BattInf_Table + 
                             " WHERE StationId > 0";
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());
        ResultSet res= null;
        ResultSet res1= null;
        res = sql.sqlMysqlQuery(sql_str_sel);
        StringBuffer sql_strs = new StringBuffer(" INSERT INTO " + Sql_Mysql.Station_Inf_Table + "(stationId,stationName1,stationName2,stationName3,stationName4,stationName5,stationName,nodeStation,stationType,stationLongitude,stationLatitude,stationAddr) VALUES ");
         int sta_cnt = 0;
        try {
            while(res.next()) {
                String StationId = res.getString("StationId").trim();
                String StationName = res.getString("StationName");
                String StationName1 = res.getString("StationName1");
                String StationName2 = res.getString("StationName2");
                String StationName3 = res.getString("StationName3");
                String StationName4 = res.getString("StationName4");
                String StationName5 = res.getString("StationName5");
                int NodeStation = res.getInt("NodeStation");
                String StationType = res.getString("StationType");
                if(null == StationType) {
                    StationType = "";
                }
                String StationAddr = "";
                double longitude = 0;
                double latitude = 0;
				
                res1 = sql.sqlMysqlQuery(" SELECT * FROM " + Sql_Mysql.BattMapInformation_Table + " WHERE stationId = " + StationId);
                if(res1.next()) {
                    StationAddr = res1.getString("address");
                    longitude = res1.getDouble("longitude");
                    latitude = res1.getDouble("latitude");					
                }
				
                if(!queryStationExist(pool, StationId)) {
                    if(sta_cnt > 0) {
                        sql_strs.append(",");
                    }		
                    sql_strs.append("('"+StationId+"','"+StationName1+"','"+StationName2+"','"+StationName3+"','"+StationName4+"','"+StationName5+"','"+StationName+"','"+NodeStation+"','"+StationType+"','"+longitude+"','"+latitude+"','"+StationAddr+"')");
					
                    sta_cnt ++;
                }			
            }
            if(sta_cnt > 0) {
                //System.out.println(sql_strs.toString());
                sql.sqlMysqlExecute(sql_strs.toString());
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(null != res) {
                try {
                    res.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(null != res1) {
                try {
                    res1.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            sql.close_con();
        }
    }
	
    /**
     * 根据电源信息表中的机房信息录入机房总表
     * @param pool
     */
    public static void initPowerStationInfoData(MysqlConnPool pool) {
        String sql_str_sel = " SELECT DISTINCT(StationId),StationName,StationName1,StationName2,StationName3,StationName4,StationName5 " + 
                             " FROM " + Sql_Mysql.Pwrdev_Inf_Table + 
                             " WHERE StationId > 0";
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());
        ResultSet res= null;
        ResultSet res1= null;
        res = sql.sqlMysqlQuery(sql_str_sel);
        StringBuffer sql_strs = new StringBuffer(" INSERT INTO " + Sql_Mysql.Station_Inf_Table + "(stationId,stationName1,stationName2,stationName3,stationName4,stationName5,stationName,nodeStation,stationType,stationLongitude,stationLatitude,stationAddr) VALUES ");
         int sta_cnt = 0;
        try {
            while(res.next()) {
                String StationId = res.getString("StationId").trim();
                String StationName = res.getString("StationName");
                String StationName1 = res.getString("StationName1");
                String StationName2 = res.getString("StationName2");
                String StationName3 = res.getString("StationName3");
                String StationName4 = res.getString("StationName4");
                String StationName5 = res.getString("StationName5");
                int NodeStation = 0;
                String StationType = "";
                String StationAddr = "";
                double longitude = 0;
                double latitude = 0;
				
                res1 = sql.sqlMysqlQuery(" SELECT * FROM " + Sql_Mysql.BattMapInformation_Table + " WHERE stationId = " + StationId);
                if(res1.next()) {
                    StationAddr = res1.getString("address");
                    longitude = res1.getDouble("longitude");
                    latitude = res1.getDouble("latitude");					
                }
				
                if(!queryStationExist(pool, StationId)) {
                    if(sta_cnt > 0) {
                        sql_strs.append(",");
                    }		
                    sql_strs.append("('"+StationId+"','"+StationName1+"','"+StationName2+"','"+StationName3+"','"+StationName4+"','"+StationName5+"','"+StationName+"','"+NodeStation+"','"+StationType+"','"+longitude+"','"+latitude+"','"+StationAddr+"')");
					
                    sta_cnt ++;
                }			
            }
            if(sta_cnt > 0) {
                //System.out.println(sql_strs.toString());
                sql.sqlMysqlExecute(sql_strs.toString());
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(null != res) {
                try {
                    res.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(null != res1) {
                try {
                    res1.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            sql.close_con();
        }
    }
	
    /**
     *     查询总站表是否已存在当前机房id的机房
     * @param pool			
     * @param stationId    当前机房id
     * @return    true:已存在      false:不存在
     */
    public static boolean queryStationExist(MysqlConnPool pool,String stationId) {
        String sql_str_sel = "SELECT * FROM " + Sql_Mysql.Station_Inf_Table + " WHERE stationId = '" + stationId+"'";
        ResultSet res2 = null;
        boolean flag = false;
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());
        try {
            //System.out.println(sql_str_sel);
            res2 = sql.sqlMysqlQuery(sql_str_sel);			
            if(res2.next()) {
                //System.out.println("StationId："+stationId);
                flag = true;
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(null != res2) {
                try {
                    res2.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            sql.close_con();
        }
        return flag;
    }
	
	
    public static void main(String[] args) {
        MysqlConnPool pool = new MysqlConnPool("192.168.10.79", 3360, 10);
        //initBattStationInfoData(pool);
        initPowerStationInfoData(pool);
    }
}

 BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java

@@ -252,7 +252,9 @@
    
    public final static String A059_Station_Inf_TABLE = DB_BATT_INF + ".`tb_a059_station_inf`";                        //充放电一体机配置机房            
    public final static String Battinf_Guides_TABLE = DB_BATT_INF + ".`tb_battinf_guides`";                            //电池组各参数参考线            
    public final static String Battmon_Standardcurve_TABLE = DB_BATT_INF + ".`tb_battmon_standardcurve`";            //标准曲线表			
    public final static String Battmon_Standardcurve_TABLE = DB_BATT_INF + ".`tb_battmon_standardcurve`";            //标准曲线表	
	
    public final static String Station_Inf_Table = DB_BATT_INF + ".`tb_station_inf`";                                //机房信息总表			
    
    
    
@@ -286,6 +288,7 @@
    public static final String Tb_Page_Param_User_Table = DB_AppSys + ".`tb_page_param_user`";
    public static final String Tb_Page_Param2_Table = DB_AppSys + ".`tb_page_param2`";
    public static final String Tb_Menu_Approve_Table = DB_AppSys + ".`tb_menu_approve`";
    public static final String Tb_Menu_User_Table = DB_AppSys + ".`tb_menu_user`";
    
    
    

 BattMonitor_DB_Builder/src/com/version_inf/version_inf.txt

@@ -1,5 +1,47 @@
蓄电池监控平台建表程序

V1.59 edit at date 2023-03-08
    1.根据电池信息配置中的数据，将未录入机房总表的机房，录入机房总表
    2.根据电源信息配置中的数据，将未录入机房总表的机房，录入机房总表
    3.创建菜单配置表 `db_app_sys`.`tb_menu_user`
        CREATE TABLE `tb_menu_user` (
          `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增长主键',
          `id` int(11) DEFAULT NULL COMMENT '菜单id',
          `label` varchar(255) DEFAULT NULL COMMENT '中文名称',
          `name` varchar(255) DEFAULT NULL COMMENT '名称',
          `src` varchar(255) DEFAULT NULL COMMENT '路径',
          `icon` varchar(100) DEFAULT NULL COMMENT '图标',
          `closable` tinyint(4) DEFAULT NULL COMMENT '是否可关闭',
          `enableduse` tinyint(4) DEFAULT NULL COMMENT '是否启用',
          `permitName` varchar(255) DEFAULT NULL COMMENT '权限',
          `level` tinyint(4) DEFAULT NULL COMMENT '菜单等级',
          `ord` tinyint(4) DEFAULT NULL COMMENT '排序',
          `menuId` int(11) DEFAULT NULL COMMENT '上级菜单id',
          `userId` int(11) DEFAULT NULL COMMENT '用户id',
          PRIMARY KEY (`num`)
        ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

V1.58 edit at date 2023-03-07
    1.新增创建机房总表 
        CREATE TABLE `tb_station_inf` (
          `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
          `stationId` varchar(255) NOT NULL DEFAULT '0' COMMENT '机房Id',
          `stationName1` varchar(255) NOT NULL DEFAULT '' COMMENT 'ʡ',
          `stationName2` varchar(255) NOT NULL DEFAULT '' COMMENT '市',
          `stationName3` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[简写]',
          `stationName4` varchar(255) NOT NULL DEFAULT '' COMMENT '设备名称',
          `stationName5` varchar(255) NOT NULL DEFAULT '' COMMENT '区县',
          `stationName` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[拼接后的]',
          `deviceType` int(11) NOT NULL DEFAULT '0' COMMENT '设备类型',
          `nodeStation` int(11) NOT NULL DEFAULT '0' COMMENT '站点类型[节点站标识:0:不是节点站[默认];1:节点站]',
          `stationType` varchar(255) NOT NULL DEFAULT '' COMMENT '站点电压等级[（35kv/110kv/220kv 字符串类型）]',
          `stationLongitude` double NOT NULL DEFAULT '0' COMMENT '经度',
          `stationLatitude` double NOT NULL DEFAULT '0' COMMENT '纬度',
          `stationAddr` varchar(255) NOT NULL DEFAULT '' COMMENT '机房详细地址',
          PRIMARY KEY (`num`)
        ) ENGINE=InnoDB AUTO_INCREMENT=132 DEFAULT CHARSET=utf8 COMMENT='机房总站表  = 电池信息表 + 电源信息表 ';
		

V1.57 edit at date 2023-03-03
    1.线程监控表中新增web平台监控线程记录，用于监控平台服务的运行状态，保证平台服务不停止
        sql.sqlMysqlExecute(" INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11024', 'WEB_PLATFORM_SERVER',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'WEB_PLATFORM_SERVER', '1', 'v1.100', '蓄电池WEB平台服务', '300');");

 BattMonitor_DB_Builder/src/main/main_BTS_DB_Builder.java

@@ -30,7 +30,7 @@
    /**************************************************************************/
    /**************************************************************************/
    public final static boolean app_debug = false;
    public final static float m_VersionNum = (float) 1.57;
    public final static float m_VersionNum = (float) 1.59;
    public final static String m_Version = "Welcome To Use BTS DB BUILDER V" + m_VersionNum + " RC_20180908";
    /**************************************************************************/
    /**************************************************************************/

			@@ -1,5 +1,47 @@
			蓄电池监控平台建表程序

			V1.59 edit at date 2023-03-08
			1.根据电池信息配置中的数据，将未录入机房总表的机房，录入机房总表
			2.根据电源信息配置中的数据，将未录入机房总表的机房，录入机房总表
			3.创建菜单配置表 `db_app_sys`.`tb_menu_user`
			CREATE TABLE `tb_menu_user` (
			`num` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增长主键',
			`id` int(11) DEFAULT NULL COMMENT '菜单id',
			`label` varchar(255) DEFAULT NULL COMMENT '中文名称',
			`name` varchar(255) DEFAULT NULL COMMENT '名称',
			`src` varchar(255) DEFAULT NULL COMMENT '路径',
			`icon` varchar(100) DEFAULT NULL COMMENT '图标',
			`closable` tinyint(4) DEFAULT NULL COMMENT '是否可关闭',
			`enableduse` tinyint(4) DEFAULT NULL COMMENT '是否启用',
			`permitName` varchar(255) DEFAULT NULL COMMENT '权限',
			`level` tinyint(4) DEFAULT NULL COMMENT '菜单等级',
			`ord` tinyint(4) DEFAULT NULL COMMENT '排序',
			`menuId` int(11) DEFAULT NULL COMMENT '上级菜单id',
			`userId` int(11) DEFAULT NULL COMMENT '用户id',
			PRIMARY KEY (`num`)
			) ENGINE=InnoDB DEFAULT CHARSET=utf8;

			V1.58 edit at date 2023-03-07
			1.新增创建机房总表
			CREATE TABLE `tb_station_inf` (
			`num` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
			`stationId` varchar(255) NOT NULL DEFAULT '0' COMMENT '机房Id',
			`stationName1` varchar(255) NOT NULL DEFAULT '' COMMENT 'ʡ',
			`stationName2` varchar(255) NOT NULL DEFAULT '' COMMENT '市',
			`stationName3` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[简写]',
			`stationName4` varchar(255) NOT NULL DEFAULT '' COMMENT '设备名称',
			`stationName5` varchar(255) NOT NULL DEFAULT '' COMMENT '区县',
			`stationName` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[拼接后的]',
			`deviceType` int(11) NOT NULL DEFAULT '0' COMMENT '设备类型',
			`nodeStation` int(11) NOT NULL DEFAULT '0' COMMENT '站点类型[节点站标识:0:不是节点站[默认];1:节点站]',
			`stationType` varchar(255) NOT NULL DEFAULT '' COMMENT '站点电压等级[（35kv/110kv/220kv 字符串类型）]',
			`stationLongitude` double NOT NULL DEFAULT '0' COMMENT '经度',
			`stationLatitude` double NOT NULL DEFAULT '0' COMMENT '纬度',
			`stationAddr` varchar(255) NOT NULL DEFAULT '' COMMENT '机房详细地址',
			PRIMARY KEY (`num`)
			) ENGINE=InnoDB AUTO_INCREMENT=132 DEFAULT CHARSET=utf8 COMMENT='机房总站表 = 电池信息表 + 电源信息表 ';


			V1.57 edit at date 2023-03-03
			1.线程监控表中新增web平台监控线程记录，用于监控平台服务的运行状态，保证平台服务不停止
			sql.sqlMysqlExecute(" INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11024', 'WEB_PLATFORM_SERVER', '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'WEB_PLATFORM_SERVER', '1', 'v1.100', '蓄电池WEB平台服务', '300');");

			@@ -2,7 +2,7 @@

			<root>
			<mysql_ramdb_recreate_en>false</mysql_ramdb_recreate_en>
			<mysql_server_ip>192.168.10.79</mysql_server_ip>
			<mysql_server_ip>127.0.0.1</mysql_server_ip>
			<!--SOURCE_BATTDATA_TYPE_FBSDEV = 0-->
			<!--SOURCE_BATTDATA_TYPE_SQLSERVER = 1-->
			<!--SOURCE_BATTDATA_TYPE_C_INTERFACE = 2-->

			@@ -49,6 +49,7 @@

			createTb_Menu_Approve_Table(pool, recreate);//创建表tb_menu_approve

			createTb_Menu_User_Table(pool, recreate);//创建表tb_menu_approve

			System.out.println(" db_app_sys init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
			}
			@@ -95,6 +96,45 @@
			sql.close_con();
			}
			}
			/**
			*
			* @Title: createTb_Menu_User_Table
			* @Description: 建表tb_menu_user
			* @param pool
			* @param recreate
			* @author author
			* @date 2021年12月13日
			*/
			private static void createTb_Menu_User_Table(MysqlConnPool pool, boolean recreate) {
			String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Tb_Menu_User_Table;
			String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Tb_Menu_User_Table + " (" +
			" `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增长主键'," +
			" `id` int(11) DEFAULT NULL COMMENT '菜单id'," +
			" `label` varchar(255) DEFAULT NULL COMMENT '中文名称'," +
			" `name` varchar(255) DEFAULT NULL COMMENT '名称'," +
			" `src` varchar(255) DEFAULT NULL COMMENT '路径'," +
			" `icon` varchar(100) DEFAULT NULL COMMENT '图标'," +
			" `closable` tinyint(4) DEFAULT NULL COMMENT '是否可关闭'," +
			" `enableduse` tinyint(4) DEFAULT NULL COMMENT '是否启用'," +
			" `permitName` varchar(255) DEFAULT NULL COMMENT '权限'," +
			" `level` tinyint(4) DEFAULT NULL COMMENT '菜单等级'," +
			" `ord` tinyint(4) DEFAULT NULL COMMENT '排序'," +
			" `menuId` int(11) DEFAULT NULL COMMENT '上级菜单id'," +
			" `userId` int(11) DEFAULT NULL COMMENT '用户id'," +
			" PRIMARY KEY (`num`)" +
			") ENGINE=InnoDB DEFAULT CHARSET=utf8;";
			Sql_Mysql sql = new Sql_Mysql(pool.getConn());
			try {
			if(true == recreate) {
			sql.sqlMysqlExecute(sql_str01);
			}
			sql.sqlMysqlExecute(sql_str02);
			} catch (SQLException e) {
			e.printStackTrace();
			} finally {
			sql.close_con();
			}
			}

			private static void createTb_Page_Param2_Table(MysqlConnPool pool, boolean recreate) {
			String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Tb_Page_Param2_Table;

			@@ -23,6 +23,8 @@

			createBattInf_Table(pool, recreate); //创建电池组信息配置表

			createStation_Inf_Table(pool,recreate); //创建机房信息总表

			createBattinfApply_table(pool, recreate); //创建机房安装审批表

			createBattinfEx_TABLE(pool, recreate); //创建基站信息
			@@ -54,6 +56,8 @@

			createBattmon_Standardcurve_TABLE(pool,recreate);



			System.out.println(" db_battinf init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
			}

			@@ -480,6 +484,13 @@
			} catch (SQLException e) {
			e.printStackTrace();
			} finally {
			if(null != res) {
			try {
			res.close();
			} catch (SQLException e) {
			e.printStackTrace();
			}
			}
			sql.close_con();
			}
			}
			@@ -611,6 +622,50 @@
			//sql.sqlMysqlExecute(sql_str01);
			}
			sql.sqlMysqlExecute(sql_str02);
			} catch (SQLException e) {
			e.printStackTrace();
			} finally {
			sql.close_con();
			}
			}

			/**
			* 创建 `db_battinf`.`tb_station_inf` 表
			* @param pool
			* @param recreate
			*/
			public static void createStation_Inf_Table(MysqlConnPool pool, boolean recreate) {
			String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Station_Inf_Table;
			String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Station_Inf_Table + " (" +
			" `num` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键'," +
			" `stationId` varchar(255) NOT NULL DEFAULT '0' COMMENT '机房Id'," +
			" `stationName1` varchar(255) NOT NULL DEFAULT '' COMMENT 'ʡ'," +
			" `stationName2` varchar(255) NOT NULL DEFAULT '' COMMENT '市'," +
			" `stationName3` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[简写]'," +
			" `stationName4` varchar(255) NOT NULL DEFAULT '' COMMENT '设备名称'," +
			" `stationName5` varchar(255) NOT NULL DEFAULT '' COMMENT '区县'," +
			" `stationName` varchar(255) NOT NULL DEFAULT '' COMMENT '机房名称[拼接后的]'," +
			" `deviceType` int(11) NOT NULL DEFAULT '0' COMMENT '设备类型'," +
			" `nodeStation` int(11) NOT NULL DEFAULT '0' COMMENT '站点类型[节点站标识:0:不是节点站[默认];1:节点站]'," +
			" `stationType` varchar(255) NOT NULL DEFAULT '' COMMENT '站点电压等级[（35kv/110kv/220kv 字符串类型）]'," +
			" `stationLongitude` double NOT NULL DEFAULT '0' COMMENT '经度'," +
			" `stationLatitude` double NOT NULL DEFAULT '0' COMMENT '纬度'," +
			" `stationAddr` varchar(255) NOT NULL DEFAULT '' COMMENT '机房详细地址'," +
			" PRIMARY KEY (`num`)" +
			") ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='机房总站表 = 电池信息表 + 电源信息表 ';";
			Sql_Mysql sql = new Sql_Mysql(pool.getConn());
			try {
			if(true == recreate) {
			//sql.sqlMysqlExecute(sql_str01);
			}
			sql.sqlMysqlExecute(sql_str02);

			//录入已存在的蓄电池机房信息
			initBattStationInfoData(pool);

			//录入已存在的电源机房信息
			initPowerStationInfoData(pool);

			} catch (SQLException e) {
			e.printStackTrace();
			} finally {
			@@ -2213,7 +2268,197 @@
			} catch (SQLException e) {
			e.printStackTrace();
			} finally {
			if(null != res) {
			try {
			res.close();
			} catch (SQLException e) {
			e.printStackTrace();
			}
			}
			sql.close_con();
			}
			}

			/**
			* 根据机房信息和电池信息更新电源信息总表
			* @param pool
			*/
			public static void initBattStationInfoData(MysqlConnPool pool) {
			String sql_str_sel = " SELECT DISTINCT(StationId),StationName,StationName1,StationName2,StationName3,StationName4,StationName5,NodeStation,StationType " +
			" FROM " + Sql_Mysql.BattInf_Table +
			" WHERE StationId > 0";
			Sql_Mysql sql = new Sql_Mysql(pool.getConn());
			ResultSet res= null;
			ResultSet res1= null;
			res = sql.sqlMysqlQuery(sql_str_sel);
			StringBuffer sql_strs = new StringBuffer(" INSERT INTO " + Sql_Mysql.Station_Inf_Table + "(stationId,stationName1,stationName2,stationName3,stationName4,stationName5,stationName,nodeStation,stationType,stationLongitude,stationLatitude,stationAddr) VALUES ");
			int sta_cnt = 0;
			try {
			while(res.next()) {
			String StationId = res.getString("StationId").trim();
			String StationName = res.getString("StationName");
			String StationName1 = res.getString("StationName1");
			String StationName2 = res.getString("StationName2");
			String StationName3 = res.getString("StationName3");
			String StationName4 = res.getString("StationName4");
			String StationName5 = res.getString("StationName5");
			int NodeStation = res.getInt("NodeStation");
			String StationType = res.getString("StationType");
			if(null == StationType) {
			StationType = "";
			}
			String StationAddr = "";
			double longitude = 0;
			double latitude = 0;

			res1 = sql.sqlMysqlQuery(" SELECT * FROM " + Sql_Mysql.BattMapInformation_Table + " WHERE stationId = " + StationId);
			if(res1.next()) {
			StationAddr = res1.getString("address");
			longitude = res1.getDouble("longitude");
			latitude = res1.getDouble("latitude");
			}

			if(!queryStationExist(pool, StationId)) {
			if(sta_cnt > 0) {
			sql_strs.append(",");
			}
			sql_strs.append("('"+StationId+"','"+StationName1+"','"+StationName2+"','"+StationName3+"','"+StationName4+"','"+StationName5+"','"+StationName+"','"+NodeStation+"','"+StationType+"','"+longitude+"','"+latitude+"','"+StationAddr+"')");

			sta_cnt ++;
			}
			}
			if(sta_cnt > 0) {
			//System.out.println(sql_strs.toString());
			sql.sqlMysqlExecute(sql_strs.toString());
			}
			} catch (SQLException e) {
			e.printStackTrace();
			} finally {
			if(null != res) {
			try {
			res.close();
			} catch (SQLException e) {
			e.printStackTrace();
			}
			}
			if(null != res1) {
			try {
			res1.close();
			} catch (SQLException e) {
			e.printStackTrace();
			}
			}
			sql.close_con();
			}
			}

			/**
			* 根据电源信息表中的机房信息录入机房总表
			* @param pool
			*/
			public static void initPowerStationInfoData(MysqlConnPool pool) {
			String sql_str_sel = " SELECT DISTINCT(StationId),StationName,StationName1,StationName2,StationName3,StationName4,StationName5 " +
			" FROM " + Sql_Mysql.Pwrdev_Inf_Table +
			" WHERE StationId > 0";
			Sql_Mysql sql = new Sql_Mysql(pool.getConn());
			ResultSet res= null;
			ResultSet res1= null;
			res = sql.sqlMysqlQuery(sql_str_sel);
			StringBuffer sql_strs = new StringBuffer(" INSERT INTO " + Sql_Mysql.Station_Inf_Table + "(stationId,stationName1,stationName2,stationName3,stationName4,stationName5,stationName,nodeStation,stationType,stationLongitude,stationLatitude,stationAddr) VALUES ");
			int sta_cnt = 0;
			try {
			while(res.next()) {
			String StationId = res.getString("StationId").trim();
			String StationName = res.getString("StationName");
			String StationName1 = res.getString("StationName1");
			String StationName2 = res.getString("StationName2");
			String StationName3 = res.getString("StationName3");
			String StationName4 = res.getString("StationName4");
			String StationName5 = res.getString("StationName5");
			int NodeStation = 0;
			String StationType = "";
			String StationAddr = "";
			double longitude = 0;
			double latitude = 0;

			res1 = sql.sqlMysqlQuery(" SELECT * FROM " + Sql_Mysql.BattMapInformation_Table + " WHERE stationId = " + StationId);
			if(res1.next()) {
			StationAddr = res1.getString("address");
			longitude = res1.getDouble("longitude");
			latitude = res1.getDouble("latitude");
			}

			if(!queryStationExist(pool, StationId)) {
			if(sta_cnt > 0) {
			sql_strs.append(",");
			}
			sql_strs.append("('"+StationId+"','"+StationName1+"','"+StationName2+"','"+StationName3+"','"+StationName4+"','"+StationName5+"','"+StationName+"','"+NodeStation+"','"+StationType+"','"+longitude+"','"+latitude+"','"+StationAddr+"')");

			sta_cnt ++;
			}
			}
			if(sta_cnt > 0) {
			//System.out.println(sql_strs.toString());
			sql.sqlMysqlExecute(sql_strs.toString());
			}
			} catch (SQLException e) {
			e.printStackTrace();
			} finally {
			if(null != res) {
			try {
			res.close();
			} catch (SQLException e) {
			e.printStackTrace();
			}
			}
			if(null != res1) {
			try {
			res1.close();
			} catch (SQLException e) {
			e.printStackTrace();
			}
			}
			sql.close_con();
			}
			}

			/**
			* 查询总站表是否已存在当前机房id的机房
			* @param pool
			* @param stationId 当前机房id
			* @return true:已存在 false:不存在
			*/
			public static boolean queryStationExist(MysqlConnPool pool,String stationId) {
			String sql_str_sel = "SELECT * FROM " + Sql_Mysql.Station_Inf_Table + " WHERE stationId = '" + stationId+"'";
			ResultSet res2 = null;
			boolean flag = false;
			Sql_Mysql sql = new Sql_Mysql(pool.getConn());
			try {
			//System.out.println(sql_str_sel);
			res2 = sql.sqlMysqlQuery(sql_str_sel);
			if(res2.next()) {
			//System.out.println("StationId："+stationId);
			flag = true;
			}
			} catch (SQLException e) {
			e.printStackTrace();
			} finally {
			if(null != res2) {
			try {
			res2.close();
			} catch (SQLException e) {
			e.printStackTrace();
			}
			}
			sql.close_con();
			}
			return flag;
			}


			public static void main(String[] args) {
			MysqlConnPool pool = new MysqlConnPool("192.168.10.79", 3360, 10);
			//initBattStationInfoData(pool);
			initPowerStationInfoData(pool);
			}
			}

			@@ -252,7 +252,9 @@

			public final static String A059_Station_Inf_TABLE = DB_BATT_INF + ".`tb_a059_station_inf`"; //充放电一体机配置机房
			public final static String Battinf_Guides_TABLE = DB_BATT_INF + ".`tb_battinf_guides`"; //电池组各参数参考线
			public final static String Battmon_Standardcurve_TABLE = DB_BATT_INF + ".`tb_battmon_standardcurve`"; //标准曲线表
			public final static String Battmon_Standardcurve_TABLE = DB_BATT_INF + ".`tb_battmon_standardcurve`"; //标准曲线表

			public final static String Station_Inf_Table = DB_BATT_INF + ".`tb_station_inf`"; //机房信息总表



			@@ -286,6 +288,7 @@
			public static final String Tb_Page_Param_User_Table = DB_AppSys + ".`tb_page_param_user`";
			public static final String Tb_Page_Param2_Table = DB_AppSys + ".`tb_page_param2`";
			public static final String Tb_Menu_Approve_Table = DB_AppSys + ".`tb_menu_approve`";
			public static final String Tb_Menu_User_Table = DB_AppSys + ".`tb_menu_user`";

			@@ -30,7 +30,7 @@
			/**************************************************************************/
			/**************************************************************************/
			public final static boolean app_debug = false;
			public final static float m_VersionNum = (float) 1.57;
			public final static float m_VersionNum = (float) 1.59;
			public final static String m_Version = "Welcome To Use BTS DB BUILDER V" + m_VersionNum + " RC_20180908";
			/**************************************************************************/
			/**************************************************************************/