|
|
@@ -307,6 +307,18 @@ func WithdrawApply(c *gin.Context) { |
|
|
|
|
|
|
|
//5、推入mq |
|
|
|
if isAuto { |
|
|
|
//更改提现单记录状态 |
|
|
|
finWithdrawApply.State = int(enum.FinWithdrawApplyStateForIng) |
|
|
|
updateAffected, err1 := finWithdrawApplyDb.UpdateFinWithdrawApply(finWithdrawApply, "state") |
|
|
|
if err1 != nil { |
|
|
|
e.OutErr(c, e.ERR_DB_ORM, err1.Error()) |
|
|
|
return |
|
|
|
} |
|
|
|
if updateAffected <= 0 { |
|
|
|
e.OutErr(c, e.ERR_DB_ORM, "更新提现单状态失败") |
|
|
|
return |
|
|
|
} |
|
|
|
|
|
|
|
ch, err1 := rabbit.Cfg.Pool.GetChannel() |
|
|
|
if err1 != nil { |
|
|
|
e.OutErr(c, e.ERR_INIT_RABBITMQ, err1.Error()) |
|
|
|