SkuServiceRpcClient.java 933 Bytes
package com.infoloop.tianting.service.client;

import com.infoloop.tianting.GeDishSkuByIdsRpcResponse;
import com.infoloop.tianting.GetSkusByIdsRpcRequest;
import com.infoloop.tianting.GetSkusByIdsRpcResponse;
import com.infoloop.tianting.SkuServiceProtoRpcGrpc;
import java.util.List;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class SkuServiceRpcClient {
  private final SkuServiceProtoRpcGrpc.SkuServiceProtoRpcBlockingStub skuServiceProtoRpcBlockingStub;
public GeDishSkuByIdsRpcResponse getDishSkusByIds(List<Integer> ids) {
  final var request = GetSkusByIdsRpcRequest.newBuilder()
      .addAllIds(ids)
      .setIncludeDeleted(false)
      .build();
  final var res = skuServiceProtoRpcBlockingStub.getDishSkusByIds(request);
  return res;
}
}