xuzhiheng 1 gadu atpakaļ
vecāks
revīzija
af68974a59
1 mainītis faili ar 8 papildinājumiem un 0 dzēšanām
  1. 8 0
      customerdata/src/task.go

+ 8 - 0
customerdata/src/task.go

@@ -328,6 +328,13 @@ func (c *Customer) EsConGetDataV7(stype string, esCon *esv.EsV7) {
 									continue
 								}
 							}
+							if c.AppId == "jyOi5XQQoCAwRZTkhKFTZk" {
+								site := qu.ObjToString(tmp["site"])
+								if site == "宁波市建设工程全过程质量监管系统" {
+									log.Println("宁波市建设工程全过程质量监管系统过滤", id)
+									continue
+								}
+							}
 							if c.AppId != "jyMwBXQAIBBwJcTUhIFR99" {
 								isExists, err := redis.Exists("datag", c.AppId+"_"+id)
 								if err != nil {
@@ -869,6 +876,7 @@ func (d *Department) GetSearchRules(cid, stype string, idRange, idRanges bson.M)
 			SR.CustomerID = cid
 			SR.DepartmentID = d.ID
 			SR.ExtFieldType = qu.IntAll(sr["i_extfieldstype"])
+			SR.ExactRule = qu.ObjToString(sr["s_exactRule"])
 			//SR.RuleData = &sync.Map{}
 			esquery := qu.ObjToString(sr["s_esquery"])
 			if IsNewSql != 0 {