配置文件修改

admin

2019-11-23 51a4ff5d777028d52a19c314a99f796334cb7b51

 fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsServiceImpl.java

@@ -1,6 +1,8 @@
package com.yeshi.fanli.service.impl.taobao.dataoke;



import java.util.ArrayList;

import java.util.Collections;

import java.util.Comparator;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

@@ -11,10 +13,14 @@
import org.springframework.stereotype.Service;



import com.yeshi.fanli.dao.mybatis.taobao.dataoke.DaTaoKeDetailMapper;

import com.yeshi.fanli.dto.dataoke.DaTaoKeGoodsResult;

import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetail;

import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService;

import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsService;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil;

import com.yeshi.fanli.util.taobao.DaTaoKeUtil;



@Service

@@ -22,7 +28,7 @@


   @Resource

   private DaTaoKeDetailMapper daTaoKeDetailMapper;

	


   @Resource

   private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService;



@@ -97,6 +103,7 @@
            || list.size() == 0)// 超过20分钟未更新

      {

         list = DaTaoKeUtil.getCurrentHotSalesRank();

         LogHelper.test("热销数量:" + list.size());

         list = reSearchDetails(list);

         if (list != null && list.size() > 0)

            redisManager.saveObjList(list, key, null);// 长期缓存

@@ -104,10 +111,51 @@
      } else

         return list;

   }

	


   @Override

   public List<DaTaoKeDetail> getGoodsNotInList(Long cid, List<Long> listId,int count) {

      return daTaoKeDetailMapper.getGoodsNotInList(cid, listId,count);

   public List<DaTaoKeDetail> getGoodsNotInList(Long cid, List<Long> listId, int count) {

      return daTaoKeDetailMapper.getGoodsNotInList(cid, listId, count);

   }



   @Override

   public List<DaTaoKeDetail> listBySellerId(long start, int count, Long sellerId){

      return daTaoKeDetailMapper.listBySellerId(start, count, sellerId);

   }

	
   @Override

   public List<DaTaoKeDetailV2> getSearchDiscoveryGoods(String keyWords){

      String key = "dataoke-goods-searchdiscovery-"+ keyWords;

      List<DaTaoKeDetailV2> list = redisManager.getObjList(DaTaoKeDetailV2.class, key);

      if ( list == null || list.size() == 0) {

         DaTaoKeGoodsResult search = DaTaoKeApiUtil.search(keyWords, null, null, null, 1, 10, 0);

         if (search != null) {

            list = search.getGoodsList();

            if (list != null && list.size() > 0) {

               Comparator<DaTaoKeDetailV2> cm = new Comparator<DaTaoKeDetailV2>() {

                  @Override

                  public int compare(DaTaoKeDetailV2 o1, DaTaoKeDetailV2 o2) {

                     int diff = o1.getHotPush() - o2.getHotPush();

                     if (diff > 0) {

                        return -1;

                     } else if (diff < 0) {

                        return 1;

                     }

                     return 0;

                  }

               };

					
               Collections.sort(list, cm);

					
               if (list.size() > 3) 
                  list = list.subList(0, 3);

					
               // 缓存 20分钟

               redisManager.saveObjList(list, key, 1000 * 60 * 20);

            }

            return list;

         }

      } 
      return list;

   }

	
}