|
|
|
package com.yoho.search.consumer.index.increment.search_default;
|
|
|
|
|
|
|
|
import java.util.Arrays;
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
|
import com.yoho.search.base.utils.EventReportEnum;
|
|
|
|
import com.yoho.search.base.utils.ISearchConstants;
|
|
|
|
import com.yoho.search.consumer.common.IYohoIndexService;
|
|
|
|
import com.yoho.search.consumer.index.fullbuild.ProductIndexIndexBuilder;
|
|
|
|
import com.yoho.search.consumer.index.increment.AbstractMqListener;
|
|
|
|
import com.yoho.search.consumer.service.logicService.ProductIndexBOToMapService;
|
|
|
|
import com.yoho.search.core.message.SearchMessageHelper;
|
|
|
|
import com.yoho.search.core.message.beans.SearchMqBeansResgister;
|
|
|
|
import com.yoho.search.core.message.beans.SearchMqConsumerListerner;
|
|
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
|
import com.yoho.search.base.utils.EventReportEnum;
|
|
|
|
import com.yoho.search.base.utils.ISearchConstants;
|
|
|
|
import com.yoho.search.consumer.common.IYohoIndexService;
|
|
|
|
import com.yoho.search.consumer.index.fullbuild.ProductIndexIndexBuilder;
|
|
|
|
import com.yoho.search.consumer.service.bo.ProductIndexBO;
|
|
|
|
import com.yoho.search.consumer.service.logicService.ProductIndexBOToMapService;
|
|
|
|
|
|
|
|
@Component
|
|
|
|
@SearchMqConsumerListerner(dbName = "search_default",tableName = "productindex")
|
|
|
|
public class ProductIndexMqListener extends AbstractMqListener {
|
...
|
...
|
|
