|
@@ -930,6 +930,19 @@ func AnalysisSaveFlowResult(j, jf *ju.Job, e *ExtractTask) map[string]interface{
|
|
|
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 {
|
|
|
//包数等于1,tmp没有值取包里的值
|
|
|
if tmp["budget"] == nil || tmp["budget"] == 0 {
|
|
@@ -1176,6 +1189,13 @@ func AnalysisSaveFlowResult(j, jf *ju.Job, e *ExtractTask) map[string]interface{
|
|
|
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 len(tmp) > 0 { //保存抽取结果
|
|
|
delete(tmp, "_id")
|