yifengapi/src/manage/controls.py

#coding=utf-8
'''
'''
import os,re
import json,time,datetime
import shutil
import tempfile
import zipfile
from docxtpl import DocxTemplate,InlineImage
from docx.shared import Mm
from django.db import transaction
from django.conf import settings
import common.models as cm
import common.error_info as ce
import common.common_functions as ccf
import common.common_control as ccc
import account.password_handle as ph
from utils.exceltool import ExcelTool
from utils.exceltool import ExcelTool
from django.db.models import Q
from PIL import Image
from PIL import Image,ImageDraw,ImageFont

import xlrd
import xlwt
from xlutils.copy import copy
from xltpl.writer import BookWriter

def thumbnail_pic(fpath):                                                          
    """                                                                            
    """                                                                            
    im=Image.open(fpath)                                                           
    im.thumbnail((300,400))                                                        
    thumb_name = os.path.splitext(fpath)[0]+"_thumb"+os.path.splitext(fpath)[-1]
    im.save(thumb_name,'png')                                                     
    return thumb_name

def render_xls_tpl(tpl,data,out):
    """
    """
    stime = time.time()
    writer = BookWriter(tpl)
    writer.jinja_env.globals.update(dir=dir, getattr=getattr)
    payloads = {"tpl_name":"Sheet1","sheet_name":"Sheet1","ctx":data}
    writer.render_book2(payloads=[payloads])
    #writer.render_book([payloads])
    writer.save(out)

def get_index_data(request):
    """
    """
    qset = cm.Category.objects.all()
    qdata = list(qset.values())
    for i,qd in enumerate(qdata):
        if i<6:
            qd["type"] = "nav"
        else:
            qd["type"] = "article"
            qd["list"] = list(cm.Article.objects.filter(category__id=qd["id"]).values())
        if qd["name"]==u"头条通知": 
            qd["type"] = "notice"
            qd["list"] = list(cm.Article.objects.filter(category__id=qd["id"]).values())
        if "{id}" in qd["path"]:
            artcs = list(cm.Article.objects.filter(category__id=qd["id"]).order_by("order").values())
            aid = artcs[0]["id"] if artcs else 0
            qd["path"] = qd["path"].replace("{id}",str(aid))
    return qdata


def get_article_info(request):
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    data = list(cm.Article.objects.filter(id=id).values())
    data = data[0] if data else {}
    #data["imgs"] = ["https://www.scxjc.club/images/jgjj.png","https://www.scxjc.club/images/jgjj.png"]
    data["imgs"] = json.loads(data["imgs"]) if data["imgs"] else []
    data["phone"] = "0827-8589102"
    data["address"] = u"巴中市江北车站三楼(体检门诊第一个办公室)"
    data["point"] = "106.755094,31.866028"
    return data

def get_intro_info(request):
    """考场和联系我们专用
    """
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    data = {"id":"1","title":"sfsfd","content":"","ctime":"2020-01-01 00:00:01"}
    data = {"id":1,"title":u"联系我们","phone":"0827-8589102","address":u"巴中市江北车站三楼(体检门诊第一个办公室)","imgs":["https://www.scxjc.club/images/jgjj.png","https://www.scxjc.club/images/jgjj.png"],"content":u"详情...."}
    return data

def get_signup_list(request):
    """
    """
    data = [
        {"relaname":u"肖小肖",
        "phone":"15982456282",
        "class_name":u"一班",
        "class_id":1,
        "subject_item":u"安全生产管理|电工作业|高压电工",
        "class_hour":30,
        "class_hour_finished":10,
        "train_type":u"新办",
        "order_status":0,
        "ctime":"2020-05-05 22:11:12",
        "id":1
        }
    ]
    uid = request.user.id
    #qset = cm.SignupOrders.objects.filter(user_id=uid).order_by("-id")
    qset = cm.SignupOrders.objects.order_by("-id")
    qdata = list(qset.values())
    for qd in qdata:
        qd["subject_item"] = u"特种作业|电工|高压电工"
        qd["class_name"] = cm.Class.objects.filter(id=qd["class_id"]).first().name
        qd["class_hour"] = cm.Class.objects.filter(id=qd["class_id"]).first().class_hour
    return qdata

def get_signup_info(request):
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    data = list(cm.SignupOrders.objects.filter(id=id).values())
    data = data[0] if data else {}
    if data.get("idnoimg_face"):
        data["idnoimg_face"] = data["idnoimg_face"] + "?t=" + str(time.time())
    if data.get("idnoimg_back"):
        data["idnoimg_back"] = data["idnoimg_back"] + "?t=" + str(time.time())
    if data.get("halfbody_img"):
        data["halfbody_img"] = data["halfbody_img"] + "?t=" + str(time.time())
    if data.get("oldcard_img"):
        data["oldcard_img"] = data["oldcard_img"] + "?t=" + str(time.time())
    return data

def get_paper_info(request):
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    data = list(cm.Papers.objects.filter(id=id).values())
    data = data[0] if data else {}
    if data:
        questions = cm.Papers.objects.filter(id=id).first().questions.all()
        q_sel = list(questions.filter(qtype=1).values())
        q_msel = list(questions.filter(qtype=2).values())
        q_tf = list(questions.filter(qtype=3).values())
        qdata = [
            {"title":u"一、单选题（每题1分、共{}题）".format(len(q_sel)),"questions":q_sel}, 
            {"title":u"二、多选题（每题1分、共{}题）".format(len(q_msel)),"questions":q_msel}, 
            {"title":u"三、判断题（每题1分、共{}题）".format(len(q_tf)),"questions":q_tf} 
        ]
        data["questions"] = qdata
        
    return data

def get_class_list(request):
    """
    """
    qdata = request.json
    qset = cm.Class.objects.filter(status=1)
    if qdata.get("name"): 
        qset = qset.filter(name__icontains=qdata.get("name"))
    if qdata.get("subject_item"): 
        qset = qset.filter(subject_item__icontains=qdata.get("subject_item"))
    #分页
    page = qdata.get("page",1)
    page_size = qdata.get("page_size",20)
    total,qset = ccc.get_page_qset(qset,page,page_size)
    data = list(qset.values())
    for d in data:
        d["signuped_count"] = cm.SignupOrders.objects.filter(class_id=d["id"]).count()
    return total,data

def get_category_list(request):
    """
    """
    qdata = request.json
    qset = cm.Category.objects.filter(status=1)
    #分页
    page = qdata.get("page",1)
    page_size = qdata.get("page_size",20)
    total,qset = ccc.get_page_qset(qset,page,page_size)
    data = list(qset.values())
    return total,data

def get_article_list(request):
    """
    """
    qdata = request.json
    qset = cm.Article.objects.filter(status=1)
    if qdata.get("title"):
        qset = qset.filter(title__icontains=qdata.get("title"))
    #分页
    page = qdata.get("page",1)
    page_size = qdata.get("page_size",20)
    total,qset = ccc.get_page_qset(qset,page,page_size)
    data = list(qset.values())
    return total,data

def get_account_list(request):
    """
    """
    qdata = request.json
    qset = cm.UserInfo.objects.filter(utype=1)
    #分页
    page = qdata.get("page",1)
    page_size = qdata.get("page_size",20)
    total,qset = ccc.get_page_qset(qset,page,page_size)
    data = list(qset.values())
    return total,data

