|
|
@@ -1874,13 +1874,24 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
this.ServeJSON()
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
+ var certsup2 []suppliercertsub.Del_OilSupplierCertSub
|
|
|
for idx, _ := range certsup {
|
|
|
certsup[idx].DeleteDate = time.Now()
|
|
|
+ certsup2 = append(certsup2, certsup[idx])
|
|
|
+ if len(certsup2) == 1000 {
|
|
|
+ _, err = svc.InsertEntityBytbl(DelOilSupplierCertSubName, &certsup2)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ certsup2 = nil
|
|
|
+ }
|
|
|
}
|
|
|
-
|
|
|
- _, err = svc.InsertEntityBytbl(DelOilSupplierCertSubName, &certsup)
|
|
|
-
|
|
|
+ _, err = svc.InsertEntityBytbl(DelOilSupplierCertSubName, &certsup2)
|
|
|
if err != nil {
|
|
|
session.Rollback()
|
|
|
errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|