winner和buyer存取redis加前缀

src/config.json

@@ -5,5 +5,6 @@
     "dbname": "extract_v3",
 	"redis":"buyer=192.168.3.18:6379,winner=192.168.3.18:6379",
     "saveresult": true,
-    "fieldscore": true
+    "fieldscore": true,
+	"buyerwinner": true
 } 

src/jy/admin/buyermanager/buyermanage.go

@@ -50,7 +50,7 @@ func AddBuyer(c *gin.Context) {
 	b := Mgo.Update("buyer", `{"name":"`+buyername+`"}`, map[string]interface{}{
 		"$set": update}, true, false)
 	if b { //新增的直接更新buyer redis
-		p := redis.PutCKV("buyer", buyername, 1)
+		p := redis.PutCKV("buyer", "buyer_"+buyername, 1)
 		log.Println("Add--Update buyer redis：", p)
 	}
 	c.JSON(200, gin.H{"rep": b})
@@ -83,7 +83,7 @@ func AuditBuyer(c *gin.Context) {
 		"$set": update}, true, false)
 	//更新redis
 	if b {
-		p := redis.PutCKV("buyer", name, 1)
+		p := redis.PutCKV("buyer", "buyer_"+name, 1)
 		log.Println("Audit--Update buyer redis：", p)
 		Mgo.Del("buyer_new", `{"_id":"`+_id+`"}`)
 	}

src/jy/admin/winnermanager/winnermanager.go

@@ -44,7 +44,7 @@ func AddWinner(c *gin.Context) {
 	b := Mgo.Update("winner", `{"name":"`+winnername+`"}`, map[string]interface{}{
 		"$set": update}, true, false)
 	if b { //新增的直接更新winner redis
-		p := redis.PutCKV("winner", winnername, 1)
+		p := redis.PutCKV("winner", "winner_"+winnername, 1)
 		log.Println("Add--Update winner redis：", p)
 	}
 	c.JSON(200, gin.H{"rep": b})
@@ -73,7 +73,7 @@ func AuditWinner(c *gin.Context) {
 		"$set": update}, true, false)
 	//更新redis
 	if b {
-		p := redis.PutCKV("winner", name, 1)
+		p := redis.PutCKV("winner", "winner_"+name, 1)
 		log.Println("Audit--Update winner redis：", p)
 		Mgo.Del("winner_new", `{"_id":"`+_id+`"}`)
 	}

src/jy/extract/extract.go

@@ -765,8 +765,9 @@ func AnalysisSaveResult(j *ju.Job, task *TaskInfo) {
 		}
 	}
 	//采购单位库，中标单位库
-	BuyerAndWinner(resulttmp)
-
+	if ju.Config["buyerwinner"].(bool) {
+		BuyerAndWinner(resulttmp)
+	}
 	b, p, c, d := TransmitData(resulttmp, _id) //抽取省份城市
 	//log.Println("抽取省份，城市，县结果=====", b, p, c, d)
 	resulttmp["district"] = d
@@ -829,7 +830,7 @@ func BuyerAndWinner(resulttmp map[string]interface{}) {
 	//buyer
 	for _, buyer := range buyerarr {
 		//log.Println("buyer---------------", buyer)
-		i := redis.GetInt("buyer", buyer)
+		i := redis.GetInt("buyer", "buyer_"+buyer)
 		//log.Println("iiiiiiiiiii", i)
 		if i == 0 {
 			buyernewdata, _ := db.Mgo.FindOne("buyer_new", `{"s_name":"`+buyer+`"}`)
@@ -842,7 +843,7 @@ func BuyerAndWinner(resulttmp map[string]interface{}) {
 	//winner
 	for _, winner := range winnerarr {
 		//log.Println("winner---------------", winner)
-		j := redis.GetInt("winner", winner)
+		j := redis.GetInt("winner", "winner_"+winner)
 		//log.Println("jjjjjjjjjjjj", j)
 		if j == 0 {
 			winnernewdata, _ := db.Mgo.FindOne("winner_new", `{"s_name":"`+winner+`"}`)