RailwayTest.java
4.33 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package com.xiniunet.system.railway;
import com.google.common.base.Optional;
import com.xiniunet.framework.base.BaseTest;
import com.xiniunet.framework.security.Passport;
import com.xiniunet.framework.util.DateUtil;
import com.xiniunet.railway.domain.RequestData;
import com.xiniunet.railway.request.EscortAttendanceCreateRequest;
import com.xiniunet.railway.request.RailwayGetPositionRequest;
import com.xiniunet.railway.response.EscortAttendanceCreateResponse;
import com.xiniunet.railway.response.RailwayGetPositionResponse;
import com.xiniunet.railway.service.RailwayService;
import org.junit.Before;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.transaction.TransactionConfiguration;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
/**
* Created by Administrator on 2016/1/13.
*/
@TransactionConfiguration(defaultRollback = false)
public class RailwayTest extends BaseTest {
@Autowired
private Passport passport;
@Autowired
private RailwayService railwayService;
@Before
public void setUp() throws Exception {
passport.setTenantId(973848199737774088L);
passport.setUserId(1L);
}
@Test
public void test() throws ParseException {
//20151130 dr:1122 cr:6001 USD 100 rate:6.0
RailwayGetPositionRequest railwayGetPositionRequest = new RailwayGetPositionRequest();
List<RequestData> requestData = new ArrayList<>();
RequestData requestData1 = new RequestData();
requestData1.setDeviceType(2);
requestData1.setDeviceMac("");
requestData1.setDeviceCode("E2C56DB5-DFFB-48D2-B060-D0F5A71096E0|1722|3977");
requestData1.setRSS(126.40000152587891);
requestData.add(requestData1);
/*RequestData requestData2 = new RequestData();
requestData2.setDeviceType(2);
requestData2.setDeviceMac("");
requestData2.setDeviceCode("E2C56DB5-DFFB-48D2-B060-D0F5A71096E0|1727|1388");
requestData2.setRSS(121.4);
requestData.add(requestData2);*/
railwayGetPositionRequest.setRequestData(requestData);
railwayGetPositionRequest.setRequestTime(DateUtil.formatDate(new Date(),"yyyyMMdd HH:mm:ss"));
RailwayGetPositionResponse response = railwayService.railwayGetPosition(railwayGetPositionRequest,passport);
System.out.println("response:"+response);
}
/**
* 获取测试导入文件的流信息
*
* @return 文件流的byte数组
* @throws IOException 读写流错误
*/
public byte[] getTestFileBytes() throws IOException {
File file = new File("D:/journalsImport2.xlsx");
InputStream is = new FileInputStream(file);
Long length = file.length();
if (length > Integer.MAX_VALUE) {
// 文件太大，无法读取
throw new IOException("File is to large " + file.getName());
}
byte[] bytes = new byte[length.intValue()];
int offset = 0;
int numRead;
while (offset < bytes.length
&& (numRead = is.read(bytes, offset, bytes.length - offset)) >= 0) {
offset += numRead;
}
//如果得到的字节长度和file实际的长度不一致就可能出错了
if (offset < bytes.length) {
System.out.println("文件长度不一致");
}
is.close();
return bytes;
}
public static void main(String[] args) {
//guava
Optional<Integer> possible = Optional.of(6);
if(possible.isPresent())
{
System.out.println("possible isPresent:" + possible.isPresent());
System.out.println("possible value:" + possible.get());
}
}
@Test
public void testEscortAttendanceUp() throws ParseException {
EscortAttendanceCreateRequest escortAttendanceCreateRequest = new EscortAttendanceCreateRequest();
escortAttendanceCreateRequest.setAccount("18768541259");
escortAttendanceCreateRequest.setType("LAID_OFF");
/* EscortAttendanceCreateResponse response = railwayService.createEscortAttendance(escortAttendanceCreateRequest,passport);
System.out.println("response:"+response);*/
}
}