|
@@ -280,6 +280,7 @@ func doIndex(infos []map[string]interface{}, eMap map[string]map[string]interfac
|
|
|
delete(eMap, tid)
|
|
delete(eMap, tid)
|
|
|
}
|
|
}
|
|
|
syncNo++
|
|
syncNo++
|
|
|
|
|
+ log.Info("抽取区域", zap.Any("省", compare["area"]), zap.Any("市", compare["city"]), zap.Any("区", compare["district"]), zap.Any("id", tid))
|
|
|
for _, k := range config.Conf.Serve.FieldS {
|
|
for _, k := range config.Conf.Serve.FieldS {
|
|
|
v1 := compare[k] //extract
|
|
v1 := compare[k] //extract
|
|
|
v2 := tmp[k] //bidding
|
|
v2 := tmp[k] //bidding
|
|
@@ -379,6 +380,7 @@ func doIndex(infos []map[string]interface{}, eMap map[string]map[string]interfac
|
|
|
update["tag_set"] = getTagSet(tmp, compare)
|
|
update["tag_set"] = getTagSet(tmp, compare)
|
|
|
}
|
|
}
|
|
|
if len(update) > 0 {
|
|
if len(update) > 0 {
|
|
|
|
|
+ log.Info("保存bidding区域", zap.Any("省", update["area"]), zap.Any("市", update["city"]), zap.Any("区", update["district"]), zap.Any("id", tid))
|
|
|
if len(del) > 0 {
|
|
if len(del) > 0 {
|
|
|
bidUpdate = append(bidUpdate, []map[string]interface{}{{
|
|
bidUpdate = append(bidUpdate, []map[string]interface{}{{
|
|
|
"_id": tmp["_id"],
|
|
"_id": tmp["_id"],
|
