bug fix ok!!!

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

@@ -149,13 +149,14 @@ public class CamelJDBCCofRealTimeConfiguration  {
                             Double strokeFrequency = Double.valueOf(aRow.get("frequency").toString());
                             String sgt = aRow.get("sgt").toString();
                             in.setHeader("sgt_last_time",prodDate);
+                            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,stroke_length,stroke_frequency,susp_max_load,susp_min_load,sgt) " +
                                 "select '${body[well_name]}','${body[dyna_create_time]}','${body[stroke]}','${body[frequency]}','${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}' "))
+                        .setBody(simple("update centralbase.sys_access_well_control set sgt_last_time = '${header.sgt_last_time}' and well_id ='${header.well_id}' "))
                         .to("jdbc:centralbase")
                         .end();