Merge branch 'dev' into test

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

@@ -2,6 +2,7 @@ package com.liquidnet.service.adam.dto.vo;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.liquidnet.commons.lang.util.DateUtil;
+import com.liquidnet.service.adam.entity.AdamMemberOrder;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -74,4 +75,30 @@ public class AdamMemberOrderVo implements Serializable, Cloneable {
             return new AdamMemberOrderVo();
         }
     }
+
+    public AdamMemberOrderVo copy(AdamMemberOrder source) {
+        if (null == source) return this;
+        this.setOrderNo(source.getOrderNo());
+        this.setUid(source.getUid());
+        this.setMode(source.getMode());
+        this.setMemberId(source.getMemberId());
+        this.setMemberName(source.getMemberName());
+        this.setMemberPriceId(source.getMemberPriceId());
+        this.setDays(source.getDays());
+        this.setState(source.getState());
+        this.setMemberNo(source.getMemberNo());
+        this.setBirthday(source.getBirthday());
+        this.setDeviceFrom(source.getDeviceFrom());
+        this.setPayType(source.getPayType());
+        this.setPayNo(source.getPayNo());
+        this.setPaymentAt(source.getPaymentAt());
+        this.setCreatedAt(source.getCreatedAt());
+        this.setUpdatedAt(source.getUpdatedAt());
+        this.setPrice(source.getPrice());
+        this.setPricePaid(source.getPricePaid());
+        this.setClientIp(source.getClientIp());
+        this.setSource(source.getSource());
+        this.setVersion(source.getVersion());
+        return this;
+    }
 }

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/admin/AdamDMAdminController.java

