diff --git a/frontend/src/components/apiList.vue b/frontend/src/components/apiList.vue
index c760b61d..c6005039 100644
--- a/frontend/src/components/apiList.vue
+++ b/frontend/src/components/apiList.vue
@@ -1,7 +1,15 @@
 <template>
   <div id="tab" class="box box-solid">
-    <div class="box-body" style="max-height:calc(100vh - 100px); overflow:auto">
-      <i-table stripe :columns="columns" :data="showedAPIData" ></i-table>
+    <div class="box-body" style="max-height:calc(100vh - 100px) overflow:auto">
+      <i-table stripe :columns="columns" :data="showedAPIData">
+        <template #category="{ row }">
+          <span v-if="row.category.length !== 0">
+            <span v-for="(item, index) in row.category" :key="index">
+              <Tag v-if="item.status == 1" color="green">{{item.label}}</Tag>
+            </span>
+          </span>
+        </template>
+      </i-table>
       <Modal
         v-model="isApiDetailModalShow"
         title="Flow Detail"
@@ -38,19 +46,16 @@ export default {
           title: 'Priority',
           key: 'priority',
           sortable: true,
-          width: 110,
         },
         {
           title: 'API',
           key: 'url',
           sortable: true,
-          width: 380,
         },
         {
           title: 'Description',
           key: 'desc',
           sortable: true,
-          width: 200,
         },
         {
           title: 'Count',
@@ -97,6 +102,12 @@ export default {
             return row.status === null
           },
         },
