过滤手机号

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/StoreSyncOperation.java

@@ -26,6 +26,7 @@ import com.gic.haoban.manage.service.service.SyncTaskService;
 import com.gic.mq.sdk.GicMQClient;
 import com.gic.redis.data.util.RedisUtil;
 import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -157,6 +158,9 @@ public class StoreSyncOperation implements BaseSyncOperation {
                 if (finalHasDatas.contains(mid.getClerkId())) {
                     return false;
                 }
+                if (StringUtils.isBlank(mid.getPhoneNumber())) {
+                    return false;
+                }
                 return true;
             }).map(clerkMid -> {
                 TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog();
@@ -169,6 +173,7 @@ public class StoreSyncOperation implements BaseSyncOperation {
                 dealLog.setWxEnterpriseId(wxEnterpriseId);
                 return dealLog;
             }).collect(Collectors.toList());
+            logger.info("过滤后导入clerk:{},{},{}", enterpriseId, dataId, JSONObject.toJSONString(preDealLogList));
             preDealService.insert(preDealLogList);
         }
         boolean b = preDealService.updateStatusByDataId(taskId, dataId, PreDealStatusEnum.computed.getVal(), "成功");

haoban-manage3-service/src/test/java/ServiceTest.java

@@ -169,6 +169,11 @@ public void sendMessage() {
         String s = qywxUserApiService.listSelfExternalUserid("ww9ede832a84b7ae5f", "01YQ-pcdYzF3K0So8uCFfkB5i8D5EBW7KcVB4qA8Ktk", "de2c33f2e8924ff884e0073ca2f2f711");
         System.out.println(JSONObject.toJSONString(s));
     }
-
+    @Test
+    public void extensionList1() {
+        UserDTO selfWorkWxUser = qywxUserApiService.getSelfWorkWxUser("ww9ede832a84b7ae5f", "65zze159pYb4ofbFsIREZ5X7d7iaZ-bWsVIQk2y5kTU", "de2c33f2e8924ff884e0073ca2f2f711");
+//        String s = qywxUserApiService.listSelfExternalUserid("ww9ede832a84b7ae5f", "01YQ-pcdYzF3K0So8uCFfkB5i8D5EBW7KcVB4qA8Ktk", "de2c33f2e8924ff884e0073ca2f2f711");
+        System.out.println(JSONObject.toJSONString(selfWorkWxUser));
+    }
 
 }