liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- 去除OrderManager.getOrders中不必要的事务

Browse Source
This commit is contained in:
gazebo
2019-05-29 17:12:30 +08:00
parent 0a945bab46
commit c8fed4543f
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/jxcallback/orderman/orderman_ext.go
View File

@@ -358,6 +358,7 @@ func (c *OrderManager) getOrders(ctx *jxcontext.Context, isIncludeSku bool, from
sqlParams = append(sqlParams, vendorIDs) sqlParams = append(sqlParams, vendorIDs)
} }
} }
db := dao.GetDB()
sql += sqlWhere sql += sqlWhere
if isIncludeSku { if isIncludeSku {
sql += ` sql += `
@@ -367,9 +368,7 @@ func (c *OrderManager) getOrders(ctx *jxcontext.Context, isIncludeSku bool, from
ORDER BY t1.order_created_at DESC ORDER BY t1.order_created_at DESC
LIMIT ? OFFSET ?` LIMIT ? OFFSET ?`
sqlParams = append(sqlParams, pageSize, offset) sqlParams = append(sqlParams, pageSize, offset)
}
db := dao.GetDB()
dao.Begin(db) dao.Begin(db)
defer func() { defer func() {
if r := recover(); r != nil { if r := recover(); r != nil {
@@ -377,10 +376,13 @@ func (c *OrderManager) getOrders(ctx *jxcontext.Context, isIncludeSku bool, from
panic(r) panic(r)
} }
}() }()
}
if err = dao.GetRows(db, &orders, sql, sqlParams...); err == nil { if err = dao.GetRows(db, &orders, sql, sqlParams...); err == nil {
totalCount = dao.GetLastTotalRowCount(db) totalCount = dao.GetLastTotalRowCount(db)
} }
if !isIncludeSku {
dao.Commit(db) dao.Commit(db)
}
return orders, totalCount, err return orders, totalCount, err
} }