fanli-server.git

			@@ -1,60 +1,53 @@
			package com.yeshi.fanli.service.impl.jd;

			import java.math.BigDecimal;
			import java.util.ArrayList;
			import java.util.Collections;
			import java.util.HashMap;
			import java.util.List;
			import java.util.Map;

			import javax.annotation.Resource;

			import org.springframework.cache.annotation.Cacheable;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;
			import org.yeshi.utils.JsonUtil;

			import com.google.gson.Gson;
			import com.google.gson.GsonBuilder;
			import com.yeshi.fanli.dto.jd.JDFilter;
			import com.yeshi.fanli.dto.jd.JDSearchFilter;
			import com.yeshi.fanli.dto.jd.JDSearchResult;
			import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
			import com.yeshi.fanli.entity.jd.JDGoods;
			import com.yeshi.fanli.entity.system.ConfigKeyEnum;
			import com.yeshi.fanli.exception.jd.JDGoodsException;
			import com.yeshi.fanli.service.inter.config.ConfigService;
			import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
			import com.yeshi.fanli.service.inter.jd.JDGoodsService;
			import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
			import com.yeshi.fanli.tag.PageEntity;
			import com.yeshi.fanli.util.Constant;
			import com.yeshi.fanli.util.StringUtil;
			import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
			import com.yeshi.fanli.util.jd.JDApiUtil;
			import com.yeshi.fanli.util.jd.JDUtil;
			import com.yeshi.fanli.vo.goods.GoodsDetailVO;

			import net.sf.json.JSONArray;
			import net.sf.json.JSONObject;

			@Service
			public class JDGoodsServiceImpl implements JDGoodsService {


			@Resource
			private ConfigService configService;


			@Resource
			private HongBaoManageService hongBaoManageService;



			private Map<String, Long> countMap = new HashMap<String, Long>();
			private static final Map<Long, String> cidMap = new HashMap<Long, String>();
			private static final Map<String, Long> countMap = new HashMap<String, Long>();

			static {
			cidMap.put(1L, "nzjh");// 精选
			cidMap.put(1L, "2,16,1,3");// 精选
			cidMap.put(2L, "737");// 电器：家用电器
			cidMap.put(3L, "652,670");// 数码：数码/电脑、办公
			cidMap.put(4L, "9987");// 手机：手机通讯
			cidMap.put(4L, "9987");// 手机：手机通讯
			cidMap.put(5L, "12218");// 生鲜
			cidMap.put(6L, "1315");// 服饰：服饰内衣
			cidMap.put(7L, "1319,6233");// 母婴：母婴/玩具乐器
			cidMap.put(6L, "1315");// 服饰：服饰内衣
			cidMap.put(7L, "1319,6233");// 母婴：母婴/玩具乐器
			cidMap.put(8L, "1713");// 图书
			cidMap.put(9L, "6196");// 厨具
			cidMap.put(10L, "1320");// 食品：食品饮料
			@@ -68,7 +61,6 @@
			cidMap.put(18L, "6728");// 汽车：汽车用品
			}


			@Override
			public List<GoodsClass> getSpecialClass() {
			List<GoodsClass> list = new ArrayList<GoodsClass>();
			@@ -90,69 +82,155 @@
			list.add(new GoodsClass(16L, "宠物"));
			list.add(new GoodsClass(17L, "家居"));
			list.add(new GoodsClass(18L, "汽车"));
			return list;
			return list;
			}


			@Cacheable(value = "jdSpecialCache", key = "'specialSearch-'+#page+'-'+#cid")
			@Override
			@Transactional
			public JDSearchResult specialSearch(Integer page, Long cid) throws JDGoodsException{
			@Transactional(rollbackFor=Exception.class)
			public List<JDGoods> specialSearch(Integer page, Long cid) throws JDGoodsException {
			if (cid == null) {
			throw new JDGoodsException(1, "分类id为空");
			}


			String jdcid = cidMap.get(cid);
			if (StringUtil.isNullOrEmpty(jdcid)) {
			throw new JDGoodsException(1, "分类id不存在");
			}

			Long jdCid1 = null;
			Integer categoryId = null;
			long totalCount = (long) (page * Constant.PAGE_SIZE);


			if (jdcid.contains(",")) {

			// 精选
			if (cid == 1) {
			Integer categoryId = null;
			int pageTemp = 0;
			long addCount = 0;
			long totalCount = (long) (page * Constant.PAGE_SIZE);
			String[] arrayId = jdcid.split(",");
			for (int i = 0; i < arrayId.length; i++) {
			Long count = countMap.get(cid + "" + arrayId[i]);
			if (count != null && totalCount > count) {
			String id = arrayId[i];
			Long count = countMap.get(cid + "-" + id);
			if (count != null) {
			addCount += count;
			}

			if (count != null && totalCount > addCount) {
			pageTemp = (int) (addCount / Constant.PAGE_SIZE);
			continue; // 当前分类商品不足
			} else {
			jdCid1 = Long.parseLong(jdcid);
			categoryId = Integer.parseInt(jdcid);
			page = page - pageTemp;
			categoryId = Integer.parseInt(id);
			break;
			}
			}
			} else {
			jdCid1 = Long.parseLong(jdcid);
			categoryId = Integer.parseInt(jdcid);

			if (categoryId == null) {
			return null;
			}

			JDSearchResult result = JDApiUtil.getJingFenGoods(page, categoryId);

			long count = 0;
			if (result != null) {
			PageEntity pageEntity = result.getPageEntity();
			if (pageEntity != null) {
			count = pageEntity.getTotalCount();
			}
			}

			long mcount = (count / Constant.PAGE_SIZE) * Constant.PAGE_SIZE;
			if (mcount == 0) {
			mcount = 20;
			}
			countMap.put(cid + "-" + categoryId, mcount);

			if (result == null) {
			return null;
			} else {
			return filterJDGoods(result.getGoodsList());
			}
			}


			// 搜索

			if (!jdcid.contains(",")) {
			return search(page, Constant.PAGE_SIZE, jdcid);
			}

			// 多个分类id处理
			List<JDGoods> list = new ArrayList<JDGoods>();
			String[] arrayId = jdcid.split(",");
			for (int i = 0; i < arrayId.length; i++) {
			if (i >= 3) {
			break;
			}
			List<JDGoods> listGoods = search(page, 10, arrayId[i]);
			if (listGoods != null && listGoods.size() > 0) {
			list.addAll(listGoods);
			}
			}
			return filterJDGoods(list);
			}

			/**
			* 过滤商品
			*
			* @param goodsList
			* @return
			*/
			private List<JDGoods> filterJDGoods(List<JDGoods> goodsList) {
			List<Long> skuIds = new ArrayList<>();
			for (JDGoods goods : goodsList) {
			skuIds.add(goods.getSkuId());
			}
			List<JDGoods> newGoodsList = JDApiUtil.listGoodsDetail(skuIds);
			if (newGoodsList != null && newGoodsList.size() > 0)
			return newGoodsList;
			return goodsList;
			}

			private List<JDGoods> search(int page, int pageSize, String jdcid) {
			JDSearchResult result = null;
			String way = configService.get("jd_api_search_key");
			String way = configService.get(ConfigKeyEnum.jdApiSearchKey.getKey());
			if ("1".equals(way)) { // API搜索
			JDFilter filterAPI = new JDFilter();
			filterAPI.setPageIndex(page);
			filterAPI.setPageSize(Constant.PAGE_SIZE);
			filterAPI.setCid1(jdCid1);
			filterAPI.setPageSize(pageSize);
			filterAPI.setCid1(Long.parseLong(jdcid));
			result = JDApiUtil.queryByKey(filterAPI);
			} else { // 网页爬取
			JDSearchFilter jdfilter = new JDSearchFilter();
			jdfilter.setPageNo(page);
			jdfilter.setPageSize(Constant.PAGE_SIZE);
			jdfilter.setCategoryId(categoryId);
			jdfilter.setPageSize(pageSize);
			jdfilter.setCategoryId(Integer.parseInt(jdcid));
			result = JDUtil.searchByKey(jdfilter);
			}

			long count = 0;
			if (result != null) {
			PageEntity pageEntity = result.getPageEntity();
			if (pageEntity != null) {
			count = pageEntity.getTotalCount();
			}

			if (result == null) {
			return null;
			} else {
			return result.getGoodsList();
			}
			countMap.put(cid + "" + jdCid1, count);

			}

			@Cacheable(value = "jdCache", key = "'getIndexJDGoods-'+#page")
			@Override
			public JDSearchResult getIndexJDGoods(int page) {
			JDSearchResult result = null;
			String way = configService.get(ConfigKeyEnum.jdApiSearchKey.getKey());
			// TODO 需要调整规则
			way = "0";
			if ("1".equals(way)) {
			JDFilter filterAPI = new JDFilter();
			filterAPI.setPageIndex(page);
			filterAPI.setPageSize(20);
			result = JDApiUtil.queryByKey(filterAPI);
			} else {
			// 网页爬取
			JDSearchFilter jdfilter = new JDSearchFilter();
			jdfilter.setPageNo(page);
			jdfilter.setPageSize(Constant.PAGE_SIZE);
			result =JDApiUtil.getJingFenGoods(page,125); //JDUtil.searchByKey(jdfilter);
			}
			if (result != null && result.getGoodsList() != null)
			Collections.shuffle(result.getGoodsList());

			return result;
			}