kafka日志集成

admin

2021-08-02 e89de9319d8f771f8e53cb5f876d06465a580c57

 src/main/java/com/yeshi/buwan/controller/parser/web/WebHomeParser.java

@@ -14,7 +14,7 @@
import org.springframework.stereotype.Controller;

import com.yeshi.buwan.domain.CategoryContry;
import com.yeshi.buwan.domain.DetailSystem;
import com.yeshi.buwan.domain.system.DetailSystem;
import com.yeshi.buwan.domain.HomeAd;
import com.yeshi.buwan.domain.HomeType;
import com.yeshi.buwan.domain.HomeVideo;
@@ -35,7 +35,7 @@
import com.yeshi.buwan.service.imp.ClassService;
import com.yeshi.buwan.service.imp.CollectionService;
import com.yeshi.buwan.service.imp.CommentService;
import com.yeshi.buwan.service.imp.ConfigService;
import com.yeshi.buwan.service.imp.DetailSystemConfigService;
import com.yeshi.buwan.service.imp.HomeAdService;
import com.yeshi.buwan.service.imp.HomeTypeService;
import com.yeshi.buwan.service.imp.RecommendService;
@@ -71,7 +71,7 @@
    @Resource
    private HomeTypeService homeTypeService;
    @Resource
    private ConfigService configService;
    private DetailSystemConfigService configService;
    @Resource
    private AdService adService;
    @Resource
@@ -123,6 +123,7 @@
        String sign = request.getParameter("Sign");
        String platform = request.getParameter("Platform");
        String packageName = request.getParameter("Package");
        String channel = request.getParameter("Channel");
        if (StringUtil.isNullOrEmpty(method)) {
            out.print(JsonUtil.loadFalseJson("请上传Method"));
            return;
@@ -148,7 +149,7 @@

        DetailSystem detailSystem = systemService.getDetailSystemByPackage(packageName);

        List<HomeAd> list = homeAdService.getHomeAdList(detailSystem);
        List<HomeAd> list = homeAdService.getHomeAdList(detailSystem, "recommend");

        for (HomeAd ad : list) {
            if (ad.getVideo() != null) {
@@ -164,7 +165,7 @@
            array.add(StringUtil.outPutResultJson(list.get(i)));

        object.put("homeAdList", array);
        object.put("homeTypeList", getHomeType(uid, platform, detailSystem.getId()));
        object.put("homeTypeList", getHomeType(uid, platform, detailSystem.getId(), channel));

        // 排行
        JSONObject rank = new JSONObject();
@@ -188,11 +189,11 @@
    }

    // 首页类型获取
    private JSONArray getHomeType(String uid, String platform, String detailsystemid) {
    private JSONArray getHomeType(String uid, String platform, String detailsystemid, String channel) {

        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(new DetailSystem("44"), 1);
        List<HomeType> list1 = homeTypeService.getHomeType(detailsystemid, resourceList,
                CacheUtil.getMD5Long(resourceList), 10, 309);
        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(new DetailSystem("44"), 1, channel);
        List<HomeType> list1 = homeTypeService.getHomeType(detailsystemid, platform, 1, resourceList,
                CacheUtil.getMD5Long(resourceList), 10, "recommend");
        List<HomeType> list = new ArrayList<>();
        for (HomeType ht : list1)
            list.add(ht);
@@ -389,7 +390,7 @@
            return;
        }

        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(new DetailSystem("44"), 1);
        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(new DetailSystem("44"), 1, null);
        DetailSystem detailSystem = systemService.getDetailSystemByPackage(packageName);

        List<VideoType> typeList = getFirstType(pid);
@@ -770,7 +771,7 @@
            return;
        }

        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(new DetailSystem("44"), Integer.parseInt(version));
        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(new DetailSystem("44"), Integer.parseInt(version), null);

        VideoInfo info = (videoDeailUtil.getVideoInfo(null, videoId, resourceId, resourceList,
                CacheUtil.getMD5Long(resourceList)));