safely run

application/init_app.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"fmt"
 	"os"
-	"runtime/debug"
 	"strconv"
 
 	"github.com/gin-gonic/gin"
@@ -19,6 +18,7 @@ import (
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/xerrors/xerror"
 	"gitlab.wanzhuangkj.com/tush/xpkg/rd/nacos"
 	"gitlab.wanzhuangkj.com/tush/xpkg/utils/dxsf"
+	goutils "gitlab.wanzhuangkj.com/tush/xpkg/utils/go_utils"
 	"gitlab.wanzhuangkj.com/tush/xpkg/utils/sliceUtils"
 	"gitlab.wanzhuangkj.com/tush/xpkg/utils/xsf"
 
@@ -53,7 +53,7 @@ type Application struct {
 }
 
 func (x *Application) Run() {
-	defer Recover()
+	defer goutils.Recover()
 	parseInit()
 	services := CreateServices(x.h())
 	closes := Close(services)
@@ -62,12 +62,6 @@ func (x *Application) Run() {
 	x.app.Run()
 }
 
-func Recover() {
-	if r := recover(); r != nil {
-		logger.Fatalf("Recovered panic: %v\nStack trace:\n%s", r, string(debug.Stack()))
-	}
-}
-
 func New(h func() *gin.Engine) *Application {
 	return &Application{
 		h: h,

config/xpkg.yaml

@@ -3,6 +3,7 @@ app:
   env: "dev"
   version: "v0.0.1"
   host: "0.0.0.0"
+  contextPath: "/qituAdmin"
   middleware:
     cors: 
       enable: true
@@ -117,7 +118,7 @@ auth:
   signKey: 6m2KywHIPEaWWIxffGpp8Dfl3z5SjE5WeeDStc1T64klnpoAqHrHN01vneteCAGE
 
 cron:
-  type: xxl
+  type: xxl # db or xxl
   enable: true
   schema: operator
   xxl:
@@ -135,6 +136,30 @@ oss:
   bucket-url: https://dev-athena.oss-cn-hangzhou.aliyuncs.com
 
 extend:
+  rpc:
+    athena:
+      srvAddr: http://athena.qitu
+      groups:
+        - name: bike
+          apis:
+          - name: create
+            uri: /internal/athena/api/v1/bike/create
+          - name: deleteByID
+            uri: /internal/athena/api/v1/bike/deleteByID
+          - name: deleteByIDs
+            uri: /internal/athena/api/v1/bike/deleteByIDs
+          - name: updateByID
+            uri: /internal/athena/api/v1/bike/updateByID
+          - name: updateByIDs
+            uri: /internal/athena/api/v1/bike/updateByIDs
+          - name: getByID
+            uri: /internal/athena/api/v1/bike/getByID
+          - name: getByIDs
+            uri: /internal/athena/api/v1/bike/getByIDs
+          - name: page
+            uri: /internal/athena/api/v1/bike/page
+          - name: exportCSV
+            uri: /internal/athena/api/v1/bike/export/csv
   third-party:
     baofu:
       bct-terminal-id: ""

rpc/rpc.go

@@ -11,6 +11,7 @@ const (
 	API_GET_BY_ID     = "getByID"
 	API_GET_BY_IDS    = "getByIDs"
 	API_PAGE          = "page"
+	API_EXPORT_CSV    = "exportCSV"
 )
 
 var ErrApiNotExist = errors.New("theapi not exist")

utils/go_utils/go_utils.go

+package goutils
+
+import (
+	"runtime/debug"
+
+	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/logger"
+)
+
+func Recover() {
+	if r := recover(); r != nil {
+		logger.Fatalf("Recovered panic: %v\nStack trace:\n%s", r, string(debug.Stack()))
+	}
+}
+
+func Safely(f func()) {
+	go func() {
+		defer Recover()
+		f()
+	}()
+}