|
|
@@ -57,9 +57,11 @@ public class DownloadServiceImpl implements DownloadService {
|
|
|
if (files != null && files.size() > 0) {
|
|
|
connect = getConnectBySob(sob);
|
|
|
if (connect != null) {
|
|
|
+ BaseUtil.getLogger().info("files："+files.size());
|
|
|
for (File file : files) {
|
|
|
try {
|
|
|
fileName += "," + file.getName();
|
|
|
+ BaseUtil.getLogger().info("file begin deal："+file.getName());
|
|
|
Statement statement = connect.createStatement();
|
|
|
//判断当前帐套和文件是否一致
|
|
|
if (!checkXmlFileToSqlToEnterprise(file, enterprise)) {
|
|
|
@@ -68,6 +70,7 @@ public class DownloadServiceImpl implements DownloadService {
|
|
|
sqls = parseXmlFileToSqls(file, statement);
|
|
|
if (sqls == null) {
|
|
|
//移动处理失败的文件到failed文件夹下
|
|
|
+ BaseUtil.getLogger().info("failed sqls is null："+file.getName());
|
|
|
client.rename(file.getName(), "failed/" + file.getName());
|
|
|
continue;
|
|
|
}
|
|
|
@@ -76,8 +79,10 @@ public class DownloadServiceImpl implements DownloadService {
|
|
|
|
|
|
if (executeRes) {
|
|
|
//移动处理完的文件到bak文件夹下
|
|
|
+ BaseUtil.getLogger().info("file deal success："+file.getName());
|
|
|
client.rename(file.getName(), "bak/" + file.getName());
|
|
|
}else {
|
|
|
+ BaseUtil.getLogger().info("file deal failed："+file.getName());
|
|
|
//移动处理失败的文件到failed文件夹下
|
|
|
client.rename(file.getName(), "failed/" + file.getName());
|
|
|
}
|
DINGYL