备份

listen_data/src/main.go

@@ -20,9 +20,7 @@ var (
 	prepareData								[]map[string]interface{}
 	startRun,startSend								string
 )
-
 func initMgo()  {
-
 	saveconf := sysconfig["save_mgodb"].(map[string]interface{})
 	save_c_name = qu.ObjToString(saveconf["coll"])
 	save_mgo = &MongodbSim{
@@ -41,7 +39,6 @@ func initMgo()  {
 	}
 	site_mgo.InitPool()
 
-
 	pconf := sysconfig["python_mgodb"].(map[string]interface{})
 	python_c_name = qu.ObjToString(pconf["coll"])
 	python_mgo = &MongodbSim{
@@ -54,12 +51,8 @@ func initMgo()  {
 		UserName:	 "dataZY",
 	}
 	python_mgo.InitPool()
-
-
 	site_unique_name = qu.ObjToString(sysconfig["site_unique_name"])
 	xlsx_name = qu.ObjToString(sysconfig["xlsx_name"])
-
-
 	log.Println(site_unique_name,xlsx_name)
 
 }
@@ -115,33 +108,6 @@ func main()  {
 	}
 	save_mgo.InitPool()
 
-	//save_mgo = &MongodbSim{
-	//	MongodbAddr: "172.17.145.163:27083,172.17.4.187:27082",
-	//	DbName:      "qfw",
-	//	Size:        10,
-	//	UserName: "zhengkun",
-	//	Password: "zk@123123",
-	//}
-	//save_mgo.InitPool()
-
-
-	//MysqlTool = &Mysql{
-	//	Address: "127.0.0.1:3306",
-	//	UserName: "root",
-	//	PassWord: "123456",
-	//	DBName: "zhengkun",
-	//}
-	//MysqlTool.Init()
-
-
-	MysqlTool = &Mysql{
-		Address: "192.168.3.109:4000",
-		UserName: "jianyu",
-		PassWord: "top@123",
-		DBName: "zktest",
-	}
-	MysqlTool.Init()
-
 	/*
 		repairYiXieChaData() 		//医械查
 		dealWithClassData()			//AB 匹配
@@ -150,9 +116,6 @@ func main()  {
 
 	*/
 
-
-	decodeJyUrl()
-
 	return
 
 

listen_data/src/zkmethod.go

@@ -40,24 +40,6 @@ var MysqlTool	*Mysql
 
 //解密
 func decodeJyUrl()  {
-	//zk@123123   zhengkun
-	//arr := []string{
-	//	"ALWY1wJYzweBSs4GWRjZHUoCDI4QCJ0XFJ0KC8COD0da3lzeiNUCWs%3D",
-	//	"AOaY1wEczweLyosI2hjZHUoCDI4QCJ0XFJ0KS8gPS4NfFZzUwlUCVM%3D",
-	//	"ACIY1wEcy4vJys4GXxjZHUoCDI4QCJ0XFJ0Pyg3LDogYGhzbh1UCb4%3D",
-	//	"ABJY1wEfT0OOD8vAnd2cHU8CjACHjJjXHRzKzg7Ji4dY2BzdA1UCY0%3D",
-	//	"AvgY1wEfT0vAj84NHtyZ08wCDNfESJgAX9kKw5RPT0wZFRzZCNUCXc%3D",
-	//	"AbgY1wEcy4vMyMsNHhjZHUoCDI4QCJ0XFJ0Pyg3KD03YFNzbytUCd0%3D",
-	//	"APUY1wEfT0OODk6En92cHU8CjACHjJjXHRzKzg7KT0eWX5wDwFUCV0%3D",
-	//	"AGcY1wEczweLyosJHxjZHUoCDI4QCJ0XFJ0KS8gPS5FXlJzVTNUCao%3D",
-	//	"ANIY1wEfT0%2FOD04GWNyZ08wCDNfESJgAX9kKwUwOSEwdFJzUFpUCW8%3D",
-	//	"APJY1wEfykoBSo7JHd2c2IkCycoQBZjZmtgK1gsPzoed2BzcCdUCcY%3D",
-	//}
-	//for _,v :=range arr{
-	//	var Decode  = qu.CommonDecodeArticle("content", v)
-	//	log.Debug(Decode[0])
-	//}
-	//return
 	test := "ABCY1wFYj1YIDY7I2d2cHU8CjACHjJjXHRzKCg7KyEgVXlzfwlUCbM%3D"
 	var Decode  = qu.CommonDecodeArticle("content", test)
 	log.Debug(Decode[0])
@@ -73,23 +55,6 @@ func encodeJyUrl()  {
 
 
 
-func mysqlTest() {
-
-	marksql := `create table if not exists test (
-    id int(20) primary key auto_increment,
-    name varchar(255) not null unique,
-    name1 varchar (255) not null default ""
-    )ENGINE=InnoDB DEFAULT CHARSET=utf8;`
-	smt, _ := MysqlTool.DB.Prepare(marksql)
-	smt.Exec()
-
-	MysqlTool.Insert("test", map[string]interface{}{
-		"name":"222",
-	})
-
-}
-
-
 func dealWithBingTuanData() {
 	f, err := os.Open("1.txt")
 	if err != nil {

process_ medical/src/main.go → process_medical/src/main.go

@@ -38,10 +38,7 @@ func init()  {
 
 
 func main()  {
-	//备份
-
-
-
+	saveAreaMysql()
 }
 
 

process_ medical/src/medical_bidding.go → process_medical/src/medical_bidding.go

@@ -9,6 +9,8 @@ import (
 	"time"
 )
 
+var proNameDict = map[string]string{}
+
 //生成两个 mysql 表
 func saveBiddingPurMysql() {
 	log.Debug("分析数据-保存两个mysql表...")
@@ -106,6 +108,7 @@ func dealWithPurData(tmp map[string]interface{},tmpid string){
 	for _,v:=range p_list{
 		data := map[string]interface{}{}
 		product_name := qu.ObjToString(v["product_name"])
+
 		data["info_id"] = info_id
 		data["bid_name"] = qu.ObjToString(v["itemname"])
 		data["product_name"] = product_name
@@ -212,6 +215,7 @@ func dealWithPurData(tmp map[string]interface{},tmpid string){
 }
 
 
+
 //导出源数据... 163-qfw
 func exportUsefulPurMysql() {
 	sess := qy_mgo.GetMgoConn()
@@ -261,20 +265,82 @@ func exportUsefulPurMysql() {
 				new_data["subscopeclass"] = tmp["subscopeclass"]
 			}
 			save_mgo.Save(o_bidding_coll,new_data)
-			//company_id:=""
-			////根据s_winner-关联company_id
-			//if s_winner != "" && !strings.Contains(s_winner,",") {
-			//	c_data := save_mgo.FindOne(o_company_coll, map[string]interface{}{
-			//		"company_name":s_winner,
-			//	})
-			//	if c_data!=nil && len(c_data)>2 {
-			//		company_id = qu.ObjToString(c_data["company_id"])
-			//	}
-			//}
-			//new_data["company_id"] = company_id
+
 		}
 		tmp = make(map[string]interface{})
 	}
 
 	log.Debug("is bidding over ",total,isok)
+}
+
+
+
+
+
+
+
+
+
+//调试- 指定数据
+func testMaiRuiData() {
+	query := "SELECT product_name FROM f_product WHERE company_name LIKE CONCAT('%',?,'%')"
+	proinfo := MysqlTool.SelectBySql(query, "迈瑞")
+	for _,v := range *proinfo{
+		product_name := qu.ObjToString(v["product_name"])
+		if proNameDict[product_name]==""{
+			proNameDict[product_name] = product_name
+		}
+	}
+	log.Debug("涉及",len(proNameDict),"产品信息")
+
+	sess := save_mgo.GetMgoConn()
+	defer save_mgo.DestoryMongoConn(sess)
+	q,total:=map[string]interface{}{},0
+	it := sess.DB(save_mgo.DbName).C("112233").Find(&q).Iter()
+	for tmp := make(map[string]interface{}); it.Next(&tmp);total++{
+		if total%1000==0 {
+			log.Debug("curent index ",total)
+		}
+		info_id := qu.ObjToString(tmp["info_id"])
+		data := save_mgo.FindOne(o_bidding_coll, map[string]interface{}{
+			"info_id":info_id,
+		})
+		dealWithBidData(data,info_id)
+		dealWithPurData(data,info_id)
+		tmp = make(map[string]interface{})
+	}
+}
+
+func exportMaiRuiInfoId(){
+	query := "SELECT product_name FROM f_product WHERE company_name LIKE CONCAT('%',?,'%')"
+	proinfo := MysqlTool.SelectBySql(query, "迈瑞")
+	log.Debug(len(*proinfo))
+	proNameArr :=[]string{}
+	proNameDict := map[string]string{}
+	for _,v := range *proinfo{
+		product_name := qu.ObjToString(v["product_name"])
+		if proNameDict[product_name]==""{
+			proNameDict[product_name] = product_name
+			proNameArr = append(proNameArr,product_name)
+		}
+	}
+
+	//812个产品名称 - -
+	bid_infoDict := map[string]string{}
+	for k,v := range proNameArr {
+		if k%100==0 {
+			log.Debug("当前：",len(bid_infoDict))
+		}
+		q := "SELECT info_id FROM f_bidproduct WHERE product_name=?"
+		infoArr := MysqlTool.SelectBySql(q, v)
+		for _,info := range *infoArr {
+			info_id := qu.ObjToString(info["info_id"])
+			if bid_infoDict[info_id]==""{
+				bid_infoDict[info_id] = info_id
+				save_mgo.Save("a_mairui", map[string]interface{}{
+					"info_id":info_id,
+				})
+			}
+		}
+	}
 }

process_ medical/src/medical_vdata.go → process_medical/src/medical_vdata.go

@@ -44,7 +44,9 @@ func saveAreaMysql() {
 		}
 		tmpid := BsonTOStringId(tmp["_id"])
 		delete(tmp,"_id")
-		insertMysqlData("v_area",tmp,tmpid)
+		code := qu.IntAll(tmp["code"])
+		tmp["code"] = code
+		insertMysqlData("v_area_copy",tmp,tmpid)
 		tmp = make(map[string]interface{})
 	}
 	log.Debug("is over ",total)