Merge branch 'dev' of http://gitlab.zhengzai.tv/dongjingwei/liquidnet-bus-v1 into dev

liquidnet-bus-api/liquidnet-service-adam-api/src/main/java/com/liquidnet/service/adam/service/IAdamUserService.java

@@ -3,6 +3,7 @@ package com.liquidnet.service.adam.service;
 import com.liquidnet.service.adam.dto.AdamThirdPartParam;
 import com.liquidnet.service.adam.dto.vo.AdamRealInfoVo;
 import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
+import com.liquidnet.service.base.ResponseDto;
 
 /**
  * <p>
@@ -26,9 +27,9 @@ public interface IAdamUserService {
      * 第三方账号注册
      *
      * @param param
-     * @return AdamUserInfoVo
+     * @return ResponseDto<AdamUserInfoVo>
      */
-    AdamUserInfoVo register(AdamThirdPartParam param);
+    ResponseDto<AdamUserInfoVo> register(AdamThirdPartParam param);
 
     /**
      * 第三方账号绑定（不存在已绑定账号）

liquidnet-bus-config/liquidnet-config/application-dev.yml

@@ -96,6 +96,8 @@ liquidnet:
       service:
         appid: wx3498304dda39c5a1
         secret: a1307fab0a5f2380086a7c636f7339ea
+        token: tftipg1427706847
+        aeskey: LwVpmpuOcl7Mi3mtfQgBol11MsmMCATIqbPgHrEpDzx
     applet:
       strawberry:
         appid: wx08b852ade69f8019

liquidnet-bus-config/liquidnet-config/application-test.yml

@@ -96,6 +96,8 @@ liquidnet:
       service:
         appid: wx3498304dda39c5a1
         secret: a1307fab0a5f2380086a7c636f7339ea
+        token: tftipg1427706847
+        aeskey: LwVpmpuOcl7Mi3mtfQgBol11MsmMCATIqbPgHrEpDzx
     applet:
       strawberry:
         appid: wx08b852ade69f8019

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

@@ -281,14 +281,16 @@ public class AdamLoginController {
             if (!checkSmsCodeDto.isSuccess()) {
                 return checkSmsCodeDto;
             }
-            AdamUserInfoVo registerUserInfo = adamUserService.register(parameter);
-            if (null == registerUserInfo) {
-                return ResponseDto.failure(ErrorMapping.get("10000"));
+            ResponseDto<AdamUserInfoVo> registerRespDto = adamUserService.register(parameter);
+            if (!registerRespDto.isSuccess()) {
+                return ResponseDto.failure(registerRespDto.getCode(), registerRespDto.getMessage());
+            } else {
+                AdamUserInfoVo registerUserInfo = registerRespDto.getData();
+                loginInfoVo.setUserInfo(registerUserInfo);
+                loginInfoVo.setThirdPartInfo(adamRdmService.getThirdPartVoListByUid(registerUserInfo.getUid()));
+//                loginInfoVo.setMemberVo(adamRdmService.getMemberSimpleVo());
             }
             toRegister = true;
-            loginInfoVo.setUserInfo(registerUserInfo);
-            loginInfoVo.setThirdPartInfo(adamRdmService.getThirdPartVoListByUid(registerUserInfo.getUid()));
-//            loginInfoVo.setMemberVo(adamRdmService.getMemberSimpleVo());
         }
         loginInfoVo.setToken(this.ssoProcess(loginInfoVo.getUserInfo()));
         loginInfoVo.getUserInfo().setMobile(SensitizeUtil.custom(loginInfoVo.getUserInfo().getMobile(), 3, 4));

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

@@ -197,6 +197,24 @@ public class AdamRdmService {
         return redisUtil.set(AdamRedisConst.INFO_THIRD_PARTY + uid, vos);
     }
 
+    public boolean rmvThirdPartVoListByUid(String uid, List<AdamThirdPartInfoVo> vos, String platform) {
+        if (CollectionUtils.isEmpty(vos)) {
+            return true;
+        }
+        vos.removeIf(r -> r.getPlatform().equals(platform));
+        return redisUtil.set(AdamRedisConst.INFO_THIRD_PARTY + uid, vos);
+    }
+
+    public AdamThirdPartInfoVo getThirdPartVoByUidPlatform(List<AdamThirdPartInfoVo> vos, String platform) {
+        if (!CollectionUtils.isEmpty(vos)) {
+            Optional<AdamThirdPartInfoVo> any = vos.stream().filter(r -> r.getPlatform().equals(platform)).findAny();
+            if (any.isPresent()) {
+                return any.get();
+            }
+        }
+        return null;
+    }
+
     public AdamThirdPartInfoVo getThirdPartVoByUidPlatform(String uid, String platform) {
         List<AdamThirdPartInfoVo> vos = this.getThirdPartVoListByUid(uid);
         if (!CollectionUtils.isEmpty(vos)) {

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

@@ -15,6 +15,7 @@ import com.liquidnet.service.adam.service.IAdamUserService;
 import com.liquidnet.service.adam.util.NknameUtil;
 import com.liquidnet.service.adam.util.QueueUtils;
 import com.liquidnet.service.base.ErrorMapping;
+import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
 import lombok.extern.slf4j.Slf4j;
@@ -64,126 +65,116 @@ public class AdamUserServiceImpl implements IAdamUserService {
         LocalDateTime now = LocalDateTime.now();
         AdamUserInfoVo userInfoVo = null;
 
-//        if (RedisLockUtil.tryLock(LOCK_KEY_UREGISTER + mobile, 1, 5)) {
-//            String uid = adamRdmService.getUidByMobile(mobile);
-//            if (StringUtils.isEmpty(uid)) {
-                userInfoVo = AdamUserInfoVo.getNew();
-                userInfoVo.setUid(IDGenerator.nextSnowId() + "");
-                userInfoVo.setMobile(mobile);
-                userInfoVo.setNickname(NknameUtil.randomNkname());
-                userInfoVo.setIsComplete(0);
-                userInfoVo.setState(1);
-                userInfoVo.setQrCode("lN".concat(userInfoVo.getUid()).concat(RandomStringUtils.randomAlphanumeric(5).toUpperCase()));
-                userInfoVo.setCreateAt(now);
+        userInfoVo = AdamUserInfoVo.getNew();
+        userInfoVo.setUid(IDGenerator.nextSnowId() + "");
+        userInfoVo.setMobile(mobile);
+        userInfoVo.setNickname(NknameUtil.randomNkname());
+        userInfoVo.setIsComplete(0);
+        userInfoVo.setState(1);
+        userInfoVo.setQrCode("lN".concat(userInfoVo.getUid()).concat(RandomStringUtils.randomAlphanumeric(5).toUpperCase()));
+        userInfoVo.setCreateAt(now);
 
 //                long s = System.currentTimeMillis();
 //                mongoTemplate.insert(userInfoVo, AdamUserInfoVo.class.getSimpleName());
 //                log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
 
-                long s = System.currentTimeMillis();
-                adamRdmService.setUidByMobile(mobile, userInfoVo.getUid());
-                adamRdmService.setUserInfoVoByUid(userInfoVo.getUid(), userInfoVo);
-                log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
+        long s = System.currentTimeMillis();
+        adamRdmService.setUidByMobile(mobile, userInfoVo.getUid());
+        adamRdmService.setUserInfoVoByUid(userInfoVo.getUid(), userInfoVo);
+        log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
 
-                LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
-                LinkedList<Object[]> initUserObjs = CollectionUtil.linkedListObjectArr(),
-                        initUserInfoObjs = CollectionUtil.linkedListObjectArr();
+        LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> initUserObjs = CollectionUtil.linkedListObjectArr(),
+                initUserInfoObjs = CollectionUtil.linkedListObjectArr();
 
-                s = System.currentTimeMillis();
-                toMqSqls.add(SqlMapping.get("adam_user.add"));
-                initUserObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getMobile(), userInfoVo.getState(), 0, now});
-                toMqSqls.add(SqlMapping.get("adam_user_info.add"));
-                initUserInfoObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getNickname(), null, userInfoVo.getQrCode()});
-                log.debug("#SQL.GET耗时:{}ms", System.currentTimeMillis() - s);
-
-                queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UREGISTER.getKey(),
-                        SqlMapping.gets(toMqSqls, initUserObjs, initUserInfoObjs)
-                );
-                log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
-//            } else {
-//                userInfoVo = adamRdmService.getUserInfoVoByUid(uid);
-//            }
-//            RedisLockUtil.unlock(LOCK_KEY_UREGISTER + mobile);
-//        }
+        s = System.currentTimeMillis();
+        toMqSqls.add(SqlMapping.get("adam_user.add"));
+        initUserObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getMobile(), userInfoVo.getState(), 0, now});
+        toMqSqls.add(SqlMapping.get("adam_user_info.add"));
+        initUserInfoObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getNickname(), null, userInfoVo.getQrCode()});
+        log.debug("#SQL.GET耗时:{}ms", System.currentTimeMillis() - s);
+
+        queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UREGISTER.getKey(),
+                SqlMapping.gets(toMqSqls, initUserObjs, initUserInfoObjs)
+        );
+        log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
         return userInfoVo;
     }
 
     @Override
 //    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
-    public AdamUserInfoVo register(AdamThirdPartParam param) {
+    public ResponseDto<AdamUserInfoVo> register(AdamThirdPartParam param) {
         LocalDateTime now = LocalDateTime.now();
         AdamUserInfoVo userInfoVo = null;
 
-//        if (RedisLockUtil.tryLock(LOCK_KEY_UREGISTER + param.getOpenId() + param.getPlatform(), 1, 5)) {
-//            String uid = adamRdmService.getUidByPlatformOpenId(param.getPlatform(), param.getOpenId());
-//            if (StringUtils.isEmpty(uid)) {
-                long s = System.currentTimeMillis();
-                String uid = adamRdmService.getUidByMobile(param.getMobile());
-                log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
-                LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
-                LinkedList<Object[]> initUserObjs = CollectionUtil.linkedListObjectArr(),
-                        initUserInfoObjs = CollectionUtil.linkedListObjectArr(),
-                        initThirdPartObjs = CollectionUtil.linkedListObjectArr();
-                if (StringUtils.isEmpty(uid)) {// 手机号未注册
-                    userInfoVo = AdamUserInfoVo.getNew();
-
-                    userInfoVo.setUid(IDGenerator.nextSnowId() + "");
-                    userInfoVo.setMobile(param.getMobile());
-                    userInfoVo.setNickname(param.getNickname());
-                    userInfoVo.setAvatar(param.getAvatar());
-                    userInfoVo.setIsComplete(0);
-                    userInfoVo.setState(1);
-                    userInfoVo.setQrCode("lN".concat(userInfoVo.getUid()).concat(RandomStringUtils.randomAlphanumeric(5).toUpperCase()));
-                    userInfoVo.setCreateAt(now);
+        long s = System.currentTimeMillis();
+        String uid = adamRdmService.getUidByMobile(param.getMobile());
+        log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
+        LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> initUserObjs = CollectionUtil.linkedListObjectArr(),
+                initUserInfoObjs = CollectionUtil.linkedListObjectArr(),
+                initThirdPartObjs = CollectionUtil.linkedListObjectArr();
+        if (StringUtils.isEmpty(uid)) {// 手机号未注册
+            userInfoVo = AdamUserInfoVo.getNew();
+
+            userInfoVo.setUid(IDGenerator.nextSnowId() + "");
+            userInfoVo.setMobile(param.getMobile());
+            userInfoVo.setNickname(param.getNickname());
+            userInfoVo.setAvatar(param.getAvatar());
+            userInfoVo.setIsComplete(0);
+            userInfoVo.setState(1);
+            userInfoVo.setQrCode("lN".concat(userInfoVo.getUid()).concat(RandomStringUtils.randomAlphanumeric(5).toUpperCase()));
+            userInfoVo.setCreateAt(now);
 
 //                    s = System.currentTimeMillis();
 //                    mongoTemplate.insert(userInfoVo, AdamUserInfoVo.class.getSimpleName());
 //                    log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
 
-                    userInfoVo.setMobile(SensitizeUtil.custom(param.getMobile(), 3, 4));
+            userInfoVo.setMobile(SensitizeUtil.custom(param.getMobile(), 3, 4));
+
+            adamRdmService.setUserInfoVoByUid(userInfoVo.getUid(), userInfoVo);
 
-                    adamRdmService.setUserInfoVoByUid(userInfoVo.getUid(), userInfoVo);
+            toMqSqls.add(SqlMapping.get("adam_user.add"));
+            initUserObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getMobile(), userInfoVo.getState(), now});
+            toMqSqls.add(SqlMapping.get("adam_user_info.add"));
+            initUserInfoObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getNickname(), userInfoVo.getAvatar(), userInfoVo.getQrCode()});
+
+            AdamThirdPartInfoVo thirdPartInfoVo = AdamThirdPartInfoVo.getNew();
+            BeanUtils.copyProperties(param, thirdPartInfoVo);
+            thirdPartInfoVo.setCreatedAt(now);
+            thirdPartInfoVo.setUid(userInfoVo.getUid());
+            thirdPartInfoVo.setState(1);// 1-绑定
 
-                    toMqSqls.add(SqlMapping.get("adam_user.add"));
-                    initUserObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getMobile(), userInfoVo.getState(), now});
-                    toMqSqls.add(SqlMapping.get("adam_user_info.add"));
-                    initUserInfoObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getNickname(), userInfoVo.getAvatar(), userInfoVo.getQrCode()});
-//                } else {
 //                    s = System.currentTimeMillis();
-//                    userInfoVo = adamRdmService.getUserInfoVoByUid(uid);
-//                    log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
-//                    toMqSqls.add(SqlMapping.get("adam_user.add"));
-//                    toMqSqls.add(SqlMapping.get("adam_user_info.add"));
-//                }
-
-                AdamThirdPartInfoVo thirdPartInfoVo = AdamThirdPartInfoVo.getNew();
-                BeanUtils.copyProperties(param, thirdPartInfoVo);
-                thirdPartInfoVo.setCreatedAt(now);
-                thirdPartInfoVo.setUid(userInfoVo.getUid());
-                thirdPartInfoVo.setState(1);// 1-绑定
-
-//                s = System.currentTimeMillis();
-//                mongoTemplate.insert(thirdPartInfoVo, AdamThirdPartInfoVo.class.getSimpleName());
-//                log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
+//                    mongoTemplate.insert(thirdPartInfoVo, AdamThirdPartInfoVo.class.getSimpleName());
+//                    log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
 
-                toMqSqls.add(SqlMapping.get("adam_third_party.add"));
-                initThirdPartObjs.add(new Object[]{thirdPartInfoVo.getUid(), thirdPartInfoVo.getOpenId(), thirdPartInfoVo.getAvatar(), thirdPartInfoVo.getNickname(), thirdPartInfoVo.getPlatform(), thirdPartInfoVo.getState(), thirdPartInfoVo.getCreatedAt()});
+            toMqSqls.add(SqlMapping.get("adam_third_party.add"));
+            initThirdPartObjs.add(new Object[]{thirdPartInfoVo.getUid(), thirdPartInfoVo.getOpenId(), thirdPartInfoVo.getAvatar(), thirdPartInfoVo.getNickname(), thirdPartInfoVo.getPlatform(), thirdPartInfoVo.getState(), thirdPartInfoVo.getCreatedAt()});
 
-                s = System.currentTimeMillis();
-                adamRdmService.setUidByPlatformOpenId(param.getPlatform(), param.getOpenId(), uid);
-                log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
+            s = System.currentTimeMillis();
+            adamRdmService.setUidByPlatformOpenId(param.getPlatform(), param.getOpenId(), uid);
+            log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
 
-                s = System.currentTimeMillis();
-                queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UREGISTER.getKey(),
-                        SqlMapping.gets(toMqSqls, initUserObjs, initUserInfoObjs, initThirdPartObjs)
-                );
-                log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
-            } else {
+            s = System.currentTimeMillis();
+            queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UREGISTER.getKey(),
+                    SqlMapping.gets(toMqSqls, initUserObjs, initUserInfoObjs, initThirdPartObjs)
+            );
+            log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
+
+        } else {// 手机号已注册
+            // 判断已注册用户是否绑定同平台的第三方账号
+            AdamThirdPartInfoVo thirdPartVo = adamRdmService.getThirdPartVoByUidPlatform(uid, param.getPlatform());
+            if (null == thirdPartVo) {// 未绑定
+                this.bindTpa(uid, param);
+                userInfoVo = adamRdmService.getUserInfoVoByUid(uid);
+            } else if (thirdPartVo.getOpenId().equals(param.getOpenId())) {
                 userInfoVo = adamRdmService.getUserInfoVoByUid(uid);
+            } else {
+                return ResponseDto.failure(ErrorMapping.get("10007"));
             }
-//            RedisLockUtil.unlock(LOCK_KEY_UREGISTER + param.getOpenId() + param.getPlatform());
-//        }
-        return userInfoVo;
+        }
+        return ResponseDto.success(userInfoVo);
     }
 
     @Override
@@ -206,7 +197,8 @@ public class AdamUserServiceImpl implements IAdamUserService {
         log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
 
         s = System.currentTimeMillis();
-        adamRdmService.delThirdPartVoListByUid(uid);
+//        adamRdmService.delThirdPartVoListByUid(uid);
+        adamRdmService.addThirdPartVoListByUid(uid, adamRdmService.getThirdPartVoListByUid(uid), thirdPartInfoVo);
         log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
 
         s = System.currentTimeMillis();
@@ -226,22 +218,24 @@ public class AdamUserServiceImpl implements IAdamUserService {
 
         LocalDateTime now = LocalDateTime.now();
 
-        AdamThirdPartInfoVo thirdPartInfoVo = AdamThirdPartInfoVo.getNew();
-        BeanUtils.copyProperties(param, thirdPartInfoVo);
-        thirdPartInfoVo.setCreatedAt(now);
-        thirdPartInfoVo.setUid(bindUid);
-        thirdPartInfoVo.setState(1);// 1-绑定
+        AdamThirdPartInfoVo bindThirdPartVo = AdamThirdPartInfoVo.getNew();
+        BeanUtils.copyProperties(param, bindThirdPartVo);
+        bindThirdPartVo.setCreatedAt(now);
+        bindThirdPartVo.setUid(bindUid);
+        bindThirdPartVo.setState(1);// 1-绑定
 
-//        mongoTemplate.insert(thirdPartInfoVo, AdamThirdPartInfoVo.class.getSimpleName());
+//        mongoTemplate.insert(bindThirdPartVo, AdamThirdPartInfoVo.class.getSimpleName());
 
         adamRdmService.setUidByPlatformOpenId(param.getPlatform(), param.getOpenId(), bindUid);
 
-        adamRdmService.delThirdPartVoListByUid(bindUid);
+//        adamRdmService.delThirdPartVoListByUid(bindUid);
+        adamRdmService.rmvThirdPartVoListByUid(unBindUid, adamRdmService.getThirdPartVoListByUid(unBindUid), param.getPlatform());
+        adamRdmService.addThirdPartVoListByUid(bindUid, adamRdmService.getThirdPartVoListByUid(bindUid), bindThirdPartVo);
 
         queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UCENTER.getKey(),
                 SqlMapping.get(
                         "adam_third_party.add",
-                        thirdPartInfoVo.getUid(), thirdPartInfoVo.getOpenId(), thirdPartInfoVo.getAvatar(), thirdPartInfoVo.getNickname(), thirdPartInfoVo.getPlatform(), thirdPartInfoVo.getState(), thirdPartInfoVo.getCreatedAt()
+                        bindThirdPartVo.getUid(), bindThirdPartVo.getOpenId(), bindThirdPartVo.getAvatar(), bindThirdPartVo.getNickname(), bindThirdPartVo.getPlatform(), bindThirdPartVo.getState(), bindThirdPartVo.getCreatedAt()
                 )
         );
     }
@@ -272,18 +266,22 @@ public class AdamUserServiceImpl implements IAdamUserService {
 //            adamRdmService.delUidByPlatformOpenId(platform, doc.getString("openId"));
 //        }
         long s = System.currentTimeMillis();
-        AdamThirdPartInfoVo unBindTpaVo = adamRdmService.getThirdPartVoByUidPlatform(uid, platform);
-        if (null != unBindTpaVo) {
-            adamRdmService.delUidByPlatformOpenId(platform, unBindTpaVo.getOpenId());
+        List<AdamThirdPartInfoVo> vos = adamRdmService.getThirdPartVoListByUid(uid);
+        if (!CollectionUtils.isEmpty(vos)) {
+            AdamThirdPartInfoVo unBindTpaVo = adamRdmService.getThirdPartVoByUidPlatform(vos, platform);
+            if (null != unBindTpaVo) {
+                adamRdmService.delUidByPlatformOpenId(platform, unBindTpaVo.getOpenId());
+
+                adamRdmService.rmvThirdPartVoListByUid(uid, vos, platform);
+
+                s = System.currentTimeMillis();
+                queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UCENTER.getKey(),
+                        SqlMapping.get("adam_third_party.unbind", now, uid, platform)
+                );
+                log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
+            }
         }
-        adamRdmService.delThirdPartVoListByUid(uid);
         log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
-
-        s = System.currentTimeMillis();
-        queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UCENTER.getKey(),
-                SqlMapping.get("adam_third_party.unbind", now, uid, platform)
-        );
-        log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
     }
 
     @Override
@@ -336,8 +334,8 @@ public class AdamUserServiceImpl implements IAdamUserService {
 //        deleteResult = mongoTemplate.remove(Query.query(Criteria.where("uid").is(uid)), AdamUserMemberVo.class.getSimpleName());
 //        log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
 //        if (deleteResult.getDeletedCount() > 0) {
-            toMqSqls.add(SqlMapping.get("adam_user_member.close"));
-            objsThirdPart.add(new Object[]{now, uid});
+        toMqSqls.add(SqlMapping.get("adam_user_member.close"));
+        objsThirdPart.add(new Object[]{now, uid});
 //        }
 
         /* ---------------------- 收货地址信息 */
