云发单教程跳转bug

yujian

2020-06-16 621852b97817fec5ae49cba443cb6d7e6069d3ca

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

@@ -14,6 +14,10 @@
import com.xxl.job.core.biz.model.ReturnT;

import com.xxl.job.core.handler.annotation.XxlJob;

import com.yeshi.fanli.dto.ConfigParamsDTO;

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

import com.yeshi.fanli.dto.taobao.haodanku.HDKGoodsListResultDTO;

import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser;

import com.yeshi.fanli.entity.bus.activity.ActivityUser;

import com.yeshi.fanli.entity.bus.activity.RecommendActivity;

import com.yeshi.fanli.entity.bus.activity.RecommendActivityInviteInfo;

import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;

@@ -21,6 +25,9 @@
import com.yeshi.fanli.entity.dynamic.WXMPDynamicInfo;

import com.yeshi.fanli.entity.goods.jd.NYouHuiGoods;

import com.yeshi.fanli.entity.jd.JDGoods;

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

import com.yeshi.fanli.entity.taobao.haodanku.HDKGoodsDetail;

import com.yeshi.fanli.exception.dynamic.GoodsEvaluateException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.activity.ActivityService;

import com.yeshi.fanli.service.inter.activity.ActivityUserService;

@@ -29,12 +36,15 @@
import com.yeshi.fanli.service.inter.dynamic.GoodsEvaluateService;

import com.yeshi.fanli.service.inter.dynamic.WXMPDynamicInfoService;

import com.yeshi.fanli.service.inter.goods.jd.NYouHuiService;

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

import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;

import com.yeshi.fanli.service.manger.goods.ConvertLinkManager;

import com.yeshi.fanli.util.Constant;

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

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.util.taobao.HaoDanKuApiUtil;



@Component

public class DynamicInfoJob {

@@ -65,6 +75,9 @@


   @Resource

   private GoodsEvaluateService goodsEvaluateService;

	
   @Resource

   private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;



   /**

    * 每10分钟 晚上00:00~06:00不下发任何一个商品

@@ -208,7 +221,6 @@
    */

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

   public void activityNeedPublish() {



      if (!Constant.IS_TASK) {

         return;

      }

@@ -255,7 +267,6 @@
    */

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

   public void insertTimeInvite() {



      if (!Constant.IS_TASK) {

         return;

      }

@@ -349,27 +360,70 @@
      }

   }



	
   /**

    * 动态发圈

    * 
    * @param param

    * @return

    * @throws Exception

    * 好单库商品加入发圈

    */

   // @Scheduled(cron = "0 0 6,7,15,16,21,22,23 * * ? ")

   @XxlJob("dynamic-insertEvaluate")

   public ReturnT<String> insertEvaluate(String param) throws Exception {

      try {

         goodsEvaluateService.addGoodsEvaluateByDaTaoKe();

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         boolean addGoods = false;

         Integer minId = 1;

         while (minId != null) {

            HDKGoodsListResultDTO dto = HaoDanKuApiUtil.getInstance().listHotGoods(minId, 100, 1, null);

            if (dto != null) {

               minId = dto.getMinId();

               addGoods = addGoodsEvaluate(dto.getGoodsList());

            } else {

               minId = null;

            }

				
            if(addGoods) {

               break;

            }

         }

			
         // 大淘客备用

         if (!addGoods) {

            DaTaoKeGoodsResult result = DaTaoKeApiUtil.getRankingList(DaTaoKeApiUtil.RANK_TYPE_TIME, null);

            if (result != null) {

               List<DaTaoKeDetailV2> detailList = result.getGoodsList();

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

                  for (DaTaoKeDetailV2 daTaoKeV2: detailList) {

                     if(goodsEvaluateService.addByDaTaoKeGoods(daTaoKeV2))

                        break;

                  }

               }

            }

         }

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

      return ReturnT.SUCCESS;

   }

	
	
   private boolean addGoodsEvaluate(List<HDKGoodsDetail> hdkList) {

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

         return false;

      }

      for (HDKGoodsDetail hdkGoods: hdkList) {

         try {

            Long itemid = hdkGoods.getItemid();

            String itemdesc = hdkGoods.getItemdesc();

            List<ActivityRuleUser> ruleList = activityUserService.listByRuleCode(ActivityRuleUser.RULE_HAOHUO, 1, 20);

            ActivityUser user = ruleList.get((int) (ruleList.size() * Math.random())).getActivityUser();

            goodsEvaluateService.addGoodsEvaluate(itemid + "", null, user, itemdesc, null, new Date());

            return true;

         } catch (GoodsEvaluateException e) {

            e.printStackTrace();

         } catch (Exception e) {

            e.printStackTrace();

         }

      }

      return false;

   }

	


   

   /**