commit
12661a53d3
@ -1,76 +1,81 @@
|
||||
#=============================================================================================================
|
||||
# MySQL
|
||||
#=============================================================================================================
|
||||
# 驱动程序
|
||||
jdbc.mysql.driver=com.mysql.jdbc.Driver
|
||||
# 连接url
|
||||
|
||||
jdbc.mysql.url=jdbc:mysql://192.168.0.110:3306/ftpdata?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&failOverReadOnly=false
|
||||
|
||||
# 用户名
|
||||
jdbc.mysql.username=root
|
||||
# 密码
|
||||
jdbc.mysql.password=root
|
||||
|
||||
#=============================================================================================================
|
||||
# Oracle 连接配置
|
||||
#=============================================================================================================
|
||||
# hui用户名
|
||||
gather-user-name=system
|
||||
# 密码
|
||||
gather-user-password=oracle
|
||||
|
||||
#
|
||||
gather-port=1521
|
||||
#
|
||||
gather-service-name=orcl
|
||||
#=============================================================================================================
|
||||
# 数据库公共配置
|
||||
#=============================================================================================================
|
||||
jdbc.initialSize=5
|
||||
jdbc.minIdle=5
|
||||
jdbc.maxIdle=20
|
||||
jdbc.maxActive=100
|
||||
jdbc.maxWait=100000
|
||||
jdbc.defaultAutoCommit=false
|
||||
jdbc.removeAbandoned=true
|
||||
jdbc.removeAbandonedTimeout=600
|
||||
jdbc.testWhileIdle=true
|
||||
jdbc.timeBetweenEvictionRunsMillis=60000
|
||||
jdbc.numTestsPerEvictionRun=20
|
||||
jdbc.minEvictableIdleTimeMillis=300000
|
||||
#==============================================================================================================
|
||||
#
|
||||
#==============================================================================================================
|
||||
table-suffix=_20152016
|
||||
extract-log-localtion=/home/web_manage/log/
|
||||
gather-tablespace-name=TS_TTSSS
|
||||
|
||||
#dbf file's path must exist
|
||||
gather-tablespace-path=/opt/oracle/app/oradata/orcl/
|
||||
# user's password must exist
|
||||
gather-table-user-password=user
|
||||
|
||||
#kuber's url must exist
|
||||
kubeMasterUrl=http://192.168.0.110:8080/
|
||||
|
||||
collect-user-name=system
|
||||
collect-password=oracle
|
||||
collect-service-name=orcl
|
||||
|
||||
gfs_control_ip=192.168.0.110
|
||||
|
||||
gfs_control_rootPassWd=root
|
||||
|
||||
HttpClientConstant_URL_IP_PORT=http://192.168.0.110:8088/jfinal/
|
||||
|
||||
#=============================================================================================================
|
||||
# 文件上传下载
|
||||
#=============================================================================================================
|
||||
file_upload_path=D:\\test\\
|
||||
|
||||
file_download_path=D:\\test\\export.xlsx
|
||||
|
||||
package_download_path=D:\\
|
||||
|
||||
package_name=zzzzz
|
||||
#=============================================================================================================
|
||||
# MySQL
|
||||
#=============================================================================================================
|
||||
# 驱动程序
|
||||
jdbc.mysql.driver=com.mysql.jdbc.Driver
|
||||
# 连接url
|
||||
|
||||
jdbc.mysql.url=jdbc:mysql://192.168.0.110:3306/ftpdata?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&failOverReadOnly=false
|
||||
|
||||
# 用户名
|
||||
jdbc.mysql.username=root
|
||||
# 密码
|
||||
jdbc.mysql.password=root
|
||||
|
||||
#=============================================================================================================
|
||||
# Oracle 连接配置
|
||||
#=============================================================================================================
|
||||
# hui用户名
|
||||
gather-user-name=system
|
||||
# 密码
|
||||
gather-user-password=oracle
|
||||
|
||||
#
|
||||
gather-port=1521
|
||||
#
|
||||
gather-service-name=orcl
|
||||
#=============================================================================================================
|
||||
# 数据库公共配置
|
||||
#=============================================================================================================
|
||||
jdbc.initialSize=5
|
||||
jdbc.minIdle=5
|
||||
jdbc.maxIdle=20
|
||||
jdbc.maxActive=100
|
||||
jdbc.maxWait=100000
|
||||
jdbc.defaultAutoCommit=false
|
||||
jdbc.removeAbandoned=true
|
||||
jdbc.removeAbandonedTimeout=600
|
||||
jdbc.testWhileIdle=true
|
||||
jdbc.timeBetweenEvictionRunsMillis=60000
|
||||
jdbc.numTestsPerEvictionRun=20
|
||||
jdbc.minEvictableIdleTimeMillis=300000
|
||||
#==============================================================================================================
|
||||
#
|
||||
#==============================================================================================================
|
||||
table-suffix=_20152016
|
||||
extract-log-localtion=/home/web_manage/log/
|
||||
gather-tablespace-name=TS_TTSSS
|
||||
|
||||
#dbf file's path must exist
|
||||
gather-tablespace-path=/opt/oracle/app/oradata/orcl/
|
||||
# user's password must exist
|
||||
gather-table-user-password=user
|
||||
|
||||
#kuber's url must exist
|
||||
kubeMasterUrl=http://192.168.0.110:8080/
|
||||
|
||||
collect-user-name=system
|
||||
collect-password=oracle
|
||||
collect-service-name=orcl
|
||||
|
||||
gfs_control_ip=192.168.0.110
|
||||
|
||||
gfs_control_rootPassWd=root
|
||||
|
||||
HttpClientConstant_URL_IP_PORT=http://192.168.0.110:8088/jfinal/
|
||||
|
||||
#=============================================================================================================
|
||||
# 文件上传下载
|
||||
#=============================================================================================================
|
||||
file_upload_path=D:\\test\\
|
||||
|
||||
file_download_path=D:\\test\\export.xlsx
|
||||
|
||||
package_download_path=D:\\
|
||||
|
||||
package_name=zzzzz
|
||||
|
||||
sql_script_path_last=D:\\sql_script_last\\
|
||||
|
||||
sql_script_path_standard=D:\\sql_script_standard\\
|
||||
|
||||
|
||||
@ -0,0 +1,478 @@
|
||||
package com.platform.entities;
|
||||
|
||||
public class DefaultDataDescription {
|
||||
|
||||
private String localNodeName = "Data";
|
||||
|
||||
private String province;
|
||||
|
||||
private String city;
|
||||
|
||||
private String county;
|
||||
|
||||
private String code;
|
||||
|
||||
private String sys_name;
|
||||
|
||||
private int sys_name_code;
|
||||
|
||||
private String contact;
|
||||
|
||||
private String phone;
|
||||
|
||||
private String district_level;
|
||||
|
||||
private String using_time;
|
||||
|
||||
private String sys_version;
|
||||
|
||||
private String sys_description;
|
||||
|
||||
private String sys_develope;
|
||||
|
||||
private String database;
|
||||
|
||||
private String database_version;
|
||||
|
||||
private String business_area_department_budget;
|
||||
|
||||
private String business_area_budget_norm;
|
||||
|
||||
private String business_area_budget_execution;
|
||||
|
||||
private String business_area_overall_budget_account;
|
||||
|
||||
private String business_area_final_settlement;
|
||||
|
||||
private String business_area_statement;
|
||||
|
||||
private String business_area_nontax_income;
|
||||
|
||||
private String business_area_wage_issue;
|
||||
|
||||
private String business_area_economic_projection;
|
||||
|
||||
private String business_area_government_debet;
|
||||
|
||||
/**
|
||||
* @return the localNodeName
|
||||
*/
|
||||
public String getLocalNodeName() {
|
||||
return localNodeName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param localNodeName the localNodeName to set
|
||||
*/
|
||||
public void setLocalNodeName(String localNodeName) {
|
||||
this.localNodeName = localNodeName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the province
|
||||
*/
|
||||
public String getProvince() {
|
||||
return province;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param province the province to set
|
||||
*/
|
||||
public void setProvince(String province) {
|
||||
this.province = province;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the city
|
||||
*/
|
||||
public String getCity() {
|
||||
return city;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param city the city to set
|
||||
*/
|
||||
public void setCity(String city) {
|
||||
this.city = city;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the county
|
||||
*/
|
||||
public String getCounty() {
|
||||
return county;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param county the county to set
|
||||
*/
|
||||
public void setCounty(String county) {
|
||||
this.county = county;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the code
|
||||
*/
|
||||
public String getCode() {
|
||||
return code;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param code the code to set
|
||||
*/
|
||||
public void setCode(String code) {
|
||||
this.code = code;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the sys_name
|
||||
*/
|
||||
public String getSys_name() {
|
||||
return sys_name;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param sys_name the sys_name to set
|
||||
*/
|
||||
public void setSys_name(String sys_name) {
|
||||
this.sys_name = sys_name;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the sys_name_code
|
||||
*/
|
||||
public int getSys_name_code() {
|
||||
return sys_name_code;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param sys_name_code the sys_name_code to set
|
||||
*/
|
||||
public void setSys_name_code(int sys_name_code) {
|
||||
this.sys_name_code = sys_name_code;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the contact
|
||||
*/
|
||||
public String getContact() {
|
||||
return contact;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param contact the contact to set
|
||||
*/
|
||||
public void setContact(String contact) {
|
||||
this.contact = contact;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the phone
|
||||
*/
|
||||
public String getPhone() {
|
||||
return phone;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param phone the phone to set
|
||||
*/
|
||||
public void setPhone(String phone) {
|
||||
this.phone = phone;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the district_level
|
||||
*/
|
||||
public String getDistrict_level() {
|
||||
return district_level;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param district_level the district_level to set
|
||||
*/
|
||||
public void setDistrict_level(String district_level) {
|
||||
this.district_level = district_level;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the using_time
|
||||
*/
|
||||
public String getUsing_time() {
|
||||
return using_time;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param using_time the using_time to set
|
||||
*/
|
||||
public void setUsing_time(String using_time) {
|
||||
this.using_time = using_time;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the sys_version
|
||||
*/
|
||||
public String getSys_version() {
|
||||
return sys_version;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param sys_version the sys_version to set
|
||||
*/
|
||||
public void setSys_version(String sys_version) {
|
||||
this.sys_version = sys_version;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the sys_description
|
||||
*/
|
||||
public String getSys_description() {
|
||||
return sys_description;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param sys_description the sys_description to set
|
||||
*/
|
||||
public void setSys_description(String sys_description) {
|
||||
this.sys_description = sys_description;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the sys_develope
|
||||
*/
|
||||
public String getSys_develope() {
|
||||
return sys_develope;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param sys_develope the sys_develope to set
|
||||
*/
|
||||
public void setSys_develope(String sys_develope) {
|
||||
this.sys_develope = sys_develope;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the database
|
||||
*/
|
||||
public String getDatabase() {
|
||||
return database;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param database the database to set
|
||||
*/
|
||||
public void setDatabase(String database) {
|
||||
this.database = database;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the database_version
|
||||
*/
|
||||
public String getDatabase_version() {
|
||||
return database_version;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param database_version the database_version to set
|
||||
*/
|
||||
public void setDatabase_version(String database_version) {
|
||||
this.database_version = database_version;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_department_budget
|
||||
*/
|
||||
public String getBusiness_area_department_budget() {
|
||||
return business_area_department_budget;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_department_budget the business_area_department_budget to set
|
||||
*/
|
||||
public void setBusiness_area_department_budget(
|
||||
String business_area_department_budget) {
|
||||
this.business_area_department_budget = business_area_department_budget;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_budget_norm
|
||||
*/
|
||||
public String getBusiness_area_budget_norm() {
|
||||
return business_area_budget_norm;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_budget_norm the business_area_budget_norm to set
|
||||
*/
|
||||
public void setBusiness_area_budget_norm(String business_area_budget_norm) {
|
||||
this.business_area_budget_norm = business_area_budget_norm;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_budget_execution
|
||||
*/
|
||||
public String getBusiness_area_budget_execution() {
|
||||
return business_area_budget_execution;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_budget_execution the business_area_budget_execution to set
|
||||
*/
|
||||
public void setBusiness_area_budget_execution(
|
||||
String business_area_budget_execution) {
|
||||
this.business_area_budget_execution = business_area_budget_execution;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_overall_budget_account
|
||||
*/
|
||||
public String getBusiness_area_overall_budget_account() {
|
||||
return business_area_overall_budget_account;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_overall_budget_account the business_area_overall_budget_account to set
|
||||
*/
|
||||
public void setBusiness_area_overall_budget_account(
|
||||
String business_area_overall_budget_account) {
|
||||
this.business_area_overall_budget_account = business_area_overall_budget_account;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_final_settlement
|
||||
*/
|
||||
public String getBusiness_area_final_settlement() {
|
||||
return business_area_final_settlement;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_final_settlement the business_area_final_settlement to set
|
||||
*/
|
||||
public void setBusiness_area_final_settlement(
|
||||
String business_area_final_settlement) {
|
||||
this.business_area_final_settlement = business_area_final_settlement;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_statement
|
||||
*/
|
||||
public String getBusiness_area_statement() {
|
||||
return business_area_statement;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_statement the business_area_statement to set
|
||||
*/
|
||||
public void setBusiness_area_statement(String business_area_statement) {
|
||||
this.business_area_statement = business_area_statement;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_nontax_income
|
||||
*/
|
||||
public String getBusiness_area_nontax_income() {
|
||||
return business_area_nontax_income;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_nontax_income the business_area_nontax_income to set
|
||||
*/
|
||||
public void setBusiness_area_nontax_income(String business_area_nontax_income) {
|
||||
this.business_area_nontax_income = business_area_nontax_income;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_wage_issue
|
||||
*/
|
||||
public String getBusiness_area_wage_issue() {
|
||||
return business_area_wage_issue;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_wage_issue the business_area_wage_issue to set
|
||||
*/
|
||||
public void setBusiness_area_wage_issue(String business_area_wage_issue) {
|
||||
this.business_area_wage_issue = business_area_wage_issue;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_economic_projection
|
||||
*/
|
||||
public String getBusiness_area_economic_projection() {
|
||||
return business_area_economic_projection;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_economic_projection the business_area_economic_projection to set
|
||||
*/
|
||||
public void setBusiness_area_economic_projection(
|
||||
String business_area_economic_projection) {
|
||||
this.business_area_economic_projection = business_area_economic_projection;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the business_area_government_debet
|
||||
*/
|
||||
public String getBusiness_area_government_debet() {
|
||||
return business_area_government_debet;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param business_area_government_debet the business_area_government_debet to set
|
||||
*/
|
||||
public void setBusiness_area_government_debet(
|
||||
String business_area_government_debet) {
|
||||
this.business_area_government_debet = business_area_government_debet;
|
||||
}
|
||||
|
||||
public void setvalue(PreDataInfo pre){
|
||||
province = "江苏省";
|
||||
|
||||
city = pre.getCityName();
|
||||
|
||||
county = pre.getDistrictName();
|
||||
|
||||
code = pre.getAreaCode();
|
||||
|
||||
sys_name = pre.getSysName();
|
||||
|
||||
sys_name_code = pre.getSysCode();
|
||||
|
||||
contact = pre.getDepartmentManager();
|
||||
|
||||
phone = pre.getManagerContacts();
|
||||
|
||||
district_level = pre.getAreaLevel();
|
||||
|
||||
using_time = pre.getBeginUseTime();
|
||||
|
||||
sys_version = pre.getDataVersion();
|
||||
|
||||
sys_description = pre.getFunctionDetails();
|
||||
|
||||
sys_develope = pre.getDeveloperFullName();
|
||||
|
||||
database = pre.getDataBaseType();
|
||||
|
||||
database_version = pre.getDataBaseVersion();
|
||||
|
||||
business_area_department_budget = pre.getDepartmentBudgetManage();
|
||||
|
||||
business_area_budget_norm = pre.getBudgetQuotaManage();
|
||||
|
||||
business_area_budget_execution = pre.getBudgetExecManage();
|
||||
|
||||
business_area_overall_budget_account = pre.getTotalBudgetAccount();
|
||||
|
||||
business_area_final_settlement = pre.getFinalAccountManage();
|
||||
|
||||
business_area_statement = pre.getReportFormManage();
|
||||
|
||||
business_area_nontax_income = pre.getNonTaxManage();
|
||||
|
||||
business_area_wage_issue = pre.getWageSystem();
|
||||
|
||||
business_area_economic_projection = pre.getAnalysisOfFinancialEconomicProsperity();
|
||||
|
||||
business_area_government_debet = pre.getGovernmentDebtManage();
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,53 @@
|
||||
package com.platform.entities;
|
||||
|
||||
public class MyFileEntity {
|
||||
|
||||
private String fileName;
|
||||
|
||||
private String lastTime;
|
||||
|
||||
private String filePath;
|
||||
|
||||
/**
|
||||
* @return the fileName
|
||||
*/
|
||||
public String getFileName() {
|
||||
return fileName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param fileName the fileName to set
|
||||
*/
|
||||
public void setFileName(String fileName) {
|
||||
this.fileName = fileName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the lastTime
|
||||
*/
|
||||
public String getLastTime() {
|
||||
return lastTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param lastTime the lastTime to set
|
||||
*/
|
||||
public void setLastTime(String lastTime) {
|
||||
this.lastTime = lastTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the filePath
|
||||
*/
|
||||
public String getFilePath() {
|
||||
return filePath;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param filePath the filePath to set
|
||||
*/
|
||||
public void setFilePath(String filePath) {
|
||||
this.filePath = filePath;
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,37 +0,0 @@
|
||||
package com.platform.entities;
|
||||
|
||||
public class PreDataInfoFull extends PreDataInfo {
|
||||
|
||||
private String sysCode;
|
||||
|
||||
private String updateTime;
|
||||
|
||||
/**
|
||||
* @return the sysCode
|
||||
*/
|
||||
public String getSysCode() {
|
||||
return sysCode;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param sysCode the sysCode to set
|
||||
*/
|
||||
public void setSysCode(String sysCode) {
|
||||
this.sysCode = sysCode;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the updateTime
|
||||
*/
|
||||
public String getUpdateTime() {
|
||||
return updateTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param updateTime the updateTime to set
|
||||
*/
|
||||
public void setUpdateTime(String updateTime) {
|
||||
this.updateTime = updateTime;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,17 @@
|
||||
package com.platform.service;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import com.platform.entities.MyFileEntity;
|
||||
|
||||
public interface IScriptMakeService {
|
||||
|
||||
public int makeCfg() throws Exception;
|
||||
|
||||
public int makeXml() throws Exception;
|
||||
|
||||
public int moveFiles(MyFileEntity file) throws Exception;
|
||||
|
||||
public List<MyFileEntity> FindFiles() throws Exception;
|
||||
|
||||
}
|
||||
@ -1,60 +1,64 @@
|
||||
package com.platform.utils;
|
||||
|
||||
import org.apache.log4j.Logger;
|
||||
|
||||
public class Configs {
|
||||
|
||||
/** 全局自定义异常--编码 */
|
||||
public static final String GLOBAL_EXP_CUSTOM = "3001001001";
|
||||
|
||||
/** 全局非自定义异常--编码 */
|
||||
public static final String GLOBAL_EXP_NOT_CUSTOM = "3001001002";
|
||||
|
||||
public static final String CONFIG_LOCALTION = "WebContent/WEB-INF/config/config.properties";
|
||||
|
||||
public static final Logger CONSOLE_LOGGER = Logger.getLogger("console");
|
||||
|
||||
public static final Logger DAILY_ROLLING_LOGGER = Logger
|
||||
.getLogger("dailyRollingFile");
|
||||
|
||||
public static final Logger DAILY_LOGGER = Logger.getLogger("railyFile");
|
||||
|
||||
public static final Logger LOGGER = Logger.getLogger(Configs.class);
|
||||
|
||||
public static String KUBE_MASTER_URL = "http://192.168.0.110:8080/"; // kubernetes集群的maser
|
||||
// URl
|
||||
|
||||
public static int ORACLE_DEFAULT_PORT = 1521; // oracle的默认端口号
|
||||
|
||||
public static String COLLECT_USER_NAME = "system"; //采集统一的登入用户名
|
||||
|
||||
public static String COLLECT_PASSWORD = "oracle"; //采集统一的登入密码
|
||||
|
||||
public static String COLLECT_SERVICE_NAME = "orcl"; //采集库统一的服务名
|
||||
|
||||
public static String GATHER_PORT ="1521"; //汇总库的端口号
|
||||
|
||||
public static String GATHER_USER_NAME = "system"; //汇总库的登入用户名
|
||||
|
||||
public static String GATHER_USER_PASSWORD = "1"; //汇总库的登入密码
|
||||
|
||||
public static String GATHER_SERVICE_NAME = "orcl"; //汇总库的服务名
|
||||
|
||||
public static String TABLE_SUFFIX = "_20152016"; //汇总库汇总表的后缀名
|
||||
|
||||
public static String EXTRACT_LOG_LOCALTION = "D:\\log"; //数据汇总日志保存位置
|
||||
|
||||
public static String GATHER_TABLESPACE_NAME=""; //表空间名
|
||||
|
||||
public static String GATHER_TABLESPACE_PATH=""; //表空间路径
|
||||
|
||||
public static String GATHER_TABLE_PASSWORD="1"; //登入密码
|
||||
|
||||
public static String FILE_UPLOAD_PATH="";
|
||||
|
||||
public static String FILE_DOWNLOAD_PATH="";
|
||||
|
||||
public static String PACKAGE_DOWNLOAD_PATH="";
|
||||
|
||||
public static String PACKAGE_NAME="";
|
||||
}
|
||||
package com.platform.utils;
|
||||
|
||||
import org.apache.log4j.Logger;
|
||||
|
||||
public class Configs {
|
||||
|
||||
/** 全局自定义异常--编码 */
|
||||
public static final String GLOBAL_EXP_CUSTOM = "3001001001";
|
||||
|
||||
/** 全局非自定义异常--编码 */
|
||||
public static final String GLOBAL_EXP_NOT_CUSTOM = "3001001002";
|
||||
|
||||
public static final String CONFIG_LOCALTION = "WebContent/WEB-INF/config/config.properties";
|
||||
|
||||
public static final Logger CONSOLE_LOGGER = Logger.getLogger("console");
|
||||
|
||||
public static final Logger DAILY_ROLLING_LOGGER = Logger
|
||||
.getLogger("dailyRollingFile");
|
||||
|
||||
public static final Logger DAILY_LOGGER = Logger.getLogger("railyFile");
|
||||
|
||||
public static final Logger LOGGER = Logger.getLogger(Configs.class);
|
||||
|
||||
public static String KUBE_MASTER_URL = "http://192.168.0.110:8080/"; // kubernetes集群的maser
|
||||
// URl
|
||||
|
||||
public static int ORACLE_DEFAULT_PORT = 1521; // oracle的默认端口号
|
||||
|
||||
public static String COLLECT_USER_NAME = "system"; //采集统一的登入用户名
|
||||
|
||||
public static String COLLECT_PASSWORD = "oracle"; //采集统一的登入密码
|
||||
|
||||
public static String COLLECT_SERVICE_NAME = "orcl"; //采集库统一的服务名
|
||||
|
||||
public static String GATHER_PORT ="1521"; //汇总库的端口号
|
||||
|
||||
public static String GATHER_USER_NAME = "system"; //汇总库的登入用户名
|
||||
|
||||
public static String GATHER_USER_PASSWORD = "1"; //汇总库的登入密码
|
||||
|
||||
public static String GATHER_SERVICE_NAME = "orcl"; //汇总库的服务名
|
||||
|
||||
public static String TABLE_SUFFIX = "_20152016"; //汇总库汇总表的后缀名
|
||||
|
||||
public static String EXTRACT_LOG_LOCALTION = "D:\\log"; //数据汇总日志保存位置
|
||||
|
||||
public static String GATHER_TABLESPACE_NAME=""; //表空间名
|
||||
|
||||
public static String GATHER_TABLESPACE_PATH=""; //表空间路径
|
||||
|
||||
public static String GATHER_TABLE_PASSWORD="1"; //登入密码
|
||||
|
||||
public static String FILE_UPLOAD_PATH="";
|
||||
|
||||
public static String FILE_DOWNLOAD_PATH="";
|
||||
|
||||
public static String PACKAGE_DOWNLOAD_PATH="";
|
||||
|
||||
public static String PACKAGE_NAME="";
|
||||
|
||||
public static String sql_script_path_last="";
|
||||
|
||||
public static String sql_script_path_standard="";
|
||||
}
|
||||
|
||||
@ -1,94 +1,95 @@
|
||||
package com.platform.utils;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Properties;
|
||||
|
||||
import javax.servlet.ServletContextEvent;
|
||||
import javax.servlet.ServletContextListener;
|
||||
|
||||
import com.platform.http.gfs.HttpClientConstant;
|
||||
|
||||
import ch.ethz.ssh2.Connection;
|
||||
|
||||
public class ConfigsLoader implements ServletContextListener {
|
||||
private static ConfigPropertyReader cReader = null;
|
||||
|
||||
@Override
|
||||
public void contextDestroyed(ServletContextEvent sEvent) {
|
||||
// TODO Auto-generated method stub
|
||||
Configs.CONSOLE_LOGGER.info("系统停止..");
|
||||
}
|
||||
|
||||
@SuppressWarnings("static-access")
|
||||
@Override
|
||||
public void contextInitialized(ServletContextEvent sEvent) {
|
||||
// TODO Auto-generated method stub
|
||||
Configs.CONSOLE_LOGGER.info("系统初始化..");
|
||||
String contextPath = sEvent.getServletContext().getRealPath("/")
|
||||
+ "WEB-INF/config/config.properties";
|
||||
this.cReader = ConfigPropertyReader.Builder(contextPath);
|
||||
init();
|
||||
new ThreadVolume("ThreadVolume-in-ConfigsLoader").start();
|
||||
}
|
||||
|
||||
public static void init() {
|
||||
Properties properties = cReader.getProperties();
|
||||
|
||||
Configs.KUBE_MASTER_URL = properties.getProperty("kubeMasterUrl");
|
||||
|
||||
Configs.COLLECT_USER_NAME = properties.getProperty("collect-user-name");
|
||||
|
||||
Configs.COLLECT_PASSWORD = properties.getProperty("collect-password");
|
||||
|
||||
Configs.COLLECT_SERVICE_NAME = properties
|
||||
.getProperty("collect-service-name");
|
||||
|
||||
Configs.GATHER_USER_NAME = properties.getProperty("gather-user-name");
|
||||
|
||||
Configs.GATHER_USER_PASSWORD = properties
|
||||
.getProperty("gather-user-password");
|
||||
|
||||
Configs.GATHER_PORT = properties.getProperty("gather-port");
|
||||
|
||||
Configs.GATHER_SERVICE_NAME = properties
|
||||
.getProperty("gather-service-name");
|
||||
|
||||
Configs.TABLE_SUFFIX = properties.getProperty("table-suffix");
|
||||
|
||||
Configs.EXTRACT_LOG_LOCALTION = properties
|
||||
.getProperty("extract-log-localtion");
|
||||
|
||||
Configs.GATHER_TABLESPACE_NAME = properties
|
||||
.getProperty("gather-tablespace-name");
|
||||
|
||||
Configs.GATHER_TABLESPACE_PATH = properties
|
||||
.getProperty("gather-tablespace-path");
|
||||
|
||||
Configs.GATHER_TABLE_PASSWORD=properties.getProperty("gather-table-user-password");
|
||||
|
||||
Configs.FILE_UPLOAD_PATH = properties.getProperty("file_upload_path");
|
||||
|
||||
Configs.FILE_DOWNLOAD_PATH = properties.getProperty("file_download_path");
|
||||
|
||||
Configs.PACKAGE_DOWNLOAD_PATH = properties.getProperty("package_download_path");
|
||||
|
||||
Configs.PACKAGE_NAME = properties.getProperty("package_name");
|
||||
|
||||
HttpClientConstant.URL_IP_PORT = properties.getProperty("HttpClientConstant_URL_IP_PORT").trim();
|
||||
|
||||
Constant.hostIp=properties.getProperty("gfs_control_ip").trim();
|
||||
Constant.rootPasswd=properties.getProperty("gfs_control_rootPassWd").trim();
|
||||
Constant.ganymedSSH = new GanymedSSH(Constant.hostIp, Constant.rootUser, Constant.rootPasswd, Constant.port);
|
||||
|
||||
}
|
||||
|
||||
public ConfigPropertyReader getcReader() {
|
||||
return cReader;
|
||||
}
|
||||
|
||||
@SuppressWarnings("static-access")
|
||||
public void setcReader(ConfigPropertyReader cReader) {
|
||||
this.cReader = cReader;
|
||||
}
|
||||
|
||||
}
|
||||
package com.platform.utils;
|
||||
|
||||
import java.util.Properties;
|
||||
|
||||
import javax.servlet.ServletContextEvent;
|
||||
import javax.servlet.ServletContextListener;
|
||||
|
||||
import com.platform.http.gfs.HttpClientConstant;
|
||||
|
||||
public class ConfigsLoader implements ServletContextListener {
|
||||
private static ConfigPropertyReader cReader = null;
|
||||
|
||||
@Override
|
||||
public void contextDestroyed(ServletContextEvent sEvent) {
|
||||
// TODO Auto-generated method stub
|
||||
Configs.CONSOLE_LOGGER.info("系统停止..");
|
||||
}
|
||||
|
||||
@SuppressWarnings("static-access")
|
||||
@Override
|
||||
public void contextInitialized(ServletContextEvent sEvent) {
|
||||
// TODO Auto-generated method stub
|
||||
Configs.CONSOLE_LOGGER.info("系统初始化..");
|
||||
String contextPath = sEvent.getServletContext().getRealPath("/")
|
||||
+ "WEB-INF/config/config.properties";
|
||||
this.cReader = ConfigPropertyReader.Builder(contextPath);
|
||||
init();
|
||||
new ThreadVolume("ThreadVolume-in-ConfigsLoader").start();
|
||||
}
|
||||
|
||||
public static void init() {
|
||||
Properties properties = cReader.getProperties();
|
||||
|
||||
Configs.KUBE_MASTER_URL = properties.getProperty("kubeMasterUrl");
|
||||
|
||||
Configs.COLLECT_USER_NAME = properties.getProperty("collect-user-name");
|
||||
|
||||
Configs.COLLECT_PASSWORD = properties.getProperty("collect-password");
|
||||
|
||||
Configs.COLLECT_SERVICE_NAME = properties
|
||||
.getProperty("collect-service-name");
|
||||
|
||||
Configs.GATHER_USER_NAME = properties.getProperty("gather-user-name");
|
||||
|
||||
Configs.GATHER_USER_PASSWORD = properties
|
||||
.getProperty("gather-user-password");
|
||||
|
||||
Configs.GATHER_PORT = properties.getProperty("gather-port");
|
||||
|
||||
Configs.GATHER_SERVICE_NAME = properties
|
||||
.getProperty("gather-service-name");
|
||||
|
||||
Configs.TABLE_SUFFIX = properties.getProperty("table-suffix");
|
||||
|
||||
Configs.EXTRACT_LOG_LOCALTION = properties
|
||||
.getProperty("extract-log-localtion");
|
||||
|
||||
Configs.GATHER_TABLESPACE_NAME = properties
|
||||
.getProperty("gather-tablespace-name");
|
||||
|
||||
Configs.GATHER_TABLESPACE_PATH = properties
|
||||
.getProperty("gather-tablespace-path");
|
||||
|
||||
Configs.GATHER_TABLE_PASSWORD=properties.getProperty("gather-table-user-password");
|
||||
|
||||
Configs.FILE_UPLOAD_PATH = properties.getProperty("file_upload_path");
|
||||
|
||||
Configs.FILE_DOWNLOAD_PATH = properties.getProperty("file_download_path");
|
||||
|
||||
Configs.PACKAGE_DOWNLOAD_PATH = properties.getProperty("package_download_path");
|
||||
|
||||
Configs.PACKAGE_NAME = properties.getProperty("package_name");
|
||||
|
||||
Configs.sql_script_path_last = properties.getProperty("sql_script_path_last");
|
||||
|
||||
Configs.sql_script_path_standard = properties.getProperty("sql_script_path_standard");
|
||||
|
||||
HttpClientConstant.URL_IP_PORT = properties.getProperty("HttpClientConstant_URL_IP_PORT").trim();
|
||||
|
||||
Constant.hostIp=properties.getProperty("gfs_control_ip").trim();
|
||||
Constant.rootPasswd=properties.getProperty("gfs_control_rootPassWd").trim();
|
||||
Constant.ganymedSSH = new GanymedSSH(Constant.hostIp, Constant.rootUser, Constant.rootPasswd, Constant.port);
|
||||
|
||||
}
|
||||
|
||||
public ConfigPropertyReader getcReader() {
|
||||
return cReader;
|
||||
}
|
||||
|
||||
@SuppressWarnings("static-access")
|
||||
public void setcReader(ConfigPropertyReader cReader) {
|
||||
this.cReader = cReader;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@ -0,0 +1,39 @@
|
||||
package com.platform.test;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
import com.platform.utils.FileOperateHelper;
|
||||
|
||||
public class FileOperationTest {
|
||||
|
||||
@Test
|
||||
public void addLastSeparator() {
|
||||
System.out.println(FileOperateHelper.addLastSeparator("D:/gitTmp3/aggregation-platform"));
|
||||
|
||||
}
|
||||
@Test
|
||||
public void removeLastSeparator() {
|
||||
System.out.println(FileOperateHelper.removeLastSeparator("D:/gitTmp3/aggregation-platform/"));
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
public void fileCreate() {
|
||||
File f = new File("D:/Create1");
|
||||
f.mkdir();
|
||||
File f2 = new File("D:/Create1/1.txt");
|
||||
try {
|
||||
f2.createNewFile();
|
||||
} catch (IOException e) {
|
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace();
|
||||
}
|
||||
File f3 = new File("D:/Create1");
|
||||
f3.mkdir();
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in new issue