yujian
2019-05-30 bdf5e14bc25776d5114e832d500b9a422faf9da3
更新商品信息调整
2个文件已修改
66 ■■■■ 已修改文件
fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java 19 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java 47 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java
@@ -38,9 +38,11 @@
import com.yeshi.fanli.service.inter.dynamic.InviteMaterialService;
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoShopService;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsService;
import com.yeshi.fanli.service.inter.user.QrCodeService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
@@ -87,6 +89,9 @@
    
    @Resource
    private QrCodeService qrCodeService;
    @Resource
    private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;
    
    
    @Override
@@ -900,6 +905,12 @@
     * 更新商品信息
     */
    public void updateGoodInfo(List<DynamicInfo> list) {
        // 外网进行更新
        if (!Constant.IS_OUTNET) {
            return;
        }
        if (list == null || list.size() == 0) {
            return;
        }
@@ -949,6 +960,14 @@
                
                try {
                    TaoBaoGoodsBrief goodsBrief = redisManager.getTaoBaoGoodsBrief(oldExtra.getAuctionId());
                    // 更新商品信息
                    try {
                        taoBaoGoodsUpdateService.updateTaoBaoGoods(goodsBrief);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    listGoods.add(goodsBrief);
                    
                    // 更新热销单品的分享奖金  ,其余不做更新
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java
@@ -108,15 +108,13 @@
            e.printStackTrace();
        }
        List<TaoBaoGoodsBrief> goodsList = taoBaoGoodsBriefMapper.queryByAuctionId(goods.getAuctionId());
        if (goodsList != null)
            for (TaoBaoGoodsBrief tb : goodsList) {
                goods.setId(tb.getId());
                TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(goods);
                System.out.println("更细信息:" + new Gson().toJson(updateGoods));
                taoBaoGoodsBriefMapper.updateByPrimaryKeySelective(updateGoods);
            }
        TaoBaoGoodsBrief tb = taoBaoGoodsBriefMapper.selectByPrimaryKey(goods.getAuctionId());
        if (tb != null) {
            goods.setId(tb.getId());
            TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(goods);
            System.out.println("更细信息:" + new Gson().toJson(updateGoods));
            taoBaoGoodsBriefMapper.updateByPrimaryKeySelective(updateGoods);
        }
        // 更新动态商品
        activityService.updateRecommendActivityGoods(goods);
@@ -218,14 +216,31 @@
    @Override
    public void updateByTaoKeGoodsDetail(Long id) {
        try {
            TaoBaoGoodsBrief newGoods = TaoKeApiUtil.searchGoodsDetail(id);
            if (newGoods != null) {
                try {
                    updateTaoBaoGoods(newGoods);
                } catch (TaobaoGoodsUpdateException e) {
                    e.printStackTrace();
                }
            TaoBaoGoodsBrief oldGoods = taoBaoGoodsBriefMapper.selectByPrimaryKey(id);
            if (oldGoods == null) {
                return;
            }
            TaoBaoGoodsBrief newGoods = TaoKeApiUtil.searchGoodsDetail(id);
            if (newGoods == null) {
                return;
            }
            // 更新精选商品
            newGoods.setId(id);
            TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(newGoods);
            taoBaoGoodsBriefMapper.updateByPrimaryKeySelective(updateGoods);
            // 更新动态商品
            activityService.updateRecommendActivityGoods(newGoods);
            // 更新收藏信息
            try {
                commonGoodsService.updateCommonGoods(CommonGoodsFactory.create(newGoods));
            } catch (CommonGoodsException e) {
                e.printStackTrace();
            }
        } catch (TaobaoGoodsDownException e) {
            offlineTaoBaoGoods(id);
        } catch (Exception e) {