|
|
@@ -295,9 +295,9 @@ func task(data []byte, mapInfo map[string]interface{}) {
|
|
|
newData, update_map ,isReplace := mergeDataFields(source, info)
|
|
|
if isReplace {//替换-数据池
|
|
|
fmt.Println("替换更新：",source.id)
|
|
|
- //数据池
|
|
|
- DM.replacePoolData(newData) //替换
|
|
|
- //mongo更新 - 具体字段
|
|
|
+ //数据池 - 替换
|
|
|
+ DM.replacePoolData(newData)
|
|
|
+ //mongo更新 - 具体字段 - merge
|
|
|
mgo.UpdateById(extract,source.id,update_map)
|
|
|
//发udp ids：更新索引
|
|
|
if len(ids)>=9 {
|
