MiFaZhan
38 lines
1.4 KiB
Go
38 lines
1.4 KiB
Go
package httpclient
|
|
|
|
import (
|
|
"context"
|
|
|
|
"git.5iot.com/iotlcm-public/iotlcm-upstream-chan/internal/pub/xjpubconsts"
|
|
"git.5iot.com/iotlcm-public/iotlcm-upstream-chan/internal/pub/xjpubmodel"
|
|
"git.5iot.com/iotlcm-public/iotlcm-upstream-chan/internal/pub/xjpubmodel/response"
|
|
"git.5iot.com/iotlcm-public/iotlcm-upstream-chan/internal/pub/xjpubservice"
|
|
)
|
|
|
|
type sUpstreamProxyClient struct {
|
|
}
|
|
|
|
func NewUpstreamProxyClient() *sUpstreamProxyClient {
|
|
return &sUpstreamProxyClient{}
|
|
}
|
|
|
|
func init() {
|
|
xjpubservice.RegisterUpstreamProxyClient(NewUpstreamProxyClient())
|
|
}
|
|
|
|
// 物联网卡在线信息实时查询
|
|
func (s *sUpstreamProxyClient) QuerySimSession(ctx context.Context, input *xjpubmodel.SimSessionInput) (output *xjpubmodel.SimSessionOutput, err error) {
|
|
res := &response.ResponseGeneric[*xjpubmodel.SimSessionOutput]{}
|
|
err = xjpubservice.HttpClient().PostObj(ctx, xjpubconsts.ServiceNameYzUpstreamChanSvc, "/query/sim-session", input, res)
|
|
output = res.Data
|
|
return output, err
|
|
}
|
|
|
|
// 物联网卡卡状态查询
|
|
func (s *sUpstreamProxyClient) QuerySimCardStatus(ctx context.Context, input *xjpubmodel.SimCardStatusInput) (output *xjpubmodel.SimCardStatusOutput, err error) {
|
|
res := &response.ResponseGeneric[*xjpubmodel.SimCardStatusOutput]{}
|
|
err = xjpubservice.HttpClient().PostObj(ctx, xjpubconsts.ServiceNameYzUpstreamChanSvc, "/query/sim-status", input, res)
|
|
output = res.Data
|
|
return output, err
|
|
}
|