Merge remote-tracking branch 'origin/master'

admin

2019-07-30 573c491b4a1ba60e12a5678a01c1546c0077c1ee

 fanli/src/main/java/com/yeshi/fanli/job/TaoLiJinJob.java

@@ -1,5 +1,8 @@
package com.yeshi.fanli.job;



import java.math.BigDecimal;

import java.util.Collections;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;

@@ -9,14 +12,19 @@


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

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

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

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

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.taobao.ShareHotGoodsService;

import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService;

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

import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinReportService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.TaoBaoConstant;

import com.yeshi.fanli.util.TimeUtil;

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

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



@Component

public class TaoLiJinJob {

@@ -29,6 +37,9 @@


   @Resource

   private TLJBuyGoodsService tljBuyGoodsService;



   @Resource

   private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService;



   /**

    * 更新报告

@@ -67,7 +78,7 @@
   /**

    * 每天凌晨过5分钟验证

    */

   @Scheduled(cron = "0 5 0 * * ?")

   @Scheduled(cron = "0 2 0 * * ?")

   public void updateShareTLJGoods() {

      if (!Constant.IS_TASK)

         return;

@@ -88,9 +99,9 @@
   }



   /**

    * 每天凌晨过3分钟验证

    * 每天凌晨5点过10分钟验证

    */

   @Scheduled(cron = "0 3 0 * * ?")

   @Scheduled(cron = "0 10 5 * * ? ")

   public void updateBuyTLJGoods() {

      if (!Constant.IS_TASK)

         return;

@@ -101,13 +112,65 @@
      for (int i = 0; i < list.size(); i++) {

         if (count >= 10)

            break;

         boolean success = shareHotGoodsService.verifyCanCreateTLJ(list.get(i).getGoods().getAuctionId(),

               new TaoKeAppInfo(TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET,

                     TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT));

         boolean success = tljBuyGoodsService.verifyCanCreateTLJ(list.get(i).getGoods().getAuctionId());

         if (success) {

            count++;

         }

      }

   }



   private void addTLJBuyGoods(List<TaoBaoGoodsBrief> list, String day) {

      for (TaoBaoGoodsBrief goods : list) {

         // 获取商品详情

         try {

            goods = TaoKeApiUtil.searchGoodsDetail(goods.getAuctionId());

         } catch (TaobaoGoodsDownException e) {

            e.printStackTrace();

         }

         if (goods != null && goods.getCouponAmount() != null

               && goods.getCouponAmount().compareTo(new BigDecimal(0)) > 0) {



            if (TaoBaoUtil.getAfterUseCouplePrice(goods).multiply(goods.getTkRate())

                  .compareTo(new BigDecimal("143")) >= 0) {

               goods = daTaoKeGoodsDetailService.filterTaoBaoGoods(goods);

               int totalHongBaoCount = 2000 + (int) (Math.random() * 8000);

               int leftHongBaoCount = 200 + (int) (Math.random() * 2000);

               tljBuyGoodsService.addTLJBuyGoods(

                     new TLJBuyGoods(null, day, new Date(), goods, totalHongBaoCount, leftHongBaoCount),

                     TaoBaoConstant.ownBuyApp);

            }

         }

      }

   }



   /**

    * 每天晚上11点50添加淘礼金1个商品，用于兼容Android前端没有商品不显示banner的问题

    */

   @Scheduled(cron = "0 50 23 * * ? ")

   public void autoAddTLJBuyGoods() {

      if (!Constant.IS_TASK)

         return;

      String day = TimeUtil.getGernalTime(System.currentTimeMillis() + 1000 * 60 * 60 * 24L, "yyyy-MM-dd");

      List<TaoBaoGoodsBrief> list = tljBuyGoodsService.listPreGoods(1);

      Collections.shuffle(list);

      if (list.size() > 0)

         list = list.subList(0, 1);

      addTLJBuyGoods(list, day);

   }



   /**

    * 每天凌晨5点过1分开始爬取剩余9个商品

    */

   @Scheduled(cron = "0 1 5 * * ? ")

   public void autoAddTLJBuyGoods2() {

      if (!Constant.IS_TASK)

         return;

      String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd");

      List<TaoBaoGoodsBrief> list = tljBuyGoodsService.listPreGoods(1);

      Collections.shuffle(list);

      if (list.size() > 20)

         list = list.subList(0, 20);

      addTLJBuyGoods(list, day);

   }



}