wangshan 2 жил өмнө
parent
commit
c70a35ef4e

+ 2 - 0
jyBXCore/api/internal/logic/participateActionLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewParticipateActionLogic(ctx context.Context, svcCtx *svc.ServiceContext,
 }
 }
 
 
 func (l *ParticipateActionLogic) ParticipateAction(req *types.ParticipateActionReq) (resp *types.CommonResp, err error) {
 func (l *ParticipateActionLogic) ParticipateAction(req *types.ParticipateActionReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	res, err := l.svcCtx.BxCore.ParticipateAction(l.ctx, &bxcore.ParticipateActionReq{
 	res, err := l.svcCtx.BxCore.ParticipateAction(l.ctx, &bxcore.ParticipateActionReq{
 		EntId:        req.EntId,
 		EntId:        req.EntId,
 		EntUserId:    req.EntUserId,
 		EntUserId:    req.EntUserId,

+ 2 - 0
jyBXCore/api/internal/logic/participateContentLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewParticipateContentLogic(ctx context.Context, svcCtx *svc.ServiceContext,
 }
 }
 
 
 func (l *ParticipateContentLogic) ParticipateContent(req *types.ParticipateContentReq) (resp *types.CommonResp, err error) {
 func (l *ParticipateContentLogic) ParticipateContent(req *types.ParticipateContentReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	res, err := l.svcCtx.BxCore.ParticipateContent(l.ctx, &bxcore.ParticipateContentReq{
 	res, err := l.svcCtx.BxCore.ParticipateContent(l.ctx, &bxcore.ParticipateContentReq{
 		EntId:        req.EntId,
 		EntId:        req.EntId,
 		EntUserId:    req.EntUserId,
 		EntUserId:    req.EntUserId,

+ 2 - 0
jyBXCore/api/internal/logic/participateInfoLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewParticipateInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext, r
 }
 }
 
 
 func (l *ParticipateInfoLogic) ParticipateInfo(req *types.ParticipateInfoReq) (resp *types.CommonResp, err error) {
 func (l *ParticipateInfoLogic) ParticipateInfo(req *types.ParticipateInfoReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	res, err := l.svcCtx.BxCore.ParticipateInfo(l.ctx, &bxcore.ParticipateInfoReq{
 	res, err := l.svcCtx.BxCore.ParticipateInfo(l.ctx, &bxcore.ParticipateInfoReq{
 		EntId:        req.EntId,
 		EntId:        req.EntId,
 		EntUserId:    req.EntUserId,
 		EntUserId:    req.EntUserId,

+ 2 - 0
jyBXCore/api/internal/logic/participateListLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewParticipateListLogic(ctx context.Context, svcCtx *svc.ServiceContext, r
 }
 }
 
 
 func (l *ParticipateListLogic) ParticipateList(req *types.ParticipateListReq) (resp *types.CommonResp, err error) {
 func (l *ParticipateListLogic) ParticipateList(req *types.ParticipateListReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	res, err := l.svcCtx.BxCore.ParticipateList(l.ctx, &bxcore.ParticipateListReq{
 	res, err := l.svcCtx.BxCore.ParticipateList(l.ctx, &bxcore.ParticipateListReq{
 		Identity:      req.Identity,
 		Identity:      req.Identity,
 		EntId:         req.EntId,
 		EntId:         req.EntId,

+ 2 - 0
jyBXCore/api/internal/logic/participatePersonsLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewParticipatePersonsLogic(ctx context.Context, svcCtx *svc.ServiceContext,
 }
 }
 
 
 func (l *ParticipatePersonsLogic) ParticipatePersons(req *types.ParticipatePersonsReq) (resp *types.CommonResp, err error) {
 func (l *ParticipatePersonsLogic) ParticipatePersons(req *types.ParticipatePersonsReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	res, err := l.svcCtx.BxCore.ParticipatePersons(l.ctx, &bxcore.ParticipatePersonsReq{
 	res, err := l.svcCtx.BxCore.ParticipatePersons(l.ctx, &bxcore.ParticipatePersonsReq{
 		EntId:        req.EntId,
 		EntId:        req.EntId,
 		EntUserId:    req.EntUserId,
 		EntUserId:    req.EntUserId,

+ 2 - 0
jyBXCore/api/internal/logic/participateRecordsLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewParticipateRecordsLogic(ctx context.Context, svcCtx *svc.ServiceContext,
 }
 }
 
 
 func (l *ParticipateRecordsLogic) ParticipateRecords(req *types.ParticipateRecordsReq) (resp *types.CommonResp, err error) {
 func (l *ParticipateRecordsLogic) ParticipateRecords(req *types.ParticipateRecordsReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	res, err := l.svcCtx.BxCore.ParticipateRecords(l.ctx, &bxcore.ParticipateRecordsReq{
 	res, err := l.svcCtx.BxCore.ParticipateRecords(l.ctx, &bxcore.ParticipateRecordsReq{
 		EntId:        req.EntId,
 		EntId:        req.EntId,
 		EntUserId:    req.EntUserId,
 		EntUserId:    req.EntUserId,

+ 2 - 0
jyBXCore/api/internal/logic/participateSetUpInfoLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewParticipateSetUpInfoLogic(ctx context.Context, svcCtx *svc.ServiceContex
 }
 }
 
 
 func (l *ParticipateSetUpInfoLogic) ParticipateSetUpInfo(req *types.ParticipateSetUpInfoReq) (resp *types.CommonResp, err error) {
 func (l *ParticipateSetUpInfoLogic) ParticipateSetUpInfo(req *types.ParticipateSetUpInfoReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	var (
 	var (
 		bidType    []*bxcore.BidTypeReq
 		bidType    []*bxcore.BidTypeReq
 		remindRule []*bxcore.RemindRuleReq
 		remindRule []*bxcore.RemindRuleReq

+ 2 - 0
jyBXCore/api/internal/logic/participateShowLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewParticipateShowLogic(ctx context.Context, svcCtx *svc.ServiceContext, r
 }
 }
 
 
 func (l *ParticipateShowLogic) ParticipateShow(req *types.ParticipateShowReq) (resp *types.CommonResp, err error) {
 func (l *ParticipateShowLogic) ParticipateShow(req *types.ParticipateShowReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	res, err := l.svcCtx.BxCore.ParticipateShow(l.ctx, &bxcore.ParticipateShowReq{
 	res, err := l.svcCtx.BxCore.ParticipateShow(l.ctx, &bxcore.ParticipateShowReq{
 		EntId:        req.EntId,
 		EntId:        req.EntId,
 		EntUserId:    req.EntUserId,
 		EntUserId:    req.EntUserId,

+ 1 - 0
jyBXCore/api/internal/logic/searchListLogic.go

@@ -36,6 +36,7 @@ func NewSearchListLogic(ctx context.Context, svcCtx *svc.ServiceContext, r *http
 }
 }
 
 
 func (l *SearchListLogic) SearchList(req *types.SearchReq) (resp *types.CommonResp, err error) {
 func (l *SearchListLogic) SearchList(req *types.SearchReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	t := time.Now()
 	t := time.Now()
 	limitFlag, isNew := util.GetFlag(l.r, l.w, req.UserId)
 	limitFlag, isNew := util.GetFlag(l.r, l.w, req.UserId)
 	res, err := l.svcCtx.BxCore.GetSearchList(l.ctx, &bxcore.SearchReq{
 	res, err := l.svcCtx.BxCore.GetSearchList(l.ctx, &bxcore.SearchReq{

+ 2 - 0
jyBXCore/api/internal/logic/updateBidStatusLogic.go

@@ -1,6 +1,7 @@
 package logic
 package logic
 
 
 import (
 import (
+	"app.yhyue.com/moapp/jybase/common"
 	"context"
 	"context"
 	"jyBXCore/rpc/type/bxcore"
 	"jyBXCore/rpc/type/bxcore"
 	"net/http"
 	"net/http"
@@ -28,6 +29,7 @@ func NewUpdateBidStatusLogic(ctx context.Context, svcCtx *svc.ServiceContext, r
 }
 }
 
 
 func (l *UpdateBidStatusLogic) UpdateBidStatus(req *types.UpdateBidStatusReq) (resp *types.CommonResp, err error) {
 func (l *UpdateBidStatusLogic) UpdateBidStatus(req *types.UpdateBidStatusReq) (resp *types.CommonResp, err error) {
+	defer common.Catch()
 	res, err := l.svcCtx.BxCore.UpdateBidStatus(l.ctx, &bxcore.UpdateBidStatusReq{
 	res, err := l.svcCtx.BxCore.UpdateBidStatus(l.ctx, &bxcore.UpdateBidStatusReq{
 		EntId:         req.EntId,
 		EntId:         req.EntId,
 		EntUserId:     req.EntUserId,
 		EntUserId:     req.EntUserId,