@@ -35,68 +35,70 @@ public class AdamDMAdminController extends AdamBaseController {
     DMAddressesProcessor dmAddressesProcessor;
     @Autowired
     DMTracesInfoProcessor dmTracesInfoProcessor;
+    @Autowired
+    DMMemberOrderProcessor dmMemberOrderProcessor;
 
     @ApiOperationSupport(order = 0)
     @ApiOperation(value = "user")
     @GetMapping(value = {"user"})
-    public ResponseDto<Object> dataMigrationForUser(@RequestParam boolean flg) {
-        dmUserInformationProcessor.handler(flg);
+    public ResponseDto<Object> dataMigrationForUser() {
+        dmUserInformationProcessor.handler();
         return ResponseDto.success();
     }
 
     @ApiOperationSupport(order = 1)
     @ApiOperation(value = "tpa")
     @GetMapping(value = {"tpa"})
-    public ResponseDto<Object> dataMigrationForTpa(@RequestParam boolean flg) {
-        dmThirdPartsProcessor.handler(flg);
+    public ResponseDto<Object> dataMigrationForTpa() {
+        dmThirdPartsProcessor.handler();
         return ResponseDto.success();
     }
 
     @ApiOperationSupport(order = 2)
     @ApiOperation(value = "real")
     @GetMapping(value = {"real"})
-    public ResponseDto<Object> dataMigrationForReal(@RequestParam boolean flg) {
-        dmRealNameProcessor.handler(flg);
+    public ResponseDto<Object> dataMigrationForReal() {
+        dmRealNameProcessor.handler();
         return ResponseDto.success();
     }
 
     @ApiOperationSupport(order = 3)
     @ApiOperation(value = "vip")
     @GetMapping(value = {"vip"})
-    public ResponseDto<Object> dataMigrationForVip(@RequestParam boolean flg) {
-        dmUserMemberProcessor.handler(flg);
+    public ResponseDto<Object> dataMigrationForVip() {
+        dmUserMemberProcessor.handler();
         return ResponseDto.success();
     }
 
     @ApiOperationSupport(order = 4)
     @ApiOperation(value = "traces")
     @GetMapping(value = {"traces"})
-    public ResponseDto<Object> dataMigrationForTraces(@RequestParam boolean flg) {
-        dmTracesInfoProcessor.handler(flg);
+    public ResponseDto<Object> dataMigrationForTraces() {
+        dmTracesInfoProcessor.handler();
         return ResponseDto.success();
     }
 
     @ApiOperationSupport(order = 5)
     @ApiOperation(value = "enters")
     @GetMapping(value = {"enters"})
-    public ResponseDto<Object> dataMigrationForEnters(@RequestParam boolean flg) {
-        dmEntersProcessor.handler(flg);
+    public ResponseDto<Object> dataMigrationForEnters() {
+        dmEntersProcessor.handler();
         return ResponseDto.success();
     }
 
     @ApiOperationSupport(order = 6)
     @ApiOperation(value = "addr")
     @GetMapping(value = {"addr"})
-    public ResponseDto<Object> dataMigrationForAddr(@RequestParam boolean flg) {
-        dmAddressesProcessor.handler(flg);
+    public ResponseDto<Object> dataMigrationForAddr() {
+        dmAddressesProcessor.handler();
         return ResponseDto.success();
     }
 
     @ApiOperationSupport(order = 7)
     @ApiOperation(value = "morder")
     @GetMapping(value = {"morder"})
-    public ResponseDto<Object> dataMigrationForMOrder(@RequestParam boolean flg) {
-
+    public ResponseDto<Object> dataMigrationForMOrder() {
+        dmMemberOrderProcessor.handler();
         return ResponseDto.success();
     }
 }

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

@@ -16,6 +16,7 @@ import java.util.Arrays;
 import java.util.List;
 
 public abstract class DataMigrationProcessorService {
+    public static final String DM_FLG = "flg";
     public static final String DM_FLUSH = "flu";
     public static List<String> reUidList = new ArrayList<>();
     static {
@@ -29,11 +30,11 @@ public abstract class DataMigrationProcessorService {
     public PreparedStatement statement = null;
     public ResultSetImpl row = null;
 
-    public void handler(boolean flg) {
+    public void handler() {
         preHandler();
 
         try {
-            dataProcessing(flg);
+            dataProcessing();
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -54,7 +55,7 @@ public abstract class DataMigrationProcessorService {
         connection = DriverManager.getConnection(url, "readonly", "ZWDsf8Fy");
     }
 
-    protected abstract void dataProcessing(boolean flg);
+    protected abstract void dataProcessing();
 
     private void postHandler() {
         try {

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

@@ -17,6 +17,8 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
+import javax.servlet.http.HttpServletRequest;
+
 @Slf4j
 @Service
 public class DMAddressesProcessor extends DataMigrationProcessorService {
@@ -29,8 +31,10 @@ public class DMAddressesProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    protected void dataProcessing(boolean flg) {
-        if (StringUtils.isNotEmpty(ServletUtils.getRequest().getParameter(DM_FLUSH))) {
+    protected void dataProcessing() {
+        HttpServletRequest request = ServletUtils.getRequest();
+        String flg = StringUtils.defaultIfBlank(request.getParameter(DM_FLG), "");
+        if (StringUtils.isNotEmpty(request.getParameter(DM_FLUSH))) {
             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());
@@ -41,7 +45,7 @@ public class DMAddressesProcessor extends DataMigrationProcessorService {
 //                     1-id,2-user_id,3-user_name,4-user_phone,5-province,6-city,7-county,8-user_address,9-defaultDelivery,10-created_at
         String sql = sqlCount.replace("count(1)", field);
 
-        if (flg) {
+        if ("1".equals(flg)) {
             sqlCount += " and user_id in ('2026628','544327','1997335','773650','809406')";
             sql += " and user_id in ('2026628','544327','1997335','773650','809406')";
         }

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

@@ -17,6 +17,8 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
+import javax.servlet.http.HttpServletRequest;
+
 @Slf4j
 @Service
 public class DMEntersProcessor extends DataMigrationProcessorService {
@@ -29,8 +31,10 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    protected void dataProcessing(boolean flg) {
-        if (StringUtils.isNotEmpty(ServletUtils.getRequest().getParameter(DM_FLUSH))) {
+    protected void dataProcessing() {
+        HttpServletRequest request = ServletUtils.getRequest();
+        String flg = StringUtils.defaultIfBlank(request.getParameter(DM_FLG), "");
+        if (StringUtils.isNotEmpty(request.getParameter(DM_FLUSH))) {
             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());
@@ -41,7 +45,7 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
 //                     1-id,2-user_id,3-type,4-`name`,5-mobile,6-idcode,7-if(is_default='no', 0, 1),8-created_at
         String sql = sqlCount.replace("count(1)", field);
 
-        if (flg) {
+        if ("1".equals(flg)) {
             sqlCount += " and user_id in ('2026628','544327','1997335','773650','809406')";
             sql += " and user_id in ('2026628','544327','1997335','773650','809406')";
         }

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

+package com.liquidnet.service.adam.service.processor;
+
+import com.liquidnet.common.cache.redis.util.RedisUtil;
+import com.liquidnet.commons.lang.util.ServletUtils;
+import com.liquidnet.service.adam.dto.vo.AdamMemberOrderVo;
+import com.liquidnet.service.adam.entity.AdamMemberOrder;
+import com.liquidnet.service.adam.mapper.AdamMemberOrderMapper;
+import com.liquidnet.service.adam.service.DataMigrationProcessorService;
+import com.mysql.cj.jdbc.result.ResultSetImpl;
+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.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Service;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+@Service
+public class DMMemberOrderProcessor extends DataMigrationProcessorService {
+    @Autowired
+    MongoTemplate mongoTemplate;
+    @Autowired
+    RedisUtil redisUtil;
+    @Autowired
+    AdamMemberOrderMapper memberOrderMapper;
+
+    public static final String MEMBER_NAME = "摩登天空会员";
+    public static final String MEMBER_ID = "1";
+
+    // APPWEPAY|APPALIPAY|WAPWEPAY|WAPALIPAY|JSWEPAY|GIFT_CODE|VIP_CODE|APPLETWEPAY
+    public static final Map<String, String> dfMap = new HashMap<>();
+    public static final Map<String, String> ptMap = new HashMap<>();
+    static {
+        dfMap.put("APPWEPAY", "app");
+        dfMap.put("APPALIPAY", "app");
+        dfMap.put("WAPWEPAY", "wap");
+        dfMap.put("WAPALIPAY", "wap");
+        dfMap.put("JSWEPAY", "js");
+        dfMap.put("APPLETWEPAY", "applet");
+        dfMap.put("APPLETALIPAY", "applet");
+
+        ptMap.put("APPWEPAY", "wepay");
+        ptMap.put("APPALIPAY", "alipay");
+        ptMap.put("WAPWEPAY", "wepay");
+        ptMap.put("WAPALIPAY", "alipay");
+        ptMap.put("JSWEPAY", "wepay");
+        ptMap.put("APPLETWEPAY", "wepay");
+        ptMap.put("APPLETALIPAY", "alipay");
+    }
+
+    @SneakyThrows
+    @Override
+    protected void dataProcessing() {
+        HttpServletRequest request = ServletUtils.getRequest();
+        String flg = StringUtils.defaultIfBlank(request.getParameter(DM_FLG), "");
+        if (StringUtils.isNotEmpty(request.getParameter(DM_FLUSH))) {
+            log.info("DM.flush.user_member:{}", userMapper.executeForDM("adam_member_order"));
+
+            log.info("DM.flush.AdamUserMemberVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamMemberOrder.class.getSimpleName()).getDeletedCount());
+        }
+
+        String sqlCount = "select count(1) from user_vip_card_orders where status in (1,5)";
+        String field = "order_code,uid,order_sub_type,vip_card_price,price,status,card_number,birthday,pay_type,pay_code,pay_at,created_at,updated_at,client_ip,source,version";
+//      1-order_code,2-uid,3-order_sub_type,4-vip_card_price,5-price,6-status,7-card_number,8-birthday,
+//      9-pay_type,10-pay_code,11-pay_at,12-created_at,13-updated_at,14-client_ip,15-source,16-version
+        String sql = sqlCount.replace("count(1)", field);
+
+        if ("1".equals(flg)) {
+            sqlCount += " and uid in ('2026628','544327','1997335','773650','809406')";
+            sql += " and uid in ('2026628','544327','1997335','773650','809406')";
+        }
+
+        sql += " limit ?,?";
+
+        statement = connection.prepareStatement(sqlCount);
+        row = (ResultSetImpl) statement.executeQuery();
+        row.first();
+        int ct = row.getInt(1), pSize = 1000, num = 0;
+        log.info("DM数据迁移总数:{}", ct);
+
+
+        while (ct > 0) {
+            statement = connection.prepareStatement(sql);
+            statement.setInt(1, pSize * num);
+            statement.setInt(2, pSize);
+            row = (ResultSetImpl) statement.executeQuery();
+            log.info("DM.execute.limit:[pNo:{},pSize:{}]", pSize * num, pSize);
+            while (row.next()) {
+                String uid = row.getString(1);
+
+                if (!reUidList.contains(uid)) {
+                    AdamMemberOrder memberOrder = new AdamMemberOrder();
+                    memberOrder.setOrderNo(row.getString(1));
+                    memberOrder.setUid(row.getString(2));
+                    memberOrder.setMode(row.getInt(3));
+                    memberOrder.setPrice(row.getBigDecimal(4));
+                    memberOrder.setPricePaid(row.getBigDecimal(5));
+                    memberOrder.setMemberName(MEMBER_NAME);
+                    memberOrder.setMemberId(MEMBER_ID);
+                    memberOrder.setMemberPriceId(MEMBER_ID);
+                    memberOrder.setDays(365);
+                    memberOrder.setState(row.getInt(6));
+                    memberOrder.setMemberNo(row.getString(7));
+                    memberOrder.setBirthday(row.getString(8));
+                    String payType = row.getString(9);
+                    memberOrder.setDeviceFrom(dfMap.get(payType));
+                    memberOrder.setPayType(ptMap.get(payType));
+                    memberOrder.setPayNo(row.getString(10));
+                    memberOrder.setPaymentAt(row.getLocalDateTime(11));
+                    memberOrder.setCreatedAt(row.getLocalDateTime(12));
+                    memberOrder.setUpdatedAt(row.getLocalDateTime(13));
+                    memberOrder.setClientIp(row.getString(14));
+                    memberOrder.setSource(row.getString(15));
+                    memberOrder.setVersion(row.getString(16));
+
+                    AdamMemberOrderVo vo = AdamMemberOrderVo.getNew().copy(memberOrder);
+
+                    memberOrderMapper.insert(memberOrder);
+
+                    mongoTemplate.insert(vo, AdamMemberOrderVo.class.getSimpleName());
+                }
+            }
+
+
+            num++;
+            ct -= pSize;
+        }
+    }
+}

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

@@ -16,6 +16,8 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
+import javax.servlet.http.HttpServletRequest;
+
 @Slf4j
 @Service
 public class DMRealNameProcessor extends DataMigrationProcessorService {
@@ -28,8 +30,10 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    protected void dataProcessing(boolean flg) {
-        if (StringUtils.isNotEmpty(ServletUtils.getRequest().getParameter(DM_FLUSH))) {
+    protected void dataProcessing() {
+        HttpServletRequest request = ServletUtils.getRequest();
+        String flg = StringUtils.defaultIfBlank(request.getParameter(DM_FLG), "");
+        if (StringUtils.isNotEmpty(request.getParameter(DM_FLUSH))) {
             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());
@@ -40,7 +44,7 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
 //                     1-id,2-uid,3-real_name,4-id_card,5-created_at,6-updated_at
         String sql = sqlCount.replace("count(1)", field);
 
-        if (flg) {
+        if ("1".equals(flg)) {
             sqlCount += " and uid in ('2026628','544327','1997335','773650','809406')";
             sql += " and uid in ('2026628','544327','1997335','773650','809406')";
         }

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

@@ -16,6 +16,8 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
+import javax.servlet.http.HttpServletRequest;
+
 @Slf4j
 @Service
 public class DMThirdPartsProcessor extends DataMigrationProcessorService {
@@ -28,8 +30,10 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    protected void dataProcessing(boolean flg) {
-        if (StringUtils.isNotEmpty(ServletUtils.getRequest().getParameter(DM_FLUSH))) {
+    protected void dataProcessing() {
+        HttpServletRequest request = ServletUtils.getRequest();
+        String flg = StringUtils.defaultIfBlank(request.getParameter(DM_FLG), "");
+        if (StringUtils.isNotEmpty(request.getParameter(DM_FLUSH))) {
             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());
@@ -40,7 +44,7 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
 //                     1-uid,2-open_id,3-avatar,4-nickname,5-type,6-created_at,7-updated_at
         String sql = sqlCount.replace("count(1)", field);
 
-        if (flg) {
+        if ("1".equals(flg)) {
             sqlCount += " and uid in ('2026628','544327','1997335','773650','809406')";
             sql += " and uid in ('2026628','544327','1997335','773650','809406')";
         }

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

@@ -36,8 +36,9 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
     AdamMemberPriceMapper memberPriceMapper;
 
     @Override
-    protected void dataProcessing(boolean flg) {
-        if (StringUtils.isNotEmpty(ServletUtils.getRequest().getParameter(DM_FLUSH))) {
+    protected void dataProcessing() {
+        HttpServletRequest request = ServletUtils.getRequest();
+        if (StringUtils.isNotEmpty(request.getParameter(DM_FLUSH))) {
             log.info("DM.flush.member:{}", userMapper.executeForDM("adam_member"));
             log.info("DM.flush.member_price:{}", userMapper.executeForDM("adam_member_price"));
 

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

@@ -22,6 +22,7 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
+import javax.servlet.http.HttpServletRequest;
 import java.sql.SQLException;
 import java.util.*;
 
@@ -48,8 +49,10 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    protected void dataProcessing(boolean flg) {
-        if (StringUtils.isNotEmpty(ServletUtils.getRequest().getParameter(DM_FLUSH))) {
+    protected void dataProcessing() {
+        HttpServletRequest request = ServletUtils.getRequest();
+        String flg = StringUtils.defaultIfBlank(request.getParameter(DM_FLG), "");
+        if (StringUtils.isNotEmpty(request.getParameter(DM_FLUSH))) {
             log.info("DM.flush.user:{}", userMapper.executeForDM("adam_user"));
             log.info("DM.flush.user_info:{}", userMapper.executeForDM("adam_user_info"));
 
@@ -61,7 +64,7 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
 //                     1-uid,2-mobile,3-username,4-sex,5-birthday,6-area,7-sign,8-face_url,9-back_url,10-created_at,11-updated_at,12-is_complete,13-rong_cloud_token,14-rong_cloud_tag
         String sql = sqlCount.replace("count(1)", field);
 
-        if (flg) {
+        if ("1".equals(flg)) {
             sqlCount += "and mobile in ('13753596360','17701223310','18518013286','18548596019','15901093014')";
             sql += " and mobile in ('13753596360','17701223310','18518013286','18548596019','15901093014')";
         }

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

@@ -31,8 +31,10 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    protected void dataProcessing(boolean flg) {
-        if (StringUtils.isNotEmpty(ServletUtils.getRequest().getParameter(DM_FLUSH))) {
+    protected void dataProcessing() {
+        HttpServletRequest request = ServletUtils.getRequest();
+        String flg = StringUtils.defaultIfBlank(request.getParameter(DM_FLG), "");
+        if (StringUtils.isNotEmpty(request.getParameter(DM_FLUSH))) {
             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());
@@ -43,7 +45,7 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
 //                     1-uid,2-card_id,3-card_number,4-status,5-expired_at,6-created_at,7-updated_at
         String sql = sqlCount.replace("count(1)", field);
 
-        if (flg) {
+        if ("1".equals(flg)) {
             sqlCount += " and uid in ('2026628','544327','1997335','773650','809406')";
             sql += " and uid in ('2026628','544327','1997335','773650','809406')";
         }