4
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
userinfos = UserInfo.objects.filter(Q(status=True) & (Q(user_id__icontains=query) | Q(nickname__icontains=query) | Q(phone__icontains=query) | Q(memberusercardcode__icontains=query))).order_by('-pk')
if level:
@@ -273,21 +220,12 @@ def query_userinfo(request):
@logit
+@check_admin
@transaction.atomic
-def userinfo_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+def userinfo_update(request, administrator):
user_id = request.POST.get('user_id', '')
integral = int(request.POST.get('integral', 0))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
# 校验用户是否存在
try:
user = UserInfo.objects.select_for_update().get(user_id=user_id, status=True)
@@ -295,28 +233,18 @@ def userinfo_update(request):
return response(UserStatusCode.USER_NOT_FOUND)
user.integral = integral
-
user.save()
return response(200, 'Userinfo Update Success', u'修改用户信息成功', data={})
# 统计
-def statistic_userprofile(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def statistic_userprofile(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
model_name = request.POST.get('model_name', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
if model_name:
logs = ConsumeModelSaleStatisticInfo.objects.filter(model_name=model_name, ymd__gte=start_time, ymd__lte=end_time)
else:
@@ -346,20 +274,11 @@ def statistic_userprofile(request):
})
-def statistic_daily(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def statistic_daily(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
sale_logs = ConsumeSaleStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time)
user_logs = ConsumeUserStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time)
@@ -372,44 +291,29 @@ def statistic_daily(request):
})
-def statistic_model(request):
+@check_admin
+def statistic_model(request, administrator):
brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
admin_id = request.POST.get('admin_id', '')
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
logs = ConsumeModelSaleStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time).values_list('model_name').annotate(Sum('num'))
logs = [{'model_name': log[0], 'num': log[1]} for log in logs]
+
return response(200, 'Get Model Statistic Success', u'获取型号统计成功', data={
'logs': logs
})
-def statistic_distributor(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def statistic_distributor(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
model_name = request.POST.get('model_name', '')
distributor_name = request.POST.get('distributor_name', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
daily_sql = 'select id, Count(*) AS num, Count(code_version=1 or NULL) AS code1 , Count(code_version=2 or NULL) AS code2, Count((code_version=1 AND has_scan=True) or NULL) AS has_code1_scan_num, Count((code_version=2 AND has_scan=True) or NULL) AS has_code2_scan_num FROM integral_saleclerksubmitloginfo where ymd >= %s AND ymd <= %s AND test_user=False AND dupload=False AND test_sn=False AND status=True %s %s GROUP BY ymd;' % (start_time, end_time, ('AND model_uni_name="%s"' % (model_name)) if model_name else '', ('AND distributor_name="%s"' % (distributor_name)) if distributor_name else '')
daily_logs = SaleclerkSubmitLogInfo.objects.raw(daily_sql)
@@ -436,20 +340,11 @@ def statistic_distributor(request):
})
-def dashboard(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def dashboard(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
# 销售员统计
sale_logs = SaleclerkSubmitLogInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time, test_user=False, dupload=False, test_sn=False, status=True)
@@ -484,21 +379,12 @@ def dashboard(request):
})
-def statistic_consumer(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def statistic_consumer(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
model_name = request.POST.get('model_name', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
# 消费者统计
daily_sql = 'select id, Count(id) AS num, Count(code_version=1 or NULL) AS code1 , Count(code_version=2 or NULL) AS code2 FROM mch_consumeinfosubmitloginfo where ymd >= %s AND ymd <= %s AND test_user=False AND dupload=False AND status=True %s GROUP BY ymd;' % (start_time, end_time, ('AND model_uni_name="%s"' % (model_name)) if model_name else '')
@@ -524,20 +410,11 @@ def statistic_consumer(request):
})
-def statistic_member(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def statistic_member(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
# 消费者统计
if start_time and end_time:
start_time = datetime.strptime(start_time, '%Y%m%d')
@@ -578,9 +455,8 @@ def statistic_member(request):
})
-def statistic_coupon(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def statistic_coupon(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
@@ -608,24 +484,15 @@ def statistic_coupon(request):
})
-def record_consumer(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- page = request.POST.get('page', 1)
- num = request.POST.get('num', 20)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def record_consumer(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
query = request.POST.get('query', '')
dupload = request.POST.get('dupload', '')
code_version = request.POST.get('code_version', 0)
-
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
+ page = request.POST.get('page', 1)
+ num = request.POST.get('num', 20)
logs = ConsumeInfoSubmitLogInfo.objects.filter(Q(status=True) & Q(test_user=False) & (Q(model_name__icontains=query) | Q(phone__icontains=query) | Q(serialNo__icontains=query))).order_by('-pk')
@@ -649,9 +516,8 @@ def record_consumer(request):
})
-def record_consumer_batch(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def record_consumer_batch(request, administrator):
logs = json.loads(request.POST.get('logs', '[]'))
infos = []
@@ -669,9 +535,8 @@ def record_consumer_batch(request):
})
-def record_sale(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def record_sale(request, administrator):
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
start_time = request.POST.get('start_time', '')
@@ -682,14 +547,6 @@ def record_sale(request):
code_version = request.POST.get('code_version', 0)
is_online_sale = request.POST.get('is_online_sale', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
logs = SaleclerkSubmitLogInfo.objects.filter(Q(status=True) & Q(test_user=False) & Q(test_sn=False) & (Q(model_name__icontains=query) | Q(clerk_name__icontains=query) | Q(distributor_name__icontains=query) | Q(code__icontains=query))).order_by('-created_at')
if dupload:
@@ -718,9 +575,8 @@ def record_sale(request):
})
-def record_sale_batch(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def record_sale_batch(request, administrator):
logs = json.loads(request.POST.get('logs', '[]'))
infos = []
@@ -738,18 +594,8 @@ def record_sale_batch(request):
})
-def model_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
-
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
+@check_admin
+def model_list(request, administrator):
infos = list(ModelInfo.objects.filter(status=True).values_list('model_uni_name', flat=True).distinct().order_by('model_uni_name'))
return response(200, 'Get Model List Success', u'获取型号列表成功', data={
@@ -757,18 +603,8 @@ def model_list(request):
})
-def distributor_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
-
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
+@check_admin
+def distributor_list(request, administrator):
infos = list(DistributorInfo.objects.filter(status=True).values_list('distributor_name', flat=True).distinct().order_by('distributor_name'))
return response(200, 'Get Model List Success', u'获取经销商列表成功', data={
@@ -776,9 +612,8 @@ def distributor_list(request):
})
-def member_goods_order(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_goods_order(request, administrator):
query = request.POST.get('query', '')
good_type = request.POST.get('good_type', '')
page = request.POST.get('page', 1)
@@ -787,14 +622,6 @@ def member_goods_order(request):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
orders = GoodsOrderInfo.objects.filter(Q(phone__icontains=query) | Q(user_id=query) | Q(title__icontains=query) & Q(status=True)).order_by('-pk')
if good_type:
@@ -822,40 +649,22 @@ def member_goods_order(request):
})
-def member_goods_order_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_goods_order_update(request, administrator):
order_id = request.POST.get('order_id', '')
tracking_number = request.POST.get('tracking_number', '')
remark = request.POST.get('remark', u'您的礼品正在快马加鞭赶来,请耐心等待呦~')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
if not send_trackingNumber_message(order_id, tracking_number, remark):
return response(400001, 'Member Goods Order Update Failure', u'会员商品订单修改失败')
return response(200, 'Member Goods Order Update Success', u'会员商品订单修改成功')
-def member_goods_order_batch_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_goods_order_batch_update(request, administrator):
orders = json.loads(request.POST.get('orders', '[]'))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
err_orders = []
for order in orders:
if not send_trackingNumber_message(order.get('order_id', ''), order.get('tracking_number', ''), order.get('remark', u'您的礼品正在快马加鞭赶来,请耐心等待呦~')):
@@ -909,9 +718,8 @@ def send_trackingNumber_message(order_id, tracking_number, remark):
return False
-def record_warehouse(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def record_warehouse(request, administrator):
model_name = request.POST.get('model_name', '')
sn = request.POST.get('sn', '')
start_time = request.POST.get('start_time', '')
@@ -919,14 +727,6 @@ def record_warehouse(request):
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
models = ModelInfo.objects.filter(model_name__icontains=model_name, status=True).values_list('pk', flat=True)
logs = MchInfoEncryptLogInfo.objects.filter(model_pk__in=models, sn__icontains=sn, status=True)
@@ -948,9 +748,8 @@ def record_warehouse(request):
})
-def member_activity_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_list(request, administrator):
activity_type = request.POST.get('activity_type', '')
title = request.POST.get('title', '')
start_time = request.POST.get('start_time', '')
@@ -958,15 +757,6 @@ def member_activity_list(request):
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
- # logs = MemberActivityInfo.objects.filter(title__icontains=title)
logs = MemberActivityInfo.objects.filter(status=True)
if activity_type:
@@ -993,19 +783,10 @@ def member_activity_list(request):
})
-def member_activity_detail(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_detail(request, administrator):
activity_id = request.POST.get('activity_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
log = MemberActivityInfo.objects.get(activity_id=activity_id)
except MemberActivityInfo.DoesNotExist:
@@ -1016,9 +797,8 @@ def member_activity_detail(request):
})
-def member_activity_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_update(request, administrator):
activity_id = request.POST.get('activity_id', '')
activity_type = int(request.POST.get('activity_type', 0))
title = request.POST.get('title', '')
@@ -1042,14 +822,6 @@ def member_activity_update(request):
share_h5_link = request.POST.get('share_h5_link', '')
activity_state = int(request.POST.get('activity_state', 0))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
log = MemberActivityInfo.objects.get(activity_id=activity_id, status=True)
except MemberActivityInfo.DoesNotExist:
@@ -1082,9 +854,8 @@ def member_activity_update(request):
return response(200, 'MemberActivityInfo Update Success', u'会员活动更新成功')
-def member_activity_create(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_create(request, administrator):
activity_type = int(request.POST.get('activity_type', 0))
title = request.POST.get('title', '')
subtitle = request.POST.get('subtitle', '')
@@ -1107,14 +878,6 @@ def member_activity_create(request):
share_h5_link = request.POST.get('share_h5_link', '')
activity_state = int(request.POST.get('activity_state', 0))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
MemberActivityInfo.objects.create(
brand_id=administrator.brand_id,
activity_type=activity_type,
@@ -1144,21 +907,12 @@ def member_activity_create(request):
return response(200, 'MemberActivityInfo Create Success', u'会员活动创建成功')
-def member_activity_share_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_share_list(request, administrator):
activity_id = request.POST.get('activity_id', '')
page = int(request.POST.get('page', 1))
num = int(request.POST.get('num', 20))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
logs = MemberActivityGroupShareInfo.objects.filter(activity_id=activity_id, status=True)
total_integral = logs.aggregate(Sum('integral'))['integral__sum']
@@ -1176,21 +930,12 @@ def member_activity_share_list(request):
})
-def member_activity_register_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_register_list(request, administrator):
activity_id = request.POST.get('activity_id', '')
page = int(request.POST.get('page', 1))
num = int(request.POST.get('num', 20))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
logs = MemberActivitySignupInfo.objects.filter(activity_id=activity_id, status=True)
count = logs.count()
@@ -1204,21 +949,12 @@ def member_activity_register_list(request):
})
+@check_admin
@transaction.atomic
-def member_activity_contribute_audit(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+def member_activity_contribute_audit(request, administrator):
contribution_id = request.POST.get('contribution_id', '')
audit = get_query_value(request, 'audit', val_cast_type='int')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
contribution = MemberActivityContributionInfo.objects.select_for_update().get(contribution_id=contribution_id, status=True)
except MemberActivityContributionInfo.DoesNotExist:
@@ -1230,21 +966,12 @@ def member_activity_contribute_audit(request):
return response(200, 'Member Activity Contribution Audit Success', u'会员活动投稿审批成功')
+@check_admin
@transaction.atomic
-def member_activity_contribute_selected(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+def member_activity_contribute_selected(request, administrator):
contribution_id = request.POST.get('contribution_id', '')
selected = get_query_value(request, 'selected', val_cast_type='int')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
contribution = MemberActivityContributionInfo.objects.select_for_update().get(contribution_id=contribution_id, status=True)
except MemberActivityContributionInfo.DoesNotExist:
@@ -1256,22 +983,13 @@ def member_activity_contribute_selected(request):
return response(200, 'Member Activity Contribution Selected Success', u'会员活动投稿入围成功')
-def member_activity_contribute_welfare_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_contribute_welfare_list(request, administrator):
welfare_type = request.POST.get('welfare_type', '')
welfare_title = request.POST.get('welfare_title', '')
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
welfares = MemberActivityContributionWelfareInfo.objects.filter(status=True)
if welfare_type:
@@ -1293,19 +1011,10 @@ def member_activity_contribute_welfare_list(request):
})
-def member_activity_contribute_welfare_detail(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_contribute_welfare_detail(request, administrator):
welfare_id = request.POST.get('welfare_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
welfare = MemberActivityContributionWelfareInfo.objects.get(welfare_id=welfare_id)
except MemberActivityContributionWelfareInfo.DoesNotExist:
@@ -1316,9 +1025,8 @@ def member_activity_contribute_welfare_detail(request):
})
-def member_activity_contribute_welfare_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_contribute_welfare_update(request, administrator):
welfare_id = request.POST.get('welfare_id', '')
welfare_type = int(request.POST.get('welfare_type', 0))
welfare_title = request.POST.get('welfare_title', '')
@@ -1326,14 +1034,6 @@ def member_activity_contribute_welfare_update(request):
welfare_value = request.POST.get('welfare_value', '')
welfare_image_path = request.POST.get('welfare_image_path', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
welfare = MemberActivityContributionWelfareInfo.objects.get(welfare_id=welfare_id, status=True)
except MemberActivityContributionWelfareInfo.DoesNotExist:
@@ -1349,23 +1049,14 @@ def member_activity_contribute_welfare_update(request):
return response(200, 'Update Member Activity Contribute Welfare Success', u'更新会员活动投稿福利成功')
-def member_activity_contribute_welfare_create(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_activity_contribute_welfare_create(request, administrator):
welfare_type = int(request.POST.get('welfare_type', 0))
welfare_title = request.POST.get('welfare_title', '')
welfare_detail = request.POST.get('welfare_detail', '')
welfare_value = request.POST.get('welfare_value', '')
welfare_image_path = request.POST.get('welfare_image_path', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
MemberActivityContributionWelfareInfo.objects.create(
brand_id=administrator.brand_id,
welfare_type=welfare_type,
@@ -1378,23 +1069,14 @@ def member_activity_contribute_welfare_create(request):
return response(200, 'Create Member Activity Contribute Welfare Success', u'创建会员活动投稿福利成功')
-def coupon_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def coupon_list(request, administrator):
title = request.POST.get('title', '')
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
logs = CouponInfo.objects.filter(coupon_title__icontains=title, status=True)
if start_time and end_time:
@@ -1415,19 +1097,10 @@ def coupon_list(request):
})
-def coupon_detail(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def coupon_detail(request, administrator):
coupon_id = request.POST.get('coupon_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
log = CouponInfo.objects.get(coupon_id=coupon_id)
except CouponInfo.DoesNotExist:
@@ -1440,9 +1113,8 @@ def coupon_detail(request):
})
-def coupon_create(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def coupon_create(request, administrator):
coupon_title = request.POST.get('coupon_title', '')
coupon_detail = request.POST.get('coupon_detail', '')
coupon_value = int(request.POST.get('coupon_value', 0))
@@ -1452,16 +1124,8 @@ def coupon_create(request):
coupon_expire_at = request.POST.get('coupon_expire_at', '')
is_coupon_admin_writeoff = int(request.POST.get('is_coupon_admin_writeoff', 1))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
info = CouponInfo.objects.create(
- brand_id=brand_id,
+ brand_id=administrator.brand_id,
coupon_title=coupon_title,
coupon_detail=coupon_detail,
coupon_value=coupon_value,
@@ -1478,9 +1142,8 @@ def coupon_create(request):
return response(200, 'CouponInfo Create Success', u'劵创建成功')
-def coupon_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def coupon_update(request, administrator):
coupon_id = request.POST.get('coupon_id', '')
coupon_title = request.POST.get('coupon_title', '')
coupon_detail = request.POST.get('coupon_detail', '')
@@ -1491,20 +1154,12 @@ def coupon_update(request):
coupon_expire_at = request.POST.get('coupon_expire_at', '')
is_coupon_admin_writeoff = int(request.POST.get('is_coupon_admin_writeoff', 1))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
log = CouponInfo.objects.get(coupon_id=coupon_id, status=True)
except CouponInfo.DoesNotExist:
return response()
- log.brand_id = brand_id
+ log.brand_id = administrator.brand_id
log.coupon_title = coupon_title
log.coupon_detail = coupon_detail
log.coupon_value = coupon_value
@@ -1519,19 +1174,10 @@ def coupon_update(request):
return response(200, 'CouponInfo Update Success', u'劵更新成功')
-def coupon_delete(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def coupon_delete(request, administrator):
coupon_id = request.POST.get('activity_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
log = CouponInfo.objects.get(coupon_id=coupon_id, status=True)
except CouponInfo.DoesNotExist:
@@ -1543,26 +1189,18 @@ def coupon_delete(request):
return response(200, 'CouponInfo Delete Success', u'劵删除成功')
-def member_goods_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_goods_list(request, administrator):
title = request.POST.get('title', '')
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
logs = GoodsInfo.objects.filter(title__icontains=title, only_for_member=False).order_by('-pk')
count = logs.count()
logs, left = pagination(logs, page, num)
logs = [log.admindata for log in logs]
+
return response(200, 'Get Member Goods Success', u'获取会员商品成功', data={
'logs': logs,
'left': left,
@@ -1570,19 +1208,10 @@ def member_goods_list(request):
})
-def member_goods_detail(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_goods_detail(request, administrator):
good_id = request.POST.get('good_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
log = GoodsInfo.objects.get(good_id=good_id)
except GoodsInfo.DoesNotExist:
@@ -1595,9 +1224,8 @@ def member_goods_detail(request):
})
-def member_goods_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_goods_update(request, administrator):
good_id = request.POST.get('good_id', '')
title = request.POST.get('title', '')
desc = request.POST.get('desc', '')
@@ -1609,14 +1237,6 @@ def member_goods_update(request):
integral = int(request.POST.get('integral', 0))
fee = int(request.POST.get('fee', 0))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
log = GoodsInfo.objects.get(good_id=good_id, status=True)
except GoodsInfo.DoesNotExist:
@@ -1636,9 +1256,8 @@ def member_goods_update(request):
return response(200, 'GoodsInfo Update Success', u'积分商品更新成功')
-def member_goods_create(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def member_goods_create(request, administrator):
good_type = int(request.POST.get('good_type', 0))
title = request.POST.get('title', '')
desc = request.POST.get('desc', '')
@@ -1650,14 +1269,6 @@ def member_goods_create(request):
integral = int(request.POST.get('integral', 0))
fee = int(request.POST.get('fee', 0))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
GoodsInfo.objects.create(
brand_id=administrator.brand_id,
good_type=good_type,
@@ -1675,23 +1286,14 @@ def member_goods_create(request):
return response(200, 'GoodsInfo Create Success', u'积分商品创建成功')
-def complement_code_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- page = request.POST.get('page', 1)
- num = request.POST.get('num', 20)
+@check_admin
+def complement_code_list(request, administrator):
start_time = request.POST.get('start_time', '')
end_time = request.POST.get('end_time', '')
type_ = request.POST.get('type', '')
query = request.POST.get('query', '')
-
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
+ page = request.POST.get('page', 1)
+ num = request.POST.get('num', 20)
logs = ComplementCodeLogInfo.objects.filter(status=True)
@@ -1723,21 +1325,14 @@ def complement_code_list(request):
})
+@check_admin
@transaction.atomic
-def complement_code_audit(request):
+def complement_code_audit(request, administrator):
brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
admin_id = request.POST.get('admin_id', '')
log_id = request.POST.get('log_id', '')
audit_status = int(request.POST.get('audit_status', 0)) # -1 审核不通过, 1 审核通过
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
if audit_status not in [ComplementCodeLogInfo.AUDIT_REFUSED, ComplementCodeLogInfo.AUDIT_PASS]:
return response(ComplementCodeStatusCode.COMPLEMENT_CODE_STATUS_INVALID)
@@ -1820,21 +1415,12 @@ def complement_code_audit(request):
return response()
+@check_admin
@transaction.atomic
-def complement_code_contacted(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+def complement_code_contacted(request, administrator):
log_id = request.POST.get('log_id', '')
is_contacted = int(request.POST.get('is_contacted', 0)) # 0 未联系, 1 已联系
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
try:
log = ComplementCodeLogInfo.objects.select_for_update().get(log_id=log_id, status=True)
except ComplementCodeLogInfo.DoesNotExist:
@@ -1846,20 +1432,11 @@ def complement_code_contacted(request):
return response()
-def administrator_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def administrator_list(request, administrator):
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
if administrator.admin_type != AdministratorInfo.ADMINISTRATOR:
return response(AdministratorStatusCode.ADMINISTRATOR_PERMISSION_DENIED)
@@ -1868,6 +1445,7 @@ def administrator_list(request):
count = logs.count()
logs, left = pagination(logs, page, num)
logs = [log.admindata for log in logs]
+
return response(200, 'Get Admin List Success', u'获取后台管理员成功', data={
'logs': logs,
'left': left,
@@ -1875,31 +1453,21 @@ def administrator_list(request):
})
-def administrator_create(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
-
+@check_admin
+def administrator_create(request, administrator):
admin_type = request.POST.get('admin_type', '')
phone = request.POST.get('phone', '')
name = request.POST.get('name', '')
password = request.POST.get('password', '')
brand_name = request.POST.get('brand_name', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
if administrator.admin_type != AdministratorInfo.ADMINISTRATOR:
return response(AdministratorStatusCode.ADMINISTRATOR_PERMISSION_DENIED)
encryption = make_password(strip(password), settings.MAKE_PASSWORD_SALT, settings.MAKE_PASSWORD_HASHER)
AdministratorInfo.objects.create(
- brand_id=brand_id,
+ brand_id=administrator.brand_id,
brand_name=brand_name,
admin_type=admin_type,
phone=phone,
@@ -1911,24 +1479,14 @@ def administrator_create(request):
return response(200, 'Create Admin Success', u'创建后台管理员成功')
-def administrator_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
-
+@check_admin
+def administrator_update(request, administrator):
target_admin_id = request.POST.get('target_admin_id', '')
admin_type = int(request.POST.get('admin_type', -1))
phone = request.POST.get('phone', '')
name = request.POST.get('name', '')
password = request.POST.get('password', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
if administrator.admin_type != AdministratorInfo.ADMINISTRATOR:
return response(AdministratorStatusCode.ADMINISTRATOR_PERMISSION_DENIED)
@@ -1953,19 +1511,10 @@ def administrator_update(request):
return response(200, 'Update Admin Success', u'更新后台管理员成功')
-def administrator_delete(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def administrator_delete(request, administrator):
target_admin_id = request.POST.get('target_admin_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
if administrator.admin_type != AdministratorInfo.ADMINISTRATOR:
return response(AdministratorStatusCode.ADMINISTRATOR_PERMISSION_DENIED)
@@ -1974,21 +1523,12 @@ def administrator_delete(request):
return response(200, 'Delete Admin Success', u'删除后台管理员成功')
-def administrator_login_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
+@check_admin
+def administrator_login_list(request, administrator):
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
target_admin_id = request.POST.get('target_admin_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
if administrator.admin_type != AdministratorInfo.ADMINISTRATOR:
return response(AdministratorStatusCode.ADMINISTRATOR_PERMISSION_DENIED)
@@ -0,0 +1,39 @@ |
||
| 1 |
+# -*- coding: utf-8 -*- |
|
| 2 |
+ |
|
| 3 |
+from __future__ import division |
|
| 4 |
+ |
|
| 5 |
+from functools import wraps |
|
| 6 |
+ |
|
| 7 |
+from django.conf import settings |
|
| 8 |
+from django_response import response |
|
| 9 |
+ |
|
| 10 |
+from mch.models import AdministratorInfo |
|
| 11 |
+from utils.error.errno_utils import AdministratorStatusCode, ProductBrandStatusCode |
|
| 12 |
+ |
|
| 13 |
+ |
|
| 14 |
+def check_admin(func=None): |
|
| 15 |
+ def decorator(func): |
|
| 16 |
+ @wraps(func) |
|
| 17 |
+ def returned_wrapper(request, *args, **kwargs): |
|
| 18 |
+ brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
|
|
| 19 |
+ admin_id = request.POST.get('admin_id', '')
|
|
| 20 |
+ |
|
| 21 |
+ if brand_id != settings.KODO_DEFAULT_BRAND_ID: |
|
| 22 |
+ return response(ProductBrandStatusCode.BRAND_NOT_MATCH) |
|
| 23 |
+ |
|
| 24 |
+ try: |
|
| 25 |
+ administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True) |
|
| 26 |
+ except AdministratorInfo.DoesNotExist: |
|
| 27 |
+ return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND) |
|
| 28 |
+ |
|
| 29 |
+ return func(request, administrator=administrator, *args, **kwargs) |
|
| 30 |
+ |
|
| 31 |
+ return returned_wrapper |
|
| 32 |
+ |
|
| 33 |
+ if not func: |
|
| 34 |
+ def foo(func): |
|
| 35 |
+ return decorator(func) |
|
| 36 |
+ |
|
| 37 |
+ return foo |
|
| 38 |
+ |
|
| 39 |
+ return decorator(func) |