|
@@ -197,7 +197,7 @@ func (u *User) Add(tx *sql.Tx, entId int, user *User, paymentAddress, source, ns
|
|
|
}, `{"s_phone":-1}`, `{"_id":1,"base_user_id":1}`, false, 0, 1)
|
|
|
if data != nil && len(*data) > 0 {
|
|
|
for _, v := range *data {
|
|
|
- userId := v["_id"]
|
|
|
+ userId := BsonIdToSId(v["_id"])
|
|
|
baseUserId := v["base_user_id"]
|
|
|
MQFW.UpdateById("user", userId, map[string]interface{}{
|
|
|
"$set": map[string]interface{}{
|
|
@@ -347,7 +347,7 @@ func (u *User) UpdateUserName(tx *sql.Tx, entId, userId int, user_name string) {
|
|
|
}, `{"s_phone":-1}`, `{"_id":1,"base_user_id":1}`, false, 0, 1)
|
|
|
if data != nil && len(*data) > 0 {
|
|
|
for _, v := range *data {
|
|
|
- userId := v["_id"]
|
|
|
+ userId := BsonIdToSId(v["_id"])
|
|
|
baseUserId := v["base_user_id"]
|
|
|
MQFW.UpdateById("user", userId, map[string]interface{}{
|
|
|
"$set": map[string]interface{}{
|