拉新

yujian

2020-06-29 ec60e757d358636dcac1589c44a66f3e276fe58c

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

@@ -29,6 +29,7 @@
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;

@@ -44,9 +45,11 @@
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.factory.goods.TaoBaoGoodsFactory;

import com.yeshi.fanli.util.jd.JDApiUtil;

import com.yeshi.fanli.util.jd.JDUtil;

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

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



@Component

public class DynamicInfoJob {

@@ -418,20 +421,27 @@
               continue;

            }

            

            for (HDKWXCircleContentDTO hdkGoods: list) {

            for (HDKWXCircleContentDTO circleContentDTO: list) {

               try {

                  String itemid = hdkGoods.getItemid();

                  List<String> pics = hdkGoods.getItempic();

                  String copy_content = hdkGoods.getCopy_content();

                  String itemid = circleContentDTO.getItemid();

                  HDKGoodsDetail hdkGoods = HaoDanKuApiUtil.getInstance().getItemDetail(itemid);

                  if (hdkGoods == null) {

                     continue;

                  }

                  

                  List<String> pics = circleContentDTO.getItempic();

                  String copy_content = circleContentDTO.getCopy_content();

                  String showtitle = StringEscapeUtils.unescapeHtml(copy_content);

                  showtitle = showtitle.replace("<br>", "\r\n");

                  

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

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

                  goodsEvaluateService.addGoodsEvaluate2(itemid, pics, user, showtitle, null);

                  addResult = true;

                  break;

						
                  int addProcess = goodsEvaluateService.addGoodsEvaluate(TaoBaoGoodsFactory.create(hdkGoods), pics, user, showtitle);

                  if (addProcess == 0) {

                     addResult = true;

                     break;

                  }

               } catch (GoodsEvaluateException e) {

                  e.printStackTrace();

               } catch (Exception e) {

@@ -455,28 +465,37 @@
      try {

         DaTaoKeGoodsResult result = DaTaoKeApiUtil.getFriendsFircleList("1", 100);

         while (result.getGoodsList() != null && result.getGoodsList().size() > 0) {

            for (DaTaoKeDetailV2 v2 : result.getGoodsList()) {

            for (DaTaoKeDetailV2 detailV2 : result.getGoodsList()) {

               try {

                  Long goodsId = v2.getGoodsId();

                  String circleText = v2.getCircleText();

                  Long goodsId = detailV2.getGoodsId();

						
                  String circleText = detailV2.getCircleText();

                  if (circleText == null) {

                     continue;

                  }

                  String showtitle = URLDecoder.decode(circleText, "UTF-8");

                  showtitle = showtitle.replace("&nbsp;", " ");



                  DaTaoKeDetailV2 tkGoods = DaTaoKeApiUtil.getGoodsDetailByGoodsId(goodsId);

                  if(tkGoods == null) {

                     continue;

                  }

						
                  ActivityUser user = null;

                  if (v2.getCid() != null) {

                     user = activityUserService.getRandomByDaTaoKeCid(v2.getCid());

                  if (detailV2.getCid() != null) {

                     user = activityUserService.getRandomByDaTaoKeCid(detailV2.getCid());

                  }

                  if (user == null) {

                     List<ActivityRuleUser> ruleList = activityUserService

                           .listByRuleCode(ActivityRuleUser.RULE_HAOHUO, 1, 20);

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

                  }

                  goodsEvaluateService.addGoodsEvaluate2(goodsId + "", null, user, showtitle, null);

                  addResult = true;

                  break;

						
                  int addProcess = goodsEvaluateService.addGoodsEvaluate(TaoBaoUtil.convert(tkGoods), null, user, showtitle);

                  if (addProcess == 0) {

                     addResult = true;

                     break;

                  }

               } catch (GoodsEvaluateException e) {

                  e.printStackTrace();

               } catch (Exception e) {

@@ -489,9 +508,9 @@
            }



            try {

               result = DaTaoKeApiUtil.listAll(result.getPageId());

               result = DaTaoKeApiUtil.getFriendsFircleList(result.getPageId(), 100);

            } catch (Exception e) {

               result = DaTaoKeApiUtil.listAll(result.getPageId());

               result = DaTaoKeApiUtil.getFriendsFircleList(result.getPageId(), 100);

            }

            try {

               Thread.sleep(10);