采购单位、中标单位，支持迁移新集群地址

createEsIndex/buyertask.go

@@ -177,6 +177,13 @@ func buyerOnce() {
 				if err != nil {
 					log.Info("buyerOnce", zap.Any("InsertOrUpdate err", err))
 				}
+				// 华为云新集群，存储标讯、项目、凭安数据
+				if config.Conf.DB.Es.Addr3 != "" {
+					err = Es3.InsertOrUpdate(config.Conf.DB.Es.IndexBuyer, arrEs)
+					if err != nil {
+						log.Info("buyerOnce", zap.Any("Addr3 InsertOrUpdate err", err))
+					}
+				}
 			}
 		}
 

createEsIndex/init.go

@@ -470,7 +470,7 @@ func InitRule() {
 	//军队类
 	jundui := "解放军,军队,部队,国防,国防部,军委,军事,战争,军用,军史,军营,野战,后勤保障部,武器装备,装备发展部,战区,陆军,海军,空军,火箭军,战略支援部队,联勤保障,军事法院,军事检察院,军事法庭,卫生勤务,卫勤,运输投送,军需,卫戍区,集团军,训练基地," +
 		"卫星发射中心,试训基地,试验训练基地,国防教育,舰,舰队,舰载,航空兵,雷达兵,电子对抗,军装备研究院,炮兵,空降兵,烈士,舟桥,边海防," +
-		"人民防空,人防,防空,边海空防,海防,边疆,边防团,国防动员,军区,省军区,军分区,警备区,武装部,人武部,军区&!点军区,经济动员," +
+		"人民防空,人防,防空,边海空防,海防,边疆,边防团,国防动员,省军区,军分区,警备区,武装部,人武部,军区&!点军区,经济动员," +
 		"科技动员,信息动员,交通动员,卫生动员,征兵,民兵,预备役,转业,军人招待所,军休所,兵员,战争院,军事科学院,国防大学,国防科技大学,国防科大,陆军指挥学院,陆军工程大学,步兵学院,装甲兵学院,炮兵防空兵学院,航空兵学院,陆军特种作战学院,边海防学院,防化学院,陆军勤务学院,陆军军事交通学院,海军指挥学院,海军工程大学,海军大连舰艇学院,海军潜艇学院,海军航空大学,海军勤务学院,海军士官学校,空军指挥学院,空军工程大学,空军航空大学,空军预警学院,空军哈尔滨飞行学院,空军石家庄飞行学院,空军西安飞行学院,空军勤务学院,空军通信士官学校,火箭军指挥学院,火箭军工程大学,火箭军士官学校,战略支援军航天工程大学,战略支援军信息工程大学,武装警察部队指挥学院,武警指挥学院,武装警察部队工程大学,武警工程大学,武装警察部队警官学院,武警警官学院,武装警察部队特种警察学院,武警特种警察学院,武装警察部队后勤学院,武警后勤学院,武装警察部队士官学校,武警士官学校,中国人民解放军国际关系学院,国际关系学院,国防信息学院,解放军西安通信学院,解放军电子工程学院,中国人民解放军理工大学,国防大学政法学院,国防大学政治学院,参谋学院,军事文化学院,后装保障学院,气象海洋学院,军医大学," +
 		"军&&医院,部队&&医院,军医大学附属&&医院,安庆医院,武警&&医院,医学中心&&军"
 	tagJ1 := TagMatching{
@@ -536,7 +536,7 @@ func InitRule() {
 		"融通农业发展（北京）,融通农业发展（沈阳）,融通农业发展（南京）,融通农业发展（乌鲁木齐）,融通农业发展（济南）,融通农业发展（成都）,融通农业发展（昆明）,融通农业发展（武汉）,融通农业发展（广州）," +
 		"融通农业发展（杭州）,融通农发惠君（青岛）,融通粮食产业发展,中国融通财产保险,融通特种物流,融通安保服务,融通安防,融通安保,融通物流,融发能源,融通运输,融通被装发展,陕西融通军民服务社," +
 		"融通海油能源,融通运输（上海）,融通运输（广州）,宜宾五商股权投资基金（有限合伙）,中海油山东销售,中化物产（青岛）,莱州市中海油销售,东营中海油交发油品,淄博赛福橡塑,总参谋部第六十研究所," +
-		"中国融通科学研究院集团,融通科学院,融通科学研究院,融通资源（海南）,融通资源安徽,融通传媒,北京君通银轮宾馆,新华工程咨询,天津 272 医院,正定 256 医院,邯郸 285 医院,开封 155 医院,镇江 359 医院,中国融通上海 411 医院,中国融通安庆医院"
+		"中国融通科学研究院集团,融通科学院,融通科学研究院,融通资源（海南）,融通资源安徽,融通传媒,北京君通银轮宾馆,新华工程咨询,中国融通安庆医院,上海411医院,安庆116医院,淮安82医院,莆田95医院,鹰潭184医院,镇江359医院,苏州100医院,连云港149医院,马鞍山86医院,宁德442医院,郴州198医院,柳州158医院,曲靖69医院,成都81骨科医院,新疆474医院,临夏7医院,泰安88医院,淄博148医院,包头291医院,沈阳121医院,开封155医院,郑州460医院,信阳154医院,天津272医院,正定256医院,邯郸285医院"
 	tagT1 := TagMatching{
 		tagName:     "融通类",
 		matchField:  []string{"buyer"},

createEsIndex/main.go

@@ -30,7 +30,7 @@ var (
 	MgoS  *mongodb.MongodbSim
 	Mysql *mysqldb.Mysql
 
-	Es, Es2, Es3 *elastic.Elastic
+	Es, Es2, Es3 *elastic.Elastic //Es3 迁移华为云新集群地址
 	//PreEs        = make(map[string]*elastic.Elastic, 0) //预处理 索引客户端
 
 	UdpClient  udp.UdpClient

createEsIndex/winnertask.go

@@ -160,6 +160,10 @@ SELECT
 				if len(arrEs) >= EsBulkSize {
 					tmps := arrEs
 					Es.BulkSave(config.Conf.DB.Es.IndexWinner, tmps)
+					// 华为云新集群，存储标讯、项目、凭安数据
+					if config.Conf.DB.Es.Addr3 != "" {
+						Es3.BulkSave(config.Conf.DB.Es.IndexWinner, tmps)
+					}
 					arrEs = []map[string]interface{}{}
 				}
 				winerEsLock.Unlock()
@@ -181,6 +185,10 @@ SELECT
 	if len(arrEs) > 0 {
 		tmps := arrEs
 		Es.BulkSave(config.Conf.DB.Es.IndexWinner, tmps)
+		// 华为云新集群，存储标讯、项目、凭安数据
+		if config.Conf.DB.Es.Addr3 != "" {
+			Es3.BulkSave(config.Conf.DB.Es.IndexWinner, tmps)
+		}
 		arrEs = []map[string]interface{}{}
 	}