+        {
+          title: 'Category',
+          key: 'category',
+          slot: 'category',
+          sortable: true,
+        },
         {
           title: 'Detail',
           key: 'id',
diff --git a/frontend/src/store/index.js b/frontend/src/store/index.js
index 12763c62..ba6b230d 100644
--- a/frontend/src/store/index.js
+++ b/frontend/src/store/index.js
@@ -39,7 +39,7 @@ export default new Vuex.Store({
       apis
         .getCoverage()
         .then((response) => {
-          context.commit('setCoverageData', response.data)
+          context.commit('setCoverageData', response.data.coverage)
         })
         .catch(() => {
           this.$Notice.open({ title: 'loadCoverageData error!' })
diff --git a/lyrebird_api_coverage/api.py b/lyrebird_api_coverage/api.py
index 0082f36b..8a4976d9 100644
--- a/lyrebird_api_coverage/api.py
+++ b/lyrebird_api_coverage/api.py
@@ -17,12 +17,12 @@ def generate(data):
 # 获取内存里保存的测试结果API
 # /getTest
 def get_test_data():
-    return Response(stream_with_context(generate({'test_data': app_context.merge_list})), content_type='application/json')
+    return context.make_ok_response(test_data=app_context.merge_list)
 
 # 获取内存里保存的测试覆盖率信息
 # /getCoverage
 def get_coverage():
-    return Response(stream_with_context(generate(app_context.coverage)), content_type='application/json')
+    return context.make_ok_response(coverage = app_context.coverage)
 
 # 保存测试数据在本地
 #  /saveResult
diff --git a/lyrebird_api_coverage/client/context.py b/lyrebird_api_coverage/client/context.py
index fca1b489..45fd45fd 100644
--- a/lyrebird_api_coverage/client/context.py
+++ b/lyrebird_api_coverage/client/context.py
@@ -37,6 +37,10 @@ def __init__(self):
         self.covtime = 0
         # 时间间隔，每隔指定时间触发1次socket io消息，防止刷新频繁
         self.SOCKET_PUSH_INTERVAL = 1
+        # 是否使用接口请求实时base数据
+        self.is_api_base_data = False
+        # category信息
+        self.category = ''
 
 
 # 单例模式
diff --git a/lyrebird_api_coverage/client/load_base.py b/lyrebird_api_coverage/client/load_base.py
index c7e29ac1..0fe43e8e 100644
--- a/lyrebird_api_coverage/client/load_base.py
+++ b/lyrebird_api_coverage/client/load_base.py
@@ -2,8 +2,11 @@
 import hashlib
 import json
 import lyrebird
+from pathlib import Path
 from lyrebird.log import get_logger
 import os
+import imp
+import traceback
 
 from lyrebird_api_coverage.client.context import app_context
 
@@ -11,6 +14,8 @@
 DEFAULT_BASE = os.path.join(PLUGINS_CONF_DIR, 'base.json')
 CURRENT_DIR = os.path.dirname(__file__)
 
+logger = get_logger()
+
 
 def get_file_sha1(path):
     with open(path, 'rb') as f:
@@ -25,12 +30,31 @@ def auto_load_base():
     # 读取指定base文件，写入到base.json
     if lyrebird_conf.get('hunter.base'):
         base_path = lyrebird_conf.get('hunter.base')
-        base = codecs.open(base_path, 'r', 'utf-8').read()
-        f = codecs.open(DEFAULT_BASE, 'w', 'utf-8')
-        f.write(base)
-        f.close()
-        app_context.base_sha1 = get_file_sha1(DEFAULT_BASE)
-        return json.loads(base)
+        base_path_obj = Path(base_path)
+        if not base_path_obj.is_file():
+            return
+        # 判断是否需要实时获取接口数据
+        if base_path_obj.suffix == '.py':
+            try:
+                init_base_file = imp.load_source('load_base', str(base_path_obj))
+            except Exception:
+                logger.warning(f'Failed to load the file, {traceback.format_exc()}')
+                return
+            if not hasattr(init_base_file, 'load_api_base'):
+                logger.warning(f'load_api_base does not exist')
+                return
+            if not callable(init_base_file.load_api_base):
+                logger.warning(f'The method does not exist')
+                return
+            app_context.is_api_base_data = True
+            return init_base_file.load_api_base()
+        else:
+            base = codecs.open(base_path, 'r', 'utf-8').read()
+            f = codecs.open(DEFAULT_BASE, 'w', 'utf-8')
+            f.write(base)
+            f.close()
+            app_context.base_sha1 = get_file_sha1(DEFAULT_BASE)
+            return json.loads(base)
     # 通过本地默认base文件获取base
     elif not os.path.exists(DEFAULT_BASE):
         copy_file(DEFAULT_BASE)
diff --git a/lyrebird_api_coverage/client/merge_algorithm.py b/lyrebird_api_coverage/client/merge_algorithm.py
index 09a3b128..df16f968 100644
--- a/lyrebird_api_coverage/client/merge_algorithm.py
+++ b/lyrebird_api_coverage/client/merge_algorithm.py
@@ -35,33 +35,36 @@ def init_basedata_handler(self, dic):
         #     url_dic = {'url': k, 'desc': v.get('desc'), 'priority': v.get('priority'), 'count': 0, 'status': 0,
         #                'org': []}
         #     app_context.merge_list.append(url_dic)
-        dict2 = {'count': 0, 'status': 0, 'id': ''}
-        for item in dic.get('api_list'):
-            # 处理带参数的情况
-            if '?' in item['url']:
-                path = item['url'].split('?')[0].lower()
-                params = item['url'].split('?')[1].split('&')
-                param_dic = {}
-                for i in params:
-                    key = i.split('=')[0]
-                    val = i.split('=')[1]
-                    param_dic[key] = val
-
-                if app_context.path_param_dic.get(path):
-                    app_context.path_param_dic[path].append({'url': item['url'], 'params': param_dic,
-                                                             'url_base': format_url.format_api_source(
-                                                                 item.get('url')).lower()})
-                else:
-                    app_context.path_param_dic[path] = [{'url': item['url'], 'params': param_dic,
-                                                         'url_base': format_url.format_api_source(
-                                                             item.get('url')).lower()}]
-
-            # format base源 同时变成大小写归一化，变小写
-            item['url'] = format_url.format_api_source(item.get('url')).lower()
-            item.update(dict2)
-            app_context.merge_list.append(item)
-
-    def merge_handler_new(self, user_url, path_id):
+        if app_context.is_api_base_data:
+            # 如果接口获取base数据，同步merge_list内容
+            app_context.merge_list = dic.get('api_list')
+        else:
+            dict2 = {'count': 0, 'status': 0, 'id': ''}
+            for item in dic.get('api_list'):
+                # 处理带参数的情况
+                if '?' in item['url']:
+                    path = item['url'].split('?')[0].lower()
+                    params = item['url'].split('?')[1].split('&')
+                    param_dic = {}
+                    for i in params:
+                        key = i.split('=')[0]
+                        val = i.split('=')[1]
+                        param_dic[key] = val
+
+                    if app_context.path_param_dic.get(path):
+                        app_context.path_param_dic[path].append({'url': item['url'], 'params': param_dic,
+                                                                'url_base': format_url.format_api_source(
+                                                                    item.get('url')).lower()})
+                    else:
+                        app_context.path_param_dic[path] = [{'url': item['url'], 'params': param_dic,
+                                                            'url_base': format_url.format_api_source(
+                                                                item.get('url')).lower()}]
+                # format base源 同时变成大小写归一化，变小写
+                item['url'] = format_url.format_api_source(item.get('url')).lower()
+                item.update(dict2)
+                app_context.merge_list.append(item)
+
+    def merge_handler_new(self, user_url, path_id, category):
         """
         status=0 base中包含未覆盖，status=1 base中包含已覆盖，status=2 base中不包含且覆盖到的;
         path_id表示URL的handler_context的唯一标识，查看详情用
@@ -75,17 +78,45 @@ def merge_handler_new(self, user_url, path_id):
             specific_dic = specific_filter_list[0]
             # 移除掉对应的数据为插入index0的位置做前置处理
             app_context.merge_list.remove(specific_dic)
-            # 做业务处理
-            if specific_dic['status'] == 0:
-                specific_dic['status'] = 1
-                # 把首次覆盖到的API,放入user_list里面
-                app_context.user_list.append(user_url)
+            # 根据数据源,进行业务处理
+            if app_context.is_api_base_data:
+                category_dic = specific_dic.get('category')
+                for p in category_dic:
+                    if category == p['name'] and p['status'] == 0:
+                        p['status'] = 1
+                        p['count'] += 1
+                        p['id'] = path_id
+                if specific_dic['status'] == 0:
+                    specific_dic['status'] = 1
+                    # 把首次覆盖到的API,放入user_list里面
+                    app_context.user_list.append(user_url)
+            else:
+                # 非接口获取base数据
+                if specific_dic['status'] == 0:
+                    specific_dic['status'] = 1
+                    # 把首次覆盖到的API,放入user_list里面
+                    app_context.user_list.append(user_url)
             # count +1
             specific_dic['count'] += 1  # 插入原始url  # specific_dic['org'].append(org_url)
             specific_dic['id'] = path_id
         else:
-            # specific_dic = {'url': user_url, 'desc': '', 'priority': '', 'count': 1, 'status': 2, 'org': [org_url]}
-            specific_dic = {'url': user_url, 'desc': '', 'priority': None, 'count': 1, 'status': 2, 'id': path_id}
+            if app_context.is_api_base_data:
+                specific_dic = {
+                    'url': user_url,
+                    'desc': '',
+                    'priority': None,
+                    'status': 2,
+                    'count': 1,
+                    'category': []
+                }
+                specific_dic['category'].append({
+                    'id': None,
+                    'name': category,
+                    'status': 2,
+                    'count': 1
+                })
+            else:
+                specific_dic = {'url': user_url, 'desc': '', 'priority': None, 'count': 1, 'status': 2, 'id': path_id}
         # 插入到 index=0 的位置
         app_context.merge_list.insert(0, specific_dic)
 
diff --git a/lyrebird_api_coverage/client/report.py b/lyrebird_api_coverage/client/report.py
index 7a738588..32fb938e 100644
--- a/lyrebird_api_coverage/client/report.py
+++ b/lyrebird_api_coverage/client/report.py
@@ -1,5 +1,5 @@
 from lyrebird_api_coverage.client.context import app_context
-from lyrebird import report
+from lyrebird import publish
 
 """
 上报处理器，用户请求行为上报到ELK中
@@ -7,7 +7,7 @@
 """
 
 class ReportHandler:
-    def check_url_info(self, url, device_ip):
+    def check_url_info(self, url, device_ip, category):
         specific_list = list(filter(lambda x: x.get('url') == url, app_context.merge_list))
         if specific_list and specific_list[0].get('status') == 1:
             desc = specific_list[0].get('desc')
@@ -17,19 +17,26 @@ def check_url_info(self, url, device_ip):
             desc = 'N/A'
             count_flag = -1
             priority = -1
-        info_dict = {'url': url, 'desc': desc, 'priority': priority, 'count_flag': count_flag,
-                     'business': app_context.business, 'version_name': app_context.version_name,
-                     'version_code': app_context.version_code}
+        info_dict = {
+            'coverage':{
+                'url': url,
+                'desc': desc,
+                'priority': priority,
+                'count_flag': count_flag,
+                'version_name': app_context.version_name,
+                'version_code': app_context.version_code,
+                'category': category
+            }
+        }
         if app_context.info.get(device_ip):
             # 如果有Device信息，就上报device相关的信息
-            info_dict.update(app_context.info.get(device_ip))
+            info_dict['coverage'].update(app_context.info.get(device_ip))
         return info_dict
 
 
 report_handler = ReportHandler()
 
 
-def report_worker(url, device_ip):
-    update_data = report_handler.check_url_info(url, device_ip)
-    update_data.update({"action": "api-coverage", "user_info": app_context.user_info})
-    report(update_data)
+def report_worker(url, device_ip, category):
+    update_data = report_handler.check_url_info(url, device_ip, category)
+    publish('coverage', update_data)
diff --git a/lyrebird_api_coverage/handlers/base_source_handler.py b/lyrebird_api_coverage/handlers/base_source_handler.py
index ce976171..b4d80c35 100644
--- a/lyrebird_api_coverage/handlers/base_source_handler.py
+++ b/lyrebird_api_coverage/handlers/base_source_handler.py
@@ -46,7 +46,8 @@ def get_base_source(self):
     def check_base(self, obj):
         try:
             # 检查base schema
-            check_schema(obj)
+            if not app_context.is_api_base_data:
+                check_schema(obj)
             # 检查url是否有重复项存在
             redundant_items = check_url_redundant(obj)
             if redundant_items:
@@ -59,12 +60,12 @@ def check_base(self, obj):
                 resp = context.make_fail_response('导入API有重复项' + str(redundant_items))
                 lyrebird.publish('api_coverage', 'error', name='import_base')
                 return resp
-            # 获取base内容，解析出base的business等字段
-            filename = obj.get('business') + obj.get('version_name') + '.' + str(obj.get('version_code'))
+            # 获取base内容，解析出base的business等字段 
+            filename = f'''{obj.get('business','')}{obj.get('version_name','')}{obj.get('version_code','')}'''
             app_context.filename = filename
-            app_context.business = obj.get('business')
-            app_context.version_name = obj.get('version_name')
-            app_context.version_code = obj.get('version_code')
+            app_context.business = obj.get('business', '')
+            app_context.version_name = obj.get('version_name', '--')
+            app_context.version_code = obj.get('version_code', '--')
             return
         except Exception as e:
             resp = context.make_fail_response(f'导入文件有误: {e}\n请重新import base')
diff --git a/lyrebird_api_coverage/interceptor.py b/lyrebird_api_coverage/interceptor.py
index 5e9f334f..6f1bbd76 100644
--- a/lyrebird_api_coverage/interceptor.py
+++ b/lyrebird_api_coverage/interceptor.py
@@ -1,10 +1,11 @@
 import lyrebird
-from lyrebird import log
+from lyrebird import log, application
 from lyrebird_api_coverage.client import format_url
 from lyrebird_api_coverage.client.context import app_context
 from lyrebird_api_coverage.client.merge_algorithm import mergeAlgorithm
 from lyrebird_api_coverage.client.report import report_worker
 from lyrebird_api_coverage.client.url_compare import compare_query
+from urllib.parse import urlparse
 
 logger = log.get_logger()
 import time
@@ -15,19 +16,29 @@ def on_request(msg):
     logger.debug(req_msg)
     if not msg['flow']['request']['url']:
         return
-    short_url = msg['flow']['request']['url'].replace('http://', '').replace('https://', '').split('?')[0]
-    # format之后的真正PATH，处理{num}这样的情况，emit给前端，做刷新table用，同时处理成小写
-    path = format_url.format_api(short_url).lower()
+
     # 获取handler_context.id，为前端展开看详情准备
     path_id = msg['flow']['id']
     device_ip = msg['flow']['client_address']
+    # 获取产品信息
+    app_context.category = get_current_category(req_msg)
+    if app_context.is_api_base_data:
+        new_path = format_url.format_api(urlparse(msg['flow']['request']['url']).path).lower()
+        coverage_judgment(new_path, path_id, device_ip, req_starttime, msg, app_context.category)
+    else:
+        short_url = msg['flow']['request']['url'].replace('http://', '').replace('https://', '').split('?')[0]
+        # format之后的真正PATH，处理{num}这样的情况，emit给前端，做刷新table用，同时处理成小写
+        path = format_url.format_api(short_url).lower()
+        coverage_judgment(path, path_id, device_ip, req_starttime, msg, app_context.category)
+
+def coverage_judgment(path, path_id, device_ip, req_starttime, msg, category):
     if path in app_context.base_list:
         # merge到 context merge list中
-        mergeAlgorithm.merge_handler_new(path, path_id)
+        mergeAlgorithm.merge_handler_new(path, path_id, category)
         # 在base里的需要去计算下覆盖率
         mergeAlgorithm.coverage_handler()
         # 进行上报
-        report_worker(path, device_ip)
+        report_worker(path, device_ip, category)
         # 计算差值，指定时间间隔内只发1次io msg，限制刷新频率
         emit(req_starttime, path)
     # 如果path配置了对应的参数
@@ -38,7 +49,7 @@ def on_request(msg):
             if compare_query(item['url'], msg['flow']['request']['url']):
                 mergeAlgorithm.merge_handler_new(item['url_base'], path_id)
                 mergeAlgorithm.coverage_handler()
-                report_worker(item['url_base'], device_ip)
+                report_worker(item['url_base'], device_ip, category)
                 flag = 1
         # 如果参数组合不存在，提取关注的字段
         if flag == 0:
@@ -54,19 +65,33 @@ def on_request(msg):
                     url_pgroup = url_pgroup + '&' + str(p) + '=' + str(val)
                 else:
                     url_pgroup = path + '?' + str(p) + '=' + str(val)
-            mergeAlgorithm.merge_handler_new(url_pgroup, path_id)
+            mergeAlgorithm.merge_handler_new(url_pgroup, path_id, category)
             mergeAlgorithm.coverage_handler()
-            report_worker(url_pgroup, device_ip)
+            report_worker(url_pgroup, device_ip, category)
         # 计算差值，指定时间间隔内只发1次io msg，限制刷新频率
         emit(req_starttime, path)
     # 如果不在base里，不需要merge到数据中
     else:
         # mergeAlgorithm.merge_handler_new(path, path_id)
         # 进行上报
-        report_worker(path, device_ip)
+        report_worker(path, device_ip, category)
 
 def emit(starttime, path):
         duration = starttime - app_context.endtime
         if duration > app_context.SOCKET_PUSH_INTERVAL:
             app_context.endtime = starttime
             lyrebird.emit('apiCoverageBaseData')
+
+# 获取产品信息
+def get_current_category(req_msg):
+    # 读取产品映射关系
+    if application.config.get('apicoverage.category'):
+        for item in application.config.get('apicoverage.category'):
+            params = req_msg.get('request').get(item.get('params_source'))
+            new_params = {k.lower(): v for k, v in params.items()}
+            if item.get('keyWord') != '' and params.get(item['params']) and params.get(item['params']).startswith(item.get('keyWord')):
+                return item.get('categoryName')
+            elif item.get('keyWord') == '' and item.get('params') in new_params:
+                return new_params.get(item.get('params').lower())
+    
+    return ''
diff --git a/lyrebird_api_coverage/version.py b/lyrebird_api_coverage/version.py
index 23622075..3bc41c1a 100644
--- a/lyrebird_api_coverage/version.py
+++ b/lyrebird_api_coverage/version.py
@@ -1,2 +1,2 @@
-IVERSION = (0, 3, 3)
+IVERSION = (0, 4, 0)
 VERSION = ".".join(str(i) for i in IVERSION)