diff --git a/app/services/thirdpay/thirdpay_notify/notify.go b/app/services/thirdpay/thirdpay_notify/notify.go index 34cf6f2..4c11d72 100644 --- a/app/services/thirdpay/thirdpay_notify/notify.go +++ b/app/services/thirdpay/thirdpay_notify/notify.go @@ -12,6 +12,7 @@ import ( "PaymentCenter/app/services" "PaymentCenter/app/utils" "PaymentCenter/app/utils/httpclient" + "fmt" "time" "github.com/bytedance/sonic" @@ -208,19 +209,21 @@ func (o *OrderNotify) checkApp() { } func (o *OrderNotify) checkOrder() { - utils.Log(nil, "检查订单状态:%d", o.order.Id) + fmt.Println(fmt.Sprintf("检查订单状态:%d", o.order.Id)) cond := builder.NewCond() cond = cond.And(builder.Eq{"id": o.OrderId}) o.order, o.Code = services.OrderFindOne(&ordersmodel.Orders{}, cond) if o.Code != errorcode.OrdersExist { return } - utils.Log(nil, "收到回调,当前状态:%d", o.order.Status) + fmt.Println(fmt.Sprintf("收到回调,当前状态:%d", o.order.Status)) + switch o.order.Status { case common.ORDER_STATUS_PAYING: return default: - utils.Log(nil, "订单状态异常,加入异常数据表:%d", o.order.Status) + fmt.Println(fmt.Sprintf("订单状态异常,加入异常数据表:%d", o.order.Status)) + exceptionModel := data.NewOrderExceptionRepo(orderexceptionmodel.GetInstance().GetDb()) _, err := exceptionModel.InsertOne(&orderexceptionmodel.OrderException{ OrderId: o.order.Id,