过滤动态热销商品，3次重新加入数据

yujian

2019-08-05 87976c4c8b4435ad896d94deae7d6640c1993ffa

过滤动态热销商品，3次重新加入数据

 fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java

@@ -414,7 +414,12 @@
    public void insertTimeHotSale() {

        Long classId = 1L;

        try {

            saveHotSale(classId, 0L);

            for (int i = 0; i < 3; i++) {

                boolean addSuccess = saveHotSale(classId, 0L);

                if (addSuccess) {

                    break;

                }

            }

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

@@ -427,7 +432,12 @@
        List<GoodsClass> list = DaTaoKeUtil.goodsClasses;

        for (GoodsClass goodsClass : list) {

            try {

                saveHotSale(classId, goodsClass.getId());

                for (int i = 0; i < 3; i++) {

                    boolean addSuccess = saveHotSale(classId, goodsClass.getId());

                    if (addSuccess) {

                        break;

                    }

                }

            } catch (Exception e) {

                try {

                    LogHelper.errorDetailInfo(e);

@@ -445,7 +455,8 @@
     * @param subclassId

     * @throws TaobaoGoodsDownException

     */

    public void saveHotSale(Long classId, Long subclassId) throws TaobaoGoodsDownException {

    public boolean saveHotSale(Long classId, Long subclassId) throws TaobaoGoodsDownException {

        boolean addSuccess = false;

        List<Long> listId = null;

        List<DynamicInfo> listInfo = dynamicInfoDao.query(classId, subclassId);

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

@@ -459,6 +470,9 @@
        }

        // 大淘客数据

        DaTaoKeDetail daTaoKe = daTaoKeGoodsService.getGoodsNotInList(subclassId, listId, 1).get(0);

        if (daTaoKe == null) {

            return addSuccess;

        }



        try {

            daTaoKe = DaTaoKeUtil.filterDaTaoKe(TaoKeApiUtil.searchGoodsDetail(daTaoKe.getGoodsId()), daTaoKe);

@@ -466,41 +480,27 @@


        }

        

        // 过滤为空的

        if (daTaoKe == null) {

            return;

        }



        List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();

        TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);

        listGoods.add(taoBaoGoodsBrief);



        BigDecimal proportion = hongBaoManageService.getFanLiRate();

        TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief,

        TaoBaoGoodsBriefExtra goodsExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief,

                proportion.toString(), null);

        

        // 商品图片

        GoodsPicture goodsPicture = getGoodsPicture(daTaoKe);

        if (!taoBaoGoodsBriefExtra.isCoupon()) {

            taoBaoGoodsBriefExtra.setState(1);

            goodsPicture.setGoodState(1);

        if (!goodsExtra.isCoupon() || (goodsExtra.getState() != null && goodsExtra.getState() == 1)) {

            return addSuccess;  // 已下架 、无券 不加入

        }

        taoBaoGoodsBriefExtra.setTkRate(taoBaoGoodsBrief.getTkRate());

        taoBaoGoodsBriefExtra.setUpdatetime(new Date());

        taoBaoGoodsBriefExtra.setCouponInfo(null);

        goodsPicture.setGoods(taoBaoGoodsBriefExtra);

        

        List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();

        listGoods.add(taoBaoGoodsBrief);

		
        goodsExtra.setTkRate(taoBaoGoodsBrief.getTkRate());

        goodsExtra.setUpdatetime(new Date());

        goodsExtra.setCouponInfo(null);

		
        GoodsPicture goodsPicture = getGoodsPicture(daTaoKe);

        goodsPicture.setGoods(goodsExtra);

        // 商品列表

        List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();

        listPicture.add(goodsPicture);

		
        // 分享奖金

        BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);

        ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();

        shareMoneyDesc.setColor("#FFFFFF");

        shareMoneyDesc.setBottomColor("#E8AE48");

        shareMoneyDesc.setContent("预估分享奖金：¥" + shareMoney);

		


        // 获取商品列表图片

        TaoBaoGoodsBrief taoBaoGoodsBrief2 = TaoKeApiUtil.getSimpleGoodsInfo(daTaoKe.getGoodsId());

@@ -526,8 +526,14 @@
                listPicture.add(picture);

            }

        }



        taoBaoGoodsBriefExtra.setImgList(imgList);

        goodsExtra.setImgList(imgList);

		
        // 分享奖金

        BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);

        ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();

        shareMoneyDesc.setColor("#FFFFFF");

        shareMoneyDesc.setBottomColor("#E8AE48");

        shareMoneyDesc.setContent("预估分享奖金：¥" + shareMoney);



        // 组织动态信息

        DynamicInfo dynamicInfo = getDynamicInfo(daTaoKe, classId, subclassId);

@@ -550,6 +556,9 @@


        // 保存信息

        dynamicInfoDao.insert(dynamicInfo);

		
        addSuccess = true;

        return addSuccess;

    }



    /**