consumerclientserver.go 2.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
  1. // Code generated by goctl. DO NOT EDIT!
  2. // Source: consumer.proto
  3. package server
  4. import (
  5. "context"
  6. "app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/logic"
  7. "app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/svc"
  8. "app.yhyue.com/moapp/jyInfo/rpc/consumer/type/consumer"
  9. )
  10. type ConsumerClientServer struct {
  11. svcCtx *svc.ServiceContext
  12. consumer.UnimplementedConsumerClientServer
  13. }
  14. func NewConsumerClientServer(svcCtx *svc.ServiceContext) *ConsumerClientServer {
  15. return &ConsumerClientServer{
  16. svcCtx: svcCtx,
  17. }
  18. }
  19. // 发布信息
  20. func (s *ConsumerClientServer) PublishInfo(ctx context.Context, in *consumer.PublishInfoReq) (*consumer.PublishInfoResp, error) {
  21. l := logic.NewPublishInfoLogic(ctx, s.svcCtx)
  22. return l.PublishInfo(in)
  23. }
  24. // 根据用户id获取当月已发布信息数量
  25. func (s *ConsumerClientServer) InfoByUserId(ctx context.Context, in *consumer.UserIdReq) (*consumer.InfoByUserIdResp, error) {
  26. l := logic.NewInfoByUserIdLogic(ctx, s.svcCtx)
  27. return l.InfoByUserId(in)
  28. }
  29. // 关联公告
  30. func (s *ConsumerClientServer) InfoRelated(ctx context.Context, in *consumer.UserIdReq) (*consumer.InfoRelatedResp, error) {
  31. l := logic.NewInfoRelatedLogic(ctx, s.svcCtx)
  32. return l.InfoRelated(in)
  33. }
  34. // 我的发布列表
  35. func (s *ConsumerClientServer) MyPublishList(ctx context.Context, in *consumer.MyPublishListReq) (*consumer.MyPublishListResp, error) {
  36. l := logic.NewMyPublishListLogic(ctx, s.svcCtx)
  37. return l.MyPublishList(in)
  38. }
  39. // 更新发布的信息0:获取详情;1:物理删除()
  40. func (s *ConsumerClientServer) InfoChange(ctx context.Context, in *consumer.InfoDetailReq) (*consumer.InfoDetailResp, error) {
  41. l := logic.NewInfoChangeLogic(ctx, s.svcCtx)
  42. return l.InfoChange(in)
  43. }
  44. // 信息审核状态查询
  45. func (s *ConsumerClientServer) StatusQuery(ctx context.Context, in *consumer.StatusReq) (*consumer.StatusResp, error) {
  46. l := logic.NewStatusQueryLogic(ctx, s.svcCtx)
  47. return l.StatusQuery(in)
  48. }
  49. // 供应信息查询
  50. func (s *ConsumerClientServer) SupplyInfoSearch(ctx context.Context, in *consumer.SupplyInfoSearchReq) (*consumer.SupplyInfoSearchResp, error) {
  51. l := logic.NewSupplyInfoSearchLogic(ctx, s.svcCtx)
  52. return l.SupplyInfoSearch(in)
  53. }
  54. // 供应信息详情(前端页面查询结果详情请求地址)
  55. func (s *ConsumerClientServer) SupplyInfoDetail(ctx context.Context, in *consumer.StatusReq) (*consumer.SupplyInfoDetailResp, error) {
  56. l := logic.NewSupplyInfoDetailLogic(ctx, s.svcCtx)
  57. return l.SupplyInfoDetail(in)
  58. }
  59. // 上传附件
  60. func (s *ConsumerClientServer) InfoFileUpload(ctx context.Context, in *consumer.InfoFileUploadReq) (*consumer.InfoFileUploadResp, error) {
  61. l := logic.NewInfoFileUploadLogic(ctx, s.svcCtx)
  62. return l.InfoFileUpload(in)
  63. }
  64. // 删除附件
  65. func (s *ConsumerClientServer) InfoFileDel(ctx context.Context, in *consumer.InfoFileDelReq) (*consumer.BaseResp, error) {
  66. l := logic.NewInfoFileDelLogic(ctx, s.svcCtx)
  67. return l.InfoFileDel(in)
  68. }