feat:广告引擎FM模型迭代

ad-engine-commons/src/main/java/com/tzld/piaoquan/ad/engine/commons/score/ScorerUtils.java

@@ -33,11 +33,11 @@ public final class ScorerUtils {
 
     public static void warmUp() {
         log.info("scorer warm up ");
-        ScorerUtils.init(BASE_CONF);
-        ScorerUtils.init(THOMPSON_CONF);
+        // ScorerUtils.init(BASE_CONF);
+        // ScorerUtils.init(THOMPSON_CONF);
         // ScorerUtils.init(BREAK_CONFIG);
         // ScorerUtils.init(SHARE0_CONFIG);
-        ScorerUtils.init(CVR_ADJUSTING);
+        // ScorerUtils.init(CVR_ADJUSTING);
         // ScorerUtils.init(VIDEO_CREATIVE_THOMPSON);
 
         ScorerUtils.init(LR_ROV_SCORE_20240626);

ad-engine-server/src/main/resources/ad_score_config_20240626.conf

@@ -2,7 +2,7 @@ scorer-config = {
   lr-rov-score-config = {
     scorer-name = "com.tzld.piaoquan.ad.engine.service.score.VlogRovFMScorer"
     scorer-priority = 99
-    model-path = "zhangbo/model_bkb8_v3.txt"
+    model-path = "zhangbo/model_bkb8_v4.txt"
   }
 
 }

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/container/PidLambdaContainer.java

@@ -68,20 +68,20 @@ public class PidLambdaContainer {
     private static ConcurrentHashMap<Long, V1CacheItem>  lambdaCache=new ConcurrentHashMap<>();
     private Date cacheDate;
 
-    @PostConstruct
-    private void init(){
-        instanceClient();
-        final Runnable task = new Runnable() {
-            public void run() {
-                try {
-                    loadAndCalIfNeed();
-                }catch (Exception e){
-                    e.printStackTrace();
-                }
-            }
-        };
-        scheduler.scheduleAtFixedRate(task, 0, SCHEDULE_PERIOD, TimeUnit.MINUTES); // 10分钟
-    }
+    // @PostConstruct
+    // private void init(){
+    //     instanceClient();
+    //     final Runnable task = new Runnable() {
+    //         public void run() {
+    //             try {
+    //                 loadAndCalIfNeed();
+    //             }catch (Exception e){
+    //                 e.printStackTrace();
+    //             }
+    //         }
+    //     };
+    //     scheduler.scheduleAtFixedRate(task, 0, SCHEDULE_PERIOD, TimeUnit.MINUTES); // 10分钟
+    // }
 
     private void instanceClient(){
         CredentialsProvider credentialsProvider = new DefaultCredentialProvider(accessKeyId, accessKetSecret);

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/container/PidLambdaV2Container.java

@@ -67,20 +67,20 @@ public class PidLambdaV2Container {
     private static ConcurrentHashMap<Long,CacheItem>  lambdaCache=new ConcurrentHashMap<>();
     private Date cacheDate;
 
-    @PostConstruct
-    private void init(){
-        instanceClient();
-        final Runnable task = new Runnable() {
-            public void run() {
-                try {
-                    loadAndCalIfNeed();
-                }catch (Exception e){
-                    e.printStackTrace();
-                }
-            }
-        };
-        scheduler.scheduleAtFixedRate(task, 0, SCHEDULE_PERIOD, TimeUnit.MINUTES); // 10分钟
-    }
+    // @PostConstruct
+    // private void init(){
+    //     instanceClient();
+    //     final Runnable task = new Runnable() {
+    //         public void run() {
+    //             try {
+    //                 loadAndCalIfNeed();
+    //             }catch (Exception e){
+    //                 e.printStackTrace();
+    //             }
+    //         }
+    //     };
+    //     scheduler.scheduleAtFixedRate(task, 0, SCHEDULE_PERIOD, TimeUnit.MINUTES); // 10分钟
+    // }
 
     private void instanceClient(){
         CredentialsProvider credentialsProvider = new DefaultCredentialProvider(accessKeyId, accessKetSecret);

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/impl/RankServiceImpl.java

@@ -91,6 +91,15 @@ public class RankServiceImpl implements RankService {
     private AdRankItem rankBy680(RankRecommendRequestParam request) {
         ScoreParam scoreParam = RequestConvert.requestConvert(request);
         List<AdRankItem> adRankItems = fmRankService.adItemRank(request, scoreParam);
+        // List<JSONObject> collect = adRankItems.stream().map(i -> {
+        //     JSONObject jsonObject = new JSONObject();
+        //     jsonObject.put("cid", i.getId());
+        //     jsonObject.put("adverid", i.getAdVerId());
+        //     jsonObject.put("feature", i.getFeatureMap());
+        //     jsonObject.put("score", i.getScore());
+        //     jsonObject.put("ctcvrScore", i.getLrScore());
+        //     return jsonObject;
+        // }).collect(Collectors.toList());
         logHubService.scoreLogUpload(scoreParam, request.getAdIdList(), adRankItems, request, "LRModelScore", "680");
         return adRankItems.get(0);
     }