Browse Source

hana人员地址特殊处理

njs 3 years ago
parent
commit
6b9d28380a

+ 79 - 79
suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/HanaOrderComponent.java

@@ -303,47 +303,47 @@ public class HanaOrderComponent {
 
                 fw.write(
                         result.getString("VBELN")
-                                +"?"+ result.getString("POSNR")
-                                +"?"+ result.getString("VKORG")
-                                +"?"+ result.getString("VKORG_TXT")
-                                +"?"+ result.getString("VTWEG")
-                                +"?"+ result.getString("KUNNR")
-                                +"?"+ result.getString("NAME1")
-                                +"?"+ result.getString("ROUTE")
-                                +"?"+ result.getString("SPART")
-                                +"?"+ result.getString("VKGRP")
-                                +"?"+ result.getString("WERKS")
-                                +"?"+ result.getString("WERKS_NAME")
-                                +"?"+ result.getString("LGORT")
-                                +"?"+ result.getString("LGOBE")
-                                +"?"+ result.getString("AUART")
-                                +"?"+ result.getString("ERDAT")
-                                +"?"+ result.getString("ERDAT_P")
-                                +"?"+ result.getString("LFSTA")
-                                +"?"+ result.getString("MATNR")
-                                +"?"+ result.getString("ZMAKTXX")
-                                +"?"+ result.getString("PRODHA_TXT")
-                                +"?"+ result.getString("GROES")
-                                +"?"+ result.getString("TRAGR")
-                                +"?"+ result.getString("ZCMFRE")
-                                +"?"+ result.getString("ZCMGST")
-                                +"?"+ result.getString("ABGRU")
-                                +"?"+ checkgetBigDecimal(result.getBigDecimal("ZZMENG"))
-                                +"?"+ checkgetBigDecimal(result.getBigDecimal("ZZMENG2"))
-                                +"?"+ checkgetBigDecimal(result.getBigDecimal("ZNETWR"))
-                                +"?"+ checkgetBigDecimal(result.getBigDecimal("ZRFMNG"))
-                                +"?"+ checkgetBigDecimal(result.getBigDecimal("ZRFMNG2"))
-                                +"?"+ checkgetBigDecimal(result.getBigDecimal("ZNETWR1"))
-                                +"?"+ result.getString("VSBED")
-                                +"?"+ result.getString("VSBED_TXT")
-                                +"?"+ result.getString("ABRVW")
-                                +"?"+ result.getString("ABRVW_TXT")
-                                +"?"+ result.getString("VKBUR")
-                                +"?"+ result.getString("ZCODE1")
-                                +"?"+ result.getString("ZCODE1_DESC")
-                                +"?"+ result.getString("ZCODE4")
-                                +"?"+ result.getString("ZCODE4_DESC")
-                                +"?"+ result.getString("BSTKD_E")
+                                +"$$"+ result.getString("POSNR")
+                                +"$$"+ result.getString("VKORG")
+                                +"$$"+ result.getString("VKORG_TXT")
+                                +"$$"+ result.getString("VTWEG")
+                                +"$$"+ result.getString("KUNNR")
+                                +"$$"+ result.getString("NAME1")
+                                +"$$"+ result.getString("ROUTE")
+                                +"$$"+ result.getString("SPART")
+                                +"$$"+ result.getString("VKGRP")
+                                +"$$"+ result.getString("WERKS")
+                                +"$$"+ result.getString("WERKS_NAME")
+                                +"$$"+ result.getString("LGORT")
+                                +"$$"+ result.getString("LGOBE")
+                                +"$$"+ result.getString("AUART")
+                                +"$$"+ result.getString("ERDAT")
+                                +"$$"+ result.getString("ERDAT_P")
+                                +"$$"+ result.getString("LFSTA")
+                                +"$$"+ result.getString("MATNR")
+                                +"$$"+ result.getString("ZMAKTXX")
+                                +"$$"+ result.getString("PRODHA_TXT")
+                                +"$$"+ result.getString("GROES")
+                                +"$$"+ result.getString("TRAGR")
+                                +"$$"+ result.getString("ZCMFRE")
+                                +"$$"+ result.getString("ZCMGST")
+                                +"$$"+ result.getString("ABGRU")
+                                +"$$"+ checkgetBigDecimal(result.getBigDecimal("ZZMENG"))
+                                +"$$"+ checkgetBigDecimal(result.getBigDecimal("ZZMENG2"))
+                                +"$$"+ checkgetBigDecimal(result.getBigDecimal("ZNETWR"))
+                                +"$$"+ checkgetBigDecimal(result.getBigDecimal("ZRFMNG"))
+                                +"$$"+ checkgetBigDecimal(result.getBigDecimal("ZRFMNG2"))
+                                +"$$"+ checkgetBigDecimal(result.getBigDecimal("ZNETWR1"))
+                                +"$$"+ result.getString("VSBED")
+                                +"$$"+ result.getString("VSBED_TXT")
+                                +"$$"+ result.getString("ABRVW")
+                                +"$$"+ result.getString("ABRVW_TXT")
+                                +"$$"+ result.getString("VKBUR")
+                                +"$$"+ result.getString("ZCODE1")
+                                +"$$"+ result.getString("ZCODE1_DESC")
+                                +"$$"+ result.getString("ZCODE4")
+                                +"$$"+ result.getString("ZCODE4_DESC")
+                                +"$$"+ result.getString("BSTKD_E")
                                 + "\r\n");
 
 
@@ -581,42 +581,42 @@ public class HanaOrderComponent {
 
                 fw.write(
                 result.getString("VBELN")
-                +"??"+result.getString("POSNR")
-                +"??"+result.getString("VGBEL")
-                +"??"+result.getString("VGPOS")
-                +"??"+result.getString("VKORG")
-                +"??"+result.getString("VKORG_TXT")
-                +"??"+result.getString("VTWEG")
-                +"??"+result.getString("KUNAG")
-                +"??"+result.getString("KUNAG_TXT")
-                +"??"+result.getString("SPART")
-                +"??"+result.getString("VKGRP")
-                +"??"+result.getString("WERKS")
-                +"??"+result.getString("WERKS_NAME")
-                +"??"+result.getString("AUART_S")
-                +"??"+result.getString("LFART")
-                +"??"+result.getString("MATNR")
-                +"??"+result.getString("ZMAKTXX")
-                +"??"+result.getString("GROES")
-                +"??"+result.getString("ZTKNUM")
-                +"??"+""
-                +"??"+result.getString("ZSTREET")
-                +"??"+result.getString("ERDAT_S")
-                +"??"+result.getString("ZERDAT2")
-                +"??"+result.getString("ERDAT")
-                +"??"+result.getString("WADAT_IST")
-                +"??"+""
-                +"??"+""
-                +"??"+""
-                +"??"+result.getString("STATUS")
-                +"??"+result.getBigDecimal("ZKWMENG")
-                +"??"+result.getBigDecimal("NTGEW_VBAP")
-                +"??"+result.getBigDecimal("LFIMG")
-                +"??"+result.getBigDecimal("NTGEW")
-                +"??"+result.getBigDecimal("KZWI4")
-                +"??"+result.getString("WADAT_IST")
-                +"??"+result.getString("BOLNR")
-                +"??"+result.getString("ERZET")
+                +"$$"+result.getString("POSNR")
+                +"$$"+result.getString("VGBEL")
+                +"$$"+result.getString("VGPOS")
+                +"$$"+result.getString("VKORG")
+                +"$$"+result.getString("VKORG_TXT")
+                +"$$"+result.getString("VTWEG")
+                +"$$"+result.getString("KUNAG")
+                +"$$"+result.getString("KUNAG_TXT")
+                +"$$"+result.getString("SPART")
+                +"$$"+result.getString("VKGRP")
+                +"$$"+result.getString("WERKS")
+                +"$$"+result.getString("WERKS_NAME")
+                +"$$"+result.getString("AUART_S")
+                +"$$"+result.getString("LFART")
+                +"$$"+result.getString("MATNR")
+                +"$$"+result.getString("ZMAKTXX")
+                +"$$"+result.getString("GROES")
+                +"$$"+result.getString("ZTKNUM")
+                +"$$"+""
+                +"$$"+result.getString("ZSTREET")
+                +"$$"+result.getString("ERDAT_S")
+                +"$$"+result.getString("ZERDAT2")
+                +"$$"+result.getString("ERDAT")
+                +"$$"+result.getString("WADAT_IST")
+                +"$$"+""
+                +"$$"+""
+                +"$$"+""
+                +"$$"+result.getString("STATUS")
+                +"$$"+result.getBigDecimal("ZKWMENG")
+                +"$$"+result.getBigDecimal("NTGEW_VBAP")
+                +"$$"+result.getBigDecimal("LFIMG")
+                +"$$"+result.getBigDecimal("NTGEW")
+                +"$$"+result.getBigDecimal("KZWI4")
+                +"$$"+result.getString("WADAT_IST")
+                +"$$"+result.getString("BOLNR")
+                +"$$"+result.getString("ERZET")
                 + "\r\n");
 
                 fw.flush();
@@ -796,7 +796,7 @@ public class HanaOrderComponent {
         //测试表
 //        String testSql = "LOAD DATA LOCAL INFILE 'testIO.txt' into table sap_hana_sales_order fields terminated by '?' lines terminated by '\\n'";
         //生产表
-        String testSql = "LOAD DATA LOCAL INFILE 'testIO.txt' into table meta_hana_sales_order fields terminated by '?' lines terminated by '\\n'";
+        String testSql = "LOAD DATA LOCAL INFILE 'testIO.txt' into table meta_hana_sales_order fields terminated by '$$' lines terminated by '\\n'";
         try {
             long beginTime=System.currentTimeMillis();
             int rows=this.bulkLoadFromInputStream(testSql, mergeGetStream(new File((Global.getTemdataPath()+"salesOrder/"))));
@@ -813,7 +813,7 @@ public class HanaOrderComponent {
         //测试表
 //        String testSql = "LOAD DATA LOCAL INFILE 'testIO.txt' into table sap_hana_deliver_order fields terminated by '?' lines terminated by '\\n'";
         //生产表
-        String testSql = "LOAD DATA LOCAL INFILE 'testIO.txt' into table meta_hana_deliver_order fields terminated by '??' lines terminated by '\\n'";
+        String testSql = "LOAD DATA LOCAL INFILE 'testIO.txt' into table meta_hana_deliver_order fields terminated by '$$' lines terminated by '\\n'";
         try {
             long beginTime=System.currentTimeMillis();
             int rows=this.bulkLoadFromInputStream(testSql, mergeGetStream(new File((Global.getTemdataPath()+"deliverOrder/"))));