OtherProject
/
YouChuKoffee
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增订单轮询

This commit is contained in:
qiyunfanbo126.com 2024-09-04 16:17:57 +08:00
parent 7549facafa
commit 196447c108
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/services/OrderService.go
View File

@ -105,7 +105,7 @@ func OrderQueryService(userId int, OrderRequest *front.OrderListRequest) (code i
conn = conn.And(builder.Eq{"a.state": OrderRequest.State}) conn = conn.And(builder.Eq{"a.state": OrderRequest.State})
} }
count, err := repo.Where(conn).Alias("a"). count, err := repo.Where(conn).Alias("a").
Join("INNER", "Products b", "a.product_id = b.id").Select("a.*,b.main_image"). Join("INNER", "products b", "a.product_id = b.id").Select("a.*,b.main_image").
Desc("id").Limit(OrderRequest.PageSize, (OrderRequest.Page-1)*OrderRequest.PageSize).FindAndCount(&data) Desc("id").Limit(OrderRequest.PageSize, (OrderRequest.Page-1)*OrderRequest.PageSize).FindAndCount(&data)
code = handErr(err) code = handErr(err)
return return
@ -181,7 +181,7 @@ func OrderRefundService(userId int, orderId int) (code int) {
_, err := ordersmodel.GetInstance().GetDb().Where("id = ?", order.Id).Update(order) _, err := ordersmodel.GetInstance().GetDb().Where("id = ?", order.Id).Update(order)
//增加库存 //增加库存
if err == nil { if err == nil {
_, err = ordersmodel.GetInstance().GetDb().Exec("update Products set stock=stock+1 where id = " + strconv.Itoa(order.ProductId)) _, err = ordersmodel.GetInstance().GetDb().Exec("update products set stock=stock+1 where id = " + strconv.Itoa(order.ProductId))
return errorcode.Success return errorcode.Success
} else { } else {
return errorcode.OrderRefundUpdateFail return errorcode.OrderRefundUpdateFail