[manager,webapp] 全局监控搜索框功能实现

manager/src/main/java/com/usthe/manager/controller/MonitorsController.java

@@ -65,13 +65,19 @@ public class MonitorsController {
                 Predicate predicateApp = criteriaBuilder.equal(root.get("app"), app);
                 predicate = criteriaBuilder.and(predicateApp);
             }
-            if (name != null && !"".equals(name)) {
+            if (name != null && !"".equals(name) && host != null && !"".equals(host)) {
                 Predicate predicateName = criteriaBuilder.like(root.get("name"), "%" + name + "%");
-                predicate = criteriaBuilder.and(predicateName);
-            }
-            if (host != null && !"".equals(host)) {
                 Predicate predicateHost = criteriaBuilder.like(root.get("host"), "%" + host + "%");
-                predicate = criteriaBuilder.and(predicateHost);
+                predicate = criteriaBuilder.or(predicateName, predicateHost);
+            } else {
+                if (host != null && !"".equals(host)) {
+                    Predicate predicateHost = criteriaBuilder.like(root.get("host"), "%" + host + "%");
+                    predicate = criteriaBuilder.and(predicateHost);
+                }
+                if (name != null && !"".equals(name)) {
+                    Predicate predicateName = criteriaBuilder.like(root.get("name"), "%" + name + "%");
+                    predicate = criteriaBuilder.and(predicateName);
+                }
             }
             return predicate;
         };

web-app/src/app/layout/basic/widgets/search.component.ts

@@ -12,6 +12,8 @@ import {
 } from '@angular/core';
 import { BehaviorSubject } from 'rxjs';
 import { debounceTime, distinctUntilChanged, tap } from 'rxjs/operators';
+import {MonitorService} from "../../../service/monitor.service";
+import {Monitor} from "../../../pojo/Monitor";
 
 @Component({
   selector: 'header-search',
@@ -34,8 +36,14 @@ import { debounceTime, distinctUntilChanged, tap } from 'rxjs/operators';
         [attr.placeholder]="'menu.search.placeholder' | i18n"
       />
     </nz-input-group>
-    <nz-autocomplete nzBackfill #auto>
+    <nz-autocomplete nzBackfill="false" nzDefaultActiveFirstOption #auto>
-      <nz-auto-option *ngFor="let i of options" [nzValue]="i">{{ i }}</nz-auto-option>
+      <nz-auto-option *ngFor="let option of options" [nzValue]="option.id" [nzLabel]="option.name">
+        <a [routerLink]="['/monitors/' + option.id]">
+          监控名称: {{ option.name }}
+          <span style="left:50% ; position: absolute;">监控Host: {{option.host}}</span>
+          <span style="right: 10px; position: absolute;"><i nz-icon nzType="arrow-right" nzTheme="outline"></i></span>
+        </a>
+      </nz-auto-option>
     </nz-autocomplete>
   `,
   changeDetection: ChangeDetectionStrategy.OnPush
@@ -43,7 +51,7 @@ import { debounceTime, distinctUntilChanged, tap } from 'rxjs/operators';
 export class HeaderSearchComponent implements AfterViewInit, OnDestroy {
   q = '';
   qIpt: HTMLInputElement | null = null;
-  options: string[] = [];
+  options: Monitor[] = [];
   search$ = new BehaviorSubject('');
   loading = false;
 
@@ -65,7 +73,9 @@ export class HeaderSearchComponent implements AfterViewInit, OnDestroy {
   }
   @Output() readonly toggleChangeChange = new EventEmitter<boolean>();
 
-  constructor(private el: ElementRef<HTMLElement>, private cdr: ChangeDetectorRef) {}
+  constructor(private el: ElementRef<HTMLElement>,
+              private cdr: ChangeDetectorRef,
+              private monitorSvc : MonitorService) {}
 
   ngAfterViewInit(): void {
     this.qIpt = this.el.nativeElement.querySelector('.ant-input') as HTMLInputElement;
@@ -80,9 +90,23 @@ export class HeaderSearchComponent implements AfterViewInit, OnDestroy {
         })
       )
       .subscribe(value => {
-        this.options = value ? [value, value + value, value + value + value] : [];
+        // 远程加载搜索数据
-        this.loading = false;
+        let searchMonitors$ = this.monitorSvc.searchMonitors(value, value, 0, 10)
-        this.cdr.detectChanges();
+          .subscribe(message => {
+            this.loading = false;
+            searchMonitors$.unsubscribe();
+            if (message.code === 0) {
+              let page = message.data;
+              this.options = page.content;
+              this.cdr.detectChanges();
+            } else {
+              console.warn(message.msg);
+            }
+          }, error => {
+            this.loading = false;
+            searchMonitors$.unsubscribe();
+            console.error(error.msg);
+          })
       });
   }
 

web-app/src/app/service/monitor.service.ts

@@ -88,6 +88,22 @@ export class MonitorService {
     return this.http.get<Message<Page<Monitor>>>(monitors_uri, options);
   }
 
+  public searchMonitors(monitorName: string, monitorHost: string,
+                        pageIndex: number, pageSize: number): Observable<Message<Page<Monitor>>> {
+    pageIndex = pageIndex ? pageIndex : 0;
+    pageSize = pageSize ? pageSize : 8;
+    // 注意HttpParams是不可变对象 需要保存set后返回的对象为最新对象
+    let httpParams = new HttpParams();
+    httpParams = httpParams.appendAll({
+      'name': monitorName,
+      'host': monitorHost,
+      'pageIndex': pageIndex,
+      'pageSize': pageSize
+    });
+    const options = { params: httpParams };
+    return this.http.get<Message<Page<Monitor>>>(monitors_uri, options);
+  }
+
   public getMonitorMetricData(monitorId: number, metric: string) : Observable<Message<any>> {
     return this.http.get<Message<any>>(`/monitors/${monitorId}/metrics/${metric}`);
   }