Browse Source

homepage recommend

丁云鹏 1 year ago
parent
commit
b28bfb6369

+ 33 - 43
recommend-server-client/src/main/java/com/tzld/piaoquan/recommend/server/client/RecommendClient.java

@@ -1,53 +1,43 @@
 package com.tzld.piaoquan.recommend.server.client;
 
-import com.tzld.piaoquan.recommend.server.gen.recommend.RecommendRequest;
-import com.tzld.piaoquan.recommend.server.gen.recommend.RecommendResponse;
-import com.tzld.piaoquan.recommend.server.gen.recommend.RecommendServiceGrpc;
-import com.tzld.piaoquan.recommend.server.gen.recommend.VideoProto;
-import lombok.extern.slf4j.Slf4j;
-import net.devh.boot.grpc.client.inject.GrpcClient;
 import org.springframework.stereotype.Component;
 
-import java.util.Collections;
-import java.util.List;
-
 /**
  * @author dyp
  */
 @Component
-@Slf4j
 public class RecommendClient {
-    @GrpcClient("recommend-server")
-    private RecommendServiceGrpc.RecommendServiceBlockingStub client;
-
-    public List<VideoProto> homepageRecommend(RecommendRequest request) {
-
-        RecommendResponse response = client.homepageRecommend(request);
-        if (response == null
-                || !response.hasResult()) {
-            log.info("homepageRecommend grpc error");
-            return Collections.emptyList();
-        }
-        if (response.getResult().getCode() != 1) {
-            log.info("homepageRecommend grpc code={}, msg={}", response.getResult().getCode(),
-                    response.getResult().getMessage());
-            return Collections.emptyList();
-        }
-        return response.getVideoCount() > 0 ? response.getVideoList() : Collections.emptyList();
-    }
-
-    public List<VideoProto> relevantRecommend(RecommendRequest request) {
-        RecommendResponse response = client.relevantRecommend(request);
-        if (response == null
-                || !response.hasResult()) {
-            log.info("relevantRecommend grpc error");
-            return Collections.emptyList();
-        }
-        if (response.getResult().getCode() != 1) {
-            log.info("relevantRecommend grpc code={}, msg={}", response.getResult().getCode(),
-                    response.getResult().getMessage());
-            return Collections.emptyList();
-        }
-        return response.getVideoCount() > 0 ? response.getVideoList() : Collections.emptyList();
-    }
+//    @GrpcClient("recommend-server")
+//    private RecommendServiceGrpc.RecommendServiceBlockingStub client;
+//
+//    public List<VideoProto> homepageRecommend(RecommendRequest request) {
+//
+//        RecommendResponse response = client.homepageRecommend(request);
+//        if (response == null
+//                || !response.hasResult()) {
+//            log.info("homepageRecommend grpc error");
+//            return Collections.emptyList();
+//        }
+//        if (response.getResult().getCode() != 1) {
+//            log.info("homepageRecommend grpc code={}, msg={}", response.getResult().getCode(),
+//                    response.getResult().getMessage());
+//            return Collections.emptyList();
+//        }
+//        return response.getVideoCount() > 0 ? response.getVideoList() : Collections.emptyList();
+//    }
+//
+//    public List<VideoProto> relevantRecommend(RecommendRequest request) {
+//        RecommendResponse response = client.relevantRecommend(request);
+//        if (response == null
+//                || !response.hasResult()) {
+//            log.info("relevantRecommend grpc error");
+//            return Collections.emptyList();
+//        }
+//        if (response.getResult().getCode() != 1) {
+//            log.info("relevantRecommend grpc code={}, msg={}", response.getResult().getCode(),
+//                    response.getResult().getMessage());
+//            return Collections.emptyList();
+//        }
+//        return response.getVideoCount() > 0 ? response.getVideoList() : Collections.emptyList();
+//    }
 }