@@ -345,8 +343,8 @@ public class AdamUserServiceImpl implements IAdamUserService {
 //        deleteResult = mongoTemplate.remove(Query.query(Criteria.where("uid").is(uid)), AdamAddressesVo.class.getSimpleName());
 //        log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
 //        if (deleteResult.getDeletedCount() > 0) {
-            toMqSqls.add(SqlMapping.get("adam_addresses.close"));
-            objsAddresses.add(new Object[]{now, now, uid});
+        toMqSqls.add(SqlMapping.get("adam_addresses.close"));
+        objsAddresses.add(new Object[]{now, now, uid});
 //        }
 
         /* ---------------------- 入场人信息 */
@@ -354,8 +352,8 @@ public class AdamUserServiceImpl implements IAdamUserService {
 //        deleteResult = mongoTemplate.remove(Query.query(Criteria.where("uid").is(uid)).getQueryObject(), AdamEnters.class.getSimpleName());
 //        log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
 //        if (deleteResult.getDeletedCount() > 0) {
-            toMqSqls.add(SqlMapping.get("adam_enters.close"));
-            objsAddresses.add(new Object[]{now, now, uid});
+        toMqSqls.add(SqlMapping.get("adam_enters.close"));
+        objsAddresses.add(new Object[]{now, now, uid});
 //        }
 
         s = System.currentTimeMillis();
@@ -370,10 +368,7 @@ public class AdamUserServiceImpl implements IAdamUserService {
 //    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
     public AdamRealInfoVo identity(String uid, String name, String idCard) {
         AdamRealInfoVo vo = null;
-//        if (RedisLockUtil.tryLock(AdamRedisConst.LOCK_KEY_UIDENTITY + uid, 1, 3)) {
-//            vo = adamRdmService.getRealInfoVoByUid(uid);
-//            if (null == vo) {
-                if (!adamRdmService.isCertification(1, idCard, name)) {
+        if (!adamRdmService.isCertification(1, idCard, name)) {
 //                    String respStr = null;
 //                    try {
 //                        LinkedMultiValueMap<String, String> paramsMap = new LinkedMultiValueMap<>();
@@ -394,39 +389,36 @@ public class AdamUserServiceImpl implements IAdamUserService {
 //                        ErrorMapping.ErrorMessage errorMessage = ErrorMapping.get("10102");
 //                        throw new LiquidnetServiceException(errorMessage.getCode(), errorMessage.getMessage());
 //                    }
-                    String respStr = IdentityUtils.aliThird(name, idCard);
-                    JsonNode respJNode = JsonUtils.fromJson(respStr, JsonNode.class);
-                    if (null == respJNode || !"0".equals(respJNode.get("error_code").asText())) {
-                        log.info("###实名认证失败[{}]", respStr);
-                        ErrorMapping.ErrorMessage errorMessage = ErrorMapping.get("10102");
-                        throw new LiquidnetServiceException(errorMessage.getCode(), errorMessage.getMessage());
-                    }
-                    adamRdmService.setCertification(1, idCard, name);
-                }
-
-                AdamRealName realName = new AdamRealName();
-                realName.setRealNameId(IDGenerator.nextSnowId() + "");
-                realName.setUid(uid);
-                realName.setType(1);
-                realName.setName(name);
-                realName.setIdCard(idCard);
-                realName.setState(1);
-                realName.setCreatedAt(LocalDateTime.now());
-                adamRealNameService.add(realName);
-
-                vo = AdamRealInfoVo.getNew();
-                vo.setUid(uid);
-                vo.setName(name);
-                vo.setIdCard(idCard);
-                vo.setType(realName.getType());
-                vo.setState(1);
-
-                long s = System.currentTimeMillis();
-                adamRdmService.setRealInfoVoByUid(uid, vo);
-                log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
-//            }
-//            RedisLockUtil.unlock(AdamRedisConst.LOCK_KEY_UIDENTITY + uid);
-//        }
+            String respStr = IdentityUtils.aliThird(name, idCard);
+            JsonNode respJNode = JsonUtils.fromJson(respStr, JsonNode.class);
+            if (null == respJNode || !"0".equals(respJNode.get("error_code").asText())) {
+                log.info("###实名认证失败[{}]", respStr);
+                ErrorMapping.ErrorMessage errorMessage = ErrorMapping.get("10102");
+                throw new LiquidnetServiceException(errorMessage.getCode(), errorMessage.getMessage());
+            }
+            adamRdmService.setCertification(1, idCard, name);
+        }
+
+        AdamRealName realName = new AdamRealName();
+        realName.setRealNameId(IDGenerator.nextSnowId() + "");
+        realName.setUid(uid);
+        realName.setType(1);
+        realName.setName(name);
+        realName.setIdCard(idCard);
+        realName.setState(1);
+        realName.setCreatedAt(LocalDateTime.now());
+        adamRealNameService.add(realName);
+
+        vo = AdamRealInfoVo.getNew();
+        vo.setUid(uid);
+        vo.setName(name);
+        vo.setIdCard(idCard);
+        vo.setType(realName.getType());
+        vo.setState(1);
+
+        long s = System.currentTimeMillis();
+        adamRdmService.setRealInfoVoByUid(uid, vo);
+        log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
         return vo;
     }
 }