yoho-search / yoho-search-consumer · Commits

Go to a project

Authored by Gino Zhang
Commit 25c3afcf9b46794249572ec4814ad25d964cd224 1 parent c728d124

yoho-search-core拆分 依赖yoho-core版本升级到1.1.7

Inline Side-by-side
Showing 5 changed files with 20 additions and 25 deletions
package com.yoho.search.comsumer.builder.view;
import com.yoho.search.dal.ActivityProductMapper;
import com.yoho.search.model.ProductActivities;
import com.yoho.search.model.ProductActivity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import com.yoho.core.dal.ActivityProductMapper;
import com.yoho.search.model.ProductActivities;
import com.yoho.search.model.ProductActivity;
/**
* Created by wangnan on 2016/6/30.
*/
... ...
... ... @@ -3,19 +3,17 @@ package com.yoho.search.comsumer.mq;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.rabbitmq.client.Channel;
import com.yoho.consumer.dal.service.*;
import com.yoho.error.event.SearchEvent;
import com.yoho.search.comsumer.common.CostStatistics;
import com.yoho.search.comsumer.common.PerformanceMonitor;
import com.yoho.search.comsumer.index.IYohoIndexService;
import com.yoho.core.dal.service.*;
import com.yoho.search.comsumer.utils.SpecialDealForIndex;
import com.yoho.search.core.es.utils.IgnoreSomeException;
import com.yoho.search.dal.service.*;
import com.yoho.search.model.Product;
import com.yoho.search.model.ProductI;
import com.yoho.search.model.ProductPrice;
import com.yoho.search.model.StorageSku;
import com.yoho.search.core.es.utils.IgnoreSomeException;
import com.yoho.search.comsumer.utils.SpecialDealForIndex;
import com.yoho.error.event.SearchEvent;
import com.yoho.search.service.utils.*;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
... ...
package com.yoho.search.comsumer.mq;
import com.alibaba.fastjson.JSONObject;
import com.rabbitmq.client.Channel;
import com.yoho.consumer.dal.service.*;
import com.yoho.error.event.SearchEvent;
import com.yoho.search.comsumer.common.CostStatistics;
import com.yoho.search.comsumer.index.IYohoIndexService;
import com.yoho.search.core.es.utils.IgnoreSomeException;
import com.yoho.search.dal.service.*;
import com.yoho.search.model.Storage;
import com.yoho.search.service.utils.ConvertUtils;
import com.yoho.search.service.utils.EventReportEnum;
import com.yoho.core.dal.service.*;
import com.yoho.error.event.SearchEvent;
import com.yoho.search.service.utils.ISearchConstans;
import com.yoho.search.model.Storage;
import com.yoho.search.core.es.utils.IgnoreSomeException;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
... ... @@ -61,7 +60,7 @@ public class StorageMqListener extends AbstractMqListener implements ChannelAwar
} catch (Exception e) {
publisher.publishEvent(new SearchEvent(EventReportEnum.STORAGEMQLISTENER_ONMESSAGE.getEventName(),
EventReportEnum.STORAGEMQLISTENER_ONMESSAGE.getFunctionName(),
EventReportEnum.STORAGEMQLISTENER_ONMESSAGE.getMoudleName(),"exception",IgnoreSomeException.filterSomeException(e),null));
EventReportEnum.STORAGEMQLISTENER_ONMESSAGE.getMoudleName(),"exception", IgnoreSomeException.filterSomeException(e),null));
Thread.sleep(1000);
throw e;
}
... ...
package com.yoho.search.dal.service;
import java.util.List;
import java.util.Map;
import com.alibaba.fastjson.JSONObject;
import com.yoho.search.dal.ActivityProductMapper;
import com.yoho.search.model.ActivityProduct;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import com.alibaba.fastjson.JSONObject;
import com.yoho.core.dal.ActivityProductMapper;
import com.yoho.search.model.ActivityProduct;
import java.util.List;
import java.util.Map;
@Component
public class ActivityProductService {
... ...
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.yoho.core.dal.ActivityProductMapper" >
<mapper namespace="com.yoho.search.dal.ActivityProductMapper" >
<resultMap id="BaseResultMap" type="com.yoho.search.model.ActivityProduct" >
<id column="id" property="id" jdbcType="INTEGER" />
<result column="template_id" property="templateId" jdbcType="INTEGER" />
... ...