Skip to content

Commit 011cc9b

Browse files
huaapphuaapp
committed
update dashboard
1 parent 6590461 commit 011cc9b

2 files changed

Lines changed: 639 additions & 0 deletions

File tree

‎service/dashboard/dasApi/main.go‎

Lines changed: 221 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,221 @@
1+
package main
2+
3+
import (
4+
"encoding/json"
5+
"github.com/code/bottos/service/dashboard/proto"
6+
"github.com/micro/go-micro"
7+
api "github.com/micro/micro/api/proto"
8+
"golang.org/x/net/context"
9+
log "github.com/jeanphorn/log4go"
10+
"github.com/code/bottos/config"
11+
)
12+
13+
type Dashboard struct {
14+
Client dashboard.DashboardClient
15+
}
16+
17+
func (s *Dashboard) GetAllTxNum(ctx context.Context, req *api.Request, rsp *api.Response) error {
18+
response, err := s.Client.GetAllTxNum(ctx, &dashboard.GetAllTxNumRequest{})
19+
if err != nil {
20+
return err
21+
}
22+
23+
rsp.StatusCode = 200
24+
b, _ := json.Marshal(map[string]interface{}{
25+
"code": response.Code,
26+
"data": response.Data,
27+
"msg":"OK",
28+
})
29+
rsp.Body = string(b)
30+
return nil
31+
}
32+
33+
func (s *Dashboard) GetRecentTxList(ctx context.Context, req *api.Request, rsp *api.Response) error {
34+
body := req.Body
35+
log.Info(body)
36+
var dashboardRecentTxList dashboard.GetRecentTxListRequest
37+
err := json.Unmarshal([]byte(body), &dashboardRecentTxList)
38+
response, err := s.Client.GetRecentTxList(ctx, &dashboardRecentTxList)
39+
if err != nil {
40+
log.Error(err)
41+
}
42+
43+
rsp.StatusCode = 200
44+
b, _ := json.Marshal(map[string]interface{}{
45+
"code": response.Code,
46+
"data": response.Data,
47+
"msg":"OK",
48+
})
49+
rsp.Body = string(b)
50+
return nil
51+
}
52+
53+
func (s *Dashboard) GetBlockList(ctx context.Context, req *api.Request, rsp *api.Response) error {
54+
body := req.Body
55+
log.Info(body)
56+
var blockListRequest dashboard.GetBlockListRequest
57+
err := json.Unmarshal([]byte(body), &blockListRequest)
58+
response, err := s.Client.GetBlockList(ctx, &blockListRequest)
59+
if err != nil {
60+
log.Error(err)
61+
}
62+
63+
rsp.StatusCode = 200
64+
b, _ := json.Marshal(map[string]interface{}{
65+
"code": response.Code,
66+
"data": response.Data,
67+
"msg":"OK",
68+
})
69+
rsp.Body = string(b)
70+
return nil
71+
}
72+
73+
func (s *Dashboard) GetNodeInfos(ctx context.Context, req *api.Request, rsp *api.Response) error {
74+
response, err := s.Client.GetNodeInfos(ctx, &dashboard.GetNodeInfosRequest{})
75+
if err != nil {
76+
return err
77+
}
78+
79+
rsp.StatusCode = 200
80+
b, _ := json.Marshal(map[string]interface{}{
81+
"code": response.Code,
82+
"data": response.Data,
83+
"msg":"OK",
84+
})
85+
rsp.Body = string(b)
86+
return nil
87+
}
88+
89+
func (s *Dashboard) GetRequirementNumByDay(ctx context.Context, req *api.Request, rsp *api.Response) error {
90+
response, err := s.Client.GetRequirementNumByDay(ctx, &dashboard.GetRequirementNumByDayRequest{})
91+
if err != nil {
92+
return err
93+
}
94+
95+
rsp.StatusCode = 200
96+
b, _ := json.Marshal(map[string]interface{}{
97+
"code": response.Code,
98+
"data": response.Data,
99+
"msg":"OK",
100+
})
101+
rsp.Body = string(b)
102+
return nil
103+
}
104+
105+
func (s *Dashboard) GetAssetNumByDay(ctx context.Context, req *api.Request, rsp *api.Response) error {
106+
response, err := s.Client.GetAssetNumByDay(ctx, &dashboard.GetAssetNumByDayRequest{})
107+
if err != nil {
108+
return err
109+
}
110+
111+
rsp.StatusCode = 200
112+
b, _ := json.Marshal(map[string]interface{}{
113+
"code": response.Code,
114+
"data": response.Data,
115+
"msg":"OK",
116+
})
117+
rsp.Body = string(b)
118+
return nil
119+
}
120+
121+
func (s *Dashboard) GetAccountNumByDay(ctx context.Context, req *api.Request, rsp *api.Response) error {
122+
response, err := s.Client.GetAccountNumByDay(ctx, &dashboard.GetAccountNumByDayRequest{})
123+
if err != nil {
124+
return err
125+
}
126+
127+
rsp.StatusCode = 200
128+
b, _ := json.Marshal(map[string]interface{}{
129+
"code": response.Code,
130+
"data": response.Data,
131+
"msg":"OK",
132+
})
133+
rsp.Body = string(b)
134+
return nil
135+
}
136+
137+
func (s *Dashboard) GetSumTxAmount(ctx context.Context, req *api.Request, rsp *api.Response) error {
138+
response, err := s.Client.GetSumTxAmount(ctx, &dashboard.GetSumTxAmountRequest{})
139+
if err != nil {
140+
return err
141+
}
142+
143+
rsp.StatusCode = 200
144+
b, _ := json.Marshal(map[string]interface{}{
145+
"code": response.Code,
146+
"data": response.Data,
147+
"msg":"OK",
148+
})
149+
rsp.Body = string(b)
150+
return nil
151+
}
152+
153+
func (s *Dashboard) GetTxNumByDay(ctx context.Context, req *api.Request, rsp *api.Response) error {
154+
response, err := s.Client.GetTxNumByDay(ctx, &dashboard.GetTxNumByDayRequest{})
155+
if err != nil {
156+
return err
157+
}
158+
159+
rsp.StatusCode = 200
160+
b, _ := json.Marshal(map[string]interface{}{
161+
"code": response.Code,
162+
"data": response.Data,
163+
"msg":"OK",
164+
})
165+
rsp.Body = string(b)
166+
return nil
167+
}
168+
169+
func (s *Dashboard) GetTxAmountByDay(ctx context.Context, req *api.Request, rsp *api.Response) error {
170+
response, err := s.Client.GetTxAmountByDay(ctx, &dashboard.GetTxAmountByDayRequest{})
171+
if err != nil {
172+
return err
173+
}
174+
175+
rsp.StatusCode = 200
176+
b, _ := json.Marshal(map[string]interface{}{
177+
"code": response.Code,
178+
"data": response.Data,
179+
"msg":"OK",
180+
})
181+
rsp.Body = string(b)
182+
return nil
183+
}
184+
185+
func (s *Dashboard) GetAllTypeTotal(ctx context.Context, req *api.Request, rsp *api.Response) error {
186+
response, err := s.Client.GetAllTypeTotal(ctx, &dashboard.GetAllTypeTotalRequest{})
187+
if err != nil {
188+
return err
189+
}
190+
191+
rsp.StatusCode = 200
192+
b, _ := json.Marshal(map[string]interface{}{
193+
"code": response.Code,
194+
"data": response.Data,
195+
"msg":"OK",
196+
})
197+
rsp.Body = string(b)
198+
return nil
199+
}
200+
201+
func main() {
202+
log.LoadConfiguration(config.BASE_LOG_CONF)
203+
defer log.Close()
204+
log.LOGGER("dashboard.api")
205+
206+
service := micro.NewService(
207+
micro.Name("go.micro.api.v2.dashboard"),
208+
)
209+
210+
// parse command line flags
211+
service.Init()
212+
213+
service.Server().Handle(
214+
service.Server().NewHandler(
215+
&Dashboard{Client: dashboard.NewDashboardClient("go.micro.srv.dashboard", service.Client())},
216+
),
217+
)
218+
if err := service.Run(); err != nil {
219+
log.Exit(err)
220+
}
221+
}

0 commit comments

Comments
 (0)