TransArriveExportImpl.java
5.9 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
package com.tianbo.analysis.service.imp;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.tianbo.analysis.config.CustomsProperties;
import com.tianbo.analysis.dao.TRANSTOARRIVEEXPORTMapper;
import com.tianbo.analysis.model.ResultJson;
import com.tianbo.analysis.model.TRANSTOARRIVEEXPORT;
import com.tianbo.analysis.service.TransArriveExportService;
import com.tianbo.analysis.tools.XmlTools;
import com.tianbo.util.Date.DateUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FileUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.ResourceUtils;
import org.thymeleaf.TemplateEngine;
import org.thymeleaf.context.Context;
import org.thymeleaf.exceptions.TemplateInputException;
import org.xml.sax.SAXParseException;
import javax.annotation.Resource;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.List;
import java.util.Locale;
import java.util.UUID;
@Service
@Slf4j
public class TransArriveExportImpl implements TransArriveExportService {
@Resource
TRANSTOARRIVEEXPORTMapper mapper;
@Autowired
private TemplateEngine templateEngine;
@Autowired
private CustomsProperties customsProperties;
@Value("${customs.transarrive.xml-save}")
private String saveXmlForSendDir;
@Override
public int addTransArriveExport(TRANSTOARRIVEEXPORT transtoarriveexport) {
return mapper.insertSelective(transtoarriveexport);
}
@Override
public int ediTransArriveExport(TRANSTOARRIVEEXPORT transtoarriveexport) {
return mapper.updateByPrimaryKeySelective(transtoarriveexport);
}
@Override
public int delTransArriveExport(String autoid) {
return mapper.deleteByPrimaryKey(autoid);
}
@Override
public PageInfo<TRANSTOARRIVEEXPORT> selectTrans(TRANSTOARRIVEEXPORT transtoarriveexport, int pageNum, int pageSize) {
PageHelper.startPage(pageNum,pageSize);
List<TRANSTOARRIVEEXPORT> list=mapper.selectTrans(transtoarriveexport);
PageInfo<TRANSTOARRIVEEXPORT> pageInfo=new PageInfo<TRANSTOARRIVEEXPORT>(list);
return pageInfo;
}
@Override
public ResultJson send(TRANSTOARRIVEEXPORT record) {
//设置海关相关信息配置
record.setApplycode(customsProperties.getApplyCode());
record.setApplyname(customsProperties.getApplyName());
record.setCopcode(customsProperties.getCopCode());
record.setCustomscode("4604");
//操作员IC卡号
record.setInputopid(customsProperties.getInputOpId());
// 操作员姓名
record.setInputopname(customsProperties.getInputOpName());
ResultJson resultJson= new ResultJson();
try{
String nowStr = DateUtil.getCurrentTime17();
//从配置文件读取
String messageID = "CN_"
+ "TRANSARRIVE_EXPORT_DECLARE"
+ "_1P0_"
+ record.getCustomscode()+
"_" + nowStr;
Context context = new Context();
context.setVariable("declare",record);
context.setLocale(Locale.SIMPLIFIED_CHINESE);
//生成的文件名
String fileName = messageID + ".xml";
//生成的报文路径,带斜杠
String filePath = customsProperties.getTransarrive().getXmlSave()+fileName;
File file = ResourceUtils.getFile(filePath);
/**
* 中文的地方在模板中要用utext,否则中文会被 escape 转义
*/
String xmlStr = templateEngine.process("transToArrive/EXPORT_DECLARE_TPL.xml",context);
boolean valied = XmlTools.validateXMLSchemaThrowError("xsd/ETAImportMessage.xsd", xmlStr);
if (valied) {
FileUtils.writeStringToFile(file, xmlStr, StandardCharsets.UTF_8);
//todo:更新发送状态,插入发送日志
resultJson.setCode("200");
resultJson.setMsg("报文发送成功");
log.info("[XML-BUILD]- 报文已生成到目录{}",filePath);
}
}catch (FileNotFoundException e){
e.printStackTrace();
resultJson.setCode("401");
resultJson.setMsg("报文发送失败,文件未找到");
resultJson.setError(e.toString());
log.error("报文发送失败,[{}]文件未找到",e.toString());
}catch (IOException e) {
e.printStackTrace();
resultJson.setCode("402");
resultJson.setMsg("报文发送失败,文件读取失败");
resultJson.setError(e.toString());
log.error("报文发送失败,[{}]文件IO读取失败",e.toString());
}catch (TemplateInputException e){
resultJson.setCode("404");
resultJson.setMsg("报文发送失败,报文模板未找到");
resultJson.setError(e.toString());
log.error("报文发送失败,[{}]报文模板未找到",e.toString());
}catch (SAXParseException e){
log.error("[XML-ERR]-xml报文校验失败:[{}]", e.getMessage());
resultJson.setCode("400");
resultJson.setMsg("报文发送失败,报文校验不通过");
resultJson.setError(e.getMessage());
} catch (Exception ignored){
resultJson.setCode("405");
resultJson.setMsg("报文发送失败,其他错误");
resultJson.setError(ignored.toString());
log.error("[XML-ERR]-报文发送失败,其他错误:[{}]", ignored.getMessage());
}
return resultJson;
}
@Override
public ResultJson batchSend(TRANSTOARRIVEEXPORT var) {
return null;
}
}