UDI
/
udispssync-java
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

文件下载调整

Browse Source
rabbit_dev
wj 2 years ago
parent 26a0717f20
commit 5f5f474e19
2 changed files with 81 additions and 19 deletions
Show Stats Download Patch File Download Diff File

2
api-admin/src/main/java/com/glxp/sale/admin/idc/service/IdcService.java
Unescape Escape View File

@ -48,5 +48,5 @@ public interface IdcService {
boolean batchDownloadFile(String syncIp, String[] files);
BaseResponse onceSync(String tableName, boolean isUpload);
boolean signleDownloadFile(String syncIp, String fileName);
boolean signleDownloadFile(String syncIp, String fileFullName);
}

98
api-admin/src/main/java/com/glxp/sale/admin/idc/service/impl/IdcServiceImpl.java
Unescape Escape View File

@ -1163,17 +1163,76 @@ public class IdcServiceImpl implements IdcService {
return success;
}
// @Override
// public boolean signleDownloadFile(String syncIp, String fileName) {
// String filePathSlash = filePath.substring(filePath.length() - 1).equals("/") ? "" : "/";
// if (!FileUtils.makeDirectory(filePath + filePathSlash + imagePath))
// IDCUtils.createDirectory(filePath + filePathSlash + imagePath);
// OkHttpClient client = new OkHttpClient().newBuilder()
// .build();
// ;
// MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
//
// RequestBody body = RequestBody.create(mediaType, "fileName=" + fileName);
//
// Request request = new Request.Builder()
// .url(syncIp + "/spssync/common/downloadFile")
// .post(body)
// .addHeader("Content-Type", "application/x-www-form-urlencoded")
// .build();
// int total = 0;
// try {
// Response result = client.newCall(request).execute();
// String msg = result != null ? result.message().length() > 200 ? result.message().substring(0, 200) : result.message() : "";
//
// if (result != null && result.isSuccessful() && MediaType.parse("application/force-download").equals(result.body().contentType())) {
// try (InputStream inputStream = result.body().byteStream()) {
// fileName = fileName.substring(fileName.lastIndexOf('/') + 1);
//
// FileOutputStream outputStream = new FileOutputStream(filePath + filePathSlash + imagePath + fileName);
//
// byte b[] = new byte[1024];
//
// int len = 0;
// while ((len = inputStream.read(b)) != -1) {
// total += len;
// outputStream.write(b, 0, len);
//
// }
//
// outputStream.flush();
// outputStream.close();
// if (!(total > 0)) {
// new File(filePath + filePathSlash + imagePath + fileName).delete();
// executeSql("delete from idc_file where filePath='" + fileName + "'");
// }
//
// } catch (Exception e) {
// e.printStackTrace();
// log.error("", e);
// }
// }
// if (!(total > 0)) {
// String sql = "replace idc_file (filePath,createTime,msg) values ('" + fileName + "',now(),'" + msg + "')";
// executeSql(sql);
// }
//
// } catch (IOException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// return (total > 0);
// }
@Override
public boolean signleDownloadFile(String syncIp, String fileName) {
String filePathSlash = filePath.substring(filePath.length() - 1).equals("/") ? "" : "/";
if (!FileUtils.makeDirectory(filePath + filePathSlash + imagePath))
IDCUtils.createDirectory(filePath + filePathSlash + imagePath);
public boolean signleDownloadFile(String syncIp, String fileFullName) {
OkHttpClient client = new OkHttpClient().newBuilder()
.build();
;
MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
RequestBody body = RequestBody.create(mediaType, "fileName=" + fileName);
RequestBody body = RequestBody.create(mediaType, "fileName=" + fileFullName);
Request request = new Request.Builder()
.url(syncIp + "/spssync/common/downloadFile")
@ -1183,13 +1242,17 @@ public class IdcServiceImpl implements IdcService {
int total = 0;
try {
Response result = client.newCall(request).execute();
String msg = result != null ? result.message().length() > 200 ? result.message().substring(0, 200) : result.message() : "";
String msg = result!=null ? result.message().length()>200 ? result.message().substring(0,200) : result.message() : "";
if (result != null && result.isSuccessful() && MediaType.parse("application/force-download").equals(result.body().contentType())) {
if (result!=null&&result.isSuccessful()&&MediaType.parse("application/force-download").equals(result.body().contentType())) {
try (InputStream inputStream = result.body().byteStream()) {
fileName = fileName.substring(fileName.lastIndexOf('/') + 1);
FileOutputStream outputStream = new FileOutputStream(filePath + filePathSlash + imagePath + fileName);
String path = fileFullName.substring(0,fileFullName.lastIndexOf("/"));
if(!FileUtils.makeDirectory(path))
IDCUtils.createDirectory(path);
FileOutputStream outputStream = new FileOutputStream(fileFullName);
byte b[] = new byte[1024];
@ -1202,18 +1265,18 @@ public class IdcServiceImpl implements IdcService {
outputStream.flush();
outputStream.close();
if (!(total > 0)) {
new File(filePath + filePathSlash + imagePath + fileName).delete();
executeSql("delete from idc_file where filePath='" + fileName + "'");
if(!(total>0)) {
new File(fileFullName).delete();
executeSql("delete from idc_file where filePath='"+fileFullName+"'");
}
} catch (Exception e) {
e.printStackTrace();
log.error("", e);
}
}
if (!(total > 0)) {
String sql = "replace idc_file (filePath,createTime,msg) values ('" + fileName + "',now(),'" + msg + "')";
if(!(total>0)) {
String sql = "replace idc_file (filePath,createTime,msg) values ('"+fileFullName+"',now(),'"+msg+"')";
executeSql(sql);
}
@ -1221,8 +1284,7 @@ public class IdcServiceImpl implements IdcService {
// TODO Auto-generated catch block
e.printStackTrace();
}
return (total > 0);
return (total>0);
}
/*获取转发服务地址，当前值允许单向，只使用参数upper_server_ip*/

Write Preview
Loading…
Cancel
Save