organization_grpc.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479
  1. // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
  2. // versions:
  3. // - protoc-gen-go-grpc v1.3.0
  4. // - protoc v3.21.12
  5. // source: organization.proto
  6. package pb
  7. import (
  8. context "context"
  9. grpc "google.golang.org/grpc"
  10. codes "google.golang.org/grpc/codes"
  11. status "google.golang.org/grpc/status"
  12. )
  13. // This is a compile-time assertion to ensure that this generated file
  14. // is compatible with the grpc package it is being compiled against.
  15. // Requires gRPC-Go v1.32.0 or later.
  16. const _ = grpc.SupportPackageIsVersion7
  17. const (
  18. Organization_GetWorkingUfByCode_FullMethodName = "/pb.Organization/GetWorkingUfByCode"
  19. Organization_GetWorkingRoByCode_FullMethodName = "/pb.Organization/GetWorkingRoByCode"
  20. Organization_GetWorkingChestByCode_FullMethodName = "/pb.Organization/GetWorkingChestByCode"
  21. Organization_GetWorkingPumpByCode_FullMethodName = "/pb.Organization/GetWorkingPumpByCode"
  22. Organization_GetWorkingValveByCode_FullMethodName = "/pb.Organization/GetWorkingValveByCode"
  23. Organization_MultiAddItemHistoryData_FullMethodName = "/pb.Organization/MultiAddItemHistoryData"
  24. Organization_ItemHistoryDataList_FullMethodName = "/pb.Organization/ItemHistoryDataList"
  25. Organization_ItemHistoryDataByTime_FullMethodName = "/pb.Organization/ItemHistoryDataByTime"
  26. Organization_ItemHistoryDataMaxMinByTime_FullMethodName = "/pb.Organization/ItemHistoryDataMaxMinByTime"
  27. Organization_ItemHistoryDataFirstLastByTime_FullMethodName = "/pb.Organization/ItemHistoryDataFirstLastByTime"
  28. Organization_ChangeTypeItemHistoryData_FullMethodName = "/pb.Organization/ChangeTypeItemHistoryData"
  29. )
  30. // OrganizationClient is the client API for Organization service.
  31. //
  32. // 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.
  33. type OrganizationClient interface {
  34. GetWorkingUfByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingUfByCodeResp, error)
  35. GetWorkingRoByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingRoByCodeResp, error)
  36. GetWorkingChestByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingChestByCodeResp, error)
  37. GetWorkingPumpByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingPumpByCodeResp, error)
  38. GetWorkingValveByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingValveByCodeResp, error)
  39. MultiAddItemHistoryData(ctx context.Context, in *MultiAddItemHistoryDataReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataResp, error)
  40. ItemHistoryDataList(ctx context.Context, in *ItemHistoryDataListReq, opts ...grpc.CallOption) (*ItemHistoryDataListResp, error)
  41. ItemHistoryDataByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataListResp, error)
  42. ItemHistoryDataMaxMinByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataMaxMinResp, error)
  43. ItemHistoryDataFirstLastByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataFirstLastResp, error)
  44. ChangeTypeItemHistoryData(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ChangeTypeItemHistoryDataResp, error)
  45. }
  46. type organizationClient struct {
  47. cc grpc.ClientConnInterface
  48. }
  49. func NewOrganizationClient(cc grpc.ClientConnInterface) OrganizationClient {
  50. return &organizationClient{cc}
  51. }
  52. func (c *organizationClient) GetWorkingUfByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingUfByCodeResp, error) {
  53. out := new(GetWorkingUfByCodeResp)
  54. err := c.cc.Invoke(ctx, Organization_GetWorkingUfByCode_FullMethodName, in, out, opts...)
  55. if err != nil {
  56. return nil, err
  57. }
  58. return out, nil
  59. }
  60. func (c *organizationClient) GetWorkingRoByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingRoByCodeResp, error) {
  61. out := new(GetWorkingRoByCodeResp)
  62. err := c.cc.Invoke(ctx, Organization_GetWorkingRoByCode_FullMethodName, in, out, opts...)
  63. if err != nil {
  64. return nil, err
  65. }
  66. return out, nil
  67. }
  68. func (c *organizationClient) GetWorkingChestByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingChestByCodeResp, error) {
  69. out := new(GetWorkingChestByCodeResp)
  70. err := c.cc.Invoke(ctx, Organization_GetWorkingChestByCode_FullMethodName, in, out, opts...)
  71. if err != nil {
  72. return nil, err
  73. }
  74. return out, nil
  75. }
  76. func (c *organizationClient) GetWorkingPumpByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingPumpByCodeResp, error) {
  77. out := new(GetWorkingPumpByCodeResp)
  78. err := c.cc.Invoke(ctx, Organization_GetWorkingPumpByCode_FullMethodName, in, out, opts...)
  79. if err != nil {
  80. return nil, err
  81. }
  82. return out, nil
  83. }
  84. func (c *organizationClient) GetWorkingValveByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingValveByCodeResp, error) {
  85. out := new(GetWorkingValveByCodeResp)
  86. err := c.cc.Invoke(ctx, Organization_GetWorkingValveByCode_FullMethodName, in, out, opts...)
  87. if err != nil {
  88. return nil, err
  89. }
  90. return out, nil
  91. }
  92. func (c *organizationClient) MultiAddItemHistoryData(ctx context.Context, in *MultiAddItemHistoryDataReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataResp, error) {
  93. out := new(MultiAddItemHistoryDataResp)
  94. err := c.cc.Invoke(ctx, Organization_MultiAddItemHistoryData_FullMethodName, in, out, opts...)
  95. if err != nil {
  96. return nil, err
  97. }
  98. return out, nil
  99. }
  100. func (c *organizationClient) ItemHistoryDataList(ctx context.Context, in *ItemHistoryDataListReq, opts ...grpc.CallOption) (*ItemHistoryDataListResp, error) {
  101. out := new(ItemHistoryDataListResp)
  102. err := c.cc.Invoke(ctx, Organization_ItemHistoryDataList_FullMethodName, in, out, opts...)
  103. if err != nil {
  104. return nil, err
  105. }
  106. return out, nil
  107. }
  108. func (c *organizationClient) ItemHistoryDataByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataListResp, error) {
  109. out := new(ItemHistoryDataListResp)
  110. err := c.cc.Invoke(ctx, Organization_ItemHistoryDataByTime_FullMethodName, in, out, opts...)
  111. if err != nil {
  112. return nil, err
  113. }
  114. return out, nil
  115. }
  116. func (c *organizationClient) ItemHistoryDataMaxMinByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataMaxMinResp, error) {
  117. out := new(ItemHistoryDataMaxMinResp)
  118. err := c.cc.Invoke(ctx, Organization_ItemHistoryDataMaxMinByTime_FullMethodName, in, out, opts...)
  119. if err != nil {
  120. return nil, err
  121. }
  122. return out, nil
  123. }
  124. func (c *organizationClient) ItemHistoryDataFirstLastByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataFirstLastResp, error) {
  125. out := new(ItemHistoryDataFirstLastResp)
  126. err := c.cc.Invoke(ctx, Organization_ItemHistoryDataFirstLastByTime_FullMethodName, in, out, opts...)
  127. if err != nil {
  128. return nil, err
  129. }
  130. return out, nil
  131. }
  132. func (c *organizationClient) ChangeTypeItemHistoryData(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ChangeTypeItemHistoryDataResp, error) {
  133. out := new(ChangeTypeItemHistoryDataResp)
  134. err := c.cc.Invoke(ctx, Organization_ChangeTypeItemHistoryData_FullMethodName, in, out, opts...)
  135. if err != nil {
  136. return nil, err
  137. }
  138. return out, nil
  139. }
  140. // OrganizationServer is the server API for Organization service.
  141. // All implementations must embed UnimplementedOrganizationServer
  142. // for forward compatibility
  143. type OrganizationServer interface {
  144. GetWorkingUfByCode(context.Context, *DcWorkingReq) (*GetWorkingUfByCodeResp, error)
  145. GetWorkingRoByCode(context.Context, *DcWorkingReq) (*GetWorkingRoByCodeResp, error)
  146. GetWorkingChestByCode(context.Context, *DcWorkingReq) (*GetWorkingChestByCodeResp, error)
  147. GetWorkingPumpByCode(context.Context, *DcWorkingReq) (*GetWorkingPumpByCodeResp, error)
  148. GetWorkingValveByCode(context.Context, *DcWorkingReq) (*GetWorkingValveByCodeResp, error)
  149. MultiAddItemHistoryData(context.Context, *MultiAddItemHistoryDataReq) (*MultiAddItemHistoryDataResp, error)
  150. ItemHistoryDataList(context.Context, *ItemHistoryDataListReq) (*ItemHistoryDataListResp, error)
  151. ItemHistoryDataByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataListResp, error)
  152. ItemHistoryDataMaxMinByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataMaxMinResp, error)
  153. ItemHistoryDataFirstLastByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataFirstLastResp, error)
  154. ChangeTypeItemHistoryData(context.Context, *ItemHistoryDataByTimeReq) (*ChangeTypeItemHistoryDataResp, error)
  155. mustEmbedUnimplementedOrganizationServer()
  156. }
  157. // UnimplementedOrganizationServer must be embedded to have forward compatible implementations.
  158. type UnimplementedOrganizationServer struct {
  159. }
  160. func (UnimplementedOrganizationServer) GetWorkingUfByCode(context.Context, *DcWorkingReq) (*GetWorkingUfByCodeResp, error) {
  161. return nil, status.Errorf(codes.Unimplemented, "method GetWorkingUfByCode not implemented")
  162. }
  163. func (UnimplementedOrganizationServer) GetWorkingRoByCode(context.Context, *DcWorkingReq) (*GetWorkingRoByCodeResp, error) {
  164. return nil, status.Errorf(codes.Unimplemented, "method GetWorkingRoByCode not implemented")
  165. }
  166. func (UnimplementedOrganizationServer) GetWorkingChestByCode(context.Context, *DcWorkingReq) (*GetWorkingChestByCodeResp, error) {
  167. return nil, status.Errorf(codes.Unimplemented, "method GetWorkingChestByCode not implemented")
  168. }
  169. func (UnimplementedOrganizationServer) GetWorkingPumpByCode(context.Context, *DcWorkingReq) (*GetWorkingPumpByCodeResp, error) {
  170. return nil, status.Errorf(codes.Unimplemented, "method GetWorkingPumpByCode not implemented")
  171. }
  172. func (UnimplementedOrganizationServer) GetWorkingValveByCode(context.Context, *DcWorkingReq) (*GetWorkingValveByCodeResp, error) {
  173. return nil, status.Errorf(codes.Unimplemented, "method GetWorkingValveByCode not implemented")
  174. }
  175. func (UnimplementedOrganizationServer) MultiAddItemHistoryData(context.Context, *MultiAddItemHistoryDataReq) (*MultiAddItemHistoryDataResp, error) {
  176. return nil, status.Errorf(codes.Unimplemented, "method MultiAddItemHistoryData not implemented")
  177. }
  178. func (UnimplementedOrganizationServer) ItemHistoryDataList(context.Context, *ItemHistoryDataListReq) (*ItemHistoryDataListResp, error) {
  179. return nil, status.Errorf(codes.Unimplemented, "method ItemHistoryDataList not implemented")
  180. }
  181. func (UnimplementedOrganizationServer) ItemHistoryDataByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataListResp, error) {
  182. return nil, status.Errorf(codes.Unimplemented, "method ItemHistoryDataByTime not implemented")
  183. }
  184. func (UnimplementedOrganizationServer) ItemHistoryDataMaxMinByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataMaxMinResp, error) {
  185. return nil, status.Errorf(codes.Unimplemented, "method ItemHistoryDataMaxMinByTime not implemented")
  186. }
  187. func (UnimplementedOrganizationServer) ItemHistoryDataFirstLastByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataFirstLastResp, error) {
  188. return nil, status.Errorf(codes.Unimplemented, "method ItemHistoryDataFirstLastByTime not implemented")
  189. }
  190. func (UnimplementedOrganizationServer) ChangeTypeItemHistoryData(context.Context, *ItemHistoryDataByTimeReq) (*ChangeTypeItemHistoryDataResp, error) {
  191. return nil, status.Errorf(codes.Unimplemented, "method ChangeTypeItemHistoryData not implemented")
  192. }
  193. func (UnimplementedOrganizationServer) mustEmbedUnimplementedOrganizationServer() {}
  194. // UnsafeOrganizationServer may be embedded to opt out of forward compatibility for this service.
  195. // Use of this interface is not recommended, as added methods to OrganizationServer will
  196. // result in compilation errors.
  197. type UnsafeOrganizationServer interface {
  198. mustEmbedUnimplementedOrganizationServer()
  199. }
  200. func RegisterOrganizationServer(s grpc.ServiceRegistrar, srv OrganizationServer) {
  201. s.RegisterService(&Organization_ServiceDesc, srv)
  202. }
  203. func _Organization_GetWorkingUfByCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  204. in := new(DcWorkingReq)
  205. if err := dec(in); err != nil {
  206. return nil, err
  207. }
  208. if interceptor == nil {
  209. return srv.(OrganizationServer).GetWorkingUfByCode(ctx, in)
  210. }
  211. info := &grpc.UnaryServerInfo{
  212. Server: srv,
  213. FullMethod: Organization_GetWorkingUfByCode_FullMethodName,
  214. }
  215. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  216. return srv.(OrganizationServer).GetWorkingUfByCode(ctx, req.(*DcWorkingReq))
  217. }
  218. return interceptor(ctx, in, info, handler)
  219. }
  220. func _Organization_GetWorkingRoByCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  221. in := new(DcWorkingReq)
  222. if err := dec(in); err != nil {
  223. return nil, err
  224. }
  225. if interceptor == nil {
  226. return srv.(OrganizationServer).GetWorkingRoByCode(ctx, in)
  227. }
  228. info := &grpc.UnaryServerInfo{
  229. Server: srv,
  230. FullMethod: Organization_GetWorkingRoByCode_FullMethodName,
  231. }
  232. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  233. return srv.(OrganizationServer).GetWorkingRoByCode(ctx, req.(*DcWorkingReq))
  234. }
  235. return interceptor(ctx, in, info, handler)
  236. }
  237. func _Organization_GetWorkingChestByCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  238. in := new(DcWorkingReq)
  239. if err := dec(in); err != nil {
  240. return nil, err
  241. }
  242. if interceptor == nil {
  243. return srv.(OrganizationServer).GetWorkingChestByCode(ctx, in)
  244. }
  245. info := &grpc.UnaryServerInfo{
  246. Server: srv,
  247. FullMethod: Organization_GetWorkingChestByCode_FullMethodName,
  248. }
  249. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  250. return srv.(OrganizationServer).GetWorkingChestByCode(ctx, req.(*DcWorkingReq))
  251. }
  252. return interceptor(ctx, in, info, handler)
  253. }
  254. func _Organization_GetWorkingPumpByCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  255. in := new(DcWorkingReq)
  256. if err := dec(in); err != nil {
  257. return nil, err
  258. }
  259. if interceptor == nil {
  260. return srv.(OrganizationServer).GetWorkingPumpByCode(ctx, in)
  261. }
  262. info := &grpc.UnaryServerInfo{
  263. Server: srv,
  264. FullMethod: Organization_GetWorkingPumpByCode_FullMethodName,
  265. }
  266. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  267. return srv.(OrganizationServer).GetWorkingPumpByCode(ctx, req.(*DcWorkingReq))
  268. }
  269. return interceptor(ctx, in, info, handler)
  270. }
  271. func _Organization_GetWorkingValveByCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  272. in := new(DcWorkingReq)
  273. if err := dec(in); err != nil {
  274. return nil, err
  275. }
  276. if interceptor == nil {
  277. return srv.(OrganizationServer).GetWorkingValveByCode(ctx, in)
  278. }
  279. info := &grpc.UnaryServerInfo{
  280. Server: srv,
  281. FullMethod: Organization_GetWorkingValveByCode_FullMethodName,
  282. }
  283. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  284. return srv.(OrganizationServer).GetWorkingValveByCode(ctx, req.(*DcWorkingReq))
  285. }
  286. return interceptor(ctx, in, info, handler)
  287. }
  288. func _Organization_MultiAddItemHistoryData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  289. in := new(MultiAddItemHistoryDataReq)
  290. if err := dec(in); err != nil {
  291. return nil, err
  292. }
  293. if interceptor == nil {
  294. return srv.(OrganizationServer).MultiAddItemHistoryData(ctx, in)
  295. }
  296. info := &grpc.UnaryServerInfo{
  297. Server: srv,
  298. FullMethod: Organization_MultiAddItemHistoryData_FullMethodName,
  299. }
  300. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  301. return srv.(OrganizationServer).MultiAddItemHistoryData(ctx, req.(*MultiAddItemHistoryDataReq))
  302. }
  303. return interceptor(ctx, in, info, handler)
  304. }
  305. func _Organization_ItemHistoryDataList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  306. in := new(ItemHistoryDataListReq)
  307. if err := dec(in); err != nil {
  308. return nil, err
  309. }
  310. if interceptor == nil {
  311. return srv.(OrganizationServer).ItemHistoryDataList(ctx, in)
  312. }
  313. info := &grpc.UnaryServerInfo{
  314. Server: srv,
  315. FullMethod: Organization_ItemHistoryDataList_FullMethodName,
  316. }
  317. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  318. return srv.(OrganizationServer).ItemHistoryDataList(ctx, req.(*ItemHistoryDataListReq))
  319. }
  320. return interceptor(ctx, in, info, handler)
  321. }
  322. func _Organization_ItemHistoryDataByTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  323. in := new(ItemHistoryDataByTimeReq)
  324. if err := dec(in); err != nil {
  325. return nil, err
  326. }
  327. if interceptor == nil {
  328. return srv.(OrganizationServer).ItemHistoryDataByTime(ctx, in)
  329. }
  330. info := &grpc.UnaryServerInfo{
  331. Server: srv,
  332. FullMethod: Organization_ItemHistoryDataByTime_FullMethodName,
  333. }
  334. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  335. return srv.(OrganizationServer).ItemHistoryDataByTime(ctx, req.(*ItemHistoryDataByTimeReq))
  336. }
  337. return interceptor(ctx, in, info, handler)
  338. }
  339. func _Organization_ItemHistoryDataMaxMinByTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  340. in := new(ItemHistoryDataByTimeReq)
  341. if err := dec(in); err != nil {
  342. return nil, err
  343. }
  344. if interceptor == nil {
  345. return srv.(OrganizationServer).ItemHistoryDataMaxMinByTime(ctx, in)
  346. }
  347. info := &grpc.UnaryServerInfo{
  348. Server: srv,
  349. FullMethod: Organization_ItemHistoryDataMaxMinByTime_FullMethodName,
  350. }
  351. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  352. return srv.(OrganizationServer).ItemHistoryDataMaxMinByTime(ctx, req.(*ItemHistoryDataByTimeReq))
  353. }
  354. return interceptor(ctx, in, info, handler)
  355. }
  356. func _Organization_ItemHistoryDataFirstLastByTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  357. in := new(ItemHistoryDataByTimeReq)
  358. if err := dec(in); err != nil {
  359. return nil, err
  360. }
  361. if interceptor == nil {
  362. return srv.(OrganizationServer).ItemHistoryDataFirstLastByTime(ctx, in)
  363. }
  364. info := &grpc.UnaryServerInfo{
  365. Server: srv,
  366. FullMethod: Organization_ItemHistoryDataFirstLastByTime_FullMethodName,
  367. }
  368. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  369. return srv.(OrganizationServer).ItemHistoryDataFirstLastByTime(ctx, req.(*ItemHistoryDataByTimeReq))
  370. }
  371. return interceptor(ctx, in, info, handler)
  372. }
  373. func _Organization_ChangeTypeItemHistoryData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  374. in := new(ItemHistoryDataByTimeReq)
  375. if err := dec(in); err != nil {
  376. return nil, err
  377. }
  378. if interceptor == nil {
  379. return srv.(OrganizationServer).ChangeTypeItemHistoryData(ctx, in)
  380. }
  381. info := &grpc.UnaryServerInfo{
  382. Server: srv,
  383. FullMethod: Organization_ChangeTypeItemHistoryData_FullMethodName,
  384. }
  385. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  386. return srv.(OrganizationServer).ChangeTypeItemHistoryData(ctx, req.(*ItemHistoryDataByTimeReq))
  387. }
  388. return interceptor(ctx, in, info, handler)
  389. }
  390. // Organization_ServiceDesc is the grpc.ServiceDesc for Organization service.
  391. // It's only intended for direct use with grpc.RegisterService,
  392. // and not to be introspected or modified (even as a copy)
  393. var Organization_ServiceDesc = grpc.ServiceDesc{
  394. ServiceName: "pb.Organization",
  395. HandlerType: (*OrganizationServer)(nil),
  396. Methods: []grpc.MethodDesc{
  397. {
  398. MethodName: "GetWorkingUfByCode",
  399. Handler: _Organization_GetWorkingUfByCode_Handler,
  400. },
  401. {
  402. MethodName: "GetWorkingRoByCode",
  403. Handler: _Organization_GetWorkingRoByCode_Handler,
  404. },
  405. {
  406. MethodName: "GetWorkingChestByCode",
  407. Handler: _Organization_GetWorkingChestByCode_Handler,
  408. },
  409. {
  410. MethodName: "GetWorkingPumpByCode",
  411. Handler: _Organization_GetWorkingPumpByCode_Handler,
  412. },
  413. {
  414. MethodName: "GetWorkingValveByCode",
  415. Handler: _Organization_GetWorkingValveByCode_Handler,
  416. },
  417. {
  418. MethodName: "MultiAddItemHistoryData",
  419. Handler: _Organization_MultiAddItemHistoryData_Handler,
  420. },
  421. {
  422. MethodName: "ItemHistoryDataList",
  423. Handler: _Organization_ItemHistoryDataList_Handler,
  424. },
  425. {
  426. MethodName: "ItemHistoryDataByTime",
  427. Handler: _Organization_ItemHistoryDataByTime_Handler,
  428. },
  429. {
  430. MethodName: "ItemHistoryDataMaxMinByTime",
  431. Handler: _Organization_ItemHistoryDataMaxMinByTime_Handler,
  432. },
  433. {
  434. MethodName: "ItemHistoryDataFirstLastByTime",
  435. Handler: _Organization_ItemHistoryDataFirstLastByTime_Handler,
  436. },
  437. {
  438. MethodName: "ChangeTypeItemHistoryData",
  439. Handler: _Organization_ChangeTypeItemHistoryData_Handler,
  440. },
  441. },
  442. Streams: []grpc.StreamDesc{},
  443. Metadata: "organization.proto",
  444. }