经验手册涉及数据库

.idea/dictionaries/Administrator.xml

@@ -7,6 +7,7 @@
       <w>authprotocol</w>
       <w>authtype</w>
       <w>businessid</w>
+      <w>businessids</w>
       <w>contextname</w>
       <w>departmentid</w>
       <w>dingding</w>
@@ -60,6 +61,7 @@
       <w>privatekey</w>
       <w>privpassphrase</w>
       <w>privprotocol</w>
+      <w>problemid</w>
       <w>proxyids</w>
       <w>publickey</w>
       <w>pytest</w>

WorkApi/APP/Experience/experience_create.py

@@ -26,40 +26,40 @@ class ExperienceCreate(object):
         self._data = {}
         self.response = ""
 
-        self.local_json = {}
+        self.token = None
 
         self.title = None
         self.content = None
-        self.businessid = None
-        self.businessName = None
-        self.hostType = None
-        self.hostid = None
-        self.versions = None
-        self.monitorid = None
-        self.monitorName = None
+        self.businessids = None
+        self.hostTypes = None
+        self.hostids = None
+        self.itemids = None
+        self.manageIpList = None
         self.alarmRuleids = None
         self.description = None
         self.tagNameList = None
+        self.problemidList = None
+        self.hostTypeTree = None
 
         self.api = UtilsRequest()
 
     def get_response(self):
+        base = ApiBase()
+        base.dict_add_key(_key="token", value=self.token)
+        self._headers = base._json
 
         base = ApiBase()
         base.dict_add_key(_key="title", value=self.title)
         base.dict_add_key(_key="content", value=self.content)
-        base.dict_add_key(_key="businessid", value=self.businessid)
-        base.dict_add_key(_key="businessName", value=self.businessName)
-        base.dict_add_key(_key="hostType", value=self.hostType)
-        base.dict_add_key(_key="hostid", value=self.hostid)
-        base.dict_add_key(_key="versions", value=self.versions)
-        base.dict_add_key(_key="monitorid", value=self.monitorid)
-        base.dict_add_key(_key="monitorName", value=self.monitorName)
+        base.dict_add_key(_key="businessids", value=self.businessids)
+        base.dict_add_key(_key="hostTypes", value=self.hostTypes)
+        base.dict_add_key(_key="hostids", value=self.hostids)
+        base.dict_add_key(_key="itemids", value=self.itemids)
+        base.dict_add_key(_key="manageIpList", value=self.manageIpList)
         base.dict_add_key(_key="alarmRuleids", value=self.alarmRuleids)
         base.dict_add_key(_key="description", value=self.description)
         base.dict_add_key(_key="tagNameList", value=self.tagNameList)
-
-        self.local_json = base._json
-
-        self._json = self.local_json
-        self.response = self.api.post(url=self._url, json=self._json)
+        base.dict_add_key(_key="problemidList", value=self.problemidList)
+        base.dict_add_key(_key="hostTypeTree", value=self.hostTypeTree)
+        self._json = base._json
+        self.response = self.api.post(url=self._url, headers=self._headers, json=self._json)

WorkData/Argus/experience.py

 # -*- coding: utf_8 -*-
 # 表名: experience
 # 作者: 陈磊
-# 时间: 2019-11-18
+# 时间: 2019-12-03
 
 
 from sqlalchemy.ext.declarative import declarative_base
@@ -26,15 +26,14 @@ class Experience(Base):
     experienceid = Column(BigInteger, primary_key=True)
     title = Column(VARCHAR(255), comment="标题")
     content = Column(TEXT, comment="内容")
-    businessid = Column(VARCHAR(32), comment="业务Id")
-    business_name = Column(VARCHAR(255), comment="业务名称")
-    host_type = Column(Integer, comment="资产类型（和下面hostid对应的资产不一定对应）")
-    hostid = Column(BigInteger, comment="资产Id")
     versions = Column(Integer, comment="版本号")
-    monitorid = Column(BigInteger, comment="监控Id")
-    monitor_name = Column(VARCHAR(255), comment="监控名称")
-    description = Column(VARCHAR(255), comment="告警描述")
-    eventid = Column(BigInteger, comment="对应problem")
+    remark = Column(VARCHAR(255), comment="备注")
+    create_time = Column(BigInteger, comment="创建时间")
+    create_by = Column(BigInteger, comment="创建人")
+    update_time = Column(BigInteger, comment="更新时间")
+    update_by = Column(BigInteger, comment="更新人")
+    host_type_tree = Column(VARCHAR(255), comment="资源类型树状图")
+    businessids_tree = Column(VARCHAR(255), comment="经验手册树状图")
 
 
 class DataExperience(object):
@@ -44,12 +43,12 @@ class DataExperience(object):
 
         self.table = Experience
 
