clear code

src/bzyifeng/control_contacts.py

@@ -1,82 +0,0 @@
-# -*-coding:utf-8-*-
-import datetime
-
-import common.error_info as ce
-import common.models as cm
-import common.common_functions as ccf
-import utils.constant as const
-
-
-def add_contacts(request):
-    """
-    """
-    uid = request.user.id
-    kwargs = request.json
-    need_params = ["name","phone","email"]
-    mse = ccf.check_params(*need_params,**kwargs)
-    if mse:
-        raise ce.TipException(mse)
-    need_params.append("remark")
-    cvals = ccf.get_need_params(*need_params,**kwargs)
-    cvals.update({"user_id":uid})
-    cm.Contacts.objects.create(**cvals)
-
-    
-def update_contacts(request):
-    """
-    """
-    uid = request.user.id
-    kwargs = request.json
-    need_params = ["id"]
-    mse = ccf.check_params(*need_params,**kwargs)
-    if mse:
-        raise ce.TipException(mse)
-    id = kwargs.get("id")
-    uvals = {}
-    if "name" in kwargs:
-        uvals.update({"name":kwargs.get("name")})
-    if "email" in kwargs:
-        uvals.update({"email":kwargs.get("email")})
-    if "phone" in kwargs:
-        uvals.update({"phone":kwargs.get("phone")})
-    if "remark" in kwargs:
-        uvals.update({"remark":kwargs.get("remark")})
-    cm.Contacts.objects.filter(id=id).update(**uvals)
-
-
-def delete_contacts(request):
-    """删除批量用,隔开
-    """
-    kwargs = request.json
-    need_params = ["id"]
-    mse = ccf.check_params(*need_params,**kwargs)
-    if mse:
-        raise ce.TipException(mse)
-    id = kwargs.get("id")
-    ids = str(id).split(",")
-    cm.Contacts.objects.filter(id__in=ids).delete()
-
-
-def get_contacts_info(*ids):
-    """获取联系人详情
-    """
-    if not ids:
-        raise ce.TipException(u"缺少参数id!")
-    if not cm.Contacts.objects.filter(id__in=ids).exists():
-        raise ce.TipException(u"资源不存在!")
-    qdata = cm.Contacts.objects.filter(id__in=ids).values()
-    return list(qdata)
-
-
-def get_contacts_list(request):
-    """
-    """
-    uid = request.user.id
-    filter_info = request.json
-    qset = cm.Contacts.objects.filter(user__id=uid)
-    if filter_info.get("name"):
-        qset = qset.filter(name__icontains=filter_info.get("name"))
-    qdata = list(qset.values())
-
-    return qset.count(),qdata
-

src/bzyifeng/control_notice.py

