fix;

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

@@ -103,8 +103,9 @@ public class AdamUserServiceImpl implements IAdamUserService {
                 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.getQrCode(), userInfoVo.getUid()});
+                initUserInfoObjs.add(new Object[]{userInfoVo.getUid(), userInfoVo.getNickname(), userInfoVo.getQrCode()});
                 log.debug("#SQL.GET耗时:{}ms", System.currentTimeMillis() - s);
+
                 queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UREGISTER.getKey(),
                         SqlMapping.gets(toMqSqls, initUserObjs, initUserInfoObjs)
                 );
@@ -131,6 +132,7 @@ public class AdamUserServiceImpl implements IAdamUserService {
                 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();
@@ -151,10 +153,14 @@ public class AdamUserServiceImpl implements IAdamUserService {
 
                     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.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();
@@ -176,7 +182,7 @@ public class AdamUserServiceImpl implements IAdamUserService {
 
                 s = System.currentTimeMillis();
                 queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UREGISTER.getKey(),
-                        SqlMapping.gets(toMqSqls, initUserObjs, initThirdPartObjs)
+                        SqlMapping.gets(toMqSqls, initUserObjs, initUserInfoObjs, initThirdPartObjs)
                 );
                 log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
             } else {

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/resources/sqlmap.properties

@@ -4,7 +4,7 @@ adam_user.edit.mobile=UPDATE adam_user SET mobile=?, updated_at=? WHERE `uid`=?
 adam_user.close=UPDATE adam_user SET `state`=2, updated_at=?, closed_at=? WHERE `uid`=? 
 
 # ----------------------------------------------------
-adam_user_info.add=INSERT INTO adam_user_info (`uid`, qr_code) VALUES (?,?) 
+adam_user_info.add=INSERT INTO adam_user_info (`uid`, nickname, qr_code) VALUES (?,?,?) 
 adam_user_info.edit=UPDATE adam_user_info SET nickname=?, sex=?, birthday=?, area=?, signature=?, avatar=?, background=?, tag_me=? WHERE uid=? 
 
 # ----------------------------------------------------