elasticutil.go 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374
  1. package elastic
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "log"
  6. "net/url"
  7. "reflect"
  8. "runtime"
  9. "strconv"
  10. "strings"
  11. "sync"
  12. "time"
  13. es "sfbase/olivere/elastic.v1"
  14. )
  15. //检索库服务地址
  16. var addrs []string
  17. var LocCity = map[string]string{}
  18. var SIZE = 30
  19. const (
  20. QStr = `{"query":{"bool":{"must":[$and],"must_not":[],
  21. "should":[$or],"minimum_should_match" : 1}}}`
  22. )
  23. var pool chan *es.Client
  24. var ntimeout int
  25. var syncPool sync.Pool
  26. //初始化全文检索
  27. func InitElastic(addr string) {
  28. InitElasticSize(addr, SIZE)
  29. }
  30. //自定义HttpClient
  31. /**
  32. var httpclient = &http.Client{Transport: &http.Transport{
  33. Dial: func(netw, addr string) (net.Conn, error) {
  34. deadline := time.Now().Add(5000 * time.Millisecond)
  35. c, err := net.DialTimeout(netw, addr, 10000*time.Millisecond)
  36. if err != nil {
  37. return nil, err
  38. }
  39. tcp_conn := c.(*net.TCPConn)
  40. tcp_conn.SetKeepAlive(false)
  41. tcp_conn.SetDeadline(deadline)
  42. return tcp_conn, nil
  43. },
  44. DisableKeepAlives: true, //不保持,这样才能释放
  45. }}
  46. **/
  47. //var op = es.SetHttpClient(httpclient)
  48. var poolsize = int32(20)
  49. //n倍的池
  50. func InitElasticSize(addr string, size int) {
  51. poolsize = int32(3 * size)
  52. pool = make(chan *es.Client, poolsize)
  53. for _, s := range strings.Split(addr, ",") {
  54. addrs = append(addrs, s)
  55. }
  56. for i := 0; i < size; i++ {
  57. client, _ := es.NewClient(es.SetURL(addrs...), es.SetMaxRetries(2), es.SetSniff(false))
  58. pool <- client
  59. }
  60. }
  61. //关闭连接
  62. func DestoryEsConn(client *es.Client) {
  63. select {
  64. case pool <- client:
  65. break
  66. case <-time.After(time.Second * 1):
  67. if client != nil {
  68. client.Stop()
  69. }
  70. client = nil
  71. }
  72. }
  73. var (
  74. lastTime = int64(0)
  75. lastTimeLock = &sync.Mutex{}
  76. )
  77. //获取连接
  78. func GetEsConn() *es.Client {
  79. select {
  80. case c := <-pool:
  81. if c == nil || !c.IsRunning() {
  82. log.Println("new esclient.", len(pool))
  83. client, err := es.NewClient(es.SetURL(addrs...),
  84. es.SetMaxRetries(2), es.SetSniff(false))
  85. if err == nil && client.IsRunning() {
  86. return client
  87. }
  88. }
  89. return c
  90. case <-time.After(time.Second * 4):
  91. //超时
  92. ntimeout++
  93. lastTimeLock.Lock()
  94. defer lastTimeLock.Unlock()
  95. //12秒后允许创建链接
  96. c := time.Now().Unix() - lastTime
  97. if c > 12 {
  98. lastTime = time.Now().Unix()
  99. log.Println("add client..", len(pool))
  100. c, _ := es.NewClient(es.SetURL(addrs...), es.SetMaxRetries(2), es.SetSniff(false))
  101. go func() {
  102. for i := 0; i < 2; i++ {
  103. client, _ := es.NewClient(es.SetURL(addrs...), es.SetMaxRetries(2), es.SetSniff(false))
  104. pool <- client
  105. }
  106. }()
  107. return c
  108. }
  109. return nil
  110. }
  111. }
  112. //保存对象
  113. func Save(index, itype string, obj interface{}) bool {
  114. client := GetEsConn()
  115. defer DestoryEsConn(client)
  116. defer func() {
  117. if r := recover(); r != nil {
  118. log.Println("[E]", r)
  119. for skip := 1; ; skip++ {
  120. _, file, line, ok := runtime.Caller(skip)
  121. if !ok {
  122. break
  123. }
  124. go log.Printf("%v,%v\n", file, line)
  125. }
  126. }
  127. }()
  128. _, err := client.Index().Index(index).Type(itype).BodyJson(objToMap(obj)).Do()
  129. if err != nil {
  130. log.Println("保存到ES出错", err.Error(), obj)
  131. return false
  132. } else {
  133. return true
  134. }
  135. }
  136. //通用查询
  137. //{"query": {"bool":{"must":[{"query_string":{"default_field":"name","query":"*"}}]}}}
  138. //{"query":{"bool":{"must":{"match":{"content":{"query":"fulltextsearch","operator":"and"}}},"should":[{"match":{"content":{"query":"Elasticsearch","boost":3}}},{"match":{"content":{"query":"Lucene","boost":2}}}]}}}
  139. //prefix
  140. //{"query":{"match":{"title":{"query":"brownfox","operator":"and"}}}} //默认为or
  141. //{"query":{"multi_match":{"query":"PolandStreetW1V","type":"most_fields","fields":["*_street","city^2","country","postcode"]}}}
  142. //{"query":{"wildcard":{"postcode":"W?F*HW"}}}
  143. //{"query":{"regexp":{"postcode":"W[0-9].+"}}}
  144. //{"query":{"filtered":{"filter":{"range":{"price":{"gte":10000}}}}},"aggs":{"single_avg_price":{"avg":{"field":"price"}}}}
  145. //{"query":{"match":{"make":"ford"}},"aggs":{"colors":{"terms":{"field":"color"}}}}//查fork有几种颜色
  146. //过滤器不会计算相关度的得分,所以它们在计算上更快一些
  147. //{"query":{"filtered":{"query":{"match_all":{}},"filter":{"range":{"balance":{"gte":20000,"lte":30000}}}}}}
  148. //{"query":{"match_all":{}},"from":10,"size":10,"_source":["account_number","balance"],"sort":{"balance":{"order":"desc"}}}
  149. //{"query":{"match_phrase":{"address":"milllane"}}}和match不同会去匹配整个短语,相当于must[]
  150. func Get(index, itype, query string) *[]map[string]interface{} {
  151. //log.Println("query -- ", query)
  152. client := GetEsConn()
  153. defer func() {
  154. go DestoryEsConn(client)
  155. }()
  156. var res []map[string]interface{}
  157. if client != nil {
  158. defer func() {
  159. if r := recover(); r != nil {
  160. log.Println("[E]", r)
  161. for skip := 1; ; skip++ {
  162. _, file, line, ok := runtime.Caller(skip)
  163. if !ok {
  164. break
  165. }
  166. go log.Printf("%v,%v\n", file, line)
  167. }
  168. }
  169. }()
  170. searchResult, err := client.Search().Index(index).Type(itype).Source(query).Do()
  171. if err != nil {
  172. log.Println("从ES查询出错", err.Error())
  173. return nil
  174. }
  175. if searchResult.Hits != nil {
  176. resNum := len(searchResult.Hits.Hits)
  177. if resNum < 5000 {
  178. res = make([]map[string]interface{}, resNum)
  179. for i, hit := range searchResult.Hits.Hits {
  180. //d := json.NewDecoder(bytes.NewBuffer(*hit.Source))
  181. //d.UseNumber()
  182. //d.Decode(&res[i])
  183. parseErr := json.Unmarshal(*hit.Source, &res[i])
  184. if parseErr == nil && hit.Highlight != nil && res[i] != nil {
  185. res[i]["highlight"] = map[string][]string(hit.Highlight)
  186. }
  187. }
  188. } else {
  189. log.Println("查询结果太多,查询到:", resNum, "条")
  190. }
  191. }
  192. }
  193. return &res
  194. }
  195. func GetOA(index, itype, query string) (*[]map[string]interface{}, int) {
  196. //log.Println("query -- ", query)
  197. client := GetEsConn()
  198. defer func() {
  199. go DestoryEsConn(client)
  200. }()
  201. var res []map[string]interface{}
  202. var resNum int
  203. if client != nil {
  204. defer func() {
  205. if r := recover(); r != nil {
  206. log.Println("[E]", r)
  207. for skip := 1; ; skip++ {
  208. _, file, line, ok := runtime.Caller(skip)
  209. if !ok {
  210. break
  211. }
  212. go log.Printf("%v,%v\n", file, line)
  213. }
  214. }
  215. }()
  216. searchResult, err := client.Search().Index(index).Type(itype).Source(query).Do()
  217. if err != nil {
  218. log.Println("从ES查询出错", err.Error())
  219. return nil, 0
  220. }
  221. if searchResult.Hits != nil {
  222. resNum = len(searchResult.Hits.Hits)
  223. if resNum < 5000 {
  224. res = make([]map[string]interface{}, resNum)
  225. for i, hit := range searchResult.Hits.Hits {
  226. //d := json.NewDecoder(bytes.NewBuffer(*hit.Source))
  227. //d.UseNumber()
  228. //d.Decode(&res[i])
  229. parseErr := json.Unmarshal(*hit.Source, &res[i])
  230. if parseErr == nil && hit.Highlight != nil && res[i] != nil {
  231. res[i]["highlight"] = map[string][]string(hit.Highlight)
  232. }
  233. }
  234. } else {
  235. log.Println("查询结果太多,查询到:", resNum, "条")
  236. }
  237. }
  238. }
  239. return &res, resNum
  240. }
  241. func GetNoLimit(index, itype, query string) *[]map[string]interface{} {
  242. //log.Println("query -- ", query)
  243. client := GetEsConn()
  244. defer DestoryEsConn(client)
  245. var res []map[string]interface{}
  246. if client != nil {
  247. defer func() {
  248. if r := recover(); r != nil {
  249. log.Println("[E]", r)
  250. for skip := 1; ; skip++ {
  251. _, file, line, ok := runtime.Caller(skip)
  252. if !ok {
  253. break
  254. }
  255. go log.Printf("%v,%v\n", file, line)
  256. }
  257. }
  258. }()
  259. searchResult, err := client.Search().Index(index).Type(itype).Source(query).Do()
  260. if err != nil {
  261. log.Println("从ES查询出错", err.Error())
  262. return nil
  263. }
  264. if searchResult.Hits != nil {
  265. resNum := len(searchResult.Hits.Hits)
  266. res = make([]map[string]interface{}, resNum)
  267. for i, hit := range searchResult.Hits.Hits {
  268. json.Unmarshal(*hit.Source, &res[i])
  269. }
  270. }
  271. }
  272. return &res
  273. }
  274. //分页查询
  275. //{"name":"张三","$and":[{"age":{"$gt":10}},{"age":{"$lte":20}}]}
  276. //fields直接是 `"_id","title"`
  277. func GetPage(index, itype, query, order, field string, start, limit int) *[]map[string]interface{} {
  278. return Get(index, itype, MakeQuery(query, order, field, start, limit))
  279. }
  280. //openapi
  281. func GetOAPage(index, itype, query, order, field string, start, limit int) (*[]map[string]interface{}, int) {
  282. return GetOA(index, itype, MakeQuery(query, order, field, start, limit))
  283. }
  284. var SR = strings.Replace
  285. func MakeQuery(query, order, fileds string, start, limit int) string {
  286. res := AnalyQuery(query, "", QStr)
  287. if len(res) > 10 {
  288. res = SR(SR(SR(SR(res, ",$and", "", -1), "$and", "", -1), ",$or", "", -1), "$or", "", -1)
  289. if len(fileds) > 0 {
  290. //"_source":["account_number","balance"]
  291. res = res[:len(res)-1] + `,"_source":[` + fileds + "]}"
  292. }
  293. //{"name":-1,"age":1}
  294. if len(order) > 0 {
  295. res = res[:len(res)-1] + `,"sort":[` + SR(SR(SR(SR(order, ",", "},{", -1), " ", "", -1), ":-1", `:"desc"`, -1), ":1", `:"asc"`, -1) + `]}`
  296. }
  297. if start > -1 {
  298. res = res[:len(res)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  299. }
  300. return res
  301. }
  302. return ""
  303. }
  304. //{"name":"aaa"}
  305. func AnalyQuery(query interface{}, parent string, result string) string {
  306. m := make(map[string]interface{})
  307. if q1, ok := query.(string); ok {
  308. json.Unmarshal([]byte(q1), &m)
  309. } else if q2, ok2 := query.(map[string]interface{}); ok2 {
  310. m = q2
  311. }
  312. if len(parent) == 0 {
  313. for k, v := range m {
  314. if k == "$and" || k == "$or" {
  315. temps := ""
  316. if map1, ok := v.([]interface{}); ok {
  317. for i := 0; i < len(map1); i++ {
  318. temps += "," + AnalyQuery(map1[i], k, "")
  319. }
  320. }
  321. if len(temps) > 0 {
  322. temps = temps[1:]
  323. }
  324. result = SR(result, k, temps+","+k, 1)
  325. } else {
  326. switch reflect.TypeOf(v).String() {
  327. case "string":
  328. if strings.Index(k, "TERM_") == 0 {
  329. result = SR(result, "$and", `{"term":{"`+SR(k, "TERM_", "", 1)+`":"`+fmt.Sprintf("%v", v)+`"}},$and`, 1)
  330. } else {
  331. result = SR(result, "$and", `{"query_string":{"default_field":"`+k+`","query":"`+fmt.Sprintf("%v", v)+`"}},$and`, 1)
  332. }
  333. case "int", "int8", "int32", "int64", "float32", "float64":
  334. if strings.Index(k, "TERM_") == 0 {
  335. result = SR(result, "$and", `{"term":{"`+SR(k, "TERM_", "", 1)+`":`+fmt.Sprintf("%v", v)+`}},$and`, 1)
  336. } else {
  337. result = SR(result, "$and", `{"query_string":{"default_field":"`+k+`","query":`+fmt.Sprintf("%v", v)+`}},$and`, 1)
  338. }
  339. default:
  340. result = SR(result, "$and", AnalyQuery(v, k, "")+",$and", 1)
  341. }
  342. }
  343. }
  344. return result
  345. } else {
  346. for k, v := range m {
  347. if k == "$in" {
  348. s := ""
  349. if map1, ok := v.([]interface{}); ok {
  350. for i := 0; i < len(map1); i++ {
  351. s += "," + `"` + fmt.Sprintf("%v", map1[i]) + `"`
  352. }
  353. }
  354. if len(s) > 0 {
  355. s = s[1:]
  356. }
  357. return `{"terms":{"` + parent + `":[` + s + `]}}`
  358. } else if strings.Contains(k, "$lt") || strings.Contains(k, "$gt") {
  359. return `{"range":{"` + parent + `":{"` + SR(k, "$", "", 1) + `":` + fmt.Sprintf("%v", v) + `}}}`
  360. } else {
  361. switch reflect.TypeOf(v).String() {
  362. case "string":
  363. if strings.Index(k, "TERM_") == 0 {
  364. return `{"term":{"` + SR(k, "TERM_", "", 1) + `":"` + fmt.Sprintf("%v", v) + `"}}`
  365. } else {
  366. return `{"query_string":{"default_field":"` + k + `","query":"` + fmt.Sprintf("%v", v) + `"}}`
  367. }
  368. case "int", "int8", "int32", "int64", "float32", "float64":
  369. if strings.Index(k, "TERM_") == 0 {
  370. return `{"term":{"` + SR(k, "TERM_", "", 1) + `":` + fmt.Sprintf("%v", v) + `}}`
  371. } else {
  372. return `{"query_string":{"default_field":"` + k + `","query":` + fmt.Sprintf("%v", v) + `}}`
  373. }
  374. default:
  375. return AnalyQuery(v, k, result)
  376. }
  377. }
  378. }
  379. }
  380. return result
  381. }
  382. func GetByIdField(index, itype, id, fields string) *map[string]interface{} {
  383. client := GetEsConn()
  384. defer DestoryEsConn(client)
  385. if client != nil {
  386. defer func() {
  387. if r := recover(); r != nil {
  388. log.Println("[E]", r)
  389. for skip := 1; ; skip++ {
  390. _, file, line, ok := runtime.Caller(skip)
  391. if !ok {
  392. break
  393. }
  394. go log.Printf("%v,%v\n", file, line)
  395. }
  396. }
  397. }()
  398. query := `{"query":{"term":{"_id":"` + id + `"}}`
  399. if len(fields) > 0 {
  400. query = query + `,"_source":[` + fields + `]`
  401. }
  402. query = query + "}"
  403. searchResult, err := client.Search().Index(index).Type(itype).Source(query).Do()
  404. if err != nil {
  405. log.Println("从ES查询出错", err.Error())
  406. return nil
  407. }
  408. var res map[string]interface{}
  409. if searchResult.Hits != nil {
  410. resNum := len(searchResult.Hits.Hits)
  411. if resNum == 1 {
  412. res = make(map[string]interface{})
  413. for _, hit := range searchResult.Hits.Hits {
  414. json.Unmarshal(*hit.Source, &res)
  415. }
  416. return &res
  417. }
  418. }
  419. }
  420. return nil
  421. }
  422. //根据id来查询文档
  423. func GetById(index, itype string, ids ...string) *[]map[string]interface{} {
  424. client := GetEsConn()
  425. defer DestoryEsConn(client)
  426. var res []map[string]interface{}
  427. if client != nil {
  428. defer func() {
  429. if r := recover(); r != nil {
  430. log.Println("[E]", r)
  431. for skip := 1; ; skip++ {
  432. _, file, line, ok := runtime.Caller(skip)
  433. if !ok {
  434. break
  435. }
  436. go log.Printf("%v,%v\n", file, line)
  437. }
  438. }
  439. }()
  440. query := es.NewIdsQuery().Ids(ids...)
  441. searchResult, err := client.Search().Index(index).Type(itype).Query(&query).Do()
  442. if err != nil {
  443. log.Println("从ES查询出错", err.Error())
  444. return nil
  445. }
  446. if searchResult.Hits != nil {
  447. resNum := len(searchResult.Hits.Hits)
  448. if resNum < 5000 {
  449. res = make([]map[string]interface{}, resNum)
  450. for i, hit := range searchResult.Hits.Hits {
  451. json.Unmarshal(*hit.Source, &res[i])
  452. }
  453. } else {
  454. log.Println("查询结果太多,查询到:", resNum, "条")
  455. }
  456. }
  457. }
  458. return &res
  459. }
  460. //删除某个索引,根据查询
  461. func Del(index, itype string, query interface{}) bool {
  462. client := GetEsConn()
  463. defer DestoryEsConn(client)
  464. b := false
  465. if client != nil {
  466. defer func() {
  467. if r := recover(); r != nil {
  468. log.Println("[E]", r)
  469. for skip := 1; ; skip++ {
  470. _, file, line, ok := runtime.Caller(skip)
  471. if !ok {
  472. break
  473. }
  474. go log.Printf("%v,%v\n", file, line)
  475. }
  476. }
  477. }()
  478. var err error
  479. if qs, ok := query.(string); ok {
  480. temp := es.BoolQuery{
  481. QueryStrings: qs,
  482. }
  483. _, err = client.DeleteByQuery().Index(index).Type(itype).Query(temp).Do()
  484. } else if qi, ok2 := query.(es.Query); ok2 {
  485. _, err = client.DeleteByQuery().Index(index).Type(itype).Query(qi).Do()
  486. }
  487. if err != nil {
  488. log.Println("删除索引出错:", err.Error())
  489. } else {
  490. b = true
  491. }
  492. }
  493. return b
  494. }
  495. //根据语句更新对象
  496. func Update(index, itype, id string, updateStr string) bool {
  497. client := GetEsConn()
  498. defer DestoryEsConn(client)
  499. b := false
  500. if client != nil {
  501. defer func() {
  502. if r := recover(); r != nil {
  503. log.Println("[E]", r)
  504. for skip := 1; ; skip++ {
  505. _, file, line, ok := runtime.Caller(skip)
  506. if !ok {
  507. break
  508. }
  509. go log.Printf("%v,%v\n", file, line)
  510. }
  511. }
  512. }()
  513. var err error
  514. _, err = client.Update().Index(index).Type(itype).Id(id).Script(updateStr).ScriptLang("groovy").Do()
  515. if err != nil {
  516. log.Println("更新检索出错:", err.Error())
  517. } else {
  518. b = true
  519. }
  520. }
  521. return b
  522. }
  523. func BulkUpdate(index, itype string, ids []string, updateStr string) {
  524. client := GetEsConn()
  525. defer DestoryEsConn(client)
  526. if client != nil {
  527. defer func() {
  528. if r := recover(); r != nil {
  529. log.Println("[E]", r)
  530. for skip := 1; ; skip++ {
  531. _, file, line, ok := runtime.Caller(skip)
  532. if !ok {
  533. break
  534. }
  535. go log.Printf("%v,%v\n", file, line)
  536. }
  537. }
  538. }()
  539. for _, id := range ids {
  540. _, err := client.Update().Index(index).Type(itype).Id(id).Script(updateStr).ScriptLang("groovy").Do()
  541. if err != nil {
  542. log.Println("更新检索出错:", err.Error())
  543. }
  544. }
  545. }
  546. }
  547. //根据id删除索引对象
  548. func DelById(index, itype, id string) bool {
  549. client := GetEsConn()
  550. defer DestoryEsConn(client)
  551. b := false
  552. if client != nil {
  553. defer func() {
  554. if r := recover(); r != nil {
  555. log.Println("[E]", r)
  556. for skip := 1; ; skip++ {
  557. _, file, line, ok := runtime.Caller(skip)
  558. if !ok {
  559. break
  560. }
  561. go log.Printf("%v,%v\n", file, line)
  562. }
  563. }
  564. }()
  565. var err error
  566. _, err = client.Delete().Index(index).Type(itype).Id(id).Do()
  567. if err != nil {
  568. log.Println("更新检索出错:", err.Error())
  569. } else {
  570. b = true
  571. }
  572. }
  573. return b
  574. }
  575. //先删除后增
  576. func UpdateNewDoc(index, itype string, obj ...interface{}) bool {
  577. client := GetEsConn()
  578. defer DestoryEsConn(client)
  579. b := false
  580. if client != nil {
  581. defer func() {
  582. if r := recover(); r != nil {
  583. log.Println("[E]", r)
  584. for skip := 1; ; skip++ {
  585. _, file, line, ok := runtime.Caller(skip)
  586. if !ok {
  587. break
  588. }
  589. go log.Printf("%v,%v\n", file, line)
  590. }
  591. }
  592. }()
  593. var err error
  594. for _, v := range obj {
  595. tempObj := objToMap(v)
  596. id := fmt.Sprintf("%v", (*tempObj)["_id"])
  597. client.Delete().Index(index).Type(itype).Id(id).Do()
  598. _, err = client.Index().Index(index).Type(itype).BodyJson(tempObj).Do()
  599. if err != nil {
  600. log.Println("保存到ES出错", err.Error())
  601. } else {
  602. b = true
  603. }
  604. }
  605. }
  606. return b
  607. }
  608. //把地市代码转为地市
  609. func getLoc(code string, res *map[string]string) (loc string) {
  610. switch len(code) {
  611. case 6:
  612. loc = (*res)[code[:2]] + " " + (*res)[code[:4]] + " " + (*res)[code]
  613. break
  614. case 4:
  615. loc = (*res)[code[:2]] + " " + (*res)[code]
  616. break
  617. case 2:
  618. loc = (*res)[code]
  619. break
  620. }
  621. return
  622. }
  623. func ConverData(ent *map[string]interface{}) map[string]interface{} {
  624. tmp := *ent
  625. id64, _ := tmp["ID"].(int64)
  626. ids := fmt.Sprintf("%d", id64)
  627. tmp2 := make(map[string]interface{})
  628. tmp2["ID"] = ids
  629. tmp2["_id"] = tmp["_id"]
  630. tmp2["Area"] = tmp["Area"]
  631. tmp2["LeRep"] = tmp["LeRep"]
  632. tmp2["RegNo"] = tmp["RegNo"]
  633. tmp2["EntType"] = tmp["EntType"]
  634. tmp2["EntName"] = tmp["EntName"]
  635. tmp2["EntTypeName"] = tmp["EntTypeName"]
  636. tmp2["Dom"] = tmp["Dom"]
  637. tmp2["EstDate"] = tmp["EstDate"]
  638. tmp2["OpStateName"] = tmp["OpStateName"]
  639. tmp2["OpScope"] = tmp["OpScope"]
  640. tmp2["OpState"] = tmp["OpState"]
  641. tmp2["s_submitid"] = tmp["s_submitid"]
  642. tmp2["l_submittime"] = tmp["l_submittime"]
  643. tmp2["s_submitname"] = tmp["s_submitname"]
  644. tmp2["RegCapCurName"] = tmp["RegCapCurName"]
  645. //增加营业状态排序
  646. if tmp2["OpState"] == "06" {
  647. tmp2["OpSint"] = true
  648. } else {
  649. tmp2["OpSint"] = false
  650. }
  651. tmp2["OpLocDistrict"] = tmp["OpLocDistrict"]
  652. //增加代码转名称
  653. tmpLoc, _ := tmp["OpLocDistrict"].(string)
  654. tmp2["OpLocDistrictName"] = getLoc(tmpLoc, &LocCity)
  655. tmp2["RecCap"] = tmp["RecCap"]
  656. tmp2["RegCap"] = tmp["RegCap"]
  657. tmp2["IndustryPhy"] = tmp["IndustryPhy"]
  658. tmp2["IndustryPhyName"] = tmp["IndustryPhyName"]
  659. tmp2["RegOrg"] = tmp["RegOrg"]
  660. tmp2["RegOrgName"] = tmp["RegOrgName"]
  661. tmp2["Tel"] = tmp["Tel"]
  662. tmp2["CompForm"] = tmp["CompForm"]
  663. tmp2["CompFormName"] = tmp["CompFormName"]
  664. //增加异常名录标记 Ycml可能是bool也可能是string
  665. Ycmlb, _ := tmp["Ycml"].(bool)
  666. Ycmls, _ := tmp["Ycml"].(string)
  667. if Ycmlb || Ycmls == "1" {
  668. tmp2["Ycml"] = true
  669. } else {
  670. tmp2["Ycml"] = false
  671. }
  672. //增加年报联系信息
  673. if tmp["Nb_email"] != nil {
  674. tmp2["Nb_email"] = tmp["Nb_email"]
  675. }
  676. if tmp["Nb_tel"] != nil {
  677. tmp2["Nb_tel"] = tmp["Nb_tel"]
  678. }
  679. if tmp["Nb_addr"] != nil {
  680. tmp2["Nb_addr"] = tmp["Nb_addr"]
  681. }
  682. s_synopsis := tmp["s_synopsis"]
  683. if s_synopsis == nil {
  684. s_synopsis = ""
  685. }
  686. tmp2["s_synopsis"] = s_synopsis //企业简介
  687. //股东
  688. stock := getStock(tmp["investor"])
  689. tmp2["stock"] = stock
  690. tmp2["LegCerNO"] = tmp["LegCerNO"]
  691. if tmp["s_microwebsite"] != nil {
  692. tmp2["s_microwebsite"] = tmp["s_microwebsite"]
  693. }
  694. tmp2["SourceType"] = tmp["SourceType"] //数据来源
  695. s_servicenames := tmp["s_servicenames"]
  696. if s_servicenames == nil {
  697. s_servicenames = ""
  698. }
  699. tmp2["s_servicenames"] = s_servicenames //服务名称
  700. s_action := tmp["s_action"]
  701. if s_action == nil {
  702. s_action = "N"
  703. }
  704. tmp2["s_action"] = s_action
  705. tmp2["s_persion"] = tmp["s_persion"]
  706. tmp2["s_mobile"] = tmp["s_mobile"]
  707. tmp2["s_enturl"] = tmp["s_enturl"]
  708. tmp2["s_weixin"] = tmp["s_weixin"]
  709. tmp2["s_avatar"] = tmp["s_avatar"]
  710. return tmp2
  711. }
  712. func getStock(obj interface{}) string {
  713. stock := ""
  714. if ns, ok := obj.([]interface{}); ok {
  715. stock = " "
  716. for _, ns1 := range ns {
  717. if nn, ok1 := ns1.(map[string]interface{}); ok1 {
  718. tmp := fmt.Sprintf("%s", nn["Inv"])
  719. if strings.Index(stock, tmp) < 0 {
  720. stock += tmp + " "
  721. }
  722. }
  723. }
  724. }
  725. return stock
  726. }
  727. func BulkSave(index, itype string, obj *[]map[string]interface{}, isDelBefore bool) {
  728. client := GetEsConn()
  729. defer DestoryEsConn(client)
  730. if client != nil {
  731. defer func() {
  732. if r := recover(); r != nil {
  733. log.Println("[E]", r)
  734. for skip := 1; ; skip++ {
  735. _, file, line, ok := runtime.Caller(skip)
  736. if !ok {
  737. break
  738. }
  739. go log.Printf("%v,%v\n", file, line)
  740. }
  741. }
  742. }()
  743. req := client.Bulk()
  744. for _, v := range *obj {
  745. if isDelBefore {
  746. req = req.Add(es.NewBulkDeleteRequest().Index(index).Type(itype).Id(fmt.Sprintf("%v", v["_id"])))
  747. }
  748. req = req.Add(es.NewBulkIndexRequest().Index(index).Type(itype).Doc(v))
  749. }
  750. _, err := req.Do()
  751. if err != nil {
  752. log.Println("批量保存到ES出错", err.Error())
  753. }
  754. }
  755. }
  756. func Count(index, itype string, query interface{}) int64 {
  757. client := GetEsConn()
  758. defer DestoryEsConn(client)
  759. if client != nil {
  760. defer func() {
  761. if r := recover(); r != nil {
  762. log.Println("[E]", r)
  763. for skip := 1; ; skip++ {
  764. _, file, line, ok := runtime.Caller(skip)
  765. if !ok {
  766. break
  767. }
  768. go log.Printf("%v,%v\n", file, line)
  769. }
  770. }
  771. }()
  772. var qq es.Query
  773. if qs, ok := query.(string); ok {
  774. temp := es.BoolQuery{
  775. QueryStrings: qs,
  776. }
  777. qq = temp
  778. } else if qi, ok2 := query.(es.Query); ok2 {
  779. qq = qi
  780. }
  781. n, err := client.Count(index).Type(itype).Query(qq).Do()
  782. if err != nil {
  783. log.Println("统计出错", err.Error())
  784. }
  785. return n
  786. }
  787. return 0
  788. }
  789. //ngram精确查询
  790. /*
  791. {
  792. "query": {
  793. "bool": {
  794. "should": [
  795. {
  796. "bool":{
  797. "must":[
  798. { "multi_match": {
  799. "query": "智能",
  800. "type": "phrase",
  801. "fields": [
  802. "title"
  803. ],
  804. "analyzer": "my_ngram"
  805. }
  806. },{
  807. "multi_match": {
  808. "query": "机器",
  809. "type": "phrase",
  810. "fields": [
  811. "title"
  812. ],
  813. "analyzer": "my_ngram"
  814. }
  815. },{
  816. "multi_match": {
  817. "query": "2016",
  818. "type": "phrase",
  819. "fields": [
  820. "title"
  821. ],
  822. "analyzer": "my_ngram"
  823. }
  824. }
  825. ]
  826. }
  827. },
  828. {
  829. "bool":{
  830. "must":[
  831. { "multi_match": {
  832. "query": "河南",
  833. "type": "phrase",
  834. "fields": [
  835. "title"
  836. ],
  837. "analyzer": "my_ngram"
  838. }
  839. },{
  840. "multi_match": {
  841. "query": "工商",
  842. "type": "phrase",
  843. "fields": [
  844. "title"
  845. ],
  846. "analyzer": "my_ngram"
  847. }
  848. },{
  849. "multi_match": {
  850. "query": "2016",
  851. "type": "phrase",
  852. "fields": [
  853. "title"
  854. ],
  855. "analyzer": "my_ngram"
  856. }
  857. }
  858. ]
  859. }
  860. }
  861. ],"minimum_should_match": 1
  862. }
  863. },
  864. "_source": [
  865. "_id",
  866. "title"
  867. ],
  868. "from": 0,
  869. "size": 10,
  870. "sort": [{
  871. "publishtime": "desc"
  872. }]
  873. }
  874. */
  875. //"2016+智能+办公,"河南+工商"
  876. //["2016+智能+办公","河南+工商"]
  877. //QStr = `{"query":{"bool":{should":[$or],"minimum_should_match" : 1}}}`
  878. //{"bool":{"must":[]}}
  879. //{"multi_match": {"query": "$word","type": "phrase", "fields": [$field],"analyzer": "my_ngram"}}
  880. //"highlight": {"pre_tags": [""],"post_tags": [""],"fields": {"detail": {"fragment_size": 1,"number_of_fragments": 1},"title": {"fragment_size": 1,"number_of_fragments": 1}}}
  881. const (
  882. //此处最后少一个},正好NgramStr取[1:]多一个}
  883. FilterQuery = `{"query": {"filtered": {"filter": {"bool": {"must": [%s]}},%s}}`
  884. NgramStr = `{"query":{"bool":{"must":[%s],"should":[%s],"minimum_should_match": 1}}}`
  885. NgramMust = `{"bool":{"must":[%s]}}`
  886. NgramMustAndNot = `{"bool":{"must":[%s],"must_not":[%s]}}`
  887. minq = `{"multi_match": {"query": "%s","type": "phrase", "fields": [%s]}}`
  888. HL = `"highlight": {"pre_tags": [""],"post_tags": [""],"fields": {%s}}`
  889. highlightStr = `%s: {"fragment_size": %d,"number_of_fragments": 1}`
  890. FilterQuery_New = `{"query":{"bool":{"must": [%s%s%s],"should":[]}}}`
  891. MatchQueryString = `{"match": {%s: { "query":"%s", "operator": "and"}}}`
  892. HL_New = `"highlight": {"pre_tags": ["<HL>"],"post_tags": ["<HL>"],"fields": {%s}}`
  893. //数据查询高亮标记2019-07-10
  894. HL_MP = `"highlight": {"pre_tags": ["<HL>"],"post_tags": ["</HL>"],"fields": {%s}}`
  895. ik_highlightStr = `%s: {"fragment_size": %d,"number_of_fragments": 1,"require_field_match": true}`
  896. IK_pre_tags = `<font class=\"es-highlight\">`
  897. IK_post_tags = `</font>`
  898. HL_IK = `"highlight": {"pre_tags": ["` + IK_pre_tags + `"],"post_tags": ["` + IK_post_tags + `"],"fields": {%s}}`
  899. )
  900. //替换了"号
  901. func GetNgramQuery(query interface{}, mustquery, findfields string) (qstr string) {
  902. var words []string
  903. if q, ok := query.(string); ok {
  904. if q != "" {
  905. words = strings.Split(q, ",")
  906. }
  907. } else if q, ok := query.([]string); ok {
  908. words = q
  909. } else if q, ok := query.([]interface{}); ok {
  910. words = objArrToStringArr(q)
  911. }
  912. if words != nil {
  913. new_minq := fmt.Sprintf(minq, "%s", findfields)
  914. musts := []string{}
  915. for _, qs_words := range words {
  916. qws := strings.Split(qs_words, "+")
  917. mq := []string{}
  918. for _, qs_word := range qws {
  919. mq = append(mq, fmt.Sprintf(new_minq, ReplaceYH(qs_word)))
  920. }
  921. musts = append(musts, fmt.Sprintf(NgramMust, strings.Join(mq, ",")))
  922. }
  923. qstr = fmt.Sprintf(NgramStr, mustquery, strings.Join(musts, ","))
  924. //log.Println("ngram-query", qstr)
  925. } else {
  926. qstr = fmt.Sprintf(NgramStr, mustquery, "")
  927. }
  928. return
  929. }
  930. func GetNgramQuery_New(querystring, querymust interface{}, must, findfields string) (qstring string) {
  931. querymust_string := ""
  932. var wordsMust []string
  933. if q, ok := querymust.(string); ok {
  934. if q != "" {
  935. wordsMust = strings.Split(q, ",")
  936. }
  937. } else if q, ok := querymust.([]string); ok {
  938. wordsMust = q
  939. } else if q, ok := querymust.([]interface{}); ok {
  940. wordsMust = objArrToStringArr(q)
  941. }
  942. if wordsMust != nil {
  943. new_minq := fmt.Sprintf(minq, "%s", findfields)
  944. musts := []string{}
  945. for _, qs_wordsMust := range wordsMust {
  946. qws := strings.Split(qs_wordsMust, "+")
  947. mq := []string{}
  948. for _, qs_word := range qws {
  949. mq = append(mq, fmt.Sprintf(new_minq, qs_word))
  950. }
  951. musts = append(musts, fmt.Sprintf(NgramMust, strings.Join(mq, ",")))
  952. }
  953. querymust_string = strings.Join(musts, ",")
  954. }
  955. //log.Println("must", must, querymust_string)
  956. //querystring---------------------------------------------
  957. query_string := ""
  958. var querysShold []string
  959. if q, ok := querystring.(string); ok {
  960. if q != "" {
  961. querysShold = strings.Split(q, ",")
  962. }
  963. } else if q, ok := querystring.([]string); ok {
  964. querysShold = q
  965. } else if q, ok := querystring.([]interface{}); ok {
  966. querysShold = objArrToStringArr(q)
  967. }
  968. if querysShold != nil {
  969. for k, name := range strings.Split(findfields, ",") {
  970. for _, qs_querysShold := range querysShold {
  971. if k > 0 {
  972. query_string = query_string + "," + fmt.Sprintf(MatchQueryString, fmt.Sprint(name), qs_querysShold)
  973. } else {
  974. query_string = query_string + fmt.Sprintf(MatchQueryString, fmt.Sprint(name), qs_querysShold)
  975. }
  976. }
  977. }
  978. }
  979. //log.Println("querystring", query_string)
  980. if querymust_string == "" {
  981. qstring = fmt.Sprintf(FilterQuery_New, must, query_string, querymust_string)
  982. } else {
  983. qstring = fmt.Sprintf(FilterQuery_New, must, query_string, ","+querymust_string)
  984. }
  985. return
  986. }
  987. func GetByNgram(index, itype string, query interface{}, mustquery, findfields, order, fields string, start, limit int) *[]map[string]interface{} {
  988. return GetByNgramAll(index, itype, query, mustquery, findfields, order, fields, start, limit, false, false)
  989. }
  990. //增加高亮、过滤查询、高亮截取字数
  991. func GetByNgramOther(index, itype string, query interface{}, mustquery, findfields, order, fields string, start, limit int, highlight bool, filtermode bool, count int) *[]map[string]interface{} {
  992. defer catch()
  993. qstr := ""
  994. if mustquery != "" && filtermode {
  995. qstr = GetNgramQuery(query, "", findfields)
  996. qstr = fmt.Sprintf(FilterQuery, mustquery, qstr[1:])
  997. } else {
  998. qstr = GetNgramQuery(query, mustquery, findfields)
  999. }
  1000. if qstr != "" {
  1001. if highlight {
  1002. ws := []string{}
  1003. for _, w := range strings.Split(findfields, ",") {
  1004. ws = append(ws, fmt.Sprintf(highlightStr, w, count))
  1005. }
  1006. qstr = qstr[:len(qstr)-1] + `,` + fmt.Sprintf(HL, strings.Join(ws, ",")) + `}`
  1007. }
  1008. if len(fields) > 0 {
  1009. qstr = qstr[:len(qstr)-1] + `,"_source":[` + fields + "]}"
  1010. }
  1011. if len(order) > 0 {
  1012. qstr = qstr[:len(qstr)-1] + `,"sort":[` + SR(SR(SR(SR(order, ",", "},{", -1), " ", "", -1), ":-1", `:"desc"`, -1), ":1", `:"asc"`, -1) + `]}`
  1013. }
  1014. if start > -1 {
  1015. qstr = qstr[:len(qstr)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  1016. }
  1017. //log.Println("ngram-find", qstr)
  1018. return Get(index, itype, qstr)
  1019. } else {
  1020. return nil
  1021. }
  1022. }
  1023. //增加高亮、过滤查询
  1024. //替换了"号
  1025. func GetByNgramAll(index, itype string, query interface{}, mustquery, findfields, order, fields string, start, limit int, highlight bool, filtermode bool) *[]map[string]interface{} {
  1026. defer catch()
  1027. qstr := ""
  1028. if mustquery != "" && filtermode {
  1029. qstr = GetNgramQuery(query, "", findfields)
  1030. qstr = fmt.Sprintf(FilterQuery, mustquery, qstr[1:])
  1031. } else {
  1032. qstr = GetNgramQuery(query, mustquery, findfields)
  1033. }
  1034. if qstr != "" {
  1035. if highlight {
  1036. ws := []string{}
  1037. for _, w := range strings.Split(findfields, ",") {
  1038. ws = append(ws, fmt.Sprintf(highlightStr, w, 1))
  1039. }
  1040. qstr = qstr[:len(qstr)-1] + `,` + fmt.Sprintf(HL, strings.Join(ws, ",")) + `}`
  1041. }
  1042. if len(fields) > 0 {
  1043. qstr = qstr[:len(qstr)-1] + `,"_source":[` + fields + "]}"
  1044. }
  1045. if strings.HasPrefix(order, "CUSTOM_") {
  1046. qstr = qstr[:len(qstr)-1] + `,` + strings.TrimLeft(order, "CUSTOM_") + `}`
  1047. } else if len(order) > 0 {
  1048. qstr = qstr[:len(qstr)-1] + `,"sort":[` + SR(SR(SR(SR(order, ",", "},{", -1), " ", "", -1), ":-1", `:"desc"`, -1), ":1", `:"asc"`, -1) + `]}`
  1049. }
  1050. if start > -1 {
  1051. qstr = qstr[:len(qstr)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  1052. }
  1053. //log.Println("ngram-find", qstr)
  1054. return Get(index, itype, qstr)
  1055. } else {
  1056. return nil
  1057. }
  1058. }
  1059. //增加高亮、过滤查询
  1060. func GetByNgramAll_New(index, itype string, querystring, querymust interface{}, mustquery, findfields, order, fields string, start, limit int, highlight bool, filtermode bool) *[]map[string]interface{} {
  1061. defer catch()
  1062. qstr := ""
  1063. if filtermode {
  1064. qstr = GetNgramQuery_New(querystring, querymust, mustquery, findfields)
  1065. } else {
  1066. qstr = GetNgramQuery_New(querystring, "", mustquery, findfields)
  1067. }
  1068. if qstr != "" {
  1069. if highlight {
  1070. ws := []string{}
  1071. for _, w := range strings.Split(findfields, ",") {
  1072. ws = append(ws, w+`:{"force_source": true}`)
  1073. }
  1074. qstr = qstr[:len(qstr)-1] + `,` + fmt.Sprintf(HL_New, strings.Join(ws, ",")) + `}`
  1075. }
  1076. if len(fields) > 0 {
  1077. qstr = qstr[:len(qstr)-1] + `,"_source":[` + fields + "]}"
  1078. }
  1079. if len(order) > 0 {
  1080. qstr = qstr[:len(qstr)-1] + `,"sort":[` + SR(SR(SR(SR(order, ",", ",", -1), " ", "", -1), ":-1", `:"desc"`, -1), ":1", `:"asc"`, -1) + `]}`
  1081. }
  1082. if start > -1 {
  1083. qstr = qstr[:len(qstr)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  1084. }
  1085. //log.Println("ngram-find", order, qstr)
  1086. return Get(index, itype, qstr)
  1087. } else {
  1088. return nil
  1089. }
  1090. }
  1091. type KeyConfig struct {
  1092. Keys []string `json:"key"`
  1093. NotKeys []string `json:"notkey"`
  1094. InfoTypes []string `json:"infotype"`
  1095. Areas []string `json:"area"`
  1096. }
  1097. //替换了"号
  1098. func GetResForJY(index, itype string, keys []KeyConfig, allquery, findfields, SortQuery, fields string, start, limit int) *[]map[string]interface{} {
  1099. if len(keys) > 0 {
  1100. qstr := ""
  1101. new_minq := fmt.Sprintf(minq, "%s", findfields)
  1102. not_new_minq := fmt.Sprintf(minq, "%s", findfields) //排除词只查询标题
  1103. musts := []string{}
  1104. for _, qs_words := range keys {
  1105. mq := []string{}
  1106. notmq := []string{}
  1107. for _, qs_word := range qs_words.Keys {
  1108. mq = append(mq, fmt.Sprintf(new_minq, ReplaceYH(qs_word)))
  1109. /*
  1110. qs := AnalyzerWord("bidding", qs_word)
  1111. for _, qw := range qs {
  1112. mq = append(mq, fmt.Sprintf(new_minq, ReplaceYH(qw)))
  1113. }
  1114. */
  1115. }
  1116. for _, qs_word := range qs_words.NotKeys {
  1117. notmq = append(notmq, fmt.Sprintf(not_new_minq, ReplaceYH(qs_word)))
  1118. }
  1119. if len(qs_words.Areas) > 0 {
  1120. mq = append(mq, fmt.Sprintf(`{"terms":{"area":["%s"]}}`, strings.Join(qs_words.Areas, `","`)))
  1121. }
  1122. if len(qs_words.InfoTypes) > 0 {
  1123. mq = append(mq, fmt.Sprintf(`{"terms":{"toptype":["%s"]}}`, strings.Join(qs_words.InfoTypes, `","`)))
  1124. }
  1125. musts = append(musts, fmt.Sprintf(NgramMustAndNot, strings.Join(mq, ","), strings.Join(notmq, ",")))
  1126. }
  1127. qstr = fmt.Sprintf(NgramStr, "", strings.Join(musts, ","))
  1128. qstr = fmt.Sprintf(FilterQuery, allquery, qstr[1:])
  1129. ws := []string{}
  1130. for _, w := range strings.Split(findfields, ",") {
  1131. ws = append(ws, fmt.Sprintf(highlightStr, w, 1))
  1132. }
  1133. qstr = qstr[:len(qstr)-1] + `,` + fmt.Sprintf(HL, strings.Join(ws, ",")) + `}`
  1134. if len(fields) > 0 {
  1135. qstr = qstr[:len(qstr)-1] + `,"_source":[` + fields + "]}"
  1136. }
  1137. if len(SortQuery) > 0 {
  1138. qstr = qstr[:len(qstr)-1] + `,"sort":` + SortQuery + `}`
  1139. }
  1140. if start > -1 {
  1141. qstr = qstr[:len(qstr)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  1142. }
  1143. //log.Println("jy-ngram-find", qstr)
  1144. return Get(index, itype, qstr)
  1145. } else {
  1146. return nil
  1147. }
  1148. }
  1149. func ReplaceYH(src string) (rpl string) {
  1150. return strings.Replace(src, `"`, `\"`, -1)
  1151. }
  1152. //
  1153. func GetAllByNgram(index, itype, qstr, findfields, order, fields string, start, limit, count int, highlight bool) *[]map[string]interface{} {
  1154. if qstr != "" {
  1155. if highlight {
  1156. ws := []string{}
  1157. for _, w := range strings.Split(findfields, ",") {
  1158. ws = append(ws, fmt.Sprintf(highlightStr, w, count))
  1159. }
  1160. qstr = qstr[:len(qstr)-1] + `,` + fmt.Sprintf(HL, strings.Join(ws, ",")) + `}`
  1161. }
  1162. if len(fields) > 0 {
  1163. qstr = qstr[:len(qstr)-1] + `,"_source":[` + fields + "]}"
  1164. }
  1165. if len(order) > 0 {
  1166. qstr = qstr[:len(qstr)-1] + `,"sort":[` + SR(SR(SR(SR(order, ",", "},{", -1), " ", "", -1), ":-1", `:"desc"`, -1), ":1", `:"asc"`, -1) + `]}`
  1167. }
  1168. if start > -1 {
  1169. qstr = qstr[:len(qstr)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  1170. }
  1171. log.Println("GetAllByNgram:", qstr)
  1172. return Get(index, itype, qstr)
  1173. } else {
  1174. return nil
  1175. }
  1176. }
  1177. //数据标记2019-07-10
  1178. func GetAllByNgram_MP(index, itype, qstr, findfields, order, fields string, start, limit, count int, highlight bool) *[]map[string]interface{} {
  1179. if qstr != "" {
  1180. if highlight {
  1181. ws := []string{}
  1182. for _, w := range strings.Split(findfields, ",") {
  1183. ws = append(ws, fmt.Sprintf(highlightStr, w, count))
  1184. }
  1185. qstr = qstr[:len(qstr)-1] + `,` + fmt.Sprintf(HL_MP, strings.Join(ws, ",")) + `}`
  1186. }
  1187. if len(fields) > 0 {
  1188. qstr = qstr[:len(qstr)-1] + `,"_source":[` + fields + "]}"
  1189. }
  1190. if len(order) > 0 {
  1191. qstr = qstr[:len(qstr)-1] + `,"sort":[` + SR(SR(SR(SR(order, ",", "},{", -1), " ", "", -1), ":-1", `:"desc"`, -1), ":1", `:"asc"`, -1) + `]}`
  1192. }
  1193. if start > -1 {
  1194. qstr = qstr[:len(qstr)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  1195. }
  1196. // log.Println("GetAllByNgram:", qstr)
  1197. return Get(index, itype, qstr)
  1198. } else {
  1199. return nil
  1200. }
  1201. }
  1202. //ik 分词
  1203. func GetAllByIk(index, itype, qstr, findfields, order, fields string, start, limit, count int, highlight bool) *[]map[string]interface{} {
  1204. if qstr != "" {
  1205. if highlight {
  1206. ws := []string{}
  1207. for _, w := range strings.Split(findfields, ",") {
  1208. ws = append(ws, fmt.Sprintf(ik_highlightStr, w, count))
  1209. }
  1210. qstr = qstr[:len(qstr)-1] + `,` + fmt.Sprintf(HL_IK, strings.Join(ws, ",")) + `}`
  1211. }
  1212. if len(fields) > 0 {
  1213. qstr = qstr[:len(qstr)-1] + `,"_source":[` + fields + "]}"
  1214. }
  1215. if len(order) > 0 {
  1216. qstr = qstr[:len(qstr)-1] + `,"sort":[` + SR(SR(SR(SR(order, ",", "},{", -1), " ", "", -1), ":-1", `:"desc"`, -1), ":1", `:"asc"`, -1) + `]}`
  1217. }
  1218. if start > -1 {
  1219. qstr = qstr[:len(qstr)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  1220. }
  1221. //log.Println("GetAllByNgram:", qstr)
  1222. return Get(index, itype, qstr)
  1223. } else {
  1224. return nil
  1225. }
  1226. }
  1227. //分词
  1228. func AnalyzerWord(index, word string) (result []string) {
  1229. client := GetEsConn()
  1230. defer DestoryEsConn(client)
  1231. result = []string{}
  1232. p := url.Values{}
  1233. p["text"] = []string{word}
  1234. p["analyzer"] = []string{"ik"}
  1235. by, err := client.PerformRequest("GET", "/"+index+"/_analyze", p, nil)
  1236. if err != nil {
  1237. log.Println("AnalyzerWord Error:", err)
  1238. return
  1239. }
  1240. b, err := by.Body.MarshalJSON()
  1241. if err != nil {
  1242. log.Println("AnalyzerWord MarshalJSON Error:", err)
  1243. return
  1244. }
  1245. var res map[string][]map[string]interface{}
  1246. err = json.Unmarshal(b, &res)
  1247. if err != nil {
  1248. log.Println("AnalyzerWord Unmarshal Error:", err)
  1249. return
  1250. }
  1251. if res == nil {
  1252. return
  1253. }
  1254. for _, v := range res["tokens"] {
  1255. token, _ := v["token"].(string)
  1256. if token != "" {
  1257. result = append(result, token)
  1258. }
  1259. }
  1260. return
  1261. }
  1262. func GetResForJYView(index, itype string, keys []KeyConfig, allquery, findfields, SortQuery, fields string, start, limit int) *[]map[string]interface{} {
  1263. if len(keys) > 0 {
  1264. qstr := ""
  1265. new_minq := fmt.Sprintf(minq, "%s", findfields)
  1266. not_new_minq := fmt.Sprintf(minq, "%s", findfields) //排除词只查询标题
  1267. musts := []string{}
  1268. for _, qs_words := range keys {
  1269. mq := []string{}
  1270. notmq := []string{}
  1271. for _, qs_word := range qs_words.Keys {
  1272. mq = append(mq, fmt.Sprintf(new_minq, ReplaceYH(qs_word)))
  1273. }
  1274. for _, qs_word := range qs_words.NotKeys {
  1275. notmq = append(notmq, fmt.Sprintf(not_new_minq, ReplaceYH(qs_word)))
  1276. }
  1277. if len(qs_words.Areas) > 0 {
  1278. mq = append(mq, fmt.Sprintf(`{"terms":{"area":["%s"]}}`, strings.Join(qs_words.Areas, `","`)))
  1279. }
  1280. if len(qs_words.InfoTypes) > 0 {
  1281. mq = append(mq, fmt.Sprintf(`{"terms":{"toptype":["%s"]}}`, strings.Join(qs_words.InfoTypes, `","`)))
  1282. }
  1283. musts = append(musts, fmt.Sprintf(NgramMustAndNot, strings.Join(mq, ","), strings.Join(notmq, ",")))
  1284. }
  1285. qstr = fmt.Sprintf(NgramStr, "", strings.Join(musts, ","))
  1286. qstr = fmt.Sprintf(FilterQuery, allquery, qstr[1:])
  1287. ws := []string{}
  1288. for _, w := range strings.Split(findfields, ",") {
  1289. ws = append(ws, fmt.Sprintf(highlightStr, w, 1))
  1290. }
  1291. qstr = qstr[:len(qstr)-1] + `,` + fmt.Sprintf(HL, strings.Join(ws, ",")) + `}`
  1292. if len(fields) > 0 {
  1293. qstr = qstr[:len(qstr)-1] + `,"_source":[` + fields + "]}"
  1294. }
  1295. if len(SortQuery) > 0 {
  1296. qstr = qstr[:len(qstr)-1] + `,"sort":` + SortQuery + `}`
  1297. }
  1298. if start > -1 {
  1299. qstr = qstr[:len(qstr)-1] + `,"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(limit) + "}"
  1300. }
  1301. return Get(index, itype, qstr)
  1302. } else {
  1303. return nil
  1304. }
  1305. }