bug fix ok!!!

src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelJDBCConfiguration.java

@@ -82,6 +82,9 @@ public class CamelJDBCConfiguration {
                        .split(body()).process(exchange -> {
                       Message in = exchange.getIn();
                       HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                      if (StringUtils.isEmpty(aRow.get("qyrq"))){
+                          aRow.put("qyrq","2021-01-01 00:00:00");
+                      }
                       if (!aRow.containsKey("JM")) aRow.put("JM",aRow.get("JH"));
                       String org_level3 = aRow.get("ZYQ") + "@" + aRow.get("CYDMC") + "@" + aRow.get("ZK");
                       String org_level2 = aRow.get("ZYQ") + "@" + aRow.get("CYDMC");
@@ -106,8 +109,6 @@ public class CamelJDBCConfiguration {
                       if(orgIDs.get(org_level3) !=null){
                           aRow.put("org_id",orgIDs.get(org_level3));
                       }
-                      String format = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
-                      aRow.putIfAbsent("QYRQ",format);
                   })
                   .setBody(simple("insert into centralbase.cb_cd_well_source (well_id,well_common_name,spud_date,org_id,station_id,station_name,completion_name,PRODUCING_AREA_name,remarks) " +
                                   "select '${body[JH]}','${body[JM]}','${body[QYRQ]}'::timestamp,'${body[org_id]}','${body[station_id]}','${body[ZK]}','${body[SCCW]}','${body[QK]}','${body[BZ]}' " +