@@ -1,120 +0,0 @@
-# -*-coding:utf-8-*-
-import datetime
-
-import common.error_info as ce
-import common.models as cm
-import common.common_functions as ccf
-import common.common_control as ccc
-import utils.constant as const
-
-
-def add_sysnotice(request):
-    """
-    """
-    uid = request.user.id
-    uname = request.user.name
-    kwargs = request.json
-    need_params = ["title","content"]
-    mse = ccf.check_params(*need_params,**kwargs)
-    if mse:
-        raise ce.TipException(mse)
-    cvals = ccf.get_need_params(*need_params,**kwargs)
-    cvals.update({"cid":uid})
-    cvals.update({"cperson":uname})
-    cm.SysNotice.objects.create(**cvals)
-
-
-def update_sysnotice(id,**kwargs):
-    """
-    """
-    uvals = {}
-    org_viewer = cm.SysNotice.objects.filter(id=id).first().viewer
-    org_viewer = org_viewer if org_viewer else ""
-    org_viewer = org_viewer.split(",")
-    if "viewer" in kwargs:
-        viewer = kwargs.get("viewer")
-        org_viewer.append(str(viewer))
-        viewer = ",".join(list(set(org_viewer)))
-        uvals.update({"viewer":viewer})
-    cm.SysNotice.objects.filter(id=id).update(**uvals)
-
-    
-def delete_sysnotice(request):
-    """删除批量用,隔开
-    """
-    kwargs = request.json
-    need_params = ["id"]
-    mse = ccf.check_params(*need_params,**kwargs)
-    if mse:
-        raise ce.TipException(mse)
-    id = kwargs.get("id")
-    ids = str(id).split(",")
-    cm.SysNotice.objects.filter(id__in=ids).delete()
-
-
-def get_sysnotice_info(*ids):
-    """获取系统通知详情
-    """
-    if not ids:
-        raise ce.TipException(u"缺少参数id!")
-    if not cm.SysNotice.objects.filter(id__in=ids).exists():
-        raise ce.TipException(u"资源不存在!")
-    qdata = cm.SysNotice.objects.filter(id__in=ids).values()
-    return list(qdata)
-
-
-def get_sysnotice_list(request):
-    """
-    """
-    uid = request.user.id
-    filter_info = request.json
-    qset = cm.SysNotice.objects.filter(cid=uid)
-    if filter_info.get("title"):
-        qset = qset.filter(title=filter_info.get("title"))
-    # if filter_info.get("stime"):
-    #     qset = qset.filter(ctime__gte=filter_info.get("stime"))
-    # if filter_info.get("etime"):
-    #     qset = qset.filter(ctime__lte=filter_info.get("etime"))
-    if filter_info.get("ctime", ""):
-        import web_site.tools as wst
-        query = wst.datetime_filter("ctime", {}, filter_info["ctime"])
-        qset = qset.filter(**query)
-    if filter_info.get("new"):
-        vuid = str(uid)
-        qset = qset.exclude(viewer__contains=vuid)
-    qdata = list(qset.values())
-
-    return qset.count(),qdata
-
-
-def get_warning_notice_list(request):
-    filter_info = request.json
-    qset = cm.WarningNotice.objects.filter(is_suc=1)
-    if filter_info.get("warning_type"):
-        qset = qset.filter(warning_type=filter_info.get("warning_type"))
-    if filter_info.get("notice_type"):
-        qset = qset.filter(notice_type=filter_info.get("notice_type"))
-    # if filter_info.get("stime"):
-    #     qset = qset.filter(ctime__gte=filter_info.get("stime"))
-    # if filter_info.get("etime"):
-    #     qset = qset.filter(ctime__lte=filter_info.get("etime"))
-    if filter_info.get("ctime", ""):
-        import web_site.tools as wst
-        query = wst.datetime_filter("ctime", {}, filter_info["ctime"])
-        qset = qset.filter(**query)
-    count = qset.count()
-    page = filter_info.get("page")
-    page_size = filter_info.get("page_size")
-    if page and page_size:
-        count,qset = ccc.get_page_qset(qset,page,page_size)
-    qdata = list(qset.values())
-
-    return count,qdata
-
-
-def get_warning_notice(*ids):
-    """
-    """
-    qset = cm.WarningNotice.objects.filter(id__in=ids)
-    qdata = qset.values()
-    return qdata

src/bzyifeng/urls_backstage.py

@@ -1,15 +0,0 @@
-# coding=utf-8
-'''
-'''
-from django.conf.urls import url
-import views_contacts,views_notice
-
-urlpatterns = [
-    url(r'^contacts$', views_contacts.ContactsView.as_view()),
-    url(r'^contacts/list$', views_contacts.ContactsListView.as_view()),
-    url(r'^notice/sys$', views_notice.SysNoticeView.as_view()),
-    url(r'^notice/sys/list$', views_notice.SysNoticeListView.as_view()),
-    url(r'^notice/warning$', views_notice.WarningNoticeView.as_view()),
-    url(r'^notice/warning/list$', views_notice.WarningNoticeListView.as_view()),
-]
-

src/bzyifeng/views.py

@@ -78,10 +78,3 @@ class DocView(cv.BaseView):
         return cv.to_suc()
 
 
-class HookView(cv.BaseView):
-    def post(self,request):
-        """
-        """
-        cmdstr = "cd /mnt/gzyunweb/pc/gzyun_web & git pull origin master & cnpm run build"
-        os.system(cmdstr)
-        return cv.to_suc()

src/bzyifeng/views_contacts.py

