debug

dspt_api/util/general/suggest_params.py

@@ -25,6 +25,7 @@ from dspt_api.util.api.order_ticket_flag import ApiOrderTicketFlag
 from dspt_api.util.api.order_status import ApiOrderStatus
 from dspt_api.util.api.order_info import ApiOrderInfo
 from dspt_api.util.api.goods_deduct import ApiGoodsDeduct
+from dspt_api.util.mapi.play_seat_status import MapiPlaySeatStatus
 
 
 # 通过api来匹配不同的接口文件获取推荐
@@ -150,6 +151,13 @@ def suggest_params(member_type, api, env, cid, pid, ip, **kwargs):
         print("kwargs['sale_type']", kwargs['sale_type'])
         data['sale_type'] = kwargs['sale_type']
         params = ApiSeatCheckCoupon(**data).get_suggestion()
+
+    # 会员
+    # 3.2.6 获取场次座位状态
+    if api == 'play/seat-status' and member_type == 'member':
+        print('play/seat-status')
+        params = MapiPlaySeatStatus(**data).get_suggestion()
+
     return params
 
 def suggest_params_timestamp(member_type, api, env, cid, pid, ip, **kwargs):
@@ -268,4 +276,13 @@ def suggest_params_timestamp(member_type, api, env, cid, pid, ip, **kwargs):
         print("kwargs['sale_type']", kwargs['sale_type'])
         data['sale_type'] = kwargs['sale_type']
         _timestamps = ApiSeatCheckCoupon(**data).get_timestamp()
+
+    # 会员
+    # 3.2.6 获取场次座位状态
+    if api == 'play/seat-status' and member_type == 'member':
+        print('play/seat-status')
+        _timestamps = MapiPlaySeatStatus(**data).get_timestamp()
+
     return _timestamps
+
+

dspt_api/util/mapi/play_seat_status.py

@@ -0,0 +1,49 @@
+from dspt_api.util.general.handle_redis import get_data_from_redis
+import time
+
+
+class MapiPlaySeatStatus:
+    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.user_data = {
+            'ip': self.ip,
+            'env': self.env,
+            'member_type': self.member_type,
+            'pid': self.pid,
+            'cid': self.cid,
+        }
+        self.return_data = []
+
+    def get_suggestion(self):
+        # play_id play_update_time
+        print('get_suggestion', self.user_data)
+        self.handle()
+        return self.return_data
+
+    def get_timestamp(self):
+        # play_id play_update_time
+        redis_key_prefix = f'dspt_api_{self.ip}_{self.env}_{self.member_type}_{self.pid}_{self.cid}'
+        request_api_play_seat_status = {'name': '3.2.3 获取放映计划列表', 'path': 'cinema/plays'}
+        redis_key_api_play_seat_status = f'{redis_key_prefix}_{request_api_play_seat_status["path"]}'
+        result, _format, play_data, _timestamp = get_data_from_redis(redis_key_api_play_seat_status)
+        return _timestamp if result else 0
+
+    def handle(self):
+        redis_key_prefix = f'dspt_api_{self.ip}_{self.env}_{self.member_type}_{self.pid}_{self.cid}'
+        request_api_play_seat_status = {'name': '3.2.3 获取放映计划列表', 'path': 'cinema/plays'}
+        redis_key_api_play_seat_status = f'{redis_key_prefix}_{request_api_play_seat_status["path"]}'
+        result, _format, play_data, _timestamp = get_data_from_redis(redis_key_api_play_seat_status)
+        if not result:
+            self.add_param('play_id', '请手动输入参数，或先请求接口：3.2.3 获取放映计划列表')
+            self.add_param('play_update_time', '请手动输入参数，或先请求接口：3.2.3 获取放映计划列表')
+        self.add_param('play_id', play_data['id'])
+        self.add_param('play_update_time', play_data['cineUpdateTime'])
+
+    def add_param(self, field, value, is_checked=True, result=True, timestamp=int(time.time() * 1000)):
+        self.return_data.append(
+            {'param': field, 'value': value, 'is_checked': is_checked, 'result': result, 'timestamp': timestamp})

dspt_api/views.py

@@ -308,6 +308,9 @@ def set_user_select_data(request):
     member_type = req.get('member_type')
     resp_format = 'xml' if req.get('format') == 'html' else req.get('format')
     user_data = req.get('user_data')
+    print('request.META', request.META)
+    print('request.body', request.body)
+    print('request', request)
     user_ip = request.META.get('REMOTE_ADDR')
     env = req.get('env')
     pid = req.get('pid')