浏览代码

Merge branch '11.7' into debug

Roc 2 年之前
父节点
当前提交
8f9f9deb39
共有 1 个文件被更改,包括 20 次插入4 次删除
  1. 20 4
      models/edb_data_calculate_nhcc.go

+ 20 - 4
models/edb_data_calculate_nhcc.go

@@ -570,10 +570,26 @@ func refreshAllCalculateNhcc(to orm.TxOrmer, edbInfo *EdbInfo, existItemA, exist
 
 	//数据入库
 	if len(addDataList) > 0 {
-		_, tmpErr := to.InsertMulti(len(addDataList), addDataList)
-		if tmpErr != nil {
-			err = tmpErr
-			return
+		tmpAddDataList := make([]*EdbDataCalculateNhcc, 0)
+		i := 0
+		for _, v := range addDataList {
+			tmpAddDataList = append(tmpAddDataList, v)
+			i++
+			if i >= 500 {
+				_, err = to.InsertMulti(len(tmpAddDataList), tmpAddDataList)
+				if err != nil {
+					return
+				}
+				i = 0
+				tmpAddDataList = make([]*EdbDataCalculateNhcc, 0)
+			}
+		}
+
+		if len(tmpAddDataList) > 0 {
+			_, err = to.InsertMulti(len(tmpAddDataList), tmpAddDataList)
+			if err != nil {
+				return
+			}
 		}
 	}
 	return