|
|
@@ -579,27 +579,6 @@ func historyTask(data []byte, mapInfo map[string]interface{}) {
|
|
|
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- //if invalidData(info.buyer, info.projectname, info.projectcode, info.contractnumber) {
|
|
|
- // updateExtract = append(updateExtract, []map[string]interface{}{
|
|
|
- // map[string]interface{}{
|
|
|
- // "_id": tmp["_id"],
|
|
|
- // },
|
|
|
- // map[string]interface{}{
|
|
|
- // "$set": map[string]interface{}{
|
|
|
- // "repeat": -1,
|
|
|
- // },
|
|
|
- // },
|
|
|
- // })
|
|
|
- // if len(updateExtract) > 500 {
|
|
|
- // mgo.UpSertBulk(extract, updateExtract...)
|
|
|
- // updateExtract = [][]map[string]interface{}{}
|
|
|
- // }
|
|
|
- //} else {
|
|
|
- //
|
|
|
- //}
|
|
|
}(tmp)
|
|
|
if len(updateExtract) > 500 {
|
|
|
mgo.UpSertBulk(extract, updateExtract...)
|
