fix:校验手机号、第三方账号是否已注册添加降级MDB操作;

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

@@ -10,6 +10,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Field;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -34,7 +35,15 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
 
     @Override
     public String getUidByMobile(String mobile) {
-        return (String) redisUtil.get(AdamRedisConst.IDENTITY_MOBILE.concat(mobile));
+        String key = AdamRedisConst.IDENTITY_MOBILE.concat(mobile);
+        String val = (String) redisUtil.get(key);
+        if (StringUtils.isEmpty(val)) {
+            Query query = Query.query(Criteria.where("mobile").is(mobile).and("state").is(1));
+            query.fields().include("uid");
+            AdamUserInfoVo vo = mongoTemplate.findOne(query, AdamUserInfoVo.class, AdamUserInfoVo.class.getSimpleName());
+            if (null != vo) redisUtil.set(key, vo.getUid());
+        }
+        return val;
     }
 
     @Override
@@ -49,7 +58,15 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
 
     @Override
     public String getUidByPlatformOpenId(String platform, String openId) {
-        return (String) redisUtil.get(AdamRedisConst.IDENTITY_THIRD_PARTY.concat(platform).concat(openId));
+        String key = AdamRedisConst.IDENTITY_THIRD_PARTY.concat(platform).concat(openId);
+        String val = (String) redisUtil.get(key);
+        if (StringUtils.isEmpty(val)) {
+            Query query = Query.query(Criteria.where("openId").is(openId).and("platform").is(platform).and("state").is(1));
+            query.fields().include("uid");
+            AdamThirdPartInfoVo vo = mongoTemplate.findOne(query, AdamThirdPartInfoVo.class, AdamThirdPartInfoVo.class.getSimpleName());
+            if (null != vo) redisUtil.set(key, vo.getUid());
+        }
+        return val;
     }
 
     @Override