fix:支付
This commit is contained in:
parent
821c2063c9
commit
3a51a5f297
|
@ -204,7 +204,7 @@ func (d *defaultOrder) CloseList(ctx context.Context, in *CloseListReq) (res *Cl
|
||||||
Where("pay_status = ?", int64(constants.ORDER_PAY_STATUS_UNPAIDDEPOSIT)).
|
Where("pay_status = ?", int64(constants.ORDER_PAY_STATUS_UNPAIDDEPOSIT)).
|
||||||
Find(&orderList)
|
Find(&orderList)
|
||||||
if result.Error != nil {
|
if result.Error != nil {
|
||||||
logc.Errorf(ctx, "order count failed, err: %v", err)
|
logc.Errorf(ctx, "order CloseList failed, err: %v", err)
|
||||||
return nil, result.Error
|
return nil, result.Error
|
||||||
}
|
}
|
||||||
for _, orderInfo := range orderList {
|
for _, orderInfo := range orderList {
|
||||||
|
@ -222,7 +222,7 @@ func (d *defaultOrder) CloseList(ctx context.Context, in *CloseListReq) (res *Cl
|
||||||
d.DelayQueue.AddTask(dtime, constants.QUEUE_NAME_ORDER, func(args ...interface{}) {
|
d.DelayQueue.AddTask(dtime, constants.QUEUE_NAME_ORDER, func(args ...interface{}) {
|
||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
orderSn := args[0].(string)
|
orderSn := args[0].(string)
|
||||||
logc.Infof(ctx, "order close, orderSn: %s", orderSn)
|
logc.Infof(ctx, "order CloseList, orderSn: %s", orderSn)
|
||||||
d.Close(ctx, &CloseReq{
|
d.Close(ctx, &CloseReq{
|
||||||
OrderSn: orderSn,
|
OrderSn: orderSn,
|
||||||
Type: 1,
|
Type: 1,
|
||||||
|
|
Loading…
Reference in New Issue
Block a user