commit
159fe1a3c1
@ -1,56 +1,72 @@
|
||||
#=============================================================================================================
|
||||
# MySQL
|
||||
#=============================================================================================================
|
||||
# 驱动程序
|
||||
jdbc.mysql.driver=com.mysql.jdbc.Driver
|
||||
# 连接url
|
||||
jdbc.mysql.url=jdbc:mysql://192.168.0.101:3306/test?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true
|
||||
# 用户名
|
||||
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
|
||||
|
||||
gather-tablespace-path=
|
||||
gather-table-user-password=
|
||||
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
|
||||
#=============================================================================================================
|
||||
# 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:\\
|
||||
|
||||
file_download_path=D:\\uuu.xls
|
||||
|
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -1,4 +1,11 @@
|
||||
#3001001
|
||||
3001001001=ThreadVolume\u7C7B\u67E5\u8BE2 volume\u5F02\u5E38
|
||||
3001001002=ThreadVolume\u7C7B\u7EBF\u7A0B\u4F11\u7720\u5F02\u5E38
|
||||
3002001002= \u62BD\u53D6\u6C47\u603B--\u7684-\u83B7\u53D6\u62BD\u53D6\u52A8\u4F5C\u5F02\u5E38
|
||||
3002001002=SQL\u6267\u884C\u9519\u8BEF
|
||||
|
||||
#3002001
|
||||
3002001001= \u62BD\u53D6\u6C47\u603B--\u7684-\u83B7\u53D6\u62BD\u53D6\u52A8\u4F5C\u5F02\u5E38
|
||||
3002001002=SQL\u6267\u884C\u9519\u8BEF
|
||||
3002001003=\u8FDE\u63A5\u6C47\u603B-\u521B\u5EFAoracle\u8FDE\u63A5\u5931\u8D25
|
||||
|
||||
#3002002
|
||||
3002002001=MySQL\u9519\u8BEF
|
||||
Binary file not shown.
@ -0,0 +1,140 @@
|
||||
package com.platform.controller;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.io.RandomAccessFile;
|
||||
|
||||
import javax.servlet.ServletException;
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
|
||||
import org.apache.commons.io.FileUtils;
|
||||
import org.springframework.http.HttpHeaders;
|
||||
import org.springframework.http.HttpStatus;
|
||||
import org.springframework.http.MediaType;
|
||||
import org.springframework.http.ResponseEntity;
|
||||
import org.springframework.stereotype.Controller;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RequestMethod;
|
||||
|
||||
import com.base.BaseController;
|
||||
import com.platform.entities.ResumableInfo;
|
||||
import com.platform.entities.ResumableInfoStorage;
|
||||
import com.platform.utils.Configs;
|
||||
import com.platform.utils.HttpUtils;
|
||||
|
||||
@Controller
|
||||
@RequestMapping("/fileOperation")
|
||||
public class ExcelController extends BaseController {
|
||||
|
||||
// 文件上传处理函数
|
||||
@RequestMapping(value = "/file/upload", method = RequestMethod.POST)
|
||||
public void upload(HttpServletRequest request, HttpServletResponse response)
|
||||
throws ServletException, IOException {
|
||||
|
||||
int resumableChunkNumber = HttpUtils.toInt(
|
||||
request.getParameter("resumableChunkNumber"), -1);
|
||||
ResumableInfo info = getResumableInfo(request);
|
||||
|
||||
String requestMethod = request.getMethod();
|
||||
// 处理GET请求
|
||||
if ("GET".equals(requestMethod)) {
|
||||
if (info.uploadedChunks
|
||||
.contains(new ResumableInfo.ResumableChunkNumber(
|
||||
resumableChunkNumber))) {
|
||||
response.getWriter().print("Uploaded."); // This Chunk has been
|
||||
// Uploaded.
|
||||
} else {
|
||||
response.setStatus(HttpServletResponse.SC_NOT_FOUND);
|
||||
}
|
||||
} else if ("POST".equals(requestMethod)) { // 处理POST请求
|
||||
RandomAccessFile raf = new RandomAccessFile(info.resumableFilePath,
|
||||
"rw");
|
||||
// Seek to position
|
||||
raf.seek((resumableChunkNumber - 1)
|
||||
* (long) info.resumableChunkSize);
|
||||
|
||||
// Save to file
|
||||
InputStream is = request.getInputStream();
|
||||
long readed = 0;
|
||||
long content_length = request.getContentLength();
|
||||
byte[] bytes = new byte[1024 * 100];
|
||||
while (readed < content_length) {
|
||||
int r = is.read(bytes);
|
||||
if (r < 0) {
|
||||
break;
|
||||
}
|
||||
raf.write(bytes, 0, r);
|
||||
readed += r;
|
||||
}
|
||||
raf.close();
|
||||
|
||||
// Mark as uploaded.
|
||||
info.uploadedChunks.add(new ResumableInfo.ResumableChunkNumber(
|
||||
resumableChunkNumber));
|
||||
if (info.checkIfUploadFinished()) { // Check if all chunks uploaded,
|
||||
// and change filename
|
||||
ResumableInfoStorage.getInstance().remove(info);
|
||||
response.getWriter().print("All finished.");
|
||||
} else {
|
||||
response.getWriter().print("Upload");
|
||||
}
|
||||
} else { // 不处理非GET/POST请求
|
||||
throw new IllegalStateException("只接受 POST或GET请求");
|
||||
}
|
||||
}
|
||||
|
||||
// 文件下载处理函数
|
||||
@RequestMapping(value = "/file/download")
|
||||
public ResponseEntity<byte[]> download(HttpServletRequest request,
|
||||
HttpServletResponse response) throws IOException {
|
||||
File file = new File(Configs.FILE_DOWNLOAD_PATH);
|
||||
System.out.println(Configs.FILE_DOWNLOAD_PATH);
|
||||
if (file.exists()) {
|
||||
HttpHeaders headers = new HttpHeaders();
|
||||
String fileName = new String(file.getName().getBytes("UTF-8"),
|
||||
"iso-8859-1");// 为了解决中文名称乱码问题
|
||||
headers.setContentDispositionFormData("attachment", fileName);
|
||||
headers.setContentDispositionFormData("attachment", fileName);
|
||||
headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
|
||||
return new ResponseEntity<byte[]>(
|
||||
FileUtils.readFileToByteArray(file), headers,
|
||||
HttpStatus.CREATED);
|
||||
} else {
|
||||
response.setStatus(500);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
// 文件上传处理函数
|
||||
private ResumableInfo getResumableInfo(HttpServletRequest request)
|
||||
throws ServletException {
|
||||
String base_dir = Configs.FILE_UPLOAD_PATH;
|
||||
|
||||
int resumableChunkSize = HttpUtils.toInt(
|
||||
request.getParameter("resumableChunkSize"), -1);
|
||||
long resumableTotalSize = HttpUtils.toLong(
|
||||
request.getParameter("resumableTotalSize"), -1);
|
||||
String resumableIdentifier = request
|
||||
.getParameter("resumableIdentifier");
|
||||
String resumableFilename = request.getParameter("resumableFilename");
|
||||
String resumableRelativePath = request
|
||||
.getParameter("resumableRelativePath");
|
||||
// Here we add a ".temp" to every upload file to indicate NON-FINISHED
|
||||
new File(base_dir).mkdir();
|
||||
String resumableFilePath = new File(base_dir, resumableFilename)
|
||||
.getAbsolutePath() + ".temp";
|
||||
|
||||
ResumableInfoStorage storage = ResumableInfoStorage.getInstance();
|
||||
|
||||
ResumableInfo info = storage.get(resumableChunkSize,
|
||||
resumableTotalSize, resumableIdentifier, resumableFilename,
|
||||
resumableRelativePath, resumableFilePath);
|
||||
if (!info.vaild()) {
|
||||
storage.remove(info);
|
||||
throw new ServletException("Invalid request params.");
|
||||
}
|
||||
return info;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,431 @@
|
||||
package com.platform.entities;
|
||||
|
||||
public class PreDataInfo {
|
||||
|
||||
/** 是否更新 */
|
||||
private String isupdate = "-";
|
||||
|
||||
/** 是否采集 */
|
||||
private String iscollect = "否";
|
||||
|
||||
/** 市名称 */
|
||||
private String cityName;
|
||||
|
||||
/** 县区名称 */
|
||||
private String districtName;
|
||||
|
||||
/** 地区编码 */
|
||||
private String areaCode;
|
||||
|
||||
/** 地区级别 */
|
||||
private String areaLevel;
|
||||
|
||||
/** 系统名称 */
|
||||
private String sysName;
|
||||
|
||||
/** 系统版本信息 */
|
||||
private String dataVersion;
|
||||
|
||||
/** 投入使用时间 */
|
||||
private String beginUseTime;
|
||||
|
||||
/** 系统数据功能描述 */
|
||||
private String functionDetails;
|
||||
|
||||
/** 管理部门联系人 */
|
||||
private String departmentConcactor;
|
||||
|
||||
/** 联系方式 */
|
||||
private String concacts;
|
||||
|
||||
/** 信息系统开发商全称 */
|
||||
private String developerFullName;
|
||||
|
||||
/** 数据库类型 */
|
||||
private String dataBaseType;
|
||||
|
||||
/** 数据库版本 */
|
||||
private String dataBaseVersion;
|
||||
|
||||
/** 部门预算管理 */
|
||||
private String departmentBudgetManage;
|
||||
|
||||
/** 预算指标管理 */
|
||||
private String budgetQuotaManage;
|
||||
|
||||
/** 预算执行管理 */
|
||||
private String budgetExecManage;
|
||||
|
||||
/** 总预算会计 */
|
||||
private String totalBudgetAccount;
|
||||
|
||||
/** 决算管理 */
|
||||
private String finalAccountManage;
|
||||
|
||||
/** 报表管理 */
|
||||
private String reportFormManage;
|
||||
|
||||
/** 非税收入管理 */
|
||||
private String nonTaxManage;
|
||||
|
||||
/** 工作统发系统 */
|
||||
private String wageSystem;
|
||||
|
||||
/** 财政经济景气预测与分析 */
|
||||
private String analysisOfFinancialEconomicProsperity;
|
||||
|
||||
/** 政府性债务管理 */
|
||||
private String governmentDebtManage;
|
||||
|
||||
/**
|
||||
* @return the isupdate
|
||||
*/
|
||||
public String getIsupdate() {
|
||||
return isupdate;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param isupdate the isupdate to set
|
||||
*/
|
||||
public void setIsupdate(String isupdate) {
|
||||
this.isupdate = isupdate;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the iscollect
|
||||
*/
|
||||
public String getIscollect() {
|
||||
return iscollect;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param iscollect the iscollect to set
|
||||
*/
|
||||
public void setIscollect(String iscollect) {
|
||||
this.iscollect = iscollect;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the cityName
|
||||
*/
|
||||
public String getCityName() {
|
||||
return cityName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param cityName the cityName to set
|
||||
*/
|
||||
public void setCityName(String cityName) {
|
||||
this.cityName = cityName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the districtName
|
||||
*/
|
||||
public String getDistrictName() {
|
||||
return districtName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param districtName the districtName to set
|
||||
*/
|
||||
public void setDistrictName(String districtName) {
|
||||
this.districtName = districtName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the areaCode
|
||||
*/
|
||||
public String getAreaCode() {
|
||||
return areaCode;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param areaCode the areaCode to set
|
||||
*/
|
||||
public void setAreaCode(String areaCode) {
|
||||
this.areaCode = areaCode;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the areaLevel
|
||||
*/
|
||||
public String getAreaLevel() {
|
||||
return areaLevel;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param areaLevel the areaLevel to set
|
||||
*/
|
||||
public void setAreaLevel(String areaLevel) {
|
||||
this.areaLevel = areaLevel;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the sysName
|
||||
*/
|
||||
public String getSysName() {
|
||||
return sysName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param sysName the sysName to set
|
||||
*/
|
||||
public void setSysName(String sysName) {
|
||||
this.sysName = sysName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the dataVersion
|
||||
*/
|
||||
public String getDataVersion() {
|
||||
return dataVersion;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param dataVersion the dataVersion to set
|
||||
*/
|
||||
public void setDataVersion(String dataVersion) {
|
||||
this.dataVersion = dataVersion;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the beginUseTime
|
||||
*/
|
||||
public String getBeginUseTime() {
|
||||
return beginUseTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param beginUseTime the beginUseTime to set
|
||||
*/
|
||||
public void setBeginUseTime(String beginUseTime) {
|
||||
this.beginUseTime = beginUseTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the functionDetails
|
||||
*/
|
||||
public String getFunctionDetails() {
|
||||
return functionDetails;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param functionDetails the functionDetails to set
|
||||
*/
|
||||
public void setFunctionDetails(String functionDetails) {
|
||||
this.functionDetails = functionDetails;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the departmentConcactor
|
||||
*/
|
||||
public String getDepartmentConcactor() {
|
||||
return departmentConcactor;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param departmentConcactor the departmentConcactor to set
|
||||
*/
|
||||
public void setDepartmentConcactor(String departmentConcactor) {
|
||||
this.departmentConcactor = departmentConcactor;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the concacts
|
||||
*/
|
||||
public String getConcacts() {
|
||||
return concacts;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param concacts the concacts to set
|
||||
*/
|
||||
public void setConcacts(String concacts) {
|
||||
this.concacts = concacts;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the developerFullName
|
||||
*/
|
||||
public String getDeveloperFullName() {
|
||||
return developerFullName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param developerFullName the developerFullName to set
|
||||
*/
|
||||
public void setDeveloperFullName(String developerFullName) {
|
||||
this.developerFullName = developerFullName;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the dataBaseType
|
||||
*/
|
||||
public String getDataBaseType() {
|
||||
return dataBaseType;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param dataBaseType the dataBaseType to set
|
||||
*/
|
||||
public void setDataBaseType(String dataBaseType) {
|
||||
this.dataBaseType = dataBaseType;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the dataBaseVersion
|
||||
*/
|
||||
public String getDataBaseVersion() {
|
||||
return dataBaseVersion;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param dataBaseVersion the dataBaseVersion to set
|
||||
*/
|
||||
public void setDataBaseVersion(String dataBaseVersion) {
|
||||
this.dataBaseVersion = dataBaseVersion;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the departmentBudgetManage
|
||||
*/
|
||||
public String getDepartmentBudgetManage() {
|
||||
return departmentBudgetManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param departmentBudgetManage the departmentBudgetManage to set
|
||||
*/
|
||||
public void setDepartmentBudgetManage(String departmentBudgetManage) {
|
||||
this.departmentBudgetManage = departmentBudgetManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the budgetQuotaManage
|
||||
*/
|
||||
public String getBudgetQuotaManage() {
|
||||
return budgetQuotaManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param budgetQuotaManage the budgetQuotaManage to set
|
||||
*/
|
||||
public void setBudgetQuotaManage(String budgetQuotaManage) {
|
||||
this.budgetQuotaManage = budgetQuotaManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the budgetExecManage
|
||||
*/
|
||||
public String getBudgetExecManage() {
|
||||
return budgetExecManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param budgetExecManage the budgetExecManage to set
|
||||
*/
|
||||
public void setBudgetExecManage(String budgetExecManage) {
|
||||
this.budgetExecManage = budgetExecManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the totalBudgetAccount
|
||||
*/
|
||||
public String getTotalBudgetAccount() {
|
||||
return totalBudgetAccount;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param totalBudgetAccount the totalBudgetAccount to set
|
||||
*/
|
||||
public void setTotalBudgetAccount(String totalBudgetAccount) {
|
||||
this.totalBudgetAccount = totalBudgetAccount;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the finalAccountManage
|
||||
*/
|
||||
public String getFinalAccountManage() {
|
||||
return finalAccountManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param finalAccountManage the finalAccountManage to set
|
||||
*/
|
||||
public void setFinalAccountManage(String finalAccountManage) {
|
||||
this.finalAccountManage = finalAccountManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the reportFormManage
|
||||
*/
|
||||
public String getReportFormManage() {
|
||||
return reportFormManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param reportFormManage the reportFormManage to set
|
||||
*/
|
||||
public void setReportFormManage(String reportFormManage) {
|
||||
this.reportFormManage = reportFormManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the nonTaxManage
|
||||
*/
|
||||
public String getNonTaxManage() {
|
||||
return nonTaxManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param nonTaxManage the nonTaxManage to set
|
||||
*/
|
||||
public void setNonTaxManage(String nonTaxManage) {
|
||||
this.nonTaxManage = nonTaxManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the wageSystem
|
||||
*/
|
||||
public String getWageSystem() {
|
||||
return wageSystem;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param wageSystem the wageSystem to set
|
||||
*/
|
||||
public void setWageSystem(String wageSystem) {
|
||||
this.wageSystem = wageSystem;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the analysisOfFinancialEconomicProsperity
|
||||
*/
|
||||
public String getAnalysisOfFinancialEconomicProsperity() {
|
||||
return analysisOfFinancialEconomicProsperity;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param analysisOfFinancialEconomicProsperity the analysisOfFinancialEconomicProsperity to set
|
||||
*/
|
||||
public void setAnalysisOfFinancialEconomicProsperity(
|
||||
String analysisOfFinancialEconomicProsperity) {
|
||||
this.analysisOfFinancialEconomicProsperity = analysisOfFinancialEconomicProsperity;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the governmentDebtManage
|
||||
*/
|
||||
public String getGovernmentDebtManage() {
|
||||
return governmentDebtManage;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param governmentDebtManage the governmentDebtManage to set
|
||||
*/
|
||||
public void setGovernmentDebtManage(String governmentDebtManage) {
|
||||
this.governmentDebtManage = governmentDebtManage;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,68 @@
|
||||
package com.platform.entities;
|
||||
|
||||
import java.io.File;
|
||||
import java.util.HashSet;
|
||||
|
||||
import com.platform.utils.HttpUtils;
|
||||
|
||||
public class ResumableInfo {
|
||||
|
||||
public int resumableChunkSize;
|
||||
public long resumableTotalSize;
|
||||
public String resumableIdentifier;
|
||||
public String resumableFilename;
|
||||
public String resumableRelativePath;
|
||||
|
||||
public static class ResumableChunkNumber {
|
||||
public ResumableChunkNumber(int number) {
|
||||
this.number = number;
|
||||
}
|
||||
|
||||
public int number;
|
||||
|
||||
@Override
|
||||
public boolean equals(Object obj) {
|
||||
return obj instanceof ResumableChunkNumber ? ((ResumableChunkNumber) obj).number == this.number
|
||||
: false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int hashCode() {
|
||||
return number;
|
||||
}
|
||||
}
|
||||
|
||||
// Chunks uploaded
|
||||
public HashSet<ResumableChunkNumber> uploadedChunks = new HashSet<ResumableChunkNumber>();
|
||||
|
||||
public String resumableFilePath;
|
||||
|
||||
public boolean vaild() {
|
||||
if (resumableChunkSize < 0 || resumableTotalSize < 0
|
||||
|| HttpUtils.isEmpty(resumableIdentifier)
|
||||
|| HttpUtils.isEmpty(resumableFilename)
|
||||
|| HttpUtils.isEmpty(resumableRelativePath)) {
|
||||
return false;
|
||||
} else {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
public boolean checkIfUploadFinished() {
|
||||
// check if upload finished
|
||||
int count = (int) Math.ceil(((double) resumableTotalSize)
|
||||
/ ((double) resumableChunkSize));
|
||||
for (int i = 1; i < count; i++) {
|
||||
if (!uploadedChunks.contains(new ResumableChunkNumber(i))) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
// Upload finished, change filename.
|
||||
File file = new File(resumableFilePath);
|
||||
String new_path = file.getAbsolutePath().substring(0,
|
||||
file.getAbsolutePath().length() - ".temp".length());
|
||||
file.renameTo(new File(new_path));
|
||||
return true;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,64 @@
|
||||
package com.platform.entities;
|
||||
|
||||
import java.util.HashMap;
|
||||
|
||||
public class ResumableInfoStorage {
|
||||
|
||||
// Single instance
|
||||
private ResumableInfoStorage() {
|
||||
}
|
||||
|
||||
private static ResumableInfoStorage sInstance;
|
||||
|
||||
public static synchronized ResumableInfoStorage getInstance() {
|
||||
if (sInstance == null) {
|
||||
sInstance = new ResumableInfoStorage();
|
||||
}
|
||||
return sInstance;
|
||||
}
|
||||
|
||||
// resumableIdentifier -- ResumableInfo
|
||||
private HashMap<String, ResumableInfo> mMap = new HashMap<String, ResumableInfo>();
|
||||
|
||||
/**
|
||||
* Get ResumableInfo from mMap or Create a new one.
|
||||
*
|
||||
* @param resumableChunkSize
|
||||
* @param resumableTotalSize
|
||||
* @param resumableIdentifier
|
||||
* @param resumableFilename
|
||||
* @param resumableRelativePath
|
||||
* @param resumableFilePath
|
||||
* @return
|
||||
*/
|
||||
public synchronized ResumableInfo get(int resumableChunkSize,
|
||||
long resumableTotalSize, String resumableIdentifier,
|
||||
String resumableFilename, String resumableRelativePath,
|
||||
String resumableFilePath) {
|
||||
|
||||
ResumableInfo info = mMap.get(resumableIdentifier);
|
||||
|
||||
if (info == null) {
|
||||
info = new ResumableInfo();
|
||||
|
||||
info.resumableChunkSize = resumableChunkSize;
|
||||
info.resumableTotalSize = resumableTotalSize;
|
||||
info.resumableIdentifier = resumableIdentifier;
|
||||
info.resumableFilename = resumableFilename;
|
||||
info.resumableRelativePath = resumableRelativePath;
|
||||
info.resumableFilePath = resumableFilePath;
|
||||
|
||||
mMap.put(resumableIdentifier, info);
|
||||
}
|
||||
return info;
|
||||
}
|
||||
|
||||
/**
|
||||
* ɾ³ýResumableInfo
|
||||
*
|
||||
* @param info
|
||||
*/
|
||||
public void remove(ResumableInfo info) {
|
||||
mMap.remove(info.resumableIdentifier);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,7 @@
|
||||
package com.platform.http.gfs;
|
||||
|
||||
public class HttpClientConstant {
|
||||
|
||||
public static String URL_IP_PORT = "http://192.168.0.110:8088/jfinal/";
|
||||
|
||||
}
|
||||
@ -0,0 +1,85 @@
|
||||
package com.platform.http.gfs;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import net.sf.json.JSONObject;
|
||||
|
||||
import org.apache.http.HttpEntity;
|
||||
import org.apache.http.HttpResponse;
|
||||
import org.apache.http.NameValuePair;
|
||||
import org.apache.http.client.HttpClient;
|
||||
import org.apache.http.client.entity.UrlEncodedFormEntity;
|
||||
import org.apache.http.client.methods.HttpPost;
|
||||
import org.apache.http.impl.client.DefaultHttpClient;
|
||||
import org.apache.http.message.BasicNameValuePair;
|
||||
import org.apache.http.util.EntityUtils;
|
||||
|
||||
import com.platform.utils.Bean2MapUtils;
|
||||
|
||||
public class HttpUtils {
|
||||
|
||||
public String sendPost(String subUrl, Object data) {
|
||||
String resultStr = null;
|
||||
HttpClient client = new DefaultHttpClient();
|
||||
HttpPost post = new HttpPost(HttpClientConstant.URL_IP_PORT + subUrl);
|
||||
try {
|
||||
// 传参
|
||||
List<NameValuePair> parameters = new ArrayList<NameValuePair>();
|
||||
|
||||
if (null != data) {
|
||||
// 转 map
|
||||
Map<String, Object> map = Bean2MapUtils.convertBean(data);
|
||||
// 转json
|
||||
JSONObject jsondata = JSONObject.fromObject(map);
|
||||
// 封装数据
|
||||
parameters.add(new BasicNameValuePair("jsondata", jsondata
|
||||
.toString()));
|
||||
parameters.add(new BasicNameValuePair("type", data.getClass()
|
||||
.getName()));
|
||||
// 传参 放入 url的 form中
|
||||
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(parameters,
|
||||
"UTF-8");
|
||||
post.setEntity(entity);
|
||||
}
|
||||
|
||||
// 发送
|
||||
HttpResponse respone = client.execute(post);
|
||||
HttpEntity result = respone.getEntity();
|
||||
if (null != result) {
|
||||
resultStr = EntityUtils.toString(result);
|
||||
}
|
||||
// resultMap = Bean2MapUtils.convertBean(result);
|
||||
} catch (Exception e) {
|
||||
System.out.println(e);
|
||||
}
|
||||
return resultStr;
|
||||
}
|
||||
|
||||
// public static void main(String[] args) {
|
||||
// Date d = new Date();
|
||||
// HttpUtils ht = new HttpUtils();
|
||||
// BaseForm1 bas = new BaseForm1();
|
||||
// bas.setId("12");
|
||||
// bas.setName("n12");
|
||||
// String rest = ht.sendPost("gfs/getAllvolume", null);
|
||||
// if (null != rest) {
|
||||
// System.out.println(rest);
|
||||
// JSONArray jsondata = JSONArray.fromObject(rest);
|
||||
// ArrayList<VolumeEntity> fo = (ArrayList<VolumeEntity>) JSONArray.toCollection(jsondata, VolumeEntity.class);
|
||||
// System.err.println(fo);
|
||||
// try {
|
||||
// System.err.println(Bean2MapUtils.convertBean(fo));
|
||||
// } catch (IllegalAccessException | InvocationTargetException
|
||||
// | IntrospectionException e) {
|
||||
// // TODO Auto-generated catch block
|
||||
// e.printStackTrace();
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// Date r = new Date();
|
||||
// System.err.println(r.getTime() - d.getTime());
|
||||
// }
|
||||
|
||||
}
|
||||
@ -0,0 +1,36 @@
|
||||
package com.platform.service.thread;
|
||||
|
||||
import com.base.Custom4exception;
|
||||
import com.base.CustomException;
|
||||
import com.platform.entities.oracleForm;
|
||||
import com.platform.service.IOracleExtractService;
|
||||
|
||||
/** oracle汇总库抽取
|
||||
* @author chen
|
||||
*
|
||||
*/
|
||||
public class ThreadExtractOracle extends Thread {
|
||||
|
||||
private IOracleExtractService OracleExtract;
|
||||
|
||||
private oracleForm form;
|
||||
|
||||
/** oracle汇总库抽取
|
||||
* @param form
|
||||
* @param OracleExtract
|
||||
*/
|
||||
public ThreadExtractOracle(oracleForm form, IOracleExtractService OracleExtract) {
|
||||
this.OracleExtract = OracleExtract;
|
||||
this.form = form;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
try {
|
||||
OracleExtract.extractOracle(form.getName(), form.getInneed(),form.getTarget());
|
||||
} catch (Exception e) {
|
||||
new CustomException(Custom4exception.threadVolume_Oracle_Except,e,form,OracleExtract);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,55 @@
|
||||
package com.platform.service.thread;
|
||||
|
||||
import com.base.Custom4exception;
|
||||
import com.base.CustomException;
|
||||
import com.platform.entities.oracleForm;
|
||||
import com.platform.service.IOracleExtractService;
|
||||
|
||||
/** 测试是否能获得oracle连接
|
||||
* @author chen
|
||||
*
|
||||
*/
|
||||
public class ThreadGainOracleConnect extends Thread {
|
||||
|
||||
private boolean isConnect = false;
|
||||
|
||||
private boolean isExcept = false;
|
||||
|
||||
private IOracleExtractService OracleExtract;
|
||||
|
||||
private oracleForm form;
|
||||
|
||||
/** 测试是否能获得oracle连接
|
||||
* @param form
|
||||
* @param OracleExtract
|
||||
*/
|
||||
public ThreadGainOracleConnect(oracleForm form, IOracleExtractService OracleExtract) {
|
||||
this.form = form;
|
||||
this.OracleExtract= OracleExtract;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
try {
|
||||
this.isConnect = OracleExtract.isConnectTotalOracle(form.getTarget());
|
||||
} catch (Exception e) {
|
||||
isExcept = true;
|
||||
new CustomException(Custom4exception.connect_Oracle_Except,e,form,OracleExtract);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the isConnect true:能连接
|
||||
*/
|
||||
public boolean isConnect() {
|
||||
return isConnect;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the isExcept
|
||||
*/
|
||||
public boolean isExcept() {
|
||||
return isExcept;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,44 @@
|
||||
package com.platform.utils;
|
||||
|
||||
public class HttpUtils {
|
||||
|
||||
public static boolean isEmpty(String value) {
|
||||
return value == null || "".equals(value);
|
||||
}
|
||||
/**
|
||||
* Convert String to long
|
||||
* @param value
|
||||
* @param def default value
|
||||
* @return
|
||||
*/
|
||||
public static long toLong(String value, long def) {
|
||||
if (isEmpty(value)) {
|
||||
return def;
|
||||
}
|
||||
|
||||
try {
|
||||
return Long.valueOf(value);
|
||||
} catch (NumberFormatException e) {
|
||||
e.printStackTrace();
|
||||
return def;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Convert String to int
|
||||
* @param value
|
||||
* @param def default value
|
||||
* @return
|
||||
*/
|
||||
public static int toInt(String value, int def) {
|
||||
if (isEmpty(value)) {
|
||||
return def;
|
||||
}
|
||||
try {
|
||||
return Integer.valueOf(value);
|
||||
} catch (NumberFormatException e) {
|
||||
e.printStackTrace();
|
||||
return def;
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue