import os import time from django.views.generic.base import View from obs import ObsClient from Model.models import FreeEvaluationActivity, ActivityTime, ActivityUser, Device_User from Object.AWS.AmazonS3Util import AmazonS3Util from Object.Enums.RedisKeyConstant import RedisKeyConstant from Object.RedisObject import RedisObject from Object.ResponseObject import ResponseObject from Object.TokenObject import TokenObject from Ansjer.config import SERVER_DOMAIN, LOGGER, HUAWEICLOUD_AK, HUAWEICLOUD_SK, HUAWEICLOUD_OBS_SERVER, \ HUAWEICLOUD_SERVER_BUKET 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) elif operation == 'addStoryCollectionUser': # 新增故事征集客户信息 return self.add_story_collection_user(user_id, request_dict, response) elif operation == 'addStoryCollectionUserSuccess': # 新增故事征集客户信息成功回调 return self.add_story_collection_user_success(user_id, request_dict, response) else: return response.json(404) @staticmethod def get_activity(user_id, request_dict, response): try: now_time = int(time.time()) activity_id = request_dict.get('activityId') activity_qs = FreeEvaluationActivity.objects.filter(is_show=1) if activity_id: activity_qs = activity_qs.filter(id=int(activity_id)) activity_qs = activity_qs.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).values('registration_status') if user.exists(): if user[0]['registration_status']: activity['activity_status'] = 2 # 1:可报名；2：已报名；3：报名截止；4：活动结束 else: activity['activity_status'] = 1 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) with transaction.atomic(): if activity_id: # 编辑活动 activity = FreeEvaluationActivity.objects.get(id=activity_id) activity.activity_name = activity_name activity.issue = issue activity.product_number = product_number activity.product_name = product_name activity.original_price = original_price activity.is_show = is_show activity.update_time = now_time # 上传轮播图 if carousel_image: carousel_image_path = '前端/EvaluationActivity/carousel_image_{}.jpg'.format(activity_id) s3_obj.upload_file_obj( bucket, carousel_image_path, carousel_image, {"ContentType": carousel_image.content_type, "ACL": "public-read"}, ) activity.carousel_image_url = s3_url + carousel_image_path # 上传详情图 if details_image: details_image_path = '前端/EvaluationActivity/details_image_{}.jpg'.format(activity_id) s3_obj.upload_file_obj( bucket, details_image_path, details_image, {"ContentType": details_image.content_type, "ACL": "public-read"}, ) activity.details_image_url = s3_url + details_image_path activity.save() # 处理活动时间节点 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) # 创建活动对象（先不保存图片URL） activity = FreeEvaluationActivity.objects.create( activity_name=activity_name, issue=issue, product_number=product_number, product_name=product_name, original_price=original_price, is_show=is_show, created_time=now_time, update_time=now_time, carousel_image_url='', # 初始化为空 details_image_url='' ) activity_id = activity.id # 上传轮播图并更新URL carousel_image_path = '前端/EvaluationActivity/carousel_image_{}.jpg'.format(activity_id) s3_obj.upload_file_obj( bucket, carousel_image_path, carousel_image, {"ContentType": carousel_image.content_type, "ACL": "public-read"}, ) activity.carousel_image_url = s3_url + carousel_image_path # 上传详情图并更新URL details_image_path = '前端/EvaluationActivity/details_image_{}.jpg'.format(activity_id) s3_obj.upload_file_obj( bucket, details_image_path, details_image, {"ContentType": details_image.content_type, "ACL": "public-read"}, ) activity.details_image_url = s3_url + details_image_path activity.save() # 保存图片URL # 创建活动时间节点 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 ) # 初始化Redis客户端，使用4号数据库 redis_client = RedisObject(4) redis_key = RedisKeyConstant.ACTIVITY_INFO.value redis_client.del_data(redis_key) 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() # 华为云 obs_client = ObsClient( access_key_id=HUAWEICLOUD_AK, secret_access_key=HUAWEICLOUD_SK, server=HUAWEICLOUD_OBS_SERVER) user_qs = user_qs.values('id', 'user_name', 'phone', 'age', 'address', 'sex', 'is_selected', 'activity_id', 'usage_environment', 'is_reports', 'story', 'file_1_name', 'file_2_name')[(page - 1) * line:page * line] activity_list = [] for item in user_qs: activity_dict = {'id': item['id'], 'user_name': item['user_name'], 'phone': item['phone'], 'age': item['age'], 'address': item['address'], 'sex': item['sex'], 'is_selected': item['is_selected'], 'activity_id': item['activity_id'], 'usage_environment': item['usage_environment'], 'is_reports': item['is_reports'], 'story': item['story'], 'file_1_name': '', 'file_2_name': ''} if item['file_1_name']: create_res = obs_client.createSignedUrl( method='GET', bucketName=HUAWEICLOUD_SERVER_BUKET, objectKey=item['file_1_name'], expires=300) activity_dict['file_1_name'] = create_res.signedUrl if item['file_2_name']: create_res = obs_client.createSignedUrl( method='GET', bucketName=HUAWEICLOUD_SERVER_BUKET, objectKey=item['file_1_name'], expires=300) activity_dict['file_2_name'] = create_res.signedUrl activity_list.append(activity_dict) return response.json(0, {'list': activity_list, '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))) @staticmethod def add_story_collection_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) story = request_dict.get('story', None) file_name_list = request_dict.get('file_name_list') if not all([activity_id, user_name, phone, address, sex, age, usage_environment, story]): return response.json(404) now_time = int(time.time()) try: data = { 'user_name': user_name, 'phone': phone, 'address': address, 'sex': sex, 'age': age, 'story': story, 'usage_environment': usage_environment, 'update_time': now_time } signed_url = [] # 如果上传文件,生成华为云OBS上传链接 if file_name_list: # 报名状态暂时设置为不成功 data['registration_status'] = 0 obs_client = ObsClient( access_key_id=HUAWEICLOUD_AK, secret_access_key=HUAWEICLOUD_SK, server=HUAWEICLOUD_OBS_SERVER ) file_name_list = eval(file_name_list) for index, file_name in enumerate(file_name_list): file_name = str(index) + os.path.splitext(file_name)[1] file_name = 'story-collection/{}/{}'.format(user_id, file_name) if index == 0: data['file_1_name'] = file_name else: data['file_2_name'] = file_name res = obs_client.createSignedUrl( method='PUT', bucketName=HUAWEICLOUD_SERVER_BUKET, objectKey=file_name, expires=3600 ) signed_url.append(res.signedUrl) user = ActivityUser.objects.filter(user_id=user_id, activity_id=activity_id) if user.exists(): user.update(**data) else: data['activity_id'] = activity_id data['user_id'] = user_id data['created_time'] = now_time ActivityUser.objects.create(**data) if signed_url: res = { 'signed_url': signed_url } return response.json(0, res) 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_story_collection_user_success(user_id, request_dict, response): activity_id = request_dict.get('activity_id', None) try: ActivityUser.objects.filter(user_id=user_id, activity_id=activity_id).update(registration_status=1) return response.json(0) except Exception as e: return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))