券推送插入

yujian

2019-04-22 b6c37e4bc38db88a360d0f2c6099183f9bb75bdc

 fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java

@@ -8,7 +8,6 @@
import java.util.Collections;

import java.util.Date;

import java.util.List;

import java.util.Map;



import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;

@@ -28,11 +27,11 @@
import com.google.gson.JsonPrimitive;

import com.google.gson.JsonSerializationContext;

import com.google.gson.JsonSerializer;

import com.yeshi.fanli.dao.mybatis.HongBaoManageMapper;

import com.yeshi.fanli.entity.accept.AcceptData;

import com.yeshi.fanli.entity.bus.homemodule.Special;

import com.yeshi.fanli.entity.bus.homemodule.SuperSpecial;

import com.yeshi.fanli.entity.bus.homemodule.SwiperPicture;

import com.yeshi.fanli.entity.bus.lable.QualityFactory;

import com.yeshi.fanli.entity.bus.recommend.Honest;

import com.yeshi.fanli.entity.bus.recommend.RecommendBanner;

import com.yeshi.fanli.entity.bus.recommend.RecommendBannerV2;

@@ -53,7 +52,6 @@
import com.yeshi.fanli.entity.taobao.ClientTBPid;

import com.yeshi.fanli.entity.taobao.PidUser;

import com.yeshi.fanli.entity.taobao.SearchFilter;

import com.yeshi.fanli.entity.taobao.TBPid;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;

import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult;

@@ -75,7 +73,6 @@
import com.yeshi.fanli.service.inter.config.SystemConfigService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.goods.CommonGoodsService;

import com.yeshi.fanli.service.inter.goods.RecommendBannerService;

import com.yeshi.fanli.service.inter.goods.ScanHistoryV2Service;

import com.yeshi.fanli.service.inter.goods.SuperRecommendBannerService;

import com.yeshi.fanli.service.inter.goods.SuperRecommendBannerV2Service;

@@ -86,6 +83,7 @@
import com.yeshi.fanli.service.inter.homemodule.SuperSpecialService;

import com.yeshi.fanli.service.inter.homemodule.SwiperPictureService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.lable.QualityFlashSaleService;

import com.yeshi.fanli.service.inter.lable.QualityGoodsService;

import com.yeshi.fanli.service.inter.monitor.MonitorService;

import com.yeshi.fanli.service.inter.order.OrderService;

@@ -107,7 +105,6 @@
import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;

import com.yeshi.fanli.util.factory.MonitorFactory;

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

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

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

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

import com.yeshi.fanli.vo.user.UserSettingsVO;

@@ -119,8 +116,6 @@
@RequestMapping("api/v1/user")

public class RecommendController {



   @Resource

   private RecommendBannerService recommendService;



   @Resource

   private BusinessSystemService businessSystemService;

@@ -146,8 +141,6 @@
   @Resource

   private UserInfoService userInfoService;



   @Resource

   private TaoBaoOrderUtil taoBaoOrderUtil;



   @Resource

   private TaoBaoCouponService taoBaoCouponService;

@@ -160,9 +153,6 @@


   @Resource

   private CollectionGoodsV2Service collectionGoodsV2Service;



   @Resource

   private HongBaoManageMapper hongBaoManageMapper;



   @Resource

   private TaoBaoGoodsBriefService taoBaoGoodsBriefService;

@@ -223,14 +213,16 @@


   @Resource

   private UserInfoExtraService userInfoExtraService;

	
   @Resource

   private QualityFlashSaleService qualityFlashSaleService;

	


   @Resource

   private TaoBaoGoodsCacheUtil taoBaoGoodsCacheUtil;



   @RequestMapping(value = "getHonestList")

   public void getHonestList(AcceptData acceptData, PrintWriter out) {

      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),

