当前位置：网站首页>Mall project -- day09 -- order module

Mall project -- day09 -- order module

2022-07-06 11:48:00 【mb61037a3723f67】

One ： Create a new order application and migrate to create a table ：

1： New application orders:

2: Register subapplication , Configure the routing ：

1:dev.py
  'apps.orders',
2: Total route 
path("",include('apps.orders.urls')),
3： Sub route ：
urlpatterns = [
    
]


      1.
2.
3.
4.
5.
6.
7.
8.

3： Create model classes ：

from meiduo_mall.utils.models import BaseModel
from django.db import models

class OrderInfo(BaseModel):
    """ Order information """
    PAY_METHODS_ENUM = {
        "CASH": 1,
        "ALIPAY": 2
    }
    PAY_METHOD_CHOICES = (
        (1, " Cash on Delivery "),
        (2, " Alipay "),
    )
    ORDER_STATUS_ENUM = {
        "UNPAID": 1,
        "UNSEND": 2,
        "UNRECEIVED": 3,
        "UNCOMMENT": 4,
        "FINISHED": 5
    }
    ORDER_STATUS_CHOICES = (
        (1, " To be paid "),
        (2, " To be delivered "),
        (3, " To be received "),
        (4, " To be evaluated "),
        (5, " Completed "),
        (6, " Cancelled "),
    )
    order_id = models.CharField(max_length=64, primary_key=True, verbose_name=" The order number ")
    user = models.ForeignKey('users.User', on_delete=models.PROTECT, verbose_name=" Order user ")
    address = models.ForeignKey('users.Address', on_delete=models.PROTECT, verbose_name=" Shipping address ")
    total_count = models.IntegerField(default=1, verbose_name=" Total commodity ")
    total_amount = models.DecimalField(max_digits=10, decimal_places=2, verbose_name=" The total amount of goods ")
    freight = models.DecimalField(max_digits=10, decimal_places=2, verbose_name=" The freight ")
    pay_method = models.SmallIntegerField(choices=PAY_METHOD_CHOICES, default=1, verbose_name=" Method of payment ")
    status = models.SmallIntegerField(choices=ORDER_STATUS_CHOICES, default=1, verbose_name=" The order status ")

    class Meta:
        db_table = "tb_order_info"
        verbose_name = ' Basic order information '
        verbose_name_plural = verbose_name

    def __str__(self):
        return self.order_id


class OrderGoods(BaseModel):
    """ Order goods """
    SCORE_CHOICES = (
        (0, '0 branch '),
        (1, '20 branch '),
        (2, '40 branch '),
        (3, '60 branch '),
        (4, '80 branch '),
        (5, '100 branch '),
    )
    order = models.ForeignKey(OrderInfo, related_name='skus', on_delete=models.CASCADE, verbose_name=" Order ")
    sku = models.ForeignKey('goods.SKU', on_delete=models.PROTECT, verbose_name=" Order goods ")
    count = models.IntegerField(default=1, verbose_name=" Number ")
    price = models.DecimalField(max_digits=10, decimal_places=2, verbose_name=" The unit price ")
    comment = models.TextField(default="", verbose_name=" Evaluation information ")
    score = models.SmallIntegerField(choices=SCORE_CHOICES, default=5, verbose_name=' Satisfaction score ')
    is_anonymous = models.BooleanField(default=False, verbose_name=' Whether to comment anonymously ')
    is_commented = models.BooleanField(default=False, verbose_name=' Have you evaluated ')

    class Meta:
        db_table = "tb_order_goods"
        verbose_name = ' Order goods '
        verbose_name_plural = verbose_name

    def __str__(self):
        return self.sku.name


      1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.

4： Migration table creation ：

Mall project ---day09--- Order module _ data

Two ： Create and save order to realize ：

1： edit orders/views.py Implementation view ：

