|
@@ -258,8 +258,7 @@ func (s *SecondPush) SecondPushTask() {
|
|
|
}
|
|
|
}
|
|
|
if len(updateMap) > 0 {
|
|
|
- b := MgoCus.UpdateBulk("usermail", updateMap...)
|
|
|
- log.Println("项目id更新是否成功", b)
|
|
|
+ MgoCus.UpdateBulk("usermail", updateMap...)
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -281,8 +280,7 @@ func (s *SecondPush) SecondPushTask() {
|
|
|
xlsxArr = append(xlsxArr, l)
|
|
|
}
|
|
|
if len(updateMap) > 0 {
|
|
|
- b := MgoCus.UpdateBulk("usermail", updateMap...)
|
|
|
- log.Println("项目id更新是否成功", b)
|
|
|
+ MgoCus.UpdateBulk("usermail", updateMap...)
|
|
|
}
|
|
|
}
|
|
|
if len(xlsxArr) == 0 {
|
|
@@ -313,7 +311,6 @@ func searchProjectId(l map[string]interface{}, updateMap [][]map[string]interfac
|
|
|
} else {
|
|
|
l["projectId"] = ""
|
|
|
_projectid = ""
|
|
|
- log.Println(l["id"], "未匹配到项目id")
|
|
|
}
|
|
|
updateMap = append(updateMap, []map[string]interface{}{
|
|
|
map[string]interface{}{
|
|
@@ -326,8 +323,7 @@ func searchProjectId(l map[string]interface{}, updateMap [][]map[string]interfac
|
|
|
},
|
|
|
})
|
|
|
if len(updateMap) > 500 {
|
|
|
- b := MgoCus.UpdateBulk("usermail", updateMap...)
|
|
|
- log.Println("项目id更新是否成功", b)
|
|
|
+ MgoCus.UpdateBulk("usermail", updateMap...)
|
|
|
updateMap = [][]map[string]interface{}{}
|
|
|
}
|
|
|
return updateMap
|