YgcBasicDataServiceImpl.java
11.2 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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
package com.bsth.service.traffic.impl;
import com.bsth.service.impl.TrafficManageServiceImpl;
import com.bsth.service.traffic.YgcBasicDataService;
import com.bsth.util.db.DBUtils_oldSystem;
import org.apache.axiom.om.*;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
import org.apache.commons.codec.digest.DigestUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.w3c.dom.Document;
import org.w3c.dom.NodeList;
import javax.activation.DataHandler;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import java.io.*;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.zip.ZipEntry;
import java.util.zip.ZipFile;
import java.util.zip.ZipInputStream;
/**
* 运管处基础数据操作类
* Created by zq on 2017/6/15.
*/
@Service
public class YgcBasicDataServiceImpl implements YgcBasicDataService{
Logger logger = LoggerFactory.getLogger(TrafficManageServiceImpl.class);
@Autowired
JdbcTemplate jdbcTemplate;
private static String IP = "218.242.195.76:9091";
private static String targetEndpoint = "http://" + IP +"/ygc.TransManager.Basicdown?wsdl";
private static String namespace = "http://service.shygc.com";
private static String userName = "admin";
private static String passWord = "000000";
private static EndpointReference targetEPR;
{
try {
targetEPR = new EndpointReference(targetEndpoint);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 更新运管处基础数据
*/
public void updateYgcBasicData(){
String saveFile = "ygcBasicData.zip";
String flag = "failure";
try {
// 调用接口下载基础数据
if(download(userName, DigestUtils.md5Hex(passWord), saveFile)){
// 读取基础数据zip
StringBuffer sb = readZipFile(saveFile);
// 解析xml
List<HashMap<String,String>> result = parseXml(sb);
// 插入数据库
if(result != null && result.size() > 0){
insertRecord(result);
}
}
flag = "success";
}catch (Exception e){
e.printStackTrace();
}
finally {
// 删除文件
File fill = new File(saveFile);
logger.info("updateYgcBasicData:"+fill.getAbsolutePath());
logger.info("updateYgcBasicData:"+flag);
if(fill.exists()){
fill.delete();
}
}
}
/**
* 下载基础数据，并生成rar文件
* @param userName
* @param password
* @param saveFile
* @return
*/
private boolean download(String userName, String password, String saveFile)
{
try
{
OMElement data = buildDownloadEnvelope(userName, password);
ServiceClient sender = new ServiceClient();
Options options = sender.getOptions();
options.setProperty("SO_TIMEOUT", Integer.valueOf(1800000));
options.setTo(targetEPR);
sender.setOptions(options);
System.out.println("The data in method download: " + data);
data.build();
OMElement ome = sender.sendReceive(data);
OMText binaryNode = (OMText)ome.getFirstOMChild();
binaryNode.setOptimize(true);
DataHandler actualDH = (DataHandler)binaryNode.getDataHandler();
FileOutputStream imageOutStream = new FileOutputStream(saveFile);
InputStream is = actualDH.getInputStream();
int read ;
byte[] buffer = new byte[1024];
while ((read = is.read(buffer)) != -1) {
imageOutStream.write(buffer, 0, read);
}
return true;
} catch (Exception e) {
e.printStackTrace();
}return false;
}
/**
* 构建webservice接口参数
* @param userName
* @param password
* @return
*/
private OMElement buildDownloadEnvelope(String userName, String password)
{
OMFactory fac = OMAbstractFactory.getOMFactory();
OMNamespace omNs = fac.createOMNamespace(namespace,
"ser");
OMElement data = fac.createOMElement("downloadAllDataFile", omNs);
OMElement _userName = fac.createOMElement("userName", omNs);
_userName.setText(userName);
OMElement _passWord = fac.createOMElement("passWord", omNs);
_passWord.setText(String.valueOf(password));
data.addChild(_userName);
data.addChild(_passWord);
OMElement soap = fac.createOMElement("downloadAllDataFile", omNs);
soap.addChild(data);
return soap;
}
/**
* 读取zip文件的内容
* @param file
* @return
* @throws Exception
*/
public StringBuffer readZipFile(String file) throws Exception {
ZipFile zf = new ZipFile(file);
InputStream in = new BufferedInputStream(new FileInputStream(file));
ZipInputStream zin = new ZipInputStream(in);
ZipEntry ze;
StringBuffer sb = new StringBuffer();
while ((ze = zin.getNextEntry()) != null) {
System.out.print(ze);
if (ze.isDirectory()) {
} else {
System.err.println("file - " + ze.getName() + " : "
+ ze.getSize() + " bytes");
long size = ze.getSize();
if (size > 0) {
BufferedReader br = new BufferedReader(
new InputStreamReader(zf.getInputStream(ze),"GBK"));
String line;
boolean addFlag = false;
while ((line = br.readLine()) != null) {
if(line.indexOf("BusLineList") != -1){
addFlag = true;
}
if(addFlag){
sb.append(line);
}
if(line.indexOf("/BusLineList") != -1){
break;
}
}
br.close();
}
}
}
zin.closeEntry();
return sb;
}
/**
* 解析xml
* @param sb
*/
private List<HashMap<String,String>> parseXml(StringBuffer sb){
List<HashMap<String,String>> list = new ArrayList<>();
HashMap<String,String> map;
try {
DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
DocumentBuilder builder = factory.newDocumentBuilder();
Document doc = builder.parse(new ByteArrayInputStream(sb.toString().getBytes()));
NodeList nl = doc.getElementsByTagName("BusLine");
String lineName; //线路名称
String lineId; // 线路ID
String abbreviation ; // 公司名称
String ddfs ; // 调度方式
String lineStandardCode; // 上海市线路编码
String parentUnitName ; // 总公司
for (int i = 0; i < nl.getLength(); i++) {
parentUnitName = doc.getElementsByTagName("ParentUnitName").item(i).getFirstChild() == null ?"":
doc.getElementsByTagName("ParentUnitName").item(i).getFirstChild().getNodeValue();
if(parentUnitName.indexOf("浦东") != -1){// 只查找浦东的数据
lineName = doc.getElementsByTagName("LineName").item(i).getFirstChild() == null ?"":
doc.getElementsByTagName("LineName").item(i).getFirstChild().getNodeValue();
lineId = doc.getElementsByTagName("LineId").item(i).getFirstChild() == null ?"":
doc.getElementsByTagName("LineId").item(i).getFirstChild().getNodeValue();
abbreviation = doc.getElementsByTagName("Abbreviation").item(i).getFirstChild() == null ?"":
doc.getElementsByTagName("Abbreviation").item(i).getFirstChild().getNodeValue();
ddfs = doc.getElementsByTagName("DDFS").item(i).getFirstChild() == null ?"":
doc.getElementsByTagName("DDFS").item(i).getFirstChild().getNodeValue();
lineStandardCode = doc.getElementsByTagName("LineStandardCode").item(i).getFirstChild() == null ?"":
doc.getElementsByTagName("LineStandardCode").item(i).getFirstChild().getNodeValue();
map = new HashMap<>();
map.put("lineName",lineName);
map.put("lineId",lineId);
map.put("abbreviation",abbreviation);
map.put("ddfs",ddfs);
map.put("lineStandardCode",lineStandardCode);
list.add(map);
}
}
}catch (Exception e){
e.printStackTrace();;
}
return list;
}
/**
* 批量插入用法
* @param list
*/
public boolean insertRecord(List<HashMap<String,String>> list)
{
boolean flag = false;
final List<HashMap<String,String>> tempList=list;
String sql="INSERT INTO JJWGPS_T_SHSXLFILE(XLID,SHSXLBM,XLMC,GSMC,DDFS,CREATETIME,XLMC_ALL) VALUES (?,?,?,?,?,SYSDATE,?)";
jdbcTemplate = new JdbcTemplate(DBUtils_oldSystem.getDataSource());
jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter()
{
public void setValues(PreparedStatement ps, int i)throws SQLException
{
String lineId =tempList.get(i).get("lineId");
String lineStandardCode =tempList.get(i).get("lineStandardCode");
String lineName =tempList.get(i).get("lineName");
String abbreviation =tempList.get(i).get("abbreviation");
String ddfs =tempList.get(i).get("ddfs");
String lineNameAll = lineName;
if(ddfs.equals("2")){
lineNameAll = lineName+"区间（走向部分在全程线路之外）";
}else if(ddfs.equals("7")){
lineNameAll = lineName+"区间（走向在全程线路之内）";
}
ps.setString(1, lineId);
ps.setString(2, lineStandardCode);
ps.setString(3, lineName);
ps.setString(4, abbreviation);
ps.setString(5, ddfs);
ps.setString(6, lineNameAll);
}
public int getBatchSize()
{
return tempList.size();
}
});
flag = true;
return flag;
}
}