48b57983c654cfa7912e2318af5cef57L408">408
- mssi.save()
-
- mssi, _ = ModelSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- model_name=model.model_uni_name,
- ymd=ymd[:4],
- )
- mssi.saleclerks += [clerk.clerk_id]
- mssi.num = len(mssi.saleclerks)
- mssi.save()
-
- # 经销商销量统计
- dssi, _ = DistributorSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- distributor_id=distributor.distributor_id,
- ymd=ymd,
- )
- dssi.distributor_name = distributor.distributor_name
- dssi.num += 1
- dssi.save()
-
- dssi2, _ = DistributorSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- distributor_id=distributor.distributor_id,
- ymd=0,
- )
- dssi2.distributor_name = distributor.distributor_name
- dssi2.num += 1
- dssi2.save()
-
- # 日省份销量统计
- pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- province_code=distributor.distributor_province_code,
- ymd=ymd,
- )
- pssi.province_name = distributor.distributor_province_name
- pssi.num += 1
- pssi.save()
- # 月省份销量统计
- pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- province_code=distributor.distributor_province_code,
- ymd=ymd[:6],
- )
- pssi.province_name = distributor.distributor_province_name
- pssi.num += 1
- pssi.save()
- # 年省份销量统计
- pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- province_code=distributor.distributor_province_code,
- ymd=ymd[:4],
- )
- pssi.province_name = distributor.distributor_province_name
- pssi.num += 1
- pssi.save()
-
- # 日销售员销量统计
- sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- clerk_id=clerk.clerk_id,
- ymd=ymd,
- )
- sssi.distributor_id = distributor.distributor_id
- sssi.distributor_name = distributor.distributor_name
- sssi.distributor_short_name = distributor.distributor_short_name
- sssi.clerk_name = clerk.clerk_name
- sssi.num += 1
- sssi.save()
- # 月销售员销量统计
- sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- clerk_id=clerk.clerk_id,
- ymd=ymd[:6],
- )
- sssi.distributor_id = distributor.distributor_id
- sssi.distributor_name = distributor.distributor_name
- sssi.distributor_short_name = distributor.distributor_short_name
- sssi.clerk_name = clerk.clerk_name
- sssi.num += 1
- sssi.save()
- # 年销售员销量统计
- sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create(
- brand_id=brand.brand_id,
- clerk_id=clerk.clerk_id,
- ymd=ymd[:4],
- )
- sssi.distributor_id = distributor.distributor_id
- sssi.distributor_name = distributor.distributor_name
- sssi.distributor_short_name = distributor.distributor_short_name
- sssi.clerk_name = clerk.clerk_name
- sssi.num += 1
- sssi.save()
+ with transaction.atomic():
+ # 日销量统计
+ ssi, _ = SaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ ymd=ymd,
+ )
+ ssi.num += 1
+ ssi.save()
+ # 月销量统计
+ ssi, _ = SaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ ymd=ymd[:6],
+ )
+ ssi.num += 1
+ ssi.save()
+ # 年销量统计
+ ssi, _ = SaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ ymd=ymd[:4],
+ )
+ ssi.num += 1
+ ssi.save()
+
+ # 型号销量统计
+ mssi, _ = ModelSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ model_name=model.model_uni_name,
+ ymd=ymd,
+ )
+ mssi.saleclerks += [clerk.clerk_id]
+ mssi.num = len(mssi.saleclerks)
+ mssi.save()
+
+ mssi, _ = ModelSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ model_name=model.model_uni_name,
+ ymd=ymd[:6],
+ )
+ mssi.saleclerks += [clerk.clerk_id]
+ mssi.num = len(mssi.saleclerks)
+ mssi.save()
+
+ mssi, _ = ModelSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ model_name=model.model_uni_name,
+ ymd=ymd[:4],
+ )
+ mssi.saleclerks += [clerk.clerk_id]
+ mssi.num = len(mssi.saleclerks)
+ mssi.save()
+
+ # 经销商销量统计
+ dssi, _ = DistributorSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ distributor_id=distributor.distributor_id,
+ ymd=ymd,
+ )
+ dssi.distributor_name = distributor.distributor_name
+ dssi.num += 1
+ dssi.save()
+
+ dssi2, _ = DistributorSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ distributor_id=distributor.distributor_id,
+ ymd=0,
+ )
+ dssi2.distributor_name = distributor.distributor_name
+ dssi2.num += 1
+ dssi2.save()
+
+ # 日省份销量统计
+ pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ province_code=distributor.distributor_province_code,
+ ymd=ymd,
+ )
+ pssi.province_name = distributor.distributor_province_name
+ pssi.num += 1
+ pssi.save()
+ # 月省份销量统计
+ pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ province_code=distributor.distributor_province_code,
+ ymd=ymd[:6],
+ )
+ pssi.province_name = distributor.distributor_province_name
+ pssi.num += 1
+ pssi.save()
+ # 年省份销量统计
+ pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ province_code=distributor.distributor_province_code,
+ ymd=ymd[:4],
+ )
+ pssi.province_name = distributor.distributor_province_name
+ pssi.num += 1
+ pssi.save()
+
+ # 日销售员销量统计
+ sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ clerk_id=clerk.clerk_id,
+ ymd=ymd,
+ )
+ sssi.distributor_id = distributor.distributor_id
+ sssi.distributor_name = distributor.distributor_name
+ sssi.distributor_short_name = distributor.distributor_short_name
+ sssi.clerk_name = clerk.clerk_name
+ sssi.num += 1
+ sssi.save()
+ # 月销售员销量统计
+ sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ clerk_id=clerk.clerk_id,
+ ymd=ymd[:6],
+ )
+ sssi.distributor_id = distributor.distributor_id
+ sssi.distributor_name = distributor.distributor_name
+ sssi.distributor_short_name = distributor.distributor_short_name
+ sssi.clerk_name = clerk.clerk_name
+ sssi.num += 1
+ sssi.save()
+ # 年销售员销量统计
+ sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create(
+ brand_id=brand.brand_id,
+ clerk_id=clerk.clerk_id,
+ ymd=ymd[:4],
+ )
+ sssi.distributor_id = distributor.distributor_id
+ sssi.distributor_name = distributor.distributor_name
+ sssi.distributor_short_name = distributor.distributor_short_name
+ sssi.clerk_name = clerk.clerk_name
+ sssi.num += 1
+ sssi.save()