|
@@ -930,19 +930,6 @@ func AnalysisSaveFlowResult(j, jf *ju.Job, e *ExtractTask) map[string]interface{
|
|
tmp["bidamount"] = tmpBidamount
|
|
tmp["bidamount"] = tmpBidamount
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- //if qu.Float64All(tmp["bidamount"]) > 0 && qu.Float64All(tmp["budget"]) > 0 && (qu.Float64All(tmp["bidamount"])/10 > qu.Float64All(tmp["budget"])) {
|
|
|
|
- // fieldSource["bidamount"] = map[string]interface{}{
|
|
|
|
- // "ext_type": "",
|
|
|
|
- // "ext_from": "package",
|
|
|
|
- // }
|
|
|
|
- // tmp["bidamount"] = tmpBidamount
|
|
|
|
- //} else if qu.Float64All(tmp["bidamount"]) < tmpBidamount {
|
|
|
|
- // fieldSource["bidamount"] = map[string]interface{}{
|
|
|
|
- // "ext_type": "",
|
|
|
|
- // "ext_from": "package",
|
|
|
|
- // }
|
|
|
|
- // tmp["bidamount"] = tmpBidamount
|
|
|
|
- //}
|
|
|
|
} else {
|
|
} else {
|
|
//包数等于1,tmp没有值取包里的值
|
|
//包数等于1,tmp没有值取包里的值
|
|
if tmp["budget"] == nil || tmp["budget"] == 0 {
|
|
if tmp["budget"] == nil || tmp["budget"] == 0 {
|
|
@@ -1189,13 +1176,6 @@ func AnalysisSaveFlowResult(j, jf *ju.Job, e *ExtractTask) map[string]interface{
|
|
tmp["ffield"] = ffield
|
|
tmp["ffield"] = ffield
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- //临时保存指定字段数据
|
|
|
|
- //new_tmp := map[string]interface{}{}
|
|
|
|
- //new_tmp["area"] = qu.ObjToString(tmp["area"])
|
|
|
|
- //new_tmp["city"] = qu.ObjToString(tmp["city"])
|
|
|
|
- //new_tmp["district"] = qu.ObjToString(tmp["district"])
|
|
|
|
- //tmp = new_tmp
|
|
|
|
-
|
|
|
|
if e.TaskInfo.TestColl == "" {
|
|
if e.TaskInfo.TestColl == "" {
|
|
if len(tmp) > 0 { //保存抽取结果
|
|
if len(tmp) > 0 { //保存抽取结果
|
|
delete(tmp, "_id")
|
|
delete(tmp, "_id")
|