|
|
@@ -1,5 +1,16 @@
|
|
|
package com.uas.main;
|
|
|
|
|
|
+import com.jcraft.jsch.JSchException;
|
|
|
+import com.uas.util.BaseUtil;
|
|
|
+import com.uas.util.FtpUtil;
|
|
|
+import com.uas.util.JdbcUtil;
|
|
|
+import com.uas.util.SFTPUtil;
|
|
|
+import org.apache.commons.net.ftp.FTPClient;
|
|
|
+import org.codehaus.jackson.map.ObjectMapper;
|
|
|
+import org.dom4j.Document;
|
|
|
+import org.dom4j.Element;
|
|
|
+import org.dom4j.io.SAXReader;
|
|
|
+
|
|
|
import java.io.File;
|
|
|
import java.io.FileInputStream;
|
|
|
import java.io.IOException;
|
|
|
@@ -8,15 +19,10 @@ import java.sql.Connection;
|
|
|
import java.sql.ResultSet;
|
|
|
import java.sql.SQLException;
|
|
|
import java.sql.Statement;
|
|
|
-import java.util.*;
|
|
|
-
|
|
|
-import com.jcraft.jsch.JSchException;
|
|
|
-import com.uas.util.*;
|
|
|
-import org.apache.commons.net.ftp.FTPClient;
|
|
|
-import org.codehaus.jackson.map.ObjectMapper;
|
|
|
-import org.dom4j.Document;
|
|
|
-import org.dom4j.Element;
|
|
|
-import org.dom4j.io.SAXReader;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
|
|
|
public class Download{
|
|
|
|
|
|
@@ -70,13 +76,12 @@ public class Download{
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- String updateMainConditon = getUpdateMainCondtion(mainData,xmlConfig);
|
|
|
- updateMainConditon = updateMainConditon.replace(" pi_inoutno='' and ","");
|
|
|
+ String updateMainConditon = getUpdateMainCondtion(mainData,xmlConfig); //主表更新条件
|
|
|
+ updateMainConditon = updateMainConditon.replace(" pi_inoutno='' and ","");//主表更新条件
|
|
|
String maincode = mainData.get(xmlConfig.get("xd_main_conditiontag"));
|
|
|
if(mainXmlConfig.size()>0){
|
|
|
mainTableUpdateSql = getUpdateMainFields(mainData,xmlConfig,mainXmlConfig); //主表更新字段
|
|
|
mainTableUpdateSql += " where " + updateMainConditon;
|
|
|
-
|
|
|
sqls.add(mainTableUpdateSql);
|
|
|
}
|
|
|
if(detailXmlConfig!=null&&detailXmlConfig.size()>0){
|
|
|
@@ -427,41 +432,23 @@ public class Download{
|
|
|
}
|
|
|
return data;
|
|
|
}
|
|
|
- public static void run(){
|
|
|
- downloadByDepotAndSob("N_YITOA_LHCT-SF","N_YITOA_LHCT","聯合創泰科技有限公司"); //联合创泰-顺丰
|
|
|
- //downloadByDepotAndSob("N_YITOA_LHCT-QF","N_YITOA_LHCT","聯合創泰科技有限公司"); //联合创泰-旗丰
|
|
|
- downloadByDepotAndSob("N_YITOA_LHCT-FS","N_YITOA_LHCT","聯合創泰科技有限公司"); //联合创泰-富森
|
|
|
- downloadByDepotAndSob("N_YITOA_LHCT-SLC","N_YITOA_LHCT","聯合創泰科技有限公司"); //联合创泰-SLC上海保税仓
|
|
|
- downloadByDepotAndSob("N_YITOA_LHCT-ZSD","N_YITOA_LHCT","聯合創泰科技有限公司"); //联合创泰-准时达
|
|
|
- downloadByDepotAndSob("N_YITOA_LHCT_HK-FS","N_YITOA_LHCT_HK","英唐創泰香港科技有限公司");//英唐创泰香港-富森
|
|
|
- downloadByDepotAndSob("N_HUASL-FS","N_HUASL","香港华商龙"); //华商龙-富森
|
|
|
- downloadByDepotAndSob("N_HUASL-XN","N_HUASL","香港华商龙"); //华商龙-新宁
|
|
|
- //downloadByDepotAndSob("N_HUASL-QF","N_HUASL","香港华商龙");//华商龙-旗丰
|
|
|
- downloadByDepotAndSob("N_WILICHK-QF","N_WILICHK","(华商龙)威尔电子");//威尔电子-旗丰
|
|
|
- downloadByDepotAndSob("N_WILICHK-FS","N_WILICHK","(华商龙)威尔电子");//威尔电子-富森
|
|
|
- //downloadByDepotAndSob("N_BJKG-QF","N_BJKG","柏建控股");//柏建控股-旗丰
|
|
|
- downloadByDepotAndSob("N_BJKG-FS","N_BJKG","柏建控股"); //柏建控股-富森
|
|
|
- //深圳华商龙-准时达
|
|
|
- downloadByDepotAndSob("N_HUASL_SZ-DRD","N_HUASL_SZ","深圳华商龙");
|
|
|
- //上海宇声-准时达
|
|
|
- downloadByDepotAndSob("N_E_SHINE_SH-DRD","N_E_SHINE_SH","上海宇声");
|
|
|
- //重庆华商龙-准时达
|
|
|
- downloadByDepotAndSob("HSL_CQ-DRD","HSL_CQ","重庆华商龙");
|
|
|
- //北京华商龙-准时达
|
|
|
- downloadByDepotAndSob("HSL_BJ-DRD","HSL_BJ","北京华商龙");
|
|
|
- //青岛华商龙-准时达
|
|
|
- downloadByDepotAndSob("N_HUASL_QD-DRD","N_HUASL_QD","青岛华商龙");
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-// downloadByDepotAndSob("N_HUASL-JS","N_HUASL"); //华商龙-嘉晟
|
|
|
-// downloadByDepotAndSob("N_WILICHK-JS","N_WILICHK"); //威尔电子-嘉晟
|
|
|
-// downloadByDepotAndSob("N_BJKG-JS","N_BJKG"); //柏建控股-嘉晟
|
|
|
-// downloadByDepotAndSob("USOFT_MALL_HK-JS","USOFT_MALL_HK"); //优软商城香港-嘉晟
|
|
|
-// downloadByDepotAndSob("t_n_huasl-QF","t_n_huasl");
|
|
|
+ public static void downloadRun(){
|
|
|
+ //联合创泰-顺丰
|
|
|
+ //downloadByDepotAndSob("N_YITOA_LHCT-SF","N_YITOA_LHCT","聯合創泰科技有限公司");
|
|
|
+ //联合创泰-富森
|
|
|
+ downloadByDepotAndSob("N_YITOA_LHCT-FS","N_YITOA_LHCT","聯合創泰科技有限公司");
|
|
|
+ //联合创泰-准时达
|
|
|
+ //downloadByDepotAndSob("N_YITOA_LHCT-ZSD","N_YITOA_LHCT","聯合創泰科技有限公司");
|
|
|
+ //联合创泰-SLC上海保税仓
|
|
|
+ downloadByDepotAndSob("N_YITOA_LHCT-SLC","N_YITOA_LHCT","聯合創泰科技有限公司");
|
|
|
+ //联合创泰-中芯
|
|
|
+ downloadByDepotAndSob("N_YITOA_LHCT-ZX","N_YITOA_LHCT","聯合創泰科技有限公司");
|
|
|
+ //英唐创泰香港-富森
|
|
|
+ //downloadByDepotAndSob("N_YITOA_LHCT_HK-FS","N_YITOA_LHCT_HK","英唐創泰香港科技有限公司");
|
|
|
+
|
|
|
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
@SuppressWarnings("unchecked")
|
|
|
public static void downloadByDepotAndSob(String depot,String sob,String enterprise){
|
|
|
FTPClient client = null;
|
|
|
@@ -469,11 +456,11 @@ public class Download{
|
|
|
List<String> sqls = new ArrayList<String>();
|
|
|
boolean executeRes = false;
|
|
|
Connection connect = null;
|
|
|
-
|
|
|
- try {
|
|
|
- Map<String,Object> servMap = JdbcUtil.getFtpConfigs();
|
|
|
+
|
|
|
+ try {
|
|
|
+ Map<String,Object> servMap = JdbcUtil.getFtpConfigs();
|
|
|
Map<String,Object> ftpMap = (Map<String,Object>)servMap.get(depot);
|
|
|
- if ("N_YITOA_LHCT-SF".equals(depot)){
|
|
|
+ if ("N_YITOA_LHCT-SF".equals(depot)||"N_YITOA_LHCT-ZX".equals(depot)){
|
|
|
sftp = new SFTPUtil(ftpMap.get("user").toString(),ftpMap.get("password").toString(),
|
|
|
ftpMap.get("ip").toString(),
|
|
|
Integer.parseInt(ftpMap.get("port").toString()));
|
|
|
@@ -487,7 +474,7 @@ public class Download{
|
|
|
}
|
|
|
if(client!=null||sftp!=null) {
|
|
|
List<File> files = null;
|
|
|
- if ("N_YITOA_LHCT-SF".equals(depot)) {
|
|
|
+ if ("N_YITOA_LHCT-SF".equals(depot)||"N_YITOA_LHCT-ZX".equals(depot)) {
|
|
|
files = sftp.download(ftpMap.get("downloadpath").toString());
|
|
|
|
|
|
}else if("N_YITOA_LHCT-SLC".equals(depot)){
|
|
|
@@ -521,6 +508,10 @@ public class Download{
|
|
|
String s = file.getName().substring(0, file.getName().indexOf(".")) + ".xml";
|
|
|
Boolean rename = sftp.rename(ftpMap.get("downloadpath").toString() + "/" + s, "goodsreceipt/backup/" + s);
|
|
|
System.err.println(rename);
|
|
|
+ }else if("N_YITOA_LHCT-ZX".equals(depot)){
|
|
|
+ String s = file.getName().substring(0, file.getName().indexOf(".")) + ".xml";
|
|
|
+ Boolean rename = sftp.rename(ftpMap.get("downloadpath").toString() + "/" + s,ftpMap.get("downloadpath").toString() + "/bak/" + s);
|
|
|
+ System.err.println(rename);
|
|
|
} else {
|
|
|
//移动处理完的文件到bak文件夹下
|
|
|
client.rename(file.getName(), "bak/" + file.getName());
|
|
|
@@ -540,12 +531,12 @@ public class Download{
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- } catch (Exception e) {
|
|
|
- BaseUtil.getLogger().error(e.toString());
|
|
|
+ } catch (Exception e) {
|
|
|
+ BaseUtil.getLogger().error(e.toString());
|
|
|
e.printStackTrace();
|
|
|
}finally{
|
|
|
if(client!=null){
|
|
|
- FtpUtil.closeFtpClient(client);
|
|
|
+ FtpUtil.closeFtpClient(client);
|
|
|
client = null;
|
|
|
}
|
|
|
if (sftp!=null){
|