wishpal_ironfan
/
service
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1

This commit is contained in:
lwl0608 2024-07-17 17:51:08 +08:00
parent 7c36b8c16f
commit f01f9a3ecb
4 changed files with 33 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
api/proto/zone/proto/zone_op.go
View File

@ -141,3 +141,8 @@ type OpManualUnlockWechatParam struct {
ProductId string `json:"product_id"` // 商品id
Oid2 string `json:"oid2"` // oid2
}
type OpRollbackZoneRefundStatusParam struct {
Userid int64 `json:"userid"`
StreamerUserid int64 `json:"streamer_userid"`
}

1
app/mix/controller/init.go
View File

@ -318,6 +318,7 @@ func Init(r *gin.Engine) {
opVasPayGroup.POST("wxpay_callback_manual", middleware.JSONParamValidator(vasproto.WxpayCallbackManualParam{}), WxpayCallbackManual)
opVasPayGroup.POST("zone_refund_list", middleware.JSONParamValidator(zoneproto.OpZoneRefundListParam{}), OpZoneRefundList)
opVasPayGroup.POST("manual_unlock_wechat", middleware.JSONParamValidator(zoneproto.OpManualUnlockWechatParam{}), OpManualUnlockWechat)
opVasPayGroup.POST("rollback_zone_exit_status", middleware.JSONParamValidator(zoneproto.OpRollbackZoneRefundStatusParam{}), OpManualUnlockWechat)
// 慧用工
extHvyogoGroup := r.Group("/ext/hvyogo")

15
app/mix/controller/vas_op.go
View File

@ -75,3 +75,18 @@ func OpManualUnlockWechat(ctx *gin.Context) {
}
ReplyOk(ctx, nil)
}
func OpRollbackZoneRefundStatus(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*zoneproto.OpRollbackZoneRefundStatusParam)
ec, err := service.DefaultService.OpRollbackZoneRefundStatus(ctx, req)
if ec != errcode.ErrCodeVasSrvOk {
logger.Error("RefundOrder fail, req: %v, ec: %v", util.ToJson(req), ec)
if err != nil {
ReplyErrorMsg(ctx, err.Error())
return
}
ReplyErrCodeMsg(ctx, ec)
return
}
ReplyOk(ctx, nil)
}

12
app/mix/service/vasservice.go
View File

@ -1175,3 +1175,15 @@ func (s *Service) VasIncomePage(ctx *gin.Context, req *vasproto.IncomePageReq) (
}
return
}
func (s *Service) OpRollbackZoneRefundStatus(ctx *gin.Context, req *zoneproto.OpRollbackZoneRefundStatusParam) (ec errcode.ErrCode, err error) {
userAcnt, _ := _DefaultAccount.OpListByUserId(ctx, &accountproto.OpListByUserIdReq{UserId: goproto.Int64(req.Userid)})
err = _DefaultVas.SuperfanUnlockContact(ctx, nil, req.Mid, req.StreamerMid, req.Oid2)
ec, err = errs.DealVasErr(err)
if err != nil {
logger.Error("OneStepUnlockContact fail, req: %v, err: %v", util.ToJson(req), err)
return
}
return
}