MeiZhongYiHeServiceClient.java 1.63 KB
package com.infoloop.tianting.service.client;

import com.infoloop.rpc.meizhongyiheservice.GetCustomerAllergiesByCustomerIdsRpcRequest;
import com.infoloop.rpc.meizhongyiheservice.GetCustomerAllergiesByCustomerIdsRpcResponse;
import com.infoloop.rpc.meizhongyiheservice.GetCustomerMedicalAdvicesByHospitalRecordIdsRpcRequest;
import com.infoloop.rpc.meizhongyiheservice.GetCustomerMedicalAdvicesByHospitalRecordIdsRpcResponse;
import com.infoloop.rpc.meizhongyiheservice.MeiZhongYiHeServiceRpcGrpc;
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 MeiZhongYiHeServiceClient {

  private final MeiZhongYiHeServiceRpcGrpc.MeiZhongYiHeServiceRpcBlockingStub
      meiZhongYiHeServiceRpcBlockingStub;

  public GetCustomerAllergiesByCustomerIdsRpcResponse getHisCustomerAllergiesByCustomerId(
      String hisCustomerId ) {
    final var request = GetCustomerAllergiesByCustomerIdsRpcRequest.newBuilder()
        .addAllCustomerIds(List.of(hisCustomerId))
        .build();
    return meiZhongYiHeServiceRpcBlockingStub.getCustomerAllergiesByCustomerIds(request);
  }

  public GetCustomerMedicalAdvicesByHospitalRecordIdsRpcResponse
  getHisCustomerMedicalAdvicesByContractNo (String contractNo) {
    final var request = GetCustomerMedicalAdvicesByHospitalRecordIdsRpcRequest.newBuilder()
        .addAllHospitalRecordIds(List.of(contractNo))
        .build();
    return meiZhongYiHeServiceRpcBlockingStub.getCustomerMedicalAdvicesByHospitalRecordIds(request);
  }
}