|
@@ -7,10 +7,9 @@ import com.gct.common.util.SGTUtil;
|
7
|
7
|
import com.gct.tools.etlcamelhuge.entity.ZDJG_WELL;
|
8
|
8
|
import com.gct.tools.etlcamelhuge.util.CALUtil;
|
9
|
9
|
import com.gct.tools.etlcamelhuge.util.TransUtil;
|
|
10
|
+import org.apache.camel.Expression;
|
10
|
11
|
import org.apache.camel.Message;
|
11
|
12
|
import org.apache.camel.builder.RouteBuilder;
|
12
|
|
-import org.apache.camel.model.dataformat.JsonLibrary;
|
13
|
|
-import org.checkerframework.checker.units.qual.A;
|
14
|
13
|
import org.springframework.context.annotation.Configuration;
|
15
|
14
|
import org.springframework.jdbc.core.JdbcTemplate;
|
16
|
15
|
|
|
@@ -63,7 +62,7 @@ public class CamelRestConfiguration extends RouteBuilder {
|
63
|
62
|
return string;
|
64
|
63
|
}
|
65
|
64
|
|
66
|
|
- public String getDate() {
|
|
65
|
+ public Expression getDate() {
|
67
|
66
|
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式
|
68
|
67
|
String date = df.format(new java.util.Date());// new Date()为获取当前系统时间
|
69
|
68
|
return date;
|
|
@@ -474,13 +473,17 @@ public class CamelRestConfiguration extends RouteBuilder {
|
474
|
473
|
from("timer:mytimer?period=3600000")
|
475
|
474
|
.setBody(simple("select well_id from centralbase.cb_cd_well_source"))
|
476
|
475
|
.to("jdbc:centralbase")
|
|
476
|
+ .process(exchange -> {
|
|
477
|
+ Message in = exchange.getIn();
|
|
478
|
+ in.setHeader("date", getDate());
|
|
479
|
+ })
|
477
|
480
|
.split(body()).process(
|
478
|
481
|
exchange -> {
|
479
|
482
|
Message in = exchange.getIn();
|
480
|
483
|
HashMap<String, Object> aRow = in.getBody(HashMap.class);
|
481
|
484
|
in.setHeader("well_id", aRow.get("well_id"));
|
482
|
485
|
// System.out.println("step 1 =============="+aRow.get("well_id"));
|
483
|
|
- in.setHeader("date", getDate());
|
|
486
|
+//
|
484
|
487
|
// map.put("date", in.getHeader("date").toString());
|
485
|
488
|
// getCurrentTimeParams("", aRow.get("well_id").toString(), map.get("date"));
|
486
|
489
|
// Double phd = "".equals(loadPhdDate(aRow.get("id").toString())) ? 0 : Double.valueOf(loadPhdDate(aRow.get("id").toString()));
|