dm for redis cache;

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-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();