MeiZhongYiHeServiceClient.java 1.68 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 lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@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);
    }
}