edit after xusirui

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

@@ -90,6 +90,8 @@ public class CamelJDBCCofRealTimeConfiguration  {
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
                     String prod_date = aRow.get("dyna_create_time").toString().split("\\+")[0];
                     aRow.put("dyna_create_time", prod_date);
+                    String check_date = aRow.get("check_date").toString().split("\\+")[0];
+                    aRow.put("check_date", check_date);
                     aRow.put("sgt", "");
                     if (!StringUtils.isEmpty(aRow.get("displacement")) && !StringUtils.isEmpty(aRow.get("disp_load"))) {
                         String[] displacements = aRow.get("displacement").toString().split(";");//10 四舍五入
@@ -158,8 +160,8 @@ public class CamelJDBCCofRealTimeConfiguration  {
                             in.setHeader("well_id",wellId);
                             sendDataToRocketMQ(wellName,wellId,prodDate,strokeLength,strokeFrequency,sgt);
                         })
-                        .setBody(simple("insert into centralbase.cb_temp_well_mech_runtime(well_id,prod_date,susp_max_load,susp_min_load,sgt) " +
-                                "select '${body[well_name]}','${body[dyna_create_time]}','${body[susp_max_load]}','${body[susp_min_load]}','${body[sgt]}' " +
+                        .setBody(simple("insert into centralbase.cb_temp_well_mech_runtime(well_id,prod_date,check_date,susp_max_load,susp_min_load,sgt) " +
+                                "select '${body[well_name]}','${body[dyna_create_time]}','${body[check_date]}','${body[susp_max_load]}','${body[susp_min_load]}','${body[sgt]}' " +
                                 "where NOT EXISTS (SELECT * FROM centralbase.cb_temp_well_mech_runtime WHERE well_id = '${body[well_name]}' and  prod_date = '${body[dyna_create_time]}' )"))
                         .to("jdbc:centralbase")
                         .setBody(simple("update centralbase.sys_access_well_control set sgt_last_time = '${header.sgt_last_time}' where well_id ='${header.well_id}' "))