def get_user_list(request):
    """
    """
    qdata = request.json
    qset = cm.UserInfo.objects.filter(utype=2).order_by("-ctime")
    #分页
    page = qdata.get("page",1)
    page_size = qdata.get("page_size",20)
    total,qset = ccc.get_page_qset(qset,page,page_size)
    data = list(qset.values())
    return total,data


def get_paper_list(request):
    """
    """
    qdata = request.json
    qset = cm.Papers.objects.all()
    #分页
    page = qdata.get("page",1)
    page_size = qdata.get("page_size",20)
    total,qset = ccc.get_page_qset(qset,page,page_size)
    data = list(qset.values())
    for item in data:
        id = item["id"]
        item["questions_count"] = cm.Papers.objects.filter(id=id).first().questions.all().count()
    return total,data

def get_video_list(request):
    """
    """
    qdata = request.json
    qset = cm.Videos.objects.all()
    #分页
    page = qdata.get("page",1)
    page_size = qdata.get("page_size",20)
    total,qset = ccc.get_page_qset(qset,page,page_size)
    data = list(qset.values())
    return total,data

def get_subject_item(subject_id):
    """
    """
    data = []
    for sid in subject_id:
        tmp = []
        for ssid in sid:
            tmp.append(cm.Subject.objects.filter(id=ssid).first().name)
        data.append("|".join(tmp))
    return ",".join(data)

