Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
X
xzxt-api-report
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
雷紫添
xzxt-api-report
Commits
5b2fb8bc
Commit
5b2fb8bc
authored
Dec 11, 2020
by
雷紫添
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
增加测试数据
parent
f2ece133
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
43 additions
and
32 deletions
+43
-32
src/main/java/com/founder/service/impl/RycjServiceImpl.java
+2
-0
src/main/java/com/founder/test.java
+1
-1
src/main/java/com/founder/util/FtpUtil.java
+40
-31
No files found.
src/main/java/com/founder/service/impl/RycjServiceImpl.java
View file @
5b2fb8bc
...
...
@@ -14,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import
org.springframework.util.StringUtils
;
import
java.io.ByteArrayInputStream
;
import
java.io.File
;
import
java.io.InputStream
;
import
java.text.SimpleDateFormat
;
import
java.util.ArrayList
;
...
...
@@ -64,6 +65,7 @@ public class RycjServiceImpl implements RycjService {
//获取zip包 进行入库
byte
[]
data
=
decoder
.
decode
(
jccj
.
getXxsb_zip
());
InputStream
in
=
new
ByteArrayInputStream
(
data
);
// File file=in.
boolean
bool
=
false
;
try
{
Rycj
yrycj
=
rycjDao
.
selectByPrimaryKey
(
jccj
.
getTaskid
());
...
...
src/main/java/com/founder/test.java
View file @
5b2fb8bc
...
...
@@ -45,7 +45,7 @@ public class test {
jccj
.
setUser_dept
(
"1400000000"
);
jccj
.
setVersion
(
"1.00"
);
//发送,httpclient 包含zip包
JSONObject
jsonResult
=
JccjServiceImpl
.
requestByPost
(
"http://
localhost
:9061/jccj/xxbs"
,
jccj
);
JSONObject
jsonResult
=
JccjServiceImpl
.
requestByPost
(
"http://
47.92.223.200
:9061/jccj/xxbs"
,
jccj
);
System
.
out
.
println
(
"返回的参数为::"
+
jsonResult
.
toJSONString
());
}
catch
(
Exception
e
)
{
...
...
src/main/java/com/founder/util/FtpUtil.java
View file @
5b2fb8bc
...
...
@@ -15,7 +15,7 @@ import java.util.Date;
* ftp上传下载工具类
* <p>Title: FtpUtil</p>
* <p>Description: </p>
* <p>Company: www.itcast.com</p>
* <p>Company: www.itcast.com</p>
* @author chent
* @date 20180806
* @version 1.0
...
...
@@ -24,21 +24,24 @@ import java.util.Date;
public
class
FtpUtil
{
/**
* Description: 向FTP服务器上传文件
* @param host FTP服务器hostname
* @param port FTP服务器端口
* @param username FTP登录账号
* @param password FTP登录密码
/**
* Description: 向FTP服务器上传文件
* @param host FTP服务器hostname
* @param port FTP服务器端口
* @param username FTP登录账号
* @param password FTP登录密码
* @param basePath FTP服务器基础目录
* @param filePath FTP服务器文件存放路径。例如分日期存放:/2015/01/01。文件的路径为basePath+filePath
* @param filename 上传到FTP服务器上的文件名
* @param input 输入流
* @return 成功返回true,否则返回false
*/
* @param filename 上传到FTP服务器上的文件名
* @param input 输入流
* @return 成功返回true,否则返回false
*/
public
static
boolean
uploadFile
(
String
host
,
int
port
,
String
username
,
String
password
,
String
basePath
,
String
filePath
,
String
filename
,
InputStream
input
)
{
boolean
result
=
false
;
String
LOCAL_CHARSET
=
"GBK"
;
String
SERVER_CHARSET
=
"ISO-8859-1"
;
FTPClient
ftp
=
new
FTPClient
();
try
{
int
reply
;
...
...
@@ -70,8 +73,14 @@ public class FtpUtil {
ftp
.
enterLocalPassiveMode
();
//设置上传文件的类型为二进制类型
ftp
.
setFileType
(
FTP
.
BINARY_FILE_TYPE
);
if
(
FTPReply
.
isPositiveCompletion
(
ftp
.
sendCommand
(
"OPTS UTF8"
,
"ON"
)))
{
LOCAL_CHARSET
=
"UTF-8"
;
}
ftp
.
setControlEncoding
(
LOCAL_CHARSET
);
//上传文件
if
(!
ftp
.
storeFile
(
filename
,
input
))
{
if
(!
ftp
.
storeFile
(
new
String
(
filename
.
getBytes
(
"GBK"
),
SERVER_CHARSET
),
input
))
{
return
result
;
}
input
.
close
();
...
...
@@ -89,18 +98,18 @@ public class FtpUtil {
}
return
result
;
}
/**
* Description: 从FTP服务器下载文件
* @param host FTP服务器hostname
* @param port FTP服务器端口
* @param username FTP登录账号
* @param password FTP登录密码
* @param remotePath FTP服务器上的相对路径
* @param fileName 要下载的文件名
* @param localPath 下载后保存到本地的路径
* @return
*/
/**
* Description: 从FTP服务器下载文件
* @param host FTP服务器hostname
* @param port FTP服务器端口
* @param username FTP登录账号
* @param password FTP登录密码
* @param remotePath FTP服务器上的相对路径
* @param fileName 要下载的文件名
* @param localPath 下载后保存到本地的路径
* @return
*/
public
static
boolean
downloadFile
(
String
host
,
int
port
,
String
username
,
String
password
,
String
remotePath
,
String
fileName
,
String
localPath
)
{
boolean
result
=
false
;
...
...
@@ -161,12 +170,12 @@ public class FtpUtil {
}
public
static
void
main
(
String
[]
args
)
{
try
{
FileInputStream
in
=
new
FileInputStream
(
new
File
(
"D:\\JC
XX-R1100000500002014070008.zip
"
));
boolean
flag
=
uploadFile
(
"47.92.129.99"
,
4546
,
"ftpuser"
,
"
p@ssw0rd[123]"
,
"/home/ftpuser/"
,
"/2016/"
,
"JCXX-R1100000500002014070008.zip
"
,
in
);
System
.
out
.
println
(
flag
);
}
catch
(
FileNotFoundException
e
)
{
e
.
printStackTrace
();
}
try
{
FileInputStream
in
=
new
FileInputStream
(
new
File
(
"D:\\JC
CJ-R1100000500002014070001.xml
"
));
boolean
flag
=
uploadFile
(
"47.92.129.99"
,
4546
,
"ftpuser"
,
"
fou3rfnder4SD1"
,
"/home/ftpuser/"
,
"/2016/"
,
"JCCJ-两岸三地R1100000500002014070001.xml
"
,
in
);
System
.
out
.
println
(
flag
);
}
catch
(
FileNotFoundException
e
)
{
e
.
printStackTrace
();
}
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment