Add log search function code.

Add log search function code.

Change-Id: Ib54a5d5fd8885962f84077921202c2d56bf1b31d

venus_dashboard/api/venus.py

@@ -0,0 +1,49 @@
+# Copyright 2015 - Alcatel-Lucent
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+#    you may not use this file except in compliance with the License.
+#    You may obtain a copy of the License at
+#
+#        http://www.apache.org/licenses/LICENSE-2.0
+#
+#    Unless required by applicable law or agreed to in writing, software
+#    distributed under the License is distributed on an "AS IS" BASIS,
+#    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#    See the License for the specific language governing permissions and
+#    limitations under the License.
+
+import logging
+
+from horizon.utils.memoized import memoized
+from openstack_dashboard.api import base
+from keystoneauth1.identity.generic.token import Token
+from keystoneauth1.session import Session
+from venusclient.v1 import client
+
+
+LOG = logging.getLogger(__name__)
+
+
+@memoized
+def venusclient(request):
+    endpoint = base.url_for(request, 'identity')
+    token_id = request.user.token.id
+    tenant_name = request.user.tenant_name
+    project_domain_id = request.user.token.project.get('domain_id', 'Default')
+    auth = Token(auth_url=endpoint,
+                 token=token_id,
+                 project_name=tenant_name,
+                 project_domain_id=project_domain_id)
+    session = Session(auth=auth, timeout=600)
+    return client.Client(session=session)
+
+
+def log_storage_days(request):
+    return venusclient(request).config.get_days()
+
+
+def logs(request, start_time, end_time, page_size, page_num):
+    return venusclient(request).config.get_logs(start_time=start_time,
+                                                end_time=end_time,
+                                                page_size=page_size,
+                                                page_num=page_num)

venus_dashboard/api/venus_rest_api.py

@@ -0,0 +1,44 @@
+# Copyright 2015 - Alcatel-Lucent
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+#    you may not use this file except in compliance with the License.
+#    You may obtain a copy of the License at
+#
+#        http://www.apache.org/licenses/LICENSE-2.0
+#
+#    Unless required by applicable law or agreed to in writing, software
+#    distributed under the License is distributed on an "AS IS" BASIS,
+#    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#    See the License for the specific language governing permissions and
+#    limitations under the License.
+
+from django.views import generic
+import json
+import logging
+from openstack_dashboard.api.rest import urls
+from openstack_dashboard.api.rest import utils as rest_utils
+from venus_dashboard.api import venus
+
+LOG = logging.getLogger(__name__)
+
+
+@urls.register
+class LogStorageDays(generic.View):
+    url_regex = r'venus/log_storage_days/$'
+
+    @rest_utils.ajax()
+    def get(self, request):
+        return venus.log_storage_days(request)
+
+
+@urls.register
+class Logs(generic.View):
+    url_regex = r'venus/logs/$'
+
+    @rest_utils.ajax()
+    def get(self, request):
+        start_time = request.GET.get('start_time', 0)
+        end_time = request.GET.get('end_time', 0)
+        page_size = request.GET.get('page_size', 20)
+        page_num = request.GET.get('page_num', 1)
+        return venus.logs(request, start_time, end_time, page_size, page_num)

venus_dashboard/log_search/panel.py

@@ -0,0 +1,26 @@
+# Copyright 2012 United States Government as represented by the
+# Administrator of the National Aeronautics and Space Administration.
+# All Rights Reserved.
+#
+# Copyright 2012 Nebula, Inc.
+#
+#    Licensed under the Apache License, Version 2.0 (the "License"); you may
+#    not use this file except in compliance with the License. You may obtain
+#    a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+#    Unless required by applicable law or agreed to in writing, software
+#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+#    License for the specific language governing permissions and limitations
+#    under the License.
+
+from django.utils.translation import ugettext_lazy as _
+
+import horizon
+
+
+class LogSearch(horizon.Panel):
+    name = _("Log Search")
+    slug = 'venus'

venus_dashboard/log_search/templates/log_search/index.html

@@ -0,0 +1,13 @@
+{% extends 'base.html' %}
+{% load i18n %}
+{% block title %}Log Search{% endblock %}
+
+{% block page_header %}
+{% include "horizon/common/_page_header.html" with title=_("Log Search") %}
+{% endblock page_header %}
+
+{% block main %}
+<div ng-cloak ng-init="">
+    <ng-include src="'{{STATIC_URL}}dashboard/admin/venus/logSearch/logSearch.html'"></ng-include>
+</div>
+{% endblock %}

venus_dashboard/log_search/tests.py

@@ -0,0 +1,326 @@
+# Copyright 2012 United States Government as represented by the
+# Administrator of the National Aeronautics and Space Administration.
+# All Rights Reserved.
+#
+# Copyright 2012 Nebula, Inc.
+#
+#    Licensed under the Apache License, Version 2.0 (the "License"); you may
+#    not use this file except in compliance with the License. You may obtain
+#    a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+#    Unless required by applicable law or agreed to in writing, software
+#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+#    License for the specific language governing permissions and limitations
+#    under the License.
+
+# import datetime
+# import logging
+#
+# from django.test.utils import override_settings
+# from django.urls import reverse
+# from django.utils import timezone
+#
+# from openstack_dashboard import api
+# from openstack_dashboard.test import helpers as test
+# from openstack_dashboard import usage
+#
+#
+# INDEX_URL = reverse('horizon:project:overview:index')
+#
+#
+# class UsageViewTests(test.TestCase):
+#
+#     @test.create_mocks({
+#         api.nova: ('usage_get',),
+#         api.neutron: ('is_quotas_extension_supported',),
+#         usage.quotas: ('tenant_quota_usages',),
+#     }, stop_mock=False)
+#     # NOTE: _stub_api_calls() and _check_api_calls() are used as pair
+#     # and the test logic will be placed between these calls,
+#     # so we cannot stop mocking when exiting this method.
+#     def _stub_api_calls(self, nova_stu_enabled=True,
+#                         stu_exception=False, overview_days_range=1,
+#                         quota_usage_overrides=None,
+#                         quota_extension_support=True):
+#         self.mock_is_quotas_extension_supported.return_value = \
+#             quota_extension_support
+#         if nova_stu_enabled:
+#             self._nova_stu_enabled(stu_exception,
+#                                    overview_days_range=overview_days_range)
+#
+#         self._stub_tenant_quota_usages(overrides=quota_usage_overrides)
+#
+#     def _check_api_calls(self, nova_stu_enabled=True,
+#                          stu_exception=False, overview_days_range=1):
+#         if nova_stu_enabled:
+#             self._check_stu_enabled(stu_exception,
+#                                     overview_days_range=overview_days_range)
+#         else:
+#             self.mock_usage_get.assert_not_called()
+#         self._check_tenant_quota_usages()
+#
+#     @staticmethod
+#     def _add_quota_usages(usages, quota_usages, excludes=None):
+#         excludes = excludes or []
+#         for k in quota_usages.usages:
+#             if k in excludes:
+#                 continue
+#             quota = quota_usages[k]['quota']
+#             if quota == float('inf'):
+#                 quota = -1
+#             usages.add_quota(api.base.Quota(k, quota))
+#             usages.tally(k, quota_usages[k]['used'])
+#
+#     def _stub_tenant_quota_usages(self, overrides):
+#         usages_data = usage.quotas.QuotaUsage()
+#         self._add_quota_usages(usages_data, self.quota_usages.first(),
+#                                # At now, nova quota_usages contains
+#                                # volumes and gigabytes.
+#                                excludes=('volumes', 'gigabytes'))
+#         self._add_quota_usages(
+#             usages_data, self.neutron_quota_usages.first())
+#         self._add_quota_usages(usages_data, self.cinder_quota_usages.first())
+#         if overrides:
+#             for key, value in overrides.items():
+#                 if 'quota' in value:
+#                     usages_data.add_quota(api.base.Quota(key, value['quota']))
+#                 if 'used' in value:
+#                     usages_data.tally(key, value['used'])
+#         self.mock_tenant_quota_usages.return_value = usages_data
+#
+#     def _check_tenant_quota_usages(self):
+#         self.mock_tenant_quota_usages.assert_called_once_with(
+#             test.IsHttpRequest())
+#
+#     def _nova_stu_enabled(self, exception=False, overview_days_range=1):
+#         if exception:
+#             self.mock_usage_get.side_effect = exception
+#         else:
+#             usage = api.nova.NovaUsage(self.usages.first())
+#             self.mock_usage_get.return_value = usage
+#
+#     def _check_stu_enabled(self, exception=False, overview_days_range=1):
+#         now = timezone.now()
+#         if overview_days_range:
+#             start_day = now - datetime.timedelta(days=overview_days_range)
+#         else:
+#             start_day = datetime.date(now.year, now.month, 1)
+#         start = datetime.datetime(start_day.year, start_day.month,
+#                                   start_day.day, 0, 0, 0, 0)
+#         end = datetime.datetime(now.year, now.month, now.day, 23, 59, 59, 0)
+#
+#         self.mock_usage_get.assert_called_once_with(
+#             test.IsHttpRequest(), self.tenant.id, start, end)
+#
+#     def _common_assertions(self, nova_stu_enabled,
+#                            maxTotalFloatingIps=50):
+#         res = self.client.get(reverse('horizon:project:overview:index'))
+#         usages = res.context['usage']
+#         self.assertTemplateUsed(res, 'project/overview/usage.html')
+#         self.assertIsInstance(usages, usage.ProjectUsage)
+#         self.assertEqual(nova_stu_enabled,
+#                          res.context['simple_tenant_usage_enabled'])
+#         if nova_stu_enabled:
+#             self.assertContains(res, 'form-inline')
+#         else:
+#             self.assertNotContains(res, 'form-inline')
+#         self.assertEqual(usages.limits['floatingip']['quota'],
+#                          maxTotalFloatingIps)
+#
+#     @override_settings(OVERVIEW_DAYS_RANGE=None)
+#     def test_usage(self):
+#         self._test_usage(nova_stu_enabled=True, overview_days_range=None)
+#
+#     def test_usage_1_day(self):
+#         self._test_usage(nova_stu_enabled=True)
+#
+#     @override_settings(
+#         OVERVIEW_DAYS_RANGE=None,
+#         OPENSTACK_USE_SIMPLE_TENANT_USAGE=False,
+#     )
+#     def test_usage_disabled(self):
+#         self._test_usage(nova_stu_enabled=False, overview_days_range=None)
+#
+#     def _test_usage(self, nova_stu_enabled, overview_days_range=1):
+#         self._stub_api_calls(nova_stu_enabled,
+#                              overview_days_range=overview_days_range)
+#
+#         self._common_assertions(nova_stu_enabled)
+#
+#         self._check_api_calls(nova_stu_enabled,
+#                               overview_days_range=overview_days_range)
+#
+#     def test_unauthorized(self):
+#         url = reverse('horizon:admin:volumes:index')
+#
+#         # Avoid the log message in the test
+#         # when unauthorized exception will be logged
+#         logging.disable(logging.ERROR)
+#         res = self.client.get(url)
+#         logging.disable(logging.NOTSET)
+#
+#         self.assertEqual(403, res.status_code)
+#
+#     def test_usage_csv(self):
+#         self._test_usage_csv(nova_stu_enabled=True)
+#
+#     @override_settings(OVERVIEW_DAYS_RANGE=1)
+#     def test_usage_csv_1_day(self):
+#         self._test_usage_csv(nova_stu_enabled=True, overview_days_range=1)
+#
+#     @override_settings(OPENSTACK_USE_SIMPLE_TENANT_USAGE=False)
+#     def test_usage_csv_disabled(self):
+#         self._test_usage_csv(nova_stu_enabled=False)
+#
+#     def _test_usage_csv(self, nova_stu_enabled=True, overview_days_range=1):
+#         self._stub_api_calls(nova_stu_enabled,
+#                              overview_days_range=overview_days_range)
+#
+#         res = self.client.get(reverse('horizon:project:overview:index') +
+#                               "?format=csv")
+#         self.assertTemplateUsed(res, 'project/overview/usage.csv')
+#         self.assertIsInstance(res.context['usage'], usage.ProjectUsage)
+#         self._check_api_calls(nova_stu_enabled,
+#                               overview_days_range=overview_days_range)
+#
+#     def test_usage_exception_usage(self):
+#         self._stub_api_calls(stu_exception=self.exceptions.nova)
+#
+#         res = self.client.get(reverse('horizon:project:overview:index'))
+#         self.assertTemplateUsed(res, 'project/overview/usage.html')
+#         self.assertEqual(res.context['usage'].usage_list, [])
+#
+#         self._check_api_calls(stu_exception=self.exceptions.nova)
+#
+#     def test_usage_default_tenant(self):
+#         self._stub_api_calls()
+#
+#         res = self.client.get(reverse('horizon:project:overview:index'))
+#         self.assertTemplateUsed(res, 'project/overview/usage.html')
+#         self.assertIsInstance(res.context['usage'], usage.ProjectUsage)
+#
+#         self._check_api_calls()
+#
+#     @test.update_settings(OPENSTACK_NEUTRON_NETWORK={'enable_quotas': True})
+#     def test_usage_with_neutron(self):
+#         self._test_usage_with_neutron(neutron_sg_enabled=True)
+#
+#     @test.update_settings(OPENSTACK_NEUTRON_NETWORK={'enable_quotas': True})
+#     def test_usage_with_neutron_nova_security_group(self):
+#         self._test_usage_with_neutron(neutron_sg_enabled=False)
+#
+#     @test.update_settings(OPENSTACK_NEUTRON_NETWORK={'enable_quotas': True})
+#     def test_usage_with_neutron_floating_ip_disabled(self):
+#         self._test_usage_with_neutron(neutron_fip_enabled=False)
+#
+#     def _test_usage_with_neutron(self,
+#                                  neutron_sg_enabled=True,
+#                                  neutron_fip_enabled=True):
+#         self._stub_api_calls()
+#         self._test_usage_with_neutron_check(neutron_sg_enabled,
+#                                             neutron_fip_enabled)
+#         self._check_api_calls()
+#
+#     def _test_usage_with_neutron_check(self, neutron_sg_enabled=True,
+#                                        neutron_fip_expected=True,
+#                                        max_fip_expected=50,
+#                                        max_sg_expected=20):
+#         res = self.client.get(reverse('horizon:project:overview:index'))
+#         if neutron_fip_expected:
+#             self.assertContains(res, 'Floating IPs')
+#         self.assertContains(res, 'Security Groups')
+#
+#         res_limits = res.context['usage'].limits
+#         max_floating_ips = res_limits['floatingip']['quota']
+#         self.assertEqual(max_floating_ips, max_fip_expected)
+#         if neutron_sg_enabled:
+#             max_security_groups = res_limits['security_group']['quota']
+#             self.assertEqual(max_security_groups, max_sg_expected)
+#
+#     def test_usage_cinder(self):
+#         self._stub_api_calls(
+#             quota_usage_overrides={'volumes': {'used': 4},
+#                                    'gigabytes': {'used': 400}}
+#         )
+#
+#         res = self.client.get(reverse('horizon:project:overview:index'))
+#         usages = res.context['usage']
+#         self.assertTemplateUsed(res, 'project/overview/usage.html')
+#         self.assertIsInstance(usages, usage.ProjectUsage)
+#
+#         self.assertEqual(usages.limits['volumes']['used'], 4)
+#         self.assertEqual(usages.limits['volumes']['quota'], 10)
+#         self.assertEqual(usages.limits['gigabytes']['used'], 400)
+#         self.assertEqual(usages.limits['gigabytes']['quota'], 1000)
+#
+#         self._check_api_calls(nova_stu_enabled=True)
+#
+#     # nova_stu_enable=False is specified below, so we need this.
+#     @override_settings(OPENSTACK_USE_SIMPLE_TENANT_USAGE=False)
+#     def _test_usage_charts(self, quota_usage_overrides=None,
+#                            quota_extension_support=True):
+#         self._stub_api_calls(nova_stu_enabled=False,
+#                              quota_usage_overrides=quota_usage_overrides,
+#                              quota_extension_support=quota_extension_support)
+#
+#         res = self.client.get(reverse('horizon:project:overview:index'))
+#
+#         self._check_api_calls(nova_stu_enabled=False)
+#
+#         return res
+#
+#     def test_usage_charts_created(self):
+#         res = self._test_usage_charts(
+#             quota_usage_overrides={'floatingip': {'quota': -1, 'used': 1234}})
+#         self.assertIn('charts', res.context)
+#         charts = res.context['charts']
+#
+#         self.assertEqual(['Compute', 'Volume', 'Network'],
+#                          [c['title'] for c in charts])
+#
+#         compute_charts = [c for c in charts if c['title'] == 'Compute'][0]
+#         chart_ram = [c for c in compute_charts['charts']
+#                      if c['type'] == 'ram'][0]
+#         # Check mb_float_format filter is applied
+#         self.assertEqual(10000, chart_ram['quota'])
+#         self.assertEqual('9.8GB', chart_ram['quota_display'])
+#         self.assertEqual(0, chart_ram['used'])
+#         self.assertEqual('0B', chart_ram['used_display'])
+#
+#         volume_charts = [c for c in charts if c['title'] == 'Volume'][0]
+#         chart_gigabytes = [c for c in volume_charts['charts']
+#                            if c['type'] == 'gigabytes'][0]
+#         # Check diskgbformat filter is applied
+#         self.assertEqual(1000, chart_gigabytes['quota'])
+#         self.assertEqual('1000GB', chart_gigabytes['quota_display'])
+#         self.assertEqual(0, chart_gigabytes['used'])
+#         self.assertEqual('0B', chart_gigabytes['used_display'])
+#
+#         network_charts = [c for c in charts if c['title'] == 'Network'][0]
+#         chart_fip = [c for c in network_charts['charts']
+#                      if c['type'] == 'floatingip'][0]
+#         # Check intcomma default filter is applied
+#         self.assertEqual(float('inf'), chart_fip['quota'])
+#         self.assertEqual(float('inf'), chart_fip['quota_display'])
+#         self.assertEqual(1234, chart_fip['used'])
+#         self.assertEqual('1,234', chart_fip['used_display'])
+#
+#     def test_disallowed_network_chart(self):
+#         res = self._test_usage_charts(
+#             quota_usage_overrides={'floatingip': {'quota': -1, 'used': 1234}},
+#             quota_extension_support=False)
+#         charts = res.context['charts']
+#         self.assertEqual(['Compute', 'Volume'],
+#                          [c['title'] for c in charts])
+#
+#     def test_usage_charts_infinite_quota(self):
+#         res = self._test_usage_charts(
+#             quota_usage_overrides={'floatingip': {'quota': -1}})
+#
+#         max_floating_ips = res.context['usage'].limits['floatingip']['quota']
+#         self.assertEqual(max_floating_ips, float("inf"))
+#
+#         self.assertContains(res, '(No Limit)')

venus_dashboard/log_search/urls.py

@@ -0,0 +1,26 @@
+# Copyright 2012 United States Government as represented by the
+# Administrator of the National Aeronautics and Space Administration.
+# All Rights Reserved.
+#
+# Copyright 2012 Nebula, Inc.
+#
+#    Licensed under the Apache License, Version 2.0 (the "License"); you may
+#    not use this file except in compliance with the License. You may obtain
+#    a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+#    Unless required by applicable law or agreed to in writing, software
+#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+#    License for the specific language governing permissions and limitations
+#    under the License.
+
+from django.conf.urls import url
+
+from venus_dashboard.log_search import views
+import venus_dashboard.api.venus_rest_api  #noqa
+
+urlpatterns = [
+    url(r'^log_search$', views.LogSearch.as_view(), name='index'),
+]

venus_dashboard/log_search/views.py

@@ -0,0 +1,27 @@
+# Copyright 2012 United States Government as represented by the
+# Administrator of the National Aeronautics and Space Administration.
+# All Rights Reserved.
+#
+# Copyright 2012 Nebula, Inc.
+#
+#    Licensed under the Apache License, Version 2.0 (the "License"); you may
+#    not use this file except in compliance with the License. You may obtain
+#    a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+#    Unless required by applicable law or agreed to in writing, software
+#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+#    License for the specific language governing permissions and limitations
+#    under the License.
+
+
+from horizon import views
+
+
+class LogSearch(views.APIView):
+    template_name = 'log_search/index.html'
+
+    def get_data(self, request, context, *args, **kwargs):
+        return context

venus_dashboard/static/app/core/openstack-service-api/venus.service.js

@@ -0,0 +1,43 @@
+(function () {
+  'use strict';
+
+  angular
+        .module('horizon.app.core.openstack-service-api')
+        .factory('horizon.app.core.openstack-service-api.venus', venusAPI);
+
+  venusAPI.$inject = [
+    'horizon.framework.util.http.service',
+    'horizon.framework.widgets.toast.service'
+
+  ];
+
+  function venusAPI(apiService, toastService) {
+
+    function getLogStorageDays() {
+      var url = '/api/venus/log_storage_days/';
+
+      return apiService.get(url)
+                .catch(function () {
+                  // toastService.add('error', gettext('Unable to fetch the venus log storage days.'));
+                });
+    }
+
+    function getLogs(config) {
+      config = config || {};
+      var url = '/api/venus/logs/';
+
+      return apiService.get(url, config)
+                .catch(function () {
+                  // toastService.add('error', gettext('Unable to fetch the venus logs.'));
+                });
+    }
+
+    var service = {
+      getLogStorageDays: getLogStorageDays,
+      getLogs: getLogs
+    };
+
+    return service;
+  }
+
+}());

venus_dashboard/static/dashboard/admin/services/venus.service.js

@@ -0,0 +1,49 @@
+(function () {
+  'use strict';
+
+  angular
+    .module('horizon.dashboard.admin.venus')
+    .service('venusSrv', venusSrv);
+
+  venusSrv.$inject = ['$http', '$injector'];
+
+  function venusSrv($http, $injector) {
+    var venusAPI;
+
+    if ($injector.has('horizon.app.core.openstack-service-api.venus')) {
+      venusAPI = $injector.get('horizon.app.core.openstack-service-api.venus');
+    }
+
+    function getLogStorageDays() {
+      if (venusAPI) {
+        return venusAPI.getLogStorageDays()
+          .then(function (data) {
+            return data;
+          })
+          .catch(function (err) {
+            console.error(err);
+          }
+          );
+      }
+    }
+
+    function getLogs(config) {
+      config = {params: config};
+      if (venusAPI) {
+        return venusAPI.getLogs(config)
+          .then(function (data) {
+            return data;
+          })
+          .catch(function (err) {
+            console.error(err);
+          }
+          );
+      }
+    }
+
+    return {
+      getLogStorageDays: getLogStorageDays,
+      getLogs: getLogs
+    };
+  }
+})();

