|
|
@@ -65,15 +65,18 @@ public class Download{
|
|
|
if(xmlConfig.get("xd_detail_conditiontag")!=null&&detailData!=null){
|
|
|
if("Packing".equals(caller)||"Invoice".equals(caller)){
|
|
|
detailXmlConfig = getXmlConfigDetail(statement,xmlConfig.get("xd_id"),"1"); //获取明细表的配置
|
|
|
- }else
|
|
|
- detailXmlConfig = getXmlConfigDetail(statement,xmlConfig.get("xd_id"),"1",xmlConfig.get("xd_detail_conditiontag")); //获取明细表的配置
|
|
|
- }
|
|
|
+ }else {
|
|
|
+ detailXmlConfig = getXmlConfigDetail(statement, xmlConfig.get("xd_id"), "1", xmlConfig.get("xd_detail_conditiontag")); //获取明细表的配置
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- String updateMainConditon = getUpdateMainCondtion(mainData,xmlConfig); //主表更新条件
|
|
|
+ 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){
|
|
|
@@ -426,12 +429,28 @@ public class Download{
|
|
|
}
|
|
|
public static void run(){
|
|
|
downloadByDepotAndSob("N_YITOA_LHCT-SF","N_YITOA_LHCT","聯合創泰科技有限公司"); //联合创泰-顺丰
|
|
|
- downloadByDepotAndSob("N_YITOA_LHCT-QF","N_YITOA_LHCT","聯合創泰科技有限公司"); //联合创泰-旗丰
|
|
|
- downloadByDepotAndSob("N_HUASL-FS","N_HUASL","香港华商龙"); //华商龙-富森
|
|
|
+ //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_HUASL-QF","N_HUASL","香港华商龙");//华商龙-旗丰
|
|
|
downloadByDepotAndSob("N_WILICHK-QF","N_WILICHK","(华商龙)威尔电子");//威尔电子-旗丰
|
|
|
- downloadByDepotAndSob("N_BJKG-QF","N_BJKG","柏建控股");//柏建控股-旗丰
|
|
|
+ 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","青岛华商龙");
|
|
|
|
|
|
|
|
|
|
|
|
@@ -466,56 +485,61 @@ public class Download{
|
|
|
}else {
|
|
|
client = FtpUtil.connect(ftpMap);
|
|
|
}
|
|
|
- if(client!=null||sftp!=null){
|
|
|
+ if(client!=null||sftp!=null) {
|
|
|
List<File> files = null;
|
|
|
- if ("N_YITOA_LHCT-SF".equals(depot)){
|
|
|
+ if ("N_YITOA_LHCT-SF".equals(depot)) {
|
|
|
files = sftp.download(ftpMap.get("downloadpath").toString());
|
|
|
|
|
|
- }else {
|
|
|
- files = FtpUtil.downloadAllFileByType(client,"XML");
|
|
|
+ }else if("N_YITOA_LHCT-SLC".equals(depot)){
|
|
|
+ files = FtpUtil.downloadDirFileByType(client, "XML",
|
|
|
+ ftpMap.get("downloadpath").toString());
|
|
|
+ }else{
|
|
|
+ files = FtpUtil.downloadAllFileByType(client, "XML");
|
|
|
}
|
|
|
String fileName = "";
|
|
|
- if(files!=null&&files.size()>0){
|
|
|
+ if (files != null && files.size() > 0) {
|
|
|
connect = JdbcUtil.getConnectBySob(sob);
|
|
|
- if(connect!=null){
|
|
|
- for (File file:files)
|
|
|
+ if (connect != null) {
|
|
|
+ for (File file : files) {
|
|
|
try {
|
|
|
fileName += "," + file.getName();
|
|
|
Statement statement = connect.createStatement();
|
|
|
System.err.println(statement);
|
|
|
- //判断当前帐套和文件是否一致
|
|
|
- if (!checkXmlFileToSqlToEnterprise(file, enterprise)) {
|
|
|
- continue;
|
|
|
- }
|
|
|
- sqls = parseXmlFileToSqls(file, statement);
|
|
|
- if (sqls == null) {
|
|
|
- continue;
|
|
|
- }
|
|
|
+ //判断当前帐套和文件是否一致
|
|
|
+ if (!checkXmlFileToSqlToEnterprise(file, enterprise)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ sqls = parseXmlFileToSqls(file, statement);
|
|
|
+ if (sqls == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
|
|
|
- executeRes = JdbcUtil.executeSqls(connect, sqls);
|
|
|
+ executeRes = JdbcUtil.executeSqls(connect, sqls);
|
|
|
|
|
|
- if (executeRes) {
|
|
|
- if ("N_YITOA_LHCT-SF".equals(depot)) {
|
|
|
- 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 {
|
|
|
- client.rename(file.getName(), "bak/" + file.getName()); //移动处理完的文件到bak文件夹下
|
|
|
- }
|
|
|
+ if (executeRes) {
|
|
|
+ if ("N_YITOA_LHCT-SF".equals(depot)) {
|
|
|
+ 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 {
|
|
|
+ //移动处理完的文件到bak文件夹下
|
|
|
+ client.rename(file.getName(), "bak/" + file.getName());
|
|
|
}
|
|
|
+ }
|
|
|
statement.close();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
BaseUtil.getLogger().error(e.toString());
|
|
|
continue;
|
|
|
}
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (!"".equals(fileName)) {
|
|
|
+ BaseUtil.logDownload(fileName.substring(1), ftpMap.get("ip").toString(), ftpMap.get("downloadpath").toString());
|
|
|
}
|
|
|
-
|
|
|
}
|
|
|
- if(!"".equals(fileName)){
|
|
|
- BaseUtil.logDownload(fileName.substring(1),ftpMap.get("ip").toString(),ftpMap.get("downloadpath").toString());
|
|
|
- }
|
|
|
- }
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
|
BaseUtil.getLogger().error(e.toString());
|
|
|
e.printStackTrace();
|