@@ -1,84 +0,0 @@
-#-*-coding:utf-8-*-
-import json
-import uuid
-from django.contrib import auth
-from django.core.cache import cache
-from django.conf import settings
-
-from common import core_views as cv
-from common.models import UserInfo
-import common.common_functions as ccf
-import common.error_info as ce
-import wsm.control_contacts as cct
-
-
-class ContactsView(cv.AuthView):
-    def get(self, request):
-        """
-        #获取联系人详情
-        @id:1,联系人id
-        """
-        try:
-            kwargs = request.json
-            need_params = ["id"]
-            mse = ccf.check_params(*need_params,**kwargs)
-            if mse:
-                raise ce.TipException(mse)
-            ids = str(kwargs.get("id")).split(",")
-            res = cct.get_contacts_info(*ids)
-            res = res[0] if res else {}
-            return cv.to_suc(res)
-        except Exception as e:
-            return cv.to_fail(e)
-
-
-    def post(self,request):
-        """
-        #新增联系人
-        @name:"名称"
-        @email:"496498291@qq.com"
-        @phone:"496498291@qq.com"
-        @remark:"备注"
-        """
-        try:
-            cct.add_contacts(request)
-            return cv.to_suc()
-        except Exception as e:
-            return cv.to_fail(e)
-
-
-    def put(self,request):
-        """
-        #修改联系人
-        @id:1,其他参数同新增新增
-        """
-        try:
-            cct.update_contacts(request)
-            return cv.to_suc()
-        except Exception as e:
-            return cv.to_fail(e)
-
-    def delete(self,request):
-        """
-        #删除联系人
-        @id:1
-        """
-        try:
-            cct.delete_contacts(request)
-            return cv.to_suc()
-        except Exception as e:
-            return cv.to_fail(e)
-
-
-
-class ContactsListView(cv.AuthView):
-    def get(self, request):
-        """
-        #获取联系人列表
-        @name:"名称",联系人名称筛选
-        """
-        try:
-            count,res = cct.get_contacts_list(request)
-            return cv.to_suc({"total":count,"list":res})
-        except Exception as e:
-            return cv.to_fail(e)

src/bzyifeng/views_notice.py

@@ -1,110 +0,0 @@
-#-*-coding:utf-8-*-
-import json
-import uuid
-from django.contrib import auth
-from django.core.cache import cache
-from django.conf import settings
-
-from common import core_views as cv
-from common.models import UserInfo
-import common.common_functions as ccf
-import common.error_info as ce
-import wsm.control_notice as cnt
-
-
-class SysNoticeView(cv.AuthView):
-    def get(self, request):
-        """
-        #获取系统通知详情
-        @id:1,id
-        """
-        try:
-            kwargs = request.json
-            need_params = ["id"]
-            mse = ccf.check_params(*need_params,**kwargs)
-            if mse:
-                raise ce.TipException(mse)
-            ids = str(kwargs.get("id")).split(",")
-            res = cnt.get_sysnotice_info(*ids)
-            res = res[0] if res else {}
-            for id in ids:
-                cnt.update_sysnotice(id,**{"viewer":request.user.id})
-            return cv.to_suc(res)
-        except Exception as e:
-            return cv.to_fail(e)
-
-
-    def post(self,request):
-        """
-        #新增系统公告
-        @title:"标题"
-        @content:"公告内容"
-        """
-        try:
-            cnt.add_sysnotice(request)
-            return cv.to_suc()
-        except Exception as e:
-            return cv.to_fail(e)
-
-
-    def delete(self,request):
-        """
-        #删除系统公告
-        @id:1
-        """
-        try:
-            cnt.delete_sysnotice(request)
-            return cv.to_suc()
-        except Exception as e:
-            return cv.to_fail(e)
-
-
-
-class SysNoticeListView(cv.AuthView):
-    def get(self, request):
-        """
-        #获取系统公告列表
-        @title:"名称",联系人名称筛选
-        @ctime:"2020-03-04 00:00:00,2020-03-05 00:00:00" 时间范围
-        """
-        try:
-            count,res = cnt.get_sysnotice_list(request)
-            return cv.to_suc({"total":count,"list":res})
-        except Exception as e:
-            return cv.to_fail(e)
-
-
-class WarningNoticeView(cv.AuthView):
-    def get(self, request):
-        """
-        #获取告警通知记录详情
-        @id:1,告警记录id
-        """
-        kwargs = request.json
-        need_params = ["id"]
-        mse = ccf.check_params(*need_params,**kwargs)
-        if mse:
-            raise ce.TipException(mse)
-        try:
-            id = kwargs.get("id")
-            wnotice = cnt.get_warning_notice(*[id])
-            wnotice = wnotice[0] if wnotice else {}
-            return cv.to_suc(wnotice)
-        except Exception as e:
-            return cv.to_fail(e)
-
-
-class WarningNoticeListView(cv.AuthView):
-    def get(self, request):
-        """
-        #获取告警通知记录列表
-        @warning_type:"bug",告警类型
-        @notice_type:"email",告警方式(email,msg)
-        @ctime:"2020-03-04 00:00:00,2020-03-05 00:00:00" 时间范围
-        """
-        try:
-            count,res = cnt.get_warning_notice_list(request)
-            return cv.to_suc({"total":count,"list":res})
-        except Exception as e:
-            return cv.to_fail(e)
-