venus_dashboard/static/dashboard/admin/venus.module.js

@@ -0,0 +1,6 @@
+(function() {
+  'use strict';
+
+  angular.module('horizon.dashboard.admin.venus',['ui.bootstrap']);
+
+})();

venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.controller.js

@@ -0,0 +1,51 @@
+(function () {
+  'use strict';
+
+  angular
+        .module('horizon.dashboard.admin.venus')
+        .controller('LogSearchController', LogSearchController);
+
+  LogSearchController.$inject = ['$scope', 'venusSrv'];
+
+  function LogSearchController($scope, venusSrv) {
+    $scope.STATIC_URL = STATIC_URL;
+    $scope.model = {
+      start_time: new Date(),
+      end_time: new Date(),
+      condition: 'module_name',
+      page_size: 20,
+      page_num: 1
+    };
+    $scope.tableData = [];
+
+    $scope.getData = function() {
+      var config = {
+        start_time: $scope.model.start_time.getTime() / 1000,
+        end_time: $scope.model.end_time.getTime() / 1000,
+        page_size: $scope.model.page_size,
+        page_num: $scope.model.page_num
+      };
+      venusSrv.getLogs(config).then(function(res) {
+        $scope.tableData = [];
+        if (res.data.hasOwnProperty('data')) {
+          $scope.tableData = res.data.data.values;
+        }
+      });
+    };
+
+    function init() {
+      var end_time = new Date();
+      end_time.setMilliseconds(0);
+      var start_time = new Date();
+      start_time.setMilliseconds(0);
+      start_time.setTime(end_time.getTime() - 24 * 60 * 60 * 1000);
+      $scope.model.start_time = start_time;
+      $scope.model.end_time = end_time;
+
+      $scope.getData();
+    }
+
+    init();
+  }
+
+})();

