存储更新

src/config.json

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

src/jy/extract/extract.go

@@ -86,7 +86,7 @@ func StartExtractTaskId(taskId string) bool {
 		ext.Id = taskId
 		ext.InitTaskInfo()
 	}
-	ext.TaskInfo.DB = db.MgoFactory(5, 10, 120, ext.TaskInfo.FromDbAddr, ext.TaskInfo.FromDB)
+	ext.TaskInfo.DB = db.MgoFactory(10, 30, 120, ext.TaskInfo.FromDbAddr, ext.TaskInfo.FromDB)
 	ext.InitRulePres()
 	ext.InitRuleBacks()
 	ext.InitRuleCore()
@@ -740,7 +740,6 @@ func AnalysisSaveResult(j *ju.Job, task *TaskInfo) {
 	}
 	//从排序结果中取值
 	tmp := map[string]interface{}{} //抽取值
-	resulttmp := tmp                //保存结果
 	for key, val := range values {
 		for _, v := range val { //取第一个
 			if v.Key != "" {
@@ -749,6 +748,8 @@ func AnalysisSaveResult(j *ju.Job, task *TaskInfo) {
 			}
 		}
 	}
+	//resulttmp := tmp
+	resulttmp, _ := ju.DeepCopy(tmp).(map[string]interface{}) //保存结果
 	resulttmp["result"] = result
 	if len(j.BlockPackage) > 0 { //分包详情
 		resulttmp["epackage"] = j.BlockPackage