parent
c1cfc46a8b
commit
b786e0ddc1
16 changed files with 9038 additions and 57 deletions
@ -0,0 +1,54 @@ |
||||
from dspt_api.util.general.handle_redis import get_data_from_redis |
||||
from dspt_api.util.general.handle_seat import general_seat_params |
||||
from dspt_api.util.general.get_order_num import general_order_num |
||||
import random |
||||
|
||||
|
||||
class ApiSeatLockBuy: |
||||
def __init__(self, **kwargs): |
||||
self.member_type = kwargs.get('member_type') |
||||
self.api = kwargs.get('api') |
||||
self.ip = kwargs.get('ip') |
||||
self.env = kwargs.get('env') |
||||
self.cid = kwargs.get('cid') |
||||
self.pid = kwargs.get('pid') |
||||
self.sale_type = kwargs.get('sale_type') |
||||
self.pay_type = kwargs.get('pay_type') |
||||
self.user_data = { |
||||
'ip': self.ip, |
||||
'env': self.env, |
||||
'member_type': self.member_type, |
||||
'pid': self.pid, |
||||
'cid': self.cid, |
||||
} |
||||
|
||||
def get_suggestion(self): |
||||
return_data = [{'param': 'mobile', 'value': '18688886666', 'is_checked': True, 'result': True}] |
||||
# _ticket_result, _goods_result = False, False |
||||
|
||||
if self.sale_type in ['ticket', 'all']: |
||||
_ticket_result, _seat, _ticket_cash, _play_id, _play_update_time, _lock_flag, _ticket_timestamp = general_seat_params( |
||||
self.pay_type, self.user_data) |
||||
print('general_seat_params', _ticket_result, _seat, _ticket_cash, _play_id, _play_update_time, _lock_flag, _ticket_timestamp) |
||||
_partner_buy_ticket_id = general_order_num('BUY', self.api, self.member_type, self.ip, self.env, self.pid, |
||||
self.cid) |
||||
return_data.append({'param': 'play_id', 'value': _play_id, 'is_checked': True, 'result': True}) |
||||
return_data.append({'param': 'seat', 'value': _seat, 'is_checked': True, 'result': True}) |
||||
return_data.append({'param': 'lock_flag', 'value': _lock_flag, 'is_checked': True, 'result': True}) |
||||
return_data.append( |
||||
{'param': 'play_update_time', 'value': _play_update_time, 'is_checked': True, 'result': True}) |
||||
return_data.append( |
||||
{'param': 'partner_buy_ticket_id', 'value': _partner_buy_ticket_id, 'is_checked': True, 'result': True}) |
||||
return_data.append({'param': 'cash', 'value': _ticket_cash, 'is_checked': True, 'result': True}) |
||||
|
||||
elif self.sale_type in ['goods', 'all']: |
||||
pass |
||||
else: |
||||
pass |
||||
return return_data |
||||
|
||||
def get_timestamp(self): |
||||
_ticket_result, _seat, _ticket_cash, _play_id, _play_update_time, _lock_flag, _ticket_timestamp = general_seat_params( |
||||
self.pay_type, self.user_data) |
||||
|
||||
return _ticket_timestamp |
||||
@ -0,0 +1,121 @@ |
||||
""" |
||||
说明： |
||||
支持现金、联名卡支付，电子券支付，扫码券支付 |
||||
现金支付时，可以走电商渠道定价 |
||||
联名卡支付时，价格取联名卡的优惠价，支付方式还是现金 |
||||
电子券和扫码券都是走鼎新定价，然后通过券接口获取价格，剩余待支付的金额为现金支付 |
||||
券只支持如下几种券： |
||||
|
||||
先从seat_lock接口获取座位价格 |
||||
如果seat_lock没有获取到座位价格就到 |
||||
|
||||
返回 结果, seat , ticket_cash, play_id, play_update_time, lock_flag, timestamp |
||||
""" |
||||
import random |
||||
from decimal import Decimal, ROUND_HALF_UP |
||||
from dspt_api.util.general.handle_redis import get_data_from_redis |
||||
|
||||
|
||||
def general_seat_params(pay_type, data): |
||||
redis_key_prefix = f'dspt_api_{data["ip"]}_{data["env"]}_{data["member_type"]}_{data["pid"]}_{data["cid"]}' |
||||
|
||||
# 获取 area_info和partner_price |
||||
request_api_lock = {'name': '3.3.1 座位锁定', 'path': 'seat/lock'} |
||||
redis_key_api_lock = f'{redis_key_prefix}_{request_api_lock["path"]}' |
||||
result_lock, _format_lock, seat_price_from_lock, _timestamp_lock = get_data_from_redis(redis_key_api_lock) |
||||
area_info = seat_price_from_lock['areaInfo'] if len(seat_price_from_lock['areaInfo']) > 0 else False |
||||
lock_flag = seat_price_from_lock['lockFlag'] |
||||
# partner_price = seat_price_from_lock['partnerPrice'] if seat_price_from_lock['partnerPrice'] is not None else False |
||||
|
||||
# 获取market_price |
||||
request_api_play = {'name': '3.1.5 获取放映计划列表', 'path': 'cinema/plays'} |
||||
redis_key_api_play = f'{redis_key_prefix}_{request_api_play["path"]}' |
||||
result_play, _format_play, seat_price_from_play, _timestamp_play = get_data_from_redis(redis_key_api_play) |
||||
market_price = seat_price_from_play['marketPrice'] |
||||
play_id = seat_price_from_play['id'] |
||||
play_update_time = seat_price_from_play['cineUpdateTime'] |
||||
|
||||
# 获取手续费 |
||||
request_api_config = {'name': '3.1.2 获取单个影院配置信息', 'path': 'cinema/config'} |
||||
redis_key_api_config = f'{redis_key_prefix}_{request_api_config["path"]}' |
||||
result_config, _format_config, seat_price_from_config, _timestamp_config = get_data_from_redis(redis_key_api_config) |
||||
handle_fee = seat_price_from_config['handleFee'] |
||||
partner_type = seat_price_from_config['partnerSubsidyType'] # 1：电商平台补贴；2：合作商补贴 |
||||
|
||||
# 获取座位信息 |
||||
request_api_seat = {'name': '3.1.8 获取某场次座位状态', 'path': 'play/seat-status'} |
||||
redis_key_api_seat = f'{redis_key_prefix}_{request_api_seat["path"]}' |
||||
result_seat, _format_seat, seat_price_from_seat, _timestamp_seat = get_data_from_redis(redis_key_api_seat) |
||||
seat_id_list = [{'seat_id': seat['cineSeatId'], 'ticket_discount': seat['ticketDiscount'], |
||||
'service_discount': seat['serviceDiscount']} for seat in seat_price_from_seat] |
||||
|
||||
# 计算最大时间戳 |
||||
last_timestamp = max([_timestamp_lock, _timestamp_play, _timestamp_config, _timestamp_seat]) |
||||
|
||||
# 判断获取到了全部接口数据，就继续，否则报错 |
||||
if not (result_lock and result_play and result_config and result_seat): |
||||
return_str = '请手动输入参数，检查相关接口返回值：3.3.1 座位锁定、3.1.5 获取放映计划列表、3.1.8 获取某场次座位状态、3.1.2 获取单个影院配置信息' |
||||
return False, return_str, 0, return_str, return_str, return_str, last_timestamp |
||||
|
||||
if pay_type == 'cash': |
||||
""" |
||||
-- 当影院合作商是电商平台定价时（partner_type = 1） |
||||
price：不包含手续费,含服务费 |
||||
user_real_pay_price：用户真实支付影票金额，不含手续费、服务费，该字段只做记录不参与计算 |
||||
service_fee：影厅座位服务费（仅当锁座接口返回的服务费[areaServiceFee]不为零时，才传此参数） |
||||
ticket_discount_price：影票优惠金额; service_fee_discount_price：服务费优惠金额， |
||||
注：如果是鼎新电商平台对合作商价格管控，使用以上两个优惠金额字段需要联系请联系鼎新杰盈公司商务打开开关即可使用，否则直接回传会产生掉单。 |
||||
-- 当影院合作商是合作商自主定价时（partner_type = 2） |
||||
price：真实的票价[不含服务费、不含手续费] |
||||
user_real_pay_price：用户真实支付影票金额[不含手续费、服务费] 需要扣减 ticket_discount_price |
||||
service_fee：真实的服务费 需要扣减 service_fee_discount_price |
||||
ticket_discount_price：影票优惠金额，仅做记录 |
||||
service_fee_discount_price：服务费优惠金额，仅做记录 |
||||
|
||||
测试影院： |
||||
测试影院3.166 乐影网 电商平台补贴 是否允许传递优惠金额 否 影票价格控制 是 卖品价格控制 是 |
||||
测试影院3.166 淘票票 电商平台补贴 是否允许传递优惠金额 是 影票价格控制 否 卖品价格控制 否 |
||||
测试影院3.166 美团猫眼 电商平台补贴 是否允许传递优惠金额 否 影票价格控制 是 卖品价格控制 是 |
||||
测试影院3.166 合作商补贴 合作商补贴 是否允许传递优惠金额 否 影票价格控制 否 卖品价格控制 否 |
||||
|
||||
""" |
||||
seat_list = [] |
||||
ticket_cash = 0 |
||||
for seat_info in seat_id_list: |
||||
ticket_discount = seat_info["ticket_discount"] |
||||
service_discount = seat_info["service_discount"] |
||||
if area_info is not False: |
||||
for area_seat_info in area_info: |
||||
if area_seat_info['seatId'] == int(seat_info['seat_id']): |
||||
price = Decimal(area_seat_info["areaPrice"]).quantize(Decimal('0.00'), ROUND_HALF_UP) |
||||
# if partner_type == '2': # 合作商定价 |
||||
# price -= Decimal(area_seat_info["areaServiceFee"]).quantize(Decimal('0.00'), ROUND_HALF_UP) |
||||
real_pay = Decimal(area_seat_info["areaPrice"]).quantize(Decimal('0.00'), ROUND_HALF_UP) |
||||
real_pay -= Decimal(area_seat_info["areaServiceFee"]).quantize(Decimal('0.00'), ROUND_HALF_UP) |
||||
if ticket_discount != 0: |
||||
real_pay -= Decimal(ticket_discount) |
||||
if service_discount != 0: |
||||
if partner_type == '2': |
||||
real_pay -= Decimal(service_discount) |
||||
seat = f'{seat_info["seat_id"]}-{handle_fee}-{str(price)}-{str(real_pay)}-{area_seat_info["areaServiceFee"]}{f"-{str(ticket_discount)}" if ticket_discount != 0 else ""}{f"-{str(service_discount)}" if service_discount != 0 else ""}' |
||||
seat_list.append(seat) |
||||
ticket_cash += real_pay |
||||
else: |
||||
real_pay = Decimal(market_price).quantize(Decimal('0.00'), ROUND_HALF_UP) |
||||
if ticket_discount != 0: |
||||
real_pay -= Decimal(ticket_discount) |
||||
if service_discount != 0: |
||||
real_pay -= Decimal(service_discount) |
||||
seat = f'{seat_info["seat_id"]}-{handle_fee}-{market_price}-{str(real_pay)}-0{f"-{str(ticket_discount)}" if ticket_discount != 0 else ""}{f"-{str(service_discount)}" if service_discount != 0 else ""}' |
||||
seat_list.append(seat) |
||||
ticket_cash += real_pay |
||||
return True, ','.join(seat_list), ticket_cash, play_id, play_update_time, lock_flag, last_timestamp |
||||
|
||||
elif pay_type == 'ecard': |
||||
pass |
||||
elif pay_type == 'yushouquan': |
||||
pass |
||||
elif pay_type == 'equan': |
||||
pass |
||||
else: |
||||
pass |
||||
File diff suppressed because it is too large
Load Diff
Loading…
Reference in new issue