fix;

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

@@ -196,6 +196,15 @@ public class AdamRdmService {
         return thirdPartInfoVos;
     }
 
+    public boolean addThirdPartVoListByUid(String uid, List<AdamThirdPartInfoVo> vos, AdamThirdPartInfoVo vo) {
+        if (CollectionUtils.isEmpty(vos)) {
+            vos = Collections.singletonList(vo);
+        } else {
+            vos.add(vo);
+        }
+        return redisUtil.set(AdamRedisConst.INFO_THIRD_PARTY + uid, vos);
+    }
+
     public AdamThirdPartInfoVo getThirdPartVoByUidPlatform(String uid, String platform) {
         List<AdamThirdPartInfoVo> vos = this.getThirdPartVoListByUid(uid);
         if (!CollectionUtils.isEmpty(vos)) {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/DataMigrationProcessorService.java

@@ -2,7 +2,6 @@ package com.liquidnet.service.platform.service.impl.adam.dm;
 
 import com.liquidnet.service.adam.mapper.AdamUserMapper;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.mongodb.core.MongoTemplate;
 
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -30,8 +29,8 @@ public abstract class DataMigrationProcessorService {
 //    public static final String DB_PWD = "zhengzai!mYT";
 //    public static final String DB_NAME_PASSPORT = "devpassport";
 
-    @Autowired
-    public MongoTemplate mongoTemplate;
+//    @Autowired
+//    public MongoTemplate mongoTemplate;
     @Autowired
     public DMRdmService dmRdmService;
     @Autowired

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMAddressesProcessor.java

@@ -31,10 +31,10 @@ public class DMAddressesProcessor extends DataMigrationProcessorService {
     public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.addresses:{}", userMapper.executeForDM("adam_addresses"));
-            log.info("DM.flush.AdamAddressesVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamAddressesVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamAddressesVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamAddressesVo.class.getSimpleName()).getDeletedCount());
         }
 
-        String sqlCount = "select count(1) from addresses where created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()";
+        String sqlCount = "select count(1) from addresses where created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt));
         if (null != dg) {
             sqlCount = sqlCount + " and id%" + dG + "=" + dg;
         }
@@ -92,10 +92,13 @@ public class DMAddressesProcessor extends DataMigrationProcessorService {
 
                         addressesList.add(addresses);
                         vos.add(vo);
+
+                        dmRdmService.addAddressesVoByUid(uid, dmRdmService.getAddressesVoByUid(uid), vo);
                     }
+
                     if (addressesList.size() == 500 || (addressesList.size() > 0 && smFlg)) {
                         tl += addressesList.size();
-                        mongoTemplate.insert(vos, AdamAddressesVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamAddressesVo.class.getSimpleName());
                         log.info("DM.execute.limit.result:{}", dmAddressesService.saveBatch(addressesList));
                         vos.clear();
                         addressesList.clear();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMCollectionProcessor.java

@@ -32,10 +32,10 @@ public class DMCollectionProcessor extends DataMigrationProcessorService {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.collection:{}", userMapper.executeForDM("adam_collection"));
 
-            log.info("DM.flush.AdamCollectVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamCollectBaseVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamCollectVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamCollectBaseVo.class.getSimpleName()).getDeletedCount());
         }
 
-        String sqlCount = "select count(1) from user_collections where type='TICKET' and status=1 and content_id>=5722 and created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()";
+        String sqlCount = "select count(1) from user_collections where type='TICKET' and status=1 and content_id>=5722 and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt));
         if (null != dg) {
             sqlCount = sqlCount + " and id%" + dG + "=" + dg;
         }
@@ -89,7 +89,7 @@ public class DMCollectionProcessor extends DataMigrationProcessorService {
                     }
                     if (collectionList.size() == 500 || (collectionList.size() > 0 && smFlg)) {
                         tl += collectionList.size();
-                        mongoTemplate.insert(vos, AdamCollectBaseVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamCollectBaseVo.class.getSimpleName());
                         log.info("DM.execute.limit.result:{}", dmCollectionService.saveBatch(collectionList));
                         vos.clear();
                         collectionList.clear();

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

@@ -32,11 +32,11 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.enters:{}", userMapper.executeForDM("adam_enters"));
 
-            log.info("DM.flush.AdamEntersVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamEntersVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamEntersVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamEntersVo.class.getSimpleName()).getDeletedCount());
         }
 
         String sqlCount = "select count(1) from (\n" +
-                "                  select row_number() over (partition by user_id,type,idcode,name order by updated_at desc) rn,e.* from enters e where e.is_certification = 'yes' and e.deleted_at is null and created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()\n" +
+                "                  select row_number() over (partition by user_id,type,idcode,name order by updated_at desc) rn,e.* from enters e where e.is_certification = 'yes' and e.deleted_at is null and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt)) + "\n" +
                 "                  ) tk where tk.rn=1 ";
         if (null != dg) {
             sqlCount = sqlCount + " and id%" + dG + "=" + dg;
@@ -98,10 +98,11 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
                         if (enters.getType() == 1) {
                             dmRdmService.setCertification(1, enters.getIdCard(), enters.getName());
                         }
+                        dmRdmService.addEntersVoByUid(uid, dmRdmService.getEntersVoByUid(uid), vo);
                     }
                     if (entersList.size() == 500 || (entersList.size() > 0 && smFlg)) {
                         tl += entersList.size();
-                        mongoTemplate.insert(vos, AdamEntersVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamEntersVo.class.getSimpleName());
                         log.info("DM.execute.limit.result:{}", dmEntersService.saveBatch(entersList));
                         vos.clear();
                         entersList.clear();

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

@@ -186,7 +186,7 @@ public class DMMemberCodeProcessor extends DataMigrationProcessorService {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.member_code:{}", userMapper.executeForDM("adam_member_code"));
 
-            log.info("DM.flush.AdamMemberCodeVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberCodeVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamMemberCodeVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberCodeVo.class.getSimpleName()).getDeletedCount());
         }
 
         String sqlCount = "select count(1) from vip_card_codes where buy_order_id <> use_order_id or status=0";
@@ -253,7 +253,7 @@ public class DMMemberCodeProcessor extends DataMigrationProcessorService {
 //                }
                     if (memberCodeList.size() == 500) {
                         tl += memberCodeList.size();
-                        mongoTemplate.insert(vos, AdamMemberCodeVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamMemberCodeVo.class.getSimpleName());
                         log.info("DM.execute.limit.result:{}", dmMemberCodeService.saveBatch(memberCodeList));
                         vos.clear();
                         memberCodeList.clear();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMMemberOrderProcessor.java

@@ -56,10 +56,10 @@ public class DMMemberOrderProcessor extends DataMigrationProcessorService {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.member_order:{}", userMapper.executeForDM("adam_member_order"));
 
-            log.info("DM.flush.AdamMemberOrderVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberOrderVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamMemberOrderVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberOrderVo.class.getSimpleName()).getDeletedCount());
         }
 
-        String sqlCount = "select count(1) from user_vip_card_orders where status in (1,5) and created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()";
+        String sqlCount = "select count(1) from user_vip_card_orders where status in (1,5) and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt));
         if (null != dg) {
             sqlCount = sqlCount + " and id%" + dG + "=" + dg;
         }
@@ -129,10 +129,12 @@ public class DMMemberOrderProcessor extends DataMigrationProcessorService {
 
                         memberOrderList.add(memberOrder);
                         vos.add(vo);
+
+                        dmRdmService.addMemberOrderVoByUid(uid, dmRdmService.getMemberOrderVosByUid(uid), vo);
                     }
                     if (memberOrderList.size() == 500 || (memberOrderList.size() > 0 && smFlg)) {
                         tl += memberOrderList.size();
-                        mongoTemplate.insert(vos, AdamMemberOrderVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamMemberOrderVo.class.getSimpleName());
                         log.info("DM.execute.limit.result:{}", dmMemberOrderService.saveBatch(memberOrderList));
                         vos.clear();
                         memberOrderList.clear();

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

@@ -32,10 +32,10 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.real_name:{}", userMapper.executeForDM("adam_real_name"));
 
-            log.info("DM.flush.AdamRealInfoVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamRealInfoVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamRealInfoVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamRealInfoVo.class.getSimpleName()).getDeletedCount());
         }
 
-        String sqlCount = "select count(1) from user_real_name where id not in (9145,7456,7448,7197,7194,4137,4138,4139,269,261,262,263,264,265,266,267,251) and created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()";
+        String sqlCount = "select count(1) from user_real_name where id not in (9145,7456,7448,7197,7194,4137,4138,4139,269,261,262,263,264,265,266,267,251) and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt));
         if (null != dg) {
             sqlCount = sqlCount + " and id%" + dG + "=" + dg;
         }
@@ -96,11 +96,12 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
                         realNameList.add(realName);
                         vos.add(vo);
 
+                        dmRdmService.setRealInfoVoByUid(uid, vo);
                         dmRdmService.setCertification(1, realName.getIdCard(), realName.getName());
                     }
                     if (realNameList.size() == 500 || (realNameList.size() > 0 && smFlg)) {
                         tl += realNameList.size();
-                        mongoTemplate.insert(vos, AdamRealInfoVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamRealInfoVo.class.getSimpleName());
                         log.info("DM.execute.limit.result:{}", dmRealNameService.saveBatch(realNameList));
                         vos.clear();
                         realNameList.clear();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMThirdPartsProcessor.java

@@ -34,11 +34,11 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.third_party:{}", userMapper.executeForDM("adam_third_party"));
 
-            log.info("DM.flush.AdamThirdPartInfoVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamThirdPartInfoVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamThirdPartInfoVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamThirdPartInfoVo.class.getSimpleName()).getDeletedCount());
         }
 
         String sqlCount = "select count(1) from (\n" +
-                "                         select row_number() over (partition by uid,type order by created_at desc) rn,id,uid,open_id,avatar,nickname,type,created_at,updated_at from user_third_parts where `status`=1 and delete_tag in (0,1) and open_id<>'' and uid>0 and created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()\n" +
+                "                         select row_number() over (partition by uid,type order by created_at desc) rn,id,uid,open_id,avatar,nickname,type,created_at,updated_at from user_third_parts where `status`=1 and delete_tag in (0,1) and open_id<>'' and uid>0 and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt)) + "\n" +
                 "                     ) t where t.rn=1";
         if (null != dg) {
             sqlCount = sqlCount + " and id%" + dG + "=" + dg;
@@ -106,10 +106,11 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
                         vos.add(vo);
 
                         dmRdmService.setUidByPlatformOpenId(thirdParty.getPlatform(), thirdParty.getOpenId(), uid);
+                        dmRdmService.addThirdPartVoListByUid(uid, dmRdmService.getThirdPartVoListByUid(uid), vo);
                     }
                     if (thirdPartyList.size() == 500 || (thirdPartyList.size() > 0 && smFlg)) {
                         tl += thirdPartyList.size();
-                        mongoTemplate.insert(vos, AdamThirdPartInfoVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamThirdPartInfoVo.class.getSimpleName());
                         log.info("DM.execute.limit.result:{}", dmThirdPartyService.saveBatch(thirdPartyList));
                         vos.clear();
                         thirdPartyList.clear();

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

@@ -39,8 +39,8 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
             log.info("DM.flush.member:{}", userMapper.executeForDM("adam_member"));
             log.info("DM.flush.member_price:{}", userMapper.executeForDM("adam_member_price"));
 
-            log.info("DM.flush.AdamMemberVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberVo.class.getSimpleName()).getDeletedCount());
-            log.info("DM.flush.AdamMemberPriceVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberPriceVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamMemberVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamMemberPriceVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberPriceVo.class.getSimpleName()).getDeletedCount());
         }
         this.memberCardInfoHandler();
         this.memberCardPriceHandler();
@@ -90,7 +90,7 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
             dmRdmService.setMemberVoByMemberId(vo.getMemberId(), vo);
 
             memberMapper.insert(o);
-            mongoTemplate.insert(vo, AdamMemberVo.class.getSimpleName());
+//            mongoTemplate.insert(vo, AdamMemberVo.class.getSimpleName());
 
             log.info("DM.execute ----------------------------> end");
 
@@ -147,7 +147,7 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
             dmRdmService.setMemberPriceVoByMemberId(vo.getMemberId(), Collections.singletonList(vo));
 
             memberPriceMapper.insert(o);
-            mongoTemplate.insert(vo, AdamMemberPriceVo.class.getSimpleName());
+//            mongoTemplate.insert(vo, AdamMemberPriceVo.class.getSimpleName());
 
             log.info("DM.execute ----------------------------> end");
 
@@ -214,8 +214,8 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
     }
 
     private void setRdsCache() {
-        dmRdmService.setSwitch(AdamRedisConst.SWITCH_GRAY_LOGIN_SMS, 612543);
-        log.info("switch {}:{}", AdamRedisConst.SWITCH_GRAY_LOGIN_SMS, dmRdmService.getSwitch(AdamRedisConst.SWITCH_GRAY_LOGIN_SMS));
+//        dmRdmService.setSwitch(AdamRedisConst.SWITCH_GRAY_LOGIN_SMS, 612543);
+//        log.info("switch {}:{}", AdamRedisConst.SWITCH_GRAY_LOGIN_SMS, dmRdmService.getSwitch(AdamRedisConst.SWITCH_GRAY_LOGIN_SMS));
         List<String> nknameList = dmRdmService.getNknameList();
         log.info("init loader nknameList.size:{}", nknameList.size());
     }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMUserInformationProcessor.java

@@ -52,11 +52,11 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
             log.info("DM.flush.user:{}", userMapper.executeForDM("adam_user"));
             log.info("DM.flush.user_info:{}", userMapper.executeForDM("adam_user_info"));
 
-            log.info("DM.flush.AdamUserInfoVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamUserInfoVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamUserInfoVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamUserInfoVo.class.getSimpleName()).getDeletedCount());
         }
 
 //        String sqlCount = "select count(1) from users where delete_tag in (0,1) and length(mobile)=11 and created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()";
-        String sqlCount = "select count(1) from users where delete_tag in (0,1) and created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()";
+        String sqlCount = "select count(1) from users where delete_tag in (0,1) and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt));
         if (null != dg) {
             sqlCount = sqlCount + " and uid%" + dG + "=" + dg;
         }
@@ -144,11 +144,12 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
 
                         if (StringUtils.length(mobile) == 11) {
                             dmRdmService.setUidByMobile(mobile, uid);
+                            dmRdmService.setUserInfoVoByUid(uid, vo);
                         }
                     }
                     if (userList.size() == 500 || (userList.size() > 0 && smFlg)) {
                         tl += userList.size();
-                        mongoTemplate.insert(vos, AdamUserInfoVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamUserInfoVo.class.getSimpleName());
                         log.info("DM.execute.result:{} - {}", dmUserService.saveBatch(userList), dmUserInfoService.saveBatch(userInfoList));
                         vos.clear();
                         userList.clear();

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

 package com.liquidnet.service.platform.service.impl.adam.dm.processor;
 
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.adam.dto.vo.AdamUserMemberVo;
 import com.liquidnet.service.adam.entity.AdamUserMember;
 import com.liquidnet.service.platform.service.impl.adam.dm.DMUserMemberService;
@@ -9,8 +11,6 @@ import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.mongodb.core.query.Criteria;
-import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.sql.Connection;
@@ -32,10 +32,10 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.user_member:{}", userMapper.executeForDM("adam_user_member"));
 
-            log.info("DM.flush.AdamUserMemberVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamUserMemberVo.class.getSimpleName()).getDeletedCount());
+//            log.info("DM.flush.AdamUserMemberVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamUserMemberVo.class.getSimpleName()).getDeletedCount());
         }
 
-        String sqlCount = "select count(1) from user_cards where created_at" + (StringUtils.isBlank(incrDt) ? "<" : ">=") + "curdate()";
+        String sqlCount = "select count(1) from user_cards where created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt));
         if (null != dg) {
             sqlCount = sqlCount + " and id%" + dG + "=" + dg;
         }
@@ -101,7 +101,7 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
                     }
                     if (userMemberList.size() == 500 || (userMemberList.size() > 0 && smFlg)) {
                         tl += userMemberList.size();
-                        mongoTemplate.insert(vos, AdamUserMemberVo.class.getSimpleName());
+//                        mongoTemplate.insert(vos, AdamUserMemberVo.class.getSimpleName());
                         log.info("DM.execute.limit.result:{}", dmUserMemberService.saveBatch(userMemberList));
                         vos.clear();
                         userMemberList.clear();
@@ -116,6 +116,12 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
                 log.info("DM.execute.limit {},{} - handle.counts:{}", ls, pSize, tl);
             }
             log.info("DM.execute.counts:{}/{},{} ~ {} ----------------------------> end", pl, num, pSize, tl);
+
+            AdamUserMember max = dmUserMemberService.getOne(Wrappers.lambdaQuery(AdamUserMember.class).orderByDesc(AdamUserMember::getMemberNo));
+            log.info("DM.execute.setMaxMemberNo:{} ----------------------------> end", JsonUtils.toJson(max));
+            if (null != max) {
+                dmRdmService.setMaxMemberNo(Integer.parseInt(max.getMemberNo()));
+            }
         } catch (Exception e) {
             log.error("ex:getConnection,dG/dg:{}/{},msg:{}", dG, dg, e.getMessage());
         }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/NknameUtil.java

+package com.liquidnet.service.platform.utils;
+
+import com.liquidnet.commons.lang.util.CollectionUtil;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+
+public class NknameUtil {
+    private static final Logger log = LoggerFactory.getLogger(NknameUtil.class);
+
+    public static ArrayList<String> readForStringList() {
+        ArrayList<String> nknameList = CollectionUtil.arrayListString();
+        InputStream inputStream = null;
+        InputStreamReader inputStreamReader = null;
+        BufferedReader bufferedReader = null;
+        try {
+            inputStream = NknameUtil.class.getClassLoader().getResourceAsStream("META-FIL/library_nickname.csv");
+            inputStreamReader = new InputStreamReader(inputStream, StandardCharsets.UTF_8);
+            bufferedReader = new BufferedReader(inputStreamReader);
+
+            String line;
+            while ((line = bufferedReader.readLine()) != null) {
+                int l = StringUtils.length(line);
+                if (l == 0) {
+                    break;
+                }
+                if (l > 11) {
+                    line = line.substring(0, 11);
+                }
+                nknameList.add(line);
+            }
+        } catch (IOException e) {
+            log.error("Read CSV[library_nickname.csv] failure.", e);
+        } finally {
+            try {
+                if (null != bufferedReader) bufferedReader.close();
+                if (null != inputStreamReader) inputStreamReader.close();
+                if (null != inputStream) inputStream.close();
+            } catch (IOException e) {
+                log.error("Close stream failure.", e);
+            }
+        }
+        return nknameList;
+    }
+}
\ No newline at end of file