-    def select_all_from_allKeys(self, session, experienceid=None, title=None, description=None):
+    def select_all_from_allKeys(self, session, experienceid=None, title=None, content=None):
         """
         :param session: 指针
         :param experienceid:
         :param title:
-        :param description:
+        :param content:
         :return: 查询结果
         """
         self.log.debug("查询数据库:")
@@ -57,7 +56,7 @@ class DataExperience(object):
             base = UtilsDataBase()
             base.add_param(_key="experienceid", value=experienceid)
             base.add_param(_key="title", value=title)
-            base.add_param(_key="description", value=description)
+            base.add_param(_key="content", value=content)
             sql_rep = session.query(self.table).filter_by(**base.param).all()
             self.log.debug(sql_rep)
             session.close()
@@ -88,48 +87,3 @@ class DataExperience(object):
             self.log.error(error)
             session.close()
             return error
-
-    def insert_one(self, session, title=None, content=None, businessid=None, business_name=None, host_type=None,
-                   hostid=None, versions=None, monitorid=None, monitor_name=None, description=None, eventid=None):
-        """
-        :param session: 指针
-        :param title:
-        :param content:
-        :param businessid:
-        :param business_name:
-        :param host_type:
-        :param hostid:
-        :param versions:
-        :param monitorid:
-        :param monitor_name:
-        :param description:
-        :param eventid:
-        :return:
-        """
-        self.log.debug("新增表数据:")
-        try:
-            base = UtilsDataBase()
-            base.add_param(_key="title", value=title)
-            base.add_param(_key="content", value=content)
-            base.add_param(_key="businessid", value=businessid)
-            base.add_param(_key="business_name", value=business_name)
-            base.add_param(_key="host_type", value=host_type)
-            base.add_param(_key="hostid", value=hostid)
-            base.add_param(_key="versions", value=versions)
-            base.add_param(_key="monitorid", value=monitorid)
-            base.add_param(_key="monitor_name", value=monitor_name)
-            base.add_param(_key="description", value=description)
-            base.add_param(_key="eventid", value=eventid)
-            sql_rep = self.table(**base.param)
-
-            session.add(sql_rep)
-            session.commit()
-            hostid = sql_rep.hostid
-            self.log.debug("新增的hostid:%s" % hostid)
-            session.close()
-            return hostid
-        except UtilsDataBase().errors as error:
-            self.log.error("异常:")
-            self.log.error(error)
-            session.close()
-            return error

WorkData/Argus/experience_alarm_rule.py

+# -*- coding: utf_8 -*-
+# 表名: experience_alarm_rule
+# 作者: 陈磊
+# 时间: 2019-12-03
+
+
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy import Column, Integer, VARCHAR, SMALLINT, DATETIME, DECIMAL, BigInteger, FLOAT, NUMERIC, TEXT
+from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
+from sqlalchemy import or_
+
+from WorkUtils.UtilsLog import UtilsLog
+from WorkUtils.UtilsDataBase import UtilsDataBase
+
+import time
+
+Base = declarative_base()
+
+
+class ExperienceAlarmRule(Base):
+    """
+    经验手册与规则关系
+    """
+    __tablename__ = "experience_alarm_rule"
+
+    id = Column(BigInteger, primary_key=True)
+    experienceid = Column(BigInteger, comment="经验手册ID")
+    alarm_ruleid = Column(BigInteger, comment="规则ID")
+
+
+class DataExperienceAlarmRule(object):
+    def __init__(self):
+        self.log = UtilsLog()
+        self.log.info(self.__class__)
+
+        self.table = ExperienceAlarmRule
+
+    def select_all_from_allKeys(self, session, experienceid=None):
+        """
+        :param session: 指针
+        :param experienceid:
+        :return: 查询结果
+        """
+        self.log.debug("查询数据库:")
+        try:
+            base = UtilsDataBase()
+            base.add_param(_key="experienceid", value=experienceid)
+            sql_rep = session.query(self.table).filter_by(**base.param).all()
+            self.log.debug(sql_rep)
+            session.close()
+            return sql_rep
+        except UtilsDataBase().errors as error:
+            self.log.error("异常:")
+            self.log.error(error)
+            session.close()
+            return error

WorkData/Argus/experience_businesses.py

