|
@@ -1113,21 +1113,22 @@ class testView(View):
|
|
order_qs = AbnormalOrder.objects.filter(id__gt=ab_order_id).values('order_id', 'agreement_id')
|
|
order_qs = AbnormalOrder.objects.filter(id__gt=ab_order_id).values('order_id', 'agreement_id')
|
|
if order_qs.exists():
|
|
if order_qs.exists():
|
|
for order in order_qs:
|
|
for order in order_qs:
|
|
- order_id, agreement_id = order['order_id'], order['agreement_id']
|
|
|
|
- # 根据agreement_id查询最后一条订单
|
|
|
|
- orders_qs = Order_Model.objects.filter(agreement_id=agreement_id).first()
|
|
|
|
- # 更新订单id
|
|
|
|
- if orders_qs:
|
|
|
|
- old_order_id = orders_qs.orderID
|
|
|
|
- UID_Bucket.objects.filter(orderId=old_order_id).update(orderId=order_id)
|
|
|
|
- Order_Model.objects.filter(orderID=old_order_id).update(orderID=order_id)
|
|
|
|
-
|
|
|
|
- # orders_qs.orderID = order_id
|
|
|
|
- # orders_qs.save()
|
|
|
|
- LOGGER.info('{} -> {}'.format(old_order_id, order_id))
|
|
|
|
- else:
|
|
|
|
- LOGGER.info('订单不存在: {}'.format(order_id))
|
|
|
|
|
|
+ try:
|
|
|
|
+ order_id, agreement_id = order['order_id'], order['agreement_id']
|
|
|
|
+ # 根据agreement_id查询最后一条订单
|
|
|
|
+ orders_qs = Order_Model.objects.filter(agreement_id=agreement_id).first()
|
|
|
|
+ # 更新订单id
|
|
|
|
+ if orders_qs:
|
|
|
|
+ old_order_id = orders_qs.orderID
|
|
|
|
+ UID_Bucket.objects.filter(orderId=old_order_id).update(orderId=order_id)
|
|
|
|
+ orders_qs.orderID = order_id
|
|
|
|
+ orders_qs.save()
|
|
|
|
+ LOGGER.info('{} -> {}'.format(old_order_id, order_id))
|
|
|
|
+ else:
|
|
|
|
+ LOGGER.info('订单不存在: {}'.format(order_id))
|
|
|
|
+ except Exception as e:
|
|
|
|
+ print(old_order_id, order_id)
|
|
|
|
+ continue
|
|
return response.json(0)
|
|
return response.json(0)
|
|
except Exception as e:
|
|
except Exception as e:
|
|
- print(old_order_id, order_id)
|
|
|
|
return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|