from django.shortcuts import render from django.http import HttpResponse, HttpResponseRedirect, JsonResponse from datetime import datetime, timedelta, date from django.forms.models import model_to_dict import json from .data import ADMIN_PSW from .setting import APPLICATION_NAME, get_media_url_prefix from .functions import is_volunteer_login, upload_file, get_ext, msg_and_direct, service_log from .models import Volunteer, ServiceTimeSlot, ServiceBooking, Bonus, BonusRecord, CreditRecord # from Niko.settings import DEBUG, ENVIRONMENT from django.db import transaction from backend.wechat import WeChatOA2, WeChatMsg from Niko.settings import DEBUG import csv # Create your views here. def index(request): if request.method == 'GET': # 尝试微信登录 if 'micromessenger' in request.META['HTTP_USER_AGENT'].lower(): wechat_id = request.session.get('wechat_openid') if DEBUG: service_log('打印session中的微信wechat_openid') service_log(wechat_id) if wechat_id is None: return HttpResponseRedirect('/cq/volunteer/wechat_entry/') else: wechat_id = None # wechat_id = 'o3MJZ02eAuLBNSMson2NeI19135Y' if wechat_id: volunteer = Volunteer.get_by_wechat_id(wechat_id) if volunteer: if volunteer.status == 'active': request.session['volunteer_id'] = volunteer.ID redirect_uri = request.session.get('redirect_uri') # 检索是否需要重定向 if redirect_uri is None: redirect_uri = '/cq/volunteer/home/' else: request.session.pop('redirect_uri') return HttpResponseRedirect(redirect_uri) else: request.session.flush() return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '账户未激活', 'dirLink': '/cq/volunteer/'}) return render(request, 'volunteer_arrangement/index.html', {'buttom_bg_color': 'rgb(88, 167, 255)'}) if request.method == 'POST': volunteer = Volunteer.get_by_mobile_social_id(request.POST['mobile'], request.POST['social_id'].upper().strip()) if volunteer: if volunteer.status == 'active': request.session['volunteer_id'] = volunteer.ID if volunteer.wechat_id is None: # 如果用户没有wechat_id，就写入wechat_id volunteer.wechat_id = request.session.get('wechat_openid') volunteer.save() redirect_uri = request.session.get('redirect_uri') # 检索是否需要重定向 if redirect_uri is None: redirect_uri = '/cq/volunteer/home/' else: request.session.pop('redirect_uri') return HttpResponseRedirect(redirect_uri) else: return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '账户未激活', 'dirLink': '/cq/volunteer/'}) else: return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '手机号码和身份证错误', 'dirLink': '/cq/volunteer/'}) # 微信入口跳转 def wechat_entry(request): # 微信登录 wechat_oa2 = WeChatOA2() # 这里的Volunteer和Base是两个参数，表示volunteer应用调用微信登录，用户获取Base信息 return HttpResponseRedirect(wechat_oa2.snsapi_base('VolunteerBase')) def volunteer_reg(request): if request.method == 'GET': return render(request, 'volunteer_arrangement/volunteer_reg.html', {'title': '志愿者注册'}) if request.method == 'POST': if Volunteer.get_by_mobile(request.POST['mobile']) is None: volunteer = Volunteer() volunteer.status = 'pending' volunteer.name = request.POST['name'].strip() volunteer.mobile = request.POST['mobile'].strip() if len(volunteer.mobile) != 11: return msg_and_direct(request, 'http://127.0.0.1:8000/cq/volunteer/volunteer_reg/', '手机号码需要为11位') volunteer.gender = request.POST['gender'] volunteer.social_id = request.POST['social_id'].upper().strip() if len(volunteer.social_id) != 18: return msg_and_direct(request, 'http://127.0.0.1:8000/cq/volunteer/volunteer_reg/', '身份证号码需要为18位') volunteer.political_outlook = request.POST['political_outlook'] volunteer.organization = request.POST['organization'].strip() volunteer.district_street = request.POST['district_street'].strip() volunteer.save() return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '提交成功，请等待审批', 'dirLink': '/cq/volunteer'}) else: return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '手机号码已经注册过了', 'dirLink': '/cq/volunteer'}) # 志愿者编辑个人信息 def volunteer_update_info(request): if request.method == 'GET': # 验证登陆状态 if not request.session.get('volunteer_id'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请登录', 'dirLink': '/cq/volunteer'}) volunteer = Volunteer.get_by_id(request.session.get('volunteer_id')) return render(request, 'volunteer_arrangement/volunteer_update_info.html', {'volunteer': volunteer}) if request.method == 'POST': volunteer = Volunteer.get_by_id(request.session.get('volunteer_id')) if volunteer.mobile != int(request.POST['mobile']): # POST上来一个新的手机号码 if Volunteer.get_by_mobile(request.POST['mobile']) is not None: # 这个新的号码已经存在了 return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '手机号码已经注册过了', 'dirLink': '/cq/volunteer/update_info/'}) else: volunteer.status = 'pending' volunteer.name = request.POST['name'].strip() volunteer.mobile = request.POST['mobile'] volunteer.gender = request.POST['gender'] volunteer.social_id = request.POST['social_id'].upper() volunteer.political_outlook = request.POST['political_outlook'] volunteer.organization = request.POST['organization'].strip() volunteer.district_street = request.POST['district_street'].strip() volunteer.save() request.session.flush() return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '更新成功，请等待审批', 'dirLink': '/cq/volunteer'}) def volunteer_home(request): if request.method == 'GET': if not is_volunteer_login(request): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请登录', 'dirLink': '/cq/volunteer'}) available_address = ServiceTimeSlot.available_address() volunteer = Volunteer.get_by_id(request.session.get('volunteer_id')) return render(request, 'volunteer_arrangement/volunteer_home.html', {'address': available_address, 'volunteer': volunteer}) def admin(request): if request.method == 'GET': return render(request, 'volunteer_arrangement/admin_login.html') if request.method == 'POST': if request.POST['password'] == ADMIN_PSW: request.session['admin_login'] = True return HttpResponseRedirect('/cq/volunteer/admin_management/home/') else: return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '密码错误', 'dirLink': '/cq/volunteer/admin/'}) def admin_management(request, action): # 验证管理员登录状态 if not request.session.get('admin_login'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请重新登录管理员', 'dirLink': '/cq/volunteer/admin/'}) if action == 'home': return render(request, 'volunteer_arrangement/admin_home.html') if action == 'pending_list': pending_list = Volunteer.pending_list() return render(request, 'volunteer_arrangement/admin_pending_list.html', {'pending_list': pending_list}) if action == 'approve_volunteer': v_id = request.GET.get('v_id') Volunteer.approve_volunteer(v_id) # 微信推送批准消息 volunteer = Volunteer.get_by_id(v_id) if volunteer.wechat_id != None: wechat_msg = WeChatMsg(volunteer.wechat_id, '-WK6XrgmvW7cR7pZFwpHQwLVABd1dmzc3MXkXsQ6dGc', APPLICATION_NAME) wechat_msg.set_first('你已通过了审核') wechat_msg.add_keyboard(volunteer.name) wechat_msg.add_keyboard(volunteer.mobile) wechat_msg.add_keyboard(str(datetime.today().date())) wechat_msg.add_keyboard('通过') wechat_msg.set_remark('现在可以报名志愿者服务了。') wechat_msg.submit() return HttpResponseRedirect('/cq/volunteer/admin_management/home/') if action == 'reject_volunteer': v_id = request.GET.get('v_id') Volunteer.reject(v_id) return HttpResponseRedirect('/cq/volunteer/admin_management/home/') if action == 'create_service': if request.method == 'GET': return render(request, 'volunteer_arrangement/admin_create_service.html') if request.method == 'POST': if request.POST.get('day') == 'full_month': new_service_list = [] year = int(request.POST.get('year')) month = int(request.POST.get('month')) + 1 if month > 12: month -= 12 year += 1 service_year_month = datetime(year=year, month=month, day=1) service_year_month = service_year_month - timedelta(days=1) for x in range(service_year_month.day): service_timeslot = ServiceTimeSlot() service_timeslot.date = date(year=service_year_month.year, month=service_year_month.month, day=x + 1) service_timeslot.start_time = request.POST.get('start_time') service_timeslot.end_time = request.POST.get('end_time') service_timeslot.address = request.POST.get('address') service_timeslot.service_address = request.POST.get('service_address') service_timeslot.service_content = request.POST.get('service_content') service_timeslot.people_count = request.POST.get('people_count') new_service_list.append(service_timeslot) ServiceTimeSlot.objects.bulk_create(new_service_list) return msg_and_direct(request, '/cq/volunteer/admin_management/home/', message='成功添加{}条记录'.format(service_year_month.day)) elif request.POST.get('day') == 'not_full_month': service_timeslot = ServiceTimeSlot() service_timeslot.date = date(int(request.POST.get('year')), int(request.POST.get('month')), int(request.POST.get('date'))) service_timeslot.start_time = request.POST.get('start_time') service_timeslot.end_time = request.POST.get('end_time') service_timeslot.address = request.POST.get('address') service_timeslot.service_address = request.POST.get('service_address') service_timeslot.service_content = request.POST.get('service_content') service_timeslot.people_count = request.POST.get('people_count') service_timeslot.save() return msg_and_direct(request, '/cq/volunteer/admin_management/home/', '成功添加1条记录') if action == 'delete_service': if request.method == 'GET': booking_list = None # booking_overall_status = [] # 如果有日期就获取当天的报名状况 if request.GET.get('date'): service_date = request.GET['date'] service_address = request.GET.get('address') if request.GET.get('timeslot_id'): # 如果指定service timeslot id 就根据ID查找 service_list = ServiceTimeSlot.get_by_id(request.GET.get('timeslot_id')) else: service_list = ServiceTimeSlot.search_by_date_and_address(service_date, service_address) # service_list = ServiceTimeSlot.search_by_date(service_date) booking_list = ServiceBooking.search_by_service_timeslot_list(service_list) return render(request, 'volunteer_arrangement/admin_delete_service.html', {'booking_status': booking_list, 'date': str(request.GET.get('date'))}) if action == 'get_month_service': if request.method == 'GET': # 获取日期值 if request.GET.get('date'): service_date = request.GET.get('date') monthly_report = ServiceBooking.get_monthly_report(service_date) for item in monthly_report: # 添加一个tab，用来避免excel打开身份证号码最后几位显示为0的问题 item['volunteer_id__social_id'] = '\t' + item['volunteer_id__social_id'] # 获取数据,生成response response = HttpResponse(content_type='text/csv;charset=ANSI') response['Content-Disposition'] = 'attachment; filename="MonthlyReport.csv"' writer = csv.writer(response) # keys = monthly_report[0].keys() keys = ['日期', '开始时间', '结束时间', '服务地点', '姓名', '性别', '手机号码', '身份证号码', '政治面貌', '学校/单位', '居住区域（区或街道）'] writer.writerow(keys) for x in monthly_report: writer.writerow(x.values()) return response # 列出所有未来的志愿者服务 if action == 'future_timeslot': if request.method == 'GET': timeslots = ServiceTimeSlot.search_future_timeslots(datetime.today().date()) return render(request, 'volunteer_arrangement/admin_future_timeslots.html', {'timeslots': timeslots}) # 删除service time slot会cascade删除所有报名的记录 if action == 'delete_timeslot': if request.method == 'POST': timeslot_id = request.POST.get('timeslot_id') timeslot = ServiceTimeSlot.get_by_id(timeslot_id) # 微信通知删除者 notify_bookings = ServiceBooking.search_by_service_timeslot(timeslot) for booking in notify_bookings: if booking.volunteer_id.wechat_id is not None: wechat_msg = WeChatMsg(booking.volunteer_id.wechat_id, 'QKMJ1XFQoXWnxdc1ZDSXKraZpumcZbg_Ow8DdaP3Cuo', APPLICATION_NAME) wechat_msg.set_first('志愿者活动已取消') wechat_msg.add_keyboard('志愿者服务') wechat_msg.add_keyboard(str(booking.timeslot_id.date) + " " + str(booking.timeslot_id.start_time) + '-' + str(booking.timeslot_id.end_time)) wechat_msg.add_keyboard(booking.timeslot_id.address) wechat_msg.set_remark('你的志愿者服务，已被管理员取消。') wechat_msg.submit() pass timeslot.delete() return msg_and_direct(request, '/cq/volunteer/admin_management/home/', '活动删除成功，并解除所有报名') # 修改服务人数 if action == 'modify_people_count': if request.method == 'POST': timeslot_id = request.POST.get('timeslot_id') timeslot = ServiceTimeSlot.get_by_id(timeslot_id) new_people_count = int(request.POST.get('new_count')) if new_people_count < timeslot.booked_count: # 防止修改完成后的人数少于已经报名的人数 return_value = {'result': 'fail', 'code': 10} return JsonResponse(return_value) # return msg_and_direct(request, '/cq/volunteer/admin_management/future_timeslot/', '总人数少于已报名人数') else: timeslot.people_count = new_people_count timeslot.save() return_value = {'result': 'success'} return JsonResponse(return_value) # return msg_and_direct(request, '/cq/volunteer/admin_management/future_timeslot/', '修改成功') # 调整积分 if action == 'adjust_credit': if request.method == 'GET': return render(request, 'volunteer_arrangement/admin/adjust_credit.html') if request.method == 'POST': mobile = request.POST.get('mobile').strip() social_id = request.POST.get('social_id').strip() adjust_credit = request.POST.get('credit').strip() try: adjust_credit = int(adjust_credit) except Exception as e: print(e) return msg_and_direct(request, '/cq/volunteer/admin_management/adjust_credit/', '积分请输入数字') volunteer = Volunteer.get_by_mobile_social_id(mobile, social_id) if volunteer: volunteer.total_credit = volunteer.total_credit + adjust_credit volunteer.current_credit = volunteer.current_credit + adjust_credit volunteer.save() credit_record = CreditRecord() credit_record.volunteer = volunteer credit_record.reason = '管理员调整{}积分/{}'.format(volunteer.name, adjust_credit) credit_record.admin = None credit_record.change = adjust_credit credit_record.save() return msg_and_direct(request, '/cq/volunteer/admin_management/home/', '调整成功') else: return msg_and_direct(request, '/cq/volunteer/admin_management/adjust_credit/', '手机、身份证未匹配') # 导出现有的志愿者 if action == 'export_volunteers': if request.method == 'GET': volunteer_list = Volunteer.volunteer_list() for v in volunteer_list: # 添加一个tab，用来避免excel打开身份证号码最后几位显示为0的问题 v.social_id = '\t' + v.social_id # 获取数据,生成response response = HttpResponse(content_type='text/csv;charset=ANSI') response['Content-Disposition'] = 'attachment; filename="Volunteer_List.csv"' writer = csv.writer(response) # keys = monthly_report[0].keys() keys = ['ID', '姓名', '性别', '手机号码', '身份证号码', '政治面貌', '单位/学校', '居住区域（区或街道）', '是否激活', '微信ID', '目前积分', '总积分'] writer.writerow(keys) for x in volunteer_list: x = model_to_dict(x) writer.writerow(x.values()) return response def logout(request): volunteer = Volunteer.get_by_id(request.session.get('volunteer_id')) if volunteer: if volunteer.wechat_id: volunteer.wechat_id = None volunteer.save() request.session.flush() return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '已经退出', 'dirLink': '/cq/volunteer/'}) def booking_service(request): # 志愿者注册服务时间页面 if request.method == 'GET': booking_overall_status = [] monthly_booking_status = [] # count_month = [] # current_year = datetime.now().year # current_month = datetime.now().month # 验证登陆状态 if not request.session.get('volunteer_id'): request.session['redirect_uri'] = request.get_full_path() return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请登录', 'dirLink': '/cq/volunteer'}) volunteer = Volunteer.get_by_id(request.session.get('volunteer_id')) # 如果有指定地址 if request.GET.get('address'): address = request.GET.get('address') else: address = 'false' # 如果有日期就获取当天的报名状况 if request.GET.get('date'): service_date = request.GET['date'] if datetime.strptime(service_date, '%Y-%m-%d').date() < datetime.now().date(): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '日期不能早于今天', 'dirLink': '/cq/volunteer/booking_service/?date={};address={}'.format (str(datetime.now().date()), address)}) else: service_date = str(datetime.now().date()) service_list = ServiceTimeSlot.search_by_date_and_address(service_date, address) # service_list_IDs = [] # for service in service_list: # service_list_IDs.append(service.ID) booking_list = ServiceBooking.search_by_service_timeslot_list(service_list) # service_list_json = serializers.serialize('json', service_list) for service in service_list: service_dict = model_to_dict(service) service_exist_booking_count = len(booking_list.filter(timeslot_id=service)) service_dict['current_booking'] = service_exist_booking_count # service_dict['date'] = service_dict['date'].strftime("%Y-%m-%d") service_dict['date'] = str(service_dict['date']) service_dict['start_time'] = service_dict['start_time'].strftime("%H:%M:%S") service_dict['end_time'] = service_dict['end_time'].strftime("%H:%M:%S") booking_overall_status.append(service_dict) selected_date = datetime.strptime(service_date, '%Y-%m-%d').date() current_year = selected_date.year current_month = selected_date.month monthly_service_list = ServiceTimeSlot.search_by_year_month_address(current_year, current_month, address) monthly_booking_list = ServiceBooking.search_by_service_timeslot_list(monthly_service_list) count_date = 0 count_people = 0 count_volunteer = 0 count_month = [] for service in monthly_service_list: # 只显示今天以及以后的日期 if service.date >= datetime.today().date(): service_dict = model_to_dict(service) service_exist_booking_count = len(monthly_booking_list.filter(timeslot_id=service)) service_dict['current_booking'] = service_exist_booking_count service_dict['start_time'] = service_dict['start_time'].strftime("%H:%M:%S") service_dict['end_time'] = service_dict['end_time'].strftime("%H:%M:%S") monthly_booking_status.append(service_dict) # 根据日期，统计每天在指定的地点可以提供的志愿者服务总人数和当前人数 if count_date == 0 and service_dict['date'].day != count_date: count_date = service_dict['date'].day count_people += service_dict['people_count'] count_volunteer += service_dict['current_booking'] elif service_dict['date'].day == count_date: count_people += service_dict['people_count'] count_volunteer += service_dict['current_booking'] else: count_month.append({'day': count_date, 'total': count_people, 'current': count_volunteer}) count_date = service_dict['date'].day count_people = 0 count_volunteer = 0 count_people += service_dict['people_count'] count_volunteer += service_dict['current_booking'] # 防止循环最后一次漏掉 if count_date != 0: count_month.append({'day': count_date, 'total': count_people, 'current': count_volunteer}) return render(request, 'volunteer_arrangement/booking_service.html', {'booking_status': booking_overall_status, 'monthly_status': count_month, 'date': service_date, 'volunteer': volunteer}) def my_service(request): # 验证登陆状态 if not request.session.get('volunteer_id'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请登录', 'dirLink': '/cq/volunteer'}) my_booking_list = ServiceBooking.search_by_volunteer(request.session.get('volunteer_id')) return render(request, 'volunteer_arrangement/my_service.html', {'my_service': my_booking_list}) def booking_info_api(request): # 获取指定日期注册查询信息 service_date = request.GET['date'] service_list = ServiceTimeSlot.search_by_date(service_date) booking_list = ServiceBooking.search_by_service_timeslot_list(service_list) booking_overall_status = [] for service in service_list: service_dict = model_to_dict(service) service_exist_booking_count = len(booking_list.filter(timeslot_id=service)) service_dict['current_booking'] = service_exist_booking_count service_dict['date'] = str(service_dict['date']) service_dict['start_time'] = service_dict['start_time'].strftime("%H:%M:%S") service_dict['end_time'] = service_dict['end_time'].strftime("%H:%M:%S") booking_overall_status.append(service_dict) booking_overall_status_json = json.dumps(booking_overall_status, ensure_ascii=False) return JsonResponse(json.loads(booking_overall_status_json), safe=False) # 用户注册服务和管理员删除服务功能 def register(request, action): if action == 'add': # 验证登陆状态 if not request.session.get('volunteer_id'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请登录', 'dirLink': '/cq/volunteer'}) # 验证是否传入timeslot_id if not request.GET.get('timeslot_id'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '参数错误', 'dirLink': '/cq/volunteer'}) # 如果有指定地址 if request.GET.get('address'): address = request.GET.get('address') else: address = 'false' volunteer = Volunteer.get_by_id(request.session.get('volunteer_id')) booking_timeslot = ServiceTimeSlot.get_by_id(request.GET.get('timeslot_id')) has_conflict = ServiceBooking.has_conflict_booking(volunteer, booking_timeslot) if has_conflict: # 一下N行是研发代码，测试完成后删除 # from django.forms.models import model_to_dict # volunteer_json = volunteer.__dict__ # volunteer_json = model_to_dict(volunteer) # return JsonResponse(volunteer_json, safe=False) # 研发代码结束 return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '这个报名和你已经报名的服务时间上有冲突', 'dirLink': '/cq/volunteer/booking_service/?date={};address={}'.format( str(booking_timeslot.date), address)}) else: current_booking_count = len(ServiceBooking.search_by_service_timeslot(booking_timeslot)) if current_booking_count < booking_timeslot.people_count: service_booking = ServiceBooking() service_booking.volunteer_id = volunteer service_booking.timeslot_id = booking_timeslot if ServiceBooking.add(service_booking) is True: booking_timeslot.booked_count += 1 booking_timeslot.save() wechat_msg = WeChatMsg(volunteer.wechat_id, 'bsDiCVb3G2WERHvX4DJO83A-FonYYGRwTQD_Zp3fq7s', APPLICATION_NAME) wechat_msg.set_first('志愿者活动报名成功') wechat_msg.add_keyboard(volunteer.name) wechat_msg.add_keyboard('志愿者服务') wechat_msg.add_keyboard(str(booking_timeslot.date) + " " + str(booking_timeslot.start_time)) wechat_msg.add_keyboard(str(booking_timeslot.date) + " " + str(booking_timeslot.end_time)) wechat_msg.add_keyboard(booking_timeslot.address) wechat_msg.set_remark('志愿者服务报名成功，请准时参加。') wechat_msg.submit() return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '报名成功', 'dirLink': '/cq/volunteer/home/'}) else: return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '你已经报名了', 'dirLink': '/cq/volunteer/home/'}) return HttpResponse("test for conflict") if action == 'volunteer_self_delete': # 验证登陆状态 if not request.session.get('volunteer_id'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请登录', 'dirLink': '/cq/volunteer'}) else: volunteer_id = request.session.get('volunteer_id') volunteer = Volunteer.get_by_id(volunteer_id) service_booking_id = request.GET.get('service_booking_id') service_booking = ServiceBooking.get_by_ID(service_booking_id) if volunteer.ID == service_booking.volunteer_id.ID: # 判断是否是本人删除 if datetime.today().date() + timedelta(days=1) >= service_booking.timeslot_id.date: return msg_and_direct(request, '/cq/volunteer/my_service/', '距离活动开始时间过短，如果需要取消请联系管理员。') else: service_timeslot_id = service_booking.timeslot_id.ID service_timeslot = ServiceTimeSlot.get_by_id(service_timeslot_id) wechat_msg = WeChatMsg(volunteer.wechat_id, 'QKMJ1XFQoXWnxdc1ZDSXKraZpumcZbg_Ow8DdaP3Cuo', APPLICATION_NAME) wechat_msg.set_first('志愿者活动已取消') wechat_msg.add_keyboard('志愿者服务') wechat_msg.add_keyboard(str(service_timeslot.date) + " " + str(service_timeslot.start_time) + '-' + str(service_timeslot.end_time)) wechat_msg.add_keyboard(service_timeslot.address) wechat_msg.set_remark('你的志愿者服务，已取消。') wechat_msg.submit() ServiceBooking.delete(service_timeslot_id, volunteer_id) service_timeslot.booked_count -= 1 service_timeslot.save() return msg_and_direct(request, '/cq/volunteer/my_service/', '活动取消成功。') else: return HttpResponse('请使用本人账号删除') if action == 'delete': # 验证管理员登录状态 if not request.session.get('admin_login'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请重新登录管理员', 'dirLink': '/cq/admin/'}) # 验证是否传入timeslot_id and volunteer_id if not request.GET.get('timeslot_id') and request.GET.get('volunteer_id'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '参数错误', 'dirLink': '/cq/volunteer'}) volunteer_id = request.GET.get('volunteer_id') volunteer = Volunteer.get_by_id(volunteer_id) service_timeslot_id = request.GET.get('timeslot_id') service_timeslot = ServiceTimeSlot.get_by_id(service_timeslot_id) wechat_msg = WeChatMsg(volunteer.wechat_id, 'QKMJ1XFQoXWnxdc1ZDSXKraZpumcZbg_Ow8DdaP3Cuo', APPLICATION_NAME) wechat_msg.set_first('志愿者活动已取消') # wechat_msg.add_keyboard(volunteer.name) wechat_msg.add_keyboard('志愿者服务') wechat_msg.add_keyboard(str(service_timeslot.date) + " " + str(service_timeslot.start_time) + '-' + str(service_timeslot.end_time)) # wechat_msg.add_keyboard(str(service_timeslot.date) + " " + str(service_timeslot.end_time)) wechat_msg.add_keyboard(service_timeslot.address) wechat_msg.set_remark('你的志愿者服务，已被管理员取消。') wechat_msg.submit() ServiceBooking.delete(service_timeslot_id, volunteer_id) service_timeslot.booked_count -= 1 service_timeslot.save() return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '删除成功', 'dirLink': '/cq/volunteer/admin_management/delete_service/?date=' + str(service_timeslot.date)}) # 志愿者查看和兑换礼物 @transaction.atomic def volunteer_bonus(request, action): # 验证登陆状态 if not request.session.get('volunteer_id'): request.session['redirect_uri'] = '/cq/volunteer/bonus/list/' return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请登录', 'dirLink': '/cq/volunteer'}) volunteer = Volunteer.get_by_id(request.session.get('volunteer_id')) if action == 'list': bonus_list = Bonus.all_available_bonus() url_prefix = get_media_url_prefix() return render(request, 'volunteer_arrangement/volunteer_bonus_list.html', {'bonus_list': bonus_list, 'volunteer': volunteer, 'url_prefix': url_prefix}) if action == 'enroll': bonus = request.GET.get('bonus_id') bonus = Bonus.get_by_id(bonus) if bonus is None: return msg_and_direct(request, '/cq/volunteer/home/', '参数错误') if BonusRecord.is_exist(volunteer, bonus): # 检查是否已经兑换过 return msg_and_direct(request, '/cq/volunteer/bonus/list/', '你已经兑换过了') if volunteer.current_credit < bonus.cost: return msg_and_direct(request, '/cq/volunteer/bonus/list/', '积分不足，请继续努力') if bonus.used_qty < bonus.total_qty: bonus.used_qty += 1 bonus.save() bonus_record = BonusRecord() bonus_record.volunteer = volunteer bonus_record.bonus = bonus bonus_record.save() volunteer.current_credit -= bonus.cost volunteer.save() credit_record = CreditRecord() credit_record.volunteer = volunteer credit_record.reason = '{}兑换{}/{}奖励'.format(volunteer.name, bonus.id, bonus.name) credit_record.admin = None credit_record.change = bonus.cost * -1 credit_record.save() wechat_msg = WeChatMsg(volunteer.wechat_id, 'wkjPXVLn_OT57IKINx3uInDlA9S1-XndV7bO4d_sbcQ', APPLICATION_NAME) wechat_msg.set_first(bonus.name + '兑换成功') wechat_msg.add_keyboard(str(datetime.today().date())) wechat_msg.add_keyboard('通过') wechat_msg.add_keyboard('请保留这条消息。我们的工作人员会尽快和你联系。') wechat_msg.set_remark('消耗{}积分，还剩{}积分'.format(bonus.cost, volunteer.current_credit)) wechat_msg.submit() return msg_and_direct(request, '/cq/volunteer/home/', '兑换成功') if action == 'my_enrollment': bonus_record_list = BonusRecord.search_by_volunteer(volunteer) url_prefix = get_media_url_prefix() return render(request, 'volunteer_arrangement/volunteer_bonus_my_enrollment.html', {'bonus_record_list': bonus_record_list, 'volunteer': volunteer, 'url_prefix': url_prefix}) # 管理员后台管理礼物 def admin_bonus(request, action): # 验证管理员登录状态 if not request.session.get('admin_login'): return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '请重新登录管理员', 'dirLink': '/cq/volunteer/admin/'}) if action == 'list': bonus_list = Bonus.get_bonus_list() url_prefix = get_media_url_prefix() return render(request, 'volunteer_arrangement/bonus/admin_list.html', {'bonus_list': bonus_list, 'url_prefix': url_prefix}) if action == 'download_bonus_enrollment': bonus_id = request.GET.get('bonus_id') bonus = Bonus.get_by_id(bonus_id) bonus_list = BonusRecord.search_bonus_with_volunteer(bonus) for bonus in bonus_list: # 添加一个tab，用来避免excel打开身份证号码最后几位显示为0的问题 bonus['volunteer__social_id'] = '\t' + bonus['volunteer__social_id'] # 获取数据,生成response response = HttpResponse(content_type='text/csv;charset=ANSI') response['Content-Disposition'] = 'attachment; filename="Enrollment.csv"' writer = csv.writer(response) # keys = monthly_report[0].keys() keys = ['姓名', '性别', '手机号码', '身份证号码', '政治面貌', '学校/单位', '居住区域（区或街道）'] writer.writerow(keys) for x in bonus_list: writer.writerow(x.values()) return response if action == 'create': if request.method == 'GET': return render(request, 'volunteer_arrangement/bonus/create.html') if request.method == 'POST': bonus = Bonus() bonus.name = request.POST.get('name') bonus.description = request.POST.get('description') pic_filename = request.FILES.get('picture') if pic_filename is None: filename = None else: new_pic_name = hash(str(pic_filename) + str(datetime.now())) upload_file(request, filename='picture', prefix=new_pic_name) filename = str(new_pic_name) + '.' + get_ext(pic_filename) bonus.picture = filename bonus.type = request.POST.get('type') bonus.total_qty = request.POST.get('total_qty') bonus.cut_off_date = request.POST.get('cut_off_date') bonus.cost = request.POST.get('cost') bonus.save() return render(request, 'volunteer_arrangement/directPage.html', {'alertMsg': '添加成功', 'dirLink': '/cq/volunteer/admin_management/home/'}) if action == 'delete': bonus_id = request.GET.get('bonus_id') if Bonus.del_bonus(bonus_id): return msg_and_direct(request, '/cq/volunteer/admin_management/home/', '删除成功') else: return msg_and_direct(request, '/cq/volunteer/admin_management/home/', '兑换已经有人报名了，不能删除')