init

MaTao008 · Sep 30, 2018 · da9c789 · da9c789
1 parent 5ca4946
commit da9c789
Show file tree

Hide file tree

Showing 1,017 changed files with 199,291 additions and 0 deletions.
diff --git a/HEADER b/HEADER
@@ -0,0 +1,15 @@
+/*
+ * Copyright (C) 2018-2118 UCAR Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
diff --git a/LICENSE b/LICENSE
diff --git a/NOTICE b/NOTICE
@@ -0,0 +1,13 @@
+UCAR Datalink
+Copyright (C) 2018-2118 UCAR Inc
+
+* com.ucar.datalink.worker.api.compile.* 中的代码参考自Alibaba-Otter的com.alibaba.otter.shared.common.extension.*
+* com.ucar.datalink.worker.core.runtime.coordinate.*中的部分代码参考自Kafka-Connect(0.10.1.0)的org.apache.kafka.connect.runtime.distributed.*,具体如下
+   WorkerCoordinator       <->         WorkerCoordinator
+   WorkerGroupMember       <->         WorkerGroupMember
+   WorkerKeeper            <->         DistributedHerder
+* com.ucar.datalink.worker.core.rutime.*中的部分代码参考自Kafka-Connect(0.10.1.0)的org.apache.kafka.connect.runtime.*,具体如下
+   Worker                  <->         Worker
+   WorkerConfig            <->         WorkerConfig
+   WorkerTask              <->         WorkerTask
+
diff --git a/dl-biz/pom.xml b/dl-biz/pom.xml
@@ -0,0 +1,235 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.ucar.datalink</groupId>
+        <artifactId>datalink</artifactId>
+        <version>0.0.1</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>dl-biz</artifactId>
+    <packaging>jar</packaging>
+    <name>biz module for datalink</name>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.ucar.datalink</groupId>
+            <artifactId>dl-common</artifactId>
+            <version>0.0.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.ucar.datalink</groupId>
+            <artifactId>dl-domain</artifactId>
+            <version>0.0.1</version>
+        </dependency>
+
+        <!-- rdbms -->
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>jcl-over-slf4j</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
+
+        <!-- spring -->
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-beans</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-aop</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context-support</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-tx</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-jdbc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-orm</artifactId>
+        </dependency>
+
+        <!--mybatis-->
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis-spring</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.github.pagehelper</groupId>
+            <artifactId>pagehelper</artifactId>
+            <version>5.0.0</version>
+        </dependency>
+        <!--mysql-->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.microsoft.sqlserver</groupId>
+            <artifactId>sqljdbc4</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <version>42.1.4</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.tomcat</groupId>
+            <artifactId>tomcat-jdbc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>commons-collections</groupId>
+            <artifactId>commons-collections</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.ddlutils</groupId>
+            <artifactId>ddlutils</artifactId>
+            <version>1.0</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>commons-beanutils</groupId>
+                    <artifactId>commons-beanutils-core</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>commons-logging</groupId>
+                    <artifactId>commons-logging-api</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>dom4j</groupId>
+                    <artifactId>dom4j</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>stax</groupId>
+                    <artifactId>stax-api</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>commons-collections</groupId>
+                    <artifactId>commons-collections</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>commons-digester</groupId>
+                    <artifactId>commons-digester</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>commons-betwixt</groupId>
+                    <artifactId>commons-betwixt</artifactId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>commons-dbcp</artifactId>
+                    <groupId>commons-dbcp</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>commons-pool</artifactId>
+                    <groupId>commons-pool</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>commons-codec</artifactId>
+                    <groupId>commons-codec</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid</artifactId>
+            <version>1.0.31</version>
+        </dependency>
+
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.quartz-scheduler</groupId>
+            <artifactId>quartz</artifactId>
+            <version>2.1.4</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>commons-logging</artifactId>
+                    <groupId>commons-logging</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
+        <dependency>
+            <groupId>javax.mail</groupId>
+            <artifactId>javax.mail-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.sun.mail</groupId>
+            <artifactId>javax.mail</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpcore</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <filters>
+            <filter>src/main/filters/release.properties</filter>
+        </filters>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <filtering>true</filtering>
+            </resource>
+        </resources>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-jar-plugin</artifactId>
+                <configuration>
+                    <excludes>
+                        <exclude>**/conf/</exclude>
+                    </excludes>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>
diff --git a/dl-biz/src/main/filters/release.properties b/dl-biz/src/main/filters/release.properties
@@ -0,0 +1,9 @@
+maven.datasource.url=jdbc:mysql://localhost:3306/ucar_datalink
+maven.datasource.username=root
+maven.datasource.password=722b14aca98fcafe
+#默认报警间隔，单位s
+maven.biz.monitor.defaultIntervalTime=120
+#默认延迟阈值，单位ms，超过该阈值进行报警
+maven.biz.monitor.defaultDelayThreshold=2000
+#默认Jvm使用阈值，单位%
+maven.biz.monitor.defaultJvmUsageThreshold=90
diff --git a/dl-biz/src/main/java/com/ucar/datalink/biz/dal/AuthorityDAO.java b/dl-biz/src/main/java/com/ucar/datalink/biz/dal/AuthorityDAO.java
@@ -0,0 +1,19 @@
+package com.ucar.datalink.biz.dal;
+
+import com.ucar.datalink.domain.authority.RoleAuthorityInfo;
+
+import java.util.List;
+
+/**
+ * Created by sqq on 2017/5/4.
+ */
+public interface AuthorityDAO {
+
+    List<RoleAuthorityInfo> getListByRoleId(Long roleId);
+
+    Integer insert(RoleAuthorityInfo roleAuthorityInfo);
+
+    Integer delete(RoleAuthorityInfo roleAuthorityInfo);
+
+    Integer checkExist(RoleAuthorityInfo roleAuthorityInfo);
+}
diff --git a/dl-biz/src/main/java/com/ucar/datalink/biz/dal/GroupDAO.java b/dl-biz/src/main/java/com/ucar/datalink/biz/dal/GroupDAO.java
@@ -0,0 +1,26 @@
+package com.ucar.datalink.biz.dal;
+
+import com.ucar.datalink.domain.group.GroupInfo;
+import com.ucar.datalink.domain.statis.StatisDetail;
+
+import java.util.List;
+
+/**
+ * Created by lubiao on 2017/1/20.
+ */
+public interface GroupDAO {
+
+    List<GroupInfo> listAllGroups();
+
+    Integer insert(GroupInfo groupInfo);
+
+    Integer update(GroupInfo groupInfo);
+
+    Integer delete(Long id);
+
+    GroupInfo getById(Long id);
+
+    Integer groupCount();
+
+    List<StatisDetail> getCountByName();
+}
diff --git a/dl-biz/src/main/java/com/ucar/datalink/biz/dal/HomeStatisticDAO.java b/dl-biz/src/main/java/com/ucar/datalink/biz/dal/HomeStatisticDAO.java
@@ -0,0 +1,25 @@
+package com.ucar.datalink.biz.dal;
+
+import com.ucar.datalink.domain.statis.HomeStatistic;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Created by sqq on 2018/4/17.
+ */
+public interface HomeStatisticDAO {
+
+    List<HomeStatistic> taskSizeStatistic(@Param("groupId")Long groupId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+
+    List<HomeStatistic> taskRecordStatistic(@Param("groupId")Long groupId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+
+    List<HomeStatistic> taskDelayStatistic(@Param("groupId")Long groupId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+
+    List<HomeStatistic> workerJvmUsedStatistic(@Param("groupId")Long groupId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+
+    List<HomeStatistic> workerYoungGCCountStatistic(@Param("groupId")Long groupId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+
+    List<HomeStatistic> workerNetTrafficStatistic(@Param("groupId")Long groupId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+}
diff --git a/dl-biz/src/main/java/com/ucar/datalink/biz/dal/InterceptorDAO.java b/dl-biz/src/main/java/com/ucar/datalink/biz/dal/InterceptorDAO.java
@@ -0,0 +1,21 @@
+package com.ucar.datalink.biz.dal;
+
+import com.ucar.datalink.domain.interceptor.InterceptorInfo;
+
+import java.util.List;
+
+/**
+ * Created by user on 2017/3/22.
+ */
+public interface InterceptorDAO {
+
+    List<InterceptorInfo> getList();
+
+    InterceptorInfo findInterceptorById(Long id);
+
+    Integer insert(InterceptorInfo interceptorInfo);
+
+    Integer update(InterceptorInfo interceptorInfo);
+
+    Integer delete(Long id);
+}