1

conf/db.go

@@ -47,4 +47,4 @@ var DbMasterList = []DbConfig{
 	},
 }
 
-var DbMaster = DbMasterList[1]
+var DbMaster = DbMasterList[2]

conf/redis.go

@@ -34,4 +34,4 @@ var RdsCacheList = []RdsConfig{
 	},
 }
 
-var RdsCache RdsConfig = RdsCacheList[0]
+var RdsCache RdsConfig = RdsCacheList[1]

dao/tree_contract_dao.go

@@ -397,7 +397,7 @@ func (d *TreeContractDao) CreateAll(data []*models.CmTreeContracts) error {
 			return errors.New("新增失败")
 		}
 	}
-
+	session.Rollback()
 	err = session.Commit()
 	if err != nil {
 		session.Rollback()

datasource/rdshelper.go

@@ -68,6 +68,7 @@ func InstanceCache() *RedisConn {
 func NewCache() *RedisConn {
 	pool := redis.Pool{
 		Dial: func() (redis.Conn, error) {
+			// redis.DialDatabase(1)
 			c, err := redis.Dial("tcp", fmt.Sprintf("%s:%d", conf.RdsCache.Host, conf.RdsCache.Port))
 			if err != nil {
 				log.Fatal("rdshelper.NewCache Dial error ", err)

services/project_account_service.go

@@ -253,6 +253,7 @@ func (s *projectAccountService) GetBidAccount(bidsectionId int, projectId int, p
 		}
 		accountListVM = append(accountListVM, account)
 	}
+
 	return accountListVM
 }