diff --git a/api/proto/vas/proto/vas.go b/api/proto/vas/proto/vas.go index a8a73292..9c2a8a87 100644 --- a/api/proto/vas/proto/vas.go +++ b/api/proto/vas/proto/vas.go @@ -225,6 +225,7 @@ type ZoneRefundResp struct { type ZoneRefundListReq struct { base.BaseRequest Zid int64 `json:"zid"` // 空间id + Mid int64 `json:"mid"` // 用户 id BMid int64 `json:"b_mid"` // 主播 id AuditType int64 `json:"audit_type"` // 审核状态 1:待处理,2:已处理 Offset int `json:"offset"` diff --git a/app/mix/service/xxljob_tasks.go b/app/mix/service/xxljob_tasks.go index 2ad5ad74..2fdc3440 100644 --- a/app/mix/service/xxljob_tasks.go +++ b/app/mix/service/xxljob_tasks.go @@ -676,12 +676,13 @@ func (s *CronService) ClearVeriCodeWrongTimes(ctx context.Context, param *xxl.Ru return "vericode_wrong_times collection has been cleared" } -func (s *CronService) UserRefundAuditTimes(ctx context.Context, param *xxl.RunReq) (msg string) { +func (s *CronService) UserRefundAuditTimes(param *xxl.RunReq) (msg string) { logger.Info("task %v param: %v log_id: %v", param.ExecutorHandler, param.ExecutorParams, xxl.Int64ToStr(param.LogID)) logger.Info("user_refund_audit_times collection...") err := _DefaultVas.UserRefundAuditTimes(&gin.Context{}) if err != nil { - return "" + logger.Error("user_refund_audit_times collection fail: %v", err) + return fmt.Sprintf("user_refund_audit_times collection fail: %v", err) } return "user_refund_audit_times collection has been " }