wx_grpc.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554
  1. // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
  2. package wx
  3. import (
  4. context "context"
  5. account "git.ikuban.com/server/pw-protobuf/api/account"
  6. common "git.ikuban.com/server/pw-protobuf/api/common"
  7. grpc "google.golang.org/grpc"
  8. codes "google.golang.org/grpc/codes"
  9. status "google.golang.org/grpc/status"
  10. emptypb "google.golang.org/protobuf/types/known/emptypb"
  11. )
  12. // This is a compile-time assertion to ensure that this generated file
  13. // is compatible with the grpc package it is being compiled against.
  14. // Requires gRPC-Go v1.32.0 or later.
  15. const _ = grpc.SupportPackageIsVersion7
  16. // WxClient is the client API for Wx service.
  17. //
  18. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
  19. type WxClient interface {
  20. // 定时发送签到提醒
  21. CronSignInUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
  22. // 定时发送未读消息提醒
  23. CronSendUnreadTemplate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
  24. // 未读发送模板消息
  25. SendNewMessageUnreadReminder(ctx context.Context, in *SendNewMessageUnreadReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  26. // 好友访问提醒
  27. SendNewVisitorTemplateReminder(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*emptypb.Empty, error)
  28. // 移除用户已读
  29. ReduceUserUnread(ctx context.Context, in *ReduceUserUnreadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  30. // 获取key对应的参数
  31. GetUserMsgByKey(ctx context.Context, in *GetUserMsgByKeyRequest, opts ...grpc.CallOption) (*GetUserMsgByKeyReply, error)
  32. // 微信SDK初始化
  33. WxConf(ctx context.Context, in *common.WxConfReq, opts ...grpc.CallOption) (*common.WxConfResponse, error)
  34. // 通过微信下载语音并上传到七牛
  35. UploadMaterialVoice(ctx context.Context, in *account.MediaID, opts ...grpc.CallOption) (*account.MaterialLink, error)
  36. // 定时删除过期选择
  37. CronDeleteOldUserSelect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
  38. GetAccessToken(ctx context.Context, in *GetAccessTokenRequest, opts ...grpc.CallOption) (*GetAccessTokenReply, error)
  39. SendNewVisitorReminder(ctx context.Context, in *OpenIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  40. SendAIReply(ctx context.Context, in *SendAIReplyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  41. GetWxGzhQrcode(ctx context.Context, in *GetWxGzhQrcodeRequest, opts ...grpc.CallOption) (*GetWxGzhQrcodeReply, error)
  42. }
  43. type wxClient struct {
  44. cc grpc.ClientConnInterface
  45. }
  46. func NewWxClient(cc grpc.ClientConnInterface) WxClient {
  47. return &wxClient{cc}
  48. }
  49. func (c *wxClient) CronSignInUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  50. out := new(emptypb.Empty)
  51. err := c.cc.Invoke(ctx, "/api.wx.Wx/CronSignInUser", in, out, opts...)
  52. if err != nil {
  53. return nil, err
  54. }
  55. return out, nil
  56. }
  57. func (c *wxClient) CronSendUnreadTemplate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  58. out := new(emptypb.Empty)
  59. err := c.cc.Invoke(ctx, "/api.wx.Wx/CronSendUnreadTemplate", in, out, opts...)
  60. if err != nil {
  61. return nil, err
  62. }
  63. return out, nil
  64. }
  65. func (c *wxClient) SendNewMessageUnreadReminder(ctx context.Context, in *SendNewMessageUnreadReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  66. out := new(emptypb.Empty)
  67. err := c.cc.Invoke(ctx, "/api.wx.Wx/SendNewMessageUnreadReminder", in, out, opts...)
  68. if err != nil {
  69. return nil, err
  70. }
  71. return out, nil
  72. }
  73. func (c *wxClient) SendNewVisitorTemplateReminder(ctx context.Context, in *common.PersonIDParam, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  74. out := new(emptypb.Empty)
  75. err := c.cc.Invoke(ctx, "/api.wx.Wx/SendNewVisitorTemplateReminder", in, out, opts...)
  76. if err != nil {
  77. return nil, err
  78. }
  79. return out, nil
  80. }
  81. func (c *wxClient) ReduceUserUnread(ctx context.Context, in *ReduceUserUnreadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  82. out := new(emptypb.Empty)
  83. err := c.cc.Invoke(ctx, "/api.wx.Wx/ReduceUserUnread", in, out, opts...)
  84. if err != nil {
  85. return nil, err
  86. }
  87. return out, nil
  88. }
  89. func (c *wxClient) GetUserMsgByKey(ctx context.Context, in *GetUserMsgByKeyRequest, opts ...grpc.CallOption) (*GetUserMsgByKeyReply, error) {
  90. out := new(GetUserMsgByKeyReply)
  91. err := c.cc.Invoke(ctx, "/api.wx.Wx/GetUserMsgByKey", in, out, opts...)
  92. if err != nil {
  93. return nil, err
  94. }
  95. return out, nil
  96. }
  97. func (c *wxClient) WxConf(ctx context.Context, in *common.WxConfReq, opts ...grpc.CallOption) (*common.WxConfResponse, error) {
  98. out := new(common.WxConfResponse)
  99. err := c.cc.Invoke(ctx, "/api.wx.Wx/WxConf", in, out, opts...)
  100. if err != nil {
  101. return nil, err
  102. }
  103. return out, nil
  104. }
  105. func (c *wxClient) UploadMaterialVoice(ctx context.Context, in *account.MediaID, opts ...grpc.CallOption) (*account.MaterialLink, error) {
  106. out := new(account.MaterialLink)
  107. err := c.cc.Invoke(ctx, "/api.wx.Wx/UploadMaterialVoice", in, out, opts...)
  108. if err != nil {
  109. return nil, err
  110. }
  111. return out, nil
  112. }
  113. func (c *wxClient) CronDeleteOldUserSelect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  114. out := new(emptypb.Empty)
  115. err := c.cc.Invoke(ctx, "/api.wx.Wx/CronDeleteOldUserSelect", in, out, opts...)
  116. if err != nil {
  117. return nil, err
  118. }
  119. return out, nil
  120. }
  121. func (c *wxClient) GetAccessToken(ctx context.Context, in *GetAccessTokenRequest, opts ...grpc.CallOption) (*GetAccessTokenReply, error) {
  122. out := new(GetAccessTokenReply)
  123. err := c.cc.Invoke(ctx, "/api.wx.Wx/GetAccessToken", in, out, opts...)
  124. if err != nil {
  125. return nil, err
  126. }
  127. return out, nil
  128. }
  129. func (c *wxClient) SendNewVisitorReminder(ctx context.Context, in *OpenIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  130. out := new(emptypb.Empty)
  131. err := c.cc.Invoke(ctx, "/api.wx.Wx/SendNewVisitorReminder", in, out, opts...)
  132. if err != nil {
  133. return nil, err
  134. }
  135. return out, nil
  136. }
  137. func (c *wxClient) SendAIReply(ctx context.Context, in *SendAIReplyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  138. out := new(emptypb.Empty)
  139. err := c.cc.Invoke(ctx, "/api.wx.Wx/SendAIReply", in, out, opts...)
  140. if err != nil {
  141. return nil, err
  142. }
  143. return out, nil
  144. }
  145. func (c *wxClient) GetWxGzhQrcode(ctx context.Context, in *GetWxGzhQrcodeRequest, opts ...grpc.CallOption) (*GetWxGzhQrcodeReply, error) {
  146. out := new(GetWxGzhQrcodeReply)
  147. err := c.cc.Invoke(ctx, "/api.wx.Wx/GetWxGzhQrcode", in, out, opts...)
  148. if err != nil {
  149. return nil, err
  150. }
  151. return out, nil
  152. }
  153. // WxServer is the server API for Wx service.
  154. // All implementations must embed UnimplementedWxServer
  155. // for forward compatibility
  156. type WxServer interface {
  157. // 定时发送签到提醒
  158. CronSignInUser(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
  159. // 定时发送未读消息提醒
  160. CronSendUnreadTemplate(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
  161. // 未读发送模板消息
  162. SendNewMessageUnreadReminder(context.Context, *SendNewMessageUnreadReminderRequest) (*emptypb.Empty, error)
  163. // 好友访问提醒
  164. SendNewVisitorTemplateReminder(context.Context, *common.PersonIDParam) (*emptypb.Empty, error)
  165. // 移除用户已读
  166. ReduceUserUnread(context.Context, *ReduceUserUnreadRequest) (*emptypb.Empty, error)
  167. // 获取key对应的参数
  168. GetUserMsgByKey(context.Context, *GetUserMsgByKeyRequest) (*GetUserMsgByKeyReply, error)
  169. // 微信SDK初始化
  170. WxConf(context.Context, *common.WxConfReq) (*common.WxConfResponse, error)
  171. // 通过微信下载语音并上传到七牛
  172. UploadMaterialVoice(context.Context, *account.MediaID) (*account.MaterialLink, error)
  173. // 定时删除过期选择
  174. CronDeleteOldUserSelect(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
  175. GetAccessToken(context.Context, *GetAccessTokenRequest) (*GetAccessTokenReply, error)
  176. SendNewVisitorReminder(context.Context, *OpenIDRequest) (*emptypb.Empty, error)
  177. SendAIReply(context.Context, *SendAIReplyRequest) (*emptypb.Empty, error)
  178. GetWxGzhQrcode(context.Context, *GetWxGzhQrcodeRequest) (*GetWxGzhQrcodeReply, error)
  179. mustEmbedUnimplementedWxServer()
  180. }
  181. // UnimplementedWxServer must be embedded to have forward compatible implementations.
  182. type UnimplementedWxServer struct {
  183. }
  184. func (UnimplementedWxServer) CronSignInUser(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
  185. return nil, status.Errorf(codes.Unimplemented, "method CronSignInUser not implemented")
  186. }
  187. func (UnimplementedWxServer) CronSendUnreadTemplate(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
  188. return nil, status.Errorf(codes.Unimplemented, "method CronSendUnreadTemplate not implemented")
  189. }
  190. func (UnimplementedWxServer) SendNewMessageUnreadReminder(context.Context, *SendNewMessageUnreadReminderRequest) (*emptypb.Empty, error) {
  191. return nil, status.Errorf(codes.Unimplemented, "method SendNewMessageUnreadReminder not implemented")
  192. }
  193. func (UnimplementedWxServer) SendNewVisitorTemplateReminder(context.Context, *common.PersonIDParam) (*emptypb.Empty, error) {
  194. return nil, status.Errorf(codes.Unimplemented, "method SendNewVisitorTemplateReminder not implemented")
  195. }
  196. func (UnimplementedWxServer) ReduceUserUnread(context.Context, *ReduceUserUnreadRequest) (*emptypb.Empty, error) {
  197. return nil, status.Errorf(codes.Unimplemented, "method ReduceUserUnread not implemented")
  198. }
  199. func (UnimplementedWxServer) GetUserMsgByKey(context.Context, *GetUserMsgByKeyRequest) (*GetUserMsgByKeyReply, error) {
  200. return nil, status.Errorf(codes.Unimplemented, "method GetUserMsgByKey not implemented")
  201. }
  202. func (UnimplementedWxServer) WxConf(context.Context, *common.WxConfReq) (*common.WxConfResponse, error) {
  203. return nil, status.Errorf(codes.Unimplemented, "method WxConf not implemented")
  204. }
  205. func (UnimplementedWxServer) UploadMaterialVoice(context.Context, *account.MediaID) (*account.MaterialLink, error) {
  206. return nil, status.Errorf(codes.Unimplemented, "method UploadMaterialVoice not implemented")
  207. }
  208. func (UnimplementedWxServer) CronDeleteOldUserSelect(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
  209. return nil, status.Errorf(codes.Unimplemented, "method CronDeleteOldUserSelect not implemented")
  210. }
  211. func (UnimplementedWxServer) GetAccessToken(context.Context, *GetAccessTokenRequest) (*GetAccessTokenReply, error) {
  212. return nil, status.Errorf(codes.Unimplemented, "method GetAccessToken not implemented")
  213. }
  214. func (UnimplementedWxServer) SendNewVisitorReminder(context.Context, *OpenIDRequest) (*emptypb.Empty, error) {
  215. return nil, status.Errorf(codes.Unimplemented, "method SendNewVisitorReminder not implemented")
  216. }
  217. func (UnimplementedWxServer) SendAIReply(context.Context, *SendAIReplyRequest) (*emptypb.Empty, error) {
  218. return nil, status.Errorf(codes.Unimplemented, "method SendAIReply not implemented")
  219. }
  220. func (UnimplementedWxServer) GetWxGzhQrcode(context.Context, *GetWxGzhQrcodeRequest) (*GetWxGzhQrcodeReply, error) {
  221. return nil, status.Errorf(codes.Unimplemented, "method GetWxGzhQrcode not implemented")
  222. }
  223. func (UnimplementedWxServer) mustEmbedUnimplementedWxServer() {}
  224. // UnsafeWxServer may be embedded to opt out of forward compatibility for this service.
  225. // Use of this interface is not recommended, as added methods to WxServer will
  226. // result in compilation errors.
  227. type UnsafeWxServer interface {
  228. mustEmbedUnimplementedWxServer()
  229. }
  230. func RegisterWxServer(s grpc.ServiceRegistrar, srv WxServer) {
  231. s.RegisterService(&Wx_ServiceDesc, srv)
  232. }
  233. func _Wx_CronSignInUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  234. in := new(emptypb.Empty)
  235. if err := dec(in); err != nil {
  236. return nil, err
  237. }
  238. if interceptor == nil {
  239. return srv.(WxServer).CronSignInUser(ctx, in)
  240. }
  241. info := &grpc.UnaryServerInfo{
  242. Server: srv,
  243. FullMethod: "/api.wx.Wx/CronSignInUser",
  244. }
  245. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  246. return srv.(WxServer).CronSignInUser(ctx, req.(*emptypb.Empty))
  247. }
  248. return interceptor(ctx, in, info, handler)
  249. }
  250. func _Wx_CronSendUnreadTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  251. in := new(emptypb.Empty)
  252. if err := dec(in); err != nil {
  253. return nil, err
  254. }
  255. if interceptor == nil {
  256. return srv.(WxServer).CronSendUnreadTemplate(ctx, in)
  257. }
  258. info := &grpc.UnaryServerInfo{
  259. Server: srv,
  260. FullMethod: "/api.wx.Wx/CronSendUnreadTemplate",
  261. }
  262. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  263. return srv.(WxServer).CronSendUnreadTemplate(ctx, req.(*emptypb.Empty))
  264. }
  265. return interceptor(ctx, in, info, handler)
  266. }
  267. func _Wx_SendNewMessageUnreadReminder_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  268. in := new(SendNewMessageUnreadReminderRequest)
  269. if err := dec(in); err != nil {
  270. return nil, err
  271. }
  272. if interceptor == nil {
  273. return srv.(WxServer).SendNewMessageUnreadReminder(ctx, in)
  274. }
  275. info := &grpc.UnaryServerInfo{
  276. Server: srv,
  277. FullMethod: "/api.wx.Wx/SendNewMessageUnreadReminder",
  278. }
  279. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  280. return srv.(WxServer).SendNewMessageUnreadReminder(ctx, req.(*SendNewMessageUnreadReminderRequest))
  281. }
  282. return interceptor(ctx, in, info, handler)
  283. }
  284. func _Wx_SendNewVisitorTemplateReminder_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  285. in := new(common.PersonIDParam)
  286. if err := dec(in); err != nil {
  287. return nil, err
  288. }
  289. if interceptor == nil {
  290. return srv.(WxServer).SendNewVisitorTemplateReminder(ctx, in)
  291. }
  292. info := &grpc.UnaryServerInfo{
  293. Server: srv,
  294. FullMethod: "/api.wx.Wx/SendNewVisitorTemplateReminder",
  295. }
  296. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  297. return srv.(WxServer).SendNewVisitorTemplateReminder(ctx, req.(*common.PersonIDParam))
  298. }
  299. return interceptor(ctx, in, info, handler)
  300. }
  301. func _Wx_ReduceUserUnread_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  302. in := new(ReduceUserUnreadRequest)
  303. if err := dec(in); err != nil {
  304. return nil, err
  305. }
  306. if interceptor == nil {
  307. return srv.(WxServer).ReduceUserUnread(ctx, in)
  308. }
  309. info := &grpc.UnaryServerInfo{
  310. Server: srv,
  311. FullMethod: "/api.wx.Wx/ReduceUserUnread",
  312. }
  313. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  314. return srv.(WxServer).ReduceUserUnread(ctx, req.(*ReduceUserUnreadRequest))
  315. }
  316. return interceptor(ctx, in, info, handler)
  317. }
  318. func _Wx_GetUserMsgByKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  319. in := new(GetUserMsgByKeyRequest)
  320. if err := dec(in); err != nil {
  321. return nil, err
  322. }
  323. if interceptor == nil {
  324. return srv.(WxServer).GetUserMsgByKey(ctx, in)
  325. }
  326. info := &grpc.UnaryServerInfo{
  327. Server: srv,
  328. FullMethod: "/api.wx.Wx/GetUserMsgByKey",
  329. }
  330. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  331. return srv.(WxServer).GetUserMsgByKey(ctx, req.(*GetUserMsgByKeyRequest))
  332. }
  333. return interceptor(ctx, in, info, handler)
  334. }
  335. func _Wx_WxConf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  336. in := new(common.WxConfReq)
  337. if err := dec(in); err != nil {
  338. return nil, err
  339. }
  340. if interceptor == nil {
  341. return srv.(WxServer).WxConf(ctx, in)
  342. }
  343. info := &grpc.UnaryServerInfo{
  344. Server: srv,
  345. FullMethod: "/api.wx.Wx/WxConf",
  346. }
  347. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  348. return srv.(WxServer).WxConf(ctx, req.(*common.WxConfReq))
  349. }
  350. return interceptor(ctx, in, info, handler)
  351. }
  352. func _Wx_UploadMaterialVoice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  353. in := new(account.MediaID)
  354. if err := dec(in); err != nil {
  355. return nil, err
  356. }
  357. if interceptor == nil {
  358. return srv.(WxServer).UploadMaterialVoice(ctx, in)
  359. }
  360. info := &grpc.UnaryServerInfo{
  361. Server: srv,
  362. FullMethod: "/api.wx.Wx/UploadMaterialVoice",
  363. }
  364. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  365. return srv.(WxServer).UploadMaterialVoice(ctx, req.(*account.MediaID))
  366. }
  367. return interceptor(ctx, in, info, handler)
  368. }
  369. func _Wx_CronDeleteOldUserSelect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  370. in := new(emptypb.Empty)
  371. if err := dec(in); err != nil {
  372. return nil, err
  373. }
  374. if interceptor == nil {
  375. return srv.(WxServer).CronDeleteOldUserSelect(ctx, in)
  376. }
  377. info := &grpc.UnaryServerInfo{
  378. Server: srv,
  379. FullMethod: "/api.wx.Wx/CronDeleteOldUserSelect",
  380. }
  381. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  382. return srv.(WxServer).CronDeleteOldUserSelect(ctx, req.(*emptypb.Empty))
  383. }
  384. return interceptor(ctx, in, info, handler)
  385. }
  386. func _Wx_GetAccessToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  387. in := new(GetAccessTokenRequest)
  388. if err := dec(in); err != nil {
  389. return nil, err
  390. }
  391. if interceptor == nil {
  392. return srv.(WxServer).GetAccessToken(ctx, in)
  393. }
  394. info := &grpc.UnaryServerInfo{
  395. Server: srv,
  396. FullMethod: "/api.wx.Wx/GetAccessToken",
  397. }
  398. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  399. return srv.(WxServer).GetAccessToken(ctx, req.(*GetAccessTokenRequest))
  400. }
  401. return interceptor(ctx, in, info, handler)
  402. }
  403. func _Wx_SendNewVisitorReminder_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  404. in := new(OpenIDRequest)
  405. if err := dec(in); err != nil {
  406. return nil, err
  407. }
  408. if interceptor == nil {
  409. return srv.(WxServer).SendNewVisitorReminder(ctx, in)
  410. }
  411. info := &grpc.UnaryServerInfo{
  412. Server: srv,
  413. FullMethod: "/api.wx.Wx/SendNewVisitorReminder",
  414. }
  415. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  416. return srv.(WxServer).SendNewVisitorReminder(ctx, req.(*OpenIDRequest))
  417. }
  418. return interceptor(ctx, in, info, handler)
  419. }
  420. func _Wx_SendAIReply_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  421. in := new(SendAIReplyRequest)
  422. if err := dec(in); err != nil {
  423. return nil, err
  424. }
  425. if interceptor == nil {
  426. return srv.(WxServer).SendAIReply(ctx, in)
  427. }
  428. info := &grpc.UnaryServerInfo{
  429. Server: srv,
  430. FullMethod: "/api.wx.Wx/SendAIReply",
  431. }
  432. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  433. return srv.(WxServer).SendAIReply(ctx, req.(*SendAIReplyRequest))
  434. }
  435. return interceptor(ctx, in, info, handler)
  436. }
  437. func _Wx_GetWxGzhQrcode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  438. in := new(GetWxGzhQrcodeRequest)
  439. if err := dec(in); err != nil {
  440. return nil, err
  441. }
  442. if interceptor == nil {
  443. return srv.(WxServer).GetWxGzhQrcode(ctx, in)
  444. }
  445. info := &grpc.UnaryServerInfo{
  446. Server: srv,
  447. FullMethod: "/api.wx.Wx/GetWxGzhQrcode",
  448. }
  449. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  450. return srv.(WxServer).GetWxGzhQrcode(ctx, req.(*GetWxGzhQrcodeRequest))
  451. }
  452. return interceptor(ctx, in, info, handler)
  453. }
  454. // Wx_ServiceDesc is the grpc.ServiceDesc for Wx service.
  455. // It's only intended for direct use with grpc.RegisterService,
  456. // and not to be introspected or modified (even as a copy)
  457. var Wx_ServiceDesc = grpc.ServiceDesc{
  458. ServiceName: "api.wx.Wx",
  459. HandlerType: (*WxServer)(nil),
  460. Methods: []grpc.MethodDesc{
  461. {
  462. MethodName: "CronSignInUser",
  463. Handler: _Wx_CronSignInUser_Handler,
  464. },
  465. {
  466. MethodName: "CronSendUnreadTemplate",
  467. Handler: _Wx_CronSendUnreadTemplate_Handler,
  468. },
  469. {
  470. MethodName: "SendNewMessageUnreadReminder",
  471. Handler: _Wx_SendNewMessageUnreadReminder_Handler,
  472. },
  473. {
  474. MethodName: "SendNewVisitorTemplateReminder",
  475. Handler: _Wx_SendNewVisitorTemplateReminder_Handler,
  476. },
  477. {
  478. MethodName: "ReduceUserUnread",
  479. Handler: _Wx_ReduceUserUnread_Handler,
  480. },
  481. {
  482. MethodName: "GetUserMsgByKey",
  483. Handler: _Wx_GetUserMsgByKey_Handler,
  484. },
  485. {
  486. MethodName: "WxConf",
  487. Handler: _Wx_WxConf_Handler,
  488. },
  489. {
  490. MethodName: "UploadMaterialVoice",
  491. Handler: _Wx_UploadMaterialVoice_Handler,
  492. },
  493. {
  494. MethodName: "CronDeleteOldUserSelect",
  495. Handler: _Wx_CronDeleteOldUserSelect_Handler,
  496. },
  497. {
  498. MethodName: "GetAccessToken",
  499. Handler: _Wx_GetAccessToken_Handler,
  500. },
  501. {
  502. MethodName: "SendNewVisitorReminder",
  503. Handler: _Wx_SendNewVisitorReminder_Handler,
  504. },
  505. {
  506. MethodName: "SendAIReply",
  507. Handler: _Wx_SendAIReply_Handler,
  508. },
  509. {
  510. MethodName: "GetWxGzhQrcode",
  511. Handler: _Wx_GetWxGzhQrcode_Handler,
  512. },
  513. },
  514. Streams: []grpc.StreamDesc{},
  515. Metadata: "wx.proto",
  516. }