Explorar o código

修复项目多包字段类型不一致 导致无法生索引

wcc hai 1 ano
pai
achega
da686f39ab
Modificáronse 2 ficheiros con 30 adicións e 30 borrados
  1. 29 29
      createEsIndex/common.toml
  2. 1 1
      createEsIndex/project_es.go

+ 29 - 29
createEsIndex/common.toml

@@ -7,38 +7,38 @@
 
 [db]
 [db.mongoB] ## bidding标讯数据
-#    addr = "127.0.0.1:27083"
-#    dbname = "qfw"
-#    coll = "bidding"
-#    size = 15
-#    user = "SJZY_RWbid_ES"
-#    password = "SJZY@B4i4D5e6S"
-#    direct = true
-
-    addr = "192.168.3.206:27002"    ## 测试环境
-    dbname = "qfw_data"
+    addr = "127.0.0.1:27083"
+    dbname = "qfw"
     coll = "bidding"
     size = 15
-    user = "root"
-    password = "root"
+    user = "SJZY_RWbid_ES"
+    password = "SJZY@B4i4D5e6S"
     direct = true
 
-[db.mongoP] ## projectset 项目信息
-    addr = "192.168.3.206:27002"
-    dbname = "qfw_data"
-    coll = "projectset"
-    size = 15
-    user = "root"
-    password = "root"
-
-#    addr = "127.0.0.1:27080"
-#    dbname = "qfw"
-#    coll = "projectset_20230904"
+#    addr = "192.168.3.206:27002"    ## 测试环境
+#    dbname = "qfw_data"
+#    coll = "bidding"
 #    size = 15
-#    user = ""
-#    password = ""
+#    user = "root"
+#    password = "root"
 #    direct = true
 
+[db.mongoP] ## projectset 项目信息
+#    addr = "192.168.3.206:27002"
+#    dbname = "qfw_data"
+#    coll = "projectset"
+#    size = 15
+#    user = "root"
+#    password = "root"
+
+    addr = "127.0.0.1:27080"
+    dbname = "qfw"
+    coll = "projectset_20230904"
+    size = 15
+    user = ""
+    password = ""
+    direct = true
+
 [db.mongoQ] ##  winner
     addr = "192.168.3.206:27002"
     dbname = "mixdata"
@@ -76,11 +76,11 @@
     bucketname = "topjy"
     filesize = 500000  ## 单位字节,附件总字节长度限制;超过就不再读取
 [db.es]
-#    addr = "http://127.0.0.1:19805"      ## 正常bidding 链接
-    addr = "http://192.168.3.149:9201"      ## 测试环境 bidding 链接
+    addr = "http://127.0.0.1:19908"      ## 正常bidding 链接
+#    addr = "http://192.168.3.149:9201"      ## 测试环境 bidding 链接
 #    addrp = "http://192.168.3.149:9201"    ##  采集使用的单机版地址
-#    username = "es_all"
-#    password = "TopJkO2E_d1x"
+    username = "jybid"
+    password = "Top2023_JEB01i@31"
     size = 5
     indexb = "bidding"
 #    indextmp = "bidding_temporary"       ## 临时索引,其他程序需要;目前已不需要

+ 1 - 1
createEsIndex/project_es.go

@@ -151,7 +151,7 @@ func projectTask(data []byte, mapInfo map[string]interface{}) {
 					newTmp["_id"] = mongodb.BsonIdToSId(tmp["_id"])
 					newTmp["id"] = mongodb.BsonIdToSId(tmp["_id"])
 				} else {
-					if fieldval := tmp[f]; reflect.TypeOf(fieldval).String() != ftype {
+					if fieldval := tmp[f]; reflect.TypeOf(fieldval).String() != ftype && ftype != "" {
 						continue
 					} else {
 						if fieldval != "" {