+# -*- coding: utf_8 -*-
+# 表名: experience_businesses
+# 作者: 陈磊
+# 时间: 2019-12-03
+
+
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy import Column, Integer, VARCHAR, SMALLINT, DATETIME, DECIMAL, BigInteger, FLOAT, NUMERIC, TEXT
+from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
+from sqlalchemy import or_
+
+from WorkUtils.UtilsLog import UtilsLog
+from WorkUtils.UtilsDataBase import UtilsDataBase
+
+import time
+
+Base = declarative_base()
+
+
+class ExperienceBusinesses(Base):
+    """
+    经验手册与业务关系
+    """
+    __tablename__ = "experience_businesses"
+
+    id = Column(BigInteger, primary_key=True)
+    experienceid = Column(BigInteger, comment="经验手册ID")
+    businessid = Column(BigInteger, comment="业务ID")
+
+
+class DataExperienceBusinesses(object):
+    def __init__(self):
+        self.log = UtilsLog()
+        self.log.info(self.__class__)
+
+        self.table = ExperienceBusinesses
+
+    def select_all_from_allKeys(self, session, experienceid=None):
+        """
+        :param session: 指针
+        :param experienceid:
+        :return: 查询结果
+        """
+        self.log.debug("查询数据库:")
+        try:
+            base = UtilsDataBase()
+            base.add_param(_key="experienceid", value=experienceid)
+            sql_rep = session.query(self.table).filter_by(**base.param).all()
+            self.log.debug(sql_rep)
+            session.close()
+            return sql_rep
+        except UtilsDataBase().errors as error:
+            self.log.error("异常:")
+            self.log.error(error)
+            session.close()
+            return error

WorkData/Argus/experience_hosts.py

+# -*- coding: utf_8 -*-
+# 表名: experience_hosts
+# 作者: 陈磊
+# 时间: 2019-12-03
+
+
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy import Column, Integer, VARCHAR, SMALLINT, DATETIME, DECIMAL, BigInteger, FLOAT, NUMERIC, TEXT
+from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
+from sqlalchemy import or_
+
+from WorkUtils.UtilsLog import UtilsLog
+from WorkUtils.UtilsDataBase import UtilsDataBase
+
+import time
+
+Base = declarative_base()
+
+
+class ExperienceHosts(Base):
+    """
+    经验手册与资产关系
+    """
+    __tablename__ = "experience_hosts"
+
+    id = Column(BigInteger, primary_key=True)
+    experienceid = Column(BigInteger, comment="经验手册ID")
+    hostid = Column(BigInteger, comment="资产ID")
+
+
+class DataExperienceHosts(object):
+    def __init__(self):
+        self.log = UtilsLog()
+        self.log.info(self.__class__)
+
+        self.table = ExperienceHosts
+
+    def select_all_from_allKeys(self, session, experienceid=None):
+        """
+        :param session: 指针
+        :param experienceid:
+        :return: 查询结果
+        """
+        self.log.debug("查询数据库:")
+        try:
+            base = UtilsDataBase()
+            base.add_param(_key="experienceid", value=experienceid)
+            sql_rep = session.query(self.table).filter_by(**base.param).all()
+            self.log.debug(sql_rep)
+            session.close()
+            return sql_rep
+        except UtilsDataBase().errors as error:
+            self.log.error("异常:")
+            self.log.error(error)
+            session.close()
+            return error

WorkData/Argus/experience_hosts_type.py

+# -*- coding: utf_8 -*-
+# 表名: experience_hosts_type
+# 作者: 陈磊
+# 时间: 2019-12-03
+
+
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy import Column, Integer, VARCHAR, SMALLINT, DATETIME, DECIMAL, BigInteger, FLOAT, NUMERIC, TEXT
+from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
+from sqlalchemy import or_
+
+from WorkUtils.UtilsLog import UtilsLog
+from WorkUtils.UtilsDataBase import UtilsDataBase
+
+import time
+
+Base = declarative_base()
+
+
+class ExperienceHostsType(Base):
+    """
+    经验手册与资产类型关系
+    """
+    __tablename__ = "experience_hosts_type"
+
+    id = Column(BigInteger, primary_key=True)
+    experienceid = Column(BigInteger, comment="经验手册ID")
+    hosts_type = Column(BigInteger, comment="资产类型ID")
+
+
+class DataExperienceHostsType(object):
+    def __init__(self):
+        self.log = UtilsLog()
+        self.log.info(self.__class__)
+
+        self.table = ExperienceHostsType
+
+    def select_all_from_allKeys(self, session, experienceid=None):
+        """
+        :param session: 指针
+        :param experienceid:
+        :return: 查询结果
+        """
+        self.log.debug("查询数据库:")
+        try:
+            base = UtilsDataBase()
+            base.add_param(_key="experienceid", value=experienceid)
+            sql_rep = session.query(self.table).filter_by(**base.param).all()
+            self.log.debug(sql_rep)
+            session.close()
+            return sql_rep
+        except UtilsDataBase().errors as error:
+            self.log.error("异常:")
+            self.log.error(error)
+            session.close()
+            return error

WorkData/Argus/experience_ips.py