def add_class(request):
    uid = request.user.id
    qdata = request.json
    #need_params = ["name","subject_id","subject_item","signup_limit","remark"]
    #need_params = ["name","subject_id","subject_item","signup_limit","remark"]
    need_params = ["name","subject_id","signup_limit","remark"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.append("subject_id")
    need_params.append("remind")
    vals = ccf.get_need_params(*need_params,**qdata)
    subject_id = vals["subject_id"]
    vals["cid"] = uid
    vals["subject_id"] = json.dumps(vals["subject_id"])
    vals["subject_item"] = get_subject_item(subject_id)
    #vals["subject_name"] = vals["subject_item"].split("|")[0]
    obj = cm.Class.objects.create(**vals)
    return obj.id

def get_docs_info(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Docs.objects.filter(id=id).values().first()
    return obj

def get_docs_list(request):
    """
    """
    qdata = request.json
    qset = cm.Docs.objects.all()
    #分页
    page = qdata.get("page",1)
    page_size = qdata.get("page_size",20)
    total,qset = ccc.get_page_qset(qset,page,page_size)
    data = list(qset.values())
    return total,data

def add_docs(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["name","url"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    vals = ccf.get_need_params(*need_params,**qdata)
    obj = cm.Docs.objects.create(**vals)
    return obj.id

def update_docs(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["name","url"])
    vals = ccf.get_need_params(*need_params,**qdata)
    id = vals.pop("id")
    obj = cm.Docs.objects.filter(id=id).update(**vals)
    return id

def delete_docs(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Docs.objects.filter(id=id).delete()
    return id

def add_video(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["title","subject_id","subject_item","train_type","img","url"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    vals = ccf.get_need_params(*need_params,**qdata)
    obj = cm.Videos.objects.create(**vals)
    return obj.id

def update_video(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["title","subject_id","subject_item","train_type","img","url"])
    vals = ccf.get_need_params(*need_params,**qdata)
    id = vals.pop("id")
    obj = cm.Videos.objects.filter(id=id).update(**vals)
    return id


def delete_video(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Videos.objects.filter(id=id).delete()
    return id


def delete_paper(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    paper = cm.Papers.objects.filter(id=id).first()
    paper.questions.all().delete()
    obj = cm.Papers.objects.filter(id=id).delete()
    return id


def get_video_info(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Videos.objects.filter(id=id).values().first()
    return obj


def add_category(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["name"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["order","desc"])
    vals = ccf.get_need_params(*need_params,**qdata)
    vals["cid"] = uid
    obj = cm.Category.objects.create(**vals)
    return obj.id

def add_article(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["title","category_id","content"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["imgs","address","point"])
    vals = ccf.get_need_params(*need_params,**qdata)
    vals["imgs"] = json.dumps(vals["imgs"])
    vals["cid"] = uid
    obj = cm.Article.objects.create(**vals)
    return obj.id

def add_article(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["title","category_id","content"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["imgs","address","point"])
    vals = ccf.get_need_params(*need_params,**qdata)
    vals["imgs"] = json.dumps(vals["imgs"])
    vals["cid"] = uid
    obj = cm.Article.objects.create(**vals)
    return obj.id

def add_account(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["name","realname","password","repassword","phone"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.append("permissions")
    vals = ccf.get_need_params(*need_params,**qdata)
    vals.pop("repassword")
    vals["password"] = ph.make_password(vals["password"])
    vals["cid"] = uid
    vals["utype"] = 1
    obj = cm.UserInfo.objects.create(**vals)
    return obj.id



def update_class(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["name","subject_id","subject_item","signup_limit","remark","remind"])
    vals = ccf.get_need_params(*need_params,**qdata)
    id = vals.pop("id")
    vals["cid"] = uid
    subject_id = vals["subject_id"]
    vals["subject_id"] = json.dumps(vals["subject_id"])
    vals["subject_item"] = get_subject_item(subject_id)
    #vals["subject_name"] = vals["subject_item"].split("|")[0]
    obj = cm.Class.objects.filter(id=id).update(**vals)
    return obj

def update_account(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    #need_params.extend(["name","realname","password","repassword","phone","permissions"])
    need_params.extend(["name","realname","phone","permissions"])
    vals = ccf.get_need_params(*need_params,**qdata)
    id = vals.pop("id")
    #vals.pop("repassword")
    #vals["password"] = ph.make_password(vals["password"])
    vals["cid"] = uid
    obj = cm.UserInfo.objects.filter(id=id).update(**vals)
    return obj

def update_article(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["title","category_id","content","imgs","address","point","phone"])
    vals = ccf.get_need_params(*need_params,**qdata)
    id = vals.pop("id")
    vals["imgs"] = json.dumps(vals["imgs"])
    vals["cid"] = uid
    obj = cm.Article.objects.filter(id=id).update(**vals)
    return obj

def update_category(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["name","order","desc"])
    vals = ccf.get_need_params(*need_params,**qdata)
    id = vals.pop("id")
    vals["cid"] = uid
    obj = cm.Category.objects.filter(id=id).update(**vals)
    return obj

def get_class_info(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Class.objects.filter(id=id).values().first()
    obj["subject_id"] = json.loads(obj["subject_id"])
    return obj

def get_account_info(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.UserInfo.objects.filter(id=id).values().first()
    return obj

def get_user_info(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.UserInfo.objects.filter(id=id).values().first()
    return obj

def get_article_info(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Article.objects.filter(id=id).values().first()
    obj["imgs"] = json.loads(obj["imgs"]) if obj["imgs"] else []
    return obj

def delete_class(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Class.objects.filter(id=id).delete()
    return id

def delete_category(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Category.objects.filter(id=id).delete()
    return id

def delete_account(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.UserInfo.objects.filter(id=id).delete()
    return id

def delete_article(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Article.objects.filter(id=id).delete()
    return id

def get_category_info(request):
    """
    """
    uid = request.user.id
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    obj = cm.Category.objects.filter(id=id).values().first()
    return obj


def get_training_list(request):
    """
    """
    data = {
        "videos":[{
            "title":u"高压电工实操课程",     
            "image":u"https://www.scxjc.club/images/jgjj.png",     
            "url":u"https://www.scxjc.club/demo.mp4",     
            "class_hour":20,     
            "total_time":"45:32",     
            "finished_time":"30:32",
            "status":1
        }],     
        "papers":[{
            "id":1, 
            "title":u"高压电工实操模拟试题",     
            "class_hour":20,     
            "full_mark":100,     
            "time_limit":60,     
            "mark":90,     
            "status":1     
        }]
    }
    return data


def get_paper_info1(request):
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    data = {
        "id":1, 
        "title":u"高压电工实操模拟试题",     
        "class_hour":20,     
        "full_mark":100,     
        "time_limit":60,     
        "mark":90,     
        "status":1,
        "questions":[
            {
                "id":1,
                "type":1,
                "title":u"欧姆定律是什么",
                "options":[u"A、电阻",u"B、电流"],
                "stand_answer":"A",
                "myanswer":"A"
            },
            {
                "id":2,
                "type":2,
                "title":u"欧姆定律是什么",
                "options":[u"A、电阻",u"B、电流"],
                "stand_answer":["A","B"],
                "myanswer":["A","B"]
            },
            {
                "id":3,
                "type":3,
                "title":u"电流等于电压除电阻",
                "options":[u"对",u"错"],
                "stand_answer":[u"对"],
                "myanswer":[u"对"]
            } 
        ]
    }
    return data


def add_signup(request):
    """
    """
    uid = request.user.id
    #uid = 15
    qdata = request.json
    need_params = ["name","sex","idno","education","phone",
        "train_type","receive_card","price"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["company","class_id","remark","idnoimg_face","idnoimg_back","halfbody_img","education_img","oldcard_img","area","address","subject_id","subject_item"])
    vals = ccf.get_need_params(*need_params,**qdata)
    vals["cid"] = uid
    vals["user_id"] = uid
    vals["order_status"] = 0
    vals["subject_item"] = cm.Class.objects.filter(id=vals["class_id"]).first().subject_item
    obj = cm.SignupOrders.objects.create(**vals)
    return obj.id


def update_signup(request):
    """
    """
    uid = request.user.id
    #uid = 15
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    _id = qdata.pop("id")
    ids = str(_id).split(",")
    need_params.extend(["name","sex","idno","education","phone","train_type",
        "receive_card","area","price","company","class_id","remark","idnoimg_face",
        "idnoimg_back","halfbody_img","education_img","oldcard_img","admin_remark",
        "subject_item","subject_id","address","exam_time","classhour_cert_status","health_img"])
    vals = ccf.get_need_params(*need_params,**qdata)
    if vals.get("idnoimg_face") and "?" in vals["idnoimg_face"]:
        vals["idnoimg_face"] = vals["idnoimg_face"].split("?")[0]
    if vals.get("idnoimg_back") and "?" in vals["idnoimg_back"]:
        vals["idnoimg_back"] = vals["idnoimg_back"].split("?")[0]
    if vals.get("halfbody_img") and "?" in vals["halfbody_img"]:
        vals["halfbody_img"] = vals["halfbody_img"].split("?")[0]
    if vals.get("education_img") and "?" in vals["education_img"]:
        vals["education_img"] = vals["education_img"].split("?")[0]
    if vals.get("oldcard_img") and "?" in vals["oldcard_img"]:
        vals["oldcard_img"] = vals["oldcard_img"].split("?")[0]
    if vals.get("health_img") and "?" in vals["health_img"]:
        vals["health_img"] = vals["health_img"].split("?")[0]
    if vals.get("classhour_cert_status"):
        vals["order_status"] = 7
    if qdata.get("train_time"):
        vals["train_time_start"] = qdata.get("train_time").split(",")[0]
        vals["train_time_end"] = qdata.get("train_time").split(",")[1]
        #发送培训通知
        from utils.aliyun_sms import send_training_notice,send_training_notice_special
        import common.common_notice as cn
        sorders = cm.SignupOrders.objects.filter(id__in=ids)
        for so in sorders:
            user_id = so.user_id
            phone = so.phone
            subject_item = so.subject_item.split("|")[-1]
            begin_time = vals["train_time_start"]
            end_time = vals["train_time_end"]
            if u"特种作业" in subject_item:
                send_training_notice_special(phone,subject_item,begin_time,end_time)
                cn.send_training_notice_special(user_id,subject_item,begin_time,end_time)
            else:
                send_training_notice(phone,subject_item,begin_time,end_time)
                cn.send_training_notice(user_id,subject_item,begin_time,end_time)
    #更新用户信息
    uid = cm.SignupOrders.objects.filter(id=_id).first().user_id
    userinfo = cm.UserInfo.objects.filter(id=uid).first().userinfo
    userinfo = json.loads(userinfo) if userinfo else {}
    #if userinfo:
    #    vals.update(userinfo)
    userinfo.update(vals)
    cm.UserInfo.objects.filter(id=uid).update(userinfo=json.dumps(userinfo))

    vals["cid"] = uid
    vals["update_time"] = datetime.datetime.now()
    subject_id = vals.get("subject_id")
    train_type = vals.get("train_type")
    subject_item = cm.Subject.objects.filter(id=subject_id).first()
    if subject_item:
        if train_type == "新办":
            vals["price"] = subject_item.price_new
        if train_type == "复审":
            vals["price"] = subject_item.price_re
        if train_type == "换证":
            vals["price"] = subject_item.price_change
    obj = cm.SignupOrders.objects.filter(id__in=ids).update(**vals)
    if qdata.get("exam_time"):
        #发送培训通知
        from utils.aliyun_sms import send_exam_notice
        import common.common_notice as cn
        sorders = cm.SignupOrders.objects.filter(id__in=ids)
        for so in sorders:
            name = so.name
            user_id = so.user_id
            phone = so.phone
            subject_item = so.subject_item.split("|")[-1]
            exam_time = vals["exam_time"]
            send_exam_notice(phone,name,subject_item,exam_time)
            cn.send_exam_notice(user_id,name,subject_item,exam_time)
    return obj

def delete_signup(request):
    """
    """
    uid = request.user.id
    #uid = 15
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    rst = cm.SignupOrders.objects.filter(id=id).delete()
    return id

def get_yrxindex(request):
    """
    """
    recs = cm.ClassRoom.objects.all()
    recs = list(recs.values())
    teachers = [{
        "name":u"肖老师",
        "avatar":"肖老师",
        "lessons_count":2,
        "students":200
    }]
    data = {
        "rec":recs,     
        "lessons":recs,     
        "teachers":teachers     
    }
    return data


def get_yrxlist(request):
    """
    """
    recs = cm.ClassRoom.objects.all()
    recs = list(recs.values())
    teachers = [{
        "name":u"肖老师",
        "avatar":"肖老师",
        "lessons_count":2,
        "students":200
    }]
    data = {
        "rec":recs,     
        "lessons":recs,     
        "teachers":teachers     
    }
    return recs


def get_yrxdetail(request):
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    data = list(cm.ClassRoom.objects.filter(id=id).values())
    data = data[0] if data else {}
    if data:
        lessons = list(cm.Lessons.objects.filter(classroom_id=id).values())
        data["lessons"] = lessons
    return data


def get_subject_tree(sub=None,data=None):
    """
    """
    if sub:
        roots = list(cm.Subject.objects.filter(pid=sub).values())
        for citem in roots:
            citem["device_cats"] = json.loads(citem["device_cats"]) if citem["device_cats"] else []
    else:
        roots = list(cm.Subject.objects.filter(Q(pid=0)|Q(pid__isnull=True)).values())
        for citem in roots:
            citem["device_cats"] = json.loads(citem["device_cats"]) if citem["device_cats"] else []
    for rn in roots:
        rn["label"] = rn["name"]
        rn["value"] = rn["id"]
        children = list(cm.Subject.objects.filter(pid=rn["id"]).values())
        for citem in children:
            citem["label"] = citem["name"]
            citem["value"] = citem["id"]
            citem["device_cats"] = json.loads(citem["device_cats"]) if citem["device_cats"] else []
        rn["children"] = children
        for rnn in rn["children"]:
            children = list(cm.Subject.objects.filter(pid=rnn["id"]).values())
            for citem in children:
                citem["label"] = citem["name"]
                citem["value"] = citem["id"]
                citem["device_cats"] = json.loads(citem["device_cats"]) if citem["device_cats"] else []
            rnn["children"] = children
    return roots


def get_subjectitem_tree(request):
    """
    """
    qdata = request.json
    subject_id = qdata.get("subject_id")
    data = get_subject_tree(subject_id)
    return data


def post_paper(request):
    qdata = request.json
    need_params = ["paper_id","questions"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    paper_id = qdata.get("paper_id")
    return True


def save_video_time(request):
    qdata = request.json
    need_params = ["video_id","time"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    paper_id = qdata.get("paper_id")
    return True


#def do_signup_pay(request):
#    qdata = request.json
#    need_params = ["signup_id","total_fee"]
#    mse = ccf.check_params(*need_params,**qdata)
#    if mse:
#        raise ce.TipException(mse)
#    signup_id = str(qdata.get("signup_id"))+str(int(time.time()))
#    total_fee = str(qdata.get("total_fee")*100)
#    #openid = "ow7pX46fM1xAVgCHH5eNcxkurRks"
#    openid = request.user.openid
#    prepayinfo = wxpay.get_wx_unifiedorder(signup_id,total_fee,openid)
#    prepayinfo["key"] = "kAHuCc2g4MINcLRk3o0lxT6J1Z04WuZq"
#    return prepayinfo


def add_subject(request):
    """
    """
    qdata = request.json
    need_params = ["name","price_change","price_new","price_re"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    need_params.extend(["order","intro","pid","class_hour","update_class_hour","change_class_hour"])
    vals = ccf.get_need_params(*need_params,**qdata)
    vals["cid"] = request.user.id
    vals["cperson"] = request.user.name
    obj = cm.Subject.objects.create(**vals)
    return obj.id

def update_subject(request):
    """
    """
    qdata = request.json
    need_params = ["id","name","price_change","price_new","price_re"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    need_params.extend(["order","pid","intro","class_hour","update_class_hour","change_class_hour","device_cats"])
    vals = ccf.get_need_params(*need_params,**qdata)
    vals["device_cats"] = json.dumps(vals["device_cats"])
    vals["cid"] = request.user.id
    vals["cperson"] = request.user.name
    rst = cm.Subject.objects.filter(id=id).update(**vals)
    return id

def delete_subject(request):
    """
    """
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    rst = cm.Subject.objects.filter(id=id).delete()
    return id

def get_subject_info(request):
    """
    """
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    id = qdata.get("id")
    rst = cm.Subject.objects.filter(id=id).values().first()
    return rst


def get_subject_ids(subject_id,data=None):
    """
    """
    data = data if data else []
    data.append(int(subject_id))
    #subobj = cm.Subject.objects.filter(pid=subject_id).first()
    subobjs = cm.Subject.objects.filter(pid=subject_id)
    for subobj in subobjs:
        get_subject_ids(subobj.id,data)
    return data

def get_signup_list(request):
    """
    """
    uid = request.user.id
    qdata = request.json
    qset = cm.SignupOrders.objects.filter(status=1).order_by("-update_time")
    if qdata.get("train_type"):
        qset = qset.filter(train_type=qdata.get("train_type"))
    if qdata.get("subject_item"):
        subject_item = qdata.get("subject_item").split("|")[-1]                     
        subject_id = cm.Subject.objects.filter(name=subject_item).first().id    
        subject_ids = get_subject_ids(subject_id)                                   
        #qset = qset.filter(subject_item__icontains=qdata.get("subject_item"))  
        qset = qset.filter(subject_id__in=subject_ids)
    if qdata.get("name"):
        qset = qset.filter(name__icontains=qdata.get("name"))
    if qdata.get("idno"):
        qset = qset.filter(idno__icontains=qdata.get("idno"))
    if qdata.get("phone"):
        qset = qset.filter(phone__icontains=qdata.get("phone"))
    if qdata.get("signup_time"):
        stime = ccf.str_to_datetime(qdata.get("signup_time").split(",")[0],"%Y-%m-%d %H:%M:%S")
        etime = ccf.str_to_datetime(qdata.get("signup_time").split(",")[1],"%Y-%m-%d %H:%M%:%S")
        qset = qset.filter(ctime__gte=stime,ctime__lte=etime)
    if qdata.get("bill_type"):
        qset = qset.filter(bill_type=qdata.get("bill_type"))
    if qdata.get("receive_card"):
        qset = qset.filter(receive_card=qdata.get("receive_card"))
    if qdata.get("set_exam_time"):
        if qdata.get("set_exam_time") == 1:
            qset = qset.filter(exam_time__isnull=False)
        else:
            qset = qset.filter(exam_time__isnull=True)
    if qdata.get("exam_time"):
        qset = qset.filter(exam_time=qdata.get("exam_time"))
    if qdata.get("set_train_time"):
        if qdata.get("set_train_time") == 1:
            qset = qset.filter(train_time__isnull=False)
        else:
            qset = qset.filter(train_time__isnull=True)
    if qdata.get("train_time"):
        stime = ccf.str_to_datetime(qdata.get("train_time").split(",")[0],"%Y-%m-%d")
        etime = ccf.str_to_datetime(qdata.get("train_time").split(",")[1],"%Y-%m-%d")
        qset = qset.filter(train_time_start__gte=stime,train_time_end__lte=etime)
    if qdata.get("company"):
        qset = qset.filter(company__icontains=qdata.get("company"))
    if qdata.get("order_status"):
        qset = qset.filter(order_status=qdata.get("order_status"))
    if qdata.get("class_id"):
        qset = qset.filter(class_id=qdata.get("class_id"))

    qset1 = qset.filter(status=1).exclude(order_status=7).order_by("-update_time")

    qset2 = qset.filter(status=1,order_status=7).order_by("-update_time")

    data = list(qset1.values())+list(qset2.values())

    page = int(qdata.get("page",1))
    page_size = int(qdata.get("page_size",20))

    #total,qset = ccc.get_page_qset(qset,page,page_size)
    total,data = ccf.get_page_list(data,page,page_size)

    #data = list(qset.values("name","phone","order_status","remark","subject_item","train_type","ctime","id"))
    #data = list(qset.values())
    for d in data:
        if d["train_time_start"] and d["train_time_end"]:
            d["train_time"] = ccf.datetime_to_str(d["train_time_start"])+","+ccf.datetime_to_str(d["train_time_end"])
        else:
            d["train_time"] = ""
        try:
            d["subject_item0"] = d["subject_item"].split("|")[0]
        except:
            d["subject_item0"] = ""
        try:
            d["subject_item1"] = d["subject_item"].split("|")[1]
        except:
            d["subject_item1"] = ""
        try:
            d["subject_item2"] = d["subject_item"].split("|")[2]
        except:
            d["subject_item2"] = ""
        d["verify"] = cm.UserInfo.objects.filter(id=uid).first().verify
        d["signup_time"] = d["pay_time"]
        try:
            d["class_name"] = cm.Class.objects.filter(id=d["class_id"]).first().name
        except:
            d["class_name"] = ""
    return total,data

#def get_subject_ids(subject_id,data=None):
#    """
#    """
#    data = data if data else []
#    data.append(int(subject_id))
#    subobj = cm.Subject.objects.filter(id=subject_id).first()
#    if subobj and  int(subobj.pid):
#        get_subject_ids(subobj.pid,data)
#    return data


#def get_signup_info(request):
#    """
#    """
#    qdata = request.json
#    need_params = ["id"]
#    mse = ccf.check_params(*need_params,**qdata)
#    if mse:
#        raise ce.TipException(mse)
#    id = qdata.get("id")
#    print id,888888888888888
#    rst = cm.SignupOrders.objects.filter(id=id).values().first()
#    print rst,99999999999999
#    print rst["subject_id"],777777777777777
#    subject_ids = get_subject_ids(rst["subject_id"])
#    subject_ids.sort()
#    rst["subject_ids"] = subject_ids 
#    rst["order_no"] = "yf1212"
#    rst["order_time"] = "2020-05-19 11:22:22"
#    rst["pay_status"] = 1
#    rst["pay_status"] = 1
#    rst["total_fee"] = 1000
#    rst["get_card_time"] = "2020-05-19 11:22:22"
#    rst["review_card_time"] = "2020-05-19 11:22:22"
#    rst["change_card_time"] = "2020-05-19 11:22:22"
#    return rst

def addText(img,orgpath,string,path,point=(100,100),size=32):
    draw = ImageDraw.Draw(img)
    fontpath = os.path.join(settings.BASE_DIR,"templates/font/simsun.ttc")
    #fontpath = os.path.join(settings.BASE_DIR,"templates/font/consola.ttf")
    font = ImageFont.truetype(fontpath, size,encoding="unic")
    draw.text(point,string,fill='black',font=font)
    img.save(path)

def update_signup_state(request):
    uid = request.user.id
    qdata = request.json
    need_params = ["id","order_status"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    vals = ccf.get_need_params(*need_params,**qdata)
    ids = vals.pop("id").split(",")
    minx = cm.SignupOrders.objects.filter(id__in=ids).order_by("order_status").first().order_status
    if vals.get("order_status") < minx and vals.get("order_status")!=-2:
        raise ce.TipException(u"非法操作!")
    if vals.get("order_status"):
        if int(vals.get("order_status")) > 0:
            cm.UserInfo.objects.filter(id=uid).update(verify=1)
    #正向操作顺序验证
    sx_flag = False
    sx_status_dct = {-1:[0,-1],0:[1,-2,0],1:[2,1],2:[3,2],3:[7,3],7:[9,7]}
    sorders = cm.SignupOrders.objects.filter(id__in=ids)
    for so in sorders:
        cur_status = so.order_status
        if not vals.get("order_status") in sx_status_dct[cur_status]: 
            sx_flag = True
    if sx_flag:
        raise ce.TipException(u"非法操作!")

    #审核通过发送支付通知
    vals["update_time"] = datetime.datetime.now()
    rst = cm.SignupOrders.objects.filter(id__in=ids).update(**vals)
    if int(vals.get("order_status")) == 1:
        from utils.aliyun_sms import send_audit_notice
        import common.common_notice as cn
        for item in cm.SignupOrders.objects.filter(id__in=ids):
            user_id = item.user_id
            phone = item.phone
            subject_item0 = item.subject_item.split("|")[-1]
            send_audit_notice(phone,subject_item0)
            cn.send_audit_notice(user_id,item.subject_item.split("|")[-1])
    if int(vals.get("order_status")) == -2:
        from utils.aliyun_sms import send_unauthed_notice
        import common.common_notice as cn
        for item in cm.SignupOrders.objects.filter(id__in=ids):
            user_id = item.user_id
            phone = item.phone
            send_unauthed_notice(phone)
            cn.send_unauthed_notice(user_id)

    if str(vals.get("order_status")) == "3":
        #root_target = os.path.join(settings.BASE_DIR,"../static/upload")
        root_target = os.path.join(settings.STATIC_ROOT,"upload")
        root = os.path.join(settings.BASE_DIR,"templates")
        class_hour_tpl = os.path.join(root,"classhour.png")
        signuporders = cm.SignupOrders.objects.filter(id__in=ids)
        for so in signuporders:
            subject_item = so.subject_item
            subject_item0 = subject_item.split("|")[0]
            subject_item1 = subject_item.split("|")[1]
            subject_item2 = subject_item.split("|")[2]
            train_type = so.train_type
            name = so.name
            subject = cm.Subject.objects.filter(id=so.subject_id).first()
            if train_type == u"新办":
                total_classhour = subject.class_hour
            elif train_type == u"复审":
                total_classhour = subject.update_class_hour
            else:
                total_classhour = subject.change_class_hour

            class_hour_file = os.path.join(root_target,"classhour{}.png".format(so.id))
            #
            img = Image.open(class_hour_tpl)
            addText(img,class_hour_tpl,unicode("巴中逸沣安全培训学时证明","utf-8"),class_hour_file,(160,65),24)
            addText(img,class_hour_tpl,unicode("姓名:{}".format(name),"utf-8"),class_hour_file,(80,100),20)
            addText(img,class_hour_tpl,unicode("工种:{}".format(subject_item0),"utf-8"),class_hour_file,(80,130),20)
            addText(img,class_hour_tpl,unicode("操作类型:{}".format(subject_item1),"utf-8"),class_hour_file,(80,160),20)
            addText(img,class_hour_tpl,unicode("准操项目:{}".format(subject_item2),"utf-8"),class_hour_file,(80,190),20)
            addText(img,class_hour_tpl,unicode("培训类型:{}".format(train_type),"utf-8"),class_hour_file,(80,220),20)
            addText(img,class_hour_tpl,unicode("总学时:{}".format(total_classhour),"utf-8"),class_hour_file,(80,250),20)
            addText(img,class_hour_tpl,unicode("已完成学时:{}".format(total_classhour),"utf-8"),class_hour_file,(80,280),20)
            url = "https://wxapi.yifeng2016.com/upload" + class_hour_file.replace(root_target,"")
            so.classhour_cert_url = url
            so.update_time = datetime.datetime.now()
            so.save()
    #考试完成记录复审和换证时间
    if str(vals.get("order_status")) == "7":
        now = datetime.datetime.now().date()
        signuporders = cm.SignupOrders.objects.filter(id__in=ids)
        for so in signuporders:
            subject_item = so.subject_item
            subject_item0 = subject_item.split("|")[0]
            #特种作业复审3年,换证6年
            if u"特种作业" in subject_item0:
                #so.update_time = now + datetime.timedelta(days=3*365)
                so.change_time = now + datetime.timedelta(days=6*365)
            #换证3年每年复审
            else:
                #so.update_time = now + datetime.timedelta(days=365)
                so.change_time = now + datetime.timedelta(days=3*365)
            so.update_time = datetime.datetime.now()
            so.save()

    return rst


def download_signup(request):
    """
    """
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    header = [u"姓名",u"联系电话",u"状态",u"管理员备注",u"报名类型",u"作业类别",
        u"准操项目",u"培训类型",u"考试时间",u"支付状态",u"支付金额",u"更新时间",
        u"发票类型",u"领证方式",u"实名认证",u"报名时间",u"培训开始时间",u"培训结束时间",u"公司名称"]
    ids = qdata.get("id").split(",")
    qset = cm.SignupOrders.objects.filter(id__in=ids)
    data = []
    for o in qset:
        subject_item0 = o.subject_item.split("|")[0]
        subject_item1 = o.subject_item.split("|")[1]
        subject_item2 = o.subject_item.split("|")[2]
        row = [o.name,o.phone,o.order_status,o.remark,
            subject_item0,subject_item1,subject_item2,o.train_type,o.exam_time,
            o.order_status,o.price,o.ctime,o.bill_type,o.receive_card,o.order_status,
            o.ctime,o.train_time_start,o.train_time_end,o.company]
        data.append(row)
    exceltool = ExcelTool("/tmp/demo.xls")
    xlsdata = exceltool.save_data(u"学员报名数据表",header,data)
    return xlsdata


def download_class_stu(request):
    """
    """
    qdata = request.json
    need_params = ["id"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    header = [u"姓名",u"联系电话",u"状态",u"管理员备注",u"报名类型",u"作业类别",
        u"准操项目",u"培训类型",u"考试时间",u"支付状态",u"支付金额",u"更新时间",
        u"发票类型",u"领证方式",u"实名认证",u"报名时间",u"培训开始时间",u"培训结束时间",u"公司名称"]
    ids = qdata.get("id").split(",")
    ids = [51,52,52,54]
    qset = cm.SignupOrders.objects.filter(id__in=ids)
    data = []
    for o in qset:
        subject_item0 = o.subject_item.split("|")[0]
        subject_item1 = o.subject_item.split("|")[1]
        subject_item2 = o.subject_item.split("|")[2]
        row = [o.name,o.phone,o.order_status,o.remark,
            subject_item0,subject_item1,subject_item2,o.train_type,o.exam_time,
            o.order_status,o.price,o.ctime,o.bill_type,o.receive_card,o.order_status,
            o.ctime,o.train_time_start,o.train_time_end,o.company]
        data.append(row)
    exceltool = ExcelTool("/tmp/demo.xls")
    xlsdata = exceltool.save_data(u"学员报名数据表",header,data)
    return xlsdata


def get_zipfile(files):                                                            
    """                                                                            
    """                                                                            
    cur_path = os.getcwd()                                                         
    path = os.path.split(files[0])[0]                                              
    os.chdir(path)                                                                 
    temp = tempfile.TemporaryFile()                                                
    archive = zipfile.ZipFile(temp, 'w', zipfile.ZIP_DEFLATED)                     
    for f in files:                                                                
        if os.path.exists(f):                                    
            f = os.path.split(f)[-1]
            archive.write(f)                                                
            os.remove(f)                                                    
    archive.close()                                                                
    os.chdir(cur_path)                                                             
    temp.seek(0)
    return temp


def set_style(name,height,bold=False,left=True):
    style = xlwt.XFStyle() # 初始化样式

    font = xlwt.Font() # 为样式创建字体
    font.name = name # 'Times New Roman'
    font.bold = bold
    font.color_index = 4
    font.height = height
    #borders= xlwt.Borders()
    #borders.left= 6
    #borders.right= 6
    #borders.top= 6
    #borders.bottom= 6
    alignment = xlwt.Alignment()
    if left:
        alignment.horz = 0x01
    else:
        alignment.horz = 0x03
    alignment.vert = 0x01
    style.font = font
    style.alignment = alignment
    #style.borders = borders
    return style

def copy_excel(src_file):
    """
    """
    # 首先用 xlrd 读取一张表格
    read_file = src_file
    workbook = xlrd.open_workbook(read_file, formatting_info=True)
    # 拷贝此表格
    new_book = copy(workbook)
    sheet = new_book.get_sheet(0)
    #return sheet
    #sheet.write_merge(8,8,0,8, u'考试时间：      年    月    日',set_style('Times New Roman',220,True))
    #sheet.write_merge(9,9,0,8, u'四川省安全生产监督管理局',set_style('Times New Roman',220,True,False))
    # 更多请见 xlwt_demo.py.
    
    #new_output_path = 'result2.xls'
    #new_book.save(new_output_path)
    return sheet,new_book


def download_zip1(request):
    """
    """
    qdata = request.json
    need_params = ["id","type"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    ids = qdata.get("id").split(",")
    qset = cm.SignupOrders.objects.filter(id__in=ids)
    root = os.path.join(settings.BASE_DIR,"templates")
    type = qdata.get("type")
    if type == "apply":
        tpl = os.path.join(root,"apply_template.docx")
        files = []
        for o in qset:
            doc = DocxTemplate(tpl)
            fname = os.path.join(root,u"{}.docx".format(o.name)).decode('utf-8').encode('gbk')
            subject_item0 = o.subject_item.split("|")[0]
            subject_item1 = o.subject_item.split("|")[1]
            subject_item2 = o.subject_item.split("|")[2]
            context = {"name":o.name,"sex":o.sex,"education":o.education,"idno":o.idno,"class_id":o.class_id,
                    "company":o.company,"phone":o.phone,"train_type":o.train_type,
                    "train_time_start":o.train_time_start,"train_time_end":o.train_time_end}
            doc.render(context)
            doc.save(fname)
            files.append(fname)
    else:
        files = []
        tpl_1 = os.path.join(root,"pxqd.xls")
        tpl_2 = os.path.join(root,"szksqd.xls")
        tpl_3 = os.path.join(root,"xxkqqd.xls")
        target_1 = os.path.join(root,u"培训签到表.xls")
        target_2 = os.path.join(root,u"实作考试签到表.xls")
        target_3 = os.path.join(root,u"新训考勤签到表.xls")
        #培训签到表
        sheet1,book = copy_excel(tpl_1)
        for i,o in enumerate(qset):
            #培训签到表
            sheet1.write(i+2,0,i+1)
            sheet1.write(i+2,1,o.name)
            ##实作考试签到表
            #sheet2 = copy_excel(tpl_2)
            #sheet2.write(i+4,0,i+1)
            #sheet2.write(i+4,0,o.name)
            ##新训考勤签到表
            #sheet3 = copy_excel(tpl_2)
            #sheet3.write(i+4,0,i+1)
            #sheet3.write(i+4,0,o.name)

        book.save(target_1)
        files.append(target_1)
        #实作考试签到表
        if qset.count() == 1:
            sheet2,book = copy_excel(tpl_2)
            for i,o in enumerate(qset):
                sheet2.write(i+3,0,i+1,set_style('Times New Roman',220,False))
                sheet2.write(i+3,1,o.name,set_style('Times New Roman',220,False))
            sheet2.write_merge(qset.count()+3,qset.count()+3,0,8, u'考试时间：      年    月    日',set_style('Times New Roman',220,True))
            sheet2.write_merge(qset.count()+4,qset.count()+4,0,8, u'四川省安全生产监督管理局',set_style('Times New Roman',220,True,False))
            book.save(target_2)
            files.append(target_2)
        elif qset.count() == 2:
            sheet2,book = copy_excel(tpl_2)
            for i,o in enumerate(qset):
                sheet2.write(3,i*5+i,i+1,set_style('Times New Roman',220,False))
                sheet2.write(3,i*5+i+1,o.name,set_style('Times New Roman',220,False))
            sheet2.write_merge(4,4,0,8, u'考试时间：      年    月    日',set_style('Times New Roman',220,True))
            sheet2.write_merge(5,5,0,8, u'四川省安全生产监督管理局',set_style('Times New Roman',220,True,False))
            book.save(target_2)
            files.append(target_2)
        else:
            qdata = list(qset.values_list("name",flat=True))
            rows = ccf.list_split(qdata,2)
            sheet2,book = copy_excel(tpl_2)
            for i,item in enumerate(rows):
                sheet2.write(i+3,0,i+1,set_style('Times New Roman',220,False))
                sheet2.write(i+3,1,item[0],set_style('Times New Roman',220,False))
                if len(item) == 2:
                    sheet2.write(i+3,5,i+3,set_style('Times New Roman',220,False))
                    sheet2.write(i+3,6,item[1],set_style('Times New Roman',220,False))
            sheet2.write_merge(len(rows)+3,len(rows)+3,0,8, u'考试时间：      年    月    日',set_style('Times New Roman',220,True))
            sheet2.write_merge(len(rows)+4,len(rows)+4,0,8, u'四川省安全生产监督管理局',set_style('Times New Roman',220,True,False))
            book.save(target_2)
            files.append(target_2)

    if files:
        zipfile = get_zipfile(files)

        return zipfile


def download_zip(request):
    """
    """
    qdata = request.json
    need_params = ["id","type"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    ids = qdata.get("id").split(",")
    qset = cm.SignupOrders.objects.filter(id__in=ids)
    root = os.path.join(settings.BASE_DIR,"templates")
    type = qdata.get("type")
    if type == "apply":
        tpl = os.path.join(root,"apply_template.docx")
        tpl_1 = os.path.join(root,"apply_template_tzzy.docx")
        tpl_2 = os.path.join(root,"apply_template_aqxy.docx")
        tpl_3 = os.path.join(root,"apply_template_cyry.docx")
        tpl_4 = os.path.join(root,"apply_template_tzsb.docx")
        files = []
        for o in qset:
            try:
                subject_item = o.subject_item
                if u"特种作业" in subject_item:
                    doc = DocxTemplate(tpl_1)
                #elif u"负责人" in subject_item:
                elif u"安全生产知识和管理能力" in subject_item:
                    doc = DocxTemplate(tpl_2)
                elif u"特种设备" in subject_item:
                    doc = DocxTemplate(tpl_4)
                else:
                    doc = DocxTemplate(tpl_3)
                subject_item0 = o.subject_item.split("|")[0]
                subject_item1 = o.subject_item.split("|")[1]
                subject_item2 = o.subject_item.split("|")[2]
                try:
                    subject_item_code = re.search(r"\w+",subject_item2).group()
                except:
                    subject_item_code = ""
                fname = u"{}_{}.docx".format(o.name,subject_item2)
                #fname = u"{}.docx".format(o.name)
                #fname = unicode(fname,"utf-8")
                fname = os.path.join(root,fname)
                birthday = "{}-{}-{}".format(o.idno[6:10],o.idno[10:12],o.idno[12:14])
                idnoimg_face = o.idnoimg_face.replace(settings.HOST,settings.STATIC_ROOT)
                idnoimg_back = o.idnoimg_back.replace(settings.HOST,settings.STATIC_ROOT)
                education_img = o.education_img.replace(settings.HOST,settings.STATIC_ROOT)
                oldcard_img = o.oldcard_img.replace(settings.HOST,settings.STATIC_ROOT) if o.oldcard_img else None
                classhour_cert_url = o.classhour_cert_url.replace(settings.HOST,settings.STATIC_ROOT) if o.classhour_cert_url else None
                halfbody_img = o.halfbody_img.replace(settings.HOST,settings.STATIC_ROOT) if o.halfbody_img else None

                idnoimg_face = thumbnail_pic(idnoimg_face) if idnoimg_face else None
                idnoimg_back = thumbnail_pic(idnoimg_back) if idnoimg_back else None
                education_img = thumbnail_pic(education_img) if education_img else None
                oldcard_img = thumbnail_pic(oldcard_img) if oldcard_img else None
                classhour_cert_url = thumbnail_pic(classhour_cert_url) if classhour_cert_url else None
                halfbody_img = thumbnail_pic(halfbody_img) if halfbody_img else None
                context = {"name":o.name,"sex":o.sex,"education":o.education,"idno":o.idno,"class_id":o.class_id,
                        "company":o.company,"phone":o.phone,"train_type":o.train_type,"subject_item1":subject_item1,
                        "subject_item2":subject_item2,"train_time_start":o.train_time_start,"subject_item_code":subject_item_code,
                        "train_time_end":o.train_time_end,"birthday":birthday,
                        "idnoimg_face":InlineImage(doc,idnoimg_face,height=Mm(82.5),width=Mm(140.66)),
                        "idnoimg_back":InlineImage(doc,idnoimg_back,height=Mm(82.5),width=Mm(140.66)),
                        "halfbody_img":InlineImage(doc,halfbody_img,height=Mm(30.97),width=Mm(28.91)),
                        "education_img":InlineImage(doc,education_img,height=Mm(82.5),width=Mm(140.66))
                        }
                if oldcard_img and o.train_type in [u"复审",u"换证"]:
                    context.update({
                        "oldcard_img":InlineImage(doc,oldcard_img,height=Mm(82.5),width=Mm(140.66))
                        })
                if classhour_cert_url:
                    context.update({
                        "classhour_cert_url":InlineImage(doc,classhour_cert_url,height=Mm(82.5),width=Mm(140.66))
                        })
                doc.render(context)
                doc.save(fname)
                files.append(fname)
            except Exception as e:
                import traceback
                traceback.print_exc()
                print e,8888888888888
                continue
    else:
        files = []
        data = {}
        tpl_1 = os.path.join(root,"pxqd.xls")
        tpl_2 = os.path.join(root,"szksqd.xls")
        tpl_3 = os.path.join(root,"xxkqqd.xls")

        tpl_4 = os.path.join(root,"qtcy.xls")
        tpl_5 = os.path.join(root,"tzzy.xls")

        target_1 = os.path.join(root,u"培训签到表.xls")
        target_2 = os.path.join(root,u"实作考试签到表.xls")
        target_3 = os.path.join(root,u"新训考勤签到表.xls")

        target_4 = os.path.join(root,u"安全考核合格证人员名册.xls")
        target_5 = os.path.join(root,u"大安全管理人员.xls")
        target_6 = os.path.join(root,u"考试申报表.xls")

        subject_item0 = qset.first().subject_item.split("|")[0]
        subject_item1 = qset.first().subject_item.split("|")[1]
        subject_item2 = qset.first().subject_item.split("|")[2]
        qdata = list(qset.values_list("name",flat=True))
        rows = ccf.list_split(qdata,2)
        items = []
        for i,item in enumerate(rows):
            if len(item) == 2:
                items.append([i+1,item[0],i+2,item[1]])
            else:
                items.append([i+1,item[0]])
        data["subject_item0"] = subject_item0
        data["subject_item1"] = subject_item1
        data["subject_item2"] = subject_item2
        data["items"] = items
        #考勤签到表
        tpl_1 = os.path.join(root,"kqqd.xls")
        target_1 = os.path.join(root,u"考勤签到表.xls")
        render_xls_tpl(tpl_1,data,target_1)
        files.append(target_1)
        #考试签到表
        tpl_2 = os.path.join(root,"ksqd.xls")
        target_2 = os.path.join(root,u"考试签到表.xls")
        render_xls_tpl(tpl_2,data,target_2)
        files.append(target_2)

        #申报考试表
        subject_item0 = qset.first().subject_item.split("|")[0]
        if subject_item0 == u"其他安全生产从业人员":
            items = []
            for i,o in enumerate(qset):
                subject_item1 = o.subject_item.split("|")[1]
                subject_item2 = o.subject_item.split("|")[2]
                items.append([i+1,o.name,o.sex,o.education,o.idno,o.company,
                    subject_item1,subject_item2,o.phone])
            data["items"] = items
            render_xls_tpl(tpl_4,data,target_4)
            files.append(target_4)
        else:
            items = []
            for i,o in enumerate(qset):
                train_type = o.train_type
                train_day = 3
                subject_item1 = o.subject_item.split("|")[1]
                subject_item2 = o.subject_item.split("|")[2]
                birthday = "{}-{}-{}".format(o.idno[6:10],o.idno[10:12],o.idno[12:14])
                items.append([i+1,"",o.name,o.sex,birthday,o.idno,o.education,
                    o.phone,subject_item1,subject_item2,train_type,u"巴中逸沣安全培训","",
                    train_day,u"正常考试","",o.company,"","",u"巴中市"])
            #写xls文件
            tpl_3 = os.path.join(root,"tzzykssbb.xls")
            target_3 = os.path.join(root,u"特种作业考试申报表.xls")

            sheet2,book = copy_excel(tpl_5)
            for i,item in enumerate(items):
                for j in range(0,len(item)):
                    sheet2.write(i+2,j,item[j],set_style('Times New Roman',220,False,True))
            book.save(target_3)
            files.append(target_3)


    if files:
        zipfile = get_zipfile(files)

        return zipfile


def upload_paper_info(request):
    """
    """
    upload_file = request.FILES['file']
    if not upload_file:
        raise ce.TipException(u"缺少文件参数!")
    tmpxls = "/tmp/{}.xls".format(str(int(time.time())))
    with open(tmpxls,"wb+") as f:
        for chunk in upload_file.chunks():
            f.write(chunk)
    f.close()
    exceltool = ExcelTool(tmpxls)
    data = exceltool.get_data()
    total_score = 100
    total_time = 60
    score = 1
    for row in data:
        subject_item = u"{}|{}|{}".format(row[0].strip(),row[1].strip(),row[2].strip())
        train_type = row[3].strip()
        title = row[4].strip()
        subject_id = cm.Subject.objects.filter(name=row[2]).first().id
        #新增试卷
        obj,flag = cm.Papers.objects.get_or_create(**{
                "title":title, 
                "subject_item":subject_item, 
                "train_type":train_type, 
            })
        obj.total_time = row[11]
        obj.subject_id = subject_id
        #新增题库
        qtype = {u"单选题":1,u"多选题":2,u"判断题":3}.get(row[5].strip())
        title = row[6].strip()
        options = row[7].strip()
        answer = row[8].strip()
        analysis = row[9].strip()
        qobj,flag = cm.Questions.objects.get_or_create(**{
                "title":title.encode("utf-8"), 
                "qtype":qtype, 
                "options":options.encode("utf-8"), 
                "answer":answer.encode("utf-8"),
                "analysis":analysis.encode("utf-8")
            })
        qobj.score = row[10]
        qobj.save()
        obj.questions.add(qobj)
        total_score = obj.total_score if obj.total_score else 0
        total_score += row[10]
        obj.total_score = total_score
        obj.total_score = total_score
        obj.save()

def get_permission_list(request):
    
    data = [u"概览",u"项目管理",u"培训计划",u"在线培训",u"用户管理",u"内容管理",u"系统管理"]
    roots = list(cm.Subject.objects.filter(Q(pid=0)|Q(pid__isnull=True)).values_list("name",flat=True))
    data.extend(roots)
    return data

def rotate_image(request):
    """旋转图像
    """
    qdata = request.json
    need_params = ["url"]
    mse = ccf.check_params(*need_params,**qdata)
    if mse:
        raise ce.TipException(mse)
    url = qdata.get("url")
    if "?" in url:
        url = url.split("?")[0]
    _id = qdata.get("id")
    imgpath = url.replace(settings.HOST,settings.STATIC_ROOT)
    im = Image.open(imgpath)
    if im.mode == "P":
        im = im.convert('RGB')
    im_rotate = im.transpose(Image.ROTATE_90)
    #im_rotate = im.rotate(90)
    im_rotate.save(imgpath)
    url = imgpath.replace(settings.STATIC_ROOT,settings.HOST)
    return url


def get_index_data(request):
    """
    """
    ret = {}
    user_count = cm.UserInfo.objects.filter(utype=2).count()
    signup_count = cm.SignupOrders.objects.all().count()
    paper_count = cm.Papers.objects.all().count()
    videos_count = cm.Videos.objects.all().count()

    waiting_pay_count = cm.SignupOrders.objects.filter(order_status=1).count()
    waiting_audit_count = cm.SignupOrders.objects.filter(order_status=0).count()
    waiting_exam_count = cm.SignupOrders.objects.filter(order_status=3).count()
    ret["user_count"] = user_count
    ret["signup_count"] = signup_count
    ret["paper_count"] = paper_count
    ret["videos_count"] = videos_count
    ret["waiting_pay_count"] = waiting_pay_count
    ret["waiting_audit_count"] = waiting_audit_count
    ret["waiting_exam_count"] = waiting_exam_count
    return ret


def allocation_class(request):
    """
    """
    qdata = request.json
    ids = qdata.get("ids")
    class_id = qdata.get("class_id")
    cm.SignupOrders.objects.filter(id__in=ids).update(class_id=class_id)