|
@@ -1,5 +1,6 @@
|
|
|
package com.tzld.piaoquan.ad.engine.service.log.impl;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.tzld.commons.aliyun.log.AliyunLogManager;
|
|
|
import com.tzld.piaoquan.ad.engine.commons.score.ScoreParam;
|
|
@@ -20,6 +21,8 @@ import java.util.Set;
|
|
|
import java.util.concurrent.LinkedBlockingDeque;
|
|
|
import java.util.concurrent.ThreadPoolExecutor;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
+import java.util.function.Function;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
@Slf4j
|
|
|
@Service
|
|
@@ -54,10 +57,12 @@ public class LogHubServiceImpl implements LogHubService {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ logMap.put("scoreResult", JSON.toJSONString(rankItems));
|
|
|
+ logMap.put("creativeList", JSON.toJSONString(adIdList));
|
|
|
+
|
|
|
logMap.put("abExpCode", abExpCode);
|
|
|
logMap.put("adAbGroup", requestParam.getAdAbGroup());
|
|
|
- logMap.put("creativeList", adIdList);
|
|
|
- logMap.put("scoreResult", rankItems);
|
|
|
logMap.put("scoreStrategy", scoreStrategy);
|
|
|
logMap.put("appType", requestParam.getAppType());
|
|
|
aliyunLogManager.sendLog(project, logStore, "", logMap);
|