Browse Source

bug fix ok!!!

gxt 3 years ago
parent
commit
45591fd5bd

+ 1 - 1
src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelJDBCConfiguration.java

@@ -83,7 +83,7 @@ public class CamelJDBCConfiguration {
83 83
                       Message in = exchange.getIn();
84 84
                       HashMap<String, Object> aRow = in.getBody(HashMap.class);
85 85
                       if (StringUtils.isEmpty(aRow.get("qyrq"))){
86
-                          aRow.put("qyrq","2021-01-01 00:00:00");
86
+                          aRow.put("QYRQ","2021-01-01 00:00:00");
87 87
                       }
88 88
                       if (!aRow.containsKey("JM")) aRow.put("JM",aRow.get("JH"));
89 89
                       String org_level3 = aRow.get("ZYQ") + "@" + aRow.get("CYDMC") + "@" + aRow.get("ZK");