+# -*- coding: utf_8 -*-
+# 表名: experience_ips
+# 作者: 陈磊
+# 时间: 2019-12-03
+
+
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy import Column, Integer, VARCHAR, SMALLINT, DATETIME, DECIMAL, BigInteger, FLOAT, NUMERIC, TEXT
+from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
+from sqlalchemy import or_
+
+from WorkUtils.UtilsLog import UtilsLog
+from WorkUtils.UtilsDataBase import UtilsDataBase
+
+import time
+
+Base = declarative_base()
+
+
+class ExperienceIps(Base):
+    """
+    经验手册与资产关系
+    """
+    __tablename__ = "experience_ips"
+
+    id = Column(BigInteger, primary_key=True)
+    experienceid = Column(BigInteger, comment="经验手册ID")
+    hostid = Column(BigInteger, comment="资产ID")
+
+
+class DataExperienceIps(object):
+    def __init__(self):
+        self.log = UtilsLog()
+        self.log.info(self.__class__)
+
+        self.table = ExperienceIps
+
+    def select_all_from_allKeys(self, session, experienceid=None):
+        """
+        :param session: 指针
+        :param experienceid:
+        :return: 查询结果
+        """
+        self.log.debug("查询数据库:")
+        try:
+            base = UtilsDataBase()
+            base.add_param(_key="experienceid", value=experienceid)
+            sql_rep = session.query(self.table).filter_by(**base.param).all()
+            self.log.debug(sql_rep)
+            session.close()
+            return sql_rep
+        except UtilsDataBase().errors as error:
+            self.log.error("异常:")
+            self.log.error(error)
+            session.close()
+            return error

WorkData/Argus/experience_items.py

+# -*- coding: utf_8 -*-
+# 表名: experience_items
+# 作者: 陈磊
+# 时间: 2019-12-03
+
+
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy import Column, Integer, VARCHAR, SMALLINT, DATETIME, DECIMAL, BigInteger, FLOAT, NUMERIC, TEXT
+from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
+from sqlalchemy import or_
+
+from WorkUtils.UtilsLog import UtilsLog
+from WorkUtils.UtilsDataBase import UtilsDataBase
+
+import time
+
+Base = declarative_base()
+
+
+class ExperienceItems(Base):
+    """
+    经验手册与监控项关系
+    """
+    __tablename__ = "experience_items"
+
+    id = Column(BigInteger, primary_key=True)
+    experienceid = Column(BigInteger, comment="经验手册ID")
+    itemid = Column(BigInteger, comment="监控项ID")
+
+
+class DataExperienceItems(object):
+    def __init__(self):
+        self.log = UtilsLog()
+        self.log.info(self.__class__)
+
+        self.table = ExperienceItems
+
+    def select_all_from_allKeys(self, session, experienceid=None):
+        """
+        :param session: 指针
+        :param experienceid:
+        :return: 查询结果
+        """
+        self.log.debug("查询数据库:")
+        try:
+            base = UtilsDataBase()
+            base.add_param(_key="experienceid", value=experienceid)
+            sql_rep = session.query(self.table).filter_by(**base.param).all()
+            self.log.debug(sql_rep)
+            session.close()
+            return sql_rep
+        except UtilsDataBase().errors as error:
+            self.log.error("异常:")
+            self.log.error(error)
+            session.close()
+            return error

WorkData/Argus/experience_problem.py

+# -*- coding: utf_8 -*-
+# 表名: experience_problem
+# 作者: 陈磊
+# 时间: 2019-12-03
+
+
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy import Column, Integer, VARCHAR, SMALLINT, DATETIME, DECIMAL, BigInteger, FLOAT, NUMERIC, TEXT
+from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
+from sqlalchemy import or_
+
+from WorkUtils.UtilsLog import UtilsLog
+from WorkUtils.UtilsDataBase import UtilsDataBase
+
+import time
+
+Base = declarative_base()
+
+
+class ExperienceProblem(Base):
+    """
+    经验手册与告警关系
+    """
+    __tablename__ = "experience_problem"
+
+    id = Column(BigInteger, primary_key=True)
+    experienceid = Column(BigInteger, comment="经验手册ID")
+    problemid = Column(BigInteger, comment="告警id （eventids）")
+
+
+class DataExperienceProblem(object):
+    def __init__(self):
+        self.log = UtilsLog()
+        self.log.info(self.__class__)
+
+        self.table = ExperienceProblem
+
+    def select_all_from_allKeys(self, session, experienceid=None):
+        """
+        :param session: 指针
+        :param experienceid:
+        :return: 查询结果
+        """
+        self.log.debug("查询数据库:")
+        try:
+            base = UtilsDataBase()
+            base.add_param(_key="experienceid", value=experienceid)
+            sql_rep = session.query(self.table).filter_by(**base.param).all()
+            self.log.debug(sql_rep)
+            session.close()
+            return sql_rep
+        except UtilsDataBase().errors as error:
+            self.log.error("异常:")
+            self.log.error(error)
+            session.close()
+            return error