            acceptData.getPackages());

      List<Honest> honestList = null;

      List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);

      if ((Integer.parseInt(acceptData.getVersion()) >= 20 && "android".equalsIgnoreCase(acceptData.getPlatform()))

@@ -979,7 +971,6 @@
      ClientTBPid clientTBPid = null;

      // 用户已经登录

      if (!StringUtil.isNullOrEmpty(uid)) {

         TBPid tbPid = null;

         if (acceptData.getPlatform().equalsIgnoreCase("android")) {

            clientTBPid = tbPidService.getAndroidDefault();

         } else {

@@ -1301,7 +1292,6 @@
      // 从推荐来

      if (page <= 1) {

         array.clear();

         Map<String, String> map = hongBaoManageService.convertMap();

         BigDecimal proportion = manageService.getFanLiRate();

         if (!StringUtil.isNullOrEmpty(imei) || !StringUtil.isNullOrEmpty(idfa)) {

            long startTime = java.lang.System.currentTimeMillis();

@@ -1343,14 +1333,12 @@
               proportion.toString());

         array.addAll(localArray);

      } else {// 从精选库来

         Map<String, String> map = hongBaoManageService.convertMap();

         BigDecimal proportion = manageService.getFanLiRate();

         array = qualityGoodsService.getRecommendToIndex((page - 1) * pageSize, pageSize, proportion.toString());

         if (array == null) {

            out.print(JsonUtil.loadFalseResult("没有更多了"));

            return;

         }

         long count = qualityGoodsService.countRecommendToIndex(proportion.toString());

      }



      JSONObject data = new JSONObject();

@@ -1570,11 +1558,192 @@
               root.put("invite", invite);

         }

      }



      out.print(JsonUtil.loadTrueResult(root));



   }



	
   /**

    * 新版推荐专题管理(1.5.3)

    * 
    * @param acceptData

    * @param out

    */

   @RequestMapping(value = "getRecommendIndex")

   public void getRecommendIndex(AcceptData acceptData, Long uid, PrintWriter out) {

      try {

         //  1、专题模块

         JSONObject root = specialService.listCacheSpecialToIndex(acceptData);



         // 2、顶部轮播图

         List<SwiperPicture> topPicList = getSwiperByCard("index_top");

         if (topPicList == null) {

            topPicList = new ArrayList<SwiperPicture>();

         }

         root.put("topPicList", JsonUtil.getApiCommonGson().toJson(topPicList));

			
			
         // 3、邀请有奖

         List<SwiperPicture> invitePicList = null;

         if ("ios".equalsIgnoreCase(acceptData.getPlatform())

               && configService.iosOnLining(Integer.parseInt(acceptData.getVersion()))) {

            // 如果IOS当前版本处于审核状态就不返回

         } else {

            invitePicList = getSwiperByCard("index_invite");	
         }

			
         if (invitePicList == null) {

            invitePicList = new ArrayList<SwiperPicture>();

         } 
         root.put("invitePicList", JsonUtil.getApiCommonGson().toJson(invitePicList));

			
			
         // 4、IOS的底部网页链接

         String platform = acceptData.getPlatform();

         if ("ios".equalsIgnoreCase(platform)) {

            root.put("htmlLink", configService.get("index_html_link_ios"));

         } 
			
         out.print(JsonUtil.loadTrueResult(root));

      } catch (Exception e) {

         out.print(JsonUtil.loadFalseResult(1, "获取数据失败"));

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }	
      }

   }

	
   /**

    * 邀请有奖是否需要返回

    * @param uid

    * @param acceptData

    * @return

    */

   public List<SwiperPicture>  getInvitePicList(Long uid, AcceptData acceptData) {

      // 如果IOS当前版本处于审核状态就不返回

      if ("ios".equalsIgnoreCase(acceptData.getPlatform())

            && configService.iosOnLining(Integer.parseInt(acceptData.getVersion()))) {

         return null;

      } 
		
      List<SwiperPicture> invitePicList = getSwiperByCard("index_invite");	
		
		
		
      return invitePicList;

   }

	
	
   public List<SwiperPicture> getSwiperByCard(String card){

      List<SwiperPicture> swiperList = null;

      try {

         swiperList = swiperPictureService.getByBannerCard(card);

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         e.printStackTrace();

      }

      return swiperList;

   }

	
	
   /**

    * 限时秒杀 1.5.3

    * 
    * @param acceptData

    * @param out

    */

   @RequestMapping(value = "getSpikeGoods")

   public void getSpikeGoods(AcceptData acceptData, PrintWriter out) {

		
      // 下一次倒计时的时间

      int type = qualityFlashSaleService.getNowType() + 1;

      int hour = 0;

      switch(type) {

         case 1:

            hour = 0;

            break;

         case 2:

            hour = 9;

            break;

         case 3:

            hour = 12;

            break;

         case 4:

            hour = 14;

            break;

         case 5:

            hour = 16;

            break;

         case 6:

            hour = 20;

            break;

         case 7:

            hour = 22;

            break;

         default:

            break;

      }

		
      Calendar nextTime = Calendar.getInstance();

      nextTime.set(Calendar.HOUR_OF_DAY, hour);

      nextTime.set(Calendar.MINUTE, 0);

      nextTime.set(Calendar.SECOND, 0);

      nextTime.set(Calendar.MILLISECOND, 0);

		
	
      JSONArray array = null;

      String timekey = "spikeGoods_hour";

      String cachekey = "spikeGoodsList";

		
      String timeValue = redisManager.getCommonString(timekey);

      if (timeValue == null || !timeValue.equals(hour+"")) {

         redisManager.cacheCommonString(timekey, hour+"", 60 * 30);

      } else {

         String cacheValue = redisManager.getCommonString(cachekey);

         if (!StringUtil.isNullOrEmpty(cacheValue)) {

            array = JSONArray.fromObject(cacheValue);

         }

      }

		
      if (array == null) {

         array = new JSONArray();

			
         BigDecimal proportion = manageService.getFanLiRate();

         Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

               .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

			
         // 缓存中不存在

         List<QualityFactory> listGoods = qualityGoodsService.listFlashSaleRandGoods();

         if (listGoods == null) {

            listGoods = new ArrayList<QualityFactory>();

         }

			
         /* 遍历列表数据 */

         for (QualityFactory qualityFactory : listGoods) {

					
            TaoBaoGoodsBrief taoBaoGoodsBrief = qualityFactory.getTaoBaoGoodsBrief();

            if (taoBaoGoodsBrief == null) {

               continue;

            }

            array.add(gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), null)));

         }

			
         // 缓存半个小时

         redisManager.cacheCommonString(cachekey, array.toString(), 60 * 30);

      }

		
      JSONObject root = new JSONObject();

      root.put("time", nextTime.getTimeInMillis());

      root.put("listgoods", array);

      out.print(JsonUtil.loadTrueResult(root));

   }

	
	
   /**

    * 商品基本详情 (1.4.0)

    * 

@@ -1723,7 +1892,6 @@
      TaoBaoGoodsBrief tb = null;

      if (goodsList.size() > 0) {

         tb = goodsList.get(0);



      }



      if (tb == null) {