zkyuan/src/manage/views.py

# coding=utf-8
from __future__ import unicode_literals
import requests
import random,datetime,time
import json
import uuid
from django.contrib import auth
from django.core.cache import cache
from django.conf import settings
from django.http import FileResponse,HttpResponse
from wsgiref.util import FileWrapper

import common.error_info as ce
from common import core_views as cv
import common.common_control as ccc
import common.common_functions as ccf
import manage.control_auth as ca
import manage.controls as ctl


class SysUserInfoListView(cv.AdminView):
    def get(self, request):
        """#获取账号列表(管理后台)
        @name:账号或管理员姓名
        @journal_id:期刊id
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class SysUserInfoAllListView(cv.AdminView):
    def get(self, request):
        """#获取账号列表(管理后台)
        @name:账号或管理员姓名
        """
        try:
            qdata = request.json
            rst = ctl.get_all_users(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class UserJournalsView(cv.AdminView):
    def get(self, request):
        """#获取账号期刊列表(管理后台)
        """
        try:
            qdata = request.json
            rst = ctl.get_user_journals_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class UserRolesView(cv.AdminView):
    def get(self, request):
        """#获取账号角色列表(管理后台)
        """
        try:
            qdata = request.json
            rst = ctl.get_user_roles_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class UserPermissionsView(cv.AdminView):
    def get(self, request):
        """#获取账号权限列表(管理后台)
        """
        try:
            qdata = request.json
            rst = ctl.get_user_permissions_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class SysUserInfoView(cv.AdminView):
    def get(self, request):
        """#账号详情(平台管理后台)
        @id:1
        """
        try:
            rst = ctl.get_user_info(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增账号(平台管理后台)
        @name:"账号"
        @password:"密码"
        @realname:"姓名"
        @is_active:"是否激活",0/1
        @journal_id:"期刊id"
        @role_id:"角色id"
        @phone:"手机号"
        """
        qdata = request.json
        need_params = ["name","phone","password","realname","is_active","journal_id","role_id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["password"] = ccf.make_password(vals["password"])
            vals["cid"] = request.user.id
            vals["cname"] = request.user.name
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改账号(平台管理后台)
        @id:"1"
        @name:"账号"
        @password:"密码"
        @realname:"姓名"
        @is_active:"是否激活",0/1
        @journal_id:"期刊id"
        @role_id:"角色id"
        @phone:"手机号"
        """
        qdata = request.json
        need_params = ["id","phone","name","password","realname","is_active","journal_id","role_id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            if len(vals["password"])<20:
                vals["password"] = ccf.make_password(vals["password"])
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class EnterPriseAllView(cv.AdminView):
    def get(self, request):
        """#所有企业(平台管理后台)
        @name:"企业名称"
        """
        try:
            rst = ctl.get_all_enterprise_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class EnterPriseListView(cv.AdminView):
    def get(self, request):
        """#企业列表(平台管理后台)
        @name:"企业名称"
        @area:"区域"
        @category:"企业类型"
        @page:1
        @page_size:20
        """
        try:
            total,rst = ctl.get_enterprise_list(request)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class EnterPriseView(cv.AdminView):
    def get(self, request):
        """#企业详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增企业账号(平台管理后台)
        @name:"名称"
        @username:"账号"
        @password:"密码"
        @area:"所属区域"
        @parent_id:"上级id"
        @parent_name:"上级名称",
        @is_active:"账号状态",0/1
        @category:"行业",
        @busscope:"经营范围",
        @legalperson:"法人",
        @legalperson_phone:"法人电话",
        @safecolor_img:"安全四色图",
        @faceimg:"背景图"
        """
        qdata = request.json
        need_params = ["name","username","password","category","area",
            "legalperson","legalperson_phone","busscope","is_active"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["parent_id","parent_name","principal","principal_phone","faceimg","safecolor_img"])
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["password"] = ccf.make_password(vals["password"])
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改企业账号(平台管理后台)
        @id:"id"
        @name:"名称"
        @username:"账号"
        @password:"密码"
        @area:"所属区域"
        @parent_id:"上级id"
        @parent_name:"上级名称",
        @is_active:"账号状态",0/1
        @category:"行业",
        @busscope:"经营范围",
        @legalperson:"法人",
        @legalperson_phone:"法人电话",
        @safecolor_img:"安全四色图",
        @faceimg:"背景图"
        """
        qdata = request.json
        need_params = ["id","name","username","password","category","area",
            "legalperson","legalperson_phone","busscope","faceimg","safecolor_img","is_active"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["parent_id","parent_name","principal","principal_phone"])
            vals = ccf.get_need_params(*need_params,**qdata)
            if len(vals["password"]) < 20:
                vals["password"] = ccf.make_password(vals["password"])
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """删除政府账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class GovermentListView(cv.AdminView):
    def get(self, request):
        """#获取政府列表(平台管理后台)
        @area:"昵称"
        @name:"姓名"
        """
        try:
            rst = ctl.get_goverment_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class GovermentView(cv.AdminView):
    def get(self, request):
        """#政府详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增政府账号(平台管理后台)
        @name:"政府名称"
        @username:"政府账号"
        @password:"密码"
        @area:"所属区域"
        @parent_id:"上级id",不传或传null
        @parent_name:"上级名称",不传或传null
        @is_active:"账号状态",0/1
        """
        qdata = request.json
        need_params = ["name","username","password","area","is_active"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["parent_id","parent_name"])
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["password"] = ccf.make_password(vals["password"])
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改政府账号(平台管理后台)
        @id:"政府id"
        @name:"政府名称"
        @username:"政府账号"
        @password:"密码"
        @area:"所属区域"
        @parent_id:"上级id"
        @parent_name:"上级名称",
        @is_active:"账号状态",0/1
        """
        qdata = request.json
        need_params = ["id","name","username","password","area","is_active"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["parent_id","parent_name"])
            vals = ccf.get_need_params(*need_params,**qdata)
            if len(vals["password"]) < 20:
                vals["password"] = ccf.make_password(vals["password"])
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除政府账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class GovermentSubEntView(cv.AdminView):
    def post(self,request):
        """#新增政府下属企业(平台管理后台)
        @goverment_id:1,
        @enterprise_id:1
        """
        qdata = request.json
        need_params = ["goverment_id","enterprise_id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_goverment_subenterprise(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除下属企业(平台管理后台)
        @goverment_id:1,
        @enterprise_id:1
        """
        qdata = request.json
        need_params = ["goverment_id","enterprise_id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_goverment_subenterprise(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class DepartmentListView(cv.AdminView):
    def get(self, request):
        """#获取部门列表(平台管理后台)
        @enterprise_id:"企业id"
        """
        try:
            qdata = request.json
            need_params = ["enterprise_id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            total,rst = ctl.get_department_list(**vals)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class DepartmentView(cv.AdminView):
    def get(self, request):
        """#部门详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_department_info(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增部门(平台管理后台)
        @name:"政府名称"
        @enterprise_id:"政府名称"
        @enterprise_name:"政府名称"
        @staffusers:[{id:0,name:"",password:"","phone":"",utype:"部门级/岗位级"}]
        """
        qdata = request.json
        need_params = ["enterprise_id","enterprise_name","name"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["staffusers"])
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_department(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改部门(平台管理后台)
        @id:""
        @name:"政府名称"
        @enterprise_id:"政府名称"
        @enterprise_name:"政府名称"
        @staffusers:[{id:1,name:"",password:"","phone":"",utype:"部门级/岗位级"}]
        """
        qdata = request.json
        need_params = ["id","enterprise_id","enterprise_name","name"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["staffusers"])
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_department(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除部门(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_department(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class RiskPointListView(cv.AdminView):
    def get(self, request):
        """#获取风险点列表(平台管理后台)
        """
        try:
            qdata = request.json
            rst = ctl.get_riskpoint_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class RiskPointView(cv.AdminView):
    def get(self, request):
        """#风险点详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增风险点(平台管理后台)
        @name:"政府名称"
        @parent_id:"上级id",不传或传null
        @parent_name:"上级名称",不传或传null
        @enterprise_id:"上级id",不传或传null
        @enterprise_name:"上级名称",不传或传null
        """
        qdata = request.json
        need_params = ["name","enterprise_id","enterprise_name"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["parent_id","parent_name"])
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改风险点(平台管理后台)
        @id:1
        @name:"政府名称"
        @parent_id:"上级id",不传或传null
        @parent_name:"上级名称",不传或传null
        @enterprise_id:"上级id",不传或传null
        @enterprise_name:"上级名称",不传或传null
        """
        qdata = request.json
        need_params = ["id","name","enterprise_id","enterprise_name"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["parent_id","parent_name"])
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除风险点(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MonitTaskListView(cv.AdminView):
    def get(self, request):
        """#获取任务列表(平台管理后台)
        @riskpoint_id:1,风险点id
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class StaffUserView(cv.AdminView):
    def get(self, request):
        """#获取员工详情(平台管理后台)
        @id:1
        """
        try:
            qdata = request.json
            need_params = ["id"]
            #mse = ccf.check_params(*need_params,**qdata)
            #if mse:
            #    raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            id = vals.get("id")
            rst = ctl.get_staffuser_info(*[id])
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self, request):
        """#新增员工(平台管理后台)
        @enterprise_id:1
        @department_id:1
        @name:"肖小肖"
        @username:"15982456282"
        @password:"123456"
        @phone:"15982456282"
        @utype:"岗位级/部门级/公司级"
        """
        try:
            qdata = request.json
            need_params = ["enterprise_id","name","username","password","phone","utype"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            need_params.extend(["department_id"])
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_staffuser(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self, request):
        """#修改员工(平台管理后台)
        @id:1
        @enterprise_id:1
        @department_id:1,公司级传0
        @name:"肖小肖"
        @username:"15982456282"
        @password:"123456"
        @phone:"15982456282"
        @utype:"岗位级/部门级/公司级"
        """
        try:
            qdata = request.json
            need_params = ["id","enterprise_id","department_id","name","username","password","phone","utype"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_staffuser(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除员工(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class StaffUserListView(cv.AdminView):
    def get(self, request):
        """#获取员工列表(平台管理后台)
        @department_id:1
        @enterprise_id:1
        """
        try:
            qdata = request.json
            need_params = ["department_id","enterprise_id"]
            #mse = ccf.check_params(*need_params,**qdata)
            #if mse:
            #    raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            total,rst = ctl.get_list_info(self,**vals)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MonitTaskView(cv.AdminView):
    def get(self, request):
        """#任务详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增任务(平台管理后台)
        @riskpoint_id:"风险点id"
        @riskpoint_name:"风险点名称"
        @riskpoint_item:"宿舍|男生宿舍",风险点拼接
        @enterprise_id:"企业id"
        @enterprise_name:"上级名称"
        @name:"风险描述"
        @rec_stand:"辨识标准"
        @danger_result:"导致结果"
        @monit_tec:"工程技术"
        @monit_method:"管控措施"
        @monit_edu:"教育培训"
        @single_defense:"个体防护"
        @emerg_handle:"应急处理"
        @risk_level:"风险级别"
        @other_method:"其他管控措施"
        @department_id:"部门id"
        @cycle:"周期"
        @held_person_id:"责任人id"
        @held_person:"责任人"
        @held_person_phone:"责任人电话"
        """
        qdata = request.json
        need_params = ["riskpoint_id","riskpoint_name","riskpoint_item","enterprise_id",
            "enterprise_name","name","rec_stand","danger_result","monit_tec","monit_method",
            "monit_edu","single_defense","emerg_handle","risk_level","other_method",
            "department_id","cycle","held_person","held_person_phone"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#新增任务(平台管理后台)
        @id:"id"
        @riskpoint_id:"风险点id"
        @riskpoint_name:"风险点名称"
        @riskpoint_item:"宿舍|男生宿舍",风险点拼接
        @enterprise_id:"企业id"
        @enterprise_name:"上级名称"
        @name:"风险描述"
        @rec_stand:"辨识标准"
        @danger_result:"导致结果"
        @monit_tec:"工程技术"
        @monit_method:"管控措施"
        @monit_edu:"教育培训"
        @single_defense:"个体防护"
        @emerg_handle:"应急处理"
        @risk_level:"风险级别"
        @other_method:"其他管控措施"
        @department_id:"部门id"
        @cycle:"周期"
        @held_person_id:"责任人id"
        @held_person:"责任人"
        @held_person_phone:"责任人电话"
        """
        qdata = request.json
        need_params = ["id","riskpoint_id","riskpoint_name","enterprise_id",
            "enterprise_name","name","rec_stand","danger_result","monit_tec","monit_method",
            "monit_edu","single_defense","emerg_handle","risk_level","other_method",
            "department_id","cycle","held_person","held_person_phone"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            #need_params = need_params.extend(["riskpoint_item","held_person_id"])
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除任务(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)



class UploadFileView(cv.BaseView):
    def post(self, request):
        """
        #文件上传(平台管理后台)
        @file:"",文件对象
        @type:"",前端自定义参数
        """
        try:
            rst = ccc.upload_file(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class GetDefaultView(cv.AdminView):
    def get(self, request):
        """
        #获取默认枚举数据(平台管理后台)
        """
        try:
            rst = ctl.get_default_data(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessagesView(cv.AdminView):
    def post(self, request):
        """#发送消息(平台管理后台)
        @send_type:"1/2群发/单发"
        @area:"区域"
        @category:"公司类型"
        @title:"消息标题"
        @content:"消息内容"
        @attach:"附件"
        """
        try:
            rst = ctl.send_messages(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除消息(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessagesListView(cv.AdminView):
    def get(self, request):
        """#消息列表(平台管理后台)
        @message_type:"notice/sys/warning(通知/系统/告警)"
        @name:"搜索字段"
        """
        try:
            total,rst = ctl.get_messages_list(request)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class MessageReceiverListView(cv.AdminView):
    def get(self, request):
        """#获取消息接收人列表(平台管理后台)
        """
        try:
            rst = ctl.get_message_receiver_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MonitTaskUploadView(cv.AdminView):
    def post(self, request):
        """
        #批量导入管控任务(平台管理后台)
        @file:"",文件对象
        """
        try:
            success,failed = ctl.upload_monittasks(request)
            return cv.to_suc({"success":success,"failed":failed})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class DocumentionView(cv.AdminView):
    def get(self, request):
        """#用户详情
        @id:1
        """
        try:
            rst = ctl.get_detail_info(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """新增文件资料(平台管理后台)
        @name:"账号"
        @fileurl:"文件地址"
        """
        qdata = request.json
        need_params = ["name","fileurl"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """修改文件资料(平台管理后台)
        @id:"1"
        @name:"账号"
        @fileurl:"文件地址"
        """
        qdata = request.json
        need_params = ["name","fileurl"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class DocumentionListView(cv.AdminView):
    def get(self, request):
        """#获取任务列表(平台管理后台)
        @riskpoint_id:1,风险点id
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class FriendLinkView(cv.AdminView):
    def get(self, request):
        """#用户详情
        @id:1
        """
        try:
            rst = ctl.get_detail_info(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """新增友情链接(平台管理后台)
        @name:"账号"
        @url:"链接地址"
        """
        qdata = request.json
        need_params = ["name","url"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """修改友情链接(平台管理后台)
        @id:"1"
        @name:"账号"
        @url:"链接地址"
        """
        qdata = request.json
        need_params = ["id","name","url"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class FriendLinkListView(cv.AdminView):
    def get(self, request):
        """#获取任务列表(平台管理后台)
        @riskpoint_id:1,风险点id
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class DashboardIndexView(cv.AdminView):
    def get(self, request):
        """#获取概览数据(平台管理后台)
        @type:"pt/zf/qy"
        """
        try:
            qdata = request.json
            need_params = ["type"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["uid"] = request.user.id
            vals["utype"] = request.utype
            rst = ctl.get_dashboard_index(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MonitJobListView(cv.AdminView):
    def get(self, request):
        """
        #获取任务巡检记录(平台管理后台)
        @riskpoint_item:"风险点",
        @page:1,
        @page_size:20
        """
        try:
            rst = ctl.get_monitjob_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class BillView(cv.AdminView):
    def get(self, request):
        """#用户详情
        @id:1
        """
        try:
            rst = ctl.get_detail_info(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """新增文件资料(平台管理后台)
        @name:"账号"
        @fileurl:"文件地址"
        """
        qdata = request.json
        need_params = ["name","fileurl"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """修改文件资料(平台管理后台)
        @id:"1"
        @name:"账号"
        @fileurl:"文件地址"
        """
        qdata = request.json
        need_params = ["name","fileurl"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class IndexView(cv.AdminView):
    def get(self, request):
        """#首页统计数据(平台管理后台)
        """
        try:
            qdata = request.json
            cats = ctl.get_cat_list()
            return cv.to_suc(cats)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class CatListView(cv.AdminView):
    def get(self, request):
        """#获取分类列表(平台管理后台)
        """
        try:
            qdata = request.json
            cats = ctl.get_cat_list()
            return cv.to_suc(cats)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class CategoryView(cv.AdminView):
    
    def post(self,request):
        """新增商品分类
        """
        qdata = request.json
        need_params = ["name","parent_id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self, request):
        """#分类信息(平台管理后台)
        """
        qdata = request.json
        need_params = ["id","name","parent_id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class GoodsView(cv.AdminView):
    def get(self,request):
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """新增商品分类
        """
        qdata = request.json
        need_params = ["name","category_id","price","content","imgs","img"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self, request):
        """#分类信息(平台管理后台)
        """
        qdata = request.json
        need_params = ["id","name","category_id","price","content","imgs","img"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_goods(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class GoodsListView(cv.AdminView):
    def get(self, request):
        """#获取分类列表(平台管理后台)
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class OrdersListView(cv.AdminView):
    def get(self, request):
        """#获取分类列表(平台管理后台)
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class OrdersView(cv.AdminView):
    
    def put(self, request):
        """#分类信息(平台管理后台)
        """
        qdata = request.json
        need_params = ["id","name"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class OrdersModifyView(cv.AdminView):
    
    def put(self, request):
        """#分类信息(平台管理后台)
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            rst = ctl.modify_orders(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class TemplateView(cv.AdminView):
    def get(self, request):
        """#模板详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            rst["widget"] = json.loads(rst["widget"]) if rst else []
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#模板账号(平台管理后台)
        @name:"模板名称"
        @widget:"模板字段/组件"
        """
        qdata = request.json
        need_params = ["name","widget"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["cid"] = request.user.id
            vals["cname"] = request.user.name
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改模板(平台管理后台)
        @id:"1"
        @name:"模板名称"
        @widget:"模板字段/组件"
        """
        qdata = request.json
        need_params = ["id","name","widget"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class TemplateStatusView(cv.AdminView):
    def put(self,request):
        """#修改模板(平台管理后台)
        @id:"1"
        @name:"模板名称"
        @widget:"模板字段/组件"
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_status(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class MessageStatusView(cv.AdminView):
    def put(self,request):
        """#修改模板(平台管理后台)
        @id:"1"
        @name:"模板名称"
        @widget:"模板字段/组件"
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_status(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class TemplateListView(cv.AdminView):
    def get(self, request):
        """#获取模板列表(管理后台)
        @name:账号或管理员姓名
        @page:1
        @page_size:20
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class TemplateAllListView(cv.AdminView):
    def get(self, request):
        """#获取所有模板(管理后台)
        """
        try:
            qdata = request.json
            rst = ctl.get_all_template_list(request)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class RoleView(cv.AdminView):
    def get(self, request):
        """#角色详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增角色(平台管理后台)
        @name:"模板名称"
        @permissions:"权限"
        """
        qdata = request.json
        need_params = ["name","permissions"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["cid"] = request.user.id
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改模板(平台管理后台)
        @id:"1"
        @name:"模板名称"
        @widget:"模板字段/组件"
        """
        qdata = request.json
        need_params = ["id","name","permissions"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class RoleListView(cv.AdminView):
    def get(self, request):
        """#获取角色列表(管理后台)
        @name:账号或管理员姓名
        @page:1
        @page_size:20
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class MessageOutView(cv.BaseView):
    def get(self, request):
        """#消息详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_message_out_info(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class MessageView(cv.AdminView):
    def get(self, request):
        """#消息详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["cid"] = request.user.id
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增消息(平台管理后台)
        @name:"名称"
        @receiver_id:"接收人"
        @template_id:"模板id"
        """
        qdata = request.json
        need_params = ["name"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["receiver_id","fileurl","filename","template_id"])
            vals = ccf.get_need_params(*need_params,**qdata)
            if vals.get("receiver_id"):
                vals["type"] = 0
            else:
                vals["type"] = 1
            vals["cid"] = request.user.id
            vals["cname"] = request.user.name
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改消息(平台管理后台)
        @id:"1"
        @name:"名称"
        @receiver_id:"接收人"
        @template_id:"模板id"
        """
        qdata = request.json
        need_params = ["id","name","receiver_id","template_id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["fileurl","filename"])
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class MessageListView(cv.AdminView):
    def get(self, request):
        """#获取消息列表(管理后台)
        @name:账号或管理员姓名
        @page:1
        @page_size:20
        """
        try:
            qdata = request.json
            qdata["cid"] = request.user.id
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class CityListView(cv.AdminView):
    def get(self, request):
        """#获取城市数据列表(管理后台)
        """
        try:
            qdata = request.json
            rst = ctl.get_citys_data()
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class OrganizerAllListView(cv.AdminView):
    def get(self, request):
        """#获取所有主办单位(管理后台)
        """
        try:
            qdata = request.json
            rst = ctl.get_all_organizers(self,**qdata)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class ConferenceView(cv.AdminView):
    def get(self, request):
        """#会议详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增会议(平台管理后台)
        @name:"模板名称"
        @img:"图片"
        @organizer_id:"主办单位"
        @city:"城市"
        @address:"地址"
        @desc:"会议简介"
        """
        qdata = request.json
        need_params = ["name","img","organizer_id","city","address","desc","is_signup",
            "signup_fields","signup_number","is_popular","is_recommend","speaker"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["cid"] = request.user.id
            rst = ctl.add_conference(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改会议(平台管理后台)
        @id:"1"
        @name:"模板名称"
        @widget:"模板字段/组件"
        """
        qdata = request.json
        need_params = ["id","name","img","organizer_id","city","address"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除会议(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class ConferenceListView(cv.AdminView):
    def get(self, request):
        """#获取会议数据列表(管理后台)
        """
        try:
            qdata = request.json
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class MessageSurveyResultOutView(cv.BaseView):
    def post(self,request):
        """#新增消息(平台管理后台)
        @message_id:"接收人"
        @result:"模板id"
        """
        qdata = request.json
        need_params = ["message_id","result"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            try:
                vals["cid"] = request.user.id if request.user else 0
                vals["cname"] = request.user.name if request.user else ""
            except:
                vals["cid"] = 0
                vals["cname"] = ""
            rst = ctl.save_survey_result_out(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessageSurveyResultView(cv.AdminView):
    def get(self, request):
        """#新增调查结果(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_detail_info(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#新增消息(平台管理后台)
        @message_id:"接收人"
        @result:"模板id"
        """
        qdata = request.json
        need_params = ["message_id","result"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            try:
                vals["cid"] = request.user.id if request.user else 0
                vals["cname"] = request.user.name if request.user else ""
            except:
                vals["cid"] = 0
                vals["cname"] = ""
            rst = ctl.save_survey_result(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改消息(平台管理后台)
        @id:"1"
        @name:"名称"
        @receiver_id:"接收人"
        @template_id:"模板id"
        """
        qdata = request.json
        need_params = ["message_id","result"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessageSurveyAnalyseView(cv.AdminView):
    def get(self, request):
        """#获取问卷分析结果(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["message_id","type"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            need_params.append("name")
            vals = ccf.get_need_params(*need_params,**qdata)
            total,rst = ctl.get_survey_analyse_list(**vals)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessageSurveyAnalyseOutView(cv.AdminView):
    def get(self, request):
        """#获取问卷分析结果(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["message_id","type"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            need_params.append("name")
            vals = ccf.get_need_params(*need_params,**qdata)
            total,rst,headers = ctl.get_survey_analyse_list_out(**vals)
            return cv.to_suc({"total":total,"list":rst,"headers":headers})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessageSurveyQuestionAnalyseView(cv.AdminView):
    def get(self, request):
        """#获取问卷分析结果(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id","type"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.get_survey_question_analyse_list(**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessageSurveyResultDownloadView(cv.AdminView):
    def get(self,request):
        """#新增消息(平台管理后台)
        @message_id:"接收人"
        @result:"模板id"
        """
        try:
            import urllib
            xlsdata = ctl.download_survey_result(request)
            filename = u"统计结果.xls"
            return cv.stream_file(xlsdata,"application/vnd.ms-excel",filename)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class MessageSurveyResultDownloadOutView(cv.AdminView):
    def get(self,request):
        """#新增消息(平台管理后台)
        @message_id:"接收人"
        @result:"模板id"
        """
        try:
            import urllib
            xlsdata = ctl.download_survey_result_out(request)
            filename = u"统计结果.xls"
            return cv.stream_file(xlsdata,"application/vnd.ms-excel",filename)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessageSurveyResultDownloadAllView(cv.AdminView):
    def get(self,request):
        """#导出所有(平台管理后台)
        @message_id:"message_id"
        @type:"文件类型"
        """
        try:
            import urllib
            xlsdata = ctl.download_survey_result_all(request)
            filename = u"统计结果.xls"
            return cv.stream_file(xlsdata,"application/vnd.ms-excel",filename)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

class MessageSurveyResultDownloadItemView(cv.AdminView):
    def post(self,request):
        """#按题导出所有(平台管理后台)
        @message_id:"message_id"
        @type:"文件类型"
        """
        try:
            import urllib
            xlsdata = ctl.download_survey_result_item(request)
            filename = u"统计结果.xls"
            return cv.stream_file(xlsdata,"application/vnd.ms-excel",filename)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessageNoticeAnalyseDownloadView(cv.AdminView):
    def get(self,request):
        """#下载消息查阅分析(平台管理后台)
        @id:"id"
        @result:"模板id"
        """
        try:
            import urllib
            xlsdata = ctl.download_notice_analyse(request)
            filename = u"统计结果.xls"
            return cv.stream_file(xlsdata,"application/vnd.ms-excel",filename)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class NoticeView(cv.AdminView):
    def get(self, request):
        """#模板详情(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["cid"] = request.user.id
            rst = ctl.get_detail_info(self,**vals)
            #rst["widget"] = json.loads(rst["widget"]) if rst else []
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def post(self,request):
        """#模板账号(平台管理后台)
        @name:"模板名称"
        @widget:"模板字段/组件"
        """
        qdata = request.json
        need_params = ["name","receiver_id","content"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["fileurl","filename"])
            vals = ccf.get_need_params(*need_params,**qdata)
            vals["cid"] = request.user.id
            vals["cname"] = request.user.name
            rst = ctl.add_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def put(self,request):
        """#修改模板(平台管理后台)
        @id:"1"
        @name:"模板名称"
        @widget:"模板字段/组件"
        """
        qdata = request.json
        need_params = ["id","name","receiver_id","content"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            need_params.extend(["fileurl","filename"])
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.update_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)

    def delete(self,request):
        """#删除账号(平台管理后台)
        @id:"1",多个逗号分隔
        """
        qdata = request.json
        need_params = ["id"]
        mse = ccf.check_params(*need_params,**qdata)
        if mse:
            raise ce.TipException(mse)
        try:
            vals = ccf.get_need_params(*need_params,**qdata)
            rst = ctl.delete_model(self,**vals)
            return cv.to_suc(rst)
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class NoticeListView(cv.AdminView):
    def get(self, request):
        """#内部消息列表(管理后台)
        @name:账号或管理员姓名
        @page:1
        @page_size:20
        """
        try:
            qdata = request.json
            qdata["cid"] = request.user.id
            total,rst = ctl.get_list_info(self,**qdata)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)


class MessageNoticeAnalyseView(cv.BaseView):
    def get(self, request):
        """#内部消息阅读统计(平台管理后台)
        @id:1
        """
        qdata = request.json
        try:
            need_params = ["id"]
            mse = ccf.check_params(*need_params,**qdata)
            if mse:
                raise ce.TipException(mse)
            need_params.append("type")
            need_params.append("name")
            vals = ccf.get_need_params(*need_params,**qdata)
            total,rst = ctl.get_notice_analyse(**vals)
            return cv.to_suc({"total":total,"list":rst})
        except Exception as e:
            cv.tracefail()
            return cv.to_fail(e)