#  preservation / New order 
class OrderCommitView(LoginRequiredJSONMixin, View):

    def post(self, request):

        data = json.loads(request.body.decode())
        address_id = data.get('address_id')
        pay_method = data.get('pay_method')

        if not all([address_id, pay_method]):
            return JsonResponse({'code': 400, 'errmsg': ' Lack of parameter '})

        try:
            Address.objects.get(pk=address_id)
        except Address.DoesNotExist as e:
            return JsonResponse({'code': 400, 'errmsg': ' The address doesn't exist '})

        if pay_method not in [OrderInfo.PAY_METHODS_ENUM['CASH'], OrderInfo.PAY_METHODS_ENUM['ALIPAY']]:
            return JsonResponse({'code': 400, 'errmsg': ' Payment method does not support '})

        # 0、 Put... In the shopping cart sku Read out the commodity data 
        cart_dict = {} # {1: {"count": 5, "selected": True}}
        conn = get_redis_connection('carts')
        # {b"1": b"5"}
        redis_skus = conn.hgetall('carts_%d'%request.user.id)
        # [b'1']
        redis_selected = conn.smembers('selected_%d'%request.user.id)
        for sku_id,count in redis_skus.items():
            if sku_id in redis_selected:
                cart_dict[int(sku_id)] = {
                    'count': int(count),
                    'selected': sku_id in redis_selected
                }

        #  data / Business processing 
        # 1、 Create new order table data OrderInfo( Lord )
        # 20200912111256000001 ---->  Agreed order id The format of ： Time stamp  +  user id( Fixed length )
        #  Adding a timestamp can guarantee the id Uniqueness 
        order_id = timezone.localtime().strftime('%Y%m%d%H%M%S') + '%06d'%request.user.id
        freight = Decimal('10.5')
        order = OrderInfo.objects.create(
            order_id=order_id,
            user=request.user,
            address_id=address_id,
            total_count=0, #  initialization 
            total_amount=0, #  initialization 
            freight=freight,
            pay_method=pay_method
        )

        # 2、 Insert order item table data OrderGoods( from ) -->  Concrete sku Goods are the goods selected in the shopping cart 
        sku_ids = cart_dict.keys()
        for sku_id in sku_ids:
            #  In the shopping cart sku goods 
            sku = SKU.objects.get(pk=sku_id)
            #  In the middle of table OrderGoods Insert a piece of data into the table , Indicates sku goods 
            OrderGoods.objects.create(
                order=order,
                sku=sku,
                count=cart_dict[sku_id]['count'],
                price=sku.price,
            )

            order.total_count += cart_dict[sku_id]['count']
            order.total_amount += cart_dict[sku_id]['count'] * sku.price

        order.total_amount += freight
        order.save()

        return JsonResponse({
            'code': 0,
            'errmsg': 'ok',
            'order_id': order_id
        })


      1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.

2： route ：

from django.urls import re_path
from . import views

urlpatterns = [
    #  Save order 
    re_path(r'^orders/commit/$', views.OrderCommitView.as_view()),
]

      1.
2.
3.
4.
5.
6.
7.

3、 ... and ： Concurrent order resource competition ：

Mall project ---day09--- Order module _ other _02

Mall project ---day09--- Order module _ data _05

Mall project ---day09--- Order module _ other _06

Four ： Optimistic lock order ：

1： Modify the isolation level of the database ：

(1)、 open mysql The configuration file : sudo vim /etc/mysql/mysql.conf.d/mysqld.cnf
(2)、 Add configuration items at the end of the configuration file : transaction-isolation=READ-COMMITTED
- Be careful ： According to our analysis , The isolation level here can be set to READ-COMMITTED or READ-UNCOMMITTED Can achieve optimistic locking mechanism , But follow Maximize isolation strength principle , Let's set it to READ-COMMITTED Level ;
- Higher isolation level , The more data security can be guaranteed ; The lower the isolation level , The more likely it is to produce wrong data ;
- No solution is absolutely superior or inferior , Only relatively appropriate ;
(3)、 restart Mysql database : sudo /etc/init.d/mysql restart

2: edit `apps/orders/views.py

#  preservation / New order 
class OrderCommitView(LoginRequiredJSONMixin, View):

    def post(self, request):

        data = json.loads(request.body.decode())
        address_id = data.get('address_id')
        pay_method = data.get('pay_method')

        if not all([address_id, pay_method]):
            return JsonResponse({'code': 400, 'errmsg': ' Lack of parameter '})

        try:
            Address.objects.get(pk=address_id)
        except Address.DoesNotExist as e:
            return JsonResponse({'code': 400, 'errmsg': ' The address doesn't exist '})

        if pay_method not in [OrderInfo.PAY_METHODS_ENUM['CASH'], OrderInfo.PAY_METHODS_ENUM['ALIPAY']]:
            return JsonResponse({'code': 400, 'errmsg': ' Payment method does not support '})


        # 0、 Put... In the shopping cart sku Read out the commodity data 
        cart_dict = {} # {1: {"count": 5, "selected": True}}
        conn = get_redis_connection('carts')
        # {b"1": b"5"}
        redis_skus = conn.hgetall('carts_%d'%request.user.id)
        # [b'1']
        redis_selected = conn.smembers('selected_%d'%request.user.id)
        for sku_id,count in redis_skus.items():
            if sku_id in redis_selected:
                cart_dict[int(sku_id)] = {
                    'count': int(count),
                    'selected': sku_id in redis_selected
                }
        sku_ids = cart_dict.keys()

        #  data / Business processing 
        # 1、 Create new order table data OrderInfo( Lord )
        # 20200912111256000001 ---->  Agreed order id The format of ： Time stamp  +  user id( Fixed length )
        #  Adding a timestamp can guarantee the id Uniqueness 
        order_id = timezone.localtime().strftime('%Y%m%d%H%M%S') + '%06d'%request.user.id
        freight = Decimal('10.5')


        with transaction.atomic():
            #  Set a transaction savepoint 
            save_id = transaction.savepoint()

            order = OrderInfo.objects.create(
                order_id=order_id,
                user=request.user,
                address_id=address_id,
                total_count=0, #  initialization 
                total_amount=0, #  initialization 
                freight=freight,
                pay_method=pay_method
            )

            # 2、 Insert order item table data OrderGoods( from ) -->  Concrete sku Goods are the goods selected in the shopping cart 
            for sku_id in sku_ids:

                #  Optimistic lock handling mechanism 
                while True:
                    #  In the shopping cart sku goods 
                    sku = SKU.objects.get(pk=sku_id)
                    # (1)、 Read old inventory and sales 
                    old_stock = sku.stock
                    old_sales = sku.sales

                    # TODO:  Judge inventory and sales 
                    #  The number of orders placed by users 
                    count = cart_dict[sku_id]['count']
                    if count > old_stock:
                        #  Insufficient inventory ,  Roll back the transaction 
                        transaction.savepoint_rollback(save_id)
                        return JsonResponse({'code': 400, 'errmsg': ' Insufficient inventory '}, status=400)

                    #  Modify sales volume and inventory data 
                    # sku.stock -= count
                    # sku.sales += count
                    # sku.save()

                    # (2)、 Calculate new value based on old inventory and sales 
                    new_stock = old_stock - count
                    new_sales = old_sales + count
                    # (3)、 On the basis of old inventory and sales , Modify... After query 
                    ret = SKU.objects.filter(
                        pk=sku.id,
                        stock=old_stock,
                        sales=old_sales
                    ).update(stock=new_stock, sales=new_sales)
                    #  If update The return value of the function is 0, explain filter The filter result is empty , It indicates that the original... Cannot be found according to the old data sku
                    #  It means that there are other matters involved 
                    if ret:
                        #  If ret Not for 0, Instructions updated correctly 
                        break

                #  In the middle of table OrderGoods Insert a piece of data into the table , Indicates sku goods 
                OrderGoods.objects.create(
                    order=order,
                    sku=sku,
                    count=cart_dict[sku_id]['count'],
                    price=sku.price,
                )

                order.total_count += cart_dict[sku_id]['count']
                order.total_amount += cart_dict[sku_id]['count'] * sku.price

            order.total_amount += freight
            order.save()

            #  Submit savepoints （ Delete savepoint ）
            transaction.savepoint_commit(save_id)


        #  Delete shopping cart after placing order 
        conn.hdel('carts_%d'%request.user.id, *sku_ids)
        conn.srem('selected_%d'%request.user.id, *sku_ids)

        return JsonResponse({
            'code': 0,
            'errmsg': 'ok',
            'order_id': order_id
        })

      1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.

5、 ... and ： Settlement page ：

1： edit apps/orders/views.py

class OrderSettlementView(LoginRequiredJSONMixin, View):

    def get(self, request):
        user = request.user

        #  Return the user's optional address 
        addresses = []
        add_queryset = Address.objects.filter(
            user=user,
            is_deleted=False
        )
        for address in add_queryset:
            addresses.append({
                'id': address.id,
                'province': address.province.name,
                'city': address.city.name,
                'district': address.district.name,
                'place': address.place,
                'mobile': address.mobile,
                'receiver': address.receiver
            })

        #  Return the selected shopping cart data 
        skus = []

        conn = get_redis_connection('carts')
        # redis_skus = {b'1': b'5'}
        redis_skus = conn.hgetall('carts_%d'%user.id)
        # redis_selected = [b'1']
        redis_selected = conn.smembers('selected_%d'%user.id)

        for sku_id,count in redis_skus.items():
            # sku_id: b'1'; count: b'5'
            if sku_id in redis_selected:
                sku = SKU.objects.get(pk=int(sku_id))
                skus.append({
                    'id': sku.id,
                    'name': sku.name,
                    'default_image_url': sku.default_image.url,
                    'count': int(count),
                    'price': sku.price
                })

        return JsonResponse({
            'code': 0,
            'errmsg': 'ok',
            'context': {
                'addresses': addresses,
                'skus': skus,
                'freight': Decimal('10.5') #  The accuracy will not be lost in the calculation 
            }
        })

      1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.

Routing configuration ：

from django.urls import re_path
from . import views

urlpatterns = [
    re_path(r'^orders/settlement/$', views.OrderSettlementView.as_view()),
]

      1.
2.
3.
4.
5.
6.