|
@@ -382,8 +382,28 @@ func (d *TreeContractDao) UpdateSerial(section *models.CmTreeContracts, serial i
|
|
|
|
|
|
// 插入多条数据
|
|
|
func (d *TreeContractDao) CreateAll(data []*models.CmTreeContracts) error {
|
|
|
- _, err := d.engine.Insert(data)
|
|
|
- return err
|
|
|
+ session := d.engine.NewSession()
|
|
|
+ defer session.Close()
|
|
|
+ err := session.Begin()
|
|
|
+ if err != nil {
|
|
|
+ return errors.New("新增失败-db")
|
|
|
+ }
|
|
|
+ // 新增
|
|
|
+ for _, item := range data {
|
|
|
+ _, err := session.Insert(item)
|
|
|
+ if err != nil {
|
|
|
+ log.Println(" error=", err)
|
|
|
+ session.Rollback()
|
|
|
+ return errors.New("新增失败")
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ err = session.Commit()
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return errors.New("新增失败-db")
|
|
|
+ }
|
|
|
+ return nil
|
|
|
}
|
|
|
|
|
|
// 新增项目节
|