From 2f80e0485d7ef83cc08cbfaceeaf346171c44835 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期五, 26 七月 2019 13:38:37 +0800
Subject: [PATCH] add GetDbpersonsId
---
.idea/workspace.xml | 187 ++++++++++++++++++++++++++++++++++++++++++++++
EsApi.go | 49 ++++++++++++
2 files changed, 236 insertions(+), 0 deletions(-)
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
new file mode 100644
index 0000000..84b050c
--- /dev/null
+++ b/.idea/workspace.xml
@@ -0,0 +1,187 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+ <component name="ChangeListManager">
+ <list default="true" id="e1f05817-985c-458c-b947-3716306448a1" name="Default Changelist" comment="">
+ <change beforePath="$PROJECT_DIR$/EsApi.go" beforeDir="false" afterPath="$PROJECT_DIR$/EsApi.go" afterDir="false" />
+ </list>
+ <ignored path="$PROJECT_DIR$/out/" />
+ <option name="EXCLUDED_CONVERTED_TO_IGNORED" value="true" />
+ <option name="SHOW_DIALOG" value="false" />
+ <option name="HIGHLIGHT_CONFLICTS" value="true" />
+ <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
+ <option name="LAST_RESOLUTION" value="IGNORE" />
+ </component>
+ <component name="FileEditorManager">
+ <leaf>
+ <file pinned="false" current-in-tab="true">
+ <entry file="file://$PROJECT_DIR$/EsApi.go">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="312">
+ <caret line="319" column="45" selection-start-line="319" selection-start-column="38" selection-end-line="319" selection-end-column="45" />
+ <folding>
+ <element signature="e#16#126#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/EsClient_test.go">
+ <provider selected="true" editor-type-id="text-editor" />
+ </entry>
+ </file>
+ <file pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/EsClient.go">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="-1843">
+ <caret line="60" column="39" selection-start-line="60" selection-start-column="32" selection-end-line="60" selection-end-column="39" />
+ </state>
+ </provider>
+ </entry>
+ </file>
+ </leaf>
+ </component>
+ <component name="GOROOT" path="D:\Go" />
+ <component name="Git.Settings">
+ <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
+ </component>
+ <component name="IdeDocumentHistory">
+ <option name="CHANGED_PATHS">
+ <list>
+ <option value="$PROJECT_DIR$/EsApi.go" />
+ </list>
+ </option>
+ </component>
+ <component name="ProjectFrameBounds" extendedState="6">
+ <option name="x" value="953" />
+ <option name="width" value="974" />
+ <option name="height" value="1167" />
+ </component>
+ <component name="ProjectView">
+ <navigator proportions="" version="1">
+ <foldersAlwaysOnTop value="true" />
+ </navigator>
+ <panes>
+ <pane id="PackagesPane" />
+ <pane id="Scope" />
+ <pane id="ProjectPane" />
+ </panes>
+ </component>
+ <component name="PropertiesComponent">
+ <property name="WebServerToolWindowFactoryState" value="false" />
+ <property name="aspect.path.notification.shown" value="true" />
+ <property name="com.android.tools.idea.instantapp.provision.ProvisionBeforeRunTaskProvider.myTimeStamp" value="1564119272205" />
+ <property name="go.gopath.indexing.explicitly.defined" value="true" />
+ <property name="last_opened_file_path" value="$PROJECT_DIR$/../esutiltest" />
+ <property name="nodejs_interpreter_path.stuck_in_default_project" value="undefined stuck path" />
+ <property name="nodejs_npm_path_reset_for_default_project" value="true" />
+ <property name="settings.editor.selected.configurable" value="go.vgo" />
+ </component>
+ <component name="RunDashboard">
+ <option name="ruleStates">
+ <list>
+ <RuleState>
+ <option name="name" value="ConfigurationTypeDashboardGroupingRule" />
+ </RuleState>
+ <RuleState>
+ <option name="name" value="StatusDashboardGroupingRule" />
+ </RuleState>
+ </list>
+ </option>
+ </component>
+ <component name="SvnConfiguration">
+ <configuration />
+ </component>
+ <component name="TaskManager">
+ <task active="true" id="Default" summary="Default task">
+ <changelist id="e1f05817-985c-458c-b947-3716306448a1" name="Default Changelist" comment="" />
+ <created>1564037615220</created>
+ <option name="number" value="Default" />
+ <option name="presentableId" value="Default" />
+ <updated>1564037615220</updated>
+ <workItem from="1564037616784" duration="11715000" />
+ </task>
+ <servers />
+ </component>
+ <component name="TimeTrackingManager">
+ <option name="totallyTimeSpent" value="11715000" />
+ </component>
+ <component name="ToolWindowManager">
+ <frame x="-8" y="-8" width="1936" height="1176" extended-state="6" />
+ <editor active="true" />
+ <layout>
+ <window_info id="Image Layers" />
+ <window_info id="Designer" />
+ <window_info id="UI Designer" />
+ <window_info id="Capture Tool" />
+ <window_info id="Favorites" side_tool="true" />
+ <window_info content_ui="combo" id="Project" order="0" visible="true" weight="0.12153518" />
+ <window_info id="Structure" order="1" side_tool="true" weight="0.25" />
+ <window_info anchor="bottom" id="Docker" show_stripe_button="false" />
+ <window_info anchor="bottom" id="Database Changes" />
+ <window_info anchor="bottom" id="Version Control" />
+ <window_info active="true" anchor="bottom" id="Terminal" visible="true" weight="0.33877158" />
+ <window_info anchor="bottom" id="Event Log" side_tool="true" />
+ <window_info anchor="bottom" id="Message" order="0" />
+ <window_info anchor="bottom" id="Find" order="1" />
+ <window_info anchor="bottom" id="Run" order="2" />
+ <window_info anchor="bottom" id="Debug" order="3" weight="0.4" />
+ <window_info anchor="bottom" id="Cvs" order="4" weight="0.25" />
+ <window_info anchor="bottom" id="Inspection" order="5" weight="0.4" />
+ <window_info anchor="bottom" id="TODO" order="6" />
+ <window_info anchor="right" id="Palette" />
+ <window_info anchor="right" id="Theme Preview" />
+ <window_info anchor="right" id="Maven" />
+ <window_info anchor="right" id="Capture Analysis" />
+ <window_info anchor="right" id="Palette	" />
+ <window_info anchor="right" id="Database" />
+ <window_info anchor="right" id="Commander" internal_type="SLIDING" order="0" type="SLIDING" weight="0.4" />
+ <window_info anchor="right" id="Ant Build" order="1" weight="0.25" />
+ <window_info anchor="right" content_ui="combo" id="Hierarchy" order="2" weight="0.25" />
+ </layout>
+ </component>
+ <component name="TypeScriptGeneratedFilesManager">
+ <option name="version" value="1" />
+ </component>
+ <component name="VgoProject">
+ <integration-enabled>true</integration-enabled>
+ </component>
+ <component name="editorHistoryManager">
+ <entry file="file://$PROJECT_DIR$/EsClient.go">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="-1843">
+ <caret line="60" column="39" selection-start-line="60" selection-start-column="32" selection-end-line="60" selection-end-column="39" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/EsClient_test.go">
+ <provider selected="true" editor-type-id="text-editor" />
+ </entry>
+ <entry file="file://$PROJECT_DIR$/EsApi.go">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="312">
+ <caret line="319" column="45" selection-start-line="319" selection-start-column="38" selection-end-line="319" selection-end-column="45" />
+ <folding>
+ <element signature="e#16#126#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ </component>
+ <component name="masterDetails">
+ <states>
+ <state key="ProjectJDKs.UI">
+ <settings>
+ <last-edited>1.8</last-edited>
+ <splitter-proportions>
+ <option name="proportions">
+ <list>
+ <option value="0.2" />
+ </list>
+ </option>
+ </splitter-proportions>
+ </settings>
+ </state>
+ </states>
+ </component>
+</project>
\ No newline at end of file
diff --git a/EsApi.go b/EsApi.go
index 850fdf5..246b57a 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -300,4 +300,53 @@
capturetable = append(capturetable, source["id"].(string))
}
return capturetable
+}
+
+//鑾峰彇搴曞簱浜哄憳ID
+func GetDbpersonsId(compareArgs protomsg.CompareArgs,indexName string, serverIp string, serverPort string) (source map[string][]string) {
+ queryStr := ""
+ queryBody := compareArgs.InputValue
+ //妫�绱㈡
+ if queryBody != "" {
+ queryStr = "\"must\":[{\"multi_match\":{\"query\":\"" + queryBody + "\",\"fields\":[\"personName^1.5\",\"age^1.5\",\"idCard^1.5\",\"phoneNum^1.5\",\"sex^2.0\",\"reserved^2.0\"]," +
+ "\"type\":\"cross_fields\",\"operator\":\"OR\",\"slop\":0,\"prefix_length\":0,\"max_expansions\":50,\"zero_terms_query\":\"NONE\",\"auto_generate_synonyms_phrase_query\":true,\"fuzzy_transpositions\":true,\"boost\":1}}],"
+ }
+ //鍒ゆ柇搴撹〃ID
+ tableId := compareArgs.Tabs
+ esTableId := ""
+ esTableIdStr := ""
+ if tableId != nil && len(tableId) > 0 {
+ esTableId = strings.Replace(strings.Trim(fmt.Sprint(tableId), "[]"), " ", "\",\"", -1)
+ esTableIdStr = "{\"terms\":{\"tableId\":[\"" + esTableId + "\"]}}"
+ }
+
+ prama := "{" +
+ "\"size\":\"100000000\"," +
+ "\"query\":{\"bool\":{" + queryStr +
+ "\"filter\":[" +
+ esTableIdStr +
+ "]}}," +
+ "\"_source\":[\"id\",\"tableId\"]" +
+ "}"
+
+ url := "http://" + serverIp + ":" + serverPort +
+ "/" + indexName + "/_search?search_type=dfs_query_then_fetch"
+ fmt.Println(url)
+ fmt.Println(prama)
+ buf, err := EsReq("POST", url,[]byte(prama))
+ if err != nil {
+ fmt.Println("http request videoUrlInfo info is err!")
+ return
+ }
+ sources, err := Sourcelist(buf)
+ if err != nil {
+ return
+ }
+ tabsource := make(map[string][]string)
+ for _, source := range sources{
+ tableId := source["tableId"].(string)
+ id := source["id"].(string)
+ tabsource[tableId] = append(tabsource[tableId], id)
+ }
+ return tabsource
}
\ No newline at end of file
--
Gitblit v1.8.0