api/staff_views.py

@@ -1,5 +1,6 @@

                 # -*- coding: utf-8 -*-
              

                 
              

                +from mch.models import ConsumeShotUnbindingInfo
              

                 import json
              

                 
              

                 from django.conf import settings
              
@@ -516,3 +517,66 @@ def batch_del_consumer_submit_api(request):

                         exec_del_consumer_submit(pk, admin_id)
              

                 
              

                     return response(200, 'Del Success', u'删除成功')
              

                +
              

                +@logit
              

                +@transaction.atomic
              

                +def unbind_consumer_submit_api(request):
              

                +    brand_id = request.POST.get('brand_id') or settings.KODO_DEFAULT_BRAND_ID
              

                +    admin_id = request.POST.get('admin_id', '')
              

                +    pk = int(request.POST.get('pk', ''))
              

                +
              

                +    try:
              

                +        administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
              

                +    except AdministratorInfo.DoesNotExist:
              

                +        return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
              

                +
              

                +    exec_unbind_consumer_submit(pk, admin_id)
              

                +
              

                +    return response(200, 'Del Success', u'删除成功')
              

                +
              

                +@logit
              

                +@transaction.atomic
              

                +def batch_unbind_consumer_submit_api(request):
              

                +    brand_id = request.POST.get('brand_id') or settings.KODO_DEFAULT_BRAND_ID
              

                +    admin_id = request.POST.get('admin_id', '')
              

                +    pks = json.loads(request.POST.get('pks', []))
              

                +
              

                +    try:
              

                +        administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
              

                +    except AdministratorInfo.DoesNotExist:
              

                +        return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
              

                +
              

                +    for pk in pks:
              

                +        exec_unbind_consumer_submit(pk, admin_id)
              

                +
              

                +    return response(200, 'Unbind Success', u'解绑成功')
              

                +
              

                +
              

                +def exec_unbind_consumer_submit(pk, admin_id):
              

                +    log_info = ConsumeInfoSubmitLogInfo.objects.get(pk=pk)
              

                +
              

                +    try:
              

                +        target_log_info = ConsumeInfoSubmitLogInfo.objects.get(model_id=log_info.model_id, serialNo=log_info.serialNo, dupload=False, unbound=False, status=True)
              

                +        
              

                +        ConsumeInfoSubmitLogInfo.objects.filter(model_id=log_info.model_id, serialNo=log_info.serialNo).update(delete_type=ConsumeInfoSubmitLogInfo.UNBINDING, status=False)
              

                +
              

                +        user = UserInfo.objects.get(user_id=target_log_info.user_id)
              

                +
              

                +        if user.shots_num <= 5:
              

                +            user.level -= 1
              

                +
              

                +        user.integral -= target_log_info.integral
              

                +        user.integral = max(user.integral, 0)
              

                +        
              

                +        user.shots_num -= 1
              

                +
              

                +        user.save()
              

                +
              

                +        ConsumeShotUnbindingInfo.objects.update_or_create(user_id=target_log_info.user_id, submit_pk=target_log_info.submit_pk, defaults={
              

                +            'model_id': target_log_info.model_id,
              

                +            'sn': target_log_info.sn,
              

                +            'submit_at': target_log_info.submit_at,
              

                +            'reason': admin_id,
              

                +        })
              

                +    except:
              

                +        ConsumeInfoSubmitLogInfo.objects.filter(model_id=log_info.model_id, serialNo=log_info.serialNo).update(delete_type=ConsumeInfoSubmitLogInfo.UNBINDING, status=False)
              

api/urls.py

@@ -264,6 +264,8 @@ urlpatterns += [

                     url(r'^batch/del/clerk/sale/submit$', staff_views.batch_del_clerk_sale_submit_api, name='batch_del_clerk_sale_submit_api'),
              

                     url(r'^del/consumer/submit$', staff_views.del_consumer_submit_api, name='del_consumer_submit_api'),
              

                     url(r'^batch/del/consumer/submit$', staff_views.batch_del_consumer_submit_api, name='batch_del_consumer_submit_api'),
              

                +
              

                +    url(r'^unbind/consumer/submit$', staff_views.unbind_consumer_submit_api, name='unbind_consumer_submit_api'),
              

                 ]
              

                 
              

                 urlpatterns += [