Merge remote-tracking branch 'origin/dev' into dev

liquidnet-bus-api/liquidnet-service-adam-api/src/main/java/com/liquidnet/service/adam/dto/vo/AdamRealInfoVo.java

@@ -17,7 +17,7 @@ public class AdamRealInfoVo implements Serializable, Cloneable {
     @ApiModelProperty(position = 12, value = "证件号[50]")
     private String idCard;
     @ApiModelProperty(position = 13, value = "类型[1-大陆身份证,2-港澳通行证,3-台胞证,4-护照,5-军官证]")
-    private String type;
+    private Integer type;
     @ApiModelProperty(position = 14, value = "状态:1-正常")
     private Integer state;
 

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/bootstrap-prod.yml

@@ -6,7 +6,7 @@ liquidnet:
     username: user
     password: user123
   eureka:
-    host: 172.17.192.65:7001
+    host: 172.17.207.189:7001
 # end-dev-这里是配置信息基本值
 
 spring:

liquidnet-bus-client/liquidnet-client-job/src/main/resources/bootstrap-prod.yml

@@ -6,7 +6,7 @@ liquidnet:
     username: user
     password: user123
   eureka:
-    host: 172.17.192.65:7001
+    host: 172.17.207.189:7001
 # end-dev-这里是配置信息基本值
 
 spring:

liquidnet-bus-config/liquidnet-config/application-dev.yml

@@ -59,4 +59,9 @@ liquidnet:
       phpMallUrl: https://devmall.zhengzai.tv
       phpMerchantApiUrl: https://devmerchantapi.zhengzai.tv
       phpPassportUrl: https://devpassport.zhengzai.tv
+      shunfeng:
+        url: "https://butler-dev-ms.sf-express.com"
+        sk: 21e9a70f677a2bf29dfa2b3bead4f018
+        appid: 557104628450889728
+        custid: 7551234567
 #application-dev-end
\ No newline at end of file

liquidnet-bus-config/liquidnet-config/application-test.yml

@@ -63,3 +63,8 @@ liquidnet:
       phpMallUrl: https://testmall.zhengzai.tv
       phpMerchantApiUrl: https://testmerchantapi.zhengzai.tv
       phpPassportUrl: https://testpassport.zhengzai.tv
+      shunfeng:
+        url: "https://butler-dev-ms.sf-express.com"
+        sk: 21e9a70f677a2bf29dfa2b3bead4f018
+        appid: 557104628450889728
+        custid: 7551234567
\ No newline at end of file

liquidnet-bus-config/liquidnet-config/liquidnet-client-admin-web.yml

@@ -40,10 +40,10 @@ liquidnet:
       accessKeyId: LTAI4FxrURzMvvu9reFgwY5o
       accessKeySecret: Ym5tfAxOf2zX20MgjikLI3Wz3tlwVV
     shunfeng:
-      url: "https://butler-dev-ms.sf-express.com"
-      sk: 21e9a70f677a2bf29dfa2b3bead4f018
-      appid: 557104628450889728
-      custid: 7551234567
+      url: ${liquidnet.client.admin.shunfeng.url}
+      sk: ${liquidnet.client.admin.shunfeng.sk}
+      appid: ${liquidnet.client.admin.shunfeng.appid}
+      custid: ${liquidnet.client.admin.shunfeng.custid}
       jCompany: 北京正在映画互联网有限公司
       jContact: 姜秀龙
       jMobile: 15811009011

liquidnet-bus-do/liquidnet-service-adam-do/src/main/java/com/liquidnet/service/adam/entity/AdamRealName.java

@@ -32,7 +32,7 @@ public class AdamRealName implements Serializable {
     /**
      * 1-大陆身份证,2-港澳通行证,3-台胞证,4-护照,5-军官证
      */
-    private String type;
+    private Integer type;
 
     /**
      * 真实姓名

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/docu/db_ln_adam_initialdata.sql

@@ -85,7 +85,7 @@ create table adam_real_name
     mid          bigint unsigned auto_increment primary key,
     real_name_id varchar(64) not null,
     uid          varchar(64) not null,
-    type         enum ('1','2','3','4','5') not null default '1' comment '1-大陆身份证,2-港澳通行证,3-台胞证,4-护照,5-军官证',
+    type         tinyint     not null comment '1-大陆身份证,2-港澳通行证,3-台胞证,4-护照,5-军官证',
     name         varchar(60) not null comment '真实姓名',
     id_card      varchar(30) not null comment '证件号码',
     state        tinyint     not null comment '0-INIT,1-NORMAL,2-INVALID',

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/processor/DMEntersProcessor.java

@@ -90,6 +90,10 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
 
                         entersList.add(enters);
                         vos.add(vo);
+
+                        if (enters.getType() == 1) {
+                            adamRdmService.setCertification(1, enters.getIdCard(), enters.getName());
+                        }
                     }
                     if (entersList.size() == 500) {
                         tl += entersList.size();

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/processor/DMMemberCodeProcessor.java

@@ -244,7 +244,12 @@ public class DMMemberCodeProcessor extends DataMigrationProcessorService {
                     memberCode.setUseAt(row.getLocalDateTime(12));
 
                     memberCodeList.add(memberCode);
-                    vos.add(AdamMemberCodeVo.getNew().copy(memberCode));
+                    AdamMemberCodeVo vo = AdamMemberCodeVo.getNew().copy(memberCode);
+                    vos.add(vo);
+
+                    if (memberCode.getState() == 0) {
+                        adamRdmService.setMemberCodeVoByCode(memberCode.getCode(), vo);
+                    }
 //                }
                     if (memberCodeList.size() == 500) {
                         tl += memberCodeList.size();

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/processor/DMRealNameProcessor.java

@@ -78,7 +78,7 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
                         AdamRealName realName = new AdamRealName();
                         realName.setRealNameId(row.getString(1));
                         realName.setUid(uid);
-                        realName.setType("1");
+                        realName.setType(1);
                         realName.setName(row.getString(3));
                         realName.setIdCard(row.getString(4));
                         realName.setState(1);
@@ -87,13 +87,15 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
 
                         AdamRealInfoVo vo = AdamRealInfoVo.getNew();
                         vo.setUid(uid);
-                        vo.setType(realName.getType());
+                        vo.setType(1);
                         vo.setName(realName.getName());
                         vo.setIdCard(realName.getIdCard());
                         vo.setState(1);
 
                         realNameList.add(realName);
                         vos.add(vo);
+
+                        adamRdmService.setCertification(1, realName.getIdCard(), realName.getName());
                     }
                     if (realNameList.size() == 500) {
                         tl += realNameList.size();

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/processor/DMTracesInfoProcessor.java

@@ -22,6 +22,7 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
+import java.util.Collections;
 
 @Slf4j
 @Service
@@ -84,6 +85,8 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
 
             AdamMemberVo vo = AdamMemberVo.getNew().copy(o);
 
+            adamRdmService.setMemberVoByMemberId(vo.getMemberId(), vo);
+
             memberMapper.insert(o);
             mongoTemplate.insert(vo, AdamMemberVo.class.getSimpleName());
 
@@ -124,6 +127,8 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
 
             AdamMemberPriceVo vo = AdamMemberPriceVo.getNew().copy(o);
 
+            adamRdmService.setMemberPriceVoByMemberId(vo.getMemberId(), Collections.singletonList(vo));
+
             memberPriceMapper.insert(o);
             mongoTemplate.insert(vo, AdamMemberPriceVo.class.getSimpleName());
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/processor/DMUserMemberProcessor.java

@@ -95,6 +95,8 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
 
                         userMemberList.add(userMember);
                         vos.add(vo);
+
+                        adamRdmService.setUserMemberVoByUid(uid, vo);
                     }
                     if (userMemberList.size() == 500) {
                         tl += userMemberList.size();

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/resources/bootstrap-prod.yml

@@ -6,7 +6,7 @@ liquidnet:
     username: user
     password: user123
   eureka:
-    host: 172.17.192.65:7001
+    host: 172.17.207.189:7001
 # end-prod-这里是配置信息基本值
 
 spring:

liquidnet-bus-service/liquidnet-service-consumer/src/main/resources/bootstrap-prod.yml

@@ -6,7 +6,7 @@ liquidnet:
     username: user
     password: user123
   eureka:
-    host: 172.17.192.65:7001
+    host: 172.17.207.189:7001
 # end-prod-这里是配置信息基本值
 
 spring:

liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/src/main/resources/bootstrap-prod.yml

@@ -6,7 +6,7 @@ liquidnet:
     username: user
     password: user123
   eureka:
-    host: 172.17.192.65:7001
+    host: 172.17.207.189:7001
 # end-dev-这里是配置信息基本值
 
 spring:

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/resources/bootstrap-prod.yml

@@ -6,7 +6,7 @@ liquidnet:
     username: user
     password: user123
   eureka:
-    host: 172.17.192.65:7001
+    host: 172.17.207.189:7001
 # end-dev-这里是配置信息基本值
 
 spring:

liquidnet-bus-support/liquidnet-support-config/src/main/resources/application-prod.yml

@@ -11,7 +11,7 @@ liquidnet:
     path: /data/logs
     name: support-config
   eureka:
-    host: 172.17.192.65:7001
+    host: 172.17.207.189:7001
   rabbitmq:
     host: 127.0.0.1
     port: 5672

liquidnet-bus-support/liquidnet-support-eureka/src/main/resources/application-prod-server1.yml

@@ -23,7 +23,7 @@ spring:
 
 eureka:
   instance:
-    hostname: 172.17.192.65
+    hostname: 172.17.207.189
     preferIpAddress: true
     health-check-url: http://localhost:${server.port}${server.servlet.context-path}/actuator/health
     status-page-url: http://localhost:${server.port}${server.servlet.context-path}/actuator/info
@@ -38,7 +38,7 @@ eureka:
     register-with-eureka: true #禁止自己当做服务注册
     fetch-registry: true       #屏蔽注册信息
     serviceUrl:
-      defaultZone:  http://${spring.security.user.name}:${spring.security.user.password}@172.17.196.19:7001${server.servlet.context-path}/eureka
+      defaultZone:  http://${spring.security.user.name}:${spring.security.user.password}@172.17.207.189:7001${server.servlet.context-path}/eureka
 #  instance:
 #    prefer-ip-address: true
 #    instance-id: ${spring.application.name}:${server.port}

liquidnet-bus-support/liquidnet-support-eureka/src/main/resources/application-prod-server2.yml

-liquidnet:
-  logfile:
-    path: /data/logs
-    name: support-eureka
-    file-max-size: 200MB
-    pattern-file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    pattern-console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    pattern-rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
-    level: debug
-
-server:
-  port: 7001
-  servlet:
-    context-path: /eureka-server
-
-spring:
-  application:
-    name: liquidnet-support-eureka
-  security:
-    user:
-      name: user
-      password: user123
-
-eureka:
-  instance:
-    hostname: 172.17.196.19
-    preferIpAddress: true
-    health-check-url: http://localhost:${server.port}${server.servlet.context-path}/actuator/health
-    status-page-url: http://localhost:${server.port}${server.servlet.context-path}/actuator/info
-    home-page-url: http://localhost:${server.port}${server.servlet.context-path}
-    metadata-map:
-      configPath: ${server.servlet.context-path}
-      management.context-path: ${server.servlet.context-path}
-  server:
-    enable-self-preservation: false  # 设为false，关闭自我保护 #自我保护设置 解决Eureka Server不踢出已关停的节点的问题,同时客户端也需要配置
-    eviction-interval-timer-in-ms: 4000 # 清理间隔（单位毫秒，默认是60*1000）
-  client:
-    register-with-eureka: true #禁止自己当做服务注册
-    fetch-registry: true       #屏蔽注册信息
-    serviceUrl:
-      defaultZone:  http://${spring.security.user.name}:${spring.security.user.password}@172.17.192.65:7001${server.servlet.context-path}/eureka
-#  instance:
-#    prefer-ip-address: true
-#    instance-id: ${spring.application.name}:${server.port}
-#     hostname: localhost
-
-logging:
-  file:
-    name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
-    max-size: 200MB
-  pattern:
-    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
-    rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
-  level:
-    root: info
-    #以下是为指定包设置日志级别
-    com.liquidnet: ${liquidnet.logfile.level}
\ No newline at end of file

liquidnet-bus-support/liquidnet-support-zuul/src/main/resources/bootstrap-prod.yml

@@ -6,7 +6,7 @@ liquidnet:
     username: user
     password: user123
   eureka:
-    host: 172.17.192.65:7001
+    host: 172.17.207.189:7001
 # end-prod-这里是配置信息基本值
 
 spring: