diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/src/main/java/org/well/well/domain/AlarmRecord.java b/src/main/java/org/well/well/domain/AlarmRecord.java
index 77c2cf1..7ffc8eb 100644
--- a/src/main/java/org/well/well/domain/AlarmRecord.java
+++ b/src/main/java/org/well/well/domain/AlarmRecord.java
@@ -2,6 +2,7 @@
import org.hibernate.annotations.NotFound;
import org.hibernate.annotations.NotFoundAction;
+import org.well.well.util.SnowFlakeUtil;
import javax.persistence.*;
import java.io.Serializable;
@@ -44,6 +45,7 @@
public AlarmRecord(Long jobId, String alarmType,Integer alarmLevel, String alarmContent, String alarmValue,
Device device, String deviceCode, String wellCode, Date alarmTime,String alarmMsg) {
+ this.id= SnowFlakeUtil.getId();
this.jobId = jobId;
this.alarmType = alarmType;
this.alarmLevel = alarmLevel;
@@ -58,7 +60,7 @@
}
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
public Long getId() {
return id;
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/src/main/java/org/well/well/domain/AlarmRecord.java b/src/main/java/org/well/well/domain/AlarmRecord.java
index 77c2cf1..7ffc8eb 100644
--- a/src/main/java/org/well/well/domain/AlarmRecord.java
+++ b/src/main/java/org/well/well/domain/AlarmRecord.java
@@ -2,6 +2,7 @@
import org.hibernate.annotations.NotFound;
import org.hibernate.annotations.NotFoundAction;
+import org.well.well.util.SnowFlakeUtil;
import javax.persistence.*;
import java.io.Serializable;
@@ -44,6 +45,7 @@
public AlarmRecord(Long jobId, String alarmType,Integer alarmLevel, String alarmContent, String alarmValue,
Device device, String deviceCode, String wellCode, Date alarmTime,String alarmMsg) {
+ this.id= SnowFlakeUtil.getId();
this.jobId = jobId;
this.alarmType = alarmType;
this.alarmLevel = alarmLevel;
@@ -58,7 +60,7 @@
}
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
public Long getId() {
return id;
diff --git a/src/main/java/org/well/well/domain/LGGas.java b/src/main/java/org/well/well/domain/LGGas.java
index eb4d781..c186d21 100644
--- a/src/main/java/org/well/well/domain/LGGas.java
+++ b/src/main/java/org/well/well/domain/LGGas.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -22,7 +24,7 @@
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -99,6 +101,7 @@
}
public LGGas(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/src/main/java/org/well/well/domain/AlarmRecord.java b/src/main/java/org/well/well/domain/AlarmRecord.java
index 77c2cf1..7ffc8eb 100644
--- a/src/main/java/org/well/well/domain/AlarmRecord.java
+++ b/src/main/java/org/well/well/domain/AlarmRecord.java
@@ -2,6 +2,7 @@
import org.hibernate.annotations.NotFound;
import org.hibernate.annotations.NotFoundAction;
+import org.well.well.util.SnowFlakeUtil;
import javax.persistence.*;
import java.io.Serializable;
@@ -44,6 +45,7 @@
public AlarmRecord(Long jobId, String alarmType,Integer alarmLevel, String alarmContent, String alarmValue,
Device device, String deviceCode, String wellCode, Date alarmTime,String alarmMsg) {
+ this.id= SnowFlakeUtil.getId();
this.jobId = jobId;
this.alarmType = alarmType;
this.alarmLevel = alarmLevel;
@@ -58,7 +60,7 @@
}
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
public Long getId() {
return id;
diff --git a/src/main/java/org/well/well/domain/LGGas.java b/src/main/java/org/well/well/domain/LGGas.java
index eb4d781..c186d21 100644
--- a/src/main/java/org/well/well/domain/LGGas.java
+++ b/src/main/java/org/well/well/domain/LGGas.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -22,7 +24,7 @@
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -99,6 +101,7 @@
}
public LGGas(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/LGLiquid.java b/src/main/java/org/well/well/domain/LGLiquid.java
index 67b1243..fb2ec82 100644
--- a/src/main/java/org/well/well/domain/LGLiquid.java
+++ b/src/main/java/org/well/well/domain/LGLiquid.java
@@ -20,7 +20,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/src/main/java/org/well/well/domain/AlarmRecord.java b/src/main/java/org/well/well/domain/AlarmRecord.java
index 77c2cf1..7ffc8eb 100644
--- a/src/main/java/org/well/well/domain/AlarmRecord.java
+++ b/src/main/java/org/well/well/domain/AlarmRecord.java
@@ -2,6 +2,7 @@
import org.hibernate.annotations.NotFound;
import org.hibernate.annotations.NotFoundAction;
+import org.well.well.util.SnowFlakeUtil;
import javax.persistence.*;
import java.io.Serializable;
@@ -44,6 +45,7 @@
public AlarmRecord(Long jobId, String alarmType,Integer alarmLevel, String alarmContent, String alarmValue,
Device device, String deviceCode, String wellCode, Date alarmTime,String alarmMsg) {
+ this.id= SnowFlakeUtil.getId();
this.jobId = jobId;
this.alarmType = alarmType;
this.alarmLevel = alarmLevel;
@@ -58,7 +60,7 @@
}
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
public Long getId() {
return id;
diff --git a/src/main/java/org/well/well/domain/LGGas.java b/src/main/java/org/well/well/domain/LGGas.java
index eb4d781..c186d21 100644
--- a/src/main/java/org/well/well/domain/LGGas.java
+++ b/src/main/java/org/well/well/domain/LGGas.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -22,7 +24,7 @@
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -99,6 +101,7 @@
}
public LGGas(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/LGLiquid.java b/src/main/java/org/well/well/domain/LGLiquid.java
index 67b1243..fb2ec82 100644
--- a/src/main/java/org/well/well/domain/LGLiquid.java
+++ b/src/main/java/org/well/well/domain/LGLiquid.java
@@ -20,7 +20,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Liquid.java b/src/main/java/org/well/well/domain/Liquid.java
index 51ef826..0b651d9 100644
--- a/src/main/java/org/well/well/domain/Liquid.java
+++ b/src/main/java/org/well/well/domain/Liquid.java
@@ -23,7 +23,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/src/main/java/org/well/well/domain/AlarmRecord.java b/src/main/java/org/well/well/domain/AlarmRecord.java
index 77c2cf1..7ffc8eb 100644
--- a/src/main/java/org/well/well/domain/AlarmRecord.java
+++ b/src/main/java/org/well/well/domain/AlarmRecord.java
@@ -2,6 +2,7 @@
import org.hibernate.annotations.NotFound;
import org.hibernate.annotations.NotFoundAction;
+import org.well.well.util.SnowFlakeUtil;
import javax.persistence.*;
import java.io.Serializable;
@@ -44,6 +45,7 @@
public AlarmRecord(Long jobId, String alarmType,Integer alarmLevel, String alarmContent, String alarmValue,
Device device, String deviceCode, String wellCode, Date alarmTime,String alarmMsg) {
+ this.id= SnowFlakeUtil.getId();
this.jobId = jobId;
this.alarmType = alarmType;
this.alarmLevel = alarmLevel;
@@ -58,7 +60,7 @@
}
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
public Long getId() {
return id;
diff --git a/src/main/java/org/well/well/domain/LGGas.java b/src/main/java/org/well/well/domain/LGGas.java
index eb4d781..c186d21 100644
--- a/src/main/java/org/well/well/domain/LGGas.java
+++ b/src/main/java/org/well/well/domain/LGGas.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -22,7 +24,7 @@
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -99,6 +101,7 @@
}
public LGGas(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/LGLiquid.java b/src/main/java/org/well/well/domain/LGLiquid.java
index 67b1243..fb2ec82 100644
--- a/src/main/java/org/well/well/domain/LGLiquid.java
+++ b/src/main/java/org/well/well/domain/LGLiquid.java
@@ -20,7 +20,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Liquid.java b/src/main/java/org/well/well/domain/Liquid.java
index 51ef826..0b651d9 100644
--- a/src/main/java/org/well/well/domain/Liquid.java
+++ b/src/main/java/org/well/well/domain/Liquid.java
@@ -23,7 +23,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Methane.java b/src/main/java/org/well/well/domain/Methane.java
index e06e34c..ad90ba4 100644
--- a/src/main/java/org/well/well/domain/Methane.java
+++ b/src/main/java/org/well/well/domain/Methane.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -24,7 +26,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -128,6 +130,7 @@
}
public Methane(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/src/main/java/org/well/well/domain/AlarmRecord.java b/src/main/java/org/well/well/domain/AlarmRecord.java
index 77c2cf1..7ffc8eb 100644
--- a/src/main/java/org/well/well/domain/AlarmRecord.java
+++ b/src/main/java/org/well/well/domain/AlarmRecord.java
@@ -2,6 +2,7 @@
import org.hibernate.annotations.NotFound;
import org.hibernate.annotations.NotFoundAction;
+import org.well.well.util.SnowFlakeUtil;
import javax.persistence.*;
import java.io.Serializable;
@@ -44,6 +45,7 @@
public AlarmRecord(Long jobId, String alarmType,Integer alarmLevel, String alarmContent, String alarmValue,
Device device, String deviceCode, String wellCode, Date alarmTime,String alarmMsg) {
+ this.id= SnowFlakeUtil.getId();
this.jobId = jobId;
this.alarmType = alarmType;
this.alarmLevel = alarmLevel;
@@ -58,7 +60,7 @@
}
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
public Long getId() {
return id;
diff --git a/src/main/java/org/well/well/domain/LGGas.java b/src/main/java/org/well/well/domain/LGGas.java
index eb4d781..c186d21 100644
--- a/src/main/java/org/well/well/domain/LGGas.java
+++ b/src/main/java/org/well/well/domain/LGGas.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -22,7 +24,7 @@
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -99,6 +101,7 @@
}
public LGGas(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/LGLiquid.java b/src/main/java/org/well/well/domain/LGLiquid.java
index 67b1243..fb2ec82 100644
--- a/src/main/java/org/well/well/domain/LGLiquid.java
+++ b/src/main/java/org/well/well/domain/LGLiquid.java
@@ -20,7 +20,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Liquid.java b/src/main/java/org/well/well/domain/Liquid.java
index 51ef826..0b651d9 100644
--- a/src/main/java/org/well/well/domain/Liquid.java
+++ b/src/main/java/org/well/well/domain/Liquid.java
@@ -23,7 +23,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Methane.java b/src/main/java/org/well/well/domain/Methane.java
index e06e34c..ad90ba4 100644
--- a/src/main/java/org/well/well/domain/Methane.java
+++ b/src/main/java/org/well/well/domain/Methane.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -24,7 +26,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -128,6 +130,7 @@
}
public Methane(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/Well.java b/src/main/java/org/well/well/domain/Well.java
index 544a1f2..6a8daf2 100644
--- a/src/main/java/org/well/well/domain/Well.java
+++ b/src/main/java/org/well/well/domain/Well.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;
@@ -17,7 +19,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -72,6 +74,7 @@
}
public Well(String devCode, String wellCode,String desc, String status) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode = wellCode;
this.desc = desc;
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/src/main/java/org/well/well/domain/AlarmRecord.java b/src/main/java/org/well/well/domain/AlarmRecord.java
index 77c2cf1..7ffc8eb 100644
--- a/src/main/java/org/well/well/domain/AlarmRecord.java
+++ b/src/main/java/org/well/well/domain/AlarmRecord.java
@@ -2,6 +2,7 @@
import org.hibernate.annotations.NotFound;
import org.hibernate.annotations.NotFoundAction;
+import org.well.well.util.SnowFlakeUtil;
import javax.persistence.*;
import java.io.Serializable;
@@ -44,6 +45,7 @@
public AlarmRecord(Long jobId, String alarmType,Integer alarmLevel, String alarmContent, String alarmValue,
Device device, String deviceCode, String wellCode, Date alarmTime,String alarmMsg) {
+ this.id= SnowFlakeUtil.getId();
this.jobId = jobId;
this.alarmType = alarmType;
this.alarmLevel = alarmLevel;
@@ -58,7 +60,7 @@
}
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
public Long getId() {
return id;
diff --git a/src/main/java/org/well/well/domain/LGGas.java b/src/main/java/org/well/well/domain/LGGas.java
index eb4d781..c186d21 100644
--- a/src/main/java/org/well/well/domain/LGGas.java
+++ b/src/main/java/org/well/well/domain/LGGas.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -22,7 +24,7 @@
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -99,6 +101,7 @@
}
public LGGas(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/LGLiquid.java b/src/main/java/org/well/well/domain/LGLiquid.java
index 67b1243..fb2ec82 100644
--- a/src/main/java/org/well/well/domain/LGLiquid.java
+++ b/src/main/java/org/well/well/domain/LGLiquid.java
@@ -20,7 +20,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Liquid.java b/src/main/java/org/well/well/domain/Liquid.java
index 51ef826..0b651d9 100644
--- a/src/main/java/org/well/well/domain/Liquid.java
+++ b/src/main/java/org/well/well/domain/Liquid.java
@@ -23,7 +23,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Methane.java b/src/main/java/org/well/well/domain/Methane.java
index e06e34c..ad90ba4 100644
--- a/src/main/java/org/well/well/domain/Methane.java
+++ b/src/main/java/org/well/well/domain/Methane.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -24,7 +26,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -128,6 +130,7 @@
}
public Methane(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/Well.java b/src/main/java/org/well/well/domain/Well.java
index 544a1f2..6a8daf2 100644
--- a/src/main/java/org/well/well/domain/Well.java
+++ b/src/main/java/org/well/well/domain/Well.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;
@@ -17,7 +19,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -72,6 +74,7 @@
}
public Well(String devCode, String wellCode,String desc, String status) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode = wellCode;
this.desc = desc;
diff --git a/src/main/java/org/well/well/kafka/KafkaConsumer.java b/src/main/java/org/well/well/kafka/KafkaConsumer.java
index c2ad4bf..c0f154e 100644
--- a/src/main/java/org/well/well/kafka/KafkaConsumer.java
+++ b/src/main/java/org/well/well/kafka/KafkaConsumer.java
@@ -1,13 +1,58 @@
package org.well.well.kafka;
import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.kafka.listener.MessageListener;
+import org.well.well.base.AbstractResponse;
+import org.well.well.util.ResponseResolver;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
public class KafkaConsumer implements MessageListener {
+ private static final Logger LOGGER = LoggerFactory.getLogger(TopicApiUseKafkaListener.class);
+
+ private ClassPathXmlApplicationContext ac;
+ private static ExecutorService threadPool = Executors.newCachedThreadPool();
+
+ public void intContext() {
+ ClassPathXmlApplicationContext cac = new ClassPathXmlApplicationContext(
+ new String[]{"classpath:wellSensor/*.xml"});
+ cac.start();
+ ac = cac;
+ }
+
+ int i = 0;
@Override
public void onMessage(ConsumerRecord record) {
- String value = record.value();
- System.out.println(value);
+
+ try {
+ String value = record.value();
+
+ LOGGER.info("######收到kafka消息:" + value);
+
+ System.out.println("######收到kafka消息:" + value);
+ System.out.println("######消费数据条数:" + (++i));
+
+
+ AbstractResponse resp = ResponseResolver.makeResponse(value);
+ if (resp == null) return;
+ if (ac == null) intContext();
+ if (resp.getAc() == null) {
+ resp.setAc(ac);
+ }
+ resp.setContent(value);
+ threadPool.execute(resp);
+// resp.process(value);//对应的消息处理
+
+ Thread.sleep(100);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
}
}
diff --git a/pom.xml b/pom.xml
index 82e3252..fa57954 100644
--- a/pom.xml
+++ b/pom.xml
@@ -276,5 +276,11 @@
1.1.1.RELEASE
+
+ cn.hutool
+ hutool-captcha
+ 4.6.0
+
+
\ No newline at end of file
diff --git a/src/main/java/META-INF/MANIFEST.MF b/src/main/java/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/META-INF/MANIFEST.MF
+++ b/src/main/java/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
index 172042e..b4a7450 100644
--- a/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
+++ b/src/main/java/org/well/mysql/sink/META-INF/MANIFEST.MF
@@ -1,3 +1,45 @@
Manifest-Version: 1.0
+Class-Path: commons-beanutils-1.9.2.jar httpcore-4.2.1.jar javassist-3
+ .18.1-GA.jar velocity-1.7.jar concurrentlinkedhashmap-lru-1.2_jdk5.ja
+ r commons-compiler-2.7.6.jar jackson-jaxrs-json-provider-2.4.2.jar sp
+ ring-retry-1.1.3.RELEASE.jar json-lib-2.4-jdk15.jar commons-pool2-2.4
+ .2.jar activemq-jms-pool-5.14.5.jar java-sizeof-0.0.4.jar fastjson-1.
+ 1.15.jar spring-beans-4.0.6.RELEASE.jar jul-to-slf4j-1.7.7.jar flume-
+ ng-sdk-1.4.0.jar xbean-spring-4.2.jar hibernate-core-4.3.6.Final.jar
+ kafka-clients-0.11.0.1.jar jsr305-1.3.9.jar gson-2.2.2.jar activemq-p
+ ool-5.14.5.jar hibernate-jpa-2.1-api-1.0.0.Final.jar commons-logging-
+ 1.1.1.jar xml-apis-1.0.b2.jar log4j-1.2.16.jar classmate-1.0.0.jar lo
+ gback-classic-1.1.2.jar jackson-databind-2.4.2.jar avro-1.7.3.jar com
+ mons-io-2.4.jar flume-ng-core-1.4.0.jar commons-fileupload-1.3.1.jar
+ logback-core-1.1.2.jar joda-time-2.1.jar activemq-client-5.14.5.jar o
+ rika-core-1.4.5.jar jackson-jaxrs-base-2.4.2.jar ezmorph-1.0.6.jar sp
+ ring-kafka-1.1.1.RELEASE.jar mina-core-2.0.4.jar spring-context-suppo
+ rt-4.0.6.RELEASE.jar geronimo-j2ee-management_1.1_spec-1.0.1.jar comm
+ ons-httpclient-3.1.jar jackson-module-jaxb-annotations-2.4.2.jar libt
+ hrift-0.7.0.jar spring-tx-4.0.6.RELEASE.jar aopalliance-1.0.jar jboss
+ -transaction-api_1.2_spec-1.0.0.Final.jar jandex-1.1.0.Final.jar hawt
+ buf-1.11.jar guava-10.0.1.jar servlet-api-2.5-20110124.jar validation
+ -api-1.1.0.Final.jar netty-3.4.0.Final.jar commons-dbcp-1.4.jar sprin
+ g-jdbc-4.0.6.RELEASE.jar spring-aop-4.0.6.RELEASE.jar activemq-broker
+ -5.14.5.jar geronimo-jms_1.1_spec-1.1.1.jar mysql-connector-java-5.1.
+ 25.jar jcl-over-slf4j-1.7.7.jar spring-orm-4.0.6.RELEASE.jar flume-ng
+ -configuration-1.4.0.jar jansi-1.11.jar commons-lang3-3.3.2.jar dom4j
+ -1.6.1.jar spring-expression-4.0.6.RELEASE.jar spring-webmvc-4.0.6.RE
+ LEASE.jar lz4-1.3.0.jar spring-jms-3.2.8.RELEASE.jar commons-pool-1.5
+ .4.jar jetty-6.1.26.jar jackson-core-asl-1.9.3.jar hibernate-commons-
+ annotations-4.0.5.Final.jar slf4j-log4j12-1.6.1.jar jackson-mapper-as
+ l-1.9.3.jar jboss-logging-annotations-1.2.0.Beta1.jar commons-codec-1
+ .9.jar jackson-annotations-2.4.0.jar commons-cli-1.2.jar paranamer-2.
+ 3.jar avro-ipc-1.7.3.jar log4jdbc-remix-0.2.7.jar hibernate-validator
+ -5.1.2.Final.jar jetty-util-6.1.26.jar snappy-java-1.1.2.6.jar common
+ s-lang-2.5.jar spring-messaging-4.3.3.RELEASE.jar antlr-2.7.7.jar gex
+ in-rp-fastjson-1.0.0.1.jar gexin-rp-sdk-base-4.0.0.28.jar gexin-rp-sd
+ k-http-4.1.0.3.jar gexin-rp-sdk-template-4.0.0.22.jar protobuf-java-2
+ .5.0.jar slf4j-api-1.7.7.jar httpclient-4.2.1.jar activemq-spring-5.1
+ 4.5.jar spring-web-4.0.6.RELEASE.jar jackson-core-2.4.2.jar activemq-
+ openwire-legacy-5.14.5.jar spring-context-4.0.6.RELEASE.jar ojdbc6-11
+ .1.0.7.0.jar spring-core-4.0.6.RELEASE.jar jstl-1.2.jar jboss-logging
+ -3.1.3.GA.jar geronimo-jta_1.0.1B_spec-1.0.1.jar janino-2.7.6.jar com
+ mons-collections-3.2.1.jar
Main-Class: org.well.mysql.sink.WellSink
diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java
index 5eaec39..ffe1f64 100644
--- a/src/main/java/org/well/mysql/sink/WellSink.java
+++ b/src/main/java/org/well/mysql/sink/WellSink.java
@@ -114,13 +114,13 @@
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[]{"classpath:wellSensor/*.xml"});
ac.start();
- String temp =
- "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
+// String temp =
+// "{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018030001\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\": 90,\"datas\": [{\"uptime\":\"20180911222000\",\"level\":0.55}, {\"uptime\":\"20181111212001\",\"level\": 0.46}],\"logTime\":\"20190315010000\"},\"ts\":\"12345678901\"}";
// temp="{\"mType\":\"Event\",\"devType\":\"Concentrator\",\"devCode\":\"00003\",\"mBody\":{\"logTime\":\"20190605002024\",\"bType\":\"ConcentratorOnline\"},\"ts\":1559665224343}";
- temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
- temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"datas\":[{\"value\":\"00\",\"uptime\":\"20190605000000\"}],\"logTime\":\"201906010003002\",\"bType\":\"WellData\"},\"ts\":1559665802828}";
+// temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"112018040040\",\"mBody\":{\"cell\":9.9,\"datas\":[{\"level\":6.1892,\"uptime\":\"20200925173400\"}],\"logTime\":\"20190502000125\",\"bType\":\"LiquidData\"},\"ts\":1556726485336}";
// temp="{\"mType\":\"Event\",\"devType\":\"Liquid\",\"devCode\":\"11201900001\",\"mBody\":{\"eventType\":[\"LiquidPressureError\"],\"logTime\":\"20190510134635\",\"bType\":\"LiquidEvent\"},\"ts\":1557467195358}";
// temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019010212\",\"mBody\":{\"eventType\":[\"WellLowBatteryAlarm\"],\"logTime\":\"20190624114710\",\"bType\":\"WellEvent\"},\"ts\":1560484030810}";
// temp="{\"mType\":\"Data\",\"devType\":\"Locator\",\"devCode\":\"71201900001\",\"mBody\":{\"datas\":[{\"longitude\":126.243324343,\"latitude\":39.2546546546,\"uptime\":\"20190809140900\"}],\"logTime\":\"20190809141012\",\"bType\":\"LocatorData\"},\"ts\":1565331012453}";
@@ -153,7 +153,7 @@
// DeviceManager deviceManager = ac.getBean(DeviceManager.class);
// deviceManager.updateDeviceStatus();
- System.out.println("已经起来了,可以处理数据了。。。。。");
+ System.out.println("kafkaSink已启动,可以处理数据了。。。。。");
}
}
diff --git a/src/main/java/org/well/well/base/AbstractResponse.java b/src/main/java/org/well/well/base/AbstractResponse.java
index 51132d6..fe320fc 100644
--- a/src/main/java/org/well/well/base/AbstractResponse.java
+++ b/src/main/java/org/well/well/base/AbstractResponse.java
@@ -5,9 +5,13 @@
/**
* Created by lenovo on 2018/1/8.
*/
-public abstract class AbstractResponse implements IResponse {
+public abstract class AbstractResponse implements IResponse , Runnable {
private ClassPathXmlApplicationContext ac;
+
+ private String content;
+
+
public void process(String content){
}
@@ -19,4 +23,12 @@
public void setAc(ClassPathXmlApplicationContext ac) {
this.ac = ac;
}
+
+ public String getContent() {
+ return content;
+ }
+
+ public void setContent(String content) {
+ this.content = content;
+ }
}
diff --git a/src/main/java/org/well/well/core/util/DateUtils.java b/src/main/java/org/well/well/core/util/DateUtils.java
index 47b94be..4198af6 100644
--- a/src/main/java/org/well/well/core/util/DateUtils.java
+++ b/src/main/java/org/well/well/core/util/DateUtils.java
@@ -17,12 +17,15 @@
public static String DateFormat(String dataString) {
- String strymd = dataString.substring(0, 8);
- String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
- String strhms = dataString.substring(8);
- String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
- dataString =str1+str2;
- return dataString;
+// String strymd = dataString.substring(0, 8);
+// String str1 = strymd.substring(0, 4) + "-" + strymd.substring(4, 6) + "-" + strymd.substring(6, 8) + " ";
+// String strhms = dataString.substring(8);
+// String str2 =strhms.substring(0,2)+":"+strhms.substring(2,4)+":"+strhms.substring(4,6);
+// dataString =str1+str2;
+// return dataString;
+
+ String reg = "(\\d{4})(\\d{2})(\\d{2})(\\d{2})(\\d{2})(\\d{2})";
+ return dataString.replaceAll(reg, "$1-$2-$3 $4:$5:$6");
}
public static Date getSevenBeforeDate() throws ParseException {
diff --git a/src/main/java/org/well/well/domain/AlarmRecord.java b/src/main/java/org/well/well/domain/AlarmRecord.java
index 77c2cf1..7ffc8eb 100644
--- a/src/main/java/org/well/well/domain/AlarmRecord.java
+++ b/src/main/java/org/well/well/domain/AlarmRecord.java
@@ -2,6 +2,7 @@
import org.hibernate.annotations.NotFound;
import org.hibernate.annotations.NotFoundAction;
+import org.well.well.util.SnowFlakeUtil;
import javax.persistence.*;
import java.io.Serializable;
@@ -44,6 +45,7 @@
public AlarmRecord(Long jobId, String alarmType,Integer alarmLevel, String alarmContent, String alarmValue,
Device device, String deviceCode, String wellCode, Date alarmTime,String alarmMsg) {
+ this.id= SnowFlakeUtil.getId();
this.jobId = jobId;
this.alarmType = alarmType;
this.alarmLevel = alarmLevel;
@@ -58,7 +60,7 @@
}
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
public Long getId() {
return id;
diff --git a/src/main/java/org/well/well/domain/LGGas.java b/src/main/java/org/well/well/domain/LGGas.java
index eb4d781..c186d21 100644
--- a/src/main/java/org/well/well/domain/LGGas.java
+++ b/src/main/java/org/well/well/domain/LGGas.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -22,7 +24,7 @@
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -99,6 +101,7 @@
}
public LGGas(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/LGLiquid.java b/src/main/java/org/well/well/domain/LGLiquid.java
index 67b1243..fb2ec82 100644
--- a/src/main/java/org/well/well/domain/LGLiquid.java
+++ b/src/main/java/org/well/well/domain/LGLiquid.java
@@ -20,7 +20,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Liquid.java b/src/main/java/org/well/well/domain/Liquid.java
index 51ef826..0b651d9 100644
--- a/src/main/java/org/well/well/domain/Liquid.java
+++ b/src/main/java/org/well/well/domain/Liquid.java
@@ -23,7 +23,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
diff --git a/src/main/java/org/well/well/domain/Methane.java b/src/main/java/org/well/well/domain/Methane.java
index e06e34c..ad90ba4 100644
--- a/src/main/java/org/well/well/domain/Methane.java
+++ b/src/main/java/org/well/well/domain/Methane.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.sql.Timestamp;
@@ -24,7 +26,7 @@
private String snr;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -128,6 +130,7 @@
}
public Methane(String devCode, String wellCode, String strength, String cell, Timestamp uptime, Timestamp logtime) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode=wellCode;
this.strength = strength;
diff --git a/src/main/java/org/well/well/domain/Well.java b/src/main/java/org/well/well/domain/Well.java
index 544a1f2..6a8daf2 100644
--- a/src/main/java/org/well/well/domain/Well.java
+++ b/src/main/java/org/well/well/domain/Well.java
@@ -1,5 +1,7 @@
package org.well.well.domain;
+import org.well.well.util.SnowFlakeUtil;
+
import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;
@@ -17,7 +19,7 @@
private Date logtime;
@Id
- @GeneratedValue(strategy = GenerationType.IDENTITY)
+// @GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "ID")
public Long getDbId() {
return dbId;
@@ -72,6 +74,7 @@
}
public Well(String devCode, String wellCode,String desc, String status) {
+ this.dbId= SnowFlakeUtil.getId();
this.devCode = devCode;
this.wellCode = wellCode;
this.desc = desc;
diff --git a/src/main/java/org/well/well/kafka/KafkaConsumer.java b/src/main/java/org/well/well/kafka/KafkaConsumer.java
index c2ad4bf..c0f154e 100644
--- a/src/main/java/org/well/well/kafka/KafkaConsumer.java
+++ b/src/main/java/org/well/well/kafka/KafkaConsumer.java
@@ -1,13 +1,58 @@
package org.well.well.kafka;
import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.kafka.listener.MessageListener;
+import org.well.well.base.AbstractResponse;
+import org.well.well.util.ResponseResolver;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
public class KafkaConsumer implements MessageListener {
+ private static final Logger LOGGER = LoggerFactory.getLogger(TopicApiUseKafkaListener.class);
+
+ private ClassPathXmlApplicationContext ac;
+ private static ExecutorService threadPool = Executors.newCachedThreadPool();
+
+ public void intContext() {
+ ClassPathXmlApplicationContext cac = new ClassPathXmlApplicationContext(
+ new String[]{"classpath:wellSensor/*.xml"});
+ cac.start();
+ ac = cac;
+ }
+
+ int i = 0;
@Override
public void onMessage(ConsumerRecord record) {
- String value = record.value();
- System.out.println(value);
+
+ try {
+ String value = record.value();
+
+ LOGGER.info("######收到kafka消息:" + value);
+
+ System.out.println("######收到kafka消息:" + value);
+ System.out.println("######消费数据条数:" + (++i));
+
+
+ AbstractResponse resp = ResponseResolver.makeResponse(value);
+ if (resp == null) return;
+ if (ac == null) intContext();
+ if (resp.getAc() == null) {
+ resp.setAc(ac);
+ }
+ resp.setContent(value);
+ threadPool.execute(resp);
+// resp.process(value);//对应的消息处理
+
+ Thread.sleep(100);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
}
}
diff --git a/src/main/java/org/well/well/manager/AlarmRuleManager.java b/src/main/java/org/well/well/manager/AlarmRuleManager.java
index bf6849a..4e01795 100644
--- a/src/main/java/org/well/well/manager/AlarmRuleManager.java
+++ b/src/main/java/org/well/well/manager/AlarmRuleManager.java
@@ -52,9 +52,9 @@
if (DeviceTypeEnum.Liquid.toString().equals(devTypeName)) {
// SensorType sensorType = sensorTypeManager.get("000034");
alarmRule = findRuleByDevAndSensor(devCode, null);
- if (null != alarmRule) {
- ruleStr = String.valueOf(alarmRule.getHighValue());
- }
+
+ ruleStr =alarmRule!=null? String.valueOf(alarmRule.getHighValue()):"0.2";
+
} else if (DeviceTypeEnum.Noise.toString().equals(devTypeName)) {
SensorType sensorType = sensorTypeManager.get("000032");
alarmRule = findRuleByDevAndSensor(devCode, sensorType);
@@ -106,19 +106,8 @@
return ruleStr;
}
-// public Long getTenantIdBydep(String depId) {
-// try {
-// String sql = "SELECT TENANT_ID FROM sys_dept_detail s WHERE s.id=" + depId;
-// List