datasync / yoho-datasync-consumer · Commits

Go to a project

Authored by liangyi.chen@yoho.cn
Commit 70b387b632ad159fb3aa654bbb53fc4b7a755f6f 1 parent 9a17bc86

优化

Inline Side-by-side
Showing 10 changed files with 46 additions and 22 deletions
@@ -28,3 +28,7 @@ HELP.md @@ -28,3 +28,7 @@ HELP.md
28 starter/target/classes/application.yml 28 starter/target/classes/application.yml
29 common/target/ 29 common/target/
30 *.lst 30 *.lst
  31 +dal/target/
  32 +handler/target/
  33 +service/target/
  34 +starter/target/
@@ -9,8 +9,8 @@ public enum EventEnum { @@ -9,8 +9,8 @@ public enum EventEnum {
9 GRASS_ARTICLE_UPDATE("dealData", "GrassArticleListener.dealData"), 9 GRASS_ARTICLE_UPDATE("dealData", "GrassArticleListener.dealData"),
10 GRASS_ARTICLE_BLOCK_UPDATE("dealData", "GrassArticleBlockListener.dealData"), 10 GRASS_ARTICLE_BLOCK_UPDATE("dealData", "GrassArticleBlockListener.dealData"),
11 GRASS_ARTICLE_PRODUCT_UPDATE("dealData", "GrassArticleProductListener.dealData"), 11 GRASS_ARTICLE_PRODUCT_UPDATE("dealData", "GrassArticleProductListener.dealData"),
12 - GRASS_LABEL_GROUP_UPDATEDATA("DealData", "GrassLableGroupListener.dealData"),  
13 - GRASS_LABEL_UPDATEDATA("DealData", "GrassLableGroupListener.dealData"), 12 + GRASS_LABEL_GROUP_UPDATEDATA("DealData", "GrassLabelGroupListener.dealData"),
  13 + GRASS_LABEL_UPDATEDATA("DealData", "GrassLabelGroupListener.dealData"),
14 GRASS_ARTICLE_LABEL_UPDATE("dealData", "GrassArticleLabelListener.dealData"), 14 GRASS_ARTICLE_LABEL_UPDATE("dealData", "GrassArticleLabelListener.dealData"),
15 GRASS_USER_ACHIEVE_UPDATE("dealData", "GrassUserAchieveListener.dealData"); 15 GRASS_USER_ACHIEVE_UPDATE("dealData", "GrassUserAchieveListener.dealData");
16 16
@@ -15,8 +15,8 @@ import org.springframework.stereotype.Component; @@ -15,8 +15,8 @@ import org.springframework.stereotype.Component;
15 import javax.annotation.Resource; 15 import javax.annotation.Resource;
16 16
17 @Component 17 @Component
18 -@MqConsumerListerner(dbName = "yh_grass",tableName = "grass_lable_group")  
19 -public class GrassLableGroupListener extends AbstractMqListener<GrassLabelGroup> { 18 +@MqConsumerListerner(dbName = "yh_grass",tableName = "grass_label_group")
  19 +public class GrassLabelGroupListener extends AbstractMqListener<GrassLabelGroup> {
20 20
21 @Resource 21 @Resource
22 PublicLabelGroupService publicLabelGroupService; 22 PublicLabelGroupService publicLabelGroupService;
@@ -24,7 +24,7 @@ public class GrassLableGroupListener extends AbstractMqListener<GrassLabelGroup> @@ -24,7 +24,7 @@ public class GrassLableGroupListener extends AbstractMqListener<GrassLabelGroup>
24 @Resource 24 @Resource
25 AnnotationClassFactory annotationClassFactory; 25 AnnotationClassFactory annotationClassFactory;
26 26
27 - private static final Logger logger = LoggerFactory.getLogger(GrassLableGroupListener.class); 27 + private static final Logger logger = LoggerFactory.getLogger(GrassLabelGroupListener.class);
28 28
29 @Override 29 @Override
30 protected void deleteData(GrassLabelGroup sourceObject , Object checkResult) throws Exception { 30 protected void deleteData(GrassLabelGroup sourceObject , Object checkResult) throws Exception {
@@ -15,8 +15,8 @@ import org.springframework.stereotype.Component; @@ -15,8 +15,8 @@ import org.springframework.stereotype.Component;
15 import javax.annotation.Resource; 15 import javax.annotation.Resource;
16 16
17 @Component 17 @Component
18 -@MqConsumerListerner(dbName = "yh_grass",tableName = "grass_lable")  
19 -public class GrassLableListener extends AbstractMqListener<GrassLabel> { 18 +@MqConsumerListerner(dbName = "yh_grass",tableName = "grass_label")
  19 +public class GrassLabelListener extends AbstractMqListener<GrassLabel> {
20 20
21 @Resource 21 @Resource
22 PublicLabelService publicLabelService; 22 PublicLabelService publicLabelService;
@@ -24,7 +24,7 @@ public class GrassLableListener extends AbstractMqListener<GrassLabel> { @@ -24,7 +24,7 @@ public class GrassLableListener extends AbstractMqListener<GrassLabel> {
24 @Resource 24 @Resource
25 AnnotationClassFactory annotationClassFactory; 25 AnnotationClassFactory annotationClassFactory;
26 26
27 - private static final Logger logger = LoggerFactory.getLogger(GrassLableListener.class); 27 + private static final Logger logger = LoggerFactory.getLogger(GrassLabelListener.class);
28 28
29 @Override 29 @Override
30 protected void deleteData(GrassLabel sourceObject , Object checkResult) throws Exception { 30 protected void deleteData(GrassLabel sourceObject , Object checkResult) throws Exception {
@@ -98,13 +98,4 @@ @@ -98,13 +98,4 @@
98 </dependencyManagement> 98 </dependencyManagement>
99 99
100 100
101 - <build>  
102 - <plugins>  
103 - <plugin>  
104 - <groupId>org.springframework.boot</groupId>  
105 - <artifactId>spring-boot-maven-plugin</artifactId>  
106 - </plugin>  
107 - </plugins>  
108 - </build>  
109 -  
110 </project> 101 </project>
@@ -28,5 +28,25 @@ @@ -28,5 +28,25 @@
28 </dependency> 28 </dependency>
29 </dependencies> 29 </dependencies>
30 30
  31 + <build>
  32 + <finalName>yoho-datasync-consumer</finalName>
  33 + <plugins>
  34 + <plugin>
  35 + <groupId>org.springframework.boot</groupId>
  36 + <artifactId>spring-boot-maven-plugin</artifactId>
  37 + <executions>
  38 + <execution>
  39 + <goals>
  40 + <goal>repackage</goal>
  41 + </goals>
  42 + </execution>
  43 + </executions>
  44 + <configuration>
  45 + <mainClass>com.yoho.datasync.consumer.starter.YohoDatasyncConsumerApplication</mainClass>
  46 + </configuration>
  47 + </plugin>
  48 + </plugins>
  49 + </build>
  50 +
31 51
32 </project> 52 </project>
  1 +server:
  2 + servlet:
  3 + context-path: /datasync-consumer
1 spring: 4 spring:
2 profiles: 5 profiles:
3 active: dev 6 active: dev
@@ -38,7 +38,7 @@ @@ -38,7 +38,7 @@
38 </filter> 38 </filter>
39 <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> 39 <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
40 <!-- 按天回滚 daily --> 40 <!-- 按天回滚 daily -->
41 - <fileNamePattern>/Data/logs/yoho-datasync-producer/%d{yyyy-MM-dd}/info-log.log</fileNamePattern> 41 + <fileNamePattern>/Data/logs/yoho-datasync-consumer/%d{yyyy-MM-dd}/info-log.log</fileNamePattern>
42 <!-- 日志最大的保存天数 --> 42 <!-- 日志最大的保存天数 -->
43 <maxHistory>${maxHistory}</maxHistory> 43 <maxHistory>${maxHistory}</maxHistory>
44 </rollingPolicy> 44 </rollingPolicy>
1 rabbitmq: 1 rabbitmq:
2 - server: "192.168.102.216" 2 + server: yohoops-rabbit-common-service
3 port: 5672 3 port: 5672
4 username: "admin1" 4 username: "admin1"
5 password: "123qwe" 5 password: "123qwe"
@@ -8,7 +8,10 @@ rabbitmq: @@ -8,7 +8,10 @@ rabbitmq:
8 8
9 spring: 9 spring:
10 datasource: 10 datasource:
11 - url: jdbc:mysql://192.168.102.219:3306/yh_pcms?useUnicode=true&amp;characterEncoding=UTF-8 11 + url: jdbc:mysql://read.cms.yohoops.org:3306/yh_pcms?useUnicode=true&amp;characterEncoding=UTF-8
12 username: yh_test 12 username: yh_test
13 password: 9nm0icOwt6bMHjMusIfMLw== 13 password: 9nm0icOwt6bMHjMusIfMLw==
14 driver-class-name: com.mysql.jdbc.Driver 14 driver-class-name: com.mysql.jdbc.Driver
  15 +
  16 +logging:
  17 + config: classpath:logback-boot.xml
1 rabbitmq: 1 rabbitmq:
2 - server: "192.168.102.216" 2 + server: yohoops-rabbit-common-service
3 port: 5672 3 port: 5672
4 username: "admin1" 4 username: "admin1"
5 password: "123qwe" 5 password: "123qwe"
@@ -8,7 +8,10 @@ rabbitmq: @@ -8,7 +8,10 @@ rabbitmq:
8 8
9 spring: 9 spring:
10 datasource: 10 datasource:
11 - url: jdbc:mysql://192.168.102.219:3306/yh_pcms?useUnicode=true&amp;characterEncoding=UTF-8 11 + url: jdbc:mysql://read.cms.yohoops.org:3306/yh_pcms?useUnicode=true&amp;characterEncoding=UTF-8
12 username: yh_test 12 username: yh_test
13 password: 9nm0icOwt6bMHjMusIfMLw== 13 password: 9nm0icOwt6bMHjMusIfMLw==
14 driver-class-name: com.mysql.jdbc.Driver 14 driver-class-name: com.mysql.jdbc.Driver
  15 +
  16 +logging:
  17 + config: classpath:logback-boot.xml