Browse Source

mongodb测试通过

qdy 2 months ago
parent
commit
5be200cba3

+ 11
- 0
config/config.go View File

@@ -6,6 +6,17 @@ import (
6 6
 	"git.x2erp.com/qdy/go-base/config/subconfigs"
7 7
 )
8 8
 
9
+const (
10
+	//数据仓库-数据库名称
11
+	DorisDatabaseName = "x6_data"
12
+	//客户端档案中心所在数据库yaml配置ID
13
+	AgentDBArchivesId = "archives"
14
+	//客户端单据中心所在数据库yaml配置ID
15
+	AgentDBBillsId = "bills"
16
+	//客户端库存中心所在数据库yaml配置ID
17
+	AgentDBStockId = "stock"
18
+)
19
+
9 20
 // IConfig 主配置接口(更新支持多数据库)
10 21
 type IConfig interface {
11 22
 	// 多数据库支持

+ 8
- 41
go.mod View File

@@ -3,22 +3,19 @@ module git.x2erp.com/qdy/go-base
3 3
 go 1.25.4
4 4
 
5 5
 require (
6
-	github.com/go-micro/plugins/v4/registry/consul v1.2.1
7
-	go-micro.dev/v4 v4.11.0
6
+	github.com/hashicorp/consul/api v1.9.0
7
+	go.mongodb.org/mongo-driver v1.17.6
8 8
 	gopkg.in/yaml.v2 v2.4.0
9 9
 )
10 10
 
11 11
 require (
12
-	dario.cat/mergo v1.0.2 // indirect
13 12
 	github.com/armon/go-metrics v0.0.0-20180917152333-f0300d1749da // indirect
14
-	github.com/cloudflare/circl v1.6.1 // indirect
15
-	github.com/cyphar/filepath-securejoin v0.6.1 // indirect
16 13
 	github.com/elastic/elastic-transport-go/v8 v8.7.0 // indirect
17 14
 	github.com/fatih/color v1.9.0 // indirect
18 15
 	github.com/go-logr/logr v1.4.2 // indirect
19 16
 	github.com/go-logr/stdr v1.2.2 // indirect
20
-	github.com/golang/groupcache v0.0.0-20241129210726-2c02b8208cf8 // indirect
21
-	github.com/hashicorp/consul/api v1.9.0 // indirect
17
+	github.com/google/btree v1.0.0 // indirect
18
+	github.com/google/go-cmp v0.7.0 // indirect
22 19
 	github.com/hashicorp/errwrap v1.1.0 // indirect
23 20
 	github.com/hashicorp/go-cleanhttp v0.5.1 // indirect
24 21
 	github.com/hashicorp/go-hclog v0.12.0 // indirect
@@ -28,58 +25,28 @@ require (
28 25
 	github.com/hashicorp/go-uuid v1.0.3 // indirect
29 26
 	github.com/hashicorp/golang-lru v0.5.3 // indirect
30 27
 	github.com/hashicorp/serf v0.9.5 // indirect
31
-	github.com/klauspost/cpuid/v2 v2.3.0 // indirect
28
+	github.com/kr/pretty v0.3.1 // indirect
32 29
 	github.com/mattn/go-colorable v0.1.8 // indirect
33 30
 	github.com/mattn/go-isatty v0.0.20 // indirect
34
-	github.com/mitchellh/hashstructure v1.1.0 // indirect
35 31
 	github.com/mitchellh/mapstructure v1.3.3 // indirect
36
-	github.com/pjbgf/sha1cd v0.5.0 // indirect
37
-	github.com/skeema/knownhosts v1.3.2 // indirect
38
-	github.com/stretchr/objx v0.5.2 // indirect
32
+	github.com/rogpeppe/go-internal v1.14.1 // indirect
33
+	github.com/stretchr/testify v1.11.1 // indirect
39 34
 	go.opentelemetry.io/otel v1.28.0 // indirect
40 35
 	go.opentelemetry.io/otel/metric v1.28.0 // indirect
41 36
 	go.opentelemetry.io/otel/trace v1.28.0 // indirect
42 37
 	go.uber.org/multierr v1.10.0 // indirect
38
+	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
43 39
 )
44 40
 
45 41
 require (
46
-	github.com/Microsoft/go-winio v0.6.2 // indirect
47
-	github.com/ProtonMail/go-crypto v1.3.0 // indirect
48
-	github.com/bitly/go-simplejson v0.5.1 // indirect
49
-	github.com/cpuguy83/go-md2man/v2 v2.0.7 // indirect
50 42
 	github.com/elastic/go-elasticsearch/v8 v8.19.0
51
-	github.com/emirpasic/gods v1.18.1 // indirect
52
-	github.com/fsnotify/fsnotify v1.9.0 // indirect
53
-	github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376 // indirect
54
-	github.com/go-git/go-billy/v5 v5.6.2 // indirect
55
-	github.com/go-git/go-git/v5 v5.16.4 // indirect
56
-	github.com/golang/protobuf v1.5.4 // indirect
57
-	github.com/google/uuid v1.6.0 // indirect
58 43
 	github.com/iancoleman/strcase v0.3.0
59
-	github.com/imdario/mergo v0.3.16 // indirect
60
-	github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99 // indirect
61
-	github.com/kevinburke/ssh_config v1.4.0 // indirect
62 44
 	github.com/miekg/dns v1.1.68 // indirect
63 45
 	github.com/mitchellh/go-homedir v1.1.0 // indirect
64
-	github.com/nxadm/tail v1.4.11 // indirect
65
-	github.com/oxtoacart/bpool v0.0.0-20190530202638-03653db5a59c // indirect
66
-	github.com/patrickmn/go-cache v2.1.0+incompatible // indirect
67 46
 	github.com/pkg/errors v0.9.1 // indirect
68
-	github.com/russross/blackfriday/v2 v2.1.0 // indirect
69
-	github.com/sergi/go-diff v1.4.0 // indirect
70
-	github.com/urfave/cli/v2 v2.27.7 // indirect
71
-	github.com/xanzy/ssh-agent v0.3.3 // indirect
72
-	github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342 // indirect
73 47
 	go.uber.org/zap v1.27.1
74
-	golang.org/x/crypto v0.45.0 // indirect
75
-	golang.org/x/mod v0.30.0 // indirect
76 48
 	golang.org/x/net v0.47.0 // indirect
77
-	golang.org/x/sync v0.18.0 // indirect
78 49
 	golang.org/x/sys v0.38.0 // indirect
79
-	golang.org/x/text v0.31.0 // indirect
80 50
 	golang.org/x/tools v0.39.0 // indirect
81
-	google.golang.org/protobuf v1.36.10 // indirect
82 51
 	gopkg.in/natefinch/lumberjack.v2 v2.2.1
83
-	gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 // indirect
84
-	gopkg.in/warnings.v0 v0.1.2 // indirect
85 52
 )

+ 8
- 105
go.sum View File

@@ -1,28 +1,10 @@
1
-dario.cat/mergo v1.0.2 h1:85+piFYR1tMbRrLcDwR18y4UKJ3aH1Tbzi24VRW1TK8=
2
-dario.cat/mergo v1.0.2/go.mod h1:E/hbnu0NxMFBjpMIE34DRGLWqDy0g5FuKDhCb31ngxA=
3
-github.com/Microsoft/go-winio v0.5.2/go.mod h1:WpS1mjBmmwHBEWmogvA2mj8546UReBk4v8QkMxJ6pZY=
4
-github.com/Microsoft/go-winio v0.6.2 h1:F2VQgta7ecxGYO8k3ZZz3RS8fVIXVxONVUPlNERoyfY=
5
-github.com/Microsoft/go-winio v0.6.2/go.mod h1:yd8OoFMLzJbo9gZq8j5qaps8bJ9aShtEA8Ipt1oGCvU=
6
-github.com/ProtonMail/go-crypto v1.3.0 h1:ILq8+Sf5If5DCpHQp4PbZdS1J7HDFRXz/+xKBiRGFrw=
7
-github.com/ProtonMail/go-crypto v1.3.0/go.mod h1:9whxjD8Rbs29b4XWbB8irEcE8KHMqaR2e7GWU1R+/PE=
8
-github.com/anmitsu/go-shlex v0.0.0-20200514113438-38f4b401e2be h1:9AeTilPcZAjCFIImctFaOjnTIavg87rW78vTPkQqLI8=
9
-github.com/anmitsu/go-shlex v0.0.0-20200514113438-38f4b401e2be/go.mod h1:ySMOLuWl6zY27l47sB3qLNK6tF2fkHG55UZxx8oIVo4=
10 1
 github.com/armon/circbuf v0.0.0-20150827004946-bbbad097214e/go.mod h1:3U/XgcO3hCbHZ8TKRvWD2dDTCfh9M9ya+I9JpbB7O8o=
11 2
 github.com/armon/go-metrics v0.0.0-20180917152333-f0300d1749da h1:8GUt8eRujhVEGZFFEjBj46YV4rDjvGrNxb0KMWYkL2I=
12 3
 github.com/armon/go-metrics v0.0.0-20180917152333-f0300d1749da/go.mod h1:Q73ZrmVTwzkszR9V5SSuryQ31EELlFMUz1kKyl939pY=
13 4
 github.com/armon/go-radix v0.0.0-20180808171621-7fddfc383310/go.mod h1:ufUuZ+zHj4x4TnLV4JWEpy2hxWSpsRywHrMgIH9cCH8=
14 5
 github.com/armon/go-radix v1.0.0/go.mod h1:ufUuZ+zHj4x4TnLV4JWEpy2hxWSpsRywHrMgIH9cCH8=
15
-github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5 h1:0CwZNZbxp69SHPdPJAN/hZIm0C4OItdklCFmMRWYpio=
16
-github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5/go.mod h1:wHh0iHkYZB8zMSxRWpUBQtwG5a7fFgvEO+odwuTv2gs=
17 6
 github.com/bgentry/speakeasy v0.1.0/go.mod h1:+zsyZBPWlz7T6j88CTgSN5bM796AkVf0kBD4zp0CCIs=
18
-github.com/bitly/go-simplejson v0.5.1 h1:xgwPbetQScXt1gh9BmoJ6j9JMr3TElvuIyjR8pgdoow=
19
-github.com/bitly/go-simplejson v0.5.1/go.mod h1:YOPVLzCfwK14b4Sff3oP1AmGhI9T9Vsg84etUnlyp+Q=
20
-github.com/cloudflare/circl v1.6.1 h1:zqIqSPIndyBh1bjLVVDHMPpVKqp8Su/V+6MeDzzQBQ0=
21
-github.com/cloudflare/circl v1.6.1/go.mod h1:uddAzsPgqdMAYatqJ0lsjX1oECcQLIlRpzZh3pJrofs=
22
-github.com/cpuguy83/go-md2man/v2 v2.0.7 h1:zbFlGlXEAKlwXpmvle3d8Oe3YnkKIK4xSRTd3sHPnBo=
23
-github.com/cpuguy83/go-md2man/v2 v2.0.7/go.mod h1:oOW0eioCTA6cOiMLiUPZOpcVxMig6NIQQ7OS05n1F4g=
24
-github.com/cyphar/filepath-securejoin v0.6.1 h1:5CeZ1jPXEiYt3+Z6zqprSAgSWiggmpVyciv8syjIpVE=
25
-github.com/cyphar/filepath-securejoin v0.6.1/go.mod h1:A8hd4EnAeyujCJRrICiOWqjS1AX0a9kM5XL+NwKoYSc=
7
+github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
26 8
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
27 9
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
28 10
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@@ -30,44 +12,19 @@ github.com/elastic/elastic-transport-go/v8 v8.7.0 h1:OgTneVuXP2uip4BA658Xi6Hfw+P
30 12
 github.com/elastic/elastic-transport-go/v8 v8.7.0/go.mod h1:YLHer5cj0csTzNFXoNQ8qhtGY1GTvSqPnKWKaqQE3Hk=
31 13
 github.com/elastic/go-elasticsearch/v8 v8.19.0 h1:VmfBLNRORY7RZL+9hTxBD97ehl9H8Nxf2QigDh6HuMU=
32 14
 github.com/elastic/go-elasticsearch/v8 v8.19.0/go.mod h1:F3j9e+BubmKvzvLjNui/1++nJuJxbkhHefbaT0kFKGY=
33
-github.com/elazarl/goproxy v1.7.2 h1:Y2o6urb7Eule09PjlhQRGNsqRfPmYI3KKQLFpCAV3+o=
34
-github.com/elazarl/goproxy v1.7.2/go.mod h1:82vkLNir0ALaW14Rc399OTTjyNREgmdL2cVoIbS6XaE=
35
-github.com/emirpasic/gods v1.18.1 h1:FXtiHYKDGKCW2KzwZKx0iC0PQmdlorYgdFG9jPXJ1Bc=
36
-github.com/emirpasic/gods v1.18.1/go.mod h1:8tpGGwCnJ5H4r6BWwaV6OrWmMoPhUl5jm/FMNAnJvWQ=
37 15
 github.com/fatih/color v1.7.0/go.mod h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4=
38 16
 github.com/fatih/color v1.9.0 h1:8xPHl4/q1VyqGIPif1F+1V3Y3lSmrq01EabUW3CoW5s=
39 17
 github.com/fatih/color v1.9.0/go.mod h1:eQcE1qtQxscV5RaZvpXrrb8Drkc3/DdQ+uUYCNjL+zU=
40
-github.com/fsnotify/fsnotify v1.6.0/go.mod h1:sl3t1tCWJFWoRz9R8WJCbQihKKwmorjAbSClcnxKAGw=
41
-github.com/fsnotify/fsnotify v1.9.0 h1:2Ml+OJNzbYCTzsxtv8vKSFD9PbJjmhYF14k/jKC7S9k=
42
-github.com/fsnotify/fsnotify v1.9.0/go.mod h1:8jBTzvmWwFyi3Pb8djgCCO5IBqzKJ/Jwo8TRcHyHii0=
43
-github.com/gliderlabs/ssh v0.3.8 h1:a4YXD1V7xMF9g5nTkdfnja3Sxy1PVDCj1Zg4Wb8vY6c=
44
-github.com/gliderlabs/ssh v0.3.8/go.mod h1:xYoytBv1sV0aL3CavoDuJIQNURXkkfPA/wxQ1pL1fAU=
45
-github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376 h1:+zs/tPmkDkHx3U66DAb0lQFJrpS6731Oaa12ikc+DiI=
46
-github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376/go.mod h1:an3vInlBmSxCcxctByoQdvwPiA7DTK7jaaFDBTtu0ic=
47
-github.com/go-git/go-billy/v5 v5.6.2 h1:6Q86EsPXMa7c3YZ3aLAQsMA0VlWmy43r6FHqa/UNbRM=
48
-github.com/go-git/go-billy/v5 v5.6.2/go.mod h1:rcFC2rAsp/erv7CMz9GczHcuD0D32fWzH+MJAU+jaUU=
49
-github.com/go-git/go-git-fixtures/v4 v4.3.2-0.20231010084843-55a94097c399 h1:eMje31YglSBqCdIqdhKBW8lokaMrL3uTkpGYlE2OOT4=
50
-github.com/go-git/go-git-fixtures/v4 v4.3.2-0.20231010084843-55a94097c399/go.mod h1:1OCfN199q1Jm3HZlxleg+Dw/mwps2Wbk9frAWm+4FII=
51
-github.com/go-git/go-git/v5 v5.16.4 h1:7ajIEZHZJULcyJebDLo99bGgS0jRrOxzZG4uCk2Yb2Y=
52
-github.com/go-git/go-git/v5 v5.16.4/go.mod h1:4Ge4alE/5gPs30F2H1esi2gPd69R0C39lolkucHBOp8=
53 18
 github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
54 19
 github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
55 20
 github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
56 21
 github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
57 22
 github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
58
-github.com/go-micro/plugins/v4/registry/consul v1.2.1 h1:3wctYMtstwQLCjoJ1HA6mKGGFF1hcdKDv5MzHakB1jE=
59
-github.com/go-micro/plugins/v4/registry/consul v1.2.1/go.mod h1:wTat7/K9XQ+i64VbbcMYFcEwipYfSgJM51HcA/sgsM4=
60
-github.com/golang/groupcache v0.0.0-20241129210726-2c02b8208cf8 h1:f+oWsMOmNPc8JmEHVZIycC7hBoQxHH9pNKQORJNozsQ=
61
-github.com/golang/groupcache v0.0.0-20241129210726-2c02b8208cf8/go.mod h1:wcDNUvekVysuuOpQKo3191zZyTpiI6se1N1ULghS0sw=
62
-github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
63
-github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
64 23
 github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
65 24
 github.com/google/btree v1.0.0 h1:0udJVsspx3VBr5FwtLhQQtuAsVc79tTq0ocGIPAU6qo=
66 25
 github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
67 26
 github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
68 27
 github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
69
-github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
70
-github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
71 28
 github.com/hashicorp/consul/api v1.9.0 h1:T6dKIWcaihG2c21YUi0BMAHbJanVXiYuz+mPgqxY3N4=
72 29
 github.com/hashicorp/consul/api v1.9.0/go.mod h1:XjsvQN+RJGWI2TWy1/kqaE16HrR2J/FWgkYjdZQsX9M=
73 30
 github.com/hashicorp/consul/sdk v0.8.0 h1:OJtKBtEjboEZvG6AOUdh4Z1Zbyu0WcxQ0qatRrZHTVU=
@@ -107,16 +64,8 @@ github.com/hashicorp/serf v0.9.5 h1:EBWvyu9tcRszt3Bxp3KNssBMP1KuHWyO51lz9+786iM=
107 64
 github.com/hashicorp/serf v0.9.5/go.mod h1:UWDWwZeL5cuWDJdl0C6wrvrUwEqtQ4ZKBKKENpqIUyk=
108 65
 github.com/iancoleman/strcase v0.3.0 h1:nTXanmYxhfFAMjZL34Ov6gkzEsSJZ5DbhxWjvSASxEI=
109 66
 github.com/iancoleman/strcase v0.3.0/go.mod h1:iwCmte+B7n89clKwxIoIXy/HfoL7AsD47ZCWhYzw7ho=
110
-github.com/imdario/mergo v0.3.16 h1:wwQJbIsHYGMUyLSPrEq1CT16AhnhNJQ51+4fdHUnCl4=
111
-github.com/imdario/mergo v0.3.16/go.mod h1:WBLT9ZmE3lPoWsEzCh9LPo3TiwVN+ZKEjmz+hD27ysY=
112
-github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99 h1:BQSFePA1RWJOlocH6Fxy8MmwDt+yVQYULKfN0RoTN8A=
113
-github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99/go.mod h1:1lJo3i6rXxKeerYnT8Nvf0QmHCRC1n8sfWVwXF2Frvo=
114
-github.com/kevinburke/ssh_config v1.4.0 h1:6xxtP5bZ2E4NF5tuQulISpTO2z8XbtH8cg1PWkxoFkQ=
115
-github.com/kevinburke/ssh_config v1.4.0/go.mod h1:q2RIzfka+BXARoNexmF9gkxEX7DmvbW9P4hIVx2Kg4M=
116
-github.com/klauspost/cpuid/v2 v2.3.0 h1:S4CRMLnYUhGeDFDqkGriYKdfoFlDnMtqTiI/sFzhA9Y=
117
-github.com/klauspost/cpuid/v2 v2.3.0/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
118
-github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
119 67
 github.com/kr/pretty v0.2.0/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
68
+github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
120 69
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
121 70
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
122 71
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
@@ -144,24 +93,13 @@ github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG
144 93
 github.com/mitchellh/go-homedir v1.1.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
145 94
 github.com/mitchellh/go-testing-interface v1.0.0 h1:fzU/JVNcaqHQEcVFAKeR41fkiLdIPrefOvVG1VZ96U0=
146 95
 github.com/mitchellh/go-testing-interface v1.0.0/go.mod h1:kRemZodwjscx+RGhAo8eIhFbs2+BFgRtFPeD/KE+zxI=
147
-github.com/mitchellh/hashstructure v1.1.0 h1:P6P1hdjqAAknpY/M1CGipelZgp+4y9ja9kmUZPXP+H0=
148
-github.com/mitchellh/hashstructure v1.1.0/go.mod h1:xUDAozZz0Wmdiufv0uyhnHkUTN6/6d8ulp4AwfLKrmA=
149 96
 github.com/mitchellh/mapstructure v0.0.0-20160808181253-ca63d7c062ee/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
150 97
 github.com/mitchellh/mapstructure v1.1.2/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
151 98
 github.com/mitchellh/mapstructure v1.3.3 h1:SzB1nHZ2Xi+17FP0zVQBHIZqvwRN9408fJO8h+eeNA8=
152 99
 github.com/mitchellh/mapstructure v1.3.3/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
153
-github.com/nxadm/tail v1.4.11 h1:8feyoE3OzPrcshW5/MJ4sGESc5cqmGkGCWlco4l0bqY=
154
-github.com/nxadm/tail v1.4.11/go.mod h1:OTaG3NK980DZzxbRq6lEuzgU+mug70nY11sMd4JXXHc=
155
-github.com/onsi/gomega v1.34.1 h1:EUMJIKUjM8sKjYbtxQI9A4z2o+rruxnzNvpknOXie6k=
156
-github.com/onsi/gomega v1.34.1/go.mod h1:kU1QgUvBDLXBJq618Xvm2LUX6rSAfRaFRTcdOeDLwwY=
157
-github.com/oxtoacart/bpool v0.0.0-20190530202638-03653db5a59c h1:rp5dCmg/yLR3mgFuSOe4oEnDDmGLROTvMragMUXpTQw=
158
-github.com/oxtoacart/bpool v0.0.0-20190530202638-03653db5a59c/go.mod h1:X07ZCGwUbLaax7L0S3Tw4hpejzu63ZrrQiUe6W0hcy0=
159 100
 github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c h1:Lgl0gzECD8GnQ5QCWA8o6BtfL6mDH5rQgM4/fX3avOs=
160 101
 github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=
161
-github.com/patrickmn/go-cache v2.1.0+incompatible h1:HRMgzkcYKYpi3C8ajMPV8OFXaaRUnok+kx1WdO15EQc=
162
-github.com/patrickmn/go-cache v2.1.0+incompatible/go.mod h1:3Qf8kWWT7OJRJbdiICTKqZju1ZixQ/KpMGzzAfe6+WQ=
163
-github.com/pjbgf/sha1cd v0.5.0 h1:a+UkboSi1znleCDUNT3M5YxjOnN1fz2FhN48FlwCxs0=
164
-github.com/pjbgf/sha1cd v0.5.0/go.mod h1:lhpGlyHLpQZoxMv8HcgXvZEhcGs0PG/vsZnEJ7H0iCM=
102
+github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA=
165 103
 github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
166 104
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
167 105
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
@@ -169,38 +107,27 @@ github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZb
169 107
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
170 108
 github.com/posener/complete v1.1.1/go.mod h1:em0nMJCgc9GFtwrmVmEMR/ZL6WyhyjMBndrE9hABlRI=
171 109
 github.com/posener/complete v1.2.3/go.mod h1:WZIdtGGp+qx0sLrYKtIRAruyNpv6hFCicSgv7Sy7s/s=
110
+github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
172 111
 github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
173 112
 github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
174
-github.com/russross/blackfriday/v2 v2.1.0 h1:JIOH55/0cWyOuilr9/qlrm0BSXldqnqwMsf35Ld67mk=
175
-github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
176 113
 github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
177 114
 github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529 h1:nn5Wsu0esKSJiIVhscUtVbo7ada43DJhG55ua/hjS5I=
178 115
 github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529/go.mod h1:DxrIzT+xaE7yg65j358z/aeFdxmN0P9QXhEzd20vsDc=
179
-github.com/sergi/go-diff v1.4.0 h1:n/SP9D5ad1fORl+llWyN+D6qoUETXNZARKjyY2/KVCw=
180
-github.com/sergi/go-diff v1.4.0/go.mod h1:A0bzQcvG0E7Rwjx0REVgAGH58e96+X0MeOfepqsbeW4=
181
-github.com/sirupsen/logrus v1.7.0/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0=
182
-github.com/skeema/knownhosts v1.3.2 h1:EDL9mgf4NzwMXCTfaxSD/o/a5fxDw/xL9nkU28JjdBg=
183
-github.com/skeema/knownhosts v1.3.2/go.mod h1:bEg3iQAuw+jyiw+484wwFJoKSLwcfd7fqRy+N0QTiow=
184 116
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
185 117
 github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY=
186 118
 github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA=
187 119
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
188
-github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
189 120
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
190 121
 github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
191 122
 github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
192
-github.com/urfave/cli/v2 v2.27.7 h1:bH59vdhbjLv3LAvIu6gd0usJHgoTTPhCFib8qqOwXYU=
193
-github.com/urfave/cli/v2 v2.27.7/go.mod h1:CyNAG/xg+iAOg0N4MPGZqVmv2rCoP267496AOXUZjA4=
194
-github.com/xanzy/ssh-agent v0.3.3 h1:+/15pJfg/RsTxqYcX6fHqOXZwwMP+2VyYWJeWM2qQFM=
195
-github.com/xanzy/ssh-agent v0.3.3/go.mod h1:6dzNDKs0J9rVPHPhaGCukekBHKqfl+L3KghI1Bc68Uw=
196
-github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342 h1:FnBeRrxr7OU4VvAzt5X7s6266i6cSVkkFPS0TuXWbIg=
197
-github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342/go.mod h1:Ohn+xnUBiLI6FVj/9LpzZWtj1/D6lUovWYBkxHVV3aM=
198
-go-micro.dev/v4 v4.11.0 h1:DZ2xcr0pnZJDlp6MJiCLhw4tXRxLw9xrJlPT91kubr0=
199
-go-micro.dev/v4 v4.11.0/go.mod h1:eE/tD53n3KbVrzrWxKLxdkGw45Fg1qaNLWjpJMvIUF4=
123
+go.mongodb.org/mongo-driver v1.17.6 h1:87JUG1wZfWsr6rIz3ZmpH90rL5tea7O3IHuSwHUpsss=
124
+go.mongodb.org/mongo-driver v1.17.6/go.mod h1:Hy04i7O2kC4RS06ZrhPRqj/u4DTYkFDAAccj+rVKqgQ=
200 125
 go.opentelemetry.io/otel v1.28.0 h1:/SqNcYk+idO0CxKEUOtKQClMK/MimZihKYMruSMViUo=
201 126
 go.opentelemetry.io/otel v1.28.0/go.mod h1:q68ijF8Fc8CnMHKyzqL6akLO46ePnjkgfIMIjUIX9z4=
202 127
 go.opentelemetry.io/otel/metric v1.28.0 h1:f0HGvSl1KRAU1DLgLGFjrwVyismPlnuU6JD6bOeuA5Q=
203 128
 go.opentelemetry.io/otel/metric v1.28.0/go.mod h1:Fb1eVBFZmLVTMb6PPohq3TO9IIhUisDsbJoL/+uQW4s=
129
+go.opentelemetry.io/otel/sdk v1.21.0 h1:FTt8qirL1EysG6sTQRZ5TokkU8d0ugCj8htOgThZXQ8=
130
+go.opentelemetry.io/otel/sdk v1.21.0/go.mod h1:Nna6Yv7PWTdgJHVRD9hIYywQBRx7pbox6nwBnZIxl/E=
204 131
 go.opentelemetry.io/otel/trace v1.28.0 h1:GhQ9cUuQGmNDd5BTCP2dAvv75RdMxEfTmYejp+lkx9g=
205 132
 go.opentelemetry.io/otel/trace v1.28.0/go.mod h1:jPyXzNPg6da9+38HEwElrQiHlVMTnVfM3/yv2OlIHaI=
206 133
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
@@ -212,18 +139,12 @@ go.uber.org/zap v1.27.1/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
212 139
 golang.org/x/crypto v0.0.0-20181029021203-45a5f77698d3/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
213 140
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
214 141
 golang.org/x/crypto v0.0.0-20190923035154-9ee001bba392/go.mod h1:/lpIB1dKB+9EgE3H3cr1v9wB50oz8l4C4h62xy7jSTY=
215
-golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
216
-golang.org/x/crypto v0.45.0 h1:jMBrvKuj23MTlT0bQEOBcAE0mjg8mK9RXFhRH6nyF3Q=
217
-golang.org/x/crypto v0.45.0/go.mod h1:XTGrrkGJve7CYK7J8PEww4aY7gM3qMCElcJQ8n8JdX4=
218
-golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56 h1:2dVuKD2vS7b0QIHQbpyTISPd0LeHDbnYEryqj5Q1ug8=
219
-golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56/go.mod h1:M4RDyNAINzryxdtnbRXRL/OHtkFuWGRjvuhBJpk2IlY=
220 142
 golang.org/x/mod v0.30.0 h1:fDEXFVZ/fmCKProc/yAXXUijritrDzahmwwefnjoPFk=
221 143
 golang.org/x/mod v0.30.0/go.mod h1:lAsf5O2EvJeSFMiBxXDki7sCgAxEUcZHXoXMKT4GJKc=
222 144
 golang.org/x/net v0.0.0-20181023162649-9b4f9f5ad519/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
223 145
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
224 146
 golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
225 147
 golang.org/x/net v0.0.0-20190923162816-aa69164e4478/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
226
-golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
227 148
 golang.org/x/net v0.47.0 h1:Mx+4dIFzqraBXUugkia1OOvlD6LemFo1ALMHjrXDOhY=
228 149
 golang.org/x/net v0.47.0/go.mod h1:/jNxtkgq5yWUGYkaZGqo27cfGZ1c5Nen03aYrrKpVRU=
229 150
 golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@@ -241,40 +162,22 @@ golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7w
241 162
 golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
242 163
 golang.org/x/sys v0.0.0-20200124204421-9fbb57f87de9/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
243 164
 golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
244
-golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
245
-golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
246
-golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
247
-golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
248
-golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
249
-golang.org/x/sys v0.0.0-20220908164124-27713097b956/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
250 165
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
251 166
 golang.org/x/sys v0.38.0 h1:3yZWxaJjBmCWXqhN1qh02AkOnCQ1poK6oF+a7xWL6Gc=
252 167
 golang.org/x/sys v0.38.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
253
-golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
254
-golang.org/x/term v0.37.0 h1:8EGAD0qCmHYZg6J17DvsMy9/wJ7/D/4pV/wfnld5lTU=
255
-golang.org/x/term v0.37.0/go.mod h1:5pB4lxRNYYVZuTLmy8oR2BH8dflOR+IbTYFD8fi3254=
256 168
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
257 169
 golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
258
-golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
259
-golang.org/x/text v0.31.0 h1:aC8ghyu4JhP8VojJ2lEHBnochRno1sgL6nEi9WGFGMM=
260
-golang.org/x/text v0.31.0/go.mod h1:tKRAlv61yKIjGGHX/4tP1LTbc13YSec1pxVEWXzfoeM=
261 170
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
262 171
 golang.org/x/tools v0.0.0-20190907020128-2ca718005c18/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
263 172
 golang.org/x/tools v0.39.0 h1:ik4ho21kwuQln40uelmciQPp9SipgNDdrafrYA4TmQQ=
264 173
 golang.org/x/tools v0.39.0/go.mod h1:JnefbkDPyD8UU2kI5fuf8ZX4/yUeh9W877ZeBONxUqQ=
265 174
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
266
-google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE=
267
-google.golang.org/protobuf v1.36.10/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
268 175
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
269 176
 gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
270 177
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
271 178
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
272 179
 gopkg.in/natefinch/lumberjack.v2 v2.2.1 h1:bBRl1b0OH9s/DuPhuXpNl+VtCaJXFZ5/uEFST95x9zc=
273 180
 gopkg.in/natefinch/lumberjack.v2 v2.2.1/go.mod h1:YD8tP3GAjkrDg1eZH7EGmyESg/lsYskCTPBJVb9jqSc=
274
-gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
275
-gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
276
-gopkg.in/warnings.v0 v0.1.2 h1:wFXVbFY8DY5/xOe1ECiWdKCzZlxgshcYVNkBHstARME=
277
-gopkg.in/warnings.v0 v0.1.2/go.mod h1:jksf8JmL6Qr/oQM2OXTHunEvvTAsrWBLb6OOjuVWRNI=
278 181
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
279 182
 gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
280 183
 gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=

+ 0
- 68
handlers/base.go View File

@@ -1,68 +0,0 @@
1
-package handlers
2
-
3
-import (
4
-	"encoding/json"
5
-	"net/http"
6
-	"time"
7
-
8
-	"git.x2erp.com/qdy/go-base/logger"
9
-	"git.x2erp.com/qdy/go-db/factory/database"
10
-)
11
-
12
-type BaseHandlers struct {
13
-	ServiceName    string
14
-	ServiceVersion string
15
-}
16
-
17
-func NewBaseHandlers(name, version string) *BaseHandlers {
18
-	return &BaseHandlers{
19
-		ServiceName:    name,
20
-		ServiceVersion: version,
21
-	}
22
-}
23
-
24
-// RootHandler 根处理器
25
-func (h *BaseHandlers) RootHandler() http.HandlerFunc {
26
-	return func(w http.ResponseWriter, r *http.Request) {
27
-		logger.Debug("接收到根路径请求")
28
-		w.Header().Set("Content-Type", "application/json")
29
-		w.WriteHeader(http.StatusOK)
30
-		w.Write([]byte(`{"service": "` + h.ServiceName + `", "version": "` + h.ServiceVersion + `", "status": "running"}`))
31
-	}
32
-}
33
-
34
-// HealthHandler 健康检查处理器
35
-func (h *BaseHandlers) HealthHandler(dbFactory *database.DBFactory) http.HandlerFunc {
36
-	return func(w http.ResponseWriter, r *http.Request) {
37
-		logger.Debug("接收到健康检查请求")
38
-		w.Header().Set("Content-Type", "application/json")
39
-
40
-		if dbFactory == nil {
41
-			w.WriteHeader(http.StatusServiceUnavailable)
42
-			w.Write([]byte(`{"status": "unhealthy", "error": "database not initialized"}`))
43
-			return
44
-		}
45
-
46
-		w.WriteHeader(http.StatusOK)
47
-		w.Write([]byte(`{"status": "healthy", "service": "` + h.ServiceName + `"}`))
48
-	}
49
-}
50
-
51
-// InfoHandler 信息处理器
52
-func (h *BaseHandlers) InfoHandler() http.HandlerFunc {
53
-	return func(w http.ResponseWriter, r *http.Request) {
54
-		logger.Debug("接收到信息查询请求")
55
-		w.Header().Set("Content-Type", "application/json")
56
-
57
-		info := map[string]interface{}{
58
-			"service":   h.ServiceName,
59
-			"version":   h.ServiceVersion,
60
-			"status":    "running",
61
-			"timestamp": time.Now().Format(time.RFC3339),
62
-		}
63
-
64
-		jsonData, _ := json.Marshal(info)
65
-		w.WriteHeader(http.StatusOK)
66
-		w.Write(jsonData)
67
-	}
68
-}

+ 2
- 2
middleware/auth_middleware.go View File

@@ -9,7 +9,7 @@ import (
9 9
 	"git.x2erp.com/qdy/go-base/config"
10 10
 	"git.x2erp.com/qdy/go-base/ctx"
11 11
 	"git.x2erp.com/qdy/go-base/logger"
12
-	"git.x2erp.com/qdy/go-base/types"
12
+	"git.x2erp.com/qdy/go-base/model/response"
13 13
 )
14 14
 
15 15
 // 全局配置(单例)
@@ -99,7 +99,7 @@ func sendAuthError(w http.ResponseWriter, message string, format ResponseFormat)
99 99
 		w.Write([]byte("unauthorized," + message + "\n"))
100 100
 	default:
101 101
 		w.Header().Set("Content-Type", "application/json")
102
-		json.NewEncoder(w).Encode(&types.QueryResult[map[string]interface{}]{
102
+		json.NewEncoder(w).Encode(&response.QueryResult[map[string]interface{}]{
103 103
 			Success: false,
104 104
 			Error:   message,
105 105
 			Time:    time.Now().Format(time.RFC3339),

models/bson_model.go → model/bson/bson_model.go View File

@@ -1,4 +1,4 @@
1
-package models
1
+package bson
2 2
 
3 3
 import (
4 4
 	"time"

types/types.go → model/request/requset_model.go View File

@@ -1,9 +1,7 @@
1
-package types
1
+package request
2 2
 
3 3
 import (
4 4
 	"time"
5
-
6
-	"git.x2erp.com/qdy/go-base/ctx"
7 5
 )
8 6
 
9 7
 // ExchangeRequest 创建交换机的请求
@@ -103,24 +101,3 @@ type QueryRequest struct {
103 101
 	DorisTable       string                 `json:"dorisTable,omitempty"`       //doris数据库里的表名称
104 102
 
105 103
 }
106
-
107
-// QueryResult 查询结果
108
-type QueryResult[T any] struct {
109
-	Success    bool                `json:"success"`
110
-	Data       T                   `json:"data,omitempty"`
111
-	Error      string              `json:"error,omitempty"`
112
-	Count      int                 `json:"count,omitempty"`
113
-	Time       string              `json:"time,omitempty"`
114
-	QueryTime  time.Duration       `json:"queryTime,omitempty"`
115
-	SaveTime   time.Duration       `json:"saveTime,omitempty"`
116
-	TotalCount int                 `json:"totalCount,omitempty"`
117
-	Message    string              `json:"message,omitempty"`
118
-	Metadata   *ctx.RequestContext `json:"metadata,omitempty"`
119
-}
120
-
121
-// HealthCheck 健康检查
122
-type HealthCheck struct {
123
-	Status    string    `json:"status"`
124
-	Timestamp time.Time `json:"timestamp"`
125
-	Version   string    `json:"version"`
126
-}

+ 28
- 0
model/response/response_model.go View File

@@ -0,0 +1,28 @@
1
+package response
2
+
3
+import (
4
+	"time"
5
+
6
+	"git.x2erp.com/qdy/go-base/ctx"
7
+)
8
+
9
+// QueryResult 查询结果
10
+type QueryResult[T any] struct {
11
+	Success    bool                `json:"success"`
12
+	Data       T                   `json:"data,omitempty"`
13
+	Error      string              `json:"error,omitempty"`
14
+	Count      int                 `json:"count,omitempty"`
15
+	Time       string              `json:"time,omitempty"`
16
+	QueryTime  time.Duration       `json:"queryTime,omitempty"`
17
+	SaveTime   time.Duration       `json:"saveTime,omitempty"`
18
+	TotalCount int                 `json:"totalCount,omitempty"`
19
+	Message    string              `json:"message,omitempty"`
20
+	Metadata   *ctx.RequestContext `json:"metadata,omitempty"`
21
+}
22
+
23
+// HealthCheck 健康检查
24
+type HealthCheck struct {
25
+	Status    string    `json:"status"`
26
+	Timestamp time.Time `json:"timestamp"`
27
+	Version   string    `json:"version"`
28
+}

myservice/create_error_result.go → util/create_error_result.go View File

@@ -1,17 +1,17 @@
1
-package myservice
1
+package util
2 2
 
3 3
 import (
4 4
 	"time"
5 5
 
6 6
 	"git.x2erp.com/qdy/go-base/ctx"
7 7
 	"git.x2erp.com/qdy/go-base/logger"
8
-	"git.x2erp.com/qdy/go-base/types"
8
+	"git.x2erp.com/qdy/go-base/model/response"
9 9
 )
10 10
 
11 11
 //	CreateErrorResult 创建错误结果的泛型辅助函数
12 12
 //
13 13
 // T 是 QueryResult 中 Data 字段的类型
14
-func CreateErrorResult[T any](errorMsg string, startTime time.Time, reqCtx *ctx.RequestContext) *types.QueryResult[T] {
14
+func CreateErrorResult[T any](errorMsg string, startTime time.Time, reqCtx *ctx.RequestContext) *response.QueryResult[T] {
15 15
 	// 使用 *new(T) 获取 T 类型的零值指针
16 16
 	var zeroValue T
17 17
 	return createResult(zeroValue, false, errorMsg, startTime, reqCtx)
@@ -20,23 +20,23 @@ func CreateErrorResult[T any](errorMsg string, startTime time.Time, reqCtx *ctx.
20 20
 // CreateSuccessResult 建立返回成功对象
21 21
 //
22 22
 //	T 是 QueryResult 中 Data 字段的类型
23
-func CreateSuccessResultData[T any](data T, startTime time.Time, reqCtx *ctx.RequestContext) *types.QueryResult[T] {
23
+func CreateSuccessResultData[T any](data T, startTime time.Time, reqCtx *ctx.RequestContext) *response.QueryResult[T] {
24 24
 	return createResult(data, true, "", startTime, reqCtx)
25 25
 }
26 26
 
27
-func CreateSuccessResult[T any](startTime time.Time, reqCtx *ctx.RequestContext) *types.QueryResult[T] {
27
+func CreateSuccessResult[T any](startTime time.Time, reqCtx *ctx.RequestContext) *response.QueryResult[T] {
28 28
 	var zeroValue T
29 29
 	return createResult(zeroValue, true, "", startTime, reqCtx)
30 30
 }
31 31
 
32
-func createResult[T any](data T, success bool, msg string, startTime time.Time, reqCtx *ctx.RequestContext) *types.QueryResult[T] {
32
+func createResult[T any](data T, success bool, msg string, startTime time.Time, reqCtx *ctx.RequestContext) *response.QueryResult[T] {
33 33
 	if success {
34 34
 		logger.DebugC(reqCtx, msg)
35 35
 	} else {
36 36
 		logger.ErrorC(reqCtx, msg)
37 37
 	}
38 38
 
39
-	return &types.QueryResult[T]{
39
+	return &response.QueryResult[T]{
40 40
 		Success:  success,
41 41
 		Error:    msg,
42 42
 		Time:     time.Since(startTime).String(),

myservice/crypto_service.go → util/crypto_service.go View File

@@ -1,4 +1,4 @@
1
-package myservice
1
+package util
2 2
 
3 3
 import (
4 4
 	"crypto/aes"

mycsv/writer.go → util/csv_writer.go View File

@@ -1,4 +1,4 @@
1
-package mycsv
1
+package util
2 2
 
3 3
 import (
4 4
 	"encoding/csv"

utils/modle_util.go → util/modle_util.go View File

@@ -1,4 +1,4 @@
1
-package utils
1
+package util
2 2
 
3 3
 import (
4 4
 	"reflect"

Loading…
Cancel
Save