医院整体流程

整合 → 清洗 → 判重 → 合并新增表1 → 补标识 → 校验名录→ 判重 → 合并新增表2 → 删除临时表（待定：未删）

fieldproject_medical/data_preparation/src/hospital/hospital.go

@@ -10,9 +10,6 @@ var (
 	merge_hospital_coll_1 = "zktest_hospital_info_merge"
 	merge_hospital_coll_2 = "zktest_hospital_info_merge_new"
 	history_hospital_coll = "f_hospital_codes"
-
-	//merge_coll_second = "zktest_hospital_info_merge_new"
-	//history_coll      = "f_hospital_codes"
 )
 
 func RunHospital() {

fieldproject_medical/data_preparation/src/hospital/hospital_extra.go

@@ -34,7 +34,7 @@ func compareHospital() {
 			})
 			if len(dataArr) > 0 {
 				b, finally_name, finally_alias := compareHospitalNameData(name, dataArr, alias)
-				if b {
+				if b { //是否可以补充医疗库
 					isok++
 					//根据返回结果~更新当前表数据
 					info_id := class.BsonTOStringId(tmp["_id"])
@@ -82,9 +82,7 @@ func compareHospital() {
 					class.Save_Mgo.UpdateById(merge_hospital_coll_1, info_id, map[string]interface{}{
 						"$set": info_update,
 					})
-					if info_update == nil {
-						log.Debug("异常~~~")
-					}
+
 				}
 			}
 		}
@@ -100,17 +98,21 @@ func compareHospitalNameData(search_name string, dataArr []map[string]interface{
 	for _, v := range dataArr {
 		hospital_name := qu.ObjToString(v["hospital_name"])
 		alias_name := qu.ObjToString(v["alias_name"])
-		if alias_name == "" || hospital_name == "" {
+		if hospital_name == "" {
 			continue
 		}
 		aliasArr := strings.Split(alias_name, ",")
+		//匹配原则~是否优化为...
 		b := compareAliasName(search_name, aliasArr)
+		if search_name == hospital_name {
+			b = true
+		}
 		if b {
-			//合并别名信息
 			new_alias_str := mergeAliasName(search_name, hospital_name, source_alias, alias_name)
 			return true, hospital_name, new_alias_str
 		}
 	}
+
 	return false, "", ""
 }
 

fieldproject_medical/data_preparation/src/hospital/hospital_reset.go

@@ -2,7 +2,7 @@ package hospital
 
 import (
 	"class"
-	"github.com/go-xweb/log"
+	log "github.com/donnie4w/go-logger/logger"
 	qu "qfw/util"
 )
 

fieldproject_medical/data_preparation/src/main.go

@@ -4,6 +4,7 @@ import (
 	"class"
 	"flag"
 	log "github.com/donnie4w/go-logger/logger"
+	"hospital"
 	"net/http"
 	"time"
 )
@@ -16,7 +17,7 @@ func main() {
 	//处理医院
 	//hospital.RunHospital()
 	//暂时需要线上补充~数据
-	//hospital.RunHospitalOnline()
+	hospital.RunHospitalOnline()
 	//导入信息~医疗关联sql表
 	//hospital.ExportHospitalInfoToMysql()