venus_dashboard/static/dashboard/admin/venus/logSearch/logSearch.html

@@ -0,0 +1,55 @@
+<div ng-controller="LogSearchController as vm">
+    <div class="row">
+        <div class="col-xs-12">
+            <form class="form-inline pull-right">
+                <div class="form-group">
+                    <input type="datetime-local" class="form-control" ng-model="model.start_time">
+                </div>
+                -
+                <div class="form-group">
+                    <input type="datetime-local" class="form-control" ng-model="model.end_time">
+                </div>
+                <div class="form-group">
+                    <select class="form-control" ng-model="model.condition">
+                        <option value="module_name">模块</option>
+                    </select>
+                </div>
+                <div class="form-group">
+                    <input type="text" class="form-control">
+                </div>
+                <div class="form-group">
+                    <button type="button" class="btn btn-default" ng-click="getData()">筛选</button>
+                </div>
+            </form>
+        </div>
+        <table class="table table-hover">
+            <thead>
+                <tr>
+                    <th>时间</th>
+                    <th>主机</th>
+                    <th>模块</th>
+                    <th>组件</th>
+                    <th>级别</th>
+                    <th>项目ID</th>
+                    <th>用户ID</th>
+                    <th>描述</th>
+                </tr>
+            </thead>
+            <tbody>
+                <tr class="text-center" ng-if="tableData.length === 0">
+                    <td colspan="8">暂无数据。</td>
+                </tr>
+                <tr ng-repeat="item in tableData">
+                    <td>{$ item.time $}</td>
+                    <td>{$ item.host_name $}</td>
+                    <td>{$ item.module_name $}</td>
+                    <td>{$ item.program_name $}</td>
+                    <td>{$ item.level $}</td>
+                    <td>{$ item.project_id $}</td>
+                    <td>{$ item.user_id $}</td>
+                    <td>{$ item.desc $}</td>
+                </tr>
+            </tbody>
+        </table>
+    </div>
+</div>