organization_grpc.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501
  1. // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
  2. // versions:
  3. // - protoc-gen-go-grpc v1.2.0
  4. // - protoc v4.23.4
  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. // OrganizationClient is the client API for Organization service.
  18. //
  19. // 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.
  20. type OrganizationClient interface {
  21. GetWorkingUfByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingUfByCodeResp, error)
  22. FindWorkingUfByCycle(ctx context.Context, in *FindWorkingUfByCycleReq, opts ...grpc.CallOption) (*FindWorkingUfByCycleResp, error)
  23. GetWorkingRoByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingRoByCodeResp, error)
  24. GetWorkingChestByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingChestByCodeResp, error)
  25. GetWorkingPumpByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingPumpByCodeResp, error)
  26. GetWorkingValveByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingValveByCodeResp, error)
  27. MultiAddItemHistoryData(ctx context.Context, in *MultiAddItemHistoryDataReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataResp, error)
  28. ItemHistoryDataList(ctx context.Context, in *ItemHistoryDataListReq, opts ...grpc.CallOption) (*ItemHistoryDataListResp, error)
  29. ItemHistoryDataByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataListResp, error)
  30. ItemHistoryDataMaxMinByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataMaxMinResp, error)
  31. ItemHistoryDataFirstLastByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataFirstLastResp, error)
  32. ChangeTypeItemHistoryData(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ChangeTypeItemHistoryDataResp, error)
  33. }
  34. type organizationClient struct {
  35. cc grpc.ClientConnInterface
  36. }
  37. func NewOrganizationClient(cc grpc.ClientConnInterface) OrganizationClient {
  38. return &organizationClient{cc}
  39. }
  40. func (c *organizationClient) GetWorkingUfByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingUfByCodeResp, error) {
  41. out := new(GetWorkingUfByCodeResp)
  42. err := c.cc.Invoke(ctx, "/pb.Organization/GetWorkingUfByCode", in, out, opts...)
  43. if err != nil {
  44. return nil, err
  45. }
  46. return out, nil
  47. }
  48. func (c *organizationClient) FindWorkingUfByCycle(ctx context.Context, in *FindWorkingUfByCycleReq, opts ...grpc.CallOption) (*FindWorkingUfByCycleResp, error) {
  49. out := new(FindWorkingUfByCycleResp)
  50. err := c.cc.Invoke(ctx, "/pb.Organization/FindWorkingUfByCycle", in, out, opts...)
  51. if err != nil {
  52. return nil, err
  53. }
  54. return out, nil
  55. }
  56. func (c *organizationClient) GetWorkingRoByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingRoByCodeResp, error) {
  57. out := new(GetWorkingRoByCodeResp)
  58. err := c.cc.Invoke(ctx, "/pb.Organization/GetWorkingRoByCode", in, out, opts...)
  59. if err != nil {
  60. return nil, err
  61. }
  62. return out, nil
  63. }
  64. func (c *organizationClient) GetWorkingChestByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingChestByCodeResp, error) {
  65. out := new(GetWorkingChestByCodeResp)
  66. err := c.cc.Invoke(ctx, "/pb.Organization/GetWorkingChestByCode", in, out, opts...)
  67. if err != nil {
  68. return nil, err
  69. }
  70. return out, nil
  71. }
  72. func (c *organizationClient) GetWorkingPumpByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingPumpByCodeResp, error) {
  73. out := new(GetWorkingPumpByCodeResp)
  74. err := c.cc.Invoke(ctx, "/pb.Organization/GetWorkingPumpByCode", in, out, opts...)
  75. if err != nil {
  76. return nil, err
  77. }
  78. return out, nil
  79. }
  80. func (c *organizationClient) GetWorkingValveByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*GetWorkingValveByCodeResp, error) {
  81. out := new(GetWorkingValveByCodeResp)
  82. err := c.cc.Invoke(ctx, "/pb.Organization/GetWorkingValveByCode", in, out, opts...)
  83. if err != nil {
  84. return nil, err
  85. }
  86. return out, nil
  87. }
  88. func (c *organizationClient) MultiAddItemHistoryData(ctx context.Context, in *MultiAddItemHistoryDataReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataResp, error) {
  89. out := new(MultiAddItemHistoryDataResp)
  90. err := c.cc.Invoke(ctx, "/pb.Organization/MultiAddItemHistoryData", in, out, opts...)
  91. if err != nil {
  92. return nil, err
  93. }
  94. return out, nil
  95. }
  96. func (c *organizationClient) ItemHistoryDataList(ctx context.Context, in *ItemHistoryDataListReq, opts ...grpc.CallOption) (*ItemHistoryDataListResp, error) {
  97. out := new(ItemHistoryDataListResp)
  98. err := c.cc.Invoke(ctx, "/pb.Organization/ItemHistoryDataList", in, out, opts...)
  99. if err != nil {
  100. return nil, err
  101. }
  102. return out, nil
  103. }
  104. func (c *organizationClient) ItemHistoryDataByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataListResp, error) {
  105. out := new(ItemHistoryDataListResp)
  106. err := c.cc.Invoke(ctx, "/pb.Organization/ItemHistoryDataByTime", in, out, opts...)
  107. if err != nil {
  108. return nil, err
  109. }
  110. return out, nil
  111. }
  112. func (c *organizationClient) ItemHistoryDataMaxMinByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataMaxMinResp, error) {
  113. out := new(ItemHistoryDataMaxMinResp)
  114. err := c.cc.Invoke(ctx, "/pb.Organization/ItemHistoryDataMaxMinByTime", in, out, opts...)
  115. if err != nil {
  116. return nil, err
  117. }
  118. return out, nil
  119. }
  120. func (c *organizationClient) ItemHistoryDataFirstLastByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ItemHistoryDataFirstLastResp, error) {
  121. out := new(ItemHistoryDataFirstLastResp)
  122. err := c.cc.Invoke(ctx, "/pb.Organization/ItemHistoryDataFirstLastByTime", in, out, opts...)
  123. if err != nil {
  124. return nil, err
  125. }
  126. return out, nil
  127. }
  128. func (c *organizationClient) ChangeTypeItemHistoryData(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*ChangeTypeItemHistoryDataResp, error) {
  129. out := new(ChangeTypeItemHistoryDataResp)
  130. err := c.cc.Invoke(ctx, "/pb.Organization/ChangeTypeItemHistoryData", in, out, opts...)
  131. if err != nil {
  132. return nil, err
  133. }
  134. return out, nil
  135. }
  136. // OrganizationServer is the server API for Organization service.
  137. // All implementations must embed UnimplementedOrganizationServer
  138. // for forward compatibility
  139. type OrganizationServer interface {
  140. GetWorkingUfByCode(context.Context, *DcWorkingReq) (*GetWorkingUfByCodeResp, error)
  141. FindWorkingUfByCycle(context.Context, *FindWorkingUfByCycleReq) (*FindWorkingUfByCycleResp, error)
  142. GetWorkingRoByCode(context.Context, *DcWorkingReq) (*GetWorkingRoByCodeResp, error)
  143. GetWorkingChestByCode(context.Context, *DcWorkingReq) (*GetWorkingChestByCodeResp, error)
  144. GetWorkingPumpByCode(context.Context, *DcWorkingReq) (*GetWorkingPumpByCodeResp, error)
  145. GetWorkingValveByCode(context.Context, *DcWorkingReq) (*GetWorkingValveByCodeResp, error)
  146. MultiAddItemHistoryData(context.Context, *MultiAddItemHistoryDataReq) (*MultiAddItemHistoryDataResp, error)
  147. ItemHistoryDataList(context.Context, *ItemHistoryDataListReq) (*ItemHistoryDataListResp, error)
  148. ItemHistoryDataByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataListResp, error)
  149. ItemHistoryDataMaxMinByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataMaxMinResp, error)
  150. ItemHistoryDataFirstLastByTime(context.Context, *ItemHistoryDataByTimeReq) (*ItemHistoryDataFirstLastResp, error)
  151. ChangeTypeItemHistoryData(context.Context, *ItemHistoryDataByTimeReq) (*ChangeTypeItemHistoryDataResp, error)
  152. mustEmbedUnimplementedOrganizationServer()
  153. }
  154. // UnimplementedOrganizationServer must be embedded to have forward compatible implementations.
  155. type UnimplementedOrganizationServer struct {
  156. }
  157. func (UnimplementedOrganizationServer) GetWorkingUfByCode(context.Context, *DcWorkingReq) (*GetWorkingUfByCodeResp, error) {
  158. return nil, status.Errorf(codes.Unimplemented, "method GetWorkingUfByCode not implemented")
  159. }
  160. func (UnimplementedOrganizationServer) FindWorkingUfByCycle(context.Context, *FindWorkingUfByCycleReq) (*FindWorkingUfByCycleResp, error) {
  161. return nil, status.Errorf(codes.Unimplemented, "method FindWorkingUfByCycle 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: "/pb.Organization/GetWorkingUfByCode",
  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_FindWorkingUfByCycle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  221. in := new(FindWorkingUfByCycleReq)
  222. if err := dec(in); err != nil {
  223. return nil, err
  224. }
  225. if interceptor == nil {
  226. return srv.(OrganizationServer).FindWorkingUfByCycle(ctx, in)
  227. }
  228. info := &grpc.UnaryServerInfo{
  229. Server: srv,
  230. FullMethod: "/pb.Organization/FindWorkingUfByCycle",
  231. }
  232. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  233. return srv.(OrganizationServer).FindWorkingUfByCycle(ctx, req.(*FindWorkingUfByCycleReq))
  234. }
  235. return interceptor(ctx, in, info, handler)
  236. }
  237. func _Organization_GetWorkingRoByCode_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).GetWorkingRoByCode(ctx, in)
  244. }
  245. info := &grpc.UnaryServerInfo{
  246. Server: srv,
  247. FullMethod: "/pb.Organization/GetWorkingRoByCode",
  248. }
  249. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  250. return srv.(OrganizationServer).GetWorkingRoByCode(ctx, req.(*DcWorkingReq))
  251. }
  252. return interceptor(ctx, in, info, handler)
  253. }
  254. func _Organization_GetWorkingChestByCode_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).GetWorkingChestByCode(ctx, in)
  261. }
  262. info := &grpc.UnaryServerInfo{
  263. Server: srv,
  264. FullMethod: "/pb.Organization/GetWorkingChestByCode",
  265. }
  266. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  267. return srv.(OrganizationServer).GetWorkingChestByCode(ctx, req.(*DcWorkingReq))
  268. }
  269. return interceptor(ctx, in, info, handler)
  270. }
  271. func _Organization_GetWorkingPumpByCode_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).GetWorkingPumpByCode(ctx, in)
  278. }
  279. info := &grpc.UnaryServerInfo{
  280. Server: srv,
  281. FullMethod: "/pb.Organization/GetWorkingPumpByCode",
  282. }
  283. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  284. return srv.(OrganizationServer).GetWorkingPumpByCode(ctx, req.(*DcWorkingReq))
  285. }
  286. return interceptor(ctx, in, info, handler)
  287. }
  288. func _Organization_GetWorkingValveByCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  289. in := new(DcWorkingReq)
  290. if err := dec(in); err != nil {
  291. return nil, err
  292. }
  293. if interceptor == nil {
  294. return srv.(OrganizationServer).GetWorkingValveByCode(ctx, in)
  295. }
  296. info := &grpc.UnaryServerInfo{
  297. Server: srv,
  298. FullMethod: "/pb.Organization/GetWorkingValveByCode",
  299. }
  300. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  301. return srv.(OrganizationServer).GetWorkingValveByCode(ctx, req.(*DcWorkingReq))
  302. }
  303. return interceptor(ctx, in, info, handler)
  304. }
  305. func _Organization_MultiAddItemHistoryData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  306. in := new(MultiAddItemHistoryDataReq)
  307. if err := dec(in); err != nil {
  308. return nil, err
  309. }
  310. if interceptor == nil {
  311. return srv.(OrganizationServer).MultiAddItemHistoryData(ctx, in)
  312. }
  313. info := &grpc.UnaryServerInfo{
  314. Server: srv,
  315. FullMethod: "/pb.Organization/MultiAddItemHistoryData",
  316. }
  317. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  318. return srv.(OrganizationServer).MultiAddItemHistoryData(ctx, req.(*MultiAddItemHistoryDataReq))
  319. }
  320. return interceptor(ctx, in, info, handler)
  321. }
  322. func _Organization_ItemHistoryDataList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  323. in := new(ItemHistoryDataListReq)
  324. if err := dec(in); err != nil {
  325. return nil, err
  326. }
  327. if interceptor == nil {
  328. return srv.(OrganizationServer).ItemHistoryDataList(ctx, in)
  329. }
  330. info := &grpc.UnaryServerInfo{
  331. Server: srv,
  332. FullMethod: "/pb.Organization/ItemHistoryDataList",
  333. }
  334. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  335. return srv.(OrganizationServer).ItemHistoryDataList(ctx, req.(*ItemHistoryDataListReq))
  336. }
  337. return interceptor(ctx, in, info, handler)
  338. }
  339. func _Organization_ItemHistoryDataByTime_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).ItemHistoryDataByTime(ctx, in)
  346. }
  347. info := &grpc.UnaryServerInfo{
  348. Server: srv,
  349. FullMethod: "/pb.Organization/ItemHistoryDataByTime",
  350. }
  351. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  352. return srv.(OrganizationServer).ItemHistoryDataByTime(ctx, req.(*ItemHistoryDataByTimeReq))
  353. }
  354. return interceptor(ctx, in, info, handler)
  355. }
  356. func _Organization_ItemHistoryDataMaxMinByTime_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).ItemHistoryDataMaxMinByTime(ctx, in)
  363. }
  364. info := &grpc.UnaryServerInfo{
  365. Server: srv,
  366. FullMethod: "/pb.Organization/ItemHistoryDataMaxMinByTime",
  367. }
  368. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  369. return srv.(OrganizationServer).ItemHistoryDataMaxMinByTime(ctx, req.(*ItemHistoryDataByTimeReq))
  370. }
  371. return interceptor(ctx, in, info, handler)
  372. }
  373. func _Organization_ItemHistoryDataFirstLastByTime_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).ItemHistoryDataFirstLastByTime(ctx, in)
  380. }
  381. info := &grpc.UnaryServerInfo{
  382. Server: srv,
  383. FullMethod: "/pb.Organization/ItemHistoryDataFirstLastByTime",
  384. }
  385. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  386. return srv.(OrganizationServer).ItemHistoryDataFirstLastByTime(ctx, req.(*ItemHistoryDataByTimeReq))
  387. }
  388. return interceptor(ctx, in, info, handler)
  389. }
  390. func _Organization_ChangeTypeItemHistoryData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  391. in := new(ItemHistoryDataByTimeReq)
  392. if err := dec(in); err != nil {
  393. return nil, err
  394. }
  395. if interceptor == nil {
  396. return srv.(OrganizationServer).ChangeTypeItemHistoryData(ctx, in)
  397. }
  398. info := &grpc.UnaryServerInfo{
  399. Server: srv,
  400. FullMethod: "/pb.Organization/ChangeTypeItemHistoryData",
  401. }
  402. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  403. return srv.(OrganizationServer).ChangeTypeItemHistoryData(ctx, req.(*ItemHistoryDataByTimeReq))
  404. }
  405. return interceptor(ctx, in, info, handler)
  406. }
  407. // Organization_ServiceDesc is the grpc.ServiceDesc for Organization service.
  408. // It's only intended for direct use with grpc.RegisterService,
  409. // and not to be introspected or modified (even as a copy)
  410. var Organization_ServiceDesc = grpc.ServiceDesc{
  411. ServiceName: "pb.Organization",
  412. HandlerType: (*OrganizationServer)(nil),
  413. Methods: []grpc.MethodDesc{
  414. {
  415. MethodName: "GetWorkingUfByCode",
  416. Handler: _Organization_GetWorkingUfByCode_Handler,
  417. },
  418. {
  419. MethodName: "FindWorkingUfByCycle",
  420. Handler: _Organization_FindWorkingUfByCycle_Handler,
  421. },
  422. {
  423. MethodName: "GetWorkingRoByCode",
  424. Handler: _Organization_GetWorkingRoByCode_Handler,
  425. },
  426. {
  427. MethodName: "GetWorkingChestByCode",
  428. Handler: _Organization_GetWorkingChestByCode_Handler,
  429. },
  430. {
  431. MethodName: "GetWorkingPumpByCode",
  432. Handler: _Organization_GetWorkingPumpByCode_Handler,
  433. },
  434. {
  435. MethodName: "GetWorkingValveByCode",
  436. Handler: _Organization_GetWorkingValveByCode_Handler,
  437. },
  438. {
  439. MethodName: "MultiAddItemHistoryData",
  440. Handler: _Organization_MultiAddItemHistoryData_Handler,
  441. },
  442. {
  443. MethodName: "ItemHistoryDataList",
  444. Handler: _Organization_ItemHistoryDataList_Handler,
  445. },
  446. {
  447. MethodName: "ItemHistoryDataByTime",
  448. Handler: _Organization_ItemHistoryDataByTime_Handler,
  449. },
  450. {
  451. MethodName: "ItemHistoryDataMaxMinByTime",
  452. Handler: _Organization_ItemHistoryDataMaxMinByTime_Handler,
  453. },
  454. {
  455. MethodName: "ItemHistoryDataFirstLastByTime",
  456. Handler: _Organization_ItemHistoryDataFirstLastByTime_Handler,
  457. },
  458. {
  459. MethodName: "ChangeTypeItemHistoryData",
  460. Handler: _Organization_ChangeTypeItemHistoryData_Handler,
  461. },
  462. },
  463. Streams: []grpc.StreamDesc{},
  464. Metadata: "organization.proto",
  465. }