#!/usr/bin/env python3 # -*- coding: utf-8 -*- """ @Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved. @AUTHOR: ASJRD018 @NAME: AnsjerFormal @software: PyCharm @DATE: 2024年7月29日15:51:04 @Version: python3.6 @MODIFY DECORD:ansjer dev """ import time from django.views.generic.base import View from Model.models import FreeEvaluationActivity, ActivityTime, ActivityUser, Device_User from Object.AWS.AmazonS3Util import AmazonS3Util from Object.ResponseObject import ResponseObject from Object.TokenObject import TokenObject from Ansjer.config import SERVER_DOMAIN, LOGGER from Ansjer.cn_config.config_formal import SECRET_ACCESS_KEY, ACCESS_KEY_ID, REGION_NAME from django.db import transaction class EvaluationActivityView(View): def get(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.GET, request, operation) def post(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.POST, request, operation) def validation(self, request_dict, request, operation): language = request_dict.get('language', 'en') response = ResponseObject(language, 'pc') tko = TokenObject(request.META.get('HTTP_AUTHORIZATION'), returntpye='pc') if tko.code != 0: return response.json(tko.code) response.lang = tko.lang user_id = tko.userID if operation == 'getActivity': return self.get_activity(user_id, request_dict, response) elif operation == 'getActivityList': return self.get_activity_list(request_dict, response) elif operation == 'addOrEditActivity': return self.add_or_edit_activity(request, request_dict, response) elif operation == 'getActivityUser': return self.get_user_list(request_dict, response) elif operation == 'addActivityUser': return self.add_activity_user(user_id, request_dict, response) elif operation == 'editActivityUser': return self.edit_activity_user(request_dict, response) else: return response.json(404) @staticmethod def get_activity(user_id, request_dict, response): try: now_time = int(time.time()) activity_qs = FreeEvaluationActivity.objects.filter(is_show=1).values('activity_name', 'carousel_image_url', 'details_image_url', 'issue', 'id', 'product_number', 'original_price', 'product_name') if activity_qs.exists(): activity = activity_qs[0] time_qs = ActivityTime.objects.filter(activity_id=activity['id']).values('node_content', 'start_time', 'end_time').order_by('sort') activity['activity_start_time'] = time_qs.first()['start_time'] activity['activity_end_time'] = time_qs.last()['end_time'] activity['activity_process'] = list(time_qs) user_qs = ActivityUser.objects.filter(activity_id=activity['id']) activity['user_count'] = user_qs.count() if user_qs.exists(): user = user_qs.filter(user_id=user_id) if user.exists(): activity['activity_status'] = 2 # 1:可报名；2：已报名；3：报名截止；4：活动结束 else: activity['activity_status'] = 1 user_qs = user_qs.filter(is_selected=1).values('user_name', 'phone', 'user_id') for item in user_qs: users = Device_User.objects.filter(userID=item['user_id']).values('userIconPath') if users.exists(): user_icon_path = str(users[0]['userIconPath']) if user_icon_path and user_icon_path.find('static/') != -1: user_icon_path = user_icon_path.replace('static/', '').replace('\\', '/') item['user_icon'] = SERVER_DOMAIN + 'account/getAvatar/' + user_icon_path else: item['user_icon'] = '' else: item['user_icon'] = '' item['phone'] = item['phone'][:3] + "****" + item['phone'][7:] activity['activity_user'] = list(user_qs) else: activity['activity_status'] = 1 activity['activity_user'] = [] if now_time > time_qs.first()['end_time']: activity['activity_status'] = 3 if now_time > time_qs.last()['end_time']: activity['activity_status'] = 4 return response.json(0, activity) else: return response.json(0, {}) except Exception as e: return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e))) @staticmethod def add_activity_user(user_id, request_dict, response): activity_id = request_dict.get('activity_id', None) user_name = request_dict.get('user_name', None) phone = request_dict.get('phone', None) address = request_dict.get('address', None) sex = request_dict.get('sex', None) age = request_dict.get('age', None) usage_environment = request_dict.get('usage_environment', None) is_reports = request_dict.get('is_reports', None) if not all([activity_id, user_name, phone, address, sex, age, usage_environment, is_reports]): return response.json(404) now_time = int(time.time()) try: user = ActivityUser.objects.filter(user_id=user_id, activity_id=activity_id) if user.exists(): user.update(phone=phone, address=address, sex=sex, user_name=user_name, is_reports=is_reports, age=age, usage_environment=usage_environment, update_time=now_time) else: ActivityUser.objects.create(activity_id=activity_id, user_id=user_id, phone=phone, address=address, sex=sex, age=age, usage_environment=usage_environment, user_name=user_name, is_reports=is_reports, created_time=now_time, update_time=now_time) return response.json(0) except Exception as e: return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e))) @staticmethod def add_or_edit_activity(request, request_dict, response): activity_id = request_dict.get('activity_id', None) activity_name = request_dict.get('activity_name', None) carousel_image = request.FILES.get('carousel_image', None) details_image = request.FILES.get('details_image', None) issue = request_dict.get('issue', None) product_number = request_dict.get('product_number', None) product_name = request_dict.get('product_name', None) original_price = request_dict.get('original_price', None) activity_process = request_dict.get('activity_process', None) is_show = request_dict.get('is_show', None) if not all([activity_name, issue, product_number, original_price, is_show, activity_process, product_name]): return response.json(404) now_time = int(time.time()) activity_process = eval(activity_process) try: bucket = "ansjerfilemanager" s3_obj = AmazonS3Util(ACCESS_KEY_ID, SECRET_ACCESS_KEY, REGION_NAME) s3_url = 'https://{}.s3.{}.amazonaws.com.cn/'.format(bucket, REGION_NAME) if carousel_image: carousel_image_path = '前端/EvaluationActivity/carousel_image_{}.jpg'.format(issue) s3_obj.upload_file_obj( bucket, carousel_image_path, carousel_image, {"ContentType": carousel_image.content_type, "ACL": "public-read"}, ) carousel_image_url = s3_url + carousel_image_path if activity_id: FreeEvaluationActivity.objects.filter(id=activity_id).update(carousel_image_url=carousel_image_url) if details_image: details_image_path = '前端/EvaluationActivity/details_image_{}.jpg'.format(issue) s3_obj.upload_file_obj( bucket, details_image_path, details_image, {"ContentType": details_image.content_type, "ACL": "public-read"}, ) details_image_url = s3_url + details_image_path if activity_id: FreeEvaluationActivity.objects.filter(id=activity_id).update(details_image_url=details_image_url) with transaction.atomic(): if activity_id: # 编辑活动 FreeEvaluationActivity.objects.filter(id=activity_id).update(issue=issue, product_name=product_name, product_number=product_number, original_price=original_price, is_show=is_show, update_time=now_time, activity_name=activity_name) ActivityTime.objects.filter(activity_id=activity_id).delete() for index, item in enumerate(activity_process): ActivityTime.objects.create(activity_id=activity_id, node_content=item['node_content'], start_time=item['start_time'], end_time=item['end_time'], sort=index) else: # 增加活动 if not all([carousel_image, details_image]): return response.json(404) activity_qs = FreeEvaluationActivity.objects.create(activity_name=activity_name, issue=issue, product_number=product_number, carousel_image_url=carousel_image_url, is_show=is_show, product_name=product_name, original_price=original_price, details_image_url=details_image_url, created_time=now_time, update_time=now_time) for index, item in enumerate(activity_process): ActivityTime.objects.create(activity_id=activity_qs.id, node_content=item['node_content'], start_time=item['start_time'], end_time=item['end_time'], sort=index) return response.json(0) except Exception as e: return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e))) @staticmethod def get_activity_list(request_dict, response): page = request_dict.get('page', None) line = request_dict.get('line', None) if not all([page, line]): return response.json(444) try: page = int(page) line = int(line) activity_qs = FreeEvaluationActivity.objects.all() count = activity_qs.count() activity_qs = activity_qs.values('id', 'activity_name', 'carousel_image_url', 'details_image_url', 'issue', 'is_show', 'product_number', 'original_price', 'product_name')[ (page - 1) * line: page * line] for item in activity_qs: time_qs = ActivityTime.objects.filter(activity_id=item['id']).values('node_content', 'start_time', 'end_time').order_by('sort') item['activity_process'] = list(time_qs) return response.json(0, {'list': list(activity_qs), 'count': count}) except Exception as e: return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e))) @staticmethod def get_user_list(request_dict, response): activity_id = request_dict.get('activity_id', None) user_name = request_dict.get('user_name', None) phone = request_dict.get('phone', None) page = request_dict.get('page', None) line = request_dict.get('line', None) if not all([activity_id, page, line]): return response.json(444) try: page = int(page) line = int(line) user_qs = ActivityUser.objects.filter(activity_id=activity_id) if user_name: user_qs = user_qs.filter(user_name=user_name) if phone: user_qs = user_qs.filter(phone=phone) count = user_qs.count() user_qs = user_qs.values('id', 'user_name', 'phone', 'age', 'address', 'sex', 'is_selected', 'activity_id', 'usage_environment', 'is_reports')[(page - 1) * line:page * line] return response.json(0, {'list': list(user_qs), 'count': count}) except Exception as e: return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e))) @staticmethod def edit_activity_user(request_dict, response): activity_id = request_dict.get('activity_id', None) user_id = request_dict.get('user_id', None) is_selected = request_dict.get('is_selected', None) try: ActivityUser.objects.filter(activity_id=activity_id, id=user_id).update(is_selected=is_selected) return response.json(0) except Exception as e: return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))