xiugai

src/jfw/modules/pushsubscribe/src/match/job/matchjob.go

@@ -284,7 +284,7 @@ func (m *MatchJob) ToRelationProject(projectUser *sync.Map) {
 				})
 			}
 			if len(updateproject) == BigBulkSize {
-				mongodb.NewUpdateBulk(Pushspace_project, updateproject...)
+				mongodb.NewUpdateBulk(Pushspace_project, true, true, updateproject...)
 				updateproject = [][]map[string]interface{}{}
 			}
 		}(k, v)
@@ -296,7 +296,7 @@ func (m *MatchJob) ToRelationProject(projectUser *sync.Map) {
 	})
 	m.saveWaitGroup.Wait()
 	if len(updateproject) > 0 {
-		mongodb.NewUpdateBulk(Pushspace_project, updateproject...)
+		mongodb.NewUpdateBulk(Pushspace_project, true, true, updateproject...)
 		updateproject = [][]map[string]interface{}{}
 	}
 	logger.Info("关联项目结束。。。", index)