@@ -273,7 +273,7 @@ def userinfo_update(request): |
||
273 | 273 |
|
274 | 274 |
# 校验用户是否存在 |
275 | 275 |
try: |
276 |
- user = UserInfo.objects.get(user_id=user_id, status=True) |
|
276 |
+ user = UserInfo.objects.select_for_update().get(user_id=user_id, status=True) |
|
277 | 277 |
except UserInfo.DoesNotExist: |
278 | 278 |
return response(UserStatusCode.USER_NOT_FOUND) |
279 | 279 |
|
@@ -57,7 +57,7 @@ class Command(CompatibilityBaseCommand): |
||
57 | 57 |
ymd = str(v.get('ymd', '')) |
58 | 58 |
|
59 | 59 |
# 更新用户表 |
60 |
- user = UserInfo.objects.get(user_id=user_id, status=True) |
|
60 |
+ user = UserInfo.objects.select_for_update().get(user_id=user_id, status=True) |
|
61 | 61 |
user.province_name = ProvinceShortModelMixin.PROVINCE_CODE_NAME_DICT.get(province_code) |
62 | 62 |
user.save() |
63 | 63 |
|
@@ -118,6 +118,7 @@ def qy_login_api(request): |
||
118 | 118 |
|
119 | 119 |
return response(200, 'Mini App Login Success', u'微信小程序登录成功', user.brand_qydata(brand_id=brand_id)) |
120 | 120 |
|
121 |
+ |
|
121 | 122 |
@logit(res=True) |
122 | 123 |
@transaction.atomic |
123 | 124 |
def query_userinfo(request): |
@@ -197,7 +197,7 @@ def get_userinfo_api2(request): |
||
197 | 197 |
iv = request.POST.get('iv', '') |
198 | 198 |
|
199 | 199 |
try: |
200 |
- user = UserInfo.objects.get(user_id=user_id, status=True) |
|
200 |
+ user = UserInfo.objects.select_for_update().get(user_id=user_id, status=True) |
|
201 | 201 |
except UserInfo.DoesNotExist: |
202 | 202 |
return response(UserStatusCode.USER_NOT_FOUND) |
203 | 203 |
|